| | |
|---|
| | | package com.dy.testClient.tcpClient; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol.p206V1_0_0.CommonV1_0_1; |
|---|
| | | import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0; |
|---|
| | | import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; |
|---|
| | | import com.dy.common.threadPool.ThreadPool; |
|---|
| | | import com.dy.common.util.ByteUtil; |
|---|
| | | import com.dy.testClient.ServerProperties; |
|---|
| | |
|---|
| | | if(sendTimes <= ServerProperties.sendTimes){ |
|---|
| | | log.info("RTU" + rtuAddr + "开始任务"); |
|---|
| | | log.info("RTU" + rtuAddr + "将要执行" + ServerProperties.sendTimes + "轮次任务，当前轮次是" + sendTimes); |
|---|
| | | sendDataOfP206V1_0_0(curCd) ; |
|---|
| | | sendDataOfP206V1(curCd) ; |
|---|
| | | }else{ |
|---|
| | | if(ServerProperties.sendOverThenCloseConnect == 1){ |
|---|
| | | log.info("RTU" + rtuAddr + "等待一会，以接收通信中间件下行数据"); |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void sendDataOfP206V1_0_0(String cd){ |
|---|
| | | private void sendDataOfP206V1(String cd){ |
|---|
| | | try{ |
|---|
| | | if(heartbeatTimes > ServerProperties.heartbeatTimes){ |
|---|
| | | heartbeatTimes = 1 ; |
|---|
