ShipmentApi.java
4.83 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
115
116
117
118
119
120
121
122
package com.huaheng.api.Common;
import com.alibaba.fastjson.JSON;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.common.utils.http.HttpUtils;
import com.huaheng.common.utils.security.ShiroUtils;
import com.huaheng.framework.web.controller.BaseController;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.general.company.service.ICompanyService;
import com.huaheng.pc.general.material.domain.Material;
import com.huaheng.pc.general.material.service.IMaterialService;
import com.huaheng.pc.shipment.shipmentDetail.domain.ShipmentDetail;
import com.huaheng.pc.shipment.shipmentDetail.service.IShipmentDetailService;
import com.huaheng.pc.shipment.shipmentHeader.domain.ShipmentHeader;
import com.huaheng.pc.shipment.shipmentHeader.domain.ShipmentModel;
import com.huaheng.pc.shipment.shipmentHeader.service.IShipmentHeaderService;
import com.huaheng.pc.system.dict.service.IDictDataService;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
/**
* 出库下发或回传
* @author huaheng
* @date 2018-12-18
*
*
*
*/
public class ShipmentApi extends BaseController {
@Autowired
private IDictDataService dictDataService;
@Autowired
IShipmentDetailService shipmentDetailService;
@Autowired
ICompanyService companyService;
@Autowired
IShipmentHeaderService shipmentHeaderService;
@Autowired
private IMaterialService materialService;
//出库单下发
public AjaxResult insertShipment(ShipmentHeader shipmentHeader, List<ShipmentDetail> shipmentDetails){
if(dictDataService.checkConfig("shipmentType", shipmentHeader.getType()) == false)
{
return AjaxResult.error("没有对应的出库单类型");
}
int result = shipmentHeaderService.insert(shipmentHeader);
if(result<1){
return AjaxResult.error("新增主单失败");
}
//添加细表到shipmentDetail
for(ShipmentDetail shipmentDetail : shipmentDetails) {
ShipmentHeader shipmentHeader1 = shipmentHeaderService.selectEntityById(shipmentDetail.getShipmentId());
if (!shipmentHeader1.equals(shipmentHeader)) {
return AjaxResult.error("找不到主单据");
}
if (shipmentHeader1.getFirstStatus() > 100) {
//表示已经加入了波次
return AjaxResult.error("主单据状态不允许新增明细");
}
Material material = new Material();
material.setCode(shipmentDetail.getMaterialCode());
material.setWarehouseId(ShiroUtils.getWarehouseId());
material = materialService.selectFirstEntity(material);
if (material == null) {
return AjaxResult.error("物料未找到");
}
if (StringUtils.isNotEmpty(material.getCompanyCode()) &&
ShiroUtils.getCompanyCodeList().contains(material.getCompanyCode()) == false)
{
return AjaxResult.error("物料不属于当前货主！");
}
if (shipmentDetailService.insert(shipmentDetail) > 0){
//更新单据总行数与总数量
shipmentHeader.setTotalLines(shipmentHeader.getTotalLines() + 1);
shipmentHeader.setTotalQty(shipmentHeader.getTotalQty().add(shipmentDetail.getQty()));
shipmentHeaderService.updateByModel(shipmentHeader);
}
else {
return AjaxResult.error("新增单据明细失败");
}
}
return AjaxResult.success("出库单下发成功");
}
//出库单回传
public AjaxResult shipmentAssign(String url)
{
ShipmentHeader shipmentHeader = new ShipmentHeader();
shipmentHeader.setLastStatus(300);
shipmentHeader = shipmentHeaderService.selectFirstEntity(shipmentHeader);
if (shipmentHeader == null) {
return AjaxResult.error("出库回传主单不存在");
}
ShipmentDetail shipmentDetail = new ShipmentDetail();
shipmentDetail.setShipmentCode(shipmentHeader.getCode());
List<ShipmentDetail> shipmentDetails = shipmentDetailService.selectListEntityByEqual(shipmentDetail);
if (shipmentDetails == null) {
return AjaxResult.error("出库回传子单不存在");
}
ShipmentModel model=new ShipmentModel();
model.setShipmentHeader(shipmentHeader);
model.setShipmentDetails(shipmentDetails);
String JsonParam = JSON.toJSONString(model);
String result = HttpUtils.sendPost(url, JsonParam);
AjaxResult ajaxResult = JSON.parseObject(result, AjaxResult.class);
shipmentHeader.setFirstStatus(900);
shipmentHeader.setLastStatus(900);
shipmentHeaderService.updateByModel(shipmentHeader);
return ajaxResult;
}
}