From e82c0c7ec9cdab78bbf5276ccd87bbee7a95503a Mon Sep 17 00:00:00 2001 From: liquanyu Date: Tue, 9 Aug 2016 17:49:33 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9F=AD=E4=BF=A1=E9=85=8D=E7=BD=AE=E5=8F=96?= =?UTF-8?q?=E6=B6=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lyms/platform/common/utils/HttpRequest.java | 78 +++++++++++++++++++--- .../lyms/platform/data/pojo/MessageRequest.java | 10 +++ .../platform/data/util/SaveMessageService.java | 21 ++++-- .../platform/operate/web/utils/ConfigTask.java | 2 +- .../operate/web/utils/MessageCenterService.java | 5 +- 5 files changed, 97 insertions(+), 19 deletions(-) diff --git a/platform-common/src/main/java/com/lyms/platform/common/utils/HttpRequest.java b/platform-common/src/main/java/com/lyms/platform/common/utils/HttpRequest.java index e648ca0..fb24bd2 100644 --- a/platform-common/src/main/java/com/lyms/platform/common/utils/HttpRequest.java +++ b/platform-common/src/main/java/com/lyms/platform/common/utils/HttpRequest.java @@ -258,6 +258,60 @@ public class HttpRequest { return result; } + public static String sendPut(String url, String param,String auth) { + PrintWriter out = null; + BufferedReader in = null; + String result = ""; + try { + URL realUrl = new URL(url); + // 打开和URL之间的连接 + HttpURLConnection conn = (HttpURLConnection)realUrl.openConnection(); + // 设置通用的请求属性 + conn.setRequestProperty("accept", "*/*"); + conn.setRequestProperty("connection", "Keep-Alive"); + conn.setRequestProperty("Authorization",auth); + conn.setRequestProperty("Content-Type", "application/json"); + conn.setRequestProperty("user-agent", + "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + // 发送POST请求必须设置如下两行 + conn.setDoOutput(true); + conn.setDoInput(true); + conn.setRequestMethod("PUT"); + conn.setRequestProperty("Charset", "UTF-8"); + // 获取URLConnection对象对应的输出流 + out = new PrintWriter(conn.getOutputStream()); + // 发送请求参数 + out.print(param); + // flush输出流的缓冲 + out.flush(); + // 定义BufferedReader输入流来读取URL的响应 + in = new BufferedReader( + new InputStreamReader(conn.getInputStream())); + String line; + while ((line = in.readLine()) != null) { + result += line; + } + } catch (Exception e) { + System.out.println("发送 POST 请求出现异常！"+e); + e.printStackTrace(); + } + //使用finally块来关闭输出流、输入流 + finally{ + try{ + if(out!=null){ + out.close(); + } + if(in!=null){ + in.close(); + } + } + catch(IOException ex){ + ex.printStackTrace(); + } + } + return result; + } + public static String Send(String sendUrl,String param){ String retValue = null; HttpURLConnection con = null; @@ -291,16 +345,18 @@ public class HttpRequest { public static void main(String[] args) { // sendGet("http://localhost:8080/message_develop/sendMMS","id=222222"); // String str = sendGet("http://data.api.healthbaby.com.cn/v1/messages","hospitalId=1&tagName=,高血压,&page=1&limit=9999"); - Map headers = new HashMap(); - headers.put("Authorization", "healthbaby2015"); - Map params = new HashMap(); - params.put("hospitalId", "e66aafcf-1be5-4cd0-89bc-cf65db7297cc"); - params.put("tagName", "1周"); - params.put("page", "1"); - params.put("limit", "999"); - - String str = sendGet("http://data.api.healthbaby.com.cn/v1/messages", - params,headers); - System.out.println(str); +// Map headers = new HashMap(); +// headers.put("Authorization", "healthbaby2015"); +// Map params = new HashMap(); +// params.put("hospitalId", "e66aafcf-1be5-4cd0-89bc-cf65db7297cc"); +// params.put("tagName", "1周"); +// params.put("page", "1"); +// params.put("limit", "999"); +// +// String str = sendGet("http://data.api.healthbaby.com.cn/v1/messages", +// params,headers); +// System.out.println(str); + String json = "[{\"key\":\"6\",\"value\":\"true\"},{\"key\":\"7\",\"value\":\"true\"},{\"key\":\"2\",\"value\":\"false\"},{\"key\":\"3\",\"value\":\"false\"},{\"key\":\"8\",\"value\":\"false\"},{\"key\":\"9\",\"value\":\"false\"},{\"key\":\"10\",\"value\":\"false\"},{\"key\":\"12\",\"value\":\"false\"},{\"key\":\"13\",\"value\":\"false\"},{\"key\":\"15\",\"value\":\"false\"},{\"key\":\"16\",\"value\":\"false\"},{\"key\":\"17\",\"value\":\"false\"},{\"key\":\"19\",\"value\":\"false\"},{\"key\":\"20\",\"value\":\"false\"},{\"key\":\"22\",\"value\":\"false\"},{\"key\":\"23\",\"value\":\"false\"}]"; + String result = HttpRequest.sendPut("http://192.168.5.13:8080/v1/serviceConfig/196",json,"YMer2016"); } } diff --git a/platform-data-api/src/main/java/com/lyms/platform/data/pojo/MessageRequest.java b/platform-data-api/src/main/java/com/lyms/platform/data/pojo/MessageRequest.java index d60c2a7..8e1e981 100644 --- a/platform-data-api/src/main/java/com/lyms/platform/data/pojo/MessageRequest.java +++ b/platform-data-api/src/main/java/com/lyms/platform/data/pojo/MessageRequest.java @@ -8,6 +8,7 @@ public class MessageRequest { private String content; private Integer typeId; private Integer subTypeId; + private Integer status; //计划发送时间 @@ -29,6 +30,15 @@ public class MessageRequest { //患者ID private String ext3; + + public Integer getStatus() { + return status; + } + + public void setStatus(Integer status) { + this.status = status; + } + public String getPhone() { return phone; } diff --git a/platform-data-api/src/main/java/com/lyms/platform/data/util/SaveMessageService.java b/platform-data-api/src/main/java/com/lyms/platform/data/util/SaveMessageService.java index a403c65..5423ec1 100644 --- a/platform-data-api/src/main/java/com/lyms/platform/data/util/SaveMessageService.java +++ b/platform-data-api/src/main/java/com/lyms/platform/data/util/SaveMessageService.java @@ -21,7 +21,8 @@ public class SaveMessageService { public static boolean saveSmsCenter(MessageListRequest list) { String json = JsonUtil.obj2JsonString(list); - String result = HttpRequest.sendPost(CENTER_BASE_URL+"saveCreatedSMS",json,CENTER_TOKEN); + //String result = HttpRequest.sendPost(CENTER_BASE_URL+"saveCreatedSMS",json,CENTER_TOKEN); + String result = HttpRequest.sendPost("http://192.168.5.13:8080/v1/saveCreatedSMS",json,"YMer2016"); if (StringUtils.isNotEmpty(result)) { Map map = JsonUtil.str2Obj(result, Map.class); @@ -55,21 +56,31 @@ public class SaveMessageService { List messages = new ArrayList<>(); MessageRequest request = new MessageRequest(); request.setTypeId(1); - request.setContent("222222222222222"); + request.setStatus(0); + request.setContent("cccccccccccccccccc"); request.setObjType(1); - request.setPhone("18382670032"); + request.setPhone("18382670000"); request.setPlanTime("2015-01-06 15:22:12"); request.setServiceType(1); + request.setExt1("196"); + request.setExt2("10"); + request.setExt3("10"); + request.setSubTypeId(6); messages.add(request); MessageRequest request1 = new MessageRequest(); request1.setTypeId(1); - request1.setContent("1111111111111111"); + request1.setStatus(0); + request1.setContent("bbbbbbbbbbbbbb"); request1.setObjType(1); - request1.setPhone("18382670031"); + request1.setPhone("18382670001"); request1.setPlanTime("2015-01-06 15:22:12"); request1.setServiceType(1); + request.setSubTypeId(7); + request1.setExt1("196"); + request1.setExt2("10"); + request1.setExt3("10"); messages.add(request1); list.setTypeId(1); diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/ConfigTask.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/ConfigTask.java index 26f5cb1..77c982a 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/ConfigTask.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/ConfigTask.java @@ -67,6 +67,6 @@ public class ConfigTask implements Runnable { } } - MessageCenterService.serviceConfig(resultServices,hid); + //MessageCenterService.serviceConfig(resultServices,hid); } } diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/MessageCenterService.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/MessageCenterService.java index 1b807b4..4dca111 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/MessageCenterService.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/MessageCenterService.java @@ -26,8 +26,9 @@ public class MessageCenterService { */ public static boolean serviceConfig(List configs,String hid) { - String json = JsonUtil.obj2JsonString(configs); - String result = HttpRequest.sendPost(CENTER_BASE_URL+"serviceConfig/{"+hid+"}", json, CENTER_TOKEN); + String json = JsonUtil.array2JsonString(configs); +// String result = HttpRequest.sendPost(CENTER_BASE_URL + "serviceConfig/{" + hid + "}", json, CENTER_TOKEN); + String result = HttpRequest.sendPut("http://192.168.5.13:8080/v1/serviceConfig/"+hid,json,"YMer2016"); if (StringUtils.isNotEmpty(result)) { Map map = JsonUtil.str2Obj(result, Map.class); -- 1.8.3.1