package com.power.spcomm;
|
|
import gnu.io.CommPortIdentifier;
|
import gnu.io.PortInUseException;
|
import gnu.io.SerialPort;
|
import gnu.io.UnsupportedCommOperationException;
|
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.nio.ByteBuffer;
|
import java.nio.ByteOrder;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.Enumeration;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import com.power.alarm.Alarm_Config;
|
import com.power.alarm.Alarm_Config_SQL;
|
import com.power.mysql.MysqlConnPool;
|
|
|
|
|
public class SPCommModule implements Runnable{
|
|
Logger logger = LogManager.getLogger(SPCommModule.class);
|
|
// ¼ì²âϵͳÖпÉÓõÄͨѶ¶Ë¿ÚÀà
|
private CommPortIdentifier portId;
|
private Enumeration<CommPortIdentifier> portList;
|
// ÊäÈëÊä³öÁ÷
|
private InputStream inputStream;
|
private OutputStream outputStream;
|
// RS-232µÄ´®ÐпÚ
|
private SerialPort serialPort;
|
|
private ByteBuffer CommRxBuffer = ByteBuffer.allocate(512);
|
|
private int comm_baudrate = 9600;
|
|
private MysqlConnPool m_Conn_Pool;
|
|
private int Alarm_way;
|
|
private Alarm_Config Alarm_config;
|
|
private boolean CommPortOK = false;
|
|
private ArrayList<String> phoneNumList = new ArrayList<String>();
|
|
public Date last_Alarm_Time = null;
|
public Date sms_AlarmCheck_Time = null;
|
|
public SPCommModule(MysqlConnPool pool,int alarm_way) {
|
m_Conn_Pool = pool;
|
Alarm_way = alarm_way;
|
}
|
|
@SuppressWarnings("unchecked")
|
public boolean OpenCommPort(String comm_name) {
|
portList = CommPortIdentifier.getPortIdentifiers();
|
while (portList.hasMoreElements()) {
|
portId = portList.nextElement();
|
if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
|
if (portId.getName().equals(comm_name)) {
|
try {
|
serialPort = (SerialPort) portId.open("SerialPort-Test", 2000);
|
//serialPort.addEventListener(new SPComm());
|
serialPort.notifyOnDataAvailable(true);
|
/* ÉèÖô®¿ÚͨѶ²ÎÊý */
|
serialPort.setSerialPortParams(comm_baudrate, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
|
|
outputStream = serialPort.getOutputStream();
|
inputStream = serialPort.getInputStream();
|
} catch (PortInUseException e) {
|
//e.printStackTrace();
|
logger.error(e.toString(),e);
|
} catch (UnsupportedCommOperationException e) {
|
//e.printStackTrace();
|
logger.error(e.toString(),e);
|
} catch (IOException e) {
|
//e.printStackTrace();
|
logger.error(e.toString(),e);
|
}
|
}
|
}
|
}
|
if(null == serialPort) {
|
logger.info(comm_name + "´ò¿ªÊ§°Ü£¬²»´æÔÚ»òÕýÔÚʹÓÃÖÐ !");
|
|
return false;
|
} else {
|
|
logger.info(comm_name + "´ò¿ª³É¹¦ !");
|
|
CommRxBuffer.order(ByteOrder.BIG_ENDIAN);
|
|
return true;
|
}
|
}
|
|
public void clearRxBuffer() throws IOException, InterruptedException {
|
|
byte[] rx_buf_t = new byte[64];
|
|
while(true) {
|
if(inputStream.available() > 0) {
|
int rx_cnt_t = inputStream.read(rx_buf_t, 0, rx_buf_t.length);
|
|
if(rx_cnt_t <= 0)
|
break;
|
}
|
else
|
break;
|
}
|
}
|
|
public void readMsg(ByteBuffer bbf_rx) {
|
bbf_rx.clear();
|
int time_out = 0;
|
byte[] rx_buf_t = new byte[512];
|
|
try {
|
while(true) {
|
if(inputStream.available() > 0) {
|
time_out = 0;
|
int rx_cnt_t = inputStream.read(rx_buf_t);
|
if((bbf_rx.position()+rx_cnt_t) < (bbf_rx.capacity()-1)) {
|
bbf_rx.put(rx_buf_t, 0, rx_cnt_t);
|
} else {
|
break;
|
}
|
} else {
|
Thread.sleep(5);
|
time_out++;
|
if(0 == bbf_rx.position()) {
|
if(time_out >= 2000) {
|
break;
|
}
|
} else {
|
if(time_out >= 5) {
|
break;
|
}
|
}
|
}
|
}
|
|
bbf_rx.flip();
|
}
|
catch (Exception e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
|
private boolean sendShortMessage(String phonenumber) {
|
|
logger.info("****************** sendShortMessage ***********");
|
|
boolean send_success = false;
|
|
String msg_str = "86" + phonenumber + ":0:" + Alarm_config.SMS_Alarm_Text;
|
|
try {
|
outputStream.write(msg_str.getBytes("GBK"),0,msg_str.getBytes("GBK").length);
|
outputStream.flush();
|
}catch (Exception e) {
|
logger.error(e.toString(), e);
|
}
|
|
readMsg(CommRxBuffer);
|
|
String rx_str = null;
|
|
CommRxBuffer.position(0);
|
|
byte[] bt_dat = new byte[CommRxBuffer.remaining()];
|
|
for(int n=0; n<bt_dat.length; n++) {
|
bt_dat[n] = CommRxBuffer.get();
|
}
|
|
rx_str = new String(bt_dat);
|
|
//logger.info("Recv Message: " + rx_str);
|
|
if(rx_str.contains("SMS_SEND_SUCESS")) {
|
send_success = true;
|
logger.info("SMS_SEND_SUCESS");
|
}
|
else if(rx_str.contains("SMS_SEND_FAIL")) {
|
logger.info("SMS_SEND_FAIL");
|
}
|
else {
|
logger.info("Unkwon return text...");
|
}
|
|
return send_success;
|
}
|
|
private void buzzerBeepAndLedOn() { //´ò¿ª µÆ ºÍ ÉùÒô
|
byte[] bt_dat = new byte[8];
|
|
bt_dat[0] = 0x7E;
|
bt_dat[1] = (byte)0xFF;
|
bt_dat[2] = 0x06;
|
bt_dat[3] = 0x3A;
|
bt_dat[4] = 0x00;
|
|
bt_dat[5] = 0x01;
|
bt_dat[6] = 0x00;
|
|
bt_dat[7] = (byte)0xEF;
|
|
try {
|
outputStream.write(bt_dat,0,8);
|
outputStream.flush();
|
}catch (Exception e) {
|
logger.error(e.toString(), e);
|
}
|
|
}
|
|
private void turnOffBuzzerBeep() { //¹Ø±Õ ÉùÒô£¬ ±£Áô µÆ
|
byte[] bt_dat = new byte[8];
|
|
bt_dat[0] = 0x7E;
|
bt_dat[1] = (byte)0xFF;
|
bt_dat[2] = 0x06;
|
bt_dat[3] = 0x3A;
|
bt_dat[4] = 0x00;
|
|
bt_dat[5] = 0x00;
|
bt_dat[6] = 0x00;
|
|
bt_dat[7] = (byte)0xEF;
|
|
try {
|
outputStream.write(bt_dat,0,8);
|
outputStream.flush();
|
}catch (Exception e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
|
private void turnOffBuzzerAndLed() { //¹Ø±Õ ÉùÒô ºÍ µÆ
|
byte[] bt_dat = new byte[8];
|
|
bt_dat[0] = 0x7E;
|
bt_dat[1] = (byte)0xFF;
|
bt_dat[2] = 0x06;
|
bt_dat[3] = 0x3A;
|
bt_dat[4] = 0x00;
|
|
bt_dat[5] = 0x00;
|
bt_dat[6] = 0x01;
|
|
bt_dat[7] = (byte)0xEF;
|
|
try {
|
outputStream.write(bt_dat,0,8);
|
outputStream.flush();
|
}catch (Exception e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
|
private void query_phone_number() {
|
String ph = "18627009360";
|
|
phoneNumList.clear();
|
|
phoneNumList.add(ph);
|
}
|
|
@Override
|
public void run() {
|
|
CommPortOK = false;
|
|
last_Alarm_Time = new Date();
|
sms_AlarmCheck_Time = new Date();
|
|
for(int i=0;i<60;i++) {
|
try {
|
Thread.sleep(1000);
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
|
if(Alarm_Config.ALARM_WAY_BEEPER==Alarm_way) {
|
logger.info("Beeper Alarm Thread Start....");
|
}
|
else {
|
logger.info("SMS Alarm Thread Start....");
|
}
|
|
if(Alarm_Config.ALARM_WAY_SMS == Alarm_way) {
|
|
boolean new_alarm_exists = false;
|
|
while(true) {
|
long timelong =((new Date()).getTime()-sms_AlarmCheck_Time.getTime())/1000;
|
|
if(timelong >= 60) { //60 seconds
|
|
sms_AlarmCheck_Time = new Date();
|
|
new_alarm_exists = Alarm_Config_SQL.check_if_new_alarm(m_Conn_Pool, last_Alarm_Time);
|
}
|
|
if(new_alarm_exists) {
|
last_Alarm_Time = new Date();
|
|
Alarm_config = Alarm_Config_SQL.query_alarm_config(m_Conn_Pool);
|
|
if(Alarm_config.SMS_Alarm_EN>0) {
|
|
if(Alarm_config.SMS_CommPort_ReInit>0) {
|
|
CommPortOK = false;
|
|
if(null != serialPort) {
|
serialPort.close();
|
}
|
|
CommPortOK = OpenCommPort(Alarm_config.SMS_CommPort);
|
|
if(CommPortOK) {
|
Alarm_config.SMS_CommPort_ReInit = 0;
|
Alarm_Config_SQL.update_alarm_config(m_Conn_Pool, Alarm_config);
|
}
|
else {
|
try {
|
Thread.sleep(3000);
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
}
|
|
if(CommPortOK) {
|
|
last_Alarm_Time = new Date();
|
|
for(int i=0;i<phoneNumList.size();i++) {
|
if(sendShortMessage(phoneNumList.get(i)) == false) {
|
try {
|
Thread.sleep(20000); //·¢ËͶÌÐÅʧ°Ü£¬20SºóÔÙ¼ÌÐø
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
|
sendShortMessage(phoneNumList.get(i));
|
}
|
}
|
}
|
}
|
}
|
|
try {
|
Thread.sleep(1000);
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
}
|
else if(Alarm_Config.ALARM_WAY_BEEPER == Alarm_way) {
|
|
boolean alarm_exists = false;
|
|
while(true) {
|
|
alarm_exists = Alarm_Config_SQL.check_if_alarm_exists(m_Conn_Pool);
|
|
if(alarm_exists) {
|
|
Alarm_config = Alarm_Config_SQL.query_alarm_config(m_Conn_Pool);
|
|
if(Alarm_config.Beeper_Alarm_EN>0) {
|
|
if(Alarm_config.Beeper_CommPort_ReInit>0) {
|
|
CommPortOK = false;
|
|
if(null != serialPort) {
|
serialPort.close();
|
}
|
|
CommPortOK = OpenCommPort(Alarm_config.Beeper_CommPort);
|
|
if(CommPortOK) {
|
Alarm_config.Beeper_CommPort_ReInit = 0;
|
Alarm_Config_SQL.update_alarm_config(m_Conn_Pool, Alarm_config);
|
}
|
else {
|
try {
|
Thread.sleep(3000);
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
}
|
|
if(CommPortOK) {
|
|
if(Alarm_config.Beeper_Sound_OFF>0) {
|
turnOffBuzzerBeep();
|
}
|
else {
|
buzzerBeepAndLedOn();
|
}
|
}
|
}
|
else {
|
if(CommPortOK) {
|
turnOffBuzzerAndLed();
|
}
|
}
|
}
|
|
try {
|
Thread.sleep(5000);
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
}
|
}
|
|
}
|
