package com.qianwen.mdc.collect.service;
|
|
import java.time.Instant;
|
import java.time.LocalDate;
|
import java.time.ZoneOffset;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
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.google.common.collect.Sets;
|
import com.qianwen.mdc.collect.cache.TimeSliceCache;
|
import com.qianwen.mdc.collect.cache.WorkstationCache;
|
import com.qianwen.mdc.collect.constants.CommonConstant;
|
import com.qianwen.mdc.collect.domain.TelemetryData;
|
import com.qianwen.mdc.collect.domain.TelemetryDataItem;
|
import com.qianwen.mdc.collect.dto.CacheBuildDTO;
|
import com.qianwen.mdc.collect.dto.CalendarShiftTimeSlicesDTO;
|
import com.qianwen.mdc.collect.dto.PackedTelemetryData;
|
import com.qianwen.mdc.collect.handler.PackedTelemetryDataHandlerSelector;
|
import com.qianwen.mdc.collect.handler.TelemetryDataHandler;
|
import com.qianwen.mdc.collect.utils.LocalDateTimeUtils;
|
import com.qianwen.mdc.collect.vo.FactoryDataVO;
|
|
import cn.hutool.core.date.DatePattern;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
|
/**
|
* 工厂数据获取
|
*/
|
@Service
|
public class FactoryDataService {
|
private static final Logger log = LoggerFactory.getLogger(FactoryDataService.class);
|
|
private static final Map<Integer, String> PROCESS_PARAM_MAP = new HashMap<>();
|
|
|
@Autowired
|
private WorkstationCache workstationCache;
|
@Autowired
|
private TimeSliceCache timeSliceCache;
|
|
/**
|
* 填充生产日历code，以及factoryyear
|
*
|
* @param pdata
|
*/
|
public FactoryDataVO getFactoryData(long workstationId,long dataCollectTime) {
|
//原来在TelemetryPropertyWrapper.packWorkstationCalendarInfo中完成
|
FactoryDataVO result = new FactoryDataVO();
|
|
Date collectTime = new Date(dataCollectTime);
|
String calendarCode = workstationCache.getWorkstationCalendarCodeForDate(workstationId, DateUtil.formatDate(DateUtil.date(collectTime)));
|
if (ObjectUtil.isNotEmpty(calendarCode)) {
|
result.setCalendarCode(calendarCode);
|
} else {
|
//telemetryData.setCalendarCode("#default#");
|
result.setCalendarCode("#default#");
|
}
|
|
// TelemetryPropertyWrapper中packWorkstationCalendarInfo
|
//------------start
|
boolean isDefaultCalendar = true;
|
if (!"#default#".equals(result.getCalendarCode())) {
|
CalendarShiftTimeSlicesDTO calendarShiftTimeSlicesDTO = timeSliceCache.getTimeSliceShift(result.getCalendarCode(), collectTime);//从redis中获得日历的时间切片
|
if (ObjectUtil.isEmpty(calendarShiftTimeSlicesDTO)) {//如果没有时间切片，则使用TimeSliceCache.build(cacheBuildDTO);构建
|
LocalDate targetDate = Instant.ofEpochMilli(dataCollectTime).atZone(ZoneOffset.systemDefault()).toLocalDate();
|
CacheBuildDTO cacheBuildDTO = CacheBuildDTO.builder().tenantIds(Sets.newHashSet(new String[]{"000000"})).calendarCode(calendarCode).targetDate(targetDate).build();
|
timeSliceCache.build(cacheBuildDTO);
|
calendarShiftTimeSlicesDTO = timeSliceCache.getTimeSliceShift(result.getCalendarCode(), collectTime);
|
}
|
if (ObjectUtil.isNotEmpty(calendarShiftTimeSlicesDTO)) {
|
result.setShiftIndex(calendarShiftTimeSlicesDTO.getShiftIndex());
|
result.setShiftTimeType(Integer.valueOf(calendarShiftTimeSlicesDTO.getShiftTimeType()));
|
result.setFactoryDate(Integer.valueOf(calendarShiftTimeSlicesDTO.getFactoryDate().replaceAll("-", "")));
|
result.setFactoryWeek(calendarShiftTimeSlicesDTO.getFactoryWeek());
|
result.setFactoryMonth(calendarShiftTimeSlicesDTO.getFactoryMonth());
|
result.setFactoryYear(calendarShiftTimeSlicesDTO.getFactoryYear());
|
isDefaultCalendar = false;
|
}
|
}
|
|
//无日历切片，使用采集时间填充factoryYear，month，date，week几个属性
|
if (isDefaultCalendar) {
|
log.info("无日历切片");
|
LocalDate localDate = Instant.ofEpochMilli(dataCollectTime).atZone(ZoneOffset.systemDefault()).toLocalDate();
|
result.setFactoryDate(Integer.valueOf(DatePattern.PURE_DATE_FORMAT.format(collectTime)));
|
result.setFactoryYear(DateUtil.year(collectTime));
|
result.setFactoryWeek(LocalDateTimeUtils.getWeek(localDate));
|
result.setFactoryMonth(DateUtil.month(collectTime) + 1);
|
result.setShiftIndex(CommonConstant.DEFAULT_SHIFT_INDEX);
|
result.setShiftTimeType(CommonConstant.DEFAULT_SHIFT_TYPE);
|
}
|
|
|
return result;
|
}
|
|
}
|
