Merge branch 'V0.0.1' of http://10.87.10.227:4000/jzyd_yyds/soc into V0.0.1

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteDictDataService.java

@@ -25,6 +25,6 @@ public interface RemoteDictDataService
      * @param file 文件信息
      * @return 结果
      */
-    @GetMapping(value = "/dict/data/type/{dictType}")
-     public List<SysDictData> dictType(@PathVariable("dictType") String dictType, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
+    @GetMapping(value = "/dict/data/bytype/{dictType}")
+     public List<SysDictData> selectDictByeType(@PathVariable("dictType") String dictType, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
 }

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteOrgService.java

@@ -72,7 +72,7 @@ public interface RemoteOrgService {
      */
     @GetMapping("/org/getUpOrgs/{orgId}")
     List<Long> getUpOrgs(@PathVariable("orgId") Long orgId);
-    @GetMapping("/list/findAllOrg")
+    @GetMapping("/org/list/findAllOrg")
     List<SysOrg> findAllOrg(@RequestHeader(SecurityConstants.FROM_SOURCE) String source);
 
     /**

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteDictDataFallbackFactory.java

@@ -7,6 +7,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.cloud.openfeign.FallbackFactory;
 import org.springframework.stereotype.Component;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -24,8 +25,8 @@ public class RemoteDictDataFallbackFactory implements FallbackFactory<RemoteDict
         return new RemoteDictDataService() {
 
             @Override
-            public List<SysDictData> dictType(String dictType, String source) {
-                return null;
+            public List<SysDictData> selectDictByeType(String dictType, String source) {
+                return new ArrayList<>();
             }
         };
     }

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteOrgFallbackFactory.java

@@ -9,6 +9,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.cloud.openfeign.FallbackFactory;
 import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 
 import java.util.ArrayList;

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/edu/domain/CoreEduTrainingTask.java

@@ -60,7 +60,7 @@ public class CoreEduTrainingTask extends BaseEntity {
 
 
     /**
-     * @see com.xunmei.common.core.enums.edu.EduTrainingDoStatus
+     * @see com.xunmei.common.core.enums.edu.EduTrainingType
      * 类型
      */
     @TableField("type")

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/edu/dto/CoreEduTrainingTaskEditDto.java

@@ -7,7 +7,7 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import javax.validation.constraints.NotNull;
-import java.util.Date;
+import java.time.LocalDateTime;
 import java.util.List;
 
 @Data
@@ -18,42 +18,20 @@ public class CoreEduTrainingTaskEditDto {
     @JsonSerialize(using = com.fasterxml.jackson.databind.ser.std.ToStringSerializer.class)
     private Long id;
 
-    @ApiModelProperty(value = "教育培训计划Id")
-    private Long planId;
-
-    @ApiModelProperty(value = "机构")
-    private Long orgId;
-
-    @ApiModelProperty(value = "机构名称")
-    private String orgName;
-
-    @ApiModelProperty(value = "学习主题")
-    private String title;
-
     /**
-     * @see com.xunmei.common.core.enums.edu.EduTrainingDoStatus
+     * @see com.xunmei.common.core.enums.edu.EduTrainingType
      * 类型
      */
     @ApiModelProperty(value = "类型")
     private Integer type;
 
-    @ApiModelProperty(value = "类型名称")
-    private String typeText;
-
-
-    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
-    @ApiModelProperty(value = "开始日期")
-    private Date startDate;
-
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
-    @ApiModelProperty(value = "截止日期")
-    private Date endDate;
-
     @ApiModelProperty(value = "培训开始时间")
-    private Date trainingStartDateTime;
+    private LocalDateTime trainingStartDateTime;
 
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @ApiModelProperty(value = "培训截止时间")
-    private Date trainingEndDateTime;
+    private LocalDateTime trainingEndDateTime;
 
 
     @ApiModelProperty(value = "内容")
@@ -66,8 +44,6 @@ public class CoreEduTrainingTaskEditDto {
     @ApiModelProperty(value = "图片")
     private List<String> imageList;
 
-    @ApiModelProperty(value = "附件")
-    private List<String> fileList;
     @ApiModelProperty(value = "提交类型", notes = "1:暂存,2:提交")
     private Integer submitType;
 

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/edu/dto/CoreEduTrainingTaskPageDto.java

@@ -1,7 +1,5 @@
 package com.xunmei.common.core.domain.edu.dto;
 
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.ObjectUtil;
 import com.xunmei.common.core.web.domain.PageRequest;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -13,11 +11,6 @@ import java.util.Date;
 @EqualsAndHashCode(callSuper = true)
 public class CoreEduTrainingTaskPageDto extends PageRequest {
 
-    @ApiModelProperty(value = "培训机构")
-    private Long orgId;
-
-    @ApiModelProperty(value = "培训机构")
-    private String orgPath;
 
     @ApiModelProperty(value = "学习主题")
     private String title;
@@ -28,19 +21,19 @@ public class CoreEduTrainingTaskPageDto extends PageRequest {
     @ApiModelProperty(value = "状态")
     private Integer status;
 
-    @ApiModelProperty("任务时间范围")
+    @ApiModelProperty(value = "任务时间范围", notes = "web端传递此参数")
     private Date[] range;
 
+
     private Date startTime;
 
     private Date endTime;
 
+    @ApiModelProperty(value = "任务时间范围", notes = "App传递此参数")
+    private Date date;
+
+    @ApiModelProperty(value = "是否是App端查询", notes = "App端查询传递此参数")
+    private Integer isAppSelect;
 
-    public CoreEduTrainingTaskPageDto() {
-        if (ObjectUtil.isNotEmpty(this.range)) {
-            this.startTime = DateUtil.beginOfDay(this.range[0]);
-            this.endTime = DateUtil.endOfDay(this.range[0]);
-        }
-    }
 
 }

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/edu/vo/CoreEduTrainingTaskDetailVo.java

@@ -6,7 +6,7 @@ import com.xunmei.common.core.domain.edu.domain.CoreEduTrainingTaskToUser;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
-import java.util.Date;
+import java.time.LocalDateTime;
 import java.util.List;
 
 @Data
@@ -57,19 +57,19 @@ public class CoreEduTrainingTaskDetailVo {
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @ApiModelProperty(value = "计划任务开始日期")
-    private Date startDate;
+    private LocalDateTime startDate;
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @ApiModelProperty(value = "计划任务截止日期")
-    private Date endDate;
+    private LocalDateTime endDate;
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @ApiModelProperty(value = "培训开始时间")
-    private Date trainingStartDateTime;
+    private LocalDateTime trainingStartDateTime;
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @ApiModelProperty(value = "培训截止时间")
-    private Date trainingEndDateTime;
+    private LocalDateTime trainingEndDateTime;
 
     @ApiModelProperty(value = "内容")
     private String content;

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/edu/vo/CoreEduTrainingTaskPageVo.java

@@ -1,13 +1,5 @@
 package com.xunmei.common.core.domain.edu.vo;
 
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.databind.annotation.JsonSerialize;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Data;
-
-import java.util.Date;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import io.swagger.annotations.ApiModelProperty;
@@ -36,7 +28,7 @@ public class CoreEduTrainingTaskPageVo {
     private String title;
 
     /**
-     * @see com.xunmei.common.core.enums.edu.EduTrainingDoStatus
+     * @see com.xunmei.common.core.enums.edu.EduTrainingType
      * 类型
      */
     @ApiModelProperty(value = "类型")
@@ -60,17 +52,14 @@ public class CoreEduTrainingTaskPageVo {
     @ApiModelProperty(value = "任务计划截止日期")
     private Date endDate;
 
-//    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
-//    @ApiModelProperty(value = "培训时间")
-//    private Date dateTime;
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @ApiModelProperty(value = "培训开始时间")
     private Date trainingStartDateTime;
 
-//    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
-//    @ApiModelProperty(value = "培训开始时间")
-//    private Date trainingEndDateTime;
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @ApiModelProperty(value = "培训开始时间")
+    private Date trainingEndDateTime;
 
     /**
      * @see com.xunmei.common.core.enums.edu.EduTrainingDoStatus
@@ -83,5 +72,9 @@ public class CoreEduTrainingTaskPageVo {
 
     private String taskRoleNameList;
 
-  @ApiModelProperty(value = "pdf下载地址")
-    private String pdfUrl;}
+    @ApiModelProperty(value = "pdf下载地址")
+    private String pdfUrl;
+
+    @ApiModelProperty(value = "签名情况", notes = "已签名人数/总人数")
+    private String signNums;
+}

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/domain/CoreMonitoringRetrievalTask.java

@@ -69,7 +69,7 @@ private static final long serialVersionUID=1L;
     private Integer ymdDay;
 
     /** 周期无周期、每日、每周、每月、每季度、每半年、每年（0-6） */
-    private Integer cycle;
+    private String cycle;
 
     /** 开始时间 */
             @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@@ -93,7 +93,7 @@ private static final long serialVersionUID=1L;
 
     /** 状态 */
             @ApiModelProperty(value = "状态")
-    private Integer status;
+    private String status;
 
     /** 角色id */
     private Long roleId;

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/dto/RetrievalTaskPageDto.java

@@ -37,9 +37,9 @@ public class RetrievalTaskPageDto extends BaseEntity
 
 
     /** 周期无周期、每日、每周、每月、每季度、每半年、每年（0-6） */
-    private Integer cycle;
+    private String cycle;
     /** 状态 */
-    private Integer status;
+    private String status;
 
     /** 角色id */
     private Long roleId;

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/vo/CoreMonitoringRetrievalTaskOneVo.java

@@ -7,6 +7,7 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import java.util.Date;
+import java.util.List;
 
 /**
  * 监控调阅任务对象 core_monitoring_retrieval_task
@@ -16,7 +17,7 @@ import java.util.Date;
  */
 @Data
 @ApiModel(value = "CoreMonitoringRetrievalTask对象", description = "监控调阅任务")
-public class CoreMonitoringRetrievalTaskOneVo extends BaseEntity {
+public class CoreMonitoringRetrievalTaskOneVo {
     private static final long serialVersionUID = 1L;
 
     /**
@@ -25,11 +26,6 @@ public class CoreMonitoringRetrievalTaskOneVo extends BaseEntity {
     private Long id;
 
     /**
-     * 计划id
-     */
-    private Long planId;
-
-    /**
      * 任务名称
      */
     @ApiModelProperty(value = "任务名称")
@@ -38,60 +34,10 @@ public class CoreMonitoringRetrievalTaskOneVo extends BaseEntity {
     /**
      * 调阅机构
      */
-    private Long orgId;
-
-    /**
-     * 调阅机构
-     */
-    private String orgPath;
-
-    /**
-     * 调阅机构
-     */
     @ApiModelProperty(value = "调阅机构")
     private String orgName;
 
     /**
-     * 年月日
-     */
-    private Date ymdDate;
-
-    /**
-     * 年
-     */
-    private Long ymdYear;
-
-    /**
-     * 半年
-     */
-    private Long ymdHalfyear;
-
-    /**
-     * 季度
-     */
-    private Long ymdQuarter;
-
-    /**
-     * 月
-     */
-    private Long ymdMonth;
-
-    /**
-     * 周
-     */
-    private Long ymdWeek;
-
-    /**
-     * 日
-     */
-    private Long ymdDay;
-
-    /**
-     * 周期无周期、每日、每周、每月、每季度、每半年、每年（0-6）
-     */
-    private Long cycle;
-
-    /**
      * 开始时间
      */
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
@@ -123,45 +69,16 @@ public class CoreMonitoringRetrievalTaskOneVo extends BaseEntity {
      * 状态
      */
     @ApiModelProperty(value = "状态")
-    private Long status;
+    private String status;
 
-    private String statusText;
-
-    /**
-     * 角色id
-     */
-    private Long roleId;
 
     private String roleName;
 
-    /**
-     * 调阅人
-     */
-    private Long retrievalUser;
 
     private String retrievalUserName;
 
-    /**
-     * 第几次调阅（根据计划的频次计算的来）
-     */
-    private Long orderNum;
-
-    /**
-     * 批次号（同一计划多频次为一个批次号）
-     */
-    private Long batchNum;
-
-    /**
-     * 提交时间
-     */
-    private Date submitTime;
+    List<TaskDataVo> taskDataVoList;
 
-    /**
-     * 异常数
-     */
-    @ApiModelProperty(value = "异常数")
-    private Long exceptionCount;
 
 
-    private Integer no;
 }

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/vo/CoreMonitoringRetrievalTaskVo.java

@@ -64,37 +64,37 @@ public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
     /**
      * 年
      */
-    private Long ymdYear;
+    private Integer ymdYear;
 
     /**
      * 半年
      */
-    private Long ymdHalfyear;
+    private Integer ymdHalfyear;
 
     /**
      * 季度
      */
-    private Long ymdQuarter;
+    private Integer ymdQuarter;
 
     /**
      * 月
      */
-    private Long ymdMonth;
+    private Integer ymdMonth;
 
     /**
      * 周
      */
-    private Long ymdWeek;
+    private Integer ymdWeek;
 
     /**
      * 日
      */
-    private Long ymdDay;
+    private Integer ymdDay;
 
     /**
      * 周期无周期、每日、每周、每月、每季度、每半年、每年（0-6）
      */
-    private Long cycle;
+    private String cycle;
 
     /**
      * 开始时间
@@ -128,7 +128,7 @@ public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
      * 状态
      */
     @ApiModelProperty(value = "状态")
-    private Long status;
+    private String status;
 
     private String statusText;
 

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/vo/TaskDataVo.java

@@ -0,0 +1,31 @@
+package com.xunmei.common.core.domain.retrieval.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xunmei.common.core.web.domain.BaseEntity;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 监控调阅任务对象 core_monitoring_retrieval_task
+ *
+ * @author xunmei
+ * @date 2023-08-25
+ */
+@Data
+@ApiModel(value = "CoreMonitoringRetrievalTask对象", description = "监控调阅任务")
+public class TaskDataVo {
+    private static final long serialVersionUID = 1L;
+
+    private String hostName;
+    private String channelName;
+    private String project;
+    private String remark;
+    private String situation;
+
+
+
+
+}

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/enums/edu/EduTrainingType.java

@@ -15,8 +15,8 @@ import java.util.Map;
 public enum EduTrainingType {
 
 
-    AQFFXXJY(0, "安全防范学习教育"),
-    ZBXZHD(1, "治保小组活动");
+    AQFFXXJY(0, "每月安全培训教育"),
+    ZBXZHD(1, "专项安全培训教育");
 
 
     /**

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/utils/DateUtils.java

@@ -300,13 +300,13 @@ public class DateUtils extends org.apache.commons.lang3.time.DateUtils {
 
     public static void main(String[] args) throws ParseException {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        Date startDate = sdf.parse("2023-01-01 00:00:00");
-        Date endDate = sdf.parse("2023-01-01 00:00:02");
-        Map<Integer, DateRange> dateRanges = splitDateRange(startDate, endDate, 2);
+        /*Date startDate = sdf.parse("2023-09-01 00:00:00");
+       // Date endDate = sdf.parse("2023-01-01 00:00:02");
+        DateRange startAndEnd = getStartAndEnd(startDate, 3);*/
+        Date dateTime = Date.from(LocalDate.now().atStartOfDay(ZoneId.systemDefault()).toInstant());
+        DateRange startAndEnd = DateUtils.getStartAndEnd(dateTime, 3);
 
-        for (Map.Entry<Integer, DateRange> entry : dateRanges.entrySet()) {
-            System.out.println("Key: " + entry.getKey() + ", Start Time: " + sdf.format(entry.getValue().getStartTime()) + ", End Time: " + sdf.format(entry.getValue().getEndTime()));
-        }
+            System.out.println( " Start Time: " + sdf.format(startAndEnd.getStartTime()) + ", End Time: " + sdf.format(startAndEnd.getEndTime()));
     }
 }
 

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/controller/CoreMonitoringTaskMonitorInfoController.java

@@ -1,7 +1,6 @@
 package com.xunmei.core.access.controller;
 
-import com.xunmei.common.core.web.page.TableDataInfo;
-import com.xunmei.core.access.domain.CoreMonitoringTaskMonitorInfo;
+
 import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationMonitorDTO;
 import com.xunmei.core.access.service.ICoreMonitoringTaskMonitorInfoService;
 import com.xunmei.core.access.service.ICoreMonitoringTaskRegistrationMonitorService;
@@ -9,7 +8,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.PutMapping;
-import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -38,17 +36,6 @@ public class CoreMonitoringTaskMonitorInfoController extends BaseController {
     @Autowired
     private ICoreMonitoringTaskRegistrationMonitorService coreMonitoringTaskRegistrationMonitorService;
 
-/*    *//**
-     * 查询调阅任务登记检查情况列表
-     *//*
-    @ApiOperation(value = "查询CoreMonitoringTaskMonitorInfo列表")
-    @RequiresPermissions("system:info:list")
-    @GetMapping("/list")
-    public TableDataInfo<CoreMonitoringTaskMonitorInfo> list(CoreMonitoringTaskMonitorInfo coreMonitoringTaskMonitorInfo) {
-        return null;
-    }*/
-
-
     /**
      * 获取调阅任务登记检查情况详细信息
      */
@@ -82,14 +69,4 @@ public class CoreMonitoringTaskMonitorInfoController extends BaseController {
         return toAjax(coreMonitoringTaskMonitorInfoService.updateCoreMonitoringTaskMonitorInfo(coreMonitoringTaskMonitorInfo));
     }
 
-/*    *//**
-     * 删除调阅任务登记检查情况
-     *//*
-    @ApiOperation(value = "删除CoreMonitoringTaskMonitorInfo")
-    @RequiresPermissions("system:info:remove")
-    @Log(title = "调阅任务登记检查情况", businessType = BusinessType.DELETE)
-    @DeleteMapping("/{ids}")
-    public AjaxResult remove(@PathVariable Long[] ids) {
-        return toAjax(coreMonitoringTaskMonitorInfoService.deleteCoreMonitoringTaskMonitorInfoByIds(ids));
-    }*/
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/controller/CoreMonitoringTaskRegistrationController.java

@@ -1,19 +1,16 @@
 package com.xunmei.core.access.controller;
 
-import java.util.List;
 
-import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.core.access.domain.CoreMonitoringTaskRegistration;
-import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationDTO;
+
 import com.xunmei.core.access.service.ICoreMonitoringTaskRegistrationMonitorService;
 import com.xunmei.core.access.service.ICoreMonitoringTaskRegistrationService;
-import com.xunmei.core.access.service.impl.CoreMonitoringTaskRegistrationServiceImpl;
-import com.xunmei.core.access.vo.CoreMonitoringTaskRegistrationVO;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.PutMapping;
-import org.springframework.web.bind.annotation.DeleteMapping;
+
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -84,15 +81,5 @@ public class CoreMonitoringTaskRegistrationController extends BaseController {
     public AjaxResult edit(@RequestBody CoreMonitoringTaskRegistration coreMonitoringTaskRegistration) {
         return toAjax(iCoreMonitoringTaskRegistrationService.updateCoreMonitoringTaskRegistration(coreMonitoringTaskRegistration));
     }
-    /*
-     *//**
-     * 删除【请填写功能名称】
-     *//*
-    @ApiOperation(value = "删除CoreMonitoringTaskRegistration")
-    @RequiresPermissions("system:registration:remove")
-    @Log(title = "【请填写功能名称】", businessType = BusinessType.DELETE)
-    @DeleteMapping("/{ids}")
-    public AjaxResult remove(@PathVariable Long[] ids) {
-        return toAjax(coreMonitoringTaskRegistrationService.deleteCoreMonitoringTaskRegistrationByIds(ids));
-    }*/
+
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/controller/CoreMonitoringTaskRegistrationMonitorController.java

@@ -2,7 +2,6 @@ package com.xunmei.core.access.controller;
 
 import com.xunmei.common.core.web.controller.BaseController;
 import com.xunmei.common.core.web.domain.AjaxResult;
-import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.core.access.domain.CoreMonitoringTaskRegistrationMonitor;
 import com.xunmei.core.access.service.ICoreMonitoringTaskRegistrationMonitorService;
 import io.swagger.annotations.Api;
@@ -11,7 +10,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.PutMapping;
-import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -33,19 +31,6 @@ import com.xunmei.common.security.annotation.RequiresPermissions;
 public class CoreMonitoringTaskRegistrationMonitorController extends BaseController {
     @Autowired
     private ICoreMonitoringTaskRegistrationMonitorService coreMonitoringTaskRegistrationMonitorService;
-/*
-*//**
- * 查询调阅任务登记监控列表
- *//*
-@ApiOperation(value = "查询CoreMonitoringTaskRegistrationMonitor列表")
-@RequiresPermissions("system:monitor:list")
-@GetMapping("/list")
-    public TableDataInfo<CoreMonitoringTaskRegistrationMonitor> list(CoreMonitoringTaskRegistrationMonitor coreMonitoringTaskRegistrationMonitor) {
-
-      //  return coreMonitoringTaskRegistrationMonitorService.selectPage( coreMonitoringTaskRegistrationMonitor);
-   return  null;
-    }*/
-
 
 
     /**
@@ -79,15 +64,4 @@ public class CoreMonitoringTaskRegistrationMonitorController extends BaseControl
     public AjaxResult edit(@RequestBody CoreMonitoringTaskRegistrationMonitor coreMonitoringTaskRegistrationMonitor) {
         return toAjax(coreMonitoringTaskRegistrationMonitorService.updateCoreMonitoringTaskRegistrationMonitor(coreMonitoringTaskRegistrationMonitor));
     }
-/*
-    *//**
-     * 删除调阅任务登记监控
-     *//*
-    @ApiOperation(value = "删除CoreMonitoringTaskRegistrationMonitor")
-    @RequiresPermissions("system:monitor:remove")
-    @Log(title = "调阅任务登记监控" , businessType = BusinessType.DELETE)
-    @DeleteMapping("/{ids}")
-    public AjaxResult remove(@PathVariable String[] ids) {
-        return toAjax(coreMonitoringTaskRegistrationMonitorService.deleteCoreMonitoringTaskRegistrationMonitorByIds(ids));
-    }*/
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/ICoreMonitoringTaskMonitorInfoService.java

@@ -2,7 +2,6 @@ package com.xunmei.core.access.service;
 
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.core.access.domain.CoreMonitoringTaskMonitorInfo;
 import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationMonitorDTO;
 
@@ -63,11 +62,5 @@ public interface ICoreMonitoringTaskMonitorInfoService extends IService<CoreMoni
      */
     int deleteCoreMonitoringTaskMonitorInfoById(Long id);
 
-    /**
-     * 查询调阅任务登记检查情况分页数据
-     *
-     * @param coreMonitoringTaskMonitorInfo 查询条件对象
-     * @return Page
-     */
-  //  TableDataInfo<CoreMonitoringTaskMonitorInfo> selectPage(CoreMonitoringTaskMonitorInfo coreMonitoringTaskMonitorInfo);
+
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/ICoreMonitoringTaskRegistrationMonitorService.java

@@ -2,7 +2,6 @@ package com.xunmei.core.access.service;
 
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.core.access.domain.CoreMonitoringTaskRegistrationMonitor;
 import com.xunmei.core.access.vo.CoreMonitoringTaskRegistrationMonitorVO;
 import com.xunmei.core.access.vo.CoreMonitoringTaskRegistrationVO;

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/ICoreMonitoringTaskRegistrationService.java

@@ -2,7 +2,6 @@ package com.xunmei.core.access.service;
 
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.core.access.domain.CoreMonitoringTaskRegistration;
 import com.xunmei.core.access.vo.CoreMonitoringTaskRegistrationVO;
 
@@ -63,11 +62,4 @@ public interface ICoreMonitoringTaskRegistrationService extends IService<CoreMon
      */
     int deleteCoreMonitoringTaskRegistrationById(Long id);
 
-    /**
-     * 查询【请填写功能名称】分页数据
-     *
-     * @param coreMonitoringTaskRegistration 查询条件对象
-     * @return Page
-     */
-  //  TableDataInfo<CoreMonitoringTaskRegistration> selectPage(CoreMonitoringTaskRegistration coreMonitoringTaskRegistration);
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/impl/CoreMonitoringTaskMonitorInfoServiceImpl.java

@@ -12,15 +12,13 @@ import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationMonitorDTO;
 import com.xunmei.core.access.mapper.CoreMonitoringTaskMonitorInfoMapper;
 import com.xunmei.core.access.mapper.CoreMonitoringTaskRegistrationMonitorMapper;
 import com.xunmei.core.access.service.ICoreMonitoringTaskMonitorInfoService;
-import com.xunmei.core.access.vo.CoreMonitoringTaskRegistrationMonitorVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.Arrays;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.xunmei.common.core.web.page.TableDataInfo;
+
 
 
 /**
@@ -36,38 +34,6 @@ public class CoreMonitoringTaskMonitorInfoServiceImpl extends ServiceImpl<CoreMo
     @Autowired
     private CoreMonitoringTaskRegistrationMonitorMapper coreMonitoringTaskRegistrationMonitorMapper;
 
-/*    @Override
-    public TableDataInfo<CoreMonitoringTaskMonitorInfo> selectPage(CoreMonitoringTaskMonitorInfo coreMonitoringTaskMonitorInfo) {
-        //未删除
-        coreMonitoringTaskMonitorInfo.setDeleted(0L);
-        Page<CoreMonitoringTaskMonitorInfo> page;
-        //分页
-        if (coreMonitoringTaskMonitorInfo.getPageNum()!=null&&coreMonitoringTaskMonitorInfo.getPageSize()!=null)
-        {
-            page = new Page<>(coreMonitoringTaskMonitorInfo.getPageNum(), coreMonitoringTaskMonitorInfo.getPageSize());
-        }else{
-            page = new Page<>();
-        }
-        //查询条件
-        QueryWrapper<CoreMonitoringTaskMonitorInfo> query = new QueryWrapper<>(coreMonitoringTaskMonitorInfo);
-        //下穿
-        if (coreMonitoringTaskMonitorInfo.getCheckSub()){
-            List<Long> ids = orgService.selectCheckSubOrgIdList(coreMonitoringTaskMonitorInfo.getOrgId());
-            //清空前端传递的org_id
-            coreMonitoringTaskMonitorInfo.setOrgId(null);
-            //添加in条件
-            query.in("org_id",ids);
-        }
-        //时间范围查询
-        if (coreMonitoringTaskMonitorInfo.getParams().get("beginTime")!=null&&coreMonitoringTaskMonitorInfo.getParams().get("endTime")!=null){
-            query.between("create_time", coreMonitoringTaskMonitorInfo.getParams().get("beginTime"), coreMonitoringTaskMonitorInfo.getParams().get("endTime"));
-        }
-        //获取数据
-        page = coreMonitoringTaskMonitorInfoMapper.selectPage(page, query);
-        //抓换为TableDataInfo适配前端
-        return TableDataInfo.build(page);
-    }*/
-
 
     /**
      * 查询调阅任务登记检查情况
@@ -140,7 +106,7 @@ public class CoreMonitoringTaskMonitorInfoServiceImpl extends ServiceImpl<CoreMo
         coreMonitoringTaskRegistrationMonitor.setUpdateTime(DateUtils.getNowDate());
         coreMonitoringTaskRegistrationMonitor.setUpdateBy(SecurityUtils.getUsername());
         coreMonitoringTaskRegistrationMonitorMapper.updateById(coreMonitoringTaskRegistrationMonitor);
-        QueryWrapper queryWrapper=new QueryWrapper();
+        QueryWrapper<CoreMonitoringTaskMonitorInfo> queryWrapper=new QueryWrapper();
         queryWrapper.eq("task_monitor_id",coreMonitoringTaskRegistrationMonitor.getId());
         coreMonitoringTaskMonitorInfoMapper.delete(queryWrapper);
         int i = 0;

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/impl/CoreMonitoringTaskRegistrationMonitorServiceImpl.java

@@ -1,10 +1,7 @@
 package com.xunmei.core.access.service.impl;
 
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-
 
+import java.util.List;
 import com.alibaba.nacos.common.utils.CollectionUtils;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.xunmei.common.core.utils.DateUtils;
@@ -36,39 +33,6 @@ public class CoreMonitoringTaskRegistrationMonitorServiceImpl extends ServiceImp
     @Autowired
     private CoreMonitoringTaskMonitorInfoMapper coreMonitoringTaskMonitorInfoMapper;
 
-/*    @Override
-    public TableDataInfo<CoreMonitoringTaskRegistrationMonitor> selectPage(CoreMonitoringTaskRegistrationMonitor coreMonitoringTaskRegistrationMonitor) {
-        //未删除
-        coreMonitoringTaskRegistrationMonitor.setDeleted(0L);
-        Page<CoreMonitoringTaskRegistrationMonitor> page;
-        //分页
-        if (coreMonitoringTaskRegistrationMonitor.getPageNum()!=null&&coreMonitoringTaskRegistrationMonitor.getPageSize()!=null)
-        {
-            page = new Page<>(coreMonitoringTaskRegistrationMonitor.getPageNum(), coreMonitoringTaskRegistrationMonitor.getPageSize());
-        }else{
-            page = new Page<>();
-        }
-        //查询条件
-        QueryWrapper<CoreMonitoringTaskRegistrationMonitor> query = new QueryWrapper<>(coreMonitoringTaskRegistrationMonitor);
-        //下穿
-        if (coreMonitoringTaskRegistrationMonitor.getCheckSub()){
-            List<Long> ids = orgService.selectCheckSubOrgIdList(coreMonitoringTaskRegistrationMonitor.getOrgId());
-            //清空前端传递的org_id
-            coreMonitoringTaskRegistrationMonitor.setOrgId(null);
-            //添加in条件
-            query.in("org_id",ids);
-        }
-        //时间范围查询
-        if (coreMonitoringTaskRegistrationMonitor.getParams().get("beginTime")!=null&&coreMonitoringTaskRegistrationMonitor.getParams().get("endTime")!=null){
-            query.between("create_time", coreMonitoringTaskRegistrationMonitor.getParams().get("beginTime"), coreMonitoringTaskRegistrationMonitor.getParams().get("endTime"));
-        }
-        //获取数据
-        page = coreMonitoringTaskRegistrationMonitorMapper.selectPage(page, query);
-        //抓换为TableDataInfo适配前端
-        return TableDataInfo.build(page);
-    }*/
-
-
     /**
      * 查询调阅任务登记监控
      *

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/impl/CoreMonitoringTaskRegistrationServiceImpl.java

@@ -16,11 +16,7 @@ import com.xunmei.core.access.vo.CoreMonitoringTaskRegistrationVO;
 import com.xunmei.core.retrieval.mapper.CoreMonitoringRetrievalTaskMapper;
 import com.xunmei.core.retrieval.service.ICoreMonitoringRetrievalTaskService;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.config.ConfigurableBeanFactory;
-import org.springframework.context.annotation.Lazy;
-import org.springframework.context.annotation.Scope;
 import org.springframework.stereotype.Service;
-
 import java.util.Arrays;
 import java.util.List;
 
@@ -30,11 +26,10 @@ import java.util.List;
  * @author xunmei
  * @date 2023-08-28
  */
-@Lazy
 @Service
 public class CoreMonitoringTaskRegistrationServiceImpl extends ServiceImpl<CoreMonitoringTaskRegistrationMapper, CoreMonitoringTaskRegistration> implements ICoreMonitoringTaskRegistrationService {
-    private static final Integer ONE = 1;
-    private static final Integer TWO = 2;
+  private static  final String ONE="1";
+  private static final String TWO="2";
     @Autowired
     private CoreMonitoringTaskRegistrationMapper coreMonitoringTaskRegistrationMapper;
     @Autowired
@@ -84,7 +79,7 @@ public class CoreMonitoringTaskRegistrationServiceImpl extends ServiceImpl<CoreM
         coreMonitoringTaskRegistration.setCreateBy(SecurityUtils.getUsername());
         //修改任务状态为进行中
         CoreMonitoringRetrievalTask coreMonitoringRetrievalTask = coreMonitoringRetrievalTaskMapper.selectCoreMonitoringRetrievalTaskById(coreMonitoringTaskRegistration.getTaskId());
-        coreMonitoringRetrievalTask.setStatus(1);
+        coreMonitoringRetrievalTask.setStatus(ONE);
         coreMonitoringRetrievalTask.setStartTime(DateUtils.getNowDate());
         coreMonitoringRetrievalTaskMapper.updateById(coreMonitoringRetrievalTask);
         coreMonitoringTaskRegistration.setId(IdWorker.getId());
@@ -103,7 +98,7 @@ public class CoreMonitoringTaskRegistrationServiceImpl extends ServiceImpl<CoreM
         coreMonitoringTaskRegistration.setUpdateBy(SecurityUtils.getUsername());
         //修改任务状态已完成
         CoreMonitoringRetrievalTask coreMonitoringRetrievalTask = coreMonitoringRetrievalTaskMapper.selectCoreMonitoringRetrievalTaskById(coreMonitoringTaskRegistration.getTaskId());
-        coreMonitoringRetrievalTask.setStatus(2);
+        coreMonitoringRetrievalTask.setStatus(TWO);
         coreMonitoringRetrievalTask.setEndTime(DateUtils.getNowDate());
         coreMonitoringRetrievalTask.setUpdateBy(SecurityUtils.getUsername());
         coreMonitoringRetrievalTask.setUpdateTime(DateUtils.getNowDate());

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/impl/TMonitoringRetrievalPlanServiceImpl.java

@@ -1,8 +1,7 @@
 package com.xunmei.core.access.service.impl;
 
-
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.xunmei.common.core.constant.SecurityConstants;
@@ -23,13 +22,10 @@ import com.xunmei.system.api.domain.SysUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
-
 import javax.annotation.Resource;
 import java.util.ArrayList;
-import java.util.Collection;
 import java.util.List;
-import java.util.Map;
-import java.util.function.Function;
+
 
 /**
  * 监控调阅计划Service业务层处理
@@ -194,7 +190,7 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring
                 iCoreMonitoringRetrievalTaskService.noCycleTask(tMonitoringRetrievalPlans);
             }
         }
-        tMonitoringRetrievalPlan.setCreateType(0);
+        tMonitoringRetrievalPlan.setId(IdWorker.getId());
         return tMonitoringRetrievalPlanMapper.insert(tMonitoringRetrievalPlan);
     }
 

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/edu/controller/CoreEduTrainingTaskController.java

@@ -35,33 +35,30 @@ public class CoreEduTrainingTaskController extends BaseController {
     @Autowired
     private ICoreEduTrainingTaskService coreEduTrainingTaskService;
 
-    /**
-     * 查询教育任务列表
-     */
-    @ApiOperation(value = "查询CoreEduTrainingTask列表")
+
+    @ApiOperation(value = "查询教育任务分页")
     @RequiresPermissions("core:eduTask:list")
     @GetMapping("/list")
     public TableDataInfo<CoreEduTrainingTaskPageVo> list(CoreEduTrainingTaskPageDto coreEduTrainingTask) {
-
-        //return  new TableDataInfo<CoreEduTrainingTaskPageVo>();
         return coreEduTrainingTaskService.selectPage(coreEduTrainingTask);
     }
 
 
-    /**
-     * 获取教育任务详细信息
-     */
-    @ApiOperation(value = "获取CoreEduTrainingTask详细信息")
+    @ApiOperation(value = "App端获取签名情况")
+    @RequiresPermissions("core:eduTask:list")
+    @GetMapping("/signUserList/{id}")
+    public AjaxResult signUserList(@PathVariable Long id) {
+        return success(coreEduTrainingTaskService.signUserList(id));
+    }
+
+    @ApiOperation(value = "获取教育任务详细信息")
     @RequiresPermissions("core:eduTask:query")
     @GetMapping(value = "/{id}")
     public AjaxResult getInfo(@PathVariable("id") Long id) {
         return success(coreEduTrainingTaskService.selectCoreEduTrainingTaskById(id));
     }
 
-    /**
-     * 新增教育任务
-     */
-    @ApiOperation(value = "新增CoreEduTrainingTask")
+    @ApiOperation(value = "新增教育任务")
     @RequiresPermissions("core:eduTask:add")
     @Log(title = "教育任务", businessType = BusinessType.INSERT)
     @PostMapping
@@ -69,10 +66,7 @@ public class CoreEduTrainingTaskController extends BaseController {
         return toAjax(coreEduTrainingTaskService.insertCoreEduTrainingTask(coreEduTrainingTask));
     }
 
-    /**
-     * 修改教育任务
-     */
-    @ApiOperation(value = "修改CoreEduTrainingTask")
+    @ApiOperation(value = "任务登记")
     @RequiresPermissions("core:eduTask:edit")
     @Log(title = "教育任务", businessType = BusinessType.UPDATE)
     @PutMapping
@@ -80,24 +74,15 @@ public class CoreEduTrainingTaskController extends BaseController {
         return toAjax(coreEduTrainingTaskService.updateCoreEduTrainingTask(coreEduTrainingTask));
     }
 
-    /**
-     * 删除教育任务
-     */
-    @ApiOperation(value = "删除CoreEduTrainingTask")
+    @ApiOperation(value = "ApiOperation")
     @RequiresPermissions("core:eduTask:remove")
     @Log(title = "教育任务", businessType = BusinessType.DELETE)
     @DeleteMapping("/{ids}")
     public AjaxResult remove(@PathVariable Long[] ids) {
-
-
         return toAjax(coreEduTrainingTaskService.deleteCoreEduTrainingTaskByIds(ids));
     }
 
-
-    /**
-     * 导出教育任务
-     */
-    @ApiOperation(value = "导出CoreEduTrainingTask")
+    @ApiOperation(value = "导出教育任务")
     @RequiresPermissions("core:eduTask:report")
     @PostMapping("report")
     public AjaxResult report(@RequestBody @Validated CoreEduTrainingTaskReportDto request) {

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/edu/service/ICoreEduTrainingTaskService.java

@@ -3,6 +3,7 @@ package com.xunmei.core.edu.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.xunmei.common.core.domain.edu.domain.CoreEduTrainingTask;
+import com.xunmei.common.core.domain.edu.domain.CoreEduTrainingTaskToUser;
 import com.xunmei.common.core.domain.edu.dto.CoreEduTrainingTaskEditDto;
 import com.xunmei.common.core.domain.edu.dto.CoreEduTrainingTaskPageDto;
 import com.xunmei.common.core.domain.edu.dto.CoreEduTrainingTaskReportDto;
@@ -90,4 +91,6 @@ public interface ICoreEduTrainingTaskService extends IService<CoreEduTrainingTas
     AjaxResult buildEduPdf(Long id);
 
     String buildEduTask(Integer cycle, Date date);
+
+    List<CoreEduTrainingTaskToUser> signUserList(Long taskId);
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/edu/service/impl/CoreEduTrainingTaskServiceImpl.java

@@ -87,6 +87,22 @@ public class CoreEduTrainingTaskServiceImpl extends ServiceImpl<CoreEduTrainingT
 
     @Override
     public TableDataInfo<CoreEduTrainingTaskPageVo> selectPage(CoreEduTrainingTaskPageDto request) {
+        //如果是web段的查询
+        if (ObjectUtil.isNotEmpty(request.getRange())) {
+            request.setStartTime(DateUtil.beginOfDay(request.getRange()[0]));
+            request.setEndTime(DateUtil.endOfDay(request.getRange()[1]));
+        }
+        //如果是App段的查询
+        if (ObjectUtil.isNotNull(request.getDate())) {
+            // Date date = java.sql.Date.valueOf(request.getDate());
+            request.setStartTime(DateUtil.beginOfMonth(request.getDate()));
+            request.setEndTime(DateUtil.endOfMonth(request.getDate()));
+
+        }
+        if (ObjectUtil.equal(1, request.getIsAppSelect())) {
+            request.setCheckSub(true);
+        }
+        //App 默认下穿
         if (Boolean.TRUE.equals(request.getCheckSub())) {
             SysOrg org = RemoteCallHandlerExecutor.executeRemoteCall(() -> orgService.selectOrgById(request.getOrgId(), SecurityConstants.INNER), ErrorMsgConstants.QUERY_ORG_DATA_ERROR);
             request.setOrgPath(org.getPath());
@@ -106,6 +122,11 @@ public class CoreEduTrainingTaskServiceImpl extends ServiceImpl<CoreEduTrainingT
                     continue;
                 }
                 record.setTaskRoleNameList(coreEduTrainingTaskToRoles.stream().map(CoreEduTrainingTaskToRole::getRoleName).collect(Collectors.joining(",")));
+
+                List<CoreEduTrainingTaskToUser> userList = taskToUserMapper.selectList(new LambdaQueryWrapper<CoreEduTrainingTaskToUser>()
+                        .eq(CoreEduTrainingTaskToUser::getEduTrainingTaskId, record.getId()));
+                int signNums = (int) userList.stream().filter(user -> user.getSign() == 1).count();
+                record.setSignNums(signNums + "/" + userList.size());
             }
         }
 
@@ -113,6 +134,11 @@ public class CoreEduTrainingTaskServiceImpl extends ServiceImpl<CoreEduTrainingT
         return TableDataInfo.build(pageData);
     }
 
+    @Override
+    public List<CoreEduTrainingTaskToUser> signUserList(Long taskId) {
+        return taskToUserMapper.selectList(new LambdaQueryWrapper<CoreEduTrainingTaskToUser>()
+                .eq(CoreEduTrainingTaskToUser::getEduTrainingTaskId, taskId));
+    }
 
     /**
      * 查询教育任务
@@ -162,6 +188,7 @@ public class CoreEduTrainingTaskServiceImpl extends ServiceImpl<CoreEduTrainingT
     @Override
     public int updateCoreEduTrainingTask(CoreEduTrainingTaskEditDto request) {
         CoreEduTrainingTask coreEduTrainingTask = coreEduTrainingTaskMapper.selectById(request.getId());
+        taskToUserMapper.deleteByMap(MapUtil.of("edu_training_task_id", request.getId()));
         BeanUtils.copyProperties(request, coreEduTrainingTask);
         coreEduTrainingTask.setRecorderId(SecurityUtils.getUserId());
         coreEduTrainingTask.setImageList(ObjectUtil.isNotEmpty(request.getImageList()) ? JSON.toJSONString(request.getImageList()) : null);
@@ -179,6 +206,7 @@ public class CoreEduTrainingTaskServiceImpl extends ServiceImpl<CoreEduTrainingT
 
         coreEduTrainingTask.setUpdateBy(SecurityUtils.getLoginUser().getSysUser().getId().toString());
         coreEduTrainingTask.setUpdateTime(DateUtils.getNowDate());
+
         return coreEduTrainingTaskMapper.updateById(coreEduTrainingTask);
     }
 
@@ -443,6 +471,8 @@ public class CoreEduTrainingTaskServiceImpl extends ServiceImpl<CoreEduTrainingT
         }
         return "创建成功";
     }
+
+
 }
 
 

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/controller/ResumptionController.java

@@ -142,6 +142,24 @@ public class ResumptionController {
     AjaxResult toTaskDetails( @RequestBody @Valid final TaskDetailsDto request) throws ParseException {
         TaskDetailsVo  detailvo = new TaskDetailsVo();
         List<Map<String,Object>> tasktotal = resumptionBusiness.toTaskDetails(request);
+
+        //nfc总区域数量统计
+        Integer nfcScanN=0;
+        for (Map<String,Object> m :
+                tasktotal) {
+            List<ResumptionNfcVo> nfc= (List<ResumptionNfcVo>) m.get("nfclist");
+            nfcScanN += nfc.size();
+        }
+        detailvo.setNfcScanN(nfcScanN);
+        detailvo.setNfcScanY(0);
+
+        //区域数量统计
+        Integer areaScanN=0;
+        areaScanN = tasktotal.size();
+        detailvo.setAreaScanN(areaScanN);
+        detailvo.setAreaScanY(0);
+
+
         ResumptionTaskListVo taskObj =resumptionBusiness.getTaskObjByTaskid(request);
         SysConfig systemParame = remoteConfigService.findFirstByCode(SystemParameterConstant.NFC_SCANNING, SecurityConstants.INNER).getData();
 
@@ -149,6 +167,7 @@ public class ResumptionController {
         detailvo.setTaskarealist(tasktotal);
         detailvo.setTaskObj(taskObj);
         detailvo.setNfcScaning("0");
+
         return AjaxResult.success(detailvo);
     }
 

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/mapper/CoreResumptionDataProtectionMapper.java

@@ -4,6 +4,7 @@ import java.util.List;
 
 import com.xunmei.core.resumption.domain.CoreResumptionDataProtection;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.xunmei.core.resumption.vo.ResumptionDataProtectionVo;
 
 /**
  * 【请填写功能名称】Mapper接口
@@ -28,6 +29,7 @@ public interface CoreResumptionDataProtectionMapper extends BaseMapper<CoreResum
      */
     List<CoreResumptionDataProtection> selectCoreResumptionDataProtectionList(CoreResumptionDataProtection coreResumptionDataProtection);
 
+    List<ResumptionDataProtectionVo> selectProtection(Long orgId);
     /**
      * 新增【请填写功能名称】
      *

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/service/ICoreResumptionDataProtectionService.java

@@ -6,6 +6,7 @@ import com.xunmei.core.resumption.domain.CoreResumptionDataProtection;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.xunmei.common.core.web.page.TableDataInfo;
+import com.xunmei.core.resumption.vo.ResumptionDataProtectionVo;
 
 /**
  * 【请填写功能名称】Service接口
@@ -22,6 +23,7 @@ public interface ICoreResumptionDataProtectionService extends IService<CoreResum
      */
      CoreResumptionDataProtection selectCoreResumptionDataProtectionById(Long id);
 
+    List<ResumptionDataProtectionVo> selectProtection(Long orgId);
     /**
      * 查询【请填写功能名称】列表
      *

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/service/ResumptionBusiness.java

@@ -47,6 +47,8 @@ public class ResumptionBusiness {
     private AppResumptionDataService appResumptionDataService;
     @Autowired
     private IProtectionService protectionService;
+    @Autowired
+    private ICoreResumptionDataProtectionService coreResumptionDataProtectionService;
 
     public Map<String, Object> tasktotal(ResumptionTaskDto request) throws ParseException {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
@@ -479,6 +481,7 @@ public class ResumptionBusiness {
         });
         //获取nfc
         List<ResumptionNfcVo> nfclists = appResumptionDataNfcService.findNfcByAreaIdAndOrgId(nfcBindIdList, resumption.getOrgId(), resumption.getPlanId());
+
         //对nfc进行去重
         List<ResumptionNfcVo> nfclist = nfclists.stream().collect(Collectors.collectingAndThen
                 (Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(ResumptionNfcVo -> ResumptionNfcVo.getNfccdoe()))), ArrayList::new));
@@ -537,6 +540,7 @@ public class ResumptionBusiness {
             Map<String, Object> area = new HashMap<>();
             area.put("areaid", key.toString());
             area.put("areaname", pointsList.get(0).getAreaname());
+
             List<ResumptionNfcVo> areanfclist = nfclist.stream().filter(r -> r.getAreaId().equals(key)).collect(Collectors.toList());
             if ("0".equals(0)) {
                 if (areanfclist == null || areanfclist.size() == 0) {
@@ -557,7 +561,8 @@ public class ResumptionBusiness {
                     for (ResumptionPointVo r :
                             checkitemlist) {
                         if (r.getBusinessType() == 1) {
-                            r.setProtectionVo(protectionService.findNotAllHour(resumption.getOrgId()));
+                            List<ResumptionDataProtectionVo> list = coreResumptionDataProtectionService.selectProtection(resumption.getOrgId());
+                            r.setProtectionVo(list);
                         }
                     }
                 }
@@ -565,6 +570,7 @@ public class ResumptionBusiness {
                 item.put("itemid", keya);
                 item.put("itemname", checkitemlist.get(0).getItemname());
                 item.put("checkitemlist", checkitemlist);
+
                 checklist.add(item);
             }
             area.put("checklist", checklist);

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/service/impl/AppPlanServiceImpl.java

@@ -227,6 +227,9 @@ public class AppPlanServiceImpl extends ServiceImpl<AppPlanMapper, AppPlan> impl
 //
 //            }
         } else {
+            if(app.getRoleList()==null){
+                app.setRoleList(new ArrayList<>());
+            }
             //修改
             QueryWrapper<AppPlan> qw = new QueryWrapper<>();
             qw.lambda().eq(AppPlan::getPlanName, app.getPlanName())
@@ -242,9 +245,12 @@ public class AppPlanServiceImpl extends ServiceImpl<AppPlanMapper, AppPlan> impl
             baseMapper.updateById(plan);
 
             Long id = plan.getId();
-            QueryWrapper<AppPlanToRole> apr = new QueryWrapper<>();
-            apr.lambda().eq(AppPlanToRole::getPlanId, id);
-            appPlanToRoleMapper.delete(apr);
+            if(app.getRoleList().size()>0){
+                QueryWrapper<AppPlanToRole> apr = new QueryWrapper<>();
+                apr.lambda().eq(AppPlanToRole::getPlanId, id);
+                appPlanToRoleMapper.delete(apr);
+            }
+
 
             QueryWrapper<AppPlanToPoint> api = new QueryWrapper<>();
             api.lambda().eq(AppPlanToPoint::getPlanId, id);
@@ -260,6 +266,8 @@ public class AppPlanServiceImpl extends ServiceImpl<AppPlanMapper, AppPlan> impl
             appPlanToExecOrgMapper.delete(ape);
 
             List<Long> roleList = app.getRoleList();
+
+
             AppPlanToRole atr = null;
             for (Long roleId : roleList) {
                 atr = new AppPlanToRole();

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/service/impl/CoreResumptionDataProtectionServiceImpl.java

@@ -5,6 +5,7 @@ import java.util.List;
 import com.xunmei.core.resumption.domain.CoreResumptionDataProtection;
 import com.xunmei.core.resumption.mapper.CoreResumptionDataProtectionMapper;
 import com.xunmei.core.resumption.service.ICoreResumptionDataProtectionService;
+import com.xunmei.core.resumption.vo.ResumptionDataProtectionVo;
 import com.xunmei.system.api.RemoteOrgService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -74,6 +75,11 @@ public class CoreResumptionDataProtectionServiceImpl extends ServiceImpl<CoreRes
         return coreResumptionDataProtectionMapper.selectById(id);
     }
 
+    @Override
+    public List<ResumptionDataProtectionVo> selectProtection(Long orgId) {
+        return baseMapper.selectProtection(orgId);
+    }
+
     /**
      * 查询【请填写功能名称】列表
      *

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/vo/ResumptionDataProtectionVo.java

@@ -0,0 +1,11 @@
+package com.xunmei.core.resumption.vo;
+
+import com.xunmei.core.resumption.domain.Protection;
+import lombok.Data;
+
+import java.util.Date;
+@Data
+public class ResumptionDataProtectionVo extends Protection {
+    private String protectionStatus;
+    private Date protectionTime;
+}

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/vo/ResumptionNfcVo.java

@@ -26,5 +26,9 @@ public class ResumptionNfcVo {
     private Long areaId;
     @JsonSerialize(using = ToStringSerializer.class)
     private Long nfcid;
+    private Long nfcScanStatus;
+    private Long scanMethod;
+    private String img;
+
 }
 

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/vo/ResumptionPointVo.java

@@ -8,6 +8,7 @@ import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import java.util.Date;
 import java.util.List;
 
 @Data
@@ -30,7 +31,7 @@ public class ResumptionPointVo {
     private int pointnum;
     private int pointScan;
 
-    private List<Protection> protectionVo;
+    private List<ResumptionDataProtectionVo> protectionVo;
 
     private  int required;
     private Long planId;
@@ -38,8 +39,11 @@ public class ResumptionPointVo {
     private Long pointdataid;
     private String resTime;
     private Integer businessType;
+    private Integer submitBy;
     private String resremark;
+    private Date submitTime;
     private List<ResumptionNfcVo> pointnfclist;
+    private String rectificationDeadline;
 
 }
 

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/vo/TaskDetailsVo.java

@@ -18,7 +18,11 @@ import java.util.Map;
 @Builder
 public class TaskDetailsVo {
     @ApiModelProperty("任务统计及列表")
-    private List<Map<String,Object>> taskarealist;
+    private List<Map<String, Object>> taskarealist;
     private ResumptionTaskListVo taskObj;
     private String nfcScaning;
+    private Integer nfcScanY;
+    private Integer nfcScanN;
+    private Integer areaScanY;
+    private Integer areaScanN;
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/controller/CoreMonitoringRetrievalTaskController.java

@@ -5,6 +5,7 @@ import com.xunmei.common.core.web.domain.AjaxResult;
 import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.common.log.annotation.Log;
 import com.xunmei.common.log.enums.BusinessType;
+import com.xunmei.common.security.annotation.InnerAuth;
 import com.xunmei.common.security.annotation.RequiresPermissions;
 import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationDTO;
 import com.xunmei.common.core.domain.retrieval.domain.CoreMonitoringRetrievalTask;
@@ -72,7 +73,7 @@ public class CoreMonitoringRetrievalTaskController extends BaseController {
     @RequiresPermissions("core:task:query")
     @GetMapping(value = "/{id}")
     public AjaxResult getInfo(@PathVariable("id") Long id) {
-        return success(coreMonitoringRetrievalTaskService.selectCoreMonitoringRetrievalTaskById(id));
+        return success(coreMonitoringRetrievalTaskService.selectCoreMonitoringRetrievalTaskOneVoById(id));
     }
 
     /**
@@ -113,12 +114,14 @@ public class CoreMonitoringRetrievalTaskController extends BaseController {
      * 如果当天是周一还需生成周任务
      * @return
      */
+    @InnerAuth
     @GetMapping("/dayTask")
-    public AjaxResult dayTask(@RequestParam("taskTime") LocalDate taskTime) {
+    public AjaxResult dayTask(@RequestParam(value = "taskTime",required = false) LocalDate taskTime) {
         try {
             coreMonitoringRetrievalTaskService.dayTask(taskTime);
             return AjaxResult.success("任务生成成功");
         } catch (Exception e) {
+            e.printStackTrace();
             return AjaxResult.error("任务生成失败" + e.getMessage());
         }
 
@@ -131,8 +134,9 @@ public class CoreMonitoringRetrievalTaskController extends BaseController {
      * 其他日期生成月任务
      * @return
      */
+    @InnerAuth
     @GetMapping("/monthTask")
-    public AjaxResult monthTask(@RequestParam("taskTime")  LocalDate taskTime) {
+    public AjaxResult monthTask(@RequestParam(value = "taskTime",required = false)  LocalDate taskTime) {
         try {
             coreMonitoringRetrievalTaskService.monthTask(taskTime);
             return AjaxResult.success("任务生成成功");

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/mapper/CoreMonitoringRetrievalTaskMapper.java

@@ -6,7 +6,9 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.xunmei.common.core.domain.retrieval.domain.CoreMonitoringRetrievalTask;
 import com.xunmei.common.core.domain.retrieval.dto.RetrievalTaskPageDto;
+import com.xunmei.common.core.domain.retrieval.vo.CoreMonitoringRetrievalTaskOneVo;
 import com.xunmei.common.core.domain.retrieval.vo.CoreMonitoringRetrievalTaskVo;
+import com.xunmei.common.core.domain.retrieval.vo.TaskDataVo;
 import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationDTO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -70,4 +72,8 @@ public interface CoreMonitoringRetrievalTaskMapper extends BaseMapper<CoreMonito
     Page<CoreMonitoringRetrievalTaskVo> selectPageList(Page<CoreMonitoringRetrievalTaskVo> page, @Param("request") RetrievalTaskPageDto request);
 
     List<CoreMonitoringRetrievalTask> selectListApp(CoreMonitoringTaskRegistrationDTO coreMonitoringTaskRegistrationDTO);
+
+    List<TaskDataVo> selectTaskDataVoListByRetrievalTaskId(@Param("taskId") Long id);
+
+    CoreMonitoringRetrievalTaskOneVo selectOneById(@Param("taskId") Long id);
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/service/ICoreMonitoringRetrievalTaskService.java

@@ -6,6 +6,7 @@ import java.util.Date;
 import java.util.List;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.xunmei.common.core.domain.retrieval.vo.CoreMonitoringRetrievalTaskOneVo;
 import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.core.access.domain.TMonitoringRetrievalPlan;
 import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationDTO;
@@ -84,4 +85,6 @@ public interface ICoreMonitoringRetrievalTaskService extends IService<CoreMonito
     void noCycleTask(List<TMonitoringRetrievalPlan> planList);
     void dayTask(LocalDate taskTime);
     void monthTask(LocalDate taskTime);
+
+    CoreMonitoringRetrievalTaskOneVo selectCoreMonitoringRetrievalTaskOneVoById(Long id);
 }

soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/service/impl/CoreMonitoringRetrievalTaskServiceImpl.java

@@ -12,12 +12,11 @@ import com.xunmei.common.core.constant.SecurityConstants;
 import com.xunmei.common.core.domain.DateRange;
 import com.xunmei.common.core.domain.retrieval.domain.CoreMonitoringRetrievalTask;
 import com.xunmei.common.core.domain.retrieval.dto.RetrievalTaskPageDto;
+import com.xunmei.common.core.domain.retrieval.vo.CoreMonitoringRetrievalTaskOneVo;
 import com.xunmei.common.core.domain.retrieval.vo.CoreMonitoringRetrievalTaskVo;
+import com.xunmei.common.core.domain.retrieval.vo.TaskDataVo;
 import com.xunmei.common.core.enums.RetrievalTaskCycle;
-import com.xunmei.common.core.utils.DateHelper;
-import com.xunmei.common.core.utils.DateUtils;
-import com.xunmei.common.core.utils.IDHelper;
-import com.xunmei.common.core.utils.Ymd;
+import com.xunmei.common.core.utils.*;
 import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.core.access.domain.TMonitoringRetrievalPlan;
 import com.xunmei.core.access.dto.CoreMonitoringTaskRegistrationDTO;
@@ -96,7 +95,7 @@ public class CoreMonitoringRetrievalTaskServiceImpl extends ServiceImpl<CoreMoni
         request.setPageSize(null);
         request.setPageNum(null);
         SysOrg sysOrg = RemoteCallHandlerExecutor.executeRemoteCall(() -> orgService.selectTopOrg(SecurityConstants.INNER), ErrorMsgConstants.QUERY_ORG_DATA_ERROR);
-        List<SysDictData> listDict = RemoteCallHandlerExecutor.executeRemoteCall(() -> dictDataService.dictType("retrieval_task_status", SecurityConstants.INNER), ErrorMsgConstants.QUERY_DICT_DATA_ERROR);
+        List<SysDictData> listDict = RemoteCallHandlerExecutor.executeRemoteCall(() -> dictDataService.selectDictByeType("retrieval_task_status", SecurityConstants.INNER), ErrorMsgConstants.QUERY_DICT_DATA_ERROR);
         final TableDataInfo tableDataInfo = this.selectPage(request);
         if (ObjectUtil.isEmpty(tableDataInfo.getRows())) {
             throw new RuntimeException("导出数据为空!");
@@ -326,6 +325,16 @@ public class CoreMonitoringRetrievalTaskServiceImpl extends ServiceImpl<CoreMoni
 
     }
 
+    @Override
+    public CoreMonitoringRetrievalTaskOneVo selectCoreMonitoringRetrievalTaskOneVoById(Long id) {
+        CoreMonitoringRetrievalTaskOneVo retrievalTaskOneVo = coreMonitoringRetrievalTaskMapper.selectOneById(id);
+       /* CoreMonitoringRetrievalTask retrievalTask = this.getById(id);
+        BeanHelper.copyProperties(retrievalTaskOneVo, retrievalTask);*/
+        List<TaskDataVo>  taskDataVoList = coreMonitoringRetrievalTaskMapper.selectTaskDataVoListByRetrievalTaskId(id);
+        retrievalTaskOneVo.setTaskDataVoList(taskDataVoList);
+        return retrievalTaskOneVo;
+    }
+
     /**
      * @param cycle    周期
      * @param taskTime 日期
@@ -388,8 +397,7 @@ public class CoreMonitoringRetrievalTaskServiceImpl extends ServiceImpl<CoreMoni
         DateRange dateRange = null;
         if (Integer.parseInt(plan.getPlanCycle()) == RetrievalTaskCycle.NOCYCLE.getCode()) {
             //无周期任务获取计划时间//重计划中获取
-            dateRange.setStartTime(plan.getStartTime());
-            dateRange.setEndTime(plan.getEndTime());
+            dateRange = new  DateRange(plan.getStartTime(), plan.getEndTime());
         } else {
             //周期任务获取计划时间
             dateRange = DateUtils.getStartAndEnd(dateTime, Integer.parseInt(plan.getPlanCycle()));
@@ -397,14 +405,15 @@ public class CoreMonitoringRetrievalTaskServiceImpl extends ServiceImpl<CoreMoni
         CoreMonitoringRetrievalTask task = new CoreMonitoringRetrievalTask();
         task.setId(IDHelper.id());
         task.setTaskName(plan.getPlanName() + "第" + frequency + "次调阅");
-        task.setCycle(Integer.parseInt(plan.getPlanCycle()));
+        task.setCycle(plan.getPlanCycle());
         task.setOrgId(sysOrg.getId());
         task.setOrgPath(sysOrg.getPath());
         task.setOrgName(sysOrg.getName());
         task.setBatchNum(batchNum);
         task.setPlanId(plan.getId());
         task.setOrderNum(frequency);
-        task.setPlanEndTime(dateRange.getStartTime());
+        System.out.println(dateRange.getStartTime() + "---" + dateRange.getEndTime());
+        task.setPlanStartTime(dateRange.getStartTime());
         task.setPlanEndTime(dateRange.getEndTime());
         task.setYmdDate(ymd.getDate());
         task.setYmdYear(ymd.getYear());
@@ -414,7 +423,7 @@ public class CoreMonitoringRetrievalTaskServiceImpl extends ServiceImpl<CoreMoni
         task.setYmdWeek(ymd.getWeek());
         task.setYmdDay(ymd.getDay());
         task.setRoleId(plan.getRoleId());
-        task.setStatus(0);
+        task.setStatus("0");
         return task;
     }
 

soc-modules/soc-modules-core/src/main/resources/mapper/edu/CoreEduTrainingTaskMapper.xml

@@ -83,7 +83,7 @@
         <!--            </if>-->
         <!--        </where>-->
         select t.id, plan_id, t.org_id, t.org_name, title, type, status, host_id,u.name as hostName,
-        start_date, end_date, training_start_date_time,training_end_date_time
+        start_date, end_date, t.training_start_date_time,t.training_end_date_time
         from core_edu_training_task t left join sys_user u on t.host_id=u.id
         <where>
             <choose>
@@ -104,10 +104,10 @@
                 and t.status=#{request.status}
             </if>
             <if test="request.startTime != null">
-                and t.date_time >=#{request.startTime}
+                and t.start_date >=#{request.startTime}
             </if>
             <if test="request.endTime != null">
-                and t.date_time <![CDATA[<=]]> #{request.endTime}
+                and t.end_date <![CDATA[<=]]> #{request.endTime}
             </if>
         </where>
     </select>

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

@@ -131,18 +131,18 @@
 
 
     <select id="selectByPlanId" resultType="com.xunmei.core.resumption.vo.appPlan.RuleItemVo">
-        SELECT a.item_id,
-               b.name as item_name,
-               b.desc as item_desc,
---                b.item_num,
+        SELECT
+            h.point_id as id,
+            a.item_id,
+            b.NAME AS item_name,
+            b.DESC AS item_desc,--                b.item_num,
 --                a.safe_type,
-               c.`name`           area_name,
-               a.name as point_name,
---                a.point_num,
-               h.point_scan,
-               h.required,
-               d.name  as ruleName,
-               a.business_type as businessType
+            c.`name` area_name,
+            a.NAME AS point_name,--                a.point_num,
+            h.point_scan,
+            h.required,
+            d.NAME AS ruleName,
+            a.business_type AS businessType
         FROM (SELECT point_id, point_scan, required FROM core_resumption_plan_to_point WHERE plan_id = #{planId}) h
                  LEFT JOIN core_resumption_rule_point a ON h.point_id = a.id
                  LEFT JOIN core_resumption_rule_item b ON a.item_id = b.id

soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppResumptionDataNfcMapper.xml

@@ -52,13 +52,17 @@
         a.CODE AS nfccdoe,
         d.id AS pointId,
         a.area_id AS areaId,
-        a.id AS nfcid
+        a.id AS nfcid,
+        dnf.STATUS as nfc_scan_status,
+        dnf.scan_method,
+        dnf.img
         FROM
         sys_nfc_bind a
         LEFT JOIN sys_area_check c ON a.check_id = c.id
         LEFT JOIN core_resumption_rule_point d ON a.area_id = d.area_id
         LEFT JOIN core_resumption_plan_to_point e ON e.point_id = d.id
-        WHERE
+        LEFT JOIN core_resumption_data_nfc dnf ON dnf.nfc_id = a.id
+        where
         a.org_id = #{orgId}
 
         AND e.plan_id = #{planId}

soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppRulePointMapper.xml

@@ -198,23 +198,28 @@
     <select id="findPointByRulePlan" resultType="com.xunmei.core.resumption.vo.ResumptionPointVo">
         SELECT
             a.id AS pointid,
-            a.name AS pointname,
---             a.point_num AS pointnum,
+            a.NAME AS pointname,--             a.point_num AS pointnum,
             a.item_id AS itemid,
             a.area_id AS areaid,
-            f.name AS areaname,
---             a.time_type AS timeType,
+            f.NAME AS areaname,--             a.time_type AS timeType,
             b.plan_id AS planId,
-            e.name AS itemname,
+            e.NAME AS itemname,
             b.point_scan AS pointScan,
             b.required,
-            a.business_type AS businessType
+            a.business_type AS businessType,
+            rd.res_value,
+            rd.res_time,
+            rd.submit_time,
+            rd.res_status,
+            rd.res_remark,
+            rd.submit_by
         FROM
             core_resumption_rule_point a
                 LEFT JOIN core_resumption_plan_to_point b ON a.id = b.point_id
                 LEFT JOIN core_resumption_plan c ON b.plan_id = c.id
                 LEFT JOIN core_resumption_rule_item e ON a.item_id = e.id
                 LEFT JOIN sys_area f ON a.area_id = f.id
+                LEFT JOIN core_resumption_data rd ON rd.item_id = a.item_id
         WHERE
             c.id = #{planId} and a.deleted=0
     </select>

soc-modules/soc-modules-core/src/main/resources/mapper/resumption/CoreResumptionDataProtectionMapper.xml

@@ -4,13 +4,14 @@
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.xunmei.core.resumption.mapper.CoreResumptionDataProtectionMapper">
 
-    <resultMap type="com.xunmei.core.resumption.domain.CoreResumptionDataProtection" id="CoreResumptionDataProtectionResult">
-                <result property="id" column="id"/>
-                <result property="resumptionDataId" column="resumption_data_id"/>
-                <result property="resumptionId" column="resumption_id"/>
-                <result property="protectionId" column="protection_id"/>
-                <result property="protectionStatus" column="protection_status"/>
-                <result property="protectionTime" column="protection_time"/>
+    <resultMap type="com.xunmei.core.resumption.domain.CoreResumptionDataProtection"
+               id="CoreResumptionDataProtectionResult">
+        <result property="id" column="id"/>
+        <result property="resumptionDataId" column="resumption_data_id"/>
+        <result property="resumptionId" column="resumption_id"/>
+        <result property="protectionId" column="protection_id"/>
+        <result property="protectionStatus" column="protection_status"/>
+        <result property="protectionTime" column="protection_time"/>
     </resultMap>
 
     <sql id="selectCoreResumptionDataProtectionVo">
@@ -18,91 +19,105 @@
         from core_resumption_data_protection
     </sql>
 
-    <select id="selectCoreResumptionDataProtectionList" parameterType="com.xunmei.core.resumption.domain.CoreResumptionDataProtection"
+    <select id="selectCoreResumptionDataProtectionList"
+            parameterType="com.xunmei.core.resumption.domain.CoreResumptionDataProtection"
             resultMap="CoreResumptionDataProtectionResult">
         <include refid="selectCoreResumptionDataProtectionVo"/>
         <where>
-                        <if test="resumptionDataId != null ">
-                            and resumption_data_id = #{resumptionDataId}
-                        </if>
-                        <if test="resumptionId != null ">
-                            and resumption_id = #{resumptionId}
-                        </if>
-                        <if test="protectionId != null ">
-                            and protection_id = #{protectionId}
-                        </if>
-                        <if test="protectionStatus != null  and protectionStatus != ''">
-                            and protection_status = #{protectionStatus}
-                        </if>
-                        <if test="protectionTime != null ">
-                            and protection_time = #{protectionTime}
-                        </if>
+            <if test="resumptionDataId != null ">
+                and resumption_data_id = #{resumptionDataId}
+            </if>
+            <if test="resumptionId != null ">
+                and resumption_id = #{resumptionId}
+            </if>
+            <if test="protectionId != null ">
+                and protection_id = #{protectionId}
+            </if>
+            <if test="protectionStatus != null  and protectionStatus != ''">
+                and protection_status = #{protectionStatus}
+            </if>
+            <if test="protectionTime != null ">
+                and protection_time = #{protectionTime}
+            </if>
         </where>
     </select>
 
     <select id="selectCoreResumptionDataProtectionById" parameterType="Long"
             resultMap="CoreResumptionDataProtectionResult">
-            <include refid="selectCoreResumptionDataProtectionVo"/>
-            where id = #{id}
+        <include refid="selectCoreResumptionDataProtectionVo"/>
+        where id = #{id}
+    </select>
+    <select id="selectProtection" resultType="com.xunmei.core.resumption.vo.ResumptionDataProtectionVo">
+        SELECT cp.*,
+               dp.protection_status,
+               dp.protection_time
+        FROM core_protection cp
+                 LEFT JOIN core_resumption_data_protection dp ON cp.id = dp.protection_id
+        where cp.org_id = #{orgId}
+          and deleted = 0
+          and all_Hour = 0
     </select>
 
-    <insert id="insertCoreResumptionDataProtection" parameterType="com.xunmei.core.resumption.domain.CoreResumptionDataProtection">
+    <insert id="insertCoreResumptionDataProtection"
+            parameterType="com.xunmei.core.resumption.domain.CoreResumptionDataProtection">
         insert into core_resumption_data_protection
         <trim prefix="(" suffix=")" suffixOverrides=",">
-                    <if test="id != null">id,
-                    </if>
-                    <if test="resumptionDataId != null">resumption_data_id,
-                    </if>
-                    <if test="resumptionId != null">resumption_id,
-                    </if>
-                    <if test="protectionId != null">protection_id,
-                    </if>
-                    <if test="protectionStatus != null">protection_status,
-                    </if>
-                    <if test="protectionTime != null">protection_time,
-                    </if>
+            <if test="id != null">id,
+            </if>
+            <if test="resumptionDataId != null">resumption_data_id,
+            </if>
+            <if test="resumptionId != null">resumption_id,
+            </if>
+            <if test="protectionId != null">protection_id,
+            </if>
+            <if test="protectionStatus != null">protection_status,
+            </if>
+            <if test="protectionTime != null">protection_time,
+            </if>
         </trim>
         <trim prefix="values (" suffix=")" suffixOverrides=",">
-                    <if test="id != null">#{id},
-                    </if>
-                    <if test="resumptionDataId != null">#{resumptionDataId},
-                    </if>
-                    <if test="resumptionId != null">#{resumptionId},
-                    </if>
-                    <if test="protectionId != null">#{protectionId},
-                    </if>
-                    <if test="protectionStatus != null">#{protectionStatus},
-                    </if>
-                    <if test="protectionTime != null">#{protectionTime},
-                    </if>
+            <if test="id != null">#{id},
+            </if>
+            <if test="resumptionDataId != null">#{resumptionDataId},
+            </if>
+            <if test="resumptionId != null">#{resumptionId},
+            </if>
+            <if test="protectionId != null">#{protectionId},
+            </if>
+            <if test="protectionStatus != null">#{protectionStatus},
+            </if>
+            <if test="protectionTime != null">#{protectionTime},
+            </if>
         </trim>
     </insert>
 
-    <update id="updateCoreResumptionDataProtection" parameterType="com.xunmei.core.resumption.domain.CoreResumptionDataProtection">
+    <update id="updateCoreResumptionDataProtection"
+            parameterType="com.xunmei.core.resumption.domain.CoreResumptionDataProtection">
         update core_resumption_data_protection
         <trim prefix="SET" suffixOverrides=",">
-                    <if test="resumptionDataId != null">resumption_data_id =
-                        #{resumptionDataId},
-                    </if>
-                    <if test="resumptionId != null">resumption_id =
-                        #{resumptionId},
-                    </if>
-                    <if test="protectionId != null">protection_id =
-                        #{protectionId},
-                    </if>
-                    <if test="protectionStatus != null">protection_status =
-                        #{protectionStatus},
-                    </if>
-                    <if test="protectionTime != null">protection_time =
-                        #{protectionTime},
-                    </if>
+            <if test="resumptionDataId != null">resumption_data_id =
+                #{resumptionDataId},
+            </if>
+            <if test="resumptionId != null">resumption_id =
+                #{resumptionId},
+            </if>
+            <if test="protectionId != null">protection_id =
+                #{protectionId},
+            </if>
+            <if test="protectionStatus != null">protection_status =
+                #{protectionStatus},
+            </if>
+            <if test="protectionTime != null">protection_time =
+                #{protectionTime},
+            </if>
         </trim>
         where id = #{id}
     </update>
 
     <delete id="deleteCoreResumptionDataProtectionById" parameterType="Long">
         delete
-        from core_resumption_data_protection where id = #{id}
+        from core_resumption_data_protection
+        where id = #{id}
     </delete>
 
     <delete id="deleteCoreResumptionDataProtectionByIds" parameterType="String">

soc-modules/soc-modules-core/src/main/resources/mapper/retrieval/CoreMonitoringRetrievalTaskMapper.xml

@@ -108,6 +108,20 @@
          and ymdDate like concat('%', #{ymd_date}, '%')
      </if>
     </select>
+    <select id="selectTaskDataVoListByRetrievalTaskId"
+            resultType="com.xunmei.common.core.domain.retrieval.vo.TaskDataVo">
+        select  e.device_name as hostName,d.device_name as channelName,c.project,c.abnormal_illustrate as remark,c.situation
+        from core_monitoring_task_registration a left join core_monitoring_task_registration_monitor b on a.id=b.task_registration_id
+        inner join core_monitoring_task_monitor_info c on b.id=c.task_monitor_id
+        inner join sys_device d on d.id = b.video_channel
+        inner join sys_device e on e.id = b.`host`
+        where a.task_id=#{taskId}
+    </select>
+    <select id="selectOneById"
+            resultType="com.xunmei.common.core.domain.retrieval.vo.CoreMonitoringRetrievalTaskOneVo">
+        select  a.*,b.role_name as roleName,c.name as retrievalUserName from core_monitoring_retrieval_task a left join sys_role b on a.role_id = b.id left join sys_user c on a.retrieval_user = c.id
+        where a.id=#{taskId}
+    </select>
 
     <insert id="insertCoreMonitoringRetrievalTask" parameterType="com.xunmei.common.core.domain.retrieval.domain.CoreMonitoringRetrievalTask">
         insert into core_monitoring_retrieval_task

soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/RetrievalTask.java

@@ -24,7 +24,7 @@ public class RetrievalTask {
     /**
      * 每天生成日任务 如果当天是周一还需生成周任务
      */
-    public void retrieveDayTask(LocalDate taskTime)
+    public void retrieveDayTaskByDate(LocalDate taskTime)
     {   System.out.println("监控调阅每日每周任务生产服务有参"+taskTime);
         AjaxResult result = remoteRetrievalTaskService.dayTask(taskTime, SecurityConstants.INNER);
         System.out.println(JSON.toJSONString(result));
@@ -36,7 +36,7 @@ public class RetrievalTask {
      * 其他日期生成月任务
      *
      */
-    public void retrieveMonthTask(LocalDate taskTime)
+    public void retrieveMonthTaskByDate(LocalDate taskTime)
     {   System.out.println("监控调阅每月任务生产服务有参"+taskTime);
         AjaxResult result = remoteRetrievalTaskService.monthTask(taskTime,SecurityConstants.INNER);
         System.out.println(JSON.toJSONString(result));

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/controller/SysAreaCheckController.java

@@ -1,11 +1,7 @@
 package com.xunmei.system.controller;
 
 import java.util.List;
-import java.io.IOException;
-import javax.servlet.http.HttpServletResponse;
-
 import com.xunmei.system.api.domain.SysArea;
-import com.xunmei.system.domain.SysNfcBind;
 import com.xunmei.system.service.ISysAreaService;
 import com.xunmei.system.service.ISysNfcBindService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -26,7 +22,6 @@ import com.xunmei.common.core.web.controller.BaseController;
 import com.xunmei.common.core.web.domain.AjaxResult;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.xunmei.common.core.web.page.TableDataInfo;
 
 /**

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/controller/SysDictDataController.java

@@ -70,6 +70,17 @@ public class SysDictDataController extends BaseController
         }
         return success(data);
     }
+    @ApiOperation(value = "根据字典类型查询字典数据信息")
+    @GetMapping(value = "/bytype/{dictType}")
+    public List<SysDictData> dictByType(@PathVariable String dictType)
+    {
+        List<SysDictData> data = dictTypeService.selectDictDataByType(dictType);
+        if (StringUtils.isNull(data))
+        {
+            data = new ArrayList<SysDictData>();
+        }
+        return data;
+    }
 
     /**
      * 新增字典类型

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/controller/SysNfcBindController.java

@@ -1,14 +1,10 @@
 package com.xunmei.system.controller;
 
 import java.util.List;
-import java.io.IOException;
-import javax.servlet.http.HttpServletResponse;
-
 import com.xunmei.system.api.domain.SysArea;
 import com.xunmei.system.domain.SysAreaCheck;
 import com.xunmei.system.service.ISysAreaCheckService;
 import com.xunmei.system.service.ISysAreaService;
-import com.xunmei.system.service.ISysOrgService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -27,7 +23,6 @@ import com.xunmei.common.core.web.controller.BaseController;
 import com.xunmei.common.core.web.domain.AjaxResult;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.xunmei.common.core.web.page.TableDataInfo;
 
 /**

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/controller/SysRoleController.java

@@ -1,7 +1,6 @@
 package com.xunmei.system.controller;
 
 import com.xunmei.common.core.domain.IdName;
-import com.xunmei.common.core.domain.R;
 import com.xunmei.common.core.vo.IdNameVo;
 import com.xunmei.common.core.web.controller.BaseController;
 import com.xunmei.common.core.web.domain.AjaxResult;
@@ -205,21 +204,21 @@ public class SysRoleController extends BaseController {
      * 获取所有可用的角色信息
      */
     @GetMapping(value = "/all")
-    public AjaxResult all() {
-        return success(roleService.selectSimpleRoleAll(null));
+    public AjaxResult all(@RequestParam(value = "orgType", required = false) Integer orgType) {
+        return success(roleService.selectSimpleRoleAll(null, orgType));
     }
+
     @ApiOperation(value = "根据id查询角色")
     @InnerAuth
     @GetMapping(value = "/getRoleById")
     public SysRole getRoleById(Long id) {
-        SysRole sysRole = roleService.getById(id);
-        return sysRole;
+        return roleService.getById(id);
     }
 
 //    @InnerAuth
     @PostMapping ("/getNames")
     public List<IdNameVo> getNames(RoleConditionEto condition) {
-        List<IdName<Long, String>> r= roleService.selectSimpleRoleAll(condition);
+        List<IdName<Long, String>> r = roleService.selectSimpleRoleAll(condition, null);
         return r.stream().map(i->new IdNameVo(i.getId(),i.getName(),null)).collect(Collectors.toList());
     }
 }

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

@@ -26,7 +26,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
-
 import java.util.Date;
 import java.util.List;
 import java.util.Set;

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/ISysRoleService.java

@@ -2,7 +2,6 @@ package com.xunmei.system.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.xunmei.common.core.domain.IdName;
-import com.xunmei.common.core.vo.IdNameVo;
 import com.xunmei.common.core.web.page.TableDataInfo;
 import com.xunmei.system.api.Eto.RoleConditionEto;
 import com.xunmei.system.api.domain.SysRole;
@@ -184,5 +183,5 @@ public interface ISysRoleService extends IService<SysRole>
      */
     String getRoleName(Long userId);
 
-    List<IdName<Long,String>> selectSimpleRoleAll(RoleConditionEto conditionEto);
+    List<IdName<Long, String>> selectSimpleRoleAll(RoleConditionEto conditionEto, Integer orgType);
 }

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/impl/SysAreaCheckServiceImpl.java

@@ -3,9 +3,9 @@ package com.xunmei.system.service.impl;
 import java.util.ArrayList;
 import java.util.List;
 
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.xunmei.common.core.exception.ServiceException;
 import com.xunmei.common.core.utils.DateUtils;
-import com.xunmei.common.core.utils.StringUtils;
 import com.xunmei.common.core.utils.bean.BeanUtils;
 import com.xunmei.common.security.utils.SecurityUtils;
 import com.xunmei.system.api.domain.SysArea;
@@ -18,9 +18,6 @@ import com.xunmei.system.mapper.SysOrgMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.xunmei.system.service.ISysOrgService;
-
-import java.util.Arrays;
-
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -178,7 +175,7 @@ public class SysAreaCheckServiceImpl extends ServiceImpl<SysAreaCheckMapper, Sys
         query.eq("del_flag", "0");
         query.in("check_id", ids);
         List<SysNfcBind> sysNfcBinds = sysNfcBindMapper.selectList(query);
-        if (null == sysNfcBinds || sysNfcBinds.size() > 0) {
+        if(CollectionUtils.isNotEmpty(sysNfcBinds)){
             throw new ServiceException("数据使用中，不能删除");
         }
         int i = 0;

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/impl/SysAreaServiceImpl.java

@@ -1,12 +1,6 @@
 package com.xunmei.system.service.impl;
 
-import java.util.ArrayList;
-import java.util.Collections;
 import java.util.List;
-
-import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.A;
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
-import com.sun.org.apache.bcel.internal.generic.NEW;
 import com.xunmei.common.core.exception.ServiceException;
 import com.xunmei.common.core.utils.DateUtils;
 import com.xunmei.common.security.utils.SecurityUtils;
@@ -18,11 +12,7 @@ import com.xunmei.system.mapper.SysAreaCheckMapper;
 import com.xunmei.system.mapper.SysDictDataMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import com.xunmei.system.service.ISysOrgService;
-
-import java.util.Arrays;
 import java.util.stream.Collectors;
-
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -62,8 +52,8 @@ public class SysAreaServiceImpl extends ServiceImpl<ISysAreaMapper, SysArea> imp
         //查询条件
         QueryWrapper<SysArea> query = new QueryWrapper<>(sysArea);
         //下穿
-        if (sysArea.getCheckSub()) {
-            //  List<Long> ids = orgService.selectCheckSubOrgIdList(sysArea.getOrgType());
+        Boolean checkSub = sysArea.getCheckSub();
+        if (checkSub) {
             List<SysDictData> sysDictData = sysDictDataMapper.selectDictDataByType(sysArea.getOrgType());
             List<String> ids = sysDictData.stream().map(e -> e.getDictValue()).collect(Collectors.toList());
             //清空前端传递的org_id
@@ -155,9 +145,8 @@ public class SysAreaServiceImpl extends ServiceImpl<ISysAreaMapper, SysArea> imp
         SysAreaCheck sysAreaCheck = new SysAreaCheck();
         QueryWrapper<SysAreaCheck> query = new QueryWrapper<>(sysAreaCheck);
         query.eq("del_flag", "0");
-        List<SysAreaCheck> sysAreaChecks = new ArrayList<>();
         query.in("area_id", ids);
-        sysAreaChecks = sysAreaCheckMapper.selectList(query);
+        List<SysAreaCheck> sysAreaChecks = sysAreaCheckMapper.selectList(query);
         if (null == sysAreaChecks || sysAreaChecks.size() > 0) {
             throw new ServiceException("数据使用中，不能删除");
         }
@@ -186,9 +175,8 @@ public class SysAreaServiceImpl extends ServiceImpl<ISysAreaMapper, SysArea> imp
         SysAreaCheck sysAreaCheck = new SysAreaCheck();
         QueryWrapper<SysAreaCheck> query = new QueryWrapper<>(sysAreaCheck);
         query.eq("del_flag", "0");
-        List<SysAreaCheck> sysAreaChecks = new ArrayList<>();
         query.eq("area_id", id);
-        sysAreaChecks = sysAreaCheckMapper.selectList(query);
+        List<SysAreaCheck> sysAreaChecks = sysAreaCheckMapper.selectList(query);
         if (null == sysAreaChecks || sysAreaChecks.size() > 0) {
             throw new ServiceException("数据使用中，不能删除");
         }

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/impl/SysOrgServiceImpl.java

@@ -3,6 +3,7 @@ package com.xunmei.system.service.impl;
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.xunmei.common.core.constant.CacheConstants;
@@ -260,20 +261,23 @@ public class SysOrgServiceImpl extends ServiceImpl<SysOrgMapper, SysOrg> impleme
     @Override
     @Transactional(rollbackFor = Exception.class)
     public boolean saveOrUpdateOrg(SysOrg org) {
-
         boolean isOk = false;
         if (org.getId() != null) {
             isOk = this.updateById(org);
         } else {
+            SysOrg sysOrg = sysOrgMapper.selectById(org.getParentId());
+            org.setParentGuid(sysOrg.getGuid());
+            org.setDeleted(0);
+            long id = IdWorker.getId();
+            org.setId(id);
+            org.setPath(sysOrg.getPath()+id+"-");
             isOk = this.save(org);
         }
-
         /*
          * 重置缓存
          */
         this.clearOrgCache();
         this.loadingOrgCache();
-
         return isOk;
     }
 

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/impl/SysRoleServiceImpl.java

@@ -15,8 +15,12 @@ import com.xunmei.common.security.utils.SecurityUtils;
 import com.xunmei.system.api.Eto.RoleConditionEto;
 import com.xunmei.system.api.domain.SysRole;
 import com.xunmei.system.api.domain.SysUser;
-import com.xunmei.system.domain.*;
-import com.xunmei.system.mapper.*;
+import com.xunmei.system.domain.SysRoleMenu;
+import com.xunmei.system.domain.SysUserRole;
+import com.xunmei.system.mapper.SysRoleDeptMapper;
+import com.xunmei.system.mapper.SysRoleMapper;
+import com.xunmei.system.mapper.SysRoleMenuMapper;
+import com.xunmei.system.mapper.SysUserRoleMapper;
 import com.xunmei.system.service.ISysRoleService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -411,15 +415,17 @@ public class SysRoleServiceImpl extends ServiceImpl<SysRoleMapper, SysRole> impl
     }
 
     @Override
-    public List<IdName<Long, String>> selectSimpleRoleAll(RoleConditionEto conditionEto) {
+    public List<IdName<Long, String>> selectSimpleRoleAll(RoleConditionEto conditionEto, Integer orgType) {
         final LambdaQueryWrapper<SysRole> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(SysRole::getStatus, 0)
+        queryWrapper
+                .eq(SysRole::getStatus, 0)
                 .eq(SysRole::getDelFlag, 0)
-                .select(SysRole::getId,SysRole::getRoleName);
+                .eq(ObjectUtil.isNotNull(orgType), SysRole::getOrgType, orgType)
+                .select(SysRole::getId, SysRole::getRoleName);
 
-        if(ObjectUtil.isNotNull(conditionEto)){
-            if(ObjectUtil.isNotEmpty(conditionEto.getIds())){
-                queryWrapper.in(SysRole::getId,conditionEto.getIds());
+        if (ObjectUtil.isNotNull(conditionEto)) {
+            if (ObjectUtil.isNotEmpty(conditionEto.getIds())) {
+                queryWrapper.in(SysRole::getId, conditionEto.getIds());
             }
         }
         return roleMapper.selectList(queryWrapper).stream().map(role -> new IdName<>(role.getId(), role.getRoleName())).collect(Collectors.toList());

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

@@ -70,6 +70,8 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
 
     @Autowired
     protected Validator validator;
+    @Autowired
+    private SysOrgMapper sysOrgMapper;
 
     /**
      * 根据条件分页查询用户列表
@@ -91,6 +93,12 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
         }
         //查询条件
         QueryWrapper<SysUser> query = new QueryWrapper<>(user);
+        QueryWrapper queryWrapper = new QueryWrapper();
+        queryWrapper.eq("parent_id", -1);
+        SysOrg sysOrg1 = sysOrgMapper.selectOne(queryWrapper);
+        if (null == user.getOrgId()) {
+            user.setOrgId(sysOrg1.getId());
+        }
         //下穿
         if (user.getCheckSub()) {
             List<Long> ids = orgService.selectCheckSubOrgIdList(user.getOrgId());
@@ -127,8 +135,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
      * @return 用户信息集合信息
      */
     @Override
-    public List<SysUser> selectSyncUserList(SysUser user)
-    {
+    public List<SysUser> selectSyncUserList(SysUser user) {
         return userMapper.selectSyncUserList(user);
     }
 
@@ -182,7 +189,7 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
      */
     @Override
     public SysUser selectUserByUserName(String userName) {
-        return userMapper.selectOne(new QueryWrapper<SysUser>().eq("username", userName).eq("deleted",0));
+        return userMapper.selectOne(new QueryWrapper<SysUser>().eq("username", userName).eq("deleted", 0));
     }
 
     /**
@@ -315,7 +322,8 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
     public int insertUser(SysUser user) {
         user.setCreateTime(new Date());
         // 新增用户信息
-        SysOrg sysOrg = orgService.selectSysOrgById(user.getOrgId());user.setOrgName(sysOrg.getName());
+        SysOrg sysOrg = orgService.selectSysOrgById(user.getOrgId());
+        user.setOrgName(sysOrg.getName());
 
         int rows = userMapper.insert(user);
         // 新增用户岗位关联
@@ -356,7 +364,8 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
         insertUserPost(user);
         user.setPassword(null);
         user.setSalt(null);
-        SysOrg sysOrg = orgService.selectSysOrgById(user.getOrgId());user.setOrgName(sysOrg.getName());
+        SysOrg sysOrg = orgService.selectSysOrgById(user.getOrgId());
+        user.setOrgName(sysOrg.getName());
         return userMapper.updateById(user);
     }
 

soc-modules/soc-modules-system/src/main/resources/mapper/system/SysOrgMapper.xml

@@ -54,7 +54,8 @@
                org_extend_id,
                source,
                short_name,
-               remark
+               remark,
+               path
         from sys_org
     </sql>