Explorar el Código

fix: 阿拉钉同时发起的渠道存redis

lixuesong hace 3 años
padre
commit
00a76dfea2

+ 13 - 0
hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/controller/SysUserSignCertController.java

@@ -27,8 +27,10 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 /**
  * 用户签约认证
@@ -205,6 +207,17 @@ public class SysUserSignCertController {
 				return R.failed("身份证或视频信息不能为空");
 			}
 		}
+
+		// 过滤出阿拉钉的渠道
+		Collection<GigTypeEnum> oladingTypeList =
+				CollUtil.intersection(userSignCertDTO.getGigTypeList(),
+						CollUtil.toList(GigTypeEnum.OLADING, GigTypeEnum.JIN_YUAN, GigTypeEnum.XIN_TAI_ZI));
+		if (!oladingTypeList.isEmpty()) {
+			// 选择的渠道的阿拉钉的部分记录到redis
+			String redisKey = CacheConstants.OLADING_CERT_SEND_CHANNEL + userSignCertDTO.getUserId();
+			redisTemplate.opsForValue().set(redisKey, JSONUtil.toJsonStr(oladingTypeList), 24, TimeUnit.HOURS);
+		}
+
 		sysUserSignCertService.batchChannelCert(userSignCertDTO);
 
 		return R.ok();

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

@@ -303,11 +303,6 @@ public class SysUserSignCertServiceImpl implements SysUserSignCertService {
 			Collection<GigTypeEnum> oladingTypeList =
 					CollUtil.intersection(userSignCertDTO.getGigTypeList(),
 							CollUtil.toList(GigTypeEnum.OLADING, GigTypeEnum.JIN_YUAN, GigTypeEnum.XIN_TAI_ZI));
-			if (!oladingTypeList.isEmpty()) {
-				// 选择的渠道的阿拉钉的部分记录到redis
-				String redisKey = CacheConstants.OLADING_CERT_SEND_CHANNEL + sysUser.getUserId();
-				redisTemplate.opsForValue().set(redisKey, JSONUtil.toJsonStr(oladingTypeList), 24, TimeUnit.HOURS);
-			}
 
 			// 封装请求数据
 			userSubList.stream().filter(sysUserSub -> {