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 13:51:04 +08:00
parent 89e2f4326c
commit 907a5f057f
3 changed files with 25 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/PayApplyPluginInitializer.java
View File

@ -97,12 +97,14 @@ public class PayApplyPluginInitializer extends PluginBaseEntity {
**/ **/
@Override @Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception { public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
PaymentEntity paymentEntity; PaymentEntity paymentEntity = null;
if (null != requestJson){ if (null != requestJson){
requestJson.remove("jsonStr"); requestJson.remove("jsonStr");
paymentEntity = JSONObject.parseObject(requestJson.toString(),PaymentEntity.class);
} }
if (null == paymentEntity)
paymentEntity = new PaymentEntity();
//支付申请 //支付申请
paymentEntity = new PaymentEntity();
paymentEntity.setOaId("5490849762671477371"); paymentEntity.setOaId("5490849762671477371");
cbsPluginService.applyPay(paymentEntity); cbsPluginService.applyPay(paymentEntity);
return null; return null;

15
buildpackage/src/main/java/com/hzya/frame/plugin/cbs8/plugin/TransactionDetailPluginInitializer.java
View File

@ -1,5 +1,6 @@
package com.hzya.frame.plugin.cbs8.plugin; package com.hzya.frame.plugin.cbs8.plugin;
import cn.hutool.core.date.DateUtil;
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.cbs8.dto.req.TransactionDetailReqDTO; import com.hzya.frame.cbs8.dto.req.TransactionDetailReqDTO;
@ -101,10 +102,22 @@ public class TransactionDetailPluginInitializer extends PluginBaseEntity {
**/ **/
@Override @Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception { public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
TransactionDetailReqDTO transactionDetailReqDTO = new TransactionDetailReqDTO(); TransactionDetailReqDTO transactionDetailReqDTO = null;
if (null != requestJson){
requestJson.remove("jsonStr");
transactionDetailReqDTO = JSONObject.parseObject(requestJson.toString(),TransactionDetailReqDTO.class);
}
if (null == transactionDetailReqDTO){
transactionDetailReqDTO = new TransactionDetailReqDTO();
}
transactionDetailReqDTO.setCurrentPage(CBSUtil.DEFAULT_CURRENT_PAGE); transactionDetailReqDTO.setCurrentPage(CBSUtil.DEFAULT_CURRENT_PAGE);
transactionDetailReqDTO.setPageSize(CBSUtil.DEFAULT_PAGE_SIZE); transactionDetailReqDTO.setPageSize(CBSUtil.DEFAULT_PAGE_SIZE);
transactionDetailReqDTO.setStartDate(DateUtil.today());
transactionDetailReqDTO.setEndDate(DateUtil.today());
transactionDetailReqDTO.setDateType("0");
transactionDetailReqDTO.setLoanType("2");
List<TransactionDetailDTO> transactionDetailList = cbsPluginService.queryTransactionDetail(transactionDetailReqDTO); List<TransactionDetailDTO> transactionDetailList = cbsPluginService.queryTransactionDetail(transactionDetailReqDTO);
System.out.println("11111");
return null; return null;
} }
} }

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

@ -89,7 +89,14 @@ public class CbsPluginServiceImpl implements ICbsPluginService {
for (PaymentEntity pay : paymentList) { for (PaymentEntity pay : paymentList) {
//调用支付申请接口 //调用支付申请接口
PayResponseDTO payResponseDTO = cbs8Service.payApply(pay); PayResponseDTO payResponseDTO = cbs8Service.payApply(pay);
boolean successed = payResponseDTO.getSuccessed();
if (successed){
pay.setPayResult(PayState.p.getValue());
}else {
pay.setPayResult("推送失败");
}
//4、更新OA表单 //4、更新OA表单
pay.setDataSourceCode(oa_data_source_code);
paymentService.updatePayState(pay); paymentService.updatePayState(pay);
//5、记录操作日志 //5、记录操作日志
cbsLogService.saveLog(new CbsLogEntity()); cbsLogService.saveLog(new CbsLogEntity());