package com.ks.lucky.util.mq.consumer;
|
|
import com.ks.lucky.exception.LuckyActivityAwardException;
|
import com.ks.lucky.exception.LuckyActivityException;
|
import com.ks.lucky.exception.LuckyActivityOpenException;
|
import com.ks.lucky.exception.LuckyMQException;
|
import com.ks.lucky.pojo.DTO.ActivityMQMsg;
|
import com.ks.lucky.remote.service.LuckyActivityOpenService;
|
import com.ks.lucky.service.impl.LuckyActivityManager;
|
import com.ks.lucky.util.mq.CMQConsumeRunner;
|
import com.ks.lucky.util.mq.CMQManager;
|
|
import javax.annotation.Resource;
|
import java.util.Iterator;
|
import java.util.Map;
|
|
public class AcitivtyConsumer implements CMQConsumeRunner {
|
|
@Resource
|
private LuckyActivityManager luckyActivityManager;
|
|
@Resource
|
private LuckyActivityOpenService luckyActivityOpenService;
|
|
private void preOpen(Long activityId, String handler) {
|
|
try {
|
luckyActivityOpenService.preOpenAward(activityId);
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
} catch (LuckyActivityException e) {
|
e.printStackTrace();
|
} catch (LuckyActivityAwardException e) {
|
e.printStackTrace();
|
} catch (LuckyActivityOpenException e) {
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
}
|
}
|
|
|
@Override
|
public void start() {
|
while (true) {
|
Map<String, ActivityMQMsg> map = CMQManager.getInstance().consumeActivityMsg(16);
|
if (map != null) {
|
for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
|
String handler = its.next();
|
ActivityMQMsg msg = map.get(handler);
|
if (msg != null) {
|
switch (msg.getType()) {
|
case ActivityMQMsg.TYPE_EXEC_START:
|
//启动活动
|
try {
|
luckyActivityManager.startUpActivity(msg.getActivityId());
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
} catch (LuckyActivityException e) {
|
e.printStackTrace();
|
} catch (LuckyMQException e) {
|
e.printStackTrace();
|
}
|
|
break;
|
case ActivityMQMsg.TYPE_EXEC_FINSIH:
|
//结束活动
|
try {
|
luckyActivityManager.finishActivity(msg.getActivityId(), false, "定时结束");
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
} catch (LuckyActivityException e) {
|
e.printStackTrace();
|
} catch (LuckyMQException e) {
|
e.printStackTrace();
|
}
|
|
break;
|
|
|
case ActivityMQMsg.TYPE_REACH_MIN_PERSON:
|
try {
|
luckyActivityOpenService.reachMinPerson(msg.getActivityId());
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
} catch (LuckyActivityException e) {
|
e.printStackTrace();
|
}
|
break;
|
|
case ActivityMQMsg.TYPE_REACH_MAX_PERSON:
|
try {
|
luckyActivityManager.finishActivity(msg.getActivityId(), false, "活动达到最大开奖人数");
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
} catch (LuckyActivityException e) {
|
e.printStackTrace();
|
} catch (LuckyMQException e) {
|
e.printStackTrace();
|
}
|
|
|
break;
|
|
case ActivityMQMsg.TYPE_REACH_OPEN_TIME:
|
try {
|
luckyActivityManager.finishActivity(msg.getActivityId(), false, "活动达到开奖时间");
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
} catch (LuckyActivityException e) {
|
e.printStackTrace();
|
} catch (LuckyMQException e) {
|
e.printStackTrace();
|
}
|
break;
|
|
case ActivityMQMsg.TYPE_OPEN_SHOW:
|
try {
|
luckyActivityOpenService.showOpenAward(msg.getActivityId());
|
CMQManager.getInstance().deleteActivityMsg(handler);
|
} catch (LuckyActivityException e) {
|
e.printStackTrace();
|
}
|
break;
|
|
case ActivityMQMsg.TYPE_EXEC_OPEN:
|
preOpen(msg.getActivityId(), handler);
|
break;
|
}
|
}
|
|
|
}
|
|
|
}
|
|
}
|
|
}
|
|
@Override
|
public void destroy() {
|
|
}
|
}
|
