package com.fgkj.dao.impl;

import java.sql.Connection;
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.CsvData;

public class ResDataUploadImpl {
	public static boolean uploadResData(User_inf uinf, int bg_id, CsvData csv_data, 
			String[] row_data,Boolean bl)
{
		boolean upload_res = false;
		
		Connection conn=DBUtil.getConn();
		int testRecordCount = Upload.getBattTestRecordCountNew(bg_id,
				"db_batt_testdata.TB_BattResData_Inf",
				conn);
		
		Calendar ald = Calendar.getInstance();
		ald.setTime(csv_data.m_TestTime);
		int data_type = BattTestData.BATTDATA_SER;
		String tb_name = "`db_batt_testdata`.`tb_BattResData_" + bg_id + "` ";
		try {
		if(true == bl)
		{
				String sql_str0 = "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, "
		+ "`test_starttime` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', "
		+ "`group_vol` FLOAT NOT NULL DEFAULT 0, "
		+ "`test_curr` FLOAT NOT NULL DEFAULT 0, "
		+ "`mon_num` INT NOT NULL DEFAULT 0, "
		+ "`mon_vol` FLOAT NOT NULL DEFAULT 0, "
		+ "`mon_tmp` FLOAT NOT NULL DEFAULT 0, "
		+ "`mon_res` FLOAT NOT NULL DEFAULT 0, "
		+ "`mon_ser` FLOAT NOT NULL DEFAULT 0, "
		+ "`conn_res` FLOAT NOT NULL DEFAULT 0, "
		+ "INDEX index_test_record_count (`test_record_count`), "
		+ "PRIMARY KEY (`num`));";
		DAOHelper.executeCreateTable(conn, sql_str0);
		
		ArrayList<String> al_sql_str = new ArrayList<String>();
		String sql_str1 = "INSERT INTO " + tb_name + " "
			+ " (BattGroupId, "
			+ "test_record_count, "
			+ "test_type, "
			+ "data_new, "
			+ "data_available, "
			+ "test_starttime, "
			+ "group_vol, "
			+ "test_curr, "
			+ "mon_num, "
			+ "mon_vol,"
			+ "mon_tmp,"
			+ "mon_res,"
			+ "mon_ser,"
			+ "conn_res)"
			+ " VALUES ";
		for(int n=0; n<csv_data.m_BattSum; n++)
		{
		if(n > 0)
		sql_str1 += ", ";
		
		sql_str1 = sql_str1
				+ "("
			+ bg_id + ", "
			+ testRecordCount + ", "
			+ BattTestData.BATTDATA_SER + ", "
			+ true + ", "
			+ true + ", "
			+ "'" + Com.get_DTF(csv_data.m_TestTime, Com.DTF_YMDhms) + "', "
			+ csv_data.m_GroupVol + ", "
			+ csv_data.m_TestCurr + ", "
			+ ((n+1)*10 + 1) + ", "
			+ csv_data.MonomerVol[n] + ","
			+ csv_data.MonomerTmp[n] + ","
			+ csv_data.MonomerRes[n] + ","
			+ csv_data.MonomerSer[n] + ","
			+ csv_data.MonomerConn[n]
			+ ")";
		}
		al_sql_str.add(sql_str1);
		
		String sql_str2 = "INSERT INTO TB_BattResData_Inf "
		+ " (BattGroupId, "
		+ "test_record_count, "
		+ "test_type, "
		+ "data_new, "
		+ "data_available, "
		+ "test_starttime, "
		+ "test_devtype, "
		+ "record_time, "
		+ "group_vol, "
		+ "test_curr, "
		+ "upload_usr_id) "
		+ " VALUES "
		+ "("+ bg_id + ", "
		+ testRecordCount + ", "
		+ data_type + ", "
		+ true + ", "
		+ true + ", "
		+ "'" + Com.get_DTF(ald.getTime(), Com.DTF_YMDhms) + "', "
		+ CsvData.DevType_Csv + ", "
		+ "'" + Com.get_DTF(new Date(), Com.DTF_YMDhms) + "', "
		+ csv_data.m_GroupVol + ", "
		+ csv_data.m_TestCurr + ", "
		+ uinf.getUId() + ") ";
		if(1 == testRecordCount) {
		sql_str2 = "UPDATE TB_BattResData_Inf  SET "
		+ "test_type=" + data_type + ", "
		+ "data_new=" + true + ", "
		+ "data_available=" + true + ", "
		+ "test_starttime='" + Com.get_DTF(ald.getTime(), Com.DTF_YMDhms) + "', "
		+ "test_devtype=" + CsvData.DevType_Csv + ", "
		+ "record_time='" + Com.get_DTF(new Date(), Com.DTF_YMDhms) + "', "
		+ "group_vol=" + csv_data.m_GroupVol + ", "
		+ "test_curr=" + csv_data.m_TestCurr + ", "
		+ "upload_usr_id=" + uinf.getUId() + " "
		+ " WHERE BattGroupId=" + bg_id
		+ " AND test_record_count=" + testRecordCount;
		}
		al_sql_str.add(sql_str2);
		upload_res = DAOHelper.makeManualCommit(
				conn,
				al_sql_str);
		
		}
		} catch (Exception e) {
			e.printStackTrace();
			upload_res = false;
		} finally {
			DBUtil.close(null, null,
					conn);
		}		
		return upload_res;
		}
}