From 388587b5e1a50d577030eb1a7e9598c002ff4eb3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BE=9A=E8=B1=86=E8=B1=86?= <13356128+sunandmoon60@user.noreply.gitee.com> Date: Mon, 13 Oct 2025 15:47:05 +0800 Subject: [PATCH] =?UTF-8?q?1.=E8=BF=94=E5=88=A9=E7=B3=BB=E7=BB=9F=E6=8F=92?= =?UTF-8?q?=E4=BB=B6=E5=BC=80=E5=8F=91=EF=BC=88=E6=9C=AA=E6=B5=8B=E8=AF=95?= =?UTF-8?q?=EF=BC=89=202.HttpRequestUtils=E5=B7=A5=E5=85=B7=E7=B1=BBget?= =?UTF-8?q?=E6=96=B9=E6=B3=95=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../plugin/form/pm/PurApplyBillPlugin.java | 10 +- .../form/pm/PuroderBillShareRefundPlugin.java | 6 +- .../operate/ap/PayBillOperationPlugin.java | 92 +++++- .../ap/PurApplySyncSupplierDeductPlugin.java | 8 +- .../operate/pm/PurOrderBillRebatePlugin.java | 266 +++++++++++++++--- .../operate/sys/RebateRuleOpPlugin.java | 66 +++++ .../app/plugin/utils/HttpRequestUtils.java | 24 +- 7 files changed, 384 insertions(+), 88 deletions(-) create mode 100644 lc123/cloud/app/plugin/operate/sys/RebateRuleOpPlugin.java diff --git a/lc123/cloud/app/plugin/form/pm/PurApplyBillPlugin.java b/lc123/cloud/app/plugin/form/pm/PurApplyBillPlugin.java index b6b8b1d..6527f2d 100644 --- a/lc123/cloud/app/plugin/form/pm/PurApplyBillPlugin.java +++ b/lc123/cloud/app/plugin/form/pm/PurApplyBillPlugin.java @@ -17,15 +17,11 @@ import kd.bos.orm.query.QFilter; import kd.bos.servicehelper.BusinessDataServiceHelper; import kd.bos.servicehelper.user.UserServiceHelper; import kd.sdk.plugin.Plugin; -import org.springframework.http.ResponseEntity; -import tqq9.lc123.cloud.app.api.utils.Constants; -import tqq9.lc123.cloud.app.api.utils.HttpClient; import tqq9.lc123.cloud.app.plugin.utils.EntryFieldRefresher; import tqq9.lc123.cloud.app.plugin.utils.HttpRequestUtils; import java.io.IOException; import java.math.BigDecimal; -import java.net.ConnectException; import java.util.*; /** @@ -79,7 +75,7 @@ public class PurApplyBillPlugin extends AbstractBillPlugIn implements Plugin { entryFieldRefresher.updateDynamicObjectByOrg(SH_ORGNUMBER, "supplier", tqq9_sup_sh, model); String tqq9_mulcombofield1 = tqq9_sup_sh.getString("tqq9_mulcombofield1"); model.setValue("tqq9_suparea_sh", tqq9_mulcombofield1); - HashMap queryMap = new HashMap<>(); + HashMap queryMap = new HashMap<>(); queryMap.put("supplierId", tqq9_sup_sh.getString("number")); queryMap.put("companyId", org.getString("number")); Gson gson = new Gson(); @@ -160,7 +156,7 @@ public class PurApplyBillPlugin extends AbstractBillPlugIn implements Plugin { entryFieldRefresher.updateDynamicObjectByOrg(BJ_ORGNUMBER, "supplier", tqq9_sup_bj, model); String tqq9_mulcombofield1 = tqq9_sup_bj.getString("tqq9_mulcombofield1"); model.setValue("tqq9_suparea_bj", tqq9_mulcombofield1); - HashMap queryMap = new HashMap<>(); + HashMap queryMap = new HashMap<>(); queryMap.put("supplierId", tqq9_sup_bj.getString("number")); queryMap.put("companyId", org.getString("number")); Gson gson = new Gson(); @@ -243,7 +239,7 @@ public class PurApplyBillPlugin extends AbstractBillPlugIn implements Plugin { entryFieldRefresher.updateDynamicObjectByOrg(GZ_ORGNUMBER, "supplier", tqq9_sup_gz, model); String tqq9_mulcombofield1 = tqq9_sup_gz.getString("tqq9_mulcombofield1"); model.setValue("tqq9_suparea_gz", tqq9_mulcombofield1); - HashMap queryMap = new HashMap<>(); + HashMap queryMap = new HashMap<>(); queryMap.put("supplierId", tqq9_sup_gz.getString("number")); queryMap.put("companyId", org.getString("number")); Gson gson = new Gson(); diff --git a/lc123/cloud/app/plugin/form/pm/PuroderBillShareRefundPlugin.java b/lc123/cloud/app/plugin/form/pm/PuroderBillShareRefundPlugin.java index 42cb696..34bdc7e 100644 --- a/lc123/cloud/app/plugin/form/pm/PuroderBillShareRefundPlugin.java +++ b/lc123/cloud/app/plugin/form/pm/PuroderBillShareRefundPlugin.java @@ -15,15 +15,11 @@ import kd.bos.logging.LogFactory; import kd.bos.orm.query.QCP; import kd.bos.orm.query.QFilter; import kd.bos.servicehelper.BusinessDataServiceHelper; -import org.springframework.http.ResponseEntity; -import tqq9.lc123.cloud.app.api.utils.Constants; -import tqq9.lc123.cloud.app.api.utils.HttpClient; import tqq9.lc123.cloud.app.plugin.utils.HttpRequestUtils; import java.io.IOException; import java.math.BigDecimal; import java.math.RoundingMode; -import java.net.ConnectException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; @@ -336,7 +332,7 @@ public class PuroderBillShareRefundPlugin extends AbstractBillPlugIn { ChangeData changeData = e.getChangeSet()[0]; DynamicObject newValue = (DynamicObject) changeData.getNewValue();//供应商 DynamicObject org = (DynamicObject)model.getValue("org");//组织 - HashMap queryMap =new HashMap<>(); + HashMap queryMap =new HashMap<>(); queryMap.put("supplierId",newValue.getString("number")); queryMap.put("companyId",org.getString("number")); Gson gson = new Gson(); diff --git a/lc123/cloud/app/plugin/operate/ap/PayBillOperationPlugin.java b/lc123/cloud/app/plugin/operate/ap/PayBillOperationPlugin.java index 111e045..6a88310 100644 --- a/lc123/cloud/app/plugin/operate/ap/PayBillOperationPlugin.java +++ b/lc123/cloud/app/plugin/operate/ap/PayBillOperationPlugin.java @@ -1,33 +1,28 @@ package tqq9.lc123.cloud.app.plugin.operate.ap; -import kd.bos.algo.DataSet; -import kd.bos.dataentity.OperateOption; +import com.google.gson.Gson; import kd.bos.dataentity.entity.DynamicObject; import kd.bos.dataentity.entity.DynamicObjectCollection; import kd.bos.dataentity.utils.StringUtils; -import kd.bos.db.DB; -import kd.bos.db.DBRoute; import kd.bos.entity.ExtendedDataEntity; -import kd.bos.entity.operate.OperateOptionConst; -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.AfterOperationArgs; import kd.bos.entity.validate.AbstractValidator; import kd.bos.logging.Log; import kd.bos.logging.LogFactory; -import kd.bos.orm.ORM; import kd.bos.orm.query.QCP; import kd.bos.orm.query.QFilter; import kd.bos.servicehelper.BusinessDataServiceHelper; -import kd.bos.servicehelper.operation.OperationServiceHelper; import kd.bos.servicehelper.operation.SaveServiceHelper; import kd.sdk.plugin.Plugin; -import tqq9.lc123.cloud.app.plugin.operate.cas.PurOrderReversePayBillPlugin; +import tqq9.lc123.cloud.app.plugin.utils.HttpRequestUtils; -import java.sql.*; +import java.io.IOException; import java.math.BigDecimal; -import java.sql.DriverManager; +import java.sql.*; +import java.util.HashMap; /** * 付款单操作插件 @@ -38,6 +33,8 @@ public class PayBillOperationPlugin extends AbstractOperationServicePlugIn imple private static String URL; private static String USERNAME; private static String PASSWORD; + private static String Use_URL; + static { DynamicObject url = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name", @@ -49,8 +46,16 @@ public class PayBillOperationPlugin extends AbstractOperationServicePlugIn imple DynamicObject passWord = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name", new QFilter[]{new QFilter("number", QCP.equals, "EqmDatabase_password")}); PASSWORD = passWord != null ? passWord.getString("name") : null; + url = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name", + new QFilter[]{new QFilter("number", QCP.equals, "FLXT_BillCreate_Url")}); + Use_URL = url != null ? url.getString("name") : null; } + private final static HashMap tokenMap = new HashMap() {{ + put("Authorization", "Bearer b96dad1eb4f84c41bae651162aeacdd3"); + }}; + + @Override public void onPreparePropertys(PreparePropertysEventArgs e) { super.onPreparePropertys(e); @@ -86,7 +91,7 @@ public class PayBillOperationPlugin extends AbstractOperationServicePlugIn imple if (e_payableamt.compareTo(BigDecimal.ZERO) < 0) { String banktxn = dataEntity1.getString("tqq9_banktxn");//银行流水号 String billno = dataEntity1.getString("billno");//银行流水号 - if(StringUtils.isBlank(banktxn)){ + if (StringUtils.isBlank(banktxn)) { this.addErrorMessage(dataEntity, "单据号:" + billno + ",银行流水为空，无法审核"); break; } @@ -101,7 +106,7 @@ public class PayBillOperationPlugin extends AbstractOperationServicePlugIn imple rs = stmt.executeQuery(sql); if (!rs.next()) { - this.addErrorMessage(dataEntity, "单据号:" + billno + ",银行流水:" + banktxn + ",在E企明系统中不存在,无法审核"); + this.addErrorMessage(dataEntity, "单据号:" + billno + ",银行流水:" + banktxn + ",在E企明系统中不存在,无法审核"); } break; } catch (SQLException | ClassNotFoundException e) { @@ -130,4 +135,65 @@ public class PayBillOperationPlugin extends AbstractOperationServicePlugIn imple } } + + @Override + public void afterExecuteOperationTransaction(AfterOperationArgs e) { + super.afterExecuteOperationTransaction(e); + for (DynamicObject dataEntity : e.getDataEntities()) { + String billno = dataEntity.getString("billno"); + BigDecimal tqq9_hshfsyje = dataEntity.getBigDecimal("tqq9_hshfsyje");//含税货返使用金额 + BigDecimal tqq9_hsxfsyje = dataEntity.getBigDecimal("tqq9_hsxfsyje");//含税现返使用金额 + BigDecimal tqq9_payamount = dataEntity.getBigDecimal("tqq9_payamount");//折扣后返利后价税合计 + String tqq9_hfid = dataEntity.getString("tqq9_hfid");//货返id + String tqq9_xfid = dataEntity.getString("tqq9_xfid");//现返id + if (tqq9_hshfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_payamount.compareTo(BigDecimal.ZERO) == 0) { + DynamicObject tqq9_hshfsysl = dataEntity.getDynamicObject("tqq9_hshfsysl");//含税货返使用税率 + BigDecimal taxrate = tqq9_hshfsysl.getBigDecimal("taxrate"); + BigDecimal taxamount = tqq9_hshfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 + HashMap bodyMap = new HashMap<>(); + bodyMap.put("id", tqq9_hfid); + bodyMap.put("lockMoney", tqq9_hshfsyje); + bodyMap.put("lockTaxAmount", taxamount); + Gson gson = new Gson(); + try { + String bodyString = HttpRequestUtils.postJson(Use_URL, bodyMap.toString(), tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",审核时扣除订单金额失败"); + } else { + dataEntity.set("tqq9_isrebatecalculate", true); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + //现返审核 + } else if (tqq9_hsxfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_payamount.compareTo(BigDecimal.ZERO) == 0) { + DynamicObject tqq9_hsxfsysl = dataEntity.getDynamicObject("tqq9_hsxfsysl");//含税现返使用税率 + BigDecimal taxrate = tqq9_hsxfsysl.getBigDecimal("taxrate"); + BigDecimal taxamount = tqq9_hsxfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 + HashMap bodyMap = new HashMap<>(); + bodyMap.put("id", tqq9_xfid); + bodyMap.put("lockMoney", tqq9_hsxfsyje); + bodyMap.put("lockTaxAmount", taxamount); + Gson gson = new Gson(); + try { + String bodyString = HttpRequestUtils.postJson(Use_URL, bodyMap.toString(), tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",审核时扣除订单金额失败"); + } else { + dataEntity.set("tqq9_isrebatecalculate", true); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + } + } + + + } } \ No newline at end of file diff --git a/lc123/cloud/app/plugin/operate/ap/PurApplySyncSupplierDeductPlugin.java b/lc123/cloud/app/plugin/operate/ap/PurApplySyncSupplierDeductPlugin.java index 1436b57..b6feeb7 100644 --- a/lc123/cloud/app/plugin/operate/ap/PurApplySyncSupplierDeductPlugin.java +++ b/lc123/cloud/app/plugin/operate/ap/PurApplySyncSupplierDeductPlugin.java @@ -13,10 +13,8 @@ import kd.bos.logging.Log; import kd.bos.logging.LogFactory; import kd.bos.orm.ORM; import kd.sdk.plugin.Plugin; -import tqq9.lc123.cloud.app.plugin.operate.im.PurOrderPushReceiptNoticePlugin; import java.math.BigDecimal; -import java.util.Map; /** * 付款申请单转换规则插件 @@ -45,9 +43,11 @@ public class PurApplySyncSupplierDeductPlugin extends AbstractConvertPlugIn impl DataSet dataSet = DB.queryDataSet(this.getClass().getName(), DBRoute.of("cas"), sql); DataSet copy = dataSet.copy(); DynamicObjectCollection dynamicObjects = ORM.create().toPlainDynamicObjectCollection(copy); - BigDecimal qty = dynamicObjects.get(0).getBigDecimal("qty"); - dataEntity.set("tqq9_gyskdkzje",qty); + if(dynamicObjects.size()>0){ + BigDecimal qty = dynamicObjects.get(0).getBigDecimal("qty"); + dataEntity.set("tqq9_gyskdkzje",qty); + } } } diff --git a/lc123/cloud/app/plugin/operate/pm/PurOrderBillRebatePlugin.java b/lc123/cloud/app/plugin/operate/pm/PurOrderBillRebatePlugin.java index 0bcb249..63774df 100644 --- a/lc123/cloud/app/plugin/operate/pm/PurOrderBillRebatePlugin.java +++ b/lc123/cloud/app/plugin/operate/pm/PurOrderBillRebatePlugin.java @@ -2,6 +2,7 @@ package tqq9.lc123.cloud.app.plugin.operate.pm; import com.google.gson.Gson; import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.metadata.IDataEntityProperty; import kd.bos.dataentity.utils.StringUtils; import kd.bos.entity.plugin.AbstractOperationServicePlugIn; import kd.bos.entity.plugin.args.AfterOperationArgs; @@ -10,15 +11,17 @@ 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.operation.SaveServiceHelper; import kd.sdk.plugin.Plugin; import tqq9.lc123.cloud.app.plugin.utils.HttpRequestUtils; import java.io.IOException; import java.math.BigDecimal; import java.util.HashMap; +import java.util.List; /** - * 单据操作插件 + * 采购订单操作插件 */ public class PurOrderBillRebatePlugin extends AbstractOperationServicePlugIn implements Plugin { @@ -29,106 +32,277 @@ public class PurOrderBillRebatePlugin extends AbstractOperationServicePlugIn imp put("Authorization", "Bearer b96dad1eb4f84c41bae651162aeacdd3"); }}; - private static String URL; + private static String Create_URL; + private static String Cancel_URL; + private static String Use_URL; + static { DynamicObject url = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name", - new QFilter[]{new QFilter("number", QCP.equals, "FLXT_Balance_Url")}); - URL = url != null ? url.getString("name") : null; + new QFilter[]{new QFilter("number", QCP.equals, "FLXT_BillCreate_Url")}); + Create_URL = url != null ? url.getString("name") : null; + + url = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name", + new QFilter[]{new QFilter("number", QCP.equals, "FLXT_Billcancel_Url")}); + Cancel_URL = url != null ? url.getString("name") : null; + + url = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name", + new QFilter[]{new QFilter("number", QCP.equals, "FLXT_Deduct_Url")}); + Use_URL = url != null ? url.getString("name") : null; } + @Override public void afterExecuteOperationTransaction(AfterOperationArgs e) { super.afterExecuteOperationTransaction(e); String operationKey = e.getOperationKey(); - if (StringUtils.equals("save",operationKey)) { + if (StringUtils.equals("save", operationKey)) { for (DynamicObject dataEntity : e.getDataEntities()) { + String billno = dataEntity.getString("billno"); DynamicObject supplier = dataEntity.getDynamicObject("supplier");//供应商 DynamicObject org = dataEntity.getDynamicObject("org");//组织 BigDecimal tqq9_hshfsyje = dataEntity.getBigDecimal("tqq9_hshfsyje");//含税货返使用金额 BigDecimal tqq9_hsxfsyje = dataEntity.getBigDecimal("tqq9_hsxfsyje");//含税现返使用金额 - if(tqq9_hshfsyje.compareTo(BigDecimal.ZERO)>0){ + String tqq9_hfid = dataEntity.getString("tqq9_hfid");//货返id + String tqq9_xfid = dataEntity.getString("tqq9_xfid");//现返id + //货返锁定 + if (tqq9_hshfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_hfid == null) { DynamicObject tqq9_hshfsysl = dataEntity.getDynamicObject("tqq9_hshfsysl");//含税货返使用税率 BigDecimal taxrate = tqq9_hshfsysl.getBigDecimal("taxrate"); BigDecimal taxamount = tqq9_hshfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 - HashMap bodyMap =new HashMap<>(); - bodyMap.put("supplierId",supplier.getString("number")); - bodyMap.put("companyId",org.getString("number")); - bodyMap.put("type",0); - bodyMap.put("money",tqq9_hshfsyje); - bodyMap.put("taxAmount",taxamount); + HashMap bodyMap = new HashMap<>(); + bodyMap.put("supplierId", supplier.getString("number")); + bodyMap.put("companyId", org.getString("number")); + bodyMap.put("type", 0); + bodyMap.put("money", tqq9_hshfsyje); + bodyMap.put("taxAmount", taxamount); Gson gson = new Gson(); try { - String bodyString = HttpRequestUtils.postJson(URL, bodyMap.toString(), tokenMap); + String bodyString = HttpRequestUtils.postJson(Create_URL, bodyMap.toString(), tokenMap); HashMap map = gson.fromJson(bodyString, HashMap.class); + String data = map.get("data").toString(); + if (data != null) { + dataEntity.set("tqq9_hfid", data); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } else { + this.getOperationResult().setMessage("采购订单:" + billno + ",保存时占用金额失败"); + } } catch (IOException ex) { throw new RuntimeException(ex); } - }else if(tqq9_hsxfsyje.compareTo(BigDecimal.ZERO)>0){ + //现返锁定 + } else if (tqq9_hsxfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_xfid == null) { DynamicObject tqq9_hsxfsysl = dataEntity.getDynamicObject("tqq9_hsxfsysl");//含税现返使用税率 BigDecimal taxrate = tqq9_hsxfsysl.getBigDecimal("taxrate"); BigDecimal taxamount = tqq9_hsxfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 - HashMap bodyMap =new HashMap<>(); - bodyMap.put("supplierId",supplier.getString("number")); - bodyMap.put("companyId",org.getString("number")); - bodyMap.put("type",1); - bodyMap.put("money",tqq9_hsxfsyje); - bodyMap.put("taxAmount",taxamount); + HashMap bodyMap = new HashMap<>(); + bodyMap.put("supplierId", supplier.getString("number")); + bodyMap.put("companyId", org.getString("number")); + bodyMap.put("type", 1); + bodyMap.put("money", tqq9_hsxfsyje); + bodyMap.put("taxAmount", taxamount); Gson gson = new Gson(); try { - String bodyString = HttpRequestUtils.postJson(URL, bodyMap.toString(), tokenMap); + String bodyString = HttpRequestUtils.postJson(Create_URL, bodyMap.toString(), tokenMap); HashMap map = gson.fromJson(bodyString, HashMap.class); + String data = map.get("data").toString(); + if (data != null) { + dataEntity.set("tqq9_xfid", data); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } else { + this.getOperationResult().setMessage("采购订单:" + billno + ",保存时占用金额失败"); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + //货返修改 + } else if (tqq9_hshfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_hfid != null) { + List iDataEntityProperties = dataEntity.getDataEntityState().GetDirtyProperties(); + if (iDataEntityProperties.contains("tqq9_hshfsysl")) { + DynamicObject tqq9_hshfsysl = dataEntity.getDynamicObject("tqq9_hshfsysl");//含税货返使用税率 + BigDecimal taxrate = tqq9_hshfsysl.getBigDecimal("taxrate"); + BigDecimal taxamount = tqq9_hshfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 + HashMap queryMap = new HashMap<>(); + queryMap.put("id", tqq9_xfid); + queryMap.put("money", tqq9_hshfsyje); + queryMap.put("taxAmount", taxamount); + Gson gson = new Gson(); + try { + String bodyString = HttpRequestUtils.doGet(Create_URL, queryMap, tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",删除时撤销占用金额失败"); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + HashMap bodyMap = new HashMap<>(); + bodyMap.put("supplierId", supplier.getString("number")); + bodyMap.put("companyId", org.getString("number")); + bodyMap.put("type", 0); + bodyMap.put("money", tqq9_hshfsyje); + bodyMap.put("taxAmount", taxamount); + try { + String bodyString = HttpRequestUtils.postJson(Create_URL, bodyMap.toString(), tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + String data = map.get("data").toString(); + if (data != null) { + dataEntity.set("tqq9_hfid", data); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } else { + this.getOperationResult().setMessage("采购订单:" + billno + ",保存时占用金额失败"); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + + } + + //现返修改 + } else if (tqq9_hsxfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_xfid != null) { + DynamicObject tqq9_hsxfsysl = dataEntity.getDynamicObject("tqq9_hsxfsysl");//含税现返使用税率 + BigDecimal taxrate = tqq9_hsxfsysl.getBigDecimal("taxrate"); + BigDecimal taxamount = tqq9_hsxfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 + HashMap queryMap = new HashMap<>(); + queryMap.put("id", tqq9_xfid); + queryMap.put("money", tqq9_hsxfsyje); + queryMap.put("taxAmount", taxamount); + Gson gson = new Gson(); + try { + String bodyString = HttpRequestUtils.doGet(Create_URL, queryMap, tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",删除时撤销占用金额失败"); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + HashMap bodyMap = new HashMap<>(); + bodyMap.put("supplierId", supplier.getString("number")); + bodyMap.put("companyId", org.getString("number")); + bodyMap.put("type", 1); + bodyMap.put("money", tqq9_hsxfsyje); + bodyMap.put("taxAmount", taxamount); + try { + String bodyString = HttpRequestUtils.postJson(Create_URL, bodyMap.toString(), tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + String data = map.get("data").toString(); + if (data != null) { + dataEntity.set("tqq9_xfid", data); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } else { + this.getOperationResult().setMessage("采购订单:" + billno + ",保存时占用金额失败"); + } } catch (IOException ex) { throw new RuntimeException(ex); } } - - } - - }else if(StringUtils.equals("delete",operationKey)){ + } else if (StringUtils.equals("delete", operationKey)) { + //货返删除 for (DynamicObject dataEntity : e.getDataEntities()) { - DynamicObject supplier = dataEntity.getDynamicObject("supplier");//供应商 - DynamicObject org = dataEntity.getDynamicObject("org");//组织 + String billno = dataEntity.getString("billno"); BigDecimal tqq9_hshfsyje = dataEntity.getBigDecimal("tqq9_hshfsyje");//含税货返使用金额 BigDecimal tqq9_hsxfsyje = dataEntity.getBigDecimal("tqq9_hsxfsyje");//含税现返使用金额 - if(tqq9_hshfsyje.compareTo(BigDecimal.ZERO)>0){ + String tqq9_hfid = dataEntity.getString("tqq9_hfid");//货返id + String tqq9_xfid = dataEntity.getString("tqq9_xfid");//现返id + if (tqq9_hshfsyje.compareTo(BigDecimal.ZERO) > 0) { DynamicObject tqq9_hshfsysl = dataEntity.getDynamicObject("tqq9_hshfsysl");//含税货返使用税率 BigDecimal taxrate = tqq9_hshfsysl.getBigDecimal("taxrate"); BigDecimal taxamount = tqq9_hshfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 - HashMap bodyMap =new HashMap<>(); - bodyMap.put("supplierId",supplier.getString("number")); - bodyMap.put("companyId",org.getString("number")); - bodyMap.put("type",0); - bodyMap.put("money",tqq9_hshfsyje); - bodyMap.put("taxAmount",taxamount); + HashMap bodyMap = new HashMap<>(); + bodyMap.put("id", tqq9_hfid); + bodyMap.put("money", tqq9_hshfsyje); + bodyMap.put("taxAmount", taxamount); Gson gson = new Gson(); try { - String bodyString = HttpRequestUtils.postJson(URL, bodyMap.toString(), tokenMap); + String bodyString = HttpRequestUtils.postJson(Cancel_URL, bodyMap.toString(), tokenMap); HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",删除时撤销占用金额失败"); + } } catch (IOException ex) { throw new RuntimeException(ex); } - }else if(tqq9_hsxfsyje.compareTo(BigDecimal.ZERO)>0){ + //现返删除 + } else if (tqq9_hsxfsyje.compareTo(BigDecimal.ZERO) > 0) { DynamicObject tqq9_hsxfsysl = dataEntity.getDynamicObject("tqq9_hsxfsysl");//含税现返使用税率 BigDecimal taxrate = tqq9_hsxfsysl.getBigDecimal("taxrate"); BigDecimal taxamount = tqq9_hsxfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 - HashMap bodyMap =new HashMap<>(); - bodyMap.put("supplierId",supplier.getString("number")); - bodyMap.put("companyId",org.getString("number")); - bodyMap.put("type",1); - bodyMap.put("money",tqq9_hsxfsyje); - bodyMap.put("taxAmount",taxamount); + HashMap bodyMap = new HashMap<>(); + bodyMap.put("id", tqq9_xfid); + bodyMap.put("money", tqq9_hsxfsyje); + bodyMap.put("taxAmount", taxamount); Gson gson = new Gson(); try { - String bodyString = HttpRequestUtils.postJson(URL, bodyMap.toString(), tokenMap); + String bodyString = HttpRequestUtils.postJson(Cancel_URL, bodyMap.toString(), tokenMap); HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",删除时撤销占用金额失败"); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + } + } + } else if (StringUtils.equals("audit", operationKey)) { + //货返审核 + for (DynamicObject dataEntity : e.getDataEntities()) { + String billno = dataEntity.getString("billno"); + BigDecimal tqq9_hshfsyje = dataEntity.getBigDecimal("tqq9_hshfsyje");//含税货返使用金额 + BigDecimal tqq9_hsxfsyje = dataEntity.getBigDecimal("tqq9_hsxfsyje");//含税现返使用金额 + BigDecimal tqq9_payamount = dataEntity.getBigDecimal("tqq9_payamount");//折扣后返利后价税合计 + String tqq9_hfid = dataEntity.getString("tqq9_hfid");//货返id + String tqq9_xfid = dataEntity.getString("tqq9_xfid");//现返id + if (tqq9_hshfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_payamount.compareTo(BigDecimal.ZERO) == 0) { + DynamicObject tqq9_hshfsysl = dataEntity.getDynamicObject("tqq9_hshfsysl");//含税货返使用税率 + BigDecimal taxrate = tqq9_hshfsysl.getBigDecimal("taxrate"); + BigDecimal taxamount = tqq9_hshfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 + HashMap bodyMap = new HashMap<>(); + bodyMap.put("id", tqq9_hfid); + bodyMap.put("lockMoney", tqq9_hshfsyje); + bodyMap.put("lockTaxAmount", taxamount); + Gson gson = new Gson(); + try { + String bodyString = HttpRequestUtils.postJson(Use_URL, bodyMap.toString(), tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",审核时扣除订单金额失败"); + } else { + dataEntity.set("tqq9_isrebatecalculate", true); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + //现返审核 + } else if (tqq9_hsxfsyje.compareTo(BigDecimal.ZERO) > 0 && tqq9_payamount.compareTo(BigDecimal.ZERO) == 0) { + DynamicObject tqq9_hsxfsysl = dataEntity.getDynamicObject("tqq9_hsxfsysl");//含税现返使用税率 + BigDecimal taxrate = tqq9_hsxfsysl.getBigDecimal("taxrate"); + BigDecimal taxamount = tqq9_hsxfsyje.multiply(taxrate.divide(new BigDecimal(100).add(taxrate)));//税额 + HashMap bodyMap = new HashMap<>(); + bodyMap.put("id", tqq9_xfid); + bodyMap.put("lockMoney", tqq9_hsxfsyje); + bodyMap.put("lockTaxAmount", taxamount); + Gson gson = new Gson(); + try { + String bodyString = HttpRequestUtils.postJson(Use_URL, bodyMap.toString(), tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("采购订单:" + billno + ",审核时扣除订单金额失败"); + } else { + dataEntity.set("tqq9_isrebatecalculate", true); + SaveServiceHelper.save(new DynamicObject[]{dataEntity}); + } } catch (IOException ex) { throw new RuntimeException(ex); } } - - } - } } } \ No newline at end of file diff --git a/lc123/cloud/app/plugin/operate/sys/RebateRuleOpPlugin.java b/lc123/cloud/app/plugin/operate/sys/RebateRuleOpPlugin.java new file mode 100644 index 0000000..47baaed --- /dev/null +++ b/lc123/cloud/app/plugin/operate/sys/RebateRuleOpPlugin.java @@ -0,0 +1,66 @@ +package tqq9.lc123.cloud.app.plugin.operate.sys; + +import com.google.gson.Gson; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.entity.plugin.AbstractOperationServicePlugIn; +import kd.bos.entity.plugin.args.AfterOperationArgs; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.sdk.plugin.Plugin; +import tqq9.lc123.cloud.app.plugin.operate.pm.PurOrderBillRebatePlugin; +import tqq9.lc123.cloud.app.plugin.utils.HttpRequestUtils; + +import java.io.IOException; +import java.util.Date; +import java.util.HashMap; + +/** + * 返利规则操作插件 + */ +public class RebateRuleOpPlugin extends AbstractOperationServicePlugIn implements Plugin { + private final static Log logger = LogFactory.getLog(PurOrderBillRebatePlugin.class); + private final static HashMap tokenMap = new HashMap() {{ + put("Authorization", "Bearer b96dad1eb4f84c41bae651162aeacdd3"); + }}; + + + private static String Push_URL; + + static { + DynamicObject url = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name", + new QFilter[]{new QFilter("number", QCP.equals, "FLXT_CreatRule_Url")}); + Push_URL = url != null ? url.getString("name") : null; + } + + @Override + public void afterExecuteOperationTransaction(AfterOperationArgs e) { + super.afterExecuteOperationTransaction(e); + for (DynamicObject dataEntity : e.getDataEntities()) { + String ruleName = dataEntity.getString("name");//规则名称 + String tqq9_rulestype = dataEntity.getString("tqq9_rulestype");//规则类型 + Integer type = Integer.valueOf(tqq9_rulestype);//规则类型 + Date startTime = dataEntity.getDate("startTime");//返利计算开始时间 + Date endTime = dataEntity.getDate("endTime");//返利计算结束时间 + + + + + HashMap bodyMap = new HashMap<>(); + Gson gson = new Gson(); + try { + String bodyString = HttpRequestUtils.postJson(Push_URL, bodyMap.toString(), tokenMap); + HashMap map = gson.fromJson(bodyString, HashMap.class); + Boolean data = (Boolean) map.get("data"); + if (!data) { + this.getOperationResult().setMessage("返利规则:" + ruleName + ",审核时创建返利规则失败"); + } + } catch (IOException ex) { + throw new RuntimeException(ex); + } + + } + } +} \ No newline at end of file diff --git a/lc123/cloud/app/plugin/utils/HttpRequestUtils.java b/lc123/cloud/app/plugin/utils/HttpRequestUtils.java index 707fff1..3e342ad 100644 --- a/lc123/cloud/app/plugin/utils/HttpRequestUtils.java +++ b/lc123/cloud/app/plugin/utils/HttpRequestUtils.java @@ -1,20 +1,24 @@ package tqq9.lc123.cloud.app.plugin.utils; import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.parser.Feature; +import com.alibaba.fastjson.JSONObject; import kd.bos.logging.Log; import kd.bos.logging.LogFactory; import org.apache.http.HttpEntity; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.methods.CloseableHttpResponse; +import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; +import org.apache.http.client.utils.URIBuilder; import org.apache.http.entity.ContentType; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.util.EntityUtils; -import org.apache.http.client.methods.HttpGet; -import org.apache.http.client.utils.URIBuilder; +import org.dom4j.Document; +import org.dom4j.DocumentException; +import org.dom4j.DocumentHelper; +import org.dom4j.Element; import javax.xml.bind.JAXBContext; import javax.xml.bind.JAXBException; @@ -29,12 +33,6 @@ import java.util.List; import java.util.Map; import java.util.Set; -import com.alibaba.fastjson.JSONObject; -import org.dom4j.Document; -import org.dom4j.DocumentException; -import org.dom4j.DocumentHelper; -import org.dom4j.Element; - public class HttpRequestUtils { @@ -65,7 +63,7 @@ public class HttpRequestUtils { * @return 响应字符串 * @throws IOException 请求异常时抛出 */ - public static String doGet(String url, Map params, + public static String doGet(String url, Map params, Map headers) throws IOException { return doGet(url, params, headers, DEFAULT_CONNECT_TIMEOUT, DEFAULT_SOCKET_TIMEOUT); } @@ -80,7 +78,7 @@ public class HttpRequestUtils { * @return 响应字符串 * @throws IOException 请求异常时抛出 */ - public static String doGet(String url, Map params, + public static String doGet(String url, Map params, Map headers, int connectTimeout, int socketTimeout) throws IOException { // 创建HttpClient实例 @@ -90,8 +88,8 @@ public class HttpRequestUtils { // 添加请求参数 if (params != null && !params.isEmpty()) { - for (Map.Entry entry : params.entrySet()) { - builder.addParameter(entry.getKey(), entry.getValue()); + for (Map.Entry entry : params.entrySet()) { + builder.addParameter(entry.getKey(), entry.getValue().toString()); } }