Browse Source

纠正 stats 代码

dev_shibei_match
jianjun 4 years ago
parent
commit
d6f2b17edd
  1. 2
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java
  2. 1
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/model/IndexExcelDataListener.java
  3. 5
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/impl/CustomerRelationServiceImpl.java
  4. 2
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactGridGovernDailyServiceImpl.java
  5. 4
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/todata/impl/FactOriginTopicMainDailyServiceImpl.java
  6. 1
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ShiBeiScreenCollServiceImpl.java
  7. 4
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/DataReportingServiceImpl.java
  8. 6
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsUserServiceImpl.java
  9. 2
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimQuarterServiceImpl.java
  10. 5
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/support/normalizing/ScoreCalculator.java

2
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DemoController.java

@ -158,7 +158,7 @@ public class DemoController {
*/ */
@GetMapping("testthreadpool") @GetMapping("testthreadpool")
public void testThreadPool() { public void testThreadPool() {
System.out.println(LocalDateTime.now().getSecond());; System.out.println(LocalDateTime.now().getSecond());
System.out.println("----------->>"); System.out.println("----------->>");
Future<Boolean> future1 = executorService.submit(() -> demoService.testThreadPool()); Future<Boolean> future1 = executorService.submit(() -> demoService.testThreadPool());

1
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/model/IndexExcelDataListener.java

@ -35,7 +35,6 @@ public class IndexExcelDataListener extends AnalysisEventListener<IndexModel> {
* 每隔5条存储数据库实际使用中可以3000条然后清理list 方便内存回收 * 每隔5条存储数据库实际使用中可以3000条然后清理list 方便内存回收
*/ */
private static volatile boolean isGroup = false; private static volatile boolean isGroup = false;
;
AtomicInteger total = new AtomicInteger(0); AtomicInteger total = new AtomicInteger(0);
Map<String, IndexDictEntity> indexDicMap = new HashMap<>(); Map<String, IndexDictEntity> indexDicMap = new HashMap<>();
Map<String, IndexGroupTemplateEntity> indexGroupMap = new HashMap<>(); Map<String, IndexGroupTemplateEntity> indexGroupMap = new HashMap<>();

5
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/crm/impl/CustomerRelationServiceImpl.java

@ -67,10 +67,7 @@ public class CustomerRelationServiceImpl extends BaseServiceImpl<CustomerRelatio
@Override @Override
public boolean haveSubCustomer(String customerId) { public boolean haveSubCustomer(String customerId) {
List<CustomerRelationEntity> list = baseDao.selectListByPids(customerId); List<CustomerRelationEntity> list = baseDao.selectListByPids(customerId);
if (null == list || list.isEmpty()) { return null != list && !list.isEmpty();
return false;
}
return true;
} }
/** /**

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

@ -307,7 +307,7 @@ public class FactGridGovernDailyServiceImpl extends BaseServiceImpl<FactGridGove
// 当前网格内出来的项目:由社区结案(已解决+未解决)的项目总数 // 当前网格内出来的项目:由社区结案(已解决+未解决)的项目总数
int communityClosedCount= NumConstant.ZERO; int communityClosedCount= NumConstant.ZERO;
// 当前网格内出来的项目:由街道结案(已解决+未解决)的项目总数 // 当前网格内出来的项目:由街道结案(已解决+未解决)的项目总数
int streetClosedCount=NumConstant.ZERO;; int streetClosedCount=NumConstant.ZERO;
// 当前网格内出来的项目:由街道结案(已解决+未解决)的项目总数 // 当前网格内出来的项目:由街道结案(已解决+未解决)的项目总数
int districtDeptClosedCount=NumConstant.ZERO; int districtDeptClosedCount=NumConstant.ZERO;

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

@ -215,7 +215,7 @@ public class FactOriginTopicMainDailyServiceImpl extends BaseServiceImpl<FactOri
//判断用户是否是党员,调用相成写的方法 //判断用户是否是党员,调用相成写的方法
//话题发布人是否是党员:1是党员0不是。 默认0 //话题发布人是否是党员:1是党员0不是。 默认0
if (null != userIsPartyMap && null != userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId())) { if (null != userIsPartyMap && null != userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId())) {
mainDailyEntity.setCreateTopicUserIsParty(userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId()) == NumConstant.ONE ? true : false); mainDailyEntity.setCreateTopicUserIsParty(userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId()) == NumConstant.ONE);
} else { } else {
mainDailyEntity.setCreateTopicUserIsParty(false); mainDailyEntity.setCreateTopicUserIsParty(false);
} }
@ -232,7 +232,7 @@ public class FactOriginTopicMainDailyServiceImpl extends BaseServiceImpl<FactOri
logDailyEntity.setPids(gridInfoDTO.getPids()); logDailyEntity.setPids(gridInfoDTO.getPids());
//判断用户是否是党员,调用相成写的方法 //判断用户是否是党员,调用相成写的方法
if (null != userIsPartyMap && null != userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId())) { if (null != userIsPartyMap && null != userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId())) {
logDailyEntity.setOperateUserIsParty(userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId()) == NumConstant.ONE ? true : false); logDailyEntity.setOperateUserIsParty(userIsPartyMap.get(topicOriginInfoDTO.getOperateUserId()) == NumConstant.ONE);
} else { } else {
logDailyEntity.setOperateUserIsParty(false); logDailyEntity.setOperateUserIsParty(false);
} }

1
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/screen/impl/ShiBeiScreenCollServiceImpl.java

@ -462,7 +462,6 @@ public class ShiBeiScreenCollServiceImpl implements ShiBeiScreenCollService {
int month = calendar.get(Calendar.MONTH) + NumConstant.ONE; int month = calendar.get(Calendar.MONTH) + NumConstant.ONE;
date[NumConstant.ZERO] = String.valueOf(year); date[NumConstant.ZERO] = String.valueOf(year);
date[NumConstant.ONE] = String.valueOf(month); date[NumConstant.ONE] = String.valueOf(month);
;
if (NumConstant.TEN >= month) { if (NumConstant.TEN >= month) {
date[NumConstant.ONE] = NumConstant.ZERO_STR + month; date[NumConstant.ONE] = NumConstant.ZERO_STR + month;
} }

4
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/DataReportingServiceImpl.java

@ -147,8 +147,8 @@ public class DataReportingServiceImpl implements DataReportingService {
if (StringUtils.isNotBlank(parentCustomer.getData())) { if (StringUtils.isNotBlank(parentCustomer.getData())) {
epmetCodeMap = customerProjectCategoryDictService.getByCategoryCodeMap(parentCustomer.getData()); epmetCodeMap = customerProjectCategoryDictService.getByCategoryCodeMap(parentCustomer.getData());
} }
Map<String, CustomerProjectCategoryDictEntity> codeMap = customerProjectCategoryDictService.getByCategoryCodeMap(formDTO.getCustomerId());; Map<String, CustomerProjectCategoryDictEntity> codeMap = customerProjectCategoryDictService.getByCategoryCodeMap(formDTO.getCustomerId());
//项目ID不为空时,因为只有一条,可以直接处理 //项目ID不为空时,因为只有一条,可以直接处理
Map<String, CustomerProjectCategoryDictEntity> finalEpmetCodeMap = epmetCodeMap; Map<String, CustomerProjectCategoryDictEntity> finalEpmetCodeMap = epmetCodeMap;
if (CollectionUtils.isNotEmpty(formDTO.getProjectId())) { if (CollectionUtils.isNotEmpty(formDTO.getProjectId())) {
list = projectList.stream().map(project -> { list = projectList.stream().map(project -> {

6
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsUserServiceImpl.java

@ -178,7 +178,7 @@ public class StatsUserServiceImpl implements StatsUserService {
while (iterator.hasNext()) { while (iterator.hasNext()) {
GmUploadEventFormDTO.DataList m = iterator.next(); GmUploadEventFormDTO.DataList m = iterator.next();
AtomicReference<Boolean> bl = new AtomicReference<>(false); AtomicReference<Boolean> bl = new AtomicReference<>(false);
StringBuffer gridPids = new StringBuffer(""); StringBuffer gridPids = new StringBuffer();
agencyList.forEach(ag -> { agencyList.forEach(ag -> {
if (m.getAgencyId().equals(ag.getId())) { if (m.getAgencyId().equals(ag.getId())) {
bl.set(true); bl.set(true);
@ -239,8 +239,8 @@ public class StatsUserServiceImpl implements StatsUserService {
while (iterator.hasNext()) { while (iterator.hasNext()) {
GmUploadDataFormDTO.DataList m = iterator.next(); GmUploadDataFormDTO.DataList m = iterator.next();
AtomicReference<Boolean> bl = new AtomicReference<>(false); AtomicReference<Boolean> bl = new AtomicReference<>(false);
StringBuffer pid = new StringBuffer(""); StringBuffer pid = new StringBuffer();
StringBuffer pids = new StringBuffer(""); StringBuffer pids = new StringBuffer();
agencyList.forEach(ag -> { agencyList.forEach(ag -> {
if (m.getAgencyId().equals(ag.getId())) { if (m.getAgencyId().equals(ag.getId())) {
bl.set(true); bl.set(true);

2
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimQuarterServiceImpl.java

@ -122,7 +122,7 @@ public class DimQuarterServiceImpl extends BaseServiceImpl<DimQuarterDao, DimQua
Date now = new Date(); Date now = new Date();
Date endQMonth = DateUtils.integrate(now, DateUtils.DATE_PATTERN_YYYYMM);;//初始化至当季 Date endQMonth = DateUtils.integrate(now, DateUtils.DATE_PATTERN_YYYYMM);//初始化至当季
Date startQMonth;//从该季开始初始化,不包含该季 Date startQMonth;//从该季开始初始化,不包含该季
if (latestDimEntity == null) { if (latestDimEntity == null) {

5
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/support/normalizing/ScoreCalculator.java

@ -159,10 +159,7 @@ public abstract class ScoreCalculator<T> {
* @return * @return
*/ */
protected <T> boolean validSourceArray(T[] sourceArray) { protected <T> boolean validSourceArray(T[] sourceArray) {
if (sourceArray == null || sourceArray.length == 0) { return sourceArray != null && sourceArray.length != 0;
return false;
}
return true;
} }
/** /**

Loading…
Cancel
Save