241 lines
15 KiB
Java
241 lines
15 KiB
Java
package tqq9.lc123.cloud.app.plugin.form.pm;
|
||
|
||
import com.alibaba.fastjson.JSONObject;
|
||
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.entity.datamodel.ListSelectedRow;
|
||
import kd.bos.entity.datamodel.ListSelectedRowCollection;
|
||
import kd.bos.entity.operate.result.OperationResult;
|
||
import kd.bos.form.control.events.BeforeItemClickEvent;
|
||
import kd.bos.form.events.AfterDoOperationEventArgs;
|
||
import kd.bos.list.BillList;
|
||
import kd.bos.list.plugin.AbstractListPlugin;
|
||
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.eip.iscb.LCLogService;
|
||
import tqq9.lc123.cloud.app.eip.iscb.impl.LCLogServiceImpl;
|
||
import tqq9.lc123.cloud.app.plugin.utils.HttpRequestUtils;
|
||
|
||
import java.io.IOException;
|
||
import java.math.BigDecimal;
|
||
import java.math.RoundingMode;
|
||
import java.util.HashMap;
|
||
import java.util.List;
|
||
import java.util.stream.Collectors;
|
||
|
||
/**
|
||
* 采购订单关闭推送返利系统
|
||
*/
|
||
public class PurOrderCloseBillPlugin extends AbstractListPlugin implements Plugin {
|
||
private final static Log logger = LogFactory.getLog(PurOrderCloseBillPlugin.class);
|
||
private static String Cancel_URL;
|
||
private static String RETURN_URL;
|
||
private static String FLXT_TOKEN;
|
||
|
||
static {
|
||
DynamicObject url = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name",
|
||
new QFilter[]{new QFilter("number", QCP.equals, "FLXT_Billcancel_Url")});
|
||
Cancel_URL = url != null ? url.getString("name") : null;
|
||
DynamicObject url1 = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name",
|
||
new QFilter[]{new QFilter("number", QCP.equals, "FLXT_Undeduct_Url")});
|
||
RETURN_URL = url1 != null ? url1.getString("name") : null;
|
||
DynamicObject token = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name",
|
||
new QFilter[]{new QFilter("number", QCP.equals, "FLXT_TOKEN")});
|
||
FLXT_TOKEN = token != null ? token.getString("name") : null;
|
||
}
|
||
|
||
@Override
|
||
public void beforeItemClick(BeforeItemClickEvent evt) {
|
||
super.beforeItemClick(evt);
|
||
String itemKey = evt.getItemKey();
|
||
if ("tblbizclose".equals(itemKey)) {
|
||
BillList billList = this.getControl("billlistap");
|
||
ListSelectedRowCollection selectedRows = billList.getSelectedRows();
|
||
List<String> billnoList = selectedRows.stream().map(ListSelectedRow::getBillNo).distinct().collect(Collectors.toList());
|
||
if (billnoList.size() > 1) {
|
||
this.getView().showMessage("请选择一张单据");
|
||
evt.setCancel(true);
|
||
return;
|
||
}
|
||
DynamicObject dataEntity = BusinessDataServiceHelper.loadSingle("pm_purorderbill", "id,billno,closestatus",
|
||
new QFilter[]{new QFilter("billno", QCP.in, billnoList)});
|
||
if (null != dataEntity) {
|
||
String closestatus = dataEntity.getString("closestatus");
|
||
if (StringUtils.equals("B", closestatus)) {
|
||
this.getView().showMessage("该单据已关闭");
|
||
evt.setCancel(true);
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
|
||
@Override
|
||
public void afterDoOperation(AfterDoOperationEventArgs afterDoOperationEventArgs) {
|
||
super.afterDoOperation(afterDoOperationEventArgs);
|
||
String operateKey = afterDoOperationEventArgs.getOperateKey();
|
||
OperationResult operationResult = afterDoOperationEventArgs.getOperationResult();
|
||
if (StringUtils.equals("bizclose", operateKey) && operationResult.isSuccess()) {
|
||
BillList billList = this.getView().getControl("billlistap");
|
||
ListSelectedRowCollection selectedRows = billList.getSelectedRows();
|
||
//因为只有一张关闭，这里直接调用返利接口
|
||
for (int i = 0; i < selectedRows.size(); i++) {
|
||
ListSelectedRow selectedRow = selectedRows.get(i);
|
||
String billNo = selectedRow.getBillNo();
|
||
DynamicObject pm_purorderbill = BusinessDataServiceHelper.loadSingle("pm_purorderbill", new QFilter[]{new QFilter("billno", QCP.equals, billNo)});
|
||
DynamicObjectCollection billentry = pm_purorderbill.getDynamicObjectCollection("billentry");
|
||
for (DynamicObject dynamicObject : billentry) {
|
||
BigDecimal invqty = dynamicObject.getBigDecimal("invqty");
|
||
if (invqty.compareTo(BigDecimal.ZERO)>0) {
|
||
this.getView().showMessage("部分关单不退回已使用返利");
|
||
return;
|
||
}
|
||
}
|
||
boolean tqq9_isrebatecalculate = pm_purorderbill.getBoolean("tqq9_isrebatecalculate");
|
||
LCLogService lcLogService = new LCLogServiceImpl();
|
||
|
||
// todo 在此添加业务逻辑
|
||
if(!tqq9_isrebatecalculate){
|
||
BigDecimal tqq9_hshfsyje = pm_purorderbill.getBigDecimal("tqq9_hshfsyje");//含税货返使用金额
|
||
BigDecimal tqq9_hsxfsyje = pm_purorderbill.getBigDecimal("tqq9_hsxfsyje");//含税现返使用金额
|
||
String tqq9_hfid = pm_purorderbill.getString("tqq9_hfid");//货返id
|
||
String tqq9_xfid = pm_purorderbill.getString("tqq9_xfid");//现返id
|
||
String billno = pm_purorderbill.getString("billno");//单据编号
|
||
BigDecimal oneHundred = new BigDecimal(100);
|
||
HashMap<String, String> tokenMap = new HashMap<String, String>();
|
||
tokenMap.put("Authorization", FLXT_TOKEN);
|
||
//货返关闭
|
||
if (tqq9_hshfsyje.compareTo(BigDecimal.ZERO) > 0) {
|
||
BigDecimal notaxamount = tqq9_hshfsyje.multiply(oneHundred.divide(oneHundred.add(new BigDecimal(13)), 10, RoundingMode.HALF_UP)).setScale(2, RoundingMode.HALF_UP);
|
||
BigDecimal taxamount = tqq9_hshfsyje.subtract(notaxamount);//税额
|
||
HashMap<String, Object> queryMap = new HashMap<>();
|
||
queryMap.put("id", tqq9_hfid);
|
||
queryMap.put("money", tqq9_hshfsyje);
|
||
queryMap.put("taxAmount", taxamount);
|
||
Gson gson = new Gson();
|
||
try {
|
||
String bodyString = HttpRequestUtils.doGet(Cancel_URL, queryMap, tokenMap);
|
||
JSONObject map = gson.fromJson(bodyString, JSONObject.class);
|
||
Boolean data = map.getBoolean("data");
|
||
if (data == null || !data) {
|
||
lcLogService.savelog("FL-解锁返利金额", Cancel_URL, false, false, queryMap.toString(), bodyString);
|
||
this.getView().showErrorNotification("采购订单:" + billno + ",撤销占用金额失败");
|
||
} else {
|
||
lcLogService.savelog("FL-解锁返利金额", Cancel_URL, false, true, queryMap.toString(), bodyString);
|
||
}
|
||
} catch (IOException ex) {
|
||
lcLogService.savelog("FL-解锁返利金额", Cancel_URL, false, false, queryMap.toString(), "接口调用报错，errormessage:" + ex.getMessage());
|
||
throw new RuntimeException(ex+",请求返利系统失败");
|
||
}
|
||
}
|
||
//现返关闭
|
||
if (tqq9_hsxfsyje.compareTo(BigDecimal.ZERO) > 0) {
|
||
BigDecimal notaxamount = tqq9_hsxfsyje.multiply(oneHundred.divide(oneHundred.add(new BigDecimal(13)), 10, RoundingMode.HALF_UP)).setScale(2, RoundingMode.HALF_UP);
|
||
BigDecimal taxamount = tqq9_hsxfsyje.subtract(notaxamount);//税额
|
||
HashMap<String, Object> 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(Cancel_URL, queryMap, tokenMap);
|
||
JSONObject map = gson.fromJson(bodyString, JSONObject.class);
|
||
Boolean data = map.getBoolean("data");
|
||
if (data == null || !data) {
|
||
lcLogService.savelog("FL-解锁返利金额", Cancel_URL, false, false, queryMap.toString(), bodyString);
|
||
this.getView().showErrorNotification("采购订单:" + billno + ",撤销占用金额失败");
|
||
} else {
|
||
lcLogService.savelog("FL-解锁返利金额", Cancel_URL, false, true, queryMap.toString(), bodyString);
|
||
}
|
||
} catch (IOException ex) {
|
||
lcLogService.savelog("FL-解锁返利金额", Cancel_URL, false, false, queryMap.toString(), "接口调用报错，errormessage:" + ex.getMessage());
|
||
throw new RuntimeException(ex+",请求返利系统失败");
|
||
}
|
||
}
|
||
}else{
|
||
//货返关闭
|
||
BigDecimal tqq9_hshfsyje = pm_purorderbill.getBigDecimal("tqq9_hshfsyje");//含税货返使用金额
|
||
BigDecimal tqq9_hsxfsyje = pm_purorderbill.getBigDecimal("tqq9_hsxfsyje");//含税现返使用金额
|
||
String tqq9_hfid = pm_purorderbill.getString("tqq9_hfid");//货返id
|
||
String tqq9_xfid = pm_purorderbill.getString("tqq9_xfid");//现返id
|
||
String billno = pm_purorderbill.getString("billno");//单据编号
|
||
BigDecimal oneHundred = new BigDecimal(100);
|
||
HashMap<String, String> tokenMap = new HashMap<String, String>();
|
||
tokenMap.put("Authorization", FLXT_TOKEN);
|
||
//货返关闭
|
||
if (tqq9_hshfsyje.compareTo(BigDecimal.ZERO) > 0) {
|
||
DynamicObject supplier = pm_purorderbill.getDynamicObject("supplier");//供应商
|
||
DynamicObject org = pm_purorderbill.getDynamicObject("org");//组织
|
||
String number = org.getString("number");
|
||
DynamicObject org_fl = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name",
|
||
new QFilter[]{new QFilter("number", QCP.equals, number)});
|
||
String orgid_fl = org_fl != null ? org_fl.getString("name") : null;
|
||
BigDecimal notaxamount = tqq9_hshfsyje.multiply(oneHundred.divide(oneHundred.add(new BigDecimal(13)), 10, RoundingMode.HALF_UP)).setScale(2, RoundingMode.HALF_UP);
|
||
BigDecimal taxamount = tqq9_hshfsyje.subtract(notaxamount);//税额
|
||
JSONObject queryMap = new JSONObject();
|
||
queryMap.put("id", tqq9_hfid);
|
||
queryMap.put("money", tqq9_hshfsyje);
|
||
queryMap.put("taxAmount", taxamount);
|
||
queryMap.put("supplierId", supplier.getString("tqq9_ztsupplierid"));
|
||
queryMap.put("companyId", orgid_fl);
|
||
Gson gson = new Gson();
|
||
try {
|
||
String bodyString = HttpRequestUtils.postJson(RETURN_URL, queryMap.toString(), tokenMap);
|
||
JSONObject map = gson.fromJson(bodyString, JSONObject.class);
|
||
Boolean data = map.getBoolean("data");
|
||
if (data == null || !data) {
|
||
lcLogService.savelog("FL-释放返利金额", RETURN_URL, false, false, queryMap.toString(), bodyString);
|
||
this.getView().showErrorNotification("采购订单:" + billno + ",释放返利金额失败");
|
||
} else {
|
||
lcLogService.savelog("FL-释放返利金额", RETURN_URL, false, true, queryMap.toString(), bodyString);
|
||
}
|
||
} catch (IOException ex) {
|
||
lcLogService.savelog("FL-释放返利金额", RETURN_URL, false, false, queryMap.toString(), "接口调用报错，errormessage:" + ex.getMessage());
|
||
throw new RuntimeException(ex+",请求返利系统失败");
|
||
}
|
||
}
|
||
//现返关闭
|
||
if (tqq9_hsxfsyje.compareTo(BigDecimal.ZERO) > 0) {
|
||
DynamicObject supplier = pm_purorderbill.getDynamicObject("supplier");//供应商
|
||
DynamicObject org = pm_purorderbill.getDynamicObject("org");//组织
|
||
String number = org.getString("number");
|
||
DynamicObject org_fl = BusinessDataServiceHelper.loadSingle("tqq9_thirdconfig", "name",
|
||
new QFilter[]{new QFilter("number", QCP.equals, number)});
|
||
String orgid_fl = org_fl != null ? org_fl.getString("name") : null;
|
||
BigDecimal notaxamount = tqq9_hsxfsyje.multiply(oneHundred.divide(oneHundred.add(new BigDecimal(13)), 10, RoundingMode.HALF_UP)).setScale(2, RoundingMode.HALF_UP);
|
||
BigDecimal taxamount = tqq9_hsxfsyje.subtract(notaxamount);//税额
|
||
JSONObject queryMap = new JSONObject();
|
||
queryMap.put("id", tqq9_xfid);
|
||
queryMap.put("money", tqq9_hsxfsyje);
|
||
queryMap.put("taxAmount", taxamount);
|
||
queryMap.put("supplierId", supplier.getString("tqq9_ztsupplierid"));
|
||
queryMap.put("companyId", orgid_fl);
|
||
Gson gson = new Gson();
|
||
try {
|
||
String bodyString = HttpRequestUtils.postJson(RETURN_URL, queryMap.toString(), tokenMap);
|
||
JSONObject map = gson.fromJson(bodyString, JSONObject.class);
|
||
Boolean data = map.getBoolean("data");
|
||
if (data == null || !data) {
|
||
lcLogService.savelog("FL-释放返利金额", RETURN_URL, false, false, queryMap.toString(), bodyString);
|
||
this.getView().showErrorNotification("采购订单:" + billno + ",释放返利金额失败");
|
||
} else {
|
||
lcLogService.savelog("FL-释放返利金额", RETURN_URL, false, true, queryMap.toString(), bodyString);
|
||
}
|
||
} catch (IOException ex) {
|
||
lcLogService.savelog("FL-释放返利金额", RETURN_URL, false, false, queryMap.toString(), "接口调用报错，errormessage:" + ex.getMessage());
|
||
throw new RuntimeException(ex+",请求返利系统失败");
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
}
|
||
} |