add try

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

@@ -45,7 +45,6 @@ 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",
         new UserInfoDeserializationSchema,

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

@@ -13,20 +13,23 @@ object DingTalk {
       msg: Map[String, String],
       contentType: String = "msg",
       mobiles: List[String] = List.empty[String]
-  ): Unit = {
-    val url = mkUrl(contentType)
-    val builder = StringBuilder.newBuilder
-    builder.append("StreamingUserPortrait:\n")
+  ): Unit =
+    try {
+      val url = mkUrl(contentType)
+      val builder = StringBuilder.newBuilder
+      builder.append("StreamingUserPortrait:\n")
 
-    for ((k, v) <- msg) {
-      builder.append(k)
-      builder.append(": ")
-      builder.append(v)
-      builder.append("\n")
-    }
+      for ((k, v) <- msg) {
+        builder.append(k)
+        builder.append(": ")
+        builder.append(v)
+        builder.append("\n")
+      }
 
-    makeRequest(builder.toString, contentType)
-  }
+      makeRequest(builder.toString, contentType)
+    } catch {
+      case e: Throwable => e.printStackTrace()
+    }
 
   def makeRequest(msg: String, contentType: String): Unit =
     try {