package com.battdata_rt;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;

import com.base.Com;
import com.battalarm.BattAlarmData;
import com.battalarm.BattAlarmParam;
import com.battalarm.BattAlarm_Thread_SQL;
import com.config.AppConfig;
import com.config.AppParam;
import com.sql.MysqlConnPool;

public class BattData_RT {
	
	public static final int MonomerCountMax	= 400;				//ÔÚÏ߸¡³ä
	
	public static final byte IEC61850_SYS_STATE_STOPPED	= 0;				//ÔÚÏ߸¡³ä
	public static final byte IEC61850_SYS_STATE_CHARGING = 1;				//Ô¤³äµç/£¨ÏÞÁ÷³äµç£©
	public static final byte IEC61850_SYS_STATE_DISCHARGING = 2;			//ºËÈݲâÊÔ
	public static final byte IEC61850_SYS_STATE_PD_DISCHARGING = 3;			//Í£µç·Åµç
	public static final byte IEC61850_SYS_STATE_RES_TEST = 4;				//ÄÚ×è²âÊÔ
	public static final byte IEC61850_SYS_STATE_KD_TEST = 5;				//K1/D1²âÊÔ
	
	private boolean MonDataFromCInterfaceOk = false;
	
	private boolean MonDataIsUseForIdce8200 = false;
	private boolean mIDCE8200_ConState = false;
	public long StationId;
	public String StationName;
	public byte[] StationIp = new byte[4];
	public int BattGroupId = 0;
	public int BattCurrDeviceId = 0;
	public int[] BattCurrValueId = new int[16];
	
	public int FBSDeviceId = 0;
	public String FBSDeviceIp = " ";
	public String FBSDeviceName = " ";
	public int GroupIndexInFBSDevice = 1;
	
	public int BattGroupNum;
	public int BattState;
	public int MonCount = 1;
	public float MonStdVol;
	public float MonStdCap;
	public float MonStdRes;			//±ê³ÆÄÚ×è
	
	public int dev_workstate;		//É豸¹¤×÷״̬
	
	private boolean StoreBattRes_DataEn = false;
	public boolean MysqlDataResInfTable_Exist = false;
	public boolean MysqlRecordInf_Exist = false;
	
	public ArrayList<MonVolData> al_MonVol = new ArrayList<MonVolData>();
	public ArrayList<MonVolData> al_MonVol_RtOld = new ArrayList<MonVolData>();
	public ArrayList<MonVolData> al_MonVol_History = new ArrayList<MonVolData>();
	public ArrayList<ArrayList<Integer>> al_MonVol_C_Id = new ArrayList<ArrayList<Integer>>();
	
	public BattStatData  TestData;
	
	public BattAlarmParam m_AlarmParam = new BattAlarmParam();					//µ±Ç°¸æ¾¯²ÎÊýÖеÄϵÊýֵΪʵ¼ÊãÐÖµ
	
	public BattAlarmParam m_BattAlarmParam = new BattAlarmParam();				//ÿ¸öµç³Ø×é¶ÔÓ¦Ò»¸ö¸æ¾¯µÄ²ÎÊý[мÓ]
	
	public int mMaxMonNum = 0;
	public float mMaxMonVol = 0;
	public int mMinMonNum = 0;
	public float mMinMonVol = 0;
	
	private AppParam mAppParam  = new AppParam();
	
	private float mBattFloatCurrLevel = (float) 15.0;
	public int mSaveDataTimeInterval = 10;
	private MysqlConnPool pool;
	/*********************************************************************************/
	/*********************************************************************************/
	public BattData_RT(AppConfig cfg, AppParam param, MysqlConnPool pool)
	{
		TestData = new BattStatData(cfg.getSourceBattDataType(), cfg.getSybSrvCurrChargeDirPos());
		
		mAppParam.copyAppParam(param);
		
		this.pool = pool;
	}
	
	
	/**
	 * ÉèÖà   tmp_al_id Êý×éÖÐcInterfaceIdµÄÖµ
	 */
	public void make_al_MonVol_C_Id()
	{
		al_MonVol_C_Id.clear();
		ArrayList<Integer> tmp_al_id = null;
		
		int start_index = 0;
		for(int m=0; m<al_MonVol.size(); m++)
		{
			int tmp_id = al_MonVol.get(m).cInterfaceId;
			
			if((start_index < 1) || (start_index > 24) 
				|| ((tmp_id-2) > tmp_al_id.get(start_index - 1))
				|| ((tmp_id+2) < tmp_al_id.get(start_index - 1)))
			{
				start_index = 0;
				tmp_al_id = new ArrayList<Integer>();
				al_MonVol_C_Id.add(tmp_al_id);
			}
			
			tmp_al_id.add(tmp_id);
			start_index++;
		}
	}
	
	/**
	 * ÉèÖÃal_MonVol_C_IdÖеÄcInterfaceId
	 */
	public void make_al_MonVol_Auto_C_Id()
	{
		al_MonVol_C_Id.clear();
		ArrayList<Integer> tmp_al_id = null;
		
		tmp_al_id = new ArrayList<Integer>();
		for(int m=0; m<al_MonVol.size(); m++)
		{
			int tmp_id = al_MonVol.get(m).cInterfaceId;
			tmp_al_id.add(tmp_id);
		}
		
		al_MonVol_C_Id.add(tmp_al_id);
	}
	
	public void setStoreBattRes_DataEnStat(boolean stat)
	{
		StoreBattRes_DataEn = stat;
	}
	public boolean getStoreBattRes_DataEnStat()
	{
		return StoreBattRes_DataEn;
	}
	
	public void setBattFloatVolCurrLevel(float vol_lev, float curr_level)
	{
		mBattFloatCurrLevel = curr_level;
		TestData.setBattFloatCurrLevel(mBattFloatCurrLevel);
	}
	
	public boolean isMonDataFromCInterfaceOk()
	{
		return MonDataFromCInterfaceOk;
	}
	public void setMonDataFromCInterfaceOk(boolean stat)
	{
		MonDataFromCInterfaceOk = stat;
	}
	
	public boolean isMonDataUseForIdce8200()
	{
		return MonDataIsUseForIdce8200;
	}
	public void setMonDataUseForIdce8200(boolean stat)
	{
		MonDataIsUseForIdce8200 = stat;
	}
	
	public boolean getIdce8200ComState()
	{
		return mIDCE8200_ConState;
	}
	
	public void updateMonVolFromIDCE8200(int mon_index, float vol)
	{
		mIDCE8200_ConState = true;
		setMonDataUseForIdce8200(true);
		
		al_MonVol.get(mon_index).monVol = vol;
	}
	
	public void updateMonVolFromSQL_SERVER()
	{
		if(true == isMonDataFromCInterfaceOk())
		{
			return;
		}
		
		float sumvol = 0;
		for(int bt_index=0; bt_index<al_MonVol.size(); bt_index++)
		{
			if(false == isMonDataUseForIdce8200())
			{
				al_MonVol.get(bt_index).monVol = al_MonVol.get(bt_index).monVol_TMP;
			}
			sumvol += al_MonVol.get(bt_index).monVol;
		}
		TestData.groupVol = sumvol;
	}
	
	public void updateMonVolFrom_C_Interface(int mon_c_id, float mon_vol)
	{
		float sumvol = 0;
		for(int var=0; var<al_MonVol.size(); var++)
		{
			MonVolData mvol = al_MonVol.get(var);
			if(mon_c_id == mvol.cInterfaceId)
			{
				if(false == isMonDataUseForIdce8200())
				{
					mvol.monVol = mon_vol;
				}
				
				if((mon_vol > 0.1) && (false == isMonDataFromCInterfaceOk()))
				{
					setMonDataFromCInterfaceOk(true);
				}
			}
			
			sumvol += al_MonVol.get(var).monVol;
		}
		TestData.groupVol = sumvol;
	}
	/********************************************************************************/
	
	public int getBattCount()
	{
		return MonCount;
	}
	public byte getBattState()
	{
		return TestData.battState;
	}
	public byte getBattTestType()
	{
		return TestData.battTestState;
	}
	public float getOnlineVol()
	{
		return TestData.onlineVol;
	}
	public float getGroupVol()
	{
		return TestData.groupVol;
	}
	public float getGroupTmp()
	{
		return TestData.groupTmp;
	}
	public float getTestCurr()
	{
		return TestData.testCurr;
	}
	public float getTestCap()
	{
		return TestData.testCap;
	}
	public long getTestStartTime()
	{
		return TestData.startTestTime.getTime();
	}
	public long getTestRecordTime()
	{
		return TestData.recordTime.getTime();
	}
	public int getTestTimeLong()
	{
		return TestData.testTimeLong;
	}
	public float getBattRealCap()
	{
		return TestData.battRealCap;
	}
	public float getBattRestCap()
	{
		return TestData.battRestCap;
	}
	public int getBattRestTime()
	{
		return TestData.battRestTime;
	}
	
	/**
	 * ÉèÖõç³Ø×éµ¥ÌåµÄ×î´óµ¥ÌåµçѹºÍ×îСµ¥Ìåµçѹ£¬ÒÔ¼°¶ÔÓ¦µÄµ¥Ìå±àºÅ
	 * @param al_vol
	 */
	public void makeMaxMinMonVol(ArrayList<MonVolData> al_vol)
	{
		if(null != al_vol)
		{
			float maxvol = -80000;
			float minvol = 80000;
			for(int n=0; n<al_vol.size(); n++)
			{
				if(maxvol < al_vol.get(n).monVol)
				{
					maxvol = al_vol.get(n).monVol;
					mMaxMonNum = n+1;
				}
				if(minvol > al_vol.get(n).monVol)
				{
					minvol = al_vol.get(n).monVol;
					mMinMonNum = n+1;
				}
			}
			mMaxMonVol = maxvol;
			mMinMonVol = minvol;
		}
	}
	
	
	public float getMaxMonVol()
	{
		float maxvol = -80000;
		for(int n=0; n<al_MonVol.size(); n++)
		{
			if(maxvol < al_MonVol.get(n).monVol)
			{
				maxvol = al_MonVol.get(n).monVol;
				mMaxMonNum = n+1;
			}
		}
		return maxvol;
	}
	public float getMinMonVol()
	{
		float minvol = 80000;
		for(int n=0; n<al_MonVol.size(); n++)
		{
			if(minvol > al_MonVol.get(n).monVol)
			{
				minvol = al_MonVol.get(n).monVol;
				mMinMonNum = n+1;
			}
		}
		return minvol;
	}
	public float getGroupVolFromMonVol()
	{
		float gvol = 0;
		for(int n=0; n<al_MonVol.size(); n++)
		{
			gvol += al_MonVol.get(n).monVol;
		}
		return gvol;
	}
	public float get_al_MonVol_History(int index)
	{
		float vol = 0;
		if((index>=0) && (index<al_MonVol_History.size()))
		{
			vol = al_MonVol_History.get(index).monVol;
		}
		return vol;
	}
	public boolean is_al_MonVol_History_New(int index)
	{
		boolean isnew = false;
		if((index>=0) && (index<al_MonVol_History.size()))
		{
			isnew = al_MonVol_History.get(index).data_new;
		}
		return isnew;
	}
	//==============================================================//
	//==============================================================//
	public void initAlarmParam(int dt_count_max, BattAlarmParam alm_param)
	{
		/***********************************************************************************/
		float std_group_vol = MonStdVol * MonCount;
		alm_param.setAlarmParamCellValue(std_group_vol, m_AlarmParam.alm_OnlineVol, alm_param.alm_OnlineVol);
		alm_param.setAlarmParamCellValue(std_group_vol, m_AlarmParam.alm_GroupVol, alm_param.alm_GroupVol);
		/***********************************************************************************/
		float std_curr = MonStdCap / 10;
		alm_param.setAlarmParamCellValue(std_curr, m_AlarmParam.alm_BattChargeCurr, alm_param.alm_BattChargeCurr);
		alm_param.setAlarmParamCellValue(std_curr, m_AlarmParam.alm_BattDisChargeCurr, alm_param.alm_BattDisChargeCurr);
		/***********************************************************************************/
		float std_monvol = MonStdVol;
		alm_param.setAlarmParamCellValue(std_monvol, m_AlarmParam.alm_MonVol, alm_param.alm_MonVol);
		alm_param.setAlarmParamCellValue(std_monvol, m_AlarmParam.alm_DischargeMonVol, alm_param.alm_DischargeMonVol);
		float std_montmp = 25;
		alm_param.setAlarmParamCellValue(std_montmp, m_AlarmParam.alm_MonTmp, alm_param.alm_MonTmp);
		//float std_monres = (1*(MonStdVol/2)) / (MonStdCap/100);
		float std_monres = MonStdRes;
		alm_param.setAlarmParamCellValue(std_monres, m_AlarmParam.alm_MonRes, alm_param.alm_MonRes);
		float std_connres = (float) 0.2;
		alm_param.setAlarmParamCellValue(std_connres, m_AlarmParam.alm_ConnRes, alm_param.alm_ConnRes);
		
		float std_monlyvol = (float) 1;
		alm_param.setAlarmParamCellValue(std_monlyvol, m_AlarmParam.alm_MonLYVol, alm_param.alm_MonLYVol);
		
		float std_cap = MonStdCap;
		alm_param.setAlarmParamCellValue(std_cap, m_AlarmParam.alm_MonREALCAP, alm_param.alm_MonREALCAP);
		
		TestData.initAlarmData(dt_count_max, BattGroupId, m_AlarmParam);
		for(int n=0; n<al_MonVol.size(); n++)
		{
			al_MonVol.get(n).initAlarmData(dt_count_max, BattGroupId, n+1, m_AlarmParam);
		}
	}
	
	/**
	 * ¼ì²éTestData¶ÔÏóÊÇ·ñÂú×ã¸æ¾¯Ìõ¼þ
	 * @return	Âú×ã¸æ¾¯Ìõ¼þµÄBattAlarmData¶ÔÏ󼯺Ï
	 */
	public ArrayList<BattAlarmData> makeAlarmData()
	{
		ArrayList<BattAlarmData> al_alm_data = new ArrayList<BattAlarmData>();
		//Date timetime = new Date(100,0,1);
		Calendar c = Calendar.getInstance();
		c.set(2000, 0, 1, 0, 0, 0);
		//System.out.println(this.BattGroupId+"=="+Com.getDateTimeFormat(TestData.recordTime, Com.DTF_YMDhms));
		if(TestData.recordTime.before(c.getTime())){
			//¹ýÂËÉÐδͨÐÅÉϹýµÄÉ豸µÄµç³Ø×é
			//System.out.println(Com.getDateTimeFormat(TestData.recordTime, Com.DTF_YMDhms)+"<"+Com.getDateTimeFormat(timetime, Com.DTF_YMDhms));
			return al_alm_data;
		}
		//System.out.println("2222222222222="+dev_workstate);
		if((FBSDeviceId/1000000 == 618 && (!(dev_workstate == IEC61850_SYS_STATE_DISCHARGING || dev_workstate == IEC61850_SYS_STATE_CHARGING))) || (FBSDeviceId/1000000 != 618)) {							
			TestData.onlineVol_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_OnlineVol, TestData.onlineVol);
			TestData.groupVol_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_GroupVol, TestData.groupVol);
			//System.out.println("¼ì²â×é¶Ëµçѹ");
		}
		
		
		
		if(TestData.testCurr >= 0)
		{
			TestData.battCurr_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_BattChargeCurr, TestData.testCurr);
		}
		else
		{
			TestData.battDisCurr_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_BattDisChargeCurr, Math.abs(TestData.testCurr));
		}
		
		for(int n=0; n<al_MonVol.size(); n++)
		{
			MonVolData vol_data = al_MonVol.get(n);
			
			if((FBSDeviceId/1000000 == 618 && (!(dev_workstate == IEC61850_SYS_STATE_DISCHARGING || dev_workstate == IEC61850_SYS_STATE_CHARGING))) || (FBSDeviceId/1000000 != 618)) {							
				vol_data.monVol_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_MonVol, vol_data.monVol);
			
				//System.out.println("¼ì²âµ¥Ìåµçѹ");
			}
			if(TestData.testCurr < 0) {				
				vol_data.dischargeMonVol_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_DischargeMonVol, vol_data.monVol);
			}
			vol_data.monTmp_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_MonTmp, vol_data.monTmp);
			vol_data.monRes_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_MonRes, vol_data.monRes);
			vol_data.connRes_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_ConnRes, vol_data.connRes);
			vol_data.monLYVol_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_MonLYVol, vol_data.monLYVol);
			vol_data.monRealCap_AlarmData.makeAlarmData(al_alm_data, m_AlarmParam.alm_MonREALCAP, vol_data.monRealCap);
		}
		long outtimelong = Math.abs((new Date().getTime()) - TestData.recordTime.getTime())/1000;
//		if(BattGroupId == 1000021) {
//			System.out.println("TestData.groupVol_AlarmData.alm_signal_id:"+TestData.groupVol_AlarmData.alm_signal_id+"==" + this.TestData.groupVol_AlarmData.getAlarmState());
//		}
		
		//System.out.println("³¬Ê±Ê±¼ä£º" + outtimelong + " FBSDeviceId£º"+FBSDeviceId +"-"+(FBSDeviceId/100000 != 6185));
//		if(outtimelong<60 && (FBSDeviceId/100000 != 6185)) {
			//System.out.println("¸üÐÂÊý¾Ý¡£¡£¡£");
			//61850É豸²»ÓøüР 'db_ram_db.tb_batt_rtalarm'±í ºÍ'db_ram_db.tb_batt_rsalarm'
			BattAlarm_Thread_SQL.updateBattRtState_Table(pool, this);
			BattAlarm_Thread_SQL.updateBattAlarm_RT_RamDB_Table(pool, this);
//		}
		return al_alm_data;
	}
	
	public void clearStoreDataBusyTag()
	{
	}


	public void updateMonCnt(int new_mon_cnt) {
		if((new_mon_cnt>0) && (new_mon_cnt<MonomerCountMax)) {
			int mon_cnt = this.al_MonVol.size();
			if(new_mon_cnt > mon_cnt) {
				while(new_mon_cnt > this.al_MonVol.size()) {
					MonVolData data = new MonVolData(0, 0, this.BattGroupId*1000 + this.al_MonVol.size()+1);
					this.al_MonVol.add(data);
					this.al_MonVol_RtOld.add(data.clone());
					this.al_MonVol_History.add(data.clone());
				}
				//----------- Ôö¼ÓµÄʱºò×îºóÉèÖõ¥ÌåÊýÁ¿ ----------------
				this.MonCount = new_mon_cnt;
				
			} else if(new_mon_cnt < mon_cnt) {
				//----------- ¼õÉÙµÄʱºò×îÏÈÉèÖõ¥ÌåÊýÁ¿ ----------------
				this.MonCount = new_mon_cnt;
				
				while(new_mon_cnt < this.al_MonVol.size()) {
					this.al_MonVol.remove(this.al_MonVol.size()-1);
					this.al_MonVol_RtOld.remove(this.al_MonVol_RtOld.size()-1);
					this.al_MonVol_History.remove(this.al_MonVol_History.size()-1);
				}
			}
		}	
	}
}