81041
2019-01-05 ea9db400a73b5471184c82eb9fde24aacd6d26d1
gx_tieta/src/com/fgkj/dao/impl/ram/Fbs9100_stateImpl.java
@@ -21,6 +21,7 @@
import com.fgkj.dto.ram.Fbs9600_state;
import com.fgkj.services.User_logService;
import com.sun.corba.se.spi.orbutil.fsm.FSM;
import com.sun.org.apache.bcel.internal.generic.LSTORE;
public class Fbs9100_stateImpl implements BaseDAO,CallBack{
   public List getResults(ResultSet rs) {
@@ -895,7 +896,7 @@
       String sql="select distinct dev_id,dev_alarmstate,dev_workstate,dev_temp,dev_version,dev_res_test_state,dev_testtype,dev_testgroupnum "
             + ",dev_captest_onlinevol,dev_captest_groupvol,dev_captest_curr,dev_captest_cap,dev_captest_timelong "
             + ",dev_conresist,dev_concurr,dev_condvoldp,dev_condcurr,dev_61850alarms,dev_last_captest_stop_type "
             + ",db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.StationName1,db_battinf.tb_battinf.StationName2,db_battinf.tb_battinf.StationName3,db_battinf.tb_battinf.StationName5 "
             + ",db_battinf.tb_battinf.battgroupid,db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.StationName1,db_battinf.tb_battinf.StationName2,db_battinf.tb_battinf.StationName3,db_battinf.tb_battinf.StationName5 "
             + ",db_battinf.tb_battinf.MonVolStd,db_battinf.tb_battinf.BattGroupId,db_battinf.tb_battinf.battgroupname,db_battinf.tb_battinf.moncapstd,db_battinf.tb_battinf.moncount "
             + " from db_ram_db.tb_fbs9100_state,db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr "
             + " where   dev_workstate="+FBS9100_ComBase.DISCHARGE
@@ -948,7 +949,7 @@
                  fstate.setDev_captest_curr(rs.getFloat("dev_captest_curr"));
                  fstate.setDev_captest_cap(rs.getFloat("dev_captest_cap"));
                  fstate.setDev_captest_timelong(rs.getInt("dev_captest_timelong"));
                  fstate.setBattgroupid(rs.getInt("battgroupid"));
                  fstate.setDev_conresist(rs.getFloat("dev_conresist"));
                  fstate.setDev_concurr(rs.getFloat("dev_concurr"));
                  fstate.setDev_condcurr(rs.getFloat("dev_condcurr"));
@@ -977,6 +978,86 @@
      });
      return list;
    }
    //实时刷新批量设置放电参数
    public List  freshenDischarge(Object obj) {
       List<BattInf> list=(List<BattInf>) obj;
       List listAll=new ArrayList();
       for (int i = 0; i < list.size(); i++) {
          BattInf binf=list.get(i);
         String sql="select distinct dev_id,dev_alarmstate,dev_workstate,dev_temp,dev_res_test_state,dev_testtype,dev_testgroupnum " +
                " ,dev_captest_onlinevol,dev_captest_groupvol,dev_captest_curr,dev_captest_cap,dev_captest_timelong" +
                " ,dev_conresist,dev_concurr,dev_condvoldp,dev_condcurr,dev_61850alarms,dev_last_captest_stop_type  " +
                " ,db_battinf.tb_battinf.StationName,db_battinf.tb_battinf.StationName1,db_battinf.tb_battinf.StationName2,db_battinf.tb_battinf.StationName3,db_battinf.tb_battinf.StationName5,db_battinf.tb_battinf.FbsDeviceName   " +
                " ,db_ram_db.tb_batt_rtstate.batt_test_tlong  " +//,db_ram_db.tb_batt_rtstate.group_curr,db_ram_db.tb_batt_rtstate.group_vol
                " from db_ram_db.tb_fbs9100_state,db_battinf.tb_battinf  ,db_ram_db.tb_batt_rtstate"+
                " where  db_battinf.tb_battinf.battgroupid=? "+
                " and db_battinf.tb_battinf.fbsdeviceId=db_ram_db.tb_fbs9100_state.dev_id  " +
                " and db_battinf.tb_battinf.battgroupid=db_ram_db.tb_batt_rtstate.battgroupid  limit 1";
         List listB=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{binf.getBattGroupId()}, new CallBack() {
            public List getResults(ResultSet rs) {
               List list=new ArrayList();
               try {
                  while(rs.next()){
                     Fbs9100_state fstate=new Fbs9100_state();
                     int dev_alarmstate=rs.getInt("dev_alarmstate");
                     String ContactorState="开关闭合";
                     if(dev_alarmstate==1 ||
                        dev_alarmstate==2 ||
                        dev_alarmstate==3 ||
                        dev_alarmstate==4 ||
                        dev_alarmstate==6 ){
                        ContactorState="开关断开";
                     }else{
                        ContactorState="开关闭合";
                     }
                     fstate.setDev_testgroupnum(rs.getInt("dev_testgroupnum"));         //被测电池组号
                     fstate.setDev_alarmstate(rs.getInt("dev_alarmstate"));
                     fstate.setDev_res_test_state(rs.getInt("dev_res_test_state"));
                     fstate.setDev_testtype(rs.getInt("dev_testtype"));
                     fstate.setNote(ContactorState);
                     fstate.setDev_workstate(rs.getInt("dev_workstate"));
                     fstate.setDev_id(rs.getInt("dev_id"));
                     fstate.setDev_captest_onlinevol(rs.getFloat("dev_captest_onlinevol"));
                     fstate.setDev_captest_groupvol(rs.getFloat("dev_captest_groupvol"));
                     fstate.setDev_captest_curr(rs.getFloat("dev_captest_curr"));
                     fstate.setDev_captest_cap(rs.getFloat("dev_captest_cap"));
                     fstate.setDev_captest_timelong(rs.getInt("batt_test_tlong"));//实际放电时常
                     fstate.setDev_conresist(rs.getFloat("dev_conresist"));
                     fstate.setDev_concurr(rs.getFloat("dev_concurr"));
                     fstate.setDev_condcurr(rs.getFloat("dev_condcurr"));
                     fstate.setDev_condvoldp(rs.getFloat("dev_condvoldp"));
                     fstate.setDev_61850alarms(rs.getString("dev_61850alarms"));
                     fstate.setDev_last_captest_stop_type(rs.getInt("dev_last_captest_stop_type"));
                     fstate.setDev_temp(rs.getFloat("dev_temp"));
                     fstate.setStationName(rs.getString("stationName"));
                     fstate.setStationName1(rs.getString("stationName1"));
                     fstate.setStationName2(rs.getString("stationName2"));
                     fstate.setStationName3(rs.getString("stationName3"));
                     fstate.setStationName5(rs.getString("stationName5"));
                     fstate.setDeviceName(rs.getString("FbsDeviceName"));
                     /*fstate.setOnline_vols(((Float)rs.getFloat("online_vol")).toString());
                     fstate.setGroup_vols(((Float)rs.getFloat("group_vol")).toString());
                     fstate.setGroup_currs(((Float)rs.getFloat("group_curr")).toString());*/
                     list.add(fstate);
                  }
               } catch (SQLException e) {
                  // TODO Auto-generated catch block
                  e.printStackTrace();
               }
               return list;
            }
         });
         if(listB!=null&&listB.size()>0) {
            listAll.add(listB);
         }
       }
      return listAll;
    }
   public static void main(String[] args) {
       Fbs9100_stateImpl fi=new Fbs9100_stateImpl();
       /*List<Fbs9100_state> list=fi.searchAll();
@@ -995,7 +1076,7 @@
       fs.setPage(p);
       BattInf binf=new BattInf();
       binf.setNum(1);
       binf.setBattGroupId(1002);
       binf.setBattGroupId(1001879);
       binf.setStationName("广西省");
       binf.setMonVolStd(2f);
       /*List<Fbs9100_state> list=fi.serchByCondition(fs);
@@ -1022,11 +1103,15 @@
      for(Fbs9100_state f:list){
         System.out.println(f);
      }*/
       List<Fbs9100_state> list=fi.seachDischarge(binf);
       /*List<Fbs9100_state> list=fi.seachDischarge(binf);
      System.out.println(list.size());
      for(Fbs9100_state f:list){
         System.out.println(f);
      }
      }*/
       List listb=new ArrayList();
       listb.add(binf);
       List listAll=fi.freshenDischarge(listb);
      System.out.println(listAll.size());
   }
}