推送人去重

application/api_broker/service/PushMessageService.php

@@ -48,7 +48,7 @@ class PushMessageService
             $house       = new GHouses();
             $m_report    = new OReportModel();
 
-            $data       = $house_agent->getHousesAgents($house_id, 'b.id', [ 'type' => $type ]);
+            $data       = $house_agent->getHousesAgents($house_id, 'b.id', [ 'a.type' => $type,'a.is_del'=>0 ]);
             $agent_name = $agent->getAgentsStoreById([ 'a.id' => $agent_id ], 'name,store_name');
             $house_data = $house->getHouseDetail('internal_title', [ 'id' => $house_id ]);
             $order_id = $m_report->getReportOrder('b.id',['a.report_agent_id'=>$agent_id]);

application/model/GHousesToAgents.php

@@ -278,22 +278,23 @@ class GHousesToAgents extends BaseModel
      * 楼盘对应的经纪人信息
      *
      * @param $houses_id
-     * @param string $feild
+     * @param string $field
      * @param string $where
      * @return false|\PDOStatement|string|\think\Collection
      * @throws \think\db\exception\DataNotFoundException
      * @throws \think\db\exception\ModelNotFoundException
      * @throws \think\exception\DbException
      */
-    public function getHousesAgents($houses_id, $feild = 'b.id,name,a.type,b.phone', $where = '')
+    public function getHousesAgents($houses_id, $field = 'b.id,name,a.type,b.phone', $where = '')
     {
-        $select_data = $this->field($feild)->alias('a')
+        $select_data = $this->field($field)->alias('a')
             ->join('a_agents b', 'a.agents_id = b.id', 'LEFT')
             ->where([
                 'houses_id' => $houses_id,
                 'is_del' => 0
             ])
             ->where($where)
+            ->group('a.agents_id')
             ->select();
 
         return $select_data;