|
@@ -27,6 +27,7 @@ import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
import java.util.Objects;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* 延期预警跟进表 服务实现.
|
|
@@ -62,11 +63,13 @@ public class TBDelayWarnServiceImpl extends ServiceImpl<TBDelayWarnMapper, TBDel
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
- public IPage<TBDelayWarnResult> query(IPage<Map> iPage, DelayWarnTypeEnum type, DelayWarnStatusEnum status, Long serviceId, String custom, String fieldObj, String sopNo, Long startTime, Long endTime, Long id) {
|
|
|
+ public IPage<TBDelayWarnResult> query(IPage<Map> iPage, DelayWarnTypeEnum type, List<DelayWarnStatusEnum> status,
|
|
|
+ Long serviceId, String custom, String fieldObj, String sopNo, Long startTime, Long endTime, Long id) {
|
|
|
SysUser requestUser = (SysUser) ServletUtil.getRequestUser();
|
|
|
DataPermissionDto dpr = sysUserService.buildUserDataPermission(requestUser.getId());
|
|
|
List<String> fieldObjList = new ArrayList<>();
|
|
|
- if (Objects.nonNull(fieldObj) && ProcessLimitedEnum.PROJECT_KEY_INFO_DATE.getTitle().contains(fieldObj.trim())) {
|
|
|
+ if (Objects.nonNull(fieldObj) && ProcessLimitedEnum.PROJECT_KEY_INFO_DATE.getTitle()
|
|
|
+ .contains(fieldObj.trim())) {
|
|
|
fieldObjList.add(ProcessLimitedEnum.PROJECT_KEY_INFO_DATE.getKey());
|
|
|
}
|
|
|
if (Objects.nonNull(fieldObj) && ProcessLimitedEnum.APPROVE_RADIO.getTitle().contains(fieldObj.trim())) {
|
|
@@ -84,7 +87,8 @@ public class TBDelayWarnServiceImpl extends ServiceImpl<TBDelayWarnMapper, TBDel
|
|
|
if (Objects.nonNull(fieldObj) && ProcessLimitedEnum.MARK_END_TIME.getTitle().contains(fieldObj.trim())) {
|
|
|
fieldObjList.add(ProcessLimitedEnum.MARK_END_TIME.getKey());
|
|
|
}
|
|
|
- if (Objects.nonNull(fieldObj) && ProcessLimitedEnum.SERVICE_FINISH_PLAN_DATE.getTitle().contains(fieldObj.trim())) {
|
|
|
+ if (Objects.nonNull(fieldObj) && ProcessLimitedEnum.SERVICE_FINISH_PLAN_DATE.getTitle()
|
|
|
+ .contains(fieldObj.trim())) {
|
|
|
fieldObjList.add(ProcessLimitedEnum.SERVICE_FINISH_PLAN_DATE.getKey());
|
|
|
}
|
|
|
if (Objects.nonNull(fieldObj) && ProcessLimitedEnum.ENV_DEPLOYMENT_TIME.getTitle().contains(fieldObj.trim())) {
|
|
@@ -93,7 +97,10 @@ public class TBDelayWarnServiceImpl extends ServiceImpl<TBDelayWarnMapper, TBDel
|
|
|
if (Objects.nonNull(fieldObj) && CollectionUtils.isEmpty(fieldObjList)) {
|
|
|
fieldObjList.add(fieldObj);
|
|
|
}
|
|
|
- return this.baseMapper.query(iPage, Objects.nonNull(type) ? type.name() : null, Objects.nonNull(status) ? status.name() : null, serviceId, custom, fieldObjList, sopNo, startTime, endTime, id, dpr);
|
|
|
+ return this.baseMapper.query(iPage, Objects.nonNull(type) ? type.name() : null,
|
|
|
+ !CollectionUtils.isEmpty(status) ?
|
|
|
+ status.stream().map(s -> s.name()).collect(Collectors.toList()) :
|
|
|
+ null, serviceId, custom, fieldObjList, sopNo, startTime, endTime, id, dpr);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -115,8 +122,10 @@ public class TBDelayWarnServiceImpl extends ServiceImpl<TBDelayWarnMapper, TBDel
|
|
|
} catch (Exception e) {
|
|
|
if (e instanceof DuplicateKeyException) {
|
|
|
String errorColumn = e.getCause().toString();
|
|
|
- String columnStr = errorColumn.substring(errorColumn.lastIndexOf("key") + 3, errorColumn.length()).replaceAll("'", "");
|
|
|
- throw ExceptionResultEnum.SQL_ERROR.exception("[" + FieldUniqueEnum.convertToTitle(columnStr) + "]数据不允许重复插入");
|
|
|
+ String columnStr = errorColumn.substring(errorColumn.lastIndexOf("key") + 3, errorColumn.length())
|
|
|
+ .replaceAll("'", "");
|
|
|
+ throw ExceptionResultEnum.SQL_ERROR.exception(
|
|
|
+ "[" + FieldUniqueEnum.convertToTitle(columnStr) + "]数据不允许重复插入");
|
|
|
} else if (e instanceof ApiException) {
|
|
|
ResultUtil.error((ApiException) e, ((ApiException) e).getCode(), e.getMessage());
|
|
|
} else {
|
|
@@ -140,7 +149,8 @@ public class TBDelayWarnServiceImpl extends ServiceImpl<TBDelayWarnMapper, TBDel
|
|
|
|
|
|
@Override
|
|
|
public TBDelayWarnResult get(long id) {
|
|
|
- IPage<TBDelayWarnResult> resultIPage = query(new Page<>(1, 1), null, null, null, null, null, null, null, null, id);
|
|
|
+ IPage<TBDelayWarnResult> resultIPage = query(new Page<>(1, 1), null, null, null, null, null, null, null, null,
|
|
|
+ id);
|
|
|
TBDelayWarnResult tbDelayWarnResult = resultIPage.getRecords().get(0);
|
|
|
List<TBDelayWarnDetail> tbDelayWarnDetails = tBDelayWarnDetailService.list(id);
|
|
|
tbDelayWarnResult.setTbDelayWarnDetails(tbDelayWarnDetails);
|
|
@@ -159,10 +169,12 @@ public class TBDelayWarnServiceImpl extends ServiceImpl<TBDelayWarnMapper, TBDel
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
- public IPage<WorkWarnResult> getWarnTaskList(IPage<Map> iPage, Long userId, WarnTypeEnum type, Long serviceId, String customName) {
|
|
|
+ public IPage<WorkWarnResult> getWarnTaskList(IPage<Map> iPage, Long userId, WarnTypeEnum type, Long serviceId,
|
|
|
+ String customName) {
|
|
|
SysUser sysUser = (SysUser) ServletUtil.getRequestUser();
|
|
|
userId = Objects.nonNull(sysUser) ? sysUser.getId() : userId;
|
|
|
- return this.baseMapper.getWarnTaskList(iPage, userId, Objects.nonNull(type) ? type.name() : null, serviceId, customName);
|
|
|
+ return this.baseMapper.getWarnTaskList(iPage, userId, Objects.nonNull(type) ? type.name() : null, serviceId,
|
|
|
+ customName);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -178,6 +190,7 @@ public class TBDelayWarnServiceImpl extends ServiceImpl<TBDelayWarnMapper, TBDel
|
|
|
public int getWarnTaskListCount(Long userId, WarnTypeEnum type, Long serviceId, String customName) {
|
|
|
SysUser sysUser = (SysUser) ServletUtil.getRequestUser();
|
|
|
userId = Objects.nonNull(sysUser) ? sysUser.getId() : userId;
|
|
|
- return this.baseMapper.getWarnTaskListCount(userId, Objects.nonNull(type) ? type.name() : null, serviceId, customName);
|
|
|
+ return this.baseMapper.getWarnTaskListCount(userId, Objects.nonNull(type) ? type.name() : null, serviceId,
|
|
|
+ customName);
|
|
|
}
|
|
|
}
|