Browse Source

工作日志新增按日统计采集接口v1暂存

dev_shibei_match
yinzuomei 5 years ago
parent
commit
664c57387d
  1. 7
      epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/controller/project/ProjectController.java
  2. 57
      epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordGridDailyFormDTO.java
  3. 7
      epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordGridMonthlyDTO.java
  4. 57
      epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordOrgDailyFormDTO.java
  5. 7
      epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordOrgMonthlyDTO.java
  6. 47
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/plugins/WorkRecordColController.java
  7. 7
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/plugins/ScreenWorkRecordGridMonthlyEntity.java
  8. 7
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/plugins/ScreenWorkRecordOrgMonthlyEntity.java
  9. 94
      epmet-module/data-statistical/data-statistical-server/src/main/resources/db/migration/V0.0.8__add_plugins_table.sql

7
epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/controller/project/ProjectController.java

@ -137,7 +137,7 @@ public class ProjectController {
/**
* @param customerId
* @param formDTO
* @description 事件分析数量统计查询
* @description 事件分析数量统计查询 平阴大屏
**/
@PostMapping("queryquantity")
public Result<ProjectQuantityResultDTO> queryQuantity(@RequestHeader("CustomerId") String customerId, @RequestBody ScreenCommonFormDTO formDTO){
@ -149,7 +149,7 @@ public class ProjectController {
* @param customerId
* @param formDTO
* @author yinzuomei
* @description 近12个月事件分析月度数量分析
* @description 近12个月事件分析月度数量分析 平阴大屏
**/
@PostMapping("queryquantity-monthly")
public Result<QueryQuantityMonthlyResultDTO> queryQuantityMonthly(@RequestHeader("CustomerId") String customerId, @RequestBody QueryQuantityMonthlyFormDTO formDTO) {
@ -162,7 +162,7 @@ public class ProjectController {
* @param customerId
* @param formDTO
* @author yinzuomei
* @description 事件分析效率分析
* @description 事件分析效率分析 平阴大屏
**/
@PostMapping("efficiency-analysis")
public Result<List<EfficiencyAnalysisResultDTO>> efficiencyAnalysis(@RequestHeader("CustomerId") String customerId, @RequestBody EfficiencyAnalysisFormDTO formDTO){
@ -171,4 +171,5 @@ public class ProjectController {
return new Result<List<EfficiencyAnalysisResultDTO>>().ok(projectOrgDailyService.efficiencyAnalysis(formDTO));
}
//todo 【事件类型分析】
}

57
epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordGridDailyFormDTO.java

@ -0,0 +1,57 @@
package com.epmet.dto.plugins;
import lombok.Data;
import java.io.Serializable;
/**
* 工作日志-网格按日统计(累计值)
*
* @author yinzuomei@elink-cn.com
* @date 2021/2/21 18:48
*/
@Data
public class ScreenWorkRecordGridDailyFormDTO implements Serializable {
private static final long serialVersionUID = 5993623581944585517L;
/**
* 网格id
*/
private String gridId;
/**
* 网格所属的组织id
*/
private String agencyId;
/**
* 会议类型编码对应screen_customer_work_record_dict的资源编码
*/
private String meetingCode;
/**
* 随手记类型编码对应screen_customer_work_record_dict的资源编码
*/
private String typeCode;
/**
* 组织次数
*/
private Integer organizeTotal;
/**
* 当前组织参与的总次数
*/
private Integer participateTotal;
/**
* 参与人数
*/
private Integer participateUserTotal;
/**
* 平均参与人数
*/
private Integer avgParticipateUserTotal;
}

7
epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordGridMonthlyDTO.java

@ -17,9 +17,10 @@
package com.epmet.dto.plugins;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
@ -79,12 +80,12 @@ public class ScreenWorkRecordGridMonthlyDTO implements Serializable {
private Integer participateTotal;
/**
* 总的参与次
* 参与人
*/
private Integer participateUserTotal;
/**
* 平均参与人
* 平均参与人
*/
private Integer avgParticipateUserTotal;

57
epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordOrgDailyFormDTO.java

@ -0,0 +1,57 @@
package com.epmet.dto.plugins;
import lombok.Data;
import java.io.Serializable;
/**
* 工作日志-组织按日统计(累计值)
*
* @author yinzuomei@elink-cn.com
* @date 2021/2/21 18:49
*/
@Data
public class ScreenWorkRecordOrgDailyFormDTO implements Serializable {
private static final long serialVersionUID = 819322082786098071L;
/**
* 组织Id
*/
private String orgId;
/**
* 当前组织所属上级组织如果是跟组织此列为0
*/
private String parentId;
/**
* 会议类型编码对应screen_customer_work_record_dict的资源编码
*/
private String meetingCode;
/**
* 随手记类型编码对应screen_customer_work_record_dict的资源编码
*/
private String typeCode;
/**
* 组织次数
*/
private Integer organizeTotal;
/**
* 当前组织参与的总次数
*/
private Integer participateTotal;
/**
* 参与人数
*/
private Integer participateUserTotal;
/**
* 平均参与人数
*/
private Integer avgParticipateUserTotal;
}

7
epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/plugins/ScreenWorkRecordOrgMonthlyDTO.java

@ -17,9 +17,10 @@
package com.epmet.dto.plugins;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
@ -79,12 +80,12 @@ public class ScreenWorkRecordOrgMonthlyDTO implements Serializable {
private Integer participateTotal;
/**
* 总的参与次
* 参与人
*/
private Integer participateUserTotal;
/**
* 平均参与人
* 平均参与人
*/
private Integer avgParticipateUserTotal;

47
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/plugins/WorkRecordColController.java

@ -3,9 +3,7 @@ package com.epmet.controller.plugins;
import com.alibaba.fastjson.JSON;
import com.epmet.commons.tools.exception.ValidateException;
import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.plugins.ScreenCustomerWorkRecordDictDTO;
import com.epmet.dto.plugins.ScreenWorkRecordGridMonthlyDTO;
import com.epmet.dto.plugins.ScreenWorkRecordOrgMonthlyDTO;
import com.epmet.dto.plugins.*;
import com.epmet.dto.screencoll.ScreenCollFormDTO;
import com.epmet.service.plugins.ScreenCustomerWorkRecordDictService;
import com.epmet.service.plugins.ScreenWorkRecordGridMonthlyService;
@ -67,7 +65,7 @@ public class WorkRecordColController {
public Result collectGrid(@RequestHeader("CustomerId")String customerId, @RequestBody ScreenCollFormDTO<ScreenWorkRecordGridMonthlyDTO> data){
if(StringUtils.isBlank(customerId) || CollectionUtils.isEmpty(data.getDataList()) ||
StringUtils.isBlank(data.getMonthId())) {
log.error("com.epmet.controller.plugins.WorkRecordColController.resourceDict,param:{}", JSON.toJSONString(data));
log.error("com.epmet.controller.plugins.WorkRecordColController.collectGrid,param:{}", JSON.toJSONString(data));
throw new ValidateException("客户Id、上传数据列表、月份Id不可为空");
}
gridMonthlyService.collect(customerId,data);
@ -86,7 +84,7 @@ public class WorkRecordColController {
public Result collectOrg(@RequestHeader("CustomerId")String customerId, @RequestBody ScreenCollFormDTO<ScreenWorkRecordOrgMonthlyDTO> data){
if(StringUtils.isBlank(customerId) || CollectionUtils.isEmpty(data.getDataList()) ||
StringUtils.isBlank(data.getMonthId())) {
log.error("com.epmet.controller.plugins.WorkRecordColController.resourceDict,param:{}", JSON.toJSONString(data));
log.error("com.epmet.controller.plugins.WorkRecordColController.collectOrg,param:{}", JSON.toJSONString(data));
throw new ValidateException("客户Id、上传数据列表、月份Id不可为空");
}
orgMonthlyService.collect(customerId,data);
@ -94,4 +92,43 @@ public class WorkRecordColController {
}
/**
* @Description 工作日志网格按日统计 累计值
* @param customerId
* @param data
* @return com.epmet.commons.tools.utils.Result
* @author wangc
* @date 2021.02.04 16:16
*/
@PostMapping("grid-daily")
public Result collectGridDaily(@RequestHeader("CustomerId")String customerId, @RequestBody ScreenCollFormDTO<ScreenWorkRecordGridDailyFormDTO> data){
if(StringUtils.isBlank(customerId) || CollectionUtils.isEmpty(data.getDataList()) ||
StringUtils.isBlank(data.getDateId())) {
log.error("com.epmet.controller.plugins.WorkRecordColController.collectGridDaily,param:{}", JSON.toJSONString(data));
throw new ValidateException("客户Id、上传数据列表、日期Id不可为空");
}
//todo
// gridMonthlyService.collectGridDaily(customerId,data);
return new Result();
}
/**
* @Description 工作日志组织按日统计 累计值
* @param customerId
* @param data
* @return com.epmet.commons.tools.utils.Result
* @author wangc
* @date 2021.02.04 16:16
*/
@PostMapping("org-daily")
public Result collectOrgDaily(@RequestHeader("CustomerId")String customerId, @RequestBody ScreenCollFormDTO<ScreenWorkRecordOrgDailyFormDTO> data){
if(StringUtils.isBlank(customerId) || CollectionUtils.isEmpty(data.getDataList()) ||
StringUtils.isBlank(data.getDateId())) {
log.error("com.epmet.controller.plugins.WorkRecordColController.collectOrgDaily,param:{}", JSON.toJSONString(data));
throw new ValidateException("客户Id、上传数据列表、日期Id不可为空");
}
//todo
// orgMonthlyService.collectOrgDaily(customerId,data);
return new Result();
}
}

7
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/plugins/ScreenWorkRecordGridMonthlyEntity.java

@ -18,13 +18,10 @@
package com.epmet.entity.plugins;
import com.baomidou.mybatisplus.annotation.TableName;
import com.epmet.commons.mybatis.entity.BaseEpmetEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.Date;
/**
* 工作日志-网格按月统计
*
@ -79,12 +76,12 @@ public class ScreenWorkRecordGridMonthlyEntity extends BaseEpmetEntity {
private Integer participateTotal;
/**
* 总的参与次
* 参与人
*/
private Integer participateUserTotal;
/**
* 平均参与人
* 平均参与人
*/
private Integer avgParticipateUserTotal;

7
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/plugins/ScreenWorkRecordOrgMonthlyEntity.java

@ -18,13 +18,10 @@
package com.epmet.entity.plugins;
import com.baomidou.mybatisplus.annotation.TableName;
import com.epmet.commons.mybatis.entity.BaseEpmetEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.Date;
/**
* 工作日志-组织按月统计
*
@ -79,12 +76,12 @@ public class ScreenWorkRecordOrgMonthlyEntity extends BaseEpmetEntity {
private Integer participateTotal;
/**
* 总的参与次
* 参与人
*/
private Integer participateUserTotal;
/**
* 平均参与人
* 平均参与人
*/
private Integer avgParticipateUserTotal;

94
epmet-module/data-statistical/data-statistical-server/src/main/resources/db/migration/V0.0.8__add_plugins_table.sql

@ -64,7 +64,30 @@ CREATE TABLE `screen_list_info` (
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='146:一张清单列表';
-- 2、工作日志新增3张表
-- 2、工作日志新增
drop table if EXISTS screen_customer_work_record_dict;
CREATE TABLE `screen_customer_work_record_dict` (
`ID` varchar(32) NOT NULL COMMENT '主键(客户每次上传,直接根据customerId全删全增)',
`CUSTOMER_ID` varchar(64) NOT NULL COMMENT '客户Id',
`DATE_ID` varchar(8) NOT NULL COMMENT '数据更新至日期eg:20200101',
`DICT_ID` varchar(32) NOT NULL COMMENT '资源id',
`PID` varchar(32) NOT NULL COMMENT '父资源ID;如果是一级分类pid=0',
`RESOURCE_TYPE` varchar(32) DEFAULT NULL COMMENT '资源类型',
`RESOURCE_CODE` varchar(32) NOT NULL COMMENT '资源编码',
`RESOURCE_LABEL` varchar(128) NOT NULL COMMENT '资源标签名',
`SHOW_FLAG` varchar(1) NOT NULL COMMENT '显示标识:0否,1是',
`SORT` int(10) NOT NULL DEFAULT '0' COMMENT '排序',
`DATA_TYPE` varchar(32) DEFAULT 'party' COMMENT '数据类别 :party:支部建设; union:联合建设;党员志愿服务:voluntaryservice;所有的一级分类需要对应到这三个key中',
`LEVEL` int(11) NOT NULL COMMENT '当前资源属于几级,例如:1、2、3、4....',
`DEL_FLAG` varchar(1) NOT NULL COMMENT '逻辑删除标识',
`REVISION` int(11) NOT NULL COMMENT '乐观锁',
`CREATED_BY` varchar(32) NOT NULL COMMENT '创建人',
`CREATED_TIME` datetime NOT NULL COMMENT '创建时间',
`UPDATED_BY` varchar(32) NOT NULL COMMENT '更新人',
`UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志资源字典表';
drop table if EXISTS screen_work_record_grid_monthly;
CREATE TABLE `screen_work_record_grid_monthly` (
`ID` varchar(64) NOT NULL COMMENT 'ID 主键',
@ -76,8 +99,8 @@ CREATE TABLE `screen_work_record_grid_monthly` (
`TYPE_CODE` varchar(255) NOT NULL COMMENT '随手记类型编码;对应screen_customer_work_record_dict的资源编码',
`ORGANIZE_TOTAL` int(11) NOT NULL COMMENT '组织次数',
`PARTICIPATE_TOTAL` int(11) NOT NULL COMMENT '当前组织参与的总次数',
`PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '总的参与次',
`AVG_PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '平均参与人',
`PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '参与人',
`AVG_PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '平均参与人',
`DEL_FLAG` char(1) NOT NULL DEFAULT '0' COMMENT '删除标识 0未删除;1已删除',
`REVISION` int(11) NOT NULL DEFAULT '0' COMMENT '乐观锁',
`CREATED_BY` varchar(64) NOT NULL COMMENT '创建人',
@ -85,7 +108,7 @@ CREATE TABLE `screen_work_record_grid_monthly` (
`UPDATED_BY` varchar(64) NOT NULL COMMENT '更新人',
`UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志-网格按月统计';
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志-网格按月统计(增量)';
drop table if EXISTS screen_work_record_org_monthly;
CREATE TABLE `screen_work_record_org_monthly` (
@ -98,8 +121,8 @@ CREATE TABLE `screen_work_record_org_monthly` (
`TYPE_CODE` varchar(255) NOT NULL COMMENT '随手记类型编码;对应screen_customer_work_record_dict的资源编码',
`ORGANIZE_TOTAL` int(11) NOT NULL COMMENT '组织次数',
`PARTICIPATE_TOTAL` int(11) NOT NULL COMMENT '当前组织参与的总次数',
`PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '总的参与次',
`AVG_PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '平均参与人',
`PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '参与人',
`AVG_PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '平均参与人',
`DEL_FLAG` char(1) NOT NULL DEFAULT '0' COMMENT '删除标识 0未删除;1已删除',
`REVISION` int(11) NOT NULL DEFAULT '0' COMMENT '乐观锁',
`CREATED_BY` varchar(64) NOT NULL COMMENT '创建人',
@ -107,27 +130,48 @@ CREATE TABLE `screen_work_record_org_monthly` (
`UPDATED_BY` varchar(64) NOT NULL COMMENT '更新人',
`UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志-组织按月统计';
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志-组织按月统计(增量)';
drop table if EXISTS screen_customer_work_record_dict;
CREATE TABLE `screen_customer_work_record_dict` (
`ID` varchar(32) NOT NULL COMMENT '主键(客户每次上传,直接根据customerId全删全增)',
drop table if EXISTS screen_work_record_grid_daily;
CREATE TABLE `screen_work_record_grid_daily` (
`ID` varchar(64) NOT NULL COMMENT 'ID 主键',
`CUSTOMER_ID` varchar(64) NOT NULL COMMENT '客户Id',
`DATE_ID` varchar(8) NOT NULL COMMENT '数据更新至日期eg:20200101',
`DICT_ID` varchar(32) NOT NULL COMMENT '资源id',
`PID` varchar(32) NOT NULL COMMENT '父资源ID;如果是一级分类pid=0',
`RESOURCE_TYPE` varchar(32) DEFAULT NULL COMMENT '资源类型',
`RESOURCE_CODE` varchar(32) NOT NULL COMMENT '资源编码',
`RESOURCE_LABEL` varchar(128) NOT NULL COMMENT '资源标签名',
`SHOW_FLAG` varchar(1) NOT NULL COMMENT '显示标识:0否,1是',
`SORT` int(10) NOT NULL DEFAULT '0' COMMENT '排序',
`DATA_TYPE` varchar(32) DEFAULT 'party' COMMENT '数据类别 :party:支部建设; union:联合建设;党员志愿服务:voluntaryservice;所有的一级分类需要对应到这三个key中',
`LEVEL` int(11) NOT NULL COMMENT '当前资源属于几级,例如:1、2、3、4....',
`DEL_FLAG` varchar(1) NOT NULL COMMENT '逻辑删除标识',
`REVISION` int(11) NOT NULL COMMENT '乐观锁',
`CREATED_BY` varchar(32) NOT NULL COMMENT '创建人',
`DATE_ID` varchar(8) NOT NULL COMMENT '日期Id:yyyyMMdd',
`GRID_ID` varchar(64) NOT NULL COMMENT '网格id',
`AGENCY_ID` varchar(64) NOT NULL COMMENT '网格所属的组织id',
`MEETING_CODE` varchar(255) NOT NULL COMMENT '会议类型编码;对应screen_customer_work_record_dict的资源编码',
`TYPE_CODE` varchar(255) NOT NULL COMMENT '随手记类型编码;对应screen_customer_work_record_dict的资源编码',
`ORGANIZE_TOTAL` int(11) NOT NULL COMMENT '组织次数',
`PARTICIPATE_TOTAL` int(11) NOT NULL COMMENT '当前组织参与的总次数',
`PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '参与人数',
`AVG_PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '平均参与人数',
`DEL_FLAG` char(1) NOT NULL DEFAULT '0' COMMENT '删除标识 0未删除;1已删除',
`REVISION` int(11) NOT NULL DEFAULT '0' COMMENT '乐观锁',
`CREATED_BY` varchar(64) NOT NULL COMMENT '创建人',
`CREATED_TIME` datetime NOT NULL COMMENT '创建时间',
`UPDATED_BY` varchar(32) NOT NULL COMMENT '更新人',
`UPDATED_BY` varchar(64) NOT NULL COMMENT '更新人',
`UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志-网格按日统计(累计值)';
drop table if EXISTS screen_work_record_org_daily;
CREATE TABLE `screen_work_record_org_daily` (
`ID` varchar(64) NOT NULL COMMENT 'ID 主键',
`CUSTOMER_ID` varchar(64) NOT NULL COMMENT '客户Id',
`DATE_ID` varchar(8) NOT NULL COMMENT '日期Id:yyyyMMdd',
`ORG_ID` varchar(64) NOT NULL COMMENT '组织Id',
`PARENT_ID` varchar(64) NOT NULL COMMENT '当前组织所属上级组织,如果是跟组织,此列为0',
`MEETING_CODE` varchar(255) DEFAULT NULL COMMENT '会议类型编码;对应screen_customer_work_record_dict的资源编码',
`TYPE_CODE` varchar(255) NOT NULL COMMENT '随手记类型编码;对应screen_customer_work_record_dict的资源编码',
`ORGANIZE_TOTAL` int(11) NOT NULL COMMENT '组织次数',
`PARTICIPATE_TOTAL` int(11) NOT NULL COMMENT '当前组织参与的总次数',
`PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '参与人数',
`AVG_PARTICIPATE_USER_TOTAL` int(11) NOT NULL COMMENT '平均参与人数',
`DEL_FLAG` char(1) NOT NULL DEFAULT '0' COMMENT '删除标识 0未删除;1已删除',
`REVISION` int(11) NOT NULL DEFAULT '0' COMMENT '乐观锁',
`CREATED_BY` varchar(64) NOT NULL COMMENT '创建人',
`CREATED_TIME` datetime NOT NULL COMMENT '创建时间',
`UPDATED_BY` varchar(64) NOT NULL COMMENT '更新人',
`UPDATED_TIME` datetime NOT NULL COMMENT '更新时间',
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志资源字典表';
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='工作日志-组织按日统计(累计值)';
Loading…
Cancel
Save