增加中兴注入

application/admin/controller/Video.php

@@ -149,7 +149,15 @@ class Video extends Backend
                     if ($rs) {
                         $rs = json_decode($rs, true);
                         if ($rs['code'] == 'A000000') {
-                            Db::name('video')->where(['id' => $id])->setField('inject_status', 1);
+                            //注入中兴
+                            $url2 = 'http://jscp.agency.gitv.tv/epgDataSync/v1/' . config('cspid_zx') . '/';
+                            $rs2 = httpRequest($url2, 'POST', $data, $header);
+                            if ($rs2) {
+                                $rs2 = json_decode($rs2, true);
+                                if ($rs2['code'] == 'A000000') {
+                                    Db::name('video')->where(['id' => $id])->setField('inject_status', 1);
+                                }
+                            }
                         }
                     }
 

application/api/controller/Notify.php

@@ -783,6 +783,7 @@ class Notify extends Api
         $method = 'POST';
 
         foreach ($list as &$v) {
+            //查询华为注入结果
             $url = 'http://jscp.agency.gitv.tv/injectResult/v1/queryTv?cspId=' . config('cspid') . '&cpAlbumId=' . $v['id'] . '&cpTvId=' .  $v['id'];
             $rs = httpRequest($url, 'GET', [], $header);
             if (!$rs) {
@@ -834,7 +835,23 @@ class Notify extends Api
                 if ($rt['code'] != 'A000000') {
                     continue;
                 }*/
-                $hu_video->where(['id' => $v['id'], 'inject_status' => 1])->setField(['inject_status' => 2, 'seriesid' => $data['seriesId'], 'programid' => $data['programId'], 'movieid' => $data['movieId']]);
+
+                //查询中兴注入结果
+                $url2 = 'http://jscp.agency.gitv.tv/injectResult/v1/queryTv?cspId=' . config('cspid_zx') . '&cpAlbumId=' . $v['id'] . '&cpTvId=' .  $v['id'];
+                $rs2 = httpRequest($url2, 'GET', [], $header);
+                if (!$rs2) {
+                    continue;
+                }
+                $rs2 = json_decode($rs2, true);
+                if ($rs2['code'] != 'A000000') {
+                    continue;
+                }
+                $data2 = $rs2['data'][0];
+                if ($data2['taskStatus'] == 2) {
+                    $hu_video->where(['id' => $v['id'], 'inject_status' => 1])->setField(['inject_status' => 2, 'seriesid' => $data['seriesId'], 'programid' => $data['programId'], 'movieid' => $data['movieId']]);
+                } elseif ($data2['taskStatus'] == -1 || $data2['taskStatus'] == -3 || $data2['taskStatus'] == -4) {
+                    $hu_video->where(['id' => $v['id'], 'inject_status' => 1])->setField(['inject_status' => 3, 'seriesid' => $data['seriesId'], 'programid' => $data['programId'], 'movieid' => $data['movieId']]);
+                }
             } elseif ($data['taskStatus'] == -1 || $data['taskStatus'] == -3 || $data['taskStatus'] == -4) {
                 $hu_video->where(['id' => $v['id'], 'inject_status' => 1])->setField(['inject_status' => 3, 'seriesid' => $data['seriesId'], 'programid' => $data['programId'], 'movieid' => $data['movieId']]);
             }
@@ -939,4 +956,68 @@ class Notify extends Api
     public function ordersync() {
         
     }
+
+    //(补漏)视频注入中兴
+    public function injectzx() {
+        set_time_limit(0);
+
+        $hu_video = Db::name('video');
+        $list = $hu_video->limit(50)->select();
+
+        if (!$list) {
+            echo 'mei shu ju';
+            die;
+        }
+
+        $cspid = config('cspid_zx');
+        $url = 'http://jscp.agency.gitv.tv/epgDataSync/v1/' . $cspid . '/';
+
+        foreach ($list as &$params) {
+            //内容同步
+            $videofile = $params['videofile'];
+            $videofile = explode('/', $videofile);
+            $video_url = $videofile[3];
+            $data = [
+//                        'cspId' => $cspid,
+                'cpAlbumId' => $params['id'],
+                'albumName' => $params['title'],
+                'tvSets' => 1,
+                'updateToSet' => 1,
+                'isPurchase' => $params['is_pay'],
+                'isEffective' => $params['status'],
+                'isOnline' => $params['status'],
+                'albumTypes' => '健康',
+                'picBox' => config('upload.cdnurl') . $params['image'],
+                'albumUpdateTime' => date('YmdHis', time()),
+                'albumCreateTime' => date('YmdHis', time()),
+                'tvlist' => [
+                    [
+                        'cpAlbumId' => $params['id'],
+                        'cpTvId' => $params['id'],
+                        'tvName' => $params['title'],
+                        'tvIsEffective' => $params['status'],
+                        'tvIsOnline' => $params['status'],
+                        'isPurchase' => $params['is_pay'],
+                        'playOrder' => 1,
+                        'tvUrl' => 'ftp://'.config('ftp_user').':'.config('ftp_pwd').'@'.config('ftp_ip').':'.config('ftp_port').'/'.$video_url
+                    ]
+                ]
+            ];
+
+            $data = json_encode($data, 320);
+            $header = [
+                'Content-Type: application/json'
+            ];
+            $rs = httpRequest($url, 'POST', $data, $header);
+            if ($rs) {
+                $rs = json_decode($rs, true);
+                if ($rs['code'] != 'A000000') {
+                    continue;
+                }
+            }
+        }
+
+        echo 'wan bi';
+        die;
+    }
 }