Procházet zdrojové kódy

feat: userSub加callbackTime

李学松 před 2 roky
rodič
revize
c2717cc02e

+ 5 - 0
hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/entity/SysUserSub.java

@@ -136,6 +136,11 @@ public class SysUserSub extends Model<SysUserSub> {
 	 */
 	private LocalDateTime updateTime;
 
+	/**
+	 * 认证回调时间
+	 */
+	private LocalDateTime callbackTime;
+
 	/**
 	 * 创建人
 	 */

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

@@ -183,6 +183,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				.eq(SysUserSub::getSubjectLocation, SubjectLocation.ZHONG_ZHI)
 				.eq(SysUserSub::getGigType, GigTypeEnum.ZHONG_ZHI)
 				.set(SysUserSub::getUpdateTime, now)
+				.set(SysUserSub::getCallbackTime, now)
 				.set(SysUserSub::getUpdateUser, 0)
 				.set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult));
 
@@ -275,6 +276,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				.eq(SysUserSub::getGigType, GigTypeEnum.HUI_QI_YUN)
 				.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED)
 				.set(SysUserSub::getUpdateTime, now)
+				.set(SysUserSub::getCallbackTime, now)
 				.set(SysUserSub::getUpdateUser, 0)
 				.set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult));
 
@@ -320,6 +322,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				.eq(SysUserSub::getGigType, GigTypeEnum.LANG_CHAO)
 				.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED)
 				.set(SysUserSub::getUpdateTime, now)
+				.set(SysUserSub::getCallbackTime, now)
 				.set(SysUserSub::getUpdateUser, 0)
 				.set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult));
 
@@ -373,6 +376,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				.eq(SysUserSub::getGigType, GigTypeEnum.ZHENG_QI_ZHI_XING)
 				.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED)
 				.set(SysUserSub::getUpdateTime, now)
+				.set(SysUserSub::getCallbackTime, now)
 				.set(SysUserSub::getUpdateUser, 0)
 				.set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult));
 
@@ -412,6 +416,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				.eq(SysUserSub::getGigType, GigTypeEnum.TAX_HELPOR)
 				.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED)
 				.set(SysUserSub::getUpdateTime, now)
+				.set(SysUserSub::getCallbackTime, now)
 				.set(SysUserSub::getUpdateUser, 0)
 				.set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult))
 				.set(SysUserSub::getCertStatus, taxHelperCertStatus.getCode());
@@ -461,6 +466,7 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 				.eq(SysUserSub::getGigType, GigTypeEnum.YEE)
 				.eq(SysUserSub::getSubjectLocation, SubjectLocation.YI_LIAN)
 				.set(SysUserSub::getUpdateTime, now)
+				.set(SysUserSub::getCallbackTime, now)
 				.set(SysUserSub::getUpdateUser, 0)
 				.set(SysUserSub::getCertRemark, JSONUtil.toJsonStr(subjectResult));
 		// 如果是已签约并且当前不是已认证,则设置一下状态(处理阿拉丁没有回调的情况)

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

@@ -270,7 +270,9 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 		updateUserSub.setCertRemark(String.format("%s;%s", userSub.getCertRemark(), String.format("签约回调:%s;", resMsg)));
 		updateUserSub.setFailReason(String.format("签约回调:%s;", resMsg));
 		updateUserSub.setCallbackStatus(GigCallBackStatus.RETURNED);
-		updateUserSub.setUpdateTime(LocalDateTime.now());
+		LocalDateTime now = LocalDateTime.now();
+		updateUserSub.setUpdateTime(now);
+		updateUserSub.setCallbackTime(now);
 		updateUserSub.setUpdateUser(0);
 		sysUserSubService.updateById(updateUserSub);
 
@@ -855,7 +857,9 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 			updateUserSubWrapper.set(SysUserSub::getIdCardFrontUrl, null);
 			updateUserSubWrapper.set(SysUserSub::getIdCardBackUrl, null);
 		}
-		updateUserSubWrapper.set(SysUserSub::getUpdateTime, LocalDateTime.now());
+		LocalDateTime now = LocalDateTime.now();
+		updateUserSubWrapper.set(SysUserSub::getUpdateTime, now);
+		updateUserSubWrapper.set(SysUserSub::getCallbackTime, now);
 		updateUserSubWrapper.set(SysUserSub::getUpdateUser, 0);
 		updateUserSubWrapper.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED);
 		if ("0".equals(req.getCode())) {
@@ -930,7 +934,9 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 			subMap.put("certStatus", OladingCertStatus.SIGNED.name());
 			updateUserSubWrapper.set(SysUserSub::getCertStatus, Integer.valueOf(OladingCertStatus.SIGNED.getCode()));
 		}
-		updateUserSubWrapper.set(SysUserSub::getUpdateTime, LocalDateTime.now());
+		LocalDateTime now = LocalDateTime.now();
+		updateUserSubWrapper.set(SysUserSub::getUpdateTime, now);
+		updateUserSubWrapper.set(SysUserSub::getCallbackTime, now);
 		updateUserSubWrapper.set(SysUserSub::getUpdateUser, 0);
 		updateUserSubWrapper.set(SysUserSub::getCallbackStatus, GigCallBackStatus.RETURNED);
 		if ("0".equals(req.getCode())) {