package com.zy.asrs.service.impl;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.core.common.Cools;
import com.zy.asrs.entity.ManLocDetl;
import com.zy.asrs.entity.Mat;
import com.zy.asrs.entity.Node;
import com.zy.asrs.entity.param.LocDetlAdjustParam;
import com.zy.asrs.entity.result.StockVo;
import com.zy.asrs.mapper.ManLocDetlMapper;
import com.zy.asrs.service.ManLocDetlService;
import com.zy.asrs.service.MatService;
import com.zy.asrs.service.NodeService;
import com.zy.asrs.service.WaitPakinService;
import com.zy.asrs.utils.SaasUtils;
import com.zy.asrs.utils.Utils;
import com.zy.common.model.LocDto;
import com.zy.system.entity.User;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.*;

@Service("manLocDetlService")
public class ManLocDetlServiceImpl extends ServiceImpl<ManLocDetlMapper, ManLocDetl> implements ManLocDetlService {
    @Autowired
    private MatService matService;
    @Autowired
    private NodeService nodeService;
    @Autowired
    private WaitPakinService waitPakinService;

    @Override
    public Page<ManLocDetl> getPage(Page<ManLocDetl> page) {
        Map<String, Object> condition = page.getCondition();
        List<ManLocDetl> manLocDetls = baseMapper.listByPage(condition);
        page.setRecords(manLocDetls);
        page.setTotal(baseMapper.listByPageCount(page.getCondition()));
        return page;
    }

    @Override
    public Page<ManLocDetl> getStockOut(Page<ManLocDetl> page) {
        page.setRecords(baseMapper.getStockOutPage(page.getCondition()));
        page.setTotal(baseMapper.getStockOutPageCount(page.getCondition()));
        return page;
    }

    @Override
    public boolean updateAnfme(Double anfme, String locNo, String matnr, String batch) {
        if (anfme <= 0) {
            return this.baseMapper.deleteItem(locNo, matnr, batch) > 0;
        } else {
            return baseMapper.updateAnfme(anfme, locNo, matnr, batch) > 0;
        }
    }


    @Override
    public boolean updateLocNo(String newLocNo, String oldLocNo) {
        return baseMapper.updateLocNo(newLocNo, oldLocNo) > 0;
    }

    @Override
    public List<String> getSameDetlToday(String matnr, Integer start, Integer end) {
        return this.baseMapper.selectSameDetlToday(matnr, start, end);
    }


    @Override
    public Page<ManLocDetl> getStockStatis(Page<ManLocDetl> page) {
        page.setRecords(baseMapper.getStockStatis(page.getCondition()));
        page.setTotal(baseMapper.getStockStatisCount(page.getCondition()));
        return page;
    }

    @Override
    public Double getSumAnfme(String matnr) {
        return this.baseMapper.selectSumAnfmeByMatnr(matnr);
    }

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

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

    @Override
    public Integer countLocNoNum(String locNo) {
        return this.baseMapper.countLocNoNum(locNo);
    }

    @Override
    public List<ManLocDetl> queryStock(String matnr, String batch, String orderNo, Set<String> locNos) {
        return this.baseMapper.queryStock(matnr, batch, orderNo, locNos);
    }

    @Override
    public Double queryStockAnfme(String matnr, String batch) {
        return this.baseMapper.queryStockAnfme(matnr, batch);
    }

    @Override
    public List<StockVo> queryStockTotal() {
        return this.baseMapper.queryStockTotal();
    }

    /**
     * 获取库存总数
     *
     * @return
     */
    @Override
    public Integer sum() {

        return this.baseMapper.sum();
    }

    @Override
    public List<ManLocDetl> unreason() {
        return this.baseMapper.unreason();
    }


    @Override
    public ManLocDetl selectItem(String locNo, String matnr, String batch, String csocode, String isoseq, String containerCode) {
        return this.baseMapper.selectItem(locNo, matnr, batch,csocode,isoseq,containerCode);
    }

    @Override
    public Double getLocDetlSumQty(String locNo) {
        return this.baseMapper.selectLocDetlSumQty(locNo);
    }

    @Override
    public Page<ManLocDetl> getOutPage(Page<ManLocDetl> manLocDetlPage) {
        Map<String, Object> condition = manLocDetlPage.getCondition();
        List<ManLocDetl> manLocDetls = baseMapper.listByOutPage(condition);
        manLocDetlPage.setRecords(manLocDetls);
        manLocDetlPage.setTotal(baseMapper.listByOutPageCount(manLocDetlPage.getCondition()));
        return manLocDetlPage;
    }

    @Transactional
    @Override
    public void adjustLocDetl(LocDetlAdjustParam param, Long userId, User user) {
        Date now = new Date();
        List<ManLocDetl> manLocDetls = this.selectList(new EntityWrapper<ManLocDetl>().eq("loc_no", param.getLocNo()));
        for (ManLocDetl manLocDetl : manLocDetls){
            Wrapper<ManLocDetl> wrapper = new EntityWrapper<ManLocDetl>().eq("loc_no", param.getLocNo());
            wrapper.eq("matnr",manLocDetl.getMatnr());
            Utils.wapperSetCondition(wrapper,"container_code",manLocDetl.getContainerCode());
            Utils.wapperSetCondition(wrapper,"batch",manLocDetl.getBatch());
            Utils.wapperSetCondition(wrapper,"csocode",manLocDetl.getCsocode());
            Utils.wapperSetCondition(wrapper,"isoseq",manLocDetl.getIsoseq());

            boolean existFlag = false;
            for (LocDetlAdjustParam.LocDetlAdjust locDetlAdjust : param.getList()){
                if(Cools.eq(manLocDetl.getMatnr(),locDetlAdjust.getMatnr())
                        && Cools.eq(manLocDetl.getContainerCode(),locDetlAdjust.getSuppCode())
                        && Cools.eq(manLocDetl.getBatch(),locDetlAdjust.getBatch())
                        && Cools.eq(manLocDetl.getCsocode(),locDetlAdjust.getThreeCode())
                        && Cools.eq(manLocDetl.getIsoseq(),locDetlAdjust.getDeadTime())){
                    if(!locDetlAdjust.getCount().equals(manLocDetl.getAnfme())){
                        manLocDetl.setAnfme(locDetlAdjust.getCount());
                        manLocDetl.setModiTime(now);
                        this.update(manLocDetl,wrapper);
                        SaasUtils.insertLog(3,manLocDetl.getLocNo(), manLocDetl.getMatnr(),manLocDetl.getAnfme(),user.getUsername());
                    }
                    existFlag = true;
                }
            }
            if(!existFlag){
                this.delete(wrapper);
                SaasUtils.insertLog(3,manLocDetl.getLocNo(), manLocDetl.getMatnr(),0.0,user.getUsername());

            }
        }

        for (LocDetlAdjustParam.LocDetlAdjust locDetlAdjust : param.getList()){
            Wrapper<ManLocDetl> wrapper = new EntityWrapper<ManLocDetl>().eq("loc_no", param.getLocNo());
            wrapper.eq("matnr",locDetlAdjust.getMatnr());
            Utils.wapperSetCondition(wrapper,"container_code",locDetlAdjust.getSuppCode());
            Utils.wapperSetCondition(wrapper,"batch",locDetlAdjust.getBatch());
            Utils.wapperSetCondition(wrapper,"csocode",locDetlAdjust.getThreeCode());
            Utils.wapperSetCondition(wrapper,"isoseq",locDetlAdjust.getDeadTime());

            boolean existFlag = false;
            for (ManLocDetl manLocDetl : manLocDetls){
                if(Cools.eq(manLocDetl.getMatnr(),locDetlAdjust.getMatnr())
                        && Cools.eq(manLocDetl.getContainerCode(),locDetlAdjust.getSuppCode())
                        && Cools.eq(manLocDetl.getBatch(),locDetlAdjust.getBatch())
                        && Cools.eq(manLocDetl.getCsocode(),locDetlAdjust.getThreeCode())
                        && Cools.eq(manLocDetl.getIsoseq(),locDetlAdjust.getDeadTime())){
                    if(!locDetlAdjust.getCount().equals(manLocDetl.getAnfme())){
                        manLocDetl.setAnfme(locDetlAdjust.getCount());
                        manLocDetl.setModiTime(now);
                        this.update(manLocDetl,wrapper);
                        SaasUtils.insertLog(3,manLocDetl.getLocNo(), manLocDetl.getMatnr(),manLocDetl.getAnfme(),user.getUsername());
                    }
                    existFlag = true;
                }
            }
            if(!existFlag){
                ManLocDetl manLocDetl = addManlocDetl(locDetlAdjust, param.getLocNo());
                SaasUtils.insertLog(3,manLocDetl.getLocNo(), manLocDetl.getMatnr(),0.0,user.getUsername());

            }
        }


//        for (LocDetlAdjustParam.LocDetlAdjust locDetlAdjust : param.getList()) {
//
//            ManLocDetl manLocDetl = this.baseMapper.selectItem(param.getLocNo(), locDetlAdjust.getMatnr(), locDetlAdjust.getBatch(),locDetlAdjust.getThreeCode(),locDetlAdjust.getDeadTime(),locDetlAdjust.getSuppCode());
//
//            if(Cools.isEmpty(manLocDetl)){
//                addManlocDetl(locDetlAdjust,param.getLocNo());
//                continue;
//            }
//            Wrapper<ManLocDetl> wrapper = new EntityWrapper<ManLocDetl>().eq("loc_no", param.getLocNo()).eq("matnr", locDetlAdjust.getMatnr());
//            Utils.wapperSetCondition(wrapper,"container_code",manLocDetl.getContainerCode());
//            Utils.wapperSetCondition(wrapper,"csocode",manLocDetl.getCsocode());
//            Utils.wapperSetCondition(wrapper,"isoseq",manLocDetl.getIsoseq());
//            Utils.wapperSetCondition(wrapper,"batch",manLocDetl.getBatch());
//            this.baseMapper.delete(wrapper);
//            Mat mat = matService.selectOne(new EntityWrapper<Mat>()
//                    .eq("matnr", locDetlAdjust.getMatnr()));
//            if (mat == null) {
//                throw new CoolException("无法找到需要调整的物料,请联系管理员");
//            }
//            Node node = nodeService.selectOne(new EntityWrapper<Node>()
//                    .eq("uuid", param.getLocNo()));
//            if (node == null) {
//                throw new CoolException("无法找到需要调整的库位,请联系管理员");
//
//            }
//            manLocDetl.setAnfme(locDetlAdjust.getCount());
//            manLocDetl.setUpdateBy(userId);
//            manLocDetl.setModiTime(now);
//            SaasUtils.insertLog(3,manLocDetl.getLocNo(), manLocDetl.getMatnr(),manLocDetl.getAnfme(),user.getUsername());
//            this.baseMapper.insert(manLocDetl);
//        }
    }

    @Override
    public Page<ManLocDetl> selectAllPage(Page<ManLocDetl> param) {
        Map<String, Object> condition = param.getCondition();
        List<ManLocDetl> manLocDetls = baseMapper.selectAllPage(condition);
        param.setRecords(manLocDetls);
        param.setTotal(baseMapper.selectAllPageSize(condition));
        return param;
    }

    @Override
    public ManLocDetl selectInventory(String LocNo, String Matnr, String batch) {
        return baseMapper.selectInventory(LocNo,Matnr,batch);
    }

    @Override
    public int deleteDatailed(String locNo, String matnr, String batch) {
        return baseMapper.deleteDatailed(locNo,matnr,batch);
    }

    @Override
    public int increase(Double anfme,String locNo, String matnr, String batch,Double weight) {
        return baseMapper.increase(anfme,locNo,matnr,batch,weight);
    }

    public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq) {
        Wrapper<ManLocDetl> wrapper = new EntityWrapper<ManLocDetl>().eq("matnr", matnr).orderBy("modi_time");
        wrapper.eq("status",1);
        wapperSetCondition(wrapper,"batch",batch);
        wapperSetCondition(wrapper,"csocode",csocode);
        wapperSetCondition(wrapper,"isoseq",isoseq);

        List<ManLocDetl> manLocDetls = this.selectList(wrapper);
        for (ManLocDetl manLocDetl : manLocDetls){
            if(issued > 0) {
                double anfme = manLocDetl.getAnfme();
                anfme = anfme > issued ? issued : anfme;
                LocDto locDto = new LocDto(manLocDetl.getLocNo(), manLocDetl.getMatnr(), manLocDetl.getMaktx(), manLocDetl.getBatch(), orderNo, anfme);
                locDto.setCsocode(csocode);
                locDto.setIsoseq(isoseq);
                locDto.setContainerCode(manLocDetl.getContainerCode());
                List<String> stationList = new ArrayList<>();
                stationList.add("无需站点");
                locDto.setAgvStaNos(stationList);

                locDtoList.add(locDto);
                issued -= anfme;
            }
        }

        return issued;
    }

    private void wapperSetCondition(Wrapper wrapper,String column, String condition){
        if(Cools.isEmpty(condition)){
            wrapper.andNew().eq(column,"").or().isNull(column);
        }else {
            wrapper.andNew().eq(column,condition);
        }
    }

    private ManLocDetl addManlocDetl(LocDetlAdjustParam.LocDetlAdjust param, String locNo){
        Date now = new Date();
        ManLocDetl manLocDetl = new ManLocDetl();
        Node node = nodeService.selectOne(new EntityWrapper<Node>().eq("name", locNo));
        Mat mat = matService.selectByMatnr(param.getMatnr());
        BeanUtils.copyProperties(mat,manLocDetl);
        manLocDetl.setNodeId(node.getId());
        manLocDetl.setBatch(param.getBatch());
        manLocDetl.setAnfme(param.getCount());
        manLocDetl.setContainerCode(param.getSuppCode());
        manLocDetl.setCsocode(param.getThreeCode());
        manLocDetl.setIsoseq(param.getDeadTime());
        manLocDetl.setCreateTime(now);
        manLocDetl.setModiTime(now);
        manLocDetl.setLocNo(locNo);
        manLocDetl.setStatus(1);
        this.insert(manLocDetl);

        return manLocDetl;
    }

}