|  |  |  | 
|---|
|  |  |  | 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 ; | 
|---|