package ng.devices;
|
|
import java.sql.CallableStatement;
|
import java.sql.Connection;
|
|
import builder.Manager;
|
import builder.S7control;
|
import builder.HttpApi;
|
import com.alibaba.fastjson.JSONObject;
|
import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
|
import ng.db.DBHelper;
|
import ng.db.DBSession;
|
import ng.devices.ModbusService.ModbusDataPackage;
|
|
public class MysqlService extends ModbusService {
|
|
//Êý¾Ý¿â
|
DBHelper db;
|
//É豸ID
|
int id;
|
//ʹÓõĴ洢¹ý³ÌÃû,¹Ì¶¨Ãû³Æ
|
String proc="Total_method";
|
//¼Ç¼ͨѶ´ÎÊý
|
public int ioCount;
|
|
//×îºóÒ»´Î¶ÁµÄÊý¾Ý
|
public String lastGet;
|
//×îºóÒ»´ÎдµÄÊý¾Ý
|
public String lastSend;
|
//·¢Ëͱê־λ¶¨Î»
|
public int fa_song_Pos=-1;
|
//ÇëÇó±ê־λ¶¨Î»
|
public int qing_qiu_Pos=-1;
|
//״̬±ê־λ¶¨Î»
|
public int zhuang_tai_Pos=-1;
|
//»ã±¨±ê־λ¶¨Î»
|
public int hui_bao_Pos=-1;
|
//È·Èϱê־λ¶¨Î»
|
public int que_ren_Pos=-1;
|
|
|
public int zhangtai;
|
|
//¹¹Ô캯Êý³õʼ»¯
|
public MysqlService(DBHelper db,int id) {
|
super();
|
this.db=db;
|
this.id=id;
|
|
// TODO Auto-generated constructor stub
|
}
|
|
int readWord(byte[] buff,int offset){
|
if(offset<0 || offset>=buff.length-1)
|
return 0;
|
int k=buff[offset];
|
k=(k<<8)+buff[offset+1];
|
return k;
|
}
|
|
//ÅжÏÊÇ·ñ±ê־λȫ0
|
boolean PassInvoke(byte[] buff){
|
|
int a=0,b=0,c=0,d=0;
|
a=readWord(buff,fa_song_Pos);
|
b=readWord(buff,qing_qiu_Pos);
|
c=readWord(buff,hui_bao_Pos);
|
d=readWord(buff,que_ren_Pos);
|
this.zhangtai=readWord(buff,this.zhuang_tai_Pos);
|
if(a==0 && b==0 && c==0 && d==0)
|
return true;
|
return false;
|
}
|
|
|
|
//ÕâÊǽ«¶ÁÓ¦´ð°üת»»ÎªMsyqlʶ±ðµÄÐÎʽ£¨Ö»ÄÜת»¯¶ÁÓ¦´ðÊý¾Ý°ü£©
|
String packToString(ModbusDataPackage pack){
|
String s=HexUtil.intTo2ByteHex(1);
|
s+=HexUtil.intTo2ByteHex(0);
|
s+=HexUtil.intTo2ByteHex((3+pack.ByteSize));
|
s+="0103";
|
s+=HexUtil.intTo1ByteHex(pack.ByteSize);
|
s+=HexUtil.byteToHexString(pack.ByteSize,pack.Content);
|
return s;
|
}
|
//ÕâÊǽ«mysql·µ»ØµÄ×Ö·û´®×ª»»ÎªÊý¾Ý°ü£¨Ö»ÄÜת»¯Ð´ÇëÇó°ü£©
|
boolean fillPack(ModbusDataPackage pack,String message){
|
if(message==null)
|
return false;
|
int a= HexUtil.hexToInt(message.substring(8*2,10*2));
|
int b= HexUtil.hexToInt(message.substring(10*2,12*2));
|
String s=message.substring(13*2,message.length());
|
byte[] bb= HexUtil.stringToInt(s);
|
pack.Address=a*2;
|
pack.ByteSize=b*2;
|
pack.Content=bb;
|
return true;
|
}
|
//·þÎñʵÏÖº¯Êý
|
@Override
|
protected boolean Service(ModbusDataPackage arg0, ModbusDataPackage arg1) {
|
// TODO Auto-generated method stub
|
//¶Á´ÎÊý+1
|
ioCount++;
|
//ת»¯ÎªmysqlÊäÈë²ÎÊý
|
String s=this.packToString(arg0);
|
//¸üÐÂ×îºóÒ»Ìõ¶Á±¨ÎÄ
|
this.lastGet=s;
|
DBSession sn=null;
|
String result=null;
|
String flag=null;
|
//ÉÏƬ
|
if(id==2){
|
try{
|
//´´½¨Á¬½Ó
|
sn=this.db.createSession(false);
|
Connection con= sn.getConnection();
|
JSONObject jSONObject=HttpApi.selectLoadRack();
|
boolean isSuccess=HttpApi.sendShelfTask();
|
// JSONObject jSONObject=new JSONObject();
|
// jSONObject.put("thickness", "4");
|
// jSONObject.put("width", "3660");
|
// jSONObject.put("height", "2440");
|
// jSONObject.put("sameCount", "1");
|
// jSONObject.put("glassType", "string");
|
double width_load = 0;
|
double height_load = 0;
|
double thickness_load = 0;
|
int sameCount_load = 0;
|
String glassType="";
|
if (jSONObject!=null){
|
width_load = Double.valueOf(jSONObject.get("width").toString());
|
height_load = Double.valueOf(jSONObject.get("height").toString());
|
thickness_load = Double.valueOf(jSONObject.get("thickness").toString());
|
sameCount_load = Integer.valueOf(jSONObject.get("sameCount").toString());
|
glassType =jSONObject.get("glassType").toString();
|
}
|
//System.out.println(width_load+","+height_load+","+thickness_load+","+sameCount_load+","+glassType);
|
//µ÷ÓÃÄǸö´æ´¢¹ý³Ì
|
CallableStatement sql=con.prepareCall("{call Total_method_load(?,?,?,?,?,?,?,?,?)}");
|
sql.registerOutParameter(8, java.sql.Types.VARCHAR);
|
sql.registerOutParameter(9, java.sql.Types.VARCHAR);
|
sql.setString(1, s);
|
sql.setLong(2, id);
|
sql.setDouble(3, width_load );
|
sql.setDouble(4, height_load );
|
sql.setDouble(5, thickness_load );
|
sql.setLong(6, sameCount_load );
|
sql.setString(7, glassType );
|
sql.execute();
|
//¶ÁÈ¡·µ»Ø²ÎÊý
|
//System.out.println("result:"+result);
|
result= sql.getString(8);
|
flag= sql.getString(9);//1 ±íʾÈÎÎñÍê³ÉÊýÁ¿¼õÒ»
|
if ("1".equals(flag) ){
|
//¼õÉÙÉÏƬÊýÁ¿
|
JSONObject b=HttpApi.loadRackReduction();
|
|
}else if("3".equals(flag) ){
|
|
}
|
}catch(Exception e){
|
e.printStackTrace();
|
}finally{
|
sn.close();
|
}
|
}else{
|
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);
|
|
}catch(Exception e){
|
e.printStackTrace();
|
}finally{
|
sn.close();
|
}
|
}
|
if(result!=null){
|
if(result.length()>0){
|
char c=result.charAt(0);
|
//# @ ¿ªÍ·´ú±íÌØÊâÏûÏ¢×Ö·û£¬·ñÔò´ú±íͨѶ
|
if(c=='#' || c=='@'){
|
//µ÷ÓÃÏûÏ¢´¦Àíº¯Êý£¨ÕâÊÇÒ»¸öÍⲿ½Ó¿Ú£©
|
Manager.SendMessage(result);
|
}
|
else{
|
//¸üÐÂ×îºóÒ»´Î·¢ËÍ
|
this.lastSend=result;
|
//·µ»ØÒª·¢Ë͵ı¨ÎÄ
|
System.out.println(result);
|
return this.fillPack(arg1,result);
|
}
|
}
|
}
|
return false;
|
}
|
|
}
|
