package doumeemes.service.ext.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import doumeemes.core.constants.ResponseStatus;
import doumeemes.core.exception.BusinessException;
import doumeemes.core.model.LoginUserInfo;
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Constants;
import doumeemes.dao.business.WOutboundDetailMapper;
import doumeemes.dao.business.WStockMapper;
import doumeemes.dao.business.WarehouseMapper;
import doumeemes.dao.business.model.*;
import doumeemes.dao.ext.WOutboundDetailExtMapper;
import doumeemes.dao.ext.dto.QueryWStockRecordExtDTO;
import doumeemes.dao.ext.vo.WStockRecordExtListVO;
import doumeemes.service.ext.WStockRecordExtService;
import doumeemes.dao.ext.WStockRecordExtMapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.apache.commons.lang3.StringUtils;
import org.apache.xpath.operations.String;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.Objects;

/**
 * 物料库存余额变动记录表ExtService实现
 * @author 江蹄蹄
 * @date 2022/09/23 14:39
 */
@Service
public class WStockRecordExtServiceImpl implements WStockRecordExtService {

    @Autowired
    private WStockRecordExtMapper wStockRecordExtMapper;
    @Autowired
    private WOutboundDetailMapper wOutboundDetailMapper;
    @Autowired
    private WarehouseMapper warehouseMapper;
    @Autowired
    private WStockMapper wStockMapper;

    @Override
    public void insertWStockRecord(WStockRecord wStockRecord){
        wStockRecordExtMapper.insert(wStockRecord);
    }

    @Override
    public PageData<WStockRecordExtListVO> findPage(PageWrap<QueryWStockRecordExtDTO> pageWrap) {
        PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity());
        List<WStockRecordExtListVO> result = wStockRecordExtMapper.selectList(pageWrap.getModel());
        return PageData.from(new PageInfo<>(result));
    }


    /**
     * 库存变动记录通用类
     * @param optType 操作类别：0 - 出库 ；1 入库
     * @param detailId 操作行项目主键
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void saveRecord(Integer optType, Integer detailId, LoginUserInfo userInfo){
        WOutboundDetail wOutboundDetail = wOutboundDetailMapper.selectById(detailId);
        Warehouse warehouse =warehouseMapper.selectById(wOutboundDetail.getWarehouseId());
        QueryWrapper wrapper = new QueryWrapper<WStock>();
        wrapper.eq("ROOT_DEPART_ID", wOutboundDetail.getRootDepartId());
        wrapper.eq("MATERIAL_ID", wOutboundDetail.getMaterialId());
        wrapper.eq("WAREHOUSE_ID", wOutboundDetail.getWarehouseId());
        wrapper.eq("QUALITY_TYPE", wOutboundDetail.getQualityType());
        wrapper.eq(!Objects.isNull(wOutboundDetail.getProcedureId()),"procedure_id",wOutboundDetail.getProcedureId());
        wrapper.apply(Objects.isNull(wOutboundDetail.getProcedureId())," procedure_id is null ");
        if(StringUtils.isNotBlank(wOutboundDetail.getBatch())){
            wrapper.eq("BATCH" , wOutboundDetail.getBatch());
        }else{
            wrapper.apply("BATCH is null ");
        }
        wrapper.eq(!Objects.isNull(wOutboundDetail.getLocationId())&&warehouse.getUseLocation()==Constants.ONE,"LOCATION_ID", wOutboundDetail.getLocationId());
        wrapper.eq("DELETED",0);
        WStock wStock = new WStock();
        List<WStock> wStockList = wStockMapper.selectList(wrapper);
        if(optType==Constants.ZERO){
            if(Objects.isNull(wStockList)||wStockList.size()==Constants.ZERO){
                throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "库存信息异常：【" + warehouse.getId() + "】 - 【" + wOutboundDetail.getLocationId() + "】 - 【" + wOutboundDetail.getMaterialId() + "】- 【" + wOutboundDetail.getBatch() + "】");
            }else{
                wStock = wStockList.get(0);
            }
        }else{
            if(Objects.isNull(wStockList)||wStockList.size()==Constants.ZERO){
                WStock newWStock = new WStock();
                newWStock.setCreateTime(new Date());
                newWStock.setCreateUser(userInfo.getId());
                newWStock.setRootDepartId(wOutboundDetail.getRootDepartId());
                newWStock.setWarehouseId(wOutboundDetail.getWarehouseId());
                newWStock.setQualityType(wOutboundDetail.getQualityType());
                if(!Objects.isNull(wOutboundDetail.getProcedureId())){
                    newWStock.setProcedureId(wOutboundDetail.getProcedureId());
                }
                //此仓库 开启仓位
                if(warehouse.getUseLocation()==Constants.ONE){
                    newWStock.setLocationId(wOutboundDetail.getLocationId());
                }
                newWStock.setMaterialId(wOutboundDetail.getMaterialId());
                newWStock.setBatch(wOutboundDetail.getBatch());
                newWStock.setUnitId(wOutboundDetail.getUnitId());
                newWStock.setNum(BigDecimal.ZERO);
                wStockMapper.insert(newWStock);
                wStock = newWStock;
            }else{
                wStock = wStockList.get(0);
            }
        }
        WStockRecord wStockRecord = new WStockRecord();
        wStockRecord.setId(null);
        wStockRecord.setDeleted(wStock.getDeleted());
        wStockRecord.setCreateUser(userInfo.getId());
        wStockRecord.setCreateTime(new Date());
        wStockRecord.setRootDepartId(wStock.getRootDepartId());
        wStockRecord.setDepartId(warehouse.getDepartId());
        wStockRecord.setMaterialId(wStock.getMaterialId());
        wStockRecord.setUnitId(wStock.getUnitId());
        wStockRecord.setLocationId(wStock.getLocationId());
        wStockRecord.setWarehouseId(wStock.getWarehouseId());
        if(StringUtils.isNotBlank(wStock.getBatch())){
            wStockRecord.setBatch(wStock.getBatch());
        }
        if(!Objects.isNull(wStock.getProcedureId())){
            wStockRecord.setProcedureId(wStock.getProcedureId());
        }
        wStockRecord.setQualityType(wStock.getQualityType());
        wStockRecord.setChangeType(optType);
        wStockRecord.setNum(wOutboundDetail.getDoneNum());
        wStockRecord.setBeforNum(wStock.getNum());
        if(optType == Constants.ZERO){
            wStockRecord.setAfterNum(wStock.getNum().subtract(wOutboundDetail.getDoneNum()));
        }else{
            wStockRecord.setAfterNum(wStock.getNum().add(wOutboundDetail.getDoneNum()));
        }
        wStockRecord.setDetailId(detailId);
        wStockRecord.setOutboundId(wOutboundDetail.getOutboundId());
        wStockRecord.setWStockId(wStock.getId());
        this.wStockRecordExtMapper.insert(wStockRecord);
    }


    /**
     * 库存变动记录(记录无货位)通用类
     * @param optType 操作类别：0 - 出库 ；1 入库
     * @param detailId 操作行项目主键
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void saveRecordNoLocationId(Integer optType, Integer detailId, LoginUserInfo userInfo,Integer locationId){
        WOutboundDetail wOutboundDetail = wOutboundDetailMapper.selectById(detailId);
        Warehouse warehouse =warehouseMapper.selectById(wOutboundDetail.getWarehouseId());
        QueryWrapper wrapper = new QueryWrapper<WStock>();
        wrapper.eq("ROOT_DEPART_ID", wOutboundDetail.getRootDepartId());
        wrapper.eq("MATERIAL_ID", wOutboundDetail.getMaterialId());
        wrapper.eq("WAREHOUSE_ID", wOutboundDetail.getWarehouseId());
        wrapper.eq("QUALITY_TYPE", wOutboundDetail.getQualityType());
        wrapper.eq(!Objects.isNull(wOutboundDetail.getProcedureId()),"procedure_id",wOutboundDetail.getProcedureId());
        wrapper.apply(Objects.isNull(wOutboundDetail.getProcedureId())," procedure_id is null ");
        if(StringUtils.isNotBlank(wOutboundDetail.getBatch())){
            wrapper.eq("BATCH" , wOutboundDetail.getBatch());
        }else{
            wrapper.apply("BATCH is null ");
        }
        wrapper.eq(!Objects.isNull(locationId)&&warehouse.getUseLocation()==Constants.ONE,"LOCATION_ID", locationId);
        wrapper.eq("DELETED",0);
        WStock wStock = new WStock();
        List<WStock> wStockList = wStockMapper.selectList(wrapper);
        if(optType==Constants.ZERO){
            if(Objects.isNull(wStockList)||wStockList.size()==Constants.ZERO){
                throw new BusinessException(ResponseStatus.OBJECT_EMP.getCode(), "库存信息异常：【" + warehouse.getId() + "】 - 【" + locationId + "】 - 【" + wOutboundDetail.getMaterialId() + "】- 【" + wOutboundDetail.getBatch() + "】");
            }else{
                wStock = wStockList.get(0);
            }
        }else{
            if(Objects.isNull(wStockList)||wStockList.size()==Constants.ZERO){
                WStock newWStock = new WStock();
                newWStock.setCreateTime(new Date());
                newWStock.setCreateUser(userInfo.getId());
                newWStock.setRootDepartId(wOutboundDetail.getRootDepartId());
                newWStock.setWarehouseId(wOutboundDetail.getWarehouseId());
                newWStock.setQualityType(wOutboundDetail.getQualityType());
                if(!Objects.isNull(wOutboundDetail.getProcedureId())){
                    newWStock.setProcedureId(wOutboundDetail.getProcedureId());
                }
                //此仓库 开启仓位
                if(warehouse.getUseLocation()==Constants.ONE){
                    newWStock.setLocationId(locationId);
                }
                newWStock.setMaterialId(wOutboundDetail.getMaterialId());
                newWStock.setBatch(wOutboundDetail.getBatch());
                newWStock.setUnitId(wOutboundDetail.getUnitId());
                newWStock.setNum(BigDecimal.ZERO);
                wStockMapper.insert(newWStock);
                wStock = newWStock;
            }else{
                wStock = wStockList.get(0);
            }
        }
        WStockRecord wStockRecord = new WStockRecord();
        wStockRecord.setId(null);
        wStockRecord.setDeleted(wStock.getDeleted());
        wStockRecord.setCreateUser(userInfo.getId());
        wStockRecord.setCreateTime(new Date());
        wStockRecord.setRootDepartId(wStock.getRootDepartId());
        wStockRecord.setDepartId(warehouse.getDepartId());
        wStockRecord.setMaterialId(wStock.getMaterialId());
        wStockRecord.setUnitId(wStock.getUnitId());
        wStockRecord.setLocationId(wStock.getLocationId());
        wStockRecord.setWarehouseId(wStock.getWarehouseId());
        if(StringUtils.isNotBlank(wStock.getBatch())){
            wStockRecord.setBatch(wStock.getBatch());
        }
        if(!Objects.isNull(wStock.getProcedureId())){
            wStockRecord.setProcedureId(wStock.getProcedureId());
        }
        wStockRecord.setQualityType(wStock.getQualityType());
        wStockRecord.setChangeType(optType);
        wStockRecord.setNum(wOutboundDetail.getNum());
        wStockRecord.setBeforNum(wStock.getNum());
        if(optType == Constants.ZERO){
            wStockRecord.setAfterNum(wStock.getNum().subtract(wOutboundDetail.getDoneNum()));
        }else{
            wStockRecord.setAfterNum(wStock.getNum().add(wOutboundDetail.getDoneNum()));
        }
        wStockRecord.setDetailId(detailId);
        wStockRecord.setOutboundId(wOutboundDetail.getOutboundId());
        wStockRecord.setWStockId(wStock.getId());
        this.wStockRecordExtMapper.insert(wStockRecord);
    }
}