package com.by4cloud.platformx.business.service.impl;
|
|
import cn.hutool.core.util.ArrayUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.by4cloud.platformx.admin.api.entity.SysDictItem;
|
import com.by4cloud.platformx.admin.api.feign.RemoteDeptService;
|
import com.by4cloud.platformx.admin.api.feign.RemoteDictService;
|
import com.by4cloud.platformx.business.dto.AnalysisCommonDTO;
|
import com.by4cloud.platformx.business.mapper.ContractMapper;
|
import com.by4cloud.platformx.business.service.StatisticService;
|
import com.by4cloud.platformx.business.vo.*;
|
import com.by4cloud.platformx.common.core.util.R;
|
import com.by4cloud.platformx.common.security.util.SecurityUtils;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Service
|
@RequiredArgsConstructor
|
public class StatisticServiceImpl implements StatisticService {
|
|
private final ContractMapper contractMapper;
|
private final RemoteDeptService remoteDeptService;
|
private final RemoteDictService remoteDictService;
|
|
@Value("${dept.smj}")
|
private String smj;
|
|
@Value("${dept.sgb}")
|
private String sgb;
|
|
@Value("${dept.jxc}")
|
private String jxc;
|
|
@Value("${dept.tfgs}")
|
private String tfgs;
|
|
@Value("${dept.ymj}")
|
private String ymj;
|
|
@Override
|
public R contractAmountAnalysis(AnalysisCommonDTO commonDTO) {
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractAmountAnalysisVo> contractAmountAnalysisVoList = contractMapper.contractAmountAnalysis(commonDTO,compIds);
|
return R.ok(contractAmountAnalysisVoList);
|
}
|
|
@Override
|
public R contractAmountAnalysisByComp(AnalysisCommonDTO commonDTO) {
|
List<ContractAmountAnalysisCompVo> contractIncomeAnalysisVoList = contractMapper.contractAmountAnalysisByComp(commonDTO, SecurityUtils.getUser().getCompId());
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
@Override
|
public R contractIncomeAnalysis(AnalysisCommonDTO commonDTO) {
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractIncomeAnalysisVo> contractIncomeAnalysisVoList = contractMapper.contractIncomeAnalysis(commonDTO,compIds);
|
if (ArrayUtil.isNotEmpty(contractIncomeAnalysisVoList.toArray())){
|
contractIncomeAnalysisVoList.stream().forEach(contractIncomeAnalysisVo -> {
|
if(StrUtil.equals(contractIncomeAnalysisVo.getCompId(),sgb)){
|
contractIncomeAnalysisVo.setCompName("石工泵");
|
}
|
if(StrUtil.equals(contractIncomeAnalysisVo.getCompId(),smj)){
|
contractIncomeAnalysisVo.setCompName("石煤机");
|
}
|
if(StrUtil.equals(contractIncomeAnalysisVo.getCompId(),ymj)){
|
contractIncomeAnalysisVo.setCompName("一煤机");
|
}
|
if(StrUtil.equals(contractIncomeAnalysisVo.getCompId(),tfgs)){
|
contractIncomeAnalysisVo.setCompName("通方公司");
|
}
|
if(StrUtil.equals(contractIncomeAnalysisVo.getCompId(),jxc)){
|
contractIncomeAnalysisVo.setCompName("机械厂");
|
}
|
});
|
}
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
@Override
|
public R contractIncomeAnalysisByComp(AnalysisCommonDTO commonDTO) {
|
List<ContractIncomeAnalysisCompVo> contractIncomeAnalysisVoList = contractMapper.contractIncomeAnalysisByComp(commonDTO, SecurityUtils.getUser().getCompId());
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
@Override
|
public R contractAmountAnalysisByArea(AnalysisCommonDTO commonDTO) {
|
R<List<SysDictItem>> r = remoteDictService.getDictByType("company_area");
|
List<SysDictItem> items = r.getData();
|
if (ArrayUtil.isEmpty(items.toArray())){
|
return R.failed("区域字段获取异常");
|
}
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractIncomeAnalysisAreaVo> contractIncomeAnalysisVoList = items.stream().map(item -> {
|
ContractIncomeAnalysisAreaVo analysisAreaVo = new ContractIncomeAnalysisAreaVo();
|
analysisAreaVo.setAreaId(item.getItemValue());
|
analysisAreaVo.setAreaName(item.getLabel());
|
return analysisAreaVo;
|
}).collect(Collectors.toList());
|
List<ContractIncomeAnalysisAreaVo> statisticList = contractMapper.contractAmountAnalysisByArea(commonDTO
|
,compIds,Long.valueOf(smj),Long.valueOf(sgb),Long.valueOf(jxc),Long.valueOf(tfgs),Long.valueOf(ymj));
|
contractIncomeAnalysisVoList.stream().forEach(vo1->{
|
statisticList.stream().forEach(vo2->{
|
if (StrUtil.equals(vo1.getAreaId(),vo2.getAreaId())){
|
vo1.setJxczb(vo2.getJxczb());
|
vo1.setJxcze(vo2.getJxcze());
|
vo1.setSgbzb(vo2.getSgbzb());
|
vo1.setSgbze(vo2.getSgbze());
|
vo1.setSmjzb(vo2.getSmjzb());
|
vo1.setSmjze(vo2.getSmjze());
|
vo1.setTfzb(vo2.getTfzb());
|
vo1.setTfze(vo2.getTfze());
|
vo1.setYmjzb(vo2.getYmjzb());
|
vo1.setYmjze(vo2.getYmjze());
|
}
|
});
|
});
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
@Override
|
public R contractAmountAnalysisByIndustry(AnalysisCommonDTO commonDTO) {
|
R<List<SysDictItem>> r = remoteDictService.getDictByType("industry_sector");
|
List<SysDictItem> items = r.getData();
|
if (ArrayUtil.isEmpty(items.toArray())){
|
return R.failed("区域字段获取异常");
|
}
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractIncomeAnalysisAreaVo> contractIncomeAnalysisVoList = items.stream().map(item -> {
|
ContractIncomeAnalysisAreaVo analysisAreaVo = new ContractIncomeAnalysisAreaVo();
|
analysisAreaVo.setAreaId(item.getItemValue());
|
analysisAreaVo.setAreaName(item.getLabel());
|
return analysisAreaVo;
|
}).collect(Collectors.toList());
|
List<ContractIncomeAnalysisAreaVo> statisticList = contractMapper.contractAmountAnalysisByIndustry(commonDTO
|
,compIds,Long.valueOf(smj),Long.valueOf(sgb),Long.valueOf(jxc),Long.valueOf(tfgs),Long.valueOf(ymj));
|
contractIncomeAnalysisVoList.stream().forEach(vo1->{
|
statisticList.stream().forEach(vo2->{
|
if (StrUtil.equals(vo1.getAreaId(),vo2.getAreaId())){
|
vo1.setJxczb(vo2.getJxczb());
|
vo1.setJxcze(vo2.getJxcze());
|
vo1.setSgbzb(vo2.getSgbzb());
|
vo1.setSgbze(vo2.getSgbze());
|
vo1.setSmjzb(vo2.getSmjzb());
|
vo1.setSmjze(vo2.getSmjze());
|
vo1.setTfzb(vo2.getTfzb());
|
vo1.setTfze(vo2.getTfze());
|
vo1.setYmjzb(vo2.getYmjzb());
|
vo1.setYmjze(vo2.getYmjze());
|
}
|
});
|
});
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
@Override
|
public R contractAmountAnalysisByMarket(AnalysisCommonDTO commonDTO) {
|
R<List<SysDictItem>> r = remoteDictService.getDictByType("market_type");
|
List<SysDictItem> items = r.getData();
|
if (ArrayUtil.isEmpty(items.toArray())){
|
return R.failed("区域字段获取异常");
|
}
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractIncomeAnalysisAreaVo> contractIncomeAnalysisVoList = items.stream().map(item -> {
|
ContractIncomeAnalysisAreaVo analysisAreaVo = new ContractIncomeAnalysisAreaVo();
|
analysisAreaVo.setAreaId(item.getItemValue());
|
analysisAreaVo.setAreaName(item.getLabel());
|
return analysisAreaVo;
|
}).collect(Collectors.toList());
|
List<ContractIncomeAnalysisAreaVo> statisticList = contractMapper.contractAmountAnalysisByMarket(commonDTO
|
,compIds,Long.valueOf(smj),Long.valueOf(sgb),Long.valueOf(jxc),Long.valueOf(tfgs),Long.valueOf(ymj));
|
contractIncomeAnalysisVoList.stream().forEach(vo1->{
|
statisticList.stream().forEach(vo2->{
|
if (StrUtil.equals(vo1.getAreaId(),vo2.getAreaId())){
|
vo1.setJxczb(vo2.getJxczb());
|
vo1.setJxcze(vo2.getJxcze());
|
vo1.setSgbzb(vo2.getSgbzb());
|
vo1.setSgbze(vo2.getSgbze());
|
vo1.setSmjzb(vo2.getSmjzb());
|
vo1.setSmjze(vo2.getSmjze());
|
vo1.setTfzb(vo2.getTfzb());
|
vo1.setTfze(vo2.getTfze());
|
vo1.setYmjzb(vo2.getYmjzb());
|
vo1.setYmjze(vo2.getYmjze());
|
}
|
});
|
});
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
@Override
|
public R contractAmountAnalysisBySpcBus(AnalysisCommonDTO commonDTO) {
|
R<List<SysDictItem>> r = remoteDictService.getDictByType("supply_attribute");
|
List<SysDictItem> items = r.getData();
|
if (ArrayUtil.isEmpty(items.toArray())){
|
return R.failed("区域字段获取异常");
|
}
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractIncomeAnalysisAreaVo> contractIncomeAnalysisVoList = items.stream().map(item -> {
|
ContractIncomeAnalysisAreaVo analysisAreaVo = new ContractIncomeAnalysisAreaVo();
|
analysisAreaVo.setAreaId(item.getItemValue());
|
analysisAreaVo.setAreaName(item.getLabel());
|
return analysisAreaVo;
|
}).collect(Collectors.toList());
|
List<ContractIncomeAnalysisAreaVo> statisticList = contractMapper.contractAmountAnalysisBySpcBus(commonDTO
|
,compIds,Long.valueOf(smj),Long.valueOf(sgb),Long.valueOf(jxc),Long.valueOf(tfgs),Long.valueOf(ymj));
|
contractIncomeAnalysisVoList.stream().forEach(vo1->{
|
statisticList.stream().forEach(vo2->{
|
if (StrUtil.equals(vo1.getAreaId(),vo2.getAreaId())){
|
vo1.setJxczb(vo2.getJxczb());
|
vo1.setJxcze(vo2.getJxcze());
|
vo1.setSgbzb(vo2.getSgbzb());
|
vo1.setSgbze(vo2.getSgbze());
|
vo1.setSmjzb(vo2.getSmjzb());
|
vo1.setSmjze(vo2.getSmjze());
|
vo1.setTfzb(vo2.getTfzb());
|
vo1.setTfze(vo2.getTfze());
|
vo1.setYmjzb(vo2.getYmjzb());
|
vo1.setYmjze(vo2.getYmjze());
|
}
|
});
|
});
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
@Override
|
public R contractAmountAnalysisByExportBus(AnalysisCommonDTO commonDTO) {
|
R<List<SysDictItem>> r = remoteDictService.getDictByType("export_attr");
|
List<SysDictItem> items = r.getData();
|
if (ArrayUtil.isEmpty(items.toArray())){
|
return R.failed("区域字段获取异常");
|
}
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractIncomeAnalysisAreaVo> contractIncomeAnalysisVoList = items.stream().map(item -> {
|
ContractIncomeAnalysisAreaVo analysisAreaVo = new ContractIncomeAnalysisAreaVo();
|
analysisAreaVo.setAreaId(item.getItemValue());
|
analysisAreaVo.setAreaName(item.getLabel());
|
return analysisAreaVo;
|
}).collect(Collectors.toList());
|
List<ContractIncomeAnalysisAreaVo> statisticList = contractMapper.contractAmountAnalysisByExportBus(commonDTO
|
,compIds,Long.valueOf(smj),Long.valueOf(sgb),Long.valueOf(jxc),Long.valueOf(tfgs),Long.valueOf(ymj));
|
contractIncomeAnalysisVoList.stream().forEach(vo1->{
|
statisticList.stream().forEach(vo2->{
|
if (StrUtil.equals(vo1.getAreaId(),vo2.getAreaId())){
|
vo1.setJxczb(vo2.getJxczb());
|
vo1.setJxcze(vo2.getJxcze());
|
vo1.setSgbzb(vo2.getSgbzb());
|
vo1.setSgbze(vo2.getSgbze());
|
vo1.setSmjzb(vo2.getSmjzb());
|
vo1.setSmjze(vo2.getSmjze());
|
vo1.setTfzb(vo2.getTfzb());
|
vo1.setTfze(vo2.getTfze());
|
vo1.setYmjzb(vo2.getYmjzb());
|
vo1.setYmjze(vo2.getYmjze());
|
}
|
});
|
});
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
|
|
@Override
|
public R contractAmountAnalysisBySaleModel(AnalysisCommonDTO commonDTO) {
|
R<List<SysDictItem>> r = remoteDictService.getDictByType("sales_model");
|
List<SysDictItem> items = r.getData();
|
if (ArrayUtil.isEmpty(items.toArray())){
|
return R.failed("区域字段获取异常");
|
}
|
List<Long> compIds = new ArrayList<>();
|
compIds.add(Long.valueOf(sgb));
|
compIds.add(Long.valueOf(smj));
|
compIds.add(Long.valueOf(tfgs));
|
compIds.add(Long.valueOf(ymj));
|
compIds.add(Long.valueOf(jxc));
|
List<ContractIncomeAnalysisAreaVo> contractIncomeAnalysisVoList = items.stream().map(item -> {
|
ContractIncomeAnalysisAreaVo analysisAreaVo = new ContractIncomeAnalysisAreaVo();
|
analysisAreaVo.setAreaId(item.getItemValue());
|
analysisAreaVo.setAreaName(item.getLabel());
|
return analysisAreaVo;
|
}).collect(Collectors.toList());
|
contractMapper.setSession();
|
List<ContractIncomeAnalysisAreaVo> statisticList = contractMapper.contractAmountAnalysisBySaleModel(commonDTO
|
,compIds,Long.valueOf(smj),Long.valueOf(sgb),Long.valueOf(jxc),Long.valueOf(tfgs),Long.valueOf(ymj));
|
contractIncomeAnalysisVoList.stream().forEach(vo1->{
|
statisticList.stream().forEach(vo2->{
|
if (StrUtil.equals(vo1.getAreaId(),vo2.getAreaId())){
|
vo1.setJxczb(vo2.getJxczb());
|
vo1.setJxcze(vo2.getJxcze());
|
vo1.setSgbzb(vo2.getSgbzb());
|
vo1.setSgbze(vo2.getSgbze());
|
vo1.setSmjzb(vo2.getSmjzb());
|
vo1.setSmjze(vo2.getSmjze());
|
vo1.setTfzb(vo2.getTfzb());
|
vo1.setTfze(vo2.getTfze());
|
vo1.setYmjzb(vo2.getYmjzb());
|
vo1.setYmjze(vo2.getYmjze());
|
}
|
});
|
});
|
return R.ok(contractIncomeAnalysisVoList);
|
}
|
}
|
