123

ZY

5 天以前 1a1e3398d15027a65e56e0ed82e54f3a4feea0b6

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
package com.zy.asrs.utils;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.core.exception.CoolException;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.utils.HttpHandler;
import lombok.extern.slf4j.Slf4j;
 
@Slf4j
public class PostMesDataUtils extends AbstractHandler<String> {
//            new PostMesDataUtils().postMesData("MES系统",null,null,null);
 
 
    /*
     * url: eg: 192.168.4.15:1433
     * path: eg: api/InterFace/get_InterFace_TestStorage
     * combParam:参数
     * */
    public ReturnT<String> postMesData(String name, String URL, String mesPath, Object combParam) {
//        if (true){
//            System.out.println("name:"+name+",URL:"+URL+",mesPath:"+mesPath+",combParam:"+combParam);
//            return SUCCESS;
//        }
        if (combParam != null) {
            String response = "";
            boolean success = false;
            try {
//                Map<String, Object> map = new HashMap<>()
//                map.put("appkey","ea1f0459efc02a79f046f982767939ae");
                response = new HttpHandler.Builder()
//                        .setHeaders(map)
                        .setUri(URL)
                        .setPath(mesPath)
                        .setJson(JSON.toJSONString(combParam))
                        .build()
                        .doPost();
                System.out.println("response:" + response);
                JSONObject jsonObject = JSON.parseObject(response);
 
                if (jsonObject.getInteger("code").equals(200)) {
                    success = true;
                } else {
                    log.error("请求接口失败！！！url：{}；request：{}；response：{}", URL + "/" + mesPath, JSON.toJSONString(combParam), response);
                    throw new CoolException("上报" + name);
                }
            } catch (Exception e) {
                log.error("请求接口失败！！！url：{}；request：{}；response：{}", URL + "/" + mesPath, JSON.toJSONString(combParam), response);
//                      TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                return FAIL.setMsg(e.getMessage());
            } finally {
                try {
 
                } catch (Exception e) {
                    log.error("", e);
                }
            }
        }
        return SUCCESS;
    }
}