Ver código fonte

feat: mq回调认证状态记录

lixuesong 3 anos atrás
pai
commit
f2137a2e7b

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

@@ -314,6 +314,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 		String certStatus = subjectResult.getStr("certStatus");
 		String uploadTaxPayerAgreementStatus = subjectResult.getStr("uploadTaxPayerAgreementStatus");
 		LocalDateTime now = LocalDateTime.now();
+		Map<String, String> certStatusMap = new HashMap<>();
 
 		// 查询当前认证状态
 		SysUserSub userSub = sysUserSubService.getOne(Wrappers.<SysUserSub>lambdaQuery()
@@ -338,21 +339,18 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				&& !OladingCertStatus.CERT.getCode().equals(String.valueOf(userSub.getCertStatus()))) {
 			// 如果是已上传协议成功,则设置为已认证,否则还是已签约
 			SysUser updateUser = new SysUser();
-			Map<String, String> subMap = new HashMap<>();
 			if (OladingCommonRequest.UploadTaxpayerAgreementStatus.SUCCESS.name().equals(uploadTaxPayerAgreementStatus)) {
 				updateWrapper.set(SysUserSub::getCertStatus, Integer.parseInt(OladingCertStatus.CERT.getCode()));
-				subMap.put("certStatus", OladingCertStatus.CERT.name());
+				certStatusMap.put("certStatus", OladingCertStatus.CERT.name());
 			} else {
 				updateWrapper.set(SysUserSub::getCertStatus, Integer.parseInt(OladingCertStatus.SIGNED.getCode()));
-				subMap.put("certStatus", OladingCertStatus.SIGNED.name());
+				certStatusMap.put("certStatus", OladingCertStatus.SIGNED.name());
 			}
 			updateWrapper.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED);
 			// 修改步进状态
 			updateUser.setUserId(user.getUserId());
 			updateUser.setUpdateTime(now);
 			sysUserService.updateById(updateUser);
-
-			return subMap;
 		}
 		// 已认证,则设置回调状态
 		if (OladingCertStatus.CERT.getCode().equals(String.valueOf(userSub.getCertStatus()))) {
@@ -362,7 +360,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 		sysUserSubService.update(updateWrapper);
 		// 如果是核身视频回调,则同步该账号的易联-金园数科渠道认证状态 TODO
 
-		return null;
+		return certStatusMap;
 	}
 
 }