package com.iplatform.base.config;
|
|
import com.iplatform.base.PushCacheProvider;
|
import com.iplatform.base.push.DefaultPushListener;
|
import com.iplatform.base.push.DefaultPushManager;
|
import com.iplatform.base.push.MockSmsPush;
|
import com.iplatform.base.push.SystemPush;
|
import com.iplatform.base.service.PushServiceImpl;
|
import com.iplatform.base.util.NotificationUtils;
|
import com.iplatform.core.PlatformConfiguration;
|
import com.walker.push.PushManager;
|
import com.walker.push.PushStatusListener;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Configuration
|
public class PushConfig extends PlatformConfiguration {
|
|
/**
|
* 推送参数配置
|
* @return
|
*/
|
@Bean
|
public PushProperties pushProperties(){
|
return new PushProperties();
|
}
|
|
/**
|
* 配置推送管理器对象
|
* @return
|
* @date 2023-04-21
|
*/
|
@Bean
|
public PushManager pushManager(ThreadPoolTaskExecutor threadPoolTaskExecutor
|
, PushProperties pushProperties, PushStatusListener pushStatusListener){
|
DefaultPushManager pushManager = new DefaultPushManager();
|
pushManager.setSmsId(pushProperties.getSmsPushName());
|
pushManager.setSmsTemplateCode(pushProperties.getSmsTemplateCode());
|
|
Object[] data = NotificationUtils.acquireMessagePushRules(pushProperties.getMessageType());
|
pushManager.setMessageParallel((Boolean) data[0]);
|
|
String[] indexList = (String[])data[1];
|
if(indexList == null || indexList.length == 0){
|
throw new IllegalStateException("推送（普通消息）配置规则不存在!");
|
}
|
|
List<String> channelNameList = new ArrayList<>(4);
|
for(String index: indexList){
|
channelNameList.add(index);
|
}
|
pushManager.setMessageChannelNames(channelNameList);
|
pushManager.setThreadPoolTaskExecutor(threadPoolTaskExecutor);
|
pushManager.setAsyncListener(pushStatusListener);
|
|
//
|
pushManager.setMailFrom(pushProperties.getMailFrom());
|
|
return pushManager;
|
}
|
|
/* *//**
|
* 配置默认短信推送实现（一个通道可以有多个实现）
|
* @return
|
* @date 2023-04-24
|
*//*
|
@Bean
|
public Pushable mailPush(PushManager pushManager, PushProperties pushProperties, UserCacheProvider userCacheProvider){
|
DefaultMailPush mailPush = new DefaultMailPush();
|
// mailPush.setMailServerHost("smtp.126.com");
|
// mailPush.setMailServerPort("25");
|
// mailPush.setFromAddress("hnzzzhsl@126.com");
|
// mailPush.setFromPassword("UWBUXNLFJEANRCXX");
|
mailPush.setMailServerHost(pushProperties.getMailServer());
|
mailPush.setMailServerPort("25");
|
mailPush.setFromAddress(pushProperties.getMailFrom());
|
mailPush.setFromPassword(pushProperties.getMailPassword());
|
mailPush.setUserCacheProvider(userCacheProvider);
|
mailPush.startup();
|
|
pushManager.register(mailPush);
|
return mailPush;
|
}*/
|
|
/**
|
* 配置推送监听器，仅异步推送者需要使用
|
* @return
|
* @date 2023-04-24
|
*/
|
@Bean
|
public PushStatusListener pushStatusListener(PushCacheProvider pushCacheProvider, PushServiceImpl pushService){
|
DefaultPushListener pushListener = new DefaultPushListener();
|
pushListener.setPushService(pushService);
|
pushListener.setPushCacheProvider(pushCacheProvider);
|
return pushListener;
|
}
|
|
/**
|
* 注册'模拟短信'推送者
|
* @param pushManager
|
* @return
|
* @date 2023-04-24
|
*/
|
@Bean
|
public MockSmsPush mockSmsPush(PushManager pushManager){
|
MockSmsPush mockSmsPush = new MockSmsPush();
|
mockSmsPush.startup();
|
pushManager.register(mockSmsPush);
|
return mockSmsPush;
|
}
|
|
/**
|
* 注册默认的'系统消息'推送者，其实并不推送。
|
* @param pushManager
|
* @return
|
* @date 2023-04-24
|
*/
|
@Bean
|
public SystemPush systemPush(PushManager pushManager){
|
SystemPush systemPush = new SystemPush();
|
systemPush.startup();
|
pushManager.register(systemPush);
|
return systemPush;
|
}
|
}
|
