摆片看板前端代码更新

wu

2025-04-11 f4631f8b19f30fb6c334aefe2bceab52e2e9a63c

 nglib/src/builder/Manager.java

@@ -1,20 +1,18 @@
package builder;

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.json.JSONArray;

import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
import ng.db.DBHelper;
import ng.db.DBSession;
import ng.devices.HexUtil;
import org.json.JSONArray;

public class Manager {
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.sql.ResultSet;


public class Manager extends Thread {
   //设备管理器
   static MachineManager mmgr;
   //优化排版管理器
@@ -84,8 +82,9 @@
         //读取设备列表
         DBHelper db=DBHelper.getDBHelper("mes");
         sn=DBHelper.getDBHelper("mes").createSession(false);
         sn.createSql("select id,machine_name,ip_address,port,flag,read_size,read_offset,function_type,flag from machine");
         sn.createSql("select id,machine_name,ip_address,port,flag,read_size,read_offset,function_type,remarks from machine where flag=1");
         ResultSet set= sn.query().getCurrentResult();

         //创建所有设备通讯
         while(set.next()){
            int id=(int)set.getLong(1);
@@ -96,19 +95,20 @@
            int readSize=set.getInt(6);
            int readOffset=set.getInt(7);
            byte functionType=set.getByte(8);
            int flags=set.getInt(9);
            if(flags==1){
               mmgr.createDevice(db,id,name,ip,port,readOffset,readSize,null,functionType);
            String remarks=set.getString(9);
            if(flag==1){
               mmgr.createDevice(db,id,name,ip,port,readOffset,readSize,null,functionType,remarks);
            }

         }	
         }
      }
      catch(Exception e){
         
      }
      finally{
         if(sn!=null)
         if(sn!=null){
            sn.close();
         }
      }
      mmgr.RunAll();
   }
@@ -207,9 +207,9 @@
         System.out.println("错误");
      }
   }
	

   public static void main(String[] args){
      //Manager.appStart(new String[]{"jdbc:mysql://10.153.19.150/gmms?serverTimezone=GMT%2B8","root","beibo.123/" });
      Manager.appStart(new String[]{"jdbc:mysql://localhost/gmms?serverTimezone=GMT%2B8","root","beibo.123/" });
      while(true){
         try {
            Thread.sleep(100);