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