Merge remote-tracking branch 'origin/main'
This commit is contained in:
commit
76f779ce51
|
|
@ -1462,6 +1462,8 @@ public class ApiService {
|
|||
String thirdparty = resultMap.get("shkd_thirdpartysys").toString();//第三方系统
|
||||
String issuccess = resultMap.get("shkd_issuccess").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");
|
||||
// 生成随机UUID
|
||||
UUID uuid = UUID.randomUUID();
|
||||
|
|
@ -1474,6 +1476,8 @@ public class ApiService {
|
|||
dynamicObject.set("shkd_thirdpartysys", thirdparty);
|
||||
dynamicObject.set("shkd_issuccess", issuccess);
|
||||
dynamicObject.set("shkd_logdate", new Date());
|
||||
dynamicObject.set("shkd_djlx", shkd_djlx);
|
||||
dynamicObject.set("shkd_djbm", shkd_djbm);
|
||||
SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -66,7 +66,7 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
|
|||
dzhdqFilter = new QFilter("shkd_sfcgtsgx", QCP.equals, false);
|
||||
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("billstatus", QCP.in, Arrays.asList("B", "A")));
|
||||
dzhdqFilter = dzhdqFilter.and(new QFilter("billstatus", QCP.in, Arrays.asList("A")));
|
||||
} else {
|
||||
this.getView().showTipNotification("未找到匹配的单据类型");
|
||||
return;
|
||||
|
|
@ -83,12 +83,12 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
|
|||
}
|
||||
dzhdqFilter = dzhdqFilter.and(zdyqFilter);
|
||||
}
|
||||
logger.info("dzhdqFilter:" + dzhdqFilter);
|
||||
//映射配置过滤条件
|
||||
QFilter getpeizhiqFilter=getpeizhiqFilter(shkd_apimapping);
|
||||
if (getpeizhiqFilter!=null){
|
||||
dzhdqFilter = dzhdqFilter.and(getpeizhiqFilter);
|
||||
}
|
||||
logger.info("dzhdqFilter:" + dzhdqFilter);
|
||||
|
||||
DynamicObject[] bei_elecreceiptids = BusinessDataServiceHelper.load(sourcebillnumber, "id", dzhdqFilter.toArray());
|
||||
logger.info("符合推送条件数据有:{}条", bei_elecreceiptids.length);
|
||||
|
|
@ -251,10 +251,15 @@ public class tsgxApiMappingBillPlugin extends AbstractBillPlugIn {
|
|||
resultMap.put("shkd_response", res);//响应数据
|
||||
resultMap.put("shkd_thirdpartysys", "浪潮");//第三方系统
|
||||
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);
|
||||
if (!tiaoguo) {
|
||||
ApiService.saveThePushLog(resultMap);
|
||||
|
|
|
|||
|
|
@ -66,7 +66,7 @@ public class SharePushTaskPlugin extends AbstractTask {
|
|||
dzhdqFilter = new QFilter("shkd_sfcgtsgx", QCP.equals, false);
|
||||
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("billstatus", QCP.in, Arrays.asList("B", "A")));
|
||||
dzhdqFilter = dzhdqFilter.and(new QFilter("billstatus", QCP.in, Arrays.asList("A")));
|
||||
} else {
|
||||
logger.info("未找到匹配的单据类型");
|
||||
return;
|
||||
|
|
@ -83,13 +83,12 @@ public class SharePushTaskPlugin extends AbstractTask {
|
|||
}
|
||||
dzhdqFilter = dzhdqFilter.and(zdyqFilter);
|
||||
}
|
||||
logger.info("dzhdqFilter:" + dzhdqFilter);
|
||||
|
||||
//映射配置过滤条件
|
||||
QFilter getpeizhiqFilter=getpeizhiqFilter(shkd_apimapping);
|
||||
if (getpeizhiqFilter!=null){
|
||||
dzhdqFilter = dzhdqFilter.and(getpeizhiqFilter);
|
||||
}
|
||||
logger.info("dzhdqFilter:" + dzhdqFilter);
|
||||
|
||||
DynamicObject[] bei_elecreceiptids = BusinessDataServiceHelper.load(sourcebillnumber, "id", dzhdqFilter.toArray());
|
||||
logger.info("符合推送条件数据有:{}条", bei_elecreceiptids.length);
|
||||
|
|
@ -252,9 +251,16 @@ public class SharePushTaskPlugin extends AbstractTask {
|
|||
resultMap.put("shkd_response", res);//响应数据
|
||||
resultMap.put("shkd_thirdpartysys", "浪潮");//第三方系统
|
||||
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);
|
||||
if (!tiaoguo) {
|
||||
ApiService.saveThePushLog(resultMap);
|
||||
|
|
|
|||
Loading…
Reference in New Issue