commit 8ebf9025fc014fc1cbc595292d4d119b263e79aa
author qiaowei <jov123@163.com> 周五 7月 17 15:22:20 2020 +0800
committer qiaowei <jov123@163.com> 周五 7月 17 15:22:20 2020 +0800
tree e5dd2ac5dc3529a94b838db69cb8d881628de514
parent 590939b2d8ceddc2e1aca51ea62d1634578ef9dc
parent c667aa20d6f3bd9b8570d9d4b2c3e5ba1a9c7e87

Merge tag 'tag/1.0.19' into develop

消息推送过期时间问题

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))