feat: 阿拉钉/易联-金园数科 回调修改

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

@@ -253,12 +253,6 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		Map<String, String> subMap = new HashMap<>();
 		SysUserSub updateUserSub = new SysUserSub();
 		if (OladingCommonRequest.SignUpStatus.SIGN.equals(signUpCertStatus)) {
-			// 如果成功，则发送证照上传MQ
-			log.info("=============================发送证照上传MQ==================================");
-			UserSignCertDTO userSignCertDTO = new UserSignCertDTO();
-			userSignCertDTO.setUserId(userSub.getUserId());
-			userSignCertDTO.setGigTypeList(Collections.singletonList(userSub.getGigType()));
-			sysUserSignCertService.batchChannelCert(userSignCertDTO);
 			subMap.put("certStatus", OladingCertStatus.SIGNED.name());
 			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
 		} else {
@@ -282,6 +276,15 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		Map<String, Object> result = MapUtil.newHashMap(1);
 		result.put(userSub.getGigType().name(), subMap);
 		redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
+
+		// 如果成功，则发送证照上传MQ
+		if (OladingCommonRequest.SignUpStatus.SIGN.equals(signUpCertStatus)) {
+			log.info("=============================发送证照上传MQ==================================");
+			UserSignCertDTO userSignCertDTO = new UserSignCertDTO();
+			userSignCertDTO.setUserId(userSub.getUserId());
+			userSignCertDTO.setGigTypeList(Collections.singletonList(userSub.getGigType()));
+			sysUserSignCertService.batchChannelCert(userSignCertDTO);
+		}
 	}
 
 	/**
@@ -303,13 +306,6 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		Map<String, String> subMap = new HashMap<>();
 		LambdaUpdateWrapper<SysUserSub> updateUserSubWrapper = Wrappers.lambdaUpdate();
 		if (OladingCommonRequest.UploadIdCardImageStatus.IDENTIFY_SUCCESS.equals(uploadIdCertStatus)) {
-			// 如果成功，则发送协议上传MQ
-			log.info("=============================发送协议上传MQ==================================");
-			UserSignCertDTO userSignCertDTO = new UserSignCertDTO();
-			userSignCertDTO.setUserId(userSub.getUserId());
-			userSignCertDTO.setGigTypeList(Collections.singletonList(userSub.getGigType()));
-			sysUserSignCertService.batchChannelCert(userSignCertDTO);
-
 			subMap.put("certStatus", OladingCertStatus.SIGNED.name());
 			updateUserSubWrapper.set(SysUserSub::getCertStatus, Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
 		} else {
@@ -335,6 +331,15 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		Map<String, Object> result = MapUtil.newHashMap(1);
 		result.put(userSub.getGigType().name(), subMap);
 		redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
+
+		// 如果成功，则发送协议上传MQ
+		if (OladingCommonRequest.UploadIdCardImageStatus.IDENTIFY_SUCCESS.equals(uploadIdCertStatus)) {
+			log.info("=============================发送协议上传MQ==================================");
+			UserSignCertDTO userSignCertDTO = new UserSignCertDTO();
+			userSignCertDTO.setUserId(userSub.getUserId());
+			userSignCertDTO.setGigTypeList(Collections.singletonList(userSub.getGigType()));
+			sysUserSignCertService.batchChannelCert(userSignCertDTO);
+		}
 	}
 
 	/**
@@ -356,14 +361,6 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		Map<String, String> subMap = new HashMap<>();
 		SysUserSub updateUserSub = new SysUserSub();
 		if (OladingCommonRequest.UploadTaxpayerAgreementStatus.SUCCESS.equals(agreementStatus)) {
-			// 如果成功，则发送核身视频上传MQ
-			log.info("=============================发送核身视频上传MQ==================================");
-			UserSignCertDTO userSignCertDTO = new UserSignCertDTO();
-			userSignCertDTO.setUserId(userSub.getUserId());
-			userSignCertDTO.setGigTypeList(Collections.singletonList(userSub.getGigType()));
-			userSignCertDTO.setUploadFaceID(true);
-			sysUserSignCertService.batchChannelCert(userSignCertDTO);
-
 			subMap.put("certStatus", OladingCertStatus.CERT.name());
 			updateUserSub.setCertStatus(Integer.valueOf(OladingCertStatus.CERT.getCode()));
 		} else {
@@ -387,5 +384,15 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		Map<String, Object> result = MapUtil.newHashMap(1);
 		result.put(userSub.getGigType().name(), subMap);
 		redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
+
+		// 如果成功，则发送核身视频上传MQ
+		if (OladingCommonRequest.UploadTaxpayerAgreementStatus.SUCCESS.equals(agreementStatus)) {
+			log.info("=============================发送核身视频上传MQ==================================");
+			UserSignCertDTO userSignCertDTO = new UserSignCertDTO();
+			userSignCertDTO.setUserId(userSub.getUserId());
+			userSignCertDTO.setGigTypeList(Collections.singletonList(userSub.getGigType()));
+			userSignCertDTO.setUploadFaceID(true);
+			sysUserSignCertService.batchChannelCert(userSignCertDTO);
+		}
 	}
 }