wenlukang1
/
CTSK_DEV
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

提交人：csx 

提交时间：2025年12月28日
提交内容：共享推送定时任务
This commit is contained in:
root 2025-12-28 15:50:20 +08:00
parent 5c212e93bd
commit fc78468e35
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/SharePushTaskPlugin.java
View File

@ -71,10 +71,9 @@ public class SharePushTaskPlugin extends AbstractTask {
//要推送单据的过滤（查询单子回单默认过滤条件） //要推送单据的过滤（查询单子回单默认过滤条件）
QFilter dzhdqFilter = new QFilter("ismatch", QCP.equals,true); QFilter dzhdqFilter = new QFilter("ismatch", QCP.equals,true);
dzhdqFilter = dzhdqFilter.and(new QFilter("billno", QCP.equals, "EBB-250928-101566"));
//自定义过滤条件 //自定义过滤条件
String shkd_zdygltj = shkd_apimappingid.getString("shkd_zdygltj"); String shkd_zdygltj = shkd_apimapping.getString("shkd_zdygltj");
if (!EmptyUtil.isEmpty(shkd_zdygltj)){ if (!EmptyUtil.isEmpty(shkd_zdygltj)){
QFilter zdyqFilter= null; QFilter zdyqFilter= null;
try { try {
@ -100,9 +99,9 @@ public class SharePushTaskPlugin extends AbstractTask {
for (DynamicObject bei_elecreceiptid : bei_elecreceiptids) { for (DynamicObject bei_elecreceiptid : bei_elecreceiptids) {
DynamicObject bei_elecreceipt = BusinessDataServiceHelper.loadSingle(bei_elecreceiptid.getLong("id"), "bei_elecreceipt"); DynamicObject bei_elecreceipt = BusinessDataServiceHelper.loadSingle(bei_elecreceiptid.getLong("id"), "bei_elecreceipt");
String saveRequestBody=getJSON(bei_elecreceipt,shkd_mapping);//请求json String saveRequestBody=getJSON(bei_elecreceipt,shkd_mapping);//请求json
logger.info("单据"+bei_elecreceiptid.getString("billno")+"推送json："+saveRequestBody); logger.info("单据"+bei_elecreceipt.getString("billno")+"推送json："+saveRequestBody);
String res = doPost(shkd_url,headMap,saveRequestBody,null); String res = doPost(shkd_url,headMap,saveRequestBody,null);
logger.info("单据"+bei_elecreceiptid.getString("billno")+"返回json："+res); logger.info("单据"+bei_elecreceipt.getString("billno")+"返回json："+res);
JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果 JSONObject otherIsJsonRS = JSONObject.parseObject(res);//获取返回结果
Map<String, Object> resultMap = new HashMap<>(); Map<String, Object> resultMap = new HashMap<>();
resultMap.put("shkd_requesturl",shkd_url);//请求地址 resultMap.put("shkd_requesturl",shkd_url);//请求地址