package com.qianwen.mdc.collect.service.feedback;
|
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Component;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.qianwen.core.tool.utils.SpringUtil;
|
import com.qianwen.mdc.collect.dto.StateAggregateTimeDTO;
|
import com.qianwen.mdc.collect.entity.iotdb.DeviceState;
|
import com.qianwen.mdc.collect.entity.mgr.WorkstationWcsFeedback;
|
import com.qianwen.mdc.collect.enums.FeedbackProcessStatusEnum;
|
import com.qianwen.mdc.collect.enums.FeedbackTypeEnum;
|
import com.qianwen.mdc.collect.mapper.iotdb.DeviceStateMapper;
|
import com.qianwen.mdc.collect.mapper.mgr.WorkstationWcsFeedbackDetailMapper;
|
//import com.qianwen.posting.entity.tdengine.WorkstationState;
|
import com.qianwen.mdc.collect.mapper.mgr.WorkstationWcsFeedbackMapper;
|
import com.qianwen.mdc.collect.service.DeviceStateAggregateService;
|
import com.qianwen.mdc.collect.service.DeviceStateService;
|
|
|
|
//import com.qianwen.posting.message.event.WorkstationAggregateMessage;
|
//import com.qianwen.posting.message.producer.WorkstationAggregateProducer;
|
|
@Component
|
public class ImmediateFeedbackHandlerStrategy implements WorkstationFeedbackHandlerStrategy {
|
private static final Logger log = LoggerFactory.getLogger(ImmediateFeedbackHandlerStrategy.class);
|
private WorkstationWcsFeedbackMapper feedbackMapper;
|
private WorkstationWcsFeedbackDetailMapper feedbackDetailMapper;
|
//private WorkstationAggregateProducer producer;//发送消息用的(执行状态聚合，我们直接调用了)
|
|
//, final WorkstationAggregateProducer producer
|
public ImmediateFeedbackHandlerStrategy(final WorkstationWcsFeedbackMapper feedbackMapper, final WorkstationWcsFeedbackDetailMapper feedbackDetailMapper) {
|
this.feedbackMapper = feedbackMapper;
|
this.feedbackDetailMapper = feedbackDetailMapper;
|
//this.producer = producer;
|
}
|
|
@Override
|
public void handlerFeedback(WorkstationWcsFeedback feedback) {
|
if (FeedbackTypeEnum.IMMEDIATE_FEEDBACK.isEqual(feedback.getFeedbackType())) {
|
ImmediateFeedbackAnalyseResult result = ImmediateFeedbackAnalyseResultBuilder.get().buildBaseInfo(feedback).buildFeedbackDetail(feedback).analyse();
|
if (!result.getNeedProcess().booleanValue()) {
|
return;
|
}
|
List<DeviceState> handlerStateList = new ArrayList<>();
|
|
DeviceStateMapper stateMapper = SpringUtil.getBean(DeviceStateMapper.class);
|
if (result.getResetState()) {
|
|
/*
|
List<WorkstationState> waitResetStateList = workstationStateMapper1.selectList(Wrappers.<WorkstationState>lambdaQuery()
|
.ge(WorkstationState::getTs, feedback.getStartTime())
|
.ne(WorkstationState::getIsDeleted, Boolean.TRUE)
|
.le(WorkstationState::getTs, Long.valueOf(System.currentTimeMillis())));
|
*/
|
StateAggregateTimeDTO timeRange = new StateAggregateTimeDTO();
|
timeRange.setStartTime(feedback.getStartTime().getTime());
|
timeRange.setEndTime(System.currentTimeMillis());
|
List<DeviceState> waitResetStateList = stateMapper.statesInTimeRange(feedback.getWorkstationId(), timeRange);//yys 改，此查询增加了workstationId
|
waitResetStateList = waitResetStateList.stream().map(x -> {
|
x.setIsSync(Boolean.FALSE);
|
return x;
|
}).collect(Collectors.toList());
|
|
handlerStateList.addAll(waitResetStateList);
|
}
|
handlerStateList.addAll(result.getEffectiveStateList());
|
//保存
|
//WorkstationStateMapper workstationStateMapper = SpringUtil.getBean(WorkstationStateMapper.class);
|
//workstationStateMapper.batchSave(feedback.getWorkstationId(), handlerStateList);
|
DeviceStateService stateServie = SpringUtil.getBean(DeviceStateService.class);
|
stateServie.saveDeviceStates(handlerStateList);//yangys 改，使用自己的方法
|
|
this.feedbackDetailMapper.insert(result.getFeedbackDetail());
|
this.feedbackMapper.update(null, Wrappers.<WorkstationWcsFeedback>lambdaUpdate()
|
.eq(WorkstationWcsFeedback::getId, feedback.getId())
|
.set(WorkstationWcsFeedback::getStatus, FeedbackProcessStatusEnum.PROCESSING.getValue()));
|
|
//TODO 下面是发送消息 ,消费者执行聚合状态的操作
|
/*
|
WorkstationAggregateMessage message = new WorkstationAggregateMessage();
|
message.setWorkStationId(feedback.getWorkstationId().toString());
|
this.producer.sendWorkStationAggregateMessage(Arrays.asList(message));
|
*/
|
//我们改为直接调用吧
|
DeviceStateAggregateService deviceStateAggregateService = SpringUtil.getBean(DeviceStateAggregateService.class);
|
deviceStateAggregateService.stateAggregate(feedback.getWorkstationId());
|
}
|
}
|
}
|
