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

完成

This commit is contained in:
ASUS 2025-10-17 10:22:02 +08:00
parent 1a1040b514
commit 7e93bee4fa
11 changed files with 64 additions and 652 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/command/ApplySmsTemp.php
View File

@ -48,11 +48,11 @@ class ApplySmsTemp extends Command
// \support\Redis::setEx('expired:sms:9995', $stortime - time(), 1);
// Log::info('定时发送，已存入redis');
// p(123123);
$host = RabbitMqConfig::$host;
$port = RabbitMqConfig::$port;
$user = RabbitMqConfig::$user;
$password = RabbitMqConfig::$password;
$queue = RabbitMqConfig::$queue_t . '-apply.sms.temp';
$host = config('cons.mq.host');
$port = config('cons.mq.port');
$user = config('cons.mq.user');
$password = config('cons.mq.password');
$queue = config('cons.mq.queue_t') . '-apply.sms.temp';
// 防止空闲时间断线必须设置心跳
$connection = new AMQPStreamConnection($host, $port, $user, $password,

10
app/command/BirthdayGiftSms.php
View File

@ -38,11 +38,11 @@ class BirthdayGiftSms extends Command
protected function execute(InputInterface $input, OutputInterface $output): int
{
$host = RabbitMqConfig::$host;
$port = RabbitMqConfig::$port;
$user = RabbitMqConfig::$user;
$password = RabbitMqConfig::$password;
$queue = RabbitMqConfig::$queue_t . '-birthday.gift.sms';
$host = config('cons.mq.host');
$port = config('cons.mq.port');
$user = config('cons.mq.user');
$password = config('cons.mq.password');
$queue = config('cons.mq.queue_t') . '-birthday.gift.sms';
// 防止空闲时间断线必须设置心跳
$connection = new AMQPStreamConnection($host, $port, $user, $password,

16
app/command/QuerySmsStatus.php
View File

@ -36,6 +36,14 @@ class QuerySmsStatus extends Command
*/
protected function execute(InputInterface $input, OutputInterface $output): int
{
// 一条短信的价格
$sms_price = Db::table('sys_params')->where(['param_code' => 'sms_fee'])->column('param_value');
if(!$sms_price) {
Log::info('短信价格未定,停止发送');
return false;
}else {
$sms_price = $sms_price[0];
}
$push_resp = '';
// 生日有礼
$bir_list = Db::table('mk_birthday_gift_record')->where(['push_status' => 'await_push'])->select()->toArray();
@ -56,7 +64,7 @@ class QuerySmsStatus extends Command
if($res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['SendStatus'] == 3) {
$push_status = 'success';
// 扣掉余额
ShopInfo::moeny(config('cons.sms_price'), $value['main_shop_id'], '生日有礼短信发送，任务ID:' . $value['id'], 2);
ShopInfo::moeny($sms_price, $value['main_shop_id'], '生日有礼短信发送，任务ID:' . $value['id'], 2);
}elseif ($res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['SendStatus'] == 2) {
$push_resp = $res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['ErrCode'];
$push_status = 'failed';
@ -100,7 +108,7 @@ class QuerySmsStatus extends Command
if($res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['SendStatus'] == 3) {
$push_status = 2;
// 扣掉余额
ShopInfo::moeny(config('cons.sms_price'), $value['main_shop_id'], '营销短信发送，任务ID：' . $value['event_id'], 2);
ShopInfo::moeny($sms_price, $value['main_shop_id'], '营销短信发送，任务ID：' . $value['event_id'], 2);
}elseif ($res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['SendStatus'] == 2) {
$push_resp = $res['SmsSendDetailDTOs']['SmsSendDetailDTO'][0]['ErrCode'];
$push_status = -1;
@ -123,10 +131,6 @@ class QuerySmsStatus extends Command
sleep(1);
}
}
return self::SUCCESS;
}

10
app/command/RabbOrderPrint.php
View File

@ -37,11 +37,11 @@ class RabbOrderPrint extends Command
protected function execute(InputInterface $input, OutputInterface $output): int
{
$host = RabbitMqConfig::$host;
$port = RabbitMqConfig::$port;
$user = RabbitMqConfig::$user;
$password = RabbitMqConfig::$password;
$queue = RabbitMqConfig::$queue_t . '-order.print.queue';
$host = config('cons.mq.host');
$port = config('cons.mq.port');
$user = config('cons.mq.user');
$password = config('cons.mq.password');
$queue = config('cons.mq.queue_t') . '-order.print.queue';
// 防止空闲时间断线必须设置心跳
$connection = new AMQPStreamConnection($host, $port, $user, $password,

10
app/command/RabbProductUpdate.php
View File

@ -35,11 +35,11 @@ class RabbProductUpdate extends Command
*/
protected function execute(InputInterface $input, OutputInterface $output): int
{
$host = RabbitMqConfig::$host;
$port = RabbitMqConfig::$port;
$user = RabbitMqConfig::$user;
$password = RabbitMqConfig::$password;
$queue = RabbitMqConfig::$queue_t . '-product.info.change.queue';
$host = config('cons.mq.host');
$port = config('cons.mq.port');
$user = config('cons.mq.user');
$password = config('cons.mq.password');
$queue = config('cons.mq.queue_t') . '-product.info.change.queue';
// 防止空闲时间断线必须设置心跳
$connection = new AMQPStreamConnection($host, $port, $user, $password,
'/',

19
app/common/model/RabbitMqConfig.php
View File

@ -1,19 +0,0 @@
<?php
namespace app\common\model;
use ba\Random;
use think\Model;
/**
* 错误日志
*/
class RabbitMqConfig extends Model
{
public static $host = '121.40.109.122';
public static $port = '5672';
public static $user = 'chaozg';
public static $password = 'chaozg123';
public static $queue_t = 'dev';
}

589
app/model/MessagePushTask.php
View File

@ -1,589 +0,0 @@
<?php
namespace app\model;
// 消息推送
use support\Log;
use support\think\Db;
use EasyWeChat\Factory;
class MessagePushTask
{
// 推送模版消息
public static function send_push_msg()
{
// 查询模版任务
$event_list = Db::name('tb_push_event')->where(['status' => 0, 'push_type' => 1])->select()->toArray();
if($event_list) {
try {
Db::startTrans();
foreach ($event_list as $k => $event) {
Db::name('tb_push_event')->where(['id' => $event['id']])->update(['status' => 1, 'start_time' => date('Y-m-d H:i:s')]);
$res = self::getPullInfoUser($event);
if($res) {
foreach ($res as $rk => &$rv) {
if(empty($rv['open_id'])) {
unset($res[$rk]);
}
}
$user_list = uniqueMultidimensionalArray($res);
// 需要接收推送的用户 准备发送
foreach ($user_list as $k => $user) {
$data = [
'thing2' => $event['keyword1'],
'amount3' => $event['keyword2'],
'time6' => $event['keyword3'],
];
$user_push_list_res_id = Db::name('tb_user_push_event')->insertGetId([
'push_event_id' => $event['id'],
'user_id' => $user['user_id'],
'create_time' => date("Y-m-d H:i:s"),
'content' => json_encode($data),
]);
if($user_push_list_res_id) {
$app = Factory::officialAccount([
'app_id' => config('cons.app_id'),
'secret' => config('cons.secret'),
'response_type' => 'array',
]);
// 正式推送
$push = $app->template_message->send([
'touser' => $user['open_id'],
'template_id' => $event['template_id'],
'data' => $data
]);
Log::info('用户-' . $user['user_id'] . ' 推送模版ID：'. $event['template_id'] .' 内容：' . json_encode($data, 256) . ' 推送结果：' . json_encode($push));
if($push['errcode'] == 0) {
Db::name('tb_user_push_event')->where(['id' => $user_push_list_res_id])->update(['update_time' => date("Y-m-d H:i:s"), 'status' => 1]);
// 送券
if(isset($event['coupon'])) {
$coupon = json_decode($event['coupon'], true);
self::sendUserCoupon($event['shop_id'], $user['user_id'], $coupon['id'], $coupon['num']);
}
}else {
Db::name('tb_user_push_event')->where(['id' => $user_push_list_res_id])->update(['update_time' => date("Y-m-d H:i:s"), 'status' => -1, 'error' => json_encode($push)]);
}
}
sleep(1);
}
Db::name('tb_push_event')->where(['id' => $event['id']])->update(['status' => 2, 'send_time' => date('Y-m-d H:i:s')]);
}
}
Db::commit();
}catch (\Exception $e) {
Log::info('执行出错--' . $e->getMessage());
Db::rollback();
}
}
Log::info('没有推送任务可执行');
return true;
}
// 推送短信消息
public static function send_sms_msg()
{
// 查询短信任务
$event_list = Db::name('tb_push_event')->where(['status' => 0, 'push_type' => 2])->select()->toArray();
if($event_list) {
try {
Db::startTrans();
foreach ($event_list as $k => $event) {
Db::name('tb_push_event')->where(['id' => $event['id']])->update(['status' => 1, 'start_time' => date('Y-m-d H:i:s')]);
$res = self::getPullInfoUser($event);
if($res) {
foreach ($res as $rk => &$rv) {
if(empty($rv['phone'])) {
unset($res[$rk]);
}
}
$user_list = uniqueMultidimensionalArray($res);
// 需要接收推送的用户 准备发送
foreach ($user_list as $k => $user) {
// 查询商家短信余额
$sms_shop = Db::name('tb_shop_sms_money')->where(['shop_id' => $event['shop_id']])->find();
if (!$sms_shop) {
Db::name('tb_shop_sms_money')->insertGetId([
'shop_id' => $event['shop_id'],
'create_time' => date("Y-m-d H:i:s"),
]);
log::info('商户' . $event['shop_id'] . '不存在或余额不足，停止发送');
continue 2;
} else {
// 一条短信的价格
$one_sms_price = config('cons.sms_price');
if($sms_shop['money'] < $one_sms_price) {
log::info('商户' . $event['shop_id'] . '余额不足，停止发送');
continue 2;
}else {
$user_push_list_res_id = Db::name('tb_user_push_event')->insertGetId([
'push_event_id' => $event['id'],
'user_id' => $user['user_id'],
'create_time' => date("Y-m-d H:i:s"),
'content' => json_encode($user),
]);
if ($user_push_list_res_id) {
// 发送短信
$ret = AlibabaSms::main([
'templateCode' => $event['sms_code'],
'templateParam' => json_encode($event['sms_content']),
'phoneNumbers' => $user['phone'],
'signName' => $event['sms_sign'],
]);
Log::info('用户-' . $user['user_id'] . ' 短信发送ID：' . $user['template_id'] . ' 内容：' . json_encode($event['sms_content'], 256) . ' 推送结果：' . $ret);
if ($ret) {
Db::name('tb_user_push_event')->where(['id' => $user_push_list_res_id])->update(['update_time' => date("Y-m-d H:i:s"), 'status' => 1]);
// 加入明细
$tb_shop_sms_money = Db::name('tb_shop_sms_money_detail')->insertGetId([
'shop_id' => $event['shop_id'],
'type' => 2,
'money' => $one_sms_price,
'create_time' => date("Y-m-d H:i:s"),
]);
if($tb_shop_sms_money) {
// 扣掉余额
Db::name('tb_shop_sms_money')->where([
'shop_id' => $event['shop_id'],
])->dec('money', $one_sms_price)->update();
}
// 送券
if(isset($event['coupon'])) {
$coupon = json_decode($event['coupon'], true);
self::sendUserCoupon($event['shop_id'], $user['user_id'], $coupon['id'], $coupon['num']);
}
} else {
Db::name('tb_user_push_event')->where(['id' => $user_push_list_res_id])->update(['update_time' => date("Y-m-d H:i:s"), 'status' => -1, 'error' => json_encode($push)]);
}
}
sleep(1);
}
}
}
Db::name('tb_push_event')->where(['id' => $event['id']])->update(['status' => 2, 'send_time' => date('Y-m-d H:i:s')]);
}
}
Db::commit();
}catch (\Exception $e) {
Log::info('执行出错--' . $e->getMessage());
Db::rollback();
}
}
Log::info('没有推送任务可执行');
return true;
}
/**
* 找到可以接收订阅消息的用户
* @param $type类型 1按次数发送 2自定义 3按标签
* @return array
*/
public static function getPullInfoUser($event): array
{
$user_arr = [];
switch ($event['type']) {
// 按可接收次数发送(模版推送)/全部绑定手机用户(短信推送)
case 1;
$user_arr = self::getPullInfoUserToNumber($event);
break;
// 自定义
case 2;
$user_arr = self::getPullInfoUserToCustom($event);
break;
// 按标签
case 3;
$user_arr = self::getPullInfoUserToLabel($event);
break;
}
return $user_arr;
}
// 按照可接收次数获取用户信息
public static function getPullInfoUserToNumber($event)
{
$user_num = [];
if($event['push_type'] == 1 && $event['can_send_times'] > 0) {
$user_num = Db::name('tb_user_push_event_num')->alias('upen')->where('upen.num', '>=', $event['can_send_times'])
->join('tb_user_info u', 'upen.user_id = u.id')
->field('upen.user_id as user_id, upen.open_id as open_id')
->select()
->toArray();
}
if($event['push_type'] == 2) {
$user_num = Db::name('tb_user_info')->where('phone', '<>', '')
->field('id as user_id, wechat_ac_open_id as open_id, phone')
->select()
->toArray();
}
return $user_num;
}
// 按照自定义获取用户信息
public static function getPullInfoUserToCustom($event)
{
$data_arr = [];
// 按照性别
if(isset($event['gender']) && is_string($event['gender'])) {
$gender_data_arr = [];
$gender_arr = explode(',', $event['gender']);
foreach ($gender_arr as $k => $gender) {
// 未知
if($gender == 0) {
$gender_data_res = Db::name('tb_user_info')->whereNotIn('sex', [0,1])
->field('id as user_id, wechat_ac_open_id as open_id, phone')
->select()
->toArray();
}
// 男
if($gender == 1) {
$gender_data_res = Db::name('tb_user_info')->where('sex', 1)
->field('id as user_id, wechat_ac_open_id as open_id, phone')
->select()
->toArray();
}
// 女
if($gender == 2) {
$gender_data_res = Db::name('tb_user_info')->where('sex', 0)
->field('id as user_id, wechat_ac_open_id as open_id, phone')
->select()
->toArray();
}
if($gender_data_arr) {
$gender_data_arr = array_merge($gender_data_arr, $gender_data_res);
}else {
$gender_data_arr = $gender_data_res;
}
}
if($gender_data_arr) {
$data_arr = array_merge($data_arr, $gender_data_arr);
}
}
// 按照下单次数
if(isset($event['order_history']) && is_string($event['order_history'])) {
$order_history_arr = explode(',', $event['order_history']);
$order_history_data_arr = [];
foreach ($order_history_arr as $k => $order_history) {
// 从未下单
if($order_history == 0) {
$order_history_data_res = Db::name('tb_user_info')
->alias('u') // 用户表别名u
->leftJoin('tb_order_info o', 'u.id = o.user_id')
->where('o.user_id', 'null')
->distinct()
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->select()
->toArray();
}
// 下过1单
if($order_history == 1) {
$order_history_data_res = Db::name('tb_user_info')
->alias('u')
// 关联订单表，使用内连接确保只包含有订单的用户
->join('tb_order_info o', 'u.id = o.user_id')
// 按用户ID分组
->group('u.id')
// 筛选出订单数量为1的用户
->having('COUNT(o.id) = 1')
// 选择需要的用户字段，同时查询订单数量（可选）
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->select()
->toArray();
}
// 下过2-5单
if($order_history == 2) {
$order_history_data_res = Db::name('tb_user_info')
->alias('u')
// 关联订单表，使用内连接确保只包含有订单的用户
->join('tb_order_info o', 'u.id = o.user_id')
// 按用户ID分组
->group('u.id')
// 筛选出订单数量为1的用户
->having('COUNT(o.id) BETWEEN 2 AND 5')
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->select()
->toArray();
}
// 下过5单起
if($order_history == 3) {
$order_history_data_res = Db::name('tb_user_info')
->alias('u')
// 关联订单表，使用内连接确保只包含有订单的用户
->join('tb_order_info o', 'u.id = o.user_id')
// 按用户ID分组
->group('u.id')
// 筛选出订单数量为1的用户
->having('COUNT(o.id) >= 5')
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->select()
->toArray();
}
if($order_history_data_arr) {
$order_history_data_arr = array_merge($order_history_data_arr, $order_history_data_res);
;
}else {
$order_history_data_arr = $order_history_data_res;
}
}
if($order_history_data_arr) {
$data_arr = array_merge($data_arr, $gender_data_arr);
}
}
// 按照下单时间
if(isset($event['order_times']) && is_string($event['order_times'])) {
$order_times_arr = explode(',', $event['order_times']);
$order_times_data_arr = [];
foreach ($order_times_arr as $k => $order_times) {
// 今天下过
if($order_times == 0) {
$order_times_data_res = Db::name('tb_user_info')
->alias('u') // 用户表别名u
->join('tb_order_info o', 'u.id = o.user_id')
->where('o.create_time', '>=', date('Y-m-d 00:00:00'))
->where('o.create_time', '<=', date('Y-m-d 23:59:59'))
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->distinct()
->select()
->toArray();
}
// 昨天下过
if($order_times == 1) {
$order_times_data_res = Db::name('tb_user_info')
->alias('u') // 用户表别名u
->join('tb_order_info o', 'u.id = o.user_id')
->where('o.create_time', '>=', date('Y-m-d 00:00:00', strtotime('-1 day')))
->where('o.create_time', '<=', date('Y-m-d 23:59:59', strtotime('-1 day')))
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->distinct()
->select()
->toArray();
}
// 2周内没下过
if($order_times == 2) {
$twoWeeksAgo = date('Y-m-d H:i:s', strtotime('-14 days'));
$order_times_data_res = Db::name('tb_user_info')
->alias('u') // 用户表别名u
// 左连接订单表，关联条件包含近两周内的订单
->leftJoin('tb_order_info o', 'u.id = o.user_id')
->where('o.create_time', '>=', $twoWeeksAgo)
->where('o.id', 'null')
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->distinct()
->select()
->toArray();
}
// 半个月-1个月没下过
if($order_times == 3) {
$startTime = date('Y-m-d H:i:s', strtotime('-30 days'));
$endTime = date('Y-m-d H:i:s', strtotime('-15 days'));
$order_times_data_res = Db::name('tb_user_info')
->alias('u') // 用户表别名u
// 左连接订单表，关联条件包含近两周内的订单
->join('tb_order_info o', 'u.id = o.user_id')
// 按用户分组
->group('u.id')
// 筛选最后下单时间在30天前到15天前之间的用户
->having('MAX(o.create_time) >="'. $startTime .'" AND MAX(o.create_time) <= "' . $endTime . '"')
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->select()
->toArray();
}
// 1个月以上没下过
if($order_times == 4) {
$oneMonthAgo = date('Y-m-d H:i:s', strtotime('-30 days'));
$order_times_data_res = Db::name('tb_user_info')
->alias('u') // 用户表别名u
// 左连接订单表，关联条件包含近两周内的订单
->join('tb_order_info o', 'u.id = o.user_id')
// 按用户分组
->group('u.id')
// 筛选最后下单时间在1个月前及更早
->having('MAX(o.create_time) <= "' . $oneMonthAgo . '"')
// ->field('u.id as user_id, u.wechat_ac_open_id as open_id, MAX(o.create_time) as last_order_time')
->field('u.id as user_id, u.wechat_ac_open_id as open_id, u.phone as phone')
->select()
->toArray();
}
if($order_times_data_arr) {
$order_times_data_arr = array_merge($order_times_data_arr, $order_times_data_res);
}else {
$order_times_data_arr = $order_times_data_res;
}
}
if($order_times_data_arr) {
$data_arr = array_merge($data_arr, $order_times_data_arr);
}
// 按照会员
if(isset($event['vip']) && is_string($event['vip'])) {
$vip_data_arr = [];
$vip_arr = explode(',', $event['vip']);
foreach ($vip_arr as $k => $vip) {
// 非会员
if($vip == 0) {
$vip_data_res = Db::name('tb_user_info')->whereNotIn('is_vip', 0)
->field('id as user_id, wechat_ac_open_id as open_id,phone')
->select()
->toArray();
}
// 会员
if($vip == 1) {
if($event['push_type'] == 1) {
$vip_data_res = Db::name('tb_user_info')->where('is_vip', 1)
->field('id as user_id, wechat_ac_open_id as open_id,phone')
->select()
->toArray();
}
// 推送类型为短信推送
if($event['push_type'] == 2) {
// 全部会员
if($event['vip_lavel'] == 0) {
$vip_data_res = Db::name('tb_user_info')->where('is_vip', 1)
->field('id as user_id, wechat_ac_open_id as open_id,phone')
->select()
->toArray();
}
// 仅限等级
if($event['vip_lavel'] == 1) {
$vip_data_res = Db::name('tb_user_info')->where(['is_vip' => 1, 'member_level_id' => $event['vip_lavel_id']])
->field('id as user_id, wechat_ac_open_id as open_id,phone')
->select()
->toArray();
}
// 以上等级
if($event['vip_lavel'] == 2) {
// 找到会员详情
$vip_config_info = Db::name('tb_member_level_config')->where(['id' => $event['vip_lavel_id']])->find();
if($vip_config_info) {
$vip_config_info = Db::name('tb_member_level_config')->where('experience_value', '>', $vip_config_info['experience_value'])->column('id');
if($vip_config_info) {
$vip_data_res = Db::name('tb_user_info')->where(['is_vip' => 1])->whereIn('member_level_id', $vip_config_info)
->field('id as user_id, wechat_ac_open_id as open_id,phone')
->select()
->toArray();
}
}
}
}
}
if($vip_data_arr) {
$vip_data_arr = array_merge($vip_data_arr, $vip_data_res);
}else {
$vip_data_arr = $vip_data_res;
}
}
if($vip_data_arr) {
$data_arr = array_merge($data_arr, $vip_data_arr);
}
}
// 按照手机号
if(isset($event['telphone']) && is_string($event['telphone'])) {
$telphone_data_arr = [];
$telphone_arr = explode(',', $event['telphone']);
foreach ($telphone_arr as $k => $telphone) {
// 非绑定
if($telphone == 0) {
$telphone_data_res = Db::name('tb_user_info')->where(function ($query) {
$query->where('phone', 'null') // 为 NULL
->whereOr('phone', ''); // 为空字符串
})
->field('id as user_id, wechat_ac_open_id as open_id')
->select()
->toArray();
}
// 已绑定
if($telphone == 1) {
$telphone_data_res = Db::name('tb_user_info')->where('phone', '<>', '')
->field('id as user_id, wechat_ac_open_id as open_id, phone')
->select()
->toArray();
}
if($telphone_data_arr) {
$telphone_data_arr = array_merge($telphone_data_arr, $telphone_data_res);
}else {
$telphone_data_arr = $telphone_data_res;
}
}
if($telphone_data_arr) {
$data_arr = array_merge($data_arr, $telphone_data_arr);
}
}
}
return $data_arr;
}
// 按照标签获取用户信息
public static function getPullInfoUserToLabel($event)
{
$data_arr = [];
$label = Db::name('tb_user_label')->whereIn('label_id', explode(',', $event['user_label']))
->distinct()
->column('user_id');
if($label) {
$data_arr = Db::name('tb_user_info')->whereIn('id', $label)
->field('id as user_id, wechat_ac_open_id as open_id, phone')
->select()
->toArray();
}
return $data_arr;
}
// 给用户送送优惠券
public static function sendUserCoupon($shop_id, int | array $user_id, $coupon_id, $number = 1)
{
if ($number === null || $number <= 0) {
Log::info('推送用户送券发放数量不能小于0');
return false;
}
$url = 'http://192.168.1.31/market/admin/coupon/grant';
$res = http_post($url, [
'userId' => $user_id,
'couponId' => $coupon_id,
'num' => $number,
'shopId' => $shop_id,
]);
Log::info('发券:' . $res);
$res = json_decode($res, true);
if($res['code'] == 200) {
Log::info('userId:' . $user_id . ' couponId:' . $coupon_id . ' shopId:' . $shop_id . ' 发券成功');
}else {
Log::info('userId:' . $user_id . ' couponId:' . $coupon_id . ' shopId:' . $shop_id . ' 发券失败' . ' 信息：' . $res['msg']);
}
return true;
}
}

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

@ -17,6 +17,14 @@ class BirthdayGiftSms implements Consumer
public function consume($data)
{
Log::info('消息队列【生日有礼】接收到消息' . $data);
// 一条短信的价格
$sms_price = Db::table('sys_params')->where(['param_code' => 'sms_fee'])->column('param_value');
if(!$sms_price) {
Log::info('短信价格未定,停止发送');
return false;
}else {
$sms_price = $sms_price[0];
}
if($data) {
$record = Db::table('mk_birthday_gift_record')->where(['id' => $data])->find();
if($record) {
@ -29,7 +37,7 @@ class BirthdayGiftSms implements Consumer
$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')) {
if($shop_money['money'] > $sms_price) {
$templateParam = replace_json_keys($record['template_content'], $y_temp['content_json'], $user);
$data = [
'templateCode' => $record['template_code'],

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

@ -31,6 +31,13 @@ class SendMarkSms implements Consumer
Log::info('send.mark.sms数据格式错误');
return false;
}
$sms_price = Db::table('sys_params')->where(['param_code' => 'sms_fee'])->column('param_value');
if(!$sms_price) {
Log::info('短信价格未定,停止发送');
return false;
}else {
$sms_price = $sms_price[0];
}
if($data) {
Log::info('$data');
// 发送任务
@ -74,7 +81,7 @@ class SendMarkSms implements Consumer
$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')) {
if($shop_money['money'] > $sms_price) {
$templateParam = replace_json_keys($record['json'], $y_temp['content_json'], $v);
$data = [
'templateCode' => $y_temp['template_code'],

7
config/cons.php
View File

@ -12,4 +12,11 @@ return [
],
'sms_sign' => '陕西超掌柜科技',
'push_user_list_url' => 'http://192.168.1.42/account/admin/shopUser/getPushEventUser',
'mq' => [
'host' => '121.40.109.122',
'port' => '5672',
'user' => 'chaozg',
'password' => 'chaozg123',
'queue_t' => 'dev',
]
];

26
start_webman_commands.php
View File

@ -4,24 +4,18 @@
*/
// 定义要执行的命令列表
//$commands = [
// 'nohup php webman applysmstemp &',
// 'nohup php webman birthdaygiftsms &',
// 'nohup php webman birthdaygiftsms &',
// 'nohup php webman rabborderprint &',
// 'nohup php webman rabbproductupdate &',
// 'nohup php webman sendmarksms &',
// 'nohup php webman sendwechattemp &',
//];
$commands = [
'php webman applysmstemp',
'php webman birthdaygiftsms',
'php webman birthdaygiftsms',
'php webman rabborderprint',
'php webman rabbproductupdate',
'php webman sendmarksms',
'php webman sendwechattemp',
'nohup php webman applysmstemp &',
'nohup php webman birthdaygiftsms &',
'nohup php webman rabborderprint &',
'nohup php webman rabbproductupdate &',
];
//$commands = [
// 'php webman applysmstemp',
// 'php webman birthdaygiftsms',
// 'php webman rabborderprint',
// 'php webman rabbproductupdate',
//];
echo "开始执行命令...\n";
// 遍历并执行每个命令