|
@@ -106,6 +106,7 @@ public class GigThirdApiController {
|
|
|
// 请求body json
|
|
|
JSONObject bodyJson = JSONUtil.parseObj(body);
|
|
|
|
|
|
+ String msgMethod = bodyJson.getStr("msgMethod");
|
|
|
// bizContent
|
|
|
JSONObject bizContent = bodyJson.getJSONObject("bizContent");
|
|
|
|
|
@@ -113,7 +114,7 @@ public class GigThirdApiController {
|
|
|
String batchId = bizContent.getStr("batchId");
|
|
|
JSONArray orderDetailList = bizContent.getJSONArray("orderDetailList");
|
|
|
|
|
|
- String redisKey = String.format("%s_%s", CacheConstants.QI_FU_SETTLE_NOTIFY_KEY, batchId);
|
|
|
+ String redisKey = String.format("%s_%s", CacheConstants.XIN_SHI_YI_SETTLE_NOTIFY_KEY, batchId);
|
|
|
Boolean absent = redisTemplate.opsForValue().setIfAbsent(redisKey, batchId, 30, TimeUnit.MINUTES);
|
|
|
if (Boolean.FALSE.equals(absent)) {
|
|
|
log.warn("存在在途操作batchId={}", batchId);
|
|
@@ -128,6 +129,7 @@ public class GigThirdApiController {
|
|
|
JSONObject orderDetail = (JSONObject) orderDetailList.get(0);
|
|
|
inputRecord.setOrderStatus(orderDetail.getInt("orderStatus"));
|
|
|
inputRecord.setReqId(orderDetail.getStr("partnerOrderId"));
|
|
|
+ inputRecord.setMsgMethod(msgMethod);
|
|
|
}
|
|
|
xinshiyiInputRecordMapper.insert(inputRecord);
|
|
|
|