|
@@ -2,6 +2,7 @@ package cn.cslg.pas.service.business;
|
|
|
|
|
|
import cn.cslg.pas.common.dto.business.EventDTO;
|
|
|
import cn.cslg.pas.common.dto.business.EventUpdateDTO;
|
|
|
+import cn.cslg.pas.common.dto.business.UpdateEventDTO;
|
|
|
import cn.cslg.pas.common.model.cronModel.*;
|
|
|
import cn.cslg.pas.common.model.request.*;
|
|
|
|
|
@@ -81,7 +82,7 @@ public class EventService extends ServiceImpl<EventMapper, Event> implements Bus
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public Object queryMessage(QueryRequest queryRequest) throws Exception {
|
|
|
|
|
|
- List<String> sqls = formatQueryService.reSqls(queryRequest);
|
|
|
+ List<String> sqls = formatQueryService.reSqls(queryRequest,"event");
|
|
|
//根据sql查询事件信息
|
|
|
List<EventVO> eventVOS = eventMapper.getEvent(sqls.get(0),sqls.get(1),sqls.get(2));
|
|
|
|
|
@@ -182,34 +183,34 @@ public class EventService extends ServiceImpl<EventMapper, Event> implements Bus
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public Object updateMessage(Object object, List<MultipartFile> files) {
|
|
|
|
|
|
- EventUpdateDTO eventUpdateDTO = (EventUpdateDTO) object;
|
|
|
+ UpdateEventDTO updateEventDTO = (UpdateEventDTO) object;
|
|
|
//检查事件格式
|
|
|
- if (eventUpdateDTO == null || eventUpdateDTO.getId() == null) {
|
|
|
+ if (updateEventDTO == null || updateEventDTO.getId() == null) {
|
|
|
throw new XiaoShiException("参数错误");
|
|
|
|
|
|
}
|
|
|
- Event event = this.getById(eventUpdateDTO.getId());
|
|
|
+ Event event = this.getById(updateEventDTO.getId());
|
|
|
//根据名称查询是否重复
|
|
|
- eventUpdateDTO.setName(eventUpdateDTO.getName().trim());
|
|
|
- String name = eventUpdateDTO.getName();
|
|
|
+ updateEventDTO.setName(updateEventDTO.getName().trim());
|
|
|
+ String name = updateEventDTO.getName();
|
|
|
LambdaQueryWrapper<Event> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
queryWrapper.eq(Event::getName, name);
|
|
|
List<Event> events = this.list(queryWrapper);
|
|
|
- if (eventUpdateDTO.getName() != event.getName() && events.size() != 0) {
|
|
|
+ if (updateEventDTO.getName() != event.getName() && events.size() != 0) {
|
|
|
throw new XiaoShiException("名称重复");
|
|
|
}
|
|
|
- BeanUtils.copyProperties(eventUpdateDTO, event);
|
|
|
+ BeanUtils.copyProperties(updateEventDTO, event);
|
|
|
event.updateById();
|
|
|
|
|
|
// 根据事件Id查询对应的附件Id
|
|
|
LambdaQueryWrapper<AssoEventFile> wrapper = new LambdaQueryWrapper<>();
|
|
|
- wrapper.eq(AssoEventFile::getEventId, eventUpdateDTO.getId());
|
|
|
+ wrapper.eq(AssoEventFile::getEventId, updateEventDTO.getId());
|
|
|
List<AssoEventFile> assoReportFiles = assoEventFileService.list(wrapper);
|
|
|
List<String> fileGuIds = assoReportFiles.stream().map(AssoEventFile::getFileGuid).collect(Collectors.toList());
|
|
|
// 获得事件更新后的附件Id
|
|
|
List<String> updateFilGuId = new ArrayList<>();
|
|
|
- if (eventUpdateDTO.getFileGuids() != null && eventUpdateDTO.getFileGuids().size() != 0) {
|
|
|
- updateFilGuId = eventUpdateDTO.getFileGuids();
|
|
|
+ if (updateEventDTO.getGuids() != null && updateEventDTO.getGuids().size() != 0) {
|
|
|
+ updateFilGuId = updateEventDTO.getGuids();
|
|
|
}
|
|
|
fileGuIds.retainAll(updateFilGuId);
|
|
|
//做差获得被删除的文件Id
|
|
@@ -260,11 +261,11 @@ public class EventService extends ServiceImpl<EventMapper, Event> implements Bus
|
|
|
public Object getGroup(GroupRequest groupRequest,String tableName) throws Exception {
|
|
|
StringRequest stringRequest =new StringRequest();
|
|
|
BeanUtils.copyProperties(groupRequest,stringRequest);
|
|
|
- List<String> sqls = formatQueryService.reSqls(stringRequest);
|
|
|
+ List<String> sqls = formatQueryService.reSqls(stringRequest,tableName);
|
|
|
//格式化 分组
|
|
|
GroupConfig groupConfig=null;
|
|
|
if (groupRequest.getGroupBy() != null) {
|
|
|
- String json = CommonService.readJsonFile("event.json");
|
|
|
+ String json = CommonService.readJsonFile(tableName+".json");
|
|
|
List<GroupConfig> groupConfigs = JSON.parseArray(json, GroupConfig.class);
|
|
|
groupConfig = groupConfigs.stream().filter(item -> groupRequest.getGroupBy().equals(item.getField())).findFirst().orElse(null);
|
|
|
if (groupConfig == null) {
|