pfhwyigou/backend/controllers/OthersyncController.php

<?php

/**
 * Created by PhpStorm.
 * User: xiaofeng
 * Date: 2018/4/3
 * Time: 下午5:14
 * 邮箱设置
 */

namespace backend\controllers;
use Yii;
use backend\base\Help;
use backend\base\CommonController;
use linslin\yii2\curl;
use common\models\Syncrecord;
use common\models\House;
use common\models\HouseDetail;
use common\models\HouseAlbum;
use backend\synchouse\ParamsHandle;
use backend\synchouse\ContrastLabel;
class OthersyncController extends CommonController
{
        const URL = 'http://oss.pf.com/';
        //operation_type 记录操作楼盘里  1=>添加，2=>修改，3=>相册操作，
        public $type = [
                1=>'楼盘参数',
                2=>'楼盘相册',
                3=>'楼盘户型',
                4=>'周边配套',
                5=>'预售证',
                6=>'历史价格',
        ];

        public $Operation = [
                1=>'添加',
                2=>'修改'
        ];
        public function actionIndex()
        {
            return $this->render('index');
        }

        public function actionIndexform()
        {
            $response = $this->CurlRequest(static::URL.'sync/houseall',Yii::$app->request->post());
            if(!empty($response))
            {
                return Help::JsonData(0,Yii::t('app','get_success'),$response['count'],$response['data']);
            }
        }

        //楼盘信息
        public function actionHouseinfo()
        {
            $row = $this->CurlRequest('http://oss.pf.com/sync/houseoneinfo',Yii::$app->request->get());
             if($row['code'] == 200)
             {
                 //查询是否同步过,无论修改或者添加
                 $Contrast = new ParamsHandle();
                 $unid = $Contrast->Existsunid($row['data']['uniqid']);
                 $name = $Contrast->ExistsName($row['data']['name']);
                 if($unid === false && $name === false)
                 {
                    $msg = [
                        'code'=>1,
                        'msg'=>'未检测到该楼盘信息，可直接添加。'
                    ];
                     return $this->render('houseinfo',['details'=>$row['data'],'msg'=>$msg]);
                 }
                 else
                 {
                     //查询出自己的楼盘信息
                     $query = \common\models\House::find();
                     $query->select(['pfg_house.*','pfg_house_detail.*']);
                     $query->andWhere(['pfg_house.del'=>1]);
                     $query->andWhere(['pfg_house.id'=>$name['id']]);
                     $FindHouse = $query->leftJoin('pfg_house_detail','pfg_house.id=pfg_house_detail.hid')->asArray()->one();

                     $FindHouse = $this->convertLabel($FindHouse); //转换标签


                     $dirty  = []; //远程楼盘
                     $sample = [];//本地楼盘

                     foreach ($FindHouse as $key=>$val)
                     {
                        if($key == 'id' || $key == 'update_at' || $key == 'create_at' || $key == 'hid') continue;

                         if(isset($row['data'][$key]))
                         {
                             if($FindHouse[$key] != $row['data'][$key])
                             {
                                 $dirty[$key] = $row['data'][$key];
                                 $sample[$key] = $FindHouse[$key];
                             }
                         }
                     }

                     if(!empty($dirty) && !empty($sample))
                     {
                         $this->HouseLabelsDiff($dirty,$sample);
                         $m = new \common\models\House();
                         $f = new \common\models\HouseDetail();

                         $mLabels = $m->attributeLabels();      //获取数据表里字段的描述
                         $fLabels = $f->attributeLabels();       //获取数据表里字段的描述
                         $data['mLabels'] = $mLabels;
                         $data['fLabels'] = $fLabels;
                         $data['dirty'] = $dirty;
                         $data['sample'] = $sample;

                         if(isset($dirty['thumb']) && !empty($dirty['thumb']))
                         {
//                             $dirty['thumb'] = Yii::$app->
                         }
                     }

                     $msg = [
                         'code'=>2,
                         'msg'=>'该楼盘已存在，可直接修改。'
                     ];
                     $data['details'] = $row['data'];
                     $data['msg'] = $msg;
                     $data['hid'] = $FindHouse['id'];
                     return $this->render('houseinfoedit',$data);
                 }

             }
        }

        //相册
        public function actionHousealbum()
        {
            $row = $this->CurlRequest(static::URL.'sync/album',Yii::$app->request->get());
            if($row['code'] == 200)
            {
                    $data = $row['data']['data'];
                    $dataArr = [];
                    foreach ($data as $key=>$val)
                    {
                        $dataArr[$val['name']][] = $val;
                    }
                return $this->render('housealbum',['hid'=>Yii::$app->request->get('hid'),'model'=>$dataArr,'url'=>$row['data']['url'],'style'=>$row['data']['style']]);
            }
        }

        //相册添加或修改
        public function actionHouseallbumform()
        {
            $row = $this->CurlRequest(static::URL.'sync/album',Yii::$app->request->post('data'));
            if($row['code'] == 300)   return Help::JsonCode(Help::ERROR,Yii::t('app','edit_error'));
            $data = $row['data']['data'];
            $unid = $data[0]['uniqid'];
            $Contrast = new ParamsHandle();
            $unidex = $Contrast->Existsunid($unid);
            if(!empty($unidex))
            {
                $hid = $unidex['id'];
            }
            else
            {
                $name = $Contrast->ExistsName($row['data']['name']);
                if(empty($name))  return Help::JsonCode(Help::ERROR,'未检测到该楼盘相关信息，请先添加楼盘信息。');
                $hid = $name['id'];
            }
            $albumLabel = \common\models\CategoryAlbum::find()->select(['id','name'])->andWhere(['del'=>1])->asArray()->all();
            $Label = array_column($albumLabel,'id','name');
            $model = new \common\models\HouseAlbum();
            $record = [];
            $Tran = Yii::$app->db->beginTransaction();
            foreach ($data as &$val)
            {
                if(isset($Label[$val['name']]))
                {
                    $_model  = clone $model;
                    $exists = $_model::find()->andWhere(['del'=>1])->andWhere(['img'=>$val['img']])->andWhere(['hid'=>$hid])->one();
                    if($exists == null)
                    {
                        $_model->title = $val['title'];
                        $_model->img   = $val['img'];
                        $_model->album_id   = $Label[$val['name']];
                        $_model->hid = $hid;
                        if($_model->save() == false)
                        {
                            $Tran->rollBack();
                        }
                        $val['aid'] = $Label[$val['name']];
                        $record[] = $val;
                    }
                }
                else
                {
                    return  Help::JsonCode(Help::ERROR,'未检测到-'.$val['name'].'类目信息，请联系管理员添加。');
                }
            }
            if(!empty($record))
            {
                $rec = new \common\models\Syncrecord();
                $inp['uid'] = Yii::$app->session['user_info']['uid'];
                $inp['hid'] = $hid;
                $inp['operation_type'] = 3;
                $inp['content'] = json_encode($record);
                $inp['unid'] = $unid;
                $rec->Record($inp);
            }
                $Tran->commit();
                return Help::JsonCode(Help::SUCCESS,Yii::t('app','edit_success'));
        }

        //户型
        public function actionHousetype()
        {
                
        }
        
        //户型修改或添加
        public function actionHousetypeform()
        {
            
        }



        //添加楼盘信息
        public function actionHouseadd()
        {
            $input = Yii::$app->request->post();

            switch ($input['sync'])
            {
                case 1:

                    $input = $this->convertLabel($input);
                    $result = $this->HouseCreate($input);
                    break;
                case 2:
                    $result = $this->HouseEdit($input);
                    break;
            }
            if($result === true)
            {
                return Help::JsonCode(Help::SUCCESS,Yii::t('app','edit_success'));
            }
                return Help::JsonCode(Help::ERROR,Yii::t('app','edit_error'));
        }


        public function HouseCreate($input)
        {
            if(!is_array($input)) return false;
            $model = new House();
            unset($input['id']);
            $con = new ContrastLabel();
            $input['characteristic']    = $con->addArrJson($input['characteristic']);
            $input['architecture_type'] = $con->addArrJson($input['architecture_type']);
            $input['property_tag']      = $con->addArrJson($input['property_tag']);
            $input['type']              = $con->addArrJson($input['type']);
            $city = $con->HouseCity($input['city']);
            if(!empty($city))
            {
                $input['city']              =  $city['id'];
            }
            $Transaction = Yii::$app->db->beginTransaction();

            $model->load($input,'');

            $model->save(false);

            $details = new HouseDetail();
            $details->load($input,'');
            $details->hid = $model->attributes['id'];
            $input['hid'] = $model->attributes['id'];
            $record = new \common\models\Syncrecord();
            $recordArr = [
                'uid'=>Yii::$app->session['user_info']['uid'],
                'hid'=>$model->attributes['id'],
                'operation_type'=>1,
                'content' =>json_encode($input),
                'unid'    =>  $input['uniqid']
            ];
            $record->uid = Yii::$app->session['user_info']['uid'];
            $record->hid = $model->attributes['id'];
            $record->operation_type = 1;
            $record->content =
            $record->create_at = $_SERVER['REQUEST_TIME'];
            $record->unid = $input['uniqid'];
            if($details->save(false) === true && is_numeric($model->attributes['id']) && $record->save(false) === true)
            {
                $Transaction->commit();
                return true;
            }
                $Transaction->rollBack();
                return false;
        }

        //修改逻辑
        public function HouseEdit($input)
        {


            $model = new House();
            $one = $model->FindById($input['hid']);
            $modelDetaols = new HouseDetail();
            $oneDetails = $modelDetaols->FindById($input['hid']);
            $inputArr = $input['data'];
            $con = new ContrastLabel();
            if(isset($inputArr['architecture_type']) && !empty($inputArr['architecture_type']))
            {
                $inputArr['architecture_type']    = $con->HouseAlllabel(json_encode($inputArr['architecture_type']),2);
                $tag = array_flip($inputArr['architecture_type']);
                $jsonArr = json_decode($one->architecture_type,true);
                $input['data']['architecture_type'] = '["'.implode('","', array_unique(array_values(array_merge($jsonArr,$tag)))).'"]';
            }

            if(isset($inputArr['type']) && !empty($inputArr['type']))
            {
                $inputArr['type']    = $con->HouseAlllabel(json_encode($inputArr['type']),1);

                $tag = array_flip($inputArr['type']);
                $input['data']['type'] = '["'.implode('","', array_unique(array_values(array_merge($tag,json_decode($one->type,true))))).'"]';
            }

            if(isset($inputArr['characteristic']) && !empty($inputArr['characteristic']))
            {
                $inputArr['characteristic']    = $con->HouseCharacteristic(json_encode($inputArr['characteristic']));
                $tag = array_flip($inputArr['characteristic']);
                $input['data']['characteristic'] = '["'.implode('","', array_unique(array_values(array_merge($tag,json_decode($one->characteristic,true))))).'"]';
            }

            if(isset($inputArr['property_tag']) && !empty($inputArr['property_tag']))
            {
                $inputArr['property_tag']    = $con->HouseAlllabel(json_encode($inputArr['property_tag']),3);
                $tag = array_flip($inputArr['property_tag']);
                if(is_numeric($oneDetails->property_tag))
                {
                    $proArr[] = $oneDetails->property_tag;
                    $oneDetails->property_tag = json_encode($proArr);
                }
                $input['data']['property_tag'] = '["'.implode('","', array_values(array_unique(array_merge($tag,json_decode($oneDetails->property_tag,true)))) ).'"]';
            }

            $one->load($input['data'],'');
            $oneDetails->load($input['data'],'');

            $resuleA = $one->save(false);
            $resuleB = $oneDetails->save(false);

            $recordArr = [
                'uid'=>Yii::$app->session['user_info']['uid'],
                'hid'=>$input['hid'],
                'operation_type'=>2,
                'content' =>json_encode($input),
                'unid'    =>  $input['unid']
            ];
            $rec = new \common\models\Syncrecord();
            $rec->Record($recordArr);
            if($resuleA || $resuleB)
            {
                return true;
            }

        }

        //对比楼盘标签，如果相同就删除掉
        public function HouseLabelsDiff(&$a,&$b)
        {
            if(!empty($a['characteristic']) && !empty( $b['characteristic']))
            {
                $sub =  \common\models\Characteristic::find()->andWhere(['del'=>1])->andWhere(['name'=>$a['characteristic']])->asArray()->all();
                $a['characteristic'] = array_column($sub,'name','id');
                $char = array_diff($a['characteristic'],$b['characteristic']);
                if(empty($char))
                {
                    unset($a['characteristic']);
                    unset($b['characteristic']);
                }
            }

            if(!empty($a['architecture_type']) && !empty( $b['architecture_type']))
            {
                $sub =  \common\models\CategoryLabel::find()->andWhere(['del'=>1])->andWhere(['type'=>2])->andFilterWhere(['in', 'name', $a['architecture_type']])->asArray()->all();
                $a['architecture_type'] = array_column($sub,'name','id');
                $char = array_diff($a['architecture_type'],$b['architecture_type']);
                if(empty($char))
                {
                    unset($a['architecture_type']);
                    unset($b['architecture_type']);
                }
            }

            if(!empty($a['type']) && !empty( $b['type']))
            {
                $sub =  \common\models\CategoryLabel::find()->andWhere(['del'=>1])->andWhere(['type'=>1])->andFilterWhere(['in', 'name', $a['type']])->asArray()->all();
                $a['type'] = array_column($sub,'name','id');
                $char = array_diff($a['type'],$b['type']);
                if(empty($char))
                {
                    unset($a['type']);
                    unset($b['type']);
                }
            }


            if(!empty($a['property_tag']) && !empty( $b['property_tag']))
            {
                $sub =  \common\models\CategoryLabel::find()->andWhere(['del'=>1])->andWhere(['type'=>3])->andFilterWhere(['in', 'name', $a['property_tag']])->asArray()->all();
                $a['property_tag'] = array_column($sub,'name','id');
                $char = array_diff($a['property_tag'],$b['property_tag']);
                if(empty($char))
                {
                    unset($a['property_tag']);
                    unset($b['property_tag']);
                }
            }

        }

        private function convertLabel($FindHouse)
        {
            $con = new ContrastLabel();
            $FindHouse['characteristic']    = $con->HouseCharacteristic($FindHouse['characteristic']);
            $FindHouse['architecture_type'] = $con->HouseAlllabel($FindHouse['architecture_type'],2);
            $FindHouse['property_tag']      = $con->HouseAlllabel($FindHouse['property_tag'],3);
            $FindHouse['type']              = $con->HouseAlllabel($FindHouse['type'],1);
            $FindHouse['hot']               = $con->HouseHot($FindHouse['hot']);
            $FindHouse['is_push']              = $con->HouseisPush($FindHouse['is_push']);
            $FindHouse['fit']                = $con->HouseFit($FindHouse['fit']);
            $FindHouse['state']              = $con->HouseState($FindHouse['state']);
            return $FindHouse;
        }

        //请求。
        public function CurlRequest($url,$post = null)
        {
            $curl = new curl\Curl();
            $response = $curl->reset()
                ->setOption(
                    CURLOPT_POSTFIELDS,
                    http_build_query(
                        $post
                    ))
                ->post($url);

            if(!empty($response))
            {
                return json_decode($response,true);
            }
        }

}