| | |
|---|
| | | private WorkstationCache workstationCache; |
|---|
| | | @Autowired |
|---|
| | | private TimeSliceCache timeSliceCache; |
|---|
| | | //private static String TEMPLATE_NAME = "process_param"; |
|---|
| | | |
|---|
| | | static { |
|---|
| | | PROCESS_PARAM_MAP.put(1, "STATE"); |
|---|
| | |
|---|
| | | public void handle(List<TelemetryData> telemetryDataList) { |
|---|
| | | |
|---|
| | | List<PackedTelemetryData> pdataList = packetData(telemetryDataList); |
|---|
| | | System.out.print(pdataList); |
|---|
| | | //System.out.print(pdataList); |
|---|
| | | for (PackedTelemetryData pdt : pdataList) { |
|---|
| | | TelemetryDataHandler handler = handlerSelector.select(pdt.getParamType()); |
|---|
| | | if (handler == null) { |
|---|
| | |
|---|
| | | |
|---|
| | | String[] keys = map.keySet().toArray(new String[0]); |
|---|
| | | for (int j = 0; j < keys.length; j++) { |
|---|
| | | //TODO: 这里，原系统进行了过滤。WorkstationCollectDataServiceImpl.handlerWorkstationCollectData里 |
|---|
| | | PackedTelemetryData pkData = new PackedTelemetryData(); |
|---|
| | | pkData.setWorkstationId(tdata.getWorkstationId()); |
|---|
| | | pkData.setValue(map.get(keys[j])); |
|---|
| | |
|---|
| | | pkData.setName(keys[j]);//参数名称 |
|---|
| | | |
|---|
| | | fillByCalendar(pkData); |
|---|
| | | |
|---|
| | | |
|---|
| | | result.add(pkData); |
|---|
| | | } |
|---|
| | |
|---|
| | | pdata.setCalendarCode("#default#"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | pdata.setShiftIndex(1);//临时 |
|---|
| | | pdata.setShiftTimeType(1);//临时 |
|---|
| | | //pdata.setShiftIndex(1);//临时 |
|---|
| | | //pdata.setShiftTimeType(1);//临时 |
|---|
| | | |
|---|
| | | // TelemetryPropertyWrapper中packWorkstationCalendarInfo |
|---|
| | | //------------start |
|---|
