feat: 阿拉钉河南薪泰梓-认证调整

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/mq/GigSignCertReceiver.java

@@ -303,7 +303,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + user.getUserId();
 		redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(resultMap), 1, TimeUnit.MINUTES);
 
-		// 处理同时发起时阿拉丁多个渠道需要的情况（补发）
+		// 处理同时发起时阿拉丁多个渠道的情况（补发）
 		if (gigTypeArray.size() > 1) {
 			String firstChannel = String.valueOf(gigTypeArray.get(0));
 			// 查询阿拉丁第一个渠道的认证状态
@@ -321,14 +321,11 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				// 如果阿拉丁第一个渠道是已认证的，则补发下一个阿拉丁的渠道(由于阿拉钉同一人不同渠道的回调只有一次，所以这里出现多个渠道需要依次补发)
 				if (CollUtil.isNotEmpty(certStatusMap) && OladingCertStatus.CERT.name().equals(certStatusMap.get("certStatus"))) {
 
-					log.info("=============================补发阿拉钉另一渠道MQ4==================================");
+					log.info("=============================补发阿拉钉另一渠道MQ:{}==================================", toSendChannel);
 					UserSignCertDTO reCertDTO = new UserSignCertDTO();
 					reCertDTO.setUserId(user.getUserId());
-					reCertDTO.setGigTypeList(Collections.singletonList(GigTypeEnum.JIN_YUAN));
+					reCertDTO.setGigTypeList(Collections.singletonList(Enum.valueOf(GigTypeEnum.class, toSendChannel)));
 					sysUserSignCertService.batchChannelCert(reCertDTO);
-
-					// 刷新渠道到redis
-					redisTemplate.opsForValue().set(oladingRedisKey, JSONUtil.toJsonStr(gigTypeArray));
 				}
 			}
 		}

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/service/gig/impl/SysUserSignCertServiceImpl.java

@@ -368,9 +368,11 @@ public class SysUserSignCertServiceImpl implements SysUserSignCertService {
 		Collection<GigTypeEnum> oladingTypeList =
 				CollUtil.intersection(userSignCertDTO.getGigTypeList(),
 						CollUtil.toList(GigTypeEnum.OLADING, GigTypeEnum.JIN_YUAN, GigTypeEnum.XIN_TAI_ZI));
-		// 选择的渠道记录到redis
-		String redisKey = CacheConstants.OLADING_CERT_SEND_CHANNEL + sysUser.getUserId();
-		redisTemplate.opsForValue().set(redisKey, JSONUtil.toJsonStr(oladingTypeList));
+		if (!oladingTypeList.isEmpty()) {
+			// 选择的渠道的阿拉钉的部分记录到redis
+			String redisKey = CacheConstants.OLADING_CERT_SEND_CHANNEL + sysUser.getUserId();
+			redisTemplate.opsForValue().set(redisKey, JSONUtil.toJsonStr(oladingTypeList));
+		}
 
 		switch (userSub.getGigType()) {
 			case XIN_TAI_ZI: