commit c667aa20d6f3bd9b8570d9d4b2c3e5ba1a9c7e87
author qiaowei <jov123@163.com> 周五 7月 17 15:21:27 2020 +0800
committer qiaowei <jov123@163.com> 周五 7月 17 15:21:27 2020 +0800
tree 0d4671da754cdc51576284ff382cfd91d506a008
parent 8dbea2800ddd4a200baa12ea757249dd6a273b0e
parent 7fb124c3daddaff7d5ccd75fa8625c8b7f3d1269

Merge branch 'hotfix/1.0.19'

payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt

diff --git a/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt
index c913448..fc5afd8 100644
--- a/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt
+++ b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/impl/kafka_service_impl.kt
@@ -79,10 +79,6 @@
             if (it.lastloginplatform.isNullOrEmpty()) {
                 message.platform = "all"
                 kafkaTemplate.send(topic, msg.msgid, gson.toJson(message))
-//                message.platform="ios"
-//                kafkaTemplate.send(topic, msg.msgid, gson.toJson(message))
-//                message.platform="android"
-//                kafkaTemplate.send(topic, msg.msgid, gson.toJson(message))
             } else {
                 kafkaTemplate.send(topic, msg.msgid, gson.toJson(message))
             }
@@ -109,6 +105,7 @@
                 this.callback = true
                 this.retries = 3
                 this.custom = gson.toJson(extras)
+                this.expiretime = DateUtil.getNewTime(DateUtil.getNow(), 300)
             }
             println(gson.toJson(message))
             kafkaTemplate.send(topic, noticeMsg.msgid, gson.toJson(message))