feat: 查询认证结果

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/entity/model/GigBindingCardConfirmRequest.java

@@ -1,10 +0,0 @@
-package com.qunzhixinxi.hnqz.admin.entity.model;
-
-/**
- * 税邦云绑卡确认request
- *
- * @author lixuesong
- * @date 2022年03月03日 13:39
- */
-public class GigBindingCardConfirmRequest {
-}

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/entity/model/GigBindingCardVerificationRequest.java

@@ -1,10 +0,0 @@
-package com.qunzhixinxi.hnqz.admin.entity.model;
-
-/**
- * 税邦云发送验证码request
- *
- * @author lixuesong
- * @date 2022年03月03日 13:42
- */
-public class GigBindingCardVerificationRequest {
-}

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/entity/model/GigSignCertRequest.java

@@ -1,19 +0,0 @@
-package com.qunzhixinxi.hnqz.admin.entity.model;
-
-import com.qunzhixinxi.hnqz.admin.enums.GigTypeEnum;
-import lombok.Data;
-
-import java.util.Map;
-
-/**
- * 零工平台签约认证request
- *
- * @author lixuesong
- * @date 2022年03月02日 17:48
- */
-@Data
-public class GigSignCertRequest {
-
-	Map<GigTypeEnum, GigInfoModel> info;
-
-}

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/entity/model/GigSignResponse.java

@@ -1,10 +0,0 @@
-package com.qunzhixinxi.hnqz.admin.entity.model;
-
-/**
- * 零工平台签约response
- *
- * @author lixuesong
- * @date 2022年03月02日 18:06
- */
-public class GigSignResponse {
-}

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

@@ -35,6 +35,7 @@ import org.springframework.messaging.handler.annotation.Header;
 
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 /**
  * 接收用户签约认证的结果对列监听器
@@ -98,13 +99,17 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 									.set(SysUserSub::getUpdateUser, 0)
 									.set(SysUserSub::getCertRemark, stageResult);
 
-								String cacheKeyPrefix = String.format("%s_%s_", CacheConstants.BIND_CARD_CONFIRM_NEW_BANK_CARD, user.getUserId());
+							String cacheKeyPrefix = String.format("%s_%s_", CacheConstants.BIND_CARD_CONFIRM_NEW_BANK_CARD, user.getUserId());
+							boolean success = false;
 							switch (gigTypeEnum) {
 								case TAX_HELPOR:
 									TaxHelperCertStatus taxHelperCertStatus = Enum.valueOf(TaxHelperCertStatus.class, certStatus);
 									updateWrapper.eq(SysUserSub::getGigType, GigTypeEnum.TAX_HELPOR);
 									updateWrapper.set(SysUserSub::getCertStatus, taxHelperCertStatus.getCode());
 									cacheKeyPrefix += GigTypeEnum.TAX_HELPOR.name();
+									if ("2000".equals(code)) {
+										success = true;
+									}
 									break;
 								case REN_LI_JIA:
 									// TODO
@@ -122,10 +127,13 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 									updateWrapper.eq(SysUserSub::getGigType, GigTypeEnum.YEE);
 									updateWrapper.set(SysUserSub::getCertStatus, yeeCertStatus.getCode());
 									cacheKeyPrefix += GigTypeEnum.YEE.name();
+									if ("200".equals(code)) {
+										success = true;
+									}
 									break;
 								default:
 							}
-							if ("2000".equals(code)) {
+							if (success) {
 								// 成功并且是换绑卡的情况，则更新银行卡号
 								UserSignCertDTO userSignCertDTO = (UserSignCertDTO) redisTemplate.opsForValue().get(cacheKeyPrefix);
 								if (userSignCertDTO != null && StrUtil.isNotBlank(userSignCertDTO.getBankCardNumber())) {
@@ -139,7 +147,8 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 						});
 
 						// 本次结果存入redis
-						redisTemplate.opsForValue().set(CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + user.getUserId(), JSONUtil.toJsonStr(subjectTypes));
+						redisTemplate.opsForValue().set(CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + user.getUserId(),
+								JSONUtil.toJsonStr(subjectTypes), 10, TimeUnit.MINUTES);
 					}
 				}
 			}