whycrzg
2021-02-23 351b9a53cb9ecebdf8f79db0117f540d9c42c2a4
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
package com.fgkj.mapper.impl;
 
import com.fgkj.dto.*;
import org.apache.ibatis.annotations.Select;
 
import java.util.List;
 
public interface BadBatt_monMapper{
 
    //9.1根据stationid查询机房的落后单体总数
    @Select("select count(num) as nums  from web_site.tb_badbatt_mon " +
            "where battgroupid in (select distinct battgroupid from db_battinf.tb_battinf where stationid=#{stationId} ) limit 1 ")
    public int serchByStationId(BattMap_information obj);
 
    //9.1根据stationName3查询站点的落后单体总数
    public int serchBystationName3(Object obj);
    
    //9.1根据机房stationid查询机房下电池组单体落后情况
    @Select("select battgroupid,group_concat(distinct mon_num) as mon_nums from web_site.tb_badbatt_mon " +
            " where  battgroupid =#{battGroupId}  group by  battgroupid  limit 1")
    public List<BadBatt_mon> serchMonBad(BattInf obj);
 
    @Select("select count(distinct num,battgroupid,mon_num) " +
            " from web_site.tb_badbatt_mon " +
            " where web_site.tb_badbatt_mon.battgroupid in (select distinct db_battinf.tb_battinf.battgroupid " +
            " 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=#{uId} ) ")
    public int searchNums(User_inf userInf);
 
    //落后单体查询:根据条件查询落后单体(用户管理的电池组)
    public List<Batt_Maint_Dealarm> serchByInfo(Batt_Maint_Dealarm bmd);
 
    //查询落后单体总数
    /*public int searchNums() {
        String sql="select count(num) as nums  " +
                "from web_site.tb_badbatt_mon " +
                "limit 1 ";
        //System.out.println(sql);
        List list=DateUtil.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
            
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        int nums=rs.getInt("nums");
                        list.add(nums);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });
        int nums=0;//最后的结果
        if(list!=null&&list.size()>0){
            nums=(Integer) list.get(list.size()-1);
        }
        return nums;
    }*/
 
    //落后单体查询:根据条件查询落后单体
    /*public List serchByInfo(Object obj) {
        Batt_Maint_Dealarm bmd = (Batt_Maint_Dealarm) obj;
        BattInf binf = bmd.getBinf();
        Page page=bmd.getPage();
        Connection conn=DBUtil.getConn();
        String numberSql=" SELECT FOUND_ROWS() number";
        String sql="";
        String baseSql=" SELECT SQL_CALC_FOUND_ROWS distinct web_site.tb_badbatt_mon.battgroupid,web_site.tb_badbatt_mon.mon_num,web_site.tb_badbatt_mon.real_cap,web_site.tb_badbatt_mon.stdcap,web_site.tb_badbatt_mon.note  " +
                ",db_battinf.tb_battinf.stationname1,db_battinf.tb_battinf.stationname,db_battinf.tb_battinf.battproducer,db_battinf.tb_battinf.battinusedate" +
                ",db_battinf.tb_battinf.monvolstd,db_battinf.tb_battinf.battgroupname  " +
                "FROM web_site.tb_badbatt_mon " +
                "LEFT OUTER JOIN db_battinf.tb_battinf ON web_site.tb_badbatt_mon.battgroupid=db_battinf.tb_battinf.BattGroupId  " +
                "where  battinusedate>=? and battinusedate<=? " +
                "and  test_starttime>=? and test_starttime<=? ";
        //用于维护区
        String station1SqlT=" and stationname1!=? ";//全部
        String station1SqlF=" and stationname1=? ";
        if(binf.getStationName1().equals("")){
            baseSql+=station1SqlT;
        }else{
            baseSql+=station1SqlF;
        }
        //用于机房站点
        String stationSqlT=" and stationname!=? ";//全部
        String stationSqlF=" and stationname=? ";
        if(binf.getStationName().equals("")){
            baseSql+=stationSqlT;
        }else{
            baseSql+=stationSqlF;
        }
        //选取蓄电池组条件
        String idSqlT=" and db_battinf.tb_battinf.battgroupid!=?  ";
        String idSqlF=" and db_battinf.tb_battinf.battgroupid=?  ";
        if(binf.getBattGroupId()==0){
            baseSql+=idSqlT;
        }else{
            baseSql+=idSqlF;
        }
        //用于电池类型
        String producerSqlT=" and battproducer!=? ";//全部
        String producerSqlF=" and battproducer=? ";
        if(binf.getBattProducer().equals("")){
            baseSql+=producerSqlT;
        }else{
            baseSql+=producerSqlF;
        }
        String endSql=" ORDER BY web_site.tb_badbatt_mon.battgroupid asc  ";
        String limitSql=" limit ?,? ";
        sql=baseSql+endSql+limitSql;
        //System.out.println(sql);
        List<Batt_Maint_Dealarm> list=DateUtil.executeQueryLimit(sql, conn, new Object[]{ binf.getBattInUseDate(),binf.getBattInUseDate1(),
                  binf.getBattProductDate(),binf.getBattProductDate1(),
                  binf.getStationName1(),binf.getStationName(),binf.getBattGroupId(),
                  binf.getBattProducer(),
                  (page.getPageCurr()-1)*page.getPageSize(),page.getPageSize()}, new CallBack() {
            
            public List getResults(ResultSet rs) {
                List list=new ArrayList();
                try {
                    while(rs.next()){
                        Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
                        BattInf binf=new BattInf();
                        binf.setStationName1(rs.getString("stationName1"));
                        binf.setStationName(rs.getString("stationName"));
                        binf.setBattProducer(rs.getString("battProducer"));
                        if(rs.getString("battInUseDate")!=null)
                        binf.setBattInUseDate(rs.getDate("battInUseDate"));
                        binf.setMonVolStd(rs.getFloat("monVolStd"));
                        binf.setBattGroupName(rs.getString("battGroupName"));
                        bmd.setBinf(binf);
                        BadBatt_mon bdmon=new BadBatt_mon();
                        bdmon.setBattGroupid(rs.getInt("battGroupid"));
                        bdmon.setMon_num(rs.getInt("mon_num"));
                        bdmon.setReal_cap(rs.getFloat("real_cap"));
                        bdmon.setStdcap(rs.getFloat("stdcap"));
                        if(Integer.parseInt(rs.getString("note"))==AlarmDaoFactory.Alarm_CapAlarm){
                            bdmon.setNote("告警");
                        }else if(Integer.parseInt(rs.getString("note"))==AlarmDaoFactory.Alarm_CapChange){
                            bdmon.setNote("更换");
                        }else{
                            bdmon.setNote("--");
                        }
                        bmd.setBdmon(bdmon);
                        Page page=new Page();
                        bmd.setPage(page);
                        list.add(bmd);
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return list;
            }
        });    
        //去掉limit条件后的总数
        int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
        //System.out.println("number: "+number);
        if(list!=null&&list.size()>0){
            list.get(list.size()-1).getPage().setPageAll(number);
        }
        return list;
    }*/
 
    /*public static void main(String[] args) throws ParseException {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        Date date1 = sdf.parse("2000-01-01");
        Date date2 = sdf.parse("2020-01-01");
        
        BadBatt_monImpl bimpl=new BadBatt_monImpl();
        BattMap_information binformation=new BattMap_information();
        binformation.setStationId("42070218");
        //int nums=bimpl.serchByStationId(binformation);
        //System.out.println(nums);
        
        BattInf binf = new BattInf();
        binf.setBattProductDate(ActionUtil.getSimpDate(date1));
        binf.setBattProductDate1(ActionUtil.getSimpDate(date2));
        binf.setBattInUseDate(ActionUtil.getSimpDate(date1));
        binf.setBattInUseDate1(ActionUtil.getSimpDate(date2));
        binf.setStationName1("");
        binf.setStationName("");
        binf.setBattGroupId(0);
        binf.setBattProducer("");
        Page page=new Page();
        page.setPageCurr(1);
        page.setPageSize(10);
        User_inf uinf=new User_inf();
        uinf.setuId(1002);
        Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
        bmd.setBinf(binf);
        bmd.setPage(page);
        bmd.setUinf(uinf);
        List<Batt_Maint_Dealarm> list=bimpl.serchByInfo(bmd);
        for (Batt_Maint_Dealarm b : list) {
            System.out.println(b.getBdmon());
        }
    }*/
 
 
}