|
@@ -687,7 +687,9 @@ public class CentereventTEventcatalogueServiceImpl extends BaseService implement
|
|
|
@Override
|
|
|
public void downloadsCommon(Map<String, Object> params) throws InterruptedException {
|
|
|
List<CentereventTEventcatalogue> eventcatalogues = centereventTEventcatalogueMapper.getbeforedateDownload(params);
|
|
|
+ int i = 0;
|
|
|
for (CentereventTEventcatalogue eventcatalogue : eventcatalogues) {
|
|
|
+ i++;
|
|
|
String busIndex = "bus_indx_other";// 其他
|
|
|
if ("1".equals(eventcatalogue.getEventType())) {
|
|
|
busIndex = BUS_INDEX_1;// 火情
|
|
@@ -724,6 +726,9 @@ public class CentereventTEventcatalogueServiceImpl extends BaseService implement
|
|
|
centereventTDownloads.setReason(result.getMsg());//失败原因
|
|
|
centereventTDownloadsService.insertCentereventTDownloads(centereventTDownloads);
|
|
|
}
|
|
|
+ if (i % 10 == 0) {
|
|
|
+ Thread.sleep(300000);
|
|
|
+ }
|
|
|
}
|
|
|
Thread.sleep(300000);
|
|
|
logger.info("附件表查询回写=====>{}", DateUtils.dateTimeNow());
|