1

src/main/scala/com/hikcreate/data/sync/SyncIgnite1.scala

@@ -50,7 +50,7 @@ object SyncIgnite1 extends Sparking with Logging{
                         val lon = json.getDouble("lon")/1000000
                         val lon = json.getDouble("lon")/1000000
                         val lat = json.getDouble("lat")/1000000
                         val lat = json.getDouble("lat")/1000000
                         val dateTime = DateTime.parse(json.getString("dateTime"),DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss"))//定位时间
                         val dateTime = DateTime.parse(json.getString("dateTime"),DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss"))//定位时间
-                      val time = dateTime.toString("yyyy-MM-dd HH:mm:ss")
+                        val time = dateTime.toString("yyyy-MM-dd HH:mm:ss")
                         val date = dateTime.toLocalDate.toString("yyyy-MM-dd")
                         val date = dateTime.toLocalDate.toString("yyyy-MM-dd")
                         val vehicleInfoOptional = Tools.getVehicleInfo(vehicleNo,vehicleColor)
                         val vehicleInfoOptional = Tools.getVehicleInfo(vehicleNo,vehicleColor)
                         val vehicleProvince = vehicleInfoOptional.map(x=>x.getProvince).getOrElse("无")
                         val vehicleProvince = vehicleInfoOptional.map(x=>x.getProvince).getOrElse("无")

src/main/scala/com/hikcreate/data/util/Tools.scala

@@ -73,10 +73,10 @@ object Tools extends Logging{
       arr.add(lonAndLat)
       arr.add(lonAndLat)
     }
     }
     json.put("locations",arr)
     json.put("locations",arr)
-    val startTime = DateTime.now()
+    //val startTime = DateTime.now()
     val response = Http(Const.areaCodeAndAddressUrl).postData(json.toJSONString).header("content-type","application/json").asString
     val response = Http(Const.areaCodeAndAddressUrl).postData(json.toJSONString).header("content-type","application/json").asString
-    val endTime = DateTime.now()
-    println("http请求时间："+new Duration(startTime,endTime).getMillis)
+    //val endTime = DateTime.now()
+    //println("http请求时间："+new Duration(startTime,endTime).getMillis/1000)
     val body = JSON.parseObject(response.body)
     val body = JSON.parseObject(response.body)
     val items = body.getJSONObject("result").getJSONArray("regeoItems")
     val items = body.getJSONObject("result").getJSONArray("regeoItems")
     (0 until items.size()).map{ index =>
     (0 until items.size()).map{ index =>