Commit 4abc4c68 authored by zhkwei's avatar zhkwei

Merge remote-tracking branch 'origin/dev_mysql' into dev_mysql

parents fd46b4ca 41c01ae3
...@@ -6,6 +6,7 @@ import java.util.UUID; ...@@ -6,6 +6,7 @@ import java.util.UUID;
public final class Constant { public final class Constant {
public static final String Comma = ","; public static final String Comma = ",";
public static final String Other = "其他"; public static final String Other = "其他";
public static final String ALL = "ALL";
public static final int WholeYear = -1; public static final int WholeYear = -1;
/* ----------------------------- kevin insert -----------------*/ /* ----------------------------- kevin insert -----------------*/
......
...@@ -1931,6 +1931,7 @@ public class DataImportService extends BaseService { ...@@ -1931,6 +1931,7 @@ public class DataImportService extends BaseService {
List<String> orgIds = organizationService.getMyOrgList().stream().map(OrgSelectDto::getId).collect(Collectors.toList()); List<String> orgIds = organizationService.getMyOrgList().stream().map(OrgSelectDto::getId).collect(Collectors.toList());
// 这里会导致任何人都可以看到未映射到主体的数据 // 这里会导致任何人都可以看到未映射到主体的数据
orgIds.add(""); orgIds.add("");
orgIds.add(Constant.ALL);
criteria.andOrganizationIdIn(orgIds).andCreateTimeBetween(strDate, endDate); criteria.andOrganizationIdIn(orgIds).andCreateTimeBetween(strDate, endDate);
example.setOrderByClause("update_time desc"); example.setOrderByClause("update_time desc");
...@@ -1964,7 +1965,13 @@ public class DataImportService extends BaseService { ...@@ -1964,7 +1965,13 @@ public class DataImportService extends BaseService {
List<Integer> dataTypes = param.getDataTypes(); List<Integer> dataTypes = param.getDataTypes();
String operator = authUserHelper.getCurrentAuditor().get(); String operator = authUserHelper.getCurrentAuditor().get();
dataTypes.forEach(type -> { dataTypes.forEach(type -> {
orgs.forEach(o -> { List<Organization> tmpOrgList = Collections.emptyList();
if (type == EbsExtractTypeConstant.RATE) {
tmpOrgList = orgs.stream().limit(1).collect(Collectors.toList());
}else {
tmpOrgList = orgs;
}
tmpOrgList.forEach(o -> {
try { try {
Callable callEbs = new CallEbsThread(type, o, ebsCallUrl, dataImportLogMapper, authUserHelper, Callable callEbs = new CallEbsThread(type, o, ebsCallUrl, dataImportLogMapper, authUserHelper,
idService, dtsTokenService, period, effectiveDateFrom, effectiveDateTo, operator); idService, dtsTokenService, period, effectiveDateFrom, effectiveDateTo, operator);
...@@ -2114,9 +2121,17 @@ public class DataImportService extends BaseService { ...@@ -2114,9 +2121,17 @@ public class DataImportService extends BaseService {
int month = periodInt % 100; int month = periodInt % 100;
DataImportLog log = new DataImportLog(); DataImportLog log = new DataImportLog();
log.setTaxpayerIdNum(org.getTaxPayerNumber()); log.setTaxpayerIdNum(org.getTaxPayerNumber());
log.setOrganizationId(org.getId());
log.setCompanyCode(code); if (type == EbsExtractTypeConstant.RATE) {
log.setCompanyName(org.getName()); log.setCompanyName(Constant.ALL);
log.setOrganizationId(Constant.ALL);
log.setCompanyCode(Constant.ALL);
} else {
log.setCompanyName(org.getName());
log.setOrganizationId(org.getId());
log.setCompanyCode(code);
}
log.setPeriodYear(year); log.setPeriodYear(year);
log.setPeriodMonth(month); log.setPeriodMonth(month);
log.setType(EnumImportType.ExtractFinancialData.getCode()); log.setType(EnumImportType.ExtractFinancialData.getCode());
......
...@@ -1586,7 +1586,7 @@ constant.fileTypeList = [ ...@@ -1586,7 +1586,7 @@ constant.fileTypeList = [
{code: 104, type: "资产负债表"}, {code: 104, type: "资产负债表"},
{code: 105, type: "利润表"}, {code: 105, type: "利润表"},
{code: 106, type: "直接法现金流量表"}, {code: 106, type: "直接法现金流量表"},
{code: 107, type: "所有者权益变动表"}, // {code: 107, type: "所有者权益变动表"}, //todo 暂未开放
{code: 108, type: "汇率表"} {code: 108, type: "汇率表"}
]; ];
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment