Commit 94eefc30 by shenjunjie

暂时停止渠道表入库

parent 34909def
...@@ -685,14 +685,14 @@ public class EventServiceImpl implements EventService { ...@@ -685,14 +685,14 @@ public class EventServiceImpl implements EventService {
private List<JSONObject> getDefaultVolumes() { private List<JSONObject> getDefaultVolumes() {
List<JSONObject> res = new ArrayList<>(); List<JSONObject> res = new ArrayList<>();
for (String name : Arrays.asList("全部", "1-100", "100-1000", "1000-5000", ">=5000")) { for (String name : Arrays.asList("全部", "1-100", "100-1000", "1000-5000", "5000")) {
JSONObject json = new JSONObject(); JSONObject json = new JSONObject();
json.put("name", name); json.put("name", name);
switch (name) { switch (name) {
case "全部": case "全部":
json.put("totalDisseminationVolumes", null); json.put("totalDisseminationVolumes", null);
break; break;
case ">=5000": case "5000":
json.put("totalDisseminationVolumes", new Long[]{5000L, -1L}); json.put("totalDisseminationVolumes", new Long[]{5000L, -1L});
break; break;
default: default:
......
...@@ -100,7 +100,8 @@ public class TaskServiceImpl implements TaskService { ...@@ -100,7 +100,8 @@ public class TaskServiceImpl implements TaskService {
// 替换成新的记录map // 替换成新的记录map
channelIndexRecordMap = newRecordMap; channelIndexRecordMap = newRecordMap;
ListUtils.partition(insertList, 1000).forEach(list -> { ListUtils.partition(insertList, 1000).forEach(list -> {
channelDao.insertMany(list); // TODO 2
// channelDao.insertMany(list);
}); });
log.info("渠道统计-渠道总计-录入完毕,新增渠道{}条,更新渠道{}条", insertList.size(), channelIndexRecordMap.size() - insertList.size()); log.info("渠道统计-渠道总计-录入完毕,新增渠道{}条,更新渠道{}条", insertList.size(), channelIndexRecordMap.size() - insertList.size());
// 获得单位时间内最小最大时间戳 // 获得单位时间内最小最大时间戳
...@@ -122,7 +123,8 @@ public class TaskServiceImpl implements TaskService { ...@@ -122,7 +123,8 @@ public class TaskServiceImpl implements TaskService {
insertList.add(channelService.calculateChannelEmotionIndex(channel)); insertList.add(channelService.calculateChannelEmotionIndex(channel));
} else { } else {
channel.setRecord(entry.getValue()); channel.setRecord(entry.getValue());
channelDao.updateOne(channelService.calculateChannelEmotionIndex(channel)); // TODO 2
// channelDao.updateOne(channelService.calculateChannelEmotionIndex(channel));
} }
// 设置查询数值 // 设置查询数值
entry.getKey().setChannelInfo(channel); entry.getKey().setChannelInfo(channel);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment