package com.whyc.charge;
|
|
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.whyc.dto.ComFn;
|
import com.whyc.dto.Fbs5100ComBase;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 配网电源
|
* @author LiJun
|
*
|
*/
|
@Component
|
public class Fbs5100DisChargeData {
|
public Fbs5100BattParam battParam; //电池参数
|
public Fbs5100TestParam testParam; //测试参数
|
public Fbs5100CapState capState; //容量状态
|
|
public List<Fbs5100FbsData> fbsDatas;
|
|
public int parse_result = Fbs5100ComBase.PARSE_RESULT_NULL;
|
|
public Fbs5100DisChargeData() {
|
battParam = new Fbs5100BattParam();
|
testParam = new Fbs5100TestParam();
|
capState = new Fbs5100CapState();
|
fbsDatas = new ArrayList<Fbs5100FbsData>();
|
}
|
|
public void parseFileData(String filePath)
|
{
|
|
FileInputStream fis = null;
|
try {
|
File f = new File(filePath);
|
//既不是核容放电也不是监测放电
|
if(!filePath.endsWith(".BCP") && !filePath.endsWith(".MCP")) {
|
parse_result = Fbs5100ComBase.PARSE_RESULT_FILETYPEERR;
|
return;
|
}
|
if(!f.exists()) {
|
parse_result = Fbs5100ComBase.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 = Fbs5100ComBase.PARSE_RESULT_SUCCESS;
|
}else {
|
parse_result = Fbs5100ComBase.PARSE_RESULT_FILEERROR;
|
}
|
|
while(true)
|
{
|
Fbs5100FbsData fbsData = new Fbs5100FbsData();
|
int tag = fbsData.checkDataHead(fis);
|
if((0xFD == tag) || (0xFC == tag) || (0xFB == tag))
|
{
|
byte[] databuf = new byte[Fbs5100FbsData.BYTE_LEN - 4];
|
if(fis.read(databuf) == databuf.length)
|
{
|
//System.out.println(ComFn.bytesToHexString(databuf, databuf.length));
|
|
if(fbsData.putByteBuffer(databuf)) {
|
fbsDatas.add(fbsData);
|
}
|
}
|
}
|
if(tag == 1)
|
break;
|
}
|
}else {
|
parse_result = Fbs5100ComBase.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 < (Fbs5100BattParam.BYTE_LEN + Fbs5100TestParam.BYTE_LEN + Fbs5100CapState.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.battParam.putByteBuffer(bf);
|
//System.out.println("battParam:"+flag);
|
flag &= this.testParam.putByteBuffer(bf);
|
//System.out.println("testParam:"+flag);
|
flag &= this.capState.putByteBuffer(bf);
|
//System.out.println("capState:"+flag);
|
return flag;
|
}
|
|
@Override
|
public String toString() {
|
return "Fbs5100DisChargeData [battParam=" + battParam + ", testParam=" + testParam + ", capState=" + capState
|
+ ", fbsDatas=" + fbsDatas + ", parse_result=" + parse_result + "]";
|
}
|
|
|
}
|
