From 4209a352833999d7fbd1f44aa4da20ea729bea79 Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期四, 23 五月 2024 08:53:05 +0800 Subject: [PATCH] 与王工(江海)联调,并修改问题,完善协议实现代码。 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd93_A3Vo.java | 2 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/application-database.yml | 9 ++ pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_21_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java | 4 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Up.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java | 4 + pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/global/GlParse.java | 5 + pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd92_A2Vo.java | 6 + pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/log4j2.yml | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/downVos/ComCd26Vo.java | 1 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java | 3 + pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/CodeV202404.java | 4 pipIrr-platform/pipIrr-global/src/main/resources/application-database-pj.yml | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java | 2 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java | 8 -- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java | 10 +-- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd9AVo.java | 34 +++++++++++ pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java | 4 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java | 2 pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/test/CommandCtrl.java | 39 +++++++++--- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd80_5BVo.java | 3 + pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/PipIrrMwTestWebApplication.java | 2 pipIrr-platform/pipIrr-global/src/main/resources/application-database-ym.yml | 12 ++- 24 files changed, 116 insertions(+), 48 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/CodeV202404.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/CodeV202404.java index ed18635..39686a3 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/CodeV202404.java +++ b/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鍦板潃" : diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/downVos/ComCd26Vo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/downVos/ComCd26Vo.java index 6662a05..36ae567 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/downVos/ComCd26Vo.java +++ b/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 ;//璁惧缁堢骞寸敤姘撮噺 鍗曚綅锛歮3 鏁存暟锛屽彇鍊艰寖鍥�0~99999999 } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_21_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_21_Down.java index 1e23b06..bcacda2 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_21_Down.java +++ b/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 ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java index 089d4d6..7ccb336 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_23_Down.java +++ b/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 ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java index 9e3242f..5f46b3d 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_24_Down.java +++ b/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 ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java index fa0f86b..41e76da 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_26_Down.java +++ b/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杞珻omCd22Vo涓簄ull") ; } - 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 ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Up.java index 8427760..1387bb7 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_86_Up.java +++ b/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)) ; } } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java index cbcbfbf..c5c4369 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_87_Up.java +++ b/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)) ; } } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java index 1193d6b..00cebd7 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Down.java +++ b/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 ; } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java index 512934d..0fbd96e 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_92_A2_Up.java @@ -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 ++ ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java index f9d9796..1588e7a 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_93_A3_Down.java +++ b/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浣嶆暟瀛�") ; } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java index ff4ef59..5bb4d97 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_9A_Up.java @@ -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) ; } } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java index 5eced82..d5f5326 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/Cd_C2_Up.java +++ b/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); diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/global/GlParse.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/global/GlParse.java index 82e681d..dc2abe8 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/global/GlParse.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/parse/global/GlParse.java @@ -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) ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd80_5BVo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd80_5BVo.java index 06f782a..8f685cb 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd80_5BVo.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd80_5BVo.java @@ -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() ; } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd92_A2Vo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd92_A2Vo.java index 954ffc7..928ae12 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd92_A2Vo.java +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd92_A2Vo.java @@ -10,6 +10,7 @@ public Integer projectNo ;//鎺у埗鍣ㄧ被鍨� 0x01:娴嬫帶涓�浣撻榾锛�0x57:浜曠數鎺у埗鍣� public String icCardNo ;//IC鍗$紪鍙凤紙17浣嶆暟瀛楋級 public String orderNo ;//璁㈠崟鍙凤紙16浣嶆暟瀛楋級 + public String opDt ;//寮�娉�/闃�鏃堕棿锛坹yyy-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() ; } diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd93_A3Vo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd93_A3Vo.java index 0063ee0..fa96d54 100644 --- a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd93_A3Vo.java +++ b/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) ; diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd9AVo.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd9AVo.java new file mode 100644 index 0000000..c1c590f --- /dev/null +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/upVos/DataCd9AVo.java @@ -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 ;//璁惧缁堢骞寸敤姘撮噺 鍗曚綅锛歮3 鏁存暟锛屽彇鍊艰寖鍥�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() ; + } + +} diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/application-database-pj.yml b/pipIrr-platform/pipIrr-global/src/main/resources/application-database-pj.yml index d08d509..22cbe00 100644 --- a/pipIrr-platform/pipIrr-global/src/main/resources/application-database-pj.yml +++ b/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 diff --git a/pipIrr-platform/pipIrr-global/src/main/resources/application-database-ym.yml b/pipIrr-platform/pipIrr-global/src/main/resources/application-database-ym.yml index 07d84de..2c43ab8 100644 --- a/pipIrr-platform/pipIrr-global/src/main/resources/application-database-ym.yml +++ b/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 #閰嶇疆涓�涓繛鎺ュ湪杩炴帴姹犱腑鐨勬渶灏忕敓瀛樻椂闂淬�佹渶澶х敓瀛樻椂闂达紝瓒呰繃鏈�澶х敓瀛樻椂闂翠細琚Щ闄わ紝鍗曚綅姣銆� diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/application-database.yml b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/application-database.yml index 9a35e83..ccde4de 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/application-database.yml +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/application-database.yml @@ -7,4 +7,11 @@ username: root password: dysql,;.abc!@# druid: - # 璇存槑: 濡傛灉浣犳病鏈夋寚瀹歶seSSL=true ,鍚姩椤圭洰浼氭姤绾㈣鍛�, 鐜鐨勯棶棰橈紝瑕佺伒娲诲鐞� \ No newline at end of file + #鏁版嵁婧愬悕绉帮細褰撳瓨鍦ㄥ涓暟鎹簮鏃讹紝璁剧疆鍚嶅瓧鍙互寰堟柟渚跨殑鏉ヨ繘琛屽尯鍒�,榛樿鑷姩鐢熸垚鍚嶇О锛屾牸寮忔槸锛�"DataSource-" + System.identityHashCode(this) + #name: name: druid-mysql-mw-rtu 鍗曟暟鎹簮涓嶈捣浣滅敤锛屾墍浠ユ敞閲婃帀 + #閰嶇疆鍒濆鍖栧ぇ灏忋�佹渶灏忋�佹渶澶� + initialSize: 10 + minIdle: 10 + maxActive: 200 + # 鑾峰彇杩炴帴鏃舵渶澶х瓑寰呮椂闂�,鍗曚綅姣銆傞厤缃簡maxWait涔嬪悗,缂虹渷鍚敤鍏钩閿�,骞跺彂鏁堢巼浼氭湁鎵�涓嬮檷,濡傛灉闇�瑕佸彲浠ラ�氳繃閰嶇疆useUnfairLock灞炴�т负true浣跨敤闈炲叕骞抽攣 + maxWait: 60000 diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/log4j2.yml b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/log4j2.yml index c2dcc3f..afbac2b 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/log4j2.yml +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/log4j2.yml @@ -62,7 +62,7 @@ AppenderRef: #Root鐨勫瓙鑺傜偣锛岀敤鏉ユ寚瀹氳鏃ュ織杈撳嚭鍒板摢涓狝ppender. - ref: CONSOLE #杈撳嚭鏃ュ織鏃讹紝棣栧厛鐢辨湰level鍒ゆ柇鏄惁杈撳嚭锛岀劧鍚庡啀鐢变笂闈㈢殑Appenders.Console.ThresholdFilter.level鍒ゆ柇鏄惁杈撳嚭 - ref: ROLLING_FILE #杈撳嚭鏃ュ織鏃讹紝棣栧厛鐢辨湰level鍒ゆ柇鏄惁杈撳嚭锛岀劧鍚庡啀鐢变笂闈㈢殑Appenders.RollingFile.ThresholdFilter.level鍒ゆ柇鏄惁杈撳嚭 - # 涓哄寘閰嶇疆鐗规畩鐨凩og绾у埆锛屾柟渚胯皟璇曪紝 + # 涓虹被鍖呰矾寰勯厤缃壒娈婄殑Log绾у埆锛屾柟渚胯皟璇曪紝 # 涓嶅彈Loggers.Root.level闄愬埗 Logger: - name: com.dy.pipIrrGlobal.daoBa diff --git a/pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/PipIrrMwTestWebApplication.java b/pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/PipIrrMwTestWebApplication.java index 395a6ad..4fb99e3 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/PipIrrMwTestWebApplication.java +++ b/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; diff --git a/pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/test/CommandCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/test/CommandCtrl.java index ec70bf2..e121ea3 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/test/CommandCtrl.java +++ b/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) ;//鍙戦�佸浐瀹氬弬鏁癤Y鐨勫懡浠� + //return this.cdXY(CodeV202404.cd_9C) ;//鍙戦�佸浐瀹氬弬鏁癤Y鐨勫懡浠� //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 ;//鏈轰簳骞存渶澶х敤姘撮噺鍗曚綅锛歮3 鏁存暟锛屽彇鍊艰寖鍥�0~99999999 - comVo.limitLevel = 123.4; //姘翠綅涓嬮檺 鍗曚綅锛歮 鍙栧�艰寖鍥�:0~9999.99 + comVo.maxAmountYear = 99998888 ;//鏈轰簳骞存渶澶х敤姘撮噺鍗曚綅锛歮3 鏁存暟锛屽彇鍊艰寖鍥�0~99999999 + comVo.limitLevel = 9978.60; //姘翠綅涓嬮檺 鍗曚綅锛歮 鍙栧�艰寖鍥�: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 ;//璁惧缁堢骞寸敤姘撮噺 鍗曚綅锛歮3 鏁存暟锛屽彇鍊艰寖鍥�0~99999999 + comVo.maxAmountYear = 200 ;//璁惧缁堢骞寸敤姘撮噺 鍗曚綅锛歮3 鏁存暟锛屽彇鍊艰寖鍥�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() ; -- Gitblit v1.8.0