Merge branch 'FBS9600' of http://whychdw@118.89.139.230:10101/r/FBS9600App....

whychdw

2019-12-03 3a95c5d85ca0405a35abb416c2304fe78d37abb4

 platforms/android/app/src/main/java/com/socket/FBS9600S_DeviceService.java

@@ -1,21 +1,34 @@
package com.socket;



import android.drm.DrmStore;

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 static final int MAXCONCENTRATORCOUNT = 16;                                  //最多连接的汇集器数量

    public static final String JS_INTERFACE_NAME = "FBS9600S_DeviceService";            //JS调用类名

    public final static String TAG = "FBS9600S_DeviceService";



    public List<BattDataThread> allBattDatt;

    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){

@@ -28,14 +41,26 @@
            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");

        if(battindex > 0 && battindex <= MAXCONCENTRATORCOUNT){

            allBattDatt.get(battindex - 1).readSystemState("readSystemState");

        }

    }



@@ -63,10 +88,17 @@
        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 = allBattDatt.get(battindex-1).state;

            model.data = state;

        }

        ActionUtil.SendCallDataToJS("readBattMonInfo",model,webView, ActionUtil.getGson());

        //Log.e(TAG, "readBattMonInfo: "+ActionUtil.getGson().toJson(model) );

        ActionUtil.SendCallDataToJS(JS_INTERFACE_NAME,"readBattMonInfo",model,webView, ActionUtil.getGson());

    }



    //启动内阻测试

@@ -74,25 +106,216 @@
    public void startBattResTest(String index){

        int battindex = Integer.parseInt(index);

        if(battindex>0 && battindex <= MAXCONCENTRATORCOUNT){

            allBattDatt.get(battindex-1).startBattResTest("startBattResTest");

            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("stopBattResTest");

            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("reStartSystem");

            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 list = new ArrayList();

        for(int i=0;i<allBattDatt.size();i++){

            if(allBattDatt.get(i).state.battstate == Concentrator_State.WORKSTATE_CHARG){

                list.add(allBattDatt.get(i));

            }

        }

        ServiceModel model = new ServiceModel();

        model.code = 1;

        model.data = list;

        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){

                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();

                }

            }

        }

    }

}