yutang/application/api/controller/Suppliers.php

<?php


namespace app\api\controller;


use app\admin\model\Fishery;
use app\admin\model\FisherySuppliers;
use app\admin\model\FisherySuppliersCollection;
use app\admin\model\Third;
use app\common\controller\Api;
use think\Db;
use think\Exception;
use think\exception\ErrorException;

/**
 * 供货信息
 * @ApiWeigh (5)
 * @package app\api\controller
 */
class Suppliers extends Api
{
    protected $noNeedLogin = ['pond_list'];
    protected $noNeedRight = ['*'];

    /**
     * 渔场主-历史发布的供货信息
     * @ApiMethod (GET)
     * @ApiParams (name=limit,type="int", required=false,description="每页数量")
     * @ApiParams (name=page,type="int", required=false,description="页数")
     * @ApiReturnParams (name="id", type="int", required=true, description="供货信息id")
     * @ApiReturnParams (name="images", type="string", required=true, description="图片")
     * @ApiReturnParams (name="fish_kinds", type="string", required=true, description="鱼的种类")
     * @ApiReturnParams (name="fish_name", type="string", required=true, description="鱼塘名称")
     * @ApiReturnParams (name="description", type="string", required=true, description="货源描述")
     * @ApiReturnParams (name="publish_time", type="int", required=true, description="发布时间-int时间戳")
     * @ApiReturnParams (name="fish_address", type="string", required=true, description="鱼塘地址")
     * @ApiReturnParams (name="fish_num", type="string", required=true, description="存鱼")
     * @ApiReturnParams (name="phone", type="string", required=true, description="联系方式")
     * @ApiReturn ({"code":1,"msg":"ok","time":"1672301111","data":{"total":1,"per_page":15,"current_page":1,"last_page":1,"data":[{"id":1,"user_id":3,"images":"/uploads/20221229/bed687fe17a0b7f3a9e84f8d1580879c.png","fish_kinds":"白莲","description":"十年养鱼经验","publish_time":1672301081,"fish_name": "高铁垂钓中心","fish_address":"临沂","fish_num":"1024斤","phone":"13161001120","pay_time":0,"pay_no":"","pay_money":"0.00","status":1,"publish_status":0,"createtime":1672301106,"updatetime":1672301106,"deletetime":null,"pay_time_text":"1970-01-01 08:00:00","status_text":"Status 1","publish_status_text":"Publish_status 0"}]}})
     */
    public function history_list()
    {
        $page = input('page', 1);
        $limit = input('limit');
        $user_id = $this->auth->id;

        $suppliers_model = new FisherySuppliers();
        $query = $suppliers_model->where('user_id', $user_id)->where('status', 3)->order(['createtime' => 'desc', 'id' => 'desc']);
        $list = $query->paginate($limit, false, ['page' => $page]);

        $this->success('ok', $list);
    }

    /**
     * 渔场主-发布供货信息
     * @ApiMethod (POST)
     * @ApiParams (name=images,type="string", required=false,description="图片，多图英文,分割")
     * @ApiParams (name=fish_kinds,type="string", required=true,description="鱼的种类")
     * @ApiParams (name=fish_name,type="string", required=true,description="鱼塘名称")
     * @ApiParams (name=description,type="string", required=false,description="货源描述")
     * @ApiParams (name=publish_time,type="int", required=false,description="发布时间-int时间戳")
     * @ApiParams (name=fish_address,type="string", required=false,description="鱼塘地址")
     * @ApiParams (name=fish_num,type="string", required=false,description="存鱼")
     * @ApiParams (name=phone,type="string", required=true,description="联系方式")
     * @ApiParams (name=lng,type="string", required=true,description="经度")
     * @ApiParams (name=lat,type="string", required=true,description="纬度")
     */
    public function add_suppliers()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['fish_kinds']) || empty($input['fish_name']) || empty($input['phone'])) {
            $this->error('请完善供货信息');
        }

        $pay_money = config('site.fishery_suppliers') ?: 0;

        $suppliers_model = new FisherySuppliers();
        $data = [
            'user_id' => $user_id,
            'images' => $input['images'],
            'video' =>$input['video'],
            'fish_kinds' => $input['fish_kinds'],
            'fish_name' => $input['fish_name'],
            'description' => $input['description'],
            'publish_time' => $input['publish_time'],
            'fish_address' => $input['fish_address'],
            'fish_num' => $input['fish_num'],
            'phone' => $input['phone'],
            'pay_money' => $pay_money,
            'pay_no' => 'GH' . order_no_s($user_id),
            'lng' => $input['lng'],
            'lat' => $input['lat'],
        ];
        Db::startTrans();
        try {
            $suppliers_model->save($data);

            Db::commit();
            $this->success('发布成功', $data);
        } catch (ErrorException $e) {
            Db::rollback();
            $this->error('发布失败');
        }
    }

    /**
     * 缴费
     * @ApiMethod (POST)
     * @ApiParams (name="pay_no",type="string", required=true,description="单号")
     * @ApiParams (name="type",type="string", required=true,description="类型:wallet=钱包,wechat=微信,alipay=支付宝")
     * @ApiParams (name="mod",type="string", required=true,description="支付方法:web、wap、app、scan、pos、mp、miniapp")
     */
    public function payment()
    {
        $money = config('site.fishery_suppliers') ?: 0;
        if ($money <= 0) {
            $this->error('请联系平台设置缴费金额');
        }

        $type = $this->request->post('type');
        if ($type != 'wallet' && $type != 'wechat' && $type != 'alipay') {
            $this->error('请选择支付类型');
        }
        $method = $this->request->post('mod');
        $orderid = $this->request->post('pay_no');// 订单号
        if ($orderid == '') {
            $this->error('参数错误');
        }

        $suppliers_model = new FisherySuppliers();
        $suppliers_info = $suppliers_model->where('user_id', $this->auth->id)
            ->where('pay_no', $orderid)
            ->whereIn('status', [1, 2])
            ->find();
        if (!$suppliers_info) {
            $this->error('数据不存在');
        }

        if ($type == 'wallet') {
            // 扣除余额
            if($money>$this->auth->money){
                $this->error('余额不足');
            }
            $err_msg = \app\common\service\UserMoney::PayWallet($this->auth->id, $money * (-1), 1, "渔场主发布供货信息(" . $suppliers_info->id . ")");
            if ($err_msg != '') {
                $this->error($err_msg);
            }

            //数据回调
            \app\common\service\OrderCallback::Suppliers($suppliers_info, $type);
            $this->success('缴费成功');
        } else {
            $openID = '';
            if ($type == 'wechat') {
                $third_model = new Third();
                $openID = $third_model->where('user_id', $this->auth->id)->where('platform','xcc')->value('openid');
            }

            $params = [
                'amount' => $money,
                'orderid' => $orderid,
                'type' => $type,
                'title' => "渔场主发布供货信息(" . $suppliers_info->id . ")",
                'notifyurl' => common_url() . '/index.php/api/Notify/suppliers_notify/type/' . $type,
                'returnurl' => common_url() . '/index.php/api/Notify/suppliers_notify/type/' . $type . '/out_trade_no/' . $orderid,
                'method' => $method,
                'openid' => $openID,
            ];
            $pay = \addons\epay\library\Service::submitOrder($params);

            Db::startTrans();
            try {
                $data = [
                    'pay_type' => $type,
                    'pay_money' => $money,//更新缴费金额
                    'pay_no' => $orderid,
                    'status' => 2
                ];
                $suppliers_info->save($data);

//            $payment = [
//                'user_id' => $this->auth->id,
//                'pay_type'=> $type,
//                'order_no'=> $orderid,
//                'amount'=> $money,
//                'payment_type'=>'suppliers',
//            ];
                Db::commit();
            } catch (Exception $e) {
                Db::rollback();
                $this->error($e);
            }
            $this->success('ok', $pay);
        }
    }

    /**
     * 渔场主-供货信息详情
     * @ApiMethod (GET)
     * @ApiParams (name=suppliers_id,type="int", required=true,description="供货信息id")
     * @ApiReturnParams (name="images", type="int", required=true, description="图片")
     * @ApiReturnParams (name="fish_kinds", type="string", required=true, description="鱼的种类")
     * @ApiReturnParams (name="fish_name", type="string", required=true, description="鱼塘名称")
     * @ApiReturnParams (name="description", type="string", required=true, description="货源描述")
     * @ApiReturnParams (name="publish_time", type="int", required=true, description="发布时间-int时间戳")
     * @ApiReturnParams (name="fish_address", type="string", required=true, description="鱼塘地址")
     * @ApiReturnParams (name="fish_num", type="string", required=true, description="存鱼")
     * @ApiReturnParams (name="phone", type="string", required=true, description="联系方式")
     * @ApiReturn ({"code":1,"msg":"ok","time":"1672301992","data":{"id":2,"user_id":3,"images":"/uploads/20221229/bed687fe17a0b7f3a9e84f8d1580879c.png","fish_kinds":"白莲","description":"十年养鱼经验-2","publish_time":1672301081,"fish_name": "高铁垂钓中心","fish_address":"临沂","fish_num":"1024斤","phone":"13161001120","pay_time":0,"pay_no":"","pay_money":"0.00","status":1,"publish_status":0,"createtime":1672301318,"updatetime":1672301318,"deletetime":null,"pay_time_text":"1970-01-01 08:00:00","status_text":"Status 1","publish_status_text":"Publish_status 0"}})
     */
    public function detail()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['suppliers_id'])) {
            $this->error('参数错误');
        }

        $suppliers_model = new FisherySuppliers();
        $info = $suppliers_model->where('user_id', $user_id)
            ->where('id', $input['suppliers_id'])->find();
        if (!$info) {
            $this->error('信息不存在');
        }

        $this->success('ok', $info);
    }

    /**
     * 渔场主-修改供货信息
     * @ApiInternal
     * @ApiMethod (POST)
     * @ApiParams (name=suppliers_id,type="int", required=true,description="供货信息id")
     * @ApiParams (name=images,description="图片，多图英文,分割")
     * @ApiParams (name=fish_kinds,description="鱼的种类")
     * @ApiParams (name=fish_name,description="鱼塘名称")
     * @ApiParams (name=description,description="货源描述")
     * @ApiParams (name=publish_time,type="int", required=true,description="发布时间-int时间戳")
     * @ApiParams (name=fish_address,description="鱼塘地址")
     * @ApiParams (name=fish_num,description="存鱼")
     * @ApiParams (name=phone,description="联系方式")
     */
    public function edit_suppliers()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['suppliers_id'])) {
            $this->error('参数错误');
        }

        $suppliers_model = new FisherySuppliers();
        $info = $suppliers_model->where('user_id', $user_id)
            ->where('id', $input['suppliers_id'])->find();
        if (!$info) {
            $this->error('信息不存在');
        }

        $data = [
            'images' => $input['images'],
            'fish_kinds' => $input['fish_kinds'],
            'fish_name' => $input['fish_name'],
            'description' => $input['description'],
            'publish_time' => $input['publish_time'],
            'fish_address' => $input['fish_address'],
            'fish_num' => $input['fish_num'],
            'phone' => $input['phone'],
        ];
        Db::startTrans();
        try {
            $suppliers_model->save($data, ['id' => $input['suppliers_id']]);

            // todo 之前是否缴费

            Db::commit();
            $this->success('修改成功');
        } catch (ErrorException $e) {
            Db::rollback();
            $this->error('修改失败');
        }

        $this->success('ok', $info);
    }

    /**
     * 渔场主-删除供货信息
     * @ApiMethod (Delete)
     * @ApiParams (name=suppliers_id,type="int", required=true,description="供货信息id")
     */
    public function del_suppliers()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['suppliers_id'])) {
            $this->error('参数错误');
        }

        $suppliers_model = new FisherySuppliers();
        $suppliers = $suppliers_model::get(['id' => $input['suppliers_id'], 'user_id' => $user_id]);
        if (!$suppliers) {
            $this->error('信息不存在');
        }

        Db::startTrans();
        try {
            // 删除
            $suppliers->delete();

            Db::commit();
            $this->success('刪除成功');
        } catch (ErrorException $e) {
            Db::rollback();
            $this->error('刪除失败');
        }
    }

    /**
     * 塘主端-供货信息列表
     * @ApiMethod (GET)
     * @ApiParams (name=limit,type="int", required=false,description="每页数量")
     * @ApiParams (name=page,type="int", required=false,description="页数")
     * @ApiReturnParams (name="id", type="int", required=true, description="供货信息id")
     * @ApiReturnParams (name="images", type="string", required=true, description="图片")
     * @ApiReturnParams (name="fish_kinds", type="string", required=true, description="鱼的种类")
     * @ApiReturnParams (name="fish_name", type="string", required=true, description="鱼塘名称")
     * @ApiReturnParams (name="description", type="string", required=true, description="货源描述")
     * @ApiReturnParams (name="publish_time", type="int", required=true, description="发布时间-int时间戳")
     * @ApiReturnParams (name="fish_address", type="string", required=true, description="鱼塘地址")
     * @ApiReturnParams (name="fish_num", type="string", required=true, description="存鱼")
     * @ApiReturnParams (name="phone", type="string", required=true, description="联系方式")
     * @ApiReturn ({"code":1,"msg":"ok","time":"1672301111","data":{"total":1,"per_page":15,"current_page":1,"last_page":1,"data":[{"id":1,"user_id":3,"images":"/uploads/20221229/bed687fe17a0b7f3a9e84f8d1580879c.png","fish_kinds":"白莲","description":"十年养鱼经验","publish_time":1672301081,"fish_name": "高铁垂钓中心","fish_address":"临沂","fish_num":"1024斤","phone":"13161001120","pay_time":0,"pay_no":"","pay_money":"0.00","status":1,"publish_status":0,"createtime":1672301106,"updatetime":1672301106,"deletetime":null,"pay_time_text":"1970-01-01 08:00:00","status_text":"Status 1","publish_status_text":"Publish_status 0"}]}})
     */
    public function pond_list()
    {
        $page = input('page', 1);
        $limit = input('limit');

        $suppliers_model = new FisherySuppliers();
        $query = $suppliers_model->where('status', 3)->where('publish_status', 1)
            ->field('id,images,fish_kinds,publish_time,fish_name,fish_address,fish_num,phone,description,publish_status')
            ->order(['createtime' => 'desc', 'id' => 'desc']);
        $list = $query->paginate($limit, false, ['page' => $page]);

        $this->success('ok', $list);
    }

    /**
     * 塘主端-供货信息详情
     * @ApiMethod (GET)
     * @ApiParams (name=suppliers_id,type="int", required=true,description="供货信息id")
     * @ApiReturnParams (name="images", type="int", required=true, description="图片")
     * @ApiReturnParams (name="fish_kinds", type="string", required=true, description="鱼的种类")
     * @ApiReturnParams (name="fish_name", type="string", required=true, description="鱼塘名称")
     * @ApiReturnParams (name="description", type="string", required=true, description="货源描述")
     * @ApiReturnParams (name="publish_time", type="int", required=true, description="发布时间-int时间戳")
     * @ApiReturnParams (name="fish_address", type="string", required=true, description="鱼塘地址")
     * @ApiReturnParams (name="fish_num", type="string", required=true, description="存鱼")
     * @ApiReturnParams (name="phone", type="string", required=true, description="联系方式")
     * @ApiReturnParams (name="has_collect", type="bool", required=true, description="true收藏过，false未收藏")
     * @ApiReturn ({"code":1,"msg":"ok","time":"1672301992","data":{"id":2,"user_id":3,"images":"/uploads/20221229/bed687fe17a0b7f3a9e84f8d1580879c.png","fish_kinds":"白莲","description":"十年养鱼经验-2","publish_time":1672301081,"fish_name": "高铁垂钓中心","fish_address":"临沂","fish_num":"1024斤","phone":"13161001120","pay_time":0,"pay_no":"","pay_money":"0.00","status":1,"publish_status":0,"createtime":1672301318,"updatetime":1672301318,"deletetime":null,"has_collect": false,"pay_time_text":"1970-01-01 08:00:00","status_text":"Status 1","publish_status_text":"Publish_status 0"}})
     */
    public function pond_detail()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['suppliers_id'])) {
            $this->error('参数错误');
        }

        $suppliers_model = new FisherySuppliers();
        $info = $suppliers_model->where('status', 3)->where('publish_status', 1)->where('id', $input['suppliers_id'])->find();
        if (!$info) {
            $this->error('信息不存在');
        }

        // 是否收藏过
        $suppliers_collect_model = new FisherySuppliersCollection();
        $collect = $suppliers_collect_model->where('user_id', $user_id)->where('suppliers_id', $info['id'])->find();
        if ($collect) {
            $info['has_collect'] = true;
        } else {
            $info['has_collect'] = false;
        }

        $this->success('ok', $info);
    }

    /**
     * 塘主端--收藏供货信息
     * @ApiMethod (POST)
     * @ApiParams (name=suppliers_id,type="int", required=true,description="供货信息id")
     * @ApiParams (name=type,type="int", required=true,description="0取消收藏，1=收藏")
     */
    public function pond_collect()
    {
        $input = input();
        if (empty($input['suppliers_id'])) {
            $this->error('参数错误');
        }
        $user_id = $this->auth->id;

        // 收藏
        $suppliers_collect_model = new FisherySuppliersCollection();
        $data = [
            'user_id' => $user_id,
            'suppliers_id' => $input['suppliers_id'],
        ];
        if ($input['type'] == 1) {
            $suppliers_collect_model->save($data);

            $this->success('收藏成功');
        } else {
            $suppliers_collect_model->where($data)->delete();
        }

        $this->success('取消收藏成功');
    }

    /**
     * 塘主端-我的收藏供货信息
     * @ApiMethod (GET)
     * @ApiParams (name=limit,type="int", required=false,description="每页数量")
     * @ApiParams (name=page,type="int", required=false,description="页数")
     * @ApiReturnParams (name="images", type="int", required=true, description="图片")
     * @ApiReturnParams (name="fish_kinds", type="string", required=true, description="鱼的种类")
     * @ApiReturnParams (name="fish_name", type="string", required=true, description="鱼塘名称")
     * @ApiReturnParams (name="description", type="string", required=true, description="货源描述")
     * @ApiReturnParams (name="publish_time", type="int", required=true, description="发布时间-int时间戳")
     * @ApiReturnParams (name="fish_address", type="string", required=true, description="鱼塘地址")
     * @ApiReturnParams (name="fish_num", type="string", required=true, description="存鱼")
     * @ApiReturnParams (name="phone", type="string", required=true, description="联系方式")
     * @ApiReturnParams (name="publish_status", type="int", required=true, description="发布状态:0=待发布,1=已发布,2=发布过期,3=已注销")
     * @ApiReturn ({"code":1,"msg":"ok","time":"1672631323","data":{"total":1,"per_page":15,"current_page":1,"last_page":1,"data":[{"id":2,"images":"/uploads/20221229/bed687fe17a0b7f3a9e84f8d1580879c.png","fish_kinds":"白莲/鲤鱼","publish_time":1672303780,"fish_name":"垂钓中心211","fish_address":"临沂","fish_num":"1111","phone":"13161001120","description":"十年养鱼经验-211"}]}})
     */
    public function my_suppliers_collect()
    {
        $page = input('page', 1);
        $limit = input('limit');
        $user_id = $this->auth->id;

        // 我的收藏
        $suppliers_collect_model = new FisherySuppliersCollection();
        $query = $suppliers_collect_model->alias('c')->join('fishery_suppliers s', 'c.suppliers_id=s.id')
            ->whereIN('c.user_id', $user_id)
            ->order('c.createtime', 'DESC')
            ->field('s.id,images,fish_kinds,publish_time,fish_name,fish_address,fish_num,phone,description,publish_status');

        $collect = $query->paginate($limit, false, ['page' => $page]);

        $this->success('ok', $collect);
    }

}