package com.fgkj.fbs5100;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.IOException;
|
import java.nio.ByteBuffer;
|
import java.nio.ByteOrder;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.data.ComFn;
|
|
public class FBS5100_AlarmData {
|
public FBS5100_AlarmParam alarmParam; //告警参数
|
|
public List<FBS5100_Alarm> alarms;
|
|
|
|
public int parse_result = FBS5100_ComBase.PARSE_RESULT_NULL;
|
|
public FBS5100_AlarmData() {
|
alarmParam = new FBS5100_AlarmParam();
|
|
alarms = new ArrayList<FBS5100_Alarm>();
|
}
|
|
|
public void parseFileData(String filePath)
|
{
|
|
FileInputStream fis = null;
|
try {
|
File f = new File(filePath);
|
//既不是核容放电也不是监测放电
|
if(!filePath.endsWith(".ALM")) {
|
parse_result = FBS5100_ComBase.PARSE_RESULT_FILETYPEERR;
|
return;
|
}
|
if(!f.exists()) {
|
parse_result = FBS5100_ComBase.PARSE_RESULT_NOTFOUNDFILE;
|
return;
|
//System.out.println("文件不存在..........");
|
}
|
fis = new FileInputStream(f);
|
byte[] buf = new byte[1024];
|
if(fis.read(buf, 0, buf.length) == 1024)
|
{
|
if(this.readDataHead(buf)) {
|
parse_result = FBS5100_ComBase.PARSE_RESULT_SUCCESS;
|
}else {
|
parse_result = FBS5100_ComBase.PARSE_RESULT_FILEERROR;
|
}
|
|
while(true)
|
{
|
FBS5100_Alarm alm = new FBS5100_Alarm();
|
int tag = alm.checkDataHead(fis);
|
if((0xAA == tag))
|
{
|
byte[] databuf = new byte[FBS5100_Alarm.BYTE_LEN];
|
if(fis.read(databuf) == databuf.length)
|
{
|
//System.out.println(ComFn.bytesToHexString(databuf, databuf.length));
|
if(alm.putByteBuffer(databuf)){
|
alarms.add(alm);
|
}
|
|
}
|
}
|
if(tag == 1)
|
break;
|
}
|
}else {
|
parse_result = FBS5100_ComBase.PARSE_RESULT_FILEERROR;
|
}
|
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
if(null != fis)
|
{
|
try {
|
fis.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
|
//解析数据头
|
public boolean readDataHead(byte[] buf) {
|
System.out.println(ComFn.bytesToHexString(buf, buf.length));
|
boolean flag = false;
|
if(buf.length < (FBS5100_BattParam.BYTE_LEN)) {
|
System.out.println("头部数据长度异常");
|
return flag;
|
}
|
ByteBuffer bf = ByteBuffer.allocate(buf.length);
|
bf.order(ByteOrder.LITTLE_ENDIAN);
|
bf.put(buf);
|
bf.position(0);
|
|
flag = this.alarmParam.putByteBuffer(bf);
|
System.out.println("alarmParam:"+flag);
|
|
return flag;
|
}
|
|
|
@Override
|
public String toString() {
|
return "FBS5100_AlarmData [alarmParam=" + alarmParam + ", alarms=" + alarms + ", parse_result=" + parse_result
|
+ "]";
|
}
|
}
|
