cashierdesk / dili-cashier · Files

package com.diligrp.cashier.assistant.pipeline;

import com.diligrp.cashier.assistant.client.SmsChineseHttpClient;
import com.diligrp.cashier.assistant.domain.SmsMessage;
import com.diligrp.cashier.assistant.type.SmsPipelineType;

import java.util.stream.Collectors;

/**
 * 网建短信服务通道
 */
public class SmsChinesePipeline extends SmsPipeline {

    private final SmsChineseHttpClient client;

    public SmsChinesePipeline(int code, String name, String uri, String uid, String secretKey) {
        super(code, name, SmsPipelineType.SMS_CHINESE);
        this.client = new SmsChineseHttpClient(uri, uid, secretKey);
    }

    @Override
    public String sendSmsMessage(SmsMessage message) {
        String telephones = message.getTelephones().stream().collect(Collectors.joining());
        return client.sendSmsMessage(telephones, message.getContent(), message.getSignature());
    }
}