Sfoglia il codice sorgente

fix: 阿拉钉同时发起结果存redis

lixuesong 3 anni fa
parent
commit
d8ecc56b9a

+ 12 - 3
hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/service/gig/impl/GigThirdApiServiceImpl.java

@@ -283,10 +283,13 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		String gigTypeJson = (String) redisTemplate.opsForValue().get(oladingRedisKey);
 		if (JSONUtil.isJsonArray(gigTypeJson)) {
 			JSONArray gigTypeArray = JSONUtil.parseArray(gigTypeJson);
+			List<GigTypeEnum> gigTypeEnumList = gigTypeArray.stream()
+					.map(o -> Enum.valueOf(GigTypeEnum.class, String.valueOf(o)))
+					.collect(Collectors.toList());
 			List<SysUserSub> subList = sysUserSubService.list(Wrappers.<SysUserSub>lambdaQuery()
 					.eq(SysUserSub::getUserId, userSub.getUserId())
 					.eq(SysUserSub::getDeptId, userSub.getDeptId())
-					.in(SysUserSub::getGigType, gigTypeArray));
+					.in(SysUserSub::getGigType, gigTypeEnumList));
 			Map<String, Map<String, String>> dbResultMap = subList.stream()
 					.collect(Collectors.toMap(sysUserSub -> sysUserSub.getGigType().name(),
 							sysUserSub -> MapUtil.builder("certStatus",
@@ -356,10 +359,13 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		String gigTypeJson = (String) redisTemplate.opsForValue().get(oladingRedisKey);
 		if (JSONUtil.isJsonArray(gigTypeJson)) {
 			JSONArray gigTypeArray = JSONUtil.parseArray(gigTypeJson);
+			List<GigTypeEnum> gigTypeEnumList = gigTypeArray.stream()
+					.map(o -> Enum.valueOf(GigTypeEnum.class, String.valueOf(o)))
+					.collect(Collectors.toList());
 			List<SysUserSub> subList = sysUserSubService.list(Wrappers.<SysUserSub>lambdaQuery()
 					.eq(SysUserSub::getUserId, userSub.getUserId())
 					.eq(SysUserSub::getDeptId, userSub.getDeptId())
-					.in(SysUserSub::getGigType, gigTypeArray));
+					.in(SysUserSub::getGigType, gigTypeEnumList));
 			Map<String, Map<String, String>> dbResultMap = subList.stream()
 					.collect(Collectors.toMap(sysUserSub -> sysUserSub.getGigType().name(),
 							sysUserSub -> MapUtil.builder("certStatus",
@@ -428,10 +434,13 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		String gigTypeJson = (String) redisTemplate.opsForValue().get(oladingRedisKey);
 		if (JSONUtil.isJsonArray(gigTypeJson)) {
 			JSONArray gigTypeArray = JSONUtil.parseArray(gigTypeJson);
+			List<GigTypeEnum> gigTypeEnumList = gigTypeArray.stream()
+					.map(o -> Enum.valueOf(GigTypeEnum.class, String.valueOf(o)))
+					.collect(Collectors.toList());
 			List<SysUserSub> subList = sysUserSubService.list(Wrappers.<SysUserSub>lambdaQuery()
 					.eq(SysUserSub::getUserId, userSub.getUserId())
 					.eq(SysUserSub::getDeptId, userSub.getDeptId())
-					.in(SysUserSub::getGigType, gigTypeArray));
+					.in(SysUserSub::getGigType, gigTypeEnumList));
 			Map<String, Map<String, String>> dbResultMap = subList.stream()
 					.collect(Collectors.toMap(sysUserSub -> sysUserSub.getGigType().name(),
 							sysUserSub -> MapUtil.builder("certStatus",