package com.fzzy.sys.manager.inout;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fzzy.igds.constant.Constant;
import com.fzzy.igds.constant.RespCodeEnum;
import com.fzzy.igds.data.IgdsBaseParam;
import com.fzzy.igds.data.InoutParam;
import com.fzzy.igds.data.NoticeParam;
import com.fzzy.igds.data.PageResponse;
import com.fzzy.igds.domain.*;
import com.fzzy.igds.service.DicAreaService;
import com.fzzy.igds.service.InoutConfService;
import com.fzzy.igds.service.InoutNoticeService;
import com.fzzy.igds.service.InoutRecordService;
import com.fzzy.igds.utils.ContextUtil;
import com.fzzy.igds.utils.SystemUtil;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.core.redis.RedisCache;
import lombok.extern.slf4j.Slf4j;
import com.ruoyi.common.utils.StringUtils;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.*;

/**
 * @Description 出入库业务处理
 * @Author CZT
 * @Date 2025/11/29 11:02
 */
@Slf4j
@Component
public class InoutManager {

    @Resource
    private RedisCache redisCache;
    @Resource
    private InoutConfService inoutConfService;
    @Resource
    private InoutRecordService inoutRecordService;
    @Resource
    private DicAreaService dicAreaService;
    @Resource
    private InoutNoticeService inoutNoticeService;

    /**
     * 根据用户请求信息，根据当前客户电脑IP，获取出入库称重上次选择的地磅
     *
     * @param httpRequest
     * @return
     */
    public String getInoutWeightByClient(HttpServletRequest httpRequest) {
        String userIp = SystemUtil.getIP(httpRequest);
        log.debug("----------------根据用户IP获取选择-地磅----{}", userIp);

        String key = "INOUT:WEIGHT:" + userIp;
        String sort = (String) redisCache.getCacheObject(key);
        if (com.ruoyi.common.utils.StringUtils.isEmpty(sort)) sort = "1";
        return sort;
    }

    /**
     * 获取出入库的整个流程信息
     *
     * @param companyId
     * @param deptId
     * @param inoutType
     * @return
     */
    public String getInoutProgressConf(String companyId, String deptId, String inoutType) {
        // 从缓存中获取出入库系统配置信息
        InoutSysConf inoutSysConf = inoutConfService.getCacheInoutSysConf(companyId, deptId);
        String progressConf = null;
        if (inoutSysConf != null) {
            if (Constant.TYPE_IN.equals(inoutType)) {
                progressConf = inoutSysConf.getProgressIn();
            }
            if (Constant.TYPE_OUT.equals(inoutType)) {
                progressConf = inoutSysConf.getProgressOut();
            }
        }
        return progressConf;
    }

    /**
     * 获取出入库设备配置信息
     *
     * @param companyId
     * @param deptId
     * @return
     */
    public List<InoutConf> getListInoutConf(String companyId, String deptId) {
        return inoutConfService.getCacheInoutConf(companyId, deptId);
    }

    /**
     * 根据配置获取出入库的配置参数
     *
     * @param listInoutConf 配置列表
     * @param sort          方案序号
     * @param type          设备类型
     * @param inoutProgress 出入库流程
     * @return 车牌设备配置，没有则返回NULL
     */
    public InoutConf getInoutConf(List<InoutConf> listInoutConf, String sort, String type, String inoutProgress, int inOrder) {
        if (null == listInoutConf) {
            return new InoutConf(sort);
        }
        if (StringUtils.isEmpty(sort)) sort = "1";

        InoutConf result = null;
        for (InoutConf conf : listInoutConf) {
            if (sort.equals(conf.getSort()) && type.equals(conf.getType()) && inoutProgress.equals(conf.getInoutProgress())) {
                if (conf.getInOrder() == inOrder) {
                    result = conf;
                    break;
                }
            }
        }

        if (null == result) return new InoutConf(sort);

        return result;
    }

    /**
     * 根据配置获取出入库的配置参数
     * @param listInoutConf
     * @param type
     * @return
     */
    public List<InoutConf> getInoutConf(List<InoutConf> listInoutConf, String type) {
        List<InoutConf> result = new ArrayList<>();
        if (null == listInoutConf) return result;
        for (InoutConf conf : listInoutConf) {
            if (type.equals(conf.getType())) {
                result.add(conf);
            }
        }
        return result;
    }

    /**
     * 根据配置获取出入库的配置参数
     * @param listInoutConf
     * @param sort
     * @param type
     * @return
     */
    public InoutConf getInoutConf(List<InoutConf> listInoutConf, String sort, String type) {
        if (null == listInoutConf) return new InoutConf(sort);
        if (StringUtils.isEmpty(sort)) sort = "1";

        for (InoutConf conf : listInoutConf) {
            if (sort.equals(conf.getSort()) && type.equals(conf.getType())) {
                return conf;
            }
        }
        return new InoutConf(sort);
    }

    /**
     * 获取地磅重量编辑标签
     *
     * @param companyId
     * @param deptId
     * @return
     */
    public String getWeightEditTag(String companyId, String deptId) {
        // 从缓存中获取出入库系统配置信息
        InoutSysConf inoutSysConf = inoutConfService.getCacheInoutSysConf(companyId, deptId);
        String weightEditTag = Constant.YN_N;
        if (inoutSysConf != null) {
            weightEditTag = inoutSysConf.getWeightEditTag();
        }
        if (null == weightEditTag) weightEditTag = Constant.YN_N;

        return weightEditTag;
    }

    /**
     * 出入库注册数据提交，出入库登记使用同一个方法
     *
     * @param data
     * @return
     */
    public PageResponse<InoutRecord> submitRegister(InoutRecord data) {
        SysUser user = ContextUtil.getLoginUser();
        if (StringUtils.isEmpty(data.getCompanyId())) {
            data.setCompanyId(user.getCompanyId());
        }
        if (StringUtils.isEmpty(data.getDeptId())) {
            data.setDeptId(ContextUtil.subDeptId(user));
        }

        int num = inoutRecordService.checkExist(data.getCompanyId(), data.getPlateNum());
        if (num > 0) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "当前车牌号正在执行流程未结束，请核查车牌或联系管理员", data);
        }

        // 获取系统参数配置
        InoutSysConf inoutSysConf = inoutConfService.getCacheInoutSysConf(data.getCompanyId(), data.getDeptId());
        if (null == inoutSysConf) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "提示：当前库区未配置出入库流程信息，请联系管理员", data);
        }

        // 获取下一个流程状态
        String curProgress = data.getProgress();
        String nextProgress = getNextProgress(curProgress, data.getType(), inoutSysConf);
        data.setProgress(nextProgress);

        //去除身份证号中的空格
        if (StringUtils.isNotEmpty(data.getUserId())) {
            data.setUserId(data.getUserId().trim());
        }
        //去除姓名中的空格
        if (StringUtils.isNotEmpty(data.getUserName())) {
            data.setUserName(data.getUserName().trim());
        }
        //登记人及登记时间
        data.setRegisterUser(user.getUserName());
        data.setRegisterTime(new Date());

        num = inoutRecordService.addInoutRecord(data);

        if (num == 0) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "登记失败！", data);
        }

        //TODO 附件处理
//        List<FileData> files = data.getFiles();
//        if (null != files && files.size() > 0) {
//            // 执行附件信息
//            fileService.saveInoutFiles(files, data.getCompanyId(), data.getId(), curProgress);
//        }

        return new PageResponse<>(RespCodeEnum.CODE_0000.getCode(), "登记成功！", data);
    }

    /**
     * 化验信息提交
     * @param data
     * @return
     */
    public PageResponse<InoutRecord> submitCheck(InoutRecord data) {
        SysUser user = ContextUtil.getLoginUser();
        if (StringUtils.isEmpty(data.getCompanyId())) {
            data.setCompanyId(user.getCompanyId());
        }
        if (StringUtils.isEmpty(data.getDeptId())) {
            data.setDeptId(ContextUtil.subDeptId(user));
        }

        //化验人及时间
        data.setCheckUser(user.getUserName());
        data.setCheckTime(new Date());
        data.setCheckStatus(Constant.STATUS_CHECK);

        int num = inoutRecordService.updateInoutRecord(data);

        if (num == 0) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "提交失败！", data);
        }

        return new PageResponse<>(RespCodeEnum.CODE_0000.getCode(), "提交成功！", data);
    }

    /**
     * 称重提交，包含称重登记提交及单独称重提交
     * @param data
     * @return
     */
    public PageResponse<InoutRecord> submitWeight(InoutRecord data) {

        // 获取系统参数配置
        InoutSysConf inoutSysConf = inoutConfService.getCacheInoutSysConf(data.getCompanyId(), data.getDeptId());
        if (null == inoutSysConf) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "提示：当前系统中流程配置异常，请联系管理员", data);
        }

        // 获取下一个流程状态
        String curProgress = data.getProgress();
        String nextProgress = getNextProgress(curProgress, data.getType(), inoutSysConf);
        data.setProgress(nextProgress);

        int num;
        if(StringUtils.isBlank(data.getId())){
            data.setRegisterTime(new Date());
            data.setRegisterUser(ContextUtil.getLoginUserName());

            //设置初次提交时称重时间信息
            if(data.getFullWeight() > 0){
                data.setFullWeightUser(ContextUtil.getLoginUserName());
                data.setFullWeightTime(new Date());
            }
            if(data.getEmptyWeight() > 0){
                data.setEmptyWeightUser(ContextUtil.getLoginUserName());
                data.setEmptyWeightTime(new Date());
            }
            //称重登记
            num = inoutRecordService.addInoutRecord(data);
        }else {
            if (Constant.PROGRESS_WEIGHT_EMPTY.equals(curProgress)) {
                data.setEmptyWeightTime(new Date());
                data.setEmptyWeightUser(ContextUtil.getLoginUserName());
            }
            if (Constant.PROGRESS_WEIGHT_FULL.equals(curProgress)) {
                data.setFullWeightTime(new Date());
                data.setFullWeightUser(ContextUtil.getLoginUserName());
            }
            //称重更新
            num = inoutRecordService.updateInoutRecord(data);
        }

        if (num == 0) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "提交失败！", data);
        }

        //TODO 附件处理
//        List<FileData> files = data.getFiles();
//        if (null != files && files.size() > 0) {
//            // 执行附件信息
//            fileService.saveInoutFiles(files, data.getCompanyId(), data.getId(), curProgress);
//        }

        return new PageResponse<>(RespCodeEnum.CODE_0000.getCode(), "执行成功", data);
    }

    /**
     * 值仓信息提交
     * @param data
     * @return
     */
    public PageResponse<InoutRecord> submitHandle(InoutRecord data) {

        // 获取系统参数配置
        InoutSysConf inoutSysConf = inoutConfService.getCacheInoutSysConf(data.getCompanyId(), data.getDeptId());
        if (null == inoutSysConf) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "提示：当前系统中流程配置异常，请联系管理员", data);
        }

        // 获取下一个流程状态
        String curProgress = data.getProgress();
        String nextProgress = getNextProgress(curProgress, data.getType(), inoutSysConf);
        data.setProgress(nextProgress);

        data.setHandleEnd(new Date());
        data.setHandleUser(ContextUtil.getLoginUserName());
        // 执行数据更新
        int num = inoutRecordService.updateInoutRecord(data);

        if (num == 0) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "提交失败！", data);
        }

        //TODO 附件处理
//        List<FileData> files = data.getFiles();
//        if (null != files && files.size() > 0) {
//            // 执行附件信息
//            fileService.saveInoutFiles(files, data.getCompanyId(), data.getId(), curProgress);
//        }

        return new PageResponse<>(RespCodeEnum.CODE_0000.getCode(), "提交成功", data);
    }

    /**
     * 获取下一流程
     *
     * @param curProgress
     * @param type
     * @param sysConf
     * @return
     */
    private String getNextProgress(String curProgress, String type, InoutSysConf sysConf) {
        String nextProgress = null;
        List<String> list = null;
        if (Constant.TYPE_IN.equals(type)) {
            list = Arrays.asList(sysConf.getProgressIn().split("-"));
        }
        if (Constant.TYPE_OUT.equals(type)) {
            list = Arrays.asList(sysConf.getProgressOut().split("-"));
        }
        if (list != null) {
            for (int i = 0; i < list.size() - 1; i++) {
                if (curProgress.equals(list.get(i))) {
                    nextProgress = list.get(i + 1);
                    break;
                }
            }
        }
        return nextProgress;
    }

    /**
     * 分页查询数据
     * @param param
     * @return
     */
    public PageResponse<Page<InoutRecord>> pageInoutData(InoutParam param) {
        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }
        if (StringUtils.isEmpty(param.getDeptId())) {
            param.setDeptId(ContextUtil.subDeptId(null));
        }

        Page<InoutRecord> corePage = new Page<>(param.getPage(), param.getLimit());
        inoutRecordService.listPageInout(corePage, param);

        if (null == corePage.getRecords() || corePage.getRecords().isEmpty()) {
            return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(), "获取到数据信息为空");
        }

        return new PageResponse<>(RespCodeEnum.CODE_0000, corePage);
    }

    /**
     * 分页查询数据
     * @param param
     * @return
     */
    public PageResponse<List<InoutRecord>> listWeightData(InoutParam param) {
        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }
        if (StringUtils.isEmpty(param.getDeptId())) {
            param.setDeptId(ContextUtil.subDeptId(null));
        }

        //设置称重流程标记
        param.setWeightTag("WEIGHT");

        List<InoutRecord> inoutRecords = inoutRecordService.listInout(param);

        if (null == inoutRecords || inoutRecords.isEmpty()) {
            return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(), "获取到数据信息为空");
        }

        return new PageResponse<>(RespCodeEnum.CODE_0000, inoutRecords);
    }

    /**
     * 查询数据
     * @param param
     * @return
     */
    public PageResponse<InoutRecord> inoutQuery(InoutParam param) {
        if (StringUtils.isEmpty(param.getId())) {
            return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), "查询参数不完整，查询失败！");
        }

        InoutRecord result = inoutRecordService.selectById(param.getId());
        if (null == result) {
            return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(),
                    "系统未查询到执行中的单据信息", null);
        }
        return new PageResponse<>(RespCodeEnum.CODE_0000, result);
    }

    /**
     * 分页获取区划信息
     * @param param
     * @return
     */
    public PageResponse<Page<DicArea>> pageDicArea(IgdsBaseParam param) {

        Page<DicArea> corePage = new Page<>(param.getPage(), param.getLimit());

        dicAreaService.listPageData(corePage, param.getKey());

        if (null == corePage.getRecords() || corePage.getRecords().isEmpty()) {
            return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(), "获取到数据信息为空");
        }
        return new PageResponse<>(RespCodeEnum.CODE_0000, corePage);
    }

    /**
     *
     * @param param
     * @return
     */
    public PageResponse<List<InoutNoticeIn>> listNoticeIn(NoticeParam param) {

        SysUser user = ContextUtil.getLoginUser();
        if (org.apache.commons.lang3.StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(user.getCompanyId());
        }
        param.setDeptId(ContextUtil.subDeptId(user));

        List<InoutNoticeIn> list = inoutNoticeService.getNoticeIn(param.getCompanyId(), param.getDeptId(),Constant.COMPLETE_STATUS_NONE);

        if (null == list || list.isEmpty()) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "查询结果为空！");
        }

        return new PageResponse<>(RespCodeEnum.CODE_0000, list);
    }

    /**
     *
     * @param param
     * @return
     */
    public PageResponse<List<InoutNoticeOut>> listNoticeOut(NoticeParam param) {
        SysUser user = ContextUtil.getLoginUser();
        if (org.apache.commons.lang3.StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(user.getCompanyId());
        }
        param.setDeptId(ContextUtil.subDeptId(user));

        List<InoutNoticeOut> list = inoutNoticeService.getNoticeOut(param.getCompanyId(), param.getDeptId(),Constant.COMPLETE_STATUS_NONE);

        if (null == list || list.isEmpty()) {
            return new PageResponse<>(RespCodeEnum.CODE_1111.getCode(), "查询结果为空！");
        }

        return new PageResponse<>(RespCodeEnum.CODE_0000, list);
    }
}