youxiangjie/application/api/controller/Order.php

<?php

namespace app\api\controller;

use app\api\model\Address;
use app\api\model\Commoditycolor;
use app\api\model\CommodityModel;
use app\api\model\Logistics;
use app\api\model\OrderModel;
use app\api\model\Torder;
use app\api\model\UsersModel;
use app\common\controller\Api;
use app\common\lib\WxPay;
use think\Cache;
use think\Db;
use think\File;

/**
 * 订单接口
 */
class Order extends Api
{
    protected $noNeedLogin = '*';
    protected $noNeedRight = '*';

    /**
     * 购物车总价统计
     * @ApiMethod   (POST)
     * @param string $list colorid,number
     */
    public function carMoney()
    {
        $params = $this->request->post();
        if (!isset($params['list'])) {
            return $this->result('网络错误', [], 100);
        }
        $list = $params['list'];
        foreach ($list as $v) {
            $commoditycolor[] = Commoditycolor::where('colorid', $v)->find();
        }
        if ($commoditycolor) {
            $money = 0;
            $number = $params['number'];
            $count = count($number);
            for ($i = 0; $i < $count; $i++) {
                $money = $money + $commoditycolor[$i]['money'] * $number[$i];
            }
            return $this->result('', $money, 200);
        } else {
            return $this->result('网络错误', [], 100);
        }
    }

    /**
     * 订单先提交
     * @ApiMethod   (POST)
     * @param string $user_id 用户id
     * @param string $list 商品参数c_id,buy_number,p_id,colorid
     */
    public function orderGenerate()
    {
        $params = $this->request->post();
        if (!isset($params['user_id'])) {
            return $this->result('网络错误', [], 100);
        }
        if (!isset($params['list'])) {
            return $this->result('网络错误', [], 100);
        }
        $list = $params['list'];
        $rules = [
            'buy_number' => "require|number",
            'colorid'    => "require|number",
        ];
        $msg = [
            'buy_number.require' => '未选择购买数量',
            'colorid.require'    => '未选择颜色',
            'colorid.number'     => '网络错误',
            'buy_number.number'  => '网络错误',
        ];
        foreach ($list as $v) {
            $validata = $this->validate($v, $rules, $msg);
            if (is_string($validata)) {
                return $this->result($validata, [], 100);
            }
            $colorids[] = $v['colorid'];       //颜色id放在同一个数组里
            $buy_numbers[] = $v['buy_number']; // 购买数量放在同一个数组里
        }
        $colorid = implode(',', $colorids);       // 颜色数组拆分成为字符串
        $buy_number = implode(',', $buy_numbers); //数量数组拆分成为字符串
        $data = array(
            'user_id'     => $params['user_id'],
            'colorid'     => $colorid,
            'buy_number'  => $buy_number,
            'create_time' => date('Y-m-d H:i:s', time()),
        );
        $addPre = Db::name('order_pre')->insertGetId($data);
        if ($addPre) {
            return $this->result('', $addPre, 200);
        } else {
            return $this->result('请求失败，请重新购买', [], 100);
        }
    }

    /**
     * 支付订单显示
     * @ApiMethod   (POST)
     * @param string $pre_id 订单提交返回的值
     */
    public function preOrderIndex()
    {
        $pre_id = $this->request->post('pre_id');
        if (!$pre_id) {
            return $this->result('网络错误1', [], 100);
        }
        $order_pre = Db::name('order_pre')->where('pre_id', $pre_id)->find(); //查出预存订单
        $order_pre['colorid'] = explode(',', $order_pre['colorid']);          // 批量拆分id
        $order_pre['buy_number'] = explode(',', $order_pre['buy_number']);    // 批量拆分购买数量
        $count = count($order_pre['buy_number']);
        $commoditycolor = new Commoditycolor();
        for ($i = 0; $i < $count; $i++) {
            $data1[] = $commoditycolor->alias('co')
                ->join('parameter p', 'co.p_id = p.p_id', 'left')
                ->join('commodity c', 'p.c_id = c.c_id', 'left')
                ->where('co.colorid', $order_pre['colorid'][$i])
                ->find();  // 循环查出购买的商品
            foreach ($data1 as &$v) {
                $v['zongmoney'] = $v['money'];
            }
        }
        $data = $data1;
        $data['params']['money'] = 0;                                  // 总价
        $data['params']['freight'] = 0;                                // 运费
        $data['params']['number'] = "yxj" . rand(1000, 9999) . time(); // 订单编号
        $data['params']['create_time'] = $order_pre['create_time'];    // 创建时间
        $data['params']['whitebean'] = 0;                              // 白豆个数
        for ($i = 0; $i < $count; $i++) {
        $data[$i]['buy_number'] = $order_pre['buy_number'][$i];                                                                          // 循环写入购买数量
        $data[$i]['zongmoney'] = $order_pre['buy_number'][$i] * $data[$i]['zongmoney']+ $data[$i]['c_freight'];                                                  // 循环写入单个商品总价
        $data['params']['freight'] = $data['params']['freight'] + $data[$i]['c_freight'];                                                // 总运费
        $data['params']['money'] = $data['params']['money'] + $data[$i]['zongmoney'];                                       // 总费用
        $data['params']['whitebean'] = $data['params']['whitebean'] + $data[$i]['c_whitebean'] * $order_pre['buy_number'][$i];            // 总白豆数
        }
        // 把统计出来的总价，写入数据库
        $preAddMoney = Db::name('order_pre')->where('pre_id', $pre_id)->setInc('money', $data['params']['money']);
        $order['params'] = $data['params'];
        unset($data['params']);
        $order['order'] = $data;
        // 查出用户地址
        $order['address'] = Address::where('user_id', $order_pre['user_id'])->order('is_default desc')->select();
        if ($data && $preAddMoney) {
            return $this->result('', $order, 200);
        } else {
            return $this->result('网络错误', [], 100);
        }
    }

    /**
     * 支付订单数量修改
     * @ApiMethod   (POST)
     * @param string $pre_id 订单提交返回的值
     * @param string $buy_number 修改后数量
     * @param string $position 修改的第几个
     */
    public function updBuyNumber()
    {
        $params = $this->request->post();
        $rules = [
            'pre_id'     => 'require',
            'buy_number' => 'require',
            'position'   => 'require',
        ];
        $msg = [
            'pre_id.require'     => '网络错误',
            'buy_number.require' => '网络错误',
            'position.require'   => '网络错误',
        ];
        $validate = $this->validate($params, $rules, $msg);
        if (is_string($validate)) {
            return $this->result($validate, [], 100);
        }
        $order_pre = Db::name('order_pre')->where('pre_id', $params['pre_id'])->find();
        if (!$order_pre) {
            return $this->result('未找到该订单', [], 100);
        }
        $buynumber = explode(',', $order_pre['buy_number']);
        foreach ($buynumber as $k => $v) {
            if ($k == $params['position']) {
                $buynumber[$k] = $params['buy_number'];
            }
        }
        $str = implode(',', $buynumber);
        $upd = Db::name('order_pre')->where('pre_id', $params['pre_id'])->update(['buy_number' => $str]);
        if ($upd) {
            return $this->result('成功', $params['pre_id'], 200);
        } else {
            return $this->result('点击频率过高', [], 100);
        }
    }

    /**
     * 支付订单
     * @ApiMethod   (POST)
     * @param string $pre_id 预存id
     * @param string $list 商品参数,c_id,buy_number,p_id
     * @param string $user_id 用户id
     * @param string $money 总价
     * @param string $a_id 地址id
     * @param string $freight 运费
     * @param string $whitebean 总白豆数
     * @param string $create_time 创建时间
     * @param string $number 编号
     * @param string $user_paypwd 余额支付密码
     * @param string $type 0余额支付1第四方支付
     */
    public function orderPay()
    {
        $parames = $this->request->post();
        $rules = [
            'pre_id'      => 'require|number',
            'user_id'     => 'require',
            'money'       => 'require',
            'a_id'        => 'require',
            'freight'     => 'require',
            'whitebean'   => 'require',
            'user_paypwd' => 'require',
            'type'        => 'require|max:1',
        ];
        $msg = [
            'pre_id.require'      => '网络错误1',
            'user_id.require'     => '网络错误2',
            'money.require'       => '网络错误3',
            'a_id.require'        => '网络错误4',
            'freight.require'     => '网络错误9',
            'whitebean.require'   => '网络错误10',
            'user_paypwd.require' => '网络错误10',
            'type.require'        => '网络错误11',
            'type.max'            => '网络错误12',
            'pre_id.number'       => '网络错误13',
        ];
        $validata = $this->validate($parames, $rules, $msg);
        if (is_string($validata)) {
            return $this->result($validata, [], 100);
        }
        $order = new OrderModel();
        if ($parames['type'] == 0) {
            $res = $order->userMoneyPay($parames);
            return $res;
        }
        if ($parames['type'] == 1) {
            $res = $order->wechatOrder($parames);
            return $res;
        }
    }

    /**
     * 是否设置了余额支付密码
     * @ApiMethod   (POST)
     * @param string $user_id 用户id
     */
    public function issetpaypwd()
    {
        $user_id = $this->request->post('user_id');
        if (!$user_id) {
            return $this->result('网络错误', [], 100);
        }
        $userinfo = UsersModel::where('user_id', $user_id)->find();
        if ($userinfo) {
            if ($userinfo['is_setpaypwd'] == 0) {
                return $this->result('还未设置支付密码', [], 90);
            } else {
                return $this->result('正确', [], 200);
            }
        } else {
            return $this->result('网络错误', [], 100);
        }
    }

    /**
     * 全部订单
     * @ApiMethod   (POST)
     * @param string $user_id 用户id
     */
    public function allOrder()
    {
        $user_id = $this->request->post('user_id');
        if (!isset($user_id)) {
            return $this->result('网络错误', '', 100);
        }
        $order = new OrderModel();
        $data = $order->allOrder($user_id);
        return $data;
    }

    /**
     * 确认收货
     * @ApiMethod   (POST)
     * @param string $o_id 订单id；
     */
    public function trueOrder()
    {
        $o_id = $this->request->post('o_id');
        if (!isset($o_id)) {
            return $this->result('网络错误', '', 100);
        }
        $order = Db::name('order')->where('o_id', $o_id)->find();
        $updOrder = OrderModel::where('o_id', $o_id)->update(['state' => 6]);
        $updUserWhitebean = Db::name('users')->where('user_id', $order['user_id'])->setInc('user_whitebean', $order['whitebeon']);
        if ($updOrder && $updUserWhitebean) {
            return $this->result('收货成功', '', 200);
        } else {
            return $this->result('网络错误', '', 100);
        }
    }

    /**
     * 取消订单
     * @ApiMethod   (POST)
     * @param string $o_id 订单id；
     */
    public function orderCancel()
    {
        $o_id = $this->request->post('o_id');
        if (!isset($o_id)) {
            return $this->result('网络错误', '', 100);
        }
        $updOrder = OrderModel::where('o_id', $o_id)->update(['state' => 5]);
        if ($updOrder) {
            return $this->result('取消成功', '', 200);
        } else {
            return $this->result('网络错误', '', 100);
        }
    }

    /**
     * 删除订单
     * @ApiMethod   (POST)
     * @param string $o_id 订单id；
     */
    public function delOeder()
    {
        $o_id = $this->request->post('o_id');
        if (!isset($o_id)) {
            return $this->result('网络错误', '', 100);
        }
        $updOrder = OrderModel::where('o_id', $o_id)->delete();
        if ($updOrder) {
            return $this->result('删除成功', '', 200);
        } else {
            return $this->result('网络错误', '', 100);
        }
    }

    /**
     * 各种订单详情
     * @ApiMethod   (POST)
     * @param string $o_id 订单id
     */
    public function orderInfo()
    {
        $o_id = $this->request->post('o_id');
        if (!$o_id) {
            return $this->result('网络错误', [], 100);
        }
        $orderInfo = OrderModel::with(['OrderCommodityModel', 'OrderAddress'])
            ->where('o_id', $o_id)
            ->find()
            ->toArray();
        $orderInfo['wecharpay'] = Db::name('order_wechatpay')->where('o_id',$orderInfo['o_id'])->find();
        unset($orderInfo['wecharpay']['o_id']);
        unset($orderInfo['wecharpay']['w_id']);
        if (!$orderInfo) {
            $orderInfo = [];
        } else {
            foreach ($orderInfo['order_commodity_model'] as &$n) {
                $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
                if (!$commodity) {
                    $n['c_name'] = '已下架商品';
                } else {
                    $n['c_name'] = $commodity['c_name'];
                }
                $n['c_money'] = $n['c_vipprice'] * $n['buy_number'];  // c_vipprice存的是颜色商品的价格，而不是商品的初始价格
                $n['money'] = $n['c_money'] + $n['c_freight'];
                //$n['freight'] = $n['c_freight'] * $n['buy_number'];
            }
        }
        if ($orderInfo) {
            return $this->result('', $orderInfo, 200);
        } else {
            return $this->result('暂无数据', [], 100);
        }
    }

    /**
     * 查看物流
     * @ApiMethod   (POST)
     * @param string $o_id 订单id
     */
    public function logistics()
    {
        $o_id = $this->request->post('o_id');
        if (!$o_id) {
            return $this->result('网络错误', [], 100);
        }
        $order = OrderModel::with(['OrderCommodityModel', 'OrderAddress'])->where('o_id', $o_id)->find()->toArray();
        foreach ($order['order_commodity_model'] as &$n) {
            $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name,c_images')->find();
            if (!$commodity) {
                $n['c_name'] = '已下架商品';
            } else {
                $n['c_name'] = $commodity['c_name'];
                $order['c_images'][] = $commodity['c_images'];

            }
        }
        $model = new Logistics();
        $res = $model->logistics($order);
        return $res;
    }

    /**
     * 退款订单显示
     * @ApiMethod   (POST)
     * @param string $o_id 订单id
     */
    public function torderIndex()
    {
        $o_id = $this->request->post('o_id');
        if (!isset($o_id)) {
            return $this->result('网络错误', '', 100);
        }
        $orderInfo = OrderModel::with(['OrderCommodityModel', 'OrderAddress'])->where('o_id', $o_id)->find();
        foreach ($orderInfo['order_commodity_model'] as $n) {
            $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
            if (!$commodity) {
                $n['c_name'] = '已下架商品';
            } else {
                $n['c_name'] = $commodity['c_name'];
            }
        }
        if ($orderInfo) {
            return $this->result('', $orderInfo, 200);
        } else {
            return $this->result('网络错误', [], 100);
        }
    }

    /**
     * 退款提交
     * @ApiMethod   (POST)
     * @param string $o_id 订单id
     * @param string $reason 原因
     * @param string $money 金额
     * @param string $content 说明
     * @param string $files 图片
     */
    public function subTorder()
    {
        $params = $this->request->post();
        if (!isset($params['o_id'])) {
            return $this->result('网络错误', [], 100);
        }
        if (!isset($params['money'])) {
            return $this->result('网络错误', [], 100);
        }
        //修改订单状态
        $order = OrderModel::where('o_id', $params['o_id'])->find();
        $data = array(
            'state'         => 4,
            'tuikuan_state' => 3,
            'state_save'    => $order['state']
        );
        if(isset($params['files'])) {
            $params['images'] = implode(',',$params['files']);
        }
        $params['money'] = $order['money'];
        $params['create_time'] = date('Y-m-d H:i:s', time());
        $updOrder = OrderModel::where('o_id', $params['o_id'])->Update($data);
        $model = new Torder();
        $subTorder = $model->allowField(true)->save($params);
        if ($subTorder) {
            return $this->result('申请退款成功', [], 200);
        } else {
            return $this->result('申请失败', [], 100);
        }
    }
    /**
     * 退款图片上传
     * @ApiMethod   (POST)
     * @param File $files 图片
     */
    public function upload()
    {
        $files = $_FILES;
        $imageArr = Array();
        foreach ($files as $file) {
            $imageName = $file['name'];
            //后缀名
            $ext = strtolower(substr(strrchr($imageName, '.'), 1));
            //保存文件名
            $fileName = uniqid();
            $tmp = $file['tmp_name'];
            //保存 = 路径 + 文件名 + 后缀名
            $imageSavePath = ROOT_PATH . 'public' . DS . 'uploads/images/' . $fileName . '.' . $ext;
            $info = move_uploaded_file($tmp, $imageSavePath);
            if ($info) {
                $path = config('site.httpurl')."/uploads/images/" . $fileName . '.' . $ext;
                array_push($imageArr, $path);
            }
        }
        //最终生成的字符串路径
        $imagePathStr = implode(',', $imageArr);
        return $imagePathStr;
    }
    /**
     * 取消退款
     * @ApiMethod   (POST)
     * @param string $o_id 订单id
     */
    public function cancleTorder()
    {
        $o_id = $this->request->post('o_id');
        if (!isset($o_id)) {
            return $this->result('网络错误', [], 100);
        }
        $order = OrderModel::where('o_id', $o_id)->find();
        if (!$order) {
            return $this->result('未找到该订单', [], 100);
        }
        // 修改成为退款之前的状态
        $updOrder = OrderModel::where('o_id', $o_id)->update(['state' => $order['state_save']]);
        if ($updOrder) {
            return $this->result('取消成功', [], 200);
        } else {
            return $this->result('失败', [], 100);
        }
    }

    /**
     * 退款订单详情
     * @ApiMethod   (POST)
     * @param string $o_id 订单id
     */
    public function torderInfo()
    {
        $o_id = $this->request->post('o_id');
        if (!isset($o_id)) {
            return $this->result('网络错误', [], 100);
        }
        $orderInfo = OrderModel::with(['OrderCommodityModel', 'OrderAddress', 'Torder'])->where('o_id', $o_id)->find();
        foreach ($orderInfo['order_commodity_model'] as $n) {
            $commodity = CommodityModel::where('c_id', $n['c_id'])->field('c_name')->find();
            if (!$commodity) {
                $n['c_name'] = '已下架商品';
            } else {
                $n['c_name'] = $commodity['c_name'];
            }
        }
        if ($orderInfo) {
            return $this->result('', $orderInfo, 200);
        } else {
            return $this->result('未找到该订单', [], 100);
        }
    }

    /**
     * 微信订单支付回调
     * 可以通过@ApiInternal忽略请求的方法
     * @ApiInternal
     */
    public function order_notify()
    {
        //获取返回的xml格式数据
        $payXml = file_get_contents("php://input");
        //将xml格式转化为json格式
        $jsonXml = json_encode(simplexml_load_string($payXml, 'SimpleXMLElement', LIBXML_NOCDATA));
        //将json格式转成数组格式 $result['out_trade_no']
        $result = json_decode($jsonXml, true);
        Cache::set('result',$result);
        if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
            $order = OrderModel::where('number', $result['out_trade_no'])->find();
            //修改订单状态
            $updOederstate = Db::name('order')->where('o_id', $order['o_id'])->update(['state' => 2]);
            $updwhitebean = Db::name('users')->where('user_id', $order['user_id'])->setInc('user_whitebean', $order['whitebeon']);
            if ($updOederstate && $updwhitebean) {
                $arr = array(
                    'return_code' => 'SUCCESS',
                    'return_msg'  => 'OK',
                );
                return $this->arrayToXml($arr);
            }
        }
    }
    /**
     * 微信退款订单回调
     * 可以通过@ApiInternal忽略请求的方法
     * @ApiInternal
     */
    public function notify_refund()
    {
        $payXml = file_get_contents("php://input");
        //将xml格式转化为json格式
        $jsonXml = json_encode(simplexml_load_string($payXml, 'SimpleXMLElement', LIBXML_NOCDATA));
        //将json格式转成数组格式 $result['out_trade_no']
        $result = json_decode($jsonXml, true);
        if ($result['return_code'] == "SUCCESS") {
            $str = $result['req_info'];
            // 对加密信息进行解密,需要用到商户秘钥
            $data = $this->req_info_decrypt($str);
            // Cache::set('req_info', $data);
            if ($data['refund_status'] == "SUCCESS") {
                //修改退款状态
                $updstate = Db::name("order")->where('number', $data['out_trade_no'])->update(['tuikuan_state' => '1']);
                $arr = array(
                    'return_code' => 'SUCCESS',
                    'return_msg'  => 'OK',
                );
                return $this->arrayToXml($arr);
            }
        }
        Cache::set('aaa', $result);
        $arr = array(
            'return_code' => 'SUCCESS',
            'return_msg'  => 'OK',
        );
        return $this->arrayToXml($arr);
    }

    /**
     * 信息解密
     * 对加密信息进行解密,需要用到商户秘钥
     * 可以通过@ApiInternal忽略请求的方法
     * @ApiInternal
     */
    public function req_info_decrypt($str)
    {
        //微信商户key
        $key = "b3ae6bbf3cc4fa017eb169ae219e2c27";
        $str = base64_decode($str);
        $xml = openssl_decrypt($str, 'aes-256-ecb', md5($key), OPENSSL_RAW_DATA);
        return json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);
    }

    /**
     * 数组转xml
     * @ApiInternal
     */
    public function arrayToXml($arr)
    {
        $xml = "<xml>";
        foreach ($arr as $key => $val) {
            if (is_numeric($val)) {
                $xml .= "<" . $key . ">" . $val . "</" . $key . ">";
            } else
                $xml .= "<" . $key . "><![CDATA[" . $val . "]]></" . $key . ">";
        }
        $xml .= "</xml>";
        return $xml;
    }
}