package cn.flightfeather.supervision.lightshare.service.Impl
|
|
import cn.flightfeather.supervision.domain.entity.*
|
import cn.flightfeather.supervision.domain.enumeration.AuthenticationStatus
|
import cn.flightfeather.supervision.domain.enumeration.SceneType
|
import cn.flightfeather.supervision.domain.mapper.*
|
import cn.flightfeather.supervision.infrastructure.utils.PinYin
|
import cn.flightfeather.supervision.infrastructure.utils.UUIDGenerator
|
import cn.flightfeather.supervision.lightshare.service.AuthService
|
import cn.flightfeather.supervision.lightshare.vo.AuthSceneIndVo
|
import cn.flightfeather.supervision.lightshare.vo.AuthSceneRestVo
|
import cn.flightfeather.supervision.lightshare.vo.AuthSceneVo
|
import cn.flightfeather.supervision.lightshare.vo.BaseResponse
|
import com.google.gson.Gson
|
import org.springframework.stereotype.Service
|
import org.springframework.transaction.annotation.Transactional
|
import tk.mybatis.mapper.entity.Example
|
import java.util.*
|
|
@Service
|
class AuthServiceImpl(
|
private val userinfoMapper: UserinfoMapper,
|
private val userInfoWxMapper: UserInfoWxMapper,
|
private val companyMapper: CompanyMapper,
|
private val personalInfoMapper: PersonalInfoMapper,
|
private val baseInfoMapper: BaseInfoMapper,
|
private val fumePurifyDeviceMapper: FumePurifyDeviceMapper,
|
private val monitorDeviceMapper: MonitorDeviceMapper,
|
private val restaurantBaseInfoMapper: RestaurantBaseInfoMapper,
|
private val vehicleBaseInfoMapper: VehicleBaseInfoMapper,
|
private val industrialBaseInfoMapper: IndustrialBaseInfoMapper,
|
private val vocPurifyDeviceMapper: VocPurifyDeviceMapper,
|
): AuthService {
|
|
@Transactional
|
override fun authCompany(wxUserId: String, company: Company): BaseResponse<String> {
|
val wxUser = userInfoWxMapper.selectByPrimaryKey(wxUserId) ?: return BaseResponse(false, "用户微信id不存在")
|
company.ciExtension3 = AuthenticationStatus.YES.des
|
if (company.ciGuid == null) {
|
company.ciGuid = UUIDGenerator.generate16ShortUUID()
|
companyMapper.insert(company)
|
} else {
|
companyMapper.updateByPrimaryKeySelective(company)
|
}
|
val bInfo = if (wxUser.uiGuid == null) null else baseInfoMapper.selectByPrimaryKey(wxUser.uiGuid)
|
if (bInfo != null && bInfo.ciGuid != company.ciGuid) {
|
bInfo.ciGuid = company.ciGuid
|
bInfo.ciName = company.ciName
|
baseInfoMapper.updateByPrimaryKeySelective(bInfo)
|
} else if (bInfo == null) {
|
val userInfo = userinfoMapper.selectByPrimaryKey(wxUser.uiGuid)
|
val baseInfo = BaseInfo().apply {
|
biGuid = wxUser.uiGuid
|
biName = userInfo?.realname
|
ciGuid = company.ciGuid
|
ciName = company.ciName
|
biCreateTime = Date()
|
biExtension1 = userInfo?.acountname
|
}
|
baseInfoMapper.insertSelective(baseInfo)
|
}
|
if (wxUser.ciGuid != company.ciGuid) {
|
wxUser.ciGuid = company.ciGuid
|
userInfoWxMapper.updateByPrimaryKeySelective(wxUser)
|
}
|
return BaseResponse(true)
|
}
|
|
@Transactional
|
override fun authScene(wxUserId: String, sceneType: Int, sceneInfo: String): BaseResponse<String> {
|
// val user = userinfoMapper.selectByPrimaryKey(userId) ?: return BaseResponse(false, "用户场景id不存在")
|
val wxUser = userInfoWxMapper.selectByPrimaryKey(wxUserId) ?: return BaseResponse(false, "用户微信id不存在")
|
val gson = Gson()
|
// 所有场景统一的基础信息
|
val asVo = gson.fromJson(sceneInfo, AuthSceneVo::class.java)
|
var bInfo = if (wxUser.uiGuid == null) null else baseInfoMapper.selectByPrimaryKey(wxUser.uiGuid)
|
if (bInfo == null) {
|
val cInfo = if (wxUser.ciGuid == null) null else companyMapper.selectByPrimaryKey(wxUser.ciGuid)
|
val user = userinfoMapper.selectByPrimaryKey(wxUser.uiGuid)
|
if (user == null) {
|
val name = getUName(asVo.biName ?: "")
|
//新建场景账号及场景信息
|
val user = Userinfo().apply {
|
guid = UUIDGenerator.generate16ShortUUID()
|
acountname = name
|
realname = asVo.biName
|
password = "123456"
|
usertypeid = 3
|
usertype = "企业"
|
isenable = true
|
if (asVo.biLocation.isNotEmpty()) extension1 = asVo.biLocation[2]
|
extension2 = sceneType.toString()
|
}
|
userinfoMapper.insert(user)
|
} else {
|
user.apply {
|
realname = asVo.biName
|
if (asVo.biLocation.isNotEmpty()) extension1 = asVo.biLocation[2]
|
}
|
userinfoMapper.updateByPrimaryKeySelective(user)
|
}
|
bInfo = asVo.toNewBaseInfo(user, cInfo)
|
baseInfoMapper.insert(bInfo)
|
} else {
|
val userInfo = userinfoMapper.selectByPrimaryKey(bInfo.biGuid)
|
userInfo?.apply {
|
realname = asVo.biName
|
if (asVo.biLocation.isNotEmpty()) extension1 = asVo.biLocation[2]
|
}
|
asVo.updateBaseInfo(bInfo)
|
userinfoMapper.updateByPrimaryKeySelective(userInfo)
|
baseInfoMapper.updateByPrimaryKeySelective(bInfo)
|
}
|
val userId = bInfo.biGuid
|
when (sceneType) {
|
SceneType.Restaurant.value -> {
|
val info = gson.fromJson(sceneInfo, AuthSceneRestVo::class.java)
|
//餐饮店基本信息录入
|
var rbInfo = restaurantBaseInfoMapper.selectByPrimaryKey(userId)
|
if (rbInfo == null) {
|
rbInfo = info.toNewRestInfo(userId)
|
restaurantBaseInfoMapper.insert(rbInfo)
|
} else {
|
info.updateRestInfo(rbInfo)
|
restaurantBaseInfoMapper.updateByPrimaryKeySelective(rbInfo)
|
}
|
//餐饮店油烟净化装置信息录入
|
var fpdInfo = fumePurifyDeviceMapper.selectByExample(Example(FumePurifyDevice::class.java).apply {
|
createCriteria().andEqualTo("fpUserId", userId)
|
})?.takeIf { it.isNotEmpty() }?.get(0)
|
if (fpdInfo == null) {
|
fpdInfo = info.toNewFpdInfo(bInfo)
|
fumePurifyDeviceMapper.insert(fpdInfo)
|
} else {
|
info.updateFpdInfo(fpdInfo)
|
fumePurifyDeviceMapper.updateByPrimaryKeySelective(fpdInfo)
|
}
|
//餐饮店油烟监测设备信息录入
|
var mdInfo = monitorDeviceMapper.selectByExample(Example(MonitorDevice::class.java).apply {
|
createCriteria().andEqualTo("mdUserId", userId)
|
})?.takeIf { it.isNotEmpty() }?.get(0)
|
if (mdInfo == null) {
|
mdInfo = info.toNewMdInfo(bInfo)
|
monitorDeviceMapper.insert(mdInfo)
|
} else {
|
info.updateMdInfo(mdInfo)
|
monitorDeviceMapper.updateByPrimaryKeySelective(mdInfo)
|
}
|
}
|
SceneType.Construction.value -> {
|
val info = gson.fromJson(sceneInfo, AuthSceneVo::class.java)
|
}
|
SceneType.Wharf.value -> {
|
val info = gson.fromJson(sceneInfo, AuthSceneVo::class.java)
|
}
|
SceneType.StorageYard.value -> {
|
val info = gson.fromJson(sceneInfo, AuthSceneVo::class.java)
|
}
|
SceneType.MixingPlant.value -> {
|
val info = gson.fromJson(sceneInfo, AuthSceneVo::class.java)
|
}
|
SceneType.Industrial.value -> {
|
val info = gson.fromJson(sceneInfo, AuthSceneIndVo::class.java)
|
//工业企业基本信息录入
|
var rbInfo = industrialBaseInfoMapper.selectByPrimaryKey(userId)
|
if (rbInfo == null) {
|
rbInfo = info.toNewIndInfo(userId)
|
industrialBaseInfoMapper.insert(rbInfo)
|
} else {
|
info.updateIndInfo(rbInfo)
|
industrialBaseInfoMapper.updateByPrimaryKeySelective(rbInfo)
|
}
|
// industrialBaseInfoMapper
|
// vocPurifyDeviceMapper
|
}
|
SceneType.VehicleRepair.value -> {
|
val info = gson.fromJson(sceneInfo, AuthSceneVo::class.java)
|
}
|
else-> return BaseResponse(false, "用户场景类型错误")
|
}
|
|
return BaseResponse(true, "场景认证完成")
|
}
|
|
override fun authPersonal(wxUserId: String, personalInfo: PersonalInfo): BaseResponse<String> {
|
val wxUser = userInfoWxMapper.selectByPrimaryKey(wxUserId) ?: return BaseResponse(false, "用户微信id不存在")
|
personalInfo.piExtension3 = AuthenticationStatus.YES.des
|
personalInfo.piWxId = wxUserId
|
personalInfo.piSceneId = wxUser.uiGuid
|
if (personalInfo.piGuid == null) {
|
personalInfo.piGuid = UUIDGenerator.generate16ShortUUID()
|
personalInfoMapper.insert(personalInfo)
|
} else {
|
personalInfoMapper.updateByPrimaryKeySelective(personalInfo)
|
}
|
if (wxUser.piGuid != personalInfo.piGuid) {
|
wxUser.piGuid = personalInfo.piGuid
|
userInfoWxMapper.updateByPrimaryKeySelective(wxUser)
|
}
|
return BaseResponse(true)
|
}
|
|
override fun authStatus(wxUserId: String?, userId: String?): BaseResponse<List<Boolean>> {
|
val status = mutableListOf(false, false, false)
|
if (wxUserId != null) {
|
val wxUser = userInfoWxMapper.selectByPrimaryKey(wxUserId) ?: return BaseResponse(false, "该微信账户不存在")
|
//判断企业信息是否认证
|
if (wxUser.ciGuid != null) {
|
companyMapper.selectByPrimaryKey(wxUser.ciGuid)?.let { c ->
|
if (c.ciExtension3 == AuthenticationStatus.YES.des) status[0] = true
|
}
|
}
|
//判断场景信息是否认证
|
if (wxUser.uiGuid != null) {
|
baseInfoMapper.selectByPrimaryKey(wxUser.uiGuid)?.let {b ->
|
if (b.biExtension3 == AuthenticationStatus.YES.des) status[1] = true
|
}
|
}
|
//判断个人信息是否认证
|
if (wxUser.uiGuid != null) {
|
personalInfoMapper.selectByExample(Example(PersonalInfo::class.java).apply {
|
createCriteria().andEqualTo("piSceneId", wxUser.uiGuid)
|
.andEqualTo("piWxId", wxUser.uiOpenId)
|
})?.takeIf { it.isNotEmpty() }?.get(0)?.let { p ->
|
if (p.piExtension3 == AuthenticationStatus.YES.des) status[2] = true
|
}
|
}
|
}
|
if (userId != null) {
|
val user = userinfoMapper.selectByPrimaryKey(userId) ?: return BaseResponse(false, "该场景账户不存在")
|
val baseInfo = baseInfoMapper.selectByPrimaryKey(userId)
|
//判断企业信息是否认证
|
if (baseInfo?.ciGuid != null) {
|
companyMapper.selectByPrimaryKey(baseInfo.ciGuid)?.let { c ->
|
if (c.ciExtension3 == AuthenticationStatus.YES.des) status[0] = true
|
}
|
}
|
//判断场景信息是否认证
|
if (baseInfo?.biExtension3 == AuthenticationStatus.YES.des) status[1] = true
|
//判断个人信息是否认证
|
userInfoWxMapper.selectByExample(Example(UserInfoWx::class.java).apply {
|
createCriteria().andEqualTo("uiGuid", userId)
|
})?.takeIf { it.isNotEmpty() }?.get(0)?.let {
|
personalInfoMapper.selectByExample(Example(PersonalInfo::class.java).apply {
|
createCriteria().andEqualTo("piSceneId", it.uiGuid)
|
.andEqualTo("piWxId", it.uiOpenId)
|
})?.takeIf { it.isNotEmpty() }?.get(0)?.let { p ->
|
if (p.piExtension3 == AuthenticationStatus.YES.des) status[2] = true
|
}
|
}
|
}
|
|
return BaseResponse(true, data = status)
|
}
|
|
override fun sceneAuthStatus(userId: String?): BaseResponse<List<Boolean>> {
|
val status = mutableListOf(false, false, false)
|
val base = baseInfoMapper.selectByPrimaryKey(userId) ?: return BaseResponse(false, "该微信账户不存在")
|
//判断企业信息是否认证
|
if (base.ciGuid != null) {
|
companyMapper.selectByPrimaryKey(base.ciGuid)?.let { c ->
|
if (c.ciExtension3 == AuthenticationStatus.YES.des) status[0] = true
|
}
|
}
|
//判断场景信息是否认证
|
if (base.biExtension3 == AuthenticationStatus.YES.des) status[1] = true
|
//判断个人信息是否认证
|
personalInfoMapper.selectByExample(Example(PersonalInfo::class.java).apply {
|
createCriteria().andEqualTo("piSceneId", base.biGuid)
|
})?.takeIf { it.isNotEmpty() }?.get(0)?.let { p ->
|
if (p.piExtension3 == AuthenticationStatus.YES.des) status[2] = true
|
}
|
|
return BaseResponse(true, data = status)
|
}
|
|
private fun getUName(sceneName: String): String {
|
var uName = if (sceneName.isNotBlank()) PinYin.getPinYinHeader(sceneName) else UUIDGenerator.generateShortUUID()
|
var repeated = false
|
var i = 1
|
do {
|
userinfoMapper.selectByExample(Example(Userinfo::class.java).apply {
|
createCriteria().andEqualTo("acountname", uName)
|
}).let {
|
repeated = it.isNotEmpty()
|
if (repeated) {
|
uName += i
|
}
|
}
|
i++
|
} while (repeated && i < 20)
|
if (repeated) uName = UUIDGenerator.generateShortUUID()
|
return uName
|
}
|
|
override fun getUnAuthedUsers(): BaseResponse<List<Userinfo?>> {
|
val res = userinfoMapper.getUnAuthedUsers()
|
return BaseResponse(true, data = res)
|
}
|
}
|
