package com.sandu.ximon.admin.service; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.ListUtil; import cn.hutool.core.map.MapUtil; import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.util.HexUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.druid.support.json.JSONUtils; 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.LightTaskDto; 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.A5LightTimerReqInnerFrame; import com.sandu.ximon.admin.manager.iot.frame.inner.response.A5LightTimerRespInnerFrame; import com.sandu.ximon.admin.manager.iot.rrpc.dto.WrapResponseCommonFrame; import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5OrderEnum; 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.LightTaskIssueParam; import com.sandu.ximon.admin.param.LightTaskParam; 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.dao.bo.LightTaskPoleRelationBo; import com.sandu.ximon.dao.bo.LightTaskStatusAndPole; import com.sandu.ximon.dao.domain.LightEnergyData; import com.sandu.ximon.dao.domain.LightTask; import com.sandu.ximon.dao.domain.LightTaskPoleRelation; import com.sandu.ximon.dao.domain.Pole; import com.sandu.ximon.dao.enums.DeviceRespStatusEnums; import com.sandu.ximon.dao.enums.OrderByEnums; import com.sandu.ximon.dao.mapper.LightTaskMapper; import com.sandu.ximon.dao.mapper.LightTaskPoleRelationMapper; 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.math.BigDecimal; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.stream.Collectors; /** * @author chenjiantian * @date 2021/12/15 16:33 * 路灯任务操作 */ @Service @Slf4j @AllArgsConstructor public class LightTaskService extends BaseServiceImpl { private final PoleService poleService; private final LightTaskPoleRelationService lightTaskPoleRelationService; private final LightTaskMapper lightTaskMapper; private final ClientService clientService; private final LightEnergyDataService lightEnergyDataService; /** * 新增路灯任务 * * @param param * @return */ @Transactional(rollbackFor = Exception.class) public String AddLightTask(LightTaskParam param) { if (StrUtil.length(param.getControlOrder()) % LightTaskParam.REQUEST_ORDER_LENGTH != 0) { throw new BusinessException("灯控命令格式不正确"); } if (!"0001".equals(param.getLightAddress()) && !"0002".equals(param.getLightAddress())) { throw new BusinessException("灯头地址格式不正确"); } // LightTask lightTask = getById(null); int week = 0; for (Integer w : param.getWeekList()) { week |= w; } LightTask newLightTask = new LightTask(); newLightTask.setTaskName(param.getTaskName()); newLightTask.setClientId(clientService.getClientId()); newLightTask.setUserId(SecurityUtils.getUserId()); newLightTask.setWeek(week); newLightTask.setCreateUser(SecurityUtils.getUsername()); newLightTask.setControlOrder(param.getControlOrder()); newLightTask.setOpenOrder(param.getOpenOrder()); newLightTask.setCloseOrder(param.getCloseOrder()); newLightTask.setLightAdress(param.getLightAddress()); newLightTask.setUpdateTime(LocalDateTime.now()); newLightTask.setFramePayload(buildControlFramePayload(param.getOpenOrder(), param.getCloseOrder(), param.getControlOrder(), week)); if (!save(newLightTask)) { throw new BusinessException("保存路灯任务失败"); } 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：" + newLightTask.getTaskId() + "， 任务名：" + newLightTask.getTaskName() + "}，{内帧指令" + newLightTask.getFramePayload() + "， 灯杆ID：" + poleIdList.toString() + "， 控制的灯头地址：" + param.getLightAddress() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "新增路灯任务", content); //记录这些灯杆原先的任务 List oldLightTaskStatusAndPoles = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class) .in(LightTaskPoleRelation::getPoleId, poleIdList).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress())); List newPoleMap = new ArrayList<>(); if (!poleIdList.isEmpty()) { //新灯杆下发新任务 newPoleMap = sendControllerFrame(newLightTask, poleIdList, newLightTask.getFramePayload(), param.getLightAddress()); } newPoleMap.forEach( commend -> { //开关灯时间 // String s = newLightTask.getOpenOrder() + newLightTask.getCloseOrder(); // if (newLightTask.getControlOrder() != null) { // //控灯时间 // s = s + newLightTask.getControlOrder(); // } // // 更新系统定时 // commend.setSysScheduled(s); if (commend.getIssueStatus() == 0) { //下发成功 更新系统定时和硬件定时 commend.setDeviceScheduled(JSONObject.toJSONString(newLightTask)); } else { //下发失败 更新系统定时 保留硬件定时 硬件定时 // commend.setSysScheduled(s); oldLightTaskStatusAndPoles.forEach(task -> { if (task.getLightAddress().equals(commend.getLightAddress()) && task.getDeviceCode().equals(commend.getDeviceCode())) { //同一个灯头 LightTask oldTask = getById(task.getTaskId()); commend.setDeviceScheduled(JSONObject.toJSONString(oldTask)); } }); } } ); /** * 下发路灯任务日志记录开始 */ String content1 = "{任务ID：" + newLightTask.getTaskId() + "， 任务名：" + newLightTask.getTaskName() + "}," + " 灯杆ID：" + poleIdList.toString() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "下发路灯任务", content1); /** * 下发路灯任务日志记录结束 */ //删除旧的关系 lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class) .eq(LightTaskPoleRelation::getLightAddress, newLightTask.getLightAdress()).in(LightTaskPoleRelation::getPoleId, poleIdList)); boolean b = true; //保存任务关系 if (!newPoleMap.isEmpty()) { b = lightTaskPoleRelationService.saveBatch(newPoleMap); } if (!b) { //所有灯杆都下发失败 新增的任务不保留 removeById(newLightTask); throw new BusinessException("指令下发失败,请检查灯杆状态后重新新增任务"); } else { return "任务新增成功"; } } /** * 编辑路灯任务 * * @param taskId * @param param * @return */ @Transactional(rollbackFor = Exception.class) public String newUpdateLightTask(Long taskId, LightTaskParam param) { if (StrUtil.length(param.getControlOrder()) % LightTaskParam.REQUEST_ORDER_LENGTH != 0) { throw new BusinessException("灯控命令格式不正确"); } LightTask newLightTask = getById(taskId); if (newLightTask == null) { throw new BusinessException("找不到路灯任务"); } int week = 0; for (Integer w : param.getWeekList()) { week |= w; } // LightTask newLightTask = new LightTask(); newLightTask.setTaskName(param.getTaskName()); newLightTask.setClientId(clientService.getClientId()); newLightTask.setUserId(SecurityUtils.getUserId()); newLightTask.setWeek(week); newLightTask.setCreateUser(SecurityUtils.getUsername()); newLightTask.setControlOrder(param.getControlOrder()); newLightTask.setOpenOrder(param.getOpenOrder()); newLightTask.setCloseOrder(param.getCloseOrder()); newLightTask.setLightAdress(param.getLightAddress()); newLightTask.setUpdateTime(LocalDateTime.now()); newLightTask.setFramePayload(buildControlFramePayload(param.getOpenOrder(), param.getCloseOrder(), param.getControlOrder(), week)); updateById(newLightTask); //编辑后灯杆ID集合 List poleIdList = new ArrayList<>(); //去重 for (Long item : param.getPoleIdList()) { if (!poleIdList.contains(item)) { poleIdList.add(item); } } //记录任务编辑器前灯杆ID集合 // List oldLightTaskStatusAndPoles = lightTaskPoleRelationService.listPoleAndStatusIdByTaskId(taskId); List oldLightTaskStatusAndPoles = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getTaskId, taskId)); List oldList = oldLightTaskStatusAndPoles.stream().map(LightTaskPoleRelation::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 = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, oldRelationList) .ne(LightTaskPoleRelation::getTaskId, taskId).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress())); } //取出任务中原有的任务信息 List relations = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class) .eq(LightTaskPoleRelation::getTaskId, taskId).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress())); relations.addAll(oldRelation); List newPoleAll = new ArrayList<>(); List newPoleSuccess = new ArrayList<>(); List newPoleFail = new ArrayList<>(); if (CollectionUtil.isNotEmpty(newPoleIdList)) { //新灯杆下发新任务 Map> newPoleMap = sendControllerFrame(newPoleIdList, newLightTask.getFramePayload(), param.getLightAddress()); //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, newLightTask.getFramePayload(), param.getLightAddress()); 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.getLightAddress()); 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：" + newLightTask.getTaskId() + "， 任务名：" + newLightTask.getTaskName() + "}，{内帧指令" + newLightTask.getFramePayload() + "， 灯杆ID：" + poleIdList.toString() + "， 控制的灯头地址：" + param.getLightAddress() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "编辑路灯任务", content); /** * 编辑路灯任务日志记录结束 */ List all = new ArrayList<>(); all.addAll(newPoleSuccess); all.addAll(newPoleFail); all.addAll(oldPoleSuccess); all.addAll(oldPoleFail); all.addAll(closePoleSuccess); all.addAll(closePoleFail); if (!all.isEmpty()) { List finalOldRelation = relations; all.forEach( commend -> { commend.setTaskId(newLightTask.getTaskId()); //开关灯时间 String s = newLightTask.getOpenOrder() + newLightTask.getCloseOrder(); if (newLightTask.getControlOrder() != null) { //控灯时间 s = s + newLightTask.getControlOrder(); } // 更新系统定时 commend.setSysScheduled(s); // 先设置硬件定时为上次的硬件定时 不论成功失败 String finalS = s; finalOldRelation.forEach(task -> { if (task.getLightAddress().equals(commend.getLightAddress()) && task.getDeviceCode().equals(commend.getDeviceCode())) { //同一个灯头 commend.setDeviceScheduled(task.getDeviceScheduled()); if (commend.getIssueStatus() == 0) { //下发成功 更新系统定时和硬件定时 commend.setDeviceScheduled(finalS); } } }); } ); } boolean b = true; //编辑前后所有的灯杆ID集合 poleIdList.addAll(oldList); if (!poleIdList.isEmpty()) { lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, poleIdList)); } if (!all.isEmpty()) { b = lightTaskPoleRelationService.saveBatch(all); } /** * 下发路灯任务日志记录开始 */ String content1 = "{任务ID：" + newLightTask.getTaskId() + "， 任务名：" + newLightTask.getTaskName() + "}," + " 灯杆ID：" + poleCodeList.toString() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "下发路灯任务", content1); /** * 下发路灯任务日志记录结束 */ if (b) { return "编辑成功"; } else { return "编辑失败"; } } /** * 发送灯控请求 * * @param framePayload 灯控参数 * @param deviceCode 设备吗 * @return 返回帧 */ public A5LightTimerRespInnerFrame sendTimeRRpc(String framePayload, String deviceCode, String lightAddress) { IRequestFrame requestFrame = FrameBuilder.builderA5().innerFrame(new A5LightTimerReqInnerFrame(framePayload, lightAddress)).orderType(A5OrderEnum.REQUEST_LIGHT_DATA.getCode()).build(); System.out.println(requestFrame + " --------requestFrame"); WrapResponseCommonFrame responseCommonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(deviceCode, requestFrame, A5LightTimerRespInnerFrame.class); System.out.println(responseCommonFrame + " -----------responseCommonFrame"); StoreOperationRecordsUtils.storeInnerFrameData(deviceCode, "单灯帧-控灯", requestFrame, responseCommonFrame); return Optional.ofNullable(responseCommonFrame).map(WrapResponseCommonFrame::getResponseInnerFrame).orElse(null); } public List listLightTask(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 (LightTask lightTask : list) { LightTaskDto lightTaskDto = new LightTaskDto(); BeanUtils.copyProperties(lightTask, lightTaskDto); lightTaskDto.setWeekList(TaskOrderUtil.parseLightWeek2List(lightTask.getWeek())); //判断灯头是否存在任务 List lightTaskPoleRelationList = lightTaskPoleRelationService.list(Wrappers.lambdaQuery().eq(LightTaskPoleRelation::getTaskId, lightTask.getTaskId())); //下发成功的灯杆数量 Integer successCount = baseMapper.successCount(lightTaskDto.getTaskId()); ///任务中总的灯杆数量 Integer toTalCount = baseMapper.toTalCount(lightTaskDto.getTaskId()); if (successCount == null) { successCount = 0; } if (toTalCount == null) { toTalCount = 0; } if (toTalCount == 0) { //任务中没有灯杆 lightTaskDto.setSyncStatus("未同步"); } else { //任务中有灯杆 if (successCount == 0) { //下发成功未0 lightTaskDto.setSyncStatus("未同步"); } else if (successCount != 0 && successCount < toTalCount) { //存在下发成功 但并未全部成功 lightTaskDto.setSyncStatus("部分同步"); } else if (toTalCount.equals(successCount) && toTalCount != 0 && successCount != 0) { //全部成功 lightTaskDto.setSyncStatus("已同步"); } else { //未知类型 lightTaskDto.setSyncStatus("同步状态出错"); } } page.add(lightTaskDto); } return page; } /** * 执行中的路灯任务 * * @return */ public List listTask() { Long clientId = SecurityUtils.getClientId(); List lightTasks = lightTaskMapper.listLightTask(clientId); Page page = new Page<>(); BeanUtils.copyProperties(lightTasks, page); for (LightTask lightTask : lightTasks) { LightTaskDto lightTaskDto = new LightTaskDto(); BeanUtils.copyProperties(lightTask, lightTaskDto); lightTaskDto.setWeekList(TaskOrderUtil.parseLightWeek2List(lightTask.getWeek())); page.add(lightTaskDto); } return page; } /** * 用于任务新增,下发 * * @param lightTask * @param poleIdList * @param framePayload * @param lightAddress * @return */ private List sendControllerFrame(LightTask lightTask, List poleIdList, String framePayload, String lightAddress) { List lightTaskPoleRelationList = 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(lightTask.getTaskId()); throw new BusinessException("编辑的灯杆或原有任务的灯杆不存在mac,不能下发任务 请检查灯杆是否存在单灯"); } LightTaskPoleRelation lightTaskPoleRelation = new LightTaskPoleRelation(); lightTaskPoleRelation.setPoleId(pole.getId()); lightTaskPoleRelation.setTaskId(lightTask.getTaskId()); // rrpc 发生定时命令 // if ("FFFF".equals(lightAddress)) { // LightTaskPoleRelation lightTaskPoleRelation01 = new LightTaskPoleRelation(); // lightTaskPoleRelation01.setPoleId(pole.getId()); // lightTaskPoleRelation01.setTaskId(lightTask.getTaskId()); // lightTaskPoleRelation01.setLightAddress("0001"); // // LightTaskPoleRelation lightTaskPoleRelation02 = new LightTaskPoleRelation(); // lightTaskPoleRelation02.setPoleId(pole.getId()); // lightTaskPoleRelation02.setTaskId(lightTask.getTaskId()); // lightTaskPoleRelation02.setLightAddress("0002"); // // // 灯头1 rrpc 发生定时命令 // try { // A5LightTimerRespInnerFrame a5LightTimerRespInnerFrame01 = sendTimeRRpc(framePayload, pole.getDeviceCode(), "0001"); // //灯头1 // if (a5LightTimerRespInnerFrame01 == null) { // lightTaskPoleRelation01.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // } else { // lightTaskPoleRelation01.setIssueStatus(HexUtil.hexToInt(a5LightTimerRespInnerFrame01.getResponseStatus())); // } // // } catch (BusinessException e) { // lightTaskPoleRelation01.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // } // // // 灯头2 rrpc 发生定时命令 // try { // A5LightTimerRespInnerFrame a5LightTimerRespInnerFrame02 = sendTimeRRpc(framePayload, pole.getDeviceCode(), "0002"); // //灯头2 // if (a5LightTimerRespInnerFrame02 == null) { // lightTaskPoleRelation02.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // } else { // lightTaskPoleRelation02.setIssueStatus(HexUtil.hexToInt(a5LightTimerRespInnerFrame02.getResponseStatus())); // } // // } catch (BusinessException e) { // lightTaskPoleRelation02.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // } // // lightTaskPoleRelationList.add(lightTaskPoleRelation01); // lightTaskPoleRelationList.add(lightTaskPoleRelation02); // } else { lightTaskPoleRelation.setDeviceCode(pole.getDeviceCode()); lightTaskPoleRelation.setLightAddress(lightAddress); // rrpc 发生定时命令 try { A5LightTimerRespInnerFrame a5LightTimerRespInnerFrame = sendTimeRRpc(framePayload, pole.getDeviceCode(), lightAddress); if (a5LightTimerRespInnerFrame == null) { lightTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); } else { lightTaskPoleRelation.setIssueStatus(HexUtil.hexToInt(a5LightTimerRespInnerFrame.getResponseStatus())); } } catch (BusinessException e) { e.printStackTrace(); lightTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); } lightTaskPoleRelationList.add(lightTaskPoleRelation); } // } return lightTaskPoleRelationList; } /** * 用于任务编辑 * * @param poleIdList * @param framePayload * @param lightAddress * @return */ private Map> sendControllerFrame(List poleIdList, String framePayload, String lightAddress) { System.out.println("framePayload:" + framePayload); List lightTaskPoleRelationList = 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,不能下发任务 请检查灯杆是否存在单灯"); } LightTaskPoleRelation lightTaskPoleRelation = new LightTaskPoleRelation(); lightTaskPoleRelation.setPoleId(pole.getId()); //关系表插入灯头地址 lightTaskPoleRelation.setLightAddress(lightAddress); // rrpc 发生定时命令 // if ("FFFF".equals(lightAddress)) { // LightTaskPoleRelation lightTaskPoleRelation01 = new LightTaskPoleRelation(); // lightTaskPoleRelation01.setPoleId(pole.getId()); // lightTaskPoleRelation01.setLightAddress("0001"); // // LightTaskPoleRelation lightTaskPoleRelation02 = new LightTaskPoleRelation(); // lightTaskPoleRelation02.setPoleId(pole.getId()); // lightTaskPoleRelation02.setLightAddress("0002"); // // // 灯头1 rrpc 发生定时命令 // try { // A5LightTimerRespInnerFrame a5LightTimerRespInnerFrame01 = sendTimeRRpc(framePayload, pole.getDeviceCode(), "0001"); // //灯头1 // if (a5LightTimerRespInnerFrame01 == null) { // lightTaskPoleRelation01.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // fail.add(lightTaskPoleRelation01); // } else { // lightTaskPoleRelation01.setIssueStatus(HexUtil.hexToInt(a5LightTimerRespInnerFrame01.getResponseStatus())); // success.add(lightTaskPoleRelation01); // } // // } catch (BusinessException e) { // lightTaskPoleRelation01.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // fail.add(lightTaskPoleRelation01); // } // // // 灯头2 rrpc 发生定时命令 // try { // A5LightTimerRespInnerFrame a5LightTimerRespInnerFrame02 = sendTimeRRpc(framePayload, pole.getDeviceCode(), "0002"); // //灯头2 // if (a5LightTimerRespInnerFrame02 == null) { // lightTaskPoleRelation02.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // fail.add(lightTaskPoleRelation02); // } else { // lightTaskPoleRelation02.setIssueStatus(HexUtil.hexToInt(a5LightTimerRespInnerFrame02.getResponseStatus())); // success.add(lightTaskPoleRelation02); // } // // } catch (BusinessException e) { // lightTaskPoleRelation02.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); // fail.add(lightTaskPoleRelation02); // } // // lightTaskPoleRelationList.add(lightTaskPoleRelation01); // lightTaskPoleRelationList.add(lightTaskPoleRelation02); // } else { lightTaskPoleRelation.setLightAddress(lightAddress); lightTaskPoleRelation.setDeviceCode(pole.getDeviceCode()); // rrpc 发生定时命令 try { A5LightTimerRespInnerFrame a5LightTimerRespInnerFrame = sendTimeRRpc(framePayload, pole.getDeviceCode(), lightAddress); if (a5LightTimerRespInnerFrame == null) { lightTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); fail.add(lightTaskPoleRelation); } else { lightTaskPoleRelation.setIssueStatus(HexUtil.hexToInt(a5LightTimerRespInnerFrame.getResponseStatus())); success.add(lightTaskPoleRelation); } } catch (BusinessException e) { lightTaskPoleRelation.setIssueStatus(DeviceRespStatusEnums.OTHER_ERROR.getCode()); fail.add(lightTaskPoleRelation); } lightTaskPoleRelationList.add(lightTaskPoleRelation); } // } map.put("success", success); map.put("fail", fail); map.put("all", lightTaskPoleRelationList); log.error("发送控制器帧结果：{}", map); return map; } @Transactional(rollbackFor = Exception.class) public String delLightTask(List taskIdList) { List lightTaskList = listByIds(taskIdList); if (CollectionUtil.isEmpty(lightTaskList)) { throw new BusinessException("找不到任务信息"); } //取出任务关系 List relations = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getTaskId, taskIdList)); //取出灯杆id List poleIds = relations.stream().map(LightTaskPoleRelation::getPoleId).distinct().collect(Collectors.toList()); //下发清除任务指令 // boolean b = clearLightTask(lightTaskIds); Map> ffff = sendControllerFrame(poleIds, "", "FFFF"); /** * 删除控灯任务日志记录开始 */ String content = "{控灯任务id：" + taskIdList + " }"; StoreOperationRecordsUtils.storeOperationData(null, null, "删除控灯任务", content); /** * 删除控灯任务日志记录结束 */ if (ffff.get("fail").size() == 0) { //全部清除成功 删除全部任务关系 lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getTaskId, taskIdList)); //删除任务 removeByIds(taskIdList); return "任务删除成功"; } else { //部分清除成功 删除成功部分的任务关系 ffff.get("success").forEach(lightTaskPoleRelation -> { lightTaskPoleRelationService.remove(Wrappers.lambdaUpdate(LightTaskPoleRelation.class) .eq(LightTaskPoleRelation::getPoleId, lightTaskPoleRelation.getPoleId()).eq(LightTaskPoleRelation::getTaskId, lightTaskPoleRelation.getTaskId())); }); //删除任务 lightTaskList.forEach( taskId -> { List poleRelations = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getTaskId, taskId)); if (poleRelations.size() == 0) { //不存在任务关系 删除任务 removeById(taskId); } } ); return "部分任务删除成功,清除任务失败的任务及数据保留"; } } /** * 任务详情 */ public Map detailLightTask(Long taskId) { LightTask lightTask = getById(taskId); if (lightTask == null) { throw new BusinessException("找不到任务"); } List lightTaskStatusAndPoles = lightTaskPoleRelationService.listPoleAndStatusIdByTaskId(taskId); return MapUtil.builder().put("task", lightTask).put("poles", lightTaskStatusAndPoles).build(); } /** * 根据任务信息转成帧负荷 * * @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, LightTaskParam.REQUEST_ORDER_LENGTH); Integer[] weekArrays = TaskOrderUtil.parseLightCronWeek2List(week).toArray(new Integer[0]); if (openLightOrder == null || closeLightOrder == null) { throw new BusinessException("解析单灯命令失败"); } 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(); } /** * 下发单个灯杆的任务 */ public boolean issueLightTask(LightTaskIssueParam param) { LightTask lightTask = getById(param.getTaskId()); if (lightTask == null) { throw new BusinessException("找不到任务"); } String framePayload = buildControlFramePayload(lightTask.getOpenOrder(), lightTask.getCloseOrder(), lightTask.getControlOrder(), lightTask.getWeek()); List lightTaskPoleRelationList = sendControllerFrame(lightTask, ListUtil.toList(param.getPoleId()), framePayload, lightTask.getLightAdress()); /** * 下发路灯任务日志记录开始 */ 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：" + lightTask.getTaskId() + "， 任务名：" + lightTask.getTaskName() + "}," + " 灯杆ID：" + param.getPoleId() + " }"; StoreOperationRecordsUtils.storeOperationData(poleCodeList, null, "下发路灯任务", content); /** * 下发路灯任务日志记录结束 */ if (CollectionUtil.isNotEmpty(lightTaskPoleRelationList)) { return lightTaskPoleRelationService.update(lightTaskPoleRelationList.get(0), Wrappers.lambdaUpdate(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getPoleId, param.getPoleId()).eq(LightTaskPoleRelation::getTaskId, param.getTaskId())); } return true; } /** * 计算功率及能耗 */ public void energy() { List lightTasks = list(Wrappers.lambdaQuery(LightTask.class)); List taskIdList = new ArrayList<>(); for (LightTask bean : lightTasks) { taskIdList.add(bean.getTaskId()); } if (taskIdList.size() != 0) { List list = SpringContextHolder.getBean(LightTaskPoleRelationMapper.class).test(taskIdList); for (LightTaskPoleRelationBo bean : list) { LightTaskDto lightTaskDto = new LightTaskDto(); BeanUtils.copyProperties(bean, lightTaskDto); lightTaskDto.setWeekList(TaskOrderUtil.parseLightWeek2List(bean.getWeek())); BigDecimal energySaving; BigDecimal energy; //获取昨天的星期数 LocalDateTime now = LocalDateTime.now(); LocalDateTime yesterday = now.minusDays(1); int week = yesterday.getDayOfWeek().getValue(); if (!list.isEmpty()) { //有绑定灯杆 进行计算 if (lightTaskDto.getWeekList().contains(week)) { //任务有该星期数 计算 energySaving = SpringContextHolder.getBean(LightService.class).jisuan(lightTaskDto); energy = SpringContextHolder.getBean(LightService.class).jisuanEnergy(lightTaskDto); } else { //任务无该星期数 返回 energySaving = new BigDecimal(1); energy = BigDecimal.ZERO; } for (int i = 0; i < list.size(); i++) { LightTaskPoleRelation relation = list.get(i); if (relation.getIssueStatus() != 0) { //任务下发失败 返回 energySaving = new BigDecimal(1); energy = BigDecimal.ZERO; } } } else { //未绑定灯杆 直接返回 energySaving = new BigDecimal(1); energy = BigDecimal.ZERO; } /** * 存储数据 */ LightEnergyData lightEnergyData = new LightEnergyData(); lightEnergyData.setTaskId(bean.getTaskId()); lightEnergyData.setYtdTime(yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); lightEnergyData.setEnergySaving(energySaving); lightEnergyData.setEnergy(energy); lightEnergyData.setUserId(bean.getUserId()); lightEnergyData.setClientId(bean.getClientId()); lightEnergyData.setPoleId(bean.getPoleId()); //保存能耗数据到数据库 lightEnergyDataService.save(lightEnergyData); } } } public boolean clearLightTask(List poleIds) { Map> ffff = sendControllerFrame(poleIds, "", "FFFF"); ffff.get("success").forEach(lightTaskPoleRelation -> { lightTaskPoleRelationService.remove(Wrappers.lambdaUpdate(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getPoleId, lightTaskPoleRelation.getPoleId()).eq(LightTaskPoleRelation::getTaskId, lightTaskPoleRelation.getTaskId())); }); return true; } public Map checkTask(LightTaskParam param) { /** * 重复任务的灯头 */ String lightAddress = param.getLightAddress(); List poleIdList = param.getPoleIdList(); List lightTaskPoleRelations = lightTaskPoleRelationService.list(Wrappers.lambdaQuery(LightTaskPoleRelation.class) .in(LightTaskPoleRelation::getPoleId, poleIdList).eq(LightTaskPoleRelation::getLightAddress, param.getLightAddress())); List taskIds = lightTaskPoleRelations.stream().map(LightTaskPoleRelation::getTaskId).collect(Collectors.toList()); List poleIds = lightTaskPoleRelations.stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList()); //poleIds中重复元素只保留一个 taskIds = taskIds.stream().distinct().collect(Collectors.toList()); poleIds = poleIds.stream().distinct().collect(Collectors.toList()); Map map = new HashMap(); if (!lightTaskPoleRelations.isEmpty()) { map.put("request", "false"); map.put("msg", "任务中存在已有任务的单灯," + "任务id为{" + taskIds + "}, " + "灯杆id为{" + poleIds + "}"); // throw new BusinessException("任务中存在已有任务的单灯," + "任务id为{" + taskIds + "}, " // + "灯杆id为{" + poleIds + "}"); } else { map.put("request", "true"); map.put("msg", "任务中无重复灯杆地址"); } return map; } }