重试参数

This commit is contained in:
xiang2lin 2024-07-10 18:34:01 +08:00
parent 043f7704aa
commit 943829f8d7
1 changed files with 18 additions and 2 deletions

View File

@ -1,9 +1,12 @@
package com.hzya.frame.plugin.cbs8.plugin; package com.hzya.frame.plugin.cbs8.plugin;
import cn.hutool.core.util.StrUtil;
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.PaymentEntity; import com.hzya.frame.seeyon.cbs8.entity.PaymentEntity;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
import com.hzya.frame.sysnew.integtationTaskLivingDetails.service.IIntegrationTaskLivingDetailsService;
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;
@ -19,7 +22,8 @@ public class PayApplyPluginInitializer extends PluginBaseEntity {
@Autowired @Autowired
private ICbsPluginService cbsPluginService; private ICbsPluginService cbsPluginService;
@Autowired
private IIntegrationTaskLivingDetailsService taskLivingDetailsService;
/*** /***
* 插件初始化方法 * 插件初始化方法
* @Author 👻👻👻👻👻👻👻👻 gjh * @Author 👻👻👻👻👻👻👻👻 gjh
@ -102,8 +106,20 @@ public class PayApplyPluginInitializer extends PluginBaseEntity {
requestJson.remove("jsonStr"); requestJson.remove("jsonStr");
paymentEntity = JSONObject.parseObject(requestJson.toString(),PaymentEntity.class); paymentEntity = JSONObject.parseObject(requestJson.toString(),PaymentEntity.class);
} }
if (null == paymentEntity) if (null == paymentEntity){
paymentEntity = new PaymentEntity(); paymentEntity = new PaymentEntity();
}
String id = requestJson.getString("integration_task_living_details_id");
if (StrUtil.isNotEmpty(id)){
//查询日志里的参数
//查询日志表
IntegrationTaskLivingDetailsEntity taskDetailEntity = taskLivingDetailsService.get(id);
if (null != taskDetailEntity){
//重试标记
paymentEntity.setRetry_flag("1");
paymentEntity.setReferenceNum(taskDetailEntity.getRootAppBill());
}
}
//支付申请 //支付申请
//paymentEntity.setOaId("8475071606892874568"); //paymentEntity.setOaId("8475071606892874568");
cbsPluginService.applyPay(paymentEntity); cbsPluginService.applyPay(paymentEntity);