81041
2019-12-03 45fa5fe74137f5774d14d2c7b59ce9ed1a1ea1d5
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
package com.fgkj.impl;
 
import android.content.ContentValues;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
 
import com.fgkj.dao.ActionUtil;
import com.fgkj.dao.BaseDAO;
import com.fgkj.dto.Battresdata;
 
import java.text.ParseException;
import java.util.ArrayList;
import java.util.List;
 
public class BattresdataImpl implements BaseDAO {
    //批量插入信息
    @Override
    public boolean add(SQLiteDatabase db, Object obj) {
        List<Battresdata> list=( List<Battresdata>)obj;
        boolean bl=true;
        try {
            db.beginTransaction();
            if(list!=null&&list.size()>0){
                for (int i = 0; i < list.size(); i++) {
                    Battresdata b=list.get(i);
                    ContentValues cv=BattresdataImpl.getContentValues(b);
                    long row=db.insert("tb_battresdata_"+b.getBattGroupId(),null,cv);
                    if(row<0){
                        bl=false;
                    }
                }
            }
            db.setTransactionSuccessful();
            db.endTransaction();
        } catch (Exception e) {
            e.printStackTrace();
        }
 
        return bl;
    }
    //批量修改
    @Override
    public boolean update(SQLiteDatabase db, Object obj) {
        List<Battresdata> list=( List<Battresdata>)obj;
        boolean bl=true;
        try {
            db.beginTransaction();
            if(list!=null&&list.size()>0){
                for (int i = 0; i < list.size(); i++) {
                    Battresdata b=list.get(i);
                    ContentValues cv=BattresdataImpl.getContentValues(b);
                    String sql="num=?";
                    long row=db.update("tb_battresdata_"+b.getBattGroupId(),cv,sql,new String[]{String.valueOf(b.getNum())});
                    if(row<0){
                        bl=false;
                    }
                }
            }
            db.setTransactionSuccessful();
            db.endTransaction();
        } catch (Exception e) {
            e.printStackTrace();
        }
 
        return bl;
    }
    //批量删除
    @Override
    public boolean del(SQLiteDatabase db, Object obj) {
        List<Battresdata> list=( List<Battresdata>)obj;
        boolean bl=true;
        try {
            db.beginTransaction();
            if(list!=null&&list.size()>0){
                for (int i = 0; i < list.size(); i++) {
                    Battresdata b=list.get(i);
                    ContentValues cv=BattresdataImpl.getContentValues(b);
                    String sql="num=?";
                    long row=db.delete("tb_battresdata_"+b.getBattGroupId(),sql,new String[]{String.valueOf(b.getNum())});
                    if(row<0){
                        bl=false;
                    }
                }
            }
            db.setTransactionSuccessful();
            db.endTransaction();
        } catch (Exception e) {
            e.printStackTrace();
        }
 
        return bl;
    }
 
    @Override
    public List searchAll(SQLiteDatabase db) {
        return null;
    }
    //根据battgroupid查询内阻测试记录
    @Override
    public List serchByCondition(SQLiteDatabase db, Object obj) {
        Battresdata rdata=(Battresdata)obj;
        String sql=" select num,BattGroupId,test_record_count,test_type,test_starttime,group_vol,test_curr,mon_num,mon_vol,mon_tmp,mon_res,mon_ser,conn_res " +
                "  from tb_battresdata_"+rdata.getBattGroupId()+" where BattGroupId=? and mon_num=? order by test_starttime asc ";
        Cursor rs=db.rawQuery(sql,new String[]{String.valueOf(rdata.getBattGroupId()),String.valueOf(rdata.getMon_num())});
        List list=new ArrayList();
        try {
            while(rs.moveToNext()){
                Battresdata r=new Battresdata();
                r.setNum(rs.getInt(rs.getColumnIndex("num")));
                r.setBattGroupId(rs.getInt(rs.getColumnIndex("BattGroupId")));
                r.setTest_record_count(rs.getInt(rs.getColumnIndex("test_record_count")));
                r.setTest_type(rs.getInt(rs.getColumnIndex("test_type")));
                r.setTest_starttime(ActionUtil.sdf.parse(rs.getString(rs.getColumnIndex("test_starttime"))));
                r.setGroup_vol(rs.getFloat(rs.getColumnIndex("group_vol")));
                r.setTest_curr(rs.getFloat(rs.getColumnIndex("test_curr")));
                r.setMon_num(rs.getFloat(rs.getColumnIndex("mon_num")));
                r.setMon_vol(rs.getFloat(rs.getColumnIndex("mon_vol")));
                r.setMon_tmp(rs.getFloat(rs.getColumnIndex("mon_tmp")));
                r.setMon_res(rs.getFloat(rs.getColumnIndex("mon_res")));
                r.setMon_ser(rs.getFloat(rs.getColumnIndex("mon_ser")));
                r.setConn_res(rs.getFloat(rs.getColumnIndex("conn_res")));
                list.add(r);
            }
        } catch (ParseException e) {
            e.printStackTrace();
        }finally {
            rs.close();
        }
        return list;
    }
 
    @Override
    public List serchByInfo(SQLiteDatabase db, Object obj) {
        return null;
    }
    //获取ContentValues
    public static ContentValues getContentValues(Object obj){
        Battresdata bdata=(Battresdata)obj;
        ContentValues cv=new ContentValues();
        cv.put("num",bdata.getNum());
        cv.put("BattGroupId", bdata.getBattGroupId());
        cv.put("test_record_count", bdata.getTest_record_count());
        cv.put("test_type",bdata.getTest_type());
        cv.put("test_starttime", ActionUtil.sdf.format(bdata.getTest_starttime()));
        cv.put("group_vol",bdata.getGroup_vol());
        cv.put("test_curr", bdata.getTest_curr());
        cv.put("mon_vol",bdata.getMon_vol());
        cv.put("mon_tmp", bdata.getMon_tmp());
        cv.put("mon_res",bdata.getMon_res());
        cv.put("mon_ser", bdata.getMon_ser());
        cv.put("conn_res", bdata.getConn_res());
        return  cv;
    }
}