feat: 人力家认证调用原有的发短信认证

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

@@ -17,6 +17,7 @@ import com.qunzhixinxi.hnqz.admin.config.UpmsConfig;
 import com.qunzhixinxi.hnqz.admin.entity.SysDeptSub;
 import com.qunzhixinxi.hnqz.admin.entity.SysUserSub;
 import com.qunzhixinxi.hnqz.admin.entity.dto.UserSignCertDTO;
+import com.qunzhixinxi.hnqz.admin.entity.input.UserCertificationInput;
 import com.qunzhixinxi.hnqz.admin.entity.model.GigBaseInfoModel;
 import com.qunzhixinxi.hnqz.admin.entity.model.GigInfoModel;
 import com.qunzhixinxi.hnqz.admin.entity.model.GigUserInfoModel;
@@ -38,6 +39,7 @@ import com.qunzhixinxi.hnqz.admin.service.SysUserService;
 import com.qunzhixinxi.hnqz.admin.service.SysUserSubService;
 import com.qunzhixinxi.hnqz.admin.service.gig.SysUserSignCertService;
 import com.qunzhixinxi.hnqz.common.core.entity.BaseMap;
+import com.qunzhixinxi.hnqz.common.core.util.R;
 import com.qunzhixinxi.hnqz.common.rabbitmq.client.RabbitMqClient;
 import com.qunzhixinxi.hnqz.common.security.service.HnqzUser;
 import com.qunzhixinxi.hnqz.common.security.util.SecurityUtils;
@@ -401,6 +403,8 @@ public class SysUserSignCertServiceImpl implements SysUserSignCertService {
 						updateUserSub.setId(userSub.getId());
 						updateUserSub.setCertStatus(existUserSub.getCertStatus());
 						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();
@@ -412,6 +416,23 @@ public class SysUserSignCertServiceImpl implements SysUserSignCertService {
 					}
 				}
 				break;
+			case REN_LI_JIA:
+				// 人力家直接调用原有发短信接口
+				UserCertificationInput input = new UserCertificationInput();
+				input.setUserId(sysUser.getUserId());
+				input.setIdCardNumber(sysUser.getIdCardNumber());
+				input.setBankCardNumber(userSub.getBankCardNumber());
+				input.setSubList(new String[]{String.valueOf(GigTypeEnum.REN_LI_JIA.getCode())});
+				R r = sysUserService.batchChannelCert(input);
+				// 更新状态
+				SysUserSub updateUserSub = new SysUserSub();
+				updateUserSub.setId(userSub.getId());
+				updateUserSub.setCertRemark(r.getMsg());
+				updateUserSub.setUpdateTime(LocalDateTime.now());
+				updateUserSub.setUpdateUser(0);
+				sysUserSubService.updateById(updateUserSub);
+				// 默认返回false，不触发发送mq
+				flag = false;
 			default:
 		}
 

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

@@ -1,5 +1,7 @@
 package com.qunzhixinxi.hnqz.admin.service.impl;
 
+import cn.hutool.core.map.MapUtil;
+import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -7,6 +9,8 @@ import com.qunzhixinxi.hnqz.admin.api.constant.CacheConstants;
 import com.qunzhixinxi.hnqz.admin.api.entity.SysUser;
 import com.qunzhixinxi.hnqz.admin.entity.*;
 import com.qunzhixinxi.hnqz.admin.entity.input.SettleNoteStatusOutput;
+import com.qunzhixinxi.hnqz.admin.enums.GigTypeEnum;
+import com.qunzhixinxi.hnqz.admin.enums.RenlijiaCertStatus;
 import com.qunzhixinxi.hnqz.admin.mapper.WmSettleAccountReceiveMapper;
 import com.qunzhixinxi.hnqz.admin.service.*;
 import com.qunzhixinxi.hnqz.common.ding.entity.*;
@@ -19,7 +23,10 @@ import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 
 @Service
@@ -28,6 +35,8 @@ import java.util.List;
 public class WmSettlementServiceImpl implements WmSettlementService {
 
 	private final SysUserService sysUserService;
+	
+	private final SysUserSubService sysUserSubService;
 
 	private final WmImportUserService importUserService;
 
@@ -84,6 +93,8 @@ public class WmSettlementServiceImpl implements WmSettlementService {
 					updateUser.setCertRemark(item.getRemark());
 					updateUser.setRljCertStatus(item.getStatus());
 					sysUserService.updateById(updateUser);
+					// 更新usersub
+					updateUserSub(item, updateUser);
 				}
 
 
@@ -177,4 +188,32 @@ public class WmSettlementServiceImpl implements WmSettlementService {
 
 		return NotifyResponse.success();
 	}
+
+	/**
+	 * 更新usersub对应的人力家认证状态
+	 *
+	 * @param item
+	 * @param updateUser
+	 */
+	private void updateUserSub(EmployCheckNotifyDataItem item, SysUser updateUser) {
+		SysUserSub userSub = sysUserSubService.getOne(Wrappers.<SysUserSub>lambdaQuery()
+				.eq(SysUserSub::getUserId, updateUser.getUserId())
+				.eq(SysUserSub::getGigType, GigTypeEnum.REN_LI_JIA));
+		if (userSub != null) {
+			SysUserSub updateUserSub = new SysUserSub();
+			updateUserSub.setId(userSub.getId());
+			updateUserSub.setCertRemark(item.getRemark());
+			updateUserSub.setUpdateTime(LocalDateTime.now());
+			updateUserSub.setUpdateUser(0);
+			sysUserSubService.updateById(updateUserSub);
+			// 结果放到redis
+			String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
+			Map<String, String> subMap = new HashMap<>();
+			subMap.put("certStatus", RenlijiaCertStatus.resolve(item.getStatus()).name());
+			subMap.put("message", item.getRemark());
+			Map<String, Object> result = MapUtil.newHashMap(1);
+			result.put("REN_LI_JIA", subMap);
+			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(result), 1, TimeUnit.MINUTES);
+		}
+	}
 }