修改接口

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCalledDto.java

@@ -86,10 +86,10 @@ public class AlertCalledDto extends BaseDto{
     private String rescueGrid;
 
     @ApiModelProperty(value = "坐标x")
-    private String coordinateX;
+    private Double coordinateX;
 
     @ApiModelProperty(value = "坐标y")
-    private String coordinateY;
+    private Double coordinateY;
 
     @ApiModelProperty(value = "更新时间")
     private Date updateTime;

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/entity/AlertCalled.java

@@ -93,10 +93,10 @@ public class AlertCalled extends BaseEntity {
     private String rescueGrid;
 
     @ApiModelProperty(value = "经度")
-    private String coordinateX;
+    private Double coordinateX;
 
     @ApiModelProperty(value = "纬度")
-    private String coordinateY;
+    private Double coordinateY;
 
     @ApiModelProperty(value = "更新时间")
     private Date updateTime;

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/entity/ESAlertCalled.java

@@ -90,10 +90,10 @@ public class ESAlertCalled {
     /**
      * 坐标x
      */
-    private String coordinateX;
+    private Double coordinateX;
     /**
      * 坐标y
      */
-    private String coordinateY;
+    private Double coordinateY;
 
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/AlertCalledServiceImpl.java

 package com.yeejoin.amos.boot.module.jcs.biz.service.impl;
 
+
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -135,7 +136,26 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
 	public AlertCalledObjsDto createAlertCalled(AlertCalledObjsDto alertCalledObjsDto) {
 		try {
    	    // 警情基本信息
+
+
          AlertCalled alertCalled = alertCalledObjsDto.getAlertCalled();
+         if(alertCalled.getAddress()!=null){
+
+			String[]  data= alertCalled.getAddress().split("@address@");
+			 alertCalled.setAddress(data[0]);
+			 if(data[1]!=null&&!"".equals(data[1])){
+				 JSONObject jSONObject = JSON.parseObject(data[1]);
+				 
+				 if(jSONObject.getString("longitude")!=null&&!"".equals(jSONObject.getString("longitude"))) {
+					 alertCalled.setCoordinateX(Double.valueOf(jSONObject.getString("longitude")));
+				 }
+                 if(jSONObject.getString("longitude")!=null&&!"".equals(jSONObject.getString("longitude"))) {
+                	 alertCalled.setCoordinateY(Double.valueOf(jSONObject.getString("latitude")));
+				 }
+				
+				
+			 }
+		 }
            alertCalled.setCallTime(new Date());
  		   if(AlertStageEnums.RG.getValue().equals(alertCalled.getAlertSourceCode())||
 			AlertStageEnums.RG.getValue().equals(alertCalled.getAlertSourceCode())){
@@ -197,6 +217,7 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
          
 		 return alertCalledObjsDto;
 		} catch (Exception e) {
+			e.printStackTrace();
 			throw new RuntimeException("报送失败，系统异常!");
 		}
 	 }
@@ -405,4 +426,11 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
 	public AlertCalled getAlertCalledById(Long id) {
 		return this.getById(id);
 	}
+
+
+
+
+
+
+
 }