浏览代码

公众号取实时数据

zqwang 1 年之前
父节点
当前提交
11dd465fed

+ 12 - 1
modules/WechatPlatform/Services/WechatKeywordsService.php

@@ -52,6 +52,13 @@ class WechatKeywordsService extends BaseService
             $list = $sql->paginate(getProp($param, 'limit', 10));
             $list = $sql->paginate(getProp($param, 'limit', 10));
         }
         }
         $list->makeHidden(self::$hideField);
         $list->makeHidden(self::$hideField);
+
+        foreach ($list as  $val){
+            $val->wechat_accounts =  WechatAccountKeywordLog::query()->where(
+                ['weacht_keyworld_id' => $val->id,
+                    'status' => 1
+                ])->select('wechat_authorization_info_id as id',"appid",'nick_name')->get();;
+        }
         return $list;
         return $list;
     }
     }
 
 
@@ -71,7 +78,11 @@ class WechatKeywordsService extends BaseService
             $sql->where('miniprogram_id', $param['miniprogram_id']);
             $sql->where('miniprogram_id', $param['miniprogram_id']);
         }
         }
         if (getProp($param, 'wechat_authorization_info_id')) {
         if (getProp($param, 'wechat_authorization_info_id')) {
-            $sql->whereJsonContains('wechat_accounts->id', $param['wechat_authorization_info_id']);
+            $ids = WechatAccountKeywordLog::query()->where([
+                'wechat_authorization_info_id' => $param['wechat_authorization_info_id'],
+                'status' => 1,
+            ])->pluck('weacht_keyworld_id')->toArray();
+            $sql->whereIn('id',$ids);
         }
         }
         return $sql;
         return $sql;
     }
     }

+ 10 - 1
modules/WechatPlatform/Services/WechatMenuService.php

@@ -310,6 +310,12 @@ class WechatMenuService extends BaseService
         } else {
         } else {
             $list = $sql->paginate(getProp($param, 'limit', 10));
             $list = $sql->paginate(getProp($param, 'limit', 10));
         }
         }
+        foreach ($list as $val){
+            $val->wechat_accounts =  WechatAccountMenuDetail::query()->where(
+                ['subscribe_id' => $val->id,
+                    'status' => 1
+                ])->select('wechat_authorization_info_id as id',"appid",'nick_name')->get();
+        }
         return $list;
         return $list;
     }
     }
 
 
@@ -329,7 +335,10 @@ class WechatMenuService extends BaseService
             $sql->where('miniprogram_id', $param['miniprogram_id']);
             $sql->where('miniprogram_id', $param['miniprogram_id']);
         }
         }
         if (getProp($param, 'wechat_authorization_info_id')) {
         if (getProp($param, 'wechat_authorization_info_id')) {
-            $sql->whereJsonContains('wechat_accounts->id', $param['wechat_authorization_info_id']);
+            $ids = WechatAccountMenuDetail::query()->where([
+                'wechat_authorization_info_id' => $param['wechat_authorization_info_id'],
+                'status' => 1,
+            ])->pluck('weacht_keyworld_id')->toArray();
         }
         }
         return $sql;
         return $sql;
     }
     }

+ 11 - 1
modules/WechatPlatform/Services/WechatSubscribeService.php

@@ -241,6 +241,12 @@ class WechatSubscribeService extends BaseService
             $list = $sql->paginate(getProp($param,'limit',10));
             $list = $sql->paginate(getProp($param,'limit',10));
         }
         }
         $list->makeHidden(array_merge(self::$hideField));
         $list->makeHidden(array_merge(self::$hideField));
+        foreach ($list as  $val){
+            $val->wechat_accounts =  WechatAccountSubscribeDetail::query()->where(
+                ['subscribe_id' => $val->id,
+                    'status' => 1
+                ])->select('wechat_authorization_info_id as id',"appid",'nick_name')->get();
+        }
         return $list;
         return $list;
     }
     }
 
 
@@ -260,7 +266,11 @@ class WechatSubscribeService extends BaseService
             $sql->where('miniprogram_id',  $param['miniprogram_id']);
             $sql->where('miniprogram_id',  $param['miniprogram_id']);
         }
         }
         if(getProp($param,'wechat_authorization_info_id')){
         if(getProp($param,'wechat_authorization_info_id')){
-            $sql->whereJsonContains('wechat_accounts->id',$param['wechat_authorization_info_id']);
+            $ids = WechatAccountSubscribeDetail::query()->where([
+                    'wechat_authorization_info_id' => $param['wechat_authorization_info_id'],
+                    'status' => 1,
+                ])->pluck('weacht_keyworld_id')->toArray();
+            $sql->whereIn('id',$ids);
         }
         }
         return $sql;
         return $sql;
     }
     }