From 011aef710ccfcbdc7d9f658b1babfb01d218b131 Mon Sep 17 00:00:00 2001 From: Jackwang Date: Wed, 16 Dec 2020 18:35:35 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90=E4=BA=8B=E4=BB=B6=E4=B8=8A=E6=8A=A5?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E3=80=91-=E3=80=90=E4=BA=8B=E4=BB=B6?= =?UTF-8?q?=E4=B8=8A=E6=8A=A5=E3=80=91-=EF=BC=88=E7=8E=8B=E7=AB=A5?= =?UTF-8?q?=EF=BC=89-2020/12/16?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- shibei-gird-sdk/pom.xml | 6 + .../gird/shibei/api/ShiBeiCityGridApi.java | 11 + .../api/impl/ShiBeiCityGridApiImpl.java | 31 ++ .../gird/shibei/constant/CommonConstants.java | 24 ++ .../gird/shibei/contants/ApiConstants.java | 4 + .../shibei/dto/form/SendEventFormDto.java | 268 ++++++++++++++++++ .../shibei/dto/result/SendEventResultDto.java | 87 ++++++ 7 files changed, 431 insertions(+) create mode 100644 shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/form/SendEventFormDto.java create mode 100644 shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/result/SendEventResultDto.java diff --git a/shibei-gird-sdk/pom.xml b/shibei-gird-sdk/pom.xml index 5a87a2a..bc58279 100644 --- a/shibei-gird-sdk/pom.xml +++ b/shibei-gird-sdk/pom.xml @@ -17,6 +17,7 @@ 1.4.11.1 + 1.2.59 @@ -60,6 +61,11 @@ org.apache.httpcomponents httpcore + + com.alibaba + fastjson + ${fastjson.version} + diff --git a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/ShiBeiCityGridApi.java b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/ShiBeiCityGridApi.java index 7e78b3c..9327a59 100644 --- a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/ShiBeiCityGridApi.java +++ b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/ShiBeiCityGridApi.java @@ -4,8 +4,10 @@ package com.elink.esua.epdc.gird.shibei.api; import com.elink.esua.epdc.gird.shibei.dto.GetZSBInputInfoDto; import com.elink.esua.epdc.gird.shibei.dto.GridDto; import com.elink.esua.epdc.gird.shibei.dto.SearchCaseProcessByTaskIdDto; +import com.elink.esua.epdc.gird.shibei.dto.form.SendEventFormDto; import com.elink.esua.epdc.gird.shibei.dto.form.SendInputInfoFormDto; import com.elink.esua.epdc.gird.shibei.dto.form.SendWenXinEvaluateInfoFormDto; +import com.elink.esua.epdc.gird.shibei.dto.result.SendEventResultDto; /** * 市北城市网格化平台API接口 @@ -31,6 +33,15 @@ public interface ShiBeiCityGridApi { */ GridDto newSendInputInfo(SendInputInfoFormDto caseReportFormDto); + /** + * @describe: 事件上报信息 + * @author wangtong + * @date 2020/12/15 15:43 + * @params [SendEventFormDto] + * @return void + */ + SendEventResultDto sendEvent(SendEventFormDto sendEventFormDto); + /** * 评价事件接口 * diff --git a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/impl/ShiBeiCityGridApiImpl.java b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/impl/ShiBeiCityGridApiImpl.java index 94aafdb..0d4bd62 100644 --- a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/impl/ShiBeiCityGridApiImpl.java +++ b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/api/impl/ShiBeiCityGridApiImpl.java @@ -1,12 +1,17 @@ package com.elink.esua.epdc.gird.shibei.api.impl; +import cn.hutool.http.HttpRequest; +import cn.hutool.http.HttpResponse; +import com.alibaba.fastjson.JSONObject; import com.elink.esua.epdc.gird.shibei.api.ShiBeiCityGridApi; import com.elink.esua.epdc.gird.shibei.contants.ApiConstants; import com.elink.esua.epdc.gird.shibei.dto.GetZSBInputInfoDto; import com.elink.esua.epdc.gird.shibei.dto.GridDto; import com.elink.esua.epdc.gird.shibei.dto.SearchCaseProcessByTaskIdDto; +import com.elink.esua.epdc.gird.shibei.dto.form.SendEventFormDto; import com.elink.esua.epdc.gird.shibei.dto.form.SendInputInfoFormDto; import com.elink.esua.epdc.gird.shibei.dto.form.SendWenXinEvaluateInfoFormDto; +import com.elink.esua.epdc.gird.shibei.dto.result.SendEventResultDto; import com.elink.esua.epdc.gird.shibei.util.XstreamUtil; import com.elink.esua.httpclient.HttpClientUtils; import com.elink.esua.httpclient.ResultDto; @@ -61,6 +66,32 @@ public class ShiBeiCityGridApiImpl implements ShiBeiCityGridApi { } } + @Override + public SendEventResultDto sendEvent(SendEventFormDto sendEventFormDto) { + String json = JSONObject.toJSONString(sendEventFormDto); + String data = "content="+ json; + LOGGER.info("发送参数:" + data); + HttpResponse response = null; + try { + response = HttpRequest.post(ApiConstants.sendEventUrl).body(data) + .header("lan", "zh") + .header("Content-type", "application/x-www-form-urlencoded;charset=UTF-8").execute(); + } catch (Exception e) { + e.printStackTrace(); + LOGGER.error("事件上报信息异常：" + e.getMessage()); + } + LOGGER.info("事件上报返回数据:" + response.body()); + JSONObject res = JSONObject.parseObject(response.body()); + if(0 == Integer.parseInt(res.get("code").toString())){ + SendEventResultDto result = (SendEventResultDto) JSONObject.toJavaObject((JSONObject) res.get("data"), SendEventResultDto.class); + return result; + }else{ + LOGGER.error("事件上报返回信息错误：" + res); + SendEventResultDto result = (SendEventResultDto) JSONObject.toJavaObject(res, SendEventResultDto.class); + return result; + } + } + @Override public GridDto sendWenXinEvaluateInfo(SendWenXinEvaluateInfoFormDto sendWenXinEvaluateInfoFormDto) { Map map = Maps.newHashMap(); diff --git a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/constant/CommonConstants.java b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/constant/CommonConstants.java index b6a0c5f..05f0e53 100644 --- a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/constant/CommonConstants.java +++ b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/constant/CommonConstants.java @@ -44,4 +44,28 @@ public class CommonConstants { * 字符：/ */ public static String CHAR_ASCII_47 = "/"; + + + //*******************************新版HTTP请求参数******************************** + + /** + * 推送类别（事件上报） + */ + public static String SEND_TYPE = "SJSB"; + + /** + * 市北区编码 + */ + public static String CITY_INFO_CODE = "370203"; + + /** + * 1代表上报至区中心平台 + */ + public static String PARTY_SEND_TO = "1"; + + + /** + * 事件来源 04代表 党群e家上报 + */ + public static String PARTY_EVENT_SOURCE = "04"; } diff --git a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/contants/ApiConstants.java b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/contants/ApiConstants.java index 9a426a2..ca2875b 100644 --- a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/contants/ApiConstants.java +++ b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/contants/ApiConstants.java @@ -18,6 +18,10 @@ public class ApiConstants { */ public static final String newSendInputInfo = "http://60.209.152.68:8083/CityGridInterfaceServiceWebService1.0/WebService.asmx/SendInputInfo"; + /** + * 事件上报信息 + */ + public static final String sendEventUrl = "http://120.221.72.15:8089/sbwgh/plugin/sbwgh/sendEvent.htm"; /** * 评价事件接口 diff --git a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/form/SendEventFormDto.java b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/form/SendEventFormDto.java new file mode 100644 index 0000000..2411f26 --- /dev/null +++ b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/form/SendEventFormDto.java @@ -0,0 +1,268 @@ +package com.elink.esua.epdc.gird.shibei.dto.form; + +import com.alibaba.fastjson.annotation.JSONField; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.List; + +/** + * @program: esua-epdc + * @description: 事件上报信息 + * @author: wangtong + * @create: 2020-12-15 15:14 + **/ +public class SendEventFormDto implements Serializable { + + private static final long serialVersionUID = 8360383317020883379L; + + /** + *推送类别（事件上报） + */ + @JSONField(name = "SENDTYPE") + private String SENDTYPE; + + /** + *1代表上报至区中心平台，2代表上报至街道平台 + */ + @JSONField(name = "SENDACTDEFID") + private String SENDACTDEFID; + + /** + *推送端记录唯一标识 + */ + @JSONField(name = "UID") + private String UID; + + /** + *事件领域 + */ + @JSONField(name = "SJLYU") + private String SJLYU; + + /** + *事件大类 + */ + @JSONField(name = "SJDL") + private String SJDL; + + /** + *事件小类 + */ + @JSONField(name = "SJXL") + private String SJXL; + + /** + *事件细类 + */ + @JSONField(name = "SJXIL") + private String SJXIL; + + /** + *事件来源 04代表 党群e家上报 06代表在市北App上报 + */ + @JSONField(name = "SJLY") + private String SJLY; + + /** + *所属区市 + */ + @JSONField(name = "SSQS") + private String SSQS; + + /** + *所属街道 + */ + @JSONField(name = "SSJD") + private String SSJD; + + /** + *所属社区 + */ + @JSONField(name = "SSSQ") + private String SSSQ; + + /** + *事件地址 + */ + @JSONField(name = "SJDZ") + private String SJDZ; + + /** + *事件描述 + */ + @JSONField(name = "SJMS") + private String SJMS; + + /** + *X坐标（经纬度） + */ + @JSONField(name = "XZB") + private BigDecimal XZB; + + /** + *Y坐标（经纬度） + */ + @JSONField(name = "YZB") + private BigDecimal YZB; + + /** + *图片 + */ + @JSONField(name = "IMAGES") + private List IMAGES; + + public static long getSerialVersionUID() { + return serialVersionUID; + } + + public String getSENDTYPE() { + return SENDTYPE; + } + + public void setSENDTYPE(String SENDTYPE) { + this.SENDTYPE = SENDTYPE; + } + + public String getSENDACTDEFID() { + return SENDACTDEFID; + } + + public void setSENDACTDEFID(String SENDACTDEFID) { + this.SENDACTDEFID = SENDACTDEFID; + } + + public String getUID() { + return UID; + } + + public void setUID(String UID) { + this.UID = UID; + } + + public String getSJLYU() { + return SJLYU; + } + + public void setSJLYU(String SJLYU) { + this.SJLYU = SJLYU; + } + + public String getSJDL() { + return SJDL; + } + + public void setSJDL(String SJDL) { + this.SJDL = SJDL; + } + + public String getSJXL() { + return SJXL; + } + + public void setSJXL(String SJXL) { + this.SJXL = SJXL; + } + + public String getSJXIL() { + return SJXIL; + } + + public void setSJXIL(String SJXIL) { + this.SJXIL = SJXIL; + } + + public String getSJLY() { + return SJLY; + } + + public void setSJLY(String SJLY) { + this.SJLY = SJLY; + } + + public String getSSQS() { + return SSQS; + } + + public void setSSQS(String SSQS) { + this.SSQS = SSQS; + } + + public String getSSJD() { + return SSJD; + } + + public void setSSJD(String SSJD) { + this.SSJD = SSJD; + } + + public String getSSSQ() { + return SSSQ; + } + + public void setSSSQ(String SSSQ) { + this.SSSQ = SSSQ; + } + + public String getSJDZ() { + return SJDZ; + } + + public void setSJDZ(String SJDZ) { + this.SJDZ = SJDZ; + } + + public String getSJMS() { + return SJMS; + } + + public void setSJMS(String SJMS) { + this.SJMS = SJMS; + } + + public BigDecimal getXZB() { + return XZB; + } + + public void setXZB(BigDecimal XZB) { + this.XZB = XZB; + } + + public BigDecimal getYZB() { + return YZB; + } + + public void setYZB(BigDecimal YZB) { + this.YZB = YZB; + } + + public List getIMAGES() { + return IMAGES; + } + + public void setIMAGES(List IMAGES) { + this.IMAGES = IMAGES; + } + + @Override + public String toString() { + return "SendEventFormDto{" + + "SENDTYPE='" + SENDTYPE + '\'' + + ", SENDACTDEFID='" + SENDACTDEFID + '\'' + + ", UID='" + UID + '\'' + + ", SJLYU='" + SJLYU + '\'' + + ", SJDL='" + SJDL + '\'' + + ", SJXL='" + SJXL + '\'' + + ", SJXIL='" + SJXIL + '\'' + + ", SJLY='" + SJLY + '\'' + + ", SSQS='" + SSQS + '\'' + + ", SSJD='" + SSJD + '\'' + + ", SSSQ='" + SSSQ + '\'' + + ", SJDZ='" + SJDZ + '\'' + + ", SJMS='" + SJMS + '\'' + + ", XZB='" + XZB + '\'' + + ", YZB='" + YZB + '\'' + + ", IMAGES=" + IMAGES + + '}'; + } +} \ No newline at end of file diff --git a/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/result/SendEventResultDto.java b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/result/SendEventResultDto.java new file mode 100644 index 0000000..d2b5906 --- /dev/null +++ b/shibei-gird-sdk/src/main/java/com/elink/esua/epdc/gird/shibei/dto/result/SendEventResultDto.java @@ -0,0 +1,87 @@ +package com.elink.esua.epdc.gird.shibei.dto.result; + +import java.io.Serializable; + +/** + * @program: esua-epdc + * @description: 事件上报返回信息 + * @author: wangtong + * @create: 2020-12-16 09:36 + **/ +public class SendEventResultDto implements Serializable { + + private static final long serialVersionUID = 3306121784989678594L; + + /** + * 记录唯一标识 外系统可以通过该标识获取与之对应的信息 + */ + private String p_recId; + /** + * 活动实例唯一标识 + */ + private String p_actId; + + + private String p_recNum; + + /** + * 请求状态码，0为成功，-1为失败 + */ + private String code; + + /** + * 请求消息 + */ + private String message; + + public String getP_recId() { + return p_recId; + } + + public void setP_recId(String p_recId) { + this.p_recId = p_recId; + } + + public String getP_actId() { + return p_actId; + } + + public void setP_actId(String p_actId) { + this.p_actId = p_actId; + } + + public String getP_recNum() { + return p_recNum; + } + + public void setP_recNum(String p_recNum) { + this.p_recNum = p_recNum; + } + + public String getCode() { + return code; + } + + public void setCode(String code) { + this.code = code; + } + + public String getMessage() { + return message; + } + + public void setMessage(String message) { + this.message = message; + } + + @Override + public String toString() { + return "SendEventResultDto{" + + "p_recId='" + p_recId + '\'' + + ", p_actId='" + p_actId + '\'' + + ", p_recNum='" + p_recNum + '\'' + + ", code='" + code + '\'' + + ", message='" + message + '\'' + + '}'; + } +} \ No newline at end of file