|  |  |  | 
|---|
|  |  |  | package com.zy.asrs.service.impl; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.baomidou.mybatisplus.mapper.EntityWrapper; | 
|---|
|  |  |  | import com.baomidou.mybatisplus.plugins.Page; | 
|---|
|  |  |  | 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.InOutCountDto; | 
|---|
|  |  |  | import com.zy.asrs.entity.result.LocDetlAll; | 
|---|
|  |  |  | import com.zy.asrs.entity.result.StockVo; | 
|---|
|  |  |  | import com.zy.asrs.mapper.ReportQueryMapper; | 
|---|
|  |  |  | import com.zy.asrs.mapper.TagMapper; | 
|---|
|  |  |  | import com.zy.asrs.service.*; | 
|---|
|  |  |  | import com.zy.asrs.utils.MatUtils; | 
|---|
|  |  |  | import com.zy.common.model.DetlDto; | 
|---|
|  |  |  | import com.zy.common.utils.NodeUtils; | 
|---|
|  |  |  | import com.zy.erp.kingdee.enums.KingDeeUtilType; | 
|---|
|  |  |  | import lombok.extern.slf4j.Slf4j; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.stereotype.Service; | 
|---|
|  |  |  | 
|---|
|  |  |  | private TagService tagService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private TagMapper tagMapper; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private WrkMastService wrkMastService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private NodeService nodeService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ManLocDetlService manLocDetlService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ManPakOutService manPakOutService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private LocOwnerService locOwnerService; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private ReportQueryMapper reportQueryMapper; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | 
|---|
|  |  |  | Order order = orderService.selectByNo(param.getOrderNo()); | 
|---|
|  |  |  | if (!Cools.isEmpty(order)) { | 
|---|
|  |  |  | throw new CoolException(param.getOrderNo() + "单据已存在,请勿重复提交"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for (DetlDto detlDto : param.getOrderDetails()){ | 
|---|
|  |  |  | if (Cools.isEmpty(detlDto) || Cools.isEmpty(detlDto.getOwnerName(),detlDto.getPayment())){ | 
|---|
|  |  |  | throw new CoolException(param.getOrderNo() + "缺少货主或货物形态"); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName())); | 
|---|
|  |  |  | if (Cools.isEmpty(locOwner)){ | 
|---|
|  |  |  | LocOwner locOwner1 = new LocOwner(); | 
|---|
|  |  |  | locOwner1.setOwner(detlDto.getOwnerName()); | 
|---|
|  |  |  | locOwnerService.insert(locOwner1); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.TRUE); | 
|---|
|  |  |  | Date now = new Date(); | 
|---|
|  |  |  | 
|---|
|  |  |  | List<DetlDto> list = new ArrayList<>(); | 
|---|
|  |  |  | List<DetlDto> 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); | 
|---|
|  |  |  | DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getOwnerName(),detail.getPayment()); | 
|---|
|  |  |  | dto.setBeBatch(detail.getBeBatch()); | 
|---|
|  |  |  | KingDeeUtilType kingDeeUtilType = KingDeeUtilType.get(docType.getDocName()); | 
|---|
|  |  |  | if (kingDeeUtilType.entryId==1){ | 
|---|
|  |  |  | if (DetlDto.has2(list, dto)) { | 
|---|
|  |  |  | DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName(),detail.getBeBatch()); | 
|---|
|  |  |  | assert detlDto != null; | 
|---|
|  |  |  | detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme()); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | list.add(dto); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | dto.setWeight(detail.getWeight()); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | if (DetlDto.has1(list, dto)) { | 
|---|
|  |  |  | DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName()); | 
|---|
|  |  |  | assert detlDto != null; | 
|---|
|  |  |  | detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme()); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | list.add(dto); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | dto.setWeight(detail.getWeight()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (DetlDto detlDto : list) { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | OrderDetl orderDetl = new OrderDetl(); | 
|---|
|  |  |  | orderDetl.sync(mat); | 
|---|
|  |  |  | orderDetl.setBatch(detlDto.getBatch()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //批号为空会出现问题,设置一个默认值 | 
|---|
|  |  |  | if (detlDto.getBatch() == null) { | 
|---|
|  |  |  | orderDetl.setBatch(""); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | orderDetl.setBatch(detlDto.getBatch()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | orderDetl.setAnfme(detlDto.getAnfme()); | 
|---|
|  |  |  | orderDetl.setOrderId(order.getId()); | 
|---|
|  |  |  | orderDetl.setOrderNo(order.getOrderNo()); | 
|---|
|  |  |  | 
|---|
|  |  |  | orderDetl.setCreateTime(now); | 
|---|
|  |  |  | orderDetl.setUpdateBy(9527L); | 
|---|
|  |  |  | orderDetl.setUpdateTime(now); | 
|---|
|  |  |  | orderDetl.setPrice(0.0); | 
|---|
|  |  |  | LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName())); | 
|---|
|  |  |  | if (Cools.isEmpty(locOwner)){ | 
|---|
|  |  |  | throw new CoolException("生成单据明细失败,请联系管理员"); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | orderDetl.setOwner(locOwner.getId()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | orderDetl.setPayment(detlDto.getPayment()); | 
|---|
|  |  |  | orderDetl.setStatus(1); | 
|---|
|  |  |  | orderDetl.setQty(0.0D); | 
|---|
|  |  |  | orderDetl.setBeBatch(detlDto.getBeBatch()); | 
|---|
|  |  |  | orderDetl.setWeight(detlDto.getWeight()); | 
|---|
|  |  |  | if (!orderDetlService.insert(orderDetl)) { | 
|---|
|  |  |  | throw new CoolException("生成单据明细失败,请联系管理员"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public List<OpenOrderCompeteResult> pakinOrderComplete(OpenOrderCompleteParam param) { | 
|---|
|  |  |  | List<OpenOrderCompeteResult> 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<OrderDetl> 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<Order> orders = orderService.selectList(new EntityWrapper<Order>().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<OrderDetl> 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("服务器内部错误,请联系管理员"); | 
|---|
|  |  |  | public void pakoutOrderCreate(OpenOrderPakoutParam param) { | 
|---|
|  |  |  | Order order = orderService.selectByNo(param.getOrderNo()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for (DetlDto detlDto : param.getOrderDetails()){ | 
|---|
|  |  |  | if (Cools.isEmpty(detlDto) || Cools.isEmpty(detlDto.getOwnerName(),detlDto.getPayment())){ | 
|---|
|  |  |  | throw new CoolException(param.getOrderNo() + "缺少货主或货物形态"); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName())); | 
|---|
|  |  |  | if (Cools.isEmpty(locOwner)){ | 
|---|
|  |  |  | LocOwner locOwner1 = new LocOwner(); | 
|---|
|  |  |  | locOwner1.setOwner(detlDto.getOwnerName()); | 
|---|
|  |  |  | locOwnerService.insert(locOwner1); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return results; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public void pakoutOrderCreate(OpenOrderPakoutParam param) { | 
|---|
|  |  |  | Order order = orderService.selectByNo(param.getOrderNo()); | 
|---|
|  |  |  | // 如果单据不存在则添加;如果单据存在,作业中无法修改,反之则修改单据 | 
|---|
|  |  |  | if (!Cools.isEmpty(order)) { | 
|---|
|  |  |  | if (order.getSettle() > 1L) { | 
|---|
|  |  |  | 
|---|
|  |  |  | List<DetlDto> list = new ArrayList<>(); | 
|---|
|  |  |  | List<DetlDto> 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); | 
|---|
|  |  |  | DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getOwnerName(),detail.getPayment()); | 
|---|
|  |  |  | dto.setBeBatch(detail.getBeBatch()); | 
|---|
|  |  |  | KingDeeUtilType kingDeeUtilType = KingDeeUtilType.get(docType.getDocName()); | 
|---|
|  |  |  | if (kingDeeUtilType.entryId==1){ | 
|---|
|  |  |  | if (DetlDto.has2(list, dto)) { | 
|---|
|  |  |  | DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName(),detail.getBeBatch()); | 
|---|
|  |  |  | assert detlDto != null; | 
|---|
|  |  |  | detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme()); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | list.add(dto); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | dto.setWeight(detail.getWeight()); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | if (DetlDto.has1(list, dto)) { | 
|---|
|  |  |  | DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),detail.getOwnerName()); | 
|---|
|  |  |  | assert detlDto != null; | 
|---|
|  |  |  | detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme()); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | list.add(dto); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | dto.setWeight(detail.getWeight()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | for (DetlDto detlDto : list) { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | OrderDetl orderDetl = new OrderDetl(); | 
|---|
|  |  |  | orderDetl.sync(mat); | 
|---|
|  |  |  | orderDetl.setBatch(detlDto.getBatch()); | 
|---|
|  |  |  | orderDetl.setBatch(detlDto.getBatch() == null ? "" : detlDto.getBatch()); | 
|---|
|  |  |  | orderDetl.setAnfme(detlDto.getAnfme()); | 
|---|
|  |  |  | orderDetl.setOrderId(order.getId()); | 
|---|
|  |  |  | orderDetl.setOrderNo(order.getOrderNo()); | 
|---|
|  |  |  | 
|---|
|  |  |  | orderDetl.setUpdateTime(now); | 
|---|
|  |  |  | orderDetl.setStatus(1); | 
|---|
|  |  |  | orderDetl.setQty(0.0D); | 
|---|
|  |  |  | orderDetl.setPrice(0.0);//初始化已上报数量 | 
|---|
|  |  |  | orderDetl.setOwner(detlDto.getOwner()); | 
|---|
|  |  |  | orderDetl.setBeBatch(detlDto.getBeBatch()); | 
|---|
|  |  |  | orderDetl.setWeight(detlDto.getWeight()); | 
|---|
|  |  |  | LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName())); | 
|---|
|  |  |  | if (Cools.isEmpty(locOwner)){ | 
|---|
|  |  |  | throw new CoolException("生成单据明细失败,请联系管理员"); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | orderDetl.setOwner(locOwner.getId()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (!orderDetlService.insert(orderDetl)) { | 
|---|
|  |  |  | throw new CoolException("生成单据明细失败,请联系管理员"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public List<OpenOrderCompeteResult> pakoutOrderComplete(OpenOrderCompleteParam param) { | 
|---|
|  |  |  | List<OpenOrderCompeteResult> 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<OrderDetl> 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<Order> orders = orderService.selectList(new EntityWrapper<Order>().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<OrderDetl> 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("服务器内部错误,请联系管理员"); | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public void pakmoveOrderCreate(OpenOrderPakmoveParam param) { | 
|---|
|  |  |  | Order order = orderService.selectByNo(param.getOrderNo()); | 
|---|
|  |  |  | if (!Cools.isEmpty(order)) { | 
|---|
|  |  |  | throw new CoolException(param.getOrderNo() + "单据已存在,请勿重复提交"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for (DetlDto detlDto : param.getOrderDetails()){ | 
|---|
|  |  |  | if (Cools.isEmpty(detlDto) || Cools.isEmpty(detlDto.getOwnerName(),detlDto.getPayment())){ | 
|---|
|  |  |  | throw new CoolException(param.getOrderNo() + "缺少货主或货物形态"); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName())); | 
|---|
|  |  |  | if (Cools.isEmpty(locOwner)){ | 
|---|
|  |  |  | LocOwner locOwner1 = new LocOwner(); | 
|---|
|  |  |  | locOwner1.setOwner(detlDto.getOwnerName()); | 
|---|
|  |  |  | locOwnerService.insert(locOwner1); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return results; | 
|---|
|  |  |  | 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<DetlDto> list = new ArrayList<>(); | 
|---|
|  |  |  | List<DetlDto> orderDetails = param.getOrderDetails(); | 
|---|
|  |  |  | for (DetlDto detail : orderDetails) { | 
|---|
|  |  |  | DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getOwnerName(),detail.getPayment()); | 
|---|
|  |  |  | dto.setBeBatch(detail.getBeBatch()); | 
|---|
|  |  |  | dto.setSourceLocName(detail.getSourceLocName()); | 
|---|
|  |  |  | dto.setTargetLocName(detail.getTargetLocName()); | 
|---|
|  |  |  | if (DetlDto.has3(list, dto)) { | 
|---|
|  |  |  | DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),dto.getOwnerName(),dto.getSourceLocName(),dto.getTargetLocName()); | 
|---|
|  |  |  | assert detlDto != null; | 
|---|
|  |  |  | detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme()); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | list.add(dto); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | dto.setWeight(detail.getWeight()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //批号为空会出现问题,设置一个默认值 | 
|---|
|  |  |  | if (detlDto.getBatch() == null) { | 
|---|
|  |  |  | orderDetl.setBatch(""); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | 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.setPrice(0.0); | 
|---|
|  |  |  | LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName())); | 
|---|
|  |  |  | if (Cools.isEmpty(locOwner)){ | 
|---|
|  |  |  | throw new CoolException("生成单据明细失败,请联系管理员"); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | orderDetl.setOwner(locOwner.getId()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | orderDetl.setPayment(detlDto.getPayment()); | 
|---|
|  |  |  | orderDetl.setStatus(1); | 
|---|
|  |  |  | orderDetl.setQty(0.0D); | 
|---|
|  |  |  | orderDetl.setBeBatch(detlDto.getBeBatch()); | 
|---|
|  |  |  | orderDetl.setWeight(detlDto.getWeight()); | 
|---|
|  |  |  | orderDetl.setSourceLocName(detlDto.getSourceLocName()); | 
|---|
|  |  |  | orderDetl.setTargetLocName(detlDto.getTargetLocName()); | 
|---|
|  |  |  | if (!orderDetlService.insert(orderDetl)) { | 
|---|
|  |  |  | throw new CoolException("生成单据明细失败,请联系管理员"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public List<StockVo> queryStock() { | 
|---|
|  |  |  | return locDetlService.queryStockTotal(); | 
|---|
|  |  |  | public List<StockVo> queryStock(StockVo stockVo) { | 
|---|
|  |  |  | return locDetlService.queryStockTotal(stockVo); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | @Transactional | 
|---|
|  |  |  | public void syncMat(MatSyncParam param) { | 
|---|
|  |  |  | if (Cools.isEmpty(param.getMatDetails()) || param.getMatDetails().size() <=0 ) { | 
|---|
|  |  |  | if (Cools.isEmpty(param.getMatDetails()) || param.getMatDetails().size() <= 0) { | 
|---|
|  |  |  | throw new CoolException("商品数据为空"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for(MatSyncParam.MatParam matParam : param.getMatDetails()){ | 
|---|
|  |  |  | if(Cools.isEmpty(matParam.getMatnr())){ | 
|---|
|  |  |  | for (MatSyncParam.MatParam matParam : param.getMatDetails()) { | 
|---|
|  |  |  | if (Cools.isEmpty(matParam.getMatnr())) { | 
|---|
|  |  |  | throw new CoolException("商品编码不能为空"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | Long tagId; | 
|---|
|  |  |  | // 一级分类 | 
|---|
|  |  |  | if (!Cools.isEmpty(matParam.getGroupCode()) && !Cools.isEmpty(matParam.getGroupName())) { | 
|---|
|  |  |  | Tag priTag = tagService.selectByName(matParam.getGroupCode(), 2); | 
|---|
|  |  |  | Tag priTag = tagService.selectByName(matParam.getGroupCode(), 1); | 
|---|
|  |  |  | if (priTag == null) { | 
|---|
|  |  |  | Tag top = tagService.getTop(); | 
|---|
|  |  |  | NodeUtils nodeUtils = new NodeUtils(); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | // 二级分类 | 
|---|
|  |  |  | Tag secTag = tagService.selectByName(matParam.getGroupName(), 3); | 
|---|
|  |  |  | Tag secTag = tagService.selectByName(matParam.getGroupName(), 2); | 
|---|
|  |  |  | if (secTag == null) { | 
|---|
|  |  |  | NodeUtils nodeUtils = new NodeUtils(); | 
|---|
|  |  |  | nodeUtils.executePath(priTag.getId()); | 
|---|
|  |  |  | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | tagId = tagService.getTop().getId(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | mat.sync(param); | 
|---|
|  |  |  | //            mat.setMatnr(param.getMatnr()); | 
|---|
|  |  |  | mat.sync(matParam); | 
|---|
|  |  |  | //            mat.setMatnr(para); | 
|---|
|  |  |  | //            mat.setMaktx(param.getMaktx()); | 
|---|
|  |  |  | //            mat.setSpecs(param.getSpecs()); | 
|---|
|  |  |  | //            mat.setModel(param.getModel()); | 
|---|
|  |  |  | 
|---|
|  |  |  | mat.setStatus(1); | 
|---|
|  |  |  | mat.setCreateTime(now); | 
|---|
|  |  |  | mat.setUpdateTime(now); | 
|---|
|  |  |  | if (Cools.isEmpty(matParam.getLength()) || matParam.getLength() == 0) { | 
|---|
|  |  |  | mat.setLength(null); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (!matService.insert(mat)) { | 
|---|
|  |  |  | throw new CoolException("服务器内部错误,请联系管理员"); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | mat.sync(param); | 
|---|
|  |  |  | if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) { | 
|---|
|  |  |  | if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr", matParam.getMatnr()))) { | 
|---|
|  |  |  | throw new CoolException("更新已存在商品信息失败,请联系管理员"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public R getInOutDetl() { | 
|---|
|  |  |  | List<InOutCountDto> top100 = wrkMastService.selectTop100(); | 
|---|
|  |  |  | return R.ok().add(top100); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /* | 
|---|
|  |  |  | * 速腾数字孪生调用接口 | 
|---|
|  |  |  | * */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public DigitalTwin inventoryQuantity() { | 
|---|
|  |  |  | DigitalTwin digitalTwin = new DigitalTwin(); | 
|---|
|  |  |  | LocChartPie locUseRate = reportQueryMapper.getLocUseRate(); | 
|---|
|  |  |  | LocChartPie locUseRateL = reportQueryMapper.getLocUseRateL(); | 
|---|
|  |  |  | LocChartPie locUseRateP = reportQueryMapper.getLocUseRateP(); | 
|---|
|  |  |  | if(locUseRate!=null) { | 
|---|
|  |  |  | digitalTwin.setCount(locUseRate.getOqty()+locUseRate.getFqty()+locUseRate.getUqty()+locUseRate.getXqty()); | 
|---|
|  |  |  | digitalTwin.setOqty(locUseRate.getOqty()); | 
|---|
|  |  |  | digitalTwin.setFqty(locUseRate.getFqty()); | 
|---|
|  |  |  | digitalTwin.setUqty(locUseRate.getUqty()); | 
|---|
|  |  |  | digitalTwin.setXqty(locUseRate.getXqty()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(locUseRateL!=null) { | 
|---|
|  |  |  | digitalTwin.setCountL(locUseRateL.getOqty()+locUseRateL.getFqty()+locUseRateL.getUqty()+locUseRateL.getXqty()); | 
|---|
|  |  |  | digitalTwin.setOqtyL(locUseRateL.getOqty()); | 
|---|
|  |  |  | digitalTwin.setFqtyL(locUseRateL.getFqty()); | 
|---|
|  |  |  | digitalTwin.setUqtyL(locUseRateL.getUqty()); | 
|---|
|  |  |  | digitalTwin.setXqtyL(locUseRateL.getXqty()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (locUseRateP!=null){ | 
|---|
|  |  |  | digitalTwin.setCountP(locUseRateP.getOqty()+locUseRateP.getFqty()+locUseRateP.getUqty()+locUseRateP.getXqty()); | 
|---|
|  |  |  | digitalTwin.setOqtyP(locUseRateP.getOqty()); | 
|---|
|  |  |  | digitalTwin.setFqtyP(locUseRateP.getFqty()); | 
|---|
|  |  |  | digitalTwin.setUqtyP(locUseRateP.getUqty()); | 
|---|
|  |  |  | digitalTwin.setXqtyP(locUseRateP.getXqty()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return digitalTwin; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /* | 
|---|
|  |  |  | * 速腾数字孪生调用接口 | 
|---|
|  |  |  | * */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public synchronized R ownerAllNumber() { | 
|---|
|  |  |  | List<LocDetlAll> locDetlAlls = locDetlService.selectOwnerAllAnfme(); | 
|---|
|  |  |  | return R.ok(locDetlAlls); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|