Commit e9233d0b authored by 竹天卫's avatar 竹天卫
parents 682ad102 3a7c4c7a
...@@ -12,12 +12,14 @@ import cn.wise.sc.cement.business.model.vo.ProductionVo; ...@@ -12,12 +12,14 @@ import cn.wise.sc.cement.business.model.vo.ProductionVo;
import cn.wise.sc.cement.business.model.vo.WorkloadStatisticsVo; import cn.wise.sc.cement.business.model.vo.WorkloadStatisticsVo;
import cn.wise.sc.cement.business.service.INonStandardValueService; import cn.wise.sc.cement.business.service.INonStandardValueService;
import cn.wise.sc.cement.business.service.INormProductionService; import cn.wise.sc.cement.business.service.INormProductionService;
import cn.wise.sc.cement.business.service.IPrecipriceService;
import cn.wise.sc.cement.business.util.PageUtil; import cn.wise.sc.cement.business.util.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.Assert;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
...@@ -49,10 +51,14 @@ public class NormProductionController { ...@@ -49,10 +51,14 @@ public class NormProductionController {
final final
INormProductionService iNormProductionService; INormProductionService iNormProductionService;
@Autowired final
IPrecipriceService iPrecipriceService;
final
INonStandardValueService inonStandardValueService; INonStandardValueService inonStandardValueService;
public NormProductionController(INormProductionService iNormProductionService) { public NormProductionController(INormProductionService iNormProductionService, IPrecipriceService iPrecipriceService, INonStandardValueService inonStandardValueService) {
this.iNormProductionService = iNormProductionService; this.iNormProductionService = iNormProductionService;
this.iPrecipriceService = iPrecipriceService;
this.inonStandardValueService = inonStandardValueService;
} }
@PostMapping("/create") @PostMapping("/create")
...@@ -98,6 +104,7 @@ public class NormProductionController { ...@@ -98,6 +104,7 @@ public class NormProductionController {
return iNormProductionService.activeOrForbidden(id); return iNormProductionService.activeOrForbidden(id);
} }
@GetMapping("/statistics") @GetMapping("/statistics")
@ApiOperation("标准产值统计") @ApiOperation("标准产值统计")
public BaseResponse<Page<NormProductionStatistics>> normProductionStatistics(String start, String end, String name, Integer groupId, PageQuery pageQuery) { public BaseResponse<Page<NormProductionStatistics>> normProductionStatistics(String start, String end, String name, Integer groupId, PageQuery pageQuery) {
...@@ -110,7 +117,7 @@ public class NormProductionController { ...@@ -110,7 +117,7 @@ public class NormProductionController {
} }
//将list拆分成分页 //将list拆分成分页
BaseResponse<List<NormProductionStatistics>> baseResponse = iNormProductionService BaseResponse<List<NormProductionStatistics>> baseResponse = iPrecipriceService
.normProductionStatistics(startTime, endTime, name, groupId); .normProductionStatistics(startTime, endTime, name, groupId);
if (baseResponse.getCode() == 200) { if (baseResponse.getCode() == 200) {
List<NormProductionStatistics> data = baseResponse.getData(); List<NormProductionStatistics> data = baseResponse.getData();
...@@ -119,6 +126,7 @@ public class NormProductionController { ...@@ -119,6 +126,7 @@ public class NormProductionController {
return BaseResponse.okData(rts); return BaseResponse.okData(rts);
} }
} }
return BaseResponse.okData(null); return BaseResponse.okData(null);
} }
...@@ -126,14 +134,15 @@ public class NormProductionController { ...@@ -126,14 +134,15 @@ public class NormProductionController {
@ApiOperation("标准产值详情") @ApiOperation("标准产值详情")
public BaseResponse<Page<NormProduction.NormProductionDetail>> normProductionDetails(Integer userId, String start, public BaseResponse<Page<NormProduction.NormProductionDetail>> normProductionDetails(Integer userId, String start,
String end, PageQuery pageQuery) { String end, PageQuery pageQuery) {
Assert.notNull(userId,"用户id是必填的!");
Long startTime = null; Long startTime = null;
Long endTime = null; Long endTime = null;
if (StrUtil.isNotBlank(start) && StrUtil.isNotBlank(end)) { if (StrUtil.isNotBlank(start) && StrUtil.isNotBlank(end)) {
startTime = DateUtil.parseDate(start).getTime(); startTime = DateUtil.parseDate(start).getTime();
endTime = DateUtil.parseDate(end).getTime(); endTime = DateUtil.parseDate(end).getTime();
} }
List<NormProduction.NormProductionDetail> data = iNormProductionService.normProductionDetails(userId, startTime, endTime); List<NormProduction.NormProductionDetail> data = iPrecipriceService.normProductionDetails(userId, startTime, endTime);
List<NormProduction.NormProductionDetail> collect = data List<NormProduction.NormProductionDetail> collect = data
.stream() .stream()
.filter(arg -> arg.getUserId().intValue() == userId) .filter(arg -> arg.getUserId().intValue() == userId)
...@@ -156,7 +165,7 @@ public class NormProductionController { ...@@ -156,7 +165,7 @@ public class NormProductionController {
endTime = DateUtil.parseDate(end).getTime(); endTime = DateUtil.parseDate(end).getTime();
} }
List<ProductionVo> rts = iNormProductionService.production(name, startTime, endTime, groupId); List<ProductionVo> rts = iPrecipriceService.production(name, startTime, endTime, groupId);
if (!CollectionUtil.isEmpty(rts)) { if (!CollectionUtil.isEmpty(rts)) {
Set<Integer> ids = new HashSet<>(); Set<Integer> ids = new HashSet<>();
for (ProductionVo productionVo : rts) { for (ProductionVo productionVo : rts) {
...@@ -217,7 +226,7 @@ public class NormProductionController { ...@@ -217,7 +226,7 @@ public class NormProductionController {
startTime = DateUtil.parseDate(start).getTime(); startTime = DateUtil.parseDate(start).getTime();
endTime = DateUtil.parseDate(end).getTime(); endTime = DateUtil.parseDate(end).getTime();
} }
iNormProductionService.exportNormProductionDetail(userId, startTime, endTime, response); iPrecipriceService.exportNormProductionDetail(userId, startTime, endTime, response);
} }
@PostMapping("/export/total/production") @PostMapping("/export/total/production")
...@@ -245,7 +254,7 @@ public class NormProductionController { ...@@ -245,7 +254,7 @@ public class NormProductionController {
endTime = DateUtil.parseDate(end); endTime = DateUtil.parseDate(end);
} }
return BaseResponse.okData(iNormProductionService.workloadStatistics(startTime, endTime, userId)); return BaseResponse.okData(iPrecipriceService.workloadStatistics(startTime, endTime, userId));
} }
} }
......
...@@ -17,6 +17,7 @@ import cn.wise.sc.cement.business.service.IPrecipriceService; ...@@ -17,6 +17,7 @@ import cn.wise.sc.cement.business.service.IPrecipriceService;
import cn.wise.sc.cement.business.util.PageUtil; import cn.wise.sc.cement.business.util.PageUtil;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
...@@ -44,12 +45,12 @@ import java.util.stream.Collectors; ...@@ -44,12 +45,12 @@ import java.util.stream.Collectors;
* @since 2020-11-02 * @since 2020-11-02
*/ */
@RestController @RestController
@Api(hidden = true)
@RequestMapping("/business/preciprice") @RequestMapping("/business/preciprice")
public class PrecipriceController { public class PrecipriceController {
@Autowired @Autowired
IPrecipriceService iNormProductionService; IPrecipriceService iNormProductionService;
@Autowired @Autowired
INonStandardValueService inonStandardValueService; INonStandardValueService inonStandardValueService;
...@@ -83,6 +84,7 @@ public class PrecipriceController { ...@@ -83,6 +84,7 @@ public class PrecipriceController {
return BaseResponse.okData(rts); return BaseResponse.okData(rts);
} }
} }
return BaseResponse.okData(null); return BaseResponse.okData(null);
} }
......
...@@ -20,8 +20,6 @@ import cn.wise.sc.cement.business.entity.SysUser; ...@@ -20,8 +20,6 @@ import cn.wise.sc.cement.business.entity.SysUser;
import cn.wise.sc.cement.business.entity.TeamGroup; import cn.wise.sc.cement.business.entity.TeamGroup;
import cn.wise.sc.cement.business.mapper.PrecipriceMapper; import cn.wise.sc.cement.business.mapper.PrecipriceMapper;
import cn.wise.sc.cement.business.model.BaseResponse; import cn.wise.sc.cement.business.model.BaseResponse;
import cn.wise.sc.cement.business.model.PageQuery;
import cn.wise.sc.cement.business.model.vo.NormProductionVo;
import cn.wise.sc.cement.business.model.vo.ProductionVo; import cn.wise.sc.cement.business.model.vo.ProductionVo;
import cn.wise.sc.cement.business.model.vo.WorkloadStatisticsVo; import cn.wise.sc.cement.business.model.vo.WorkloadStatisticsVo;
import cn.wise.sc.cement.business.service.IEntrustService; import cn.wise.sc.cement.business.service.IEntrustService;
...@@ -41,12 +39,10 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; ...@@ -41,12 +39,10 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.poi.ss.formula.functions.T;
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.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.Assert; import org.springframework.util.Assert;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
...@@ -64,7 +60,6 @@ import java.util.List; ...@@ -64,7 +60,6 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
* <p> * <p>
* 服务实现类 * 服务实现类
...@@ -87,29 +82,41 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -87,29 +82,41 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
ISysUserService iSysUserService; ISysUserService iSysUserService;
final final
ISysGroupService iSysGroupService; ISysGroupService iSysGroupService;
@Autowired final
ITeamGroupService iTeamGroupService; ITeamGroupService iTeamGroupService;
@Autowired final
IHandleService iHandleService; IHandleService iHandleService;
@Autowired final
ISysPostService iSysPostService; ISysPostService iSysPostService;
@Autowired final
INonStandardValueService iNonStandardValueService; INonStandardValueService iNonStandardValueService;
@Autowired final
INonStandardApplyService iNonStandardApplyService; INonStandardApplyService iNonStandardApplyService;
@Autowired final
ISampleDistributionService iSampleDistributionService; ISampleDistributionService iSampleDistributionService;
public PrecipriceServiceImpl(IEntrustService iEntrustService, public PrecipriceServiceImpl(IEntrustService iEntrustService,
ISampleService iSampleService, ISampleService iSampleService,
INormProductionService iNormProductionService, INormProductionService iNormProductionService,
ISysUserService iSysUserService, ISysUserService iSysUserService,
ISysGroupService iSysGroupService) { ISysGroupService iSysGroupService,
ITeamGroupService iTeamGroupService,
IHandleService iHandleService,
ISysPostService iSysPostService,
INonStandardValueService iNonStandardValueService,
INonStandardApplyService iNonStandardApplyService,
ISampleDistributionService iSampleDistributionService) {
this.iEntrustService = iEntrustService; this.iEntrustService = iEntrustService;
this.iSampleService = iSampleService; this.iSampleService = iSampleService;
this.iNormProductionService = iNormProductionService; this.iNormProductionService = iNormProductionService;
this.iSysUserService = iSysUserService; this.iSysUserService = iSysUserService;
this.iSysGroupService = iSysGroupService; this.iSysGroupService = iSysGroupService;
this.iTeamGroupService = iTeamGroupService;
this.iHandleService = iHandleService;
this.iSysPostService = iSysPostService;
this.iNonStandardValueService = iNonStandardValueService;
this.iNonStandardApplyService = iNonStandardApplyService;
this.iSampleDistributionService = iSampleDistributionService;
} }
@Override @Override
...@@ -209,6 +216,7 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -209,6 +216,7 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
@Override @Override
public BaseResponse<List<NormProductionStatistics>> normProductionStatistics(Long start, Long end, String name, Integer groupId) { public BaseResponse<List<NormProductionStatistics>> normProductionStatistics(Long start, Long end, String name, Integer groupId) {
//曲解、心有灵犀、捧着、不争论、心态口才策略
//统计分样处理的详情 //统计分样处理的详情
List<NormProduction.NormProductionDetail> normProductionDetails = List<NormProduction.NormProductionDetail> normProductionDetails =
normProductionDetails(null, start, end); normProductionDetails(null, start, end);
...@@ -218,7 +226,7 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -218,7 +226,7 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
rts.setData(new ArrayList<>()); rts.setData(new ArrayList<>());
return rts; return rts;
} }
//
Map<Integer, BigDecimal> coefficientMap = new HashMap<>(normProductionDetails.size()); Map<Integer, BigDecimal> coefficientMap = new HashMap<>(normProductionDetails.size());
normProductionDetails normProductionDetails
.forEach(arg -> { .forEach(arg -> {
...@@ -334,7 +342,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -334,7 +342,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
List<NonStandardValue> nonStandardValues = iNonStandardValueService.nonValue(startDate, endDate, groupId).getData(); List<NonStandardValue> nonStandardValues = iNonStandardValueService.nonValue(startDate, endDate, groupId).getData();
//标准产值 //标准产值
List<NormProductionStatistics> productionStatistics = this.normProductionStatistics(start, end, name, groupId).getData(); List<NormProductionStatistics> productionStatistics = this.normProductionStatistics(start, end, name, groupId).getData();
//以userId找关系 //以userId找关系
Set<String> userIds = new HashSet<>(); Set<String> userIds = new HashSet<>();
nonStandardValues.forEach(arg -> userIds.add(arg.getUserId() + "")); nonStandardValues.forEach(arg -> userIds.add(arg.getUserId() + ""));
...@@ -406,7 +413,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -406,7 +413,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
return rts.stream().filter(arg -> arg.getGroupId().equals(groupId)) return rts.stream().filter(arg -> arg.getGroupId().equals(groupId))
.collect(Collectors.toList()); .collect(Collectors.toList());
} }
return rts; return rts;
} }
...@@ -558,7 +564,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -558,7 +564,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
for (NonStandardApply nonStandardApply : nonStandardApplies) { for (NonStandardApply nonStandardApply : nonStandardApplies) {
addCount(nonStandardApply.getStartTime(), map2); addCount(nonStandardApply.getStartTime(), map2);
} }
WorkloadStatisticsVo workloadStatisticsVo = new WorkloadStatisticsVo(); WorkloadStatisticsVo workloadStatisticsVo = new WorkloadStatisticsVo();
workloadStatisticsVo.setType(0); workloadStatisticsVo.setType(0);
workloadStatisticsVo.setMap(map1); workloadStatisticsVo.setMap(map1);
...@@ -568,7 +573,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -568,7 +573,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
List<WorkloadStatisticsVo> rts = new ArrayList<>(2); List<WorkloadStatisticsVo> rts = new ArrayList<>(2);
rts.add(workloadStatisticsVo); rts.add(workloadStatisticsVo);
rts.add(workloadStatisticsVo2); rts.add(workloadStatisticsVo2);
return rts; return rts;
} }
...@@ -637,7 +641,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -637,7 +641,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
for (long i = start; i <= end; i = DateUtil.offsetMonth(DateUtil.date(i), 1).getTime()) { for (long i = start; i <= end; i = DateUtil.offsetMonth(DateUtil.date(i), 1).getTime()) {
map.put(DateUtil.endOfMonth(DateUtil.date(i)).getMonth() + 1 + "", 0); map.put(DateUtil.endOfMonth(DateUtil.date(i)).getMonth() + 1 + "", 0);
} }
return map; return map;
} }
...@@ -647,7 +650,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr ...@@ -647,7 +650,6 @@ public class PrecipriceServiceImpl extends ServiceImpl<PrecipriceMapper, Precipr
start = System.currentTimeMillis(); start = System.currentTimeMillis();
start = DateUtil.beginOfYear(DateUtil.date(start)).getTime(); start = DateUtil.beginOfYear(DateUtil.date(start)).getTime();
} }
return start; return start;
} }
......
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