浏览代码

feat: 阿拉钉/易联-金园数科 发送核身视频mq回调修改

lixuesong 3 年之前
父节点
当前提交
07e940e1e2

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

@@ -246,6 +246,11 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 			result.put("YEE", subMap);
 			result.put("YEE", subMap);
 			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
 			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
 		}
 		}
+		// 已认证,则设置回调状态
+		if (OladingCertStatus.CERT.getCode().equals(String.valueOf(userSub.getCertStatus()))) {
+			updateWrapper.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED);
+		}
+
 		sysUserSubService.update(updateWrapper);
 		sysUserSubService.update(updateWrapper);
 		// 如果是核身视频回调,则同步该账号的自由职家渠道认证状态 TODO
 		// 如果是核身视频回调,则同步该账号的自由职家渠道认证状态 TODO
 	}
 	}
@@ -303,6 +308,11 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 			result.put("OLADING", subMap);
 			result.put("OLADING", subMap);
 			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
 			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
 		}
 		}
+		// 已认证,则设置回调状态
+		if (OladingCertStatus.CERT.getCode().equals(String.valueOf(userSub.getCertStatus()))) {
+			updateWrapper.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED);
+		}
+
 		sysUserSubService.update(updateWrapper);
 		sysUserSubService.update(updateWrapper);
 		// 如果是核身视频回调,则同步该账号的易联-金园数科渠道认证状态 TODO
 		// 如果是核身视频回调,则同步该账号的易联-金园数科渠道认证状态 TODO
 	}
 	}