From 678b01185fda7ffd4d0959ca39be9b3633cb8294 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 01 十二月 2020 19:18:26 +0800
Subject: [PATCH] 活动流程优化
---
service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityServiceImpl.java | 49 ++++++++++++++++++++++++++++++++-----------------
1 files changed, 32 insertions(+), 17 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..ff16ad1 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();
}
@@ -115,15 +121,15 @@
*/
private void checkActivityForPublish(LuckyActivity activity) throws LuckyActivityException {
notNull(activity);
- if (activity.getStartTime() == null) {
+ if (activity.getPreStartTime() == null) {
throw new LuckyActivityException(1, "娲诲姩寮�濮嬫椂闂存湭璁剧疆");
}
- if (activity.getStartTime().getTime() < System.currentTimeMillis()) {
+ if (activity.getPreStartTime().getTime() < System.currentTimeMillis()) {
throw new LuckyActivityException(1, "娲诲姩寮�濮嬫椂闂翠笉鑳藉皬浜庡綋鍓嶆椂闂�");
}
- if (activity.getFinishTime() != null && activity.getStartTime().getTime() >= activity.getFinishTime().getTime()) {
+ if (activity.getPreFinishTime() != null && activity.getPreStartTime().getTime() >= activity.getPreFinishTime().getTime()) {
throw new LuckyActivityException(1, "娲诲姩寮�濮嬬粨鏉熸椂闂翠笉鑳藉皬浜庡紑濮嬫椂闂�");
}
@@ -181,6 +187,13 @@
luckyActivityManager.startUpActivity(activityId);
+ //灏濊瘯鍒犻櫎娑堟伅
+ try {
+ LuckyMQ mq = LuckyMQFactory.createStartUpActivity(activity);
+ luckyMQService.removeUnSendMsg(mq.getTaskId());
+ } catch (LuckyMQException e) {
+ e.printStackTrace();
+ }
}
@@ -203,18 +216,11 @@
}
- @Transactional(rollbackFor = Exception.class)
@Override
public void forceFinishActivity(Long activityId, String remarks) throws LuckyActivityException {
- LuckyActivity activity = luckyActivityMapper.selectByPrimaryKeyForUpdate(activityId);
+ LuckyActivity activity = luckyActivityMapper.selectByPrimaryKey(activityId);
notNull(activity);
-
- if (activity.getState() != LuckyActivity.STATE_STARTED) {
- throw new LuckyActivityException(1, "娲诲姩鏈浜庡凡寮�濮嬬姸鎬�");
- }
-
- //璁剧疆娲诲姩澶勪簬寮哄埗缁撴潫鐘舵��
- luckyActivityManager.setState(activityId, LuckyActivity.STATE_FOUCE_FINISH, remarks);
+ luckyActivityManager.finishActivity(activityId, true, remarks);
}
@Transactional(rollbackFor = Exception.class)
@@ -229,6 +235,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