ModbusUtil.java 9.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250
  1. package com.mes.ui;
  2. import com.github.xingshuangs.iot.protocol.modbus.service.ModbusTcp;
  3. import com.mes.util.JdbcUtils;
  4. import java.nio.charset.Charset;
  5. public class ModbusUtil {
  6. public static void getDataA(ModbusTcp plc){
  7. // 说明预设数量有变化不能修改
  8. // 打钉数应按实际监听数算
  9. // 41065=F-out 41066=S-out
  10. // 41069=F-min 41071=S-min 41070=F-max 41072=S-max
  11. // 预设数量=41129 完成数=41137
  12. Short cur = plc.readInt16(1136);
  13. // System.out.println("F-out:"+plc.readInt16(1064));
  14. // System.out.println("S-out:"+plc.readInt16(1065));
  15. // System.out.println("F-min:"+plc.readInt16(1068));
  16. // System.out.println("S-min:"+plc.readInt16(1070));
  17. // System.out.println("F-max:"+plc.readInt16(1069));
  18. // System.out.println("S-max:"+plc.readInt16(1071));
  19. // System.out.println("预设数量:"+plc.readInt16(1128));
  20. //System.out.println("当前数量:"+cur);
  21. if(MesClient.aMax <= 0){
  22. MesClient.aMax = plc.readInt16(1128); // 任务数量
  23. MesClient.param1.setText(String.valueOf(MesClient.aMax));
  24. }
  25. if(MesClient.sortA == cur - 1){
  26. MesClient.sortA = cur;
  27. MesClient.aFinish = plc.readInt16(1138);
  28. String fout = plc.readInt16(1064)+"";
  29. String sout = (float)plc.readInt16(1065)/1000+"";
  30. String fmin = plc.readInt16(1068)+"";
  31. String smin = (float)plc.readInt16(1070)/1000+"";
  32. String fmax = plc.readInt16(1069)+"";
  33. String smax = (float)plc.readInt16(1071)/1000+"";
  34. MesClient.param2.setText(cur+"");
  35. System.out.println("cur:"+cur);
  36. if(!MesClient.product_sn.getText().isEmpty()){
  37. JdbcUtils.insertProdData(MesClient.mes_gw, MesClient.mes_line_sn, MesClient.product_sn.getText(),"A",fout,sout,fmin,smin,fmax,smax,"1",cur+"", MesClient.user_menu.getText());
  38. }
  39. }
  40. upResult();
  41. }
  42. public static void getDataB(ModbusTcp plc){
  43. // 41065=F-out 41066=S-out
  44. // 41069=F-min 41071=S-min 41070=F-max 41072=S-max
  45. // 预设数量=41129 完成数=41137
  46. Short cur = plc.readInt16(1136);
  47. // System.out.println("F-out:"+plc.readInt16(1064));
  48. // System.out.println("S-out:"+plc.readInt16(1065));
  49. // System.out.println("F-min:"+plc.readInt16(1068));
  50. // System.out.println("S-min:"+plc.readInt16(1070));
  51. // System.out.println("F-max:"+plc.readInt16(1069));
  52. // System.out.println("S-max:"+plc.readInt16(1071));
  53. // System.out.println("set:"+plc.readInt16(1128));
  54. // System.out.println("cur:"+cur);
  55. // System.out.println("cur2:"+MesClient.sortB);
  56. if(MesClient.bMax <= 0){
  57. MesClient.bMax = plc.readInt16(1128);
  58. MesClient.param3.setText(String.valueOf(MesClient.bMax));
  59. }
  60. if(MesClient.sortB == cur - 1){
  61. MesClient.sortB = cur;
  62. String fout = plc.readInt16(1064)+"";
  63. String sout = (float)plc.readInt16(1065)/1000+"";
  64. String fmin = plc.readInt16(1068)+"";
  65. String smin = (float)plc.readInt16(1070)/1000+"";
  66. String fmax = plc.readInt16(1069)+"";
  67. String smax = (float)plc.readInt16(1071)/1000+"";
  68. if(MesClient.sortB == 18){
  69. if(MesClient.bMax == 22){
  70. plc.writeInt16(1070,(short) 4000);
  71. plc.writeInt16(1071,(short) 5500);
  72. }
  73. }
  74. MesClient.param4.setText(cur+"");
  75. System.out.println("cur:"+cur);
  76. if(!MesClient.product_sn.getText().isEmpty()){
  77. JdbcUtils.insertProdData(MesClient.mes_gw, MesClient.mes_line_sn, MesClient.product_sn.getText(),"B",fout,sout,fmin,smin,fmax,smax,"1",cur+"", MesClient.user_menu.getText());
  78. }
  79. }
  80. upResult();
  81. }
  82. // 上传总结果
  83. public static void upResult(){
  84. if(!MesClient.curSn.isEmpty() && MesClient.aMax > 0 && MesClient.aMax == MesClient.sortA && MesClient.bMax > 0 && MesClient.bMax == MesClient.sortB){
  85. MesClient.finish_ok_bt.setEnabled(true);
  86. MesClient.finish_ng_bt.setEnabled(true);
  87. if(MesClient.tjStatus == 0 && MesClient.check_quality_result){
  88. MesClient.tjStatus = 1;
  89. MesClient.getUser();
  90. String retf = "OK";
  91. if(MesClient.aFinish != MesClient.aMax){
  92. retf = "NG";
  93. }
  94. Boolean ret = DataUtil.sendQuality(MesClient.nettyClient, MesClient.product_sn.getText(),retf, MesClient.user20);
  95. if(!ret){
  96. MesClient.setMenuStatus(MesClient.tjFlagTextErr,-1);
  97. }
  98. }
  99. }
  100. }
  101. // 获取控制模式
  102. public static short getControlModel(ModbusTcp plc){
  103. short control = 0;
  104. try{
  105. control = plc.readInt16(1090);
  106. }catch (Exception e){
  107. e.printStackTrace();
  108. }
  109. return control;
  110. }
  111. // 获取二维码
  112. public static String getSn(ModbusTcp plc){
  113. String sn = "";
  114. try{
  115. sn = plc.readString(1216,40, Charset.forName("UTF8"));
  116. }catch (Exception e){
  117. e.printStackTrace();
  118. }
  119. return splitIntoChunks(sn,2);
  120. }
  121. // 每两个字符分割,并反转
  122. private static String splitIntoChunks(String str, int chunkSize) {
  123. if (str == null || str.isEmpty() || chunkSize <= 0) {
  124. return "";
  125. }
  126. int length = str.length();
  127. int arraySize = (length + chunkSize - 1) / chunkSize;
  128. String[] result = new String[arraySize];
  129. for (int i = 0, j = 0; i < length; i += chunkSize, j++) {
  130. int endIndex = Math.min(i + chunkSize, length);
  131. String sttr = str.substring(i, endIndex);
  132. StringBuilder sb = new StringBuilder(sttr);
  133. String reversedStr = sb.reverse().toString(); // 字符串反转
  134. result[j] = reversedStr;
  135. }
  136. return String.join("",result);
  137. }
  138. // 远程开机
  139. public static Boolean setPowerOn(ModbusTcp plc){
  140. Boolean ret = false;
  141. try{
  142. plc.writeCoil(3128,true);
  143. // plc.writeCoil(3079,false);
  144. // plc.writeCoil(3328,true); // 必须选关掉关机,开机才起左右
  145. ret = true;
  146. }catch (Exception e){
  147. e.printStackTrace();
  148. ret = false;
  149. }
  150. return ret;
  151. }
  152. // 远程关机
  153. public static Boolean setPowerOff(ModbusTcp plc){
  154. Boolean ret = false;
  155. try{
  156. plc.writeCoil(3128,false);
  157. // plc.writeCoil(3328,false);
  158. // plc.writeCoil(3079,true); // 关机
  159. // 必须选关掉关机,开机才起左右
  160. ret = true;
  161. }catch (Exception e){
  162. e.printStackTrace();
  163. ret = false;
  164. }
  165. return ret;
  166. }
  167. // 重置任务
  168. public static void setTask(ModbusTcp plc,Short setNum){
  169. try{
  170. // 设置模式 1=标记铆接模式
  171. plc.writeInt16(1092,(short) 1);
  172. // 设置任务
  173. plc.writeInt16(1128,setNum);
  174. plc.writeInt16(1136,(short) 0);
  175. plc.writeInt16(1138,(short) 0);
  176. if(setNum == 22){
  177. plc.writeInt16(1070,(short) 2500);
  178. plc.writeInt16(1071,(short) 4500);
  179. }
  180. }catch (Exception e){
  181. e.printStackTrace();
  182. }
  183. }
  184. // A枪说明 192.168.1.7
  185. // plc.writeCoil(3079,false);
  186. // plc.writeCoil(3328,true); // 必须选关掉关机,开机才起左右
  187. //// plc.writeCoil(3128,false);
  188. // System.out.println("控制模式:"+plc.readInt16(1090)); // 1091 控制模式
  189. // System.out.println("系统运行中:"+plc.readCoil(3128,1)); // 3129 系统运行中
  190. // System.out.println("结束暂停:"+plc.readCoil(3132,1)); // 3133 系统运行中
  191. // System.out.println("远程开机:"+plc.readCoil(3328,1)); // 3329 远程开机
  192. // System.out.println("远程关机:"+plc.readCoil(3079,1)); // 3080 远程关机
  193. // System.out.println("作业模式:"+plc.readInt16(1092)); // 1093 作业模式
  194. // System.out.println("最大拉力:"+plc.readInt16(1064)); // 1065 最大拉力
  195. // System.out.println("对应位移:"+plc.readInt16(1065)); // 1066 对应位移
  196. // System.out.println("任务数量:"+plc.readInt16(1128)); // 1129 任务数量
  197. // System.out.println("合格数量:"+plc.readInt16(1138)); // 1139 合格数量
  198. // System.out.println("质量状态:"+plc.readInt16(1072)); // 1073 质量状态
  199. // System.out.println("F-out:"+plc.readInt16(1064));
  200. // System.out.println("S-out:"+plc.readInt16(1065));
  201. // System.out.println("F-min:"+plc.readInt16(1068));
  202. // System.out.println("S-min:"+plc.readInt16(1070));
  203. // System.out.println("F-max:"+plc.readInt16(1069));
  204. // System.out.println("S-max:"+plc.readInt16(1071));
  205. }