|  |  | 
 |  |  |  | 
 |  |  | import com.dy.common.mw.protocol.p206V1_0_0.parse.global.GlCreate; | 
 |  |  | import com.dy.common.util.ByteUtil; | 
 |  |  | import com.dy.common.util.ByteUtilUnsigned; | 
 |  |  | import com.dy.pipIrrMwTestRtu.ServerProperties; | 
 |  |  | import org.apache.logging.log4j.LogManager; | 
 |  |  | import org.apache.logging.log4j.Logger; | 
 |  |  | 
 |  |  |  | 
 |  |  |     private static final Logger log = LogManager.getLogger(UpCd83Close.class); | 
 |  |  |  | 
 |  |  |     public static void upCd83Data() { | 
 |  |  |     public static void upData() { | 
 |  |  |         try { | 
 |  |  |             if (UpData.session != null && UpData.session.isConnected()) { | 
 |  |  |                 byte[] bs = createData(ServerProperties.rtuAddr); | 
 |  |  | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 构造心跳数据 | 
 |  |  |      * 构造上行数据 | 
 |  |  |      * | 
 |  |  |      * @return 字节数组 | 
 |  |  |      * @throws Exception 异常 | 
 |  |  |      */ | 
 |  |  |     private static byte[] createData(String rtuAddr) throws Exception { | 
 |  |  |         UpConstant.closeValve(); | 
 |  |  |         UpConstant.addValve();//调整流量 | 
 |  |  |  | 
 |  |  |         byte[] bytes = creatHead(rtuAddr, "83", (byte)0xB0); | 
 |  |  |  | 
 |  |  |         byte[] bs = new byte[1] ; |