Browse Source

话题 网格为空时 继续下次

dev_shibei_match
jianjun 4 years ago
parent
commit
cff289eca5
  1. 11
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginTopicMainDailyServiceImpl.java

11
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginTopicMainDailyServiceImpl.java

@ -20,7 +20,6 @@ package com.epmet.service.evaluationindex.extract.todata.impl;
import com.epmet.commons.dynamic.datasource.annotation.DataSource; import com.epmet.commons.dynamic.datasource.annotation.DataSource;
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
import com.epmet.commons.tools.constant.NumConstant; import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.utils.ConvertUtils; import com.epmet.commons.tools.utils.ConvertUtils;
import com.epmet.commons.tools.utils.DateUtils; import com.epmet.commons.tools.utils.DateUtils;
import com.epmet.constant.DataSourceConstant; import com.epmet.constant.DataSourceConstant;
@ -166,7 +165,7 @@ public class FactOriginTopicMainDailyServiceImpl extends BaseServiceImpl<FactOri
* @param logDailyEntityList * @param logDailyEntityList
* @author yinzuomei * @author yinzuomei
* @description 批量插入fact_origin_topic_log_daily * @description 批量插入fact_origin_topic_log_daily
* @Date 2020/9/16 12:53 * @Date 2020/9/16 12:53
**/ **/
private void saveFactOriginTopicLogDailyEntity(List<FactOriginTopicLogDailyEntity> logDailyEntityList) { private void saveFactOriginTopicLogDailyEntity(List<FactOriginTopicLogDailyEntity> logDailyEntityList) {
//批量插入 //批量插入
@ -175,7 +174,7 @@ public class FactOriginTopicMainDailyServiceImpl extends BaseServiceImpl<FactOri
factOriginTopicLogDailyDao.insertBatchEntity(list); factOriginTopicLogDailyDao.insertBatchEntity(list);
}); });
} }
/** /**
* @return java.util.Map<java.lang.String,java.lang.Object> * @return java.util.Map<java.lang.String,java.lang.Object>
* @param topicOriginInfoList * @param topicOriginInfoList
@ -195,8 +194,8 @@ public class FactOriginTopicMainDailyServiceImpl extends BaseServiceImpl<FactOri
GridInfoDTO gridInfoDTO=gridMap.get(topicOriginInfoDTO.getGridId()); GridInfoDTO gridInfoDTO=gridMap.get(topicOriginInfoDTO.getGridId());
if(null==gridInfoDTO){ if(null==gridInfoDTO){
log.warn("没有找到 gridId="+topicOriginInfoDTO.getGridId()+" 的基本信息"); log.warn("没有找到 gridId="+topicOriginInfoDTO.getGridId()+" 的基本信息");
// continue; continue;
throw new RenException("gridInfoDTO is null gridId="+topicOriginInfoDTO.getGridId()); //throw new RenException("gridInfoDTO is null gridId="+topicOriginInfoDTO.getGridId());
} }
// 一年的第几周 // 一年的第几周
String weekId = DateUtils.format(topicOriginInfoDTO.getOriginalBusinessTime(), DateUtils.DATE_PATTERN_YYYY).concat("W").concat(String.valueOf(DateUtils.getWeekOfYear(topicOriginInfoDTO.getOriginalBusinessTime()))); String weekId = DateUtils.format(topicOriginInfoDTO.getOriginalBusinessTime(), DateUtils.DATE_PATTERN_YYYY).concat("W").concat(String.valueOf(DateUtils.getWeekOfYear(topicOriginInfoDTO.getOriginalBusinessTime())));
@ -419,4 +418,4 @@ public class FactOriginTopicMainDailyServiceImpl extends BaseServiceImpl<FactOri
} }
} }

Loading…
Cancel
Save