hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cbs8交易日志查询

This commit is contained in:
xiang2lin 2024-06-20 14:00:23 +08:00
parent 48186afb82
commit 6a2691ff69
3 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayResultPluginInitializer.java
View File

@ -3,6 +3,7 @@ package com.hzya.frame.plugin.cbs8.plugin;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity; import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.plugin.cbs8.service.ICbsPluginService; import com.hzya.frame.plugin.cbs8.service.ICbsPluginService;
import com.hzya.frame.seeyon.cbs8.entity.CbsLogEntity;
import com.hzya.frame.web.entity.JsonResultEntity; import com.hzya.frame.web.entity.JsonResultEntity;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -95,7 +96,15 @@ public class PayResultPluginInitializer extends PluginBaseEntity {
**/ **/
@Override @Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception { public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
cbsPluginService.queryResult(requestJson); CbsLogEntity cbsLogEntity = null;
if (null != requestJson){
requestJson.remove("jsonStr");
cbsLogEntity = JSONObject.parseObject(requestJson.toString(),CbsLogEntity.class);
}
if (null == cbsLogEntity){
cbsLogEntity = new CbsLogEntity();
}
cbsPluginService.queryResult(cbsLogEntity);
return null; return null;
} }
} }

5
buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/service/ICbsPluginService.java
View File

@ -8,6 +8,7 @@ import com.hzya.frame.cbs8.dto.res.PayResponseDTO;
import com.hzya.frame.cbs8.dto.res.TransactionDetailDTO; import com.hzya.frame.cbs8.dto.res.TransactionDetailDTO;
import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentDetailEntity; import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentDetailEntity;
import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentEntity; import com.hzya.frame.seeyon.cbs8.entity.AgentPaymentEntity;
import com.hzya.frame.seeyon.cbs8.entity.CbsLogEntity;
import com.hzya.frame.seeyon.cbs8.entity.PaymentEntity; import com.hzya.frame.seeyon.cbs8.entity.PaymentEntity;
import java.util.List; import java.util.List;
@ -27,10 +28,10 @@ public interface ICbsPluginService {
/** /**
* 查询支付申请的交易结果 * 查询支付申请的交易结果
* @param requestJson * @param cbsLogEntity
* @throws Exception * @throws Exception
*/ */
void queryResult(JSONObject requestJson)throws Exception; void queryResult(CbsLogEntity cbsLogEntity)throws Exception;
/** /**
* 电子回单查询 并上传OA * 电子回单查询 并上传OA

8
buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/service/impl/CbsPluginServiceImpl.java
View File

@ -107,12 +107,14 @@ public class CbsPluginServiceImpl implements ICbsPluginService {
/** /**
* 查询支付申请的交易结果 * 查询支付申请的交易结果
* *
* @param requestJson * @param cbsLogEntity
* @throws Exception * @throws Exception
*/ */
@Override @Override
public void queryResult(JSONObject requestJson) throws Exception { public void queryResult(CbsLogEntity cbsLogEntity) throws Exception {
CbsLogEntity cbsLogEntity = new CbsLogEntity(); if (null == cbsLogEntity){
cbsLogEntity = new CbsLogEntity();
}
// 1、查询支付中的日志 // 1、查询支付中的日志
List<CbsLogEntity> inPayList = cbsLogService.queryInPayment(cbsLogEntity); List<CbsLogEntity> inPayList = cbsLogService.queryInPayment(cbsLogEntity);
if (CollectionUtils.isNotEmpty(inPayList)){ if (CollectionUtils.isNotEmpty(inPayList)){