From d8a1caf97a24335e10814e84b5134010b532b2b9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 01 十二月 2020 18:28:13 +0800
Subject: [PATCH] 核心Service测试通过
---
service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityServiceImpl.java | 32 +++++++++++++++++++++++++++-----
1 files changed, 27 insertions(+), 5 deletions(-)
diff --git a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityServiceImpl.java b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityServiceImpl.java
index 55f195f..125794f 100644
--- a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityServiceImpl.java
+++ b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityServiceImpl.java
@@ -1,13 +1,11 @@
package com.ks.lucky.service.impl.remote;
import com.ks.app.exception.AppException;
+import com.ks.lib.common.exception.ParamsException;
import com.ks.lucky.exception.LuckyActivityException;
import com.ks.lucky.exception.LuckyMQException;
import com.ks.lucky.mapper.LuckyActivityMapper;
-import com.ks.lucky.pojo.DO.LuckyActivity;
-import com.ks.lucky.pojo.DO.LuckyActivityAwards;
-import com.ks.lucky.pojo.DO.LuckyActivityOpenInfo;
-import com.ks.lucky.pojo.DO.LuckyActivitySponsorInfo;
+import com.ks.lucky.pojo.DO.*;
import com.ks.lucky.query.ActivityDaoQuery;
import com.ks.lucky.remote.service.LuckyActivityService;
import com.ks.lucky.service.LuckyMQService;
@@ -91,7 +89,15 @@
@Validated
@Override
@Transactional(rollbackFor = Exception.class)
- public Long createActivity(LuckyActivity activity) throws LuckyActivityException {
+ public Long createActivity(LuckyActivity activity) throws ParamsException, LuckyActivityException {
+
+ activity.setState(LuckyActivity.STATE_NOT_SUBMIT_VERIFY);
+ activity.setStateRemarks("鏈彁浜ゅ鏍�");
+
+ if (activity.getCreateTime() == null) {
+ activity.setCreateTime(new Date());
+ }
+
luckyActivityMapper.insertSelective(activity);
return activity.getId();
}
@@ -181,6 +187,13 @@
luckyActivityManager.startUpActivity(activityId);
+ //灏濊瘯鍒犻櫎娑堟伅
+ try {
+ LuckyMQ mq = LuckyMQFactory.createStartUpActivity(activity);
+ luckyMQService.removeUnSendMsg(mq.getTaskId());
+ } catch (LuckyMQException e) {
+ e.printStackTrace();
+ }
}
@@ -229,6 +242,15 @@
//璁剧疆娲诲姩涓烘湭鍙戝竷鐘舵��
luckyActivityManager.setState(activityId, LuckyActivity.STATE_NOT_PUBLISH, remarks);
+ //鍒犻櫎鐩稿叧鐨勬秷鎭�
+ LuckyMQ mq = LuckyMQFactory.createStartUpActivity(activity);
+
+ try {
+ luckyMQService.removeUnSendMsg(mq.getTaskId());
+ } catch (LuckyMQException e) {
+ throw new LuckyActivityException(2, e.getMsg());
+ }
+
}
@Override
--
Gitblit v1.8.0