|
|
@ -10,7 +10,6 @@ import com.java3y.austin.handler.handler.HandlerHolder;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 发送消息,路由到对应的渠道下发消息
|
|
|
|
* 发送消息,路由到对应的渠道下发消息
|
|
|
|
*
|
|
|
|
*
|
|
|
@ -29,8 +28,8 @@ public class SendMessageAction implements BusinessProcess<TaskInfo> {
|
|
|
|
if (ChannelType.MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel())
|
|
|
|
if (ChannelType.MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel())
|
|
|
|
|| ChannelType.OFFICIAL_ACCOUNT.getCode().equals(taskInfo.getSendChannel())
|
|
|
|
|| ChannelType.OFFICIAL_ACCOUNT.getCode().equals(taskInfo.getSendChannel())
|
|
|
|
|| ChannelType.ALIPAY_MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel())) {
|
|
|
|
|| ChannelType.ALIPAY_MINI_PROGRAM.getCode().equals(taskInfo.getSendChannel())) {
|
|
|
|
for (String receiver : taskInfo.getReceiver()) {
|
|
|
|
|
|
|
|
TaskInfo taskClone = ObjectUtil.cloneByStream(taskInfo);
|
|
|
|
TaskInfo taskClone = ObjectUtil.cloneByStream(taskInfo);
|
|
|
|
|
|
|
|
for (String receiver : taskInfo.getReceiver()) {
|
|
|
|
taskClone.setReceiver(Sets.newHashSet(receiver));
|
|
|
|
taskClone.setReceiver(Sets.newHashSet(receiver));
|
|
|
|
handlerHolder.route(taskInfo.getSendChannel()).doHandler(taskClone);
|
|
|
|
handlerHolder.route(taskInfo.getSendChannel()).doHandler(taskClone);
|
|
|
|
}
|
|
|
|
}
|
|
|
|