核心Service测试通过

admin

2020-12-01 d8a1caf97a24335e10814e84b5134010b532b2b9

 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