hdw
2018-12-20 d97abea7262d513deda4b4dfe421df3bcf4c511f
gx_tieta/src/com/fgkj/dao/impl/Battinf_applyImpl.java
@@ -22,6 +22,8 @@
import com.fgkj.dto.Page;
import com.fgkj.dto.User_inf;
import com.fgkj.dto.User_log;
import com.fgkj.dto.ram.FBS9100;
import com.fgkj.dto.ram.Fbs9100_state;
import com.fgkj.services.User_logService;
public class Battinf_applyImpl implements BaseDAO,CallBack{
@@ -91,7 +93,7 @@
            bapply.setConfrim_uid(((User_inf)ActionUtil.getUser()).getUId());
            BattInf binf=bapply.getBinf();
            binf.setStation_install(1);
            String sql_update_apply=" update db_battinf.tb_battinf_apply set confrim_uid="+bapply.getConfrim_uid()+",apply_en=1 where battgrouoid="+binf.getBattGroupId();
            String sql_update_apply=" update db_battinf.tb_battinf_apply set confrim_uid="+bapply.getConfrim_uid()+",apply_en=1 where battgroupid="+binf.getBattGroupId();
             sql_str.add(sql_update_apply);
             String sql_insert_binf="insert into db_battinf.tb_battinf(" +
                  "StationId,StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FBSDeviceId,FbsDeviceIp,FbsDeviceIp_YM,FbsDeviceIp_WG,"
@@ -120,6 +122,29 @@
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      return bl;
      
   }
   //验收申请(多条)
   public boolean check(Object obj) {
      List<Battinf_apply> list=(List<Battinf_apply>) obj;
      List<User_log> listU=new ArrayList<User_log>();//存放user_log
      ArrayList<String> sql_str=new ArrayList();
      if(list!=null&&list.size()>0){
         for (int i = 0; i < list.size(); i++) {
            Battinf_apply bapply=list.get(i);
            BattInf binf=bapply.getBinf();
            bapply.setCheck_uid(((User_inf)ActionUtil.getUser()).getUId());
            String sql_update_apply=" update db_battinf.tb_battinf_apply set check_uid="+bapply.getCheck_uid()+",check_en=1 where battgroupid="+binf.getBattGroupId();
             sql_str.add(sql_update_apply);
             {
               String msg="验收"+binf.getStationName()+"机房";
               User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
               listU.add(ulog);
             }
         }
      }
      Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_str);
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      return bl;
   }
    //申请人再我的申请页面的修改操作
   public boolean updatePro(Object obj){
@@ -189,16 +214,18 @@
   }
   //查询出所有需要确认的申请
   public List serchByCondition(Object obj) {
      Page page=(Page) obj;
      Battinf_apply bapply=(Battinf_apply) obj;
      BattInf binf=bapply.getBinf();
      Page page=binf.getPage();
      Connection conn=DBUtil.getConn();
      String numberSql=" SELECT FOUND_ROWS() number";
      String sql=" select SQL_CALC_FOUND_ROWS distinct num,apply_uid,confrim_uid,apply_date,apply_en,apply_note,StationId,StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FbsDeviceId,FbsDeviceIp_YM,FbsDeviceIp_WG,FbsDeviceIp"+
      String sql=" select SQL_CALC_FOUND_ROWS distinct num,apply_uid,confrim_uid,check_uid,check_en,apply_date,apply_en,apply_note,StationId,StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FbsDeviceId,FbsDeviceIp_YM,FbsDeviceIp_WG,FbsDeviceIp"+
              ",FBSDeviceName,GroupIndexInFBSDevice,battgroupId,BattGroupNum,BattGroupName,FloatVolLevel,OfflineVolLevel,BattFloatCurrent" +
             ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,MonVolLowToAvg,BattProducer,BattModel,BattProductDate,BattInUseDate,Load_curr,install_user,DisCurrMax,station_phone " +
            " from db_battinf.tb_battinf_apply " +
            " where apply_en=0  order by apply_date desc" +
            " where apply_en=?  order by apply_date desc" +
            " limit ?,? ";
      List<Battinf_apply> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
      List<Battinf_apply> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{bapply.getApply_en(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
         
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
@@ -211,6 +238,9 @@
                  apply.setConfrim_uid(rs.getInt("confrim_uid"));
                  apply.setConfirm_name((new User_infImpl()).changeUidToUname(apply.getConfrim_uid()));
                  apply.setApply_en(rs.getInt("apply_en"));
                  apply.setCheck_uid(rs.getInt("check_uid"));
                  apply.setCheck_en(rs.getInt("check_en"));
                  apply.setCheck_uname((new User_infImpl()).changeUidToUname(apply.getCheck_en()));
                  apply.setApply_date(rs.getTimestamp("apply_date"));
                  apply.setApply_note(rs.getString("apply_note"));
                  
@@ -363,7 +393,7 @@
      Page page=b.getPage();
      Connection conn=DBUtil.getConn();
      String numberSql=" SELECT FOUND_ROWS() number";
      String sql=" select SQL_CALC_FOUND_ROWS distinct num,apply_uid,confrim_uid,apply_date,apply_en,apply_note,StationId,StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FbsDeviceId,FbsDeviceIp_YM,FbsDeviceIp_WG,FbsDeviceIp"+
      String sql=" select SQL_CALC_FOUND_ROWS distinct num,apply_uid,confrim_uid,check_uid,check_en,apply_date,apply_en,apply_note,StationId,StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FbsDeviceId,FbsDeviceIp_YM,FbsDeviceIp_WG,FbsDeviceIp"+
              ",FBSDeviceName,GroupIndexInFBSDevice,battgroupId,BattGroupNum,BattGroupName,FloatVolLevel,OfflineVolLevel,BattFloatCurrent" +
             ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,MonVolLowToAvg,BattProducer,BattModel,BattProductDate,BattInUseDate,Load_curr,install_user,DisCurrMax,station_phone " +
            " from db_battinf.tb_battinf_apply " +
@@ -382,6 +412,9 @@
                  apply.setConfrim_uid(rs.getInt("confrim_uid"));
                  apply.setConfirm_name((new User_infImpl()).changeUidToUname(apply.getConfrim_uid()));
                  apply.setApply_en(rs.getInt("apply_en"));
                  apply.setCheck_uid(rs.getInt("check_uid"));
                  apply.setCheck_en(rs.getInt("check_en"));
                  apply.setCheck_uname((new User_infImpl()).changeUidToUname(apply.getCheck_en()));
                  apply.setApply_date(rs.getTimestamp("apply_date"));
                  apply.setApply_note(rs.getString("apply_note"));
                  
@@ -542,7 +575,34 @@
         return false;
      }
   }
    //申请表中已审批通过的设备连接数
   public List devCommNum() {
      String sql=" select  distinct db_battinf.tb_battinf_apply.FbsDeviceId,dev_commcount " +
            " from db_battinf.tb_battinf_apply,db_ram_db.tb_fbs9100_state " +
            " where apply_en=1  and db_battinf.tb_battinf_apply.FbsDeviceId=db_ram_db.tb_fbs9100_state.dev_id "
         +   " order by apply_date desc" ;
      List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
         @Override
         public List getResults(ResultSet rs) {
            List list=new ArrayList();
            try {
               while(rs.next()) {
                  Fbs9100_state fbs=new Fbs9100_state();
                  fbs.setDev_id(rs.getInt("FbsDeviceId"));
                  fbs.setDev_commcount(rs.getInt("dev_commcount"));
                  list.add(fbs);
               }
            } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
            }
            return list;
         }
      });
      return list;
   }
   public static void main(String[] args) throws ParseException {
       SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Date date1 = sdf.parse("2000-01-01 00:00:00");
@@ -607,7 +667,11 @@
      System.out.println(station_id);
      int battgroup_id=BattinfGroupFactory.searchMaxBattgroupId();
      System.out.println(battgroup_id);*/
      boolean bl=bimpl.judgeBattInOrNot(binf);
      System.out.println(bl);
      /*boolean bl=bimpl.judgeBattInOrNot(binf);
      System.out.println(bl);*/
      /*List<Fbs9100_state> list=bimpl.devCommNum();
      for (Fbs9100_state f : list) {
         System.out.println(f.getDev_id()+"   "+f.getDev_commcount());
      }*/
   }
}