定时任务删除两月推送

src/main/java/com/mudu/mapper/ASafeZcrwMapper.java

@@ -17,7 +17,8 @@ public interface ASafeZcrwMapper extends BaseMapper<ASafeZcrw> {
      * 查询自查任务主表1个月内是否有记录就不推
      */
 
-    @Select("select count(*) from a_safe_zcrw where rksj  BETWEEN DATE_SUB( CURDATE(), INTERVAL 1 MONTH ) AND CURDATE() and qybh =#{enterPriseId} ")
+//    @Select("select count(*) from a_safe_zcrw where rksj  BETWEEN DATE_SUB( CURDATE(), INTERVAL 1 MONTH ) AND CURDATE() and qybh =#{enterPriseId} ")
+    @Select("select count(*) from a_safe_zcrw where  qybh =#{enterPriseId} ")
     Integer zcrwNum(String enterPriseId);
 
 

src/main/java/com/mudu/quartz/AcheckTaskQuartz.java

@@ -37,12 +37,12 @@ import java.util.UUID;
  * @author dong
  * @since 2024/3/12 16:37
  */
-//@RestController
+@RestController
-//@RequestMapping("pharmaceuticals/aCheck")
+@RequestMapping("pharmaceuticals/aCheck")
-//@Api(tags = "新增")
+@Api(tags = "新增")
-@Transactional(rollbackFor = Exception.class)
+//@Transactional(rollbackFor = Exception.class)
-@Configuration
+//@Configuration
-@EnableScheduling
+//@EnableScheduling
 public class AcheckTaskQuartz {
     Logger logger = LoggerFactory.getLogger(AcheckTaskQuartz.class);
     /**
@@ -158,7 +158,9 @@ public class AcheckTaskQuartz {
         String responseList = HttpRequest.post(imUrl)
                 .contentType("application/x-www-form-urlencoded;charset=UTF-8")
                 .header("Authorization", token)
+//                .timeout(60*1000*2)
                 .execute().body();
+        logger.info(responseList);
         JSONObject jsonResponseList = JSON.parseObject(responseList);
         logger.info(responseList);
         String dataList = jsonResponseList.getString("data");
@@ -183,12 +185,7 @@ public class AcheckTaskQuartz {
                 enterPriseId = aSafeQyjcxx.getXxbh();
             }
 
-            // todo 查询巡查任务主表2月是否有记录就不推
+
-            Integer xcrwNum = aSafeXcrwService.xcrwNum(enterPriseId);
-            if (xcrwNum > 0) {
-                logger.info("查任务主表2月是否有记录就不推");
-                continue;
-            }
             // todo 来自新表查询 根据企业xxbh 以及周期编号
             JSONObject xcjsonObject = new JSONObject();
             xcjsonObject.put("qybh", aSafeQyjcxx.getXxbh());
@@ -678,12 +675,7 @@ public class AcheckTaskQuartz {
             return;
         }
         for (ACheckQuatzZichaRequest a : list) {
-            // todo 查询自查任务主表本月是否有记录 有就不推
+
-            Integer zcrwNum = aSafeZcrwService.zcrwNum(a.getEnterpriseID());
-            if (zcrwNum > 0) {
-                logger.info("查询自查任务主表本月是否有记录 有就不推");
-                continue;
-            }
             if (a.getEnterpriseID() == null) {
                 logger.info("getEnterpriseID为空");
                 continue;
@@ -698,7 +690,7 @@ public class AcheckTaskQuartz {
                     .body(zcjsonObject.toJSONString())
                     .execute().body();
             JSONObject zcjsonResponse = JSON.parseObject(zcresponse);
-            logger.info(JSONUtil.toJsonStr(zcjsonResponse));
+
             if (zcjsonResponse.getString("msg") == null) {
                 continue;
             }
@@ -711,7 +703,12 @@ public class AcheckTaskQuartz {
             /**
              * 自查任务 a_safe_zcrw
              */
+            try {
                 saveZcrw(a, zcrwUuid, rwzqUuid);
+            } catch (Exception e) {
+                logger.error("============" + a.getEnterpriseID() + "==============" + "============" + rwzqUuidResponse.getXxbh() + "==============");
+            }
+
             for (ACheckQuatzZichaEntity b : a.getList()) {
                 String zcrwjlUuid = UUID.randomUUID().toString().replace("-", "").toLowerCase();
                 String zcrwwzUuid = UUID.randomUUID().toString().replace("-", "").toLowerCase();

src/main/resources/application-dev.yml

@@ -2,7 +2,7 @@
 # DataSource Config
 spring:
   datasource:
-    url: jdbc:mysql://localhost:3306/mudu?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+    url: jdbc:mysql://localhost:3306/wzawb?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
     username: root
     password: adminadmin
     #公司本地

src/main/resources/mapper/mudu/ASafeRwzqMapper.xml

@@ -13,9 +13,14 @@
     </select>
     <select id="getZcUuid" resultType="com.mudu.entity.dto.response.RwzqUuidResponse">
 
+        --         SELECT xxbh
+--         FROM `a_safe_rwzq`
+--         where RWLX = 'QYZC'
+--         ORDER BY ZQJSSJ desc limit 1
         SELECT xxbh
         FROM `a_safe_rwzq`
         where RWLX = 'QYZC'
-        ORDER BY ZQJSSJ desc limit 1
+          and ZQJSSJ = '2024-07-31 23:59:59'
+
     </select>
 </mapper>