update diary service type

src/main/scala/com.gmei.up/Main.scala

@@ -45,9 +45,8 @@ object Main extends LazyLogging {
         "172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092"
       )
 
-      // TODO remove test
       val kafkaConsumer = new FlinkKafkaConsumer[UserInfo](
-        "gm-portrait-update-device-test",
+        "gm-portrait-update-device",
         new UserInfoDeserializationSchema,
         kafkaConsumerProperties
       )
@@ -111,10 +110,11 @@ object Main extends LazyLogging {
           logger.info(s"${user.eventCn} ${deviceId}")
 
           val cost = streamTimeBegin - user.sendTimestamp
-          if (cost > 1000) {
+          if (cost > 1500 && cost < 100000) {
             deviceId == "64695DE0-B926-4188-9C62-D987DC20BEDF"
             DingTalk.send(
               Map(
+                "method" -> "Main.main",
                 "deviceId" -> deviceId,
                 "eventCn" -> user.eventCn,
                 "action" -> user.action,