[智价云] 邮件短信订阅推送

app/Facades/Servers/Sms/VerifyCode.php

@@ -7,7 +7,7 @@ use Illuminate\Support\Facades\Facade;
  * 
  * @method static array sendCode($phone,$verifyCode) 发送短信验证码
  * @method static array sendRemind($phone,$content) 发送短信
- * @method static array sendContent($phone,$content) 发送短信内容
+ * @method static array sendContent($phone,$content,$sms_tpl_id) 发送短信内容
  *
  * @see \App\Servers\Sms\VerifyCode
  * 

app/Http/Controllers/Manager/Process/LowPriceGoods.php

@@ -16,6 +16,7 @@ use App\Models\manager\Process\LowPriceGoodsRecord as LowPriceGoodsRecordModel;
 use Illuminate\Support\Facades\DB;
 use App\Models\Manager\Citys as CitysModel;
 use App\Jobs\Manager\Process\SubEmailJobs;
+use App\Jobs\Manager\Process\SubSmsJobs;
 
 /**
  * 违规处理-低价商品
@@ -838,6 +839,32 @@ class LowPriceGoods extends Controller
         return             json_send(['code' => 'success', 'msg' => '执行成功']);
     }
 
+    /**
+     * 执行订阅短信推送
+     * @author    唐远望
+     * @version   1.0
+     * @date      2026-03-30
+     * 
+     */
+    public function subscribe_sms_push(Request $request)
+    {
+        // 验证参数
+        $request->scene('data_cleaning')->validate();
+        $admin_company_id = request('admin_company_id', '0');
+        $company_id = request('access_token.company_id', '0');
+        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
+        // 权限判断
+        if ($is_admin != 1 && $company_id != 0) {
+        } else {
+            $company_id  = $admin_company_id;
+        }
+        $message_data = ['notice_type' => 'low_price_goods', 'company_id' => $company_id];
+        SubSmsJobs::dispatch($message_data);
+        // SubSmsJobs::dispatchSync($message_data);
+        // 告知结果
+        return             json_send(['code' => 'success', 'msg' => '执行成功']);
+    }
+
 
     /**
      * 处理买药中的业务

app/Http/Controllers/Manager/Process/ViolationProduct.php

@@ -15,6 +15,7 @@ use App\Models\Manager\Process\ViolationProductMember as ViolationProductMemberM
 use App\Models\Manager\Citys as CitysModel;
 use Illuminate\Support\Facades\DB;
 use App\Jobs\Manager\Process\SubEmailJobs;
+use App\Jobs\Manager\Process\SubSmsJobs;
 
 /**
  * 违规处理-违规商品
@@ -836,6 +837,33 @@ class ViolationProduct extends Controller
     }
 
 
+    /**
+     * 执行订阅短信推送
+     * @author    唐远望
+     * @version   1.0
+     * @date      2026-03-30
+     * 
+     */
+    public function subscribe_sms_push(Request $request)
+    {
+        // 验证参数
+        $request->scene('data_cleaning')->validate();
+        $admin_company_id = request('admin_company_id', '0');
+        $company_id = request('access_token.company_id', '0');
+        $is_admin = request('access_token.is_admin', '0'); //是否管理员操作 0=是1=否
+        // 权限判断
+        if ($is_admin != 1 && $company_id != 0) {
+        } else {
+            $company_id  = $admin_company_id;
+        }
+        $message_data = ['notice_type' => 'violation_product', 'company_id' => $company_id];
+        SubSmsJobs::dispatch($message_data);
+        // SubSmsJobs::dispatchSync($message_data);
+        // 告知结果
+        return             json_send(['code' => 'success', 'msg' => '执行成功']);
+    }
+
+
 
     /**
      * 下载导入模板

app/Jobs/Manager/Process/SubSmsJobs.php

@@ -0,0 +1,160 @@
+<?php
+
+namespace App\Jobs\Manager\Process;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldBeUnique;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use App\Facades\Servers\Logs\Log;
+use App\Models\Manager\Process\LowPriceGoodsMember as LowPriceGoodsMemberModel;
+use App\Models\Manager\Process\LowPriceGoods as LowPriceGoodsModel;
+use App\Models\Manager\Process\ViolationProductMember as ViolationProductMemberModel;
+use App\Models\Manager\Process\ViolationProduct as ViolationProductModel;
+use Illuminate\Support\Carbon;
+use App\Facades\Servers\Sms\VerifyCode as Sms;
+
+
+/**
+ * 订阅短信通知
+ * @author  唐远望
+ * @version 1.0
+ * @date  2026-03-30
+ */
+class SubSmsJobs implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+    protected $message_data;
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct(array $message_data)
+    {
+        $this->message_data = $message_data;
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        try {
+            $notice_type = $this->message_data['notice_type'];
+            switch ($notice_type) {
+                case 'low_price_goods':
+                    $this->send_low_price_goods_notice();
+                    break;
+                case 'violation_product':
+                    $this->send_violation_product();
+                    break;
+                default:
+                    break;
+            }
+        } catch (\Exception $e) {
+            Log::info('job_error', '订阅短信通知推送队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
+        }
+    }
+
+    /**
+     * 短信消息消息订阅推送(低价挂网)
+     * @author  唐远望
+     * @version 1.0
+     * @date  2026-03-04
+     */
+    private function send_low_price_goods_notice()
+    {
+        $LowPriceGoodsMemberModel = new LowPriceGoodsMemberModel();
+        $LowPriceGoodsModel = new LowPriceGoodsModel();
+        //获取今日待处理的商品记录
+        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
+        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
+        $lowprice_ids = $LowPriceGoodsModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd]])->pluck('id')->toArray();
+        if (empty($lowprice_ids)) return true;
+        //获取开启了通知服务的用户
+        $usert_list = $LowPriceGoodsMemberModel
+            ->whereIn('lowprice_product_logid', $lowprice_ids)
+            ->join('personnel_employee', 'process_lowprice_product_member.employee_id', '=', 'personnel_employee.id')
+            ->where('personnel_employee.open_notice', 0)
+            ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
+            ->select(['process_lowprice_product_member.*', 'personnel_employee.mobile'])
+            ->get()->toArray();
+        if (empty($usert_list)) return true;
+        //按用户统计待处理的商品数量
+        $user_data = [];
+        foreach ($usert_list as $key => $value) {
+            $user_id = $value['employee_id'];
+            if (!isset($user_data[$user_id])) {
+                $user_data[$user_id]['employee_id'] = $user_id;
+                $user_data[$user_id]['mobile'] = $value['mobile'];
+                $user_data[$user_id]['log_ids'][] = $value['lowprice_product_logid'];
+            } else {
+                $user_data[$user_id]['log_ids'][] = $value['lowprice_product_logid'];
+            }
+        }
+        $sms_tpl_id =  config('verifycode.aliyun_process_lowprice_product.sms_tpl');
+        //发送短信
+        foreach ($user_data as $key => $value) {
+            $phone = $value['mobile'];
+            $totle_number = count($value['log_ids']);
+            Sms::sendContent($phone, ['totle_number' => $totle_number], $sms_tpl_id);
+        }
+    }
+
+    /**
+     * 短信消息消息订阅推送(禁止挂网)
+     * @author  唐远望
+     * @version 1.0
+     * @date  2026-03-04
+     */
+    private function send_violation_product()
+    {
+        $ViolationProductMemberModel = new ViolationProductMemberModel();
+        $ViolationProductModel = new ViolationProductModel();
+        //获取今日待处理的商品记录
+        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
+        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
+        $violation_price_ids = $ViolationProductModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd]])->pluck('id')->toArray();
+        if (empty($violation_price_ids)) return true;
+        //获取开启了通知服务的用户
+        $usert_list = $ViolationProductMemberModel
+            ->whereIn('violation_product_logid', $violation_price_ids)
+            ->join('personnel_employee', 'process_violation_product_member.employee_id', '=', 'personnel_employee.id')
+            ->where('personnel_employee.open_notice', 0)
+            ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
+            ->select(['process_violation_product_member.*', 'personnel_employee.mobile'])
+            ->get()->toArray();
+        if (empty($usert_list)) return true;
+        //按用户统计待处理的商品数量
+        $user_data = [];
+        foreach ($usert_list as $key => $value) {
+            $user_id = $value['employee_id'];
+            if (!isset($user_data[$user_id])) {
+                $user_data[$user_id]['employee_id'] = $user_id;
+                $user_data[$user_id]['mobile'] = $value['mobile'];
+                $user_data[$user_id]['log_ids'][] = $value['violation_product_logid'];
+            } else {
+                $user_data[$user_id]['log_ids'][] = $value['violation_product_logid'];
+            }
+        }
+        $sms_tpl_id =  config('verifycode.aliyun_process_process_violation_product.sms_tpl');
+        //发送短信
+        foreach ($user_data as $key => $value) {
+            $phone = $value['mobile'];
+            $totle_number = count($value['log_ids']);
+            Sms::sendContent($phone, ['totle_number' => $totle_number], $sms_tpl_id);
+        }
+    }
+
+
+
+    public function failed(\Throwable $exception)
+    {
+        Log::info('job_error', '订阅短信通知推送队列完全失败', ['data' => $this->message_data, 'error' => $exception]);
+    }
+}

app/Servers/Sms/VerifyCode.php

@@ -87,14 +87,15 @@ class VerifyCode
     }
 
 
-    public function sendContent($phone, $content)
+    public function sendContent($phone, $content, $sms_tpl = '')
     {
         // 判断运营商，以方便发送短信
         $type                               = config('verifycode.operator_type');
         // 如果是阿里云
         if ($type == 'aliyun') {
+            $sms_tpl_id = $sms_tpl != '' ? $sms_tpl : config('verifycode.aliyun_website.sms_tpl');
             // 发送短信
-            $result                         = Aliyun::sendSms($phone, config('verifycode.aliyun_website.sms_sign'), config('verifycode.aliyun_website.sms_tpl'),$content);
+            $result                         = Aliyun::sendSms($phone, config('verifycode.aliyun_website.sms_sign'),$sms_tpl_id, $content);
             // 如果code不是03
             if (isset($result['error']))    return ['error' => $result['error'], 'data' => $result];
             // 返回结果

config/verifycode.php

@@ -11,6 +11,14 @@ return [
         'sms_sign'      => env('VERIFYCODE_ALIYUN_SMS_SIGN', '开邻'),
         'sms_tpl'       => env('VERIFYCODE_ALIYUN_SMS_TPL', 'SMS_504960050'),
     ],
+    'aliyun_process_lowprice_product'=>[
+        'sms_sign'      => env('VERIFYCODE_ALIYUN_SMS_SIGN', '开邻'),
+        'sms_tpl'       => env('VERIFYCODE_ALIYUN_SMS_TPL', 'SMS_504960050'),
+    ],
+    'aliyun_process_process_violation_product'=>[
+        'sms_sign'      => env('VERIFYCODE_ALIYUN_SMS_SIGN', '开邻'),
+        'sms_tpl'       => env('VERIFYCODE_ALIYUN_SMS_TPL', 'SMS_504960050'),
+    ],
     'guodu'=>[
         'sms_sign'      => env('VERIFYCODE_GUODU_SMS_SIGN', '开邻'),
     ],

routes/manager.php

@@ -225,6 +225,8 @@ Route::any('process/low_price_goods/delete', [App\Http\Controllers\Manager\Proce
 Route::any('process/low_price_goods/data_cleaning', [App\Http\Controllers\Manager\Process\LowPriceGoods::class, 'data_cleaning']);
 // 违规处理-低价挂网商品-执行订阅邮件推送
 Route::any('process/low_price_goods/subscribe_email_push', [App\Http\Controllers\Manager\Process\LowPriceGoods::class,'subscribe_email_push']);
+// 违规处理-低价挂网商品-执行订阅短信推送
+Route::any('process/low_price_goods/subscribe_sms_push', [App\Http\Controllers\Manager\Process\LowPriceGoods::class,'subscribe_sms_push']);
 // 违规处理-低价挂网商品-导出Excel
 Route::any('process/low_price_goods/export_excel', [App\Http\Controllers\Manager\Process\LowPriceGoods::class, 'export_excel']);
 // 违规处理-低价挂网商品-处理买药中的业务
@@ -254,6 +256,8 @@ Route::any('process/violation_goods/delete', [App\Http\Controllers\Manager\Proce
 Route::any('process/violation_goods/data_cleaning', [App\Http\Controllers\Manager\Process\ViolationProduct::class, 'data_cleaning']);
 // 违规处理-禁止挂网商品-执行订阅邮件推送
 Route::any('process/violation_goods/subscribe_email_push', [App\Http\Controllers\Manager\Process\ViolationProduct::class,'subscribe_email_push']);
+// 违规处理-禁止挂网商品-执行订阅短信推送
+Route::any('process/violation_goods/subscribe_sms_push', [App\Http\Controllers\Manager\Process\ViolationProduct::class,'subscribe_sms_push']);
 // 违规处理-禁止挂网商品-导出Excel
 Route::any('process/violation_goods/export_excel', [App\Http\Controllers\Manager\Process\ViolationProduct::class, 'export_excel']);
 // 违规处理-低价挂网商品-下载导入模板