package com.klp.service.impl;

import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.klp.common.core.domain.PageQuery;
import com.klp.common.core.page.TableDataInfo;
import com.klp.common.utils.StringUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.klp.common.helper.LoginHelper;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import com.klp.domain.bo.WmsCoilPendingActionBo;
import com.klp.domain.vo.WmsCoilPendingActionVo;
import com.klp.domain.WmsCoilPendingAction;
import com.klp.mapper.WmsCoilPendingActionMapper;
import com.klp.service.IWmsCoilPendingActionService;

import java.util.List;
import java.util.Collection;
import java.util.Date;

/**
 * 钢卷待操作Service业务层处理
 *
 * @author Joshi
 * @date 2025-11-03
 */
@RequiredArgsConstructor
@Service
public class WmsCoilPendingActionServiceImpl implements IWmsCoilPendingActionService {

    private final WmsCoilPendingActionMapper baseMapper;

    /**
     * 查询钢卷待操作
     */
    @Override
    public WmsCoilPendingActionVo queryById(Long actionId){
        return baseMapper.selectVoById(actionId);
    }

    /**
     * 查询钢卷待操作列表
     */
    @Override
    public TableDataInfo<WmsCoilPendingActionVo> queryPageList(WmsCoilPendingActionBo bo, PageQuery pageQuery) {
        QueryWrapper<WmsCoilPendingAction> lqw = buildQueryWrapperPlus(bo);
        Page<WmsCoilPendingActionVo> result = baseMapper.selectVoPagePlus(pageQuery.build(), lqw);
        return TableDataInfo.build(result);
    }

    private QueryWrapper<WmsCoilPendingAction> buildQueryWrapperPlus(WmsCoilPendingActionBo bo) {
        QueryWrapper<WmsCoilPendingAction> qw = Wrappers.query();
        qw.eq(bo.getCoilId() != null, "wcpa.coil_id", bo.getCoilId());
        qw.like(StringUtils.isNotBlank(bo.getCurrentCoilNo()), "wcpa.current_coil_no", bo.getCurrentCoilNo());
        qw.eq(bo.getActionType() != null, "wcpa.action_type", bo.getActionType());
        qw.ne(bo.getActionStatus() != null, "wcpa.action_status",2);
        qw.eq(bo.getWarehouseId() != null, "wcpa.warehouse_id", bo.getWarehouseId());
        qw.eq(bo.getPriority() != null, "wcpa.priority", bo.getPriority());
        qw.like(StringUtils.isNotBlank(bo.getSourceType()), "wcpa.source_type", bo.getSourceType());
        qw.orderByDesc("wcpa.create_time");
        qw.orderByDesc("wcpa.scan_time");
        //逻辑删除
        qw.eq("wcpa.del_flag", 0);
        return qw;
    }

    /**
     * 查询钢卷待操作列表
     */
    @Override
    public List<WmsCoilPendingActionVo> queryList(WmsCoilPendingActionBo bo) {
        LambdaQueryWrapper<WmsCoilPendingAction> lqw = buildQueryWrapper(bo);
        return baseMapper.selectVoList(lqw);
    }

    private LambdaQueryWrapper<WmsCoilPendingAction> buildQueryWrapper(WmsCoilPendingActionBo bo) {
        LambdaQueryWrapper<WmsCoilPendingAction> lqw = Wrappers.lambdaQuery();
        lqw.eq(bo.getCoilId() != null, WmsCoilPendingAction::getCoilId, bo.getCoilId());
        lqw.like(StringUtils.isNotBlank(bo.getCurrentCoilNo()), WmsCoilPendingAction::getCurrentCoilNo, bo.getCurrentCoilNo());
        lqw.eq(bo.getActionType() != null, WmsCoilPendingAction::getActionType, bo.getActionType());
        lqw.eq(bo.getActionStatus() != null, WmsCoilPendingAction::getActionStatus, bo.getActionStatus());
        lqw.eq(bo.getWarehouseId() != null, WmsCoilPendingAction::getWarehouseId, bo.getWarehouseId());
        lqw.eq(bo.getPriority() != null, WmsCoilPendingAction::getPriority, bo.getPriority());
        lqw.like(StringUtils.isNotBlank(bo.getSourceType()), WmsCoilPendingAction::getSourceType, bo.getSourceType());
        lqw.orderByDesc(WmsCoilPendingAction::getCreateTime);
        lqw.orderByDesc(WmsCoilPendingAction::getScanTime);
        return lqw;
    }

    /**
     * 新增钢卷待操作
     */
    @Override
    public Boolean insertByBo(WmsCoilPendingActionBo bo) {
        WmsCoilPendingAction add = BeanUtil.toBean(bo, WmsCoilPendingAction.class);
        validEntityBeforeSave(add);
        // 设置默认值
        if (add.getActionStatus() == null) {
            add.setActionStatus(0); // 默认待处理
        }
        if (StringUtils.isBlank(add.getSourceType())) {
            add.setSourceType("manual"); // 默认手动创建
        }
        if (add.getScanTime() == null && "scan".equals(add.getSourceType())) {
            add.setScanTime(new Date());
        }
        boolean flag = baseMapper.insert(add) > 0;
        if (flag) {
            bo.setActionId(add.getActionId());
        }
        return flag;
    }

    /**
     * 修改钢卷待操作
     */
    @Override
    public Boolean updateByBo(WmsCoilPendingActionBo bo) {
        WmsCoilPendingAction update = BeanUtil.toBean(bo, WmsCoilPendingAction.class);
        validEntityBeforeSave(update);
        return baseMapper.updateById(update) > 0;
    }

    /**
     * 保存前的数据校验
     */
    private void validEntityBeforeSave(WmsCoilPendingAction entity){
        // TODO 做一些数据校验,如唯一约束
    }

    /**
     * 批量删除钢卷待操作
     */
    @Override
    public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
        if(isValid){
            // TODO 做一些业务上的校验,判断是否需要校验
        }
        return baseMapper.deleteBatchIds(ids) > 0;
    }

    /**
     * 更新操作状态
     */
    @Override
    public Boolean updateStatus(Long actionId, Integer status) {
        WmsCoilPendingAction action = new WmsCoilPendingAction();
        action.setActionId(actionId);
        action.setActionStatus(status);
        return baseMapper.updateById(action) > 0;
    }

    /**
     * 开始处理操作
     */
    @Override
    public Boolean startProcess(Long actionId) {
        WmsCoilPendingAction action = new WmsCoilPendingAction();
        action.setActionId(actionId);
        action.setActionStatus(1); // 处理中
        action.setProcessTime(new Date());
        try {
            action.setOperatorId(LoginHelper.getUserId());
            action.setOperatorName(LoginHelper.getUsername());
        } catch (Exception e) {
            // 如果获取登录用户失败，不影响主流程
        }
        return baseMapper.updateById(action) > 0;
    }

    /**
     * 完成操作
     */
    @Override
    public Boolean completeAction(Long actionId) {
        // 先查询原记录，检查操作人是否为空
        WmsCoilPendingAction oldAction = baseMapper.selectById(actionId);
        if (oldAction == null) {
            throw new RuntimeException("待操作记录不存在");
        }

        WmsCoilPendingAction action = new WmsCoilPendingAction();
        action.setActionId(actionId);
        action.setActionStatus(2); // 已完成
        action.setCompleteTime(new Date());

        // 如果操作人为空，设置当前登录用户为操作人
        if (oldAction.getOperatorId() == null || oldAction.getOperatorName() == null) {
            try {
                action.setOperatorId(LoginHelper.getUserId());
                action.setOperatorName(LoginHelper.getUsername());
                action.setProcessTime(new Date());
            } catch (Exception e) {
                // 如果获取登录用户失败，不影响主流程
            }
        }

        return baseMapper.updateById(action) > 0;
    }

    /**
     * 取消操作
     */
    @Override
    public Boolean cancelAction(Long actionId) {
        WmsCoilPendingAction action = new WmsCoilPendingAction();
        action.setActionId(actionId);
        action.setActionStatus(3); // 已取消
        return baseMapper.updateById(action) > 0;
    }
}