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; 
 | 
    } 
 | 
} 
 |