package com.qianwen.mdc.collect.utils;
|
|
import java.util.ArrayList;
|
import java.util.Comparator;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.qianwen.core.tool.utils.BeanUtil;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.mdc.collect.entity.iotdb.AggregateState;
|
import com.qianwen.mdc.collect.entity.iotdb.DeviceState;
|
import com.qianwen.mdc.collect.enums.FeedbackTimePointEnum;
|
|
/**
|
* 无反馈得状态聚合 util
|
*
|
*/
|
public class WorkstationStateAggregateNoFeedbackUtils {
|
private static final Logger log = LoggerFactory.getLogger(WorkstationStateAggregateNoFeedbackUtils.class);
|
|
|
|
public static List<AggregateState> buildAggregateList(List<DeviceState> notSyncWorkstationStates) {
|
List<AggregateState> workstationAggregateStateList = new ArrayList<>();
|
List<DeviceState> notSyncWorkstationStates2 = rebuildNotSyncWorkstationStates(notSyncWorkstationStates);
|
if (Func.isNotEmpty(notSyncWorkstationStates2)) {
|
int resultCount = notSyncWorkstationStates2.size();
|
for (int i = 0; i < notSyncWorkstationStates2.size() - 1; i++) {
|
DeviceState current = notSyncWorkstationStates2.get(i);
|
DeviceState nextState = notSyncWorkstationStates2.get(i + 1);
|
//使用ts的差，构建durationCollect，其余使用current的属性
|
AggregateState aggState =new AggregateState();
|
//workstationAggregateStateList.add(AggregateState.builder().ts(current.getTs()).workstationId(current.getWorkstationId()).isDeleted(Boolean.FALSE).valueCollect(current.getValueCollect()).rps(current.getRps()).wcs(current.getWcs()).isPlan(current.getIsPlan()).shiftIndex(current.getShiftIndex()).shiftTimeType(current.getShiftTimeType()).calendarCode(current.getCalendarCode()).factoryDate(current.getFactoryDate()).factoryMonth(current.getFactoryMonth()).factoryWeek(current.getFactoryWeek()).factoryYear(current.getFactoryYear()).durationCollect(Long.valueOf(TimeUnit.MILLISECONDS.toSeconds(nextState.getTs().longValue() - current.getTs().longValue()))).employeeId(current.getEmployeeId()).endTime(nextState.getTs()).build());
|
aggState.setTime(current.getTime());
|
aggState.setWorkstationId(current.getWorkstationId());
|
aggState.setIsDeleted(false);
|
aggState.setValueCollect(current.getValueCollect());
|
aggState.setRps(current.getRps());
|
aggState.setWcs(current.getWcs());
|
aggState.setIsPlan(current.getIsPlan());
|
aggState.setShiftIndex(current.getShiftIndex());
|
aggState.setShiftTimeType(current.getShiftTimeType());
|
aggState.setCalendarCode(current.getCalendarCode());
|
aggState.setFactoryDate(current.getFactoryDate());
|
aggState.setFactoryMonth(current.getFactoryMonth());
|
aggState.setFactoryWeek(current.getFactoryWeek());
|
aggState.setFactoryYear(current.getFactoryYear());
|
aggState.setDurationCollect(Long.valueOf(TimeUnit.MILLISECONDS.toSeconds(nextState.getTime().longValue() - current.getTime().longValue())));
|
aggState.setEmployeeId(current.getEmployeeId());
|
aggState.setEndTime(nextState.getTime());
|
|
workstationAggregateStateList.add(aggState);
|
}
|
|
//构建最后一条，无durationCollect
|
DeviceState lastNoSyncWorkstationState = notSyncWorkstationStates2.get(resultCount - 1);
|
|
AggregateState lastAggState = new AggregateState();
|
//workstationAggregateStateList.add(AggregateState.builder().ts(lastNoSyncWorkstationState.getTime()).workstationId(lastNoSyncWorkstationState.getWorkstationId()).isDeleted(Boolean.FALSE).valueCollect(lastNoSyncWorkstationState.getValueCollect()).rps(lastNoSyncWorkstationState.getRps()).wcs(lastNoSyncWorkstationState.getWcs()).isPlan(lastNoSyncWorkstationState.getIsPlan()).shiftIndex(lastNoSyncWorkstationState.getShiftIndex()).shiftTimeType(lastNoSyncWorkstationState.getShiftTimeType()).calendarCode(lastNoSyncWorkstationState.getCalendarCode()).factoryDate(lastNoSyncWorkstationState.getFactoryDate()).factoryMonth(lastNoSyncWorkstationState.getFactoryMonth()).factoryWeek(lastNoSyncWorkstationState.getFactoryWeek()).factoryYear(lastNoSyncWorkstationState.getFactoryYear()).employeeId(lastNoSyncWorkstationState.getEmployeeId()).build());
|
lastAggState.setTime(lastNoSyncWorkstationState.getTime());
|
lastAggState.setWorkstationId(lastNoSyncWorkstationState.getWorkstationId());
|
lastAggState.setIsDeleted(false);
|
lastAggState.setValueCollect(lastNoSyncWorkstationState.getValueCollect());
|
lastAggState.setRps(lastNoSyncWorkstationState.getRps());
|
lastAggState.setWcs(lastNoSyncWorkstationState.getWcs());
|
lastAggState.setIsPlan(lastNoSyncWorkstationState.getIsPlan());
|
lastAggState.setShiftIndex(lastNoSyncWorkstationState.getShiftIndex());
|
lastAggState.setShiftTimeType(lastNoSyncWorkstationState.getShiftTimeType());
|
lastAggState.setCalendarCode(lastNoSyncWorkstationState.getCalendarCode());
|
lastAggState.setFactoryDate(lastNoSyncWorkstationState.getFactoryDate());
|
lastAggState.setFactoryMonth(lastNoSyncWorkstationState.getFactoryMonth());
|
lastAggState.setFactoryWeek(lastNoSyncWorkstationState.getFactoryWeek());
|
lastAggState.setFactoryYear(lastNoSyncWorkstationState.getFactoryYear());
|
lastAggState.setEmployeeId(lastNoSyncWorkstationState.getEmployeeId());
|
|
|
workstationAggregateStateList.add(lastAggState);
|
}
|
return workstationAggregateStateList;
|
}
|
|
/**
|
* 重新构建未同步状态列表数据
|
* @param originalDeviceStates
|
* @return
|
*/
|
private static List<DeviceState> rebuildNotSyncWorkstationStates(List<DeviceState> originalDeviceStates) {
|
List<DeviceState> stateList = new ArrayList<>();
|
if (Func.isNotEmpty(originalDeviceStates)) {
|
List<DeviceState> notSyncWorkstationStates = originalDeviceStates.stream().filter(x -> {
|
//含义未选取fixpoint 或者非反馈点，其他类型的采集数据不处理了，我们自己就不用过滤了，因为都是NO_FEED_BACK_POINT，且isFixPoint=false
|
return Boolean.TRUE.equals(x.getIsFixPoint()) || x.getFeedbackPointType() == null || x.getFeedbackPointType().equals(FeedbackTimePointEnum.NO_FEED_BACK_POINT.getValue());
|
}).map(x2 -> {
|
//固定点，设置wcs，rps=0
|
if (x2.getIsFixPoint().booleanValue()) {
|
x2.setWcs(0);
|
x2.setRps(0);
|
x2.setIsPlan(null);
|
}
|
return x2;
|
}).collect(Collectors.toList()).stream().sorted(Comparator.comparing(DeviceState::getTime)).collect(Collectors.toList());
|
|
notSyncWorkstationStates.forEach(x3 -> {
|
if (x3.getIsFixPoint().booleanValue()) {
|
//是固定点，找出不晚于该固定点的最后一个点，加入stateList;如果没有找到，则将该固定点加入stateList
|
List<DeviceState> collect = notSyncWorkstationStates.stream().filter(y -> {
|
//在列表中找出时间不晚于(<=)该固定点(x3)的非固定点(为了获取最后一条的数据)
|
return !y.getIsFixPoint().booleanValue() && y.getTime().longValue() <= x3.getTime().longValue();
|
}).collect(Collectors.toList());
|
|
if (Func.isNotEmpty(collect)) {//除非之前没有过数据，否则这个条件(isNotEmpty)都成立
|
DeviceState temp = (DeviceState) BeanUtil.copy(x3, DeviceState.class);
|
temp.setValueCollect(collect.get(collect.size() - 1).getValueCollect());
|
temp.setWcs(collect.get(collect.size() - 1).getWcs());
|
temp.setRps(collect.get(collect.size() - 1).getRps());
|
temp.setIsPlan(collect.get(collect.size() - 1).getIsPlan());
|
stateList.add(temp);
|
return;
|
}
|
stateList.add(x3);
|
return;
|
}
|
//非固定点，直接加入列表
|
stateList.add(x3);
|
});
|
}
|
return stateList;
|
}
|
|
public static List<AggregateState> getReallyEffectWorkstationStateAggregateNoFeedbackList(List<AggregateState> insertData, List<AggregateState> deleteData) {
|
HashMap<Long, AggregateState> workstationStateMap = new HashMap<>();
|
if (Func.isNotEmpty(insertData)) {
|
insertData.forEach(item -> {
|
workstationStateMap.put(item.getTime(), item);
|
});
|
}
|
if (Func.isNotEmpty(deleteData)) {
|
for (AggregateState state : deleteData) {
|
if (!workstationStateMap.containsKey(state.getTime())) {
|
workstationStateMap.put(state.getTime(), state);
|
}
|
}
|
}
|
return workstationStateMap.values().stream().collect(Collectors.toList());
|
}
|
}
|
