1

src/main/scala/com/hikcreate/data/client/IgniteClient.scala

 package com.hikcreate.data.client
 package com.hikcreate.data.client
 
 
 import java.util.concurrent.TimeUnit
 import java.util.concurrent.TimeUnit
+
 import com.hikcreate.ignite.domain.PrimaryKey
 import com.hikcreate.ignite.domain.PrimaryKey
 import com.hikcreate.ignite.domain.alarm.{AttachmentInfo, DailyAlarm, DailyAlarmDeal, DailyAlarmDetail}
 import com.hikcreate.ignite.domain.alarm.{AttachmentInfo, DailyAlarm, DailyAlarmDeal, DailyAlarmDetail}
 import com.hikcreate.ignite.domain.basic._
 import com.hikcreate.ignite.domain.basic._
@@ -9,8 +10,10 @@ import com.hikcreate.ignite.processor._
 import javax.cache.expiry.{CreatedExpiryPolicy, Duration}
 import javax.cache.expiry.{CreatedExpiryPolicy, Duration}
 import org.apache.ignite.binary.BinaryObject
 import org.apache.ignite.binary.BinaryObject
 import org.apache.ignite.cache.CacheMode
 import org.apache.ignite.cache.CacheMode
+import org.apache.ignite.cache.query.SqlFieldsQuery
 import org.apache.ignite.configuration.CacheConfiguration
 import org.apache.ignite.configuration.CacheConfiguration
 import org.apache.ignite.{Ignite, IgniteCache, Ignition}
 import org.apache.ignite.{Ignite, IgniteCache, Ignition}
+
 import scala.collection.JavaConversions.mapAsJavaMap
 import scala.collection.JavaConversions.mapAsJavaMap
 import scala.collection.JavaConverters._
 import scala.collection.JavaConverters._
 /**
 /**
@@ -191,7 +194,7 @@ object IgniteClient {
   lazy val dailyAlarmDealCache: IgniteCache[PrimaryKey, DailyAlarmDeal] = ignite.getOrCreateCache(
   lazy val dailyAlarmDealCache: IgniteCache[PrimaryKey, DailyAlarmDeal] = ignite.getOrCreateCache(
     new CacheConfiguration[PrimaryKey,DailyAlarmDeal]()
     new CacheConfiguration[PrimaryKey,DailyAlarmDeal]()
       .setSqlSchema("Alarm")
       .setSqlSchema("Alarm")
-      .setName("DailyAlarmProcess")
+      .setName("DailyAlarmDeal")
       .setIndexedTypes(classOf[PrimaryKey],classOf[DailyAlarmDeal])
       .setIndexedTypes(classOf[PrimaryKey],classOf[DailyAlarmDeal])
       .setDataRegionName("500MB_Region")
       .setDataRegionName("500MB_Region")
       .setCacheMode(CacheMode.REPLICATED)
       .setCacheMode(CacheMode.REPLICATED)
@@ -238,6 +241,30 @@ object IgniteClient {
     dailyAlarmDealCache.destroy()
     dailyAlarmDealCache.destroy()
     dailyAlarmDetailCache.destroy()*/
     dailyAlarmDetailCache.destroy()*/
 
 
+    /*ignite.destroyCache("DailyAlarmProcess")
+    IgniteClient.dailyAlarmDealCache.clear()
+
+    val value = new DailyAlarmDeal("01","2","","001","2019-10-20 10:00:00",true)
+    IgniteClient.dailyAlarmDealCache.withKeepBinary().putIfAbsent(getBinaryObject(new PrimaryKey("01","2","001")),value)
+
+    val value1 = new DailyAlarmDeal("01","2","","002","2019-10-20 12:00:00",true)
+    IgniteClient.dailyAlarmDealCache.withKeepBinary().putIfAbsent(getBinaryObject(new PrimaryKey("01","2","002")),value1)
+
+    val value2 = new DailyAlarmDeal("01","2","","003","2019-10-20 12:00:00",true)
+    IgniteClient.dailyAlarmDealCache.withKeepBinary().putIfAbsent(getBinaryObject(new PrimaryKey("01","2","003")),value2)*/
+
+    /*val dailyAlarmDetail = new DailyAlarmDetail(
+      "33","08","01","01","2","",
+      "0x00","2019-10-20 10:00:00",100.00,100.00,1L,"CES")
+    IgniteClient.dailyAlarmDetailCache.withKeepBinary().put(getBinaryObject(new PrimaryKey("01","2","2019-10-20 10:00:00")),dailyAlarmDetail)*/
+
+    /*val attachmentInfo = new AttachmentInfo("100","01","2","1","0x00","2019-10-20 10:00:00","1","1","1","/opt/a.txt","")
+    attachmentCache.withKeepBinary().put(getBinaryObject(new PrimaryKey("xxxxxxxxxx")),attachmentInfo)*/
+    //val query = new SqlFieldsQuery("select count(*) from DailyAlarmDeal where isDeal = true")
+
+
+    val me = new DailyMileage("33","08","01","","2019-10-12",200.00,200.00,"",10.00,1L)
+    mileageCache.withKeepBinary().withKeepBinary().put(getBinaryObject(new PrimaryKey("")),me)
     ignite.close()
     ignite.close()
   }
   }
 }
 }

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

@@ -89,7 +89,19 @@ object SyncIgnite extends Sparking with Logging{
           }*/
           }*/
           //车辆定位消息补报
           //车辆定位消息补报
           case tableKey if tableKey == TableKey(Some("0x1200"),Some("0x1203")) =>
           case tableKey if tableKey == TableKey(Some("0x1200"),Some("0x1203")) =>
-
+            Tools.addLocation(json).foreach{ x =>
+              val vehicleNo = x.getString("vehicleNo")
+              val vehicleColor = x.getString("vehicleColor")
+              val lon = x.getDouble("lon")/1000000
+              val lat = x.getDouble("lat")/1000000
+              val code = Tools.getLocationCode(lon,lat)
+              val vehicleInfoOptional = Tools.getVehicleInfo(vehicleNo,vehicleColor)
+              val useNature = vehicleInfoOptional.map(x=>x.getUseNature).getOrElse("无")
+              //累计行驶车辆数
+              val vehicleNumberKey = IgniteClient.getBinaryObject(new PrimaryKey(code._1,code._2,code._3,vehicleNo,vehicleColor))
+              val vehicleNumberValue = new VehicleNumber(code._1,code._2,code._3,useNature)
+              IgniteClient.vehicleNumberCache.withKeepBinary().put(vehicleNumberKey,vehicleNumberValue)
+            }
           //定时上传驾驶员身份识别信息
           //定时上传驾驶员身份识别信息
           case tableKey if tableKey == TableKey(Some("0x1D00"),Some("0x1d02")) =>
           case tableKey if tableKey == TableKey(Some("0x1D00"),Some("0x1d02")) =>
             val vehicleNo = json.getString("vehicleNo")
             val vehicleNo = json.getString("vehicleNo")