Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
短信宝
# -*- encoding: utf-8 -*-
require 'digest/md5'
require 'nestful'
class Smsbao
def initialize(login, passwd)
@login = login
@passwd = Digest::MD5.hexdigest(passwd.to_s)
end
# 发送短信
def send(mobile, content, force = false)
payment = price(content.size, default_limit[:content]) # 计费条数
if mobile.is_a?(Array) # 群发
# 中断发送,禁止批量发送长短信
if payment > 1
message = "警告:此内容群发,预计产生 #{mobile.count*payment}条 费用!"
if force
puts message
else
return { success: false, message: message }
end
end
# 粗略检测,手机号
mobile = check_mobile(mobile)
# 预计结果
result = { pending: mobile[:approved], sent: [], fail: mobile[:rejected], fee: 0 }
mobile = result[:pending]
total = mobile.count
if total > 0
mobile.each_slice( default_limit[:mobile] ).to_a.each do |batch| # 最大支持300为一组进行发送。
response = client('send', { m: batch.join(','), c: content })
stat = status(response)
if stat[:success]
# 状态转换
result[:sent] += batch
result[:pending] -= batch
# 计费
result[:fee] += (batch.count * payment)
# 进度
puts "已消费:#{result[:fee]}条;"
progress(total, result[:sent].count)
else
return stat.merge(result) # 中断发送,返回错误
end
end
return { success: true, message: '短信队列成功。' }.merge(result) # 成功
else
return { success: false, message: '无效的手机号!' }.merge(result) # 验证错误
end
else # 单发
mobile = mobile.strip.to_i
if check?(mobile)
response = client('send', { m: mobile, c: content })
stat = status(response)
return stat.merge({fee: payment}) # 返回发送状态
else
return { success: false, message: '无效的手机号!' } # 验证错误
end
end
end
# 查询余额
def balance
response = client('balance')
return status(response)
end
private
# 发送进度
def progress(total, sent, rate=2)
sent = 1 if sent < 1
sent = ( sent/total.to_f * 100).round
sent_s = case
when sent < 10
" #{sent}% "
when sent < 100
" #{sent}% "
else
" #{sent}% "
end
sent_s = "\033[37m#{sent_s}\033[33m"
total = (100.to_f / rate).round
sent = (sent.to_f / rate).round
division = (total.to_f / 2).round
bar = if sent > division
foot = total - sent
head = sent - division
head = division if head > division
if foot < 1
sent += 1
foot = 0
end
'#' * division + sent_s + '#' * head + ' ' * foot
else
'#' * sent + ' ' * (division - sent) + sent_s + ' ' * ((total % 2) > 0 ? division-1 : division) # 支持奇数
end
puts "\033[33m[#{bar}]\e[0m"
end
# 内容被拆分的条数
def price(total, size)
count = (total / size)
count += 1 if (total % size) > 0
return count
end
def check_mobile(mobile_arr)
approved = []
rejected = []
mobile_arr.each do |mobile|
mobile = mobile.strip.to_i
if check?(mobile)
approved << mobile
else
rejected << mobile
end
end
return { approved: approved.uniq, rejected: rejected.uniq }
end
def check?(mobile)
mobile = mobile.to_s
return mobile.size == 11 && mobile[0] == '1'
end
def default_limit # 默认限制
{ content: 64, mobile: 300 }
end
def status(resp)
arr = resp.split("\n")
code = arr[0]
message = case code
when '0'
if arr[1].nil?
'短信发送成功'
else
vals = arr[1].split(",")
{sent: vals[0].to_i, balance: vals[1].to_i}
end
when '30'
'密码错误'
when '40'
'账号不存在'
when '41'
'余额不足'
when '42'
'帐号过期'
when '43'
'IP地址限制'
when '50'
'内容含有敏感词'
when '51'
'手机号码不正确'
end
{ success: (code == '0'), message: message }
end
def gw_url(method)
'http://api.smsbao.com' + method_path[method.to_sym]
end
def method_path
{ send: '/sms', balance: '/query' }
end
def client(method, params={})
Nestful.get gw_url(method), params: { u: @login, p: @passwd }.merge(params)
end
end
@mimosz

This comment has been minimized.

Copy link
Owner Author

mimosz commented Oct 9, 2012

增加了手机号粗略过滤~

@mimosz

This comment has been minimized.

Copy link
Owner Author

mimosz commented Oct 12, 2012

新增,通过CSV群发短信~
https://gist.github.com/3871343

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.