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