|
|
|
@ -54,18 +54,13 @@ import org.apache.poi.ss.usermodel.*; |
|
|
|
import org.apache.poi.xssf.streaming.SXSSFSheet; |
|
|
|
import org.apache.poi.xssf.streaming.SXSSFWorkbook; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.http.HttpHeaders; |
|
|
|
import org.springframework.http.MediaType; |
|
|
|
import org.springframework.http.ResponseEntity; |
|
|
|
import org.springframework.web.bind.annotation.*; |
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
|
import javax.servlet.ServletOutputStream; |
|
|
|
import javax.servlet.http.HttpServletResponse; |
|
|
|
import java.io.ByteArrayInputStream; |
|
|
|
import java.io.ByteArrayOutputStream; |
|
|
|
import java.io.IOException; |
|
|
|
import java.io.InputStream; |
|
|
|
import java.io.*; |
|
|
|
import java.nio.file.Files; |
|
|
|
import java.nio.file.Path; |
|
|
|
import java.nio.file.Paths; |
|
|
|
@ -193,6 +188,9 @@ public class PatrolTaskController extends BaseController { |
|
|
|
patrolTaskStatus.setTaskCode(task.getTaskCode()); |
|
|
|
patrolTaskStatus.setTaskState(TaskStatus.RUNNING.getCode()); |
|
|
|
List<PatrolTaskStatus> statusList = patrolTaskStatusService.selectPatrolTaskStatusList(patrolTaskStatus); |
|
|
|
String taskMajorId = task.getTaskCode(); |
|
|
|
int totalPoints = patrolTaskInfoService.countPatrolTaskInfoByMajorId(taskMajorId); |
|
|
|
task.setTotalPoints(totalPoints); |
|
|
|
if (!statusList.isEmpty()) { |
|
|
|
task.setFileStatus("1"); |
|
|
|
} else { |
|
|
|
@ -424,25 +422,25 @@ public class PatrolTaskController extends BaseController { |
|
|
|
// 生产设备 模糊匹配 |
|
|
|
if (StringUtils.isNotEmpty(patrolTaskStatus.getDeviceName())) { |
|
|
|
newList = newList.stream().filter((element) -> |
|
|
|
element.getDeviceName().contains(patrolTaskStatus.getDeviceName()) |
|
|
|
element.getDeviceName().contains(patrolTaskStatus.getDeviceName()) |
|
|
|
).collect(Collectors.toList()); |
|
|
|
} |
|
|
|
// 点位名称 模糊匹配 |
|
|
|
if (StringUtils.isNotEmpty(patrolTaskStatus.getPointName())) { |
|
|
|
newList = newList.stream().filter((element) -> |
|
|
|
element.getPointName().contains(patrolTaskStatus.getPointName()) |
|
|
|
element.getPointName().contains(patrolTaskStatus.getPointName()) |
|
|
|
).collect(Collectors.toList()); |
|
|
|
} |
|
|
|
// 相机名称 模糊匹配 |
|
|
|
if (StringUtils.isNotEmpty(patrolTaskStatus.getChannelName())) { |
|
|
|
newList = newList.stream().filter((element) -> |
|
|
|
element.getChannelName().contains(patrolTaskStatus.getChannelName()) |
|
|
|
element.getChannelName().contains(patrolTaskStatus.getChannelName()) |
|
|
|
).collect(Collectors.toList()); |
|
|
|
} |
|
|
|
// 来源系统 模糊匹配 |
|
|
|
if (StringUtils.isNotEmpty(patrolTaskStatus.getDeviceSource())) { |
|
|
|
newList = newList.stream().filter((element) -> |
|
|
|
element.getDeviceSource().contains(patrolTaskStatus.getDeviceSource()) |
|
|
|
element.getDeviceSource().contains(patrolTaskStatus.getDeviceSource()) |
|
|
|
).collect(Collectors.toList()); |
|
|
|
} |
|
|
|
|
|
|
|
@ -763,8 +761,8 @@ public class PatrolTaskController extends BaseController { |
|
|
|
List<Map<String, String>> list = new ArrayList<>(); |
|
|
|
Map<String, Map<String, String>> eqpBooksMap = new HashMap<>(); |
|
|
|
if (eqpBookIds.size() > 0) { |
|
|
|
list = patrolTaskInfoService.selectVideoPosByPointIdByEqpbookIds(eqpBookIds); |
|
|
|
eqpBooksMap = list.stream().collect(Collectors.toMap(e -> String.valueOf(e.get("eqp_book_id")), e -> e, (e1, e2) -> e2)); |
|
|
|
list = patrolTaskInfoService.selectVideoPosByPointIdByEqpbookIds(eqpBookIds); |
|
|
|
eqpBooksMap = list.stream().collect(Collectors.toMap(e -> String.valueOf(e.get("eqp_book_id")), e -> e, (e1, e2) -> e2)); |
|
|
|
} |
|
|
|
List<PatrolTaskInfo> patrolTaskInfoListDb = new ArrayList<>(); |
|
|
|
Map<String, PatrolTaskInfo> patrolTaskInfoMap = new HashMap<>(); |
|
|
|
|