didiyu
2019-01-08 5f585252c155d62109a937563285e36d32b1b0de
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
206
207
208
package com.fgkj.services.ram;
 
import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;
 
import com.fgkj.dao.BaseDAO;
import com.fgkj.dao.BaseDAOFactory;
import com.fgkj.dao.FBS9100_ComBase;
import com.fgkj.dao.impl.BattInfImpl;
import com.fgkj.dao.impl.ram.Fbs9100_battparamImpl;
import com.fgkj.dao.impl.ram.Fbs9100_setparamImpl;
import com.fgkj.dao.impl.ram.Fbs9100_sysparamImpl;
import com.fgkj.dto.BattInf;
import com.fgkj.dto.ServiceModel;
import com.fgkj.dto.ram.Fbs9100_battparam;
import com.fgkj.dto.ram.Fbs9100_setparam;
import com.fgkj.dto.ram.Fbs9100_sysparam;
 
public class Fbs9100_sysparamService {
    private BaseDAO dao;
    private ServiceModel model;
    
    public Fbs9100_sysparamService() {
        super();
        dao=BaseDAOFactory.getBaseDAO(BaseDAO.FBS9100_SYSPARAM);
        model=new ServiceModel();
    }
    //修改系统参数
    public ServiceModel update(Object obj) {
        Fbs9100_sysparam fbs_sys=(Fbs9100_sysparam) obj;
        boolean bl=false;
        if(fbs_sys.getNum()==FBS9100_ComBase.CMD_ResetSystem){//重启
            bl=(new Fbs9100_setparamImpl()).sendCmdToFBS9100Dev(fbs_sys.getNum(),0, fbs_sys.getDev_id());
            if(bl){
                model.setCode(1);
                model.setMsg("重启成功!");
            }else{
                model.setCode(0);
                model.setMsg("重启失败!");
            }
        }else{
            Boolean b=dao.update(obj);
            if(b){
                bl=((Fbs9100_sysparamImpl)dao).sendCmdToFBS9100Dev(fbs_sys.getNum(), fbs_sys.getDev_id());
                if(bl){
                    model.setCode(1);
                    model.setMsg("修改成功!");
                }else{
                    model.setCode(0);
                    model.setMsg("设置9100参数失败,请检查网络!");
                }
            }else{
                model.setCode(0);
                model.setMsg("修改失败!");
            }    
        }
        
        return model;    
    }
    
    //根据设备id查询系统参数(一定是被管理的)
    public ServiceModel serchByCondition(Object obj){
        Fbs9100_sysparam sys=(Fbs9100_sysparam) obj;
        boolean bl=((Fbs9100_sysparamImpl)dao).replace(obj);
        boolean b=((Fbs9100_sysparamImpl)dao).sendCmdToFBS9100Dev(FBS9100_ComBase.CMD_GetSYSSetParam, sys.getDev_id());
        if(b){
            List list = dao.serchByCondition(obj);
            if(list!=null && list.size()>0){
                model.setCode(1);
                model.setData(list);
                model.setMsg("查询成功!");
            }else{
                model.setCode(0);
                model.setMsg("查询失败!");
            }
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }
        
        return model;
    } 
    //批量设置系统参数
      public ServiceModel updatePro(Object obj) {
          boolean bl=((Fbs9100_sysparamImpl)dao).updatePro(obj);
          if(bl) {
              List<Fbs9100_sysparam> list=(List<Fbs9100_sysparam>) obj;
              Calendar c = Calendar.getInstance(); 
              //现在的时间(单位:毫秒) 
              long now_time = c.getTimeInMillis();
              long time=0;
              int success=0;
              do {
                  for (int i = 0; i < list.size(); i++) {
                      Fbs9100_sysparam fs=new Fbs9100_sysparam();
                      fs=list.get(i);
                      if(fs.getNum()==0) {//前台传参设置
                          boolean b=((Fbs9100_sysparamImpl)dao).getCmdAck(fs.getOp_cmd(), fs.getDev_id());
                          if(b) {
                              success+=1;
                              list.get(i).setNum(1);
                          }
                      }
                  }
                  if(success==list.size()) {
                      break;
                  }
                  Calendar cl = Calendar.getInstance(); 
                  long moment_time = cl.getTimeInMillis();
                  time=moment_time-now_time;
              }while(time<=5*1000);
              model.setData(list);
              model.setCode(1);
              model.setSum(success);
              model.setMsg("修改成功!");
          }else {
              model.setCode(0);
              model.setMsg("修改失败!");
          }
          return model;    
      }
  //批量设置系统参数时,根据省市区,电池单体型号(伏数),组数筛选出电池组并读取它的实际系统参数
      public ServiceModel serchBattinfAndParam(Object obj) {
          List<BattInf> list=(new BattInfImpl()).serchBySys_param(obj);
          if(list!=null&&list.size()>0) {
                Calendar c = Calendar.getInstance(); 
                //现在的时间(单位:毫秒) 
                long now_time = c.getTimeInMillis();
                long time=0;
                int success=0;
                int count=0;
                do {
                    for (int i = 0; i < list.size(); i++) {
                        BattInf binf=list.get(i);
                        Fbs9100_sysparam fbs_sys=new Fbs9100_sysparam();
                        fbs_sys.setDev_id(binf.getFBSDeviceId());
                            fbs_sys.setOp_cmd(FBS9100_ComBase.CMD_GetSYSSetParam);
                        if(count==0) {
                            fbs_sys.setDev_ip("127.0.0.0");
                            fbs_sys.setIPADDR("127.0.0.0");
                            fbs_sys.setSubIPADDR("127.0.0.0");
                            fbs_sys.setNetGateADDR("127.0.0.0");
                            fbs_sys.setGroupVolRange(0);
                            fbs_sys.setGroupVolSorce(0);
                            fbs_sys.setCurrentRange(0);
                            fbs_sys.setCurrentTyte(0);
                            fbs_sys.setMonomerOrder(0);
                            fbs_sys.setBackLightTime(0);
                            fbs_sys.setMACADDR("0.0.0.0.0.0");
                            fbs_sys.setLoaderCount(0);
                            fbs_sys.setDtCardCount(0);
                            fbs_sys.setPowerBreakChargeCurr(0);
                            fbs_sys.setMajorBattGroupNum(0);
                            fbs_sys.setPOF_BG_Boost_Cnt(0);
                            fbs_sys.setPOF_BG_Boost_VolStop(0);
                            fbs_sys.setPOF_BG_Boost_VolStart(0);
                              boolean bl=((Fbs9100_sysparamImpl)dao).replacePL(fbs_sys);
                              List listb=new ArrayList();
                              listb.add(fbs_sys);
                              list.get(i).setObj(listb);
                        }
                        if(binf.getNum()==0) {
                            boolean b=((Fbs9100_sysparamImpl)dao).getCmdAck(fbs_sys.getOp_cmd(), fbs_sys.getDev_id());
                            if(b) {
                                success+=1;
                                list.get(i).setNum(1);
                                List listbatt=dao.serchByCondition(fbs_sys);
                                list.get(i).setObj(listbatt);
                            }
                        }
                    }
                    count++;
                    if(success==list.size()) {
                        break;
                    }
                    Calendar cl = Calendar.getInstance(); 
                    long moment_time = cl.getTimeInMillis();
                    time=moment_time-now_time;
                }while(time<=5*1000);
                model.setData(list);
                model.setCode(1);
                model.setSum(success);
                model.setMsg("修改成功!");
          }else{
              model.setCode(0);
              model.setMsg("查询失败!");
          }
          return model;
      }
    public static void main(String[] args) {
        Fbs9100_sysparamService fs=new Fbs9100_sysparamService();
        Fbs9100_sysparam sys=new Fbs9100_sysparam();
        /*sys.setDev_id(910000001);
        ServiceModel model=fs.serchByCondition(sys);
        System.out.println(model);*/
        BattInf binf=new BattInf();
        binf.setNum(2);
        binf.setStationName("百色");
        //binf.setGroupIndexInFBSDevice(100);
        binf.setMonVolStd(12f);
        ServiceModel model=fs.serchBattinfAndParam(binf);
        List list=(List)model.getData();
        for (int i = 0; i < list.size(); i++) {
            System.out.println(((BattInf)list.get(i)));
        }
    }
}