Commit 7b4e0a35 authored by 赵啸非's avatar 赵啸非

添加首页统计模块 统计近一周

parent 323ccb21
...@@ -59,7 +59,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD ...@@ -59,7 +59,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD
List<PhQueueEntity> phQueueEntities = phQueueService.find(phQueueQuery); List<PhQueueEntity> phQueueEntities = phQueueService.find(phQueueQuery);
log.info("更新站点评价统计数据,站点ID:{},站点名称:{},日期:{},评价数量:{}", entity.getSiteId(), entity.getSiteName(), currentDate, phQueueEntities.size()); log.info("更新站点排队统计数据,站点ID:{},站点名称:{},日期:{},排队数量:{}", entity.getSiteId(), entity.getSiteName(), currentDate, phQueueEntities.size());
updateSitePhCount(entity, phQueueEntities); updateSitePhCount(entity, phQueueEntities);
//部门 //部门
...@@ -123,7 +123,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD ...@@ -123,7 +123,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD
List<PhQueueEntity> value = item.getValue(); List<PhQueueEntity> value = item.getValue();
Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D); Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D);
log.info("更新站点评价统计数据,站点名称:{},日期:{},部门:{},评价数量:{}", entity.getSiteName(), currentDate, entity.getSectionName(), phQueueEntities.size()); log.info("更新站点排队统计数据,站点名称:{},日期:{},部门:{},排队数量:{}", entity.getSiteName(), currentDate, entity.getSectionName(), phQueueEntities.size());
PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery() PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery()
.siteId(entity.getSiteId()) .siteId(entity.getSiteId())
.sectionName(sectionName) .sectionName(sectionName)
...@@ -168,7 +168,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD ...@@ -168,7 +168,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD
if (ObjectUtils.isEmpty(hallName)) return; if (ObjectUtils.isEmpty(hallName)) return;
List<PhQueueEntity> value = item.getValue(); List<PhQueueEntity> value = item.getValue();
Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D); Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D);
log.info("更新站点评价统计数据,站点名称:{},日期:{},大厅:{},评价数量:{}", entity.getSiteName(), currentDate, entity.getHallName(), phQueueEntities.size()); log.info("更新站点排队统计数据,站点名称:{},日期:{},大厅:{},排队数量:{}", entity.getSiteName(), currentDate, entity.getHallName(), phQueueEntities.size());
PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery() PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery()
.siteId(entity.getSiteId()) .siteId(entity.getSiteId())
.hallName(hallName) .hallName(hallName)
...@@ -213,7 +213,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD ...@@ -213,7 +213,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD
if (ObjectUtils.isEmpty(bussiness)) return; if (ObjectUtils.isEmpty(bussiness)) return;
List<PhQueueEntity> value = item.getValue(); List<PhQueueEntity> value = item.getValue();
Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D); Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D);
log.info("更新站点评价统计数据,站点名称:{},日期:{},业务:{},评价数量:{}", entity.getSiteName(), currentDate, entity.getBusiness(), phQueueEntities.size()); log.info("更新站点排队统计数据,站点名称:{},日期:{},业务:{},排队数量:{}", entity.getSiteName(), currentDate, entity.getBusiness(), phQueueEntities.size());
PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery() PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery()
.siteId(entity.getSiteId()) .siteId(entity.getSiteId())
.business(bussiness) .business(bussiness)
...@@ -257,7 +257,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD ...@@ -257,7 +257,7 @@ public class PhQueueStatServiceImpl extends AbstractCRUDServiceImpl<PhQueueStatD
if (ObjectUtils.isEmpty(window)) return; if (ObjectUtils.isEmpty(window)) return;
List<PhQueueEntity> value = item.getValue(); List<PhQueueEntity> value = item.getValue();
Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D); Double intAvg = value.stream().mapToInt(e -> e.getWaitTime()).average().orElse(0D);
log.info("更新站点评价统计数据,站点名称:{},日期:{},业务:{},评价数量:{}", entity.getSiteName(), currentDate, entity.getBusiness(), phQueueEntities.size()); log.info("更新站点排队统计数据,站点名称:{},日期:{},业务:{},排队数量:{}", entity.getSiteName(), currentDate, entity.getBusiness(), phQueueEntities.size());
PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery() PhQueueStatEntity phQueueStatEntity = this.selectOne(new PhQueueStatQuery()
.siteId(entity.getSiteId()) .siteId(entity.getSiteId())
.windowFromnum(window) .windowFromnum(window)
......
...@@ -48,7 +48,7 @@ Content-Type: application/json ...@@ -48,7 +48,7 @@ Content-Type: application/json
{ {
"pjTimeStart": "2023-01-01", "pjTimeStart": "2023-01-01",
"pjTimeEnd": "2024-07-10" "pjTimeEnd": "2024-07-14"
} }
###排队 ###排队
...@@ -56,8 +56,8 @@ POST {{baseUrl}}/ph/queue/stat/stat ...@@ -56,8 +56,8 @@ POST {{baseUrl}}/ph/queue/stat/stat
Content-Type: application/json Content-Type: application/json
{ {
"taketimeStart": "2024-06-01", "taketimeStart": "2024-07-01",
"taketimeEnd": "2024-07-10" "taketimeEnd": "2024-07-15"
} }
...@@ -66,8 +66,8 @@ POST {{baseUrl}}/stat/stat ...@@ -66,8 +66,8 @@ POST {{baseUrl}}/stat/stat
Content-Type: application/json Content-Type: application/json
{ {
"createTimeStart": "2023-04-01", "createTimeStart": "2023-01-01",
"createTimeEnd": "2024-07-10" "createTimeEnd": "2024-07-15"
} }
......
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