package com.qianwen.smartman.modules.mdc.service;
|
|
import java.util.Map;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.qianwen.smartman.modules.smis.message.dto.TelemetryDataResponseDTO;
|
import com.qianwen.smartman.modules.mdc.dto.ProcessParameterVO;
|
import com.qianwen.smartman.modules.mdc.mapper.SuperProcessParameterMapper;
|
|
|
@Service
|
public class RealTimeDataService {
|
private static final Logger log = LoggerFactory.getLogger(RealTimeDataService.class);
|
@Autowired
|
private SuperProcessParameterMapper processParamMapper;
|
|
public final String statusDpName = "DeviceStatus";
|
/**
|
* 为设备状态增加当前状态的最早时间preT
|
* @param workstationId 工位id
|
* @param map 工位id对应的所有最新数据
|
*/
|
public void addPreTimeInDeviceStatus(long workstationId,Map<String, Object> map) {
|
//找到状态的数据，加入上一个状态的
|
|
if(map.containsKey(statusDpName)) {
|
TelemetryDataResponseDTO statusDTO = (TelemetryDataResponseDTO) map.get(statusDpName);
|
JSONObject statusJson = new JSONObject();
|
statusJson.put("t", statusDTO.getT());
|
statusJson.put("v", statusDTO.getV());
|
|
//存在问题，DeviceStastus,DeviceStatus_n会几乎同时过来
|
long preT = statusDTO.getT();
|
//最后一条不同值(v)的数据
|
ProcessParameterVO diffStatusVO = processParamMapper.lastParameterNotEqValue(workstationId, statusDpName, statusDTO.getV());
|
|
ProcessParameterVO tempStatusVO;
|
if(diffStatusVO != null) {
|
tempStatusVO = processParamMapper.firstParameterEqValueGtTime(workstationId, statusDpName, statusDTO.getV(), diffStatusVO.getTime().getTime());
|
}else {
|
tempStatusVO = processParamMapper.firstParameterEqValue(workstationId, statusDpName, statusDTO.getV());
|
}
|
if(tempStatusVO != null) {
|
preT = tempStatusVO.getTime().getTime();
|
}
|
statusJson.put("preT", preT);
|
|
map.put(statusDpName, statusJson);//覆盖原来的DeviceStatus
|
}
|
}
|
|
}
|
