<?php
// +----------------------------------------------------------------------
// | ThinkCMF [ WE CAN DO IT MORE SIMPLE ]
// +----------------------------------------------------------------------
// | Copyright (c) 2013-2017 http://www.thinkcmf.com All rights reserved.
// +----------------------------------------------------------------------
// | Author: wuwu <15093565100@163.com>
// +----------------------------------------------------------------------
namespace api\portal\controller;


use api\portal\model\AgencyModel;
use api\portal\model\MoneyDetailModel;
use api\portal\model\OrderModel;
use api\portal\model\RefundModel;
use api\portal\model\UserNeedModel;
use cmf\controller\HomeBaseController;
use api\portal\model\PortalPostModel;
use cmf\controller\RestBaseController;
use think\Db;
use think\Request;
use think\Loader;
use think\Config;
use think\captcha\Captcha;
use think\Url;
use SmsDemo;
//use think\Route;
/**
 * @title 订单修改
 * @description 接口说明
 * @group 接口分组
 */

class ThirdsendController extends HomeBaseController
{
    protected $postModel;
    protected $refund;
    public function __construct(PortalPostModel $postModel)
    {
        parent::__construct();
        $this->postModel = $postModel;
    }

    public function _initialize()
    {
        $this->refund = controller('Alipay','controller');
    }

    /**
     *  API返回信息格式函数 ；0失败，1成功，-1需要登录
     * @param string $code
     * @param string $message
     * @param array $data
     */
    public function apiResponse($code = '0', $message = '',$data = array(),$nums =0){
        header('Access-Control-Allow-Origin: *');
        header('Content-Type:application/json; charset=utf-8');
        $result = array(
            'code'=>$code,
            'message'=>$message,
            'data'=>$data,
            'nums'=>''.$nums
        );
        die(json_encode($result,JSON_UNESCAPED_UNICODE));
    }



//    查询中介报价（暂未用）
//  $need_id 需求id
    public function Offer($user_id,$need_id){
        $where_agency['status'] = 2;
        $where_agency['create_time'] = array('lt',time());
        $where_agency['need_id'] = $need_id;
        $agency_list = Db::name('Agency')
            ->where($where_agency)
//            ->field("id,housing_price,assessment_tax,security_tax,else_tax,service_charge")
            ->select()->toArray();
        if($agency_list){
            foreach ($agency_list as $agencyk=>$agencyv){
//                $final_list[$agencyk] = $agencyv;
//                $final_list[$agencyk]['agency_id'] = $agencyv['id'];
//                $final_list[$agencyk]['user_id'] = $user_id;
                $money = $agencyv['housing_price'] + $agencyv['assessment_tax'] + $agencyv['security_tax'] + $agencyv['else_tax'] + $agencyv['service_charge'] ;
                $money_arr[] = $money;
                $fianlMoney = substr($money, 0,-4);
                $agency_list[$agencyk]['true_money'] = $money;
//                $final_list[$agencyk]['money'] = $fianlMoney;
            }
            sort($money_arr);
            if(count($money_arr) > 3 ){
                foreach ($agency_list as $finalk=>$finalv){
                    foreach ($money_arr as $monryk=>$moneyv){
                        if($finalv['true_money'] == $moneyv){
                            $return[] =  $finalv;
                        }
                    }
                }
            }else{
                $save['status'] = 8;
            }

            return $return;
        }
    }

    public function isLogin($token){
        $where_member['token'] = $token;
//        $where_member['status'] = 1;
        $member = Db::name('Member')->where($where_member)->field('id,status')->find();
        if($member){
            if($member['status'] == 9){
                $this->apiResponse('0','您已被拉入黑名单');
            }else{
                return $member;
            }
        }else{
            $this->apiResponse('-1','请重新登录');
        }
    }



    /**
     * @title  30分钟后发布(sure)（时间为0时调用）
     * @description 接口说明
     * @author 开发者
     * @url /api/portal/Thirdsend/thirdChange
     * @method POST
     * @param name:token type:int require:1 default: other: desc:token
     * @param name:need_id type:int require:1 default: other: desc:需求id
     */
//    30分钟后发布(sure)（时间为0时调用）
//    need_id   需求id
    public function thirdChange(){
        Db::startTrans();
        $data = $this->request->param();
        $this->isLogin($data['token']);
        if(empty($data['need_id'])){
            $this->apiResponse('0','需求id不能为空');
        }
//        $where_need['status'] = 2;
        $where_need['id'] = $data['need_id'];
        $userNeedList = Db::name('UserNeed')->where($where_need)->field('id,pay_time,status')->find();
        if($userNeedList['status'] == 2) {
            $time = time();
            $sendTime = intval($userNeedList['pay_time']+1780);
            if($time < $sendTime){
                $this->apiResponse('0','未到发布时间',['now'=>$time,'pay'=>$sendTime]);
            }else{
//            查询父级
                $where_save['id'] = $data['need_id'];
                $save['status'] = 3;
                $save['update_time'] = time();
                $fianl_save = Db::name('UserNeed')->where($where_save)->update($save);
                if($fianl_save){
                    Db::commit();
                    $where_return['id'] = $data['need_id'];
                    $return = Db::name('UserNeed')->where($where_return)->find();
//                发送短信
                    $this->sendNeed($data['need_id']);
                    $this->apiResponse('1','成功',$return);
                }else{
                    Db::rollback();
                    $this->apiResponse('0','失败');
                }
            }
        }else{
            $where_return['id'] = $data['need_id'];
            $return = Db::name('UserNeed')->where($where_return)->find();
            $this->apiResponse('1','成功',$return);
        }
    }


    /**
     * @title  规定时间结束报价(sure)(时间为0时调用)
     * @description 接口说明
     * @author 开发者
     * @url /api/portal/Thirdsend/timeOver
     * @method POST
     * @param name:token type:int require:1 default: other: desc:token
     * @param name:need_id type:int require:1 default: other: desc:需求id
     */
//    规定时间结束报价(sure)(时间为0时调用)
//      need_id 需求id
    public function timeOver()
    {
        Db::startTrans();
        $data = $this->request->param();
        $res_middle_arr = array();
        $this->isLogin($data['token']);
        if(empty($data['need_id'])){
            $this->apiResponse('0','需求id不能为空');
        }
//        查询用户发布需求信息
        $where_need['status'] = array('neq',9);
        $where_need['id'] = $data['need_id'];
        $userNeedList = Db::name('UserNeed')->where($where_need)
//            ->field('id,quotation_time,create_time,pay_time,user_id,pay_money,status')
            ->find();
        if(!$userNeedList){
            $this->apiResponse('0','需求状态不正确');
        }
//        已发布，待报价， 修改状态
        if($userNeedList['status'] == 3){
            $userNeedList['user_type'] = Db::name('Member')->where(['id'=>$userNeedList['user_id']])->value('type');
            $time = time();
//        查询相应报价
            $final_time = $userNeedList['pay_time'] + $userNeedList['quotation_time'] * 86400 + 1790;
//            判断时间是否正确
            if ($time >= $final_time) {
                // 处理未支付报价
//                $not_pay = Db::name('Agency')->where(['need_id'=>$userNeedList['id'],'status'=>1])->column('id');
//                if($not_pay) {
//                    $update = [
//                        'status' => 3
//                    ];
//                    $change = Db::name('Agency')->where(['id'=>['in',$not_pay]])->update($update);
//                    if(!$change) {
//                        Db::rollback();
//                        $this->apiResponse(0,'报价处理失败');
//                    }
//                }
//                $us_middleid = $uNeedv['id'];
                $where_agency['a.status'] = 2;
                $where_agency['a.pay_time'] = array('lt', time());
                $where_agency['a.need_id'] = $userNeedList['id'];
                $where_agency['m.type'] = 2;
                $where_agency['m.status'] = 1;
                $agency_list = Db::name('Agency')->alias('a')
                    ->where($where_agency)
                    ->join("hp_Member m", 'm.id = a.agency_id')
                    ->field('a.*,m.company,m.type as user_type,m.token as token,m.id as res_mid')
                    ->select()->toArray();
//                查询品牌企业
                $where_brand['status'] = 1;
                $band_list = Db::name('Brand')->where($where_brand)->column('name');
                $agen_arr = $is_trueMoney = array();
                if ($agency_list) {
                    $get_list = array();
//                    删除十万以内报价
                    foreach ($agency_list as $tenk=>$tenv){
                        if($tenv['token'] == $data['token']){
                            $res_mid['all_price'] = $tenv['all_price'];
                            $res_mid['id'] = $tenv['id'];
                            $res_middle_arr[] = $res_mid;
                        }
                        $ten_money = $tenv['housing_price'] + $tenv['assessment_tax'] + $tenv['security_tax'] + $tenv['else_tax'] + $tenv['service_charge'];
                        if($ten_money > 100000){
                            $is_trueMoney[] = $tenv;
                        } else {
                            $up_agen['id'] = $tenv['id'];
                            $up_agen_res['status'] = 3;
                            $res_up = Db::name('Agency')->where($up_agen)->update($up_agen_res);
                            if(!$res_up){
                                Db::rollback();
                            }
//                            $this->agency_order_refund($tenv,'中介报价未进入决赛圈退款',2);
                        }
                    }
                    //        判断是否超过三个报价人
                    if (count($is_trueMoney) >= 3) {
//                    查询三人中是否有品牌中介
//                        循环匹配品牌企业
                        foreach ($is_trueMoney as $agencyk => $agencyv) {
                            foreach ($band_list as $brak => $brav) {
//                            判断是否在品牌企业中
                                if (strpos($agencyv['company'],$brav) !== false) {
//                                存在
                                    $agen_money = $agencyv['housing_price']  + $agencyv['assessment_tax'] + $agencyv['security_tax'] + $agencyv['else_tax'] + $agencyv['service_charge'];
                                    if (empty($agen_arr)) {
                                        $agen_arr[0]['money'] = $agen_money;
                                        $agen_arr[0]['id'] = $agencyv['id'];
                                    } else {
//                                    判断大小
                                        if ($agen_money < $agen_arr[0]['money']) {
                                            $agen_arr[0]['money'] = $agen_money;
                                            $agen_arr[0]['id'] = $agencyv['id'];

                                        }
                                    }
                                }
                            }
//                        取出前三报价
                            $money = $agencyv['housing_price']  + $agencyv['assessment_tax'] + $agencyv['security_tax'] + $agencyv['else_tax'] + $agencyv['service_charge'];
                            $money_list[$agencyv['id']] = $money;
                        }
                        asort($money_list);
                        $k = 0;
                        foreach ($money_list as $mok => $mov) {
                            $else_changeList[] = $mok;
                            if ($k < 3) {
                                $fin_list[$k]['id'] = $mok;
                                $fin_list[$k]['money'] = $mov;
                                $fin_arr[] = $mok;
                            }
                            $k += 1;
                        }
                        if($agen_arr){
                            if(!in_array($agen_arr[0]['id'],$fin_arr)){
//                            品牌中介不在取出三个最低价中
                                $middle_agen[0] = $agen_arr[0]['id'];
                                $get_list = array_merge($fin_arr,$middle_agen);
                            }else{
                                $get_list = $fin_arr;
                            }
                        }else{
                            $get_list = $fin_arr;
                        }
                        foreach ($else_changeList as $getk=>$getv){
                            if(in_array($getv,$get_list)){
                                $change_final['id'] = $getv;
                                $change_final['status'] = 4;
                            }else{
                                $change_final['id'] = $getv;
                                $change_final['status'] = 3;
                                // 中介报价未进入决赛，执行订单退款
                                $agencyInfo = Db::name('Agency')->alias('a')
                                    ->where(['a.id'=>$getv])
                                    ->join("hp_Member m", 'm.id = a.agency_id')
                                    ->field('a.*,m.company,m.type as user_type')
                                    ->find();
//                                $refund_result = $this->agency_order_refund($agencyInfo,'中介报价未进入决赛圈退款',2);
                            }
                            $agencyModel = new  AgencyModel();
                            $fianl_AgsaveFirst = $agencyModel->isUpdate(true)->save($change_final);
                            if(!$fianl_AgsaveFirst){
                                Db::rollback();
                            }
                        }
//                        报价成功，更改状态
                        $userSave_statusFirst['id'] = $userNeedList['id'];
                        $userSave_statusFirst['status'] = 5;
                        $userSave_statusFirst['choose_time'] = time();
                        $userNeedModel = new UserNeedModel();
                        $fianl_Ussave = $userNeedModel->isUpdate(true)->save($userSave_statusFirst);
                        if(!$fianl_Ussave){
                            Db::rollback();
                        }
                    } else {
//                报价小于3人，更改订单状态，报价失败
                        foreach ($agency_list as $changeka=>$changeva){
                            $change_final['id'] = $changeva['id'];
                            $change_final['status'] = 7;
                            $agencyModel = new  AgencyModel();
                            $fianl_AgsaveNext = $agencyModel->isUpdate(true)->save($change_final);

                            if(!$fianl_AgsaveNext){
                                Db::rollback();
                            }
                            // 中介报价订单退款
//                            $refund_result = $this->agency_order_refund($changeva,'中介报价少于3人退款',1);
                        }
                        $userSave_status['id'] = $userNeedList['id'];
                        $userSave_status['status'] = 4;
                        $userNeedModel = new UserNeedModel();
                        $fianl_Ussave = $userNeedModel->isUpdate(true)->save($userSave_status);
                        if(!$fianl_Ussave){
                            Db::rollback();
                        }

                        // 用户需求订单退款
//                        $refund_result = $this->need_order_refund($userNeedList,'报价人数不足',1);
                    }
                } else {
//                没有报价
                    $userSave_status['id'] = $userNeedList['id'];
                    $userSave_status['status'] = 4;
                    $userNeedModel = new UserNeedModel();
                    $fianl_Ussave = $userNeedModel->isUpdate(true)->save($userSave_status);
                    if(!$fianl_Ussave){
                        Db::rollback();
                    }
                    // 用户需求订单退款
//                    $refund_result = $this->need_order_refund($userNeedList,'报价人数不足',1);
                }
//            插入数据库
//            用户需求表
//            中介报价表
                Db::commit();
                $where_return['id'] = $data['need_id'];
                $return = Db::name('UserNeed')->where($where_return)->find();
                $where_tok['a.need_id'] = $data['need_id'];
                $where_tok['m.token'] = $data['token'];
                $a_status = Db::name('Agency')->alias('a')->where($where_tok)
                    ->join("Member m",'m.id = a.agency_id')
                    ->field('a.status')->find();
//                $return['agency_status'] = 4;
                $return['agency_id'] = $res_middle_arr[0]['id'];
                $return['all_price'] = $res_middle_arr[0]['all_price'];
                $return['need_status'] = $return['status'];
                $return['agency_status'] = $a_status['status'];
                $return['status'] = $a_status['status'];

                $this->apiResponse('1','成功123',$return);
            }else{
                $aa['final_time'] = $final_time;
                $aa['time'] = $time;
                $this->apiResponse('0','时间不正确',$aa);
            }
        }else if($userNeedList['status'] == 4 || $userNeedList['status'] == 5){
            $return = $userNeedList;
            $where_tok['a.need_id'] = $data['need_id'];
            $where_tok['m.token'] = $data['token'];
            $all = Db::name('Agency')->alias('a')->where($where_tok)
                ->join("Member m",'m.id = a.agency_id')
                ->field('a.*')->find();
            $return['all_price'] = $all['all_price'];
            $return['need_status'] = $userNeedList['status'];
            $return['agency_status'] = $all['status'];
            $return['status'] = $all['status'];
            $return['agency_id'] = $all['id'];
            $this->apiResponse('1','成功',$return);
        }
    }

    /**
     * @title  三天用户选择(sure)（时间为0时调用）
     * @description 接口说明
     * @author 开发者
     * @url /api/portal/Thirdsend/choose
     * @method POST
     * @param name:token type:int require:1 default: other: desc:token
     * @param name:need_id type:int require:1 default: other: desc:需求id
     */
//    三天用户选择(sure)（时间为0时调用）
//      need_id 需求id
    public function choose(){
        Db::startTrans();
        $data = $this->request->param();
        $this->isLogin($data['token']);
        if(empty($data['need_id'])){
            $this->apiResponse('0','需求id不能为空');
        }
//        查询用户发布需求信息
        $where_need['status'] = array('neq',9);
        $where_need['id'] = $data['need_id'];
        $userNeedList = Db::name('UserNeed')->where($where_need)->field('id,choose_time,user_id,pay_money,choose_time')->find();
        if($userNeedList){
//            foreach ($userNeedList as $needk=>$needv) {
            if($userNeedList['status'] == 5){
                if (time() >= ($userNeedList['choose_time'] + 259200)) {
                $where_agency['a.need_id'] = $userNeedList['id'];
                $where_agency['a.status'] = 4;
                $agency_list = Db::name('Agency')->alias('a')
                    ->where($where_agency)
                    ->join("hp_Member m", 'm.id = a.agency_id')
                    ->field('a.*,m.company,m.type as user_type')
                    ->select()->toArray();
                if ($agency_list) {
                    $where_agencyUpdate['need_id'] = $userNeedList['id'];
                    $where_agencyUpdate['status'] = 4;
                    $agency_save['status'] = 8;
                    $agency_save['update_time'] = time();
                    $agency_result = Db::name('Agency')->where($where_agencyUpdate)->update($agency_save);
                    if (!$agency_result) {
                        Db::rollback();
                    }
                }
                $where_needUpdate['id'] = $userNeedList['id'];
                $needUpdate['status'] = 6;
                $need_result = Db::name('UserNeed')->where($where_needUpdate)->update($needUpdate);
                if (!$need_result) {
                    Db::rollback();
                } else {
//                        增加平台收益
                    $add_get['type'] = 1;
                    $add_get['agency_id'] = 1;
                    foreach ($agency_list as $agencyk=>$agencyv){
                        $agency_idar[] = $agencyv['id'];
                    }
                    $add_get['agency_id'] = implode(',',$agency_idar);
                    $add_get['create_time'] = time();
                    $add_get['update_time'] = time();
                    $res_get = Db::name('Get')->insertGetId($add_get);
                    if (!$res_get) {
                        Db::rollback();
                    }
                    if ($agency_list) {
                        foreach ($agency_list as $agency_key => $agency_val) {
                            // 中介报价订单退款
                            $this->agency_order_refund($agency_val, '用户未选择中标中介退款',3);
                        }
                    }
                }
            }
            }
            Db::commit();
            $where_return['id'] = $data['need_id'];
            $return = Db::name('UserNeed')->where($where_return)->find();
            $this->apiResponse('1','成功',$return);
        }else{
            $this->apiResponse('0','需求错误');
        }
    }

    /**
     * @title  三天中介确认（时间为0时调用）
     * @description 接口说明
     * @author 开发者
     * @url /api/portal/Thirdsend/threeChoose
     * @method POST
     * @param name:token type:int require:1 default: other: desc:token
     * @param name:need_id type:int require:1 default: other: desc:需求id
     */
//    三天中介确认（时间为0时调用）
//      need_id 需求id
    public function threeChoose(){
        Db::startTrans();
        $data = $this->request->param();
        $this->isLogin($data['token']);
        if(empty($data['need_id'])){
            $this->apiResponse('0','需求id不能为空');
        }
        $where_needs['n.id'] = $data['need_id'];
        $where_needs['n.status'] = 7;
        $need_list = Db::name('UserNeed')->alias('n')
            ->join('Member m','m.id = n.user_id')
            ->field('n.*,m.referee_id,m.name,m.tel,m.id as amid,m.money as amoney')
            ->where($where_needs)
            ->find();
        if($need_list){
            if($need_list['is_refuse'] == 4){
//                拒绝投诉
                if(time() >= $need_list['refuse_complaint_time']){
                    $where_agency['a.status'] = 5;
                    $where_agency['a.need_id'] = $need_list['id'];
                    $agency = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')->field(['a.*,m.type as user_type,m.referee_id,m.id as amid'])->where($where_agency)->find();
//                    修改中介报价状态
                    if($agency){
                        //            增加中介成交数
                        $where_count_deal['id'] = $agency['amid'];
                        $save_count_deal = Db::name('Member')->where($where_count_deal)->setInc('count_deal',1);
                        if($save_count_deal){
                            Db::rollback();
                            $this->apiResponse('0', '确认失败');
                        }
                        $where_changeAgency['id'] = $agency['id'];
                        $changeAgency['status'] = 11;
                        $changeAgency['update_time'] = time();
                        $update_a = Db::name('Agency')->where($where_changeAgency)->update($changeAgency);
                        if(!$update_a){
                            Db::rollback();
                            $this->apiResponse('0','修改中介状态失败');
                        }
                    }
//                    修改用户需求状态
                    $where_needChange['id'] = $need_list['id'];
                    $update_need['status'] = 10;
                    $update_need['update_time'] = time();
                    $change_needFinal = Db::name('UserNeed')->where($where_needChange)->update($update_need);
                    if (!$change_needFinal) {
                        Db::rollback();
                        $this->apiResponse('0','修改需求状态失败');
                    }else{
                        //                    分别查询用户，中介推荐人
                        $where_m['id'] = $change_needFinal['user_id'];
                        $refereeFirst = Db::name('Member')->where($where_m)->field('referee_id,money')->find();
                        $need_referee = $refereeFirst['referee_id'];

                        $agency_referee = $agency['referee_id'];
//                        诚意金金额获取
                        $where_reward['type'] = 5;
                        $where_reward['status'] = 1;
                        $reward = Db::name('Reward')->where($where_reward)->find();
//                    查询推荐人是否已获得奖励
//                    需求用户
                        $where_nref['id'] = $need_referee;
                        $is_needReferee = Db::name('Member')->where($where_nref)->field('is_getmoney,money')->find();
                        if($is_needReferee['is_getmoney'] == 0 && !empty($need_referee)){
                            $add_detail['user_id'] = $need_referee;
                            $add_detail['title'] = '推荐'.$change_needFinal['tel'];;
                            $add_detail['money'] = $reward['number'];
                            $add_detail['order_type'] = 7;
                            $add_detail['type'] = 1;
                            $add_detail['status'] = 1;
                            $add_detail['create_time'] = time();
                            $add_detail['update_time'] = time();
                            $add_res = Db::name('MoneyDetail')->insertGetId($add_detail);
                            if($add_res) {
                                $where_addParent['id'] = $need_referee;
                                $needReferee_add['money'] = $reward['number']+$is_needReferee['money'];
                                $needReferee_add['getmoney_id'] = $change_needFinal['user_id'];
                                $needReferee_add['is_getmoney'] = 1;
                                $needReferee_add['update_time'] = time();
                                $add_parent = Db::name('Member')->where($where_addParent)->update($needReferee_add);
                                if (!$add_parent) {
                                    Db::rollback();
                                    $this->apiResponse('0', '确认失败');
                                }
                            }else{
                                Db::rollback();
                                $this->apiResponse('0','确认失败');
                            }
                        }
//                    增加信誉
//                    中介
                        $add_rewResAgency = $this->addReward($agency_referee,$agency['amid']);
                        if($add_rewResAgency == false){
                            Db::rollback();
                            $this->apiResponse('0','增加信誉失败');
                        }
                    }
                    //                增加平台收益
                    $add_get['type'] = 4;
                    $add_get['agency_id'] = $agency['id'];
                    $add_get['money'] = $agency['deposit'];
                    $add_get['create_time'] = time();
                    $add_get['update_time'] = time();
                    $res_get = Db::name('Get')->insertGetId($add_get);
                    if(!$res_get){
                        Db::rollback();
                    }

                    $this->handle($need_list,$agency);
                    $need_list['user_type'] = Db::name('Member')->where(['id'=>$need_list['user_id']])->value('type');
                    $this->need_order_refund($need_list,'中介未确认成交退款',5);
                    $agency_list = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')
                        ->field(['a.*,m.type as user_type'])->where(['a.need_id'=>$data['need_id'],'a.status'=>6])->select()->toArray();
                    if (!empty($agency_list)) {
                        foreach ($agency_list as $agency_key => $agency_val) {
                            // 中介报价订单退款
                            $this->agency_order_refund($agency_val, '用户未选择中标中介退款',3);
                        }
                    }
                }

            }else{
//                正常流程
                if(time() >= ($need_list['next_choose_time']+259150)){
                    $where_agency['a.status'] = 5;
                    $where_agency['a.need_id'] = $need_list['id'];
                    $agency = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')->field(['a.*,m.type as user_type,m.referee_id,m.id as amid'])->where($where_agency)->find();
//                    修改中介报价状态
                    if($agency){
                        //            增加中介成交数
                        $where_count_deal['id'] = $agency['amid'];
                        $save_count_deal = Db::name('Member')->where($where_count_deal)->setInc('count_deal',1);
                        if($save_count_deal){
                            Db::rollback();
                            $this->apiResponse('0', '确认失败');
                        }
                        $where_changeAgency['id'] = $agency['id'];
                        $changeAgency['status'] = 11;
                        $changeAgency['update_time'] = time();
                        $update_a = Db::name('Agency')->where($where_changeAgency)->update($changeAgency);
                        if(!$update_a){
                            Db::rollback();
                            $this->apiResponse('0','修改中介状态失败');
                        }
                    }
//                    修改用户需求状态
                    $where_needChange['id'] = $need_list['id'];
                    $update_need['status'] = 10;
                    $update_need['update_time'] = time();
                    $change_needFinal = Db::name('UserNeed')->where($where_needChange)->update($update_need);
                    //                增加平台收益
                    $add_get['type'] = 4;
                    $add_get['agency_id'] = $agency['id'];
                    $add_get['money'] = $agency['deposit'];
                    $add_get['create_time'] = time();
                    $add_get['update_time'] = time();
                    $res_get = Db::name('Get')->insertGetId($add_get);
                    if(!$res_get){
                        Db::rollback();
                    }
                    if (!$change_needFinal) {
                        Db::rollback();
                        $this->apiResponse('0','修改需求状态失败');
                    }else{
                        //                    分别查询用户，中介推荐人
                        $where_m['id'] = $change_needFinal['user_id'];
                        $refereeFirst = Db::name('Member')->where($where_m)->field('referee_id,money,type')->find();
                        $need_referee = $refereeFirst['referee_id'];

                        $agency_referee = $agency['referee_id'];
//                        诚意金金额获取
                        $where_reward['type'] = 5;
                        $where_reward['status'] = 1;
                        $reward = Db::name('Reward')->where($where_reward)->find();
//                    查询推荐人是否已获得奖励
//                    需求用户
                        $where_nref['id'] = $need_referee;
                        $is_needReferee = Db::name('Member')->where($where_nref)->field('is_getmoney')->find();
                        if($is_needReferee['is_getmoney'] == 0 && !empty($need_referee)){
                            $add_detail['user_id'] = $need_referee;
                            $add_detail['title'] = '推荐'.$change_needFinal['tel'];
                            $add_detail['user_type'] = $refereeFirst['type'];
                            $add_detail['money'] = $reward['number'];
                            $add_detail['order_type'] = 7;
                            $add_detail['type'] = 1;
                            $add_detail['status'] = 1;
                            $add_detail['create_time'] = time();
                            $add_detail['update_time'] = time();
                            $add_res = Db::name('MoneyDetail')->insertGetId($add_detail);
                            if($add_res) {
                                $where_addParent['id'] = $need_referee;
                                $needReferee_add['money'] = $reward['number']+$need_referee['money'];
                                $needReferee_add['getmoney_id'] = $change_needFinal['user_id'];
                                $add_parent = Db::name('Member')->where($where_addParent)->update($needReferee_add);
                                if (!$add_parent) {
                                    Db::rollback();
                                    $this->apiResponse('0', '确认失败');
                                }
                            }else{
                                Db::rollback();
                                $this->apiResponse('0','确认失败');
                            }
                        }
//                    增加信誉
//                    中介
                        $add_rewResAgency = $this->addReward($agency['amid']);
                        if($add_rewResAgency == false){
                            Db::rollback();
                            $this->apiResponse('0','增加信誉失败');
                        }
                    }
                    $this->handle($need_list,$agency);
                    $need_list['user_type'] = Db::name('Member')->where(['id'=>$need_list['user_id']])->value('type');
                    $this->need_order_refund($need_list,'中介未确认成交退款',5);
                    $agency_list = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')
                        ->field(['a.*,m.type as user_type'])->where(['a.need_id'=>$data['need_id'],'a.status'=>6])->select()->toArray();
                    if (!empty($agency_list)) {
                        foreach ($agency_list as $agency_key => $agency_val) {
                            // 中介报价订单退款
                            $this->agency_order_refund($agency_val, '用户未选择中标中介退款',3);
                        }
                    }
                }
            }

            Db::commit();
            $where_return['n.id'] = $need_list['id'];
            $where_return['a.id'] = $agency['id'];
            $return = Db::name('Agency')->alias('a')
                ->where($where_return)
                ->join("UserNeed n",'n.id = a.need_id')
                ->field("n.city,n.quarters,n.room,n.floor,n.house_type,n.renovation,n.status as need_status,n.create_time as need_time,n.quotation_time,n.id as need_id,n.next_choose_time,
             a.all_price,a.create_time,a.status,a.id as intermediaryNeed_id,a.pay_time,a.id ,a.refuse_complaint_time,a.choose_time,n.pay_money as deposit
             ")
                ->find();
            $changeInt = (int)$return['all_price'];
            $return['intPrice'] = substr($changeInt,0,-4);
            $this->apiResponse('1','成功',['need'=>$return]);
        }else{
            $where_return['n.id'] = $data['need_id'];
            $where_return['a.status'] = 11;
            $return = Db::name('Agency')->alias('a')
                ->where($where_return)
                ->join("UserNeed n",'n.id = a.need_id')
                ->field("n.city,n.quarters,n.room,n.floor,n.house_type,n.renovation,n.status as need_status,n.create_time as need_time,n.quotation_time,n.id as need_id,n.next_choose_time,
             a.all_price,a.create_time,a.status,a.id as intermediaryNeed_id,a.pay_time,a.id ,a.refuse_complaint_time,a.choose_time,n.pay_money as deposit
             ")
                ->find();
            $changeInt = (int)$return['all_price'];
            $return['intPrice'] = substr($changeInt,0,-4);
            if($return) {
                $this->apiResponse('1','成功',['need'=>$return]);
            } else {
                $this->apiResponse('0','需求错误');
            }
        }
    }





//    30分钟后发布(sure)(分钟执行)
    public function thirdSend(){
        Db::startTrans();
        $where_need['status'] = 2;
        $userNeedList = Db::name('UserNeed')->where($where_need)->field('id,pay_time')->select()->toArray();
        if(!empty($userNeedList)) {
            $time = time();
            $change_arr = array();
            foreach ($userNeedList as $userk=>$userv){
                if($time >= $userv['pay_time']+1800){
                    $this->sendNeed($userv['id']);
                    $change_arr[] = $userv['id'];
                }
            }
            if($change_arr){
                $where_save['id'] = array('in',$change_arr);
                $save['status'] = 3;
                $save['update_time'] = time();
                $fianl_save = Db::name('UserNeed')->where($where_save)->update($save);
                if($fianl_save){
                    Db::commit();
                }else{
                    Db::rollback();
                }
            }
        }
    }

//    规定时间结束报价(sure)(分钟执行)
    public function over()
    {
        Db::startTrans();
//        查询用户发布需求信息
        $where_need['status'] = array('neq',9);
        $userNeedList = Db::name('UserNeed')->where($where_need)->field('id,quotation_time,create_time,pay_time,user_id,status')->select()->toArray();
        $time = time();
//        循环需求，查询相应报价
        foreach ($userNeedList as $uNeedk => $uNeedv) {
            if($uNeedv['status'] == 3){
                $uNeedv['user_type'] = Db::name('Member')->where(['id'=>$uNeedv['user_id']])->value('type');
                $final_time = $uNeedv['pay_time'] + $uNeedv['quotation_time'] * 86400 + 1800;
                if ($time >= $final_time) {
                    // 处理未支付报价
//                    $not_pay = Db::name('Agency')->where(['need_id'=>$uNeedv['id'],'status'=>2])->column('id');
//                    if($not_pay) {
//                        $update = [
//                            'status' => 3
//                        ];
//                        $change = Db::name('Agency')->where(['id'=>['in',$not_pay]])->update($update);
//                        if(!$change) {
//                            Db::rollback();
//                            $this->apiResponse(0,'报价处理失败');
//                        }
//                    }
                    $us_middleid = $uNeedv['id'];
                    $where_agency['a.status'] = 2;
                    $where_agency['a.pay_time'] = array('lt', time());
                    $where_agency['a.need_id'] = $uNeedv['id'];
                    $where_agency['m.type'] = 2;
                    $where_agency['m.status'] = 1;
                    $agency_list = Db::name('Agency')->alias('a')
                        ->where($where_agency)
                        ->join("hp_Member m", 'm.id = a.agency_id')
                        ->field('a.*,m.company,m.type as user_type')
                        ->select()->toArray();
//                查询品牌企业
                    $where_brand['status'] = 1;
                    $band_list = Db::name('Brand')->where($where_brand)->column('name');
                    $agen_arr = array();
                    $money_arr = array();
                    if ($agency_list) {
//                    删除十万以内报价
                        foreach ($agency_list as $tenk=>$tenv){
                            $ten_money = $tenv['housing_price']  + $tenv['assessment_tax'] + $tenv['security_tax'] + $tenv['else_tax'] + $tenv['service_charge'];
                            if($ten_money > 100000){
                                $is_trueMoney[] = $tenv;
                            } else {
                                $up_agen['id'] = $tenv['id'];
                                $up_agen_res['status'] = 3;
                                $res_up = Db::name('Agency')->where($up_agen)->update($up_agen_res);
                                if(!$res_up){
                                    Db::rollback();
                                }
                                $this->agency_order_refund($tenv,'中介报价未进入决赛圈退款',2);
                            }
                        }
                        //        判断是否超过三个报价人
                        if (count($is_trueMoney) >= 3) {

//                    查询三人中是否有品牌中介
//                        循环匹配品牌企业
                            foreach ($is_trueMoney as $agencyk => $agencyv) {
                                foreach ($band_list as $brak => $brav) {
//                            判断是否在品牌企业中
                                    if (strpos($agencyv['company'],$brav) !== false) {
//                                存在
                                        $agen_money = $agencyv['housing_price'] + $agencyv['assessment_tax'] + $agencyv['security_tax'] + $agencyv['else_tax'] + $agencyv['service_charge'];
                                        if (empty($agen_arr)) {
                                            $agen_arr[0]['money'] = $agen_money;
                                            $agen_arr[0]['id'] = $agencyv['id'];
                                        } else {
//                                    判断大小
                                            if ($agen_money < $agen_arr[0]['money']) {
                                                $agen_arr[0]['money'] = $agen_money;
                                                $agen_arr[0]['id'] = $agencyv['id'];

                                            }
                                        }
                                    }
                                }
//                        取出前三报价
                                $money = $agencyv['housing_price'] + $agencyv['assessment_tax'] + $agencyv['security_tax'] + $agencyv['else_tax'] + $agencyv['service_charge'];
                                $money_list[$agencyv['id']] = $money;
                            }
                            asort($money_list);
                            $k = 0;
                            foreach ($money_list as $mok => $mov) {
                                $else_changeList[] = $mok;
                                if ($k < 3) {
                                    $fin_list[$k]['id'] = $mok;
                                    $fin_list[$k]['money'] = $mov;
                                    $fin_arr[] = $mok;
                                }
                                $k += 1;
                            }
                            if($agen_arr){
                                if(!in_array($agen_arr[0]['id'],$fin_arr)){
//                            品牌中介不在取出三个最低价中
                                    $middle_agen[0] = $agen_arr[0]['id'];
                                    $get_list = array_merge($fin_arr,$middle_agen);
                                }else{
                                    $get_list = $fin_arr;
                                }
                            }else{
                                $get_list = $fin_arr;
                            }
                            foreach ($else_changeList as $getk=>$getv){
                                if(in_array($getv,$get_list)){
                                    $change_final['id'] = $getv;
                                    $change_final['status'] = 4;
                                }else{
                                    $change_final['id'] = $getv;
                                    $change_final['status'] = 3;
                                    // 中介报价未进入决赛，执行订单退款
                                    $agencyInfo = Db::name('Agency')->alias('a')
                                        ->where(['a.id'=>$getv])
                                        ->join("hp_Member m", 'm.id = a.agency_id')
                                        ->field('a.*,m.company,m.type as user_type')
                                        ->find();
                                    $refund_result = $this->agency_order_refund($agencyInfo,'中介报价未进入决赛圈退款',2);
                                }
                                $agencyModel = new  AgencyModel();
                                $fianl_AgsaveFirst = $agencyModel->isUpdate(true)->save($change_final);
                                if(!$fianl_AgsaveFirst){
                                    Db::rollback();
                                }
                            }
//                        报价成功，更改状态
                            $userSave_statusFirst['id'] = $uNeedv['id'];
                            $userSave_statusFirst['status'] = 5;
                            $userSave_statusFirst['choose_time'] = time();
                            $userNeedModel = new UserNeedModel();
                            $fianl_Ussave = $userNeedModel->isUpdate(true)->save($userSave_statusFirst);
                            if(!$fianl_Ussave){
                                Db::rollback();
                            }
                        } else {
//                报价小于3人，更改订单状态，报价失败
                            foreach ($agency_list as $changeka=>$changeva){
                                $change_final['id'] = $changeva['id'];
                                $change_final['status'] = 7;
                                $agencyModel = new  AgencyModel();
                                $fianl_AgsaveNext = $agencyModel->isUpdate(true)->save($change_final);
                                if(!$fianl_AgsaveNext){
                                    Db::rollback();
                                }
                                // 中介报价订单退款
                                $refund_result = $this->agency_order_refund($changeva,'中介报价少于3人退款',1);

                            }
                            $userSave_status['id'] = $uNeedv['id'];
                            $userSave_status['status'] = 4;
                            $userNeedModel = new UserNeedModel();
                            $fianl_Ussave = $userNeedModel->isUpdate(true)->save($userSave_status);
                            if(!$fianl_Ussave){
                                Db::rollback();
                            }
                            // 用户需求订单退款
                            $refund_result = $this->need_order_refund($uNeedv,'报价人数不足',1);

                        }
                    } else {
//                没有报价
                        $userSave_status['id'] = $uNeedv['id'];
                        $userSave_status['status'] = 4;
                        $userNeedModel = new UserNeedModel();
                        $fianl_Ussave = $userNeedModel->isUpdate(true)->save($userSave_status);
                        if(!$fianl_Ussave){
                            Db::rollback();
                        }
                        // 用户需求订单退款
                        $refund_result = $this->need_order_refund($uNeedv,'报价人数不足',1);

                    }
//            插入数据库
//            用户需求表
//                $userNeedModel = new UserNeedModel();
//                foreach ($userSave_status as $fck=>$fcv){
//                    $fianl_Ussave = $userNeedModel->isUpdate(true)->save($fcv);
//                    if(!$fianl_Ussave){
//                        Db::rollback();
//                    }
//                }
//            中介报价表
                    Db::commit();
                }
            }
        }
    }

//    三天用户选择(sure)（天执行）
    public function userChoose(){
        Db::startTrans();
//        查询用户发布需求信息
        $where_need['status'] = array('neq',9);
        $userNeedList = Db::name('UserNeed')->where($where_need)->field('id,choose_time,user_id,pay_money,choose_time,status')->select()->toArray();
        if($userNeedList){
            foreach ($userNeedList as $needk=>$needv) {
                if($needv['status'] == 5){
                    if (time() >= ($needv['choose_time'] + 259200)) {
                        $where_agency['a.need_id'] = $needv['id'];
                        $where_agency['a.status'] = 4;
                        $agency_list = Db::name('Agency')->alias('a')
                            ->where($where_agency)
                            ->join("hp_Member m", 'm.id = a.agency_id')
                            ->field('a.*,m.company,m.type as user_type')
                            ->select()->toArray();
                        if ($agency_list) {
                            $where_agencyUpdate['need_id'] = $needv['id'];
                            $where_agencyUpdate['status'] = 4;
                            $agency_save['status'] = 8;
                            $agency_save['update_time'] = time();
                            $agency_result = Db::name('Agency')->where($where_agencyUpdate)->update($agency_save);
                            if (!$agency_result) {
                                Db::rollback();
                            }
//                        增加平台收益
                            $add_get['type'] = 1;
                            $add_get['agency_id'] = 1;
                            foreach ($agency_list as $agencyk=>$agencyv){
                                $agency_idar[] = $agencyv['id'];
                            }
                            $add_get['agency_id'] = implode(',',$agency_idar);
                            $add_get['create_time'] = time();
                            $add_get['update_time'] = time();
                            $res_get = Db::name('Get')->insertGetId($add_get);
                            if (!$res_get) {
                                Db::rollback();
                            }
                        }
                        $where_needUpdate['id'] = $needv['id'];
                        $needUpdate['unchoose_time'] = time();
                        $needUpdate['status'] = 6;
                        $need_result = Db::name('UserNeed')->where($where_needUpdate)->update($needUpdate);
                        if (!$need_result) {
                            Db::rollback();
                        } else {
                            if ($agency_list) {
                                foreach ($agency_list as $agency_key => $agency_val) {
                                    // 中介报价订单退款
                                    $this->agency_order_refund($agency_val, '用户未选择中标中介退款',3);
                                }
                            }
                        }
                    }
                }
            }
        }
        Db::commit();

    }


//    三天中介确认
    public function intermediaryChoose(){
        Db::name('Test')->insert(['data'=>4]);
        Db::startTrans();
        $where_needs['n.status'] = 7;
        $where_needs['n.id'] = array('in','653');
        $need_list = Db::name('UserNeed')->alias('n')->where($where_needs)
            ->join('Member m','m.id = n.user_id')
            ->field('n.*,m.referee_id,m.name,m.tel,m.id as amid,m.money as amoney')
            ->select()->toArray();
        if($need_list){
            foreach ($need_list as $needk=>$needv){
                if($needv['is_refuse'] == 4){
//                拒绝投诉
                    if(time() >= $needv['refuse_complaint_time']){
                        $where_agency['a.status'] = 5;
                        $where_agency['a.need_id'] = $needv['id'];
                        $agency = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')->field(['a.*,m.type as user_type,m.referee_id,m.id as amid'])->where($where_agency)->find();
//                    修改中介报价状态
                        if($agency){
                            //            增加中介成交数
                            $where_count_deal['id'] = $agency['amid'];
                            $save_count_deal = Db::name('Member')->where($where_count_deal)->setInc('count_deal',1);
                            if($save_count_deal){
                                Db::rollback();
                                $this->apiResponse('0', '确认失败');
                            }
                            $where_changeAgency['id'] = $agency['id'];
                            $changeAgency['status'] = 11;
                            $changeAgency['update_time'] = time();
                            $update_a = Db::name('Agency')->where($where_changeAgency)->update($changeAgency);
                            if(!$update_a){
                                Db::rollback();
//                                $this->apiResponse('0','修改中介状态失败');
                            }
                        }
//                    修改用户需求状态
                        $where_needChange['id'] = $needv['id'];
                        $update_need['status'] = 10;
                        $update_need['update_time'] = time();
                        $change_needFinal = Db::name('UserNeed')->where($where_needChange)->update($update_need);
                        if (!$change_needFinal) {
                            Db::rollback();
                            $this->apiResponse('0','修改需求状态失败');
                        }else{
                            //                    分别查询用户，中介推荐人
                            $where_m['id'] = $change_needFinal['user_id'];
                            $refereeFirst = Db::name('Member')->where($where_m)->field('referee_id,money')->find();
                            $need_referee = $refereeFirst['referee_id'];

                            $agency_referee = $agency['referee_id'];
//                        诚意金金额获取
                            $where_reward['type'] = 5;
                            $where_reward['status'] = 1;
                            $reward = Db::name('Reward')->where($where_reward)->find();
//                    查询推荐人是否已获得奖励
//                    需求用户
                            $where_nref['id'] = $need_referee;
                            $is_needReferee = Db::name('Member')->where($where_nref)->field('is_getmoney,money')->find();
                            if($is_needReferee['is_getmoney'] == 0 && !empty($need_referee)){
                                $add_detail['user_id'] = $need_referee;
                                $add_detail['title'] = '推荐'.$change_needFinal['tel'];;
                                $add_detail['money'] = $reward['number'];
                                $add_detail['order_type'] = 7;
                                $add_detail['type'] = 1;
                                $add_detail['status'] = 1;
                                $add_detail['create_time'] = time();
                                $add_detail['update_time'] = time();
                                $add_res = Db::name('MoneyDetail')->insertGetId($add_detail);
                                if($add_res) {
                                    $where_addParent['id'] = $need_referee;
                                    $needReferee_add['money'] = $reward['number']+$is_needReferee['money'];
                                    $needReferee_add['getmoney_id'] = $change_needFinal['user_id'];
                                    $needReferee_add['is_getmoney'] = 1;
                                    $needReferee_add['update_time'] = time();
                                    $add_parent = Db::name('Member')->where($where_addParent)->update($needReferee_add);
                                    if (!$add_parent) {
                                        Db::rollback();
                                        $this->apiResponse('0', '确认失败');
                                    }
                                }else{
                                    Db::rollback();
                                    $this->apiResponse('0','确认失败');
                                }
                            }
                            //                    增加信誉
//                    中介
                            $add_rewResAgency = $this->addReward($agency['amid']);
                            if($add_rewResAgency == false){
                                Db::rollback();
                                $this->apiResponse('0','增加信誉失败');
                            }
                        }
                        //                增加平台收益
                        $add_get['type'] = 4;
                        $add_get['agency_id'] = $agency['id'];
                        $add_get['money'] = $agency['deposit'];
                        $add_get['create_time'] = time();
                        $add_get['update_time'] = time();
                        $res_get = Db::name('Get')->insertGetId($add_get);
                        if(!$res_get){
                            Db::rollback();
                        }

//                        这里是退款
                        $this->handle($needv,$agency);
                        $need_list['user_type'] = Db::name('Member')->where(['id'=>$needv['user_id']])->value('type');
                        $this->need_order_refund($need_list,'中介未确认成交退款',5);
                        $agency_list = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')
                            ->field(['a.*,m.type as user_type'])->where(['a.need_id'=>$needv['need_id'],'a.status'=>6])->select()->toArray();
                        if (!empty($agency_list)) {
                            foreach ($agency_list as $agency_key => $agency_val) {
                                // 中介报价订单退款
                                $this->agency_order_refund($agency_val, '用户未选择中标中介退款',3);
                            }
                        }
                    }

                }else{
                    if(time() >= ($needv['next_choose_time']+259200)){
                        $where_agency['a.status'] = 5;
                        $where_agency['a.need_id'] = $needv['id'];
                        $agency = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')->field(['a.*,m.type as user_type,m.referee_id,m.id as amid,m.tel,m.money as amoney'])->where($where_agency)->find();
//                    修改中介报价状态
                        if($agency){
                            //            增加中介成交数
                            $where_count_deal['id'] = $agency['amid'];
                            $save_count_deal = Db::name('Member')->where($where_count_deal)->setInc('count_deal',1);
                            if(!$save_count_deal){
                                Db::rollback();
                                $this->apiResponse('0', '确认失败');
                            }
                            $where_changeAgency['id'] = $agency['id'];
                            $changeAgency['status'] = 11;
                            $changeAgency['update_time'] = time();
                            $update_a = Db::name('Agency')->where($where_changeAgency)->update($changeAgency);
                            if(!$update_a){
                                Db::rollback();
                            }
                        }
                        //                增加平台收益
                        $add_get['type'] = 4;
                        $add_get['agency_id'] = $agency['id'];
                        $add_get['money'] = $agency['deposit'];
                        $add_get['create_time'] = time();
                        $add_get['update_time'] = time();
                        $res_get = Db::name('Get')->insertGetId($add_get);
                        if(!$res_get){
                            Db::rollback();
                        }
//                        修改用户需求状态
                        $where_needChange['id'] = $needv['id'];
                        $update_need['status'] = 10;
                        $update_need['update_time'] = time();
                        $change_needFinal = Db::name('UserNeed')->where($where_needChange)->update($update_need);
                        if (!$change_needFinal) {
                            Db::rollback();
                        }else{
                            //                    分别查询用户，中介推荐人
                            $where_m['id'] = $change_needFinal['user_id'];
                            $refereeFirst = Db::name('Member')->where($where_m)->field('referee_id,money,type')->find();
                            $need_referee = $refereeFirst['referee_id'];

                            $agency_referee = $agency['referee_id'];
//                        诚意金金额获取
                            $where_reward['type'] = 5;
                            $where_reward['status'] = 1;
                            $reward = Db::name('Reward')->where($where_reward)->find();
//                    查询推荐人是否已获得奖励
//                    需求用户
                            $where_nref['id'] = $need_referee;
                            $is_needReferee = Db::name('Member')->where($where_nref)->field('is_getmoney')->find();
                            if($is_needReferee['is_getmoney'] == 0 && !empty($need_referee)){
                                $add_detail['user_id'] = $need_referee;
                                $add_detail['title'] = '推荐'.$change_needFinal['tel'];
                                $add_detail['user_type'] = $refereeFirst['type'];
                                $add_detail['money'] = $reward['number'];
                                $add_detail['order_type'] = 7;
                                $add_detail['type'] = 1;
                                $add_detail['status'] = 1;
                                $add_detail['create_time'] = time();
                                $add_detail['update_time'] = time();
                                $add_res = Db::name('MoneyDetail')->insertGetId($add_detail);
                                if($add_res) {
                                    $where_addParent['id'] = $need_referee;
                                    $needReferee_add['money'] = $reward['number']+$need_referee['money'];
                                    $needReferee_add['getmoney_id'] = $change_needFinal['user_id'];
                                    $add_parent = Db::name('Member')->where($where_addParent)->update($needReferee_add);
                                    if (!$add_parent) {
                                        Db::rollback();
//                                        $this->apiResponse('0', '确认失败');
                                    }
                                }else{
                                    Db::rollback();
//                                    $this->apiResponse('0','确认失败');
                                }
                            }
                            //                    增加信誉
//                    中介
                            $add_rewResAgency = $this->addReward($agency['amid']);
                            if($add_rewResAgency == false){
                                Db::rollback();
//                                $this->apiResponse('0','增加信誉失败');
                            }

                        }


//                        这里是退款
                        $this->handle($needv,$agency);
                        $needv['user_type'] = Db::name('Member')->where(['id'=>$needv['user_id']])->value('type');
                        $this->need_order_refund($needv,'中介未确认成交退款',5);
                        $agency_list = Db::name('Agency')->alias('a')->join('__MEMBER__ m','a.agency_id = m.id')
                            ->field(['a.*,m.type as user_type'])->where(['a.need_id'=>$needv['id'],'a.status'=>6])->select()->toArray();
                        if (!empty($agency_list)) {
                            foreach ($agency_list as $agency_key => $agency_val) {
                                // 中介报价订单退款
                                $this->agency_order_refund($agency_val, '用户未选择中标中介退款',3);
                            }
                        }
                    }



                }

            }
            Db::commit();
        }
    }


    /**
     * 需求订单退款
     * @param needInfo 用户需求信息
     * @param reason 退款原因
     */
    public function need_order_refund($needInfo,$reason,$reason_id) {
        $order_model = new OrderModel();
        $where = [
            'user_id' => $needInfo['user_id'],
            'type' => 1,
            'need_id' => $needInfo['id'],
            'is_get' => 2,
            'status' => 2
        ];
        // 根据不同订单类型执行退款操作
        $orderInfo = $order_model->where($where)->find();
        if(empty($orderInfo) || $orderInfo['status'] == 1) {
            $this->apiResponse(0,'订单状态错误');
        }
        $orderInfo['user_type'] = $needInfo['user_type'];
        $transaction_id = $orderInfo['transaction_id'];
        $order_sn = $orderInfo['order_sn'];
//        $money = $orderInfo['money'];
        $money = 0.01;
        $out_refund_no = cmf_get_order_sn();
        // 微信
        $refund_result = false;
        if($orderInfo['pay_type'] == 1 || $orderInfo['pay_type'] == 2) {
            $refund_result = $this->wxpay_refund($orderInfo, $transaction_id,$out_refund_no,$money*100,$money*100,$reason,$reason_id);
        }
        // 支付宝
        if($orderInfo['pay_type'] == 3 || $orderInfo['pay_type'] == 4) {
            $refund_result = $this->alipay_refund($orderInfo, $transaction_id,$order_sn,$money,$reason,$reason_id);
        }
        return $refund_result;
    }

    /**
     * 中介报价退款
     * @param agencyInfo 中介报价信息
     * @param reason 退款原因
     */
    public function agency_order_refund($agencyInfo,$reason,$reason_id) {
        $order_model = new OrderModel();
        $where = [
            'user_id' => $agencyInfo['agency_id'],
            'type' => 2,
            'need_id' => $agencyInfo['id'],
            'is_get' => 2,
            'status' => 2
        ];
        // 根据不同订单类型执行退款操作
        $orderInfo = $order_model->where($where)->find();
        if(empty($orderInfo) || $orderInfo['status'] == 1) {
            $this->apiResponse(0,'订单状态错误');
        }
        $orderInfo['user_type'] = $agencyInfo['user_type'];
        $transaction_id = $orderInfo['transaction_id'];
        $order_sn = $orderInfo['order_sn'];
//        $money = $orderInfo['money'];
        $money = 0.01;
        $out_refund_no = cmf_get_order_sn();
        $refund_result = false;
        // 微信
        if($orderInfo['pay_type'] == 1 || $orderInfo['pay_type'] == 2) {
            $refund_result = $this->wxpay_refund($orderInfo, $transaction_id,$out_refund_no,$money*100,$money*100,$reason,$reason_id);
        }
        // 支付宝
        if($orderInfo['pay_type'] == 3 || $orderInfo['pay_type'] == 4) {
            $refund_result = $this->alipay_refund($orderInfo, $transaction_id,$order_sn,$money,$reason,$reason_id);
        }
        return $refund_result;
    }

    /**
     * 支付宝退款接口（两个订单号不能同时为空）
     * @param trade_no 支付宝交易号
     * @param out_trade_no 商户支付订单号
     * @param refund_amount 退款金额
     * @param refund_reason 退款原因
     * @param out_request_no 如需部分退款，传此参数
     */
    private function alipay_refund($orderInfo, $trade_no = null, $out_trade_no = null, $refund_amount, $refund_reason,$reason_id, $out_request_no = null) {
        $data = [
            'trade_no' => $trade_no,
            'out_trade_no' => $out_trade_no,
            'refund_amount' => $refund_amount,
            'refund_reason' => $refund_reason,
            'out_request_no' => $out_request_no
        ];
        $result = $this->refund->refund($data);
        $refund_model = new RefundModel();
        $money_detail_model = new MoneyDetailModel();
        if($result->code == '10000' && $result->msg == 'Success') {
            $insert = [
                'order_id' => $orderInfo['id'],
                'order_sn' => $result->out_trade_no,
                'user_id' => $orderInfo['user_id'],
                'user_type' => $orderInfo['user_type'],
                'refund_id' => $result->trade_no,
                'money' => $orderInfo['money'],
                'pay_type' => 2,
                'status' => 2,
                'reason' => $reason_id,
                'create_time' => time(),
                'update_time' => time(),
                'refund_time' => strtotime($result->gmt_refund_pay),
                'more' => json_encode($result)
            ];
            $refund_result = $refund_model->insertGetId($insert);
            $money_insert = [
                'order_id' => $orderInfo['id'],
                'user_id' => $orderInfo['user_id'],
                'user_type' => $orderInfo['user_type'],
                'title' => '退款',
                'money' => $orderInfo['money'],
                'order_type' => $orderInfo['type'],
                'type' => 1,
                'reason' => $reason_id,
                'create_time' => time(),
                'update_time' => time()
            ];
            $money_result = $money_detail_model->insertGetId($money_insert);
            $update = [
                'status' => 4,
                'refund_time' => strtotime($result->gmt_refund_pay)
            ];
            $order_result = Db::name('Order')->where(['id'=>$orderInfo['id']])->update($update);
            if(!$refund_result || !$order_result || !$money_result) {
                Db::rollback();
                return false;
            }
            return true;
        } else {
            $insert = [
                'order_id' => $orderInfo['id'],
                'user_id' => $orderInfo['user_id'],
                'user_type' => $orderInfo['user_type'],
                'pay_type' => 2,
                'status' => 4,
                'reason' => $reason_id,
                'create_time' => time(),
                'update_time' => time(),
                'refund_time' => time(),
                'more' => json_encode($result)
            ];
            $refund_model->insertGetId($insert);
            return false;
        }
    }

    /**
     * 支付宝退款查询接口（两个订单号不能同时为空）
     * @param trade_no 支付宝交易号
     * @param out_trade_no 商户支付订单号
     * @param refund_amount 退款金额
     * @param refund_reason 退款原因
     * @param out_request_no 如需部分退款，传此参数
     */
    private function alipay_refundquery($trade_no = null, $out_trade_no = null, $refund_amount, $refund_reason, $out_request_no = null) {
        $refund = controller('Alipay','controller');
        $data = [
            'trade_no' => $trade_no,
            'out_trade_no' => $out_trade_no,
            'refund_amount' => $refund_amount,
            'refund_reason' => $refund_reason,
            'out_request_no' => $out_request_no
        ];
        return $refund->refund($data);
    }

    /**
     * 微信退款接口（两个订单号不能同时为空）
     * @param orderInfo 支付订单信息
     * @param transaction_id 微信业务订单号
     * @param out_refund_no 商户退款订单号
     * @param total_fee 订单金额
     * @param refund_fee 退款金额
     * @param refund_desc 退款原因
     */
    private function wxpay_refund($orderInfo, $transaction_id = null, $out_refund_no = null, $total_fee, $refund_fee, $refund_desc,$reason_id) {
        require_once VENDOR_PATH.'WxpayAPI/WxRefund.php';
        $refund = new \WxRefund(Config::get('wx_appid'),Config::get('wx_mch_id'),Config::get('wx_key'),$transaction_id,
            $out_refund_no,$total_fee,$refund_fee,$refund_desc);
        $result = $refund->pay();
        if($result['return_code'] == 'SUCCESS' && $result['return_msg'] == 'OK') {
            $refund_model = new RefundModel();
//            $refund = $refund_model->where(['order_sn'=>$result['out_refund_no_0']])->find();
//            if(!empty($refund)) {
//                return $this->wxpay_refundquery($transaction_id, $out_refund_no, $out_refund_no, $refund['refund_id']);
//            }
            if($result['result_code'] == 'SUCCESS') {
                $insert = [
                    'order_id' => $orderInfo['id'],
                    'order_sn' => $result['out_refund_no'],
                    'user_id' => $orderInfo['user_id'],
                    'user_type' => $orderInfo['user_type'],
                    'refund_id' => $result['refund_id'],
                    'money' => $orderInfo['money'],
                    'pay_type' => 1,
                    'reason' => $reason_id,
                    'create_time' => time(),
                    'update_time' => time()
                ];
                $refund_result = $refund_model->insertGetId($insert);
                if(!$refund_result) {
                    return false;
                }
            }
//            return $this->wxpay_refundquery($transaction_id, $out_refund_no, $result['out_refund_no'], $insert['refund_id']);
        } else {
            cache('refund',$result);
            return false;
        }
    }

    /**
     * 微信退款查询接口（四个订单号不能同时为空）
     * @param transaction_id 微信业务订单号
     * @param out_trade_no 商户退款订单号
     * @param out_refund_no 商户退款订单号
     * @param refund_id 微信退款单号
     */
    private function wxpay_refundquery($transaction_id = null, $out_trade_no = null, $out_refund_no = null, $refund_id = null) {
        require_once VENDOR_PATH.'WxpayAPI/WxRefundQuery.php';
        $refund = new \WxRefundQuery(Config::get('wx_appid'),Config::get('wx_mch_id'),Config::get('wx_key'),$transaction_id,
            $out_trade_no,$out_refund_no,$refund_id);
        $result = $refund->pay();
        $refund_model = new RefundModel();
        $refund = $refund_model->where(['refund_id'=>$result['refund_id_0']])->find();
        if($refund['status'] == 2) {
            return true;
        }
        if($result['return_code'] == 'SUCCESS' && $result['return_msg'] == 'OK') {
            Db::startTrans();
            $refund_success_time = 0;
            if(!empty($result['refund_success_time_0'])) {
                $refund_success_time = strtotime($result['refund_success_time_0']);
            }
            $refund_update = [
                'status' => 2,
                'update_time' => time(),
                'refund_time' => $refund_success_time
            ];
            $refund_result = $refund_model->where(['id'=>$refund['id']])->update($refund_update);
            if(!$refund_result) {
                Db::rollback();
                return false;
            }
            $order_model = new OrderModel();
            $order_update = [
                'status' => 4,
                'update_time' => time(),
                'refund_time' => $refund_success_time
            ];
            $order_result = $order_model->where(['id'=>$refund['order_id']])->update($order_update);
            if(!$order_result) {
                Db::rollback();
                return false;
            }
            Db::commit();
        } else {
            $refund_update = [
                'status' => 5,
                'update_time' => time(),
                'remark' => $result['return_msg']
            ];
            $refund_result = $refund_model->where(['id'=>$refund['id']])->update($refund_update);
            return false;
        }
    }




//    发布需求，匹配中介(暂未调用)
    public function sendNeed($need_id){
        header("Content-Type: text/html;charset=utf-8");
        $where_need['id'] = $need_id;
        $where_need['status'] = array('in','2,3');
        $need_list = Db::name('UserNeed')->where($where_need)->field("id,city,quarters")->find();
        if($need_list){
            $final_arr = array();
            $code = 'SMS_137674888';
            $where_member['type'] = 2;
            $where_member['status'] = array('neq','8,9');
//        查询，匹配:省市区县精确匹配，小区名模糊匹配（只要有连续字匹配，就算匹配）
            $member_find = Db::name('Member')->where($where_member)->field("id,name,tel,city,quarters")->select()->toArray();
            foreach ($member_find as $mek=>$mev){
                if($need_list['city'] == $mev['city']){
//                    $quarters = explode('+',$mev['quarters']);
//                    foreach ($quarters as $quak=>$quav){
                        if(strpos($mev['quarters'],$need_list['quarters']) !== false){
                            $final_arr[] =  $mev;
                            $final_tel[] = $mev['tel'];
                            $middle_arr['name'] = $mev['name'];
                            $middle_arr['name2'] = $need_list['quarters'];
                            $final_mes[] = $middle_arr;
                            $final_autograph[] = '比房价';
                        }
//                    }
                }
            }
            if(!empty($final_tel)){
                $json_tel = json_encode($final_tel,JSON_UNESCAPED_UNICODE);
                $json_mes = json_encode($final_mes,JSON_UNESCAPED_UNICODE);
                $json_autograph = json_encode($final_autograph,JSON_UNESCAPED_UNICODE);
                $res_mes = $this->sendLogin($json_tel,$code,$json_mes,$json_autograph);
                $mes = $res_mes->Message;
                if($mes != 'OK'){
                    if($mes == '触发分钟级流控Permits:1'){
                        $this->apiResponse('0','请在一分钟后获取验证码');
                    }else if($mes == '触发小时级流控Permits:5'){
                        $this->apiResponse('0', '请在一小时后获取验证码');
                    }else{
                        $this->apiResponse('0', $mes);
                    }
                }
            }
        }

    }




    // 添加推荐人余额
    public function handle($need,$agency)
    {
        //                    分别查询用户，中介推荐人
        $where_m['id'] = $need['user_id'];
        $refereeFirst = Db::name('Member')->where($where_m)->field('id,referee_id,money')->find();
        if(!empty($refereeFirst['referee_id'])) {
            $need_referee = $refereeFirst['referee_id'];
//                        诚意金金额获取
            $where_reward['type'] = 5;
            $where_reward['status'] = 1;
            $reward = Db::name('Reward')->where($where_reward)->find();
//                    查询推荐人是否已获得奖励
//                    需求用户
            $where_nref['id'] = $need_referee;
            $is_needReferee = Db::name('Member')->where($where_nref)->field('is_getmoney')->find();
            if ($is_needReferee['is_getmoney'] == 0) {
                $add_detail['user_id'] = $need_referee;
                $add_detail['title'] = '推荐'.$refereeFirst['tel'];
                $add_detail['money'] = $reward['number'];
                $add_detail['order_type'] = 7;
                $add_detail['type'] = 1;
                $add_detail['status'] = 1;
                $add_detail['create_time'] = time();
                $add_detail['update_time'] = time();
                $add_res = Db::name('MoneyDetail')->insertGetId($add_detail);
                if ($add_res) {
                    $where_addParent['id'] = $need_referee;
                    $needReferee_add['money'] = $reward['number'] + $need_referee['money'];
                    $needReferee_add['getmoney_id'] = $need['user_id'];
                    $add_parent = Db::name('Member')->where($where_addParent)->update($needReferee_add);
                    if (!$add_parent) {
                        Db::rollback();
                        $this->apiResponse('0', '确认失败',$refereeFirst);
                    }
                } else {
                    Db::rollback();
                    $this->apiResponse('0', '确认失败');
                }
            }
        }
        if(!empty($agency['referee_id'])) {
            $agency_referee = $agency['referee_id'];
//                    中介用户
            $where_aref['id'] = $agency_referee;
            $is_agencyReferee = Db::name('Member')->where($where_aref)->field('is_getmoney')->find();
            if($is_agencyReferee['is_getmoney'] == 0){
                $add_detailNext['user_id'] = $agency_referee;
                $add_detailNext['title'] = '推荐'.$agency['tel'];;
                $add_detailNext['money'] = $reward['number'];
                $add_detailNext['order_type'] = 7;
                $add_detailNext['type'] = 1;
                $add_detailNext['status'] = 1;
                $add_detailNext['create_time'] = time();
                $add_detailNext['update_time'] = time();
                $add_resNext = Db::name('MoneyDetail')->insertGetId($add_detailNext);
                if($add_resNext) {
                    $where_addParentNext['id'] = $agency_referee;
                    $needReferee_addNext['money'] = $reward['number']+$agency['amoney'];
                    $needReferee_addNext['getmoney_id'] = $agency['amid'];
                    $needReferee_addNext['update_time'] = time();
                    $add_parentNext = Db::name('Member')->where($where_addParentNext)->update($needReferee_addNext);
                    if (!$add_parentNext) {
                        Db::rollback();
                        $this->apiResponse('0', '确认失败2');
                    }
                }else{
                    Db::rollback();
                    $this->apiResponse('0','确认失败1');
                }
            }
        }

    }



    //  短信验证码
    public function sendLogin($tel,$code,$modelVal,$json_autograph){
        require_once VENDOR_PATH."aliyun-dysms-php-sdk/api_demo/SmsDemo.php";
        set_time_limit(0);
        header('Content-Type: text/plain; charset=utf-8');
        $response = SmsDemo::sendBatchSms($tel,$code,$modelVal,$json_autograph);
        return $response;
    }

    /**
     * 人机验证接口
     */
    public function luosimao() {
        $data = $this->request->param();
        $return = $this->curl('129be932c145c773f436eeb263465339',$data['response']);
        $this->apiResponse(1,'成功',$return);
    }

    //人机验证提交curl
    public function curl($api_key,$response) {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, "https://captcha.luosimao.com/api/site_verify");

        curl_setopt($ch, CURLOPT_HTTP_VERSION  , CURL_HTTP_VERSION_1_0 );
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 8);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
        curl_setopt($ch, CURLOPT_HEADER, FALSE);

        curl_setopt($ch, CURLOPT_HTTPAUTH , CURLAUTH_BASIC);
        curl_setopt($ch, CURLOPT_USERPWD  , 'api:key-'.$api_key);

        curl_setopt($ch, CURLOPT_POST, TRUE);
        curl_setopt($ch, CURLOPT_POSTFIELDS, array('api_key' => $api_key,'response' => $response));

        $res = curl_exec( $ch );
        curl_close( $ch );
//$res  = curl_error( $ch );
//        var_dump($res);
        return $res;
    }


    //增加信誉
//  $id  => 中介id
    public function addReward($id){
        $where_reNex['type'] = 4;
        $where_reNex['status'] = array('neq',9);
        $rewardNex = Db::name('Reward')->where($where_reNex)->find();
        if($rewardNex){
            $where_memNex['id'] = $id;
            $where_memNex['type'] = 2;
            $save_memNex = Db::name('Member')->where($where_memNex)->setInc('reputation',$rewardNex['number']);
            if(!$save_memNex){
                return false;
            }else{
                $saveLog['type'] = 4;
                $saveLog['number'] = $rewardNex['number'];
                $saveLog['recommen'] = $id;
                $saveLog['create_time'] = time();
                $saveLog['update_time'] = time();
                $resSaveLog = Db::name('RewardLog')->insertGetId($saveLog);
                if($resSaveLog){
                    return true;
                }else{
                    return false;
                }

            }
        }
        return true;
    }
}