package com.zy.asrs.service.impl; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.mapper.Wrapper; import com.core.common.Cools; import com.core.common.DateUtils; import com.core.common.R; import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; import com.zy.asrs.entity.*; import com.zy.asrs.entity.param.*; import com.zy.asrs.entity.result.OpenOrderCompeteResult; import com.zy.asrs.entity.result.StockVo; import com.zy.asrs.entity.result.ZphjcdgzVo; import com.zy.asrs.entity.result.ZphjcdwcVo; import com.zy.asrs.mapper.MatMapper; import com.zy.asrs.mapper.TagMapper; import com.zy.asrs.service.*; import com.zy.asrs.utils.MatUtils; import com.zy.common.constant.MesConstant; import com.zy.common.model.DetlDto; import com.zy.common.model.LocTypeDto; import com.zy.common.model.StartupDto; import com.zy.common.model.enums.WorkNoType; import com.zy.common.service.CommonService; import com.zy.common.utils.HttpHandler; import com.zy.common.utils.NodeUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.*; import java.util.stream.Collectors; /** * Created by vincent on 2022/4/9 */ @Slf4j @Service public class OpenServiceImpl implements OpenService { // 二楼堆垛机对应入库站点 private static final int[] secondFloorIn = new int[]{0,2061,2064,2067,2070,2073,2076}; @Autowired private OrderService orderService; @Autowired private OrderDetlService orderDetlService; @Autowired private SnowflakeIdWorker snowflakeIdWorker; @Autowired private DocTypeService docTypeService; @Autowired private MatService matService; @Autowired private LocDetlService locDetlService; @Autowired private PackService packService; @Autowired private TagService tagService; @Autowired private TagMapper tagMapper; @Autowired private WrkMastService wrkMastService; @Autowired private BasDevpService basDevpService; @Autowired private WrkDetlService wrkDetlService; @Autowired private WaitPakinService waitPakinService; @Autowired private CommonService commonService; @Autowired private LocDetlRullUpDetailService locDetlRullUpDetailService; @Autowired private WrkDetlSingleService wrkDetlSingleService; @Autowired private WrkMastLogService wrkMastLogService; @Autowired private WrkMastStaService wrkMastStaService; @Autowired private WrkMastStaLogService wrkMastStaLogService; @Autowired private StaDescService staDescService; @Autowired private LocMastService locMastService; @Autowired private ApiLogService apiLogService; @Resource private MatMapper matMapper; @Override @Transactional public void pakinOrderCreate(OpenOrderPakinParam param) { Order order = orderService.selectByNo(param.getOrderNo()); if (!Cools.isEmpty(order)) { throw new CoolException(param.getOrderNo() + "单据已存在，请勿重复提交"); } DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.TRUE); Date now = new Date(); // 单据主档 order = new Order( String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空] param.getOrderNo(), // 订单编号 DateUtils.convert(now), // 单据日期 docType.getDocId(), // 单据类型 null, // 项目编号 null, // null, // 调拨项目编号 null, // 初始票据号 null, // 票据号 null, // 客户编号 null, // 客户 null, // 联系方式 null, // 操作人员 null, // 合计金额 null, // 优惠率 null, // 优惠金额 null, // 销售或采购费用合计 null, // 实付金额 null, // 付款类型 null, // 业务员 null, // 结算天数 null, // 邮费支付类型 null, // 邮费 null, // 付款时间 null, // 发货时间 null, // 物流名称 null, // 物流单号 1L, // 订单状态 1, // 状态 9527L, // 添加人员 now, // 添加时间 9527L, // 修改人员 now, // 修改时间 null // 备注 ); if (!orderService.insert(order)) { throw new CoolException("生成单据主档失败，请联系管理员"); } // 单据明细档 List list = new ArrayList<>(); List orderDetails = param.getOrderDetails(); for (DetlDto detail : orderDetails) { DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme()); if (DetlDto.has(list, dto)) { DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch()); assert detlDto != null; detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme()); } else { list.add(dto); } } for (DetlDto detlDto : list) { Mat mat = matService.selectByMatnr(detlDto.getMatnr()); if (Cools.isEmpty(mat)) { throw new CoolException(detlDto.getMatnr() + "编号商品检索失败，请先添加商品"); } OrderDetl orderDetl = new OrderDetl(); orderDetl.sync(mat); orderDetl.setBatch(detlDto.getBatch()); orderDetl.setAnfme(detlDto.getAnfme()); orderDetl.setOrderId(order.getId()); orderDetl.setOrderNo(order.getOrderNo()); orderDetl.setCreateBy(9527L); orderDetl.setCreateTime(now); orderDetl.setUpdateBy(9527L); orderDetl.setUpdateTime(now); orderDetl.setStatus(1); orderDetl.setQty(0.0D); if (!orderDetlService.insert(orderDetl)) { throw new CoolException("生成单据明细失败，请联系管理员"); } } } @Override @Transactional public List pakinOrderComplete(OpenOrderCompleteParam param) { List results = new ArrayList<>(); if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) { // 指定订单 Order order = orderService.selectByNo(param.getOrderNo()); if (null != order) { OpenOrderCompeteResult result = new OpenOrderCompeteResult(); results.add(result); result.setOrderNo(order.getOrderNo()); result.setOrderTime(order.getOrderTime()); result.setOrderType(order.getDocType$()); List orderDetls = orderDetlService.selectByOrderId(order.getId()); for (OrderDetl orderDetl : orderDetls) { result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty())); } if (order.getSettle() == 4L) { // 修改订单状态 4.完成 ===>> 6.已上报 if (!orderService.updateSettle(order.getId(), 6L, null)) { throw new CoolException("服务器内部错误，请联系管理员"); } } } } else { // 所有订单 List orders = orderService.selectList(new EntityWrapper().eq("settle", 4L)); for (Order order : orders) { OpenOrderCompeteResult result = new OpenOrderCompeteResult(); results.add(result); result.setOrderNo(order.getOrderNo()); result.setOrderTime(order.getOrderTime()); result.setOrderType(order.getDocType$()); List orderDetls = orderDetlService.selectByOrderId(order.getId()); for (OrderDetl orderDetl : orderDetls) { result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty())); } // 修改订单状态 4.完成 ===>> 6.已上报 if (!orderService.updateSettle(order.getId(), 6L, null)) { throw new CoolException("服务器内部错误，请联系管理员"); } } } return results; } @Override @Transactional public void pakoutOrderCreate(OpenOrderPakoutParam param) { Order order = orderService.selectByNo(param.getOrderNo()); // 如果单据不存在则添加；如果单据存在，作业中无法修改，反之则修改单据 if (!Cools.isEmpty(order)) { if (order.getSettle() > 1L) { throw new CoolException(param.getOrderNo() + "正在出库，无法修改单据"); } orderService.remove(order.getId()); } DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE); Date now = new Date(); // 单据主档 order = new Order( String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空] param.getOrderNo(), // 订单编号 DateUtils.convert(now), // 单据日期 docType.getDocId(), // 单据类型 null, // 项目编号 null, // null, // 调拨项目编号 null, // 初始票据号 null, // 票据号 null, // 客户编号 null, // 客户 null, // 联系方式 null, // 操作人员 null, // 合计金额 null, // 优惠率 null, // 优惠金额 null, // 销售或采购费用合计 null, // 实付金额 null, // 付款类型 null, // 业务员 null, // 结算天数 null, // 邮费支付类型 null, // 邮费 null, // 付款时间 null, // 发货时间 null, // 物流名称 null, // 物流单号 1L, // 订单状态 1, // 状态 9527L, // 添加人员 now, // 添加时间 9527L, // 修改人员 now, // 修改时间 null // 备注 ); if (!orderService.insert(order)) { throw new CoolException("生成单据主档失败，请联系管理员"); } // 单据明细档 List list = new ArrayList<>(); List orderDetails = param.getOrderDetails(); for (DetlDto detail : orderDetails) { DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme()); if (DetlDto.has(list, dto)) { DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch()); assert detlDto != null; detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme()); } else { list.add(dto); } } for (DetlDto detlDto : list) { Mat mat = matService.selectByMatnr(detlDto.getMatnr()); if (Cools.isEmpty(mat)) { throw new CoolException(detlDto.getMatnr() + "编号商品检索失败，请先添加商品"); } OrderDetl orderDetl = new OrderDetl(); orderDetl.sync(mat); orderDetl.setBatch(detlDto.getBatch()); orderDetl.setAnfme(detlDto.getAnfme()); orderDetl.setOrderId(order.getId()); orderDetl.setOrderNo(order.getOrderNo()); orderDetl.setCreateBy(9527L); orderDetl.setCreateTime(now); orderDetl.setUpdateBy(9527L); orderDetl.setUpdateTime(now); orderDetl.setStatus(1); orderDetl.setQty(0.0D); if (!orderDetlService.insert(orderDetl)) { throw new CoolException("生成单据明细失败，请联系管理员"); } } } @Override public List pakoutOrderComplete(OpenOrderCompleteParam param) { List results = new ArrayList<>(); if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) { // 指定订单 Order order = orderService.selectByNo(param.getOrderNo()); if (null != order) { OpenOrderCompeteResult result = new OpenOrderCompeteResult(); results.add(result); result.setOrderNo(order.getOrderNo()); result.setOrderTime(order.getOrderTime()); result.setOrderType(order.getDocType$()); List orderDetls = orderDetlService.selectByOrderId(order.getId()); for (OrderDetl orderDetl : orderDetls) { result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty())); } if (order.getSettle() == 4L) { // 修改订单状态 4.完成 ===>> 6.已上报 if (!orderService.updateSettle(order.getId(), 6L, null)) { throw new CoolException("服务器内部错误，请联系管理员"); } } } } else { // 所有订单 List orders = orderService.selectList(new EntityWrapper().eq("settle", 4L)); for (Order order : orders) { OpenOrderCompeteResult result = new OpenOrderCompeteResult(); results.add(result); result.setOrderNo(order.getOrderNo()); result.setOrderTime(order.getOrderTime()); result.setOrderType(order.getDocType$()); List orderDetls = orderDetlService.selectByOrderId(order.getId()); for (OrderDetl orderDetl : orderDetls) { result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty())); } // 修改订单状态 4.完成 ===>> 6.已上报 if (!orderService.updateSettle(order.getId(), 6L, null)) { throw new CoolException("服务器内部错误，请联系管理员"); } } } return results; } @Override @Transactional public List queryStock() { return locDetlService.queryStockTotal(); } @Override @Transactional public void packageUp(PackParam param) { if (Cools.isEmpty(param.getBarcode())) { throw new CoolException("barcode不能为空"); } Mat analyse = MatUtils.analyseMat(param.getBarcode()); Pack pack = packService.selectByBarcode(param.getBarcode()); if (null != pack) { throw new CoolException(param.getBarcode() + "重复提交"); } Date now = new Date(); pack = new Pack( param.getBarcode(), // 条码[非空] analyse.getMatnr(), // 商品编号 analyse.getBarcode(), // 序列码 1L, // 订单状态 1, // 状态 now, // 添加时间 null, // 添加人员 now, // 修改时间 null, // 修改人员 null // 备注 ); if (!packService.insert(pack)) { throw new CoolException("服务器内部错误，请联系管理员"); } Mat mat = matService.selectByMatnr(analyse.getMatnr()); if (mat == null) { mat = new Mat(); // 分类 Long tagId; // 一级分类 if (!Cools.isEmpty(param.getGroupCode()) && !Cools.isEmpty(param.getGroupName())) { Tag priTag = tagService.selectByName(param.getGroupCode(), 2); if (priTag == null) { Tag top = tagService.getTop(); NodeUtils nodeUtils = new NodeUtils(); nodeUtils.executePath(top.getId()); priTag = new Tag( null, // 编号 param.getGroupCode(), // 名称 top.getId(), // 父级 top.getName(), // 父级名称 nodeUtils.path.toString(), // 关联路径 nodeUtils.pathName.toString(), // 关联路径名 0, // 类型 null, // 负责人 null, // 图片 null, // 简要描述 null, // 数量 2, // 等级 null, // 排序 1, // 状态 now, // 添加时间 null, // 添加人员 now, // 修改时间 null, // 修改人员 null // 备注 ); if (tagMapper.insert(priTag) == 0) { throw new CoolException("服务器内部错误，请联系管理员"); } } // 二级分类 Tag secTag = tagService.selectByName(param.getGroupName(), 3); if (secTag == null) { NodeUtils nodeUtils = new NodeUtils(); nodeUtils.executePath(priTag.getId()); secTag = new Tag( null, // 编号 param.getGroupName(), // 名称 priTag.getId(), // 父级 priTag.getName(), // 父级名称 nodeUtils.path.toString(), // 关联路径 nodeUtils.pathName.toString(), // 关联路径名 0, // 类型 null, // 负责人 null, // 图片 null, // 简要描述 null, // 数量 3, // 等级 null, // 排序 1, // 状态 now, // 添加时间 null, // 添加人员 now, // 修改时间 null, // 修改人员 null // 备注 ); if (tagMapper.insert(secTag) == 0) { throw new CoolException("服务器内部错误，请联系管理员"); } } tagId = secTag.getId(); } else { tagId = tagService.getTop().getId(); } mat.setTagId(tagId); mat.setMatnr(analyse.getMatnr()); mat.setMaktx(param.getMaterialName()); mat.setSpecs(param.getConfigureDesc()); mat.setModel(analyse.getModel()); mat.setStatus(1); mat.setCreateTime(now); mat.setUpdateTime(now); if (!matService.insert(mat)) { throw new CoolException("服务器内部错误，请联系管理员"); } else { log.info("打包上线添加新物料[商品编号：{}]", mat.getMatnr()); } } } @Override @Transactional public void syncMat(MatSyncParam param) { if (Cools.isEmpty(param.getMatDetails()) || param.getMatDetails().size() <=0 ) { throw new CoolException("商品数据为空"); } for(MatSyncParam.MatParam matParam : param.getMatDetails()){ if(Cools.isEmpty(matParam.getMatnr())){ throw new CoolException("商品编码不能为空"); } Date now = new Date(); Mat mat = matService.selectByMatnr(matParam.getMatnr()); if (mat == null) { mat = new Mat(); // 分类 Long tagId; // 一级分类 if (!Cools.isEmpty(matParam.getGroupCode()) && !Cools.isEmpty(matParam.getGroupName())) { Tag priTag = tagService.selectByName(matParam.getGroupCode(), 2); if (priTag == null) { Tag top = tagService.getTop(); NodeUtils nodeUtils = new NodeUtils(); nodeUtils.executePath(top.getId()); priTag = new Tag( null, // 编号 matParam.getGroupCode(), // 名称 top.getId(), // 父级 top.getName(), // 父级名称 nodeUtils.path.toString(), // 关联路径 nodeUtils.pathName.toString(), // 关联路径名 0, // 类型 null, // 负责人 null, // 图片 null, // 简要描述 null, // 数量 2, // 等级 null, // 排序 1, // 状态 now, // 添加时间 null, // 添加人员 now, // 修改时间 null, // 修改人员 null // 备注 ); if (tagMapper.insert(priTag) == 0) { throw new CoolException("服务器内部错误，请联系管理员"); } } // 二级分类 Tag secTag = tagService.selectByName(matParam.getGroupName(), 3); if (secTag == null) { NodeUtils nodeUtils = new NodeUtils(); nodeUtils.executePath(priTag.getId()); secTag = new Tag( null, // 编号 matParam.getGroupName(), // 名称 priTag.getId(), // 父级 priTag.getName(), // 父级名称 nodeUtils.path.toString(), // 关联路径 nodeUtils.pathName.toString(), // 关联路径名 0, // 类型 null, // 负责人 null, // 图片 null, // 简要描述 null, // 数量 3, // 等级 null, // 排序 1, // 状态 now, // 添加时间 null, // 添加人员 now, // 修改时间 null, // 修改人员 null // 备注 ); if (tagMapper.insert(secTag) == 0) { throw new CoolException("服务器内部错误，请联系管理员"); } } tagId = secTag.getId(); } else { tagId = tagService.getTop().getId(); } mat.sync(param); // mat.setMatnr(param.getMatnr()); // mat.setMaktx(param.getMaktx()); // mat.setSpecs(param.getSpecs()); // mat.setModel(param.getModel()); mat.setTagId(tagId); mat.setStatus(1); mat.setCreateTime(now); mat.setUpdateTime(now); if (!matService.insert(mat)) { throw new CoolException("服务器内部错误，请联系管理员"); } else { log.info("同步新物料[商品编号：{}]", mat.getMatnr()); } } else { mat.sync(param); if (!matService.update(mat, new EntityWrapper().eq("matnr",matParam.getMatnr()))) { throw new CoolException("更新已存在商品信息失败，请联系管理员"); } } } } /*...........................徐工汉云..............以下.............上饶江铜...........................*/ /*............................Created by Monkey D. Luffy on 2023.07.19.............................*/ /* * 贴标机申请获取货物信息 * */ @Override @Transactional public LabellerMatParam labellerMat(LabellerMatParam param){ if (Cools.isEmpty(param.getDevNo())){ throw new CoolException("参数：站点号 devNo为空"); }else if (Cools.isEmpty(param.getLabNo())){ throw new CoolException("参数：贴标机号 labNo为空"); } BasDevp basDevp = basDevpService.selectById(param.getDevNo()); if (Cools.isEmpty(basDevp)){ throw new CoolException("参数：站点号 devNo不存在"); }else if (Cools.isEmpty(basDevp.getWrkNo()) || basDevp.getWrkNo()==0){ throw new CoolException("站点:"+param.getDevNo()+" 不存在工作中任务"); } WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", basDevp.getWrkNo())); if (Cools.isEmpty(wrkMast)){ throw new CoolException("站点:"+param.getDevNo()+" 工作中任务不存在,任务号："+basDevp.getWrkNo()); }else if (!wrkMast.getWrkSts().equals(52L)){ throw new CoolException("站点:"+param.getDevNo()+" 工作中任务状态已变更，请勿重复申请,任务号："+basDevp.getWrkNo()+",任务状态:"+wrkMast.getWrkSts$()); } List wrkDetls = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", basDevp.getWrkNo())); if (Cools.isEmpty(wrkDetls) || wrkDetls.size()==0){ throw new CoolException("站点:"+param.getDevNo()+" 工作中任务不存在任务明细,任务号："+basDevp.getWrkNo()); } LabellerMatParam labellerMatParam = new LabellerMatParam(); labellerMatParam.setDevNo(param.getDevNo()); labellerMatParam.setLabNo(param.getLabNo()); labellerMatParam.setWrkNo(basDevp.getWrkNo().toString()); // ArrayList combMats = new ArrayList<>(); ArrayList boxNos = new ArrayList<>(); // String orderNo = ""; for (WrkDetl wrkDetl:wrkDetls){ LabellerMatParam.BoxNo boxNo = new LabellerMatParam.BoxNo(); boxNo.setBoxNo(wrkDetl.getBatch()); boxNos.add(boxNo); } labellerMatParam.setBoxNos(boxNos); // for (WrkDetl wrkDetl:wrkDetls){ // LabellerMatParam.CombMat combMat = new LabellerMatParam.CombMat(wrkDetl); // orderNo=wrkDetl.getOrderNo(); // combMat.setTemp1("1"); // combMats.add(combMat); // } // labellerMatParam.setCombMats(combMats); // labellerMatParam.setLabellingTime(DateUtils.convert(new Date())); // labellerMatParam.setLabTemplate("1"); // labellerMatParam.setOrderNo(orderNo); wrkMast.setWrkSts(53L); if (!wrkMastService.updateById(wrkMast)){ throw new CoolException("异常，请重新申请"); } return labellerMatParam; } /* * 贴标机贴标完成 * */ @Override @Transactional public void labellerComplete(LabellerCompleteParam param) { if (Cools.isEmpty(param.getDevNo())){ throw new CoolException("参数：站点号 devNo为空"); }else if (Cools.isEmpty(param.getLabNo())){ throw new CoolException("参数：贴标机号 labNo为空"); }else if (Cools.isEmpty(param.getLabResult())){ throw new CoolException("参数：贴标结果 labResult为空"); }else if (Cools.isEmpty(param.getWrkNo())){ throw new CoolException("参数：贴标任务号 wrkNo为空"); } BasDevp basDevp = basDevpService.selectById(param.getDevNo()); if (Cools.isEmpty(basDevp)){ throw new CoolException("参数：站点号 devNo="+param.getDevNo()+"不存在"); }else if (Cools.isEmpty(basDevp.getWrkNo()) || basDevp.getWrkNo()==0 ){ throw new CoolException("站点:"+param.getDevNo()+" 不存在工作中任务"); }else if(!basDevp.getWrkNo().toString().equals(param.getWrkNo())){ throw new CoolException("站点:"+param.getDevNo()+" 进行中任务号="+basDevp.getWrkNo()+" 与贴标结果返回任务号="+param.getWrkNo()+" 不一致"); } WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", basDevp.getWrkNo())); if (Cools.isEmpty(wrkMast)){ throw new CoolException("站点:"+param.getDevNo()+" 工作中任务不存在,任务号："+basDevp.getWrkNo()); }else if (!wrkMast.getWrkSts().equals(53L)){ throw new CoolException("站点:"+param.getDevNo()+" 工作中任务状态已变更，请勿重复申请,任务号："+basDevp.getWrkNo()+",任务状态:"+wrkMast.getWrkSts$()); } if (param.getLabResult().equals("OK")){ wrkMast.setWrkSts(54L); wrkMast.setStaNo(144); if (!wrkMastService.updateById(wrkMast)){ throw new CoolException("异常，请重新申请"); } }else if (param.getLabResult().equals("NG")){ wrkMast.setWrkSts(52L);//重新贴标 if (!wrkMastService.updateById(wrkMast)){ throw new CoolException("异常，请重新申请"); } }else { throw new CoolException("参数：贴标结果:labResult"+param.getLabResult()+";请按规则发送：成功：OK 、失败:NG"); } } /* * 中控：码垛完成下发入库信息 * */ @Override @Transactional public void PalletizingCompleteTwoFloorParam(PalletizingCompleteTwoFloorParam param) { Long userId = 7777L;//中控 //判断param参数 if (Cools.isEmpty(param.getBarcode())){ throw new CoolException("参数：托盘码 barcode为空"); }else if (Cools.isEmpty(param.getPalletizingNo())){ throw new CoolException("参数：码垛位编号 palletizingNo为空"); }else if (Cools.isEmpty(param.getBoxType())){ throw new CoolException("参数：木箱类型 boxType为空"); }else if (Cools.isEmpty(param.getMatList()) || param.getMatList().size()==0){ throw new CoolException("参数：物料明细 matLists为空"); } String matnrOne = "";//木箱相同位置 规格 matnr校验 1、左 String matnrTwo = "";//木箱相同位置 规格 matnr校验 2、右 ArrayList boxNos = new ArrayList<>(); //木箱唯一编码查重 （batch） //判断matLists参数 for (PalletizingCompleteTwoFloorParam.MatList matList:param.getMatList()){ if (Cools.isEmpty(matList.getMatnr())){ throw new CoolException("参数：规格 matnr为空"); }else if (Cools.isEmpty(matList.getPosition())){ throw new CoolException("规格："+matList.getMatnr()+"、参数：码垛位置 position为空"); }else if (Cools.isEmpty(matList.getBatch())){ throw new CoolException("规格："+matList.getMatnr()+"、参数：木箱编号 batch为空"); }else if (Cools.isEmpty(matList.getModel())){ throw new CoolException("规格："+matList.getMatnr()+"、参数：卷号 model为空"); }else if (Cools.isEmpty(matList.getBatch())){ throw new CoolException("规格："+matList.getMatnr()+"、参数：木箱编号 boxNo为空"); }else if (Cools.isEmpty(matList.getWeight()) || matList.getWeight().equals(0D)){ throw new CoolException("规格："+matList.getMatnr()+"、参数：净重 weight为空"); }else if (Cools.isEmpty(matList.getRoughWeight()) || matList.getRoughWeight().equals(0D)){ throw new CoolException("规格："+matList.getMatnr()+"、参数：毛重 roughWeight"); }else if (Cools.isEmpty(matList.getRollExtent()) || matList.getRollExtent().equals(0D)){ throw new CoolException("规格："+matList.getMatnr()+"、参数：卷长度 rollExtent"); } // else if (Cools.isEmpty(matList.getJoint()) || matList.getJoint()==0){ // throw new CoolException("规格："+matList.getMatnr()+"、参数：接头数 joint"); // } if (matList.getPosition().equals("1")){//1、左 2、右 if (!matnrOne.equals("")){ if (!matnrOne.equals(matList.getMatnr())){ throw new CoolException("木箱位置："+matList.getPosition()+"存在不同规格卷信息"); } }else { matnrOne=matList.getMatnr(); } }else if (matList.getPosition().equals("2")){ if (!matnrTwo.equals("")){ if (!matnrTwo.equals(matList.getMatnr())){ throw new CoolException("木箱位置："+matList.getPosition()+"存在不同规格卷信息"); } }else { matnrTwo=matList.getMatnr(); } }else { throw new CoolException("参数：木箱编号 boxNo:"+matList.getBatch()+",木箱位置错误："+matList.getPosition()); } if (!boxNos.contains(matList.getBatch())){ boxNos.add(matList.getBatch()); }else { throw new CoolException("参数：木箱编号 boxNo:"+matList.getBatch()+",木箱编码存在重复"); } } // BasDevp basDevp = basDevpService.selectById(Integer.parseInt(param.getDevNo$())); // if (Cools.isEmpty(basDevp)){ // throw new CoolException("参数：码垛位编号 palletizingNo="+param.getPalletizingNo()+"不存在"); // } // if (Cools.isEmpty(basDevp.getAutoing()) || !basDevp.getAutoing().equals("Y")){ // throw new CoolException("码垛位编号 palletizingNo="+param.getPalletizingNo()+" 所处站点不是自动状态"); // } // if (Cools.isEmpty(basDevp.getLoading()) || !basDevp.getLoading().equals("Y")){ // throw new CoolException("码垛位编号 palletizingNo="+param.getPalletizingNo()+" 所处站点不是有物状态"); // } // if (Cools.isEmpty(basDevp.getCanining()) || !basDevp.getCanining().equals("Y")){ // throw new CoolException("码垛位编号 palletizingNo="+param.getPalletizingNo()+" 所处站点不是能入状态"); // } if (locDetlService.selectCount(new EntityWrapper().eq("zpallet", param.getBarcode()))!=0 || wrkDetlService.selectCount(new EntityWrapper().eq("zpallet", param.getBarcode()))!=0 || waitPakinService.selectCount(new EntityWrapper().eq("zpallet", param.getBarcode()))!=0){ throw new CoolException("托盘条码："+param.getBarcode()+"已存在，请勿重复组托"); } Date now = new Date(); for (PalletizingCompleteTwoFloorParam.MatList matList:param.getMatList()){ Mat mat = matService.selectByMatnr(matList.getMatnr()); if (Cools.isEmpty(mat)) { mat = new Mat(); mat.setMatnr(matList.getMatnr()); mat.setMaktx(matList.getMatnr()); mat.setTagId(tagService.getTop().getId()); mat.setCreateBy(userId); mat.setCreateTime(now); mat.setUpdateBy(userId); mat.setUpdateTime(now); mat.setStatus(1); if (!matService.insert(mat)) { throw new CoolException("规格添加失败，请联系管理员"); } } WaitPakin waitPakin = new WaitPakin(); waitPakin.sync(mat); waitPakin.setBatch(matList.getBatch()); //木箱编码 //批次 唯一值 箱号 waitPakin.setModel(matList.getModel()); //卷号 唯一值 waitPakin.setBrand(param.getBoxType()); //木箱类型 waitPakin.setZpallet(param.getBarcode()); //托盘码 waitPakin.setOrigin(matList.getPosition()); //木箱在托盘上的位置 waitPakin.setWeight(matList.getWeight()); //净重 waitPakin.setVolume(matList.getRoughWeight()); //毛重 waitPakin.setPrice(matList.getRollExtent()); //长度 waitPakin.setSpecs(String.valueOf(matList.getJoint())); //接头 waitPakin.setIoStatus("N"); // 入出状态 waitPakin.setAnfme(matList.getAnfme()); // 数量 waitPakin.setStatus("Y"); // 状态 waitPakin.setAppeUser(userId); waitPakin.setAppeTime(now); waitPakin.setModiUser(userId); waitPakin.setModiTime(now); if (!waitPakinService.insert(waitPakin)) { throw new CoolException("保存入库通知档失败"); } } } /* * 松盛(1楼)：码垛完成下发入库信息 * */ @Override @Transactional public void palletizingCompleteS(PalletizingCompleteParam param) { //判断param参数 if (Cools.isEmpty(param.getBarcode())){ throw new CoolException("参数：托盘码 barcode为空"); } WrkMast wrkMast = wrkMastService.selectByBarcode(param.getBarcode()); if (Cools.isEmpty(wrkMast) || wrkMast.getWrkSts()!=2){ log.error("退库码垛完成，返回托盘码未查询到工作档案！"); throw new CoolException("参数：托盘码 barcode未查询到工作档案"); } wrkMast.setSheetNo("4"); wrkMastService.updateById(wrkMast); } /* *中控：出库完成月台相关 * */ @Override @Transactional public void balconyComplete(LabellerMatParam param) { if (Cools.isEmpty(param.getWrkNo())){ throw new CoolException("工作号为空！"); } WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", param.getWrkNo())); if (Cools.isEmpty(wrkMast)){ throw new CoolException("工作号为空！"); } wrkMast.setWrkSts(57L); wrkMastService.updateById(wrkMast); } /* * 桁架上位软件：单次拆垛完成通知 * */ @Override @Transactional public void singleUnstackingComplete(SingleUnstackingCompleteParam param) { Long userId = 8888L;//桁架上位软件 //判断param参数 if (Cools.isEmpty(param.getPalletizingNo())){ throw new CoolException("参数：码垛位编号 palletizingNo为空"); }else if (Cools.isEmpty(param.getMatList()) || param.getMatList().size()==0){ throw new CoolException("参数：物料明细 matLists为空"); } ArrayList wrkDetlsNew = new ArrayList<>(); ArrayList wrkDetlsOld = new ArrayList<>(); //判断matLists参数 for (SingleUnstackingCompleteParam.MatList matList:param.getMatList()){ if (Cools.isEmpty(matList.getPosition())){ throw new CoolException("参数：码垛位置 position为空"); }else if (Cools.isEmpty(matList.getBoxNo())){ throw new CoolException("参数：木箱编号 boxNo为空"); } WrkDetlSingle wrkDetlSingleOne = wrkDetlSingleService.selectOne(new EntityWrapper().eq("batch", matList.getBoxNo())); List wrkDetlSingles = wrkDetlSingleService.selectList(new EntityWrapper() .eq("wrk_no", wrkDetlSingleOne.getWrkNo()).eq("io_time", wrkDetlSingleOne.getIoTime())); boolean sign=true; for (WrkDetlSingle wrkDetlSingle:wrkDetlSingles){ WrkDetl wrkDetl = new WrkDetl(); wrkDetl.sync(wrkDetlSingle); wrkDetlsNew.add(wrkDetl); wrkDetlsOld.add(wrkDetlSingle); sign=false; break; } if (sign){ throw new CoolException("参数：木箱编号 boxNo未查询到对应的工作明细！"); } } // 生成工作号 int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(202)); Date now = new Date(); // 生成工作档 WrkMast wrkMast = new WrkMast(); wrkMast.setWrkNo(workNo); wrkMast.setIoTime(now); wrkMast.setWrkSts(51L); // 工作状态：生成入库ID wrkMast.setIoType(202); // 入出库状态：202.拆垛后出库 wrkMast.setIoPri(99D); // 优先级 wrkMast.setSourceStaNo(param.getDevNo$()); wrkMast.setStaNo(144); //贴标站点 直接到尾端 // 操作人员数据 wrkMast.setAppeUser(userId); wrkMast.setAppeTime(now); wrkMast.setModiUser(userId); wrkMast.setModiTime(now); if (!wrkMastService.insert(wrkMast)) { throw new CoolException("生成工作档失败==》桁架上位软件：单次拆垛完成通知"); } for (WrkDetl wrkDetl : wrkDetlsNew){ wrkDetl.setWrkNo(wrkMast.getWrkNo()); wrkDetl.setIoTime(wrkMast.getIoTime()); wrkDetl.setAppeTime(now); wrkDetl.setModiTime(now); if (!wrkDetlService.insert(wrkDetl)) { throw new CoolException("保存工作明细失败==》桁架上位软件：单次拆垛完成通知"); } } for (WrkDetlSingle wrkDetlSingle : wrkDetlsOld) { wrkDetlSingleService.delete(new EntityWrapper() .eq("batch",wrkDetlSingle.getBatch()) .eq("wrk_no",wrkDetlSingle.getWrkNo()) .eq("io_time",wrkDetlSingle.getIoTime())); } } /* * 桁架上位软件：单托拆垛完成通知 * */ @Override @Transactional public void singleMountUnstackingComplete(SingleMountUnstackingCompleteParam param) { // Long userId = 8888L;//桁架上位软件 //判断param参数 if (Cools.isEmpty(param.getBarcode())){ throw new CoolException("参数：托盘码 barcode为空"); } WrkMast wrkMastMatrix = wrkMastService.selectByBarcode(param.getBarcode()); if (Cools.isEmpty(wrkMastMatrix)){ throw new CoolException("参数：托盘码查询工作档失败："+param.getBarcode()); } wrkMastMatrix.setSheetNo("2"); if (!wrkMastService.updateById(wrkMastMatrix)){ throw new CoolException("更新工作档失败==》桁架上位软件：单托拆垛完成通知"); } } /* * * */ @Override @Transactional public void cs2() { // int[] staNos =new int[]{122}; // for (Integer staNo:staNos){ // int[] crnNos =new int[]{6}; // for (Integer crnNo:crnNos){ // descSta(staNo,crnNo); // } // } } @Override public void updateBarcode() { List locMasts = locMastService.selectList(new EntityWrapper().eq("loc_sts", "D")); for (int i = 0; i < locMasts.size(); i ++) { LocMast locMast = locMasts.get(i); locMast.setBarcode("a"+i); locMastService.updateById(locMast); } System.out.println("更新完了" + locMasts.size()); } @Override @Transactional public void prodCheck(List param) { if (param.isEmpty()) { throw new CoolException("请求参数不能为空"); } for (ProdCheckParam checkParam : param) { // 更新库存明细是否合格 LocDetl locDetl = locDetlService.selectOne(new EntityWrapper().eq("brand", checkParam.getPackageGroupNo()) .eq("unit", checkParam.getBoxNo()).eq("model", checkParam.getRollNo())); // 更新商品表是否合格 Mat mat = matService.selectOne(new EntityWrapper().eq("brand", checkParam.getPackageGroupNo()) .eq("unit", checkParam.getBoxNo()).eq("model", checkParam.getRollNo())); if (locDetl == null || mat == null) { throw new CoolException("更新是否合格物料不存在：" + checkParam); } locDetl.setThreeCode(checkParam.getQualified()); mat.setThreeCode(checkParam.getQualified()); locDetlService.update(locDetl,new EntityWrapper().eq("brand", checkParam.getPackageGroupNo()) .eq("unit", checkParam.getBoxNo()).eq("model", checkParam.getRollNo())); matService.update(mat,(new EntityWrapper().eq("brand", checkParam.getPackageGroupNo()) .eq("unit", checkParam.getBoxNo()).eq("model", checkParam.getRollNo()))); } } @Override @Transactional public String fxprk(FxprkParam param) { // 根据包装组号获取到木箱卷信息 List list = matService.selectList(new EntityWrapper().in("brand", param.getBoxList().stream().map(FxprkParam.Box::getPackageGroupNo).collect(Collectors.toList()))); if (list.isEmpty()) { throw new CoolException("没有查询到该包装组号信息：" + param.getBoxList().toString()); } LocTypeDto locTypeDto = new LocTypeDto(); locTypeDto.setLocType1((short) 1); StartupDto dto = commonService.getLocNo(1, param.getPalletizingNo(), locTypeDto, 0); // 返回GWCS目标信息 boolean result = pushStaNoToGwcs(param.getPalletizingNo(), dto.getStaNo(), dto.getWorkNo(), param.getBarcode()); // if (!result) { // throw new CoolException("入库回推入库码头给GWCS失败"); // } int workNo = dto.getWorkNo(); Date now = new Date(); // 生成工作档 WrkMast wrkMast = new WrkMast(); wrkMast.setWrkNo(workNo); wrkMast.setIoTime(new Date()); wrkMast.setWrkSts(1L); // 工作状态：设备上走 wrkMast.setIoType(1); // 入出库状态：1.入库 wrkMast.setIoPri(13D); // 优先级 wrkMast.setCrnNo(dto.getCrnNo()); wrkMast.setSourceStaNo(param.getPalletizingNo()); wrkMast.setStaNo(dto.getStaNo()); wrkMast.setLocNo(dto.getLocNo()); wrkMast.setBarcode(param.getBarcode()); // 托盘码 wrkMast.setFullPlt("Y"); // 满板：Y wrkMast.setPicking("N"); // 拣料 wrkMast.setExitMk("N"); // 退出 wrkMast.setEmptyMk("N"); // 空板 wrkMast.setLinkMis("Y"); wrkMast.setCtnType(1); // 容器类型 // 操作人员数据 wrkMast.setAppeTime(now); wrkMast.setModiTime(now); boolean res = wrkMastService.insert(wrkMast); if (!res) { throw new CoolException("保存工作档失败"); } for (Mat obj : list) { WrkDetl wrkDetl = new WrkDetl(); wrkDetl.setWrkNo(wrkMast.getWrkNo()); wrkDetl.setAnfme(1.0); // 重新定位木箱位置 for (FxprkParam.Box box :param.getBoxList()) { if (box.getPackageGroupNo().equals(obj.getBrand())) { if (!box.getBoxPos().equals(obj.getOrigin())) { wrkDetl.setOrigin(box.getBoxPos()); wrkDetl.setZpallet(param.getBarcode()); wrkDetl.setBarcode(param.getBarcode()); matMapper.updateBoxPos(box.getPackageGroupNo(), box.getBoxPos(),param.getBarcode()); } break; } } wrkDetl.sync(obj); wrkDetl.setIoTime(now); wrkDetl.setAppeTime(now); wrkDetl.setModiTime(now); if (!wrkDetlService.insert(wrkDetl)) { throw new CoolException("保存工作明细失败"); } } // 更新目标库位状态 LocMast locMast = locMastService.selectById(dto.getLocNo()); if (locMast.getLocSts().equals("O")) { locMast.setLocSts("S"); // S.入库预约 locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { throw new CoolException("改变库位状态失败"); } } else { throw new CoolException(dto.getLocNo() + "目标库位已被占用"); } return "入库成功"; } @Override @Transactional public R kthl(KthlParam param) { // 获取模式为电脑模式，无任务的堆垛机列表:防止分配到堆垛机不可用 List basCrnps = basCrnpService.selectList(new EntityWrapper().eq("crn_sts",3) .eq("wrk_no",0).eq("in_enable","Y").eq("out_enable","Y")); if (basCrnps.isEmpty()) { // 都有任务则获取电脑模式的堆垛机列表 basCrnps = basCrnpService.selectList(new EntityWrapper().eq("crn_sts",3).eq("in_enable","Y") .eq("out_enable","Y")); } if (basCrnps.isEmpty()) { throw new CoolException("没有可用堆垛机,堆垛机停止或异常或禁用"); } // 可用堆垛机列表 List crnNoList = basCrnps.stream().map(BasCrnp::getCrnNo).collect(Collectors.toList()); Integer crnNo = crnNoList.get(0); int workNo = commonService.getWorkNo(5); Date now = new Date(); // 生成工作档 WrkMast wrkMast = new WrkMast(); wrkMast.setWrkNo(workNo); wrkMast.setIoTime(new Date()); wrkMast.setWrkSts(1L); // wrkMast.setIoType(3); // 站到站 wrkMast.setIoPri(14D); // 优先级 wrkMast.setCrnNo(crnNo); wrkMast.setSourceStaNo(secondFloorIn[crnNo]); wrkMast.setStaNo(3013); wrkMast.setLocNo(""); wrkMast.setBarcode(param.getBarcode()); // 托盘码 wrkMast.setFullPlt("N"); // 满板：Y wrkMast.setPicking("N"); // 拣料 wrkMast.setExitMk("N"); // 退出 wrkMast.setEmptyMk("Y"); // 空板 wrkMast.setLinkMis("Y"); wrkMast.setCtnType(1); // 容器类型 // 操作人员数据 wrkMast.setAppeTime(now); wrkMast.setModiTime(now); boolean res = wrkMastService.insert(wrkMast); if (!res) { throw new CoolException("保存工作档失败"); } // 返回GWCS目标信息 pushStaNoToGwcs(wrkMast.getSourceStaNo(),wrkMast.getStaNo(),workNo,param.getBarcode()); return R.ok("空托回流请求成功"); } @Override @Transactional public R gwmsGenerateInventory(GwmsGenerateInventoryDto param) { if (Cools.isEmpty(param)) { throw new CoolException("请求参数有误：" + param); } if (!Cools.isEmpty(param.getBarcode())) { int zpalletCount = locDetlService.selectCount(new EntityWrapper().eq("zpallet", param.getBarcode())); if (zpalletCount > 0) { throw new CoolException("库存托盘码已存在：" + param.getBarcode()); } int barcodeCount = wrkMastService.selectCount(new EntityWrapper().eq("barcode", param.getBarcode())); if (barcodeCount > 0) { throw new CoolException("工作档已存在该托盘码：" + param.getBarcode()); } } LocTypeDto locTypeDto = new LocTypeDto(); locTypeDto.setLocType1((short)1); int iotype = 1; if (Cools.isEmpty(param.getMatList())) { iotype = 10; } // 根据源站点寻找库位 // StartupDto dto = commonService.getLocNo(1, 1, param.getPalletizingNo(), null,null,null, locTypeDto); StartupDto dto = commonService.getLocNo(iotype, param.getPalletizingNo(), locTypeDto,0); // 返回GWCS目标信息 pushStaNoToGwcs(param.getPalletizingNo(),dto.getStaNo(),dto.getWorkNo(),param.getBarcode()); int workNo = dto.getWorkNo(); Date now = new Date(); // 生成工作档 WrkMast wrkMast = new WrkMast(); wrkMast.setWrkNo(workNo); wrkMast.setIoTime(new Date()); wrkMast.setWrkSts(1L); // 工作状态：设备上走 wrkMast.setIoType(iotype); // 入出库状态：1.入库 wrkMast.setIoPri(13D); // 优先级 wrkMast.setCrnNo(dto.getCrnNo()); wrkMast.setSourceStaNo(param.getPalletizingNo()); wrkMast.setStaNo(dto.getStaNo()); wrkMast.setLocNo(dto.getLocNo()); wrkMast.setBarcode(param.getBarcode()); // 托盘码 wrkMast.setFullPlt("Y"); // 满板：Y wrkMast.setPicking("N"); // 拣料 wrkMast.setExitMk("N"); // 退出 wrkMast.setEmptyMk("N"); // 空板 wrkMast.setLinkMis("Y"); wrkMast.setCtnType(1); // 容器类型 // 操作人员数据 wrkMast.setAppeTime(now); wrkMast.setModiTime(now); boolean res = wrkMastService.insert(wrkMast); if (!res) { throw new CoolException("保存工作档失败"); } if (!Cools.isEmpty(param.getMatList())) { List matList = param.getMatList(); for (GwmsGenerateInventoryDto.MatList obj :matList) { WrkDetl wrkDetl = new WrkDetl(); wrkDetl.setWrkNo(wrkMast.getWrkNo()); obj.getRolls().forEach(roll -> { wrkDetl.setWrkNo(wrkMast.getWrkNo()); wrkDetl.setMatnr(roll.getSpecs()); // 规格 wrkDetl.setMaktx(roll.getSpecs()); //规格 wrkDetl.setUnit(roll.getBoxNo()); // 箱号 wrkDetl.setModel(roll.getRollNo()); // 卷号 wrkDetl.setBrand(obj.getPackageGroupNo()); // 包装组号 wrkDetl.setZpallet(param.getBarcode()); // 托盘码 wrkDetl.setBarcode(param.getBarcode()); wrkDetl.setOrigin(obj.getBoxPos()); // 木箱在托盘位置 wrkDetl.setColor(obj.getBoxType()); // 木箱类型 wrkDetl.setManu(obj.getRollType()); // 管芯类型 wrkDetl.setSku(obj.getWideInWidth()); // 实测宽幅 wrkDetl.setItemNum(obj.getThickness()); // 生箔厚度 wrkDetl.setManuDate(roll.getFqTime()); // 分切下料时间 wrkDetl.setWeight(roll.getNetWeight()); // 净重 wrkDetl.setVolume(roll.getGrossWeight()); // 毛重 wrkDetl.setLength(roll.getLength()); // 长度 wrkDetl.setSpecs(String.valueOf(roll.getSplices())); // 接头 wrkDetl.setAnfme(1.0); // wrkDetl.setThreeCode(null); // 通过mes或excel导入检测是否合格 0不合格，1 合格 wrkDetl.setIoTime(now); wrkDetl.setAppeTime(now); wrkDetl.setModiTime(now); if (!wrkDetlService.insert(wrkDetl)) { throw new CoolException("保存工作明细失败"); } // 物料表备份一份 Mat mat = new Mat(); mat.sync(wrkDetl); mat.setTagId(6L); mat.setCreateTime(now); mat.setUpdateTime(now); if (!matService.insert(mat)) { throw new CoolException("备份物料表失败"); } }); } } // 更新目标库位状态 LocMast locMast = locMastService.selectById(dto.getLocNo()); if (locMast.getLocSts().equals("O")){ locMast.setLocSts("S"); // S.入库预约 locMast.setModiTime(now); if (!locMastService.updateById(locMast)){ throw new CoolException("改变库位状态失败"); } } else { throw new CoolException(dto.getLocNo()+"目标库位已被占用"); } return null; } @Override @Transactional public String crnExecute(CrnExecuteParam param) { if (Cools.isEmpty(param.getStaNo(),param.getWorkNo())){ throw new CoolException("参数不能为空：" + param); } WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", param.getWorkNo())); if (wrkMast == null) { throw new CoolException("不存在该工作号：" + param.getWorkNo()); } wrkMast.setWrkSts(2L); if(wrkMast.getIoType() == 10){ wrkMast.setBarcode(param.getBarcode()); } wrkMastService.updateById(wrkMast); return "请求成功"; } @Override @Transactional public String zwmsOutLocWork(ZwmsOutLocWorkDto param) { Order order = orderService.selectByNo(param.getOrderNo()); if (!Cools.isEmpty(order)) { throw new CoolException(param.getOrderNo() + "单据已存在，请勿重复提交"); } DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE); Date now = new Date(); // 单据主档 order = new Order( String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空] param.getOrderNo(), // 订单编号 DateUtils.convert(now), // 单据日期 docType.getDocId(), // 单据类型 null, // 项目编号 null, // null, // 调拨项目编号 null, // 初始票据号 null, // 票据号 null, // 客户编号 null, // 客户 null, // 联系方式 null, // 操作人员 null, // 合计金额 null, // 优惠率 null, // 优惠金额 null, // 销售或采购费用合计 null, // 实付金额 null, // 付款类型 null, // 业务员 null, // 结算天数 null, // 邮费支付类型 null, // 邮费 null, // 付款时间 null, // 发货时间 null, // 物流名称 null, // 物流单号 1L, // 订单状态 1, // 状态 9527L, // 添加人员 now, // 添加时间 9527L, // 修改人员 now, // 修改时间 null // 备注 ); if (!orderService.insert(order)) { throw new CoolException("生成单据主档失败，请联系管理员"); } // 单据明细档 List list = new ArrayList<>(); List orderDetails = param.getMatDetails(); for (ZwmsOutLocWorkDto.Rolls detail : orderDetails) { DetlDto dto = new DetlDto(detail.getRollNo(), detail.getBoxNo(), 1.0); dto.setOrderNo(detail.getSpecs()); dto.setSplices(detail.getSplices()); if (DetlDto.has(list, dto)) { DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch()); assert detlDto != null; detlDto.setAnfme(detlDto.getAnfme() + 1); } else { list.add(dto); } } for (DetlDto detlDto : list) { // Mat mat = matService.selectByMatnr(detlDto.getMatnr()); OrderDetl orderDetl = new OrderDetl(); // if (Cools.isEmpty(mat)) { // throw new CoolException(detlDto.getMatnr() + "编号商品检索失败，请先添加商品"); // } else { // orderDetl.sync(mat); // } orderDetl.setSpecs(String.valueOf(detlDto.getSplices())); orderDetl.setBatch(detlDto.getBatch() == null ? "" : detlDto.getBatch()); orderDetl.setModel(detlDto.getMatnr()); orderDetl.setMatnr(detlDto.getOrderNo()); orderDetl.setMaktx(detlDto.getOrderNo()); orderDetl.setAnfme(detlDto.getAnfme()); orderDetl.setOrderId(order.getId()); orderDetl.setOrderNo(order.getOrderNo()); orderDetl.setCreateBy(9527L); orderDetl.setCreateTime(now); orderDetl.setUpdateBy(9527L); orderDetl.setUpdateTime(now); orderDetl.setStatus(1); orderDetl.setQty(0.0D); if (!orderDetlService.insert(orderDetl)) { throw new CoolException("生成单据明细失败，请联系管理员"); } } return null; } @Override @Transactional public String outLocResultReport(GhjtApiParam param) { if (Cools.isEmpty(param.getOutLocResult(),param.getWorkNo())) { throw new CoolException("入参不能为空：" + param); } WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", param.getWorkNo())); if (wrkMast == null) { throw new CoolException("该工作档不存在，任务号：" + param.getWorkNo()); } else if(wrkMast.getWrkSts() != 2) { throw new CoolException("工作档当前状态不符合，任务号：" + param.getWorkNo() + "，工作档状态：" + wrkMast.getWrkSts()); } List wrkDetls = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", param.getWorkNo())); // 是否需要复核(出库单需复核) boolean flag = false; if (!wrkDetls.isEmpty()) { flag = wrkDetls.stream().anyMatch(wrkDetl -> wrkDetl.getOrderNo() != null); } // 到达出库口确认为1，更新工作档状态为57.出库完成 if (param.getOutLocResult() == 1) { wrkMast.setWrkSts(20L); // 空托盘到位直接更新工作档状态为14.已出库未确认，空托无需复核确认 if (!flag || wrkMast.getIoType() == 110) { wrkMast.setWrkSts(14L); } wrkMastService.updateById(wrkMast); } return "出库结果上报成功"; } @Autowired private BasCrnpService basCrnpService; @Override @Transactional public String emptyOutLoc(GhjtApiParam param) { // 3102/3009/3008/3006/3003/3002→3047/3112 // 获取模式为电脑模式，无任务的堆垛机列表:防止分配到堆垛机不可用 List basCrnps = basCrnpService.selectList(new EntityWrapper().eq("crn_sts",3) .eq("wrk_no",0)); if (basCrnps.isEmpty()) { // 都有任务则获取电脑模式的堆垛机列表 basCrnps = basCrnpService.selectList(new EntityWrapper().eq("crn_sts",3)); } if (basCrnps.isEmpty()) { throw new CoolException("没有可用堆垛机,堆垛机停止或异常"); } // 可用堆垛机列表 List crnNoList = basCrnps.stream().map(BasCrnp::getCrnNo).collect(Collectors.toList()); // 寻找空托盘库位，先找浅库位 List locMasts; locMasts = locMastService.selectList(new EntityWrapper().eq("loc_sts","D") .orderAsc(Arrays.asList("row1","lev1","bay1")).in("crn_no",crnNoList).in("row1",3,4,6,7,10,11,14,15,18,19,22,23)); if (locMasts.isEmpty()) { locMasts = locMastService.selectList(new EntityWrapper().eq("loc_sts","D") .orderAsc(Arrays.asList("row1","lev1","bay1")).in("crn_no",crnNoList).in("row1",1,4,5,8,9,12,13,16,17,20,21,24)); } if (locMasts.isEmpty()) { throw new CoolException("没有找到空托盘，站点：" + param.getStaNo()); } // 取第一个空库位 LocMast locMast = locMasts.get(0); // 获取工作路径 StaDesc staDesc = staDescService.selectOne(new EntityWrapper().eq("type_no", 110).eq("stn_no", param.getStaNo()).eq("crn_no", locMast.getCrnNo())); if (staDesc == null) { throw new CoolException("路径不存在"); } //2.生成空托盘出库工作档 Date now = new Date(); WrkMast wrkMast = new WrkMast(); wrkMast.setWrkNo(commonService.getWorkNo(WorkNoType.PAKOUT.type)); wrkMast.setIoTime(now); wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID wrkMast.setIoType(110); // 入出库状态： 110.空板出库 wrkMast.setIoPri(10D); wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 源站 wrkMast.setStaNo(staDesc.getStnNo()); // 目标站 wrkMast.setCrnNo(locMast.getCrnNo()); wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位 wrkMast.setBarcode(locMast.getBarcode()); wrkMast.setFullPlt("N"); // 满板：Y wrkMast.setPicking("N"); // 拣料 wrkMast.setExitMk("N"); // 退出 wrkMast.setEmptyMk("Y"); // 空板 wrkMast.setLinkMis("N"); wrkMast.setAppeUser(9999L); wrkMast.setAppeTime(now); wrkMast.setModiUser(9999L); wrkMast.setModiTime(now); if (!wrkMastService.insert(wrkMast)) { throw new CoolException("保存工作档失败"); } // 3.更新库位状态 D.空板 -> R.出库预约 if (locMast.getLocSts().equals("D")) { locMast.setLocSts("R"); locMast.setModiUser(9999L); locMast.setModiTime(now); if (!locMastService.updateById(locMast)) { throw new CoolException("更新库位状态失败"); } } return "出库成功"; } @Override @Transactional public R zphjDw(ZphjckdwParam param) { // 根据任务号得到工作主档 if (Cools.isEmpty(param.getWorkNo())) { throw new CoolException("工作号不能为空！"); } WrkMast wrkMast = wrkMastService.selectById(param.getWorkNo()); if (wrkMast == null) { throw new CoolException("工作档不存在！"); } if (wrkMast.getWrkSts() != 2 || wrkMast.getIoType() != 103) { throw new CoolException("工作档当前状态不为2/出库类型不为拣料！"); } // 更新工作档状态2.设备上走->42.等待码垛 wrkMast.setWrkSts(42L); wrkMastService.updateById(wrkMast); // 查询要拆的位置，只有一个 List wrkDetls = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo())); List collect = wrkDetls.stream().map(WrkDetl::getOrigin).distinct().collect(Collectors.toList()); String position = collect.get(0); // 返回拆垛规则 ZphjcdgzVo zphjcdgzVo = new ZphjcdgzVo(); zphjcdgzVo.setWorkNo(wrkMast.getWrkNo()); zphjcdgzVo.setPosition(position); return R.ok(zphjcdgzVo); } @Override @Transactional public R zphjCdwc(ZphjcdwcParam param) { if (Cools.isEmpty(param.getWorkNo())) { throw new CoolException("工作号不能为空！"); } WrkMast wrkMast = wrkMastService.selectById(param.getWorkNo()); if (wrkMast == null) { throw new CoolException("工作档不存在！"); } if (wrkMast.getWrkSts() != 42 || wrkMast.getIoType() != 103) { throw new CoolException("工作档当前状态不为42/出库类型不为拣料！"); } // 保存工作主档历史档 if (!wrkMastLogService.save(wrkMast.getWrkNo())) { throw new CoolException("保存工作主档历史档失败"); } // 获取目标站 Wrapper wrapper = new EntityWrapper() .eq("type_no", wrkMast.getIoType() - 50) .eq("stn_no", wrkMast.getStaNo()) // 作业站点 = 拣料出库的目标站 .eq("crn_no", wrkMast.getCrnNo()); // 堆垛机号 StaDesc staDesc = staDescService.selectOne(wrapper); if (Cools.isEmpty(staDesc)) { throw new CoolException("入库路径不存在"); } // 堆垛机站点(目标站) Integer staNo = staDesc.getCrnStn(); // 更新工作类型103->53 wrkMast.setIoType(53); wrkMast.setWrkSts(52L); // 工作状态42->52.设备上走（拆垛完成） // 目标站点源站点转换 wrkMast.setSourceStaNo(wrkMast.getStaNo()); wrkMast.setStaNo(staNo); // 目标库位=源库位 wrkMast.setLocNo(wrkMast.getSourceLocNo()); // 源库位清除 wrkMast.setSourceLocNo(""); wrkMast.setModiTime(new Date()); int outStaNo = 0; // 出库源站点 if (staNo == 3044 || staNo == 3045) { outStaNo = 3046; } else if(staNo == 3040 || staNo == 3041) { outStaNo = 3042; } if (outStaNo == 0) { throw new CoolException("出库源站点转换有误：" + staNo); } // 获取出库物料 List wrkDetls = wrkDetlService.selectList(new EntityWrapper().eq("wrk_no", wrkMast.getWrkNo())); int descFlag = getType(wrkDetls); // get0原托盘回流信息，get1拆垛出来物料出库信息 List zphjcdwcVos = new ArrayList<>(); ZphjcdwcVo zphjcdwcVo1 = new ZphjcdwcVo(); zphjcdwcVo1.setWorkNo(wrkMast.getWrkNo()); zphjcdwcVo1.setStaNo(wrkMast.getStaNo()); zphjcdwcVo1.setSourceStaNo(wrkMast.getSourceStaNo()); zphjcdwcVos.add(zphjcdwcVo1); ZphjcdwcVo zphjcdwcVo2 = new ZphjcdwcVo(); zphjcdwcVo2.setSourceStaNo(outStaNo); zphjcdwcVo2.setStaNo(3106); // 3106/3077 zphjcdwcVo2.setDescFlag(descFlag); zphjcdwcVos.add(zphjcdwcVo2); // 更新工作主档 wrkMastService.updateById(wrkMast); // 修改库位状态 Q.拣料/盘点/并板再入库 LocMast locMast = locMastService.selectById(wrkMast.getLocNo()); locMast.setLocSts("Q"); locMast.setModiTime(new Date()); if (!locMastService.updateById(locMast)) { throw new CoolException("修改库位状态失败"); } // 下发回库的目标站点和拆垛的出库目标站点给gwcs return R.ok(zphjcdwcVos); } /** * 根据出库物料明细判断是否去贴标(单卷贴标，多卷不贴标) * @param wrkDetls 物料明细 * @return 0.多卷不贴标路径，1.单卷贴标路径 */ private int getType(List wrkDetls) { return wrkDetls.size() > 1 ? 0 : 1; // 一条记录就是一卷 } public boolean pushStaNoToGwcs(Integer palletizingNo, Integer staNo, Integer workNo,String barcode) { boolean success = false; // 获取请求头 Map headers = getHeaders(); // 构造请求体 JSONObject jsonObject = new JSONObject(); jsonObject.put("workNo", workNo); jsonObject.put("staNo", staNo); jsonObject.put("sourceStaNo", palletizingNo); jsonObject.put("barcode", barcode); String body = jsonObject.toJSONString(); String response = ""; try { response = new HttpHandler.Builder() .setUri(MesConstant.GWCS_IP_PORT) .setPath(MesConstant.GWCS_FPKW_URL) .setHeaders(headers) .setJson(body) .build() .doPost(); if (!Cools.isEmpty(response)) { success = true; // // 修改订单状态 4.完成 ===>> 6.已上报 // if (!orderService.updateSettle(order.getId(), 6L, null)) { // throw new CoolException("服务器内部错误，请联系管理员"); // } } else { log.error("zmws推送入库码头站点接口失败！！！url：{}；request：{}；response：{}", MesConstant.URL + MesConstant.PAKIN_URL, body, response); throw new CoolException("上报mes系统失败"); } } catch (Exception e) { log.error("入库请求接口失败：{}", e.getMessage()); // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); // return FAIL.setMsg(e.getMessage()); } finally { try { // 保存接口日志 apiLogService.save( "入库", MesConstant.GWCS_IP_PORT + MesConstant.GWCS_FPKW_URL, null, "127.0.0.1", body, response, success ); } catch (Exception e) { log.error("", e); } } return success; } Map getHeaders(){ Map headers = new HashMap<>(); headers.put("digi-type","sync "); headers.put("digi-protocol","raw"); headers.put("digi-datakey"," XCommon.ImportData"); return headers; } private void descSta(Integer staNo,Integer crnNo){ // int[] typeNos =new int[]{1,10,53,101,103,110}; int[] typeNos =new int[]{10,110}; for (Integer typeNo:typeNos){ descSta3(staNo,crnNo,typeNo); } } private void descSta3(Integer staNo,Integer crnNo,Integer typeNo){ StaDesc staDesc = new StaDesc(); staDesc.setTypeNo(typeNo); staDesc.setStnNo(staNo); staDesc.setCrnNo(crnNo); staDesc.setCrnStn(CrnNoRC(crnNo,staDesc.getTypeNo()>100)); descSta2(staDesc); } private void descSta2(StaDesc staDesc){ Date now = new Date(); //入库 int sameRes = staDescService.selectCount(new EntityWrapper() .eq("type_no", staDesc.getTypeNo()) .eq("stn_no", staDesc.getStnNo()) .eq("crn_no", staDesc.getCrnNo()) .eq("crn_stn", staDesc.getCrnStn())); if (sameRes == 0) { staDesc.setModiUser(9527L); staDesc.setModiTime(now); staDesc.setAppeUser(9527L); staDesc.setAppeTime(now); staDescService.insert(staDesc); } } private Integer CrnNoRC(Integer crnNo,boolean sign){ Integer crnStn = 0; switch (crnNo){ case 1: crnStn = 102; break; case 2: crnStn = 105; break; case 3: crnStn = 108; break; case 4: crnStn = 111; break; case 5: crnStn = 114; break; case 6: crnStn = 117; break; } if (sign){ return crnStn-2; } return crnStn; } /*...........................上饶江铜..............以上.............徐工汉云...........................*/ }