浏览代码

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

zhulu 2 年之前
父节点
当前提交
f7d4b04356
共有 16 个文件被更改,包括 63 次插入23 次删除
  1. 10 1
      soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/domain/CoreMonitoringRetrievalTask.java
  2. 4 0
      soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/dto/RetrievalTaskPageDto.java
  3. 3 0
      soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/vo/CoreMonitoringRetrievalTaskOneVo.java
  4. 9 0
      soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/retrieval/vo/CoreMonitoringRetrievalTaskVo.java
  5. 1 1
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/mapper/CoreMonitoringTaskMonitorInfoMapper.java
  6. 1 1
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/service/impl/CoreMonitoringTaskRegistrationServiceImpl.java
  7. 1 1
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/controller/AppRuleController.java
  8. 5 0
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppRule.java
  9. 5 4
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppRuleItem.java
  10. 3 3
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppRulePoint.java
  11. 1 2
      soc-modules/soc-modules-core/src/main/java/com/xunmei/core/retrieval/service/impl/CoreMonitoringRetrievalTaskServiceImpl.java
  12. 1 1
      soc-modules/soc-modules-core/src/main/resources/mapper/access/CoreMonitoringTaskMonitorInfoMapper.xml
  13. 1 0
      soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppRuleItemMapper.xml
  14. 2 1
      soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppRuleMapper.xml
  15. 6 6
      soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppRulePointMapper.xml
  16. 10 2
      soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/RetrievalTask.java

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

@@ -2,6 +2,8 @@ package com.xunmei.common.core.domain.retrieval.domain;
 
 import java.util.Date;
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 import org.apache.commons.lang3.builder.ToStringStyle;
 import com.baomidou.mybatisplus.annotation.TableName;
@@ -28,9 +30,11 @@ public class CoreMonitoringRetrievalTask extends BaseEntity
 private static final long serialVersionUID=1L;
 
     /** 主键 */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long id;
 
     /** 计划id */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long planId;
 
     /** 任务名称 */
@@ -38,6 +42,7 @@ private static final long serialVersionUID=1L;
     private String taskName;
 
     /** 调阅机构 */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long orgId;
 
     /** 调阅机构 */
@@ -96,15 +101,19 @@ private static final long serialVersionUID=1L;
     private String status;
 
     /** 角色id */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long roleId;
 
     /** 调阅人 */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long retrievalUser;
 
     /** 第几次调阅(根据计划的频次计算的来) */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Integer orderNum;
 
     /** 批次号(同一计划多频次为一个批次号) */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long batchNum;
 
     /** 提交时间 */
@@ -112,7 +121,7 @@ private static final long serialVersionUID=1L;
 
     /** 异常数 */
             @ApiModelProperty(value = "异常数")
-    private Long exceptionCount;
+    private Integer exceptionCount;
 
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                         
 @Override

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

@@ -3,6 +3,8 @@ package com.xunmei.common.core.domain.retrieval.dto;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
 import com.xunmei.common.core.web.domain.BaseEntity;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -30,6 +32,7 @@ public class RetrievalTaskPageDto extends BaseEntity
     private String taskName;
 
     /** 调阅机构 */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long orgId;
 
     /** 调阅机构 */
@@ -42,6 +45,7 @@ public class RetrievalTaskPageDto extends BaseEntity
     private String status;
 
     /** 角色id */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long roleId;
         /**
          * 页面

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

@@ -1,6 +1,8 @@
 package com.xunmei.common.core.domain.retrieval.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
 import com.xunmei.common.core.web.domain.BaseEntity;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -23,6 +25,7 @@ public class CoreMonitoringRetrievalTaskOneVo {
     /**
      * 主键
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long id;
 
     /**

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

@@ -2,6 +2,8 @@ package com.xunmei.common.core.domain.retrieval.vo;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
 import com.xunmei.common.core.web.domain.BaseEntity;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -27,11 +29,13 @@ public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
     /**
      * 主键
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long id;
 
     /**
      * 计划id
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long planId;
 
     /**
@@ -43,6 +47,7 @@ public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
     /**
      * 调阅机构
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long orgId;
 
     /**
@@ -135,6 +140,7 @@ public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
     /**
      * 角色id
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long roleId;
 
     private String roleName;
@@ -142,6 +148,7 @@ public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
     /**
      * 调阅人
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long retrievalUser;
 
     private String retrievalUserName;
@@ -149,11 +156,13 @@ public class CoreMonitoringRetrievalTaskVo extends BaseEntity {
     /**
      * 第几次调阅(根据计划的频次计算的来)
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long orderNum;
 
     /**
      * 批次号(同一计划多频次为一个批次号)
      */
+    @JsonSerialize(using = ToStringSerializer.class)
     private Long batchNum;
 
     /**

+ 1 - 1
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/access/mapper/CoreMonitoringTaskMonitorInfoMapper.java

@@ -23,7 +23,7 @@ public interface CoreMonitoringTaskMonitorInfoMapper extends BaseMapper<CoreMoni
      */
     CoreMonitoringTaskMonitorInfo selectCoreMonitoringTaskMonitorInfoById(Long id);
 
-    long selectAbnormalByTaskId(Long taskId);
+    int selectAbnormalByTaskId(Long taskId);
     /**
      * 查询调阅任务登记检查情况列表
      *

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

@@ -104,7 +104,7 @@ public class CoreMonitoringTaskRegistrationServiceImpl extends ServiceImpl<CoreM
         coreMonitoringRetrievalTask.setUpdateTime(DateUtils.getNowDate());
         coreMonitoringRetrievalTask.setSubmitTime(DateUtils.getNowDate());
         coreMonitoringRetrievalTask.setRetrievalUser(SecurityUtils.getUserId());
-        Long i = coreMonitoringTaskMonitorInfoMapper.selectAbnormalByTaskId(coreMonitoringTaskRegistration.getTaskId());
+        int i = coreMonitoringTaskMonitorInfoMapper.selectAbnormalByTaskId(coreMonitoringTaskRegistration.getTaskId());
         coreMonitoringRetrievalTask.setExceptionCount(i);
         coreMonitoringRetrievalTaskMapper.updateCoreMonitoringRetrievalTask(coreMonitoringRetrievalTask);
         return coreMonitoringTaskRegistrationMapper.updateById(coreMonitoringTaskRegistration);

+ 1 - 1
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/controller/AppRuleController.java

@@ -63,7 +63,7 @@ public class AppRuleController  extends BaseController {
 
     @ApiOperation(value = "删除规范")
     @RequiresPermissions("resumption:rule:remove")
-    @GetMapping("del/{id}")
+    @DeleteMapping("{id}")
 
     public AjaxResult del(@PathVariable Long id) {
         appRuleService.del(id);

+ 5 - 0
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppRule.java

@@ -2,6 +2,7 @@ package com.xunmei.core.resumption.domain;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.xunmei.common.core.web.domain.BaseEntity;
 import io.swagger.annotations.ApiModel;
@@ -51,4 +52,8 @@ public class AppRule extends BaseEntity {
     @ApiModelProperty(value = "备注")
     @TableField("remark")
     private String remark;
+
+    @TableLogic(value = "0", delval = "1")
+    @ApiModelProperty(value = "是否删除 1是 0否")
+    private int deleted;
 }

+ 5 - 4
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppRuleItem.java

@@ -1,9 +1,6 @@
 package com.xunmei.core.resumption.domain;
 
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.*;
 import com.xunmei.common.core.web.domain.BaseEntity;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -42,4 +39,8 @@ public class AppRuleItem extends BaseEntity {
     @ApiModelProperty(value = "标准及要求")
     @TableField("`desc`")
     private String desc;
+
+    @TableLogic(value = "0", delval = "1")
+    @ApiModelProperty(value = "是否删除 1是 0否")
+    private int deleted;
 }

+ 3 - 3
soc-modules/soc-modules-core/src/main/java/com/xunmei/core/resumption/domain/AppRulePoint.java

@@ -49,11 +49,11 @@ public class AppRulePoint extends BaseEntity {
     @ApiModelProperty(value = "该要点关联的业务类型")
     private String businessType;
 
-   @ApiModelProperty(value = "时间类型,0无,1时分")
+    @ApiModelProperty(value = "时间类型,0无,1时分")
     @TableField("remark")
     private String remark;
 
-   @TableLogic(value = "0", delval = "1")
-    @ApiModelProperty(value = "是否禁用 1是 0否")
+    @TableLogic(value = "0", delval = "1")
+    @ApiModelProperty(value = "是否删除 1是 0否")
     private int deleted;
 }

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

@@ -340,8 +340,7 @@ public class CoreMonitoringRetrievalTaskServiceImpl extends ServiceImpl<CoreMoni
     @Override
     public void updateTaskStart() {
         LocalDate dateTime =  LocalDate.now();
-        Date dateTimeNew = Date.from(dateTime.atStartOfDay(ZoneId.systemDefault()).toInstant());
-        DateUtil.endOfDay(dateTimeNew).setField(DateField.MILLISECOND, 0);
+        Date dateTimeNew = DateUtil.endOfDay(Date.from(dateTime.atStartOfDay(ZoneId.systemDefault()).toInstant())).setField(DateField.MILLISECOND, 0);
         coreMonitoringRetrievalTaskMapper.updateTaskStart(dateTimeNew);
     }
 

+ 1 - 1
soc-modules/soc-modules-core/src/main/resources/mapper/access/CoreMonitoringTaskMonitorInfoMapper.xml

@@ -51,7 +51,7 @@
         <include refid="selectCoreMonitoringTaskMonitorInfoVo"/>
         where task_monitor_id = #{monitorId}
     </select>
-    <select id="selectAbnormalByTaskId" resultType="java.lang.Long">
+    <select id="selectAbnormalByTaskId" resultType="java.lang.Integer">
         SELECT
             COUNT( cmtmi.id )
         FROM

+ 1 - 0
soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppRuleItemMapper.xml

@@ -9,6 +9,7 @@
         ) as pointNums from
         core_resumption_rule_item i
         <where>
+            i.deleted=0
             <if test="itemPageDto.ruleId != null and itemPageDto.ruleId !=''">
                 and i.rule_id = #{itemPageDto.ruleId}
             </if>

+ 2 - 1
soc-modules/soc-modules-core/src/main/resources/mapper/resumption/AppRuleMapper.xml

@@ -13,6 +13,7 @@
         from core_resumption_rule a
         inner join sys_org org on a.org_id = org.id
         <where>
+            a.deleted=0
             <if test="appRule.name != null and appRule.name != ''">
                 and a.name like CONCAT('%',#{appRule.name},'%')
             </if>
@@ -36,7 +37,7 @@
                r.org_type as orgTypeId
         from core_resumption_rule r
                  inner join sys_dict_data d on r.type = d.id and d.dict_code = 'sys_org_type'
-        where status = "0"
+        where status = "0" and r.deleted=0
     </select>
 
     <!--    <select id="get" resultType="com.xunmei.core.resumption.vo.appRule.AppRuleInfoVo">-->

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

@@ -77,7 +77,7 @@
         inner join sys_area a on p.area_id = a.id
         inner join sys_dict_detail d on d.code = p.safe_type and d.dict_code = 'check_type'
         inner join t_app_rule ap on p.rule_id =ap.id
-        where p.deleted = 0
+        where p.deleted = 0 and ri.deleted=0
         <if test="pointIds != null and pointIds.size > 0">
             and p.id in
             <foreach collection="pointIds" item="pointId" open="(" separator="," close=")">
@@ -104,7 +104,7 @@
     <select id="findAreaListPlan" parameterType="Long" resultType="java.util.Map">
         SELECT a.area_id as areaid, d.name as areaname
         from core_resumption_rule_point a
-                 LEFT JOIN core_resumption_plan_to_point b ON a.id = b.item_id
+                 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 sys_area d ON a.area_id = d.id
         WHERE c.id = #{planid}
@@ -141,8 +141,8 @@
 
     <update id="updatePlanItem">
         update core_resumption_plan_to_point
-        set item_id=#{newId}
-        where item_id = #{id}
+        set point_id=#{newId}
+        where point_id = #{id}
     </update>
 
 <!--    <select id="checkPointNumRepeat" resultType="java.lang.Integer">-->
@@ -225,8 +225,8 @@
     </select>
     <select id="checkIsJoinResumptionPlan" resultType="java.lang.Integer">
         SELECT DISTINCT 1
-        FROM sys_plan_to_item
-        WHERE item_id in
+        FROM core_resumption_plan_to_point
+        WHERE point_id in
         <foreach collection="pointIds" item="pointId" index="index" open="(" separator="," close=")">
             #{pointId}
         </foreach>

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

@@ -26,6 +26,7 @@ public class RetrievalTask {
 
     /**
      * 每天生成日任务 如果当天是周一还需生成周任务
+     * 指定日子在前端调用
      */
     public void retrieveDayTaskByDate(String taskTime)
     {   String id = UUID.fastUUID().toString();
@@ -39,7 +40,7 @@ public class RetrievalTask {
      * 4.1||10.1日生成周期为每月,每季
      * 7.1日获取执行周期为每月,每季,每半年的
      * 其他日期生成月任务
-     *
+     * 指定日子在前端调用
      */
     public void retrieveMonthTaskByDate(String taskTime)
     {   String id = UUID.fastUUID().toString();
@@ -49,6 +50,9 @@ public class RetrievalTask {
         log.info("监控调阅每月季度半年年任务生成定时任务执行结束,当前任务 id:{},当前时间:{},结果:{}", id, new Date(), JSON.toJSONString(result));
     }
 
+    /**
+     * 每天凌晨3点执行定时任务
+     */
     public void retrieveDayTask()
     {   String id = UUID.fastUUID().toString();
         log.info("开始执行监控调阅每日每周任务生成定时任务,当前任务 id:{},当前时间:{},无参数", id, new Date());
@@ -60,7 +64,7 @@ public class RetrievalTask {
      * 4.1||10.1日生成周期为每月,每季
      * 7.1日获取执行周期为每月,每季,每半年的
      * 其他日期生成月任务
-     *
+     * 每月凌晨3.20执行定时任务
      */
     public void retrieveMonthTask()
     {   String id = UUID.fastUUID().toString();
@@ -68,6 +72,10 @@ public class RetrievalTask {
         AjaxResult result =  remoteRetrievalTaskService.monthTask(SecurityConstants.INNER);
         log.info("监控调阅每月季度半年年任务生成定时任务执行结束,当前任务 id:{},当前时间:{},结果:{}", id, new Date(), JSON.toJSONString(result));
     }
+
+    /**
+     * 每天晚上23:59:00执行任务
+     */
     public void updateTaskStart()
     {   String id = UUID.fastUUID().toString();
         log.info("开始执行监控调阅任务超期定时任务,当前任务 id:{},当前时间:{},无参数", id, new Date());