package com.fgkj.services;
|
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.Batttestdata_inf;
|
import com.fgkj.dto.DLG_Progress;
|
import com.fgkj.dto.User_inf;
|
import com.fgkj.fbo.FboData;
|
import com.fgkj.fbo.FboDataInf;
|
import com.fgkj.fbo.IdcData;
|
import com.fgkj.mapper.impl.BattInfMapper;
|
import com.fgkj.mapper.impl.Batttestdata_infMapper;
|
import com.fgkj.mapper.impl.FboDataUploadMapper;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpSession;
|
import java.io.File;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* fbo数据上传,TODO perry校验效果
|
*/
|
import javax.annotation.Resource;
|
@Service
|
public class FboDataUploadService extends Thread{
|
|
// ServiceModel model = new ServiceModel();
|
// private User_inf uinf;
|
// private int bg_id;
|
// private String[][] tableRowData;
|
// private File[] file;
|
// private HttpSession session;
|
// private DLG_Progress progress;
|
|
@Resource
|
private Batttestdata_infMapper battTestDataInfMapper;
|
|
@Resource
|
private BattInfMapper battInfMapper;
|
|
@Resource
|
private FboDataUploadMapper mapper;
|
|
|
/*public FboDataUploadService() {
|
model = new ServiceModel();
|
progress=new DLG_Progress(true,false);
|
}
|
|
public FboDataUploadService(
|
User_inf uinf,
|
int bg_id,
|
String[][] tableRowData,
|
File[] file,
|
HttpSession session) {
|
this.model = new ServiceModel();
|
this.uinf = uinf;
|
this.bg_id = bg_id;
|
this.tableRowData=tableRowData;
|
this.file=file;
|
this.session=session;
|
progress=new DLG_Progress(true,false);
|
progress.setTableData(tableRowData);
|
progress.setTotal(file.length);
|
session.setAttribute("progress", progress);
|
}*/
|
|
public void uploadFile(User_inf uinf, int bg_id, String[][] tableRowData, File[] file, HttpSession session) {
|
DLG_Progress progress=new DLG_Progress(true,false);
|
progress.setTableData(tableRowData);
|
progress.setTotal(file.length);
|
session.setAttribute("progress", progress);
|
|
Thread thread = new Thread() {
|
@Override
|
public void run() {
|
for (int n = 0; n < tableRowData.length; n++) {
|
if (false == progress.isJudge()) {
|
break;
|
}
|
|
if ("false".equals(tableRowData[n][2])) //是否能上传
|
{
|
continue;
|
}
|
if ("true".equals(tableRowData[n][4])) //是否已上传
|
{
|
continue;
|
}
|
|
//m_UploadCount++;
|
FboDataInf data_inf = new FboDataInf();
|
ArrayList<FboData> al_fbo_data = new ArrayList<FboData>();
|
|
File f = file[n];
|
if (tableRowData[n][1].toUpperCase().endsWith(".FBO")) {
|
FboData.checkFboFile(f, data_inf, al_fbo_data);
|
} else if (tableRowData[n][1].toUpperCase().endsWith(".IDC")) {
|
IdcData.checkIdcFile(f, data_inf, al_fbo_data);
|
}
|
int bg_id = Integer.parseInt((String) tableRowData[n][0]);
|
//判断文件是否存在
|
// boolean flag=FileisUpload(bg_id, data_inf);
|
// if(!flag){
|
// continue;
|
// }
|
|
Boolean bl = mapper.uploadFboData(uinf, bg_id, data_inf, al_fbo_data, tableRowData[n], progress.isJudge());
|
if (true == bl) {
|
//System.out.println(bg_id+"\t"+bl);
|
tableRowData[n][4] = "true";
|
progress.setUploadOkcount(progress.getUploadOkcount() + 1);
|
}
|
|
}
|
for (File fl : file) {
|
if (fl.exists()) {
|
fl.delete();
|
}
|
}
|
progress.setCompleteed(true);
|
progress.setJudge(false);
|
}
|
};
|
thread.start();
|
|
}
|
|
/*public void run(){
|
//System.out.println("开启线程");
|
//System.out.println(progress);
|
for(int n=0; n<tableRowData.length; n++)
|
{
|
if(false == progress.isJudge())
|
{
|
break;
|
}
|
|
if("false".equals(tableRowData[n][2])) //是否能上传
|
{
|
continue;
|
}
|
if("true".equals(tableRowData[n][4])) //是否已上传
|
{
|
continue;
|
}
|
|
//m_UploadCount++;
|
FboDataInf data_inf = new FboDataInf();
|
ArrayList<FboData> al_fbo_data = new ArrayList<FboData>();
|
|
File f=file[n];
|
if(tableRowData[n][1].toUpperCase().endsWith(".FBO")) {
|
FboData.checkFboFile(f, data_inf, al_fbo_data);
|
} else if(tableRowData[n][1].toUpperCase().endsWith(".IDC")) {
|
IdcData.checkIdcFile(f, data_inf, al_fbo_data);
|
}
|
int bg_id = Integer.parseInt((String) tableRowData[n][0]);
|
//判断文件是否存在
|
// boolean flag=FileisUpload(bg_id, data_inf);
|
// if(!flag){
|
// continue;
|
// }
|
|
Boolean bl=new FboDataUploadImpl().uploadFboData(uinf, bg_id, data_inf, al_fbo_data, tableRowData[n], progress.isJudge());
|
if(true == bl){
|
//System.out.println(bg_id+"\t"+bl);
|
tableRowData[n][4]="true";
|
progress.setUploadOkcount(progress.getUploadOkcount()+1);
|
}
|
|
}
|
for(File fl:file){
|
if(fl.exists()){
|
fl.delete();
|
}
|
}
|
progress.setCompleteed(true);
|
progress.setJudge(false);
|
} */
|
//判断当前文件能否上传
|
/**
|
*
|
* @param bg_id 电池组名
|
* @param data_inf 上传数据
|
* @return true :能上传 false：不能上传
|
*/
|
public boolean FileisUpload(int bg_id,FboDataInf data_inf) {
|
Calendar mcld = Calendar.getInstance();
|
mcld.set(Calendar.YEAR, 2000 + data_inf.TestStartTime.year);
|
mcld.set(Calendar.MONTH, data_inf.TestStartTime.month);
|
mcld.set(Calendar.DATE, data_inf.TestStartTime.day);
|
mcld.set(Calendar.HOUR_OF_DAY, data_inf.TestStartTime.hour);
|
mcld.set(Calendar.MINUTE, data_inf.TestStartTime.minute);
|
mcld.set(Calendar.SECOND, data_inf.TestStartTime.second);
|
|
Date test_starttime = mcld.getTime();
|
//System.out.println("test_starttime: " + test_starttime);
|
boolean data_ok = true;
|
int data_reason_type = 0;
|
|
BattInf binf = new BattInf();
|
Batttestdata_inf tdata = new Batttestdata_inf();
|
binf.setBattGroupId(bg_id);
|
tdata.setBattGroupId(bg_id);
|
tdata.setTest_starttime(test_starttime);
|
float batt_cap = 0f;
|
int mon_count = 0;
|
float mon_vol = 0f;
|
List<BattInf> listB = battInfMapper.serchByCondition(binf);
|
if (listB != null && listB.size() > 0) {
|
batt_cap = listB.get(0).getMonCapStd();
|
mon_count = listB.get(0).getMonCount();
|
mon_vol = listB.get(0).getMonVolStd();
|
}
|
|
List<Batttestdata_inf> listT = battTestDataInfMapper
|
.serchTest_record_count(tdata);
|
if (listT != null && listT.size() > 0) {
|
// int test_record_count = listT.get(0).getTest_record_count();
|
data_reason_type = 1;
|
}
|
|
if (0 == data_reason_type) {
|
if (batt_cap != data_inf.STDCap) {
|
data_reason_type = 2;
|
} else if (mon_count != data_inf.BattSum) {
|
data_reason_type = 3;
|
} else if (mon_vol != data_inf.MonomerVol) {
|
data_reason_type = 4;
|
}
|
}
|
|
if (data_reason_type > 0) {
|
data_ok = false;
|
}
|
return data_ok;
|
}
|
|
}
|
