浏览代码

Merge remote-tracking branch 'origin/V0.0.2' into V0.0.2

jingyuanchao 2 年之前
父节点
当前提交
aa3c046c59
共有 23 个文件被更改,包括 251 次插入165 次删除
  1. 15 4
      project_data/sql/0.0.2/soc/soc.sql
  2. 2 2
      soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteUserService.java
  3. 4 2
      soc-api/soc-api-system/src/main/java/com/xunmei/system/api/dto/SysPlanOrgDTO.java
  4. 2 2
      soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteUserFallbackFactory.java
  5. 1 1
      soc-auth/src/main/java/com/xunmei/auth/service/SysPasswordService.java
  6. 1 1
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/controller/CoreEvaluateTaskController.java
  7. 2 0
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/mapper/CoreEvaluateTaskMapper.java
  8. 6 0
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/service/ICoreEvaluateTaskService.java
  9. 6 0
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/service/impl/CoreEvaluateTaskServiceImpl.java
  10. 8 11
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/information/service/impl/CoreResumptionConfigurationServiceImpl.java
  11. 10 0
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppResumptionData.java
  12. 10 0
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/gx/vo/ResumptionPlanVo.java
  13. 3 3
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/service/impl/ResumptionServiceImpl.java
  14. 5 0
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/safetyCheck/controller/CoreSafecheckPlanController.java
  15. 3 0
      soc-modules/soc-modules-core/src/main/resources/mapper/evaluate/CoreEvaluateTaskMapper.xml
  16. 29 20
      soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppPlanMapper.xml
  17. 116 98
      soc-modules/soc-modules-core/src/main/resources/mapper/resumption/ResumptionMapper.xml
  18. 7 3
      soc-modules/soc-modules-system/src/main/java/com/xunmei/system/controller/SysUserController.java
  19. 2 2
      soc-modules/soc-modules-system/src/main/java/com/xunmei/system/mapper/SysUserMapper.java
  20. 2 2
      soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/ISysUserService.java
  21. 2 2
      soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/impl/SysUserServiceImpl.java
  22. 10 10
      soc-modules/soc-modules-system/src/main/java/com/xunmei/system/util/UserExport.java
  23. 5 2
      soc-modules/soc-modules-system/src/main/resources/mapper/system/SysUserMapper.xml

+ 15 - 4
project_data/sql/0.0.2/soc/soc.sql

@@ -1129,19 +1129,19 @@ END IF;
 			CHANGE COLUMN `plan_id` `parent_plan_id` bigint NULL DEFAULT NULL COMMENT '父计划id,没有就与plan_id一致' AFTER `ymd_minute`,
 			ADD COLUMN `plan_id` bigint NULL COMMENT '生成任务的计划id' AFTER `parent_plan_id`;
     END IF;
-	
+
 	-- 履职库内容表增加NFC点位
     IF
         NOT EXISTS ( SELECT * FROM INFORMATION_SCHEMA.COLUMNS WHERE table_schema = DATABASE () and TABLE_NAME = 'core_resumption_rule_point' AND COLUMN_NAME = 'check_id' ) THEN
-        ALTER TABLE `core_resumption_rule_point` 
+        ALTER TABLE `core_resumption_rule_point`
 			MODIFY COLUMN `area_id` bigint NULL COMMENT '履职区域,区域表id' AFTER `name`,
 			ADD COLUMN `check_id` bigint NULL COMMENT 'NFC点位id' AFTER `area_id`;
     END IF;
-	
+
 	-- 履职登记内容表增加NFC点位
     IF
         NOT EXISTS ( SELECT * FROM INFORMATION_SCHEMA.COLUMNS WHERE table_schema = DATABASE () and TABLE_NAME = 'core_resumption_data' AND COLUMN_NAME = 'check_id' ) THEN
-        ALTER TABLE `core_resumption_data` 
+        ALTER TABLE `core_resumption_data`
 			ADD COLUMN `check_id` bigint NULL COMMENT '点位id' AFTER `area_id`;
     END IF;
 
@@ -1157,6 +1157,17 @@ END IF;
         alter table core_drill_task
             add drill_end_time datetime(6) null comment '演练结束时间' after drill_start_time;
     END IF;
+	-- 履职数据增加两个字段,是否必查,是否扫描NFC
+    IF
+        NOT EXISTS ( SELECT * FROM INFORMATION_SCHEMA.COLUMNS WHERE table_schema = DATABASE () and TABLE_NAME = 'core_resumption_data' AND COLUMN_NAME = 'point_scan' ) THEN
+        ALTER TABLE `core_resumption_data`
+			ADD COLUMN `point_scan` tinyint(1) NULL DEFAULT NULL COMMENT '是否扫描NFC 1扫描,0不扫描' AFTER `data_status`;
+    END IF;
+       IF
+        NOT EXISTS ( SELECT * FROM INFORMATION_SCHEMA.COLUMNS WHERE table_schema = DATABASE () and TABLE_NAME = 'core_resumption_data' AND COLUMN_NAME = 'required' ) THEN
+        ALTER TABLE `core_resumption_data`
+			ADD COLUMN `required` tinyint(0) NULL DEFAULT 1 COMMENT '是否必须检查 1必检查,0非必捡' AFTER `data_status`;
+    END IF;
 
 
 ALTER TABLE `core_protection` MODIFY COLUMN `device_id` BIGINT NULL DEFAULT NULL COMMENT '设备ID' AFTER `id`;

+ 2 - 2
soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteUserService.java

@@ -5,7 +5,7 @@ import com.xunmei.common.core.constant.ServiceNameConstants;
 import com.xunmei.common.core.domain.R;
 import com.xunmei.common.core.domain.message.domain.CoreAnnouncementNotificationToRole;
 import com.xunmei.common.core.vo.IdNameVo;
-import com.xunmei.system.api.dto.SysRoleOrgDTO;
+import com.xunmei.system.api.dto.SysPlanOrgDTO;
 import com.xunmei.system.api.domain.SysUser;
 import com.xunmei.system.api.factory.RemoteUserFallbackFactory;
 import com.xunmei.system.api.model.LoginUser;
@@ -72,7 +72,7 @@ public interface RemoteUserService {
     public List<SysUser>  getUserListByRole(@RequestBody List<CoreAnnouncementNotificationToRole> notificationToRoles, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
 
     @PostMapping("/user/userListByRoleAndOrg")
-    public List<SysUser> userListByRoleAndOrg(@RequestBody SysRoleOrgDTO sysRoleOrgDTO, @RequestHeader(SecurityConstants.FROM_SOURCE) String source) ;
+    public List<SysUser> userListByRoleAndOrg(@RequestBody SysPlanOrgDTO sysRoleOrgDTO, @RequestHeader(SecurityConstants.FROM_SOURCE) String source) ;
 
     /**
      * 获取用户的角色id及名称

+ 4 - 2
soc-api/soc-api-system/src/main/java/com/xunmei/system/api/dto/SysRoleOrgDTO.java → soc-api/soc-api-system/src/main/java/com/xunmei/system/api/dto/SysPlanOrgDTO.java

@@ -2,12 +2,14 @@ package com.xunmei.system.api.dto;
 
 import lombok.Data;
 
+import java.util.List;
+
 /**
  * @author :LuoWei
  * @date : 2023/9/21
  */
 @Data
-public class SysRoleOrgDTO {
+public class SysPlanOrgDTO {
     private Long orgId;
-    private Long roleId;
+    private Long planId;
 }

+ 2 - 2
soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteUserFallbackFactory.java

@@ -6,7 +6,7 @@ import com.xunmei.common.core.domain.message.domain.CoreAnnouncementNotification
 import com.xunmei.common.core.vo.IdNameVo;
 import com.xunmei.system.api.RemoteUserService;
 import com.xunmei.system.api.domain.SysUser;
-import com.xunmei.system.api.dto.SysRoleOrgDTO;
+import com.xunmei.system.api.dto.SysPlanOrgDTO;
 import com.xunmei.system.api.model.LoginUser;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -72,7 +72,7 @@ public class RemoteUserFallbackFactory implements FallbackFactory<RemoteUserServ
             }
 
             @Override
-            public List<SysUser> userListByRoleAndOrg(SysRoleOrgDTO sysRoleOrgDTO, String source) {
+            public List<SysUser> userListByRoleAndOrg(SysPlanOrgDTO sysRoleOrgDTO, String source) {
                 return null;
             }
 

+ 1 - 1
soc-auth/src/main/java/com/xunmei/auth/service/SysPasswordService.java

@@ -64,7 +64,7 @@ public class SysPasswordService
             recordLogService.recordLogininfor(username, Constants.LOGIN_FAIL, String.format("密码输入错误%s次", retryCount),platformType);
             RedisUtils.setCacheObject(getCacheKey(username), retryCount, Duration.ofMinutes(lockTime));
             //redisService.setCacheObject(getCacheKey(username), retryCount, lockTime, TimeUnit.MINUTES);
-            throw new ServiceException("用户不存在/密码错误");
+            throw new ServiceException("密码错误");
         }
         else
         {

+ 1 - 1
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/controller/CoreEvaluateTaskController.java

@@ -43,7 +43,7 @@ public class CoreEvaluateTaskController extends BaseController {
     @ApiOperation(value = "统计")
     @RequiresPermissions("core:task:list")
     @GetMapping("/statistics")
-    public TableDataInfo<CoreEvaluateTaskVO> statistics(EvaluateTaskDTO coreEvaluateTask) {
+    public TableDataInfo statistics(EvaluateTaskDTO coreEvaluateTask) {
         return coreEvaluateTaskService.selectPage(coreEvaluateTask);
     }
     /**

+ 2 - 0
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/mapper/CoreEvaluateTaskMapper.java

@@ -11,6 +11,7 @@ import com.xunmei.core.evaluate.vo.CoreEvaluateTaskVO;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 外包评价任务Mapper接口
@@ -69,4 +70,5 @@ public interface CoreEvaluateTaskMapper extends BaseMapper<CoreEvaluateTask> {
 
     Page<CoreEvaluateTaskVO> selectPageList(@Param("page") Page<CoreEvaluateTaskVO> page, @Param("request") EvaluateTaskDTO request);
 
+    Page<Map> statistics(@Param("page") Page<Map> page, @Param("request") EvaluateTaskDTO request);
 }

+ 6 - 0
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/service/ICoreEvaluateTaskService.java

@@ -75,4 +75,10 @@ public interface ICoreEvaluateTaskService extends IService<CoreEvaluateTask> {
      */
     TableDataInfo<CoreEvaluateTaskVO> selectPage(EvaluateTaskDTO evaluateTaskDTO);
 
+    /**
+     * 统计
+     * @param evaluateTaskDTO
+     * @return
+     */
+    TableDataInfo statistics(EvaluateTaskDTO evaluateTaskDTO);
 }

+ 6 - 0
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/evaluate/service/impl/CoreEvaluateTaskServiceImpl.java

@@ -101,6 +101,12 @@ public class CoreEvaluateTaskServiceImpl extends ServiceImpl<CoreEvaluateTaskMap
         return TableDataInfo.build(page);
     }
 
+    @Override
+    public TableDataInfo statistics(EvaluateTaskDTO evaluateTaskDTO) {
+
+        return null;
+    }
+
     /**
      * 查询外包评价任务
      *

+ 8 - 11
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/information/service/impl/CoreResumptionConfigurationServiceImpl.java

@@ -7,17 +7,15 @@ import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.xunmei.common.core.constant.SecurityConstants;
 import com.xunmei.common.core.utils.StringUtils;
-import com.xunmei.common.core.web.domain.AjaxResult;
 import com.xunmei.core.information.service.ICoreMessageCenterService;
 import com.xunmei.system.api.RemoteJobService;
 import com.xunmei.system.api.domain.SysUser;
 import com.xunmei.system.api.dto.SysJobDTO;
-import com.xunmei.system.api.dto.SysRoleOrgDTO;
+import com.xunmei.system.api.dto.SysPlanOrgDTO;
 import com.xunmei.common.core.utils.DateUtils;
 import com.xunmei.common.security.utils.SecurityUtils;
 import com.xunmei.core.information.domain.CoreMessageCenter;
 import com.xunmei.core.information.domain.CoreResumptionConfiguration;
-import com.xunmei.core.information.mapper.CoreMessageCenterMapper;
 import com.xunmei.core.resumption.domain.Resumption;
 import com.xunmei.core.resumption.dto.CoreResumptionConfigurationDTO;
 import com.xunmei.core.information.mapper.CoreResumptionConfigurationMapper;
@@ -213,13 +211,12 @@ public class CoreResumptionConfigurationServiceImpl extends ServiceImpl<CoreResu
         c.set(Calendar.SECOND, 0);
         c.set(Calendar.MILLISECOND, 0);
         c.add(Calendar.DAY_OF_MONTH, time);
-        System.out.print(simpleDateFormat.format(c.getTime()));
         return simpleDateFormat.format(c.getTime());
     }
 
-    private void addMassageCenter(String taskName, String time, String cycle, Long orgId, Long roleId) {
-        SysRoleOrgDTO sysRoleOrgDTO = new SysRoleOrgDTO();
-        sysRoleOrgDTO.setRoleId(roleId);
+    private void addMassageCenter(String taskName, String time, String cycle, Long orgId, Long planId) {
+        SysPlanOrgDTO sysRoleOrgDTO = new SysPlanOrgDTO();
+        sysRoleOrgDTO.setPlanId(planId);
         sysRoleOrgDTO.setOrgId(orgId);
         //根据角色和机构查人
         List<SysUser> sysUsers = remoteUserService.userListByRoleAndOrg(sysRoleOrgDTO, SecurityConstants.INNER);
@@ -275,7 +272,7 @@ public class CoreResumptionConfigurationServiceImpl extends ServiceImpl<CoreResu
         List<Resumption> resumptions = resumptionMapper.selectDay(getTime(0), "2");
         if (CollectionUtils.isNotEmpty(coreResumptionConfigurations) && CollectionUtils.isNotEmpty(resumptions)) {
             resumptions.forEach(r -> {
-                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getRoleId());
+                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getPlanId());
             });
         }
     }
@@ -289,7 +286,7 @@ public class CoreResumptionConfigurationServiceImpl extends ServiceImpl<CoreResu
         List<Resumption> resumptions = resumptionMapper.selectDay(getTime(0), "3");
         if (CollectionUtils.isNotEmpty(coreResumptionConfigurations) && CollectionUtils.isNotEmpty(resumptions)) {
             resumptions.forEach(r -> {
-                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getRoleId());
+                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getPlanId());
             });
         }
     }
@@ -303,7 +300,7 @@ public class CoreResumptionConfigurationServiceImpl extends ServiceImpl<CoreResu
         List<Resumption> resumptions = resumptionMapper.selectDay(getTime(0), "4");
         if (CollectionUtils.isNotEmpty(coreResumptionConfigurations) && CollectionUtils.isNotEmpty(resumptions)) {
             resumptions.forEach(r -> {
-                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getRoleId());
+                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getPlanId());
             });
         }
     }
@@ -317,7 +314,7 @@ public class CoreResumptionConfigurationServiceImpl extends ServiceImpl<CoreResu
         List<Resumption> resumptions = resumptionMapper.selectDay(getTime(0), "1");
         if (CollectionUtils.isNotEmpty(coreResumptionConfigurations) && CollectionUtils.isNotEmpty(resumptions)) {
             resumptions.forEach(r -> {
-                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getRoleId());
+                addMassageCenter(r.getName(), null, coreResumptionConfigurations.get(0).getTimeUnit(), r.getOrgId(), r.getPlanId());
             });
         }
     }

+ 10 - 0
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppResumptionData.java

@@ -85,4 +85,14 @@ public class AppResumptionData extends Model<AppResumptionData> implements Seria
      * 数据状态 1未处理,2已处理
      */
     private Integer dataStatus;
+
+    /**
+     * 是否扫描NFC 1扫描,0不扫描
+     */
+    private  Integer pointScan;
+
+    /**
+     * 是否检查 1检查,0不检查
+     */
+    private Integer required;
 }

+ 10 - 0
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/gx/vo/ResumptionPlanVo.java

@@ -49,6 +49,16 @@ public class ResumptionPlanVo {
     private Long pointId;
 
     /**
+     * 是否扫描NFC 1扫描,0不扫描
+     */
+    private  Integer pointScan;
+
+    /**
+     * 是否检查 1检查,0不检查
+     */
+    private Integer required;
+
+    /**
      * 履职内容
      */
     private String pointName;

+ 3 - 3
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/service/impl/ResumptionServiceImpl.java

@@ -110,7 +110,7 @@ public class ResumptionServiceImpl extends ServiceImpl<ResumptionMapper, Resumpt
     @Override
     @Transactional(readOnly = false, rollbackFor = {Exception.class, RuntimeException.class}, propagation = Propagation.REQUIRES_NEW)
     public void newbuild(Long orgId, ResumptionType type, final Date dateTime, final Boolean isWork, AppPlan appPlan, List<Object> nfcList, List<AppRulePointTaskVo> pointList, List<Long> roleIds, DateTime planstartTime, DateTime planendTime) {
-        if(ObjectUtil.notEqual(isWork,true)){
+        if (ObjectUtil.notEqual(isWork, true)) {
             return;
         }
         Ymd ymd = Ymd.of(dateTime);
@@ -186,9 +186,9 @@ public class ResumptionServiceImpl extends ServiceImpl<ResumptionMapper, Resumpt
 
     @Override
     public List<PanelListVo> selectCurUserTaskList(PanelListDto panelListDto) {
-
         List<PanelListVo> list = resumptionMapper.selectCurUserTaskList(panelListDto);
-        list.removeIf(item -> DateUtil.compare(new Date(), item.getEndTime()) > 0);
+        Date end = DateUtil.endOfDay(new Date());
+        list.removeIf(item -> DateUtil.compare(end, item.getEndTime()) <= 0);
         list.forEach(item -> {
             item.setType(PanelTypeEnums.RESUMPTION.getCode());
         });

+ 5 - 0
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/safetyCheck/controller/CoreSafecheckPlanController.java

@@ -119,7 +119,12 @@ public class CoreSafecheckPlanController extends BaseController {
     @Log(title = "常规安全检查计划", businessType = BusinessType.INSERT)
     @PostMapping
     public AjaxResult add(@RequestBody CoreSafecheckPlan coreSafecheckPlan) throws Exception {
+
         Long planId = coreSafecheckPlan.getId();
+        //处理无周期
+        if(coreSafecheckPlan.getPlanCycle()==6){
+            coreSafecheckPlan.setBuildTaskNow(true);
+        }
         Long returnId = coreSafecheckPlanService.insertCoreSafecheckPlan(coreSafecheckPlan);
         //判断是否是编辑并且计划所属任务不存在已完成或者逾期,需要删除所有任务重新生成
         boolean isEditAll = coreSafecheckPlan.getHasEdit() == null && planId != null&&coreSafecheckPlan.isBuildTaskNow();

+ 3 - 0
soc-modules/soc-modules-core/src/main/resources/mapper/evaluate/CoreEvaluateTaskMapper.xml

@@ -100,6 +100,9 @@ SELECT
         </if>
         GROUP BY a.id
     </select>
+    <select id="statistics" resultType="java.util.Map">
+
+    </select>
 
     <insert id="insertCoreEvaluateTask" parameterType="com.xunmei.core.evaluate.domain.CoreEvaluateTask">
         insert into core_evaluate_task

+ 29 - 20
soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppPlanMapper.xml

@@ -398,25 +398,34 @@
         </where>
     </select>
     <select id="selectResumptionPlan" resultType="com.xunmei.core.resumption.gx.vo.ResumptionPlanVo">
-        select q.item_id,
-               q.item_name,
-               q.point_id,
-               q.point_name,
-               q.area_id,
-               w.`name` as area_name,
-               q.check_id,
-               q.plan_id
-        from (select c.id     as item_id,
-                     c.`name` as item_name,
-                     b.id     as point_id,
-                     b.name   as point_name,
-                     b.area_id,
-                     b.check_id,
-                     a.plan_id
-              from core_resumption_plan_to_point a
-                       LEFT JOIN core_resumption_rule_point b on a.point_id = b.id
-                       LEFT JOIN core_resumption_rule_item c on b.item_id = c.id
-              where a.plan_id = #{planId}) q
-                 LEFT JOIN sys_area w on q.area_id = w.id
+        select
+            q.item_id,
+            q.item_name,
+            q.point_id,
+            q.point_name,
+            q.area_id,
+            w.`name` as area_name,
+            q.check_id,
+            q.plan_id,
+            q.point_scan,
+            q.required
+        from
+            (
+                select
+                    c.id as item_id,
+                    c.`name` as item_name,
+                    b.id as point_id,
+                    b.name as point_name,
+                    b.area_id,
+                    b.check_id,
+                    a.plan_id,
+                    a.point_scan,
+					a.required
+                from core_resumption_plan_to_point a
+                         LEFT JOIN core_resumption_rule_point b on a.point_id = b.id
+                         LEFT JOIN core_resumption_rule_item c on b.item_id = c.id
+                where a.plan_id = #{planId}
+            ) q
+                LEFT JOIN sys_area w on q.area_id = w.id
     </select>
 </mapper>

+ 116 - 98
soc-modules/soc-modules-core/src/main/resources/mapper/resumption/ResumptionMapper.xml

@@ -15,16 +15,16 @@
         <!--          and ymd_quarter = #{resumption.ymd.quarter}-->
     </update>
     <update id="updateNameByPlanId">
-update   core_resumption set name=#{planName} where plan_id =#{planId} and status in (1,2)
-
-
+        update core_resumption
+        set name=#{planName}
+        where plan_id = #{planId}
+          and status in (1, 2)
     </update>
     <delete id="deleteResumption">
         delete from core_resumption where ymd_year = #{year} and ymd_quarter=#{quarter} and id in
         <foreach collection="ids" item="item" open="(" separator="," close=")">
             #{item}
         </foreach>
-
     </delete>
 
 
@@ -139,136 +139,154 @@ update   core_resumption set name=#{planName} where plan_id =#{planId} and statu
     <select id="selectAllByPlanStartTime" resultType="com.xunmei.core.resumption.domain.Resumption">
         SELECT *
         FROM core_resumption
-        WHERE `status` =1 and type = #{type}
+        WHERE `status` = 1
+          and type = #{type}
           and plan_end_time like concat(#{planEndTime}, '%')
     </select>
     <select id="selectDay" resultType="com.xunmei.core.resumption.domain.Resumption">
-        SELECT
-            a.*
-        FROM
-            core_resumption a
-                LEFT JOIN core_resumption_plan b ON a.plan_id = b.id
-        WHERE
-            a.type =2 AND b.plan_exec=#{planExec} and a.`status` =1
+        SELECT a.*
+        FROM core_resumption a
+                 LEFT JOIN core_resumption_plan b ON a.plan_id = b.id
+        WHERE a.type = 2
+          AND b.plan_exec = #{planExec}
+          and a.`status` = 1
           AND a.plan_end_time like concat(#{planEndTime}, '%')
-
     </select>
     <select id="findResumptionList" resultType="com.xunmei.core.resumption.vo.WorkChangeResumptionVo">
         select a.id,b.id as planId,b.plan_exec as planExec,a.status,a.org_id as orgId
         from core_resumption a left join core_resumption_plan b on a.plan_id =b.id
-        where a.ymd_year = #{year} and a.ymd_quarter=#{quarter} and a.ymd_date=#{date} and `type`=#{type} and b.plan_exec not in (4,5,6) and a.org_id in
+        where a.ymd_year = #{year} and a.ymd_quarter=#{quarter} and a.ymd_date=#{date} and `type`=#{type} and
+        b.plan_exec not in (4,5,6) and a.org_id in
         <foreach collection="orgIds" item="item" open="(" separator="," close=")">
             #{item}
         </foreach>
         <if test="status!=null">
             and a.status=#{status}
         </if>
-
     </select>
     <select id="selectResumptionPlan" resultType="com.xunmei.core.resumption.gx.vo.ResumptionPlanVo">
-         select
-            a.data_id,
-            a.area_id,
-            d.`name` as area_name,
-            a.check_id,
-            c.id as item_id,
-            c.`name` as item_name,
-            b.id as point_id,
-            b.`name` as point_name,
-            a.res_value,
-            a.res_remark,
-            a.rectification_deadline,
-            a.data_status
-        from
-            (select id as data_id,area_id,check_id,item_id,res_value,res_remark,rectification_deadline,data_status
-             from core_resumption_data where resumption_id = #{resumptionId}) a
-                LEFT JOIN core_resumption_rule_point b on a.item_id = b.id
-                LEFT JOIN core_resumption_rule_item c on b.item_id = c.id
-                LEFT JOIN sys_area d on a.area_id = d.id
+        select a.data_id,
+               a.area_id,
+               d.`name` as area_name,
+               a.check_id,
+               c.id     as item_id,
+               c.`name` as item_name,
+               b.id     as point_id,
+               b.`name` as point_name,
+               a.res_value,
+               a.res_remark,
+               a.rectification_deadline,
+               a.data_status,
+               a.point_scan,
+               a.required
+        from (select id as data_id,
+                     area_id,
+                     check_id,
+                     item_id,
+                     res_value,
+                     res_remark,
+                     rectification_deadline,
+                     data_status,
+                     point_scan,
+                     required
+              from core_resumption_data
+              where resumption_id = #{resumptionId}) a
+                 LEFT JOIN core_resumption_rule_point b on a.item_id = b.id
+                 LEFT JOIN core_resumption_rule_item c on b.item_id = c.id
+                 LEFT JOIN sys_area d on a.area_id = d.id
     </select>
     <select id="selectResumptionNFC" resultType="com.xunmei.core.resumption.gx.vo.ResumptionNFCVo">
-         SELECT
-            a.area_id,
-            a.check_id,
-            a.id as nfc_id,
-            a.collection_area_name as nfc_name,
-            a.`code` as nfc_code,
-            b.`status`,
-            b.scan_method,
-            b.img
-        FROM
-            ( SELECT area_id,check_id, collection_area_name, CODE, id FROM sys_nfc_bind WHERE (area_id =#{areaId} AND org_id = #{orgId} and del_flag='0' ) a
-            LEFT JOIN ( SELECT nfc_id, point_id, img, STATUS, scan_method FROM core_resumption_data_nfc WHERE resumption_id = #{resumptionId} ) b ON a.id = b.nfc_id
-
+        SELECT a.area_id,
+               a.check_id,
+               a.id                   as nfc_id,
+               a.collection_area_name as nfc_name,
+               a.`code`               as nfc_code,
+               b.`status`,
+               b.scan_method,
+               b.img
+        FROM (SELECT area_id, check_id, collection_area_name, CODE, id
+              FROM sys_nfc_bind
+              WHERE (area_id = #{areaId} AND org_id = #{orgId} and del_flag = '0') a
+            LEFT JOIN ( SELECT nfc_id, point_id, img, STATUS, scan_method FROM core_resumption_data_nfc WHERE resumption_id = #{resumptionId} ) b
+              ON a.id = b.nfc_id
     </select>
     <select id="selectNFCOfOrg" resultType="com.xunmei.core.resumption.gx.vo.ResumptionNFCVo">
-        SELECT
-            a.area_id,
-            ar.name as area_name,
-            a.check_id,
-            a.id as nfc_id,
-            a.label_name as nfc_name,
-            a.`code` as nfc_code,
-            b.`status`,
-            b.scan_method,
-            b.img
-        FROM
-            ( SELECT area_id,check_id, collection_area_name, CODE, id,label_name FROM sys_nfc_bind WHERE org_id = #{orgId} and del_flag='0'and enable='0' ) a
-            LEFT JOIN ( SELECT nfc_id, point_id, img, STATUS, scan_method FROM core_resumption_data_nfc WHERE resumption_id = #{resumptionId} ) b ON a.id = b.nfc_id
-            left join sys_area ar on ar.id=a.area_id and ar.del_flag='0'
+        SELECT a.area_id,
+               ar.name      as area_name,
+               a.check_id,
+               a.id         as nfc_id,
+               a.label_name as nfc_name,
+               a.`code`     as nfc_code,
+               b.`status`,
+               b.scan_method,
+               b.img
+        FROM (SELECT area_id, check_id, collection_area_name, CODE, id, label_name
+              FROM sys_nfc_bind
+              WHERE org_id = #{orgId}
+                and del_flag = '0'
+                and enable = '0') a
+                 LEFT JOIN (SELECT nfc_id, point_id, img, STATUS, scan_method
+                            FROM core_resumption_data_nfc
+                            WHERE resumption_id = #{resumptionId}) b ON a.id = b.nfc_id
+                 left join sys_area ar on ar.id = a.area_id and ar.del_flag = '0'
     </select>
     <select id="selectCurUserTaskList" resultType="com.xunmei.common.core.domain.panel.vo.PanelListVo">
+        select distinct t.id              as id,
+                        name              as taskName,
+                        t.plan_start_time as startTime,
+                        t.plan_end_time   as endTime,
+                        t.status
+        from core_resumption t
+        where t.org_id = #{request.orgId}
+          and t.plan_id in (select pr.plan_id
+                            from core_resumption_plan_to_role pr
+                                     inner join core_resumption_plan p
+                                                on pr.plan_id = p.id and p.deleted = 0 and p.plan_status = 1)
 
-        select distinct t.id as id, name as taskName,t.plan_start_time as startTime,t.plan_end_time as endTime,t.status
-        from core_resumption t where  t.org_id =#{request.orgId} and  t.role_id in
-        <foreach collection="request.roleIdList" item="roleId" open="(" separator="," close=")">
-            #{roleId}
-        </foreach>
-        and  t.status in (1,2)
-        and ((
-            #{request.startTime}   <![CDATA[<=]]> t.plan_start_time
-        and #{request.endTime} >= t.plan_start_time
-        )
-        or (
-            #{request.startTime}    <![CDATA[<=]]> t.plan_end_time
-        and #{request.endTime} >= t.plan_end_time
-        )
-        or (
-            #{request.startTime} >= t.plan_start_time
-        and #{request.endTime}  <![CDATA[<=]]>  t.plan_end_time
-        ))
+          and t.status in (1, 2)
+          and ((
+                           #{request.startTime}   <![CDATA[<=]]> t.plan_start_time
+                       and #{request.endTime} >= t.plan_start_time
+                   )
+            or (
+                           #{request.startTime}    <![CDATA[<=]]> t.plan_end_time
+                       and #{request.endTime} >= t.plan_end_time
+                   )
+            or (
+                           #{request.startTime} >= t.plan_start_time
+                       and #{request.endTime}  <![CDATA[<=]]> t.plan_end_time
+                   ))
     </select>
 
     <select id="findResumptionExceptionList"
             resultType="com.xunmei.common.core.domain.safetyindex.domain.CoreSafetyExceptionData">
-       <!-- SELECT a.id as dataId, a.org_id as orgId, a.plan_id as extraField1, a.status as extraField2, a.ymd_date as dataTime,'core_resumption' as dataSource,now() as createTime
-        FROM core_resumption a
-        WHERE a.plan_id IN (SELECT a.id
-                            FROM core_resumption_plan a
-                            WHERE a.plan_cycle IN (SELECT cycle
-                                                   FROM core_safety_index_calculate_rule a
-                                                   WHERE a.type_code = 1004
-                                                   GROUP BY org_type, cycle)
-                              AND exec_org_type IN (SELECT org_type
+        <!-- SELECT a.id as dataId, a.org_id as orgId, a.plan_id as extraField1, a.status as extraField2, a.ymd_date as dataTime,'core_resumption' as dataSource,now() as createTime
+         FROM core_resumption a
+         WHERE a.plan_id IN (SELECT a.id
+                             FROM core_resumption_plan a
+                             WHERE a.plan_cycle IN (SELECT cycle
                                                     FROM core_safety_index_calculate_rule a
                                                     WHERE a.type_code = 1004
-                                                    GROUP BY org_type, cycle))
-          and ymd_year =#{year} and ymd_quarter=#{quarter} and ymd_month=#{month} and status in (4) and role_id =#{roleId}-->
-        SELECT a.id              as dataId,
-        a.org_id          as orgId,
-        a.plan_id         as extraField1,
-        p.plan_cycle      as extraField2,
-        a.ymd_date        as dataTime,
+                                                    GROUP BY org_type, cycle)
+                               AND exec_org_type IN (SELECT org_type
+                                                     FROM core_safety_index_calculate_rule a
+                                                     WHERE a.type_code = 1004
+                                                     GROUP BY org_type, cycle))
+           and ymd_year =#{year} and ymd_quarter=#{quarter} and ymd_month=#{month} and status in (4) and role_id =#{roleId}-->
+        SELECT a.id as dataId,
+        a.org_id as orgId,
+        a.plan_id as extraField1,
+        p.plan_cycle as extraField2,
+        a.ymd_date as dataTime,
         'core_resumption' as dataSource,
-        now()             as createTime
+        now() as createTime
         FROM core_resumption a
         inner join core_resumption_plan p on a.plan_id = p.id
         where p.plan_cycle in (2, 3, 4) <!--营业前中后-->
-        and  ymd_year =#{year}
+        and ymd_year =#{year}
         and ymd_quarter=#{quarter}
         and ymd_month=#{month}
         and status in (4)
         and role_id = #{roleId}
-
     </select>
 </mapper>

+ 7 - 3
soc-modules/soc-modules-system/src/main/java/com/xunmei/system/controller/SysUserController.java

@@ -25,7 +25,7 @@ import com.xunmei.system.api.model.LoginUser;
 import com.xunmei.system.domain.SysUserRole;
 import com.xunmei.system.domain.vo.SysUserListVo;
 import com.xunmei.system.domain.vo.UserRoleVo;
-import com.xunmei.system.api.dto.SysRoleOrgDTO;
+import com.xunmei.system.api.dto.SysPlanOrgDTO;
 import com.xunmei.system.mapper.SysOrgMapper;
 import com.xunmei.system.service.*;
 import com.xunmei.system.util.UserExport;
@@ -455,7 +455,7 @@ public class SysUserController extends BaseController {
     @ApiOperation(value = "通过角色和机构获取用户")
     @InnerAuth
     @PostMapping("/userListByRoleAndOrg")
-    public List<SysUser> userListByRoleAndOrg(@RequestBody SysRoleOrgDTO sysRoleOrgDTO) {
+    public List<SysUser> userListByRoleAndOrg(@RequestBody SysPlanOrgDTO sysRoleOrgDTO) {
         return userService.selectUserListByRoleAndOrg(sysRoleOrgDTO);
     }
 
@@ -485,8 +485,12 @@ public class SysUserController extends BaseController {
     @PostMapping("/export")
     public void export(SysUser user, HttpServletResponse response) {
         List<UserExport> list=null;
+        Set<String> excludeColumnFiledNames = new HashSet<String>();
+
         //如果导出模板
         if(user.getTemplate()!=null&&user.getTemplate()){
+            excludeColumnFiledNames.add("lastIp");
+            excludeColumnFiledNames.add("lastTime");
             list = new ArrayList<>();
         }else{
             list= userService.down(user);
@@ -513,7 +517,7 @@ public class SysUserController extends BaseController {
             response.setContentType("application/octet-stream;charset=UTF-8");
             response.setCharacterEncoding("utf-8");
             // 数据导出
-            EasyExcel.write(response.getOutputStream(), UserExport.class)
+            EasyExcel.write(response.getOutputStream(), UserExport.class).excludeColumnFiledNames(excludeColumnFiledNames)
                     .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).sheet("用户数据").doWrite(list);
         } catch (Exception e) {
             // 重置response

+ 2 - 2
soc-modules/soc-modules-system/src/main/java/com/xunmei/system/mapper/SysUserMapper.java

@@ -7,7 +7,7 @@ import com.xunmei.system.api.domain.SysOrg;
 import com.xunmei.system.api.domain.SysRole;
 import com.xunmei.system.api.domain.SysUser;
 import com.xunmei.system.domain.vo.SysUserVO;
-import com.xunmei.system.api.dto.SysRoleOrgDTO;
+import com.xunmei.system.api.dto.SysPlanOrgDTO;
 import com.xunmei.system.util.UserExport;
 import org.apache.ibatis.annotations.Param;
 
@@ -155,7 +155,7 @@ public interface SysUserMapper extends BaseMapper<SysUser> {
 
     List<SysUser> selectUserListByRole(@Param("notificationToRoles") List<CoreAnnouncementNotificationToRole> notificationToRoles);
 
-    List<SysUser> selectUserListByRoleAndOrg(@Param("sysRoleOrgDTO") SysRoleOrgDTO sysRoleOrgDTO);
+    List<SysUser> selectUserListByRoleAndOrg(@Param("sysRoleOrgDTO") SysPlanOrgDTO sysRoleOrgDTO);
 
     List<UserExport> select(@Param("info") SysUser user);
 

+ 2 - 2
soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/ISysUserService.java

@@ -7,7 +7,7 @@ import com.xunmei.system.api.domain.SysRole;
 import com.xunmei.system.api.domain.SysUser;
 import com.xunmei.system.domain.vo.SysUserListVo;
 import com.xunmei.system.domain.vo.SysUserVO;
-import com.xunmei.system.api.dto.SysRoleOrgDTO;
+import com.xunmei.system.api.dto.SysPlanOrgDTO;
 import com.xunmei.system.util.UserExport;
 
 import java.util.List;
@@ -222,7 +222,7 @@ public interface ISysUserService extends IService<SysUser> {
 
     List<SysUser> selectUserListByRole(List<CoreAnnouncementNotificationToRole> notificationToRoles);
 
-    List<SysUser> selectUserListByRoleAndOrg(SysRoleOrgDTO sysRoleOrgDTO);
+    List<SysUser> selectUserListByRoleAndOrg(SysPlanOrgDTO sysRoleOrgDTO);
 
     List<SysUser> selectAllUser(String userName);
 

+ 2 - 2
soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/impl/SysUserServiceImpl.java

@@ -21,7 +21,7 @@ import com.xunmei.system.domain.SysUserPost;
 import com.xunmei.system.domain.SysUserRole;
 import com.xunmei.system.domain.vo.SysUserListVo;
 import com.xunmei.system.domain.vo.SysUserVO;
-import com.xunmei.system.api.dto.SysRoleOrgDTO;
+import com.xunmei.system.api.dto.SysPlanOrgDTO;
 import com.xunmei.system.mapper.*;
 import com.xunmei.system.service.ISysConfigService;
 import com.xunmei.system.service.ISysOrgService;
@@ -608,7 +608,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
     }
 
     @Override
-    public List<SysUser> selectUserListByRoleAndOrg(SysRoleOrgDTO sysRoleOrgDTO) {
+    public List<SysUser> selectUserListByRoleAndOrg(SysPlanOrgDTO sysRoleOrgDTO) {
         return userMapper.selectUserListByRoleAndOrg(sysRoleOrgDTO);
     }
 

+ 10 - 10
soc-modules/soc-modules-system/src/main/java/com/xunmei/system/util/UserExport.java

@@ -18,25 +18,25 @@ import java.util.Date;
 @HeadRowHeight(16) //表头行高
 @ContentRowHeight(16) //数据行高
 public class UserExport {
-    @ExcelProperty(value = "序号", index = 1)
+    @ExcelProperty(value = "序号", index = 0)
     @TableField(exist = false)
     private String xh;
-    @ExcelProperty(value = "用户账号", index = 2)
+    @ExcelProperty(value = "用户账号", index = 1)
     private String username;
-    @ExcelProperty(value = "用户姓名", index = 3)
+    @ExcelProperty(value = "用户姓名", index = 2)
     private String name;
-    @ExcelProperty(value = "所属机构", index = 4)
+    @ExcelProperty(value = "所属机构", index = 3)
     private String orgName;
-    @ExcelProperty(value = "用户角色", index = 5)
+    @ExcelProperty(value = "用户角色", index = 4)
     private String roleNames;
-    @ExcelProperty(value = "手机号码", index = 6)
+    @ExcelProperty(value = "手机号码", index = 5)
     private String phone;
-    @ExcelProperty(value = "状态", index = 7, converter = UserStatusConverter.class)
+    @ExcelProperty(value = "状态", index = 6, converter = UserStatusConverter.class)
     private String isLock;
-    @ExcelProperty(value = "是否管理人员", index = 8, converter = UserManagerConverter.class)
+    @ExcelProperty(value = "是否管理人员", index = 7, converter = UserManagerConverter.class)
     private String isManager;
-    @ExcelProperty(value = "登录IP", index = 9)
+    @ExcelProperty(value = "登录IP", index = 8)
     private String lastIp;
-    @ExcelProperty(value = "登录时间", index = 10)
+    @ExcelProperty(value = "登录时间", index = 9)
     private Date lastTime;
 }

+ 5 - 2
soc-modules/soc-modules-system/src/main/resources/mapper/system/SysUserMapper.xml

@@ -609,13 +609,13 @@
             a.deleted = 0
           AND d.del_flag = 0
           AND b.id = #{sysRoleOrgDTO.orgId}
-          AND d.id = #{sysRoleOrgDTO.roleId}
+          AND d.id IN (	SELECT role_id FROM core_resumption_plan_to_role WHERE plan_id=#{sysRoleOrgDTO.planId})
     </select>
     <select id="select" resultType="com.xunmei.system.util.UserExport">
         SELECT
         #         h.user_id AS is_manager,
         GROUP_CONCAT(sr.role_name) role_names,
-        CONCAT(",",GROUP_CONCAT( sr.id ),",") as roleIds,
+        CONCAT(',',GROUP_CONCAT( sr.id ),',') as roleIds,
         u.id,
         u.dept_id,
         u.is_lock,
@@ -683,6 +683,9 @@
         <if test="info.roleId != null and info.roleId != ''">
             AND sr.id =#{info.roleId}
         </if>
+        <if test="info.onlyManager ==true">
+            AND u.is_manage ='Y'
+        </if>
         <if test="info.params.beginTime != null and info.params.beginTime != ''">
             <!-- 开始时间检索 -->
             AND date_format(u.create_time,'%y%m%d') &gt;= date_format(#{info.params.beginTime},'%y%m%d')