Przeglądaj źródła

fix: 人力家认证状态同步userSub表

lixuesong 3 lat temu
rodzic
commit
55852cd427

+ 21 - 9
hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/service/impl/WmSettlementServiceImpl.java

@@ -200,23 +200,35 @@ public class WmSettlementServiceImpl implements WmSettlementService {
 		SysUserSub userSub = sysUserSubService.getOne(Wrappers.<SysUserSub>lambdaQuery()
 				.eq(SysUserSub::getUserId, updateUser.getUserId())
 				.eq(SysUserSub::getGigType, GigTypeEnum.REN_LI_JIA));
+		LocalDateTime now = LocalDateTime.now();
+
 		if (userSub != null) {
+			// 更新
 			SysUserSub updateUserSub = new SysUserSub();
 			updateUserSub.setId(userSub.getId());
 			updateUserSub.setCertRemark(item.getRemark());
 			updateUserSub.setCertStatus(item.getStatus());
 			updateUserSub.setCallbackStatus(GigCallBackStatus.RETURNED);
-			updateUserSub.setUpdateTime(LocalDateTime.now());
+			updateUserSub.setUpdateTime(now);
 			updateUserSub.setUpdateUser(0);
 			sysUserSubService.updateById(updateUserSub);
-			// 结果放到redis
-			String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
-			Map<String, String> subMap = new HashMap<>();
-			subMap.put("certStatus", RenlijiaCertStatus.resolve(item.getStatus()).name());
-			subMap.put("message", item.getRemark());
-			Map<String, Object> result = MapUtil.newHashMap(1);
-			result.put("REN_LI_JIA", subMap);
-			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
+		} else {
+			// 新增
+			SysUserSub saveUserSub = new SysUserSub();
+			saveUserSub.setCertRemark(item.getRemark());
+			saveUserSub.setCertStatus(item.getStatus());
+			saveUserSub.setCallbackStatus(GigCallBackStatus.RETURNED);
+			saveUserSub.setCreateTime(now);
+			saveUserSub.setCreateUser(0);
+			sysUserSubService.save(saveUserSub);
 		}
+		// 结果放到redis
+		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
+		Map<String, String> subMap = new HashMap<>();
+		subMap.put("certStatus", RenlijiaCertStatus.resolve(item.getStatus()).name());
+		subMap.put("message", item.getRemark());
+		Map<String, Object> result = MapUtil.newHashMap(1);
+		result.put("REN_LI_JIA", subMap);
+		redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
 	}
 }