package com.vincent.rsf.server.api.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.vincent.rsf.framework.common.R; import com.vincent.rsf.framework.exception.CoolException; import com.vincent.rsf.server.api.controller.erp.params.*; import com.vincent.rsf.server.api.controller.erp.params.dto.CheckDiffDto; import com.vincent.rsf.server.api.controller.erp.params.dto.TransferInfoDto; import com.vincent.rsf.server.api.controller.erp.params.dto.WkOrderDto; import com.vincent.rsf.server.common.domain.BaseParam; import com.vincent.rsf.server.common.domain.PageParam; import com.vincent.rsf.server.manager.controller.dto.LocStockDto; import com.vincent.rsf.server.manager.entity.*; import com.vincent.rsf.server.manager.enums.*; import com.vincent.rsf.server.manager.service.*; import com.vincent.rsf.server.manager.service.impl.MatnrServiceImpl; import com.vincent.rsf.server.system.constant.DictTypeCode; import com.vincent.rsf.server.system.constant.SerialRuleCode; import com.vincent.rsf.server.system.entity.DictData; import com.vincent.rsf.server.system.entity.DictType; import com.vincent.rsf.server.system.entity.Fields; import com.vincent.rsf.server.system.service.DictDataService; import com.vincent.rsf.server.system.service.DictTypeService; import com.vincent.rsf.server.system.service.FieldsService; import com.vincent.rsf.server.system.service.impl.DictDataServiceImpl; import com.vincent.rsf.server.system.utils.SerialRuleUtils; import com.vincent.rsf.server.api.service.ReceiveMsgService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.*; import java.util.stream.Collectors; /** * @author Ryan * @version 1.0 * @title ErpApiServiceImpl * @description * @create 2025/3/4 16:27 */ @Slf4j @Service("erpApiService") public class ReceiveMsgServiceImpl implements ReceiveMsgService { @Autowired private PurchaseService purchaseService; @Autowired private PurchaseItemService purchaseItemService; @Autowired private FieldsService fieldsService; @Autowired private MatnrGroupService matnrGroupService; @Autowired private MatnrServiceImpl matnrService; @Autowired private AsnOrderService asnOrderService; @Autowired private AsnOrderItemService asnOrderItemService; @Autowired private DeliveryService deliveryService; @Autowired private DeliveryItemService deliveryItemService; @Autowired private LocService locService; @Autowired private WarehouseAreasService warehouseAreasService; @Autowired private WarehouseService warehouseService; @Autowired private CompanysService companysService; @Autowired private TransferService transferService; @Autowired private TransferItemService transferItemService; @Autowired private LocReviseService locReviseService; @Autowired private ReviseLogService reviseLogService; @Autowired private ReviseLogItemService reviseLogItemService; @Autowired private CheckDiffService checkDiffService; @Autowired private CheckDiffItemService checkDiffItemService; @Autowired private DictDataService dictDataService; @Autowired private DictTypeService dictTypeService; /** * @author Ryan * @date 2025/8/15 * @description: 保存PO/DO单据 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public boolean syncPurchasee(List orders) { if (orders.isEmpty()) { throw new CoolException("单据内容不能为空！！"); } orders.forEach(ors -> { if (ors.getType().equals("po")) { Purchase purchase = new Purchase(); BeanUtils.copyProperties(ors, purchase); String wkVal = SerialRuleUtils.generateRuleCode(SerialRuleCode.PURCHASE_CODE, purchase); purchase.setCode(wkVal) .setType(OrderType.ORDER_IN.type); if (!purchaseService.save(purchase)) { throw new CoolException("采购单据保存失败"); } //查询扩展字段是否存在 List fields = fieldsService.list(new LambdaQueryWrapper().eq(Fields::getStatus, 1).eq(Fields::getFlagEnable, 1)); //判断子列表不为空 if (!ors.getChildren().isEmpty()) { ArrayList list = new ArrayList<>(); ors.getChildren().forEach(orderItem -> { PurchaseItem item = new PurchaseItem(); BeanUtils.copyProperties(orderItem, item); // if (!fields.isEmpty()) { // List fieldValue = fields.stream().map(Fields::getFields).collect(Collectors.toList()); // fieldValue.forEach(value -> { // // }); // } item.setPurchaseId(purchase.getId()); list.add(item); }); if (!purchaseItemService.saveBatch(list)) { throw new CoolException("采购单明细保存失败！！"); } } } else { Delivery delivery = new Delivery(); BeanUtils.copyProperties(ors, delivery); String wkVal = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_DELIVERY_RULE_CODE, delivery); delivery.setCode(wkVal) .setType(OrderType.ORDER_OUT.type); if (!deliveryService.save(delivery)) { throw new CoolException("采购单据保存失败"); } //查询扩展字段是否存在 List fields = fieldsService.list(new LambdaQueryWrapper().eq(Fields::getStatus, 1).eq(Fields::getFlagEnable, 1)); //判断子列表不为空 if (!ors.getChildren().isEmpty()) { ArrayList list = new ArrayList<>(); ors.getChildren().forEach(orderItem -> { DeliveryItem item = new DeliveryItem(); BeanUtils.copyProperties(orderItem, item); // if (!fields.isEmpty()) { // List fieldValue = fields.stream().map(Fields::getFields).collect(Collectors.toList()); // fieldValue.forEach(value -> { // // }); // } item.setDeliveryId(delivery.getId()); list.add(item); }); if (!deliveryItemService.saveBatch(list)) { throw new CoolException("采购单明细保存失败！！"); } } } }); return true; } /** * 物料信息同步 * * @param matnrs */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public void syncMatnrs(List matnrs) { List syncMatnrs = new ArrayList<>(); if (!matnrs.isEmpty()) { matnrs.forEach(matnr -> { Matnr mat = new Matnr(); if (Objects.isNull(matnr.getMatnr())) { throw new RuntimeException("物料编码不能为空！！"); } BeanUtils.copyProperties(matnr, mat); mat.setCode(matnr.getMatnr()).setName(matnr.getMaktx()); if (!Objects.isNull(matnr.getGroupName())) { MatnrGroup matnrGroup = matnrGroupService.getOne(new LambdaQueryWrapper().eq(MatnrGroup::getName, matnr.getGroupName()), false); if (Objects.isNull(matnrGroup)) { mat.setGroupCode(matnrGroup.getCode()).setGroupId(matnrGroup.getId()); } } syncMatnrs.add(mat); }); if (!matnrService.saveOrUpdateBatch(syncMatnrs)) { throw new CoolException("物料信息保存成功！！"); } } } /** * @author Ryan * @date 2025/8/15 * @description: 订单查询 * @version 1.0 */ @Override public R queryOrderStatus(QueryOrderParam queryParams) { WkOrder wkOrders = asnOrderService.getOne(new LambdaQueryWrapper() .in(WkOrder::getCode, queryParams.getOrderNo()) .eq(WkOrder::getType, queryParams.getType())); if (Objects.isNull(wkOrders)) { throw new CoolException("单据不存在！！"); } List orderItems = asnOrderItemService.list(new LambdaQueryWrapper().eq(WkOrderItem::getOrderId, wkOrders.getId())); WkOrderDto wkorderDto = new WkOrderDto(); wkorderDto.setOrder(wkOrders).setOrderItems(orderItems); return R.ok().add(wkorderDto); } /** * @author Ryan * @date 2025/8/15 * @description: 查询库位信息 * @version 1.0 */ @Override public R syncLocsDetl(PageParam pageParam, QueryWrapper wrapper) { Page page = new Page<>(); page.setCurrent(pageParam.getCurrent()).setSize(pageParam.getSize()); IPage locStocks = locService.getLocDetls(page); return R.ok().add(locStocks); } /** * @author Ryan * @date 2025/8/18 * @description: 库位同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncLocs(List locs) { List syncLocs = new ArrayList<>(); locs.forEach(loc -> { Loc loc1 = new Loc(); BeanUtils.copyProperties(loc, loc1); loc1.setCode(loc.getLocCode()).setId(null); syncLocs.add(loc1); }); if (!locService.saveBatch(syncLocs)) { throw new CoolException("库位同步失败！！"); } return R.ok(); } /** * @author Ryan * @date 2025/8/18 * @description: 物料信息同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncMatGroups(List matGroupsParams) { List syncMatGroups = new ArrayList<>(); matGroupsParams.forEach(matGroupsParam -> { MatnrGroup matnrGroup = new MatnrGroup(); BeanUtils.copyProperties(matGroupsParam, matnrGroup); if (Objects.isNull(matGroupsParam.getCode())) { throw new CoolException("物料分组编码不能为空！！"); } if (Objects.isNull(matGroupsParam.getName())) { throw new CoolException("分组名称不能为空！！"); } if (Objects.isNull(matGroupsParam.getParCode())) { throw new CoolException("上级物料分组编码不能为空！！"); } syncMatGroups.add(matnrGroup); }); if (!matnrGroupService.saveBatch(syncMatGroups)) { throw new CoolException("物料分组保存失败！！"); } return R.ok(); } /** * @author Ryan * @date 2025/8/18 * @description: 库区信息同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncWarehouseAreas(List areasParams) { areasParams.forEach(param -> { WarehouseAreas locArea = new WarehouseAreas(); BeanUtils.copyProperties(param, locArea); WarehouseAreas warehouseAreas = warehouseAreasService .getOne(new LambdaQueryWrapper() .eq(WarehouseAreas::getName, param.getName())); if (!Objects.isNull(warehouseAreas)) { locArea.setWarehouseId(warehouseAreas.getId()); } locArea.setName(param.getName()) .setCode(param.getCode()) .setId(null); if (!warehouseAreasService.save(locArea)) { throw new CoolException("库区保存失败！！"); } }); return R.ok(); } /** * @author Ryan * @date 2025/8/18 * @description: 仓库同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncWarehouse(List warehouses) { warehouses.forEach(warehouse -> { Warehouse ware = new Warehouse(); BeanUtils.copyProperties(warehouse, ware); ware.setId(null); if (!warehouseService.save(ware)) { throw new CoolException("仓库同步保存失败！！"); } }); return R.ok(); } /** * @author Ryan * @date 2025/8/19 * @description: 同步企业信息 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncCompanies(List companyParams) { companyParams.forEach(param -> { Companys companys = new Companys(); BeanUtils.copyProperties(param, companys); if (Objects.isNull(companys.getCode())) { throw new CoolException("企业编码不能为空！！"); } Companys one = companysService.getOne(new LambdaQueryWrapper().eq(Companys::getName, param.getName())); if (Objects.isNull(one)) { String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_COMPANYS_CODE, null); companys.setCode(ruleCode); } else { throw new CoolException(one.getName() + "，企业名重复！！"); } companys.setType(CompanysType.getCustomVal(param.getType())) .setId(null); if (!companysService.save(companys)) { throw new CoolException("企业保存失败！！"); } }); return R.ok(); } /** * @author Ryan * @date 2025/8/26 * @description: 单据同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncCheckOrder(List syncOrders, Long loginUserId) { if (!syncOrders.isEmpty()) { syncOrders.forEach(syncOrder -> { WkOrder wkOrder = new WkOrder(); DictData one = dictDataService.getOne(new LambdaQueryWrapper().eq(DictData::getDictTypeCode, DictTypeCode.DICT_SYS_BUSINESS_TYPE) .eq(DictData::getLabel, syncOrder.getWkType()), false); if (Objects.isNull(one)) { throw new CoolException("单据：" + syncOrder.getOrderNo() + ", 业务类型不存在！！"); } wkOrder.setType(OrderWorkType.getOrderType(syncOrder.getWkType())) .setWkType(OrderWorkType.getWorkType(syncOrder.getWkType())) .setAnfme(syncOrder.getAnfme()) .setCode(syncOrder.getOrderNo()) .setArrTime(syncOrder.getArrTime()) .setId(null) .setCreateTime(new Date()) .setUpdateTime(new Date()) .setCreateBy(loginUserId) .setUpdateBy(loginUserId); if (!asnOrderService.save(wkOrder)) { throw new CoolException("单据保存失败！！"); } List ordersItems = syncOrder.getOrdersItems(); ordersItems.forEach(item -> { WkOrderItem wkOrderItem = new WkOrderItem(); BeanUtils.copyProperties(item, wkOrderItem); wkOrderItem.setOrderCode(wkOrder.getCode()) .setOrderId(wkOrder.getId()) .setId(null); if (!asnOrderItemService.save(wkOrderItem)) { throw new CoolException("单据明细保存失败！！"); } }); }); } return R.ok(); } /** * @author Ryan * @date 2025/8/19 * @description: 调拔单据同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncTransfer(SyncTransferParams transferParams, Long loginUserId) { Transfer transfer = new Transfer(); WarehouseAreas warehouseAreas = warehouseAreasService .getOne(new LambdaQueryWrapper() .eq(WarehouseAreas::getName, transferParams.getOrgAreaName())); if (Objects.isNull(warehouseAreas)) { throw new CoolException("原库区不存在！！"); } WarehouseAreas warehouseAreas1 = warehouseAreasService.getOne(new LambdaQueryWrapper() .eq(WarehouseAreas::getName, transferParams.getTarAreaName())); if (Objects.isNull(warehouseAreas1)) { throw new CoolException("目标库区不存在！！"); } transfer.setOrgAreaName(warehouseAreas.getName()) .setOrgAreaId(warehouseAreas.getId()) .setOrgWareName(warehouseAreas.getWarehouseId$()) .setOrgWareId(warehouseAreas.getWarehouseId()) .setTarWareName(warehouseAreas1.getWarehouseId$()) .setTarAreaName(warehouseAreas1.getName()) .setTarAreaId(warehouseAreas1.getId()) .setTarWareName(warehouseAreas1.getWarehouseId$()) .setTarWareId(warehouseAreas1.getWarehouseId()) .setCreateBy(loginUserId) .setCreateTime(new Date()) .setUpdateTime(new Date()) .setUpdateBy(loginUserId) .setCode(SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_TRANSFER_ORDER_CODE, null)) .setSource(OrderSourceType.ORDER_SOURCE_TYPE_ERP.val); if (!transferService.save(transfer)) { throw new CoolException("调拔单据保存失败！！"); } transferParams.getItems().forEach(item -> { TransferItem transferItem = new TransferItem(); BeanUtils.copyProperties(item, transferItem); Matnr matnr = matnrService.getOne(new LambdaQueryWrapper().eq(Matnr::getCode, item.getMatnrCode())); if (Objects.isNull(matnr)) { throw new CoolException("物料不存在！！"); } transferItem.setMatnrId(matnr.getId()) .setTransferId(transfer.getId()) .setCreateBy(loginUserId) .setUpdateBy(loginUserId) .setCreateTime(new Date()) .setUpdateTime(new Date()) .setTransferCode(transfer.getCode()); if (!transferItemService.save(transferItem)) { throw new CoolException("调拔单明细保存失败！！"); } }); return R.ok(); } /** * @author Ryan * @date 2025/8/20 * @description: 库存调整单同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncLocRevise(SyncLocReviseParams reviseParams, Long loginUserId) { LocRevise locRevise = new LocRevise(); if (Objects.isNull(reviseParams.getAreaName())) { throw new CoolException("库区不能为空！！"); } WarehouseAreas warehouseAreas = warehouseAreasService .getOne(new LambdaQueryWrapper() .eq(WarehouseAreas::getName, reviseParams.getAreaName())); if (Objects.isNull(warehouseAreas)) { throw new CoolException("库区不存在！！"); } locRevise.setAreaName(warehouseAreas.getName()) .setType(LocReviseType.getLocRevise(reviseParams.getType())) .setCreateBy(loginUserId) .setUpdateBy(loginUserId) .setCreateTime(new Date()) .setUpdateTime(new Date()) .setAreaId(warehouseAreas.getId()); locRevise.setCode(SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_LOC_REVISE_CODE, null)); if (!locReviseService.save(locRevise)) { throw new CoolException("库存调整单保存失败！！"); } reviseParams.getReviseItems().forEach(revise -> { Loc loc = locService.getOne(new LambdaQueryWrapper().eq(Loc::getCode, revise.getLocCode())); ReviseLog reviseLog = new ReviseLog(); BeanUtils.copyProperties(loc, reviseLog); reviseLog.setReviseId(locRevise.getId()) .setLocCode(loc.getCode()) .setType(Integer.parseInt(loc.getType())) .setCreateBy(loginUserId) .setUpdateBy(loginUserId) .setCreateTime(new Date()) .setUpdateTime(new Date()) .setReviseCode(locRevise.getCode()); if (!reviseLogService.save(reviseLog)) { throw new CoolException("库存调整单不能为空！！"); } revise.getItems().forEach(reviseItem -> { ReviseLogItem logItem = new ReviseLogItem(); BeanUtils.copyProperties(reviseItem, logItem); Matnr matnr = matnrService.getOne(new LambdaQueryWrapper().eq(Matnr::getCode, reviseItem.getMatnrCode())); if (Objects.isNull(matnr)) { throw new CoolException("物料不存在！！"); } logItem.setLocId(loc.getId()) .setLocCode(loc.getCode()) .setId(null) .setMaktx(matnr.getName()) .setMatnrCode(matnr.getCode()) .setMatnrId(matnr.getId()) .setReviseLogId(reviseLog.getId()) .setCreateBy(loginUserId) .setUpdateBy(loginUserId) .setCreateTime(new Date()) .setUpdateTime(new Date()) .setReviseQty(reviseItem.getAnfme()); if (!reviseLogItemService.save(logItem)) { throw new CoolException("调整库存明细保存失败！！"); } }); }); return R.ok(); } /** * @author Ryan * @date 2025/8/20 * @description: 单据修改--收货通知单/出库单/盘点单 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncOrderUpdate(List orders) { orders.forEach(order -> { List list = Arrays.asList(AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val, AsnExceStatus.OUT_STOCK_STATUS_TASK_INIT.val); WkOrder wkOrder = asnOrderService.getOne(new LambdaQueryWrapper() .in(WkOrder::getExceStatus, list) .eq(WkOrder::getCode, order.getOrderNo())); if (Objects.isNull(wkOrder)) { throw new CoolException("请确认单据：" + order.getOrderNo() + "是否已经执行或是否同步！！"); } order.getOrdersItems().forEach(orderItem -> { if (!asnOrderItemService.update(new LambdaUpdateWrapper() .eq(WkOrderItem::getOrderCode, order.getOrderNo()) .eq(WkOrderItem::getMatnrCode, orderItem.getMatnrCode()) .eq(StringUtils.isNotEmpty(orderItem.getBatch()), WkOrderItem::getSplrBatch, orderItem.getBatch()) .eq(StringUtils.isNotEmpty(orderItem.getPlatItemId()), WkOrderItem::getPlatItemId, orderItem.getPlatItemId()) .set(WkOrderItem::getAnfme, orderItem.getAnfme()))) { throw new CoolException("单据修改失败！！"); } }); wkOrder.setAnfme(order.getAnfme()); if (!asnOrderService.updateById(wkOrder)) { throw new CoolException("主单据修改失败！！"); } }); return null; } /** * @author Ryan * @date 2025/8/21 * @description: 删除单据 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncOrderDelete(List orders) { orders.forEach(order -> { List list = Arrays.asList(AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val, AsnExceStatus.OUT_STOCK_STATUS_TASK_INIT.val); WkOrder wkOrder = asnOrderService.getOne(new LambdaQueryWrapper() .in(WkOrder::getExceStatus, list) .eq(WkOrder::getCode, order.getOrderNo())); if (Objects.isNull(wkOrder)) { throw new CoolException("订单：" + wkOrder.getCode() + "，当前状态，不可执行删除操作！！"); } order.getOrdersItems().forEach(orderItem -> { if (!asnOrderItemService.remove(new LambdaQueryWrapper() .eq(WkOrderItem::getMatnrCode, orderItem.getMatnrCode()) .eq(StringUtils.isNotEmpty(orderItem.getBatch()), WkOrderItem::getSplrBatch, orderItem.getBatch()) .eq(StringUtils.isNotEmpty(orderItem.getPlatItemId()), WkOrderItem::getPlatItemId, orderItem.getPlatItemId()) .eq(WkOrderItem::getOrderCode, wkOrder.getCode()))) { throw new CoolException("单据明细删除失败！！"); } List orderItems = asnOrderItemService.list(new LambdaQueryWrapper().eq(WkOrderItem::getOrderId, wkOrder.getId())); if (orderItems.isEmpty()) { if (!asnOrderService.removeById(wkOrder.getId())) { throw new CoolException("单据删除失败！！"); } } else { Double sum = orderItems.stream().mapToDouble(WkOrderItem::getAnfme).sum(); if (!asnOrderService.update(new LambdaUpdateWrapper() .eq(WkOrder::getId, wkOrder.getId()) .set(WkOrder::getAnfme, sum))) { throw new CoolException("主单数量修改失败！！"); } } }); }); return R.ok(); } /** * @author Ryan * @date 2025/8/21 * @description: 调拔单明细查询 * @version 1.0 */ @Override public R queryTransfer(QueryOrderParam queryParams) { Transfer transfer = transferService.getOne(new LambdaQueryWrapper() .in(Transfer::getCode, queryParams.getOrderNo())); if (Objects.isNull(transfer)) { throw new CoolException("单据不存在！！"); } List orderItems = transferItemService.list(new LambdaQueryWrapper() .eq(TransferItem::getTransferId, transfer.getId())); TransferInfoDto wkorderDto = new TransferInfoDto(); wkorderDto.setTransfer(transfer).setItems(orderItems); return R.ok().add(wkorderDto); } /** * @author Ryan * @date 2025/8/22 * @description: 盘点差异单同步 * @version 1.0 */ @Override @Transactional(timeout = 60, rollbackFor = Exception.class) public R syncCheckDiffs(SyncCheckDiffParams syncParams) { List diffs = checkDiffService.list(new LambdaQueryWrapper() .eq(CheckDiff::getExceStatus, CheckDiffExceStatus.CHECK_DIFF_EXCE_STATUS_END.val) .in(CheckDiff::getOrderCode, syncParams.getDiffCode())); if (diffs.isEmpty()) { return R.ok(); } List dtos = new ArrayList<>(); diffs.forEach(check -> { CheckDiffDto checkDto = new CheckDiffDto(); CheckDiff checkDiff = new CheckDiff(); BeanUtils.copyProperties(check, checkDiff); List items = checkDiffItemService.list(new LambdaQueryWrapper() .eq(CheckDiffItem::getCheckId, check.getId())); checkDto.setItems(items) .setCheckDiff(checkDiff); dtos.add(checkDto); }); return R.ok().add(dtos); } }