update id type

src/main/scala/com.gmei.up/utils/Content.scala

 package com.gmei.up.utils
 
-case class Content(id: String, index: String, projects: String)
+case class Content(id: Long, index: String, projects: String)

src/main/scala/com.gmei.up/utils/ES.scala

@@ -57,7 +57,7 @@ object ES {
   implicit object ContentHitReader extends HitReader[Content] {
     override def read(hit: Hit): Try[Content] = {
       val source = hit.sourceAsMap
-      Try(Content(source("id").toString, hit.index, source("tags_v3").toString))
+      Try(Content(source("id").toString.toLong, hit.index, source("tags_v3").toString))
     }
   }
 

src/main/scala/com.gmei.up/utils/Redis.scala

@@ -14,8 +14,11 @@ object Redis {
     val key = s"streaming:candidate:${contentType}:device_id:${deviceId}"
     pRc4.del(key)
     contentF.foreach { seq =>
-      pRc4.lpush(key, seq.map(c => c.id))
-      pRc4.expire(key, 60 * 60 * 24 * 15)
+      val ids = seq.map(c => c.id)
+      if (ids.size > 0) {
+        pRc4.lpush(key, ids.head, ids.tail)
+        pRc4.expire(key, 60 * 60 * 24 * 15)
+      }
     }
   }
 }