package com.zy.asrs.wms.apis.wcs.services.Impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.zy.asrs.framework.common.R;
import com.zy.asrs.wms.apis.wcs.entity.domain.EssTaskStatus;
import com.zy.asrs.wms.apis.wcs.entity.request.*;
import com.zy.asrs.wms.apis.wcs.entity.response.CommonReponse;
import com.zy.asrs.wms.apis.wcs.services.WcsApiService;
import com.zy.asrs.wms.asrs.entity.Task;
import com.zy.asrs.wms.asrs.entity.WaitPakin;
import com.zy.asrs.wms.asrs.entity.enums.TaskStsType;
import com.zy.asrs.wms.asrs.service.TaskService;
import com.zy.asrs.wms.asrs.service.WaitPakinService;
import com.zy.asrs.wms.asrs.service.WorkService;
import io.jsonwebtoken.lang.Collections;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Service
public class WcsApiServiceImpl implements WcsApiService {

    @Autowired
    private WaitPakinService waitPakinService;
    @Autowired
    private WorkService workService;
    @Autowired
    private TaskService taskService;

    @Override
    public CommonReponse publishTaskOfCarry() {
        //获取组拖通知档中，状态为正常，组托状态为待入库且未删除的WaitPakins
        List<WaitPakin> list = waitPakinService.list(new LambdaQueryWrapper<WaitPakin>()
                .eq(WaitPakin::getStatus, 1)
                .eq(WaitPakin::getIoStatus, 0)
                .eq(WaitPakin::getDeleted, 0));
        if (!list.isEmpty()) {
            return publishTaskOfCarry(list);
        }
        return new CommonReponse();
    }

    /**
     * 下发料箱（容器）滚动至扫码区
     * //TODO 已费弃
     *
     * @param pakins
     * @return
     */
    @Override
    public CommonReponse publishTaskOfCarry(List<WaitPakin> pakins) {
        PublishTasksParam tasksParam = new PublishTasksParam();
        tasksParam.setTaskType("carry");
        List<TaskParam> tasks = new ArrayList<>();
        Map<String, List<WaitPakin>> barcodes = pakins.stream().collect(Collectors.groupingBy(WaitPakin::getBarcode));
        /**
         * 当前问题：
         * //TODO 1. 目前任务下发接口沟通下来，是需要目标位置的，这里我们只是刚组拖完成，并不是通知流动，没有目标位置
         * //TODO 2. 文档上的搬运任务下发指的都是多任务，多容器搬运，而不是我们需要物料信息同步功能
         * //TODO 3. 流程走不通暂时先跳过，确认是否需要WMS触发料箱滚动至扫码区
         * */
        barcodes.keySet().forEach(actionKey -> {
            List<TaskDescribe> taskDescribes = new ArrayList<>();
            barcodes.get(actionKey).forEach(action -> {
                TaskDescribe taskDescribe = new TaskDescribe();
                taskDescribe.setContainerCode(action.getBarcode());
                taskDescribes.add(taskDescribe);
            });
        });

        if (!pakins.isEmpty()) {
            pakins.forEach(waitPakin -> {

            });
        }
        tasksParam.setTasks(tasks);

        return null;
    }


    /**
     * 容器到达接收
     * 根据ESS返回的容器编码修改任务档中的输送线起始位置节点，及任务档执行状态
     * @param arrivedParam
     * @return
     */
    @Override
    @Transactional
    public R containerArrivedNotify(ContainerArrivedParam arrivedParam) {
        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getBarcode, arrivedParam.getContainerCode()));
        if (!Collections.isEmpty(tasks)) {
            return R.error("任务不存在！！");
//            throw new CoolException("任务不存在！！");
        }

        //DONE 根据ESS返回的容器编码修改任务档中的输送线起始位置节点，及任务档容器到达状态
        taskService.update(new LambdaUpdateWrapper<Task>()
                .set(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id)
                .set(Task::getOriginLoc, arrivedParam.getSlotCode())
                .eq(Task::getBarcode, arrivedParam.getContainerCode()));

        return R.success("success");
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean receiveTaskStatus(TasksStatusCallbackParam callbackParam) {
        TaskStsType taskStsType = TaskStsType.WCS_CONTAINER_RECEIVE;

       if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //上报取箱状态
           taskStsType = TaskStsType.WCS_TOTE_LOAD;
        } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_UNLOAD.event)) { //上报放箱状态
           taskStsType = TaskStsType.WCS_TOTE_UNLOAD;
        } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //TODO 需确认上报任务中，任务完成是哪个事件，目前暂定task事件
           taskStsType = TaskStsType.WCS_PUTAWAY_SUCESS;
       }

        return taskService.update(new LambdaUpdateWrapper<Task>()
                .set(Task::getRobotCode, callbackParam.getRobotCode())
                .set(Task::getSysTaskCode, callbackParam.getSysTaskCode())
                .set(Task::getTaskSts, taskStsType.id)
                .set(Task::getExcudeStatus, callbackParam.getStatus())
                .set(Task::getTaskDesc, callbackParam.getMessage())
                .eq(Task::getBarcode, callbackParam.getContainerCode())
                .eq(Task::getTaskNo, callbackParam.getTaskCode()));
    }


}