视频监控分页修改

security-protection-service/src/main/java/com/ai/bss/security/protection/service/impl/MonitorSceneTerminalServiceImpl.java

@@ -7,6 +7,7 @@ import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.components.common.util.JsonUtils;
import com.ai.bss.security.protection.service.interfaces.MonitorSceneTerminalService;
import com.ai.bss.work.safety.model.MonitorSceneTerminalRel;
import com.ai.bss.work.safety.service.api.AiTaskQuery;
import com.ai.bss.work.safety.service.api.MonitorSceneCommand;
import com.ai.bss.work.safety.service.api.MonitorSceneQuery;
import lombok.extern.slf4j.Slf4j;
@@ -14,6 +15,8 @@ import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -26,6 +29,9 @@ public class MonitorSceneTerminalServiceImpl implements MonitorSceneTerminalServ
    @Autowired
    private MonitorSceneQuery monitorSceneQuery;
    @Autowired
    private AiTaskQuery aiTaskQuery;
    @Override
    public CommonResponse<MonitorSceneTerminalRel> createMonitorSceneTerminalRel(MonitorSceneTerminalRel monitorSceneTerminalRel) {
        if(monitorSceneTerminalRel.getMonitorSceneId()==null){
@@ -94,10 +100,31 @@ public class MonitorSceneTerminalServiceImpl implements MonitorSceneTerminalServ
        String monitorSceneId = paramMap.get("monitorSceneId");
        Integer pageNumber = paramMap.get("pageNumber")==null?1:Integer.parseInt(paramMap.get("pageNumber"));
        Integer pageSize = paramMap.get("pageSize")==null?10:Integer.parseInt(paramMap.get("pageSize"));
        CommonRequest<Long> request = CommonRequest.<Long>builder().data(3L).build();
        CommonRequest<Long> request = CommonRequest.<Long>builder().data(Long.parseLong(monitorSceneId)).build();
        request.setPageNumber(pageNumber);
        request.setPageSize(pageSize);
        CommonResponse<PageBean<Map<String, Object>>> result = monitorSceneQuery.selectSceneTerminalRelByPage(request);
        List<Map<String, Object>> sceneTerminalRelList = result.getData().getData();
        if(sceneTerminalRelList!=null&&sceneTerminalRelList.size()>0){
            sceneTerminalRelList.forEach((sceneTerminalRel)->{
                String resourceToolId = (String) sceneTerminalRel.get("resourceToolId");
                if(resourceToolId!=null){
                    HashMap<String, Object> conditionMap = new HashMap<>();
                    conditionMap.put("resourceToolId", resourceToolId);
                    CommonResponse<List<Map<String,Object>>> aiTaskCommonResponse = aiTaskQuery.selectAiTaskDevice(CommonRequest.<Map<String,Object>>builder().data(conditionMap).build());
                    List<Map<String, Object>> aiTaskDeviceList = aiTaskCommonResponse.getData();
                    ArrayList<String> aiTaskNameList = new ArrayList<>();
                    aiTaskDeviceList.forEach((aiTaskDevice)->{
                        if(null!=aiTaskDevice.get("aiTaskName")){
                            aiTaskNameList.add((String) aiTaskDevice.get("aiTaskName"));
                        }
                    });
                    sceneTerminalRel.put("aiTaskNameList",aiTaskNameList);
                    sceneTerminalRel.put("aiTaskDeviceList",aiTaskDeviceList);
                }
            });
        }
        return result;