添加获取党员徽章方法

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<BadgeDao, BadgeEntity> 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<BadgeDao, BadgeEntity> 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;
     }
 
 }