功能完善

admin

2020-12-25 25680e135b5bdc15658622cbfde74bab73cfee77

 service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/AcitivtyConsumer.java

@@ -7,8 +7,9 @@
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 com.ks.lucky.utils.mq.CMQConsumeRunner;
import org.yeshi.utils.mq.JobThreadExecutorServiceImpl;

import javax.annotation.Resource;
import java.util.Iterator;
@@ -39,95 +40,96 @@

    @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();
                                }
        new JobThreadExecutorServiceImpl().run(new Runnable() {
            @Override
            public void run() {
                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_EXEC_FINSIH:
                                    //结束活动
                                    try {
                                        luckyActivityManager.finishActivity(msg.getActivityId(), false, "定时结束");
                                        CMQManager.getInstance().deleteActivityMsg(handler);
                                    } catch (LuckyActivityException e) {
                                        e.printStackTrace();
                                    } catch (LuckyMQException e) {
                                        e.printStackTrace();
                                    }

                                break;
                                    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_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();
                                }
                                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;
                                    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_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_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;
                                case ActivityMQMsg.TYPE_EXEC_OPEN:
                                    preOpen(msg.getActivityId(), handler);
                                    break;
                            }
                        }


                    }


                }


            }
        });

        }

    }