api接口目录

addons/unishop/controller/Order.php

@@ -903,4 +903,12 @@ class Order extends Base
             'company' => $expressInfo['name'] ?? '快递单号'
         ]);
     }
+
+    //出示核销码
+    public function show_hexiao_qrcode(){
+
+    }
+
+    //退订
+    public function tuiding(){}
 }

addons/unishop/controller/Product.php

@@ -139,12 +139,12 @@ class Product extends Base
         $by = $this->request->get('by', 'weigh');
         $desc = $this->request->get('desc', 'desc');
 
-        $sid = $this->request->get('sid'); // 二级分类Id
+//        $sid = $this->request->get('sid'); // 二级分类Id
         $fid = $this->request->get('fid'); // 一级分类Id
 
         $productModel = new productModel();
 
-        if ($fid && !$sid) {
+        /*if ($fid && !$sid) {
             $categoryModel = new \addons\unishop\model\Category();
             $sArr = $categoryModel->where('pid', $fid)->field('id')->select();
             $sArr = array_column($sArr, 'id');
@@ -152,7 +152,9 @@ class Product extends Base
             $productModel->where('category_id', 'in', $sArr);
         } else {
             $sid && $productModel->where(['category_id' => $sid]);
-        }
+        }*/
+
+        $fid && $productModel->where(['category_id' => $fid]);
 
         $result = $productModel
             ->where(['switch' => productModel::SWITCH_ON])
@@ -164,7 +166,7 @@ class Product extends Base
         if ($result) {
             $result = collection($result)->toArray();
         } else {
-            $this->error('没有更多数据');
+            $result = [];
         }
         $this->success('', $result);
     }

application/api/controller/Hexiao.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+
+/**
+ * 核销
+ */
+class Hexiao extends Api
+{
+    protected $noNeedLogin = ['*'];
+    protected $noNeedRight = ['*'];
+
+
+    //订单详情
+    public function order_info()
+    {
+        //追加退改规则
+        $this->success();
+    }
+
+    //完成核销动作
+    public function hexiao(){
+
+    }
+
+    //核销记录
+    public function order_list(){}
+}

application/api/controller/Index.php

@@ -12,12 +12,40 @@ class Index extends Api
     protected $noNeedLogin = ['*'];
     protected $noNeedRight = ['*'];
 
+
+    public function index()
+    {
+        $this->success();
+    }
+
     /**
      * 首页
      *
      */
-    public function index()
-    {
-        $this->success('请求成功');
+    public function home(){
+
+        //轮播图
+        $banner = Db::name('banner')->field('id, title, image, url')->where(['status' => 1])->order('weigh', 'desc')->select();
+        $banner = list_domain_image($banner, ['image']);
+
+        //四个顶部分类
+
+        //第一个顶部分类，的两个商品
+
+        //其他所有分类
+
+
+    }
+
+    //吃喝玩乐
+    //列表
+    public function chihewanle_list(){
+
+    }
+
+    //吃喝玩乐
+    //详情
+    public function chihewanle_info(){
+
     }
 }

application/api/controller/Takecash.php

@@ -0,0 +1,170 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+use think\Db;
+/**
+ * 提现
+ */
+class Takecash extends Api
+{
+    protected $noNeedLogin = [];
+    protected $noNeedRight = ['*'];
+
+    //提现
+    public function take_cash(){
+        $freemoney = input('freemoney',0);
+        $type = input('type',1);
+
+        if(!$freemoney){
+            $this->error('请填写金额');
+        }
+
+        if (!in_array($type,[1,2,3])) {
+            $this->error('未知的提现类型');
+        }
+
+
+        //赋值money
+        /*if($rc_id){
+            $recharge_config = Db::name('take_cash_config')->where('id',$rc_id)->find();
+            $money = $recharge_config['money'] ?: 0;
+        }*/
+
+        //自由输入覆盖
+        if(!empty($freemoney)){
+            $rc_id = 0;
+            $money = floatval($freemoney);
+        }
+
+        //
+        if($money<=0)
+        {
+            $this->error('金额必须大于0');
+        }
+
+        $min = config('site.min_takecash_money');
+        $max = config('site.max_takecash_money');
+        if($money < $min){
+            $this->error('提现金额不能小于'.$min);
+        }
+        if($money > $max){
+            $this->error('提现金额不能大于'.$max);
+        }
+
+        $check = Db::name('user_take_cash')->where(['user_id'=>$this->auth->id,'status'=>0])->find();
+        if($check){
+            $this->error('您已经申请了提现,请等待审核');
+        }
+
+        $user_money = model('wallet')->getwallet($this->auth->id,'money');
+        if($money > $user_money){
+            $this->error('提现金额不能大于可提现余额');
+        }
+
+        if($type == 1){
+            $table_name = 'user_alipay';
+            $account_json = Db::name($table_name)->where('user_id',$this->auth->id)->find();
+            if(empty($account_json)){
+                $this->error('未绑定对应的提现账号');
+            }
+        }elseif($type == 2){
+            $table_name = 'user_bank';
+            $account_json = Db::name($table_name)->where('user_id',$this->auth->id)->find();
+            if(empty($account_json)){
+                $this->error('未绑定对应的提现账号');
+            }
+        }elseif($type == 3){
+            //微信支付
+            $table_name = 'user_wechat';
+            $account_json = Db::name($table_name)->where('user_id',$this->auth->id)->find();
+            if(empty($account_json)){
+                $this->error('未绑定对应的提现账号');
+            }
+        }
+
+        //平台手续费
+        $plat_bilv = config('site.takecash_plat_bili');
+        $plat_money = bcdiv(bcmul($money,$plat_bilv,2),100,2);
+
+        //减去手续费，得实得金额
+        $get_money = bcsub($money,$plat_money,2);
+
+        $data = [
+            'user_id' => $this->auth->id,
+            'money' => $money,
+            'plat_bilv'  => $plat_bilv,
+            'plat_money' => $plat_money,
+            'get_money'  => $get_money,
+            'type' => $type,
+            'acount_json' => json_encode($account_json),
+            'createtime' => time(),
+            'updatetime' => time(),
+            'status' => 0,
+        ];
+        Db::startTrans();
+
+        $log_id = Db::name('user_take_cash')->insertGetId($data);
+        if(!$log_id){
+            Db::rollback();
+            $this->error('提现失败');
+        }
+
+        //扣除money
+        $rs_wallet = model('Wallet')->lockChangeAccountRemain($this->auth->id,'money',-$money,21,'提现(审核中)','user_take_cash',$log_id);
+        if($rs_wallet['status']===false)
+        {
+            Db::rollback();
+            $this->error($rs_wallet['msg']);
+        }
+
+        Db::commit();
+        $this->success('申请成功请等待审核');
+    }
+
+    //提现记录
+    public function take_cash_log(){
+        $list = Db::name('user_take_cash')->field('id,money,get_money,type,createtime,status')->where(['user_id'=>$this->auth->id])->autopage()->select();
+        foreach($list as $key => &$val){
+            $val['remark'] = '';
+
+            if($val['type'] == 1){
+                $val['remark'] = '支付宝提现';
+            }elseif($val['type'] == 2){
+                $val['remark'] = '银行卡提现';
+            }else{
+                $val['remark'] = '微信提现';
+            }
+        }
+
+        $this->success('success',$list);
+    }
+
+   /////////////////////////没用到/////////////////////
+
+    //提现配置
+    public function take_cash_config(){
+        $config = Db::name('take_cash_config')->order('weigh asc,id asc')->select();
+
+        $plat_bilv = config('site.takecash_plat_bili');
+        foreach($config as $key => &$val){
+            $val['get_money'] = bcdiv(bcmul($val['money'],(100-$plat_bilv),2),100,2);
+        }
+
+        $data = [
+            'config' => $config,
+            'wallet' => model('wallet')->getwallet($this->auth->id),
+            'min' => config('site.min_takecash_money'),
+            'max' => config('site.max_takecash_money'),
+            'plat_bilv' => $plat_bilv,
+            'user_bank' => Db::name('user_bank')->where('user_id',$this->auth->id)->find(),
+            'user_alipay' => Db::name('user_alipay')->where('user_id',$this->auth->id)->find(),
+            'remark' => config('site.take_cash_rule'),
+        ];
+
+        $this->success('success',$data);
+    }
+
+
+}

application/api/controller/Tuiguang.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+
+/**
+ * 推广
+ */
+class Tuiguang extends Api
+{
+    protected $noNeedLogin = ['*'];
+    protected $noNeedRight = ['*'];
+
+
+    //获取海报
+    public function create_poster()
+    {
+        $this->success();
+    }
+
+    //推广记录
+    public function lists(){
+
+    }
+
+}

application/api/controller/Unishop.php

@@ -0,0 +1,263 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+use fast\Random;
+use think\Db;
+use addons\epay\library\Service;
+use think\Exception;
+use addons\unishop\extend\Hashids;
+/**
+ * 支付订单，回调订单
+ */
+class Unishop extends Api
+{
+    protected $noNeedLogin = ['order_notify_base'];
+    protected $noNeedRight = ['*'];
+
+    //支付订单
+    public function pay_order(){
+        $apilimit = $this->apiLimit();
+        if(!$apilimit){
+            $this->error('操作频繁');
+        }
+        $pay_type = input('pay_type','alipay');
+        $platform = input('platform','app');
+        $orderid = input('order_id',0);
+
+        if(empty($orderid)){
+            $this->error();
+        }
+        $orderid = Hashids::decodeHex($orderid);
+
+        if(!in_array($pay_type,['wechat','alipay','wallet'])){
+            $this->error();
+        }
+
+        $uid = $this->auth->id;
+        $map = [
+            'id'       => $orderid,
+            'user_id'  => $uid,
+            'status'   => 1,
+            'have_paid'=> 0,
+        ];
+        $orderinfo = Db::name('unishop_order')->where($map)->find();
+        if(empty($orderinfo)){
+            $this->error('请刷新重试');
+        }
+
+        //余额支付
+        if($pay_type == 'wallet'){
+            Db::startTrans();
+
+            //扣钱
+            $rs_wallet = model('wallet')->lockChangeAccountRemain($this->auth->id,'money',-$orderinfo['total_price'],31,'商城购物','unishop_order',$orderid);
+            if($rs_wallet['status'] == false){
+                Db::rollback();
+                $this->error($rs_wallet['msg']);
+            }
+
+            //订单改为已支付
+            $order_update['pay_type'] = 2;
+            $order_update['have_paid'] = time();
+            $update_rs = Db::name('unishop_order')->where($map)->update($order_update);
+            if(!$update_rs){
+                Db::rollback();
+                $this->error('支付失败,重试一下吧');
+            }
+
+            Db::commit();
+
+            $result = [
+                'pay_type' => $pay_type,
+                'pay_params' => '',
+            ];
+            $this->success(1,$result);
+        }
+
+        //创建订单
+        $data = [];
+        $data['user_id'] = $uid;
+        $data['out_trade_no'] = createUniqueNo('U',$uid); // 数据库订单号加密
+        $data['order_amount'] = $orderinfo['total_price'];
+        $data['createtime'] = time();
+
+        $data['pay_type'] = $pay_type;
+        $data['platform'] = $platform;
+        $data['order_status'] = 0;
+        $data['table_name'] = 'unishop_order';
+        $data['table_id'] = $orderid;
+
+        $orderid = Db::name('pay_order')->insertGetId($data);
+
+        //下单
+        $params = [
+            'type'         => $pay_type,
+            'orderid'      => $data['out_trade_no'],
+            'title'        => '支付订单',
+            'amount'       => $data['order_amount'],
+//            'amount'       => 0.01,
+            'method'       => $platform,
+            'notifyurl' => config('pay_notify_url').'/api/unishop/order_notify_base/paytype/'.$pay_type,
+            'returnurl' => '',
+        ];
+
+        $res = Service::submitOrder($params);
+
+        $result = [
+            'pay_type'=> $pay_type,
+            'pay_params'=> $pay_type
+
+        ];
+        if($pay_type == 'wechat'){
+            $result['pay_params'] = json_decode($res,true);
+        }else{
+            $result['pay_params'] = $res;
+        }
+
+        $this->success(1,$result);
+    }
+
+    //异步回调对外方法
+    public function order_notify_base(){
+
+        //验签
+        $paytype = input('paytype','alipay');
+        $notify_file = $this->notify_log_start($paytype);
+        $pay = Service::checkNotify($paytype);
+        if (!$pay) {
+            echo '签名错误';
+            exit;
+        }
+
+        //验证，拿订单号等信息
+        $data = $pay->verify();
+        $out_trade_no = $data['out_trade_no'];
+        //订单查询
+        $info = Db::name('pay_order')->where('out_trade_no',$out_trade_no)->find();
+
+        if(empty($info)){
+            return $pay->success()->send();
+            exit;
+        }
+
+        if($info['order_status'] != 0)
+        {
+            return $pay->success()->send();
+            exit;
+        }
+        //你可以在此编写订单逻辑
+        $rs = $this->order_notify_do($out_trade_no,$paytype);
+        if($rs === false){
+            //不论结果都应返回success
+            return $pay->success()->send();
+            exit;
+        }else{
+            //不论结果都应返回success
+            return $pay->success()->send();
+            exit;
+        }
+
+        //默认
+        return $pay->success()->send();
+        exit;
+    }
+
+    //异步逻辑
+    private function order_notify_do($out_trade_no,$paytype){
+
+        Db::startTrans();
+        $orderInfo = Db::name('pay_order')->where(['out_trade_no' => $out_trade_no])->lock(true)->find();
+        if (empty($orderInfo)) {
+            Db::rollback();
+            return false;
+        }
+
+        if($orderInfo['order_status'] != 0){
+            Db::rollback();
+            return false;
+        }
+
+        //逻辑开始
+        $nowtime = time();
+
+        $paytype_enum = [
+            'wechat' => 3,
+            'alipay' => 4,
+        ];
+
+        //订单改为已支付
+        $update = [
+            'have_paid'=>$nowtime,
+            'pay_type' =>$paytype_enum[$paytype],
+            'pay_out_trade_no' =>$out_trade_no,
+        ];
+        $rs_order = Db::name('unishop_order')->where('id',$orderInfo['table_id'])->update($update);
+        if($rs_order === false){
+            Db::rollback();
+            return false;
+        }
+        //逻辑结束
+
+        //状态
+        $ros = Db::name('pay_order')->where(['out_trade_no' => $out_trade_no])->update(['order_status'=>1,'notifytime'=>time()]);
+        if($ros === false) {
+            Db::rollback();
+            return false;
+        }
+
+        //默认提交
+        Db::commit();
+        return true;
+
+
+    }
+
+
+
+    //异步日志
+    private function notify_log_start($paytype = 'wechat'){
+        //记录支付回调数据
+        ignore_user_abort(); // run script in background
+        set_time_limit(30);
+        // 日志文件 start
+        $log_base_dir = '../epaylog/'.$paytype.'/';
+        if (!is_dir($log_base_dir))
+        {
+            mkdir($log_base_dir, 0770, true);
+            @chmod($log_base_dir, 0770);
+        }
+        $notify_file = $log_base_dir.'notify.txt';
+        if(!file_exists($notify_file)) {
+            @touch($notify_file);
+            @chmod($notify_file, 0770);
+        }
+        if(filesize($notify_file)>5242880)//大于5M自动切换
+        {
+            rename($notify_file, $log_base_dir.'notify_'.date('Y_m_d_H_i_s').'.txt');
+        }
+        if(!file_exists($notify_file)) {
+            @touch($notify_file);
+            @chmod($notify_file, 0770);
+        }
+        // 日志文件 end
+        //开始写入
+        $_REQUEST = isset($_REQUEST) ? $_REQUEST : array();
+        if($_REQUEST && $paytype == 'alipay') {
+            file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收request]".json_encode($_REQUEST), FILE_APPEND);
+        } else {
+            $xml = file_get_contents("php://input");
+            file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流原始数据] \n".$xml, FILE_APPEND);
+            $xmlObj = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
+            file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流] ".json_encode($xmlObj), FILE_APPEND);
+        }
+
+        ini_set('display_errors','On');
+
+        return $notify_file;
+
+    }
+
+
+}

application/api/controller/Userbank.php

@@ -0,0 +1,187 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+use think\Db;
+use app\common\library\Sms;
+
+/**
+ *
+ */
+class Userbank extends Api
+{
+    protected $noNeedLogin = [];
+    protected $noNeedRight = ['*'];
+
+
+
+
+    /**
+     * 绑定银行卡
+     */
+    public function bindBank() {
+
+        //
+        $bank_no = input('bank_no');// 银行账号
+        $open_bank = input('open_bank');// 开户行
+        $realname = input('realname');// 姓名
+        if(!$bank_no || !$open_bank  || !$realname ) {
+            $this->error("请将信息填写完整");
+        }
+
+        $userId = $this->auth->id;
+
+        // 查询是否有过绑定
+        $bankInfo = Db::name('user_bank')->where(["user_id"=>$userId])->find();
+        $data = [];
+        $data["realname"] = $realname;
+        $data["bank_no"] = $bank_no;
+        $data["open_bank"] = $open_bank;
+
+        if($bankInfo) {
+            $res = Db::name('user_bank')->where(["user_id"=>$userId])->update($data);
+        } else {
+            $data["user_id"] = $userId;
+            $res = Db::name('user_bank')->insertGetId($data);
+        }
+
+
+        $this->success("银行卡绑定成功！");
+
+    }
+
+    /**
+     * 获取绑定银行卡信息
+     */
+    public function getBankInfo() {
+        // 查询是否有过绑定
+        $bankInfo = Db::name('user_bank')->where(["user_id"=>$this->auth->id])->find();
+
+        $this->success("获取成功！",$bankInfo);
+    }
+
+    /////////////////////////////////没用到/////////////////////////
+    /**
+     * 绑定支付宝
+     */
+    public function bindAlipay() {
+
+        $captcha = input('captcha');
+        if (!$captcha) {
+            $this->error(__('Invalid parameters'));
+        }
+        $result = Sms::check($this->auth->mobile, $captcha, 'changemobile');
+        if (!$result) {
+            $this->error(__('Captcha is incorrect'));
+        }
+
+        //
+        $payNo = input('pay_no');//支付宝账号
+        if(!$payNo) {
+            $this->error("请将信息填写完整");
+        }
+
+        $userId = $this->auth->id;
+
+        //检测实名认证
+        $userAuthWhere['user_id'] = $userId;
+        $userAuth = Db::name('user_idconfirm')->where($userAuthWhere)->find();
+        if (empty($userAuth)) {
+            $this->error('请先实名认证');
+        }
+        if ($userAuth['status'] != 1) {
+            $this->error('请先实名认证通过');
+        }
+
+
+        // 查询是否有过绑定
+        $bankInfo = Db::name('user_alipay')->where(["user_id"=>$userId])->find();
+        $data = [];
+        $data["realname"] = $userAuth['realname'];
+        $data["pay_no"] = $payNo;
+        if($bankInfo) {
+            $res = Db::name('user_alipay')->where(["user_id"=>$userId])->update($data);
+        } else {
+            $data["user_id"] = $userId;
+            $res = Db::name('user_alipay')->insertGetId($data);
+        }
+        if($res) {
+            $this->success("支付宝绑定成功！");
+        } else {
+            $this->error("网络异常，请稍后重试！");
+        }
+    }
+
+    /**
+     * 获取绑定银行卡信息
+     */
+    public function getAlipayInfo() {
+        // 查询是否有过绑定
+        $alipayInfo = Db::name('user_alipay')->where(["user_id"=>$this->auth->id])->find();
+        $this->success("获取成功！",$alipayInfo);
+    }
+
+
+    /**
+     * 绑定微信
+     */
+    public function bindWechat() {
+
+        $captcha = input('captcha');
+        if (!$captcha) {
+            $this->error(__('Invalid parameters'));
+        }
+        $result = Sms::check($this->auth->mobile, $captcha, 'changemobile');
+        if (!$result) {
+            $this->error(__('Captcha is incorrect'));
+        }
+
+        //
+        $payNo = input('pay_no');//支付宝账号
+        if(!$payNo) {
+            $this->error("请将信息填写完整");
+        }
+
+        $userId = $this->auth->id;
+
+        //检测实名认证
+        $userAuthWhere['user_id'] = $userId;
+        $userAuth = Db::name('user_idconfirm')->where($userAuthWhere)->find();
+        if (empty($userAuth)) {
+            $this->error('请先实名认证');
+        }
+        if ($userAuth['status'] != 1) {
+            $this->error('请先实名认证通过');
+        }
+
+
+        // 查询是否有过绑定
+        $bankInfo = Db::name('user_wechat')->where(["user_id"=>$userId])->find();
+        $data = [];
+        $data["realname"] = $userAuth['realname'];
+        $data["pay_no"] = $payNo;
+        if($bankInfo) {
+            $res = Db::name('user_wechat')->where(["user_id"=>$userId])->update($data);
+        } else {
+            $data["user_id"] = $userId;
+            $res = Db::name('user_wechat')->insertGetId($data);
+        }
+        if($res) {
+            $this->success("绑定成功！");
+        } else {
+            $this->error("网络异常，请稍后重试！");
+        }
+    }
+
+    /**
+     * 获取绑定银行卡信息
+     */
+    public function getWechatInfo() {
+        // 查询是否有过绑定
+        $alipayInfo = Db::name('user_wechat')->where(["user_id"=>$this->auth->id])->find();
+        $this->success("获取成功！",$alipayInfo);
+    }
+
+
+}

application/api/controller/Userwallet.php

@@ -0,0 +1,61 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+use think\Db;
+//use app\common\model\wallet;
+/**
+ * 用户钱包
+ */
+class Userwallet extends Api
+{
+    protected $noNeedLogin = [];
+    protected $noNeedRight = ['*'];
+
+    //我的钱包余额
+    public function my_wallet(){
+        $wallet = Db::name('user_wallet')->where(['user_id' => $this->auth->id])->find();
+
+        $wallet['user_bank']   = Db::name('user_bank')->where(['user_id' => $this->auth->id])->find();
+        $this->success('success',$wallet);
+    }
+
+    //我的余额日志
+    public function my_money_log(){
+        $type = input('type',0);
+
+        $map = [
+           'user_id' => $this->auth->id,
+        ];
+
+        if($type == 1){
+            $map['change_value'] = ['gt',0];
+        }
+        if($type == 2){
+            $map['change_value'] = ['lt',0];
+        }
+
+        $list = Db::name('user_money_log')
+            ->field('id,log_type,before,change_value,remain,remark,createtime')
+            ->where($map)->order('id desc')->autopage()->select();
+        $list = $this->list_appen_logtext($list);
+
+        $this->success('success',$list);
+    }
+
+
+    //追加log_text
+    private function list_appen_logtext($list){
+        if(!empty($list)){
+            $conf = config('wallet.logtype');
+            $conf_en = config('wallet.logtype_en');
+            foreach($list as $key => $val){
+                $list[$key]['log_text'] = isset($conf[$val['log_type']]) ? $conf[$val['log_type']] : '';
+                $list[$key]['log_text_en'] = isset($conf_en[$val['log_type']]) ? $conf_en[$val['log_type']] : '';
+            }
+        }
+        return $list;
+    }
+
+}

application/common/controller/Api.php

@@ -95,7 +95,7 @@ class Api
         //日志
         $this->request_log();
         //用户活跃
-        $this->user_active();
+//        $this->user_active();
 
         // 前置操作方法
         if ($this->beforeActionList) {

application/common/library/Auth.php

@@ -380,6 +380,8 @@ class Auth
 
         $userinfo['avatar'] = localpath_to_netpath($userinfo['avatar']);
 
+        //是否弹出未领取的优惠券
+
         return $userinfo;
     }