package com.sandu.ximon.admin.service; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.ListUtil; import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.util.HexUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; import com.sandu.common.execption.BusinessException; import com.sandu.common.object.BaseConditionVO; import com.sandu.common.service.impl.BaseServiceImpl; import com.sandu.common.util.SpringContextHolder; import com.sandu.ximon.admin.dto.PlcTaskDto; import com.sandu.ximon.admin.dto.PlcTaskDto; import com.sandu.ximon.admin.dto.SingleLightOrderDto; import com.sandu.ximon.admin.manager.iot.frame.FrameBuilder; import com.sandu.ximon.admin.manager.iot.frame.IRequestFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.request.A7PlcTimerReqInnerFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.response.A7PlcTimerRespInnerFrame; import com.sandu.ximon.admin.manager.iot.rrpc.dto.WrapResponseCommonFrame; import com.sandu.ximon.admin.manager.iot.rrpc.enums.A7OrderEnum; import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService; import com.sandu.ximon.admin.manager.iot.rrpc.util.SupplementUtils; import com.sandu.ximon.admin.param.PlcTaskIssueParam; import com.sandu.ximon.admin.param.PlcTaskParam; import com.sandu.ximon.admin.security.SecurityUtils; import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils; import com.sandu.ximon.admin.utils.TaskOrderUtil; import com.sandu.ximon.admin.vo.*; import com.sandu.ximon.dao.domain.*; import com.sandu.ximon.dao.enums.DeviceRespStatusEnums; import com.sandu.ximon.dao.enums.OrderByEnums; import com.sandu.ximon.dao.mapper.PlcTaskMapper; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDateTime; import java.util.*; import java.util.stream.Collectors; /** * plc任务表(PlcTask)表服务接口 * * @author van * @since 2022-12-19 16:53:41 */ @Service @Slf4j @AllArgsConstructor public class PlcTaskService extends BaseServiceImpl { private final PoleService poleService; private final ClientService clientService; private final PlcTaskPoleRelationService plcTaskPoleRelationService; private final PlcTaskMapper plcTaskMapper; /** * 根据任务信息转成帧负荷 * * @return 路灯定时器列表 */ private String buildControlFramePayload(String openOrder, String closeOrder, String controlOrder, Integer week) { // 添加开灯定时器 SingleLightOrderDto openLightOrder = TaskOrderUtil.parseLightOrder(openOrder); SingleLightOrderDto closeLightOrder = TaskOrderUtil.parseLightOrder(closeOrder); String[] controlOrderArray = StrUtil.split(controlOrder, PlcTaskParam.REQUEST_ORDER_LENGTH); Integer[] weekArrays = TaskOrderUtil.parseLightCronWeek2List(week).toArray(new Integer[0]); if (openLightOrder == null || closeLightOrder == null) { throw new BusinessException("解析PLC命令失败"); } if (ArrayUtil.isEmpty(weekArrays)) { throw new BusinessException("请设置星期"); } StringBuilder sb = new StringBuilder(); String weekHex = SupplementUtils.suppleZero(HexUtil.toHex(week), 2); // 拼接开灯命令 sb.append(weekHex); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(openLightOrder.getHour()), 2)); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(openLightOrder.getMinute()), 2)); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(openLightOrder.getBrightness()), 2)); // 拼接关灯命令 sb.append(weekHex); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(closeLightOrder.getHour()), 2)); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(closeLightOrder.getMinute()), 2)); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(closeLightOrder.getBrightness()), 2)); // 拼接亮度控灯命令 for (String controlOrderStr : controlOrderArray) { SingleLightOrderDto controlLightOrder = TaskOrderUtil.parseLightOrder(controlOrderStr); if (controlLightOrder != null) { sb.append(weekHex); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(controlLightOrder.getHour()), 2)); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(controlLightOrder.getMinute()), 2)); sb.append(SupplementUtils.suppleZero(HexUtil.toHex(controlLightOrder.getBrightness()), 2)); } } return sb.toString(); } /** * 用于任务新增,下发 * * @param plcTask * @param poleIdList * @param framePayload * @param plcAddress * @return */ private List sendControllerFrame(PlcTask plcTask, List poleIdList, String framePayload, String plcAddress) { List plcTaskPoleRelationList = new ArrayList<>(); //成功 List success = new ArrayList<>(); //失败 List fail = new ArrayList<>(); Map map = new HashMap(); List poles = poleService.listByIds(poleIdList); if (CollectionUtil.isEmpty(poles)) { return null; } for (Pole pole : poles) { if (pole.getDeviceCode() == null || pole.getDeviceCode().equals("")) { removeById(plcTask.getTaskId()); throw new BusinessException("编辑的灯杆或原有任务的灯杆不存在mac,不能下发任务 请检查灯杆是否存在PLC"); } PlcTaskPoleRelation plcTaskPoleRelation = new PlcTaskPoleRelation(); plcTaskPoleRelation.setPoleId(pole.getId()); plcTaskPoleRelation.setTaskId(plcTask.getTaskId()); // rrpc 发生定时命令 plcTaskPoleRelation.setDeviceCode(pole.getDeviceCode()); plcTaskPoleRelation.setPlcAddress(plcAddress); // rrpc 发生定时命令 try { A7PlcTimerRespInnerFrame a7PlcTimerRespInnerFrame = sendTimeRRpc(framePayload, pole.getDeviceCode(), plcAddress); if (a7PlcTimerRespInnerFrame == null) { plcTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); } else { plcTaskPoleRelation.setIssueStatus(HexUtil.hexToInt(a7PlcTimerRespInnerFrame.getResponseStatus())); } } catch (BusinessException e) { e.printStackTrace(); plcTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); } plcTaskPoleRelationList.add(plcTaskPoleRelation); } // } return plcTaskPoleRelationList; } /** * 发送灯控请求 * * @param framePayload 灯控参数 * @param deviceCode 设备吗 * @return 返回帧 */ public A7PlcTimerRespInnerFrame sendTimeRRpc(String framePayload, String deviceCode, String plcAddress) { IRequestFrame requestFrame = FrameBuilder.builderA7().innerFrame(new A7PlcTimerReqInnerFrame(framePayload, plcAddress)).orderType(A7OrderEnum.REQUEST_PLC_DATA.getCode()).build(); System.out.println(requestFrame + " --------requestFrame"); WrapResponseCommonFrame responseCommonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(deviceCode, requestFrame, A7PlcTimerRespInnerFrame.class); System.out.println(responseCommonFrame + " -----------responseCommonFrame"); StoreOperationRecordsUtils.storeInnerFrameData(deviceCode, "PLC帧-定时", requestFrame, responseCommonFrame); return Optional.ofNullable(responseCommonFrame).map(WrapResponseCommonFrame::getResponseInnerFrame).orElse(null); } /** * 用于任务编辑 * * @param poleIdList * @param framePayload * @param plcAddress * @return */ private Map> sendControllerFrame(List poleIdList, String framePayload, String plcAddress) { System.out.println("framePayload:" + framePayload); List plcTaskPoleRelationList = new ArrayList<>(); //成功 List success = new ArrayList<>(); //失败 List fail = new ArrayList<>(); Map> map = new HashMap(); List poles = poleService.listByIds(poleIdList); if (CollectionUtil.isEmpty(poles)) { return null; } for (Pole pole : poles) { if (pole.getDeviceCode() == null || pole.getDeviceCode().equals("")) { throw new BusinessException("编辑的灯杆或原有任务的灯杆不存在mac,不能下发任务 请检查灯杆是否存在PLC"); } PlcTaskPoleRelation plcTaskPoleRelation = new PlcTaskPoleRelation(); plcTaskPoleRelation.setPoleId(pole.getId()); //关系表插入灯头地址 plcTaskPoleRelation.setPlcAddress(plcAddress); // rrpc 发生定时命令 plcTaskPoleRelation.setPlcAddress(plcAddress); plcTaskPoleRelation.setDeviceCode(pole.getDeviceCode()); // rrpc 发生定时命令 try { A7PlcTimerRespInnerFrame a7PlcTimerRespInnerFrame = sendTimeRRpc(framePayload, pole.getDeviceCode(), plcAddress); if (a7PlcTimerRespInnerFrame == null) { plcTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); fail.add(plcTaskPoleRelation); } else { plcTaskPoleRelation.setIssueStatus(HexUtil.hexToInt(a7PlcTimerRespInnerFrame.getResponseStatus())); success.add(plcTaskPoleRelation); } } catch (BusinessException e) { plcTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); fail.add(plcTaskPoleRelation); } plcTaskPoleRelationList.add(plcTaskPoleRelation); } map.put("success", success); map.put("fail", fail); map.put("all", plcTaskPoleRelationList); log.error("发送控制器帧结果：{}", map); return map; } /** * 新增任务 * * @param param * @return */ @Transactional(rollbackFor = Exception.class) public String AddPlcTask(PlcTaskParam param) { if (StrUtil.length(param.getControlOrder()) % PlcTaskParam.REQUEST_ORDER_LENGTH != 0) { throw new BusinessException("灯控命令格式不正确"); } if (!"0001".equals(param.getPlcAddress()) && !"0002".equals(param.getPlcAddress()) && !"0003".equals(param.getPlcAddress())) { throw new BusinessException("灯头地址格式不正确"); } int week = 0; for (Integer w : param.getWeekList()) { week |= w; } PlcTask newPlcTask = new PlcTask(); newPlcTask.setTaskName(param.getTaskName()); newPlcTask.setClientId(clientService.getClientId(SecurityUtils.getUserId())); newPlcTask.setUserId(SecurityUtils.getUserId()); newPlcTask.setWeek(week); newPlcTask.setCreateUser(SecurityUtils.getUsername()); newPlcTask.setControlOrder(param.getControlOrder()); newPlcTask.setOpenOrder(param.getOpenOrder()); newPlcTask.setCloseOrder(param.getCloseOrder()); newPlcTask.setPlcAdress(param.getPlcAddress()); newPlcTask.setUpdateTime(LocalDateTime.now()); newPlcTask.setFramePayload(buildControlFramePayload(param.getOpenOrder(), param.getCloseOrder(), param.getControlOrder(), week)); if (!save(newPlcTask)) { throw new BusinessException("保存PLC任务失败"); } List poleCodeList = new ArrayList<>(); //传入的灯杆id集合 List poleIdList = new ArrayList<>(); //去重 for (Long item : param.getPoleIdList()) { if (!poleIdList.contains(item)) { poleIdList.add(item); } } if (CollectionUtil.isNotEmpty(poleIdList)) { List poleList = SpringContextHolder.getBean(PoleService.class).listByIds(poleIdList); if (CollectionUtil.isNotEmpty(poleList)) { poleCodeList = poleList.stream().map(Pole::getDeviceCode).collect(Collectors.toList()); } } String content = "{任务ID：" + newPlcTask.getTaskId() + "， 任务名：" + newPlcTask.getTaskName() + "}，{内帧指令" + newPlcTask.getFramePayload() + "， 灯杆ID：" + poleIdList.toString() + "， 控制的灯头地址：" + param.getPlcAddress() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "新增PLC任务", content); //记录这些灯杆原先的任务 List oldPlcTaskStatusAndPoles = plcTaskPoleRelationService.list(Wrappers.lambdaQuery(PlcTaskPoleRelation.class) .in(PlcTaskPoleRelation::getPoleId, poleIdList).eq(PlcTaskPoleRelation::getPlcAddress, param.getPlcAddress())); List newPoleMap = new ArrayList<>(); if (!poleIdList.isEmpty()) { //新灯杆下发新任务 newPoleMap = sendControllerFrame(newPlcTask, poleIdList, newPlcTask.getFramePayload(), param.getPlcAddress()); } newPoleMap.forEach( commend -> { //开关灯时间 commend.setSysScheduled(JSON.toJSONString(newPlcTask)); System.out.println(commend.getIssueStatus() + "状态"); if (commend.getIssueStatus() == 0) { //下发成功 更新系统定时和硬件定时 commend.setDeviceScheduled(JSON.toJSONString(newPlcTask)); } else { //下发失败 更新系统定时 保留硬件定时 硬件定时 // commend.setSysScheduled(s); oldPlcTaskStatusAndPoles.forEach(task -> { if (task.getPlcAddress().equals(commend.getPlcAddress()) && task.getDeviceCode().equals(commend.getDeviceCode())) { //同一个灯头 commend.setDeviceScheduled(task.getDeviceScheduled()); } }); } } ); /** * 下发路灯任务日志记录开始 */ String content1 = "{任务ID：" + newPlcTask.getTaskId() + "， 任务名：" + newPlcTask.getTaskName() + "}," + " 灯杆ID：" + poleIdList.toString() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "下发PLC任务", content1); /** * 下发路灯任务日志记录结束 */ //删除旧的关系 plcTaskPoleRelationService.remove(Wrappers.lambdaQuery(PlcTaskPoleRelation.class) .in(PlcTaskPoleRelation::getPoleId, poleIdList).eq(PlcTaskPoleRelation::getPlcAddress, newPlcTask.getPlcAdress())); boolean b = true; //保存任务关系 if (!newPoleMap.isEmpty()) { b = plcTaskPoleRelationService.saveBatch(newPoleMap); } if (!b) { //所有灯杆都下发失败 新增的任务不保留 removeById(newPlcTask); throw new BusinessException("指令下发失败,请检查灯杆状态后重新新增任务"); } else { return "任务新增成功"; } } /** * 编辑路灯任务 * * @param taskId * @param param * @return */ @Transactional(rollbackFor = Exception.class) public String newUpdatePlcTask(Long taskId, PlcTaskParam param) { if (StrUtil.length(param.getControlOrder()) % PlcTaskParam.REQUEST_ORDER_LENGTH != 0) { throw new BusinessException("灯控命令格式不正确"); } if (!"0001".equals(param.getPlcAddress()) && !"0002".equals(param.getPlcAddress()) && !"0003".equals(param.getPlcAddress())) { throw new BusinessException("灯头地址格式不正确"); } PlcTask newPlcTask = getById(taskId); if (newPlcTask == null) { throw new BusinessException("找不到PLC任务"); } int week = 0; for (Integer w : param.getWeekList()) { week |= w; } newPlcTask.setTaskName(param.getTaskName()); newPlcTask.setClientId(clientService.getClientId(SecurityUtils.getUserId())); newPlcTask.setUserId(SecurityUtils.getUserId()); newPlcTask.setWeek(week); newPlcTask.setCreateUser(SecurityUtils.getUsername()); newPlcTask.setControlOrder(param.getControlOrder()); newPlcTask.setOpenOrder(param.getOpenOrder()); newPlcTask.setCloseOrder(param.getCloseOrder()); newPlcTask.setPlcAdress(param.getPlcAddress()); newPlcTask.setUpdateTime(LocalDateTime.now()); newPlcTask.setFramePayload(buildControlFramePayload(param.getOpenOrder(), param.getCloseOrder(), param.getControlOrder(), week)); updateById(newPlcTask); //编辑后灯杆ID集合 List poleIdList = new ArrayList<>(); //去重 for (Long item : param.getPoleIdList()) { if (!poleIdList.contains(item)) { poleIdList.add(item); } } //记录任务编辑器前灯杆ID集合 // List oldPlcTaskStatusAndPoles = plcTaskPoleRelationService.listPoleAndStatusIdByTaskId(taskId); List oldPlcTaskStatusAndPoles = plcTaskPoleRelationService. list(Wrappers.lambdaQuery(PlcTaskPoleRelation.class).eq(PlcTaskPoleRelation::getTaskId, taskId)); List oldList = oldPlcTaskStatusAndPoles.stream(). map(PlcTaskPoleRelation::getPoleId).collect(Collectors.toList()); //判断poleIdList中是否有旧的灯杆ID (直接下发) List newPoleIdList = poleIdList.stream().filter(poleId -> !oldList.contains(poleId)).collect(Collectors.toList()); //判断poleIdList中是否有新的灯杆ID (覆盖操作) List oldPoleIdList = poleIdList.stream().filter(poleId -> oldList.contains(poleId)).collect(Collectors.toList()); //oldList中有的灯杆ID，但是poleIdList中没有 (关灯操作) List closeLight = oldList.stream().filter(poleId -> !poleIdList.contains(poleId)).collect(Collectors.toList()); //取出覆盖操作的关系信息 //记录这些灯杆原先的任务 List oldRelation = new ArrayList<>(); if (CollectionUtil.isNotEmpty(oldPoleIdList)) { List oldRelationList = new ArrayList<>(); oldRelationList.addAll(oldPoleIdList); oldRelationList.addAll(closeLight); oldRelation = plcTaskPoleRelationService.list(Wrappers.lambdaQuery(PlcTaskPoleRelation.class).in(PlcTaskPoleRelation::getPoleId, oldRelationList) .ne(PlcTaskPoleRelation::getTaskId, taskId).eq(PlcTaskPoleRelation::getPlcAddress, param.getPlcAddress())); } //取出任务中原有的任务信息 List relations = plcTaskPoleRelationService.list(Wrappers.lambdaQuery(PlcTaskPoleRelation.class) .eq(PlcTaskPoleRelation::getTaskId, taskId).eq(PlcTaskPoleRelation::getPlcAddress, param.getPlcAddress())); relations.addAll(oldRelation); List newPoleAll = new ArrayList<>(); List newPoleSuccess = new ArrayList<>(); List newPoleFail = new ArrayList<>(); if (CollectionUtil.isNotEmpty(newPoleIdList)) { //新灯杆下发新任务 Map> newPoleMap = sendControllerFrame(newPoleIdList, newPlcTask.getFramePayload(), param.getPlcAddress()); if (newPoleMap != null) { //newPoleAll集合后面用于存储关系表 newPoleAll = newPoleMap.getOrDefault("all", new ArrayList<>()); newPoleSuccess = newPoleMap.getOrDefault("success", new ArrayList<>()); newPoleFail = newPoleMap.getOrDefault("fail", new ArrayList<>()); } } List oldPoleFail = new ArrayList<>(); List oldPoleSuccess = new ArrayList<>(); if (CollectionUtil.isNotEmpty(oldPoleIdList)) { //覆盖操作灯杆 Map> oldPoleMap = sendControllerFrame(oldPoleIdList, newPlcTask.getFramePayload(), param.getPlcAddress()); if (oldPoleMap != null) { oldPoleFail = oldPoleMap.getOrDefault("fail", new ArrayList<>()); oldPoleSuccess = oldPoleMap.getOrDefault("success", new ArrayList<>()); } } List closePoleFail = new ArrayList<>(); List closePoleSuccess = new ArrayList<>(); System.out.println(closeLight + "closeLight"); if (CollectionUtil.isNotEmpty(closeLight) && closeLight != null && closeLight.get(0) != null) { //清除帧指令 String framePayloadClose = ""; //关灯操作灯杆 Map> closePoleMap = sendControllerFrame(closeLight, framePayloadClose, param.getPlcAddress()); if (closePoleMap != null) { closePoleFail = closePoleMap.getOrDefault("fail", new ArrayList<>()); closePoleSuccess = closePoleMap.getOrDefault("success", new ArrayList<>()); } } /** * 编辑路灯任务日志记录开始 */ List poleCodeList = new ArrayList<>(); if (CollectionUtil.isNotEmpty(poleIdList)) { List poleList = SpringContextHolder.getBean(PoleService.class).listByIds(poleIdList); if (CollectionUtil.isNotEmpty(poleList)) { poleCodeList = poleList.stream().map(Pole::getDeviceCode).collect(Collectors.toList()); } } String content = "{任务ID：" + newPlcTask.getTaskId() + "， 任务名：" + newPlcTask.getTaskName() + "}，{内帧指令" + newPlcTask.getFramePayload() + "， 灯杆ID：" + poleIdList.toString() + "， 控制的灯头地址：" + param.getPlcAddress() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "编辑PLC任务", content); /** * 编辑路灯任务日志记录结束 */ List all = new ArrayList<>(); all.addAll(newPoleSuccess); all.addAll(newPoleFail); all.addAll(oldPoleSuccess); all.addAll(oldPoleFail); if (closePoleFail.size() != 0) { List colesFail = new ArrayList<>(); //原来任务中本身就下发失败的任务 即硬件定时为空 编辑后进行关灯操作 可直接剔除任务关系 closePoleFail.forEach( close -> { relations.forEach( task -> { System.out.println(task.getPlcAddress().equals(close.getPlcAddress()) + " addressResult"); System.out.println(close.getPlcAddress() + " close.getPlcAddress()"); if (task.getPlcAddress().equals(close.getPlcAddress()) && task.getDeviceCode().equals(close.getDeviceCode()) && task.getDeviceScheduled() != null && !task.getDeviceScheduled().isEmpty()) { colesFail.add(close); } } ); all.addAll(colesFail); } ); } if (!all.isEmpty()) { List finalOldRelation = relations; all.forEach( commend -> { // 更新系统定时 commend.setSysScheduled(JSON.toJSONString(newPlcTask)); commend.setTaskId(taskId); // 先设置硬件定时为上次的硬件定时 不论成功失败 finalOldRelation.forEach(task -> { if (task.getPlcAddress().equals(commend.getPlcAddress()) && task.getDeviceCode().equals(commend.getDeviceCode())) { //同一个灯头 commend.setDeviceScheduled(task.getDeviceScheduled()); if (commend.getIssueStatus() == 0) { //下发成功 更新系统定时和硬件定时 commend.setDeviceScheduled(JSON.toJSONString(newPlcTask)); } } }); } ); } boolean b = true; //编辑前后所有的灯杆ID集合 poleIdList.addAll(oldList); //去重 List collect = poleIdList.stream().distinct().collect(Collectors.toList()); if (!collect.isEmpty()) { plcTaskPoleRelationService.remove(Wrappers.lambdaQuery(PlcTaskPoleRelation.class) .in(PlcTaskPoleRelation::getPoleId, collect).eq(PlcTaskPoleRelation::getPlcAddress, newPlcTask.getPlcAdress())); } if (!all.isEmpty()) { b = plcTaskPoleRelationService.saveBatch(all); } /** * 下发路灯任务日志记录开始 */ String content1 = "{任务ID：" + newPlcTask.getTaskId() + "， 任务名：" + newPlcTask.getTaskName() + "}," + " 灯杆ID：" + poleCodeList.toString() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "下发路灯任务", content1); /** * 下发路灯任务日志记录结束 */ if (b) { return "编辑成功"; } else { return "编辑失败"; } } @Transactional(rollbackFor = Exception.class) public String delPlcTask(Long taskId) { PlcTask byId = getById(taskId); if (byId == null) { throw new BusinessException("找不到任务信息"); } //取出任务关系 List relations = plcTaskPoleRelationService.list(Wrappers.lambdaQuery(PlcTaskPoleRelation.class).eq(PlcTaskPoleRelation::getTaskId, taskId)); //取出灯杆id List poleIds = relations.stream().map(PlcTaskPoleRelation::getPoleId).distinct().collect(Collectors.toList()); if (poleIds != null && poleIds.size() > 0) { //存在任务关系 下发清除任务指令 Map> ffff = sendControllerFrame(poleIds, "", byId.getPlcAdress()); if (ffff == null) { throw new BusinessException("删除失败"); } /** * 删除控灯任务日志记录开始 */ String content = "{控灯任务id：" + taskId + " }"; StoreOperationRecordsUtils.storeOperationData(null, null, "删除控灯任务", content); /** * 删除控灯任务日志记录结束 */ if (ffff.get("fail").size() == 0) { //全部清除成功 删除全部任务关系 plcTaskPoleRelationService.remove(Wrappers.lambdaQuery(PlcTaskPoleRelation.class).eq(PlcTaskPoleRelation::getTaskId, taskId)); //删除任务 removeById(taskId); return "任务删除成功"; } else if (ffff.get("success").size() != ffff.get("all").size()) { //部分成功 删除成功部分的关系 保留任务 List relations1 = ffff.get("success"); if (relations1 != null && relations1.size() > 0) { relations1.forEach(plcTaskPoleRelation -> { plcTaskPoleRelationService.remove(Wrappers.lambdaUpdate(PlcTaskPoleRelation.class) .eq(PlcTaskPoleRelation::getPoleId, plcTaskPoleRelation.getPoleId()).eq(PlcTaskPoleRelation::getTaskId, taskId)); }); } return "部分任务删除成功,清除任务失败的任务及数据保留!"; } else if (ffff.get("fail").size() == ffff.get("all").size()) { //全部失败 保留任务 return "任务删除失败 ,请检查硬件设备!"; } else { return "任务删除失败,未知错误类型!"; } } else { //不存在任务关系 空任务直接删除 removeById(taskId); return "任务删除成功"; } } /** * 下发单个灯杆的任务 */ public boolean issuePlcTask(PlcTaskIssueParam param) { PlcTaskPoleRelation relation = plcTaskPoleRelationService.getOne(Wrappers.lambdaQuery(PlcTaskPoleRelation.class) .eq(PlcTaskPoleRelation::getPoleId, param.getPoleId()).eq(PlcTaskPoleRelation::getTaskId, param.getTaskId())); if (relation == null) { throw new BusinessException("找不到任务关系,无法补发"); } PlcTask plcTask = JSONObject.parseObject(relation.getSysScheduled(), PlcTask.class); // PlcTask plcTask = getById(param.getTaskId()); if (plcTask == null) { throw new BusinessException("找不到任务"); } //转换帧指令 String framePayload = buildControlFramePayload(plcTask.getOpenOrder(), plcTask.getCloseOrder(), plcTask.getControlOrder(), plcTask.getWeek()); //发送rrpc 得到发送结果 List plcTaskPoleRelationList = sendControllerFrame(plcTask, ListUtil.toList(param.getPoleId()), framePayload, plcTask.getPlcAdress()); /** * 下发路灯任务日志记录开始 */ List poleCodeList = new ArrayList<>(); List list = SpringContextHolder.getBean(PoleService.class).list(Wrappers.lambdaQuery(Pole.class).eq(Pole::getId, param.getPoleId())); if (CollectionUtil.isNotEmpty(list)) { poleCodeList = list.stream().map(Pole::getDeviceCode).collect(Collectors.toList()); } String content = "{任务ID：" + plcTask.getTaskId() + "， 任务名：" + plcTask.getTaskName() + "}," + " 灯杆ID：" + param.getPoleId() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "下发PLC任务", content); /** * 下发路灯任务日志记录结束 */ if (CollectionUtil.isNotEmpty(plcTaskPoleRelationList)) { PlcTaskPoleRelation plcTaskPoleRelation = plcTaskPoleRelationList.get(0); if (plcTaskPoleRelation.getIssueStatus() == 0) { //下发成功 更新硬件定时 返回成功 relation.setDeviceScheduled(JSON.toJSONString(plcTaskPoleRelation)); plcTaskPoleRelationService.updateById(relation); return true; } else { return false; } } return false; } public Map checkTask(PlcTaskParam param) { /** * 重复任务的灯头 */ String plcAddress = param.getPlcAddress(); List poleIdList = param.getPoleIdList(); List plcTaskPoleRelations = plcTaskPoleRelationService.list(Wrappers.lambdaQuery(PlcTaskPoleRelation.class) .in(PlcTaskPoleRelation::getPoleId, poleIdList).eq(PlcTaskPoleRelation::getPlcAddress, plcAddress)); //重复的任务id List taskIds = plcTaskPoleRelations.stream().map(PlcTaskPoleRelation::getTaskId).collect(Collectors.toList()); //重复的灯杆id List oldPoleIds = plcTaskPoleRelations.stream().map(PlcTaskPoleRelation::getPoleId).collect(Collectors.toList()); //未重复的灯杆id List finalOldPoleIds = oldPoleIds; //取出存在于poleIdList而不在oldPoleIds中的灯杆 List newPoleIds = poleIdList.stream().filter(id -> !finalOldPoleIds.contains(id)).collect(Collectors.toList()); //重复元素只保留一个 taskIds = taskIds.stream().distinct().collect(Collectors.toList()); oldPoleIds = oldPoleIds.stream().distinct().collect(Collectors.toList()); newPoleIds = newPoleIds.stream().distinct().collect(Collectors.toList()); Map map = new HashMap(); if (!plcTaskPoleRelations.isEmpty()) { map.put("result", "false"); map.put("newPoleIds", newPoleIds); map.put("oldPoleIds", oldPoleIds); map.put("taskIds", taskIds); } else { map.put("result", "true"); map.put("msg", "任务中无重复灯杆地址"); } return map; } public List listPlcTask(BaseConditionVO conditionVO, String keyword, Integer order, Integer seq) { //排序字段 String orderByResult = "task_id"; //正序、倒叙 String orderBySeq = OrderByEnums.ASC.getCode(); if (order != null) { switch (order) { case 1: orderByResult = OrderByEnums.LIGHT_TASK_UPDATE_TIME.getCode(); break; default: } } if (seq != null) { switch (seq) { case 1: orderBySeq = OrderByEnums.ASC.getCode(); break; case 2: orderBySeq = OrderByEnums.DESC.getCode(); break; default: break; } } //排序方式 String orderBy = orderByResult + " " + orderBySeq; PageHelper.startPage(conditionVO.getPageNo(), conditionVO.getPageSize(), orderBy); List list = baseMapper.listTask(SecurityUtils.getClientId(), keyword, orderBy); Page page = new Page<>(); BeanUtils.copyProperties(list, page); for (PlcTask plcTask : list) { PlcTaskDto plcTaskDto = new PlcTaskDto(); BeanUtils.copyProperties(plcTask, plcTaskDto); plcTaskDto.setWeekList(TaskOrderUtil.parseLightWeek2List(plcTask.getWeek())); //判断灯头是否存在任务 List plcTaskPoleRelationList = plcTaskPoleRelationService.list(Wrappers.lambdaQuery().eq(PlcTaskPoleRelation::getTaskId, plcTask.getTaskId())); //下发成功的灯杆数量 Integer successCount = baseMapper.successCount(plcTaskDto.getTaskId()); ///任务中总的灯杆数量 Integer toTalCount = baseMapper.toTalCount(plcTaskDto.getTaskId()); if (successCount == null) { successCount = 0; } if (toTalCount == null) { toTalCount = 0; } if (toTalCount == 0) { //任务中没有灯杆 plcTaskDto.setSyncStatus("未同步"); } else { //任务中有灯杆 if (successCount == 0) { //下发成功未0 plcTaskDto.setSyncStatus("未同步"); } else if (successCount != 0 && successCount < toTalCount) { //存在下发成功 但并未全部成功 plcTaskDto.setSyncStatus("部分同步"); } else if (toTalCount.equals(successCount) && toTalCount != 0 && successCount != 0) { //全部成功 plcTaskDto.setSyncStatus("已同步"); } else { //未知类型 plcTaskDto.setSyncStatus("同步状态出错"); } } page.add(plcTaskDto); } return page; } /** * 执行中的路灯任务 * * @return */ public List listTask() { Long clientId = SecurityUtils.getClientId(); List plcTasks = plcTaskMapper.listPlcTask(clientId); Page page = new Page<>(); BeanUtils.copyProperties(plcTasks, page); for (PlcTask plcTask : plcTasks) { PlcTaskDto plcTaskDto = new PlcTaskDto(); BeanUtils.copyProperties(plcTask, plcTaskDto); plcTaskDto.setWeekList(TaskOrderUtil.parseLightWeek2List(plcTask.getWeek())); page.add(plcTaskDto); } return page; } /** * 任务详情 */ public Object detailPlcTask(Long taskId) { PlcTask plcTask = getById(taskId); if (plcTask == null) { throw new BusinessException("找不到任务"); } PlcTaskInfoVO vo = new PlcTaskInfoVO(); // LightTaskDto plcTaskDto = new LightTaskDto(); // BeanUtils.copyProperties(plcTask, plcTaskDto); plcTask.setWeekList(TaskOrderUtil.parseLightWeek2List(plcTask.getWeek())); vo.setPlcTask(plcTask); List relations = new ArrayList<>(); List taskPoleRelations = plcTaskPoleRelationService.list(Wrappers.lambdaQuery(PlcTaskPoleRelation.class) .eq(PlcTaskPoleRelation::getTaskId, taskId)); if (taskPoleRelations != null && !taskPoleRelations.isEmpty()) { taskPoleRelations.forEach( relation -> { PlcTaskRelationVO plcTaskRelationVO = new PlcTaskRelationVO(); plcTaskRelationVO.setPlcAddress(relation.getPlcAddress()); plcTaskRelationVO.setIssueStatus(relation.getIssueStatus()); plcTaskRelationVO.setPoleId(relation.getPoleId()); Pole byId = poleService.getById(relation.getPoleId()); if (byId != null) { plcTaskRelationVO.setPoleName(byId.getPoleName()); } PlcTaskVO sys = JSONObject.parseObject(relation.getSysScheduled(), PlcTaskVO.class); sys.setWeekList(TaskOrderUtil.parseLightWeek2List(sys.getWeek())); plcTaskRelationVO.setSysScheduled(sys); PlcTaskVO device = JSONObject.parseObject(relation.getDeviceScheduled(), PlcTaskVO.class); if (device != null) { device.setWeekList(TaskOrderUtil.parseLightWeek2List(device.getWeek())); plcTaskRelationVO.setDeviceScheduled(device); } relations.add(plcTaskRelationVO); } ); vo.setRelations(relations); } // List plcTaskStatusAndPoles = plcTaskPoleRelationService.listPoleAndStatusIdByTaskId(taskId); // return MapUtil.builder().put("task", plcTask).put("poles", plcTaskStatusAndPoles).build(); return vo; } }