|
|
@@ -66,8 +66,7 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
|
|
|
@Resource
|
|
|
private IQuestionService questionService;
|
|
|
- // CoreSafety
|
|
|
-// @Resource
|
|
|
+
|
|
|
@Resource
|
|
|
RemoteRoleService remoteRoleService;
|
|
|
|
|
|
@@ -125,7 +124,7 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
|
|
|
@Override
|
|
|
public TaskRegisterVo<TaskRegisterAreaVo> info(Long id) {
|
|
|
- TaskRegisterVo<AppTaskRegisterPointVo> appvo = appInfo(id);
|
|
|
+ TaskRegisterVo<AppTaskRegisterPointVo> appvo = getPointVos(id);
|
|
|
|
|
|
TaskRegisterVo<TaskRegisterAreaVo> vo = new TaskRegisterVo<>();
|
|
|
BeanUtils.copyProperties(appvo, vo);
|
|
|
@@ -156,11 +155,35 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
areavo.getItemList().add(itemVo);
|
|
|
});
|
|
|
});
|
|
|
+
|
|
|
return vo;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public TaskRegisterVo<AppTaskRegisterPointVo> appInfo(Long id) {
|
|
|
+ public TaskRegisterVo<AppTaskRegisterItemVo> appInfo(Long id) {
|
|
|
+ TaskRegisterVo<AppTaskRegisterPointVo> baseData = getPointVos(id);
|
|
|
+ Map<Long, List<AppTaskRegisterPointVo>> groupByItem = baseData.getCheckList()
|
|
|
+ .stream()
|
|
|
+ .collect(Collectors.groupingBy(AppTaskRegisterPointVo::getItemId));
|
|
|
+
|
|
|
+ TaskRegisterVo<AppTaskRegisterItemVo> vo = new TaskRegisterVo<AppTaskRegisterItemVo>();
|
|
|
+ BeanUtils.copyProperties(baseData, vo);
|
|
|
+ List<AppTaskRegisterItemVo> itemVos = new ArrayList<>();
|
|
|
+ for (Long itemId : groupByItem.keySet()) {
|
|
|
+ List<AppTaskRegisterPointVo> pointVos = groupByItem.get(itemId);
|
|
|
+ AppTaskRegisterItemVo itemVo = new AppTaskRegisterItemVo();
|
|
|
+ itemVo.setItemId(pointVos.get(0).getItemId());
|
|
|
+ itemVo.setItemName(pointVos.get(0).getItemName());
|
|
|
+ itemVo.setPointList(pointVos);
|
|
|
+
|
|
|
+ itemVos.add(itemVo);
|
|
|
+ }
|
|
|
+ vo.setCheckList(itemVos);
|
|
|
+
|
|
|
+ return vo;
|
|
|
+ }
|
|
|
+
|
|
|
+ private TaskRegisterVo<AppTaskRegisterPointVo> getPointVos(Long id) {
|
|
|
CoreSafetyTask task = coreSafetyTaskMapper.selectById(id);
|
|
|
if (ObjectUtil.isNull(task)) {
|
|
|
throw new ServiceException("任务不存在");
|
|
|
@@ -192,8 +215,6 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
|
|
|
List<TaskRegisterNfcVo> nfcs = baseMapper.selectNfc(plan.getId(), id, task.getOrgId());
|
|
|
TaskRegisterVo<AppTaskRegisterPointVo> vo = TaskRegisterVo.of(task, plan.getCheckOrgType().toString(), StringUtils.join(roleNames, ","));
|
|
|
-
|
|
|
- vo.setCheckList(new ArrayList<>());
|
|
|
Set<Long> usedNfcId = new HashSet<>();
|
|
|
for (AppTaskRegisterPointVo point : points) {
|
|
|
List<CoreSafetyTaskDataRemarkimg> dataImgs = taskImgs.get(point.getPointDataId());
|
|
|
@@ -210,9 +231,9 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
.collect(Collectors.toList());
|
|
|
usedNfcId.addAll(areaNfcs.stream().map(TaskRegisterNfcVo::getNfcId).collect(Collectors.toList()));
|
|
|
point.setNfcList(areaNfcs);
|
|
|
-
|
|
|
- vo.getCheckList().add(point);
|
|
|
}
|
|
|
+ vo.setCheckList(points);
|
|
|
+
|
|
|
return vo;
|
|
|
}
|
|
|
|
|
|
@@ -223,8 +244,15 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
- public Boolean appSubmit(TaskRegisterVo<AppTaskRegisterPointVo> data) {
|
|
|
- return submit(data);
|
|
|
+ public Boolean appSubmit(TaskRegisterVo<AppTaskRegisterItemVo> data) {
|
|
|
+ TaskRegisterVo<AppTaskRegisterPointVo> pointData = new TaskRegisterVo<AppTaskRegisterPointVo>();
|
|
|
+ BeanUtils.copyProperties(data, pointData);
|
|
|
+ pointData.setCheckList(new ArrayList<>());
|
|
|
+ for (AppTaskRegisterItemVo itemVo : data.getCheckList()) {
|
|
|
+ pointData.getCheckList().addAll(itemVo.getPointList());
|
|
|
+ }
|
|
|
+
|
|
|
+ return submit(pointData);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -272,7 +300,6 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
|
|
|
removeExistData(data.getId());
|
|
|
|
|
|
-
|
|
|
List<CoreSafetyTaskData> points = new ArrayList();
|
|
|
List<CoreSafetyTaskDataNfc> nfcs = new ArrayList<>();
|
|
|
List<CoreSafetyTaskDataRemarkimg> remarkimgs = new ArrayList<>();
|
|
|
@@ -280,14 +307,18 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
for (AppTaskRegisterPointVo pointVo : data.getCheckList()) {
|
|
|
CoreSafetyTaskData point = dataVoToDomain(data, pointVo);
|
|
|
points.add(point);
|
|
|
- for (TaskRegisterNfcVo taskRegisterNfcVo : pointVo.getNfcList()) {
|
|
|
- CoreSafetyTaskDataNfc nfc = nfcVoToDomain(data, point, taskRegisterNfcVo);
|
|
|
- nfcs.add(nfc);
|
|
|
+ if (CollectionUtil.isNotEmpty(pointVo.getNfcList())) {
|
|
|
+ for (TaskRegisterNfcVo taskRegisterNfcVo : pointVo.getNfcList()) {
|
|
|
+ CoreSafetyTaskDataNfc nfc = nfcVoToDomain(data, point, taskRegisterNfcVo);
|
|
|
+ nfcs.add(nfc);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
- for (SafetyCheckDataRemarkingVo imgDatum : pointVo.getImgData()) {
|
|
|
- CoreSafetyTaskDataRemarkimg img = imgVoToDomain(data, point, imgDatum);
|
|
|
- remarkimgs.add(img);
|
|
|
+ if (CollectionUtil.isNotEmpty(pointVo.getImgData())) {
|
|
|
+ for (SafetyCheckDataRemarkingVo imgDatum : pointVo.getImgData()) {
|
|
|
+ CoreSafetyTaskDataRemarkimg img = imgVoToDomain(data, point, imgDatum);
|
|
|
+ remarkimgs.add(img);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
if (ObjectUtil.equal(point.getValue(), 1)) {
|
|
|
@@ -389,7 +420,8 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
.set(CoreSafetyTask::getSubmitTime, new Date())
|
|
|
.set(CoreSafetyTask::getSubmitorId, SecurityUtils.getUserId())
|
|
|
.set(CoreSafetyTask::getSubmitBy, SecurityUtils.getLoginUser().getName())
|
|
|
- .set(CoreSafetyTask::getExceptionCount, exceptionCount);
|
|
|
+ .set(CoreSafetyTask::getExceptionCount, exceptionCount)
|
|
|
+ .set(CoreSafetyTask::getCheckTeam, data.getCheckTeam());
|
|
|
return baseMapper.update(null, taskUpdateWraper) > 0;
|
|
|
}
|
|
|
|
|
|
@@ -411,6 +443,7 @@ public class SafetyCheckRegisterSericeImpl extends ServiceImpl<CoreSafetyTaskMap
|
|
|
public Boolean grant(GrantDto dto) {
|
|
|
LambdaQueryWrapper<CoreSafetyTask> wrapper = new LambdaQueryWrapper<>();
|
|
|
wrapper.eq(CoreSafetyTask::getPlanId, dto.getPlanId())
|
|
|
+ .eq(CoreSafetyTask::getOrgId,dto.getBeCheckedOrgId())
|
|
|
.eq(CoreSafetyTask::getYmdDate, dto.getYmdDate());
|
|
|
List<CoreSafetyTask> tasks = baseMapper.selectList(wrapper);
|
|
|
Optional<CoreSafetyTask> taskOptional = tasks.stream().filter(t -> ObjectUtil.equal(t.getId(), dto.getTaskId())).findFirst();
|