ErpServiceImpl.java
5.21 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package com.huaheng.api.erp.service;
import com.huaheng.api.erp.domain.ErpMaterialSync;
import com.huaheng.api.erp.domain.ErpSalesReturnSyncDomain;
import com.huaheng.api.erp.domain.ErpSalesReturnSyncItem;
import com.huaheng.api.general.domain.ReceiptDomain;
import com.huaheng.api.general.service.ReceiptApiService;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.config.material.domain.Material;
import com.huaheng.pc.config.material.service.MaterialService;
import com.huaheng.pc.receipt.receiptDetail.domain.ReceiptDetail;
import com.huaheng.pc.receipt.receiptHeader.domain.ReceiptHeader;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@Service
public class ErpServiceImpl implements ErpService {
@Resource
private MaterialService materialService;
@Resource
private ReceiptApiService receiptApiService;
@Override
public AjaxResult materialSync(List<ErpMaterialSync> masterDataList) {
for (ErpMaterialSync erpMaterial : masterDataList) {
AjaxResult ajaxResult = syncSingleMaterial(erpMaterial);
if (ajaxResult.hasErr()) {
return ajaxResult;
}
}
return AjaxResult.success("物料信息同步成功");
}
private AjaxResult syncSingleMaterial(ErpMaterialSync erpMaterial) {
String warehouseCode = QuantityConstant.DEFAULT_WAREHOUSE;
String companyCode = QuantityConstant.COMPANYCODE;
Material material = materialService.getMaterialByCode(erpMaterial.getSku(), warehouseCode);
if (material != null) {
material.setName(erpMaterial.getSkuName());
material.setUnit(erpMaterial.getUom());
material.setSpec(erpMaterial.getSkuSpec());
material.setLastUpdated(new Date());
material.setLastUpdatedBy("ERP");
if (!materialService.updateById(material)) {
return AjaxResult.error("更新物料失败，物料编码：" + erpMaterial.getSku());
}
} else {
material = new Material();
material.setCode(erpMaterial.getSku());
material.setName(erpMaterial.getSkuName());
material.setUnit(erpMaterial.getUom());
material.setSpec(erpMaterial.getSkuSpec());
material.setWarehouseCode(warehouseCode);
material.setCompanyCode(companyCode);
material.setEnable(true);
material.setDeleted(false);
material.setCreated(new Date());
material.setCreatedBy("ERP");
material.setLastUpdated(new Date());
material.setLastUpdatedBy("ERP");
if (!materialService.save(material)) {
return AjaxResult.error("新增物料失败，物料编码：" + erpMaterial.getSku());
}
}
return AjaxResult.success("物料同步成功，物料编码：" + erpMaterial.getSku());
}
@Override
public AjaxResult salesReturnAdd(ErpSalesReturnSyncDomain erpSalesReturnSyncDomain) {
ReceiptDomain receiptDomain = new ReceiptDomain();
ReceiptHeader receiptHeader = new ReceiptHeader();
receiptHeader.setWarehouseCode(QuantityConstant.DEFAULT_WAREHOUSE);
receiptHeader.setCompanyCode(QuantityConstant.COMPANYCODE);
receiptHeader.setReceiptType(erpSalesReturnSyncDomain.getOrderType());
receiptHeader.setReferCode(erpSalesReturnSyncDomain.getOrderNo());
receiptHeader.setQcFlag(erpSalesReturnSyncDomain.getQcFlag());
receiptHeader.setMakerName(erpSalesReturnSyncDomain.getMakerName());
receiptDomain.setReceiptHeader(receiptHeader);
List<ReceiptDetail> receiptDetails = new ArrayList<>();
for (ErpSalesReturnSyncItem item : erpSalesReturnSyncDomain.getItems()) {
if (item.getSku() == null || item.getSku().isEmpty()) {
return AjaxResult.error("销退单明细物料编码不能为空");
}
if (item.getQuantity() == null || BigDecimal.ZERO.compareTo(item.getQuantity()) == 0) {
return AjaxResult.error("销退单明细入库数量不能为空或为0，物料编码：" + item.getSku());
}
ReceiptDetail receiptDetail = new ReceiptDetail();
receiptDetail.setWarehouseCode(QuantityConstant.DEFAULT_WAREHOUSE);
receiptDetail.setCompanyCode(QuantityConstant.COMPANYCODE);
receiptDetail.setMaterialCode(item.getSku());
receiptDetail.setMaterialName(item.getSkuName());
receiptDetail.setMaterialSpec(item.getSkuSpec());
receiptDetail.setMaterialUnit(item.getUom());
receiptDetail.setLot(item.getLot());
receiptDetail.setQty(item.getQuantity());
receiptDetail.setReferCode(erpSalesReturnSyncDomain.getOrderNo());
receiptDetail.setReferLineNum(item.getPoLine());
receiptDetail.setAreaCode(item.getAreaCode());
receiptDetails.add(receiptDetail);
}
receiptDomain.setReceiptDetails(receiptDetails);
return receiptApiService.receipt(receiptDomain);
}
}