package com.ks.push;
|
|
import com.google.gson.Gson;
|
import com.ks.push.exception.BPushTaskException;
|
import com.ks.push.manager.rabbitmq.RabbitmqSenderUtil;
|
import com.ks.push.pojo.DO.BPushFilter;
|
import com.ks.push.pojo.DO.BPushMessage;
|
import com.ks.push.pojo.DO.BPushTask;
|
import com.ks.push.service.BPushTaskService;
|
import org.junit.jupiter.api.Test;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.boot.test.context.SpringBootTest;
|
import org.springframework.test.context.ContextConfiguration;
|
|
import javax.annotation.Resource;
|
import java.util.Arrays;
|
|
@SpringBootTest(classes = PushApplication.class)
|
@ContextConfiguration
|
public class TaskTest {
|
|
@Resource
|
private BPushTaskService bPushTaskService;
|
|
@Test
|
public void addTask() throws BPushTaskException {
|
BPushTask task = new BPushTask();
|
BPushMessage message = new BPushMessage();
|
message.setTitle("测试标题");
|
message.setContent("测试内容");
|
message.setAndroidActivity("com.tejia.lijin.app.ui.PushOpenClickActivity");
|
message.setAndroidHostPath("com.huawei.codelabpush/deeplink");
|
message.setAndroidActivityScheme("tejiapush");
|
|
BPushFilter filter = new BPushFilter();
|
filter.setUidList(Arrays.asList(new String[]{"123456"}));
|
task.setMessage(message);
|
task.setAppCode("tejia");
|
task.setFilter(filter);
|
bPushTaskService.createTask(task);
|
}
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
|
@Test
|
public void testRabbitMq(){
|
RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, "test", "测试内容");
|
|
}
|
|
}
|
