package com.alarms;

import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
import com.concentrator.Concentrator_State;
import com.fgkj.dao.DBHelper;
import com.socket.BattDataThread;
import com.util.Com;
import java.util.Date;
import java.util.List;

/**
 * 电池告警监测线程
 */
public class BattAlarmCheckThread extends  Thread{
    public final static String TAG = "BattAlarmCheckThread";

    private DBHelper dbHelper;
    private List<BattDataThread> allBattDatt;
    public AlarmParam alarmParam;                                                                   //告警参数


    public BattAlarmCheckThread(DBHelper dbHelper, List<BattDataThread> allBattDatt){
        this.dbHelper = dbHelper;
        this.allBattDatt = allBattDatt;
        alarmParam = new AlarmParam();

        SQLiteDatabase db = dbHelper.getWritableDatabase();
        DBHelper.Create_alarm_param(db);                                //创建告警参数表
        DBHelper.Create_battalarm_data(db);                             //创建告警数据表
        if(db != null){
            db.close();
        }

    }

    @Override
    public void run() {
        Log.d(TAG, "run: BattAlarmCheckThread start at"+ Com.getDateTimeFormat(new Date(),Com.DTF_YMDhms));
        //初始化告警对象
        try {
            //线程启动30秒后开始检测电池告警
            sleep(30*1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        initBattAlarmParam(dbHelper,alarmParam);                                                    //初始化告警参数(数据库中的告警参数)
        initBattAlarmData(allBattDatt,dbHelper);                                                    //初始化告警对象

        while (true){
            try {
                for(int i=0;i<allBattDatt.size();i++){
                    BattDataThread battDataThread = allBattDatt.get(i);
                    if(battDataThread.isInstall){
                        List<BattAlarmData> alarmDatas = battDataThread.state.makeAlarmData(battDataThread,alarmParam);
                        if(alarmDatas.size() > 0){
                            //Log.e(TAG, "run: 更新告警条数"+ alarmDatas.size());

                            //更新当前告警记录
                            for(int k = 0;k<alarmDatas.size();k++){
                                //Log.e(TAG, "run: "+alarmDatas.get(k) );
                                insertOrUpdateBattAlarmData(dbHelper,alarmDatas.get(k));                                         //插入或更新当前的告警记录
                            }
                        }
                        alarmDatas.clear();
                    }else{
                        //清除未安装电池组的告警记录
                        if(battDataThread.isAlarmClear){
                            Concentrator_State state = battDataThread.state;
                            //开始清除当前电池组的告警记录
                            state.groupVol_AlarmData.alm_signal_id = 0;
                            state.battCurr_AlarmData.alm_signal_id = 0;
                            for(int k=0;k<state.monCount;k++){
                                state.monVol_AlarmData[k].alm_signal_id = 0;
                                state.monTmp_AlarmData[k].alm_signal_id = 0;
                                state.monRes_AlarmData[k].alm_signal_id = 0;
                            }
                            delBattAllAlarmDataByBattGroupId(dbHelper,battDataThread.battIndex);
                            battDataThread.isAlarmClear = false;
                        }
                    }
                }
                sleep(2000);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }




    /**
     *   初始化当前的电池告警参数表
     */
    public void initBattAlarmParam(DBHelper dbHelper,AlarmParam alarmParam){
        String str_sql = " SELECT num,alm_id,alm_name,alm_high_coe,alm_low_coe,alm_high_en,alm_low_en " +
                " FROM tb_alarm_param ";
        boolean flag = false;
        SQLiteDatabase db = null;
        try {
            db = dbHelper.getWritableDatabase();
            Cursor rs = db.rawQuery(str_sql,null);
            AlarmParam.AlarmParamCell param = null;
            while (rs.moveToNext()){
                int alm_id = rs.getInt(rs.getColumnIndex("alm_id"));
                switch (alm_id){
                    case AlarmParam.ALM_TYPE_GroupVol_ID:param = alarmParam.alm_GroupVol;break;
                    case AlarmParam.ALM_TYPE_BattCurr_ID:param = alarmParam.alm_BattCurr;break;
                    case AlarmParam.ALM_TYPE_MonVol_ID:param = alarmParam.alm_MonVol;break;
                    case AlarmParam.ALM_TYPE_MonRes_ID:param = alarmParam.alm_MonRes;break;
                    case AlarmParam.ALM_TYPE_MonTmp_ID:param = alarmParam.alm_MonTmp;break;
                    default:param = null;break;
                }
                if(param != null){
                    param.alm_id = alm_id;
                    param.alm_name = rs.getString(rs.getColumnIndex("alm_name"));
                    param.alm_low_en = rs.getInt(rs.getColumnIndex("alm_low_en"));
                    param.alm_low_coe = rs.getDouble(rs.getColumnIndex("alm_low_coe"));
                    param.alm_high_en = rs.getInt(rs.getColumnIndex("alm_high_en"));
                    param.alm_high_coe = rs.getDouble(rs.getColumnIndex("alm_high_coe"));
                }
                flag = true;
            }
            if(flag){
                //数据库中无数据时
                str_sql = "INSERT INTO tb_alarm_param "
                        + "(alm_id,alm_name,alm_high_coe,alm_low_coe,alm_high_en,alm_low_en)"
                        + " VALUES "
                        + "("+AlarmParam.ALM_TYPE_GroupVol_ID+",'Batt_Alarm_Type_GroupVol', "+alarmParam.alm_GroupVol.alm_high_coe+", "+alarmParam.alm_GroupVol.alm_low_coe+", "+alarmParam.alm_GroupVol.alm_high_en+", "+alarmParam.alm_GroupVol.alm_low_en+"),"
                        + "("+AlarmParam.ALM_TYPE_BattCurr_ID+",'Batt_Alarm_Type_BattCurr', "+alarmParam.alm_BattCurr.alm_high_coe+", "+alarmParam.alm_BattCurr.alm_low_coe+", "+alarmParam.alm_BattCurr.alm_high_en+", "+alarmParam.alm_BattCurr.alm_low_en+"),"
                        + "("+AlarmParam.ALM_TYPE_MonVol_ID+",'Batt_Alarm_Type_MonVol', "+alarmParam.alm_MonVol.alm_high_coe+", "+alarmParam.alm_MonVol.alm_low_coe+", "+alarmParam.alm_MonVol.alm_high_en+", "+alarmParam.alm_MonVol.alm_low_en+", "+"),"
                        + "("+AlarmParam.ALM_TYPE_MonTmp_ID+",'Batt_Alarm_Type_MonTmp', "+alarmParam.alm_MonTmp.alm_high_coe+", "+alarmParam.alm_MonTmp.alm_low_coe+", "+alarmParam.alm_MonTmp.alm_high_en+", "+alarmParam.alm_MonTmp.alm_low_en+", "+"),"
                        + "("+AlarmParam.ALM_TYPE_MonRes_ID+",'Batt_Alarm_Type_MonRes', "+alarmParam.alm_MonRes.alm_high_coe+", "+alarmParam.alm_MonRes.alm_low_coe+", "+alarmParam.alm_MonRes.alm_high_en+", "+alarmParam.alm_MonRes.alm_low_en+", "+")";
                db.execSQL(str_sql);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
//            if(db != null){
//                db.close();
//            }
        }
    }

    /**
     * 删除指定电池组的所有实时告警记录
     * @param dbHelper
     * @param BattGroupId
     */
    public void delBattAllAlarmDataByBattGroupId(DBHelper dbHelper,int BattGroupId){
        String sql_str = "DELETE FROM tb_battalarm_data WHERE BattGroupId = "+ BattGroupId + " AND alm_cleared_type = 0;";
        //Log.e(TAG, "delBattAllAlarmDataByBattGroupId: "+sql_str );
        SQLiteDatabase db = null;
        try {
            db = dbHelper.getWritableDatabase();
            db.execSQL(sql_str);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
//            if(db != null){
//                db.close();
//            }
        }
    }

    /**
     * 插入或者更新当前的告警记录
     */
    public void insertOrUpdateBattAlarmData(DBHelper dbHelper,BattAlarmData battAlarmData){
        String sql_str = "";
        if(battAlarmData.alm_cleared_type == BattAlarmData.ALM_CLEARED_TYPE_NULL){
            //插入新的告警记录
            sql_str = "INSERT INTO tb_battalarm_data"
                    + "(BattGroupId, "
                    + "MonNum, "
                    + "alm_id, "
                    + "alm_signal_id, "
                    + "alm_start_time, "
                    + "alm_end_time, "
                    + "alm_value, "
                    + "alm_is_confirmed, "
                    + "alm_confirmed_time, "
                    + "alm_cleared_type) "
                    + " VALUES "
                    + "("
                    + battAlarmData.BattGroupId + ", "
                    + battAlarmData.MonNum + ", "
                    + battAlarmData.alm_id + ", "
                    + battAlarmData.alm_signal_id + ", "
                    + "'" + Com.getDateTimeFormat(battAlarmData.alm_start_time, Com.DTF_YMDhms) + "', "
                    + "'" + Com.getDateTimeFormat(battAlarmData.alm_end_time, Com.DTF_YMDhms) + "', "
                    + battAlarmData.alm_value + ", "
                    + battAlarmData.alm_is_confirmed + ", "
                    + "'" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "', "
                    + battAlarmData.alm_cleared_type + " "
                    + ")";
        }else{
            sql_str = "UPDATE tb_battalarm_data SET alm_end_time = '"+Com.getDateTimeFormat(battAlarmData.alm_end_time,Com.DTF_YMDhms)+"',alm_cleared_type="+battAlarmData.alm_cleared_type +
                    " WHERE alm_id="+battAlarmData.alm_id+" AND alm_signal_id= "+battAlarmData.alm_signal_id+" AND MonNum = "+ battAlarmData.MonNum+" AND BattGroupId = "+battAlarmData.BattGroupId;
        }
        SQLiteDatabase db = null;
        try {
            db = dbHelper.getWritableDatabase();
            db.execSQL(sql_str);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
//            if(db != null){
//                db.close();
//            }
        }
    }


    /**
     *   初始化所有电池组的告警对象，并且删除当前电池组的告警记录
     * @param battDataThreads
     */
    public void initBattAlarmData(List<BattDataThread> battDataThreads,DBHelper dbHelper){
        for(int i=0;i<battDataThreads.size();i++){
            Concentrator_State state = battDataThreads.get(i).state;
            state.groupVol_AlarmData = new BattAlarmData(battDataThreads.get(i).battIndex,AlarmParam.ALM_TYPE_GroupVol_ID,0);
            state.battCurr_AlarmData = new BattAlarmData(battDataThreads.get(i).battIndex,AlarmParam.ALM_TYPE_BattCurr_ID,0);
            for(int k=0;k<state.monVol_AlarmData.length;k++){
                state.monVol_AlarmData[k] = new BattAlarmData(battDataThreads.get(i).battIndex,AlarmParam.ALM_TYPE_MonVol_ID,k+1);
                state.monTmp_AlarmData[k] = new BattAlarmData(battDataThreads.get(i).battIndex,AlarmParam.ALM_TYPE_MonTmp_ID,k+1);
                state.monRes_AlarmData[k] = new BattAlarmData(battDataThreads.get(i).battIndex,AlarmParam.ALM_TYPE_MonRes_ID,k+1);
            }
            delBattAllAlarmDataByBattGroupId(dbHelper,battDataThreads.get(i).battIndex);                                                            //删除当前电池组的实时告警记录
        }
    }
}