package com.fgkj.services;

import java.io.File;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.Vector;

import javax.servlet.http.HttpSession;

import com.fgkj.actions.ActionUtil;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.dao.impl.Batttestdata_infDAOImpl;
import com.fgkj.dao.impl.FboDataUploadImpl;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.Batttestdata_inf;
import com.fgkj.dto.Com;
import com.fgkj.dto.DLG_Progress;
import com.fgkj.dto.ServiceModel;
import com.fgkj.dto.User_inf;
import com.fgkj.fbo.FboData;
import com.fgkj.fbo.FboDataInf;
import com.fgkj.fbo.IdcData;

public class FboDataUploadService extends Thread{ 
	private ServiceModel model;
	private User_inf uinf;
	private int bg_id;
	private String[][] tableRowData;
	private File[] file;
	private HttpSession session;
	private DLG_Progress progress;
	
	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 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) {
		BaseDAO dao = BaseDAOFactory.getBaseDAO(BaseDAO.BATTINF);
		BaseDAO daoAgain = BaseDAOFactory.getBaseDAO(BaseDAO.BATTTESTDATA_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 = dao.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 = ((Batttestdata_infDAOImpl)daoAgain)
				.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;			
	}
		
	public void stopUpload(){
		progress.setJudge(false);
	}

	public String[][] getTableRowData() {
		return tableRowData;
	}

	public void setTableRowData(String[][] tableRowData) {
		this.tableRowData = tableRowData;
	}
}