四平大华的图片批量更新下载到本地

src/main/java/com/sooka/sponest/event/centereventteventcatalogue/controller/CentereventTEventcatalogueController.java

@@ -310,11 +310,11 @@ public class CentereventTEventcatalogueController extends BaseController {
         EventProducerUtil.publish(eventCode, BusinessType.DELETE);
         return toAjax(result);
     }
-    @GetMapping("/upatach")
-    public AjaxResult upatach() {
+    @GetMapping("/upatach/{num}")
+    public AjaxResult upatach(@PathVariable int num) {
         Map<String, String> paramMap = SpringUtils.getBean(RemoteConfigService.class).remotegetConfigMap(Arrays.asList(FILE_PREFIX_LOCAL, FILE_PREFIX_HIK1, FILE_PREFIX_HIK2, FILE_PREFIX_DH1, FILE_PREFIX_DH2)).getData();
         paramMap.put("token", RemoteApiUtil.getInstance().getToken());// 大华token
-        List<Map<String, Object>> list = centereventTEventcatalogueService.selectFailUpattah();
+        List<Map<String, Object>> list = centereventTEventcatalogueService.selectFailUpattah(num);
         for (Map map:list) {
             paramMap.put("czlx", "AI");
             paramMap.put("busId", MapUtils.getString(map,"busId"));

src/main/java/com/sooka/sponest/event/centereventteventcatalogue/mapper/CentereventTEventcatalogueMapper.java

@@ -66,5 +66,5 @@ public interface CentereventTEventcatalogueMapper {
 
     List<CentereventTEventcatalogue>  getbeforedateDownload(Map<String,Object> params);
 
-    List<Map<String, Object>> selectFailUpattah();
+    List<Map<String, Object>> selectFailUpattah(int num);
 }

src/main/java/com/sooka/sponest/event/centereventteventcatalogue/service/ICentereventTEventcatalogueService.java

@@ -88,5 +88,5 @@ public interface ICentereventTEventcatalogueService {
 
     void downloadsCommon(Map<String, Object> params) throws InterruptedException;
 
-    List<Map<String, Object>> selectFailUpattah();
+    List<Map<String, Object>> selectFailUpattah(int num);
 }

src/main/java/com/sooka/sponest/event/centereventteventcatalogue/service/impl/CentereventTEventcatalogueServiceImpl.java

@@ -740,7 +740,7 @@ public class CentereventTEventcatalogueServiceImpl extends BaseService implement
     }
 
     @Override
-    public List<Map<String, Object>> selectFailUpattah() {
-        return centereventTEventcatalogueMapper.selectFailUpattah();
+    public List<Map<String, Object>> selectFailUpattah(int num) {
+        return centereventTEventcatalogueMapper.selectFailUpattah(num);
     }
 }

src/main/resources/mapper/centereventteventcatalogue/CentereventTEventcatalogueMapper.xml

@@ -375,18 +375,31 @@
             )
     </select>
 
-    <select id="selectFailUpattah" resultType="map">
-         SELECT
-         a.report_source as reportSource,
-         ch.bus_id as busId
-         FROM
-         onest_event.centerevent_t_eventcatalogue a
-         LEFT JOIN onest_event.centerevent_t_fire_log d ON a.event_code = d.event_code
-         LEFT JOIN onest_data.centerdata_t_attach ch ON ch.bus_id = d.id
-         WHERE
-         ch.attach_path NOT LIKE 'group%'
-         AND a.report_source = 'reporting_source_1'
-         AND DATE_SUB( CURDATE(), INTERVAL 40 DAY ) &lt;= date(
-         a.report_time)
-     </select>
+    <select id="selectFailUpattah" parameterType="int" resultType="map">
+SELECT
+	ch.bus_id AS busId
+FROM
+	onest_event.centerevent_t_eventcatalogue a
+	LEFT JOIN (
+	SELECT
+		SUBSTRING_INDEX( GROUP_CONCAT( id ORDER BY create_time ), ',', 1 ) id,
+		event_code
+	FROM
+		centerevent_t_fire_log
+	WHERE
+		DATEDIFF( NOW(), create_time ) >= #{num}
+	GROUP BY
+		event_code
+	) d ON a.event_code = d.event_code
+	LEFT JOIN onest_data.centerdata_t_attach ch ON ch.bus_id = d.id
+WHERE
+	ch.attach_path NOT LIKE 'group%'
+	AND a.report_source = 'reporting_source_1'
+	AND DATEDIFF( NOW(), a.report_time ) >= #{num}
+	AND a.event_status_value NOT IN (
+		'forest_event_status_3',
+		'forest_event_status_4'
+	)
+
+    </select>
 </mapper>