feat: 薪事易结算回调业务2

db/v2.0/20240402.sql

@@ -4,8 +4,9 @@ create table xinshiyi_input_record
         primary key,
     req_id       varchar(64)                        null comment '请求序号',
     batch_id     varchar(64)                        null comment '批次号',
+    msg_method   char(20)                           null comment '消息接口名称',
     order_status int                                null comment '订单状态',
     req_body     text                               null comment '请求body',
     create_time  datetime default CURRENT_TIMESTAMP null comment '创建时间'
 )
-    comment '薪事易回调异步通知记录';
+    comment '薪事易回调异步通知记录';

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/controller/GigThirdApiController.java

@@ -106,9 +106,12 @@ public class GigThirdApiController {
 		// 请求body json
 		JSONObject bodyJson = JSONUtil.parseObj(body);
 
+		// bizContent
+		JSONObject bizContent = bodyJson.getJSONObject("bizContent");
+
 		// 批次号
-		String batchId = bodyJson.getStr("batchId");
-		JSONArray orderDetailList = bodyJson.getJSONArray("orderDetailList");
+		String batchId = bizContent.getStr("batchId");
+		JSONArray orderDetailList = bizContent.getJSONArray("orderDetailList");
 
 		String redisKey = String.format("%s_%s", CacheConstants.QI_FU_SETTLE_NOTIFY_KEY, batchId);
 		Boolean absent = redisTemplate.opsForValue().setIfAbsent(redisKey, batchId, 30, TimeUnit.MINUTES);
@@ -129,7 +132,7 @@ public class GigThirdApiController {
 		xinshiyiInputRecordMapper.insert(inputRecord);
 
 		// 业务处理
-
+		gigThirdApiService.xinshiyiSettleNotify(bizContent);
 
 		return "ok";
 	}

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

@@ -32,6 +32,11 @@ public class XinshiyiInputRecord implements Serializable {
      */
     private String batchId;
 
+	/**
+	 * 消息接口名称
+	 */
+	private String msgMethod;
+
     /**
      * 订单状态
      */