From 8530ae9da8c1a58700771bdf5b8fc05a8102adc2 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Fri, 25 Jul 2025 11:52:13 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E5=86=85=E5=AE=B9=EF=BC=9A?= =?UTF-8?q?=E6=8E=A8=E9=80=81=E6=98=9F=E7=A9=BA=E7=94=B5=E5=AD=90=E5=9B=9E?= =?UTF-8?q?=E5=8D=95=EF=BC=8C=E5=A2=9E=E5=8A=A0=E4=B8=8A=E5=88=92=E4=B8=8B?= =?UTF-8?q?=E6=8B=A8=E8=81=94=E6=9F=A5=E6=8E=A8=E9=80=81=E9=80=BB=E8=BE=91?= =?UTF-8?q?=20=E6=97=B6=E9=97=B4=EF=BC=9A2025-07-25=2011=EF=BC=9A51=20?= =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BA=BA=EF=BC=9A=E9=82=B9=E6=B1=9F=E6=B6=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../shkd/sys/sys/mservice/ApiService.java | 29 +- .../sys/plugin/form/ApiMappingBillPlugin.java | 49 +++- .../sys/sys/plugin/task/PushTaskPlugin.java | 258 +++++++++++------- 3 files changed, 231 insertions(+), 105 deletions(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/mservice/ApiService.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/mservice/ApiService.java index cffe9e1..d490f1a 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/mservice/ApiService.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/mservice/ApiService.java @@ -1056,18 +1056,23 @@ public class ApiService { /** * 查询星空收付款单（司库推送星空） - * @param dataEntity API映射元数据对象 - * @param billMark 单据类型（收付款） - * @param billNumber 单据编码 + * @param dataEntity API映射元数据对象 + * @param billMark 单据类型（收、付、上划、下拨） + * @param billNumber 单据编码（星瀚单据编码） * @return */ public static HashMap getSKPushXKBill(DynamicObject dataEntity, String billMark, String billNumber) { logger.info("获取推送单据类型 → billMark：{}", billMark); String xkBillType = null; + if ("cas_paybill".equals(billMark)) { - xkBillType = "AP_PAYBILL"; + xkBillType = "AP_PAYBILL";// 表单id（付款处理 → 付款单：AP_PAYBILL） } else if ("cas_recbill".equals(billMark)) { - xkBillType = "AR_RECEIVEBILL"; + xkBillType = "AR_RECEIVEBILL";// 表单id（收款处理 → 收款单：AR_RECEIVEBILL） + } else if ("fca_transupbill".equals(billMark)) { + xkBillType = "AR_RECEIVEBILL";// 表单id（上划处理 → 收款单：AR_RECEIVEBILL） + } else if ("fca_transdownbil".equals(billMark)) { + xkBillType = "AP_PAYBILL";// 表单id（下拨处理 → 付款单：AP_PAYBILL） } HashMap result = new HashMap<>(); @@ -1100,18 +1105,22 @@ public class ApiService { /** * 查询星空收付款单（星空推送司库） - * @param dataEntity API映射元数据对象 - * @param billMark 单据类型（收付款） - * @param billNumber 推送单据编码（星空单据编码） + * @param dataEntity API映射元数据对象 + * @param billMark 单据类型（收、付、上划、下拨） + * @param billNumber 推送单据编码（星空单据编码） * @return */ public static HashMap getXKPushSKBill(DynamicObject dataEntity, String billMark, String billNumber) { logger.info("获取推送单据类型 → billMark：{}", billMark); String xkBillType = null; if ("cas_paybill".equals(billMark)) { - xkBillType = "AP_PAYBILL"; + xkBillType = "AP_PAYBILL";// 表单id（付款处理 → 付款单：AP_PAYBILL） } else if ("cas_recbill".equals(billMark)) { - xkBillType = "AR_RECEIVEBILL"; + xkBillType = "AR_RECEIVEBILL";// 表单id（收款处理 → 收款单：AR_RECEIVEBILL） + } else if ("fca_transupbill".equals(billMark)) { + xkBillType = "AR_RECEIVEBILL";// 表单id（上划处理 → 收款单：AR_RECEIVEBILL） + } else if ("fca_transdownbil".equals(billMark)) { + xkBillType = "AP_PAYBILL";// 表单id（下拨处理 → 付款单：AP_PAYBILL） } HashMap result = new HashMap<>(); diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/ApiMappingBillPlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/ApiMappingBillPlugin.java index 4a333c6..317e129 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/ApiMappingBillPlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/ApiMappingBillPlugin.java @@ -8,6 +8,7 @@ import com.kingdee.bos.webapi.sdk.K3CloudApi; import kd.bos.dataentity.entity.DynamicObject; import kd.bos.dataentity.entity.DynamicObjectCollection; import kd.bos.entity.datamodel.events.PropertyChangedArgs; +import kd.bos.form.IFormView; import kd.bos.form.control.CodeEdit; import kd.bos.form.control.Toolbar; import kd.bos.form.control.events.ItemClickEvent; @@ -17,10 +18,14 @@ import kd.bos.logging.LogFactory; import kd.bos.orm.query.QCP; import kd.bos.orm.query.QFilter; import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.QueryServiceHelper; import kd.bos.servicehelper.operation.SaveServiceHelper; import kd.sdk.plugin.Plugin; +import kd.tmc.fca.common.helper.HandLinkBillHelper; import shkd.sys.sys.mservice.ApiService; +import java.nio.file.Path; +import java.nio.file.Paths; import java.util.*; import static shkd.sys.sys.mservice.ApiService.*; @@ -195,7 +200,7 @@ public class ApiMappingBillPlugin extends AbstractFormPlugin implements Plugin { if (bankTypeArray.contains(bank_name)) { this.getView().showTipNotification("获取符合推送条件的单据：" + dynamicObject.getString("billno")); -// logger.info("获取符合推送条件的单据：{}", dynamicObject.getString("billno")); + // logger.info("获取符合推送条件的单据：{}", dynamicObject.getString("billno")); String result = paymentSlipsJson(dynamicObject, "BIP", dynamicObjectList, null); if (result.contains("成功")) { SaveServiceHelper.save(dynamicObjectList.toArray(new DynamicObject[0])); @@ -205,6 +210,48 @@ public class ApiMappingBillPlugin extends AbstractFormPlugin implements Plugin { } } } + + // 查询上划单的回单编号 + if ("shkd_upbill".equals(itemKey)) { + String shkdSourcenumber = dataEntity.getString("shkd_sourcenumber"); + DynamicObject dynamicObject = BusinessDataServiceHelper.loadSingle("fca_transupbill", "id,billno,name", new QFilter("billno", QCP.equals, shkdSourcenumber).toArray()); + List receiptNos = HandLinkBillHelper.getReceiptNoByDetails(dynamicObject, dynamicObject.getDataEntityType().getName()); + logger.info("上划单回单编号：{}", receiptNos);//电子回单号 + + DynamicObject[] bei_elecreceipts = BusinessDataServiceHelper.load("bei_elecreceipt", "id,receiptno", new QFilter("receiptno", QCP.equals, receiptNos.get(0)).toArray()); + DynamicObject bei_elecreceipt = BusinessDataServiceHelper.loadSingle(bei_elecreceipts[0].getPkValue(), bei_elecreceipts[0].getDynamicObjectType().getName()); + IFormView viewByDynamicObj = createViewByDynamicObj(bei_elecreceipt); + List errMsgList = new ArrayList<>(); + DynamicObjectCollection receipts = QueryServiceHelper.query("bei_elecreceipt", "id,bank," + + "fileflag,filepath,biztype,bankcheckflag,fileserverurl,tcpurl,uploadfilename,username,password," + + "bank.bank_cate bankcate", new QFilter[]{new QFilter("id", QCP.equals, bei_elecreceipt.getPkValue())}); + String pdfUrl = getPdfUrl(viewByDynamicObj.getPageId(), receipts, errMsgList); + + Path path = Paths.get(bei_elecreceipt.getString("filepath")); + String upfileName = path.getFileName().toString(); + this.getView().showTipNotification("上划单回单编号：" + receiptNos.get(0) + "，电子回单查询 → 获取pdf地址：" + pdfUrl); + } + // 查询下拨单的回单编号 + if ("shkd_dowbill".equals(itemKey)) { + String shkdSourcenumber = dataEntity.getString("shkd_sourcenumber"); + // 这个方法可以查询（付款单、收款单、上划单、下拨单关联的回单编号） + DynamicObject dynamicObject = BusinessDataServiceHelper.loadSingle("fca_transdownbill", "id,billno,name", new QFilter("billno", QCP.equals, shkdSourcenumber).toArray()); + List receiptNos = HandLinkBillHelper.getReceiptNoByDetails(dynamicObject, dynamicObject.getDataEntityType().getName()); + logger.info("下拨单回单编号：{}", receiptNos); + + DynamicObject[] bei_elecreceipts = BusinessDataServiceHelper.load("bei_elecreceipt", "id,receiptno", new QFilter("receiptno", QCP.equals, receiptNos.get(0)).toArray()); + DynamicObject bei_elecreceipt = BusinessDataServiceHelper.loadSingle(bei_elecreceipts[0].getPkValue(), bei_elecreceipts[0].getDynamicObjectType().getName()); + IFormView viewByDynamicObj = createViewByDynamicObj(bei_elecreceipt); + List errMsgList = new ArrayList<>(); + DynamicObjectCollection receipts = QueryServiceHelper.query("bei_elecreceipt", "id,bank," + + "fileflag,filepath,biztype,bankcheckflag,fileserverurl,tcpurl,uploadfilename,username,password," + + "bank.bank_cate bankcate", new QFilter[]{new QFilter("id", QCP.equals, bei_elecreceipt.getPkValue())}); + String pdfUrl = getPdfUrl(viewByDynamicObj.getPageId(), receipts, errMsgList); + + Path path = Paths.get(bei_elecreceipt.getString("filepath")); + String upfileName = path.getFileName().toString(); + this.getView().showTipNotification("上划单回单编号：" + receiptNos.get(0) + "，电子回单查询 → 获取pdf地址：" + pdfUrl); + } } private void parseJson(Object obj, int level, String parentKey) { diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/PushTaskPlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/PushTaskPlugin.java index 9677b32..ab60106 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/PushTaskPlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/PushTaskPlugin.java @@ -18,6 +18,7 @@ import kd.bos.servicehelper.BusinessDataServiceHelper; import kd.bos.servicehelper.QueryServiceHelper; import kd.bos.servicehelper.operation.SaveServiceHelper; import kd.sdk.plugin.Plugin; +import kd.tmc.fca.common.helper.HandLinkBillHelper; import shkd.sys.sys.mservice.ApiService; import java.nio.file.Path; @@ -239,6 +240,8 @@ public class PushTaskPlugin extends AbstractTask implements Plugin { case "bei_xkfile": ArrayList paymentObjects = new ArrayList<>(); //所有符合条件存在电子回单的付款单 ArrayList receivableObjects = new ArrayList<>(); //所有符合条件存在电子回单的收款单 + ArrayList TopObjects = new ArrayList<>(); //所有符合条件存在电子回单的上划单 + ArrayList AllocatedObjects = new ArrayList<>(); //所有符合条件存在电子回单的下拨单 HashMap resultMap = null; @@ -253,6 +256,9 @@ public class PushTaskPlugin extends AbstractTask implements Plugin { DynamicObject xkApiMapping = shkd_apimappings[0]; + // 获取k3cloudapi + K3CloudApi k3CloudApi = getK3CloudApi(xkApiMapping); + // 获取多选基础资料业务单元（推送组织） ArrayList orgIds = new ArrayList<>(); DynamicObjectCollection orgsArr = xkApiMapping.getDynamicObjectCollection("shkd_orgs"); @@ -288,58 +294,21 @@ public class PushTaskPlugin extends AbstractTask implements Plugin { } } - // 获取k3cloudapi - K3CloudApi k3CloudApi = getK3CloudApi(xkApiMapping); // 筛选出符合条件的付款单，查询是否有回单，如果有则推送 for (DynamicObject dynamicObject : paymentObjects) { - // 银行收付处理 - DynamicObjectCollection transDetails = QueryServiceHelper.query("bei_transdetail_cas", "id,receredway,debitamount,creditamount,recedbillentry.e_recedbillid", (new QFilter("recedbillentry.e_recedbillid", QCP.equals, dynamicObject.getPkValue())).and(new QFilter("recedbillentry.e_recedbilltype", QCP.equals, "cas_paybill")).toArray()); - if (!transDetails.isEmpty()) { - // 交易明细查询 - DynamicObjectCollection details = QueryServiceHelper.query("bei_transdetail", "id,company,accountbank,currency,matchreceiptentry.e_receiptno receiptno", new QFilter[]{new QFilter("id", QCP.equals, transDetails.get(0).getPkValue())}); - if (!details.isEmpty()) { - // 交易明细查询的电子回单关联标记字段 - if (details.get(0).get("receiptno") != null) { - // 推 - DynamicObject[] dynamicObjects1 = BusinessDataServiceHelper.load("t_bei_elecreceipt", "id,receiptno", new QFilter("receiptno", QCP.equals, details.get(0).getString("receiptno")).toArray()); - DynamicObject dynamicObjectObj = BusinessDataServiceHelper.loadSingle(dynamicObjects1[0].getPkValue(), dynamicObjects1[0].getDynamicObjectType().getName()); - IFormView viewByDynamicObj = createViewByDynamicObj(dynamicObjectObj); - List errMsgList = new ArrayList<>(); - DynamicObjectCollection receipts = QueryServiceHelper.query("bei_elecreceipt", "id,bank," + - "fileflag,filepath,biztype,bankcheckflag,fileserverurl,tcpurl,uploadfilename,username,password," + - "bank.bank_cate bankcate", new QFilter[]{new QFilter("id", QCP.equals, dynamicObject.getPkValue())}); - String pdfUrl = getPdfUrl(viewByDynamicObj.getPageId(), receipts, errMsgList); - Path path = Paths.get(dynamicObject.getString("filepath")); - String upfileName = path.getFileName().toString(); - logger.info("付款单：{}，电子回单查询 → 电子回单附件推送接口 → 获取pdf地址：{}", dynamicObject.getString("billno"), pdfUrl); - - JSONObject jsonObject = new JSONObject(); - jsonObject.put("FileName", upfileName);// 文件名 - jsonObject.put("FormId", "AP_PAYBILL");// 表单id（付款单：AP_PAYBILL） - jsonObject.put("IsLast", true);// 是否最后一次上传 - jsonObject.put("InterId", resultMap.get("billId"));// 单据内码 - jsonObject.put("BillNO", resultMap.get("billNumber"));// 单据编码 - jsonObject.put("AliasFileName", upfileName);// 附件别名 - jsonObject.put("SendByte", attachmentBase64(pdfUrl));// 文件字节数组转base64后的字符串 - - String uploadAttachmentResult; - try { - uploadAttachmentResult = k3CloudApi.attachmentUpload(jsonObject.toString()); - JSONObject resultJson = JSON.parseObject(uploadAttachmentResult); - JSONObject Result = resultJson.getJSONObject("Result"); - JSONObject ResponseStatus = Result.getJSONObject("ResponseStatus"); - Boolean isSuccess = ResponseStatus.getBoolean("IsSuccess"); - if (isSuccess) { - dynamicObject.set("shkd_xkfilestatus", "已推送"); - logger.info("付款处理 → 电子回单推送星空，单据编码：" + dynamicObject.getString("billno") + "\n附件上传结果：" + uploadAttachmentResult); - SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); - } - } catch (Exception e) { - throw new RuntimeException(e); - } - } - } + List receiptNos = HandLinkBillHelper.getReceiptNoByDetails(dynamicObject, dynamicObject.getDataEntityType().getName()); + if (receiptNos.isEmpty()) { + logger.info("付款单：{}，无回单", dynamicObject.getString("billno")); + }else { + Map receiptResult = new HashMap<>(); + // 获取回单 + getReceipt(receiptNos.get(0), receiptResult); + String pdfUrl = receiptResult.get("pdfUrl").toString(); + String fileName = receiptResult.get("fileName").toString(); + logger.info("付款单：{}，电子回单查询 → 电子回单附件推送接口 → 获取pdf地址：{}", dynamicObject.getString("billno"), pdfUrl); + // 推送星空附件 + pushXkAttachment(dynamicObject, pdfUrl, fileName, resultMap, k3CloudApi); } } @@ -363,54 +332,83 @@ public class PushTaskPlugin extends AbstractTask implements Plugin { } for (DynamicObject dynamicObject : receivableObjects) { - // 银行收付处理 - DynamicObjectCollection transDetails = QueryServiceHelper.query("bei_transdetail_cas", "id,receredway,debitamount,creditamount,recedbillentry.e_recedbillid", (new QFilter("recedbillentry.e_recedbillid", QCP.equals, dynamicObject.getPkValue())).and(new QFilter("recedbillentry.e_recedbilltype", QCP.equals, "cas_recbill")).toArray()); - if (!transDetails.isEmpty()) { - // 交易明细查询 - DynamicObjectCollection details = QueryServiceHelper.query("bei_transdetail", "id,company,accountbank,currency,matchreceiptentry.e_receiptno receiptno", new QFilter[]{new QFilter("id", QCP.equals, transDetails.get(0).getPkValue())}); - if (!details.isEmpty()) { - // 交易明细查询的电子回单关联标记字段 - if (details.get(0).get("receiptno") != null) { - // 推 - DynamicObject[] dynamicObjects1 = BusinessDataServiceHelper.load("t_bei_elecreceipt", "id,receiptno", new QFilter("receiptno", QCP.equals, details.get(0).getString("receiptno")).toArray()); - DynamicObject dynamicObjectObj = BusinessDataServiceHelper.loadSingle(dynamicObjects1[0].getPkValue(), dynamicObjects1[0].getDynamicObjectType().getName()); - IFormView viewByDynamicObj = createViewByDynamicObj(dynamicObjectObj); - List errMsgList = new ArrayList<>(); - DynamicObjectCollection receipts = QueryServiceHelper.query("bei_elecreceipt", "id,bank," + - "fileflag,filepath,biztype,bankcheckflag,fileserverurl,tcpurl,uploadfilename,username,password," + - "bank.bank_cate bankcate", new QFilter[]{new QFilter("id", QCP.equals, dynamicObject.getPkValue())}); - String pdfUrl = getPdfUrl(viewByDynamicObj.getPageId(), receipts, errMsgList); - Path path = Paths.get(dynamicObject.getString("filepath")); - String upfileName = path.getFileName().toString(); - logger.info("收款单：{}，电子回单查询 → 电子回单附件推送接口 → 获取pdf地址：{}", dynamicObject.getString("billno"), pdfUrl); + List receiptNos = HandLinkBillHelper.getReceiptNoByDetails(dynamicObject, dynamicObject.getDataEntityType().getName()); + if (receiptNos.isEmpty()) { + logger.info("收款单：{}，无匹配回单", dynamicObject.getString("billno")); + }else { + Map receiptResult = new HashMap<>(); + // 获取回单 + getReceipt(receiptNos.get(0), receiptResult); + String pdfUrl = receiptResult.get("pdfUrl").toString(); + String fileName = receiptResult.get("fileName").toString(); + logger.info("收款单：{}，电子回单查询 → 电子回单附件推送接口 → 获取pdf地址：{}", dynamicObject.getString("billno"), pdfUrl); + // 推送星空附件 + pushXkAttachment(dynamicObject, pdfUrl, fileName, resultMap, k3CloudApi); + } + } - JSONObject jsonObject = new JSONObject(); - jsonObject.put("FileName", upfileName);// 文件名 - jsonObject.put("FormId", "AR_RECEIVEBILL");// 表单id（收款单：AR_RECEIVEBILL） - jsonObject.put("IsLast", true);// 是否最后一次上传 - jsonObject.put("InterId", resultMap.get("billId"));// 单据内码 - jsonObject.put("BillNO", resultMap.get("billNumber"));// 单据编码 - jsonObject.put("AliasFileName", upfileName);// 附件别名 - jsonObject.put("SendByte", attachmentBase64(pdfUrl));// 文件字节数组转base64后的字符串 + // 上划处理 + DynamicObject[] objects7 = BusinessDataServiceHelper.load("fca_transupbill", + "id,billno,shkd_pushxknumber,shkd_xkfilestatus,company", + new QFilter("shkd_pushxknumber", QCP.not_equals, "") + .and("shkd_xkfilestatus", QCP.not_equals, "已推送") + .and("company", QCP.equals, "").toArray()); - String uploadAttachmentResult; - try { - uploadAttachmentResult = k3CloudApi.attachmentUpload(jsonObject.toString()); + for (DynamicObject dynamicObject : objects7) { + // 只有司库推送星空业务 + resultMap = getSKPushXKBill(xkApiMapping, dynamicObject.getDataEntityType().getName(), dynamicObject.getString("billno")); + if ((boolean) resultMap.get("result")) { + TopObjects.add(dynamicObject); + logger.info("上划处理：{}，为司库推送星空单据，星空单据编码：{}", dynamicObject.getString("billno"), resultMap.get("billNumber")); + } + } - JSONObject resultJson = JSON.parseObject(uploadAttachmentResult); - JSONObject Result = resultJson.getJSONObject("Result"); - JSONObject ResponseStatus = Result.getJSONObject("ResponseStatus"); - Boolean isSuccess = ResponseStatus.getBoolean("IsSuccess"); - if (isSuccess) { - dynamicObject.set("shkd_xkfilestatus", "已推送"); - logger.info("收款处理 → 电子回单推送星空，单据编码：" + dynamicObject.getString("billno") + "\n附件上传结果：" + uploadAttachmentResult); - SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); - } - } catch (Exception e) { - throw new RuntimeException(e); - } - } - } + for (DynamicObject dynamicObject : TopObjects) { + List receiptNos = HandLinkBillHelper.getReceiptNoByDetails(dynamicObject, dynamicObject.getDataEntityType().getName()); + if (receiptNos.isEmpty()) { + logger.info("上划处理：{}，无匹配回单", dynamicObject.getString("billno")); + }else { + Map receiptResult = new HashMap<>(); + // 获取回单 + getReceipt(receiptNos.get(0), receiptResult); + String pdfUrl = receiptResult.get("pdfUrl").toString(); + String fileName = receiptResult.get("fileName").toString(); + logger.info("上划处理：{}，电子回单查询 → 电子回单附件推送接口 → 获取pdf地址：{}", dynamicObject.getString("billno"), pdfUrl); + // 推送星空附件 + pushXkAttachment(dynamicObject, pdfUrl, fileName, resultMap, k3CloudApi); + } + } + + + // 下拨处理 + DynamicObject[] objects8 = BusinessDataServiceHelper.load("fca_transdownbil", + "id,billno,shkd_pushxknumber,shkd_xkfilestatus,company", + new QFilter("shkd_pushxknumber", QCP.not_equals, "") + .and("shkd_xkfilestatus", QCP.not_equals, "已推送") + .and("company", QCP.equals, "").toArray()); + + for (DynamicObject dynamicObject : objects8) { + // 只有司库推送星空业务 + resultMap = getSKPushXKBill(xkApiMapping, dynamicObject.getDataEntityType().getName(), dynamicObject.getString("billno")); + if ((boolean) resultMap.get("result")) { + AllocatedObjects.add(dynamicObject); + logger.info("下拨处理：{}，为司库推送星空单据，星空单据编码：{}", dynamicObject.getString("billno"), resultMap.get("billNumber")); + } + } + + for (DynamicObject dynamicObject : AllocatedObjects) { + List receiptNos = HandLinkBillHelper.getReceiptNoByDetails(dynamicObject, dynamicObject.getDataEntityType().getName()); + if (receiptNos.isEmpty()) { + logger.info("下拨处理：{}，无匹配回单", dynamicObject.getString("billno")); + }else { + Map receiptResult = new HashMap<>(); + // 获取回单 + getReceipt(receiptNos.get(0), receiptResult); + String pdfUrl = receiptResult.get("pdfUrl").toString(); + String fileName = receiptResult.get("fileName").toString(); + logger.info("下拨处理：{}，电子回单查询 → 电子回单附件推送接口 → 获取pdf地址：{}", dynamicObject.getString("billno"), pdfUrl); + // 推送星空附件 + pushXkAttachment(dynamicObject, pdfUrl, fileName, resultMap, k3CloudApi); } } break; @@ -475,4 +473,76 @@ public class PushTaskPlugin extends AbstractTask implements Plugin { return Date.from(firstDayOfMonth.atStartOfDay(DEFAULT_ZONE).toInstant()); } } + + + /** + * 获取付款单、收款单、上划单、下拨单关联的回单附件地址 + * + * @param receiptNo 回单编号 + * @param resultMap 回单信息 + * @return + */ + private static void getReceipt(String receiptNo, Map resultMap) { + DynamicObject[] bei_elecreceipts = BusinessDataServiceHelper.load("bei_elecreceipt", "id,receiptno", new QFilter("receiptno", QCP.equals, receiptNo).toArray()); + DynamicObject bei_elecreceipt = BusinessDataServiceHelper.loadSingle(bei_elecreceipts[0].getPkValue(), bei_elecreceipts[0].getDynamicObjectType().getName()); + IFormView viewByDynamicObj = createViewByDynamicObj(bei_elecreceipt); + List errMsgList = new ArrayList<>(); + DynamicObjectCollection receipts = QueryServiceHelper.query("bei_elecreceipt", "id,bank," + + "fileflag,filepath,biztype,bankcheckflag,fileserverurl,tcpurl,uploadfilename,username,password," + + "bank.bank_cate bankcate", new QFilter[]{new QFilter("id", QCP.equals, bei_elecreceipt.getPkValue())}); + String pdfUrl = getPdfUrl(viewByDynamicObj.getPageId(), receipts, errMsgList); + + Path path = Paths.get(bei_elecreceipt.getString("filepath")); + String upfileName = path.getFileName().toString(); + resultMap.put("pdfUrl", pdfUrl); + resultMap.put("fileName", upfileName); + } + + /** + * 推送星空回单附件 + * + * @param dynamicObject 星瀚单据 + * @param pdfUrl 星瀚回单附件地址 + * @param fileName 星瀚回单附件名称 + * @param resultMap 查询星空单据结果（编码，id） + * @param k3CloudApi 星瀚接口访问实例对象 + * @return + */ + private static void pushXkAttachment(DynamicObject dynamicObject, String pdfUrl, String fileName, Map resultMap, K3CloudApi k3CloudApi) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("FileName", fileName);// 文件名 + + String entityName = dynamicObject.getDataEntityType().getName(); + if ("cas_paybill".equals(entityName)) { + jsonObject.put("FormId", "AP_PAYBILL");// 表单id（付款处理 → 付款单：AP_PAYBILL） + } else if ("cas_recbill".equals(entityName)) { + jsonObject.put("FormId", "AR_RECEIVEBILL");// 表单id（收款处理 → 收款单：AR_RECEIVEBILL） + } else if ("fca_transupbill".equals(entityName)) { + jsonObject.put("FormId", "AR_RECEIVEBILL");// 表单id（上划处理 → 收款单：AR_RECEIVEBILL） + } else if ("fca_transdownbil".equals(entityName)) { + jsonObject.put("FormId", "AP_PAYBILL");// 表单id（下拨处理 → 付款单：AP_PAYBILL） + } + + jsonObject.put("IsLast", true);// 是否最后一次上传 + jsonObject.put("InterId", resultMap.get("billId"));// 单据内码 + jsonObject.put("BillNO", resultMap.get("billNumber"));// 单据编码 + jsonObject.put("AliasFileName", fileName);// 附件别名 + jsonObject.put("SendByte", attachmentBase64(pdfUrl));// 文件字节数组转base64后的字符串 + + String uploadAttachmentResult; + try { + uploadAttachmentResult = k3CloudApi.attachmentUpload(jsonObject.toString()); + JSONObject resultJson = JSON.parseObject(uploadAttachmentResult); + JSONObject Result = resultJson.getJSONObject("Result"); + JSONObject ResponseStatus = Result.getJSONObject("ResponseStatus"); + Boolean isSuccess = ResponseStatus.getBoolean("IsSuccess"); + if (isSuccess) { + dynamicObject.set("shkd_xkfilestatus", "已推送"); + logger.info(entityName + " → 电子回单推送星空，单据编码：" + dynamicObject.getString("billno") + "\n附件上传结果：" + uploadAttachmentResult); + SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); + } + } catch (Exception e) { + throw new RuntimeException(e); + } + } } \ No newline at end of file