Commit bcbc9f5f by lzxry

+1

parent 3732037f
...@@ -93,6 +93,8 @@ public class Contract { ...@@ -93,6 +93,8 @@ public class Contract {
private String barrioName;//行政区域名称 private String barrioName;//行政区域名称
private String belongGroup;//隶属集团 private String belongGroup;//隶属集团
private Long trackFlow;//流量,tkio的
@Id @Id
@GeneratedValue @GeneratedValue
public Long getId() { public Long getId() {
...@@ -567,6 +569,14 @@ public class Contract { ...@@ -567,6 +569,14 @@ public class Contract {
this.barrioName = barrioName; this.barrioName = barrioName;
} }
public Long getTrackFlow() {
return trackFlow;
}
public void setTrackFlow(Long trackFlow) {
this.trackFlow = trackFlow;
}
@Override @Override
public String toString() { public String toString() {
return "Contract{" + return "Contract{" +
......
...@@ -425,7 +425,7 @@ public class ContractServiceImpl implements ContractService { ...@@ -425,7 +425,7 @@ public class ContractServiceImpl implements ContractService {
List list = new ArrayList(); List list = new ArrayList();
if ("tkio".equals(platform) || "io".equals(platform)) { if ( "io".equals(platform)) {
List<PackageType> packageTypeList = packageTypeRepository.findIsNewAll(); List<PackageType> packageTypeList = packageTypeRepository.findIsNewAll();
for (PackageType p : packageTypeList) { for (PackageType p : packageTypeList) {
p.setType("main"); p.setType("main");
......
...@@ -16,6 +16,7 @@ import org.slf4j.LoggerFactory; ...@@ -16,6 +16,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import util.ContractBranchUtil;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.ArrayList; import java.util.ArrayList;
...@@ -109,11 +110,10 @@ public class ShareIncomeServiceImpl implements ShareIncomeService { ...@@ -109,11 +110,10 @@ public class ShareIncomeServiceImpl implements ShareIncomeService {
try (Stream<Contract> streamContract = contracts.parallelStream()) { try (Stream<Contract> streamContract = contracts.parallelStream()) {
streamContract.forEachOrdered(v -> { streamContract.forEachOrdered(v -> {
switch (platform){ switch (ContractBranchUtil.getValue(platform)){
case "type_one":this.shareIncome4Contract(v, start, end); case "type_one":this.shareIncome4Contract(v, start, end);break;
break; case "type_two":this.shareIncome4Contract(v, start, end);break;
case "type_two":this.shareIncome4Contract(v, start, end); default:this.shareIncome4Contract(v, start, end);break;
break;
} }
v.setMyBodyName(bodiesNameMap.get(v.getMyBodyCode())); v.setMyBodyName(bodiesNameMap.get(v.getMyBodyCode()));
......
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