Package com.narirelays.ems.persistence.orm

Examples of com.narirelays.ems.persistence.orm.MeasureTable

566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
      media_id = GetObjectString.getMDB2RDBID(media_id);
      MeasureTableId mtid = new MeasureTableId();
      mtid.setHierarchyId(dep_id);
      mtid.setEMId(media_id);
      mtid.setTimeId(time_id);
      MeasureTable mt = measureTableDAO.findById(mtid);
      if(mt!=null){
        result.setFailed(MEASURE_TABLE_EXISTED);
      }else{
        try {
          double scc = 1;
          if(mt.getValue()!=0){
            scc = mt.getCValue()/mt.getValue();
          }else{
            EnergyMedia energyMedia = energyMediaDAO.findById(media_id);
            if(energyMedia!=null){
              scc = energyMedia.getScc();
            }
          }
          mt = new MeasureTable();
          mt.setId(mtid);
          BeanUtils.populate(mt, properties);
          if(mt.getMValue()==null){
            if(mt.getSValue()==null){
             
            }else{
              mt.setValue(mt.getSValue());
            }
          }else{
            if(mt.getSValue()==null){
              mt.setValue(mt.getMValue());
            }else{
              mt.setValue(mt.getSValue()+mt.getSValue());
            }
          }
          if(mt.getValue()!=null){
            mt.setCValue(mt.getValue()*scc);
          }
          measureTableDAO.merge(mt);
          result.setSucceed(MEASURE_TABLE_APPEND_SUCCEED);
        } catch (IllegalAccessException e) {
          // TODO Auto-generated catch block
View Full Code Here
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
      media_id = GetObjectString.getMDB2RDBID(media_id);
      MeasureTableId mtid = new MeasureTableId();
      mtid.setHierarchyId(dep_id);
      mtid.setEMId(media_id);
      mtid.setTimeId(time_id);
      MeasureTable mt = measureTableDAO.findById(mtid);
      if(mt==null){
        result.setFailed(MEASURE_TABLE_NOTEXIST,dep_id,media_id,time_id);
      }else{
        try {
          double scc = 1;
          if(mt.getValue()!=0){
            scc = mt.getCValue()/mt.getValue();
          }else{
            EnergyMedia energyMedia = energyMediaDAO.findById(media_id);
            if(energyMedia!=null){
              scc = energyMedia.getScc();
            }
          }
          mt = new MeasureTable();
          mt.setId(mtid);
          BeanUtils.populate(mt, properties);
          if(mt.getMValue()==null){
            if(mt.getSValue()==null){
             
            }else{
              mt.setValue(mt.getSValue());
            }
          }else{
            if(mt.getSValue()==null){
              mt.setValue(mt.getMValue());
            }else{
              mt.setValue(mt.getSValue()+mt.getSValue());
            }
          }
          if(mt.getValue()!=null){
            mt.setCValue(mt.getValue()*scc);
          }
          measureTableDAO.merge(mt);
          result.setSucceed(MEASURE_TABLE_APPEND_SUCCEED);
        } catch (IllegalAccessException e) {
          // TODO Auto-generated catch block
View Full Code Here
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
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
              Log.error("No such in measure energy media:"+inMeasure.getEnergyMedia().getId());
              continue;
            }else{
              energyMediaID = energyMedia.getId();
             
              MeasureTable measureTable = null;
              String measureTableIDHash = process.getId()+energyMedia.getId()+date;
              if(measureHash.containsKey(measureTableIDHash)){
                measureTable = measureHash.get(measureTableIDHash);
              }else{
                measureTable = new MeasureTable();//创建事实表中记录
                measureTable.setId(new MeasureTableId(date,entHierarchyID,energyMediaID));
                measureHash.put(measureTableIDHash, measureTable);
              }
              //获得指定计量点的指定时间的计量值
              double value = getMeasureData(inMeasure,date);
              String corType = inMeasure.getCorType();
              //根据计量点类型进行计量校正，在计算时，输入为正，输出为负。
             
              /**!
               * mvalue:计量值
               * svalue:人工调整量
               * cvalue:计量折标量
               * value: 计量总量
               */
              if("P".equalsIgnoreCase(corType)){
                //百分比校正
                measureTable.setMValue(value);
                measureTable.setSValue(value+value*Double.parseDouble(inMeasure.getCorValue()));
              }else if("O".equalsIgnoreCase(corType)){
                //绝对值校正
                measureTable.setMValue(value);
                measureTable.setSValue(value+Double.parseDouble(inMeasure.getCorValue()));
              }else if("U".equalsIgnoreCase(corType)){
                //计算公式校正
                measureTable.setMValue(value);
                try{
                  Object uresult = ScriptEvaluator.evalWithMVEL(inMeasure.getCorValue(), measureTable);
                  measureTable.setSValue((Double)uresult);
                }catch(Exception e){
                  e.printStackTrace();
                }
              }else{
                //不校正
                measureTable.setMValue(value);
                measureTable.setSValue(0.0);
              }
              //根据计量值和校正值设置对应的计量总量和计量折标量
              measureTable.setValue(measureTable.getMValue()+measureTable.getSValue());
              measureTable.setCValue(measureTable.getValue()*energyMedia.getScc());
             
            }
          }
         
        }
        List<POutMeasure> outs = pOutMeasureDAO.findByProperty("process", process);
//        Set<POutMeasure> outs = process.getPOutMeasures();
        for(POutMeasure out:outs){//对于所有工艺关联的输出计量点OutMeasure
          Measure outMeasure = measureDAO.findById(out.getId().getMId());
//          Measure outMeasure = out.getMeasure();
          if(outMeasure==null){
            Log.error("No such out measure:"+out.getMeasure().getId());
            continue;
          }else{
            //得到对应的计量点的能源介质类型
//            EnergyMedia energyMedia = outMeasure.getEnergyMedia();
            EnergyMedia energyMedia = energyMediaDAO.findById(outMeasure.getEnergyMedia().getId());
            if(energyMedia==null){
              Log.error("No such out measure energy media:"+outMeasure.getEnergyMedia().getId());
              continue;
            }else{
              energyMediaID = energyMedia.getId();
             
              MeasureTable measureTable = null;
              String measureTableIDHash = process.getId()+energyMedia.getId()+date;
              if(measureHash.containsKey(measureTableIDHash)){
                measureTable = measureHash.get(measureTableIDHash);
              }else{
                measureTable = new MeasureTable();
                measureTable.setId(new MeasureTableId(date,entHierarchyID,energyMediaID));
                measureHash.put(measureTableIDHash, measureTable);
              }
             
//              MeasureTable measureTable = null;
//              if(measureHash.containsKey(process.getId()+energyMedia.getId()+date)){
//                measureTable = measureHash.get(process.getId()+energyMedia.getId()+date);
//              }else{
//                measureTable = new MeasureTable();
//                measureTable.setId(new MeasureTableId(date,entHierarchyID,energyMediaID));
//                measureHash.put(process.getId()+energyMedia.getId()+date, measureTable);
//              }
              //获得指定计量点的指定时间的计量值
              double value = getMeasureData(outMeasure,date);
              String corType = outMeasure.getCorType();
              //根据计量点类型进行计量校正，在计算时，输入为正，输出为负。
              if("P".equalsIgnoreCase(corType)){
                //百分比校正
                measureTable.setMValue(-value);
                measureTable.setSValue(-value-value*Double.parseDouble(outMeasure.getCorValue()));
              }else if("O".equalsIgnoreCase(corType)){
                //绝对值校正
                measureTable.setMValue(-value);
                measureTable.setSValue(-value-Double.parseDouble(outMeasure.getCorValue()));
              }else if("U".equalsIgnoreCase(corType)){
                //计算公式校正
                measureTable.setMValue(value);
                try{
                  Object uresult = ScriptEvaluator.evalWithMVEL(outMeasure.getCorValue(), measureTable);
                  measureTable.setSValue((Double)uresult);
                }catch(Exception e){
                  e.printStackTrace();
                }
              }else{
                //不校正
                measureTable.setMValue(-value);
                measureTable.setSValue(0.0);
              }
              //根据计量值和校正值设置对应的计量总量和计量折标量
              measureTable.setValue(measureTable.getMValue()+measureTable.getSValue());
              measureTable.setCValue(measureTable.getValue()*energyMedia.getScc());
            }
          }
         
        }
      }
    }
    /**!
     * 处理MeasureHash中的所有对象并入库，暂时采用逐条的方式，需要改！！
     */
    int i=0;
    int total = measureHash.size();
    for(MeasureTable measureTable:measureHash.values()){
      try{
        measureTableDAO.merge(measureTable);
        i++;
        Log.info("Merge measure table "+i+"/"+total);
      }catch(Exception e){
        log.error(new StringBuilder().append("Merge error for measure table record\nDepartment ID:").append(measureTable.getId().getHierarchyId())
        .append("\nEM ID:").append(measureTable.getId().getEMId())
        .append("\nDate ID:").append(measureTable.getId().getTimeId())
        .append("\nMeasure Value:").append(measureTable.getMValue())
        .append("\nCorrect Value:").append(measureTable.getSValue())
        .append("\nTotal Value:").append(measureTable.getValue())
        .append("\nSCC Value:").append(measureTable.getCValue()).toString());
        log.error(e.getMessage());
        e.printStackTrace();
      }
    }
    if(i!=total){
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
  }
  public OperResult modifyMeasureTable(Object dep_id,Object media_id,Object time_id,Map properties){
    return basicInfomationManagement.modifyMeasureTable(stringValue(dep_id), stringValue(media_id), stringValue(time_id), properties);
  }
  public OperResult queryMeasureTable(Object dep_id,Object time_id){
    MeasureTable output = new MeasureTable();
    OperResult result =  basicInfomationManagement.queryMeasureTable(stringValue(dep_id), stringValue(time_id), output);
    if(result.isSUCCEED()){
      JSONObject jsonObject = JSONObject.fromObject(output, jsonConfig);
      result.setInfoMSG(jsonObject.toString());
    }
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
    MeasureTableId measureTableID = new MeasureTableId(timeID,departmentID,energyID);
    /**
     * 如若该记录原来存在，则读出该记录进行修改，这样不会覆盖如value、s_value等数据
     * 如果不存在，则直接新建
     * */
    MeasureTable measureTable = measureTableDAO.findById(measureTableID);
    if(measureTable==null)
    {
      measureTable = new MeasureTable();
      measureTable.setId(measureTableID);
    }
    measureTable.setPlanValue(planValue);
    measureTableDAO.merge(measureTable);
    int level =2*timeLevel+1*entLevel;//用来标识整个计划处于的层次
    //0:全年全厂，1:全年分厂，2:月全厂，3:月分厂
    result.setData(level);//将层次信息在Data中返回
    result.setSucceed();
 
View Full Code Here
TOP

Related Classes of com.narirelays.ems.persistence.orm.MeasureTable

  • com.narirelays.ems.applogic.BasicInfomationManagement
  • com.narirelays.ems.applogic.EnergyPlanManagement
  • com.narirelays.ems.services.DataImporter4PCS9000ManagementService
  • com.narirelays.ems.services.MeasureTableManagementService
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.