#1

dubin

1 天以前 295ee7dd14f5d36e2fe442714ab0a80c480c8029

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
package com.zy.asrs.task.handler;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.WrkMastService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.utils.HttpHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.HashMap;
 
@Slf4j
@Service
@Transactional
public class OutWorkHandler extends AbstractHandler<String> {
 
    @Autowired
    private ApiLogService apiLogService;
    @Value("${wcs.address.URL}")
    private String addrs;
    @Value("${wcs.address.outboundTaskSend}")
    private String outboundTaskSend;
    @Autowired
    private WrkMastService wrkMastService;
 
 
    public synchronized ReturnT<String> start(WrkMast wrkMast) {
        HashMap<String, Object> map = new HashMap<>();
        map.put("taskNo", wrkMast.getWrkNo());
        map.put("taskPriority", 10);
        map.put("barcode", wrkMast.getBarcode());
 
        if (wrkMast.getIoType() == 11) {
            map.put("taskType", 3);
            map.put("startPoint", wrkMast.getSourceLocNo());
            map.put("targetPoint", wrkMast.getLocNo());
        }else {
            map.put("taskType", 2);
            map.put("startPoint", wrkMast.getSourceLocNo());
            map.put("targetPoint", wrkMast.getSourceStaNo() + "-" + wrkMast.getStaNo());
        }
 
        String response ="";
        boolean bool =false;
//        try {
//            log.info("wms派发任务给wcs出库={}", JSON.toJSONString(map));
//            response = new HttpHandler.Builder()
//                    // .setHeaders(headParam)
//                    .setUri(addrs)
//                    .setPath(outboundTaskSend)
//                    .setJson(JSON.toJSONString(map))
//                    .build()
//                    .doPost();
//            JSONObject jsonObject = JSON.parseObject(response);
//            if(jsonObject.getInteger("code") == 200){
//                wrkMast.setWrkSts(12L);
//                wrkMastService.updateById(wrkMast);
//                bool = true;
//            }else {
//                log.error("wms派发任务给wcs出库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
//            }
//        } catch (Exception e) {
//            log.error("wms派发任务给wcs出库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
//        } finally {
//            apiLogService.save("wms派发任务给wcs出库"
//                    , addrs + outboundTaskSend
//                    , null
//                    , "127.0.0.1"
//                    , JSON.toJSONString(map)
//                    , response
//                    , bool
//            );
//        }
        return SUCCESS;
 
    }
}