From d90906cb2e04b223b9eee5790f2abcf747fb909a Mon Sep 17 00:00:00 2001
From: Chengliang <1546584672@qq.com>
Date: Thu, 7 Sep 2023 15:28:30 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=BC=96=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../entity/staff/param/StaffOutParam.java     |  5 ++
 .../organization/mapper/staff/StaffMapper.xml |  2 +-
 .../mapper/staff/StaffPlanMapper.java         |  2 +-
 .../mapper/staff/StaffPlanMapper.xml          |  3 +-
 .../impl/FunctionOutStaffServiceImpl.java     | 77 +++++++++++--------
 .../service/impl/StaffOutServiceImpl.java     | 13 ++++
 .../service/impl/StaffPlanServiceImpl.java    |  4 +-
 7 files changed, 71 insertions(+), 35 deletions(-)

diff --git a/src/com/engine/organization/entity/staff/param/StaffOutParam.java b/src/com/engine/organization/entity/staff/param/StaffOutParam.java
index 0a4a59a5..17104edc 100644
--- a/src/com/engine/organization/entity/staff/param/StaffOutParam.java
+++ b/src/com/engine/organization/entity/staff/param/StaffOutParam.java
@@ -29,6 +29,11 @@ public class StaffOutParam {
 
     private Integer job;
 
+    /**
+     * 维度 1 分部 2 部门 3 岗位
+     */
+    private Integer dimension;
+
     /**
      * 调整方式 1.流程 2.其它
      */
diff --git a/src/com/engine/organization/mapper/staff/StaffMapper.xml b/src/com/engine/organization/mapper/staff/StaffMapper.xml
index 16c8024a..231efccf 100644
--- a/src/com/engine/organization/mapper/staff/StaffMapper.xml
+++ b/src/com/engine/organization/mapper/staff/StaffMapper.xml
@@ -389,7 +389,7 @@
         where t.delete_type = 0
         AND t.ec_department IN
         <foreach collection="departmentIds" open="(" item="departmentId" separator="," close=")">
-            #{departmentIds}
+            #{departmentId}
         </foreach>
         AND t.plan_id IN (SELECT id from jcl_org_staffplan s where s.control_dimension = 2)
     </select>
diff --git a/src/com/engine/organization/mapper/staff/StaffPlanMapper.java b/src/com/engine/organization/mapper/staff/StaffPlanMapper.java
index 8884113d..b61b10ba 100644
--- a/src/com/engine/organization/mapper/staff/StaffPlanMapper.java
+++ b/src/com/engine/organization/mapper/staff/StaffPlanMapper.java
@@ -82,6 +82,6 @@ public interface StaffPlanMapper {
      * @param: [timeStart, timeEnd, ecCompany, controlDimension]
      * @return: com.engine.organization.entity.staff.po.StaffPlanPO
      */
-    StaffPlanPO customSelect(@Param("timeStart") String timeStart,@Param("ecCompany") String ecCompany,@Param("controlDimension") String controlDimension);
+    StaffPlanPO customSelect(@Param("timeStart") String timeStart,@Param("timeEnd") String timeEnd,@Param("ecCompany") String ecCompany,@Param("controlDimension") String controlDimension);
 
 }
diff --git a/src/com/engine/organization/mapper/staff/StaffPlanMapper.xml b/src/com/engine/organization/mapper/staff/StaffPlanMapper.xml
index fe600553..81b274ad 100644
--- a/src/com/engine/organization/mapper/staff/StaffPlanMapper.xml
+++ b/src/com/engine/organization/mapper/staff/StaffPlanMapper.xml
@@ -299,7 +299,8 @@
     <select id="customSelect" resultMap="BaseResultMap">
         select
         <include refid="baseColumns"/>
-        from jcl_org_staffplan t where time_start &lt;= #{timeStart,jdbcType=DATE} AND time_end > #{timeStart,jdbcType=DATE}
+        from jcl_org_staffplan t where
+        ((time_start &lt;= #{timeStart,jdbcType=DATE} AND time_end >= #{timeStart,jdbcType=DATE} OR (time_end &lt;= #{timeEnd,jdbcType=DATE} AND time_end >= #{timeEnd,jdbcType=DATE})
         AND ec_company = #{ecCompany}
         AND control_dimension = #{controlDimension}
         AND delete_type = 0
diff --git a/src/com/engine/organization/service/impl/FunctionOutStaffServiceImpl.java b/src/com/engine/organization/service/impl/FunctionOutStaffServiceImpl.java
index 1c4466bf..44a08cb8 100644
--- a/src/com/engine/organization/service/impl/FunctionOutStaffServiceImpl.java
+++ b/src/com/engine/organization/service/impl/FunctionOutStaffServiceImpl.java
@@ -2,6 +2,7 @@ package com.engine.organization.service.impl;
 
 import com.engine.organization.entity.staff.param.StaffOutParam;
 import com.engine.organization.entity.staff.po.StaffPO;
+import com.engine.organization.enums.ModuleTypeEnum;
 import com.engine.organization.enums.StaffChangeEnum;
 import com.engine.organization.exception.OrganizationRunTimeException;
 import com.engine.organization.mapper.staff.StaffMapper;
@@ -86,17 +87,17 @@ public class FunctionOutStaffServiceImpl {
 
     private Integer entryAdd(StaffOutParam param) {
         StaffPO staffPO = select(param);
-        Integer sums = staffPO.getPermanentNum() + staffPO.getFreezeNum();
-        //强控策略下不容许超编
-        if (staffPO.getControlPolicy().equals(HARDCONTROLLER)) {
-            OrganizationAssert.isFalse(sums.compareTo(staffPO.getStaffNum()) > 0,"强控策略下不容许超编");
-        }
         List<Integer> numbers = Arrays.asList(staffPO.getPermanentNum(),param.getNum());
         //1.增加在编数
         int sum = numbers.stream()
                 .mapToInt(Integer::intValue)
                 .sum();
         staffPO.setPermanentNum(sum);
+        Integer sums = staffPO.getPermanentNum() + staffPO.getFreezeNum();
+        //强控策略下不容许超编
+        if (staffPO.getControlPolicy().equals(HARDCONTROLLER)) {
+            OrganizationAssert.isFalse(sums.compareTo(staffPO.getStaffNum()) > 0,"强控策略下不容许超编");
+        }
         //向上部门 分部在编数调整
         upwardReviewSums(param);
         //2.调整方式为流程时释放冻结数
@@ -152,42 +153,58 @@ public class FunctionOutStaffServiceImpl {
         //1.分部
         if (param.getCompany() != null) {
             String allSupCompany = subCompanyComInfo.getAllSupCompany(String.valueOf(param.getCompany()));
+            Collection<Integer> subCompanys = new ArrayList<>();
+
+            if (param.getDimension().equals(ModuleTypeEnum.departmentfielddefined.getValue()) || param.getDimension().equals(ModuleTypeEnum.jobfielddefined.getValue())){
+                subCompanys.add(param.getCompany());
+            }
             if (!"".equals(allSupCompany)) {
-                Collection<Integer> subCompanys = Arrays.stream(allSupCompany.split(","))
+                Collection<Integer> sub = Arrays.stream(allSupCompany.split(","))
                         .map(Integer::parseInt)
                         .collect(Collectors.toList());
-                List<StaffPO> staffPOS = staffMapper().selectByEcCompany(subCompanys);
-                if (!CollectionUtils.isEmpty(staffPOS)) {
-                    staffPOS.forEach(item -> {
-                        if (param.getType().getValue() == 3){
-                            item.setPermanentNum(item.getPermanentNum() + param.getNum());
-                        }else {
-                            item.setPermanentNum(item.getPermanentNum() - param.getNum());
-                        }
-                        staffMapper().updateStaff(item);
-                    });
-                }
+                subCompanys.addAll(sub);
+            }
+
+            List<StaffPO> staffPOS = staffMapper().selectByEcCompany(subCompanys);
+            if (!CollectionUtils.isEmpty(staffPOS)) {
+                staffPOS.forEach(item -> {
+                    if (param.getType().getValue() == 3){
+                        item.setPermanentNum(item.getPermanentNum() + param.getNum());
+                    }else {
+                        item.setPermanentNum(item.getPermanentNum() - param.getNum());
+                    }
+                    buildStaffPO(item);
+                    staffMapper().updateStaff(item);
+                });
             }
         }
 
+
         //2.部门
         if (param.getDepartment() != null) {
             String allSupDepartment = departmentComInfo.getAllSupDepartment(String.valueOf(param.getDepartment()));
+            Collection<Integer> subDepartments = new ArrayList<>();
+            if (param.getDimension().equals(ModuleTypeEnum.jobfielddefined.getValue())) {
+                subDepartments.add(param.getDepartment());
+            }
             if (!"".equals(allSupDepartment)) {
-                Collection<Integer> subDepartments = Arrays.stream(allSupDepartment.split(","))
+                Collection<Integer> sub = Arrays.stream(allSupDepartment.split(","))
                         .map(Integer::parseInt)
                         .collect(Collectors.toList());
-                List<StaffPO> staffPOS = staffMapper().selectByEcDepartment(subDepartments);
-                if (!CollectionUtils.isEmpty(staffPOS)) {
-                    staffPOS.forEach(item -> {
-                        if (param.getType().getValue() == 3){
-                            item.setPermanentNum(item.getPermanentNum() + param.getNum());
-                        }else {
-                            item.setPermanentNum(item.getPermanentNum() - param.getNum());
-                        }
-                        staffMapper().updateStaff(item);
-                    });
-                }
+                subDepartments.addAll(sub);
+            }
+
+            List<StaffPO> staffPOS = staffMapper().selectByEcDepartment(subDepartments);
+            if (!CollectionUtils.isEmpty(staffPOS)) {
+                staffPOS.forEach(item -> {
+                    if (param.getType().getValue() == 3){
+                        item.setPermanentNum(item.getPermanentNum() + param.getNum());
+                    }else {
+                        item.setPermanentNum(item.getPermanentNum() - param.getNum());
+                    }
+                    buildStaffPO(item);
+                    staffMapper().updateStaff(item);
+                });
             }
         }
 
@@ -195,7 +212,7 @@ public class FunctionOutStaffServiceImpl {
 
     private  StaffPO select(StaffOutParam param) {
         List<StaffPO> staffPO = staffMapper().customSelect(param.getPlanId(), param.getCompany(), param.getDepartment(), param.getJob());
-        OrganizationAssert.notNull(staffPO,"未查询到对应编制方案下的组织编制信息！");
+        OrganizationAssert.isEmpty(staffPO,"未查询到对应编制方案下的组织编制信息！");
         return staffPO.get(0);
     }
 
diff --git a/src/com/engine/organization/service/impl/StaffOutServiceImpl.java b/src/com/engine/organization/service/impl/StaffOutServiceImpl.java
index 3ca212c9..d8069006 100644
--- a/src/com/engine/organization/service/impl/StaffOutServiceImpl.java
+++ b/src/com/engine/organization/service/impl/StaffOutServiceImpl.java
@@ -19,12 +19,25 @@ public class StaffOutServiceImpl  extends Service implements StaffOutService {
         OrganizationAssert.notNull(staffOutParam.getNum(),"调整数量不能为空！");
         OrganizationAssert.notNull(staffOutParam.getPlanId(),"未指定所属编制方案！");
         FunctionOutStaffServiceImpl functionFactory = new FunctionOutStaffServiceImpl();
+        buildStaffOutParam(staffOutParam);
         return functionFactory.actuator(staffOutParam.getType(), staffOutParam);
     }
 
     @Override
     public Integer transactionOnJob(StaffOutParam staffOutParam) {
         FunctionOutStaffServiceImpl functionFactory = new FunctionOutStaffServiceImpl();
+        buildStaffOutParam(staffOutParam);
         return functionFactory.actuator(staffOutParam.getType(), staffOutParam);
     }
+
+    private void buildStaffOutParam(StaffOutParam param) {
+        if (param.getCompany() != null && param.getDepartment() != null && param.getJob() != null) {
+            param.setDimension(3);
+        }else if(param.getCompany() != null && param.getDepartment() != null) {
+            param.setDimension(2);
+        }else if (param.getCompany() != null) {
+            param.setDimension(1);
+        }
+
+    }
 }
diff --git a/src/com/engine/organization/service/impl/StaffPlanServiceImpl.java b/src/com/engine/organization/service/impl/StaffPlanServiceImpl.java
index f5dc87bc..6b92a96b 100644
--- a/src/com/engine/organization/service/impl/StaffPlanServiceImpl.java
+++ b/src/com/engine/organization/service/impl/StaffPlanServiceImpl.java
@@ -73,7 +73,7 @@ public class StaffPlanServiceImpl extends Service implements StaffPlanService {
         Date startDate = DateUtil.parseToDate(timeStart);
         Date endDate = DateUtil.parseToDate(timeEnd);
         OrganizationAssert.isFalse(startDate.after(endDate), "开始时间不允许在结束时间之后");
-        StaffPlanPO staffPlanPO1 = getStaffPlanMapper().customSelect(param.getTimeStart(), param.getEcCompany(), param.getControlDimension());
+        StaffPlanPO staffPlanPO1 = getStaffPlanMapper().customSelect(param.getTimeStart(),param.getTimeEnd(), param.getEcCompany(), param.getControlDimension());
         OrganizationAssert.isNull(staffPlanPO1,"同一维度下，相同适用公司编制方案的时间段不允许出现交叉");
         return getStaffPlanMapper().insertIgnoreNull(staffPlanPO);
     }
@@ -94,7 +94,7 @@ public class StaffPlanServiceImpl extends Service implements StaffPlanService {
         Date startDate = DateUtil.parseToDate(timeStart);
         Date endDate = DateUtil.parseToDate(timeEnd);
         OrganizationAssert.isFalse(startDate.after(endDate), "开始时间不允许在结束时间之后");
-        StaffPlanPO staffPlanPO1 = getStaffPlanMapper().customSelect(param.getTimeStart(), param.getEcCompany(), param.getControlDimension());
+        StaffPlanPO staffPlanPO1 = getStaffPlanMapper().customSelect(param.getTimeStart(),param.getTimeEnd(), param.getEcCompany(), param.getControlDimension());
         OrganizationAssert.isNull(staffPlanPO1,"同一维度下，相同适用公司编制方案的时间段不允许出现交叉");
         // 多选赋值
         staffPlanPO.setCompanyId(staffPlanPO.getEcCompany());
-- 
2.40.0.windows.1