package com.whyc.service;
|
|
import com.whyc.dto.InterfaceParam;
|
import com.whyc.dto.StandardFeatureCurve;
|
import com.whyc.dto.paramter.DevAlarmPar;
|
import com.whyc.dto.result.AlarmRes;
|
import com.whyc.mapper.CallBack;
|
import com.whyc.pojo.*;
|
import com.whyc.util.ActionUtil;
|
import org.apache.ibatis.annotations.Param;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.swing.*;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.LinkedList;
|
import java.util.List;
|
|
@Service
|
public class SubTablePageInfoService {
|
@Autowired
|
private MybatisSqlExecuteService sqlExecuteService;
|
//2,7-SubTablePageInfoUtils.java;201行
|
public List<PwrdevAlarmHistory> getList2(PwrdevAlarmHistory data){
|
String sql="select alarm.*,inf.StationName,inf.StationName1,inf.StationName2,inf.StationName3,inf.StationName5 " +
|
" from db_pwrdev_alarm."+data.getRecordYear()+" alarm,db_pwrdev_inf.tb_pwrdev_inf inf " +
|
" where alarm.PowerDeviceId = inf.PowerDeviceId ";
|
if(data.getStationName1()!=null){
|
sql+=" and stationName1 like '%"+data.getStationName1()+"%'";
|
}
|
if(data.getStationName2()!=null){
|
sql+=" and stationName2 like '%"+data.getStationName2()+"%'";
|
}
|
if(data.getStationName5()!=null){
|
sql+=" and stationName5 like '%"+data.getStationName5()+"%'";
|
}
|
if(data.getStationName3()!=null){
|
sql+=" and stationName3 like '%"+data.getStationName3()+"%'";
|
}
|
if(data.getAlmStartTime()!=null){
|
sql+=" and alarm.alm_start_time >='"+ActionUtil.sdf.format(data.getAlmStartTime())+"' ";
|
}
|
if(data.getAlmStartTime1()!=null){
|
sql+=" and alarm.alm_start_time <='"+ActionUtil.sdf.format(data.getAlmStartTime1())+"' ";
|
}
|
if(data.getAlmSource()==0){
|
sql+=" and alm_source!=100 ";
|
}
|
if(data.getAlmSource()!=0){
|
sql+=" and alm_source="+data.getAlmSource()+" ";
|
}
|
if(data.getAlmTypes()!=null&&data.getAlmTypes().size()>0){
|
sql+=" and alm_type in ( ";
|
for (int i=0;i<data.getAlmTypes().size();i++) {
|
sql+=data.getAlmTypes().get(i);
|
if(i!=(data.getAlmTypes().size()-1)){
|
sql+=",";
|
}
|
}
|
sql+=")";
|
}
|
sql+=" and StationId in ( select distinct inf.StationId from " +
|
" (select StationId from db_battinf.tb_battinf union select StationId from db_pwrdev_inf.tb_pwrdev_inf ) inf," +
|
" db_user.tb_user_battgroup_baojigroup_battgroup," +
|
" db_user.tb_user_battgroup_baojigroup_usr," +
|
" db_user.tb_user_inf" +
|
" where db_user.tb_user_battgroup_baojigroup_battgroup.StationId=inf.StationId" +
|
" and" +
|
" db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id" +
|
" and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid" +
|
" and db_user.tb_user_inf.uid="+data.getUsrId()+" ) order by alarm.alm_start_time desc limit "+data.getLimitStart()+","+data.getLimitEnd()+" ";
|
List<PwrdevAlarmHistory> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<PwrdevAlarmHistory> list=new ArrayList<>();
|
while (rs.next()){
|
PwrdevAlarmHistory ph=new PwrdevAlarmHistory();
|
ph.setNum(rs.getLong("num"));
|
ph.setRecordId(rs.getLong("record_id"));
|
ph.setPowerDeviceId(rs.getLong("PowerDeviceId"));
|
ph.setAlmType(rs.getInt("alm_type"));
|
ph.setAlmLevel(rs.getInt("alm_level"));
|
ph.setAlmSource(rs.getInt("alm_source"));
|
ph.setAlmIndex(rs.getInt("alm_index"));
|
ph.setAlmStartTime(rs.getTimestamp("alm_start_time"));
|
ph.setAlmEndTime(rs.getTimestamp("alm_end_time"));
|
ph.setAlmValue(rs.getFloat("alm_value"));
|
ph.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
|
ph.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
|
ph.setAlmClearedType(rs.getInt("alm_cleared_type"));
|
ph.setUsrId(rs.getInt("usr_Id"));
|
ph.setAlmTrigger(rs.getInt("alm_trigger"));
|
ph.setAlmSeverity(rs.getInt("alm_severity"));
|
ph.setStationName(rs.getString("StationName"));
|
ph.setStationName1(rs.getString("StationName1"));
|
ph.setStationName2(rs.getString("StationName2"));
|
ph.setStationName3(rs.getString("StationName3"));
|
ph.setStationName5(rs.getString("StationName5"));
|
list.add(ph);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//3-SubTablePageInfoUtils.java;72行
|
public List<PwrdevAlarmHistory> getListForTX(PwrdevAlarmHistory data){
|
String sql="select alarm.*,inf.StationName,inf.StationName1,inf.StationName2,inf.StationName3,inf.StationName5 " +
|
" from db_pwrdev_alarm."+data.getRecordYear()+" alarm,db_pwrdev_inf.tb_pwrdev_inf inf " +
|
" where alarm.PowerDeviceId = inf.PowerDeviceId ";
|
if(data.getStationName1()!=null){
|
sql+=" and stationName1 like '%"+data.getStationName1()+"%'";
|
}
|
if(data.getStationName2()!=null){
|
sql+=" and stationName2 like '%"+data.getStationName2()+"%'";
|
}
|
if(data.getStationName5()!=null){
|
sql+=" and stationName5 like '%"+data.getStationName5()+"%'";
|
}
|
if(data.getStationName3()!=null){
|
sql+=" and stationName3 like '%"+data.getStationName3()+"%'";
|
}
|
if(data.getAlmStartTime()!=null){
|
sql+=" and alarm.alm_start_time >='"+ActionUtil.sdf.format(data.getAlmStartTime())+"' ";
|
}
|
if(data.getAlmStartTime1()!=null){
|
sql+=" and alarm.alm_start_time <='"+ActionUtil.sdf.format(data.getAlmStartTime1())+"' ";
|
}
|
if(data.getAlmSource()==0){
|
sql+=" and alm_source!=100 ";
|
}
|
if(data.getAlmSource()!=0){
|
sql+=" and alm_source="+data.getAlmSource()+" ";
|
}
|
if(data.getAlmTypes()!=null&&data.getAlmTypes().size()>0){
|
sql+=" and alm_type in ( ";
|
for (int i=0;i<data.getAlmTypes().size();i++) {
|
sql+=data.getAlmTypes().get(i);
|
if(i!=(data.getAlmTypes().size()-1)){
|
sql+=",";
|
}
|
}
|
sql+=")";
|
}
|
if(data.getAlmLevels()!=null&&data.getAlmLevels().size()>0){
|
sql+=" and alm_level in ( ";
|
for (int i=0;i<data.getAlmLevels().size();i++) {
|
sql+=data.getAlmLevels().get(i);
|
if(i!=(data.getAlmLevels().size()-1)){
|
sql+=",";
|
}
|
}
|
sql+=")";
|
}
|
sql+=" and StationId in ( select distinct inf.StationId from " +
|
" (select StationId from db_battinf.tb_battinf union select StationId from db_pwrdev_inf.tb_pwrdev_inf ) inf," +
|
" db_user.tb_user_battgroup_baojigroup_battgroup," +
|
" db_user.tb_user_battgroup_baojigroup_usr," +
|
" db_user.tb_user_inf" +
|
" where db_user.tb_user_battgroup_baojigroup_battgroup.StationId=inf.StationId" +
|
" and" +
|
" db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id" +
|
" and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid" +
|
" and db_user.tb_user_inf.uid="+data.getUsrId()+" ) order by alarm.alm_start_time desc limit "+data.getLimitStart()+","+data.getLimitEnd()+" ";
|
List<PwrdevAlarmHistory> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<PwrdevAlarmHistory> list=new ArrayList<>();
|
while (rs.next()){
|
PwrdevAlarmHistory ph=new PwrdevAlarmHistory();
|
ph.setNum(rs.getLong("num"));
|
ph.setRecordId(rs.getLong("record_id"));
|
ph.setPowerDeviceId(rs.getLong("PowerDeviceId"));
|
ph.setAlmType(rs.getInt("alm_type"));
|
ph.setAlmLevel(rs.getInt("alm_level"));
|
ph.setAlmSource(rs.getInt("alm_source"));
|
ph.setAlmIndex(rs.getInt("alm_index"));
|
ph.setAlmStartTime(rs.getTimestamp("alm_start_time"));
|
ph.setAlmEndTime(rs.getTimestamp("alm_end_time"));
|
ph.setAlmValue(rs.getFloat("alm_value"));
|
ph.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
|
ph.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
|
ph.setAlmClearedType(rs.getInt("alm_cleared_type"));
|
ph.setUsrId(rs.getInt("usr_Id"));
|
ph.setAlmTrigger(rs.getInt("alm_trigger"));
|
ph.setAlmSeverity(rs.getInt("alm_severity"));
|
ph.setStationName(rs.getString("StationName"));
|
ph.setStationName1(rs.getString("StationName1"));
|
ph.setStationName2(rs.getString("StationName2"));
|
ph.setStationName3(rs.getString("StationName3"));
|
ph.setStationName5(rs.getString("StationName5"));
|
list.add(ph);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//4,11-SubTablePageInfoUtils.java;445行,72行
|
public int getCount(UserLog userLog){
|
String sql=" select count(*) num from db_user."+userLog.getRecordYear()+" l,db_user.tb_user_inf u" +
|
" where l.uId = u.uId" +
|
" and uOprateDay between '"+ActionUtil.sdf.format(userLog.getOperationTime())+"' and '"+ActionUtil.sdf.format(userLog.getOperationTime2())+"' ";
|
if(userLog.getUId()!=null){
|
sql+=" and l.uId ="+userLog.getUId()+" ";
|
}
|
//条件查询-非全部
|
if(userLog.getEventType()!=null){
|
if(userLog.getEventType()==1){
|
if(userLog.getOperationType()==1||userLog.getOperationType()==2
|
||userLog.getOperationType()==20||userLog.getOperationType()==21){
|
if(userLog.getOperationType()==1){
|
sql+=" and uoprateType in ("+userLog.getOperationType()+",35) ";
|
}else{
|
sql+=" and uoprateType ="+userLog.getOperationType()+" ";
|
}
|
}
|
if(userLog.getOperationType()==31||userLog.getOperationType()==32
|
||userLog.getOperationType()==33||userLog.getOperationType()==34){
|
sql+=" and uoprateType ="+userLog.getOperationType()+" ";
|
if(userLog.getOperationType()==31){
|
sql+=" or uOprateMsg regexp '登录PC系统失败' ";
|
}else if(userLog.getOperationType()==32){
|
sql+=" or uOprateMsg regexp '配置参数修改|导航配置' ";
|
}else if(userLog.getOperationType()==33){
|
sql+=" r uOprateMsg regexp '密码' and uOprateMsg not regexp '更新密码复杂度规则' ";
|
}else{
|
sql+=" or uOprateMsg regexp 'LoginAction!login|imeout' ";
|
}
|
}
|
if(userLog.getOperationType()==3||userLog.getOperationType()==4||userLog.getOperationType()==5){
|
sql+=" and uoprateType= #{operationType} " +
|
" and uOprateMsg regexp " +
|
" '添加新用户|的用户信息|权限组|审计数据记录容量 " +
|
" |执行了User模块|执行了PermitGroup' ";
|
}
|
}
|
if(userLog.getEventType()==2){
|
sql+=" and uoprateType= #{operationType} " +
|
" and uOprateMsg regexp '单体|电池组|组端|设备|Batt|Dev|FBO|Fbs|Ld9|Li9130|Lithium|Station3D' " +
|
" and uOprateMsg not regexp '电源|Pwrdev' ";
|
}
|
if(userLog.getEventType()==3){
|
sql+=" and uoprateType= #{operationType} " +
|
" and uOprateMsg regexp 'PowerInf|Pwr' ";
|
}
|
if(userLog.getEventType()==4){
|
sql+=" and uoprateType= #{operationType} " +
|
" and uOprateMsg not regexp '添加新用户|的用户信息|权限组|审计数据记录容量|配置参数修改|导航配置|密码|单体|电池组|组端|设备|电源| " +
|
" |执行了User模块|执行了PermitGroup| " +
|
" |Batt|Dev|FBO|Fbs|Ld9|Li9130|Lithium|Station3D| " +
|
" |PowerInf|Pwr' ";
|
}
|
}
|
List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
LinkedList<Object> temp = new LinkedList<>();
|
try {
|
while (rs.next())
|
temp.add(rs.getInt("num"));
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return temp;
|
}
|
});
|
int num =0;
|
if(list!=null){
|
num= (int) list.get(0);
|
}
|
return num;
|
}
|
|
//5-PwrdevDataHistoryService.java;81行
|
public List<PwrdevDataHistory> getData(String tableName){
|
String sql=" select * from db_pwrdev_data_history."+tableName+" ";
|
List<PwrdevDataHistory> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<PwrdevDataHistory> list=new ArrayList<>();
|
while (rs.next()){
|
PwrdevDataHistory ph=new PwrdevDataHistory();
|
ph.setNum(rs.getInt("num"));
|
ph.setPowerDeviceId(rs.getInt("PowerDeviceId"));
|
ph.setRecordTime(rs.getTimestamp("record_time"));
|
ph.setAcAcIn1VolA(rs.getFloat("AC_acIn1_volA"));
|
ph.setAcAcIn1VolB(rs.getFloat("AC_acIn1_volB"));
|
ph.setAcAcIn1VolC(rs.getFloat("AC_acIn1_volC"));
|
ph.setAcAcIn1CurrA(rs.getFloat("AC_acIn1_currA"));
|
ph.setAcAcIn1CurrB(rs.getFloat("AC_acIn1_currB"));
|
ph.setAcAcIn1CurrC(rs.getFloat("AC_acIn1_currC"));
|
ph.setAcAcIn2VolA(rs.getFloat("AC_acIn2_volA"));
|
ph.setAcAcIn2VolB(rs.getFloat("AC_acIn2_volB"));
|
ph.setAcAcIn2VolC(rs.getFloat("AC_acIn2_volC"));
|
ph.setAcAcIn2CurrA(rs.getFloat("AC_acIn2_currA"));
|
ph.setAcAcIn2CurrB(rs.getFloat("AC_acIn2_currB"));
|
ph.setAcAcIn2CurrC(rs.getFloat("AC_acIn2_currC"));
|
ph.setAcTemprature(rs.getFloat("AC_temprature"));
|
ph.setAcAcVolHLimit(rs.getFloat("AC_acVolH_Limit"));
|
ph.setAcAcVolLLimit(rs.getFloat("AC_acVolL_Limit"));
|
ph.setAcdcAcIn1VolA(rs.getFloat("ACDC_acIn1_volA"));
|
ph.setAcdcAcIn1VolB(rs.getFloat("ACDC_acIn1_volB"));
|
ph.setAcdcAcIn1VolC(rs.getFloat("ACDC_acIn1_volC"));
|
ph.setAcdcAcIn2VolA(rs.getFloat("ACDC_acIn2_volA"));
|
ph.setAcdcAcIn2VolB(rs.getFloat("ACDC_acIn2_volB"));
|
ph.setAcdcAcIn2VolC(rs.getFloat("ACDC_acIn2_volC"));
|
ph.setAcdcAcOutVolA(rs.getFloat("ACDC_acOut_volA"));
|
ph.setAcdcAcOutVolB(rs.getFloat("ACDC_acOut_volB"));
|
ph.setAcdcAcOutVolC(rs.getFloat("ACDC_acOut_volC"));
|
ph.setAcdcAcOutCurrA(rs.getFloat("ACDC_acOut_currA"));
|
ph.setAcdcAcOutCurrB(rs.getFloat("ACDC_acOut_currB"));
|
ph.setAcdcAcOutCurrC(rs.getFloat("ACDC_acOut_currC"));
|
ph.setAcdcDcOutVol(rs.getFloat("ACDC_dcOut_vol"));
|
ph.setAcdcLoaderCurr(rs.getFloat("ACDC_loader_curr"));
|
ph.setAcdcBattgroup1Vol(rs.getFloat("ACDC_battgroup1_vol"));
|
ph.setAcdcBattgroup1Curr(rs.getFloat("ACDC_battgroup1_curr"));
|
ph.setAcdcBattgroup2Vol(rs.getFloat("ACDC_battgroup2_vol"));
|
ph.setAcdcBattgroup2Curr(rs.getFloat("ACDC_battgroup2_curr"));
|
ph.setAcdcAcdcmTemp(rs.getFloat("ACDC_acdcm_temp"));
|
ph.setAcdcM1OutCurr(rs.getFloat("ACDC_m1_outCurr"));
|
ph.setAcdcM2OutCurr(rs.getFloat("ACDC_m2_outCurr"));
|
ph.setAcdcM3OutCurr(rs.getFloat("ACDC_m3_outCurr"));
|
ph.setAcdcM4OutCurr(rs.getFloat("ACDC_m4_outCurr"));
|
ph.setAcdcM5OutCurr(rs.getFloat("ACDC_m5_outCurr"));
|
ph.setAcdcM6OutCurr(rs.getFloat("ACDC_m6_outCurr"));
|
ph.setAcdcM7OutCurr(rs.getFloat("ACDC_m7_outCurr"));
|
ph.setAcdcM8OutCurr(rs.getFloat("ACDC_m8_outCurr"));
|
ph.setAcdcM9OutCurr(rs.getFloat("ACDC_m9_outCurr"));
|
ph.setAcdcM10OutCurr(rs.getFloat("ACDC_m10_outCurr"));
|
ph.setAcdcM11OutCurr(rs.getFloat("ACDC_m11_outCurr"));
|
ph.setAcdcM12OutCurr(rs.getFloat("ACDC_m12_outCurr"));
|
ph.setAcdcM13OutCurr(rs.getFloat("ACDC_m13_outCurr"));
|
ph.setAcdcM14OutCurr(rs.getFloat("ACDC_m14_outCurr"));
|
ph.setAcdcM15OutCurr(rs.getFloat("ACDC_m15_outCurr"));
|
ph.setAcdcM16OutCurr(rs.getFloat("ACDC_m16_outCurr"));
|
ph.setAcdcChargLimitCurr(rs.getFloat("ACDC_chargLimitCurr"));
|
ph.setAcdcJunChargeVol(rs.getFloat("ACDC_junChargeVol"));
|
ph.setAcdcFloatChargeVol(rs.getFloat("ACDC_floatChargeVol"));
|
ph.setAcdcAcVolHLimit(rs.getFloat("ACDC_acVolH_Limit"));
|
ph.setAcdcAcVolLLimit(rs.getFloat("ACDC_acVolL_Limit"));
|
ph.setAcdcDcOutVolHLimit(rs.getFloat("ACDC_dcOutVolH_Limit"));
|
ph.setAcdcDcOutVolLLimit(rs.getFloat("ACDC_dcOutVolL_Limit"));
|
ph.setDcDcIn1Vol(rs.getFloat("DC_dcIn1_vol"));
|
ph.setDcDcIn2Vol(rs.getFloat("DC_dcIn2_vol"));
|
ph.setDcDcOut1Vol(rs.getFloat("DC_dcOut1_vol"));
|
ph.setDcDcOut1Curr(rs.getFloat("DC_dcOut1_curr"));
|
ph.setDcDcOut2Vol(rs.getFloat("DC_dcOut2_vol"));
|
ph.setDcDcOut2Curr(rs.getFloat("DC_dcOut2_curr"));
|
ph.setDcTemprature(rs.getFloat("DC_temprature"));
|
ph.setDcDcVolHLimit(rs.getFloat("DC_dcVolH_Limit"));
|
ph.setDcDcVolLLimit(rs.getFloat("DC_dcVolL_Limit"));
|
list.add(ph);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//6-PwrDevDataHistoryGWService.java;45行
|
public List<PwrDevDataHistoryGW> getListByParam(Long powerDeviceId, String tableMonth, Date subStartTime, Date subEndTime){
|
String sql=" select * from db_pwrdev_data_history_gw.tb_pwrdev_historydata_gw_"+powerDeviceId+"_"+tableMonth+" d " +
|
" where d.record_time >='"+ActionUtil.sdf.format(subStartTime)+"' and d.record_time <='"+ActionUtil.sdf.format(subEndTime)+"' ";
|
List<PwrDevDataHistoryGW> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<PwrDevDataHistoryGW> list=new ArrayList<>();
|
while (rs.next()){
|
PwrDevDataHistoryGW ph=new PwrDevDataHistoryGW();
|
ph.setNum(rs.getLong("num"));
|
ph.setRecordTime(rs.getTimestamp("record_time"));
|
ph.setPowerDeviceId(rs.getLong("PowerDeviceId"));
|
ph.setAcin1_vola(rs.getFloat("acin1_vola"));
|
ph.setAcin1_volb(rs.getFloat("acin1_volb"));
|
ph.setAcin1_volc(rs.getFloat("acin1_volc"));
|
ph.setAcin2_vola(rs.getFloat("acin2_vola"));
|
ph.setAcin2_volb(rs.getFloat("acin2_volb"));
|
ph.setAcin2_volc(rs.getFloat("acin2_volc"));
|
ph.setAcin1_curra(rs.getFloat("acin1_curra"));
|
ph.setAcin1_currb(rs.getFloat("acin1_currb"));
|
ph.setAcin1_currc(rs.getFloat("acin1_currc"));
|
ph.setAcin2_curra(rs.getFloat("acin2_curra"));
|
ph.setAcin2_currb(rs.getFloat("acin2_currb"));
|
ph.setAcin2_currc(rs.getFloat("acin2_currc"));
|
ph.setDcout_vol(rs.getFloat("dcout_vol"));
|
ph.setDcout_curr(rs.getFloat("dcout_curr"));
|
ph.setBattgroup1_vol(rs.getFloat("battgroup1_vol"));
|
ph.setBattgroup1_curr(rs.getFloat("battgroup1_curr"));
|
ph.setBattgroup2_vol(rs.getFloat("battgroup2_vol"));
|
ph.setBattgroup2_curr(rs.getFloat("battgroup2_curr"));
|
ph.setM1_out_vol(rs.getFloat("m1_out_vol"));
|
ph.setM2_out_vol(rs.getFloat("m2_out_vol"));
|
ph.setM3_out_vol(rs.getFloat("m3_out_vol"));
|
ph.setM4_out_vol(rs.getFloat("m4_out_vol"));
|
ph.setM5_out_vol(rs.getFloat("m5_out_vol"));
|
ph.setM6_out_vol(rs.getFloat("m6_out_vol"));
|
ph.setM7_out_vol(rs.getFloat("m7_out_vol"));
|
ph.setM8_out_vol(rs.getFloat("m8_out_vol"));
|
ph.setM9_out_vol(rs.getFloat("m9_out_vol"));
|
ph.setM10_out_vol(rs.getFloat("m10_out_vol"));
|
ph.setM11_out_vol(rs.getFloat("m11_out_vol"));
|
ph.setM12_out_vol(rs.getFloat("m12_out_vol"));
|
ph.setM13_out_vol(rs.getFloat("m13_out_vol"));
|
ph.setM14_out_vol(rs.getFloat("m14_out_vol"));
|
ph.setM15_out_vol(rs.getFloat("m15_out_vol"));
|
ph.setM16_out_vol(rs.getFloat("m16_out_vol"));
|
ph.setM1_outcurr(rs.getFloat("m1_outcurr"));
|
ph.setM2_outcurr(rs.getFloat("m2_outcurr"));
|
ph.setM3_outcurr(rs.getFloat("m3_outcurr"));
|
ph.setM4_outcurr(rs.getFloat("m4_outcurr"));
|
ph.setM5_outcurr(rs.getFloat("m5_outcurr"));
|
ph.setM6_outcurr(rs.getFloat("m6_outcurr"));
|
ph.setM7_outcurr(rs.getFloat("m7_outcurr"));
|
ph.setM8_outcurr(rs.getFloat("m8_outcurr"));
|
ph.setM9_outcurr(rs.getFloat("m9_outcurr"));
|
ph.setM10_outcurr(rs.getFloat("m10_outcurr"));
|
ph.setM11_outcurr(rs.getFloat("m11_outcurr"));
|
ph.setM12_outcurr(rs.getFloat("m12_outcurr"));
|
ph.setM13_outcurr(rs.getFloat("m13_outcurr"));
|
ph.setM14_outcurr(rs.getFloat("m14_outcurr"));
|
ph.setM15_outcurr(rs.getFloat("m15_outcurr"));
|
ph.setM16_outcurr(rs.getFloat("m16_outcurr"));
|
ph.setM_temper1(rs.getFloat("m_temper1"));
|
ph.setM_temper2(rs.getFloat("m_temper2"));
|
ph.setM_humidity1(rs.getFloat("m_humidity1"));
|
ph.setM_humidity2(rs.getFloat("m_humidity2"));
|
ph.setUseracin1_vola(rs.getFloat("useracin1_vola"));
|
ph.setUseracin1_volb(rs.getFloat("useracin1_volb"));
|
ph.setUseracin1_volc(rs.getFloat("useracin1_volc"));
|
ph.setUseracin1_curra(rs.getFloat("useracin1_curra"));
|
ph.setUseracin1_currb(rs.getFloat("useracin1_currb"));
|
ph.setUseracin1_currc(rs.getFloat("useracin1_currc"));
|
ph.setUseracin2_vola(rs.getFloat("useracin2_vola"));
|
ph.setUseracin2_volb(rs.getFloat("useracin2_volb"));
|
ph.setUseracin2_volc(rs.getFloat("useracin2_volc"));
|
ph.setUseracin2_curra(rs.getFloat("useracin2_curra"));
|
ph.setUseracin2_currb(rs.getFloat("useracin2_currb"));
|
ph.setUseracin2_currc(rs.getFloat("useracin2_currc"));
|
list.add(ph);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//8-StandardFeatureCurveService.java;86行
|
public List<StandardFeatureCurve> getList(String va, String c){
|
String sql=" select * from `web_site`.`tb_standard_feature_curve_"+va+"_"+c+"`";
|
List<StandardFeatureCurve> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<StandardFeatureCurve> list=new ArrayList<>();
|
while (rs.next()){
|
StandardFeatureCurve ph=new StandardFeatureCurve();
|
ph.setTitleNameUnion(rs.getString("id"));
|
ph.setTime(rs.getString("time"));
|
ph.setValue(rs.getDouble("value"));
|
list.add(ph);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//9,12-SubTablePageInfoUtils.java;225行,459行
|
public List<AlarmRes> getListForInterface(InterfaceParam param){
|
String sql="select history.BattGroupId,history.num,alm_id,alm_signal_id,history.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time,alm_severity" +
|
",stationId,stationname,stationname1,stationname2,stationname3,stationname5,battgroupname " +
|
" from db_alarm."+param.getRecordYear()+" history,db_battinf.tb_battinf " +
|
" where history.battgroupid=db_battinf.tb_battinf.battgroupid ";
|
if(param.getBattgroupIds()!=null){
|
sql+=" and history.BattGroupId in ( ";
|
for (int i=0;i<param.getBattgroupIds().size();i++) {
|
sql+=param.getBattgroupIds().get(i);
|
if(i!=(param.getBattgroupIds().size()-1)){
|
sql+=",";
|
}
|
}
|
sql+=")";
|
}
|
if(param.getStartTime()!=null){
|
sql+=" and alm_start_time>='"+ ActionUtil.sdf.format(param.getStartTime())+"' ";
|
}
|
if(param.getEndTime()!=null){
|
sql+=" and alm_start_time<='"+ ActionUtil.sdf.format(param.getEndTime())+"' ";
|
}
|
|
sql+=" order by history.battgroupid asc,history.alm_start_time desc,history.monnum asc limit "+param.getLimitStart()+","+param.getLimitEnd()+" ";
|
|
List<AlarmRes> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<AlarmRes> list=new ArrayList<>();
|
int id=0;
|
int i=0;
|
List dataList=new ArrayList();
|
AlarmRes ph=new AlarmRes();
|
while (rs.next()){
|
int battGroupId=rs.getInt("BattGroupId");
|
if(battGroupId!=id){
|
ph.setAdatas(dataList);
|
dataList=new ArrayList();
|
}
|
BattalarmData data=new BattalarmData();
|
data.setNum(rs.getLong("num"));
|
data.setBattGroupId(rs.getInt("BattGroupId"));
|
data.setAlmId(rs.getInt("alm_id"));
|
data.setAlmSignalId(rs.getInt("alm_signal_id"));
|
data.setMonNum(rs.getInt("monnum"));
|
data.setAlmValue(rs.getFloat("alm_value"));
|
data.setAlmLevel(rs.getInt("alm_level"));
|
data.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
|
data.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
|
data.setAlmStartTime(rs.getTimestamp("alm_start_time"));
|
data.setAlmEndTime(rs.getTimestamp("alm_end_time"));
|
data.setAlmSeverity(rs.getInt("alm_severity"));
|
dataList.add(data);
|
if(battGroupId!=id){
|
if(i!=0){
|
list.add(ph);
|
}
|
id=battGroupId;
|
ph=new AlarmRes();
|
ph.setBattGroupId(battGroupId);
|
ph.setStationId(rs.getString("stationId"));
|
ph.setStationName(rs.getString("stationname"));
|
ph.setStationName1(rs.getString("stationname1"));
|
ph.setStationName2(rs.getString("stationname2"));
|
ph.setStationName3(rs.getString("stationname3"));
|
ph.setStationName5(rs.getString("stationname5"));
|
ph.setBattGroupName(rs.getString("battgroupname"));
|
}
|
if(rs.isLast()){
|
ph.setAdatas(dataList);
|
list.add(ph);
|
}
|
i++;
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
|
//10-SubTablePageInfoUtils.java;98行
|
public int getCount(PwrdevAlarmHistory param){
|
String sql="select count(distinct alarm.num) as number from db_pwrdev_alarm."+param.getRecordYear()+" alarm,db_pwrdev_inf.tb_pwrdev_inf inf " +
|
" where alarm.PowerDeviceId = inf.PowerDeviceId ";
|
if(param.getStationName1()!=null){
|
sql+=" and stationName1 like '%"+param.getStationName1()+"%'";
|
}
|
if(param.getStationName2()!=null){
|
sql+=" and stationName2 like '%"+param.getStationName2()+"%'";
|
}
|
if(param.getStationName5()!=null){
|
sql+=" and stationName5 like '%"+param.getStationName5()+"%'";
|
}
|
if(param.getStationName3()!=null){
|
sql+=" and stationName3 like '%"+param.getStationName3()+"%'";
|
}
|
if(param.getAlmStartTime()!=null){
|
sql+=" and alarm.alm_start_time >='"+ActionUtil.sdf.format(param.getAlmStartTime())+"' ";
|
}
|
if(param.getAlmStartTime1()!=null){
|
sql+=" and alarm.alm_start_time <='"+ActionUtil.sdf.format(param.getAlmStartTime1())+"' ";
|
}
|
if(param.getAlmSource()==0){
|
sql+=" and alm_source!=100 ";
|
}
|
if(param.getAlmSource()!=0){
|
sql+=" and alm_source="+param.getAlmSource()+" ";
|
}
|
if(param.getAlmTypes()!=null&¶m.getAlmTypes().size()>0){
|
sql+=" and alm_type in ( ";
|
for (int i=0;i<param.getAlmTypes().size();i++) {
|
sql+=param.getAlmTypes().get(i);
|
if(i!=(param.getAlmTypes().size()-1)){
|
sql+=",";
|
}
|
}
|
sql+=")";
|
}
|
sql+=" and StationId in ( select distinct inf.StationId from" +
|
" (select StationId from db_battinf.tb_battinf union select StationId from db_pwrdev_inf.tb_pwrdev_inf ) inf," +
|
" db_user.tb_user_battgroup_baojigroup_battgroup," +
|
" db_user.tb_user_battgroup_baojigroup_usr," +
|
" db_user.tb_user_inf" +
|
" where db_user.tb_user_battgroup_baojigroup_battgroup.StationId=inf.StationId" +
|
" and" +
|
" db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id" +
|
" and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid" +
|
" and db_user.tb_user_inf.uid="+param.getUsrId()+" )";
|
List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
LinkedList<Object> temp = new LinkedList<>();
|
try {
|
while (rs.next())
|
temp.add(rs.getInt("number"));
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return temp;
|
}
|
});
|
int num =0;
|
if(list!=null){
|
num= (int) list.get(0);
|
}
|
return num;
|
}
|
|
//13,14-SubTablePageInfoUtils.java;88行
|
public int getCount(DevAlarmPar param){
|
String sql="SELECT count(distinct history.num) as number FROM db_alarm."+param.getRecordYear()+" history,db_battinf.tb_battinf " +
|
" where history.dev_id=db_battinf.tb_battinf.FbsDeviceId ";
|
if(param.getStationName1()!=null){
|
if(param.getStationName1().equals("")){
|
sql+=" and stationName1!='"+param.getStationName1()+"' ";
|
}else{
|
sql+=" and stationName1='"+param.getStationName1()+"' ";
|
}
|
}
|
if(param.getStationName()!=null){
|
if(param.getStationName().equals("")){
|
sql+=" and stationName!='"+param.getStationName()+"' ";
|
}else{
|
sql+=" and stationName='"+param.getStationName()+"' ";
|
}
|
}
|
sql+=" and alm_start_time >='"+ActionUtil.sdf.format(param.getAlmStartTime())+"' and alm_start_time <='"+ActionUtil.sdf.format(param.getAlmStartTime1())+"' ";
|
sql+=" and history.dev_id in(select distinct db_battinf.tb_battinf.FbsDeviceId " +
|
" from " +
|
" db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf " +
|
" where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " +
|
" and " +
|
" db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +
|
" and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " +
|
" and db_user.tb_user_inf.uid="+param.getUId()+")";
|
List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
LinkedList<Object> temp = new LinkedList<>();
|
try {
|
while (rs.next())
|
temp.add(rs.getInt("number"));
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return temp;
|
}
|
});
|
int num =0;
|
if(list!=null){
|
num= (int) list.get(0);
|
}
|
return num;
|
}
|
|
//15-PwrdevTimeOutAlarmService.java;28行
|
public List getList(int uId,String alarmParamTableName){
|
String sql="SELECT t.num num, t.PowerDeviceId PowerDeviceId,alarm_typeId,alarm_index,timeout_tag,read_datetime,system_datetime,resume_datetime,alarm_name,StationName " +
|
" FROM db_pwrdev_alarm.tb_pwrdev_time_out_alarm t ,db_pwrdev_alarm."+alarmParamTableName+" p2,db_pwrdev_inf.tb_pwrdev_inf inf " +
|
" WHERE t.alarm_typeId = p2.alarm_id and t.PowerDeviceId= inf.PowerDeviceId " +
|
" AND t.PowerDeviceId in ( SELECT DISTINCT devInf.PowerDeviceId " +
|
" FROM db_pwrdev_inf.tb_pwrdev_inf devInf, " +
|
" db_user.tb_user_battgroup_baojigroup_battgroup group1, " +
|
" db_user.tb_user_battgroup_baojigroup_usr groupUser " +
|
" WHERE " +
|
" devInf.StationId = group1.StationId " +
|
" AND group1.baoji_group_id = groupUser.baoji_group_id " +
|
" AND groupUser.uId ="+uId+")";
|
List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<PwrdevTimeOutAlarm> list=new ArrayList<>();
|
while (rs.next()){
|
PwrdevTimeOutAlarm ph=new PwrdevTimeOutAlarm();
|
ph.setNum(rs.getLong("num"));
|
ph.setPowerDeviceId(rs.getLong("PowerDeviceId"));
|
ph.setAlarmTypeid(rs.getInt("alarm_typeId"));
|
ph.setAlarmIndex(rs.getInt("alarm_index"));
|
ph.setTimeoutTag(rs.getInt("timeout_tag"));
|
ph.setReadDatetime(rs.getTimestamp("read_datetime"));
|
ph.setSystemDatetime(rs.getTimestamp("system_datetime"));
|
ph.setResumeDatetime(rs.getTimestamp("resume_datetime"));
|
ph.setAlarmName(rs.getString("alarm_name"));
|
ph.setStationName(rs.getString("StationName"));
|
list.add(ph);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//16-SubTablePageInfoUtils.java;188行
|
public List getList2(DevAlarmPar param){
|
String sql=" SELECT history.num,dev_id,dev_ip,alm_type,alm_level,alm_start_time,alm_end_time,alm_is_confirmed,alm_confirmed_time,alm_cleared_type,alm_severity, " +
|
" db_battinf.tb_battinf.stationName,stationName1,stationName2,stationName3,stationName5,db_battinf.tb_battinf.FbsDeviceName as dev_name " +
|
" FROM db_alarm."+param.getRecordYear()+" history,db_battinf.tb_battinf " +
|
" where history.dev_id=db_battinf.tb_battinf.FbsDeviceId ";
|
if(param.getStationName1()!=null){
|
if(param.getStationName1().equals("")){
|
sql+=" and stationName1!='"+param.getStationName1()+"' ";
|
}else{
|
sql+=" and stationName1='"+param.getStationName1()+"' ";
|
}
|
}
|
if(param.getStationName()!=null){
|
if(param.getStationName().equals("")){
|
sql+=" and stationName!='"+param.getStationName()+"' ";
|
}else{
|
sql+=" and stationName='"+param.getStationName()+"' ";
|
}
|
}
|
sql+=" and alm_start_time >='"+ActionUtil.sdf.format(param.getAlmStartTime())+"' and alm_start_time <='"+ActionUtil.sdf.format(param.getAlmStartTime1())+"' ";
|
sql+=" and history.dev_id in(select distinct db_battinf.tb_battinf.FbsDeviceId " +
|
" from " +
|
" db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf " +
|
" where db_user.tb_user_battgroup_baojigroup_battgroup.BattGroupId=db_battinf.tb_battinf.BattGroupId " +
|
" and " +
|
" db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id=db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id " +
|
" and db_user.tb_user_inf.uid=db_user.tb_user_battgroup_baojigroup_usr.uid " +
|
" and db_user.tb_user_inf.uid="+param.getUId()+") " +
|
" ORDER BY alm_start_time desc ,dev_name asc limit "+param.getLimitStart()+","+param.getLimitEnd()+" ";
|
List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
|
@Override
|
public List getResults(ResultSet rs) throws SQLException {
|
List<DevalarmDataHistory> list=new ArrayList<>();
|
while (rs.next()){
|
DevalarmDataHistory ph=new DevalarmDataHistory();
|
ph.setNum(rs.getLong("num"));
|
ph.setDevId(rs.getInt("dev_id"));
|
ph.setDevIp(rs.getString("dev_ip"));
|
ph.setAlmType(rs.getInt("alm_type"));
|
ph.setAlmLevel(rs.getInt("alm_level"));
|
ph.setAlmStartTime(rs.getTimestamp("alm_start_time"));
|
ph.setAlmEndTime(rs.getTimestamp("alm_end_time"));
|
ph.setAlmIsConfirmed(rs.getInt("alm_is_confirmed"));
|
ph.setAlmConfirmedTime(rs.getTimestamp("alm_confirmed_time"));
|
ph.setAlmClearedType(rs.getInt("alm_cleared_type"));
|
ph.setDevName(rs.getString("dev_name"));
|
ph.setStationName(rs.getString("stationName"));
|
ph.setStationName1(rs.getString("stationName1"));
|
ph.setStationName2(rs.getString("stationName2"));
|
ph.setStationName3(rs.getString("stationName3"));
|
ph.setStationName5(rs.getString("stationName5"));
|
list.add(ph);
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
}
|
