pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/CodeV202404.java
@@ -29,7 +29,7 @@ public static final String cd_83 = "83" ; //遥测终端定点上报 public static final String cd_84 = "84" ; //刷卡开泵/阀上报 public static final String cd_85 = "85" ; //刷卡关泵/阀上报 public static final String cd_9A = "9A" ; //清除年用水量和年用电量 public static final String cd_9A = "9A" ; //查询年用水量 public static final String cd_26 = "26" ; //设置设备终端年用水量 public static final String cd_21 = "21" ; //设置设备终端IP地址 public static final String cd_86 = "86" ; //查询设备终端IP地址 @@ -70,7 +70,7 @@ (code.equals(cd_83) ? "遥测终端定点上报" : (code.equals(cd_84) ? "刷卡开泵/阀上报" : (code.equals(cd_85) ? "刷卡关泵/阀上报" : (code.equals(cd_9A) ? "清除年用水量和年用电量" : (code.equals(cd_9A) ? "查询年用水量" : (code.equals(cd_26) ? "设置设备终端年用水量" : (code.equals(cd_21) ? "设置设备终端IP地址" : (code.equals(cd_86) ? "查询设备终端IP地址" : pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/downVos/ComCd26Vo.java
@@ -6,6 +6,5 @@ public class ComCd26Vo { public String controllerType;//控制器类型 01（0x01）:测控一体阀；57(0x57):井电控制器 public Integer projectNo ;//控制器类型 0x01:测控一体阀；0x57:井电控制器 public Integer ipChannel ;//IP通道号 0x01:1通道 0x02:2通道. public Integer maxAmountYear ;//设备终端年用水量 单位：m3 整数，取值范围0~99999999 } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_21_Down.java
@@ -95,7 +95,7 @@ byte[] bs1 = new byte[7] ; index ++ ; index = 0; GlCreate.createPw(bs1, index); index += 2 ; pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java
@@ -99,7 +99,7 @@ byte[] bs1 = new byte[7] ; index ++ ; index = 0 ; GlCreate.createPw(bs1, index); index += 2 ; pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java
@@ -89,7 +89,7 @@ bytes = ByteUtil.bytesMerge(bytes, bsRg) ; byte[] bs1 = new byte[7] ; index ++ ; index = 0 ; GlCreate.createPw(bs1, index); index += 2 ; pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java
@@ -55,23 +55,17 @@ if(cvo == null){ throw new Exception("json转ComCd22Vo为null") ; } if(cvo.ipChannel != 1 && cvo.ipChannel !=2){ throw new Exception("IP通道号只能是1或2") ; } if(cvo.maxAmountYear < 0 || cvo.maxAmountYear > 99999999){ throw new Exception("设备终端年用水量必须是0~99999999范围内的整数") ; } byte[] bs = new byte[15] ; byte[] bs = new byte[14] ; int index = 0 ; bs[index] = (byte)(Integer.parseInt(cvo.controllerType, 16)); index ++ ; bs[index] = cvo.projectNo.byteValue() ; index ++ ; bs[index] = cvo.ipChannel.byteValue() ; index ++ ; String strTemp = "" + cvo.maxAmountYear ; pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Up.java
@@ -74,7 +74,7 @@ cdData.ip = ByteUtil.bytes2String_BE(bs, index, index + ipLen - 1) ; index += ipLen ; cdData.port = Integer.parseInt(ByteUtil.bytes2String_LE(bs, index, index + portLen - 1)) ; cdData.port = Integer.parseInt(ByteUtil.bytes2String_BE(bs, index, index + portLen - 1)) ; } } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java
@@ -73,10 +73,10 @@ short portLen = ByteUtilUnsigned.byte2Byte(bs, index) ; index++ ; cdData.domain = ByteUtil.bytes2String_LE(bs, index, index + domainLen - 1) ; cdData.domain = ByteUtil.bytes2String_BE(bs, index, index + domainLen - 1) ; index += domainLen ; cdData.port = Integer.parseInt(ByteUtil.bytes2String_LE(bs, index, index + portLen - 1)) ; cdData.port = Integer.parseInt(ByteUtil.bytes2String_BE(bs, index, index + portLen - 1)) ; } } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java
@@ -113,11 +113,11 @@ for(int i = 0 ; i < bTempLen; i++){ bs[index++] = bTemp[i] ; count ++ ; if(count >= 4){ if(count >= 5){ break ; } } for(; count < 4; count++){ for(; count < 5; count++){ bs[index++] = 0 ; }
@@ -72,6 +72,9 @@ cdData.orderNo = ByteUtil.BCD2String_BE(bs, index, index + 7) ; index += 8 ; cdData.opDt = GlParse.parseRtuDt(bs, index) ; index += 6 ; cdData.opType = bs[index]; index ++ ; pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java
@@ -60,7 +60,7 @@ if(!NumUtil.isPlusIntNumber(cvo.orderNo)){ throw new Exception("订单号必须是16位数字") ; } if(cvo.orderNo.length() != 12){ if(cvo.orderNo.length() != 16){ throw new Exception("订单号必须是16位数字") ; }
@@ -2,6 +2,7 @@ import com.dy.common.mw.protocol.*; import com.dy.common.mw.protocol.p206V202404.*; import com.dy.common.mw.protocol.p206V202404.upVos.DataCd9AVo; import com.dy.common.mw.protocol.p206V202404.upVos.DataCdXyVo; import com.dy.common.util.ByteUtil; import org.apache.logging.log4j.LogManager; @@ -53,7 +54,7 @@ */ protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception { DataV202404 dV1 = (DataV202404)data.getSubData() ; DataCdXyVo cdData = new DataCdXyVo(CodeV202404.getCodeName(dataCode)) ; DataCd9AVo cdData = new DataCd9AVo(CodeV202404.getCodeName(dataCode)) ; dV1.subData = cdData ; int index = ProtocolConstantV206V202404.dataIndex ; cdData.controllerType = ByteUtil.bytes2Hex(bs, false, index, 1) ; @@ -62,12 +63,7 @@ cdData.projectNo = (int)bs[index]; index++ ; byte result = bs[index]; if(result == 1){ cdData.success = true ; }else{ cdData.success = false ; } cdData.maxAmountYear = ByteUtil.BCD2Int_LE(bs, index, index + 3) ; } } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java
@@ -109,6 +109,10 @@ cdData.success = false ; } if(!cdData.success){ return ; } index++ ; GlParse.parseRtuDt(bs, index);
@@ -312,6 +312,11 @@ index += 8 ; cdData.startDt = GlParse.parseRtuDt(bs, index) ; if(cdData.opResult == (byte)0x81){ //失败了，下面就没有数据了 return ; } index += 6 ; cdData.endDt = GlParse.parseRtuDt(bs, index) ;
@@ -143,6 +143,9 @@ sb.append(" 水表工作电压 : ") ; sb.append(waterMeterWorkVolt == null?"未知":waterMeterWorkVolt) ; sb.append("\n") ; sb.append(" 信号强度 : ") ; sb.append(csq == null?"未知":csq) ; sb.append("\n") ; return sb.toString() + super.toString() ; }
@@ -10,6 +10,7 @@ public Integer projectNo ;//控制器类型 0x01:测控一体阀；0x57:井电控制器 public String icCardNo ;//IC卡编号（17位数字） public String orderNo ;//订单号（16位数字） public String opDt ;//开泵/阀时间（yyyy-mm-dd HH:MM:SS） public Byte opType ;//开阀类型: 01:平台开泵/阀 02:用户开泵/阀 public Byte opResult ;//开启泵/阀结果: 0x00:成功 0x81:失败 @@ -34,11 +35,14 @@ sb.append(" 订单号 : ") ; sb.append(orderNo == null?"未知":orderNo) ; sb.append("\n") ; sb.append(" 开泵/阀时间 : ") ; sb.append(opDt == null?"未知":opDt) ; sb.append("\n") ; sb.append(" 开启泵/阀类型 : ") ; sb.append(opType == null?"未知":(opType.byteValue() == 0x01 ? "平台":"用户")) ; sb.append("\n") ; sb.append(" 开启泵/阀结果 : ") ; sb.append(opResult == null?"未知":(opResult.byteValue() == 0x00 ? "成功":"失败")) ; sb.append(opResult == null?"未知":(opResult.byteValue() == 0x01 ? "成功":"失败")) ; sb.append("\n") ; return sb.toString() ; } pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd93_A3Vo.java
@@ -43,7 +43,7 @@ sb.append(opType == null?"未知":(opType.byteValue() == 0x00 ? "刷卡":(opType.byteValue() == 0x01 ? "平台":(opType.byteValue() == 0x02 ? "APP":(opType.byteValue() == 0x03 ? "非法卡":(opType.byteValue() == 0x04 ? "水表异常":(opType.byteValue() == 0x05 ? "电表异常":(opType.byteValue() == 0x06 ? "剩余水量不足":(opType.byteValue() == 0x07 ? "剩余金额不足":(opType.byteValue() == 0x08 ? "无流量":(opType.byteValue() == 0x09 ? "掉电再上电":"未知"))))))))))) ; sb.append("\n") ; sb.append(" 关启泵/阀结果 : ") ; sb.append(opResult == null?"未知":(opResult.byteValue() == 0x00 ? "成功":"失败")) ; sb.append(opResult == null?"未知":(opResult.byteValue() == 0x01 ? "成功":"失败")) ; sb.append("\n") ; sb.append(" IC卡地址 : ") ; sb.append(icCardAddr == null?"未知":icCardAddr) ; pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd9AVo.java
New file @@ -0,0 +1,34 @@ package com.dy.common.mw.protocol.p206V202404.upVos; import lombok.Data; //查询设备年用水量 @Data public class DataCd9AVo { public String controllerType;//控制器类型 01（0x01）:测控一体阀；57(0x57):井电控制器 public Integer projectNo ;//控制器类型 0x01:测控一体阀；0x57:井电控制器 public Integer maxAmountYear ;//设备终端年用水量 单位：m3 整数，取值范围0~99999999 public String comName ;//命令名称 public DataCd9AVo(String comName){ this.comName = comName ; } public String toString(){ StringBuffer sb = new StringBuffer() ; sb.append(" " + comName + " : \n") ; sb.append(" 控制器类型 : ") ; sb.append(controllerType == null?"未知":(controllerType.equals("01")?"测控一体阀":(controllerType.equals("57")?"井电控制器":"未知"))) ; sb.append("\n") ; sb.append(" 项目编号 : ") ; sb.append(projectNo == null?"未知":projectNo) ; sb.append("\n") ; sb.append(" 年用水量 : ") ; sb.append(maxAmountYear == null?"未知":maxAmountYear) ; sb.append("\n") ; return sb.toString() ; } } pipIrr-platform/pipIrr-global/src/main/resources/application-database-pj.yml
@@ -9,6 +9,8 @@ username: root password: dysql,;.abc!@# druid: # 数据源名称：当存在多个数据源时，设置名字可以很方便的来进行区分,默认自动生成名称，格式是："DataSource-" + System.identityHashCode(this) name: druid-mysql-pj #配置初始化大小、最小、最大 initialSize: 1 minIdle: 1 pipIrr-platform/pipIrr-global/src/main/resources/application-database-ym.yml
@@ -9,12 +9,14 @@ username: root password: dysql,;.abc!@# druid: # 数据源名称：当存在多个数据源时，设置名字可以很方便的来进行区分,默认自动生成名称，格式是："DataSource-" + System.identityHashCode(this) name: druid-mysql-ym #配置初始化大小、最小、最大 initialSize: 1 minIdle: 1 maxActive: 100 #配置获取连接等待超时的时间，单位是毫秒 maxWait: 6000 initialSize: 10 minIdle: 10 maxActive: 200 # 获取连接时最大等待时间,单位毫秒。配置了maxWait之后,缺省启用公平锁,并发效率会有所下降,如果需要可以通过配置useUnfairLock属性为true使用非公平锁 maxWait: 60000 #配置间隔多久进行一次检测，检测需要关闭的空闲连接，单位毫秒。 默认是60s，太长可能会导致无法及时检测到连接中断 timeBetweenEvictionRunsMillis: 60000 #配置一个连接在连接池中的最小生存时间、最大生存时间，超过最大生存时间会被移除，单位毫秒。 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/application-database.yml
@@ -7,4 +7,11 @@ username: root password: dysql,;.abc!@# druid: # 说明: 如果你没有指定useSSL=true ,启动项目会报红警告, 环境的问题，要灵活处理 #数据源名称：当存在多个数据源时，设置名字可以很方便的来进行区分,默认自动生成名称，格式是："DataSource-" + System.identityHashCode(this) #name: name: druid-mysql-mw-rtu 单数据源不起作用，所以注释掉 #配置初始化大小、最小、最大 initialSize: 10 minIdle: 10 maxActive: 200 # 获取连接时最大等待时间,单位毫秒。配置了maxWait之后,缺省启用公平锁,并发效率会有所下降,如果需要可以通过配置useUnfairLock属性为true使用非公平锁 maxWait: 60000 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/log4j2.yml
@@ -62,7 +62,7 @@ AppenderRef: #Root的子节点，用来指定该日志输出到哪个Appender. - ref: CONSOLE #输出日志时，首先由本level判断是否输出，然后再由上面的Appenders.Console.ThresholdFilter.level判断是否输出 - ref: ROLLING_FILE #输出日志时，首先由本level判断是否输出，然后再由上面的Appenders.RollingFile.ThresholdFilter.level判断是否输出 # 为包配置特殊的Log级别，方便调试， # 为类包路径配置特殊的Log级别，方便调试， # 不受Loggers.Root.level限制 Logger: - name: com.dy.pipIrrGlobal.daoBa pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/PipIrrMwTestWebApplication.java
@@ -1,9 +1,7 @@ package com.dy.pipIrrMwTestWeb; import com.dy.common.webUtil.BaseResponse; import com.dy.pipIrrMwTestWeb.test.CommandCtrl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/test/CommandCtrl.java
@@ -21,13 +21,21 @@ @GetMapping(path = "test") public BaseResponse<String> test() { //return this.connect() ;//连接通信中间件测试 //return this.cdXY(CodeV202404.cd_30) ;//发送固定参数XY的命令 //return this.cdXY(CodeV202404.cd_9C) ;//发送固定参数XY的命令 //return this.cd55(1) ; //return this.cd15() ; //return this.cd16() ; //return this.cd21() ; //return this.cd22() ; //return this.cd23() ; //return this.cd24() ; //return this.cd26() ; //return this.cd31() ; return this.cd92() ; //return this.cd86() ; //return this.cd87() ; //return this.cd92() ; //return this.cd93() ; return this.cd9C() ; } /** @@ -80,8 +88,8 @@ comVo.controllerType = CommandCtrl.controllerType ; comVo.projectNo = CommandCtrl.projectNo ; comVo.channel = 1 ;//IP通道号(取值范围 1、2). comVo.ip = "111.222.123.321" ;//IP（例如 125.235.35.89） comVo.port = 60000 ;///端口号（0~65536） comVo.ip = "8.140.180.59" ;//IP（例如 125.235.35.89） comVo.port = 6001 ;///端口号（0~65536） return this.sendCom2Mw(this.command(CodeV202404.cd_21, comVo, null)) ; } @@ -90,8 +98,8 @@ ComCd22Vo comVo = new ComCd22Vo() ; comVo.controllerType = CommandCtrl.controllerType ; comVo.projectNo = CommandCtrl.projectNo ; comVo.maxAmountYear = 12345 ;//机井年最大用水量单位：m3 整数，取值范围0~99999999 comVo.limitLevel = 123.4; //水位下限 单位：m 取值范围:0~9999.99 comVo.maxAmountYear = 99998888 ;//机井年最大用水量单位：m3 整数，取值范围0~99999999 comVo.limitLevel = 9978.60; //水位下限 单位：m 取值范围:0~9999.99 return this.sendCom2Mw(this.command(CodeV202404.cd_22, comVo, null)) ; } @@ -101,8 +109,8 @@ comVo.controllerType = CommandCtrl.controllerType ; comVo.projectNo = CommandCtrl.projectNo ; comVo.channel = 1 ;//IP通道号(取值范围 1、2). comVo.domain = "www.baidu.com" ;//域名（例如 dayuyanjiuyuan.to），最大长度42字符 comVo.port = 60000 ;///端口号（0~65536） comVo.domain = "dayuyanjiuyuan.top" ;//域名（例如 dayuyanjiuyuan.top），最大长度42字符 comVo.port = 6001 ;///端口号（0~65536） return this.sendCom2Mw(this.command(CodeV202404.cd_23, comVo, null)) ; } @@ -111,7 +119,7 @@ ComCd24Vo comVo = new ComCd24Vo() ; comVo.controllerType = CommandCtrl.controllerType ; comVo.projectNo = CommandCtrl.projectNo ; comVo.registerNo = "102030405060708090" ;//域名（例如 dayuyanjiuyuan.to），最大长度42字符 comVo.registerNo = "10203040506070809000" ;// return this.sendCom2Mw(this.command(CodeV202404.cd_24, comVo, null)) ; } @@ -120,8 +128,7 @@ ComCd26Vo comVo = new ComCd26Vo() ; comVo.controllerType = CommandCtrl.controllerType ; comVo.projectNo = CommandCtrl.projectNo ; comVo.ipChannel = 1 ;//IP通道号 0x01:1通道 0x02:2通道. comVo.maxAmountYear = 123456 ;//设备终端年用水量 单位：m3 整数，取值范围0~99999999 comVo.maxAmountYear = 200 ;//设备终端年用水量 单位：m3 整数，取值范围0~99999999 return this.sendCom2Mw(this.command(CodeV202404.cd_26, comVo, null)) ; } @@ -208,6 +215,16 @@ return this.sendCom2Mw(this.command(CodeV202404.cd_93, comVo, null)) ; } //平台/APP远程关闭水泵/阀门(AFN=0x93H/AFN=0xA3H) private BaseResponse cd9C(){ ComCd9CVo comVo = new ComCd9CVo() ; comVo.controllerType = CommandCtrl.controllerType ; comVo.projectNo = CommandCtrl.projectNo ; comVo.icCardAddr = "04BEA5BB" ;// return this.sendCom2Mw(this.command(CodeV202404.cd_9C, comVo, null)) ; } //平台/APP远程关闭水泵/阀门(AFN=0x93H/AFN=0xA3H) private BaseResponse cdA3(){ ComCd93_A3Vo comVo = new ComCd93_A3Vo() ;
