外网部署参数修改

admin

2021-01-18 d6df4ca797ee1c6ce8fa78768f5425f187734bd9

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

@@ -22,14 +22,15 @@
    private LuckyActivityOpenService luckyActivityOpenService;

    private void preOpen(Long activityId, String handler) {

        try {
            luckyActivityOpenService.preOpenAward(activityId);
            CMQManager.getInstance().deleteActivityMsg(handler);
        } catch (LuckyActivityException e) {
            e.printStackTrace();
            LoggerUtil.activityLogger.error("预开奖异常:activityId-{}", activityId, e);
        } catch (LuckyActivityAwardException e) {
            e.printStackTrace();
            LoggerUtil.activityLogger.error("预开奖异常:activityId-{}", activityId, e);
        } catch (LuckyActivityOpenException e) {
            CMQManager.getInstance().deleteActivityMsg(handler);
        }
@@ -49,7 +50,7 @@
                        if (msg != null) {
                            switch (msg.getType()) {
                                case ActivityMQMsg.TYPE_EXEC_START:
                                    LoggerUtil.activityLogger.info("执行启动活动:"+msg.getActivityId());
                                    LoggerUtil.activityLogger.info("执行启动活动:activityId-{}", msg.getActivityId());
                                    //启动活动
                                    try {
                                        luckyActivityManager.startUpActivity(msg.getActivityId());
@@ -63,70 +64,79 @@

                                    break;
                                case ActivityMQMsg.TYPE_EXEC_FINSIH:
                                    LoggerUtil.activityLogger.info("执行结束活动:"+msg.getActivityId());
                                    LoggerUtil.activityLogger.info("执行结束活动:activityId-{}", msg.getActivityId());
                                    //结束活动
                                    try {
                                        luckyActivityManager.finishActivity(msg.getActivityId(), false, "定时结束");
                                        CMQManager.getInstance().deleteActivityMsg(handler);
                                    } catch (LuckyActivityException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("活动成功结束异常:activityId-{}", msg.getActivityId(), e);
                                    } catch (LuckyMQException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("活动成功结束异常:activityId-{}", msg.getActivityId(), e);
                                    }

                                    break;


                                case ActivityMQMsg.TYPE_REACH_MIN_PERSON:
                                    LoggerUtil.activityLogger.info("参与人数到达最低开奖人数:"+msg.getActivityId());
                                    LoggerUtil.activityLogger.info("参与人数到达最低开奖人数:activityId-{}", msg.getActivityId());
                                    try {
                                        luckyActivityOpenService.reachMinPerson(msg.getActivityId());
                                        CMQManager.getInstance().deleteActivityMsg(handler);
                                    } catch (LuckyActivityException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("参与人数到达最低开奖人数异常:activityId-{}", msg.getActivityId(), e);
                                    }
                                    break;

                                case ActivityMQMsg.TYPE_REACH_MAX_PERSON:
                                    LoggerUtil.activityLogger.info("参与人数到达最大参与人数:"+msg.getActivityId());
                                    LoggerUtil.activityLogger.info("参与人数到达最大参与人数:activityId-{}", msg.getActivityId());
                                    try {
                                        luckyActivityManager.finishActivity(msg.getActivityId(), false, "活动达到最大开奖人数");
                                        CMQManager.getInstance().deleteActivityMsg(handler);
                                    } catch (LuckyActivityException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("活动达到最大开奖人数，活动结束异常:activityId-{}", msg.getActivityId(), e);
                                    } catch (LuckyMQException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("活动达到最大开奖人数，活动结束异常:activityId-{}", msg.getActivityId(), e);
                                    }


                                    break;

                                case ActivityMQMsg.TYPE_REACH_OPEN_TIME:
                                    LoggerUtil.activityLogger.info("活动达到开奖时间:"+msg.getActivityId());
                                    LoggerUtil.activityLogger.info("活动达到开奖时间:activityId-{}", msg.getActivityId());
                                    try {
                                        luckyActivityManager.finishActivity(msg.getActivityId(), false, "活动达到开奖时间");
                                        CMQManager.getInstance().deleteActivityMsg(handler);
                                    } catch (LuckyActivityException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("活动达到开奖时间，活动结束异常:activityId-{}", msg.getActivityId(), e);
                                    } catch (LuckyMQException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("活动达到开奖时间，活动结束异常:activityId-{}", msg.getActivityId(), e);
                                    }
                                    break;

                                case ActivityMQMsg.TYPE_OPEN_SHOW:
                                    LoggerUtil.activityLogger.info("显示开奖结果:"+msg.getActivityId());
                                    LoggerUtil.activityLogger.info("显示开奖结果:activityId-{}", msg.getActivityId());
                                    try {
                                        luckyActivityOpenService.showOpenAward(msg.getActivityId());
                                        CMQManager.getInstance().deleteActivityMsg(handler);
                                    } catch (LuckyActivityException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("显示开奖结果异常:activityId-{}", msg.getActivityId(), e);
                                    } catch (LuckyActivityOpenInfoException e) {
                                        e.printStackTrace();
                                        LoggerUtil.activityLogger.error("显示开奖结果异常:activityId-{}", msg.getActivityId(), e);
                                    }
                                    break;

                                case ActivityMQMsg.TYPE_EXEC_OPEN:
                                    LoggerUtil.activityLogger.info("执行预开奖:"+msg.getActivityId());
                                    LoggerUtil.activityLogger.info("执行预开奖:activityId-{}", msg.getActivityId());
                                    preOpen(msg.getActivityId(), handler);
                                    break;
                            }