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

提交内容：推送BIP电子回单整体代码优化 

时间：2025-07-31 16：57
提交人：邹江涛
This commit is contained in:
zoujiangtao 2025-07-31 16:57:12 +08:00
parent 0f4aeb3b82
commit d4d17935a9
2 changed files with 49 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/ApiMappingBillPlugin.java
View File

@ -259,20 +259,30 @@ public class ApiMappingBillPlugin extends AbstractFormPlugin implements Plugin {
String bank_number = bank.getString("number"); String bank_number = bank.getString("number");
DynamicObject[] bd_finorginfo = BusinessDataServiceHelper.load("bd_finorginfo", "id,number,bank_cate", new QFilter("number", QCP.equals, bank_number).toArray()); DynamicObject[] bd_finorginfo = BusinessDataServiceHelper.load("bd_finorginfo", "id,number,bank_cate", new QFilter("number", QCP.equals, bank_number).toArray());
if (bd_finorginfo == null || bd_finorginfo.length == 0) {
//银行类别 logger.info("回单：{}，合作金融机构为空，不推送！", dynamicObject.getString("billno"));
DynamicObject bank_cate = bd_finorginfo[0].getDynamicObject("bank_cate"); } else {
//银行类别
String bank_name = bank_cate.getString("name"); DynamicObject bank_cate = bd_finorginfo[0].getDynamicObject("bank_cate");
if (bank_cate == null) {
if (bankTypeArray.contains(bank_name)) { logger.info("回单：{}，银行类别为空，不推送！", dynamicObject.getString("billno"));
// logger.info("获取符合推送条件的单据：{}", dynamicObject.getString("billno")); }else {
String result = paymentSlipsJson(dynamicObject, "BIP", dynamicObjectList, null); Object bank_name = bank_cate.get("name");
if (result.contains("成功")) { if (bank_name == null || "".equals(bank_name.toString())) {
dynamicObject.set("shkd_pushstatus", "已推送"); logger.info("回单：{}，银行类别为空，不推送！", dynamicObject.getString("billno"));
dynamicObject.set("shkd_businessname", "共享系统"); }else {
SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); logger.info("回单：{}，银行类别：{}", dynamicObject.getString("billno"), bank_name);
logger.info("电子回单推送BIP成功，单据编码：" + dynamicObject.getString("billno")); if (bankTypeArray.contains(bank_name.toString())) {
// logger.info("获取符合推送条件的单据：{}", dynamicObject.getString("billno"));
String result = paymentSlipsJson(dynamicObject, "BIP", dynamicObjectList, null);
if (result.contains("成功")) {
dynamicObject.set("shkd_pushstatus", "已推送");
dynamicObject.set("shkd_businessname", "共享系统");
SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
logger.info("电子回单推送BIP成功，单据编码：" + dynamicObject.getString("billno"));
}
}
}
} }
} }
} }

40
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/PushTaskPlugin.java
View File

@ -208,7 +208,7 @@ public class PushTaskPlugin extends AbstractTask implements Plugin {
.and("shkd_pushstatus", QCP.not_equals, "已推送") .and("shkd_pushstatus", QCP.not_equals, "已推送")
.and("company", QCP.in, orgArray).toArray()); .and("company", QCP.in, orgArray).toArray());
logger.info("符合推送条件数据有：{}条", elecreceiptArays.length); logger.info("符合推送条件数据有：{}条", elecreceiptArays.length);
Arrays.stream(elecreceiptArays).forEach(dynamicObject -> { for (DynamicObject dynamicObject : elecreceiptArays) {
//开户银行（银行账户） //开户银行（银行账户）
DynamicObject accountbank = dynamicObject.getDynamicObject("accountbank"); DynamicObject accountbank = dynamicObject.getDynamicObject("accountbank");
@ -218,22 +218,32 @@ public class PushTaskPlugin extends AbstractTask implements Plugin {
String bank_number = bank.getString("number"); String bank_number = bank.getString("number");
DynamicObject[] bd_finorginfo = BusinessDataServiceHelper.load("bd_finorginfo", "id,number,bank_cate", new QFilter("number", QCP.equals, bank_number).toArray()); DynamicObject[] bd_finorginfo = BusinessDataServiceHelper.load("bd_finorginfo", "id,number,bank_cate", new QFilter("number", QCP.equals, bank_number).toArray());
//银行类别 if (bd_finorginfo == null || bd_finorginfo.length == 0) {
DynamicObject bank_cate = bd_finorginfo[0].getDynamicObject("bank_cate"); logger.info("回单：{}，合作金融机构为空，不推送！", dynamicObject.getString("billno"));
} else {
String bank_name = bank_cate.getString("name"); //银行类别
logger.info("回单：{}，银行类别：{}", dynamicObject.getString("billno"), bank_name); DynamicObject bank_cate = bd_finorginfo[0].getDynamicObject("bank_cate");
if (bank_cate == null) {
if (bankTypeArray.contains(bank_name)) { logger.info("回单：{}，银行类别为空，不推送！", dynamicObject.getString("billno"));
String result = paymentSlipsJson(dynamicObject, "BIP", dynamicObjectList, null); }else{
if (result.contains("成功")) { Object bank_name = bank_cate.get("name");
dynamicObject.set("shkd_pushstatus", "已推送"); if (bank_name == null) {
dynamicObject.set("shkd_businessname", "共享系统"); logger.info("回单：{}，银行类别为空，不推送！", dynamicObject.getString("billno"));
SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); }else {
logger.info("电子回单推送BIP成功，单据编码：" + dynamicObject.getString("billno")); logger.info("回单：{}，银行类别：{}", dynamicObject.getString("billno"), bank_name);
if (bankTypeArray.contains(bank_name.toString())) {
String result = paymentSlipsJson(dynamicObject, "BIP", dynamicObjectList, null);
if (result.contains("成功")) {
dynamicObject.set("shkd_pushstatus", "已推送");
dynamicObject.set("shkd_businessname", "共享系统");
SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
logger.info("电子回单推送BIP成功，单据编码：" + dynamicObject.getString("billno"));
}
}
}
} }
} }
}); }
break; break;
/** /**
* 推送星空电子回单 * 推送星空电子回单