AssignTaskController.java
4.96 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
123
124
125
126
127
128
package com.huaheng.api.wcs.controller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.huaheng.api.wcs.domain.AssignTask;
import com.huaheng.api.wcs.domain.WmsTask;
import com.huaheng.api.wcs.service.assignTask.AssignTaskService;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.common.exception.service.ServiceException;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.common.utils.http.HttpUtils;
import com.huaheng.framework.aspectj.lang.annotation.Log;
import com.huaheng.framework.aspectj.lang.constant.BusinessType;
import com.huaheng.framework.web.controller.BaseController;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.config.address.service.AddressService;
import com.huaheng.pc.inventory.inventoryHeader.service.InventoryHeaderService;
import com.huaheng.pc.system.config.service.IConfigService;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.WebDataBinder;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**任务完成
* wcs向wms传递数据
* @author ricard
* @date 2019/10/11
*
*/
@RestController
@RequestMapping("/API/WMS/v2")
public class AssignTaskController extends BaseController {
@Resource
private AssignTaskService assignTaskService;
@Resource
private InventoryHeaderService inventoryHeaderService;
@Resource
private AddressService addressService;
@Resource
private IConfigService iConfigService;
@Log(title = "WMS下发下架任务或移位任务至WIS", action = BusinessType.INSERT)
@PostMapping("/assignTask")
@ApiOperation("WMS下发下架任务或移位任务至WIS")
@ResponseBody
public AjaxResult assignTask(@RequestBody AssignTask assignTask) {
AjaxResult ajaxResult=assignTaskService.assignTaskByWIS(assignTask);
return ajaxResult;
}
@Log(title = "站台呼叫空托盘", action = BusinessType.INSERT)
@PostMapping("/emptyContainerOutWcs")
@ApiOperation("站台呼叫空托盘")
@ResponseBody
public AjaxResult emptyContainerOutWcs(){
String containercode="";
AjaxResult result=inventoryHeaderService.emptyContainerOutWcs(containercode);
return result;
}
@Log(title = "空托盘校验", action = BusinessType.INSERT)
@PostMapping("/wmsPltCheck")
@ApiOperation("空托盘校验")
@ResponseBody
public AjaxResult wmsPltCheck(@RequestBody WmsTask wmsTask){
wmsTask.setReqID("123");
wmsTask.setRequestTime("2021.11.18");
String JsonParam = JSON.toJSONString(wmsTask);
System.out.println(JsonParam);
String url="";
String result = HttpUtils.bodypost(url, JsonParam);
if (StringUtils.isEmpty(result)) {
throw new ServiceException("接口地址错误或返回为空");
}
return null;
}
@PostMapping("/StationInfos")
@ResponseBody
public AjaxResult StationInfos() {
JSONObject json=new JSONObject();
String port []= {"P1001","P1004","P1005","P1008"};
json.put("stations",port);
String url="http://10.20.137.43:8124/api/WCSTask/StationInfos";
//String url = addressService.selectAddress(QuantityConstant.ADDRESS_WCS_TASK_ASSIGN, warehouseCode, area);
String result = HttpUtils.bodypost(url, json.toJSONString());
json=JSONObject.parseObject(result);
String data=json.getString("data");
List<JSONObject>jsonlist=JSON.parseArray(data,JSONObject.class);
for(JSONObject ob:jsonlist){
System.out.println(ob.getString("station"));
System.out.println(ob.getString("state"));
if(ob.getString("state")=="0"){
result=ob.getString("station");
break;
}
}
return AjaxResult.success(result);
}
@PostMapping("/getTaskNo")
@ResponseBody
public JSONObject getTaskNo(@RequestBody WmsTask wmsTask){
String taskNo="";
String emptyPallet="";
JSONObject json=new JSONObject();
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式
wmsTask.setReqID(iConfigService.getRegId());
wmsTask.setRequestTime(df.format(new Date()));
String JsonParam = JSON.toJSONString(wmsTask);
System.out.println(JsonParam);
String url = addressService.selectAddress(QuantityConstant.ADDRESS_WMS_EMPTY_JUDGE, "ZH0001", "1");
String result = HttpUtils.bodypost(url, JsonParam);
json=JSONObject.parseObject(result);
System.out.println(json.getString("data"));
JSONObject jsondata=JSONObject.parseObject(json.getString("data"));
taskNo=jsondata.getString("taskNo");
emptyPallet=jsondata.getString("emptyPallet");
System.out.println("pppppppp:0."+taskNo+"lllllll:"+emptyPallet);
return JSONObject.parseObject(taskNo);
}
}