From 25680e135b5bdc15658622cbfde74bab73cfee77 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 25 十二月 2020 18:54:40 +0800
Subject: [PATCH] 功能完善

---
 service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityOpenServiceImpl.java |    7 +++++--
 1 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityOpenServiceImpl.java b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityOpenServiceImpl.java
index 836a079..c2ee244 100644
--- a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityOpenServiceImpl.java
+++ b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityOpenServiceImpl.java
@@ -14,7 +14,6 @@
 import com.ks.lucky.util.LuckyRunUtil;
 import com.ks.lucky.util.mq.CMQManager;
 import org.apache.dubbo.config.annotation.Service;
-import org.omg.PortableServer.THREAD_POLICY_ID;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
@@ -138,7 +137,11 @@
         //璁剧疆涓鐢ㄦ埛鐘舵�佷负涓
         luckyActivityJoinManager.setActivityDrawnJoinerState(activityId);
 
-        luckyActivityAwardResultManager.setResultShow(activityId);
+        try {
+            luckyActivityAwardResultManager.setResultShow(activityId);
+        } catch (LuckyMQException e) {
+            throw new LuckyActivityException(10, "娣诲姞MQ鍑洪敊");
+        }
     }
 
     @Override

--
Gitblit v1.8.0