hongyi/application/api/controller/Order.php

<?php
namespace app\api\controller;

use app\admin\controller\Config;
use EasyWeChat\Factory;
use library\Controller;
use hg\apidoc\annotation as Apidoc;
use think\Db;

/**
 * @title 订单管理
 * @controller Order
 * @group order
 */
class Order extends Base {

    /**
     * 订单列表
     */
    public function order_list(){
        $uid = $this->uid;
        $is_pay = $this->request->param('status');
        $data = $this->request->param('data',0);
        //未刷出订单列表
        if ($is_pay == 2){
            $where[] = ['bo.uid','=',$uid];
            $where[] = ['c.is_deleted','=',0];
            if (empty($uid)){
                $this->error('请通过正规途径进入','','400');
            }
            if (!empty($data['limit'])){
                $limit = $data['limit'];
            }else{
                $limit = 10;
            }
            if (!empty($data['page'])){
                $page = $data['page'];
            }else{
                $page = 1;
            }
            $list = Db::table('hy_brush_order')
                ->alias('bo')
                ->field('bo.id,bo.money,bo.is_pay,c.bank,c.bank_card')
                ->leftJoin('hy_card c','bo.cid=c.id')
                ->where($where)
                ->page($page,$limit)
                ->order('is_pay asc')
                ->select();
            foreach ($list as $k=>$v){
                if ($v['is_pay'] == 1) {
                    $list[$k]['status_name'] = '付款成功';
                }elseif ($v['is_pay'] == 0){
                    $list[$k]['status_name'] = '待付款';
                }
                $bank = Config('bank');
                $list[$k]['bank_name'] = $bank[$v['bank']];
            }
            if ($list){
                $this->success('请求成功',$list,'200');
            }else{
                $this->success('暂无数据',[],'200');
            }
        }
        //订单列表
        else{
            $where[] = ['uid','=',$uid];
            if (strlen($is_pay) > 0){
                $where[] = ['is_pay','=',$is_pay];
            }
            if (empty($uid)){
                $this->error('请通过正规途径进入','','400');
            }
            if (!empty($data['limit'])){
                $limit = $data['limit'];
            }else{
                $limit = 10;
            }
            if (!empty($data['page'])){
                $page = $data['page'];
            }else{
                $page = 1;
            }
            $list = Db::table('hy_order')->field('id,money,order_no,is_pay')->where($where)->page($page,$limit)->order('is_pay asc')->select();
            foreach ($list as $k=>$v){
                if ($v['is_pay'] == 1) {
                    $list[$k]['status_name'] = '付款成功';
                }elseif ($v['is_pay'] == 0){
                    $list[$k]['status_name'] = '待付款';
                }
                $cards = Db::table('hy_order_card')
                    ->alias('oc')
                    ->field('c.bank_card,c.bank,oc.month,oc.money as monthly_expenses')
                    ->leftJoin('hy_card c','c.id=oc.cid')
                    ->where(['oc.oid'=>$v['id']])
                    ->select();
                $bank = Config('bank');
                foreach ($cards as $kk=>$vv){
                    $cards[$kk]['bank_name'] = $bank[$vv['bank']];
                }
                $list[$k]['cards'] = $cards;
            }
            if ($list){
                $this->success('请求成功',$list,'200');
            }else{
                $this->success('暂无数据',[],'200');
            }
        }

    }

    /**
     * 我的
     * */
    public function my(){
        $uid = $this->uid;
        $user_info = Db::table('hy_user')
            ->field('headimgurl,nickname,realname,phone')
            ->where('id',$uid)
            ->find();
        if ($user_info){
            $this->success('请求成功',$user_info,'200');
        }else{
            $this->success('暂无数据',[],'200');
        }
    }

    /**
     * 修改个人信息
     * */
    public function up_my(){
        $uid = $this->uid;
        $data = $this->request->param();
        if (empty($data['realname'])){
            $this->error('真实姓名不能为空','','400');
        }
        if (empty($data['phone'])){
            $this->error('手机号不能为空','','400');
        }
        if (strlen($data['phone'])<11){
            $this->error('手机号格式不正确','','400');
        }
        $up_data['realname'] = $data['realname'];
        $up_data['phone'] = $data['phone'];
        $user_info = Db::table('hy_user')->where('id',$uid)->find();
        if ($user_info['realname'] == $data['realname'] && $user_info['phone'] == $data['phone']){
            $this->error('修改信息不能和以前一致','','400');
        }
        $is_up = Db::table('hy_user')->where('id',$uid)->update($up_data);
        if ($is_up){
            $this->success('请求成功',$is_up,'200');
        }
    }

    /**
     * 付款
     * */
    public function wx_pay(){
        $uid = $this->uid;
        $user_info = Db::table('hy_user')->where('id',$uid)->find();
        if (!$user_info){
            $this->error('去登录','','400');
        }
        $oid = $this->request->param('id/d',0);
        if (empty($oid)){
            $this->error('数据错误','','400');
        }
        $order_info = Db::table('hy_order')->where('id',$oid)->find();
        if ($order_info){
            if ($order_info['is_pay'] == 1){
                $this->success('您已支付，请勿重复支付');
            }
            $money = $order_info['money']*100;
            $app = Factory::payment(Config('mini_program'));
            $jssdk = $app->jssdk;
            $result = $app->order->unify([
                'body' => '泓易月结账单',
                'out_trade_no' => $order_info['order_no'],
                'total_fee' => $money,
                'notify_url' => 'https://'.$_SERVER['HTTP_HOST'].'/api/login/notify',
                'trade_type' => 'JSAPI',
                'openid' => $user_info['openid'],
            ]);
            if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
                $pay_data['order_no'] = $order_info['order_no'];
                $pay_data['return_data'] = json_encode($result);
                $pay_data['uid'] = $uid;
                $pay_data['create_at'] = date('Y-m-d H:i:s',time());
                Db::table('hy_wxpay_log')->insert($pay_data);
                $prepayId = $result['prepay_id'];
                $json = $jssdk->sdkConfig($prepayId);
                $this->success('请求成功',$json,'200');
            } else {
                $this->error('调起支付失败，请稍后尝试','','400');
            }
        }else{
            $this->error('数据错误','','400');
        }
    }
    /**
     * 未刷出账单列表
     * */
    public function brush_order_list(){
        $uid = $this->uid;
        //$uid = 12;
        $is_pay = $this->request->param('status');
        $data = $this->request->param('data',0);
        $where[] = ['bo.uid','=',$uid];
        if (strlen($is_pay) > 0){
            $where[] = ['bo.is_pay','=',$is_pay];
        }
        if (empty($uid)){
            $this->error('请通过正规途径进入','','400');
        }
        if (!empty($data['limit'])){
            $limit = $data['limit'];
        }else{
            $limit = 10;
        }
        if (!empty($data['page'])){
            $page = $data['page'];
        }else{
            $page = 1;
        }
        $list = Db::table('hy_brush_order')
                ->alias('bo')
                ->field('bo.id,bo.money,bo.is_pay,c.bank,c.bank_card')
                ->leftJoin('hy_card c','bo.cid=c.id')
                ->where($where)
                ->page($page,$limit)
                ->select();
        foreach ($list as $k=>$v){
            if ($v['is_pay'] == 1) {
                $list[$k]['status_name'] = '付款成功';
            }elseif ($v['is_pay'] == 0){
                $list[$k]['status_name'] = '待付款';
            }
            $bank = Config('bank');
            $list[$k]['bank_name'] = $bank[$v['bank']];
        }
        if ($list){
            $this->success('请求成功',$list,'200');
        }else{
            $this->success('暂无数据',[],'200');
        }
    }

    /**
     * 未刷出金额付款
     * */
    public function brush_wx_pay(){
        $uid = $this->uid;
        $user_info = Db::table('hy_user')->where('id',$uid)->find();
        if (!$user_info){
            $this->error('去登录','','400');
        }
        $oid = $this->request->param('id/d',0);
        if (empty($oid)){
            $this->error('数据错误','','400');
        }
        $order_info = Db::table('hy_brush_order')->where('id',$oid)->find();
        if ($order_info){
            if ($order_info['is_pay'] == 1){
                $this->success('您已支付，请勿重复支付');
            }
            $money = $order_info['money']*100;
            $app = Factory::payment(Config('mini_program'));
            $jssdk = $app->jssdk;
            $result = $app->order->unify([
                'body' => '泓易未刷出金额账单',
                'out_trade_no' => $order_info['order_no'],
                'total_fee' => $money,
                'notify_url' => 'https://'.$_SERVER['HTTP_HOST'].'/api/login/brush_notify',
                'trade_type' => 'JSAPI',
                'openid' => $user_info['openid'],
            ]);
            if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
                $pay_data['order_no'] = $order_info['order_no'];
                $pay_data['return_data'] = json_encode($result);
                $pay_data['uid'] = $uid;
                $pay_data['create_at'] = date('Y-m-d H:i:s',time());
                Db::table('hy_wxpay_log')->insert($pay_data);
                $prepayId = $result['prepay_id'];
                $json = $jssdk->sdkConfig($prepayId);
                $this->success('请求成功',$json,'200');
            } else {
                $this->error('调起支付失败，请稍后尝试','','400');
            }
        }else{
            $this->error('数据错误','','400');
        }
    }
}