|
|
@@ -2,11 +2,11 @@ package cn.com.taiji.ias.manager.qtkPush; |
|
|
|
|
|
|
|
|
|
|
|
import cn.com.taiji.common.manager.net.http.ServiceHandleException; |
|
|
|
import cn.com.taiji.core.entity.msgw.MegwUserMessage; |
|
|
|
import cn.com.taiji.core.entity.msgw.MsgwUserMessage; |
|
|
|
import cn.com.taiji.core.model.comm.protocol.ias.message.QtkPushSendMessageRequest; |
|
|
|
import cn.com.taiji.core.model.comm.protocol.ias.message.QtkPushSendMessageResponse; |
|
|
|
import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError; |
|
|
|
import cn.com.taiji.core.repo.jpa.msgw.MegwUserMessageRepo; |
|
|
|
import cn.com.taiji.core.repo.jpa.msgw.MsgwUserMessageRepo; |
|
|
|
import cn.com.taiji.ias.manager.tools.ThreadPoolTools; |
|
|
|
import org.slf4j.Logger; |
|
|
|
import org.slf4j.LoggerFactory; |
|
|
@@ -59,7 +59,7 @@ public class QtkPushGetSendManagerImpl implements QtkPushGetSendManager { |
|
|
|
private static final Logger logger = LoggerFactory.getLogger(QtkPushGetSendManagerImpl.class); |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private MegwUserMessageRepo userMessageRepo; |
|
|
|
private MsgwUserMessageRepo userMessageRepo; |
|
|
|
@Autowired |
|
|
|
private ThreadPoolTools threadPoolTools; |
|
|
|
|
|
|
@@ -76,7 +76,7 @@ public class QtkPushGetSendManagerImpl implements QtkPushGetSendManager { |
|
|
|
threadPoolTools.execute(() -> { |
|
|
|
try { |
|
|
|
//生成待发送消息 |
|
|
|
MegwUserMessage message = new MegwUserMessage(); |
|
|
|
MsgwUserMessage message = new MsgwUserMessage(); |
|
|
|
message.setOpenId(request.getOpenId()); |
|
|
|
message.setTitle(request.getTitle()); |
|
|
|
message.setMessage(request.getMessageContent()); |