forked from luyan/epmet-cloud-lingshan
jianjun
4 years ago
28 changed files with 371 additions and 19 deletions
@ -0,0 +1,19 @@ |
|||
package com.epmet.service; |
|||
|
|||
/** |
|||
* @Description |
|||
* @Author zhaoqifeng |
|||
* @Date 2022/3/15 10:09 |
|||
*/ |
|||
public interface HistoryDataService { |
|||
/** |
|||
* 网格员立项来源改为work_event |
|||
* |
|||
* @Param customerId |
|||
* @Return |
|||
* @Author zhaoqifeng |
|||
* @Date 2022/3/15 10:13 |
|||
*/ |
|||
void projectAddGridId(String customerId); |
|||
|
|||
} |
|||
@ -0,0 +1,75 @@ |
|||
package com.epmet.service.impl; |
|||
|
|||
import com.epmet.commons.tools.utils.ConvertUtils; |
|||
import com.epmet.constant.RoleKeyConstants; |
|||
import com.epmet.dto.org.CustomerStaffGridDTO; |
|||
import com.epmet.dto.user.result.StaffRoleInfoDTO; |
|||
import com.epmet.service.HistoryDataService; |
|||
import com.epmet.service.evaluationindex.extract.todata.FactOriginProjectMainDailyService; |
|||
import com.epmet.service.evaluationindex.screen.ScreenProjectDataService; |
|||
import com.epmet.service.org.CustomerGridService; |
|||
import com.epmet.service.project.ProjectService; |
|||
import com.epmet.service.user.UserService; |
|||
import org.apache.commons.collections4.CollectionUtils; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import javax.annotation.Resource; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
import java.util.function.Function; |
|||
import java.util.stream.Collectors; |
|||
|
|||
/** |
|||
* @Description |
|||
* @Author zhaoqifeng |
|||
* @Date 2022/3/15 10:12 |
|||
*/ |
|||
@Service |
|||
public class HistoryDataServiceImpl implements HistoryDataService { |
|||
@Resource |
|||
CustomerGridService customerGridService; |
|||
@Resource |
|||
private UserService userService; |
|||
@Resource |
|||
private ProjectService projectService; |
|||
@Resource |
|||
private FactOriginProjectMainDailyService factOriginProjectMainDailyService; |
|||
@Resource |
|||
private ScreenProjectDataService screenProjectDataService; |
|||
|
|||
/** |
|||
* 网格员立项来源改为work_event |
|||
* |
|||
* @param customerId |
|||
* @Param customerId |
|||
* @Return |
|||
* @Author zhaoqifeng |
|||
* @Date 2022/3/15 10:13 |
|||
*/ |
|||
@Override |
|||
public void projectAddGridId(String customerId) { |
|||
List<CustomerStaffGridDTO> staffGridList = customerGridService.getCustomerStaffGridList(customerId); |
|||
List<StaffRoleInfoDTO> staffInfoList = userService.getStaffByRoleKey(customerId, RoleKeyConstants.ROLE_KEY_GRID_MEMBER); |
|||
if (CollectionUtils.isEmpty(staffGridList) || CollectionUtils.isEmpty(staffInfoList)) { |
|||
return; |
|||
} |
|||
Map<String, StaffRoleInfoDTO> staffMap = staffInfoList.stream().collect(Collectors.toMap(StaffRoleInfoDTO :: getStaffId, |
|||
Function.identity())); |
|||
List<CustomerStaffGridDTO> list = staffGridList.stream().filter(p -> null != staffMap.get(p.getStaffId())).map(item -> { |
|||
StaffRoleInfoDTO staffInfo = staffMap.get(item.getStaffId()); |
|||
CustomerStaffGridDTO dto = ConvertUtils.sourceToTarget(item, CustomerStaffGridDTO.class); |
|||
dto.setStaffId(staffInfo.getStaffId()); |
|||
return dto; |
|||
}).collect(Collectors.toList()); |
|||
|
|||
list.forEach(part -> { |
|||
//更新project表
|
|||
projectService.updateHistoryData(part); |
|||
//更新fact_origin_project_main_daily
|
|||
factOriginProjectMainDailyService.updateHistoryData(part); |
|||
//更新screen_project_data
|
|||
screenProjectDataService.updateHistoryData(part); |
|||
}); |
|||
|
|||
} |
|||
} |
|||
@ -0,0 +1,86 @@ |
|||
CREATE TABLE `memo_attachment` ( |
|||
`ID` varchar(64) NOT NULL COMMENT '主键', |
|||
`CUSTOMER_ID` varchar(64) NOT NULL COMMENT '客户ID', |
|||
`REMIND_MSG_ID` varchar(64) NOT NULL COMMENT 'REMIND_MSG.ID 业务(工作日志、难点堵点、人员关怀)表Id', |
|||
`FILE_NAME` varchar(255) DEFAULT NULL COMMENT '文件名', |
|||
`ATTACHMENT_NAME` varchar(64) DEFAULT NULL COMMENT '附件名（uuid随机生成）', |
|||
`ATTACHMENT_SIZE` int(11) DEFAULT NULL COMMENT '文件大小，单位b', |
|||
`ATTACHMENT_FORMAT` varchar(64) NOT NULL COMMENT '文件格式（JPG、PNG、PDF、JPEG、BMP、MP4、WMA、M4A、MP3、DOC、DOCX、XLS）', |
|||
`ATTACHMENT_TYPE` varchar(64) NOT NULL COMMENT '附件类型（（图片 - image、 视频 - video、 语音 - voice、 文档 - doc））', |
|||
`ATTACHMENT_URL` varchar(255) NOT NULL COMMENT '附件地址', |
|||
`DURATION` int(11) DEFAULT '0' COMMENT '语音或视频时长,秒', |
|||
`SORT` int(1) NOT NULL COMMENT '排序字段', |
|||
`DEL_FLAG` varchar(1) NOT NULL COMMENT '删除标记 0：未删除，1：已删除', |
|||
`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`) USING BTREE |
|||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=COMPACT COMMENT='备忘录-附件表'; |
|||
|
|||
CREATE TABLE `memo_attr` ( |
|||
`ID` varchar(32) NOT NULL COMMENT '唯一标识', |
|||
`CUSTOMER_ID` varchar(64) NOT NULL COMMENT '客户ID', |
|||
`REMIND_TIME` datetime DEFAULT NULL COMMENT '提醒时间', |
|||
`TYPE` varchar(32) NOT NULL COMMENT '业务类型 人员关怀：concern；难点堵点：difficulty；工作日志：work_diary', |
|||
`READ_FLAG` tinyint(1) NOT NULL DEFAULT '0' COMMENT '阅读标记1 已读；0未读', |
|||
`RECEIVER` varchar(32) NOT NULL COMMENT '接收人ID', |
|||
`DEL_FLAG` char(1) NOT NULL COMMENT '删除标识：0.未删除 1.已删除', |
|||
`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`) USING BTREE |
|||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='备忘录-属性(通知)表'; |
|||
|
|||
CREATE TABLE `memo_concern` ( |
|||
`ID` varchar(32) NOT NULL COMMENT '唯一标识(同memo_attr表Id)', |
|||
`CUSTOMER_ID` varchar(32) NOT NULL COMMENT '客户ID', |
|||
`CONCERN_TYPE` varchar(64) DEFAULT NULL COMMENT '关怀类型', |
|||
`RESI_NAME` varchar(64) NOT NULL COMMENT '关怀人员', |
|||
`PHONE` varchar(64) DEFAULT NULL COMMENT '关怀对象电话', |
|||
`ADDRESS` varchar(64) DEFAULT NULL COMMENT '关怀对象地址', |
|||
`CONTENT` varchar(1024) NOT NULL COMMENT '关怀事项', |
|||
`SCHEDULED_TIME` datetime DEFAULT NULL COMMENT '预计关怀时间', |
|||
`ACTUAL_TIME` datetime DEFAULT NULL COMMENT '实际执行时间(预留字段)', |
|||
`STATUS` tinyint(1) NOT NULL DEFAULT '0' COMMENT '状态 0未完成 1已完成', |
|||
`DEL_FLAG` char(1) NOT NULL COMMENT '删除标识：0.未删除 1.已删除', |
|||
`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`) USING BTREE |
|||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='备忘录-人文关怀'; |
|||
|
|||
CREATE TABLE `memo_difficulty` ( |
|||
`ID` varchar(32) NOT NULL COMMENT '唯一标识(同memo_attr表Id)', |
|||
`CUSTOMER_ID` varchar(32) NOT NULL COMMENT '客户ID', |
|||
`CONTENT` varchar(1024) NOT NULL COMMENT '内容', |
|||
`RESOLVE_WAY` varchar(512) DEFAULT NULL COMMENT '解决方式', |
|||
`REMARK` varchar(255) DEFAULT NULL COMMENT '备注', |
|||
`SCHEDULED_TIME` datetime DEFAULT NULL COMMENT '预计处理时间', |
|||
`DEL_FLAG` char(1) NOT NULL COMMENT '删除标识：0.未删除 1.已删除', |
|||
`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`) USING BTREE |
|||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='备忘录-难点读点'; |
|||
|
|||
CREATE TABLE `memo_work_diary` ( |
|||
`ID` varchar(32) NOT NULL COMMENT '唯一标识(同memo_attr表Id)', |
|||
`CUSTOMER_ID` varchar(64) NOT NULL COMMENT '客户ID', |
|||
`CONTENT` varchar(1024) NOT NULL COMMENT '内容', |
|||
`WORK_TYPE` varchar(64) DEFAULT NULL COMMENT '工作事项', |
|||
`DEL_FLAG` char(1) NOT NULL COMMENT '删除标识：0.未删除 1.已删除', |
|||
`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`) USING BTREE |
|||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='备忘录-工作日志'; |
|||
Loading…
Reference in new issue