From 7f953d9aa0e7d4fcbe3c366c7f9f0b3f847f12bd Mon Sep 17 00:00:00 2001 From: hdw <hdw@192.168.137.1> Date: 星期六, 19 一月 2019 09:16:08 +0800 Subject: [PATCH] Merge branch 'dev_lxw' of https://gitlab.com/whyclxw1/gx_tieta.git into dev_lxw --- gx_tieta/src/com/fgkj/dao/impl/Battinf_applyImpl.java | 73 ++++++++++++++++++++++++++++-------- 1 files changed, 56 insertions(+), 17 deletions(-) diff --git a/gx_tieta/src/com/fgkj/dao/impl/Battinf_applyImpl.java b/gx_tieta/src/com/fgkj/dao/impl/Battinf_applyImpl.java index 696012f..82f8c89 100644 --- a/gx_tieta/src/com/fgkj/dao/impl/Battinf_applyImpl.java +++ b/gx_tieta/src/com/fgkj/dao/impl/Battinf_applyImpl.java @@ -94,7 +94,7 @@ int uid=((User_inf)ActionUtil.getUser()).getUId(); bapply.setApply_uid(uid); BattInf binf=bapply.getBinf(); - String sql = "insert into db_battinf.tb_battinf_apply(" + + String sql = "replace into db_battinf.tb_battinf_apply(" + "apply_uid,apply_date,StationId,StationName,StationName1,StationName2,StationName3,StationName4,StationName5,StationIp,FBSDeviceId,FbsDeviceIp,FbsDeviceIp_YM,FbsDeviceIp_WG," + "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" + @@ -138,9 +138,15 @@ ","+binf.getMonCount()+","+binf.getMonCapStd()+","+binf.getMonVolStd()+","+binf.getMonResStd()+","+binf.getMonSerStd()+","+binf.getMonVolLowToAvg()+ ",'"+binf.getBattProducer()+"','"+binf.getBattModel()+"','"+DAOHelper.sdf.format(binf.getBattProductDate())+"','"+DAOHelper.sdf.format(binf.getBattInUseDate())+"',"+binf.getLoad_curr()+",'"+binf.getInstall_user()+"',"+binf.getDisCurrMax()+",'"+binf.getStation_phone()+"',"+binf.getStation_install()+")"; sql_str.add(sql_insert_binf); + //缁欐坊鍔犵殑鏈烘埧鍔犲叆鍖呮満缁勶紙绠$悊鍛樼粍锛� + String baoji_sql_main="REPLACE into db_user.tb_user_battgroup_baojigroup_battgroup(baoji_group_id,StationId,BattGroupId) values('100011','"+binf.getStationId()+"',"+binf.getBattGroupId()+")"; + sql_str.add(baoji_sql_main); + //System.out.println(baoji_sql_main); + //缁欐坊鍔犵殑鏈烘埧鍔犲叆鍖呮満缁勶紙璇ョ敤鎴风殑锛� String baoji_sql="REPLACE into db_user.tb_user_battgroup_baojigroup_battgroup(baoji_group_id,StationId,BattGroupId) " + - " SELECT baoji_group_id,'"+binf.getStationId()+"',"+binf.getBattGroupId()+" from db_user.tb_user_battgroup_baojigroup "; + " SELECT baoji_group_id,'"+binf.getStationId()+"',"+binf.getBattGroupId()+" from db_user.tb_user_battgroup_baojigroup_usr where uid="+bapply.getApply_uid(); sql_str.add(baoji_sql); + { String msg="纭娣诲姞"+binf.getStationName()+"鏈烘埧"+binf.getBattGroupId()+"鐢垫睜缁勭殑淇℃伅"; User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg); @@ -172,6 +178,8 @@ 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 sql_replace_map=" replace into web_site.tb_battmap_information(StationId,StationName,address,longitude,latitude) values('"+binf.getStationId()+"','"+binf.getStationName()+"','"+bapply.getAddress()+"',"+bapply.getLongitude()+","+bapply.getLatitude()+")"; + sql_str.add(sql_replace_map); { String msg="楠屾敹"+binf.getStationName()+"鏈烘埧"; User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg); @@ -192,7 +200,7 @@ for (int i = 0; i < list.size(); i++) { Battinf_apply bapply=list.get(i); BattInf binf=bapply.getBinf(); - String sql_update_apply=" update db_battinf.tb_battinf_apply set check_en=2 where battgroupid="+binf.getBattGroupId(); + String sql_update_apply=" update db_battinf.tb_battinf_apply set check_en=2,longitude="+bapply.getLongitude()+",latitude="+bapply.getLatitude()+",address='"+bapply.getAddress()+"' where battgroupid="+binf.getBattGroupId(); sql_str.add(sql_update_apply); { String msg="鐢宠楠屾敹"+binf.getStationName()+"鏈烘埧"; @@ -280,11 +288,23 @@ String numberSql=" SELECT FOUND_ROWS() number"; 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 " + + ",MonCount,MonCapStd,monVolStd,monResStd,MonSerStd,MonVolLowToAvg,BattProducer,BattModel,BattProductDate,BattInUseDate,Load_curr,install_user,DisCurrMax,station_phone " + + ",longitude,latitude,address " + " from db_battinf.tb_battinf_apply " + - " where apply_en=? order by apply_date desc" + - " limit ?,? "; - List<Battinf_apply> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{bapply.getApply_en(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() { + " where "; + //鏈鎵� + if(bapply.getApply_en()==0) { + sql+=" apply_en=? and check_en!=? "; + }else { + if(bapply.getCheck_en()==1) { + sql+=" apply_en=? and check_en=? "; + }else { + sql+=" apply_en=? and check_en!=? and check_en!=1 "; + } + + } + sql+=" order by apply_date desc limit ?,?"; + List<Battinf_apply> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{bapply.getApply_en(),bapply.getCheck_en(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() { public List getResults(ResultSet rs) { List list=new ArrayList(); @@ -302,6 +322,9 @@ apply.setCheck_uname((new User_infImpl()).changeUidToUname(apply.getCheck_uid())); apply.setApply_date(rs.getTimestamp("apply_date")); apply.setApply_note(rs.getString("apply_note")); + apply.setLongitude(rs.getDouble("longitude")); + apply.setLatitude(rs.getDouble("latitude")); + apply.setAddress(rs.getString("address")); BattInf binf=new BattInf(); binf.setStationId(rs.getString("stationId")); @@ -531,8 +554,20 @@ ",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=? and apply_uid=? order by apply_date desc " + - " limit ?,? "; + " where apply_en=? and check_en=0 ";//(鏈鎵瑰拰宸插鎵圭殑鏁版嵁涓嶈兘琚獙鏀�) + //鐢ㄦ埛 + String userSqlF=" and apply_uid=? " ; + String userSqlT=" and apply_uid!=? " ; + if(bapply.getApply_uid()==1002) { + bapply.setNum(0); + sql+=userSqlT; + }else { + sql+=userSqlF; + } + + String endSql=" order by apply_date desc limit ?,?"; + sql+=endSql; + //System.out.println(sql); List<Battinf_apply> list=DAOHelper.executeQueryLimit(sql, conn, new Object[]{bapply.getApply_en(),bapply.getNum(),(page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() { public List getResults(ResultSet rs) { @@ -711,7 +746,7 @@ } //鐢宠琛ㄤ腑宸插鎵归�氳繃鐨勮澶囪繛鎺ユ暟 public List devCommNum() { - String sql=" select distinct db_battinf.tb_battinf_apply.FbsDeviceId,dev_commcount " + + String sql=" select distinct db_battinf.tb_battinf_apply.FbsDeviceId,dev_commcount,dev_errcommcount " + " 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" ; @@ -725,6 +760,7 @@ Fbs9100_state fbs=new Fbs9100_state(); fbs.setDev_id(rs.getInt("FbsDeviceId")); fbs.setDev_commcount(rs.getInt("dev_commcount")); + fbs.setDev_errcommcount(rs.getInt("dev_errcommcount")); list.add(fbs); } } catch (SQLException e) { @@ -744,9 +780,10 @@ Battinf_applyImpl bimpl=new Battinf_applyImpl(); Battinf_apply bapply=new Battinf_apply(); bapply.setApply_date(ActionUtil.getSimpDate(date2)); - bapply.setApply_uid(1004); - - + bapply.setApply_uid(1002); + bapply.setApply_en(1); + bapply.setCheck_en(1); + bapply.setNum(1002);; BattInf binf=new BattInf(); binf.setStationName("骞胯タ鐪�-鐧捐壊-GX鐧捐壊涔愪笟鍘跨珛鏂板皬鍖篧F-BTS璁惧"); binf.setStationName1("婀栧寳鐪�"); @@ -786,10 +823,12 @@ Page page=new Page(); page.setPageCurr(1); - page.setPageSize(10); + page.setPageSize(20); binf.setPage(page); bapply.setBinf(binf); - /*List list=bimpl.serchByCondition(page); + List list=bimpl.serchByInfo(bapply); + System.out.println(list.size()); + /*List list=bimpl.serchByCondition(bapply); System.out.println(list.size());*/ /*List list=new ArrayList(); list.add(bapply); @@ -807,7 +846,7 @@ for (Fbs9100_state f : list) { System.out.println(f.getDev_id()+" "+f.getDev_commcount()); }*/ - List list=bimpl.serchById(bapply); - System.err.println(list.size()); + /*List list=bimpl.serchById(bapply); + System.err.println(list.size());*/ } } -- Gitblit v1.9.1