导入S7JAR包，更改数据库连接

wu

2025-03-19 1d0a4978574e2b67b4ed04783465710978dbdaba

 nglib/src/builder/Manager.java

@@ -1,18 +1,16 @@
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 S7.S7control;
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;

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.sql.ResultSet;

public class Manager {
   //设备管理器
@@ -84,31 +82,37 @@
         //读取设备列表
         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,flag from machine where id=78");
         ResultSet set= sn.query().getCurrentResult();
         //创建所有设备通讯
         while(set.next()){
            int id=(int)set.getLong(1);
            String name=set.getString(2);
            String ip=set.getString(3);
            int port=set.getInt(4);
            int flag=set.getInt(5);
            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);
            }
         System.out.println("S7链接");
         S7control s7=new S7control(EPlcType.S1500, "192.168.30.14", 102, 0, 0);
         System.out.println("S7:"+s7.readByte("DB34.0",  2));

         }	
//         //创建所有设备通讯
//         while(set.next()){
//            int id=(int)set.getLong(1);
//            String name=set.getString(2);
//            String ip=set.getString(3);
//            int port=set.getInt(4);
//            int flag=set.getInt(5);
//            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);
//            }
//
//         }
      }
      catch(Exception e){
         
      }
      finally{
         if(sn!=null)
         if(sn!=null){

            sn.close();
         }
      }
      mmgr.RunAll();
   }