科目余额表取数

code/zcdev/zcgj-zcdev-zcdev-fs/src/main/java/zcgj/zcdev/zcdev/fs/plugin/form/AssistbalancePlugin.java

@@ -1,16 +1,25 @@
 package zcgj.zcdev.zcdev.fs.plugin.form;
 
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
 import kd.bos.dataentity.entity.DynamicObject;
 import kd.bos.form.control.events.ItemClickEvent;
 import kd.bos.list.plugin.AbstractListPlugin;
+import kd.bos.openapi.common.result.OpenApiResult;
+import kd.bos.openapi.common.util.OpenApiSdkUtil;
 import kd.bos.orm.query.QCP;
 import kd.bos.orm.query.QFilter;
 import kd.bos.servicehelper.BusinessDataServiceHelper;
+import kd.bos.servicehelper.operation.DeleteServiceHelper;
+import kd.bos.servicehelper.operation.SaveServiceHelper;
 import kd.bos.servicehelper.org.OrgUnitServiceHelper;
 import kd.fi.gl.servicehelper.BalanceQueryParam;
-import kd.fi.gl.servicehelper.BanlanceServiceHelper;
+import kd.fi.gl.util.SystemParamHelper;
 import kd.sdk.plugin.Plugin;
+import zcgj.zcdev.zcdev.fs.utils.AccountRecord;
+import zcgj.zcdev.zcdev.fs.utils.BalanceQueryParamApi;
 
+import java.lang.reflect.Type;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -26,54 +35,128 @@ public class AssistbalancePlugin extends AbstractListPlugin implements Plugin  {
         super.itemClick(evt);
         String itemKey = evt.getItemKey();
         if("zcgj_gatdata".equals(itemKey)) {
-            BalanceQueryParam balanceQueryParam = new BalanceQueryParam();
             String[] selectorsArray = new String[]{"beginlocal", "endlocal",  "yeardebitfor","yearcreditfor","debitlocal","creditlocal"};
-            Arrays.asList(selectorsArray).forEach(balanceQueryParam::addSelector);
 
-            QFilter filterOrgId = new QFilter("number", QCP.equals,"100002");//主账簿
+            QFilter filteraccountTable = new QFilter("number", QCP.equals, "0003");
-            DynamicObject accountbookstype = BusinessDataServiceHelper.loadSingle("bd_accountbookstype", "id,number", new QFilter[]{filterOrgId});
+            DynamicObject accountTableLoad = BusinessDataServiceHelper.loadSingle("bd_accounttable", "id", new QFilter[]{filteraccountTable});
-            balanceQueryParam.setBookTypeId(accountbookstype.getLong("id"));
 
-            QFilter filterperiod = new QFilter("number", QCP.equals,"202501");//期间
+            QFilter number = new QFilter("fisaccounting", "=", "1");
-            DynamicObject period = BusinessDataServiceHelper.loadSingle("bd_period", "id,number", new QFilter[]{filterperiod});
+            QFilter structure = new QFilter("structure.longnumber", QCP.like, "10000000!10006431%");
-            balanceQueryParam.setPeriodId(period.getLong("id"));
+            QFilter isleaf = new QFilter("structure.isleaf", QCP.equals, true);
+            DynamicObject[] load = BusinessDataServiceHelper.load("bos_org", "id,structure.longnumber,structure.view", new QFilter[]{number, structure,isleaf});
 
-            QFilter filtercurrency= new QFilter("number", QCP.equals,"CNY");//币别
+            DynamicObject[] accountConf = BusinessDataServiceHelper.load("zcgj_conf_balanceaccount", "zcgj_account", new QFilter[]{});
-            DynamicObject currency = BusinessDataServiceHelper.loadSingle("bd_currency", "id,number", new QFilter[]{filtercurrency});
+            Set<String> accountNumber = new HashSet<>();
-            balanceQueryParam.setCurrencyId(currency.getLong("id"));
+            for (DynamicObject dynamicObject : accountConf) {
+                accountNumber.add(dynamicObject.getDynamicObject("zcgj_account").getString("number"));
+            }
 
-            QFilter filteraccount= new QFilter("number", QCP.equals,"112204");//会计科目
+            List<Long> orgIds = new ArrayList<>();
-            DynamicObject account = BusinessDataServiceHelper.loadSingle("bd_accountview", "id,number", new QFilter[]{filteraccount});
+            Map<String,DynamicObject> orgNumberMap = new HashMap<>();
-
+            for (int i = 0; i < load.length; i++) {
-            List<Map<String, Long>> paramMap = new ArrayList<>();
+                DynamicObject dynamicObject = load[i];
-            Map<String, Long> map = new HashMap<>();
+                orgNumberMap.put(dynamicObject.getString("number"), dynamicObject);
-            map.put("0001",0L);
+                orgIds.add(dynamicObject.getLong("id"));
-            paramMap.add(map);
-            balanceQueryParam.setAccountAssgrp(account.getLong("id"),paramMap);
-            balanceQueryParam.addGroupBy("0001");
-            balanceQueryParam.addGroupBy("account");
-            for (Long orgId : getKsOrg()) {
-                balanceQueryParam.setOrgId(orgId);
-                List<Map<String, Object>> balance = BanlanceServiceHelper.getBalance(balanceQueryParam);
-                System.out.println();
             }
 
 
+            //查询组织下对应的当前期间数据
+            DynamicObject[] orgByCurperiod = BusinessDataServiceHelper.load("gl_accountbook",
+                    "org,curperiod",
+                    new QFilter[]{new QFilter("enable", QCP.equals, Boolean.TRUE).
+                            and("status", QCP.equals, "C").and("org.id", QCP.in, orgIds)});
+            /*Map<Long, DynamicObject> orgByCurperiodMap =
+                    Arrays.stream(orgByCurperiod).collect(Collectors.toMap(
+                            i -> i.getLong("org.id"),
+                    i -> i));*/
+            Map<Long, DynamicObject> orgByCurperiodMap = new HashMap<>();
+            for (DynamicObject dynamicObject : orgByCurperiod) {
+                orgByCurperiodMap.put(dynamicObject.getLong("org.id"), dynamicObject);
+            }
+
+            //清除数据
+            DeleteServiceHelper.delete("zcgj_rpt_assistbalance",new QFilter[]{});
+            for (String orgNumber : orgNumberMap.keySet()) {
+                BalanceQueryParamApi balanceQueryParamApi = new BalanceQueryParamApi();
+                balanceQueryParamApi.setSelectors(Arrays.asList(selectorsArray));
+                // balanceQueryParamApi.setOrgNumber("cw000102");
+                balanceQueryParamApi.setOrgNumber(orgNumber);
+                balanceQueryParamApi.setBookTypeNumber("100002"); //账簿类型
+                balanceQueryParamApi.setAccountTableNumber("0003");//科目表
+
+                DynamicObject orgObj = orgNumberMap.get(orgNumber);
+                DynamicObject periodObj = orgByCurperiodMap.get(orgObj.getLong("id"));
+                DynamicObject curperiod = null;
+                if(periodObj != null) {
+                    curperiod = periodObj.getDynamicObject("curperiod");
+                    if( curperiod!= null) {
+                        balanceQueryParamApi.setPeriodNumber(curperiod.getString("number")); //
+                    }else{
+                        continue;
+                    }
+                }else{
+                    continue;
+                }
+
+                Map<String, List<Map<String, String>>> accountAssgrp = new HashMap<>();
+                List<Map<String, String>> li = new ArrayList<>();
+                Map<String, String> map1 = new HashMap<>();
+                map1.put("0001","");
+                li.add(map1);
+                for (String accNum : accountNumber) {
+                    accountAssgrp.put(accNum,li);
+                }
+                balanceQueryParamApi.setAccountAssgrp(accountAssgrp);
+                List<String> groupBy = new ArrayList<>();
+                groupBy.add("0001");
+                groupBy.add("account");
+                balanceQueryParamApi.setGroupBys(groupBy);
+                Gson gson = new Gson();
+                String json = gson.toJson(balanceQueryParamApi);
+                Map<String, Object> params = gson.fromJson(json,
+                        new TypeToken<Map<String, Object>>(){}.getType());
+
+                OpenApiResult balanceData = OpenApiSdkUtil.invoke("/v2/gl/getBalanceApi", params);
+
+                List<DynamicObject> addEntities = new ArrayList<>();
+                if(balanceData.isStatus()){
+                    String data = (String) balanceData.getData();
+                    Type listType = new TypeToken<List<AccountRecord>>() {}.getType();
+                    List<AccountRecord> records = gson.fromJson(data, listType);
+                    // 示例输出
+                    for (AccountRecord record : records) {
+                        DynamicObject assistbalance
+                                =BusinessDataServiceHelper.newDynamicObject("zcgj_rpt_assistbalance");
+                        assistbalance.set("zcgj_debitlocal", record.getDebitlocal());
+                        assistbalance.set("zcgj_creditlocal", record.getCreditlocal());
+                        assistbalance.set("zcgj_yeardebitfor", record.getYeardebitfor());
+                        assistbalance.set("zcgj_yearcreditfor", record.getYearcreditfor());
+                        assistbalance.set("zcgj_endlocal", record.getEndlocal());
+                        assistbalance.set("zcgj_org",orgNumberMap.get(orgNumber));
+                        assistbalance.set("zcgj_accounttable",accountTableLoad);
+                        assistbalance.set("zcgj_account", record.getAccount());
+                        assistbalance.set("zcgj_period",curperiod);
+
+                        Map<String, AccountRecord.AssGrpItem> assgrp = record.getAssgrp();
+                        if (assgrp.containsKey("0001")) {
+                            assistbalance.set("zcgj_customernumber",assgrp.get("0001").getNumber());
+                            assistbalance.set("zcgj_customername",assgrp.get("0001").getName());
+                        }
+                        addEntities.add(assistbalance);
+                    }
+
+                }
+
+                if (!addEntities.isEmpty()) {
+                    try {
+                        SaveServiceHelper.save(addEntities.toArray(new DynamicObject[0]));
+                    } catch (Exception ex) {
+                        throw new RuntimeException(ex);
+                    }
+                }
+            }
 
-            System.out.println();
-            System.out.println();
             //balanceQueryParam.setAccountAssgrp();
-
-
-            /*
-            private long orgId;
-            private long bookTypeId; ..
-            private long periodId;
-            private long currencyId;
-            private Map<Long, List<Map<String, Long>>> accountAssgrp = new HashMap();
-            private List<String> groupBys = new ArrayList();
-            private boolean isSubstractPL = false;*/
-            //BanlanceServiceHelper.getBalance(balanceQueryParam);
         }
     }
 

code/zcdev/zcgj-zcdev-zcdev-fs/src/main/java/zcgj/zcdev/zcdev/fs/utils/AccountRecord.java

@@ -0,0 +1,102 @@
+package zcgj.zcdev.zcdev.fs.utils;
+
+import java.math.BigDecimal;
+import java.util.Map;
+
+public class AccountRecord {
+    private BigDecimal creditlocal;
+    private Map<String, AssGrpItem> assgrp;
+    private BigDecimal yearcreditfor;
+    private BigDecimal debitlocal;
+    private BigDecimal yeardebitfor;
+    private BigDecimal beginlocal;
+    private long account;
+    private BigDecimal endlocal;
+
+    // getters and setters
+    public BigDecimal getCreditlocal() {
+        return creditlocal;
+    }
+
+    public void setCreditlocal(BigDecimal creditlocal) {
+        this.creditlocal = creditlocal;
+    }
+
+    public Map<String, AssGrpItem> getAssgrp() {
+        return assgrp;
+    }
+
+    public void setAssgrp(Map<String, AssGrpItem> assgrp) {
+        this.assgrp = assgrp;
+    }
+
+    public BigDecimal getYearcreditfor() {
+        return yearcreditfor;
+    }
+
+    public void setYearcreditfor(BigDecimal yearcreditfor) {
+        this.yearcreditfor = yearcreditfor;
+    }
+
+    public BigDecimal getDebitlocal() {
+        return debitlocal;
+    }
+
+    public void setDebitlocal(BigDecimal debitlocal) {
+        this.debitlocal = debitlocal;
+    }
+
+    public BigDecimal getYeardebitfor() {
+        return yeardebitfor;
+    }
+
+    public void setYeardebitfor(BigDecimal yeardebitfor) {
+        this.yeardebitfor = yeardebitfor;
+    }
+
+    public BigDecimal getBeginlocal() {
+        return beginlocal;
+    }
+
+    public void setBeginlocal(BigDecimal beginlocal) {
+        this.beginlocal = beginlocal;
+    }
+
+    public long getAccount() {
+        return account;
+    }
+
+    public void setAccount(long account) {
+        this.account = account;
+    }
+
+    public BigDecimal getEndlocal() {
+        return endlocal;
+    }
+
+    public void setEndlocal(BigDecimal endlocal) {
+        this.endlocal = endlocal;
+    }
+
+    // 嵌套类
+    public static class AssGrpItem {
+        private String number;
+        private String name;
+
+        public String getNumber() {
+            return number;
+        }
+
+        public void setNumber(String number) {
+            this.number = number;
+        }
+
+        public String getName() {
+            return name;
+        }
+
+        public void setName(String name) {
+            this.name = name;
+        }
+    }
+}

code/zcdev/zcgj-zcdev-zcdev-fs/src/main/java/zcgj/zcdev/zcdev/fs/utils/BalanceQueryParamApi.java

@@ -0,0 +1,125 @@
+package zcgj.zcdev.zcdev.fs.utils;
+
+import com.kingdee.bos.webapi.entity.KDException;
+import kd.bos.exception.BosErrorCode;
+import kd.bos.util.JSONUtils;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class BalanceQueryParamApi {
+
+    //查询字段
+    private List<String> selectors = new ArrayList<String>();
+    //组织编码
+    private String orgNumber;
+    //账簿类型编码
+    private String bookTypeNumber;
+    //期间编码
+    private String periodNumber;
+    //币别编码
+    private String currencyNumber;
+    //科目表编码
+    private String accountTableNumber;
+    //科目编码：多组核算维度编码
+    //accountAssgrp的内部Map -> 核算维度类型编码：核算维度值的编码
+    private Map<String, List<Map<String, String>>> accountAssgrp = new HashMap<>();
+    //分组字段；只包含：余额表字段与查询的核算维度
+    private List<String> groupBys = new ArrayList<String>();
+    //是否扣减损益类金额
+    private boolean isSubstractPL = false;
+    //指定科目查询
+    private boolean isSpecialAccount = true;
+
+    public List<String> getSelectors() {
+        return selectors;
+    }
+
+    public void setSelectors(List<String> selectors) {
+        this.selectors = selectors;
+    }
+
+    public String getOrgNumber() {
+        return orgNumber;
+    }
+
+    public void setOrgNumber(String orgNumber) {
+        this.orgNumber = orgNumber;
+    }
+
+    public String getBookTypeNumber() {
+        return bookTypeNumber;
+    }
+
+    public void setBookTypeNumber(String bookTypeNumber) {
+        this.bookTypeNumber = bookTypeNumber;
+    }
+
+    public String getPeriodNumber() {
+        return periodNumber;
+    }
+
+    public void setPeriodNumber(String periodNumber) {
+        this.periodNumber = periodNumber;
+    }
+
+    public String getCurrencyNumber() {
+        return currencyNumber;
+    }
+
+    public void setCurrencyNumber(String currencyNumber) {
+        this.currencyNumber = currencyNumber;
+    }
+
+    public String getAccountTableNumber() {
+        return accountTableNumber;
+    }
+
+    public void setAccountTableNumber(String accountTableNumber) {
+        this.accountTableNumber = accountTableNumber;
+    }
+
+    public Map<String, List<Map<String, String>>> getAccountAssgrp() {
+        return accountAssgrp;
+    }
+
+    public void setAccountAssgrp(Map<String, List<Map<String, String>>> accountAssgrp) {
+        this.accountAssgrp = accountAssgrp;
+    }
+
+    public List<String> getGroupBys() {
+        return groupBys;
+    }
+
+    public void setGroupBys(List<String> groupBys) {
+        this.groupBys = groupBys;
+    }
+
+    public boolean isSubstractPL() {
+        return isSubstractPL;
+    }
+
+    public void setSubstractPL(boolean substractPL) {
+        isSubstractPL = substractPL;
+    }
+
+    public boolean isSpecialAccount() {
+        return isSpecialAccount;
+    }
+
+    public void setSpecialAccount(boolean specialAccount) {
+        isSpecialAccount = specialAccount;
+    }
+
+    @Override
+    public String toString() {
+        try {
+            return JSONUtils.toString(this);
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}