<?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\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;
    public function __construct(PortalPostModel $postModel)
    {
        parent::__construct();
        $this->postModel = $postModel;
    }

    /**
     *  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']*10000 + $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')->find();
        $time = time();
        if($time < $userNeedList['pay_time']+1800){
            $this->apiResponse('0','未到发布时间');
        }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->apiResponse('1','成功',$return);
            }else{
                Db::rollback();
                $this->apiResponse('0','失败');
            }
        }
    }


    /**
     * @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();
        $this->isLogin($data['token']);
        if(empty($data['need_id'])){
            $this->apiResponse('0','需求id不能为空');
        }
//        查询用户发布需求信息
        $where_need['status'] = 3;
        $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')->find();
        if(!$userNeedList){
            $this->apiResponse('0','需求状态不正确');
        }
        $userNeedList['user_type'] = Db::name('Member')->where(['id'=>$userNeedList['user_id']])->value('type');
        $time = time();
//        查询相应报价
        $final_time = $userNeedList['pay_time'] + $userNeedList['quotation_time'] * 86400;
//            判断时间是否正确
        if ($time >= $final_time) {
//                $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')
                ->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){
                    $ten_money = $tenv['housing_price'] * 10000 + $tenv['assessment_tax'] + $tenv['security_tax'] + $tenv['else_tax'] + $tenv['service_charge'];
                    if($ten_money > 100000){
                        $is_trueMoney[] = $tenv;
                    }
                }
                //        判断是否超过三个报价人
                if (count($is_trueMoney) >= 3) {
//                    查询三人中是否有品牌中介
//                        循环匹配品牌企业
                    foreach ($is_trueMoney as $agencyk => $agencyv) {
                        foreach ($band_list as $brak => $brav) {
//                            判断是否在品牌企业中
                            if (strstr($brav, $agencyv['company']) !== false) {
//                                存在
                                $agen_money = $agencyv['housing_price'] * 10000 + $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'] * 10000 + $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();
            $this->apiResponse('1','成功',$return);
        }else{
            $this->apiResponse('0','时间不正确');
        }
//        }
    }

    /**
     * @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'] = 5;
        $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 (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 {
                    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_need['status'] = 7;
        $where_need['id'] = $data['need_id'];
        $need_list = Db::name('UserNeed')->where($where_need)->field('id,choose_time')->find();
        if($need_list){
//            foreach ($need_list as $needk=>$needv){
            if(time() >= ($need_list['choose_time']+259200)){
                $where_agency['status'] = 5;
                $where_agency['need_id'] = $need_list['id'];
                $agency = Db::name('Agency')->where($where_agency)->find();
//                    修改中介报价状态
                if($agency){
                    $where_changeAgency['id'] = $agency['id'];
                    $changeAgency['status'] = 10;
                    $changeAgency['update_time'] = time();
                    $update_a = Db::name('Agency')->where($where_changeAgency)->update($changeAgency);
                    if(!$update_a){
                        Db::rollback();
                    }
                }
//                    修改用户需求状态
                $where_needChange['id'] = $need_list['id'];
                $update_need['status'] = 8;
                $update_need['update_time'] = time();
                $change_needFinal = Db::name('UserNeed')->where($where_needChange)->update($update_need);
                if (!$change_needFinal) {
                    Db::rollback();
                }
                $need_list['user_type'] = Db::name('Member')->where(['id'=>$need_list['user_id']])->value('type');
                $this->need_order_refund($agency,'中介未确认成交退款',5);
            }
//            }
            Db::commit();
            $where_return['id'] = $data['need_id'];
            $return = Db::name('UserNeed')->where($where_return)->find();
            $this->apiResponse('1','成功',$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();
        $time = time();
        $change_arr = array();
        foreach ($userNeedList as $userk=>$userv){
            if($time >= $userv['pay_time']+1800){
                $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'] = 3;
        $userNeedList = Db::name('UserNeed')->where($where_need)->field('id,quotation_time,create_time,pay_time,user_id')->select()->toArray();
        $userNeedList['user_type'] = Db::name('Member')->where(['id'=>$userNeedList['user_id']])->value('type');
        $time = time();
//        循环需求，查询相应报价
        foreach ($userNeedList as $uNeedk => $uNeedv) {
            $final_time = $uNeedv['pay_time'] + $uNeedv['quotation_time'] * 86400;
            if ($time >= $final_time) {
                $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')
                    ->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'] * 10000 + $tenv['assessment_tax'] + $tenv['security_tax'] + $tenv['else_tax'] + $tenv['service_charge'];
                        if($ten_money > 100000){
                            $is_trueMoney[] = $tenv;
                        }
                    }


                    //        判断是否超过三个报价人
                    if (count($is_trueMoney) >= 3) {

//                    查询三人中是否有品牌中介
//                        循环匹配品牌企业
                        foreach ($is_trueMoney as $agencyk => $agencyv) {
                            foreach ($band_list as $brak => $brav) {
//                            判断是否在品牌企业中
                                if (strstr($brav, $agencyv['company']) !== false) {
//                                存在
                                    $agen_money = $agencyv['housing_price'] * 10000 + $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'] * 10000 + $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($userNeedList,'报价人数不足',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($userNeedList,'报价人数不足',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'] = 5;
        $userNeedList = Db::name('UserNeed')->where($where_need)->field('id,choose_time,user_id,pay_money,choose_time')->select()->toArray();
        if($userNeedList){
            foreach ($userNeedList as $needk=>$needv) {
                if (time() >= ($needv['choose_time'] + 259200)) {
                    $where_agency['need_id'] = $needv['id'];
                    $where_agency['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['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::startTrans();
        $where_need['status'] = 7;
        $need_list = Db::name('UserNeed')->where($where_need)->field('id,choose_time')->select()->toArray();
        if($need_list){
            foreach ($need_list as $needk=>$needv){
                if(time() >= ($needv['choose_time']+259200)){
                    $where_agency['status'] = 5;
                    $where_agency['need_id'] = $needv['id'];
                    $agency = Db::name('Agency')->where($where_agency)->find();
//                    修改中介报价状态
                    if($agency){
                        $where_changeAgency['id'] = $agency['id'];
                        $changeAgency['status'] = 10;
                        $changeAgency['update_time'] = time();
                        $update_a = Db::name('Agency')->where($where_changeAgency)->update($changeAgency);
                        if(!$update_a){
                            Db::rollback();
                        }
                    }
//                    增加中介保证金变化
                    $add_a['ag_id'] = $agency['id'];
                    $add_a['user_id'] = $agency['agency_id'];
                    $add_a['title'] = '中介未确认';
                    $add_a['type'] = 2;
                    $add_a['money'] = $agency['deposit'];
                    $add_a['create_time'] = time();
                    $add_a['update_time'] = time();
                    $amoney_id = Db::name('AmoenyDetail')->insertGetId($add_a);
                    if (!$amoney_id) {
                        Db::rollback();
                    }
//                    修改用户需求状态
                    $where_needChange['id'] = $needv['id'];
                    $update_need['status'] = 8;
                    $update_need['update_time'] = time();
                    $change_needFinal = Db::name('UserNeed')->where($where_needChange)->update($update_need);
                    if (!$change_needFinal) {
                        Db::rollback();
                    }
                    $need_list['user_type'] = Db::name('Member')->where(['id'=>$need_list['user_id']])->value('type');
                    $this->need_order_refund($agency,'中介未确认成交退款',5);
                }
            }
            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) {
        $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
        ];
        $result = $refund->refund($data);
        $refund_model = new RefundModel();
        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,
                '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);
            $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) {
                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'],
                    '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'] = 3;
        $need_list = Db::name('UserNeed')->where($where_need)->field("id,city,quarters")->find();
        $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(strstr($need_list['quarters'],$quav) !== 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[] = '比房价';
                    }
                }
            }
        }
        $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);
        if($res_mes != 'OK'){
            $this->apiResponse('0',$res_mes);
        }

    }



    //  短信验证码
    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;
    }
}