Merge branch 'dev-limitqueue-6.7' into test6.7

zhaoqing
Commit d249984382933549e19882e4959066b1ca2dae63 2 parents 5c6cc7fe 530abf8e
Showing 1 changed file with 5 additions and 2 deletions
queue/src/main/java/com/yoho/activity/queue/service/impl/DrawlineUserQueueServiceImpl.java
--- a/queue/src/main/java/com/yoho/activity/queue/service/impl/DrawlineUserQueueServiceImpl.java
View file @d249984
+++ b/queue/src/main/java/com/yoho/activity/queue/service/impl/DrawlineUserQueueServiceImpl.java
View file @d249984
@@ -11,6 +11,7 @@ import com.netflix.config.DynamicLongProperty;
 import com.netflix.config.DynamicPropertyFactory;
 import com.yoho.activity.dal.ProductLimitUserHelpMapper;
 import com.yoho.activity.dal.model.LimitProductHelpUser;
+import com.yoho.message.sdk.common.model.SendMessageRspBo;
 import com.yoho.message.sdk.service.ISendLimitCodeMessage;
 import com.yoho.service.model.activity.drawline.response.LimitProductHelpUserRespBO;
 import org.apache.commons.collections.CollectionUtils;
@@ -186,9 +187,11 @@ public class DrawlineUserQueueServiceImpl implements IDrawlineUserQueueService {
 		//先判断是否是首次，根据活动ID查询是否只有一条数据
         Integer queueCount = drawlineUserQueueDAO.selectHelpUserCount(activityId, uid, null);
 		if (queueCount == 1){
-			logger.info("addDrawlineUserQueue: push message param : uid is{}, productName is{}, limitProductCode is{}",uid, productName, limitProductCode);
 			try {
-				iSendLimitCodeMessage.queueSuccess(String.valueOf(uid), 4, productName, limitProductCode);
+				logger.info("addDrawlineUserQueue: push message param : uid is {}, productName is {}, limitProductCode is {}",uid, productName, limitProductCode);
+				SendMessageRspBo responseMessage = iSendLimitCodeMessage.queueSuccess(String.valueOf(uid), 4, productName, limitProductCode);
+				logger.info("addDrawlineUserQueue: push message success, result is {}",responseMessage);
+				logger.info("addDrawlineUserQueue: push message success, code is {}, message is {}",responseMessage.getCode(),responseMessage.getMessage());
 			}catch (Exception e){
 				logger.error("推送信息失败！", e);
 			}