diff --git a/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/InterestAccrualGenPaymentOperationPlugin.java b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/InterestAccrualGenPaymentOperationPlugin.java index cbb02f7..cd114f2 100644 --- a/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/InterestAccrualGenPaymentOperationPlugin.java +++ b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/InterestAccrualGenPaymentOperationPlugin.java @@ -11,7 +11,6 @@ import kd.bos.entity.operate.result.OperationResult; import kd.bos.entity.plugin.AbstractOperationServicePlugIn; import kd.bos.entity.plugin.AddValidatorsEventArgs; import kd.bos.entity.plugin.PreparePropertysEventArgs; -import kd.bos.entity.plugin.args.BeforeOperationArgs; import kd.bos.entity.plugin.args.BeginOperationTransactionArgs; import kd.bos.entity.validate.AbstractValidator; import kd.bos.i18n.mservice.I18nServiceHelper; @@ -87,6 +86,7 @@ public class InterestAccrualGenPaymentOperationPlugin extends AbstractOperationS @Override public void validate() { ExtendedDataEntity[] extBills = this.getDataEntities(); + StringBuilder logInfo = new StringBuilder(); for (ExtendedDataEntity extBill : extBills) { DynamicObject bill = extBill.getDataEntity(); @@ -146,7 +146,7 @@ public class InterestAccrualGenPaymentOperationPlugin extends AbstractOperationS writeLkInfo(bill,selectRows,result.getSuccessPkIds().get(0)); }else { StringBuilder str = new StringBuilder(); - str.append("------计息单:"+billNo).append("生成付款单失败。"); + str.append("------计息单:").append(billNo).append("生成付款单失败。"); List allErrorOrValidateInfo = result.getAllErrorOrValidateInfo(); if (allErrorOrValidateInfo != null){ str.append("message：\n"); diff --git a/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillCancelTicketOperationPlugin.java b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillCancelTicketOperationPlugin.java new file mode 100644 index 0000000..143dbbc --- /dev/null +++ b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillCancelTicketOperationPlugin.java @@ -0,0 +1,78 @@ +package kdsz.zyf25.tmc.cfm.plugin.operate; + +import kd.bos.entity.plugin.AbstractOperationServicePlugIn; +import kd.bos.entity.plugin.PreparePropertysEventArgs; +import kd.bos.entity.plugin.args.AfterOperationArgs; +import kd.sdk.plugin.Plugin; + +/** + * * 付款单-开票申请-开票登记 路径的开票登记 取消出票插件 + */ +public class PayableBillCancelTicketOperationPlugin extends AbstractOperationServicePlugIn implements Plugin { + @Override + public void onPreparePropertys(PreparePropertysEventArgs e) { + super.onPreparePropertys(e); + e.getFieldKeys().add("releatedcasbillentrys.rel_billid"); + } + + @Override + public void afterExecuteOperationTransaction(AfterOperationArgs e) { + super.afterExecuteOperationTransaction(e); +// DynamicObject[] bills = e.getDataEntities(); +// for (DynamicObject bill : bills) { +// Map> srcBillMap = BFTrackerServiceHelper.findSourceBills("cdm_payablebill", +// new Long[]{bill.getLong("id")}); +// //srcBillMap<单据标识，单据id>，只有上游有开票申请的才处理 +// if (!srcBillMap.containsKey("cdm_payablebill_ap_manual")){ +// continue; +// } +// HashSet payBillIds = srcBillMap.get("cas_paybill"); +// if (payBillIds == null || payBillIds.size() == 0){ +// continue; +// } +// DynamicObjectCollection relationEntries = bill.getDynamicObjectCollection("releatedcasbillentrys"); +// HashSet payBillIdSet = new HashSet<>(); +// for (DynamicObject relationEntry : relationEntries) { +// Long payBillId = relationEntry.getLong("rel_billid"); +// payBillIdSet.add(payBillId); +// } +// Long targetBillId = bill.getLong("id"); +// DynamicObject[] payBills = BusinessDataServiceHelper.load("cas_paybill", +// "billstatus,draftbill,cas_draftinfo.draftbillinfo", +// new QFilter[]{new QFilter("id", QCP.in, payBillIdSet)}); +// for (DynamicObject payBill : payBills) { +// payBill.set("billstatus", "J");//单据状态：票据处理中 +// DynamicObjectCollection draftBills = payBill.getDynamicObjectCollection("draftbill");//结算号 +// if (draftBills != null){ +// Iterator payIterator = draftBills.iterator(); +// while (payIterator.hasNext()){ +// DynamicObject draftBill = payIterator.next(); +// if(draftBill != null){ +// Long draftBillId = draftBill.getLong("id"); +// if (draftBillId.equals(targetBillId)){ +// payIterator.remove(); +// } +// } +// } +// } +// DynamicObjectCollection draftInfoEntries = payBill.getDynamicObjectCollection("cas_draftinfo"); +// if (draftInfoEntries != null){ +// Iterator draftInfoIterator = draftInfoEntries.iterator(); +// while (draftInfoIterator.hasNext()){ +// DynamicObject draftInfo = draftInfoIterator.next(); +// DynamicObject draftBillInfo = draftInfo.getDynamicObject("draftbillinfo"); +// if (draftBillInfo == null)continue; +// Long draftBillId = draftBillInfo.getLong("id"); +// if (draftBillId.equals(targetBillId)){ +// draftInfoIterator.remove(); +// } +// } +// } +// } +// SaveServiceHelper.save(payBills); +// //开票登记清空关联收付款单分录 +// relationEntries.clear(); +// } +// SaveServiceHelper.save(bills); + } +} \ No newline at end of file diff --git a/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillDeleteOperationPlugin.java b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillDeleteOperationPlugin.java new file mode 100644 index 0000000..dc751e1 --- /dev/null +++ b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillDeleteOperationPlugin.java @@ -0,0 +1,43 @@ +package kdsz.zyf25.tmc.cfm.plugin.operate; + +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.entity.plugin.AbstractOperationServicePlugIn; +import kd.bos.entity.plugin.args.BeginOperationTransactionArgs; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.botp.BFTrackerServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import kd.sdk.plugin.Plugin; + +import java.util.HashSet; +import java.util.Map; + +/** + * 付款单-开票申请-开票登记 路径的开票登记 删除插件 反写付款单单据状态 + */ +public class PayableBillDeleteOperationPlugin extends AbstractOperationServicePlugIn implements Plugin { + @Override + public void beginOperationTransaction(BeginOperationTransactionArgs e) { + super.beginOperationTransaction(e); + DynamicObject[] bills = e.getDataEntities(); + for (DynamicObject bill : bills) { + Map> srcBillMap = BFTrackerServiceHelper.findSourceBills("cdm_payablebill", + new Long[]{bill.getLong("id")}); + //srcBillMap<单据标识，单据id>，只有上游有开票申请的才处理 + if (!srcBillMap.containsKey("cdm_payablebill_ap_manual")){ + continue; + } + HashSet payBillIds = srcBillMap.get("cas_paybill"); + if (payBillIds == null || payBillIds.size() == 0){ + continue; + } + DynamicObject[] payBills = BusinessDataServiceHelper.load("cas_paybill", "billstatus", + new QFilter[]{new QFilter("id", QCP.in, payBillIds)}); + for (DynamicObject payBill : payBills) { + payBill.set("billstatus","C");//单据状态改为：已审核 + } + SaveServiceHelper.update(payBills); + } + } +} \ No newline at end of file diff --git a/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillSaveOperationPlugin.java b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillSaveOperationPlugin.java new file mode 100644 index 0000000..e584df1 --- /dev/null +++ b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillSaveOperationPlugin.java @@ -0,0 +1,43 @@ +package kdsz.zyf25.tmc.cfm.plugin.operate; + +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.entity.plugin.AbstractOperationServicePlugIn; +import kd.bos.entity.plugin.args.EndOperationTransactionArgs; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.botp.BFTrackerServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import kd.sdk.plugin.Plugin; + +import java.util.HashSet; +import java.util.Map; + +/** + * 付款单-开票申请-开票登记 路径的开票登记 保存插件 反写付款单单据状态 + */ +public class PayableBillSaveOperationPlugin extends AbstractOperationServicePlugIn implements Plugin { + @Override + public void endOperationTransaction(EndOperationTransactionArgs e) { + super.endOperationTransaction(e); + DynamicObject[] bills = e.getDataEntities(); + for (DynamicObject bill : bills) { + Map> srcBillMap = BFTrackerServiceHelper.findSourceBills("cdm_payablebill", + new Long[]{bill.getLong("id")}); + //srcBillMap<单据标识，单据id>，只有上游有开票申请的才处理 + if (!srcBillMap.containsKey("cdm_payablebill_ap_manual")){ + continue; + } + HashSet payBillIds = srcBillMap.get("cas_paybill"); + if (payBillIds == null || payBillIds.size() == 0){ + continue; + } + DynamicObject[] payBills = BusinessDataServiceHelper.load("cas_paybill", "billstatus", + new QFilter[]{new QFilter("id", QCP.in, payBillIds)}); + for (DynamicObject payBill : payBills) { + payBill.set("billstatus","J");//单据状态改为：票据处理中 + } + SaveServiceHelper.update(payBills); + } + } +} \ No newline at end of file diff --git a/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillSureTicketOperationPlugin.java b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillSureTicketOperationPlugin.java new file mode 100644 index 0000000..131452b --- /dev/null +++ b/code/tmc/kdsz-zyf25-tmc-cfm/src/main/java/kdsz/zyf25/tmc/cfm/plugin/operate/PayableBillSureTicketOperationPlugin.java @@ -0,0 +1,136 @@ +package kdsz.zyf25.tmc.cfm.plugin.operate; + +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.entity.plugin.AbstractOperationServicePlugIn; +import kd.bos.entity.plugin.PreparePropertysEventArgs; +import kd.bos.entity.plugin.args.AfterOperationArgs; +import kd.bos.entity.plugin.args.EndOperationTransactionArgs; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.botp.BFTrackerServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import kd.sdk.plugin.Plugin; + +import java.util.Date; +import java.util.HashSet; +import java.util.Map; + +/** + * 付款单-开票申请-开票登记 路径的开票登记确认出票插件 + */ +public class PayableBillSureTicketOperationPlugin extends AbstractOperationServicePlugIn implements Plugin { + @Override + public void onPreparePropertys(PreparePropertysEventArgs e) { + super.onPreparePropertys(e); + e.getFieldKeys().add("releatedcasbillentrys.seq"); + e.getFieldKeys().add("releatedcasbillentrys.rel_billtype"); + e.getFieldKeys().add("releatedcasbillentrys.rel_billno"); + e.getFieldKeys().add("releatedcasbillentrys.rel_billid"); + e.getFieldKeys().add("releatedcasbillentrys.rel_bizdate"); + e.getFieldKeys().add("releatedcasbillentrys.rel_billamount"); + e.getFieldKeys().add("releatedcasbillentrys.rel_createtime"); + e.getFieldKeys().add("releatedcasbillentrys.rel_modifytime"); + e.getFieldKeys().add("releatedcasbillentrys.rel_isrefuse"); + e.getFieldKeys().add("releatedcasbillentrys.rel_batchuseflag"); + } + + @Override + public void afterExecuteOperationTransaction(AfterOperationArgs e) { + super.afterExecuteOperationTransaction(e); +// DynamicObject[] bills = e.getDataEntities(); +// for (DynamicObject bill : bills) { +// Map> srcBillMap = BFTrackerServiceHelper.findSourceBills("cdm_payablebill", +// new Long[]{bill.getLong("id")}); +// //srcBillMap<单据标识，单据id>，只有上游有开票申请的才处理 +// if (!srcBillMap.containsKey("cdm_payablebill_ap_manual")){ +// continue; +// } +// HashSet payBillIds = srcBillMap.get("cas_paybill"); +// if (payBillIds == null || payBillIds.size() == 0){ +// continue; +// } +// DynamicObjectCollection relationEntries = bill.getDynamicObjectCollection("releatedcasbillentrys"); +// DynamicObject[] payBills = BusinessDataServiceHelper.load("cas_paybill", +// "billno,bizdate,actpayamt,billstatus,draftbill,cas_draftinfo.seq,cas_draftinfo.transamount,cas_draftinfo.paybillcurrency,cas_draftinfo.draftbillinfo", +// new QFilter[]{new QFilter("id", QCP.in, payBillIds)}); +// for (int i = 0; i < payBills.length; i++) { +// //将付款信息写入开票登记 +// DynamicObject relationEntry = relationEntries.addNew(); +// relationEntry.set("seq", i); +// relationEntry.set("rel_billtype", "cas_paybill"); +// relationEntry.set("rel_billno", payBills[i].getString("billno")); +// relationEntry.set("rel_billid", payBills[i].getLong("id")); +// relationEntry.set("rel_bizdate", payBills[i].getDate("bizdate")); +// relationEntry.set("rel_billamount", payBills[i].getBigDecimal("actpayamt")); +// relationEntry.set("rel_createtime", new Date()); +// relationEntry.set("rel_modifytime", new Date()); +// relationEntry.set("rel_isrefuse", false); +// //票据信息反写付款单 +// DynamicObjectCollection draftBills = payBills[i].getDynamicObjectCollection("draftbill"); +// draftBills.addNew().set("fbasedataid",bill);//结算号 +// payBills[i].set("billstatus","D");//单据状态改为：已付款 +//// payBills[i].set("draftbill", draftBills); +// DynamicObjectCollection draftInfo = payBills[i].getDynamicObjectCollection("cas_draftinfo"); +// int draftInfoSize = draftInfo.size(); +// DynamicObject draftInfoDetail = draftInfo.addNew(); +// draftInfoDetail.set("seq", draftInfoSize); +// draftInfoDetail.set("transamount",bill.getBigDecimal("amount")); +// draftInfoDetail.set("paybillcurrency", bill.getDynamicObject("currency")); +// draftInfoDetail.set("draftbillinfo", bill); +// } +// SaveServiceHelper.save(payBills); +// } +// SaveServiceHelper.save(bills); + } + + @Override + public void endOperationTransaction(EndOperationTransactionArgs e) { + super.endOperationTransaction(e); + DynamicObject[] bills = e.getDataEntities(); + for (DynamicObject bill : bills) { + Map> srcBillMap = BFTrackerServiceHelper.findSourceBills("cdm_payablebill", + new Long[]{bill.getLong("id")}); + //srcBillMap<单据标识，单据id>，只有上游有开票申请的才处理 + if (!srcBillMap.containsKey("cdm_payablebill_ap_manual")){ + continue; + } + HashSet payBillIds = srcBillMap.get("cas_paybill"); + if (payBillIds == null || payBillIds.size() == 0){ + continue; + } + DynamicObjectCollection relationEntries = bill.getDynamicObjectCollection("releatedcasbillentrys"); + DynamicObject[] payBills = BusinessDataServiceHelper.load("cas_paybill", + "billno,bizdate,actpayamt,billstatus,draftbill,cas_draftinfo.seq,cas_draftinfo.transamount,cas_draftinfo.paybillcurrency,cas_draftinfo.draftbillinfo", + new QFilter[]{new QFilter("id", QCP.in, payBillIds)}); + for (int i = 0; i < payBills.length; i++) { + //将付款信息写入开票登记 + DynamicObject relationEntry = relationEntries.addNew(); + relationEntry.set("seq", i); + relationEntry.set("rel_billtype", "cas_paybill"); + relationEntry.set("rel_billno", payBills[i].getString("billno")); + relationEntry.set("rel_billid", payBills[i].getLong("id")); + relationEntry.set("rel_bizdate", payBills[i].getDate("bizdate")); + relationEntry.set("rel_billamount", payBills[i].getBigDecimal("actpayamt")); + relationEntry.set("rel_createtime", new Date()); + relationEntry.set("rel_modifytime", new Date()); + relationEntry.set("rel_isrefuse", false); + //票据信息反写付款单 + DynamicObjectCollection draftBills = payBills[i].getDynamicObjectCollection("draftbill"); + draftBills.addNew().set("fbasedataid",bill);//结算号 + payBills[i].set("billstatus","D");//单据状态改为：已付款 +// payBills[i].set("draftbill", draftBills); + DynamicObjectCollection draftInfo = payBills[i].getDynamicObjectCollection("cas_draftinfo"); + int draftInfoSize = draftInfo.size(); + DynamicObject draftInfoDetail = draftInfo.addNew(); + draftInfoDetail.set("seq", draftInfoSize); + draftInfoDetail.set("transamount",bill.getBigDecimal("amount")); + draftInfoDetail.set("paybillcurrency", bill.getDynamicObject("currency")); + draftInfoDetail.set("draftbillinfo", bill); + } + SaveServiceHelper.save(payBills); + } + SaveServiceHelper.save(bills); + } +} \ No newline at end of file