|
@@ -34,6 +34,7 @@ import com.qunzhixinxi.hnqz.admin.entity.WmReport;
|
|
|
import com.qunzhixinxi.hnqz.admin.entity.WmScorePackage;
|
|
|
import com.qunzhixinxi.hnqz.admin.entity.WmTask;
|
|
|
import com.qunzhixinxi.hnqz.admin.entity.input.WmPackageExportApiInput;
|
|
|
+import com.qunzhixinxi.hnqz.admin.enums.ChannelEnum;
|
|
|
import com.qunzhixinxi.hnqz.admin.enums.ReportEnum;
|
|
|
import com.qunzhixinxi.hnqz.admin.service.*;
|
|
|
import com.qunzhixinxi.hnqz.common.core.entity.BaseMap;
|
|
@@ -60,6 +61,7 @@ import java.util.ArrayList;
|
|
|
import java.util.Arrays;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
@@ -204,7 +206,8 @@ public class ReportExportController {
|
|
|
|
|
|
rabbitMqClient.sendMessage(MqConstants.DIRECT_MODE_REPORT_EXPORT_NB_QUEUE,map);
|
|
|
|
|
|
- redisTemplate.opsForValue().set(key, WmReportOpt.WmReportOptStatus.GENERATING.name());
|
|
|
+ redisTemplate.opsForValue().set(key, WmReportOpt.WmReportOptStatus.GENERATING.name(),
|
|
|
+ CacheConstants.DEF_REPORT_CREATING_TTL, TimeUnit.MILLISECONDS);
|
|
|
|
|
|
return R.ok("开始导出,请耐心等待");
|
|
|
|
|
@@ -284,7 +287,8 @@ public class ReportExportController {
|
|
|
|
|
|
rabbitMqClient.sendMessage(MqConstants.DIRECT_MODE_REPORT_EXPORT_ZB_QUEUE,map);
|
|
|
|
|
|
- redisTemplate.opsForValue().set(key, WmReportOpt.WmReportOptStatus.GENERATING.name());
|
|
|
+ redisTemplate.opsForValue().set(key, WmReportOpt.WmReportOptStatus.GENERATING.name(),
|
|
|
+ CacheConstants.DEF_REPORT_CREATING_TTL, TimeUnit.MILLISECONDS);
|
|
|
|
|
|
return R.ok("开始导出,请耐心等待");
|
|
|
|
|
@@ -524,7 +528,8 @@ public class ReportExportController {
|
|
|
|
|
|
rabbitMqClient.sendMessage(MqConstants.DIRECT_MODE_REPORT_EXPORT_NBA_HISTORY_QUEUE,map);
|
|
|
|
|
|
- redisTemplate.opsForValue().set(key, WmReportOpt.WmReportOptStatus.GENERATING.name());
|
|
|
+ redisTemplate.opsForValue().set(key, WmReportOpt.WmReportOptStatus.GENERATING.name(),
|
|
|
+ CacheConstants.DEF_REPORT_CREATING_TTL,TimeUnit.MILLISECONDS);
|
|
|
|
|
|
return R.ok("开始导出,请耐心等待");
|
|
|
|