From: qiaowei <jov123@163.com>
Date: Fri, 17 Jul 2020 07:19:12 +0000 (+0800)
Subject: 消息推送：增加过期时间字段
X-Git-Tag: 1.0.20^2
X-Git-Url: https://source.supwisdom.com/gerrit/gitweb?a=commitdiff_plain;h=7fb124c3daddaff7d5ccd75fa8625c8b7f3d1269;p=epayment%2Ffood_payapi.git

消息推送：增加过期时间字段
---

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 c913448f..fc5afd8b 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 @@ class KafkaSendMsgServiceImpl : KafkaSendMsgService {
             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 @@ class KafkaSendMsgServiceImpl : KafkaSendMsgService {
                 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))