|  |  | @ -198,6 +198,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  | 		if (null != formDTO && StringUtils.isNotBlank(formDTO.getCustomerId())) { | 
			
		
	
		
			
				
					|  |  |  | 			try { | 
			
		
	
		
			
				
					|  |  |  | 				log.info("tagUsedMonthlyStatsjob execute by customerId:{},dateId:{}", formDTO.getCustomerId(), dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 				statsTagUsedMonthly(dimIdBean.getMonthId(), formDTO.getCustomerId()); | 
			
		
	
		
			
				
					|  |  |  | 			} catch (Exception e) { | 
			
		
	
		
			
				
					|  |  |  | 				log.error(String.format(ProjectConstant.STATS_FAILED_PREFIX, "tagUsedMonthlyStatsjob", formDTO.getCustomerId(), dimIdBean.getMonthId()), e); | 
			
		
	
	
		
			
				
					|  |  | @ -206,6 +207,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 			int pageNo = NumConstant.ONE; | 
			
		
	
		
			
				
					|  |  |  | 			int pageSize = NumConstant.ONE_HUNDRED; | 
			
		
	
		
			
				
					|  |  |  | 			List<String> customerIdList = null; | 
			
		
	
		
			
				
					|  |  |  | 			log.info("tagUsedMonthlyStatsjob execute all customerId,dateId:{}", dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 			do { | 
			
		
	
		
			
				
					|  |  |  | 				customerIdList = dimCustomerService.selectCustomerIdPage(pageNo++, pageSize); | 
			
		
	
		
			
				
					|  |  |  | 				if (!CollectionUtils.isEmpty(customerIdList)) { | 
			
		
	
	
		
			
				
					|  |  | @ -228,6 +230,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 		DimIdGenerator.DimIdBean dimIdBean = DimIdGenerator.getDimIdBean(statsDate); | 
			
		
	
		
			
				
					|  |  |  | 		if (null != formDTO && StringUtils.isNotBlank(formDTO.getCustomerId())) { | 
			
		
	
		
			
				
					|  |  |  | 			try { | 
			
		
	
		
			
				
					|  |  |  | 				log.info("tagViewedDailyStatsjob execute by customerId:{},dateId:{}", formDTO.getCustomerId(), dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 				statsTagViewedDaily(statsDate, dimIdBean, formDTO.getCustomerId()); | 
			
		
	
		
			
				
					|  |  |  | 			} catch (Exception e) { | 
			
		
	
		
			
				
					|  |  |  | 				log.error(String.format(ProjectConstant.STATS_FAILED_PREFIX, "tagViewedDailyStatsjob", formDTO.getCustomerId(), dimIdBean.getMonthId()), e); | 
			
		
	
	
		
			
				
					|  |  | @ -236,6 +239,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 			int pageNo = NumConstant.ONE; | 
			
		
	
		
			
				
					|  |  |  | 			int pageSize = NumConstant.ONE_HUNDRED; | 
			
		
	
		
			
				
					|  |  |  | 			List<String> customerIdList = null; | 
			
		
	
		
			
				
					|  |  |  | 			log.info("tagViewedDailyStatsjob execute all customerId,dateId:{}", dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 			do { | 
			
		
	
		
			
				
					|  |  |  | 				customerIdList = dimCustomerService.selectCustomerIdPage(pageNo++, pageSize); | 
			
		
	
		
			
				
					|  |  |  | 				if (!CollectionUtils.isEmpty(customerIdList)) { | 
			
		
	
	
		
			
				
					|  |  | @ -259,6 +263,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 		DimIdGenerator.DimIdBean dimIdBean = DimIdGenerator.getDimIdBean(statsDate); | 
			
		
	
		
			
				
					|  |  |  | 		if (null != formDTO && StringUtils.isNotBlank(formDTO.getCustomerId())) { | 
			
		
	
		
			
				
					|  |  |  | 			try { | 
			
		
	
		
			
				
					|  |  |  | 				log.info("tagViewedMonthlyStatsjob execute by customerId:{},dateId:{}", formDTO.getCustomerId(), dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 				statsTagViewedMonthly(dimIdBean.getMonthId(), formDTO.getCustomerId()); | 
			
		
	
		
			
				
					|  |  |  | 			} catch (Exception e) { | 
			
		
	
		
			
				
					|  |  |  | 				log.error(String.format(ProjectConstant.STATS_FAILED_PREFIX, "tagViewedMonthlyStatsjob", formDTO.getCustomerId(), dimIdBean.getDateId()), e); | 
			
		
	
	
		
			
				
					|  |  | @ -267,6 +272,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 			int pageNo = NumConstant.ONE; | 
			
		
	
		
			
				
					|  |  |  | 			int pageSize = NumConstant.ONE_HUNDRED; | 
			
		
	
		
			
				
					|  |  |  | 			List<String> customerIdList = null; | 
			
		
	
		
			
				
					|  |  |  | 			log.info("tagViewedMonthlyStatsjob execute all customerId,dateId:{}", dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 			do { | 
			
		
	
		
			
				
					|  |  |  | 				customerIdList = dimCustomerService.selectCustomerIdPage(pageNo++, pageSize); | 
			
		
	
		
			
				
					|  |  |  | 				if (!CollectionUtils.isEmpty(customerIdList)) { | 
			
		
	
	
		
			
				
					|  |  | @ -289,6 +295,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 		DimIdGenerator.DimIdBean dimIdBean = DimIdGenerator.getDimIdBean(statsDate); | 
			
		
	
		
			
				
					|  |  |  | 		if (null != formDTO && StringUtils.isNotBlank(formDTO.getCustomerId())) { | 
			
		
	
		
			
				
					|  |  |  | 			try { | 
			
		
	
		
			
				
					|  |  |  | 				log.info("tagUsedQuarterlyStatsjob execute by customerId:{},dateId:{}", formDTO.getCustomerId(), dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 				try { | 
			
		
	
		
			
				
					|  |  |  | 					log.debug("start === statsTagUsedQuarterly "); | 
			
		
	
		
			
				
					|  |  |  | 					statsTagUsedQuarterly(dimIdBean.getQuarterId(), formDTO.getCustomerId()); | 
			
		
	
	
		
			
				
					|  |  | @ -305,6 +312,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 				log.error(String.format(ProjectConstant.STATS_FAILED_PREFIX, "tagViewedMonthlyStatsjob", formDTO.getCustomerId(), dimIdBean.getDateId()), e); | 
			
		
	
		
			
				
					|  |  |  | 			} | 
			
		
	
		
			
				
					|  |  |  | 		} else { | 
			
		
	
		
			
				
					|  |  |  | 			log.info("tagUsedQuarterlyStatsjob execute all customerId,dateId:{}", dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 			int pageNo = NumConstant.ONE; | 
			
		
	
		
			
				
					|  |  |  | 			int pageSize = NumConstant.ONE_HUNDRED; | 
			
		
	
		
			
				
					|  |  |  | 			List<String> customerIdList = null; | 
			
		
	
	
		
			
				
					|  |  | @ -336,6 +344,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 		Date statsDate = getStatsDateFromParam(formDTO); | 
			
		
	
		
			
				
					|  |  |  | 		DimIdGenerator.DimIdBean dimIdBean = DimIdGenerator.getDimIdBean(statsDate); | 
			
		
	
		
			
				
					|  |  |  | 		if (null != formDTO && StringUtils.isNotBlank(formDTO.getCustomerId())) { | 
			
		
	
		
			
				
					|  |  |  | 			log.info("tagViewedQuarterlyStatsjob execute by customerId:{},dateId:{}", formDTO.getCustomerId(), dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 			try { | 
			
		
	
		
			
				
					|  |  |  | 				log.debug("start === statsTagViewedQuarterly "); | 
			
		
	
		
			
				
					|  |  |  | 				statsTagViewedQuarterly(dimIdBean.getQuarterId(), formDTO.getCustomerId()); | 
			
		
	
	
		
			
				
					|  |  | @ -349,6 +358,7 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 				log.error(String.format(ProjectConstant.STATS_FAILED_PREFIX, "statsTagViewedQuarterly", formDTO.getCustomerId(), dimIdBean.getYearId()), e); | 
			
		
	
		
			
				
					|  |  |  | 			} | 
			
		
	
		
			
				
					|  |  |  | 		} else { | 
			
		
	
		
			
				
					|  |  |  | 			log.info("tagViewedQuarterlyStatsjob execute all customerId,dateId:{}", dimIdBean.getDateId()); | 
			
		
	
		
			
				
					|  |  |  | 			int pageNo = NumConstant.ONE; | 
			
		
	
		
			
				
					|  |  |  | 			int pageSize = NumConstant.ONE_HUNDRED; | 
			
		
	
		
			
				
					|  |  |  | 			List<String> customerIdList = null; | 
			
		
	
	
		
			
				
					|  |  | @ -474,7 +484,6 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 			} | 
			
		
	
		
			
				
					|  |  |  | 			boolean b = factArticlePublishedGridDailyService.deleteAndInsertBatch(customerId, dimIdBean.getDateId(), gridDailyEntityMap.values()); | 
			
		
	
		
			
				
					|  |  |  | 		} catch (Exception e) { | 
			
		
	
		
			
				
					|  |  |  | 			e.printStackTrace(); | 
			
		
	
		
			
				
					|  |  |  | 			log.error(String.format(ProjectConstant.STATS_FAILED_PREFIX, "statsPublishedGridDaily", customerId, statsDate), e); | 
			
		
	
		
			
				
					|  |  |  | 		} | 
			
		
	
		
			
				
					|  |  |  | 	} | 
			
		
	
	
		
			
				
					|  |  | @ -560,14 +569,10 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 	 * | 
			
		
	
		
			
				
					|  |  |  | 	 * @param statsDate | 
			
		
	
		
			
				
					|  |  |  | 	 * @param dimIdBean | 
			
		
	
		
			
				
					|  |  |  | 	 * @param customerId | 
			
		
	
		
			
				
					|  |  |  | 	 * @param customerId remark:获取当天发布的文章数据,然后根据文章标签 进行统计,加上默认标签的数量 没有则为0 | 
			
		
	
		
			
				
					|  |  |  | 	 */ | 
			
		
	
		
			
				
					|  |  |  | 	private void statsTagUsedDaily(Date statsDate, DimIdGenerator.DimIdBean dimIdBean, String customerId) { | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  | 		//1.业务数据来源 发布时间为统计时间的
 | 
			
		
	
		
			
				
					|  |  |  | 		// 因为一个客户的发布文章数在同一天不会特别的多,所以以客户为单位查询今天发布的所有带有标签的文章  根据发布单位类型进行拆分
 | 
			
		
	
		
			
				
					|  |  |  | 		//  1.1查出今天所有的文章标签 根据网格Id
 | 
			
		
	
		
			
				
					|  |  |  | 		//  1.2
 | 
			
		
	
		
			
				
					|  |  |  | 		//获取所有网格
 | 
			
		
	
		
			
				
					|  |  |  | 		List<DimAgencyEntity> agencyDTOList = dimAgencyService.getAgencyListByCustomerId(customerId); | 
			
		
	
		
			
				
					|  |  |  | 		if (CollectionUtils.isEmpty(agencyDTOList)) { | 
			
		
	
	
		
			
				
					|  |  | @ -715,14 +720,10 @@ public class StatsPublicityServiceImpl implements StatsPublicityService { | 
			
		
	
		
			
				
					|  |  |  | 	 * | 
			
		
	
		
			
				
					|  |  |  | 	 * @param statsDate | 
			
		
	
		
			
				
					|  |  |  | 	 * @param dimIdBean | 
			
		
	
		
			
				
					|  |  |  | 	 * @param customerId | 
			
		
	
		
			
				
					|  |  |  | 	 * @param customerId remark:根据统计时间的阅读文章记录,然后根据文章Id获取到对应的标签 然后 进行统计 | 
			
		
	
		
			
				
					|  |  |  | 	 */ | 
			
		
	
		
			
				
					|  |  |  | 	private void statsTagViewedDaily(Date statsDate, DimIdGenerator.DimIdBean dimIdBean, String customerId) { | 
			
		
	
		
			
				
					|  |  |  | 
 | 
			
		
	
		
			
				
					|  |  |  | 		//1.业务数据来源 发布时间为统计时间的
 | 
			
		
	
		
			
				
					|  |  |  | 		// 因为一个客户的发布文章数在同一天不会特别的多,所以以客户为单位查询今天发布的所有带有标签的文章  根据发布单位类型进行拆分
 | 
			
		
	
		
			
				
					|  |  |  | 		//  1.1查出今天所有的文章标签 根据网格Id
 | 
			
		
	
		
			
				
					|  |  |  | 		//  1.2
 | 
			
		
	
		
			
				
					|  |  |  | 		//获取所有机关 用于后面想上级添加数据
 | 
			
		
	
		
			
				
					|  |  |  | 		List<DimAgencyEntity> agencyDTOList = dimAgencyService.getAgencyListByCustomerId(customerId); | 
			
		
	
		
			
				
					|  |  |  | 		if (CollectionUtils.isEmpty(agencyDTOList)) { | 
			
		
	
	
		
			
				
					|  |  | 
 |