[智价云] 短信推送更新

app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

@@ -84,7 +84,7 @@ class LowPriceGoodsDataJobs implements ShouldQueue
         $specify_responsible_person = $message_data['specify_responsible_person']; //指派责任人 0=开启 1=关闭
         $limit = isset($message_data['limit']) ? $message_data['limit'] : 50;
         $page = isset($message_data['page']) ? $message_data['page'] : 1;
-        $company_id = isset($message_data['company_id']) ? $message_data['company_id'] : 0;//品牌方公司ID
+        $company_id = isset($message_data['company_id']) ? $message_data['company_id'] : 0; //品牌方公司ID
 
         $where = [];
         if ($platform != '0') {
@@ -105,7 +105,7 @@ class LowPriceGoodsDataJobs implements ShouldQueue
         $product_datas = $product_data_info['data'];
         if (empty($product_datas)) {
             if ($executeLog_id) {
-                (new ExecuteLogModel())->where('id', $executeLog_id)->update(['status' => 0,'update_time' => time()]);
+                (new ExecuteLogModel())->where('id', $executeLog_id)->update(['status' => 0, 'update_time' => time()]);
             }
             return true;
         }
@@ -243,7 +243,7 @@ class LowPriceGoodsDataJobs implements ShouldQueue
                 $first_responsible_person = $EmployeeModel->pluck('id')->implode(',');
 
                 //当以上规则匹配不到责任人时，则去查询发货地区信息关联责任人
-                if (trim($first_responsible_person) == '' && trim($product_data['shipment_city_id']) !='') {
+                if (trim($first_responsible_person) == '' && trim($product_data['shipment_city_id']) != '') {
                     $employee_id_area = $EmployeeAreaModel->where('city_id', $product_data['city_id'])->pluck('employee_id')->toarray();
                     if (!empty($employee_id_area)) {
                         $where_city[] = ['company_id', '=', $company_id];
@@ -291,27 +291,27 @@ class LowPriceGoodsDataJobs implements ShouldQueue
                         $q->where('company_id', $company_id)
                             ->orWhereIn('id', $employee_id_list)
                             ->where('status', 0)
-                            ->where('duty_type', 2);//责任类型1=第一责任人，2=责任人
+                            ->where('duty_type', 2); //责任类型1=第一责任人，2=责任人
                     }
                 })->orWhere(function ($q) use ($employee_id_area, $company_id) {
                     if (!empty($employee_id_area)) {
                         $q->where('company_id', $company_id)
                             ->whereIn('id', $employee_id_area)
                             ->where('status', 0)
-                            ->where('duty_type', 2);//责任类型1=第一责任人，2=责任人
+                            ->where('duty_type', 2); //责任类型1=第一责任人，2=责任人
                     }
                 })->orWhere(function ($q) use ($employee_id_platform, $company_id) {
                     if (!empty($employee_id_platform)) {
                         $q->where('company_id', $company_id)
                             ->whereIn('id', $employee_id_platform)
                             ->where('status', 0)
-                            ->where('duty_type', 2);//责任类型1=第一责任人，2=责任人
+                            ->where('duty_type', 2); //责任类型1=第一责任人，2=责任人
                     }
                 });
                 $responsible_person = $EmployeeModel->pluck('id')->implode(',');
-                
+
                 //当以上规则匹配不到责任人时，则去查询发货地区信息关联责任人
-                if (trim($responsible_person) == '' && trim($product_data['shipment_city_id']) !='') {
+                if (trim($responsible_person) == '' && trim($product_data['shipment_city_id']) != '') {
                     $employee_id_area = $EmployeeAreaModel->where('city_id', $product_data['city_id'])->pluck('employee_id')->toarray();
                     if (!empty($employee_id_area)) {
                         $where_city[] = ['company_id', '=', $company_id];
@@ -331,7 +331,7 @@ class LowPriceGoodsDataJobs implements ShouldQueue
                     $first_responsible_person = explode(',', $first_responsible_person);
                     $responsible_person = explode(',', $responsible_person);
                     $source_responsible_person = array_unique(array_merge($first_responsible_person, $responsible_person));
-                    $source_responsible_person = ','.implode(',', $source_responsible_person).',';
+                    $source_responsible_person = ',' . implode(',', $source_responsible_person) . ',';
                 } else if ($first_responsible_person) {
                     $source_responsible_person = $first_responsible_person;
                 } else if ($responsible_person) {

app/Jobs/Manager/Process/SubEmailJobs.php

@@ -15,7 +15,8 @@ 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\Models\Manager\Process\ViolationStore as ViolationStoreModel;
+use App\Models\Manager\Process\ViolationStoreMember as ViolationStoreMemberModel;
 
 
 /**
@@ -47,18 +48,21 @@ class SubEmailJobs implements ShouldQueue
     {
         try {
             $notice_type = $this->message_data['notice_type'];
+            $company_id = $this->message_data['company_id'];
             switch ($notice_type) {
                 case 'low_price_goods':
-                    $this->send_low_price_goods_notice();
+                    $this->send_low_price_goods_notice($company_id);
                     break;
                 case 'violation_product':
-                    $this->send_violation_product();
+                    $this->send_violation_product($company_id);
+                    break;
+                case 'violation_store':
+                    $this->send_violation_store($company_id);
                     break;
                 default:
                     break;
             }
         } catch (\Exception $e) {
-            print_r($e->getMessage());exit;
             Log::info('job_error', '订阅邮件通知推送队列失败', ['data' => $this->message_data, 'error' => $e->getMessage()]);
         }
     }
@@ -69,7 +73,7 @@ class SubEmailJobs implements ShouldQueue
      * @version 1.0
      * @date  2026-03-04
      */
-    private function send_low_price_goods_notice()
+    private function send_low_price_goods_notice($company_id)
     {
         $EmailVerifyCode = new EmailVerifyCode();
         $LowPriceGoodsMemberModel = new LowPriceGoodsMemberModel();
@@ -77,13 +81,14 @@ class SubEmailJobs implements ShouldQueue
         //获取今日待处理的商品记录
         $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();
+        $lowprice_ids = $LowPriceGoodsModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->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.company_id', $company_id)
             ->where([['personnel_employee.email', '!=', ''], ['personnel_employee.email', '!=', null]])
             ->select(['process_lowprice_product_member.*', 'personnel_employee.email'])
             ->get()->toArray();
@@ -116,7 +121,7 @@ class SubEmailJobs implements ShouldQueue
      * @version 1.0
      * @date  2026-03-04
      */
-    private function send_violation_product()
+    private function send_violation_product($company_id)
     {
         $EmailVerifyCode = new EmailVerifyCode();
         $ViolationProductMemberModel = new ViolationProductMemberModel();
@@ -124,13 +129,14 @@ class SubEmailJobs implements ShouldQueue
         //获取今日待处理的商品记录
         $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();
+        $violation_price_ids = $ViolationProductModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->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.open_notice', 0)
+            ->where('personnel_employee.company_id', $company_id)
             ->where([['personnel_employee.email', '!=', ''], ['personnel_employee.email', '!=', null]])
             ->select(['process_violation_product_member.*', 'personnel_employee.email'])
             ->get()->toArray();
@@ -158,6 +164,54 @@ class SubEmailJobs implements ShouldQueue
     }
 
 
+    /**
+     * 邮件消息消息订阅推送(禁止店铺)
+     * @author  唐远望
+     * @version 1.0
+     * @date  2026-03-04
+     */
+    private function send_violation_store($company_id){
+        $EmailVerifyCode = new EmailVerifyCode();
+        $ViolationStoreMemberModel = new ViolationStoreMemberModel();
+        $ViolationStoreModel = new ViolationStoreModel();
+        //获取今日待处理的店铺记录
+        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
+        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
+        $violation_price_ids = $ViolationStoreModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->pluck('id')->toArray();
+        if (empty($violation_price_ids)) return true;
+        //获取开启了通知服务的用户
+        $usert_list = $ViolationStoreMemberModel
+            ->whereIn('violation_store_logid', $violation_price_ids)
+            ->join('personnel_employee', 'process_violation_store_member.employee_id', '=', 'personnel_employee.id')
+            ->where('personnel_employee.open_notice', 0)
+            ->where('personnel_employee.company_id', $company_id)
+            ->where([['personnel_employee.email', '!=', ''], ['personnel_employee.email', '!=', null]])
+            ->select(['process_violation_store_member.*', 'personnel_employee.email'])
+            ->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]['email'] = $value['email'];
+                $user_data[$user_id]['log_ids'][] = $value['violation_store_logid'];
+            } else {
+                $user_data[$user_id]['log_ids'][] = $value['violation_store_logid'];
+            }
+        }
+        //发送邮件
+        foreach ($user_data as $key => $value) {
+            $email_to = $value['email'];
+            $totle_number = count($value['log_ids']);
+            $email_title = '禁止挂网店铺提醒';
+            $email_content = '今日待处理店铺共' . $totle_number . '条，请及时登录智价云系统处理。';
+            $EmailVerifyCode->sendSmtpEmail($email_to, $email_title, $email_content);
+        }
+    }
+
+
 
     public function failed(\Throwable $exception)
     {

app/Jobs/Manager/Process/SubSmsJobs.php

@@ -13,6 +13,8 @@ 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 App\Models\Manager\Process\ViolationStore as ViolationStoreModel;
+use App\Models\Manager\Process\ViolationStoreMember as ViolationStoreMemberModel;
 use Illuminate\Support\Carbon;
 use App\Facades\Servers\Sms\VerifyCode as Sms;
 
@@ -46,12 +48,16 @@ class SubSmsJobs implements ShouldQueue
     {
         try {
             $notice_type = $this->message_data['notice_type'];
+            $company_id = $this->message_data['company_id'];
             switch ($notice_type) {
                 case 'low_price_goods':
-                    $this->send_low_price_goods_notice();
+                    $this->send_low_price_goods_notice($company_id);
                     break;
                 case 'violation_product':
-                    $this->send_violation_product();
+                    $this->send_violation_product($company_id);
+                    break;
+                case 'violation_store':
+                    $this->send_violation_store($company_id);
                     break;
                 default:
                     break;
@@ -67,20 +73,21 @@ class SubSmsJobs implements ShouldQueue
      * @version 1.0
      * @date  2026-03-04
      */
-    private function send_low_price_goods_notice()
+    private function send_low_price_goods_notice($company_id)
     {
         $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();
+        $lowprice_ids = $LowPriceGoodsModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->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.company_id', $company_id)
             ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
             ->select(['process_lowprice_product_member.*', 'personnel_employee.mobile'])
             ->get()->toArray();
@@ -112,20 +119,21 @@ class SubSmsJobs implements ShouldQueue
      * @version 1.0
      * @date  2026-03-04
      */
-    private function send_violation_product()
+    private function send_violation_product($company_id)
     {
         $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();
+        $violation_price_ids = $ViolationProductModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->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.company_id', $company_id)
             ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
             ->select(['process_violation_product_member.*', 'personnel_employee.mobile'])
             ->get()->toArray();
@@ -142,7 +150,52 @@ class SubSmsJobs implements ShouldQueue
                 $user_data[$user_id]['log_ids'][] = $value['violation_product_logid'];
             }
         }
-        $sms_tpl_id =  config('verifycode.aliyun_process_process_violation_product.sms_tpl');
+        $sms_tpl_id =  config('verifycode.aliyun_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);
+        }
+    }
+    
+    /**
+     * 短信消息消息订阅推送(禁止店铺)
+     * @author  唐远望
+     * @version 1.0
+     * @date  2026-03-04
+     */
+    private function send_violation_store($company_id){
+        $ViolationStoreMemberModel = new ViolationStoreMemberModel();
+        $ViolationStoreModel = new ViolationStoreModel();
+        //获取今日待处理的店铺记录
+        $todayStart = Carbon::today()->startOfDay()->getTimestamp(); // 今天开始时间 00:00:00
+        $todayEnd = Carbon::today()->endOfDay()->getTimestamp(); // 今天结束时间 23:59:59
+        $violation_price_ids = $ViolationStoreModel->where([['insert_time', '>=', $todayStart], ['insert_time', '<=', $todayEnd], ['company_id', '=', $company_id]])->pluck('id')->toArray();
+        if (empty($violation_price_ids)) return true;
+        //获取开启了通知服务的用户
+        $usert_list = $ViolationStoreMemberModel
+            ->whereIn('violation_store_logid', $violation_price_ids)
+            ->join('personnel_employee', 'process_violation_store_member.employee_id', '=', 'personnel_employee.id')
+            ->where('personnel_employee.open_notice', 0)
+            ->where('personnel_employee.company_id', $company_id)
+            ->where([['personnel_employee.mobile', '!=', ''], ['personnel_employee.mobile', '!=', null]])
+            ->select(['process_violation_store_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_store_logid'];
+            } else {
+                $user_data[$user_id]['log_ids'][] = $value['violation_store_logid'];
+            }
+        }
+        $sms_tpl_id =  config('verifycode.aliyun_process_violation_store.sms_tpl');
         //发送短信
         foreach ($user_data as $key => $value) {
             $phone = $value['mobile'];
@@ -150,7 +203,6 @@ class SubSmsJobs implements ShouldQueue
             Sms::sendContent($phone, ['totle_number' => $totle_number], $sms_tpl_id);
         }
     }
-
 
 
     public function failed(\Throwable $exception)

config/verifycode.php

@@ -15,7 +15,15 @@ return [
         'sms_sign'      => env('VERIFYCODE_ALIYUN_SMS_SIGN', '开邻'),
         'sms_tpl'       => env('VERIFYCODE_ALIYUN_SMS_TPL', 'SMS_504730101'),
     ],
-    'aliyun_process_process_violation_product'=>[
+    'aliyun_process_violation_product'=>[
+        'sms_sign'      => env('VERIFYCODE_ALIYUN_SMS_SIGN', '开邻'),
+        'sms_tpl'       => env('VERIFYCODE_ALIYUN_SMS_TPL', 'SMS_505050131'),
+    ],
+    'aliyun_process_violation_store'=>[
+        'sms_sign'      => env('VERIFYCODE_ALIYUN_SMS_SIGN', '开邻'),
+        'sms_tpl'       => env('VERIFYCODE_ALIYUN_SMS_TPL', 'SMS_504745112'),
+    ],
+    'aliyun_process_merge_notice'=>[
         'sms_sign'      => env('VERIFYCODE_ALIYUN_SMS_SIGN', '开邻'),
         'sms_tpl'       => env('VERIFYCODE_ALIYUN_SMS_TPL', 'SMS_505050131'),
     ],