feature 增加 风险源重置相关代码

cx-safe-check/cx-save-check-common/src/main/java/com/rongwei/sfcommon/sys/service/AspRiskSourceService.java

@@ -9,5 +9,6 @@ public interface AspRiskSourceService extends IService<AspRiskSourceDo> {
 
     void test(Boolean haveJob,String filePath,String category);
 
+    void resetInfo();
 }
 

cx-safe-check/cx-save-check-common/src/main/java/com/rongwei/sfcommon/sys/service/impl/AspRiskSourceServiceImpl.java

@@ -3,13 +3,16 @@ package com.rongwei.sfcommon.sys.service.impl;
 
 import cn.hutool.core.date.DateUtil;
 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.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.rongwe.scentity.domian.AspRiskSourceDo;
 import com.rongwei.rwadmincommon.system.domain.SysOrganizationDo;
 import com.rongwei.rwadmincommon.system.domain.SysUserDo;
 import com.rongwei.rwadmincommon.system.service.SysOrganizationService;
 import com.rongwei.rwadmincommon.system.service.SysUserService;
+import com.rongwei.rwcommon.base.BaseDo;
 import com.rongwei.rwcommon.utils.SecurityUtil;
 import com.rongwei.sfcommon.sys.dao.AspRiskSourceDao;
 import com.rongwei.sfcommon.sys.service.AspRiskSourceService;
@@ -27,6 +30,7 @@ import java.util.Date;
 import java.util.HashMap;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 @Service
 public class AspRiskSourceServiceImpl extends ServiceImpl<AspRiskSourceDao, AspRiskSourceDo> implements AspRiskSourceService {
@@ -175,4 +179,22 @@ public class AspRiskSourceServiceImpl extends ServiceImpl<AspRiskSourceDao, AspR
         //插入数据
         this.saveBatch(resList);
     }
+
+    @Override
+    public void resetInfo() {
+        List<AspRiskSourceDo> list = this.list(new LambdaQueryWrapper<AspRiskSourceDo>().eq(BaseDo::getDeleted, "0"));
+        if(list.isEmpty()){
+            log.debug("暂无需要重置信息的风险源信息");
+            return;
+        }
+        List<String> ids = list.stream().map(AspRiskSourceDo::getId).collect(Collectors.toList());
+        this.update(new LambdaUpdateWrapper<AspRiskSourceDo>()
+                .in(AspRiskSourceDo::getId,ids)
+                .set(AspRiskSourceDo::getAssessstatus,"dpg")
+                .set(AspRiskSourceDo::getAvgsalary,null)
+                .set(AspRiskSourceDo::getRating,null)
+                .set(AspRiskSourceDo::getRiskranking,null)
+        );
+
+    }
 }

cx-safe-check/cx-save-check-entity/src/main/java/com/rongwe/scentity/domian/AspRiskSourceDo.java

@@ -146,5 +146,10 @@ public class AspRiskSourceDo extends BaseDo implements Serializable {
      */
     private String dutyofficername;
 
+    /**
+     * 评估状态
+     */
+    private String assessstatus;
+
     private static final long serialVersionUID = 1L;
-}
+}

cx-safe-check/cx-save-check-server/src/main/java/com/rongwei/savecheck/controller/AspRiskSourceController.java

@@ -6,6 +6,7 @@ import com.rongwei.rwcommon.utils.StringUtils;
 import com.rongwei.sfcommon.sys.service.AspRiskSourceService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.web.bind.annotation.*;
 
 
@@ -33,4 +34,18 @@ public class AspRiskSourceController {
         }
     }
 
+    /**
+     * 定义任务每年的第一天重置 风险源相关数据
+     * 定时任务 每天8点
+     *
+     * @return
+     */
+    @Scheduled(cron = "1 1 1 1 1 ?")
+    @PostMapping("/reset")
+    public R resetInfo() {
+        log.info("重置风险源相关信息");
+        aspRiskSourceService.resetInfo();
+        return R.ok();
+    }
+
 }