This commit is contained in:
linfso 2025-05-18 23:54:46 +08:00
parent 1703799c03
commit a3de735a8b

View File

@ -131,8 +131,8 @@ public class EmisCommonController extends EmisBaseController
*/ */
@PostMapping("/payNotifyCallback") @PostMapping("/payNotifyCallback")
public String payNotifyCallback(String method,String data,String sign_type,String sign){ public String payNotifyCallback(String method,String data,String sign_type,String sign){
log.info("payNotifyCallback start");
log.info("payNotifyCallback start");
if(StringUtils.isAnyEmpty(method,data,sign)){ if(StringUtils.isAnyEmpty(method,data,sign)){
return "fail"; return "fail";
} }
@ -162,20 +162,26 @@ public class EmisCommonController extends EmisBaseController
err_msg String 错误消息 err_msg String 错误消息
*/ */
JSONObject jobjRst = JSONObject.parseObject(data); JSONObject jobjRst = JSONObject.parseObject(data);
String payId = jobjRst.getString("order_no"); String payId = jobjRst.getString("order_no");
if(StringUtils.isEmpty(payId)){ if(StringUtils.isEmpty(payId)){
return "fail"; return "fail";
} }
String lockKey="payNotifyCallback_"+payId;
redissonService.lock(lockKey,300);
try { try {
log.info("payNotifyCallback start"); log.info("payNotifyCallback start");
emisSettleBillPayLogService.checkPayStatus(payId); emisSettleBillPayLogService.checkPayStatus(payId);
} catch (EmisBizError emisBizError) { } catch (EmisBizError emisBizError) {
redissonService.unlock(lockKey);
emisBizError.printStackTrace(); emisBizError.printStackTrace();
return emisBizError.getMessage(); return emisBizError.getMessage();
} }
redissonService.unlock(lockKey);
log.info("payNotifyCallback end"); log.info("payNotifyCallback end");
return "success"; return "success";
} }