From 5dfbc4af25ab4f5e8d75f99c6e889b5004a49ef0 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期五, 18 八月 2023 19:22:25 +0800 Subject: [PATCH] 大屏统计 --- server/src/main/java/doumeemes/service/business/impl/SalaryParamServiceImpl.java | 43 +++++++++++++++++++++++++++---------------- 1 files changed, 27 insertions(+), 16 deletions(-) diff --git a/server/src/main/java/doumeemes/service/business/impl/SalaryParamServiceImpl.java b/server/src/main/java/doumeemes/service/business/impl/SalaryParamServiceImpl.java index 7d63f71..b97cf17 100644 --- a/server/src/main/java/doumeemes/service/business/impl/SalaryParamServiceImpl.java +++ b/server/src/main/java/doumeemes/service/business/impl/SalaryParamServiceImpl.java @@ -54,20 +54,25 @@ @Override public Integer create(SalaryParam salaryParam) { + + LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); SalaryParam insert = new SalaryParam(); + insert.setRootDepartId(principal.getRootDepartment().getId()); + insert.setDepartId(salaryParam.getDepartId()); + insert.setProcedureId(salaryParam.getProcedureId()); + insert.setMaterialId(salaryParam.getMaterialId()); insert.setDeleted((byte) Constants.ZERO); + if(findOne(insert) != null){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍚屼竴涓墿鏂欏湪鐩稿悓宸ュ簭涓嶈兘閲嶅閰嶇疆鍝︼紒"); + } insert.setCreateUser(principal.getId()); insert.setCreateTime(new Date()); insert.setUpdateUser(principal.getId()); insert.setUpdateTime(new Date()); insert.setRemark(salaryParam.getRemark()); - insert.setRootDepartId(salaryParam.getRootDepartId()); - insert.setDepartId(salaryParam.getDepartId()); - insert.setProcedureId(salaryParam.getProcedureId()); - insert.setMaterialId(salaryParam.getMaterialId()); - insert.setSalary(salaryParam.getSalary()); + insert.setSalary(salaryParam.getSalary().multiply(new BigDecimal("100"))); insert.setNum(salaryParam.getNum()); insert.setTimes(salaryParam.getTimes()); insert.setUnqualified(salaryParam.getUnqualified()); @@ -109,10 +114,10 @@ .set(SalaryParam::getUpdateTime,new Date()) .set(SalaryParam::getUpdateUser,principal.getId()) .set(SalaryParam::getType,salaryParam.getType()) - .set(SalaryParam::getDepartId,salaryParam.getDepartId()) - .set(SalaryParam::getMaterialId,salaryParam.getMaterialId()) - .set(SalaryParam::getProcedureId,salaryParam.getProcedureId()) - .set(SalaryParam::getSalary,salaryParam.getSalary()) +// .set(SalaryParam::getDepartId,salaryParam.getDepartId()) +// .set(SalaryParam::getMaterialId,salaryParam.getMaterialId()) +// .set(SalaryParam::getProcedureId,salaryParam.getProcedureId()) + .set(SalaryParam::getSalary,salaryParam.getSalary().multiply(new BigDecimal(100))) .set(SalaryParam::getNum,salaryParam.getNum()) .set(SalaryParam::getTimes,salaryParam.getTimes()) .set(SalaryParam::getUnqualified,salaryParam.getUnqualified()); @@ -137,6 +142,7 @@ @Override public SalaryParam findOne(SalaryParam salaryParam) { QueryWrapper<SalaryParam> wrapper = new QueryWrapper<>(salaryParam); + wrapper.last("limit 1"); return salaryParamMapper.selectOne(wrapper); } @@ -149,8 +155,15 @@ @Override public PageData<SalaryParamVO> findPage(PageWrap<SalaryParamDTO> pageWrap) { IPage<SalaryParam> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); + LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); SalaryParamDTO model = pageWrap.getModel(); - return PageData.from(salaryParamMapper.selectPage(page, model)); + model.setRootDepartId(principal.getRootDepartment().getId()); +// model.setDepartId(principal.getComDepartment().getId()); + IPage<SalaryParamVO> salaryParamVOIPage = salaryParamMapper.selectPage(page, model); + if (!CollectionUtils.isEmpty(salaryParamVOIPage.getRecords())){ + salaryParamVOIPage.getRecords().forEach(s->s.setSalary(s.getSalary().divide(new BigDecimal(100)))); + } + return PageData.from(salaryParamVOIPage); } @Override @@ -178,7 +191,7 @@ || Objects.isNull(s.getDepartName()) || Objects.isNull(s.getMaterialCode()) || Objects.isNull(s.getProcedureName()) - || Objects.isNull(s.getNUM())){ + || Objects.isNull(s.getNum())){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵煎叆鏁版嵁鍐呭鏈夎锛�"); } }); @@ -214,7 +227,7 @@ proceduresWrapper.lambda() .eq(Procedures::getName,salaryParamImportDTO.getProcedureName()) .eq(Procedures::getRootDepartId,department.getRootId()) - .eq(Procedures::getDepartId,department.getId()) +// .eq(Procedures::getOrgId,department.getId()) .last("limit 1"); Procedures procedures = proceduresMapper.selectOne(proceduresWrapper); if (Objects.isNull(procedures)){ @@ -226,10 +239,8 @@ salaryParam.setProcedureId(procedures.getId()); salaryParam.setMaterialId(material.getId()); salaryParam.setSalary(salaryParamImportDTO.getSalary()); - salaryParam.setNum(new BigDecimal(salaryParamImportDTO.getNUM())); - + salaryParam.setNum(new BigDecimal(salaryParamImportDTO.getNum())); salaryParam.setTimes(getIntegerTimes(salaryParamImportDTO.getTimesName())); - Integer unqualified = Optional.ofNullable(salaryParamImportDTO.getUnqualified()).map(s -> { if ("鍚�".equals(s)) { return 0; @@ -265,7 +276,7 @@ m = Integer.parseInt(a.substring(hIndex >=0?hIndex+2:0,mIndex)); } if(sIndex > mIndex){ - s = Integer.parseInt(a.substring(mIndex >=0?mIndex+2:0,mIndex)); + s = Integer.parseInt(a.substring(mIndex >= 0 ? mIndex+2 : 0, sIndex)); } return h*3600+m*60+s; }catch (Exception e){ -- Gitblit v1.9.3