| | |
| | | import java.sql.Connection; |
| | | |
| | | import builder.Manager; |
| | | import builder.S7control; |
| | | import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType; |
| | | import ng.db.DBHelper; |
| | | import ng.db.DBSession; |
| | | import ng.devices.ModbusService.ModbusDataPackage; |
| | |
| | | DBSession sn=null; |
| | | String result=null; |
| | | String flag=null; |
| | | |
| | | |
| | | try{ |
| | | //创建连接 |
| | | sn=this.db.createSession(false); |
| | | Connection con= sn.getConnection(); |
| | | //掉哦那个存储过程 |
| | | CallableStatement sql=con.prepareCall("{call Total_method(?,?,?,?)}"); |
| | | sql.registerOutParameter(3, java.sql.Types.VARCHAR); |
| | | sql.registerOutParameter(4, java.sql.Types.VARCHAR); |
| | | sql.setString(1, s); |
| | | sql.setLong(2, id); |
| | | sql.execute(); |
| | | //读取返回参数 |
| | | result= sql.getString(3); |
| | | flag= sql.getString(4); |
| | | //调用那个存储过程 |
| | | CallableStatement sql=con.prepareCall("{call Total_method(?,?,?,?)}"); |
| | | sql.registerOutParameter(3, java.sql.Types.VARCHAR); |
| | | sql.registerOutParameter(4, java.sql.Types.VARCHAR); |
| | | sql.setString(1, s); |
| | | sql.setLong(2, id); |
| | | sql.execute(); |
| | | //读取返回参数 |
| | | result= sql.getString(3); |
| | | flag= sql.getString(4); |
| | | |
| | | } |
| | | catch(Exception e){ |
| | | e.printStackTrace(); |
| | |
| | | //更新最后一次发送 |
| | | this.lastSend=result; |
| | | //返回要发送的报文 |
| | | System.out.println(result); |
| | | return this.fillPack(arg1,result); |
| | | } |
| | | } |