提交人:陈绍鑫

日期:2025/01/09 17:30
内容:推送共享优化
This commit is contained in:
陈绍鑫 2026-01-12 11:37:28 +08:00
parent f7cb5c36ec
commit df352938b9
3 changed files with 22 additions and 9 deletions

View File

@ -1462,6 +1462,8 @@ public class ApiService {
String thirdparty = resultMap.get("shkd_thirdpartysys").toString();//第三方系统 String thirdparty = resultMap.get("shkd_thirdpartysys").toString();//第三方系统
String issuccess = resultMap.get("shkd_issuccess").toString();//是否成功 String issuccess = resultMap.get("shkd_issuccess").toString();//是否成功
String shkd_calldescription = resultMap.get("shkd_calldescription").toString();//调用说明 String shkd_calldescription = resultMap.get("shkd_calldescription").toString();//调用说明
String shkd_djlx = resultMap.get("shkd_djlx").toString();//单据类型
String shkd_djbm = resultMap.get("shkd_djbm").toString();//单据编号
DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_thirdpartylog"); DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_thirdpartylog");
// 生成随机UUID // 生成随机UUID
UUID uuid = UUID.randomUUID(); UUID uuid = UUID.randomUUID();

View File

@ -66,7 +66,7 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
dzhdqFilter = new QFilter("shkd_sfcgtsgx", QCP.equals, false); dzhdqFilter = new QFilter("shkd_sfcgtsgx", QCP.equals, false);
dzhdqFilter = dzhdqFilter.and(new QFilter("org.shkd_sfjcgx", QCP.equals, true)); dzhdqFilter = dzhdqFilter.and(new QFilter("org.shkd_sfjcgx", QCP.equals, true));
dzhdqFilter = dzhdqFilter.and(new QFilter("paymentidentify.number", QCP.equals, "FKBS01")); dzhdqFilter = dzhdqFilter.and(new QFilter("paymentidentify.number", QCP.equals, "FKBS01"));
dzhdqFilter = dzhdqFilter.and(new QFilter("billstatus", QCP.in, Arrays.asList("B", "A"))); dzhdqFilter = dzhdqFilter.and(new QFilter("billstatus", QCP.in, Arrays.asList("A")));
} else { } else {
this.getView().showTipNotification("未找到匹配的单据类型"); this.getView().showTipNotification("未找到匹配的单据类型");
return; return;
@ -83,12 +83,12 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
} }
dzhdqFilter = dzhdqFilter.and(zdyqFilter); dzhdqFilter = dzhdqFilter.and(zdyqFilter);
} }
logger.info("dzhdqFilter:" + dzhdqFilter);
//映射配置过滤条件 //映射配置过滤条件
QFilter getpeizhiqFilter=getpeizhiqFilter(shkd_apimapping); QFilter getpeizhiqFilter=getpeizhiqFilter(shkd_apimapping);
if (getpeizhiqFilter!=null){ if (getpeizhiqFilter!=null){
dzhdqFilter = dzhdqFilter.and(getpeizhiqFilter); dzhdqFilter = dzhdqFilter.and(getpeizhiqFilter);
} }
logger.info("dzhdqFilter:" + dzhdqFilter);
DynamicObject[] bei_elecreceiptids = BusinessDataServiceHelper.load(sourcebillnumber, "id", dzhdqFilter.toArray()); DynamicObject[] bei_elecreceiptids = BusinessDataServiceHelper.load(sourcebillnumber, "id", dzhdqFilter.toArray());
logger.info("符合推送条件数据有:{}条", bei_elecreceiptids.length); logger.info("符合推送条件数据有:{}条", bei_elecreceiptids.length);
@ -251,10 +251,15 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
resultMap.put("shkd_response", res);//响应数据 resultMap.put("shkd_response", res);//响应数据
resultMap.put("shkd_thirdpartysys", "浪潮");//第三方系统 resultMap.put("shkd_thirdpartysys", "浪潮");//第三方系统
resultMap.put("shkd_calldescription", "司库->浪潮");//第三方系统 resultMap.put("shkd_calldescription", "司库->浪潮");//第三方系统
// 属性
String shkd_ycsx = shkd_apimapping.getString("shkd_ycsx");
JSONObject shkd_ycsxjsonObject = JSONObject.parseObject(shkd_ycsx);
String billnoValue = shkd_ycsxjsonObject.getString("billno");
String dateValue = shkd_ycsxjsonObject.getString("date");
// 单据类型 // 单据类型
resultMap.put("shkd_djlx", sourcebillnumber);
// 单据编码 // 单据编码(编号+日期)
resultMap.put("shkd_djbm", bei_elecreceipt.getString(billnoValue)+"___"+bei_elecreceipt.getString(dateValue));
logger.info("resultMap:" + resultMap); logger.info("resultMap:" + resultMap);
if (!tiaoguo) { if (!tiaoguo) {
ApiService.saveThePushLog(resultMap); ApiService.saveThePushLog(resultMap);

View File

@ -66,7 +66,7 @@ public class SharePushTaskPlugin extends AbstractTask {
dzhdqFilter = new QFilter("shkd_sfcgtsgx", QCP.equals, false); dzhdqFilter = new QFilter("shkd_sfcgtsgx", QCP.equals, false);
dzhdqFilter = dzhdqFilter.and(new QFilter("org.shkd_sfjcgx", QCP.equals, true)); dzhdqFilter = dzhdqFilter.and(new QFilter("org.shkd_sfjcgx", QCP.equals, true));
dzhdqFilter = dzhdqFilter.and(new QFilter("paymentidentify.number", QCP.equals, "FKBS01")); dzhdqFilter = dzhdqFilter.and(new QFilter("paymentidentify.number", QCP.equals, "FKBS01"));
dzhdqFilter = dzhdqFilter.and(new QFilter("billstatus", QCP.in, Arrays.asList("B", "A"))); dzhdqFilter = dzhdqFilter.and(new QFilter("billstatus", QCP.in, Arrays.asList("A")));
} else { } else {
logger.info("未找到匹配的单据类型"); logger.info("未找到匹配的单据类型");
return; return;
@ -83,13 +83,12 @@ public class SharePushTaskPlugin extends AbstractTask {
} }
dzhdqFilter = dzhdqFilter.and(zdyqFilter); dzhdqFilter = dzhdqFilter.and(zdyqFilter);
} }
logger.info("dzhdqFilter:" + dzhdqFilter);
//映射配置过滤条件 //映射配置过滤条件
QFilter getpeizhiqFilter=getpeizhiqFilter(shkd_apimapping); QFilter getpeizhiqFilter=getpeizhiqFilter(shkd_apimapping);
if (getpeizhiqFilter!=null){ if (getpeizhiqFilter!=null){
dzhdqFilter = dzhdqFilter.and(getpeizhiqFilter); dzhdqFilter = dzhdqFilter.and(getpeizhiqFilter);
} }
logger.info("dzhdqFilter:" + dzhdqFilter);
DynamicObject[] bei_elecreceiptids = BusinessDataServiceHelper.load(sourcebillnumber, "id", dzhdqFilter.toArray()); DynamicObject[] bei_elecreceiptids = BusinessDataServiceHelper.load(sourcebillnumber, "id", dzhdqFilter.toArray());
logger.info("符合推送条件数据有:{}条", bei_elecreceiptids.length); logger.info("符合推送条件数据有:{}条", bei_elecreceiptids.length);
@ -252,9 +251,16 @@ public class SharePushTaskPlugin extends AbstractTask {
resultMap.put("shkd_response", res);//响应数据 resultMap.put("shkd_response", res);//响应数据
resultMap.put("shkd_thirdpartysys", "浪潮");//第三方系统 resultMap.put("shkd_thirdpartysys", "浪潮");//第三方系统
resultMap.put("shkd_calldescription", "司库->浪潮");//第三方系统 resultMap.put("shkd_calldescription", "司库->浪潮");//第三方系统
// 单据类型
//属性
String shkd_ycsx = shkd_apimapping.getString("shkd_ycsx");
JSONObject shkd_ycsxjsonObject = JSONObject.parseObject(shkd_ycsx);
String billnoValue = shkd_ycsxjsonObject.getString("billno");
String dateValue = shkd_ycsxjsonObject.getString("date");
// 单据类型
resultMap.put("shkd_djlx", sourcebillnumber);
// 单据编码 // 单据编码
resultMap.put("shkd_djbm", bei_elecreceipt.getString(billnoValue)+"___"+bei_elecreceipt.getString(dateValue));
logger.info("resultMap:" + resultMap); logger.info("resultMap:" + resultMap);
if (!tiaoguo) { if (!tiaoguo) {
ApiService.saveThePushLog(resultMap); ApiService.saveThePushLog(resultMap);