package com.dev.data;
|
|
import java.io.IOException;
|
import java.nio.ByteBuffer;
|
import java.nio.ByteOrder;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.base.BaseData;
|
import com.base.Com;
|
import com.base.ComBase;
|
import com.base.ComFn;
|
import com.sql.MysqlConnPool;
|
|
/**
|
* ½âÎö¿ª¹ØÁ¿°åÊý¾Ý
|
* @author LiJun
|
*
|
*/
|
public class SwitchBoardParse_Thread implements Runnable{
|
public static final int Timing_DataCount = 130; //¶¨Ê±·¢ËÍÊý¾Ý°ü³¤¶È
|
public static final int Event_DataCount = 60; //ʼþ·¢ËÍÊý¾Ý°ü³¤¶È
|
public static final boolean isUseDataTime = true; //ÊÇ·ñʹÓÃÊý¾ÝÖ¡ÖеÄʱ¼ä
|
|
|
public MysqlConnPool conn_pool;
|
public List<Device_inf> devices;
|
public BaseData baseData;
|
public int dev_id;
|
|
public SwitchBoardParse_Thread(MysqlConnPool conn_pool,List<Device_inf> devices,BaseData baseData) {
|
this.conn_pool = conn_pool;
|
this.devices = devices;
|
this.baseData = baseData;
|
}
|
|
@Override
|
public void run() {
|
boolean flag = true;
|
// if(baseData.data.length == Timing_DataCount ||
|
// baseData.data.length == Event_DataCount) {
|
if(flag) {
|
//ÅжÏÊý¾Ý°ü³¤¶È
|
//System.out.println("½ÓÊÕµ½Êý¾Ý°ü");
|
//ÕýÈ·Êý¾Ý°ü
|
parseSwitchBoardData(); //½âÎö¿ª¹ØÁ¿°åÊý¾Ý
|
|
|
for(int i=0;i<devices.size();i++) {
|
|
//System.out.println("¸üпª¹ØÁ¿°åÊý¾Ý");
|
if(devices.get(i).dev_id/1000 == 5 && devices.get(i).isNewData) {
|
//System.err.println("¸üпª¹ØÁ¿°åÊý¾Ý");
|
devices.get(i).isNewData = false;
|
if(isUseDataTime) {
|
//System.err.println(Com.getDateTimeFormat(baseData.getDateFromDate(), Com.DTF_YMDhms)+"==="+Com.getDateTimeFormat(new Date(),Com.DTF_YMDhms));
|
//¸ù¾ÝʼþÖ¡ÖеÄʼþ¼Ç¼¿ª·¢Á¿°åÊý¾Ý
|
//¸üÐÂʵʱÊý¾Ý
|
ChildStoodParse_Thread_SQL.upDeviceRtData(conn_pool,devices.get(i),baseData.getDateFromDate());
|
|
//²åÈëÀúʷʵʱÊý¾Ý
|
ChildStoodParse_Thread_SQL.insertDeviceHistoryData(conn_pool, devices.get(i),baseData.getDateFromDate());
|
}else {
|
//¸üÐÂʵʱÊý¾Ý
|
ChildStoodParse_Thread_SQL.upDeviceRtData(conn_pool,devices.get(i));
|
|
//²åÈëÀúʷʵʱÊý¾Ý
|
ChildStoodParse_Thread_SQL.insertDeviceHistoryData(conn_pool, devices.get(i));
|
}
|
}
|
|
}
|
|
}
|
}
|
|
/**
|
* ½âÎö¿ª¹ØÁ¿°åÊý¾Ý
|
*/
|
public void parseSwitchBoardData() {
|
ByteBuffer bf = ByteBuffer.allocate(baseData.data.length);
|
bf.order(ByteOrder.LITTLE_ENDIAN);
|
bf.put(baseData.data);
|
bf.flip();
|
bf.position(0);
|
int canid = 0;
|
int update_en = 0;
|
int cfg_index = 0;
|
//System.err.println("0xE062:"+ComFn.bytesToHexString(baseData.data, baseData.data.length));
|
//System.err.println("length:"+bf.limit()+"==="+bf.position());
|
while(bf.position() != bf.limit()) {
|
if(bf.limit()-bf.position() < 10) {
|
//³¤¶ÈÉÙÓÚÒ»¸öÊý¾Ý³¤¶ÈʱÍ˳ö½âÎöÊý¾Ý
|
break;
|
}
|
canid = ComBase.changeShortToInt(bf.getShort());
|
cfg_index = 0;
|
update_en = 0;
|
switch(canid) {
|
case 0xE062:{
|
parseSpecifi(5001,bf,1);
|
};break;
|
case 0xE061:{
|
//1ºÅ¿ª¹ØÁ¿°å
|
parseSpecifi(5001,bf,0);
|
// Device_inf dev = getNowDevice(5001);
|
// if(null != dev) {
|
// List<ConfigData> cfgs = dev.cfgdatas;
|
// for(int k = 0;k<4;k++) {
|
// canid = ComBase.changeShortToInt(bf.getShort());
|
// for(int i=0;i<16 && cfg_index< cfgs.size();i++) {
|
// if(checkCanUpdate(cfgs.get(cfg_index),update_en)) {
|
// cfgs.get(cfg_index++).value = ((canid&my_power_2(i))>0)?1:0;
|
// }
|
// }
|
// }
|
// }
|
}break;
|
case 0xE064:{
|
parseSpecifi(5002,bf,1);
|
}break;
|
case 0xE063:{
|
//2ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseSpecifi(5002,bf,0);
|
};break;
|
case 0xE066:{
|
parseSpecifi(5003,bf,1);
|
}break;
|
case 0xE065:{
|
//3ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseSpecifi(5003,bf,0);
|
};break;
|
case 0xE068:{
|
parseSpecifi(5004,bf,1);
|
}break;
|
case 0xE067:{
|
//4ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseSpecifi(5004,bf,0);
|
};break;
|
case 0xE06A:{
|
parseSpecifi(5005,bf,1);
|
}break;
|
case 0xE069:{
|
//5ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseSpecifi(5005,bf,0);
|
};break;
|
case 0xE06C:{
|
parseSpecifi(5006,bf,1);
|
}break;
|
case 0xE06B:{
|
//6ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseSpecifi(5006,bf,0);
|
};break;
|
//case 0xEC46:{
|
//7ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
//parseSevenControlPanel(5007,bf,0);
|
//};break;
|
case 0xEC40:{
|
//1ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5001,bf,128);
|
}break;
|
case 0xE051:{
|
//1ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5001,bf,129);
|
}break;
|
case 0xEC41:{
|
//2ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5002,bf,128);
|
}break;
|
case 0xE052:{
|
//2ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5002,bf,129);
|
}break;
|
case 0xEC42:{
|
//3ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5003,bf,128);
|
}break;
|
case 0xE053:{
|
//3ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5003,bf,129);
|
};break;
|
case 0xEC43:{
|
//4ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5004,bf,128);
|
}break;
|
case 0xE054:{
|
//4ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5004,bf,129);
|
}break;
|
case 0xEC44:{
|
//5ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5005,bf,128);
|
}break;
|
case 0xE055:{
|
//5ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5005,bf,129);
|
}break;
|
case 0xEC45:{
|
//6ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5006,bf,128);
|
}break;
|
case 0xE056:{
|
//6ºÅ¿ª¹ØÁ¿°åÊý¾Ý
|
parseControlPanel(5006,bf,129);
|
}break;
|
default:{
|
//ÌÞ³ý´íÎóÖ¡
|
for(int k = 0;k<4;k++) {
|
canid = ComBase.changeShortToInt(bf.getShort());
|
//System.out.println(canid);
|
}
|
}break;
|
}
|
}
|
}
|
|
//½âÎöÖ¸¶¨É豸idµÄÉ豸ÐÅÏ¢
|
public void parseSpecifi(int dev_id,ByteBuffer bf,int cfg_index) {
|
int canid = 0;
|
Device_inf dev = getNowDevice(dev_id);
|
if(null != dev) {
|
dev.isNewData = true;
|
List<ConfigData> cfgs = dev.cfgdatas;
|
for(int k = 0;k<4;k++) {
|
canid = ComBase.changeShortToInt(bf.getShort());
|
for(int i=0;i<16 && cfg_index< cfgs.size();i++) {
|
cfgs.get(cfg_index++).setValue(((canid&my_power_2(i))>0)?1:0);
|
cfg_index++;
|
}
|
}
|
}
|
}
|
|
//½âÎöÄ£Äâ¿ØÖÆÅÌÊý¾Ý
|
public void parseControlPanel(int dev_id,ByteBuffer bf,int cfg_index) {
|
int canid = 0;
|
Device_inf dev = getNowDevice(dev_id);
|
if(null != dev) {
|
dev.isNewData = true;
|
List<ConfigData> cfgs = dev.cfgdatas;
|
for(int k = 0;k<3;k++) {
|
canid = ComBase.changeShortToInt(bf.getShort());
|
for(int i=0;i<16 && cfg_index< cfgs.size();i++) {
|
//System.out.println(cfgs.get(cfg_index).data_value+"===="+cfgs.get(cfg_index).value);
|
cfgs.get(cfg_index++).setValue(((canid&my_power_2(i))>0)?1:0);
|
cfg_index++;
|
}
|
}
|
canid = ComBase.changeShortToInt(bf.getShort());
|
cfgs.get(cfg_index++).setValue(canid);;
|
}
|
}
|
|
//½âÎöÄ£Äâ¿ØÖÆÅÌÊý¾Ý
|
public void parseSevenControlPanel(int dev_id,ByteBuffer bf,int cfg_index) {
|
int canid = 0;
|
Device_inf dev = getNowDevice(dev_id);
|
if(null != dev) {
|
dev.isNewData = true;
|
List<ConfigData> cfgs = dev.cfgdatas;
|
for(int k = 0;k<3;k++) {
|
canid = ComBase.changeShortToInt(bf.getShort());
|
for(int i=0;i<16 && cfg_index< cfgs.size();i++) {
|
//System.out.println(cfgs.get(cfg_index).data_value+"===="+cfgs.get(cfg_index).value);
|
cfgs.get(cfg_index++).setValue(((canid&my_power_2(i))>0)?1:0);
|
}
|
}
|
canid = ComBase.changeShortToInt(bf.getShort());
|
cfgs.get(cfg_index++).setValue(canid);;
|
}
|
}
|
|
|
//ÅжÏÊÇ·ñÐèÒª¸üÐÂ״̬
|
public boolean checkCanUpdate(ConfigData cfg,int update_en) {
|
if(cfg.update_code == 0 || (cfg.update_code ==1 && update_en == 1)) {
|
cfg.update_en = 1;
|
return true;
|
}
|
return false;
|
}
|
|
public static void main(String[] args) throws IOException{
|
for(int i = 0; i<17;i++) {
|
//System.out.println(Math.pow(2,i));
|
for(int k=0;k<6535;k++) {
|
System.out.println(k&(int)Math.pow(2,i));
|
}
|
}
|
|
|
// while(true) {
|
// BufferedReader cin = new BufferedReader(new InputStreamReader(System.in));
|
// int n = Integer.parseInt(cin.readLine().trim());
|
// System.out.println(my_power_2(n));
|
// }
|
//System.out.println(Long.MAX_VALUE);
|
//System.out.println(Long.MIN_VALUE);
|
}
|
public static int my_power_2(int N){
|
StringBuffer v = new StringBuffer("");
|
long num[] = new long[2];
|
num[1] = 1;
|
if(N > 62){
|
num[0] = 1;
|
num[0] = num[0]<<(N - 62);
|
num[1] = num[1]<<62;
|
String s = String.valueOf(num[1]);
|
int size = 30,i = 0,j = 0;
|
long n[] = new long[size + 1];
|
//System.out.println(num[0]+" "+s);
|
for(i = s.length() - 1;i >= 0;-- i){
|
n[j ++] = (long) (num[0] * (s.charAt(i) - '0'));
|
//System.out.println(n[j - 1]);
|
}
|
for(i = 0;i < size;++ i){
|
while(n[i] > 9){
|
n[i + 1] += n[i] / 10;
|
n[i] %= 10;
|
}
|
}
|
boolean bl = false;
|
for(i = size;i >= 0;-- i){
|
if(n[i] != 0 || bl){
|
v.append(n[i]);
|
bl = true;
|
}
|
}
|
}else{
|
num[1] = num[1] << N;
|
v.append(String.valueOf(num[1]));
|
}
|
return Integer.parseInt(v.toString());
|
}
|
|
//»ñÈ¡µ±Ç°É豸ÐÅÏ¢
|
public Device_inf getNowDevice(int dev_id) {
|
for(int i=0;i<devices.size();i++) {
|
if(devices.get(i).dev_id == dev_id) {
|
return devices.get(i);
|
}
|
}
|
return null;
|
}
|
|
}
|
