diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java index a0b24549e3..6bcf4a1b93 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/BadgeServiceImpl.java @@ -45,6 +45,7 @@ import com.epmet.entity.BadgeEntity; import com.epmet.feign.EpmetMessageOpenFeignClient; import com.epmet.feign.MessageFeignClient; import com.epmet.redis.UserBadgeRedis; +import com.epmet.redis.UserBaseInfoRedis; import com.epmet.service.*; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; @@ -78,8 +79,9 @@ public class BadgeServiceImpl extends BaseServiceImpl imp @Autowired private MessageFeignClient messageFeignClient; @Autowired - private EpmetMessageOpenFeignClient epmetMessageOpenFeignClient; - + private EpmetMessageOpenFeignClient epmetMessageOpenFeignClient; + @Autowired + private UserBaseInfoRedis userBaseInfoRedis; @Override @@ -438,7 +440,20 @@ public class BadgeServiceImpl extends BaseServiceImpl imp @Override public Boolean addUserPartyBadgeRecord(TokenDto tokenDto, AddUserPartyBadgeFormDTO formDTO) { String badgeId = baseDao.getPartyBadgeId(tokenDto.getCustomerId()); - return null; + ResiUserBadgeDTO resiUserBadgeDTO = new ResiUserBadgeDTO(); + resiUserBadgeDTO.setCustomerId(tokenDto.getCustomerId()); + resiUserBadgeDTO.setBadgeId(badgeId); + UserBaseInfoResultDTO userInfo = userBaseInfoRedis.getUserInfo(formDTO.getUserId()); + if (userInfo == null) { + log.error("获取用户信息失败"); + return false; + } + resiUserBadgeDTO.setGridId(userInfo.getRegisteredGridId()); + resiUserBadgeDTO.setUserId(formDTO.getUserId()); + resiUserBadgeDTO.setIsOpened(NumConstant.ONE); + resiUserBadgeDTO.setCertificationAutidStatus(BadgeConstant.APPROVED); + resiUserBadgeService.save(resiUserBadgeDTO); + return true; } } \ No newline at end of file