package zy.cloud.wms.manager.controller;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.BaseRes;
import com.core.common.Cools;
import com.core.common.R;
import com.core.common.SnowflakeIdWorker;
import com.core.exception.CoolException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import zy.cloud.wms.common.entity.Parameter;
import zy.cloud.wms.common.model.ErpUpload;
import zy.cloud.wms.common.model.param.ReplenishDto;
import zy.cloud.wms.common.model.param.ReplenishParam;
import zy.cloud.wms.common.service.erp.ErpService;
import zy.cloud.wms.common.utils.VersionUtils;
import zy.cloud.wms.common.web.BaseController;
import zy.cloud.wms.manager.entity.*;
import zy.cloud.wms.manager.service.*;

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

/**
 * Created by vincent on 2021/5/27
 */
@RestController
@RequestMapping("/open/api")
public class OpenController extends BaseController {

    @Autowired
    private PriorService priorService;
    @Autowired
    private NodeService nodeService;
    @Autowired
    private MatService matService;
    @Autowired
    private LocDetlService locDetlService;
    @Autowired
    private ErpService erpService;
    @Autowired
    private PakinService pakinService;
    @Autowired
    private SnowflakeIdWorker snowflakeIdWorker;

    @PostMapping("/erp/upload")
    public R erpUpload(@RequestBody ErpUpload erpUpload){
        Boolean result = erpService.uploadBill(erpUpload.getDtos(), erpUpload.getDocId(), erpUpload.getDocNumber()).getSuccess();
        return result ? R.ok() : R.error();
    }

    @PostMapping("/replenish")
    @Transactional
    public synchronized R asrsReplenish(@RequestBody ReplenishParam params){
        if (Cools.isEmpty(params.getList())) {
            return R.parse(BaseRes.PARAM);
        }
        Date now = new Date();
        for (ReplenishDto param : params.getList()) {
            Mat mat = matService.selectByMatnr(param.getMatnr());
            List<Prior> priors = priorService.selectList(new EntityWrapper<Prior>().eq("matnr", param.getMatnr()));
            Node node;
            // 有推荐货位
            if (!Cools.isEmpty(priors)) {
                Prior prior = priors.get(0);
                node = nodeService.selectById(prior.getNodeId());

                LocDetl locDetl = locDetlService.getLocDetl(node.getId(), param.getMatnr());
                if (locDetl == null) {
                    locDetl = new LocDetl();
                    locDetl.setLocNo(node.getName());
                    locDetl.setNodeId(node.getId());
                    locDetl.setAnfme(param.getCount());
                    VersionUtils.setLocDetl(locDetl, mat);
                    locDetl.setStatus(1);
                    locDetl.setCreateBy(9527L);
                    locDetl.setCreateTime(now);
                    locDetl.setUpdateBy(9527L);
                    locDetl.setUpdateTime(now);
                    boolean insert = locDetlService.insert(locDetl);
                    if (!insert) {
                        throw new CoolException("新增库存明细档失败");
                    }
                } else {
                    if (!locDetlService.incrementStock(node.getId(), param.getMatnr(), param.getCount())) {
                        throw new CoolException("新增库存明细档失败");
                    }
                }

            // 没有推荐货物
            } else {
                node = nodeService.selectByUuid(Parameter.get().getUniNode());

                LocDetl locDetl = locDetlService.getLocDetl(node.getId(), param.getMatnr());
                if (locDetl == null) {
                    locDetl = new LocDetl();
                    locDetl.setLocNo(node.getName());
                    locDetl.setNodeId(node.getId());
                    locDetl.setAnfme(param.getCount());
                    VersionUtils.setLocDetl(locDetl, mat);
                    locDetl.setStatus(1);
                    locDetl.setCreateBy(9527L);
                    locDetl.setCreateTime(now);
                    locDetl.setUpdateBy(9527L);
                    locDetl.setUpdateTime(now);
                    boolean insert = locDetlService.insert(locDetl);
                    if (!insert) {
                        throw new CoolException("新增库存明细档失败");
                    }
                } else {
                    if (!locDetlService.incrementStock(node.getId(), param.getMatnr(), param.getCount())) {
                        throw new CoolException("新增库存明细档失败");
                    }
                }
            }

            // 保存入库记录
            Pakin pakin = new Pakin(
                    "BC" + String.valueOf(snowflakeIdWorker.nextId()),    // 任务号[非空]
                    null,    // 工作状态
                    null,    // 托盘号
                    param.getCount(),    // 入库数量
                    node.getId(),    // 关联货位[非空]
                    node.getUuid(),    // 货位[非空]
                    mat.getMatnr(),    // 商品编码[非空]
                    null,    // 商品名称
                    null,    // 名称
                    null,    // 尺码
                    null,    // 型号
                    null,    // 批号
                    null,    // 单位
                    null,    // SKC
                    null,    // 单据类型
                    null,    // 单据编号
                    null,    // 客户名称
                    null,    // 品项数
                    null,    // 数量
                    null,    // 重量
                    1,    // 状态
                    9527L,    // 添加人员
                    now,    // 添加时间
                    9527L,    // 修改人员
                    now,    // 修改时间
                    "补仓入库[立库资料：" + param.getWorkNo() + "]"    // 备注
            );
            VersionUtils.setPakin(pakin, mat);
            if (!pakinService.insert(pakin)) {
                throw new CoolException("保存入库记录失败");
            }
        }
        return R.ok();
    }


}