#
luxiaotao1123
2021-08-07 b93887bd221deb1d0a4f6379401ff3b992594d8c
#
1个文件已修改
49 ■■■■ 已修改文件
src/main/java/zy/cloud/wms/manager/controller/OpenController.java 49 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/zy/cloud/wms/manager/controller/OpenController.java
@@ -4,6 +4,7 @@
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;
@@ -18,14 +19,8 @@
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.LocDetl;
import zy.cloud.wms.manager.entity.Mat;
import zy.cloud.wms.manager.entity.Node;
import zy.cloud.wms.manager.entity.Prior;
import zy.cloud.wms.manager.service.LocDetlService;
import zy.cloud.wms.manager.service.MatService;
import zy.cloud.wms.manager.service.NodeService;
import zy.cloud.wms.manager.service.PriorService;
import zy.cloud.wms.manager.entity.*;
import zy.cloud.wms.manager.service.*;
import java.util.Date;
import java.util.List;
@@ -47,6 +42,10 @@
    private LocDetlService locDetlService;
    @Autowired
    private ErpService erpService;
    @Autowired
    private PakinService pakinService;
    @Autowired
    private SnowflakeIdWorker snowflakeIdWorker;
    @PostMapping("/erp/upload")
    public R erpUpload(@RequestBody ErpUpload erpUpload){
@@ -69,6 +68,40 @@
                Prior prior = priors.get(0);
                Node node = nodeService.selectById(prior.getNodeId());
                // 保存入库记录
                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,    // 修改时间
                        null    // 备注
                );
                VersionUtils.setPakin(pakin, mat);
                if (!pakinService.insert(pakin)) {
                    throw new CoolException("保存入库记录失败");
                }
                LocDetl locDetl = locDetlService.getLocDetl(node.getId(), param.getMatnr());
                if (locDetl == null) {
                    locDetl = new LocDetl();