中心接口：增加媒资自动推送逻辑

SooonerHotel/App/Lib/Action/Api/CenterAction.class.php

@@ -51,6 +51,8 @@ class CenterAction extends Action
     /**
      * 修改云端片库媒资信息
      *  参数:
+     *      spid
+     *      push_mode : 是否转推:0不转推,1转推(写入酒店片库)
      *      url :   华数媒资详情url
      */
     public function media_update(){
@@ -110,12 +112,16 @@ class CenterAction extends Action
             }
         }else{
             $id = $model->add($data);
+            $data["id"]=$id;
             if($id){
                 echo 'true';
             }else{
                 echo 'false';
             }
         }
+
+        $this->media_auto_push($data);
+
         exit;
     }
     function null2str($str){
@@ -124,6 +130,40 @@ class CenterAction extends Action
         }
         return $str;
     }
+    /*
+     * 媒资自动转推函数
+     * 批量修改媒资状态
+     * 批量推送添加
+     */
+    function media_auto_push(&$data){
+        $sp_id=$data["sp_id"];
+        $media_id = $data["id"];
+        $status = $data["status"];
+
+        $updateSQL="UPDATE sh_hotel_media_map_$sp_id SET status=$status WHERE media_id=$media_id;";
+        M('')->execute($updateSQL);
+
+        $sql ="SELECT h.id,hm.media_id FROM sh_hotel h"
+            ." LEFT JOIN (SELECT media_id,hotel_id FROM sh_hotel_media_map_$sp_id WHERE media_id=$media_id) hm ON h.id=hm.hotel_id"
+            ." WHERE media_id IS NULL;";
+        $arr = M("")->query($sql);
+
+//        var_dump($arr);
+
+        foreach ($arr as $item){
+            $dataList[]=array("media_id"=>$media_id,"hotel_id"=>$item["id"],"status"=>$status,"status_inject"=>0);
+        }
+
+        if (!empty($dataList)){
+            M("$sp_id","sh_hotel_media_map_")->addAll($dataList);
+        }
+    }
+    public function test_auto_push(){
+        $data["sp_id"]=1;
+        $data["id"]=300;
+        $data["status"]=2;
+        $this->media_auto_push($data);
+    }
 
     /**
      * 增量媒资变更列表