【事件上报修改】-【事件上报】-（王童）-2020/12/16

shibei-gird-sdk/pom.xml

@@ -17,6 +17,7 @@
 
     <properties>
         <xstream.version>1.4.11.1</xstream.version>
+        <fastjson.version>1.2.59</fastjson.version>
     </properties>
 
     <dependencies>
@@ -60,6 +61,11 @@
             <groupId>org.apache.httpcomponents</groupId>
             <artifactId>httpcore</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>${fastjson.version}</version>
+        </dependency>
     </dependencies>
 
     <build>

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);
+
     /**
      * 评价事件接口
      *

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<String, Object> map = Maps.newHashMap();

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

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";
 
     /**
      * 评价事件接口

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<String> 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<String> getIMAGES() {
+        return IMAGES;
+    }
+
+    public void setIMAGES(List<String> 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 +
+                '}';
+    }
+}

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 + '\'' +
+                '}';
+    }
+}