科目余额表取数
This commit is contained in:
zhangzhiguo
parent
12e0744b63
commit
cce3525cb6
|
|
@ -0,0 +1,150 @@
|
|||
package zcgj.zcdev.zcdev.fs.plugin.common;
|
||||
|
||||
import com.google.gson.Gson;
|
||||
import com.google.gson.reflect.TypeToken;
|
||||
import kd.bos.dataentity.entity.DynamicObject;
|
||||
import kd.bos.db.DB;
|
||||
import kd.bos.db.DBRoute;
|
||||
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.SaveServiceHelper;
|
||||
import zcgj.zcdev.zcdev.fs.utils.AccountRecord;
|
||||
import zcgj.zcdev.zcdev.fs.utils.BalanceQueryParamApi;
|
||||
|
||||
import java.lang.reflect.Type;
|
||||
import java.util.*;
|
||||
|
||||
public class AssistbalanceAutoData {
|
||||
|
||||
public static void getData(){
|
||||
String[] selectorsArray = new String[]{"beginlocal", "endlocal", "yeardebitfor","yearcreditfor","debitlocal","creditlocal"};
|
||||
|
||||
QFilter filteraccountTable = new QFilter("number", QCP.equals, "0003");
|
||||
DynamicObject accountTableLoad = BusinessDataServiceHelper.loadSingle("bd_accounttable", "id", new QFilter[]{filteraccountTable});
|
||||
|
||||
QFilter number = new QFilter("fisaccounting", "=", "1");
|
||||
QFilter structure = new QFilter("structure.longnumber", QCP.like, "10000000!10006431%");
|
||||
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});
|
||||
|
||||
DynamicObject[] accountConf = BusinessDataServiceHelper.load("zcgj_conf_balanceaccount", "zcgj_account", new QFilter[]{});
|
||||
Set<String> accountNumber = new HashSet<>();
|
||||
for (DynamicObject dynamicObject : accountConf) {
|
||||
accountNumber.add(dynamicObject.getDynamicObject("zcgj_account").getString("number"));
|
||||
}
|
||||
|
||||
List<Long> orgIds = new ArrayList<>();
|
||||
Map<String,DynamicObject> orgNumberMap = new HashMap<>();
|
||||
for (int i = 0; i < load.length; i++) {
|
||||
DynamicObject dynamicObject = load[i];
|
||||
orgNumberMap.put(dynamicObject.getString("number"), dynamicObject);
|
||||
orgIds.add(dynamicObject.getLong("id"));
|
||||
}
|
||||
|
||||
|
||||
//查询组织下对应的当前期间数据
|
||||
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[]{});
|
||||
List<Object[]> sqlparams = new ArrayList<>();
|
||||
Object[] sqlparam = new Object[] { false };
|
||||
sqlparams.add(sqlparam);
|
||||
DB.executeBatch(DBRoute.of("fi"),
|
||||
"update tk_zcgj_rpt_assistbalance set fk_zcgj_isnew = ? ", sqlparams);
|
||||
|
||||
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);
|
||||
assistbalance.set("zcgj_isnew",true);
|
||||
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);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,33 +1,17 @@
|
|||
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.util.SystemParamHelper;
|
||||
import kd.bos.logging.Log;
|
||||
import kd.bos.logging.LogFactory;
|
||||
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;
|
||||
import zcgj.zcdev.zcdev.fs.plugin.common.AssistbalanceAutoData;
|
||||
|
||||
/**
|
||||
* 核算维度余额取数表(矿山二开)
|
||||
*/
|
||||
public class AssistbalancePlugin extends AbstractListPlugin implements Plugin {
|
||||
|
||||
private static final Log log = LogFactory.getLog(AssistbalancePlugin.class);
|
||||
|
||||
public static String ksNumberTop = "10006431"; //矿山总部组织编码
|
||||
@Override
|
||||
|
|
@ -35,141 +19,9 @@ public class AssistbalancePlugin extends AbstractListPlugin implements Plugin {
|
|||
super.itemClick(evt);
|
||||
String itemKey = evt.getItemKey();
|
||||
if("zcgj_gatdata".equals(itemKey)) {
|
||||
String[] selectorsArray = new String[]{"beginlocal", "endlocal", "yeardebitfor","yearcreditfor","debitlocal","creditlocal"};
|
||||
|
||||
QFilter filteraccountTable = new QFilter("number", QCP.equals, "0003");
|
||||
DynamicObject accountTableLoad = BusinessDataServiceHelper.loadSingle("bd_accounttable", "id", new QFilter[]{filteraccountTable});
|
||||
|
||||
QFilter number = new QFilter("fisaccounting", "=", "1");
|
||||
QFilter structure = new QFilter("structure.longnumber", QCP.like, "10000000!10006431%");
|
||||
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});
|
||||
|
||||
DynamicObject[] accountConf = BusinessDataServiceHelper.load("zcgj_conf_balanceaccount", "zcgj_account", new QFilter[]{});
|
||||
Set<String> accountNumber = new HashSet<>();
|
||||
for (DynamicObject dynamicObject : accountConf) {
|
||||
accountNumber.add(dynamicObject.getDynamicObject("zcgj_account").getString("number"));
|
||||
}
|
||||
|
||||
List<Long> orgIds = new ArrayList<>();
|
||||
Map<String,DynamicObject> orgNumberMap = new HashMap<>();
|
||||
for (int i = 0; i < load.length; i++) {
|
||||
DynamicObject dynamicObject = load[i];
|
||||
orgNumberMap.put(dynamicObject.getString("number"), dynamicObject);
|
||||
orgIds.add(dynamicObject.getLong("id"));
|
||||
}
|
||||
|
||||
|
||||
//查询组织下对应的当前期间数据
|
||||
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);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
//balanceQueryParam.setAccountAssgrp();
|
||||
//科目余额表自动取数
|
||||
AssistbalanceAutoData.getData();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public Set<Long> getKsOrg(){
|
||||
QFilter filterOrgId = new QFilter("number", QCP.equals,ksNumberTop);//中材矿山建设有限公司
|
||||
DynamicObject adminOrg = BusinessDataServiceHelper.loadSingle("bos_org", "number,name,fullname", new QFilter[]{filterOrgId});
|
||||
long orgId = adminOrg.getLong("id");
|
||||
List<Long> orgIds = new ArrayList<>(1);
|
||||
//orgIds.add(1692204547985902592L);
|
||||
orgIds.add(orgId);
|
||||
List<Long> subOrgIds = OrgUnitServiceHelper.getAllSubordinateOrgs(1L, orgIds, true);
|
||||
return subOrgIds.stream().collect(Collectors.toSet());
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,27 @@
|
|||
package zcgj.zcdev.zcdev.fs.plugin.task;
|
||||
|
||||
import kd.bos.context.RequestContext;
|
||||
import kd.bos.entity.operate.result.OperationResult;
|
||||
import kd.bos.exception.KDException;
|
||||
import kd.bos.logging.Log;
|
||||
import kd.bos.logging.LogFactory;
|
||||
import kd.bos.schedule.executor.AbstractTask;
|
||||
import kd.bos.servicehelper.operation.OperationServiceHelper;
|
||||
import zcgj.zcdev.zcdev.fs.plugin.common.AssistbalanceAutoData;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 科目余额取数表自动取数
|
||||
*/
|
||||
public class AssistbalanceTask extends AbstractTask {
|
||||
|
||||
private static final Log log = LogFactory.getLog(AssistbalanceTask.class);
|
||||
|
||||
@Override
|
||||
public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
|
||||
log.info("AssistbalanceTask,进入到后台任务中-开始");
|
||||
AssistbalanceAutoData.getData();
|
||||
log.info("AssistbalanceTask,进入到后台任务中-结束");
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue