czg_team/p_ysk
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

进一步完成

Browse Source
This commit is contained in:
ASUS
2025-10-15 19:30:38 +08:00
parent c957a1ba2b
commit 348a990f88
13 changed files with 547 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/command/ApplySmsTemp.php
View File

@@ -5,6 +5,7 @@ namespace app\command;
use app\common\model\MqLog;
use app\common\model\OrderInfo;
use app\common\model\RabbitMqConfig;
use app\model\ShopInfo;
use ba\Random;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use support\think\Db;
@@ -37,6 +38,13 @@ class ApplySmsTemp extends Command
*/
protected function execute(InputInterface $input, OutputInterface $output): int
{
$str = '亲爱的${用户昵称}您好，${店铺名称}祝您生日快乐！感谢您一直的陪伴。为您准备了${数量}张超值优惠券，已放入账户，愿我们的礼物能为您增添一份喜悦。拒收请回复R';
$templateContent_arr = ShopInfo::handleSmsTemplates($str);
$a = '{"店铺名称":"火锅店","用户昵称":"嘿嘿","数量":"123"}';
p(replace_json_keys($a, json_encode($templateContent_arr, 256)));
$t_str = replace_placeholder_keys($str, $templateContent_arr);
p($templateContent_arr, $t_str);
$host = RabbitMqConfig::$host;
$port = RabbitMqConfig::$port;
@@ -59,7 +67,7 @@ class ApplySmsTemp extends Command
);
$rabbit_channel = $connection->channel();
$rabbit_channel->queue_declare($queue, false, true, false, false, false, [
'x-message-ttl' => ['I', 180000]
// 'x-message-ttl' => ['I', 180000]
]);
$callback = function ($msg) use ($queue){

2
app/command/BirthdayGiftSms.php
View File

@@ -59,7 +59,7 @@ class BirthdayGiftSms extends Command
);
$rabbit_channel = $connection->channel();
$rabbit_channel->queue_declare($queue, false, true, false, false, false, [
'x-message-ttl' => ['I', 180000]
// 'x-message-ttl' => ['I', 180000]
]);
$callback = function ($msg) use ($queue){

70
app/command/QuerySmsStatus.php
View File

@@ -3,6 +3,7 @@
namespace app\command;
use app\model\AlibabaSms;
use app\model\ShopInfo;
use support\Log;
use support\think\Db;
use Symfony\Component\Console\Command\Command;
@@ -28,44 +29,63 @@ class QuerySmsStatus extends Command
}
/**
* 查询模版审核状态 1小时执行一次
* 查询短信发送状态
* @param InputInterface $input
* @param OutputInterface $output
* @return int
*/
protected function execute(InputInterface $input, OutputInterface $output): int
{
$list = Db::table('sms_shop_template')->where(['status' => 1])->select()->toArray();
Log::info('短信模版审核查询开始->' . json_encode($list));
if($list) {
foreach ($list as $k => $value) {
// 生日有礼
$bir_list = Db::table('mk_birthday_gift_record')->where(['status' => 'await_push'])->select()->toArray();
if($bir_list) {
Log::info('生日有礼短信发送状态查询开始->' . json_encode($bir_list));
foreach ($bir_list as $k => $value) {
$data = [
'TemplateCode' => $value['template_code']
'TemplateCode' => $value['template_code'],
'BizId' => $value['biz_id'],
'SendDate' => date('Ymd'),
'PageSize' => 1,
'CurrentPage' => 20,
];
$res = AlibabaSms::GetSmsTemplate($data);
if($res['Code'] == 'OK') {
$msg = '';
if($res['TemplateStatus'] == 0) {
$status = 1;
}elseif ($res['TemplateStatus'] == 1) {
$status = 2;
}elseif ($res['TemplateStatus'] == 2) {
$status = -1;
$msg = $res['AuditInfo']['RejectInfo'];
}elseif ($res['TemplateStatus'] == 10) {
$status = -1;
$msg = '取消审核';
$res = AlibabaSms::QuerySendDetails($data);
try {
Db::startTrans();
if($res['Code'] == 'OK') {
$push_resp = $res['ErrCode'];
if($res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['SendStatus'] == 3) {
$push_status = 'success';
// 扣掉余额
ShopInfo::moeny(config('cons.sms_price'), $value['main_shop_id'], 2, );
}elseif ($res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['SendStatus'] == 2) {
$push_status = 'failed';
}elseif ($res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['SendStatus'] == 1) {
$push_status = 'await_push';
}
$update_data = [
'status' => $push_status,
'push_resp' => $push_resp,
];
$update_status = Db::table('mk_birthday_gift_record')->where(['id' => $value['id']])->update($update_data);
Db::commit();
Log::info('短信查询完毕数据库更新结果---》[ID]' . $value['id'] . '更新结果-->' . $update_status . '-->更新数据 . ' . json_encode($update_data));
}
$update_data = [
'status' => $status,
'fail_msg' => $msg?:$msg,
];
$update_status = Db::table('sms_shop_template')->where(['id' => $value['id']])->update($update_data);
Log::info('模版查询完毕数据库更新结果---》[ID]' . $value['id'] . '更新结果-->' . $update_status . '-->更新数据 . ' . json_encode($update_data));
}catch (\Exception $e) {
Db::rollback();
Log::info('短信查询错误---》[ID]' . $e->getMessage());
}
sleep(1);
}
}
// 活动开始
return self::SUCCESS;
}

72
app/command/QuerySmsTempStatus.php Normal file
View File

@@ -0,0 +1,72 @@
<?php
namespace app\command;
use app\model\AlibabaSms;
use support\Log;
use support\think\Db;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Output\OutputInterface;
use ZipArchive;
// 查询短信模版审核状态
class QuerySmsTempStatus extends Command
{
protected static $defaultName = 'querysmstempstatus';
protected static $defaultDescription = 'querysmstempstatus';
/**
* @return void
*/
protected function configure()
{
$this->addArgument('name', InputArgument::OPTIONAL, 'Name description');
}
/**
* 查询模版审核状态 1小时执行一次
* @param InputInterface $input
* @param OutputInterface $output
* @return int
*/
protected function execute(InputInterface $input, OutputInterface $output): int
{
$list = Db::table('sms_shop_template')->where(['status' => 1])->select()->toArray();
Log::info('短信模版审核查询开始->' . json_encode($list));
if($list) {
foreach ($list as $k => $value) {
$data = [
'TemplateCode' => $value['template_code']
];
$res = AlibabaSms::GetSmsTemplate($data);
if($res['Code'] == 'OK') {
$msg = '';
if($res['TemplateStatus'] == 0) {
$status = 1;
}elseif ($res['TemplateStatus'] == 1) {
$status = 2;
}elseif ($res['TemplateStatus'] == 2) {
$status = -1;
$msg = $res['AuditInfo']['RejectInfo'];
}elseif ($res['TemplateStatus'] == 10) {
$status = -1;
$msg = '取消审核';
}
$update_data = [
'status' => $status,
'fail_msg' => $msg?:$msg,
];
$update_status = Db::table('sms_shop_template')->where(['id' => $value['id']])->update($update_data);
Log::info('模版查询完毕数据库更新结果---》[ID]' . $value['id'] . '更新结果-->' . $update_status . '-->更新数据 . ' . json_encode($update_data));
}
sleep(1);
}
}
return self::SUCCESS;
}
}

2
app/command/SendMarkSms.php
View File

@@ -59,7 +59,7 @@ class SendMarkSms extends Command
);
$rabbit_channel = $connection->channel();
$rabbit_channel->queue_declare($queue, false, true, false, false, false, [
'x-message-ttl' => ['I', 180000]
// 'x-message-ttl' => ['I', 180000]
]);
$callback = function ($msg) use ($queue){

2
app/command/SendWechatTemp.php
View File

@@ -59,7 +59,7 @@ class SendWechatTemp extends Command
);
$rabbit_channel = $connection->channel();
$rabbit_channel->queue_declare($queue, false, true, false, false, false, [
'x-message-ttl' => ['I', 180000]
// 'x-message-ttl' => ['I', 180000]
]);
$callback = function ($msg) use ($queue){

80
app/functions.php
View File

@@ -95,4 +95,82 @@ if(!function_exists('http_post')) {
}
return $response;
}
}
}
if (!function_exists('curl_post')) {
function curl_post($url, $params, $op)
{
$postData = json_encode($params, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
if(!empty($params['shopId'])) {
Log::write('耗材预警提交json' . $postData);
}
$opts = array(
CURLOPT_TIMEOUT => 30,
CURLOPT_RETURNTRANSFER => 1,
CURLOPT_SSL_VERIFYPEER => false,
CURLOPT_SSL_VERIFYHOST => false,
CURLOPT_ENCODING => 'gzip',
);
$opts[CURLOPT_URL] = $url;
$opts[CURLOPT_POST] = 1;
$opts[CURLOPT_POSTFIELDS] = $postData;
$opts[CURLOPT_HTTPHEADER] = $op;
$ch = curl_init();
curl_setopt_array($ch, $opts);
$responsedata = curl_exec($ch);
$error = curl_error($ch);
curl_close($ch);
return $responsedata;
}
}
// 处理${}字符串
if (!function_exists('handldollerstr')) {
function handldollerstr($str)
{
$pattern = '/\$\{(.*?)\}/';
preg_match_all($pattern, $str, $matches);
$result = $matches[1];
return $result;
}
}
if (!function_exists('replace_placeholder_keys')) {
function replace_placeholder_keys($str, $replaceArray)
{
preg_match_all('/\$\{.*?\}/', $str, $matches);
$originalPlaceholders = $matches[0]; // 结果: ['${用户昵称}', '${店铺名称}', ...]
$arrayKeys = array_keys($replaceArray); // 结果: ['username', 'shopname', 'time', 'item1', 'item2']
$replacePairs = [];
foreach ($originalPlaceholders as $index => $placeholder) {
if (isset($arrayKeys[$index])) {
// 关键：明确拼接 ${键} 结构
$replacePairs[$placeholder] = '${' . $arrayKeys[$index] . '}';
}
}
$newStr = strtr($str, $replacePairs);
return $newStr;
}
}
if (!function_exists('replace_json_keys')) {
function replace_json_keys($originalJson, $mapJson)
{
$originalData = json_decode($originalJson, true);
$mapData = json_decode($mapJson, true);
$reverseMap = array_flip($mapData);
$newData = [];
foreach ($originalData as $oldKey => $value) {
// 如果原始键在映射中存在，则替换为对应的新键；否则保留原键
$newKey = $reverseMap[$oldKey] ?? $oldKey;
$newData[$newKey] = $value;
}
$newJson = json_encode($newData, JSON_UNESCAPED_UNICODE);
return $newJson;
}
}

29
app/model/AlibabaSms.php
View File

@@ -13,6 +13,7 @@ use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\CreateSmsTemplateRequest;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\GetSmsTemplateRequest;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\UpdateSmsTemplateRequest;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\DeleteSmsTemplateRequest;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\QuerySendDetailsRequest;
use Darabonba\OpenApi\Models\Config;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\SendSmsRequest;
use AlibabaCloud\Tea\Utils\Utils;
@@ -51,11 +52,7 @@ class AlibabaSms extends Model
// 复制代码运行请自行打印 API 的返回值
$res = $client->sendSmsWithOptions($sendSmsRequest, $runtime);
Log::info('发送短信接口返回---》' . json_encode($res->body->toArray()));
if($res->body->code == 'OK') {
return true;
}else {
return false;
}
return $res->body->toArray();
}
catch (Exception $error) {
if (!($error instanceof TeaError)) {
@@ -159,18 +156,26 @@ class AlibabaSms extends Model
}
/**
* 查询短信发送结果
*/
public function QuerySendDetails($data)
{
$client = self::createClient();
$querySendDetailsRequest = new QuerySendDetailsRequest($data);
$runtime = new RuntimeOptions([]);
try {
$res = $client->querySendDetailsWithOptions($querySendDetailsRequest, $runtime);
Log::info('查询短信发送结果接口返回---》' . json_encode($res->body->toArray()));
return $res->body->toArray();
}
catch (Exception $error) {
if (!($error instanceof TeaError)) {
$error = new TeaError([], $error->getMessage(), $error->getCode(), $error);
}
Utils::assertAsString($error->message);
Log::info('查询短信发送结果接口错误--' . $error->message);
}
}
}

191
app/model/ShopInfo.php Normal file
View File

@@ -0,0 +1,191 @@
<?php
namespace app\model;
use support\Log;
use support\think\Db;
class ShopInfo
{
public static function moeny($money, $shop_id, $type = 1)
{
$shop_money = Db::table('sms_shop_money')->where(['shop_id' => $shop_id])->find();
if($shop_money) {
$db = Db::table('sms_shop_money')->where(['shop_id' => $shop_id]);
if($type == 1) {
$befor_money = $shop_money['money'] + $money;
$db->inc('money', $money);
}elseif ($type == 2) {
$befor_money = $shop_money['money'] - $money;
$db->dec('money', $money);
}
$db->update();
// 新增记录
Db::table('sms_shop_money_detail')->insert([
'shop_id' => $shop_id,
'type' => $type,
'expense' => $money,
'balance' => $befor_money,
]);
}
}
public static function javaGetUserList($k_user_params, $page, $size)
{
$get_list_url = config('cons.push_user_list_url');
$get_list_params = [
'page' => $page,
'size' => $size,
'eventId' => $k_user_params['event_id'],
'shopId' => $k_user_params['shop_id'],
'sexMan' => $k_user_params['sex_man']==1?$k_user_params['sex_man']:'',
'sexWoman' => $k_user_params['sex_woman']==1?$k_user_params['sex_woman']:'',
'sexUnknown' => $k_user_params['sex_unknown']==1?$k_user_params['sex_unknown']:'',
'isVip' => $k_user_params['is_vip']==1?$k_user_params['is_vip']:'',
'isRecharge' => $k_user_params['is_recharge']==1?$k_user_params['is_recharge']:'',
'noOrder' => $k_user_params['no_order']==1?$k_user_params['no_order']:'',
'oneOrder' => $k_user_params['one_order']==1?$k_user_params['one_order']:'',
'fiveOrder' => $k_user_params['five_order']==1?$k_user_params['five_order']:'',
'orderTimeToday' => $k_user_params['order_time_today']==1?$k_user_params['order_time_today']:'',
'orderTimeYesterday' => $k_user_params['order_time_yesterday']==1?$k_user_params['order_time_yesterday']:'',
'orderTimeTwoWeeks' => $k_user_params['order_time_two_weeks']==1?$k_user_params['order_time_two_weeks']:'',
'orderTimeMoreThanTwoWeeks' => $k_user_params['order_time_more_than_two_weeks']==1?$k_user_params['order_time_more_than_two_weeks']:'',
];
$ret = curl_post($get_list_url, $get_list_params, [
'Content-Type: application/json',
]);
return json_decode($ret, true);
}
public static function getUserList($k_user_params, $page = 1, $size = 10)
{
$data_arr = self::javaGetUserList($k_user_params, $page, $size);
$for_user_list = [];
if($data_arr['code'] == 0) {
$user_list = self::evnuserlist($data_arr['data']['records']);
if($data_arr['data']['totalPage'] > 1) {
for ($i = 2; $i <= $data_arr['data']['totalPage']; $i++) {
$data_arr = self::javaGetUserList($k_user_params, $i, $size);
if($data_arr['code'] == 0) {
if(empty($for_user_list)) {
$for_user_list = self::evnuserlist($data_arr['data']['records']);
}else {
$o_for_user_list = self::evnuserlist($data_arr['data']['records']);
$for_user_list = array_merge($for_user_list, $o_for_user_list);
}
}
}
$user_list = array_merge($user_list, $for_user_list);
}
}else {
Log::info('获取用户列表时出错' . json_encode($data_arr));
}
return $user_list;
}
public static function evnuserlist($data)
{
foreach ($data as $k => $user) {
$push_user[] = [
'user_id' => $user['id'],
'phone' => $user['phone'],
'nickName' => $user['nickName'],
];
}
return $push_user;
}
public static function getTempDineList()
{
return [
'用户昵称' => [
'username', '用户昵称'
],
'店铺名称' => [
'shopname', '店铺名称'
],
'活动名称' => [
'activityname', '活动名称',
],
'活动时间' => [
'activitytime', '活动时间',
],
'数量' => [
'num', '数量',
],
'金额' => [
'money', '金额',
],
'时间' => [
'time', '时间',
],
];
}
// 处理短信模版替换内容
public static function handleSmsTemplates($content)
{
$arr = handldollerstr($content);
$x_arr = self::getTempDineList();
$new_arr = [];
$item_new_arr = [];
if($arr) {
$i = 1;
foreach ($arr as $k => $v) {
if(isset($x_arr[$v])) {
$k_str = $x_arr[$v][0];
$v_str = $x_arr[$v][1];
$new_arr[$k_str] = $v_str;
}else {
$item = 'item' . $i;
$item_new_arr[$item] = '自定义' . $i;
$i++;
}
}
if($new_arr && $item_new_arr) {
$new_arr = array_merge($new_arr, $item_new_arr);
}
if(!$new_arr && $item_new_arr) {
$new_arr = $item_new_arr;
}
}
return $new_arr;
}
// 处理发送短信时短信模版替换内容
public static function handlesendSmsTemplates($content)
{
$arr = handldollerstr($content);
$x_arr = self::getTempDineList();
$new_arr = [];
$item_new_arr = [];
if($arr) {
$i = 1;
foreach ($arr as $k => $v) {
if(isset($x_arr[$v])) {
$k_str = $x_arr[$v][0];
$v_str = $x_arr[$v][1];
$new_arr[$k_str] = $v_str;
}else {
$item = 'item' . $i;
$item_new_arr[$item] = '自定义' . $i;
$i++;
}
}
if($new_arr && $item_new_arr) {
$new_arr = array_merge($new_arr, $item_new_arr);
}
if(!$new_arr && $item_new_arr) {
$new_arr = $item_new_arr;
}
}
return $new_arr;
}
}

14
app/queue/redis/ApplySmsTemp.php
View File

@@ -4,6 +4,7 @@ namespace app\queue\redis;
use app\model\AlibabaSms;
use app\model\ShopInfo;
use support\Log;
use support\think\Db;
use Webman\RedisQueue\Consumer;
@@ -28,12 +29,17 @@ class ApplySmsTemp implements Consumer
// 查询没有提交审核的模版
$temp = Db::table('sms_shop_template')->where(['id' => $shop_template_id])->where('status', 'in', [0, -2])->find();
if($temp) {
// 处理替换内容
$templateContent_arr = ShopInfo::handleSmsTemplates($temp['content']);
$templateContent_json = json_encode($templateContent_arr);
$content = replace_placeholder_keys($temp['content'], $templateContent_arr);
// 待申请
if($temp['status'] == 0) {
$data = [
'TemplateName' => $temp['title'],
'TemplateContent' => $temp['content'],
'Remark' => !empty($temp['remark']) ? $temp['remark'] : '',
'TemplateContent' => $content,
'TemplateRule' => $templateContent_json,
'Remark' => !empty($temp['scene_detail']) ? $temp['scene_detail'] : '',
'TemplateType' => 2,
'RelatedSignName' => config('cons.sms_sign'),
];
@@ -45,7 +51,8 @@ class ApplySmsTemp implements Consumer
'TemplateCode' => $temp['template_code'],
'TemplateName' => $temp['title'],
'TemplateContent' => $temp['content'],
'Remark' => !empty($temp['remark']) ? $temp['remark'] : '',
'TemplateRule' => $templateContent_json,
'Remark' => !empty($temp['scene_detail']) ? $temp['scene_detail'] : '',
'TemplateType' => 2,
'RelatedSignName' => config('cons.sms_sign'),
];
@@ -69,6 +76,7 @@ class ApplySmsTemp implements Consumer
$update_data = [
'status' => $status,
'template_code' => $template_code,
'content_json' => $templateContent_json,
'fail_msg' => $fail_msg,
'order_id' => $order_id,
'update_time' => date('Y-m-d H:i:s'),

50
app/queue/redis/BirthdayGiftSms.php
View File

@@ -17,9 +17,53 @@ class BirthdayGiftSms implements Consumer
public function consume($data)
{
Log::info('消息队列【生日有礼】接收到消息' . $data);
if($data) {
$record = Db::table('mk_birthday_gift_record')->where(['id' => $data])->find();
if($record) {
// 待发送
if($record['push_status'] == 'wait_push') {
$user = Db::table('tb_shop_user')->where(['id' => $record['user_id']])->find();
if($user && !empty($user['phone'])) {
// 检测余额
$shop_money = Db::table('sms_shop_money')->where(['shop_id' => $record['main_shop_id']])->find();
if($shop_money) {
// 余额计算
if($shop_money['money'] > config('cons.sms_price')) {
$data = [
'templateCode' => $record['template_code'],
'templateParam' => $record['template_content'],
'phoneNumbers' => $user['phone'],
'signName' => config('cons.sms_sign'),
];
$res = AlibabaSms::main($data);
if($res['Code'] == 'OK') {
Db::table('mk_birthday_gift_record')->where(['id' => $record['id']])->update([
'push_status' => 'await_push',
'biz_id' => $res['BizId'],
'push_time' => date('Y-m-d H:i:s'),
]);
}else {
Db::table('mk_birthday_gift_record')->where(['id' => $record['id']])->update([
'push_status' => 'failed',
'push_time' => date('Y-m-d H:i:s'),
]);
}
}else {
Log::info('商户【' . $record['main_shop_id'] . '】余额不足');
return false;
}
}else {
Log::info('商户【' . $record['main_shop_id'] . '】余额为空');
return false;
}
}else {
Log::info('【生日有礼】时查询用户不存在---》' . $record['user_id']);
}
}
}else {
Log::info('生日有礼记录未查询到');
}
}
}
}

75
app/queue/redis/SendMarkSms.php
View File

@@ -4,6 +4,7 @@ namespace app\queue\redis;
use app\model\AlibabaSms;
use app\model\ShopInfo;
use support\Log;
use support\think\Db;
use Webman\RedisQueue\Consumer;
@@ -17,10 +18,76 @@ class SendMarkSms implements Consumer
public function consume($data)
{
Log::info('消息队列【发送营销短信】接收到消息' . $data);
if($data) {
// 发送任务
$record = Db::table('sms_push_event')->where(['id' => $data, 'push_type' => 2])->find();
if($record) {
// 待发送
if($record['status'] == 0) {
// 范围用户
if($record['user_type'] == 2) {
$k_user_params = Db::table('sms_push_event_user')->where(['event_id' => $record['id']])->find();
if($k_user_params) {
$user_list = ShopInfo::getUserList($k_user_params);
}else {
Log::info('范围用户查找出错');
return false;
}
}elseif ($record['status'] == 1) {
// 全部用户
$user_list = Db::table('tb_shop_user')->whereNotNull('phone')->select();
$user_list = ShopInfo::evnuserlist($user_list);
}
$y_temp = Db::table('sms_shop_template')->where(['id' => $record['push_event_id']])->find();
if($user_list && $y_temp) {
foreach ($user_list as $k => $v) {
// 检测余额
$shop_money = Db::table('sms_shop_money')->where(['shop_id' => $record['shop_id']])->find();
if($shop_money) {
// 余额计算
if($shop_money['money'] > config('cons.sms_price')) {
$templateParam = replace_json_keys($record['json'], $y_temp['content_json']);
$data = [
'templateCode' => $record['template_code'],
'templateParam' => $templateParam,
'phoneNumbers' => $user_list['phone'],
'signName' => config('cons.sms_sign'),
];
$res = AlibabaSms::main($data);
Db::table('sms_push_event')->where(['id' => $record['id']])->update([
'status' => '1',
'update_time' => date('Y-m-d H:i:s'),
'send_time' => date('Y-m-d H:i:s'),
]);
if($res['Code'] == 'OK') {
Db::table('sms_push_event_record')->insert([
'shop_id' => $record['shop_id'],
'event_id' => $record['id'],
'user_id' => $v['user_id'],
'user_phone' => $v['phone'],
'biz_id' => $res['BizId'],
'send_time' => date('Y-m-d H:i:s'),
'create_time' => date('Y-m-d H:i:s'),
'status' => 1,
]);
}
}else {
Log::info('商户【' . $record['main_shop_id'] . '】余额不足');
return false;
}
}else {
Log::info('商户【' . $record['main_shop_id'] . '】余额为空');
return false;
}
}
}else {
Log::info('【发送营销短信】无目标用户---》' . $record['user_id']);
}
}
}else {
Log::info('发送营销短信未查询到');
}
}
}
}

3
config/cons.php
View File

@@ -10,5 +10,6 @@ return [
'access_key_id' => 'LTAI5t9Wn4qu9UFcvy5LUH4y',
'access_key_secret' => 'UnqHyd2ByXTYisnIyXl5PsJyveIEau',
],
'sms_sign' => '陕西超掌柜科技'
'sms_sign' => '陕西超掌柜科技',
'push_user_list_url' => 'http://192.168.1.42/account/admin/shopUser/getPushEventUser',
];