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

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

@@ -35,6 +35,7 @@ import com.sooka.sponest.message.api.RemoteMonitorService;
 import com.sooka.sponest.monitor.api.domain.CenterdataTAidevicedept;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.apache.commons.collections4.MapUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -298,11 +299,6 @@ public class CentereventTEventcatalogueController extends BaseController {
         return AjaxResult.success();
     }
 
-    /**
-     * 删除事件目录
-     */
-    @RequiresPermissions("eventcatalogue:eventcatalogue:remove")
-    @Log(title = "事件目录", businessType = BusinessType.DELETE)
     @DeleteMapping("/{eventCode}")
     public AjaxResult remove(@PathVariable String eventCode) {
         int result = centereventTEventcatalogueService.deleteCentereventTEventcatalogueByCode(eventCode);
@@ -310,6 +306,19 @@ public class CentereventTEventcatalogueController extends BaseController {
         return toAjax(result);
     }
 
+    @GetMapping("/upatach")
+    public AjaxResult upatach() {
+        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();
+        for (Map map:list) {
+            paramMap.put("czlx", "AI");
+            paramMap.put("busId", MapUtils.getString(map,"busId"));
+            remoteDataService.updateAttach(paramMap);
+        }
+        return AjaxResult.success();
+    }
+
     /**
      * 手机端调用发送短信
      *

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

@@ -65,4 +65,6 @@ public interface CentereventTEventcatalogueMapper {
     CentereventTEventcatalogue mqtest(@Param("start") String start, @Param("end") String end, @Param("limit") int limit);
 
     List<CentereventTEventcatalogue>  getbeforedateDownload(Map<String,Object> params);
+
+    List<Map<String, Object>> selectFailUpattah();
 }

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

@@ -87,4 +87,6 @@ public interface ICentereventTEventcatalogueService {
     CentereventTEventcatalogue mqtest(String start, String end, int limit);
 
     void downloadsCommon(Map<String, Object> params) throws InterruptedException;
+
+    List<Map<String, Object>> selectFailUpattah();
 }

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

@@ -738,4 +738,9 @@ public class CentereventTEventcatalogueServiceImpl extends BaseService implement
             centereventTDownloadsService.updateCentereventTDownloads(down);
         }
     }
+
+    @Override
+    public List<Map<String, Object>> selectFailUpattah() {
+        return centereventTEventcatalogueMapper.selectFailUpattah();
+    }
 }

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

@@ -374,4 +374,19 @@
 
             )
     </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>
 </mapper>