package com.fgkj.dao.impl;

import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.Vector;

import com.fgkj.actions.ActionUtil;
import com.fgkj.dao.BattTestData;
import com.fgkj.dao.DAOHelper;
import com.fgkj.db.DBUtil;
import com.fgkj.db.IDatabaseName;
import com.fgkj.db.Upload;
import com.fgkj.dto.Com;
import com.fgkj.dto.User_inf;
import com.fgkj.fbo.FboData;
import com.fgkj.fbo.FboDataInf;
import java.sql.Connection;

import javax.servlet.http.HttpSession;

public class FboDataUploadImpl {
	public static boolean uploadFboData(User_inf uinf, int bg_id,
			FboDataInf data_inf, ArrayList<FboData> al_fbo_data,
			String[] row_data, Boolean bl) {
		boolean upload_res = false;
		Connection conn=DBUtil.getConn();
		int testRecordCount = Upload.getBattTestRecordCountNew(bg_id,
				"db_batt_testdata.tb_batttestdata_inf",
				conn);

		Calendar ald = Calendar.getInstance();
		ald.set(Calendar.YEAR, 2000 + data_inf.TestStartTime.year);
		ald.set(Calendar.MONTH, data_inf.TestStartTime.month);
		ald.set(Calendar.DATE, data_inf.TestStartTime.day);
		ald.set(Calendar.HOUR_OF_DAY, data_inf.TestStartTime.hour);
		ald.set(Calendar.MINUTE, data_inf.TestStartTime.minute);
		ald.set(Calendar.SECOND, data_inf.TestStartTime.second);
		int data_type = BattTestData.BATTSTATE_DISCHARGE;
		if (0xFD != data_inf.DataType) {
			data_type = BattTestData.BATTSTATE_CHARGE;
		}
		String tb_name = "`db_batt_testdata`.`tb_BattTestData_" + bg_id + "` ";
		String tb_stop_name = "`db_batt_testdata`.`tb_BattTestDataStop_"
				+ bg_id + "` ";
		String tmp_tb_name = "`db_batt_testdata`.`tb_BattTestData_FBO` ";

		try {
			String sql_str = "CREATE TABLE IF NOT EXISTS "
					+ tb_name
					+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
					+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
					+ "`test_record_count` INT NOT NULL DEFAULT 0, "
					+ "`test_type` INT NOT NULL DEFAULT 0, "
					+ "`data_new` BOOLEAN NOT NULL DEFAULT false, "
					+ "`data_available` BOOLEAN NOT NULL DEFAULT false, "
					+ "`record_num` INT NOT NULL DEFAULT 0, "
					+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
					+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
					+ "`test_timelong` INT NOT NULL DEFAULT 0, "
					+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
					+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
					+ "`test_cap` FLOAT NOT NULL DEFAULT 0, "
					+ "`mon_num` INT NOT NULL DEFAULT 0, "
					+ "`mon_vol` FLOAT NOT NULL DEFAULT 0, "
					+ "INDEX index_test_record_count (`test_record_count`), "
					+ "PRIMARY KEY (`num`));";
			// sql.sqlMysqlExecute(sql_str);
			DAOHelper.executeCreateTable(conn, sql_str);

			sql_str = "CREATE TABLE IF NOT EXISTS "
					+ tb_stop_name
					+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
					+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
					+ "`test_record_count` INT NOT NULL DEFAULT 0, "
					+ "`test_type` INT NOT NULL DEFAULT 0, "
					+ "`data_new` BOOLEAN NOT NULL DEFAULT false, "
					+ "`data_available` BOOLEAN NOT NULL DEFAULT false, "
					+ "`record_num` INT NOT NULL DEFAULT 0, "
					+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
					+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
					+ "`test_timelong` INT NOT NULL DEFAULT 0, "
					+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
					+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
					+ "`test_cap` FLOAT NOT NULL DEFAULT 0, "
					+ "`mon_num` INT NOT NULL DEFAULT 0, "
					+ "`mon_vol` FLOAT NOT NULL DEFAULT 0, "
					+ "INDEX index_test_record_count (`test_record_count`), "
					+ "PRIMARY KEY (`num`));";
			// sql.sqlMysqlExecute(sql_str);
			DAOHelper.executeCreateTable(conn, sql_str);
			//System.out.println("***************************");
			sql_str = "DROP TABLE IF EXISTS " + tmp_tb_name;
			//sql.sqlMysqlExecute(sql_str);
			DAOHelper.executeCreateTable(
					conn, sql_str);
			//System.out.println("***************************");
			sql_str = "CREATE TEMPORARY TABLE IF NOT EXISTS "
					+ tmp_tb_name
					+ "( `num` BIGINT NOT NULL AUTO_INCREMENT, "
					+ "`BattGroupId` INT NOT NULL DEFAULT 0, "
					+ "`test_record_count` INT NOT NULL DEFAULT 0, "
					+ "`test_type` INT NOT NULL DEFAULT 0, "
					+ "`data_new` BOOLEAN NOT NULL DEFAULT false, "
					+ "`data_available` BOOLEAN NOT NULL DEFAULT false, "
					+ "`record_num` INT NOT NULL DEFAULT 0, "
					+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
					+ "`record_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
					+ "`test_timelong` INT NOT NULL DEFAULT 0, "
					+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
					+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
					+ "`test_cap` FLOAT NOT NULL DEFAULT 0, "
					+ "`mon_num` INT NOT NULL DEFAULT 0, "
					+ "`mon_vol` FLOAT NOT NULL DEFAULT 0, "
					+ "INDEX index_test_record_count (`test_record_count`), "
					+ "PRIMARY KEY (`num`));";
			// sql.sqlMysqlExecute(sql_str);
			DAOHelper.executeCreateTable(
					conn, sql_str);

			int test_time_long = 0;
			FboData tmp_data = null;
			for (int cnt = 0; cnt < al_fbo_data.size(); cnt++) {
				if (false == bl) {
					break;
				}

				tmp_data = al_fbo_data.get(cnt);
				//System.out.println(al_fbo_data);
				test_time_long = tmp_data.m_TestTime.hour;
				test_time_long = test_time_long * 60
						+ tmp_data.m_TestTime.minute;
				test_time_long = test_time_long * 60
						+ tmp_data.m_TestTime.second;

				if (cnt > 0) {
					for (int sn = 0; sn < data_inf.BattSum; sn++) {
						if (tmp_data.SingleVol[sn] < 0.1) {
							tmp_data.SingleVol[sn] = al_fbo_data.get(cnt - 1).SingleVol[sn];
						}
					}
				}
				
				sql_str = "INSERT INTO " + tmp_tb_name + " " + "(BattGroupId, "
						+ "test_record_count, " + "test_type, " + "data_new, "
						+ "data_available, " + "record_num, "
						+ "test_starttime, " + "record_time, "
						+ "test_timelong, " + "group_vol, " + "test_curr, "
						+ "test_cap, " + "mon_num, " + "mon_vol)" + " VALUES ";
				for (int n = 0; n < data_inf.BattSum; n++) {
					if (n > 0)
						sql_str += ", ";

					sql_str += "(" + bg_id + ", " + testRecordCount + ", "
							+ data_type + ", " + true + ", " + true + ", "
							+ (cnt + 1) + ", " + "'"
							+ Com.get_DTF(ald.getTime(), Com.DTF_YMDhms)
							+ "', " + "'"
							+ Com.get_DTF(new Date(), Com.DTF_YMDhms) + "', "
							+ test_time_long + ", " + tmp_data.SumVoltage
							+ ", " + tmp_data.SubCurrent[0] + ", "
							+ tmp_data.SubCap[0] + ", " + (n + 1) + ", "
							+ tmp_data.SingleVol[n] + ")";
				}
				// System.out.println(sql_str);
				//upload_res = sql.sqlMysqlExecute(sql_str);
				upload_res = DAOHelper
						.executeCreateTable(
								conn,
								sql_str);

				if (al_fbo_data.size() > 0) {
					row_data[5]=((cnt + 1) * 100) / al_fbo_data.size()+"";
				}				
			}

			if ((true == bl) && (al_fbo_data.size() > 0)
					&& (true == upload_res)) {
				// -----------------------------------------------------------------//
				upload_res=false;
				double test_ah = tmp_data.SubCap[0];
				test_ah = (test_ah * 3600) / test_time_long; // 平均测试电流
				tmp_data.SubCurrent[0] = (float) test_ah;
				// -----------------------------------------------------------------//
				ArrayList<String> al_sql_str = new ArrayList<String>();
				sql_str = "INSERT INTO " + tb_stop_name + " (BattGroupId, "
						+ "test_record_count, " + "test_type, " + "data_new, "
						+ "data_available, " + "record_num, "
						+ "test_starttime, " + "record_time, "
						+ "test_timelong, " + "group_vol, " + "test_curr, "
						+ "test_cap, " + "mon_num, " + "mon_vol)" + " VALUES ";
				for (int n = 0; n < data_inf.BattSum; n++) {
					if (n > 0)
						sql_str += ", ";

					sql_str = sql_str + "(" + bg_id + ", " + testRecordCount
							+ ", " + data_type + ", " + true + ", " + true
							+ ", " + al_fbo_data.size() + ", " + "'"
							+ Com.get_DTF(ald.getTime(), Com.DTF_YMDhms)
							+ "', " + "'"
							+ Com.get_DTF(new Date(), Com.DTF_YMDhms) + "', "
							+ test_time_long + ", " + tmp_data.SumVoltage
							+ ", " + tmp_data.SubCurrent[0] + ", "
							+ tmp_data.SubCap[0] + ", " + (n + 1) + ", "
							+ tmp_data.SingleVol[n] + ")";
				}
				al_sql_str.add(sql_str);

				String sql_str1 = "INSERT INTO TB_BattTestData_Inf  "
						+ " (BattGroupId, " + "test_record_count, "
						+ "test_type, " + "record_time_interval, "
						+ "data_new, " + "data_available, " + "record_num, "
						+ "test_starttime, " + "test_starttype, "
						+ "record_time, " + "test_timelong, "
						+ "test_stoptype," + "group_vol, " + "test_curr, "
						+ "test_cap, " + "max_monnum, " + "max_monvol, "
						+ "min_monnum, " + "min_monvol, " + "upload_usr_id) "
						+ " VALUES " + "("
						+ bg_id
						+ ", "
						+ testRecordCount
						+ ", "
						+ data_type
						+ ", "
						+ data_inf.SaveInterval * 60
						+ ", "
						+ true
						+ ", "
						+ true
						+ ", "
						+ al_fbo_data.size()
						+ ", "
						+ "'"
						+ Com.get_DTF(ald.getTime(), Com.DTF_YMDhms)
						+ "', "
						+ data_inf.Device
						+ ", "
						+ "'"
						+ Com.get_DTF(new Date(), Com.DTF_YMDhms)
						+ "', "
						+ test_time_long
						+ ", "
						+ data_inf.StopType
						+ ", "
						+ tmp_data.SumVoltage
						+ ", "
						+ tmp_data.SubCurrent[0]
						+ ", "
						+ tmp_data.SubCap[0]
						+ ", "
						+ (data_inf.SMaxIndex[0] + 1)
						+ ", "
						+ data_inf.SMaxVol[0]
						+ ", "
						+ (data_inf.SMinIndex[0] + 1)
						+ ", "
						+ data_inf.SMinVol[0] + ", " + uinf.getUId() + ") ";
				if (1 == testRecordCount) {
					sql_str1 = "UPDATE  TB_BattTestData_Inf  SET "
							+ "test_type="
							+ data_type
							+ ", "
							+ "record_time_interval="
							+ data_inf.SaveInterval * 60
							+ ", "
							+ "data_new="
							+ true
							+ ", "
							+ "data_available="
							+ true
							+ ", "
							+ "record_num="
							+ al_fbo_data.size()
							+ ", "
							+ "test_starttime='"
							+ Com.get_DTF(ald.getTime(), Com.DTF_YMDhms)
							+ "', "
							+ "test_starttype="
							+ data_inf.Device
							+ ", "
							+ "record_time='"
							+ Com.get_DTF(new Date(), Com.DTF_YMDhms)
							+ "', "
							+ "test_timelong="
							+ test_time_long
							+ ", "
							+ "test_stoptype="
							+ data_inf.StopType
							+ ", "
							+ "group_vol="
							+ tmp_data.SumVoltage
							+ ", "
							+ "test_curr="
							+ tmp_data.SubCurrent[0]
							+ ", "
							+ "test_cap="
							+ tmp_data.SubCap[0]
							+ ", "
							+ "max_monnum="
							+ (data_inf.SMaxIndex[0] + 1)
							+ ", "
							+ "max_monvol="
							+ data_inf.SMaxVol[0]
							+ ", "
							+ "min_monnum="
							+ (data_inf.SMinIndex[0] + 1)
							+ ", "
							+ "min_monvol="
							+ data_inf.SMinVol[0]
							+ ", "
							+ "upload_usr_id="
							+ uinf.getUId()
							+ " "
							+ " WHERE BattGroupId="
							+ bg_id
							+ " AND test_record_count=" + testRecordCount;
				}
				al_sql_str.add(sql_str1);

				String sql_str2 = "INSERT INTO " + tb_name + " "
						+ " (BattGroupId, " + "test_record_count, "
						+ "test_type, " + "data_new, " + "data_available, "
						+ "record_num, " + "test_starttime, " + "record_time, "
						+ "test_timelong, " + "group_vol, " + "test_curr, "
						+ "test_cap, " + "mon_num, " + "mon_vol) " + " SELECT "
						+ " BattGroupId, " + "test_record_count, "
						+ "test_type, " + "data_new, " + "data_available, "
						+ "record_num, " + "test_starttime, " + "record_time, "
						+ "test_timelong, " + "group_vol, " + "test_curr, "
						+ "test_cap, " + "mon_num, " + "mon_vol " + " FROM "
						+ tmp_tb_name;
				al_sql_str.add(sql_str2);

				upload_res = DAOHelper.makeManualCommit(conn,al_sql_str);
			}
		} catch (Exception e) {
			e.printStackTrace();
			upload_res = false;
		} finally {
			// sql.close_con();
			DBUtil.close(null, null,conn);
		}
		return upload_res;
	}
}