|
|
|
@ -1,6 +1,7 @@ |
|
|
|
package com.epmet.service.impl; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker; |
|
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
|
import com.epmet.commons.tools.exception.EpmetErrorCode; |
|
|
|
import com.epmet.commons.tools.exception.EpmetException; |
|
|
|
@ -8,6 +9,7 @@ import com.epmet.commons.tools.exception.RenException; |
|
|
|
import com.epmet.commons.tools.security.dto.TokenDto; |
|
|
|
import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
|
import com.epmet.commons.tools.utils.SpringContextUtils; |
|
|
|
import com.epmet.commons.tools.validator.PhoneValidatorUtils; |
|
|
|
import com.epmet.commons.tools.validator.ValidatorUtils; |
|
|
|
import com.epmet.constant.BadgeConstant; |
|
|
|
@ -24,6 +26,8 @@ import com.epmet.feign.EpmetUserOpenFeignClient; |
|
|
|
import com.epmet.feign.GovOrgFeignClient; |
|
|
|
import com.epmet.redis.UserBadgeRedis; |
|
|
|
import com.epmet.redis.UserBaseInfoRedis; |
|
|
|
import com.epmet.service.ResiUserBadgeService; |
|
|
|
import com.epmet.service.UserBadgeCertificateRecordService; |
|
|
|
import com.epmet.service.UserBadgeService; |
|
|
|
import com.epmet.service.UserBaseInfoService; |
|
|
|
import com.epmet.util.ModuleConstant; |
|
|
|
@ -274,8 +278,11 @@ public class UserBadgeServiceImpl implements UserBadgeService { |
|
|
|
List<String> userIds = new ArrayList<>(); |
|
|
|
userIds.add(certificationAddFormDTO.getUserId()); |
|
|
|
List<UserBaseInfoResultDTO> userBaseInfoResultDTOS = userBaseInfoService.queryUserBaseInfo(userIds); |
|
|
|
if (CollectionUtils.isEmpty(userBaseInfoResultDTOS)) { |
|
|
|
throw new RenException("查询用户基本信息集合为空......"); |
|
|
|
if (CollectionUtils.isEmpty(userBaseInfoResultDTOS)||null==userBaseInfoResultDTOS.get(NumConstant.ZERO)) { |
|
|
|
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),String.format("查询用户基本信息集合为空,userId:%s",certificationAddFormDTO.getUserId()),"查询用户基本信息异常"); |
|
|
|
} |
|
|
|
if(StringUtils.isBlank(userBaseInfoResultDTOS.get(NumConstant.ZERO).getRegisteredGridId())){ |
|
|
|
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),"异常信息：注册网格为空","服务器开小差了...注册网格为空"); |
|
|
|
} |
|
|
|
userBadgeDao.updateCertificateRecordIsLast(form.getBadgeId(),form.getUserId()); |
|
|
|
form.setGridId(userBaseInfoResultDTOS.get(NumConstant.ZERO).getRegisteredGridId()); |
|
|
|
@ -283,17 +290,57 @@ public class UserBadgeServiceImpl implements UserBadgeService { |
|
|
|
form.setCertificationImg(certificationAddFormDTO.getCertificationImg()); |
|
|
|
form.setSurname(certificationAddFormDTO.getSurname()); |
|
|
|
log.info(JSON.toJSONString(form)); |
|
|
|
String recordId=IdWorker.getIdStr(); |
|
|
|
form.setId(recordId); |
|
|
|
userBadgeDao.insertUserBadgeCertificateRecord(form); |
|
|
|
//TODO 站内信发送
|
|
|
|
String badgeName = badgeDao.selectBadgeName(form.getCustomerId(), form.getBadgeId()); |
|
|
|
String s = StringUtils.isBlank(userBaseInfoResultDTOS.get(NumConstant.ZERO).getDistrict()) ? userBaseInfoResultDTOS.get(NumConstant.ZERO).getRealName() : userBaseInfoResultDTOS.get(NumConstant.ZERO).getDistrict().concat(userBaseInfoResultDTOS.get(NumConstant.ZERO).getRealName()); |
|
|
|
String msg = String.format(BadgeConstant.MESSAGE_CONTENT, s, badgeName); |
|
|
|
// 记录待审核id，和消息类型
|
|
|
|
sendMessage(BadgeConstant.AUTH_TITLE,msg,form.getGridId(),form.getUserId(),form.getCustomerId(), |
|
|
|
UserMessageTypeConstant.BADGE_AUTH_APPLY, |
|
|
|
form.getId()); |
|
|
|
if(certificationAddFormDTO.getSendMsgFlag()){ |
|
|
|
//TODO 站内信发送
|
|
|
|
String badgeName = badgeDao.selectBadgeName(form.getCustomerId(), form.getBadgeId()); |
|
|
|
String s = StringUtils.isBlank(userBaseInfoResultDTOS.get(NumConstant.ZERO).getDistrict()) ? userBaseInfoResultDTOS.get(NumConstant.ZERO).getRealName() : userBaseInfoResultDTOS.get(NumConstant.ZERO).getDistrict().concat(userBaseInfoResultDTOS.get(NumConstant.ZERO).getRealName()); |
|
|
|
String msg = String.format(BadgeConstant.MESSAGE_CONTENT, s, badgeName); |
|
|
|
// 记录待审核id，和消息类型
|
|
|
|
sendMessage(BadgeConstant.AUTH_TITLE,msg,form.getGridId(),form.getUserId(),form.getCustomerId(), |
|
|
|
UserMessageTypeConstant.BADGE_AUTH_APPLY, |
|
|
|
form.getId()); |
|
|
|
} |
|
|
|
//烟台:徽章认证自动审核通过
|
|
|
|
if(certificationAddFormDTO.getAutoPassFlag()){ |
|
|
|
BadgeAuditFormDTO badgeAuditFormDTO=new BadgeAuditFormDTO(); |
|
|
|
badgeAuditFormDTO.setRecordId(recordId); |
|
|
|
//审核状态 approved:审核通过，rejected:审核驳回;auditing:审核中
|
|
|
|
badgeAuditFormDTO.setAuditStatus(BadgeConstant.APPROVED); |
|
|
|
badgeAuditFormDTO.setCurrentUserId("APP_USER"); |
|
|
|
autoPassBadge(badgeAuditFormDTO); |
|
|
|
} |
|
|
|
Map resultMap=new HashMap(); |
|
|
|
resultMap.put("recordId",recordId); |
|
|
|
return new Result().ok(resultMap); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 烟台:徽章认证，自动审核通过 |
|
|
|
* @param badgeAuditFormDTO |
|
|
|
*/ |
|
|
|
private void autoPassBadge(BadgeAuditFormDTO badgeAuditFormDTO) { |
|
|
|
UserBadgeCertificateRecordDTO dto = SpringContextUtils.getBean(UserBadgeCertificateRecordService.class).get(badgeAuditFormDTO.getRecordId()); |
|
|
|
dto.setAuditStatus(badgeAuditFormDTO.getAuditStatus()); |
|
|
|
dto.setAuditRemark(badgeAuditFormDTO.getAuditRemark()); |
|
|
|
dto.setStaffId(badgeAuditFormDTO.getCurrentUserId()); |
|
|
|
dto.setIsLast(BadgeConstant.YES); |
|
|
|
dto.setAuditTime(new Date()); |
|
|
|
SpringContextUtils.getBean(UserBadgeCertificateRecordService.class).update(dto); |
|
|
|
|
|
|
|
ResiUserBadgeDTO resiUserBadgeDTO = new ResiUserBadgeDTO(); |
|
|
|
resiUserBadgeDTO.setCustomerId(dto.getCustomerId()); |
|
|
|
resiUserBadgeDTO.setBadgeId(dto.getBadgeId()); |
|
|
|
resiUserBadgeDTO.setGridId(dto.getGridId()); |
|
|
|
resiUserBadgeDTO.setUserId(dto.getUserId()); |
|
|
|
resiUserBadgeDTO.setIsOpened(NumConstant.ONE); |
|
|
|
resiUserBadgeDTO.setCertificationAutidStatus(dto.getAuditStatus()); |
|
|
|
SpringContextUtils.getBean(ResiUserBadgeService.class).save(resiUserBadgeDTO); |
|
|
|
//更新Redis
|
|
|
|
userBadgeRedis.pushOrRemoveUserBadge4List(dto.getUserId(),dto.getBadgeId(),dto.getCustomerId()); |
|
|
|
|
|
|
|
return new Result(); |
|
|
|
} |
|
|
|
|
|
|
|
private void validateParams(CertificationAddFormDTO certificationAddFormDTO, AuthFieldFormDTO authFieldFormDTO) { |
|
|
|
|
yinzuomei
3 years ago