diff --git a/main/java/shkd/repc/repmd/formplugin/TotalAssignmentPlugin.java b/main/java/shkd/repc/repmd/formplugin/TotalAssignmentPlugin.java index 89fa431..0cdfff3 100644 --- a/main/java/shkd/repc/repmd/formplugin/TotalAssignmentPlugin.java +++ b/main/java/shkd/repc/repmd/formplugin/TotalAssignmentPlugin.java @@ -1,5 +1,7 @@ package shkd.repc.repmd.formplugin; +import com.alibaba.dubbo.common.utils.CollectionUtils; +import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import kd.bos.dataentity.OperateOption; import kd.bos.dataentity.entity.DynamicObject; @@ -12,6 +14,7 @@ import kd.bos.entity.datamodel.events.BeforeImportEntryEventArgs; import kd.bos.entity.datamodel.events.ImportDataEventArgs; import kd.bos.entity.datamodel.events.PropertyChangedArgs; import kd.bos.entity.operate.result.OperationResult; +import kd.bos.entity.plugin.ImportLogger; import kd.bos.form.container.Tab; import kd.bos.form.control.Control; import kd.bos.form.control.EntryGrid; @@ -34,10 +37,7 @@ import kd.tsc.tsrbs.business.domain.oprecord.service.helper.OprecordHelper; import java.math.BigDecimal; import java.math.RoundingMode; -import java.util.ArrayList; -import java.util.EventObject; -import java.util.HashMap; -import java.util.Map; +import java.util.*; /** * 位置:【项目主数据】-【项目建立】-表单插件 @@ -46,15 +46,23 @@ import java.util.Map; */ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClickEventListener, Plugin { + private static final String BILL_NAME="billname"; + + private static final String RENTAL_AREA="qeug_decimalfield5"; + + private static final String RENTAL_AREA_ENTRY="qeug_productentry_saleare"; private static final String ENTRY_VALUE = "qeug_jrgsbsz"; private static final String PRODUCT_ENTRY = "productentry"; + + private static final String PRODUCT_TYPE = "productentry_producttype"; + + private static final String PRODUCT_TYPE_NUMBER = "productentry_producttype.longnumber"; private static final String SUB_ENTRY = "qeug_subentryentity"; // 控件缓存 private Label publicAmountLabel; - //private Label pubInsideAmountLabel; private Label watertightAmountLabel; - private Label hardcoverAmount; + private Label hardcoverAmountLabel; @Override public void registerListener(EventObject e) { @@ -66,9 +74,8 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic entryGrid.addRowClickListener(this); // 缓存控件，减少重复调用 publicAmountLabel = (Label) this.getControl("qeug_publicamount"); - //pubInsideAmountLabel = (Label) this.getControl("qeug_pubinsideamount"); watertightAmountLabel = (Label) this.getControl("qeug_watertightamount"); - hardcoverAmount = (Label) this.getControl("qeug_hardcoveramount"); + hardcoverAmountLabel = (Label) this.getControl("qeug_hardcoveramount"); } @@ -98,28 +105,44 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic @Override public void propertyChanged(PropertyChangedArgs e) { super.propertyChanged(e); + publicAmountLabel = (Label) this.getControl("qeug_publicamount"); + watertightAmountLabel = (Label) this.getControl("qeug_watertightamount"); + hardcoverAmountLabel = (Label) this.getControl("qeug_hardcoveramount"); String fieldKey = e.getProperty().getName(); - if (ENTRY_VALUE.equals(fieldKey)) { - //当前变更分录关联产品构成是否未保存 - DynamicObjectCollection collections = (DynamicObjectCollection) this.getModel().getValue(SUB_ENTRY); - DynamicObject parent = (DynamicObject) collections.get(0).getParent(); - Long id = parent.getLong("id"); - if (id != 0L) { - //更新指标信息数据 - Object pkValue = this.getModel().getValue("id"); - Long typeId = parent.getLong("productentry_producttype.id"); - this.updateMetricInfo(collections, typeId, pkValue); - //更新产品构成数据（不切换标签也能生效） + switch (fieldKey){ + case ENTRY_VALUE: + DynamicObjectCollection collections = (DynamicObjectCollection) this.getModel().getValue(SUB_ENTRY); + DynamicObject parent = (DynamicObject) collections.get(0).getParent(); + Long id = parent.getLong("id"); + if (id != 0L) { + //更新指标信息数据 + Object pkValue = this.getModel().getValue("id"); + Long typeId = parent.getLong("productentry_producttype.id"); + this.updateMetricInfo(collections, typeId, pkValue); + //更新产品构成数据（不切换标签也能生效） + DynamicObjectCollection productEntry = this.getModel().getEntryEntity(PRODUCT_ENTRY); + this.setProductEntryValue(productEntry,collections,id); + } + break; + case BILL_NAME: + String value = (String) this.getModel().getValue("billno"); + if (value != null) { + this.getView().addClientCallBack("auto_save", 0); + } + break; + case RENTAL_AREA_ENTRY: + BigDecimal canSaleArea=BigDecimal.ZERO; DynamicObjectCollection productEntry = this.getModel().getEntryEntity(PRODUCT_ENTRY); - this.setProductEntryValue(productEntry,collections,id); - - } - - } else if ("billname".equals(fieldKey)) { - String value = (String) this.getModel().getValue("billno"); - if (value != null) { - this.getView().addClientCallBack("auto_save", 0); - } + if (null!=productEntry){ + for (DynamicObject dynamicObject : productEntry) { + BigDecimal area = dynamicObject.getBigDecimal(RENTAL_AREA_ENTRY); + if (area.compareTo(BigDecimal.ZERO)!=0){ + canSaleArea=canSaleArea.add(area); + } + } + this.getModel().setValue(RENTAL_AREA,canSaleArea); + } + break; } } @@ -152,8 +175,9 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic //先清空计入估算表数值再赋值，触发保存 for (int j = 0; j < collections.size(); j++) { this.getModel().setValue("qeug_jrgsbsz", BigDecimal.ZERO, j, i); - BigDecimal all = collections.get(j).getBigDecimal("qeug_hjs"); - this.getModel().setValue("qeug_jrgsbsz", all, j, i); + BigDecimal hjs = collections.get(j).getBigDecimal("qeug_hjs"); + BigDecimal tzz = collections.get(j).getBigDecimal("qeug_tzz"); + this.getModel().setValue("qeug_jrgsbsz", hjs.add(tzz), j, i); } } this.getView().addClientCallBack("auto_save", 0); @@ -170,11 +194,21 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic Object pkValue = this.getModel().getValue("id"); DynamicObjectCollection productEntry = this.getModel().getEntryEntity(PRODUCT_ENTRY); if (null != productEntry && productEntry.size() != 0) { - for (DynamicObject dynamicObject : productEntry) { - if (dynamicObject.getBigDecimal("productentry_buildingarea").compareTo(BigDecimal.ZERO) == 0) { - DynamicObjectCollection collections = dynamicObject.getDynamicObjectCollection(SUB_ENTRY); + for (int i = 0; i < productEntry.size(); i++) { + if (productEntry.get(i).getBigDecimal("productentry_buildingarea").compareTo(BigDecimal.ZERO) == 0) { + DynamicObjectCollection collections = productEntry.get(i).getDynamicObjectCollection(SUB_ENTRY); + //防水面积赋值 + BigDecimal waterproofArea = collections.stream() + .filter(collection -> "防水".equals(collection.getString("qeug_fl"))) // 排除 "防水" 类型 + .map(collection -> { + BigDecimal hjs = collection.getBigDecimal("qeug_hjs"); + BigDecimal tzz = collection.getBigDecimal("qeug_tzz"); + return hjs.add(tzz); + }) + .reduce(BigDecimal.ZERO, BigDecimal::add); + this.getModel().setValue("qeug_waterproofarea",waterproofArea,i); //指标信息赋值 - Long typeId = dynamicObject.getLong("productentry_producttype.id"); + Long typeId = productEntry.get(i).getLong("productentry_producttype.id"); this.updateMetricInfo(collections, typeId, pkValue); } } @@ -182,10 +216,113 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic tab.activeTab("indexpage_tab"); } } else if (StringUtils.equals("deleteproductentry", evt.getItemKey())) { + //保存表单 this.getView().addClientCallBack("auto_save", 0); + //清空标签控件 + updateLabel(publicAmountLabel, BigDecimal.ZERO); + updateLabel(watertightAmountLabel, BigDecimal.ZERO); + updateLabel(hardcoverAmountLabel, BigDecimal.ZERO); } } + @Override + public void beforeImportEntry(BeforeImportEntryEventArgs e) { + super.beforeImportEntry(e); + Set existCodes = new HashSet<>(); + DynamicObjectCollection orderFormEntry = (DynamicObjectCollection) this.getModel().getValue(PRODUCT_ENTRY); + if (null != orderFormEntry && orderFormEntry.size() != 0) { + for (DynamicObject dynamicObject : orderFormEntry) { + String number = dynamicObject.getString(PRODUCT_TYPE_NUMBER); + existCodes.add(number); + } + } + Set>> entries = ((HashMap) e.getSource()).entrySet(); + for (Map.Entry> entry : entries) { + String entryName = entry.getKey(); + List entryEntityImportDataList = entry.getValue(); + if (CollectionUtils.isEmpty(entryEntityImportDataList)) { + return; + } + Map indexVsMsgMap = validateEntry(entryEntityImportDataList, existCodes); + Set indexSet = indexVsMsgMap.keySet(); + Map> logMap = e.getEntryDataMap(); + ImportLogger importLogger = (ImportLogger) logMap.get(entryName).get(0); + for (Map.Entry indexVsMsgEntry : indexVsMsgMap.entrySet()) { + Integer index = indexVsMsgEntry.getKey(); + importLogger.log(index, indexVsMsgEntry.getValue()); + importLogger.fail(); + importLogger.setTotal(importLogger.getTotal() + 1); + } + Iterator iterator = entryEntityImportDataList.iterator(); + while (iterator.hasNext()) { + ImportEntryData entryData = iterator.next(); + Integer rowNum = (Integer) entryData.getData().get("rowNum"); + if (indexSet.contains(rowNum)) { + iterator.remove(); + } + } + // **合并相同编码的 qeug_subentryentity** + Map> groupedByNumber = new HashMap<>(); + + // 将 entryEntityImportDataList 按照 number 分组 + for (ImportEntryData entryData : entryEntityImportDataList) { + String number = entryData.getData().getJSONObject("productentry_producttype").getString("number"); + groupedByNumber.putIfAbsent(number, new ArrayList<>()); + groupedByNumber.get(number).add(entryData); + } + + // 遍历按 number 分组的条目并合并 qeug_subentryentity + List mergedEntries = new ArrayList<>(); + for (List groupedEntries : groupedByNumber.values()) { + ImportEntryData firstEntry = groupedEntries.get(0); + JSONArray mergedSubEntryEntities = firstEntry.getData().getJSONArray("qeug_subentryentity"); + + // 合并相同 number 的所有 qeug_subentryentity + for (int i = 1; i < groupedEntries.size(); i++) { + ImportEntryData currentEntry = groupedEntries.get(i); + JSONArray currentSubEntryEntities = currentEntry.getData().getJSONArray("qeug_subentryentity"); + // 将当前的 qeug_subentryentity 加入到 mergedSubEntryEntities + mergedSubEntryEntities.addAll(currentSubEntryEntities); + } + + // 更新第一个条目的 qeug_subentryentity 为合并后的结果 + firstEntry.getData().put("qeug_subentryentity", mergedSubEntryEntities); + + // 将合并后的条目添加到结果列表中 + mergedEntries.add(firstEntry); + } + + // 更新 entryEntityImportDataList 为合并后的条目 + entryEntityImportDataList.clear(); + entryEntityImportDataList.addAll(mergedEntries); + } + + } + + private Map validateEntry(List entryEntityImportDataList, Set existCodes) { + Map indexVsMsgMap = new HashMap<>(); + for (int i = 0; i < entryEntityImportDataList.size(); i++) { + ImportEntryData entryData = entryEntityImportDataList.get(i); + // 获取当前行的 JSONObject 数据 + JSONObject data = entryData.getData(); + Map map = data.toJavaObject(Map.class); + JSONObject productType = (JSONObject) map.get(PRODUCT_TYPE); + // 获取编码 + String number = productType.getString("number"); + // 获取当前行号 + Integer rowNum = (Integer) entryData.getData().get("rowNum"); + // 校验物料编码和物料单位 + if (number == null || number.trim().isEmpty()) { + indexVsMsgMap.put(rowNum, "第" + (i + 1) + "行：产品类型编码不能为空或空字符串"); + } + // 校验物料编码是否已经存在于当前页面的表格中 + if (existCodes.contains(number)) { + indexVsMsgMap.put(rowNum, "第" + (i + 1) + "行：产品类型编码已存在表单分录，不能重复导入"); + } + } + return indexVsMsgMap; + } + private void onlyCalculateArea(DynamicObjectCollection subEntryEntity) { if (subEntryEntity == null || subEntryEntity.isEmpty()) { return; // 防止空集合 @@ -215,6 +352,8 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic case "防水": watertight = watertight.add(value); break; + case "非标": + break; default: this.getView().showMessage("无效的分类: " + type + ", 请重新选择！"); break; @@ -225,7 +364,7 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic // 更新控件显示 updateLabel(publicAmountLabel, publicArea); updateLabel(watertightAmountLabel, watertight); - updateLabel(hardcoverAmount, hardcover); + updateLabel(hardcoverAmountLabel, hardcover); } @@ -261,12 +400,23 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic .map(collection -> { // 获取 BigDecimal 值，如果为 null，则使用 BigDecimal.ZERO BigDecimal hjs = collection.getBigDecimal("qeug_hjs") != null ? collection.getBigDecimal("qeug_hjs") : BigDecimal.ZERO; - return hjs; + BigDecimal tzz = collection.getBigDecimal("qeug_tzz") != null ? collection.getBigDecimal("qeug_tzz") : BigDecimal.ZERO; + return hjs.add(tzz); }) .reduce(BigDecimal.ZERO, BigDecimal::add); // 累加所有的面积 - // 获取地上面积 - 地下面积 - BigDecimal groundSummary = allArea.subtract(groundFloorSummary); + //获取防水面积 + BigDecimal waterproofArea = collections.stream() + .filter(collection -> "防水".equals(collection.getString("qeug_fl"))) // 排除 "防水" 类型 + .map(collection -> { + BigDecimal hjs = collection.getBigDecimal("qeug_hjs"); + BigDecimal tzz = collection.getBigDecimal("qeug_tzz"); + return hjs.add(tzz); + }) + .reduce(BigDecimal.ZERO, BigDecimal::add); + + // 获取地上面积 - 地下面积 - 防水面积 + BigDecimal groundSummary = allArea.subtract(groundFloorSummary).subtract(waterproofArea); // 获取精装面积汇总值 BigDecimal hardcoverSummary = collections.stream() @@ -274,7 +424,8 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic .map(collection -> { // 获取 BigDecimal 值，如果为 null，则使用 BigDecimal.ZERO BigDecimal hjs = collection.getBigDecimal("qeug_hjs") != null ? collection.getBigDecimal("qeug_hjs") : BigDecimal.ZERO; - return hjs; + BigDecimal tzz = collection.getBigDecimal("qeug_tzz") != null ? collection.getBigDecimal("qeug_tzz") : BigDecimal.ZERO; + return hjs.add(tzz); }) .reduce(BigDecimal.ZERO, BigDecimal::add); // 累加所有的 "套内" 面积 @@ -305,22 +456,48 @@ public class TotalAssignmentPlugin extends AbstractFormPlugin implements RowClic * @param id 产品构成分录id */ private void setProductEntryValue(DynamicObjectCollection productEntry, DynamicObjectCollection collections, Long id) { - - BigDecimal allArea = collections.stream() - .filter(collection -> !"防水".equals(collection.getString("qeug_fl"))) // 排除 "防水" 类型 + //公区面积汇总 + BigDecimal publicArea = collections.stream() + .filter(collection -> "公区".equals(collection.getString("qeug_fl"))) // 排除 "防水" 类型 .map(collection -> { BigDecimal hjs = collection.getBigDecimal("qeug_hjs"); - return hjs != null ? hjs : BigDecimal.ZERO; + BigDecimal tzz = collection.getBigDecimal("qeug_tzz"); + return hjs.add(tzz); }) .reduce(BigDecimal.ZERO, BigDecimal::add); + //套内面积汇总 + BigDecimal hardcoverArea = collections.stream() + .filter(collection -> "套内".equals(collection.getString("qeug_fl"))) // 排除 "防水" 类型 + .map(collection -> { + BigDecimal hjs = collection.getBigDecimal("qeug_hjs"); + BigDecimal tzz = collection.getBigDecimal("qeug_tzz"); + return hjs.add(tzz); + }) + .reduce(BigDecimal.ZERO, BigDecimal::add); + //防水面积汇总 + BigDecimal waterproofArea = collections.stream() + .filter(collection -> "防水".equals(collection.getString("qeug_fl"))) // 排除 "防水" 类型 + .map(collection -> { + BigDecimal hjs = collection.getBigDecimal("qeug_hjs"); + BigDecimal tzz = collection.getBigDecimal("qeug_tzz"); + return hjs.add(tzz); + }) + .reduce(BigDecimal.ZERO, BigDecimal::add); + for (int i = 0; i < productEntry.size(); i++) { DynamicObject dynamicObject = productEntry.get(i); Long id1 = dynamicObject.getLong("id"); if (id1.compareTo(id) == 0) { - dynamicObject.set("productentry_buildingarea", allArea); + dynamicObject.set("productentry_buildingarea", publicArea.add(hardcoverArea)); + dynamicObject.set("qeug_waterproofarea",waterproofArea); this.getView().updateView("productentry_buildingarea",i); + this.getView().updateView("qeug_waterproofarea",i); break; } } + // 更新控件显示 + updateLabel(publicAmountLabel, publicArea); + updateLabel(watertightAmountLabel, waterproofArea); + updateLabel(hardcoverAmountLabel, hardcoverArea); } }