package com.huimv.env.input.server; import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.huimv.env.input.c.MyNativeClass; import com.huimv.env.input.config.WeChatMessage; import com.huimv.env.input.entity.*; import com.huimv.env.input.mapper.TerminalPortMapper; import com.huimv.env.input.service.*; import com.huimv.env.input.ws.WebsocketWorkerUtil; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.util.CharsetUtil; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.util.ObjectUtils; import java.io.*; import java.math.BigDecimal; import java.text.DecimalFormat; import java.text.ParseException; import java.util.Arrays; import java.util.Collections; import java.util.Date; import java.util.List; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; import java.util.stream.IntStream; import java.util.stream.Stream; /** * @Project : huimv.shiwan * @Package : com.huimv.biosafety.uface.controller * @Description : TODO * @Version : 1.0 * @Author : ZhuoNing * @Create : 2020-12-25 **/ @ChannelHandler.Sharable @Component @Log4j2 public class EnvInputServerHandler extends ChannelInboundHandlerAdapter { private StringBuilder askTextSb = null; @Autowired private IEnvDataService envDataService; @Autowired private ITerminalPortService terminalPortService; @Autowired private IBaseFarmService baseFarmService; @Autowired private IBasePigpenService basePigpenService; @Autowired private IPortWarningInfoService portWarningInfoService; @Autowired private IPortChangeDataService portChangeDataService; @Autowired private ITerminalService terminalService; @Autowired private IHeartInfoService heartInfoService; @Autowired private ISysAccountMultilevelService sysAccountMultilevelService; // public void appendClientAsk(String text) { if (this.askTextSb == null) { askTextSb = new StringBuilder(); } askTextSb.append(text); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { ByteBuf data = (ByteBuf) msg; String clientAskText = data.toString(CharsetUtil.UTF_8); //保存实例内的客户端请求 appendClientAsk(clientAskText); //临时写入耳标数据到文件 // writeTxt(clientAskText,"all"); } @Override public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { if (askTextSb.toString().indexOf("end") != -1) { // {处理客户端消息} handleClientAskCmd(askTextSb.toString(), ctx); //清空重置; askTextSb.delete(0, askTextSb.length()); } } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { if (cause.getMessage().indexOf("Connection reset") != -1) { log.info("相关采集器设备正在重启:" + cause.toString()); } // cause.printStackTrace(); ctx.close(); } /** * @Method : handleClientAskCmd * @Description : 处理请求小心 * @Params : [clientAskText, ctx] * @Return : void * @Author : ZhuoNing * @Date : 2022/3/28 * @Time : 17:36 */ private void handleClientAskCmd(String clientAskText, ChannelHandlerContext ctx) throws ParseException, IOException { clientAskText = clientAskText.replaceAll("\r", "").replaceAll("\n", ""); //{处理非正常命令} // int countPlus = regexUtil.countPlus(clientAskText); // if (countPlus < 4) { // System.out.println("当前数据为不完整数据，故丢弃.>>" + clientAskText); // } else { //--处理客户端请求数据 //{拆分粘包数据} JSONArray askJa = parseAskCmdPackage(clientAskText); for (int a = 0; a < askJa.size(); a++) { String askText = askJa.getString(a); //{处理请求命令} askCmdActuator(askText, ctx); } // } } /** * @Method : askCmdActuator * @Description : * @Params : [askText, ctx] * @Return : void * @Author : ZhuoNing * @Date : 2022/3/23 * @Time : 18:08 */ private void askCmdActuator(String askText, ChannelHandlerContext ctx) throws ParseException, IOException { System.out.println("======>接收设备请求:" + askText); String[] dataArray = askText.split("\\+"); String cmdHeader = dataArray[0]; if (!cmdHeader.trim().equalsIgnoreCase("hm")) { log.info("当前命令是非hm命令[" + askText + "]"); return; } String version = dataArray[dataArray.length - 3]; if ("v2.0".equals(version)) { askCmdActuatorV2(askText, ctx, dataArray); } else { askCmdActuatorV1(askText, ctx, dataArray); log.info("当前版本异常[" + askText + "]"); } } private void askCmdActuatorV2(String askText, ChannelHandlerContext ctx, String[] dataArray){ //芯片id/设备编码 String cmd = dataArray[1]; switch (cmd) { case "1": //心跳 getHear(askText, dataArray, ctx,2); break; case "2": //上传数据 getChuanGanData2(askText, dataArray, ctx); break; case "3": //充电前后功率 savePower2(askText, dataArray, ctx); break; case "4": //充电中电流 saveElectric2(askText, dataArray, ctx); break; case "5": //充电前电流 saveBeforeElectric2(askText, dataArray, ctx); break; default: log.error(String.format("未知指令 --> %s", askText)); answerCmd("hm+4+1+end", ctx); } } private synchronized void saveBeforeElectric2(String askText, String[] dataArray, ChannelHandlerContext ctx) { String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = "1"; String num = dataArray[4]; String eleData = dataArray[5]; Date now = new Date(); try { PortChangeData portChangeData = portChangeDataService.getOne(new QueryWrapper().eq("terminal_port_code", gateWayCode + terminalCode + terminalPortCode).eq("num", num)); if (ObjectUtils.isEmpty(portChangeData)) { portChangeData = new PortChangeData(); portChangeData.setNum(Integer.parseInt(num)); portChangeData.setCreateTime(now); portChangeData.setGatwayCode(gateWayCode); portChangeData.setTerminalCode(gateWayCode+terminalCode); portChangeData.setTerminalPortCode(gateWayCode+terminalCode+terminalPortCode); portChangeData.setBeforeElectricCurrent(eleData); portChangeDataService.save(portChangeData); }else { portChangeData.setBeforeElectricCurrent(eleData); portChangeDataService.updateById(portChangeData); if(changeDataIsAll(portChangeData)){ // int i = getStatusEle(portChangeData); int i = getStatusEle2(portChangeData); TerminalPort deviceCode = terminalPortService.getOne(new QueryWrapper().eq("device_code", portChangeData.getTerminalPortCode())); System.out.println("---->"+i); if (i == 1){ deviceCode.setChargingWarning(1); String ans = "hm+5+1+end"; answerCmd(ans,ctx); saveChargingWarning(portChangeData,deviceCode); }else { String ans = "hm+5+0+end"; answerCmd(ans,ctx); deviceCode.setChargingWarning(0); } terminalPortService.updateById(deviceCode); } } }catch (Exception e){ log.error(String.format("点位查询失败--> %s" ,askText)); log.error(e); } } private int getStatusEle2(PortChangeData portChangeData) { // 前有功功率 前无功功率 前视在功率 + 前 128个电流值 String[] lastEleData = portChangeData.getBeforeElectricCurrent().split(","); String[] lastGlData =new String[]{String.valueOf(portChangeData.getBeforeActivePower()),String.valueOf(portChangeData.getBeforeReactivePower()),String.valueOf(portChangeData.getBeforeApparentPower())}; // 有功功率 无功功率 视在功率 + 128个电流值 String[] curretEleData = portChangeData.getElectricCurrent().split(","); String[] curretGlData =new String[]{String.valueOf(portChangeData.getActivePower()),String.valueOf(portChangeData.getReactivePower()),String.valueOf(portChangeData.getApparentPower())}; Object[] ints = Stream.concat( Arrays.stream(lastGlData),Arrays.stream(lastEleData)).toArray(); Object[] ints1 = Stream.concat(Arrays.stream(curretGlData) ,Arrays.stream(curretEleData)).toArray(); // return MyNativeClass.LibraryshowChar.LIBRARY_CHAR.current_detection(ints,ints1 ); return add2(ints,ints1 ); // return MyNativeClass.LibraryshowChar.LIBRARY_CHAR.current_detection( ); } public int add2(Object[] array1 , Object[] array2) { // 步骤1: 将两个数组写入临时文件 String tempInputFile = "temp_input.txt"; try (BufferedWriter writer = new BufferedWriter(new FileWriter(tempInputFile))) { String array1String = Arrays.stream(array1) .map(Object::toString) // 使用 Object 的 toString 方法转换为 String .collect(Collectors.joining(",")); writer.write(array1String); writer.newLine(); // 换行 // 写入第二个数组 String array2String = Arrays.stream(array2) .map(Object::toString) // 使用 Object 的 toString 方法转换为 String .collect(Collectors.joining(",")); writer.write(array2String); writer.newLine(); // 换行 } catch (IOException e) { e.printStackTrace(); return 0; } // 步骤2: 调用C程序 String cProgramPath = "/root/svm_detection_c/predict"; // 替换为你的C程序的实际路径 String tempOutputFile = "temp_output.txt"; // 假设C程序将结果写入此文件 ProcessBuilder processBuilder = new ProcessBuilder(cProgramPath, tempInputFile, tempOutputFile); try { Process process = processBuilder.start(); int exitCode = process.waitFor(); if (exitCode != 0) { System.err.println("C program execution failed with exit code: " + exitCode); return 0; } } catch (IOException | InterruptedException e) { e.printStackTrace(); return 0; } // 步骤3: 读取结果文件 try (BufferedReader reader = new BufferedReader(new FileReader(tempOutputFile))) { String line; String str ="1"; while ((line = reader.readLine()) != null) { System.out.println("line"+line); // 或者你可以将结果存储到某个变量或集合中 str = line; } return Integer.parseInt(str); } catch (IOException e) { e.printStackTrace(); return 0; } // 步骤4: 删除所有文件 // Path inputFilePath = Paths.get(tempInputFile); // Path outputFilePath = Paths.get(tempOutputFile); // try { // Files.deleteIfExists(inputFilePath); // Files.deleteIfExists(outputFilePath); // } catch (IOException e) { // e.printStackTrace(); // } } private synchronized void saveElectric2(String askText, String[] dataArray, ChannelHandlerContext ctx) { String ans = "hm+4+1+end"; answerCmd(ans,ctx); String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = "1"; String num = dataArray[4]; String eleData = dataArray[5]; Date now = new Date(); try { PortChangeData portChangeData = portChangeDataService.getOne(new QueryWrapper().eq("terminal_port_code", gateWayCode + terminalCode + terminalPortCode).eq("num", num)); if (ObjectUtils.isEmpty(portChangeData)) { portChangeData = new PortChangeData(); portChangeData.setNum(Integer.parseInt(num)); portChangeData.setCreateTime(now); portChangeData.setGatwayCode(gateWayCode); portChangeData.setTerminalCode(gateWayCode+terminalCode); portChangeData.setTerminalPortCode(gateWayCode+terminalCode+terminalPortCode); portChangeData.setElectricCurrent(eleData); portChangeDataService.save(portChangeData); }else { portChangeData.setElectricCurrent(eleData); portChangeDataService.updateById(portChangeData); // if(changeDataIsAll(portChangeData)){ // int i = getStatusEle(portChangeData); // TerminalPort deviceCode = terminalPortService.getOne(new QueryWrapper().eq("device_code", portChangeData.getTerminalPortCode())); // if (i == 1){ // deviceCode.setChargingWarning(1); // saveChargingWarning(portChangeData,deviceCode); // }else { // deviceCode.setChargingWarning(0); // } // terminalPortService.updateById(deviceCode); // } } }catch (Exception e){ log.error(String.format("点位查询失败--> %s" ,askText)); log.error(e); } } private synchronized void savePower2(String askText, String[] dataArray, ChannelHandlerContext ctx) { String ans = "hm+3+1+end"; answerCmd(ans,ctx); String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = "1"; String num = dataArray[4]; int[] splitPower = Arrays.stream(dataArray[5].split(",")).mapToInt(Integer::parseInt).toArray(); int[] splitBeforePower = Arrays.stream(dataArray[6].split(",")).mapToInt(Integer::parseInt).toArray(); Date now = new Date(); try { PortChangeData portChangeData = portChangeDataService.getOne(new QueryWrapper().eq("terminal_port_code", gateWayCode + terminalCode + terminalPortCode).eq("num", num)); if (ObjectUtils.isEmpty(portChangeData)) { portChangeData = new PortChangeData(gateWayCode + terminalCode + terminalPortCode,gateWayCode + terminalCode ,gateWayCode, splitPower[0],splitPower[1],splitPower[2], splitBeforePower[0],splitBeforePower[1],splitBeforePower[2], now,Integer.parseInt(num)); portChangeDataService.save(portChangeData); }else { portChangeData.setActivePower( splitPower[0]); portChangeData.setReactivePower( splitPower[1]); portChangeData.setApparentPower( splitPower[2]); portChangeData.setBeforeActivePower(splitBeforePower[0]); portChangeData.setBeforeReactivePower(splitBeforePower[1]); portChangeData.setBeforeApparentPower(splitBeforePower[2]); portChangeDataService.updateById(portChangeData); } }catch (Exception e){ log.error(String.format("点位查询失败--> %s" ,askText)); log.error(e); } } private int getStatusEle(PortChangeData portChangeData) { // 前有功功率 前无功功率 前视在功率 + 前 128个电流值 int[] lastEleData = Arrays.stream(portChangeData.getBeforeElectricCurrent().split(",")).mapToInt(Integer::parseInt).toArray(); int[] lastGlData = new int[]{portChangeData.getBeforeActivePower(),portChangeData.getBeforeReactivePower(),portChangeData.getBeforeApparentPower()}; // 有功功率 无功功率 视在功率 + 128个电流值 int[] curretEleData =Arrays.stream(portChangeData.getElectricCurrent().split(",")).mapToInt(Integer::parseInt).toArray(); int[] curretGlData = new int[]{portChangeData.getActivePower(),portChangeData.getReactivePower(),portChangeData.getApparentPower()}; int[] ints = IntStream.concat( Arrays.stream(lastGlData),Arrays.stream(lastEleData)).toArray(); int[] ints1 = IntStream.concat(Arrays.stream(curretGlData) ,Arrays.stream(curretEleData)).toArray(); System.out.println("last"); for (int i : ints) { System.out.print(i+","); } System.out.println(); System.out.println("curretData"); for (int i : ints1) { System.out.print(i+","); } System.out.println(); return MyNativeClass.LibraryshowChar.LIBRARY_CHAR.current_detection(ints,ints1 ); // return MyNativeClass.LibraryshowChar.LIBRARY_CHAR.current_detection( ); } private void saveChargingWarning(PortChangeData portChangeData ,TerminalPort deviceCode) { BasePigpen basePigpen = basePigpenService.getById(deviceCode.getLocationId()); BasePigpen basePigpen1= basePigpenService.getById(basePigpen.getOther2().split(",")[1]); PortWarningInfo portWarningInfo = new PortWarningInfo(); portWarningInfo.setGatwayCode(portChangeData.getGatwayCode()); portWarningInfo.setTerminalCode(portChangeData.getTerminalCode()); portWarningInfo.setTerminalPortCode(portChangeData.getTerminalPortCode()); portWarningInfo.setLocationId(deviceCode.getLocationId()); portWarningInfo.setFarmId(deviceCode.getFarmId()); portWarningInfo.setWarningType(2); Date now = new Date(); portWarningInfo.setCreateTime(now); portWarningInfo.setContent(String.format("%s 充电预警",basePigpen.getBuildName())); portWarningInfo.setWarningType(2); portWarningInfoService.save(portWarningInfo); List list = sysAccountMultilevelService.list(new QueryWrapper().eq("last_farm_id", deviceCode.getFarmId()).eq("subscribe", 1)); for (SysAccountMultilevel sysAccountMultilevel : list) { WeChatMessage.sendMsg(now,"充电预警",basePigpen1.getBuildName(),basePigpen.getBuildName().substring(basePigpen1.getBuildName().length()),sysAccountMultilevel.getWechatId()); sysAccountMultilevel.setSubscribe(0); sysAccountMultilevelService.updateById(sysAccountMultilevel); } WebsocketWorkerUtil.sendWarningMessage(deviceCode.getFarmId(),String.format("%s 充电预警",basePigpen.getBuildName())); } private boolean changeDataIsAll(PortChangeData portChangeData) { return portChangeData.getActivePower() != null && portChangeData.getBeforeActivePower() != null && portChangeData.getReactivePower() != null && portChangeData.getBeforeReactivePower() != null && portChangeData.getApparentPower() != null && portChangeData.getBeforeApparentPower() != null && portChangeData.getElectricCurrent() != null && portChangeData.getBeforeElectricCurrent() != null ; } private void getChuanGanData2(String askText, String[] dataArray, ChannelHandlerContext ctx) { String ans = "hm+2+1+end"; answerCmd(ans,ctx); //hm+2+867699060007086+1+2222+7+260+0+104,17,159+0,0+v2.0+24+end String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = "1"; String voltage = getNum(dataArray[4]); String electriCurrent = getNum(dataArray[5]); String temp = getNum(dataArray[6]); String leakageValue = getNum(dataArray[7]); Date now = new Date(); int[] splitPower = Arrays.stream(dataArray[8].split(",")).mapToInt(Integer::parseInt).toArray(); int[] splitStatus =Arrays.stream(dataArray[9].split(",")).mapToInt(Integer::parseInt).toArray(); EnvData envData = new EnvData(gateWayCode+terminalCode+terminalPortCode,gateWayCode+terminalCode,gateWayCode, voltage,electriCurrent,temp, leakageValue, splitPower[0],splitPower[1],splitPower[2], splitStatus[0],0,splitStatus[1], askText,now); envDataService.save(envData); //更新状态 // try { TerminalPort deviceCode = terminalPortService.getOne(new QueryWrapper().eq("device_code", gateWayCode + terminalCode + terminalPortCode)); if (ObjectUtils.isEmpty(deviceCode)){ log.info(String.format("无端口设备--> %s" ,askText)); return; } deviceCode.setVoltage(voltage); deviceCode.setElectricCurrent(electriCurrent); deviceCode.setTemp(temp); deviceCode.setLeakageValue(leakageValue); deviceCode.setActivePower( splitPower[0]); deviceCode.setReactivePower(splitPower[1]); deviceCode.setApparentPower(splitPower[2]); deviceCode.setHeightTempWarning( splitStatus[0]); deviceCode.setChargingWarning( 0); deviceCode.setLeakageWarning( splitStatus[1]); deviceCode.setUpdateTime(now); deviceCode.setStatus(1); terminalPortService.updateById(deviceCode); //添加报警 saveWarning2(gateWayCode,terminalCode,terminalPortCode,deviceCode,splitStatus,now); } private void saveWarning2(String gateWayCode,String terminaCode,String terminalPortCode ,TerminalPort terminalPort,int[] splitStatus,Date now) { if (splitStatus[0] == 0 && splitStatus[1] == 0 ) return; Integer farmId = terminalPort.getFarmId(); Integer locationId = terminalPort.getLocationId(); BasePigpen basePigpen = basePigpenService.getById(locationId); BasePigpen basePigpen1= basePigpenService.getById(basePigpen.getOther2().split(",")[1]); if (ObjectUtils.isEmpty(basePigpen)){ log.info(String.format("无栋舍数据--> %s" ,terminalPort.toString())); return; } PortWarningInfo portWarningInfo = new PortWarningInfo(); portWarningInfo.setGatwayCode(gateWayCode); portWarningInfo.setTerminalCode(gateWayCode+terminaCode); portWarningInfo.setTerminalPortCode(gateWayCode+ terminaCode +terminalPortCode); portWarningInfo.setLocationId(locationId); portWarningInfo.setFarmId(farmId); portWarningInfo.setWarningType(farmId); portWarningInfo.setCreateTime(now); if (splitStatus[0] == 1){ portWarningInfo.setContent(String.format("%s 高温预警",basePigpen.getBuildName())); portWarningInfo.setWarningType(1); portWarningInfoService.save(portWarningInfo); List list = sysAccountMultilevelService.list(new QueryWrapper().eq("last_farm_id", farmId).eq("subscribe", 1)); for (SysAccountMultilevel sysAccountMultilevel : list) { WeChatMessage.sendMsg(now,"充电预警",basePigpen1.getBuildName(),basePigpen.getBuildName().substring(basePigpen1.getBuildName().length()),sysAccountMultilevel.getWechatId()); sysAccountMultilevel.setSubscribe(0); sysAccountMultilevelService.updateById(sysAccountMultilevel); } WebsocketWorkerUtil.sendWarningMessage(farmId,String.format("%s 高温预警",basePigpen.getBuildName())); } if (splitStatus[1] == 1){ portWarningInfo.setContent(String.format("%s 漏电预警",basePigpen.getBuildName())); portWarningInfo.setWarningType(3); portWarningInfoService.save(portWarningInfo); List list = sysAccountMultilevelService.list(new QueryWrapper().eq("last_farm_id", farmId).eq("subscribe", 1)); for (SysAccountMultilevel sysAccountMultilevel : list) { WeChatMessage.sendMsg(now,"充电预警",basePigpen1.getBuildName(),basePigpen.getBuildName().substring(basePigpen1.getBuildName().length()),sysAccountMultilevel.getWechatId()); sysAccountMultilevel.setSubscribe(0); sysAccountMultilevelService.updateById(sysAccountMultilevel); } WebsocketWorkerUtil.sendWarningMessage(farmId,String.format("%s 漏电预警",basePigpen.getBuildName())); } } private void askCmdActuatorV1(String askText, ChannelHandlerContext ctx, String[] dataArray){ //芯片id/设备编码 String cmd = dataArray[1]; switch (cmd) { case "1": //心跳 getHear(askText, dataArray, ctx,1); break; case "2": //上传数据 getChuanGanData(askText, dataArray, ctx); break; case "3": //充电前后功率 savePower(askText, dataArray, ctx); break; case "4": //充电中电流 saveElectric(askText, dataArray, ctx); break; case "5": //充电前电流 saveBeforeElectric(askText, dataArray, ctx); break; default: log.error(String.format("未知指令 --> %s", askText)); answerCmd("hm+4+1+end", ctx); } } private synchronized void saveBeforeElectric(String askText, String[] dataArray, ChannelHandlerContext ctx) { String ans = "hm+5+1+end"; answerCmd(ans,ctx); String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = dataArray[4]; String num = dataArray[5]; String eleData = dataArray[6]; Date now = new Date(); try { PortChangeData portChangeData = portChangeDataService.getOne(new QueryWrapper().eq("terminal_port_code", gateWayCode + terminalCode + terminalPortCode).eq("num", num)); if (ObjectUtils.isEmpty(portChangeData)) { portChangeData = new PortChangeData(); portChangeData.setNum(Integer.parseInt(num)); portChangeData.setCreateTime(now); portChangeData.setGatwayCode(gateWayCode); portChangeData.setTerminalCode(gateWayCode+terminalCode); portChangeData.setTerminalPortCode(gateWayCode+terminalCode+terminalPortCode); portChangeData.setBeforeElectricCurrent(eleData); portChangeDataService.save(portChangeData); }else { portChangeData.setBeforeElectricCurrent(eleData); portChangeDataService.updateById(portChangeData); } }catch (Exception e){ log.error(String.format("点位查询失败--> %s" ,askText)); log.error(e); } } private synchronized void saveElectric(String askText, String[] dataArray, ChannelHandlerContext ctx) { String ans = "hm+4+1+end"; answerCmd(ans,ctx); String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = dataArray[4]; String num = dataArray[5]; String eleData = dataArray[6]; Date now = new Date(); try { PortChangeData portChangeData = portChangeDataService.getOne(new QueryWrapper().eq("terminal_port_code", gateWayCode + terminalCode + terminalPortCode).eq("num", num)); if (ObjectUtils.isEmpty(portChangeData)) { portChangeData = new PortChangeData(); portChangeData.setNum(Integer.parseInt(num)); portChangeData.setCreateTime(now); portChangeData.setGatwayCode(gateWayCode); portChangeData.setTerminalCode(gateWayCode+terminalCode); portChangeData.setTerminalPortCode(gateWayCode+terminalCode+terminalPortCode); portChangeData.setElectricCurrent(eleData); portChangeDataService.save(portChangeData); }else { portChangeData.setElectricCurrent(eleData); portChangeDataService.updateById(portChangeData); } }catch (Exception e){ log.error(String.format("点位查询失败--> %s" ,askText)); log.error(e); } } public String reverseWithComma(String input) { String[] parts = input.split(","); List partList = Arrays.asList(parts); Collections.reverse(partList); StringBuilder reversedBuilder = new StringBuilder(); for (int i = 0; i < partList.size(); i++) { reversedBuilder.append(partList.get(i)); if (i < partList.size() - 1) { reversedBuilder.append(","); } } return reversedBuilder.toString(); } private synchronized void savePower(String askText, String[] dataArray, ChannelHandlerContext ctx) { String ans = "hm+3+1+end"; answerCmd(ans,ctx); String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = dataArray[4]; String num = dataArray[5]; int[] splitPower = Arrays.stream(dataArray[6].split(",")).mapToInt(Integer::parseInt).toArray(); int[] splitBeforePower = Arrays.stream(dataArray[7].split(",")).mapToInt(Integer::parseInt).toArray(); Date now = new Date(); try { PortChangeData portChangeData = portChangeDataService.getOne(new QueryWrapper().eq("terminal_port_code", gateWayCode + terminalCode + terminalPortCode).eq("num", num)); if (ObjectUtils.isEmpty(portChangeData)) { portChangeData = new PortChangeData(gateWayCode + terminalCode + terminalPortCode,gateWayCode + terminalCode ,gateWayCode, splitPower[0],splitPower[1],splitPower[2], splitBeforePower[0],splitBeforePower[1],splitBeforePower[2], now,Integer.parseInt(num)); portChangeDataService.save(portChangeData); }else { portChangeData.setActivePower( splitPower[0]); portChangeData.setReactivePower( splitPower[1]); portChangeData.setApparentPower( splitPower[2]); portChangeData.setBeforeActivePower(splitBeforePower[0]); portChangeData.setBeforeReactivePower(splitBeforePower[1]); portChangeData.setBeforeApparentPower(splitBeforePower[2]); portChangeDataService.updateById(portChangeData); } }catch (Exception e){ log.error(String.format("点位查询失败--> %s" ,askText)); log.error(e); } } private void getHear(String askText,String[] dataArray, ChannelHandlerContext ctx,int version) { /** * 接口中只需要定义你要用到的函数或者公共变量，不需要的可以不定义 * 映射libadd.so里面的函数，注意类型要匹配 */ String ans = "hm+1+1+end"; answerCmd(ans,ctx); String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; TerminalPort terminalPort = new TerminalPort(); terminalPort.setStatus(1); terminalPortService.update(terminalPort,new UpdateWrapper().like("device_code",gateWayCode + terminalCode)); Terminal terminal = new Terminal(); terminal.setStatus(1); terminalService.update(terminal,new UpdateWrapper().eq("device_code",gateWayCode + terminalCode)); switch ( version){ case 1: HeartInfo heartInfo1 = new HeartInfo(new Date(), gateWayCode + terminalCode, gateWayCode, askText); heartInfoService.save(heartInfo1); break; case 2: HeartInfo heartInfo2 = new HeartInfo(new Date(), gateWayCode + "1", gateWayCode, askText); heartInfoService.save(heartInfo2); break; default: log.info("未知版本"); break; } } private void getChuanGanData(String askText,String[] dataArray, ChannelHandlerContext ctx) { String ans = "hm+2+1+end"; answerCmd(ans,ctx); //hm+1+867699060007086+1+1+242+3+2494+9+0+0+31+0+0+0+V1.0+0+end String gateWayCode = dataArray[2]; String terminalCode = dataArray[3]; String terminalPortCode = dataArray[4]; String voltage = getNum(dataArray[5]); String electriCurrent = getNum(dataArray[6]); String temp = getNum(dataArray[7]); String leakageValue = getNum(dataArray[8]); Date now = new Date(); int[] splitPower = Arrays.stream(dataArray[9].split(",")).mapToInt(Integer::parseInt).toArray(); int[] splitStatus =Arrays.stream(dataArray[10].split(",")).mapToInt(Integer::parseInt).toArray(); EnvData envData = new EnvData(gateWayCode+terminalCode+terminalPortCode,gateWayCode+terminalCode,gateWayCode, voltage,electriCurrent,temp, leakageValue, splitPower[0],splitPower[1],splitPower[2], splitStatus[0],splitStatus[1],splitStatus[2], askText,now); envDataService.save(envData); //更新状态 // try { TerminalPort deviceCode = terminalPortService.getOne(new QueryWrapper().eq("device_code", gateWayCode + terminalCode + terminalPortCode)); if (ObjectUtils.isEmpty(deviceCode)){ log.info(String.format("无端口设备--> %s" ,askText)); return; } deviceCode.setVoltage(voltage); deviceCode.setElectricCurrent(electriCurrent); deviceCode.setTemp(temp); deviceCode.setLeakageValue(leakageValue); deviceCode.setActivePower( splitPower[0]); deviceCode.setReactivePower(splitPower[1]); deviceCode.setApparentPower(splitPower[2]); deviceCode.setHeightTempWarning( splitStatus[0]); deviceCode.setChargingWarning( splitStatus[1]); deviceCode.setLeakageWarning( splitStatus[2]); deviceCode.setUpdateTime(now); deviceCode.setStatus(1); terminalPortService.updateById(deviceCode); //添加报警 saveWarning(gateWayCode,terminalCode,terminalPortCode,deviceCode,splitStatus,now); // }catch (Exception e){ // log.error(String.format("端口设备查询失败--> %s" ,askText)); // log.error(e); // } } private void saveWarning(String gateWayCode,String terminaCode,String terminalPortCode ,TerminalPort terminalPort,int[] splitStatus,Date now) { if (splitStatus[0] == 0 && splitStatus[1] == 0 &&splitStatus[2] == 0 ) return; Integer farmId = terminalPort.getFarmId(); Integer locationId = terminalPort.getLocationId(); BaseFarm baseFarm = baseFarmService.getById(farmId); BasePigpen basePigpen = basePigpenService.getById(locationId); if (ObjectUtils.isEmpty(baseFarm)){ log.info(String.format("无小区数据--> %s" ,terminalPort.toString())); return; } if (ObjectUtils.isEmpty(basePigpen)){ log.info(String.format("无栋舍数据--> %s" ,terminalPort.toString())); return; } BasePigpen basePigpen1= basePigpenService.getById(basePigpen.getOther2().split(",")[1]); PortWarningInfo portWarningInfo = new PortWarningInfo(); portWarningInfo.setGatwayCode(gateWayCode); portWarningInfo.setTerminalCode(gateWayCode+terminaCode); portWarningInfo.setTerminalPortCode(gateWayCode+ terminaCode +terminalPortCode); portWarningInfo.setLocationId(locationId); portWarningInfo.setFarmId(farmId); portWarningInfo.setWarningType(1); portWarningInfo.setCreateTime(now); if (splitStatus[0] == 1){ portWarningInfo.setContent(String.format("%s 高温预警",basePigpen.getBuildName())); portWarningInfo.setWarningType(1); portWarningInfoService.save(portWarningInfo); List list = sysAccountMultilevelService.list(new QueryWrapper().eq("last_farm_id", farmId).eq("subscribe", 1)); for (SysAccountMultilevel sysAccountMultilevel : list) { WeChatMessage.sendMsg(now,"充电预警",basePigpen1.getBuildName(),basePigpen.getBuildName().substring(basePigpen1.getBuildName().length()),sysAccountMultilevel.getWechatId()); sysAccountMultilevel.setSubscribe(0); sysAccountMultilevelService.updateById(sysAccountMultilevel); } WebsocketWorkerUtil.sendWarningMessage(farmId,String.format("%s 高温预警",basePigpen.getBuildName())); } if (splitStatus[1] == 1){ portWarningInfo.setContent(String.format("%s 充电预警",basePigpen.getBuildName())); portWarningInfo.setWarningType(2); portWarningInfoService.save(portWarningInfo); List list = sysAccountMultilevelService.list(new QueryWrapper().eq("last_farm_id", farmId).eq("subscribe", 1)); for (SysAccountMultilevel sysAccountMultilevel : list) { WeChatMessage.sendMsg(now,"充电预警",basePigpen1.getBuildName(),basePigpen.getBuildName().substring(basePigpen1.getBuildName().length()),sysAccountMultilevel.getWechatId()); sysAccountMultilevel.setSubscribe(0); sysAccountMultilevelService.updateById(sysAccountMultilevel); } WebsocketWorkerUtil.sendWarningMessage(farmId,String.format("%s 充电预警",basePigpen.getBuildName())); } if (splitStatus[2] == 1){ portWarningInfo.setContent(String.format("%s 漏电预警",basePigpen.getBuildName())); portWarningInfo.setWarningType(3); portWarningInfoService.save(portWarningInfo); List list = sysAccountMultilevelService.list(new QueryWrapper().eq("last_farm_id", farmId).eq("subscribe", 1)); for (SysAccountMultilevel sysAccountMultilevel : list) { WeChatMessage.sendMsg(now,"充电预警",basePigpen1.getBuildName(),basePigpen.getBuildName().substring(basePigpen1.getBuildName().length()),sysAccountMultilevel.getWechatId()); sysAccountMultilevel.setSubscribe(0); sysAccountMultilevelService.updateById(sysAccountMultilevel); } WebsocketWorkerUtil.sendWarningMessage(farmId,String.format("%s 漏电预警",basePigpen.getBuildName())); } } private String getNum(String num){ return String.format("%.1f", Double.parseDouble(num) / 10.0); } //应答 public void answerCmd(String answerText, ChannelHandlerContext ctx) { log.info(String.format("应答数据--->%s",answerText)); ctx.writeAndFlush(Unpooled.copiedBuffer(answerText.getBytes())); } //检查无效耳标 public boolean checkValidEarmark(String earmark) { if (earmark.trim().equalsIgnoreCase("ffffffffffffffff") || earmark.trim().equalsIgnoreCase("0000000000000000")) { return true; } else { return false; } } //拆分粘包数据 public JSONArray parseAskCmdPackage(String text) { String key = "end"; Pattern pattern = Pattern.compile(key); Matcher matcher = pattern.matcher(text); int count = 0; while (matcher.find()) { count++; } JSONArray dataJa = new JSONArray(); if (count == 1) { dataJa.add(text); } else { for (int a = 0; a < count; a++) { int p1 = text.indexOf("end"); dataJa.add(text.substring(0, p1 + 3)); text = text.substring(p1 + 3, text.length()); } } return dataJa; } }