package com.fzzy.igds.app.v1.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.fzzy.common.constant.RespCodeEnum;
import com.fzzy.igds.app.v1.constant.PhoneConstant;
import com.fzzy.igds.app.v1.data.AuthUser;
import com.fzzy.igds.app.v1.data.ParamInoutHandle;
import com.fzzy.igds.app.v1.data.PhoneRequest;
import com.fzzy.igds.app.v1.data.PhoneResponse;
import com.fzzy.igds.app.v1.service.PhoneService;
import com.fzzy.igds.app.v1.util.PhoneRespUtil;
import com.fzzy.igds.constant.Constant;
import com.fzzy.igds.constant.InoutConstant;
import com.fzzy.igds.data.FileData;
import com.fzzy.igds.data.InoutData;
import com.fzzy.igds.data.PageResponse;
import com.fzzy.igds.domain.FileInfo;
import com.fzzy.igds.domain.InoutRecord;
import com.fzzy.igds.domain.InoutSysConf;
import com.fzzy.igds.mapper.InoutRecordMapper;
import com.fzzy.igds.service.FileService;
import com.fzzy.igds.service.InoutConfService;
import com.fzzy.igds.service.InoutRecordService;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.utils.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;

/**
 * @Author: YYC
 * @Description: 粮食购销-入库值仓提交
 * @DateTime: 2026-1-12 14:43
 **/
@Service
public class ServiceImpl5402 implements PhoneService {
    @Resource
    private InoutRecordMapper inoutRecordMapper;
    @Resource
    private InoutRecordService inoutRecordService;
    @Resource
    private InoutConfService inoutConfService;
    @Resource
    private FileService fileService;

    @Override
    public String getInterfaceId() {
        return PhoneConstant.API_PHONE_5402;
    }

    @Override
    public PhoneResponse<Object> execute(PhoneRequest<JSONObject> req, AuthUser authUser) throws Exception {

        //转化为对象
        ParamInoutHandle param = JSONObject.parseObject(req.getData().toString(), ParamInoutHandle.class);
        if (null == param) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
        param.setCompanyId(authUser.getCompanyId());
        param.setDeptId(authUser.getDeptId());

        QueryWrapper<InoutRecord> queryWrapper = new QueryWrapper<>();
        if (StringUtils.isNotBlank(param.getCompanyId())) {
            queryWrapper.eq("company_id", param.getCompanyId());
        }
        if (StringUtils.isNotBlank(param.getId())) {
            queryWrapper.eq("id", param.getId());
        }
        //值仓提交前，再次确认当前流水是否为值仓流程
        InoutRecord inoutRecord = inoutRecordMapper.selectOne(queryWrapper);
        if (!InoutConstant.PROGRESS_HANDLE.equals(inoutRecord.getProgress())) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "该单子不在值仓状态，不能进行值仓提交！");
        }

        InoutData data = new InoutData();
        BeanUtils.copyProperties(inoutRecord, data);
        //值仓结束提交,需更新流程状态、值仓结束时间、值仓人、值仓扣重等
        data.setDeOther(param.getDeHandle());
        data.setHandleUser(authUser.getCname());
        //设置值仓图片信息
        List<FileInfo> files = new ArrayList<>();
        FileInfo fileData1 = new FileInfo();
        FileInfo fileData2 = new FileInfo();
        fileData1.setFileName(param.getFileName1());
        fileData2.setFileName(param.getFileName2());
        files.add(fileData1);
        files.add(fileData2);
        data.setFiles(files);

        if (null == data.getHandleUser()) {
            data.setHandleUser(authUser.getUsername());
        }
        InoutSysConf inoutSysConf = inoutConfService.getCacheInoutSysConf(authUser.getCompanyId(), data.getDeptId());
        if (null == inoutSysConf) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "提示：当前系统中流程配置异常，请联系管理员");
        }

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

        // 执行数据更新
        int num = inoutRecordService.updateInoutRecord(data);
        if (num == 0) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "提交失败！");
        }
        //附件处理
        fileService.saveInoutFiles(data.getFiles(), data.getId(), curProgress, "INOUT");

        return PhoneRespUtil.success(RespCodeEnum.CODE_0000, req);
//        if (param.getType().equals(PhoneConstant.PHONE_INOUT_START)) {
//            //值仓开始提交，只更新值仓开始时间
//            int i = inoutRecordService.updateInoutRecord(data);
//            if (i > 0) {
//                return PhoneRespUtil.success(RespCodeEnum.CODE_0000, req);
//            }
//            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "提交失败！");
//        } else {
//            //值仓结束提交,需更新流程状态、值仓结束时间、值仓人、值仓扣重等
//            data.setDeOther(param.getDeHandle());
//            data.setHandleUser(authUser.getCname());
//            //设置值仓图片信息
//            List<FileInfo> files = new ArrayList<>();
//            FileInfo fileData1 = new FileInfo();
//            FileInfo fileData2 = new FileInfo();
//            fileData1.setFileName(param.getFileName1());
//            fileData2.setFileName(param.getFileName2());
//            files.add(fileData1);
//            files.add(fileData2);
//            data.setFiles(files);
//
//            if (null == data.getHandleUser()) {
//                data.setHandleUser(authUser.getUsername());
//            }
//            InoutSysConf inoutSysConf = inoutConfService.getCacheInoutSysConf(authUser.getCompanyId(), data.getDeptId());
//            if (null == inoutSysConf) {
//                return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "提示：当前系统中流程配置异常，请联系管理员");
//            }
//
//            // 获取下一个流程状态
//            String curProgress = data.getProgress();
//            String nextProgress = getNextProgress(curProgress, data.getType(), inoutSysConf);
//            data.setProgress(nextProgress);
//            data.setHandleEnd(new Date());
//
//            // 执行数据更新
//            int num = inoutRecordService.updateInoutRecord(data);
//            if (num == 0) {
//                return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "提交失败！");
//            }
//            //附件处理
//            fileService.saveInoutFiles(data.getFiles(), data.getId(), curProgress, "INOUT");
//
//            return PhoneRespUtil.success(RespCodeEnum.CODE_0000, req);
//        }
    }


    /**
     * 获取下一流程
     *
     * @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;
    }
}