package com.zy.core.operation.handler;

import com.core.common.DateUtils;
import com.zy.asrs.controller.vo.OpenBusSubmitParam;
import com.zy.asrs.controller.vo.TaskDto;
import com.zy.asrs.entity.Job;
import com.zy.asrs.service.CtuMainService;
import com.zy.asrs.service.JobService;
import com.zy.asrs.service.WrkLastnoService;
import com.zy.core.enums.ConveyorStateType;
import com.zy.core.operation.OperationHandler;
import com.zy.core.properties.CtuOperationConfig;
import com.zy.core.properties.SlaveProperties;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 模拟WMS
 */
@Slf4j
@Component
public class FakeWmsOperationHandler implements OperationHandler {

    @Autowired
    private SlaveProperties slaveProperties;


    @Autowired
    private WrkLastnoService wrkLastnoService;

    @Autowired
    private CtuMainService ctuMainService;

    @Autowired
    private JobService jobService;


    @Override
    public ConveyorStateType getType() {
        return ConveyorStateType.FAKEWMS;
    }

    @Override
    public void execute(CtuOperationConfig config) {
        List<Job> jobs = jobService.listJobByJobSts(5);
        for (Job job : jobs) {
            OpenBusSubmitParam openBusSubmitParam = new OpenBusSubmitParam();
            openBusSubmitParam.setBatch(DateUtils.convert(new Date()));
            List<TaskDto> taskList = new ArrayList<>();
            TaskDto taskDto = new TaskDto();
            taskDto.setSeqNum("SSX-RK" + job.getJobNo());
            taskDto.setOriSta("1007");
            taskDto.setPriority(9527);
            taskList.add(taskDto);
            openBusSubmitParam.setTaskList(taskList);
            boolean b = ctuMainService.sendTask(openBusSubmitParam);
            if (b) {
                job.setJobSts(6);
                job.setRcsTime(new Date());
                jobService.updateById(job);
                log.info("任务发送给RCS成功," + job.getSeqNum() + " - " + job.getJobNo());
            } else {
                log.info("任务发送给RCS失败," + job.getSeqNum() + " - " + job.getJobNo());
            }
        }
    }
}