ModbusUtil.java 9.3 KB

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