支付回调

This commit is contained in:
Guoqs
2024-09-02 09:56:02 +08:00
parent 0e38ea9e13
commit 3221c9ae67
3 changed files with 2122 additions and 782 deletions

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@@ -1,6 +1,5 @@
package com.jsowell.pile.service.impl; package com.jsowell.pile.service.impl;
import com.alibaba.fastjson2.JSON;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.jsowell.common.constant.CacheConstants; import com.jsowell.common.constant.CacheConstants;
import com.jsowell.common.core.redis.RedisCache; import com.jsowell.common.core.redis.RedisCache;
@@ -25,17 +24,22 @@ public class AdapayCallbackRecordServiceImpl implements AdapayCallbackRecordServ
@Autowired @Autowired
private RedisCache redisCache; private RedisCache redisCache;
/**
* 接收到支付回调记录保存到数据库
* paymentId添加了唯一约束, 如果存在则报错
* @param callbackRecord
*/
@Override @Override
public void saveAdapayCallbackRecord(AdapayCallbackRecord callbackRecord) { public void saveAdapayCallbackRecord(AdapayCallbackRecord callbackRecord) {
AdapayCallbackRecord adapayCallbackRecord = selectByPaymentId(callbackRecord.getPaymentId()); // AdapayCallbackRecord adapayCallbackRecord = selectByPaymentId(callbackRecord.getPaymentId());
if (adapayCallbackRecord != null) { // if (adapayCallbackRecord != null) {
return; // return;
} // }
try { // try {
// } catch (Exception e) {
// log.error("saveAdapayCallbackRecord:{}, error", JSON.toJSONString(callbackRecord), e);
// }
adapayCallbackRecordMapper.insert(callbackRecord); adapayCallbackRecordMapper.insert(callbackRecord);
} catch (Exception e) {
log.error("saveAdapayCallbackRecord:{}, error", JSON.toJSONString(callbackRecord), e);
}
} }
/** /**