package com.zy.asrs.wms.asrs.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.zy.asrs.framework.exception.CoolException;
import com.zy.asrs.wms.asrs.entity.*;
import com.zy.asrs.wms.asrs.entity.enums.CacheSiteStatusType;
import com.zy.asrs.wms.asrs.entity.enums.TaskStsType;
import com.zy.asrs.wms.asrs.entity.param.SeedCompleteParam;
import com.zy.asrs.wms.asrs.mapper.CacheSiteMapper;
import com.zy.asrs.wms.asrs.service.*;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;

@Service("cacheSiteService")
public class CacheSiteServiceImpl extends ServiceImpl<CacheSiteMapper, CacheSite> implements CacheSiteService {

    @Autowired
    private OrderService orderService;
    @Autowired
    private OrderDetlService orderDetlService;
    @Autowired
    private WaveSeedService waveSeedService;
    @Autowired
    private WaveSeedLogService waveSeedLogService;
    @Autowired
    private TaskService taskService;
    @Autowired
    private TaskDetlService taskDetlService;
    @Autowired
    private PlatformService platformService;
    @Autowired
    private PlatformDetlService platformDetlService;


    @Override
    public List<String> getChannelList() {
        return this.baseMapper.getChannelList();
    }

    @Override
    public boolean seedCompletePreview(SeedCompleteParam param) {
        if (param == null) {
            throw new CoolException("参数不能为空");
        }

        String siteNo = param.getSiteNo();
        if (siteNo == null) {
            throw new CoolException("播种站点编号不能为空");
        }

        CacheSite cacheSite = this.getOne(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getSiteNo, siteNo));
        if(cacheSite == null){
            throw new CoolException("播种站点不存在");
        }

        if (cacheSite.getSiteStatus().equals(CacheSiteStatusType.O.id)) {
            throw new CoolException("站点状态异常");
        }

        Long orderId = cacheSite.getOrderId();
        Order order = orderService.getById(orderId);
        if (order == null) {
            throw new CoolException("订单不存在");
        }

        HashMap<Long, Double> stockMap = new HashMap<>();
        List<WaveSeed> waveSeeds = waveSeedService.list(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getOrderId, orderId));
        for (WaveSeed waveSeed : waveSeeds) {
            Double anfme = stockMap.get(waveSeed.getOrderDetlId());
            if (anfme == null) {
                anfme = 0.0D;
            }
            anfme += waveSeed.getWorkQty();
            stockMap.put(waveSeed.getOrderDetlId(), anfme);
        }

        List<OrderDetl> orderDetls = orderDetlService.getOrderDetlByOrderId(orderId);
        boolean check = true;
        for (OrderDetl orderDetl : orderDetls) {
            Double anfme = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D);
            Double workQty = stockMap.get(orderDetl.getId());
            if (!anfme.equals(workQty)) {
                check = false;
                break;
            }
        }

        return check;
    }

    @Override
    public void seedComplete(SeedCompleteParam param) {
        if (param == null) {
            throw new CoolException("参数不能为空");
        }

        String siteNo = param.getSiteNo();
        if (siteNo == null) {
            throw new CoolException("播种站点编号不能为空");
        }

        CacheSite cacheSite = this.getOne(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getSiteNo, siteNo));
        if(cacheSite == null){
            throw new CoolException("播种站点不存在");
        }

        if (cacheSite.getSiteStatus().equals(CacheSiteStatusType.O.id)) {
            throw new CoolException("站点状态异常");
        }

        if (cacheSite.getPlatformId() == null) {
            throw new CoolException("集货区域未绑定");
        }

        Long orderId = cacheSite.getOrderId();
        Order order = orderService.getById(orderId);
        if (order == null) {
            throw new CoolException("订单不存在");
        }
        Long waveId = order.getWaveId();

        boolean check = this.seedCompletePreview(param);
        if (!check) {//订单未处理完成
            List<Long> taskIds = new ArrayList<>();
            List<TaskDetl> taskDetls = taskDetlService.list(new LambdaQueryWrapper<TaskDetl>().eq(TaskDetl::getWaveId, waveId));
            for (TaskDetl taskDetl : taskDetls) {
                if(!taskIds.contains(taskDetl.getTaskId())){
                    taskIds.add(taskDetl.getTaskId());
                }
            }

            if (!taskIds.isEmpty()) {
                List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().in(Task::getId, taskIds).notIn(Task::getTaskSts, TaskStsType.COMPLETE_OUT.id, TaskStsType.UPDATED_OUT.id));
                if (!tasks.isEmpty()) {
                    throw new CoolException("存在未完成任务");
                }
            }
        }

        Platform platform = platformService.getById(cacheSite.getPlatformId());
        if(platform == null){
            throw new CoolException("集货区域不存在");
        }

        List<WaveSeed> waveSeeds = waveSeedService.list(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getOrderId, orderId));
        if (waveSeeds.isEmpty()) {
            throw new CoolException("播种数据不存在");
        }

        for (WaveSeed waveSeed : waveSeeds) {
            PlatformDetl platformDetl = new PlatformDetl();
            platformDetl.setPlatformId(platform.getId());
            platformDetl.setPlatformNo(platform.getPlatformNo());
            platformDetl.setOrderId(orderId);
            platformDetl.setOrderDetlId(waveSeed.getOrderDetlId());
            platformDetl.setTaskDetlId(waveSeed.getTaskDetlId());
            platformDetl.setMatnr(waveSeed.getMatnr());
            platformDetl.setBatch(waveSeed.getBatch());
            platformDetl.setFieldParams(waveSeed.getFieldParams());
            platformDetl.setAnfme(waveSeed.getAnfme());
            platformDetl.setQty(waveSeed.getWorkQty());

            if (!platformDetlService.save(platformDetl)) {
                throw new CoolException("集货区域库存插入失败");
            }


            WaveSeedLog waveSeedLog = new WaveSeedLog();
            waveSeedLog.sync(waveSeed);
            waveSeedLog.setId(null);
            if (!waveSeedLogService.save(waveSeedLog)) {
                throw new CoolException("播种数据转历史失败");
            }

            if (!waveSeedService.removeById(waveSeed.getId())) {
                throw new CoolException("播种数据删除失败");
            }
        }

        cacheSite.setSiteStatus(CacheSiteStatusType.O.id);
        cacheSite.setOrderId(null);
        cacheSite.setOrderNo(null);
        cacheSite.setPlatformId(null);
        cacheSite.setPlatformNo(null);
        cacheSite.setUpdateTime(new Date());
        if (!this.updateById(cacheSite)) {
            throw new CoolException("更新播种站点数据失败");
        }

    }
}