package com.socket;

import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
import android.webkit.JavascriptInterface;
import android.webkit.WebView;

import com.alarms.BattAlarmCheckThread;
import com.concentrator.Concentrator_State;
import com.fgkj.action.ServiceModel;
import com.fgkj.dao.ActionUtil;
import com.fgkj.dao.DBHelper;
import com.fgkj.dto.Battinf;
import com.google.gson.Gson;
import com.util.Com;

import java.lang.reflect.Array;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

public class FBS9600S_DeviceService {
    public final static String TAG = "FBS9600S_DeviceService";

    public static final int MAXCONCENTRATORCOUNT = 16;                                  //最多连接的汇集器数量
    public static final String JS_INTERFACE_NAME = "DeviceService";                     //JS调用类名

    public static List<BattDataThread> allBattDatt;
    public DBHelper dbHelper;
    public WebView webView;
    public FBS9600S_DeviceService(WebView webView,DBHelper dbHelper){
        this.dbHelper = dbHelper;
        this.webView = webView;
        allBattDatt = new ArrayList<>();
        for(int i=0;i<MAXCONCENTRATORCOUNT;i++){
            BattDataThread thread = new BattDataThread(i+1,this.dbHelper,webView);
            allBattDatt.add(thread);
            thread.start();
        }
        allBattDatt.get(0).isInstall = true;

        List<Battinf> list = queryAllBattInf(dbHelper);                     //查询数据库中的所有电池组信息

        List<Battinf> temps = initBattInfo(allBattDatt,list);

        insertBattinf(dbHelper,temps);


        //电池告警线程
        BattAlarmCheckThread battAlarmCheckThread = new BattAlarmCheckThread(dbHelper,allBattDatt);
        battAlarmCheckThread.start();

    }

    //读取系统状态
    @JavascriptInterface
    public void readSystemState(String index){
        int battindex = Integer.parseInt(index);
        if(battindex > 0 && battindex <= MAXCONCENTRATORCOUNT){
            allBattDatt.get(battindex - 1).readSystemState("readSystemState");
        }
    }

    //读取系统参数
    @JavascriptInterface
    public void readSystemParam(String index){
        int battindex = Integer.parseInt(index);
        if(battindex>0 && battindex <= MAXCONCENTRATORCOUNT){
            allBattDatt.get(battindex-1).readSystemParam("readSystemParam");
        }
    }

    //设置系统参数
    @JavascriptInterface
    public void writeSystemParam(String index,String json){
        int battindex = Integer.parseInt(index);
        if(battindex>0 && battindex <= MAXCONCENTRATORCOUNT){
            allBattDatt.get(battindex-1).writeSystemParam("writeSystemParam",json);
        }
    }

    //读取电池信息
    @JavascriptInterface
    public void readBattMonInfo(String index){
        int battindex = Integer.parseInt(index);
        ServiceModel model = new ServiceModel();
        if(battindex>0 && battindex <= MAXCONCENTRATORCOUNT){
            Concentrator_State state = allBattDatt.get(battindex-1).state;
            if(allBattDatt.get(battindex-1).isOutTime){
                state.isOutTime = 1;
            }else{
                state.isOutTime = 0;
            }
            model.code = 1;
            model.data = state;
        }
        //Log.e(TAG, "readBattMonInfo: "+ActionUtil.getGson().toJson(model) );
        ActionUtil.SendCallDataToJS(JS_INTERFACE_NAME,"readBattMonInfo",model,webView, ActionUtil.getGson());
    }

    //启动内阻测试
    @JavascriptInterface
    public void startBattResTest(String index){
        int battindex = Integer.parseInt(index);
        if(battindex>0 && battindex <= MAXCONCENTRATORCOUNT){
            allBattDatt.get(battindex-1).startBattResTest(JS_INTERFACE_NAME+"startBattResTest");
        }
    }

    //停止内阻测试
    @JavascriptInterface
    public void stopBattResTest(String index){
        int battindex = Integer.parseInt(index);
        if(battindex>0 && battindex <= MAXCONCENTRATORCOUNT){
            allBattDatt.get(battindex-1).stopBattResTest(JS_INTERFACE_NAME+"stopBattResTest");
        }
    }

    //重启系统
    @JavascriptInterface
    public void reStartSystem(String index){
        int battindex = Integer.parseInt(index);
        if(battindex>0 && battindex <= MAXCONCENTRATORCOUNT){
            allBattDatt.get(battindex-1).reStartSystem(JS_INTERFACE_NAME+"reStartSystem");
        }
    }

    //读取电池组充电个数
    @JavascriptInterface
    public void readBattCharCount(){
        int count = 0;
        for(int i=0;i<allBattDatt.size();i++){
            if(allBattDatt.get(i).state.battstate == Concentrator_State.WORKSTATE_CHARG){
                count ++;
            }
        }
        ServiceModel model = new ServiceModel();
        model.code = 1;
        model.data = count;
        ActionUtil.SendCallDataToJS(JS_INTERFACE_NAME,"readBattCharCount",model,webView, ActionUtil.getGson());
    }

    //读取电池组充电电池信息
    @JavascriptInterface
    public void readBattCharInfo(){
        List<HashMap> list = new ArrayList();
        for(int i=0;i<allBattDatt.size();i++){
            if(allBattDatt.get(i).state.battstate == Concentrator_State.WORKSTATE_CHARG && allBattDatt.get(i).isInstall){
                HashMap map = new HashMap();
                map.put("state",allBattDatt.get(i).state);
                map.put("battinf",allBattDatt.get(i).battinf);
                list.add(map);
            }
        }
        ServiceModel model = new ServiceModel();
        model.code = 1;
        model.data = list;
        //Log.e(TAG, "readBattCharInfo: "+model );
        ActionUtil.SendCallDataToJS(JS_INTERFACE_NAME,"readBattCharInfo",model,webView, ActionUtil.getGson());
    }

    //读取电池组放电个数
    @JavascriptInterface
    public void readBattDiscCount(){
        int count = 0;
        for(int i=0;i<allBattDatt.size();i++){
            if(allBattDatt.get(i).state.battstate == Concentrator_State.WORKSTATE_DISCH){
                count ++;
            }
        }
        ServiceModel model = new ServiceModel();
        model.code = 1;
        model.data = count;
        ActionUtil.SendCallDataToJS(JS_INTERFACE_NAME,"readBattDiscCount",model,webView, ActionUtil.getGson());
    }

    //读取电池组放电电池信息
    @JavascriptInterface
    public void readBattDiscInfo(){
        //Log.e(TAG, "readBattDiscInfo: ##############################"+allBattDatt.size());
        List<HashMap> list = new ArrayList();
        for(int i=0;i<allBattDatt.size();i++){
            if(allBattDatt.get(i).state.battstate == Concentrator_State.WORKSTATE_DISCH && allBattDatt.get(i).isInstall){
                HashMap map = new HashMap();
                map.put("state",allBattDatt.get(i).state);
                map.put("battinf",allBattDatt.get(i).battinf);
                list.add(map);
            }
            //Log.e(TAG, "readBattDiscInfo: "+allBattDatt.get(i).cloneRtData() );
        }
        ServiceModel model = new ServiceModel();
        model.code = 1;
        model.data = list;
        //Gson gson = ActionUtil.getGson(Com.DTF_YMD_h_m_s);
        //Log.e("#############", "readBattDiscInfo: "+gson.toJson(model));
        ActionUtil.SendCallDataToJS(JS_INTERFACE_NAME,"readBattDiscInfo",model,this.webView, ActionUtil.getGson());
    }

    /**
     * 匹配电池信息配置中的信息
     * @param battDatas
     * @param list
     */
    public List<Battinf> initBattInfo(List<BattDataThread> battDatas,List<Battinf> list){
        List<Battinf> battinfs = new ArrayList<>();
        for(int i = 0;i<battDatas.size();i++){
            BattDataThread battData =  battDatas.get(i);
            Battinf battinf = null;
            for(int k = 0;k<list.size();k++){
                if(list.get(k).getBattGroupId() == battData.battIndex){
                    battinf = list.get(k);
                }
            }
            if(battinf != null){
                battinfs.add(battinf);
                battData.isInstall = battinf.getStation_install() == 1;                               //是否是已安装
                battData.state.monCount = battinf.getMonCount();                                      //当前单体数目
            }else{
                battinf = new Battinf();
                battinf.setStation_install(battData.isInstall?1:0);
                battinf.setBattGroupId(i+1);
                battinf.setBattFloatCurrent(3);
                battinf.setBattGroupName1("电池组");
                battinf.setBattGroupName("电池组"+(i+1));
                battinf.setBattInUseDate(new Date());
                battinf.setBattProducer("");
                battinf.setMonCapStd(100);
                battinf.setMonCount(24);
                battinf.setMonVolStd(2);
                battinf.setMonResStd(0.2);
                battinf.setMonSerStd(5000);
                battinf.setMonTmpStd(24);
                battinfs.add(battinf);
            }
            battData.battinf = battinf;
        }
        return battinfs;
    }

    /**
     *  查询数据库中的所有电池组信息
     * @param dbHelper
     * @return
     */
    public List<Battinf> queryAllBattInf(DBHelper dbHelper){
        List<Battinf> battinfs = new ArrayList<>();
        String sql_str = "SELECT * FROM tb_battinf ORDER BY BattGroupId ASC";
        SQLiteDatabase db = dbHelper.getWritableDatabase();
        Cursor rs = null;
        try {
            rs = db.rawQuery(sql_str,null);
            while(rs.moveToNext()){
                Battinf battinf = new Battinf();
                battinf.setNum(rs.getInt(rs.getColumnIndex("num")));
                battinf.setMonVolStd(rs.getDouble(rs.getColumnIndex("MonVolStd")));
                battinf.setStation_install(rs.getInt(rs.getColumnIndex("station_install")));
                battinf.setMonTmpStd(rs.getDouble(rs.getColumnIndex("MonTmpStd")));
                battinf.setMonSerStd(rs.getDouble(rs.getColumnIndex("MonSerStd")));
                battinf.setMonResStd(rs.getDouble(rs.getColumnIndex("MonResStd")));
                battinf.setMonCount(rs.getInt(rs.getColumnIndex("MonCount")));
                battinf.setMonCapStd(rs.getDouble(rs.getColumnIndex("MonCapStd")));
                battinf.setBattProducer(rs.getString(rs.getColumnIndex("BattProducer")));
                Date date= ActionUtil.sdfwithOut.parse( rs.getString(rs.getColumnIndex("BattInUseDate")));
                battinf.setBattInUseDate(date);
                battinf.setBattGroupName1(rs.getString(rs.getColumnIndex("BattGroupName1")));
                battinf.setBattGroupName(rs.getString(rs.getColumnIndex("BattGroupName")));
                battinf.setBattFloatCurrent(rs.getDouble(rs.getColumnIndex("BattFloatCurrent")));
                battinf.setBattGroupId(rs.getInt(rs.getColumnIndex("BattGroupId")));
                battinfs.add(battinf);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if(rs != null){
                    rs.close();
                }
                if(db != null){
                    db.close();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return battinfs;
    }

    /**
     * 插入电池组信息
     * @param dbHelper
     * @param list
     */
    public void insertBattinf(DBHelper dbHelper,List<Battinf> list){
        boolean start = true;
        String sql_str_start = " INSERT INTO tb_battinf(BattGroupId,BattGroupName,BattGroupName1,BattFloatCurrent,MonCount,MonCapStd,MonVolStd,MonResStd,MonSerStd,MonTmpStd,BattProducer,BattInUseDate,station_install) VALUES ";
        for(int i = 0;i<list.size();i++){
            if(list.get(i).getNum() == 0){
                Battinf temp = list.get(i);
                //需要录入的电池组
                if(start){
                    start = false;
                }else{
                    sql_str_start += ",";
                }
                sql_str_start += "("+temp.getBattGroupId()+",'"+temp.getBattGroupName()+"','"+temp.getBattGroupName1()+"',"+temp.getBattFloatCurrent()+","+temp.getMonCount()+","+temp.getMonCapStd()+","+temp.getMonVolStd()+","+temp.getMonResStd()+","+temp.getMonSerStd()+","+temp.getMonTmpStd()+",'"+temp.getBattProducer()+"','"+ Com.getDateTimeFormat(temp.getBattInUseDate(),Com.DTF_YMDhms)+"',"+temp.getStation_install()+")";
            }
        }
        if(!start){
            SQLiteDatabase db = null;
            try {
                db = dbHelper.getWritableDatabase();
                db.execSQL(sql_str_start);
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
                if(db != null){
                    db.close();
                }
            }
        }
    }
}