package com.qianwen.mdc.collect.service.feedback;

import java.util.List;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.core.tool.utils.SpringUtil;
import com.qianwen.mdc.collect.cache.WorkstationCache;
import com.qianwen.mdc.collect.dto.CalendarShiftInfoDTO;
import com.qianwen.mdc.collect.entity.iotdb.DeviceState;
import com.qianwen.mdc.collect.entity.mgr.GlobalWcsOfRps;
import com.qianwen.mdc.collect.entity.mgr.WorkstationWcsFeedback;
import com.qianwen.mdc.collect.entity.mgr.WorkstationWcsFeedbackDetail;
import com.qianwen.mdc.collect.enums.FeedbackDetailStatusEnum;
import com.qianwen.mdc.collect.enums.FeedbackProcessStatusEnum;
import com.qianwen.mdc.collect.enums.FeedbackTimePointEnum;
import com.qianwen.mdc.collect.mapper.mgr.WorkstationWcsFeedbackDetailMapper;
import com.qianwen.mdc.collect.mapper.mgr.WorkstationWcsFeedbackMapper;
import com.qianwen.mdc.collect.mapper.iotdb.DeviceStateMapper;
import com.qianwen.mdc.collect.service.WorkstationService;

public class ImmediateFeedbackAnalyseResultBuilder {
    private ImmediateFeedbackAnalyseResult result = new ImmediateFeedbackAnalyseResult();
    WorkstationWcsFeedbackMapper feedbackMapper = SpringUtil.getBean(WorkstationWcsFeedbackMapper.class);
    WorkstationWcsFeedbackDetailMapper feedbackDetailMapper = SpringUtil.getBean(WorkstationWcsFeedbackDetailMapper.class);

    

    public static ImmediateFeedbackAnalyseResultBuilder get() {
        return new ImmediateFeedbackAnalyseResultBuilder();
    }

    public ImmediateFeedbackAnalyseResultBuilder buildBaseInfo(WorkstationWcsFeedback feedback) {
        if (Func.isEmpty(feedback.getEndTime())) {
          long detailCount = this.feedbackDetailMapper.selectCount(Wrappers.<WorkstationWcsFeedbackDetail>lambdaQuery()
              .eq(WorkstationWcsFeedbackDetail::getFeedbackId, feedback.getId())).longValue();
          if (detailCount > 0) {
            this.result.setNeedProcess(false);
          } else {
            this.result.getEffectiveStateList().add(wrapperImmediateFeedbackStartTimePoint(feedback));
          } 
        } else {
          this.result.setResetState(true);
          this.result.setResetStartTime(feedback.getStartTime());
          this.result.getEffectiveStateList().add(wrapperImmediateFeedbackStartTimePoint(feedback));
          this.result.getEffectiveStateList().add(wrapperImmediateFeedbackEndTimePoint(feedback));
        } 
        return this;
      }

    public ImmediateFeedbackAnalyseResultBuilder buildFeedbackDetail(WorkstationWcsFeedback feedback) {
        if (this.result.getNeedProcess().booleanValue()) {
            WorkstationWcsFeedbackDetail feedbackDetail = new WorkstationWcsFeedbackDetail();
            feedbackDetail.setWorkstationId(feedback.getWorkstationId());
            feedbackDetail.setFeedbackId(feedback.getId());
            feedbackDetail.setStartTime(feedback.getStartTime());
            feedbackDetail.setEndTime(feedback.getEndTime());
            feedbackDetail.setCancel(0);
            feedbackDetail.setStatus(FeedbackDetailStatusEnum.BE_EFFECTIVE.getValue());
            feedbackDetail.setWcs(feedback.getWcs());
            this.result.setFeedbackDetail(feedbackDetail);
        }
        return this;
    }

    private DeviceState wrapperImmediateFeedbackEndTimePoint(WorkstationWcsFeedback feedback) {
    	DeviceState workstationState = new DeviceState();
        workstationState.setTime(Long.valueOf(feedback.getEndTime().getTime()));
        workstationState.setWorkstationId(feedback.getWorkstationId());
        workstationState.setWcs(Integer.valueOf(feedback.getWcs()));
        workstationState.setIsSync(false);
        workstationState.setFeedbackId(feedback.getId());
        workstationState.setValueCollect(Integer.valueOf(feedback.getWcs()));
        workstationState.setIsFixPoint(false);
        workstationState.setFeedbackPointType(FeedbackTimePointEnum.END_POINT.getValue());
        workstationState.setIsDeleted(false);
        DeviceStateMapper stateMapper = SpringUtil.getBean(DeviceStateMapper.class);
        /*
        DeviceState suitableWorkstationState = (WorkstationState)stateMapper.selectOne(Wrappers.<WorkstationState>lambdaQuery()
            .eq(WorkstationState::getWorkstationId, feedback.getWorkstationId())
            .eq(WorkstationState::getTs, Long.valueOf(feedback.getEndTime().getTime())));
        */
        DeviceState suitableWorkstationState = stateMapper.getByWorkstationIdAndTime(feedback.getWorkstationId(), feedback.getEndTime().getTime());
        
        if (Func.isNotEmpty(suitableWorkstationState)) {
          workstationState.setIsFixPoint(true);
          workstationState.setFactoryDate(suitableWorkstationState.getFactoryDate());
          workstationState.setFactoryMonth(suitableWorkstationState.getFactoryMonth());
          workstationState.setFactoryWeek(suitableWorkstationState.getFactoryWeek());
          workstationState.setFactoryYear(suitableWorkstationState.getFactoryYear());
          workstationState.setIsFixPoint(suitableWorkstationState.getIsFixPoint());
          workstationState.setShiftIndex(suitableWorkstationState.getShiftIndex());
          workstationState.setShiftTimeType(suitableWorkstationState.getShiftTimeType());
          workstationState.setCalendarCode(suitableWorkstationState.getCalendarCode());
        } else {
        	/*
          WorkstationState resultTimePoint = stateMapper.getLastWorkstationState(Wrappers.<WorkstationState>lambdaQuery()
              .eq(WorkstationState::getWorkstationId, feedback.getWorkstationId())
              .le(WorkstationState::getTs, Long.valueOf(feedback.getEndTime().getTime()))
              .isNotNull(WorkstationState::getShiftIndex)
              .ne(WorkstationState::getIsDeleted, Boolean.TRUE));
          */
        	DeviceState resultTimePoint = stateMapper.getLastByWorkstationIdAndLeTimeAndShiftIndexNotNull(feedback.getWorkstationId(), feedback.getEndTime().getTime());
        	
	        if (Func.isNotEmpty(resultTimePoint)) {
	            workstationState.setFactoryYear(resultTimePoint.getFactoryYear());
	            workstationState.setFactoryMonth(resultTimePoint.getFactoryMonth());
	            workstationState.setFactoryWeek(resultTimePoint.getFactoryWeek());
	            workstationState.setFactoryDate(resultTimePoint.getFactoryDate());
	            workstationState.setShiftIndex(resultTimePoint.getShiftIndex());
	            workstationState.setShiftTimeType(resultTimePoint.getShiftTimeType());
	            workstationState.setCalendarCode(resultTimePoint.getCalendarCode());
	        } else {
	        	WorkstationService workstationService = SpringUtil.getBean(WorkstationService.class);
	            CalendarShiftInfoDTO calendarShiftInfo = workstationService.getCalendarShiftInfoForWorkstation(feedback.getWorkstationId(), feedback
	                .getEndTime());
	            workstationState.setFactoryYear(calendarShiftInfo.getFactoryYear());
	            workstationState.setCalendarCode(calendarShiftInfo.getCode());
	            workstationState.setFactoryDate(Integer.valueOf(calendarShiftInfo.getFactoryDate()));
	            workstationState.setFactoryWeek(calendarShiftInfo.getFactoryWeek());
	            workstationState.setFactoryMonth(calendarShiftInfo.getFactoryMonth());
	            workstationState.setShiftTimeType(calendarShiftInfo.getShiftTimeType());
	            workstationState.setShiftIndex(calendarShiftInfo.getShiftIndex());
	        } 
        } 
        return workstationState;
      }

    private DeviceState wrapperImmediateFeedbackStartTimePoint(WorkstationWcsFeedback feedback) {
    	DeviceState workstationState = new DeviceState();
        workstationState.setWorkstationId(feedback.getWorkstationId());
        workstationState.setWcs(Integer.valueOf(feedback.getWcs()));
        workstationState.setIsSync(false);
        workstationState.setFeedbackId(feedback.getId());
        workstationState.setValueCollect(Integer.valueOf(feedback.getWcs()));
        workstationState.setIsFixPoint(false);
        workstationState.setTime(feedback.getStartTime().getTime());
        workstationState.setIsDeleted(false);
        DeviceStateMapper stateMapper = SpringUtil.getBean(DeviceStateMapper.class);
        /*
        DeviceState suitableWorkstationState = stateMapper.selectOne(Wrappers.<WorkstationState>lambdaQuery()
            .eq(WorkstationState::getWorkstationId, feedback.getWorkstationId())
            .eq(WorkstationState::getIsFixPoint, Boolean.TRUE)
            .eq(WorkstationState::getTs, Long.valueOf(feedback.getStartTime().getTime())));
        */
        DeviceState suitableWorkstationState = stateMapper.getFixPointByWorkstationIdAndTime(feedback.getWorkstationId(), feedback.getStartTime().getTime());
        if (Func.isNotEmpty(suitableWorkstationState)) {
          workstationState.setIsFixPoint(true);
          workstationState.setFactoryDate(suitableWorkstationState.getFactoryDate());
          workstationState.setFactoryMonth(suitableWorkstationState.getFactoryMonth());
          workstationState.setFactoryWeek(suitableWorkstationState.getFactoryWeek());
          workstationState.setFactoryYear(suitableWorkstationState.getFactoryYear());
          workstationState.setIsFixPoint(suitableWorkstationState.getIsFixPoint());
          workstationState.setShiftTimeType(suitableWorkstationState.getShiftTimeType());
          workstationState.setCalendarCode(suitableWorkstationState.getCalendarCode());
        } 
        /*
        DeviceState resultTimePoint = stateMapper.getLastWorkstationState(Wrappers.<WorkstationState>lambdaQuery()
            .eq(WorkstationState::getWorkstationId, feedback.getWorkstationId())
            .le(WorkstationState::getTs, Long.valueOf(feedback.getStartTime().getTime()))
            .isNotNull(WorkstationState::getShiftIndex)
            .ne(WorkstationState::getIsDeleted, Boolean.TRUE));
        */
        DeviceState resultTimePoint = stateMapper.getLastByWorkstationIdAndLeTimeAndShiftIndexNotNull(feedback.getWorkstationId(), feedback.getStartTime().getTime());
        if (Func.isNotEmpty(resultTimePoint)) {
        	workstationState.setFactoryYear(resultTimePoint.getFactoryYear());
        	workstationState.setFactoryMonth(resultTimePoint.getFactoryMonth());
        	workstationState.setFactoryWeek(resultTimePoint.getFactoryWeek());
        	workstationState.setFactoryDate(resultTimePoint.getFactoryDate());
        	workstationState.setShiftIndex(resultTimePoint.getShiftIndex());
        	workstationState.setShiftTimeType(resultTimePoint.getShiftTimeType());
        	workstationState.setCalendarCode(resultTimePoint.getCalendarCode());
        } else {
        	WorkstationService workstationService = SpringUtil.getBean(WorkstationService.class);
        	CalendarShiftInfoDTO calendarShiftInfo = workstationService.getCalendarShiftInfoForWorkstation(feedback.getWorkstationId(), feedback
              .getStartTime());
        	workstationState.setFactoryYear(calendarShiftInfo.getFactoryYear());
        	workstationState.setCalendarCode(calendarShiftInfo.getCode());
        	workstationState.setFactoryDate(Integer.valueOf(calendarShiftInfo.getFactoryDate()));
        	workstationState.setFactoryWeek(calendarShiftInfo.getFactoryWeek());
        	workstationState.setFactoryMonth(calendarShiftInfo.getFactoryMonth());
        	workstationState.setShiftTimeType(calendarShiftInfo.getShiftTimeType());
        	workstationState.setShiftIndex(calendarShiftInfo.getShiftIndex());
        } 
        if (checkFeedbackStartTimeIsCrossPoint(feedback)) {
          workstationState.setFeedbackPointType(FeedbackTimePointEnum.CROSS_POINT.getValue());
        } else {
          workstationState.setFeedbackPointType(FeedbackTimePointEnum.START_POINT.getValue());
        }
        WorkstationCache workstationCache = SpringUtil.getBean(WorkstationCache.class);
        //GlobalWcsOfRps setting = WorkstationCache.getWorkstationWcsSetting(feedback.getWorkstationId(), feedback.getWcs());
        GlobalWcsOfRps setting = workstationCache.getWorkstationWcsSetting(feedback.getWorkstationId(), feedback.getWcs());
        workstationState.setRps(setting.getRps());
        workstationState.setIsPlan(setting.getIsPlan());
        return workstationState;
      }

    private boolean checkFeedbackStartTimeIsCrossPoint(WorkstationWcsFeedback feedback) {
        boolean result = false;
        List<WorkstationWcsFeedback> wcsFeedbackList = this.feedbackMapper.selectList(Wrappers.<WorkstationWcsFeedback>lambdaQuery()
            .eq(WorkstationWcsFeedback::getWorkstationId, feedback.getWorkstationId())
            .lt(WorkstationWcsFeedback::getFeedbackTime, feedback.getFeedbackTime())
            .eq(WorkstationWcsFeedback::getStatus, FeedbackProcessStatusEnum.COMPLETED.getValue())
            .orderByDesc(WorkstationWcsFeedback::getFeedbackTime));
        if (Func.isNotEmpty(wcsFeedbackList))
          return (((WorkstationWcsFeedback)wcsFeedbackList.get(0)).getEndTime().getTime() == feedback.getStartTime().getTime()); 
        return result;
      }

    public ImmediateFeedbackAnalyseResult analyse() {
        return this.result;
    }
}