|
|
@ -25,6 +25,7 @@ import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Objects; |
|
|
|
import java.util.Optional; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
@ -73,15 +74,15 @@ public class DfCheckingRecordV2Service extends BaseService<DfCheckingRecordV2Map |
|
|
|
.filter(StringUtils::isNotBlank) |
|
|
|
.ifPresent(status -> queryWrapper.like(DfCheckingRecord::getStatus, status)); |
|
|
|
|
|
|
|
Optional.ofNullable(data.getStartDate()) |
|
|
|
.filter(startDate -> startDate != null) |
|
|
|
.ifPresent(startDate -> queryWrapper.ge(DfCheckingRecord::getStartDate, startDate)); |
|
|
|
|
|
|
|
Optional.ofNullable(data.getEndDate()) |
|
|
|
.filter(endDate -> endDate != null) |
|
|
|
.ifPresent(endDate -> queryWrapper.le(DfCheckingRecord::getEndDate, endDate)); |
|
|
|
} |
|
|
|
if (!Objects.isNull(data.getStartDate())) { |
|
|
|
queryWrapper.ge(DfCheckingRecord::getStartDate, data.getStartDate()); |
|
|
|
} |
|
|
|
|
|
|
|
if (!Objects.isNull(data.getEndDate())) { |
|
|
|
queryWrapper.le(DfCheckingRecord::getStartDate, data.getEndDate()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
// 查询分页数据
|
|
|
|
Page<DfCheckingRecord> queryPage = page(page, queryWrapper); |
|
|
@ -109,18 +110,18 @@ public class DfCheckingRecordV2Service extends BaseService<DfCheckingRecordV2Map |
|
|
|
public DfRecordDetailV2Dto getInfo(String id) { |
|
|
|
DfRecordDetailV2Dto dto = new DfRecordDetailV2Dto(); |
|
|
|
DfCheckingRecord dfCheckingRecord = getById(id); |
|
|
|
if (dfCheckingRecord != null) { |
|
|
|
if (dfCheckingRecord == null) { |
|
|
|
return dto; |
|
|
|
} |
|
|
|
BeanUtils.copyProperties(dfCheckingRecord, dto); |
|
|
|
|
|
|
|
List<DfCheckingV2ProjectItem> items = dfCheckingV2ProjectItemV2Service.list( |
|
|
|
Wrappers.<DfCheckingV2ProjectItem>lambdaQuery() |
|
|
|
.eq(DfCheckingV2ProjectItem::getCheckingId, id) |
|
|
|
.eq(DfCheckingV2ProjectItem::getCheckingId, dfCheckingRecord.getCheckingId()) |
|
|
|
); |
|
|
|
dto.setItems(items.stream() |
|
|
|
.map(DfCheckingV2Service::convertToItemDto) |
|
|
|
.collect(Collectors.toList())); |
|
|
|
} |
|
|
|
assert dfCheckingRecord != null; |
|
|
|
List<DfCheckingProblemV2> recordsList = dfCheckingProblemV2Service.list(new LambdaQueryWrapper<DfCheckingProblemV2>() |
|
|
|
.eq(DfCheckingProblemV2::getRecordId, dfCheckingRecord.getId())); |
|
|
|
List<DfRecordDetailV2Dto.DfRecordItemDetailV2Dto> dtoList = new ArrayList<>(); |
|
|
@ -160,8 +161,9 @@ public class DfCheckingRecordV2Service extends BaseService<DfCheckingRecordV2Map |
|
|
|
// 提交时缺陷无数据就是无缺陷
|
|
|
|
dfCheckingRecord.setStatus(DfYhV2StatusEnum.NO_DEFECTS.getValue()); |
|
|
|
} |
|
|
|
saveOrUpdate(dfCheckingRecord); |
|
|
|
mySaveOrUpdate(dfCheckingRecord); |
|
|
|
dfRecord.setStatus(dfCheckingRecord.getStatus()); |
|
|
|
dfRecord.setRecordId(dfCheckingRecord.getId()); |
|
|
|
dfCheckingProblemV2Service.saveOrUpdateBatch(convertToImages(dfRecord)); |
|
|
|
return dfRecord; |
|
|
|
} else { |
|
|
@ -169,13 +171,23 @@ public class DfCheckingRecordV2Service extends BaseService<DfCheckingRecordV2Map |
|
|
|
BeanUtils.copyProperties(dfRecord, dfCheckingRecord); |
|
|
|
// 未提交维巡查中
|
|
|
|
dfCheckingRecord.setStatus(DfYhV2StatusEnum.DURING_INSPECTION.getValue()); |
|
|
|
saveOrUpdate(dfCheckingRecord); |
|
|
|
mySaveOrUpdate(dfCheckingRecord); |
|
|
|
dfRecord.setStatus(DfYhV2StatusEnum.DURING_INSPECTION.getValue()); |
|
|
|
dfRecord.setRecordId(dfCheckingRecord.getId()); |
|
|
|
dfCheckingProblemV2Service.saveOrUpdateBatch(convertToImages(dfRecord)); |
|
|
|
return dfRecord; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public void mySaveOrUpdate (DfCheckingRecord dfCheckingRecord) { |
|
|
|
Boolean flag = org.springframework.util.StringUtils.isEmpty(dfCheckingRecord.getId()) ? Boolean.TRUE :Boolean.FALSE; |
|
|
|
if (flag) { |
|
|
|
save(dfCheckingRecord); |
|
|
|
}else { |
|
|
|
updateById(dfCheckingRecord); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public void myRemovePraIds(DfRecordDetailV2Dto dfRecord) { |
|
|
|
List<String> ids = dfRecord.getProblems() |
|
|
|
.stream() |
|
|
@ -192,7 +204,7 @@ public class DfCheckingRecordV2Service extends BaseService<DfCheckingRecordV2Map |
|
|
|
DfCheckingProblemV2 dfCheckingProblemV2 = new DfCheckingProblemV2(); |
|
|
|
BeanUtils.copyProperties(e, dfCheckingProblemV2); |
|
|
|
dfCheckingProblemV2.setCheckingId(dfRecord.getCheckingId()); |
|
|
|
dfCheckingProblemV2.setRecordId(dfRecord.getId()); |
|
|
|
dfCheckingProblemV2.setRecordId(dfRecord.getRecordId()); |
|
|
|
dfCheckingProblemV2.setCheckingName(dfRecord.getCheckingName()); |
|
|
|
dfCheckingProblemV2.setDikeCode(dfRecord.getDikeCode()); |
|
|
|
dfCheckingProblemV2.setDikeName(dfRecord.getDikeName()); |
|
|
|