pfhwyigou/backend/server/SyncNews.php

<?php
/**
 * Created by PhpStorm.
 * User: xiaofeng
 * Date: 2018/3/12
 * Time: 上午9:57
 * 同步资讯
 */

namespace backend\server;

use Imagine\Image\ManipulatorInterface;
use yii\imagine\Image;
use common\models\CategoryWatermark;
use Yii;
use common\models\News;
use linslin\yii2\curl;

class SyncNews
{
    public $type = null;

    public function NewsList($input)
    {
        if (!empty($input['site']) && is_array($input['site'])) {
            $rows = News::find()->andWhere(['pfg_news.id' => $input['id']])
                ->select(['pfg_house.name as h_name', 'pfg_category_news.news_name', 'pfg_category_city.city_name', 'pfg_news.*'])
                ->leftJoin('pfg_house', 'pfg_news.hid = pfg_house.id')
                ->leftJoin('pfg_category_news', 'pfg_news.category = pfg_category_news.id')
                ->leftJoin('pfg_category_city', 'pfg_news.city = pfg_category_city.id')
                ->asArray()
                ->all();

            if ($rows) {
                foreach ($rows as &$val) {
                    if (!empty($val['thumb'])) {
                        $val['thumb'] = json_decode($val['thumb'], true);
                    }
                }

            }

            $curl = new curl\Curl();

            foreach ($input['site'] as $v) {
                $response = $curl->setPostParams([
                    'data' => $rows,
                    'url' => Yii::$app->params['httpImg']['host'] . Yii::$app->params['httpImg']['newsthumb'],
                    'source' => '11111'
                ])->post($v);
            }
            return $response;
        }
    }

    //资讯同步接收
    public function newsOpe($input)
    {
        $this->type = $input['type'];
        $oss_url = $input['url'];//资讯缩略图url
        $data = $input['data'];//资讯信息
        try {
            $Transaction = Yii::$app->db->beginTransaction();
            $arr = [];
            $arr['subject'] = $data['subject'];
            $arr['thumb'] = $this->PullImg(json_decode($data['thumb'], true), $oss_url);
//            $arr['thumb'] = $data['thumb'];
            $arr['abstract'] = $data['abstract'];
            $arr['author'] = $data['author'];
            if(trim($data['source']) == '同步站'){
                $arr['source'] = '易购房';
            }else{
                $arr['source'] = $data['source'];
            }
            $arr['sort'] = $data['sort'];
            $arr['clicks'] = $data['clicks'];
            $arr['state'] = $data['state'];
            if (isset($data['city_name']) && !empty($data['city_name'])) {
                $arr['city'] = $this->CityColumn($data['city_name'], $data['level']);
            }
            if ((isset($data['house_name']) || isset($data['unid'])) && !empty($data['house_name'])) {
                $arr['hid'] = $this->HouseColumn($data['house_name'], $data['unid']);
            }
            $arr['category'] = $this->NewsColumn($data['news_category']);
            $arr['content'] = $data['content'];
            $arr['del'] = $data['del'];
            $arr['create_at'] = $_SERVER['REQUEST_TIME'];
            $arr['update_at'] = $_SERVER['REQUEST_TIME'];
            $arr['open_time'] = $data['open_time'];
            $arr['thumb_size'] = $data['thumb_size'];
            $arr['short_subject'] = $data['short_subject'];
            $arr['true_click'] = $data['true_click'];
            $newsInfo = $this->exetNews($data);
            if($this->type == 1){
                $news = 'pfg_news';
            }elseif($this->type == 2){
//                $news = 'pfg_news';
            }
            if ($newsInfo) {
                //资讯存在
                $row = Yii::$app->db->createCommand()->update($news, $arr, 'id = ' . $newsInfo['id'])->execute();
                $thisid = $newsInfo['id'];
                $code = 'edit';
            } else {
                //资讯不存在
                $row = Yii::$app->db->createCommand()->insert($news, $arr)->execute();
                $thisid = Yii::$app->db->getLastInsertID();
                $code = 'add';
            }
            if ($row > 0) {
                $syncInfo = [];
                $syncInfo['this_content'] = json_encode($newsInfo);//原数据
                $syncInfo['content'] = json_encode($arr);//同步数据
                $syncInfo['audit_name'] = $input['auditor_name'];//审核人
                $syncInfo['unid'] = $data['unid'];
                $syncInfo['own_newsid'] = $thisid;
                $syncInfo['type'] = $this->type;
                $syncInfo['code'] = $code;
                $sync = Yii::$app->db->createCommand()->insert('pfg_syncnewsrecord', $syncInfo)->execute();
                if ($sync > 0) {
                    $Transaction->commit();
                    return true;
                } else {
                    $Transaction->rollBack();
                    return '添加记录表失败';
                }
            } else {
                $Transaction->rollBack();
                return '插入/修改信息失败(可能已存在完全相同的资讯信息)';
            }
        } catch (\Exception $e) {
            return $e->getMessage();
        }
    }

    /*
     *检测资讯是否存在
     * */
    public function exetnews($data)
    {
        if($this->type == 1){
            $state = \common\models\Syncnewsrecord::find()->andWhere(['unid' => $data['unid']])->one();
            if(!empty($state)){
                return \common\models\News::find()->andWhere(['id' => $state['own_newsid']])->asArray()->one();
            }
            return \common\models\News::find()->andWhere(['subject' => $data['subject']])->one();
        }elseif($this->type == 2){

        }
    }

    /*
     * 转换资讯栏目
     */
    private function NewsColumn($name)
    {
        if($this->type == 1){
            $model = \common\models\CategoryNews::find()->andWhere(['news_name' => $name])->andWhere(['del' => 1])->one();
            if ($model) {
                return $model['id'];
            } else {
                $rows = new \common\models\CategoryNews();
                $rows->news_name = $name;
                if ($rows->save()) {
                    return $rows->attributes['id'];
                }
            }
        }elseif($this->type == 2){

        }
        throw new \Exception('未检测到资讯栏目：' . $name);
    }

    /*
     * 转换区域ID
     */
    public function CityColumn($city, $level = 1)
    {
        if (!empty($city)) {
            if($this->type == 1){
                $row = \common\models\CategoryCity::find()->andFilterWhere(['like','city_name',$city])->andWhere([ 'del' => 1, 'level' => $level])->one();
                if ($row) {
                    return $row['id'];
                }
            }elseif($this->type ==2){

            }
            throw new \Exception('未检测到区域：' . $city);
        }
    }


    /*
 * 转换楼盘ID
 */
    public function HouseColumn($hname, $unid)
    {
        if($this->type == 1){
            if (!empty($hname)) {
                $row = \common\models\House::find()->andWhere(['name' => $hname, 'del' => 1])->one();
                if ($row) {
                    return $row['id'];
                }
            }
            if (!empty($unid)) {
                $row = \common\models\Synchouserecord::find()->andWhere(['unid' => $unid])->one();
                if ($row) {
                    return $row['own_hid'];
                }
            }
        }elseif($this->type == 2){

        }
        throw new \Exception('未检测到楼盘信息：' . $hname);
    }

    /*
     * 拉取图片
     */
    private function PullImg($img, $oos)
    {
        if (is_array($img) && !empty($img)) {
            foreach ($img as $val) {
                $curl = new curl\Curl();
                $resultImg = $curl->get($oos . $val);
                $imgUrl = Yii::$app->params['img_url']['news'];
                if (!is_file($imgUrl . $val)) {
                    if (!file_put_contents($imgUrl . $val, $resultImg)) {
                        throw new \Exception('图片添加失败，请联系管理员');
                    }
                }
            }
            return json_encode(array_values($img));
        }

    }

}