feat: 阿拉丁签约认证状态修改

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

@@ -104,14 +104,8 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		}
 
 		Map<String, String> subMap = new HashMap<>();
+		SysUserSub updateUserSub = new SysUserSub();
 		if (OladingCommonRequest.SignUpStatus.SIGN.equals(signUpCertStatus)) {
-			// 更新状态
-			SysUserSub updateUserSub = new SysUserSub();
-			updateUserSub.setId(userSub.getId());
-			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
-			updateUserSub.setUpdateTime(LocalDateTime.now());
-			updateUserSub.setUpdateUser(0);
-			sysUserSubService.updateById(updateUserSub);
 			// 如果成功，则发送证照上传MQ
 			log.info("=============================发送证照上传MQ==================================");
 			UserSignCertDTO userSignCertDTO = new UserSignCertDTO();
@@ -119,9 +113,17 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 			userSignCertDTO.setGigTypeList(Collections.singletonList(GigTypeEnum.OLADING));
 			sysUserSignCertService.batchChannelCert(userSignCertDTO);
 			subMap.put("certStatus", OladingCertStatus.SIGNED.name());
+			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
 		} else {
 			subMap.put("certStatus", OladingCertStatus.UN_SIGNED.name());
+			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.UN_SIGNED.getCode()));
+			updateUserSub.setCallbackStatus(GigCallBackStatus.RETURNED);
 		}
+		updateUserSub.setId(userSub.getId());
+		updateUserSub.setUpdateTime(LocalDateTime.now());
+		updateUserSub.setUpdateUser(0);
+		// 更新状态
+		sysUserSubService.updateById(updateUserSub);
 
 		// 结果放到redis
 		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
@@ -147,6 +149,7 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		}
 
 		Map<String, String> subMap = new HashMap<>();
+		SysUserSub updateUserSub = new SysUserSub();
 		if (OladingCommonRequest.UploadIdCardImageStatus.IDENTIFY_SUCCESS.equals(uploadIdCertStatus)) {
 			// 如果成功，则发送协议上传MQ
 			log.info("=============================发送协议上传MQ==================================");
@@ -155,9 +158,17 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 			userSignCertDTO.setGigTypeList(Collections.singletonList(GigTypeEnum.OLADING));
 			sysUserSignCertService.batchChannelCert(userSignCertDTO);
 			subMap.put("certStatus", OladingCertStatus.SIGNED.name());
+			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
 		} else {
 			subMap.put("certStatus", OladingCertStatus.SIGNED.name());
+			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
+			updateUserSub.setCallbackStatus(GigCallBackStatus.RETURNED);
 		}
+		updateUserSub.setId(userSub.getId());
+		updateUserSub.setUpdateTime(LocalDateTime.now());
+		updateUserSub.setUpdateUser(0);
+		// 更新状态
+		sysUserSubService.updateById(updateUserSub);
 
 		// 结果放到redis
 		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
@@ -183,19 +194,21 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		}
 
 		Map<String, String> subMap = new HashMap<>();
+		SysUserSub updateUserSub = new SysUserSub();
 		if (OladingCommonRequest.UploadTaxpayerAgreementStatus.SUCCESS.equals(agreementStatus)) {
-			// 更新状态
-			SysUserSub updateUserSub = new SysUserSub();
-			updateUserSub.setId(userSub.getId());
-			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.CERT.getCode()));
-			updateUserSub.setCallbackStatus(GigCallBackStatus.RETURNED);
-			updateUserSub.setUpdateTime(LocalDateTime.now());
-			updateUserSub.setUpdateUser(0);
 			sysUserSubService.updateById(updateUserSub);
 			subMap.put("certStatus", OladingCertStatus.CERT.name());
+			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.CERT.getCode()));
 		} else {
-			subMap.put("certStatus", OladingCertStatus.SIGNED.name());
+			subMap.put("certStatus", OladingCertStatus.SIGNED.name()); // TODO 更新状态
+			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
 		}
+		updateUserSub.setId(userSub.getId());
+		updateUserSub.setCallbackStatus(GigCallBackStatus.RETURNED);
+		updateUserSub.setUpdateTime(LocalDateTime.now());
+		updateUserSub.setUpdateUser(0);
+		// 更新状态
+		sysUserSubService.updateById(updateUserSub);
 
 		// 结果放到redis
 		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();