yutang/application/api/controller/Join.php

<?php


namespace app\api\controller;


use app\admin\model\Fishery;
use app\admin\model\Third;
use app\admin\model\User;
use app\admin\model\UserMoneyRecharge;
use app\common\controller\Api;
use think\Db;
use think\Exception;
use think\exception\ErrorException;
use \app\admin\model\Yutang as YutangModel;

/**
 * 加盟-塘主-渔场主
 * @ApiWeigh (5)
 * @package app\api\controller
 */
class Join extends Api
{
    protected $noNeedLogin = [];
    protected $noNeedRight = ['*'];

    /**
     * 申请入驻塘主or渔场主
     * @ApiMethod (POST)
     * @ApiParams (name=type, type="int", required=true,description="类型:1=塘主,2=渔场主")
     * @ApiParams (name=certificates_type, type="string", required=true,description="证件类型:营业执照/租赁资格证")
     * @ApiParams (name=certificates_image,type="string", required=true,,description="证件图片")
     * @ApiParams (name=cover_image,type="string", required=true,description="封面图")
     * @ApiParams (name=video,type="string", required=true,description="视频")
     * @ApiParams (name=province_id,type="int", required=true,description="省")
     * @ApiParams (name=city_id,type="int", required=true,description="市")
     * @ApiParams (name=area_id,type="int", required=true,description="区")
     * @ApiParams (name=address,type="string", required=true,description="详细地址")
     * @ApiParams (name=lng,type="string", required=true,description="经度")
     * @ApiParams (name=lat,type="string", required=true,description="纬度")
     * @ApiParams (name=fish_name,type="string", required=true,description="鱼塘名称")
     * @ApiParams (name=name,type="string", required=true,description="姓名")
     * @ApiParams (name=phone,type="string", required=true,description="联系方式")
     * @ApiParams (name=z_name,type="string", required=true,description="支付宝姓名")
     * @ApiParams (name=z_phone,type="string", required=true,description="支付宝手机号")
     */
    public function apply()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['type']) || empty($input['certificates_type']) || empty($input['certificates_image']) || empty($input['province_id']) || empty($input['city_id']) || empty($input['area_id']) || empty($input['address']) || empty($input['lng']) || empty($input['lat']) || empty($input['name']) || empty($input['phone'])) {
            $this->error('请完善信息');
        }

        if ($input['type'] != 1 && $input['type'] != 2) {
            $this->error('参数错误');
        }

        // 申请塘主时
        if ($input['type'] == 1 && (empty($input['cover_image']) || empty($input['video']) || empty($input['fish_name']) || empty($input['z_name']) || empty($input['z_phone']))) {
            $this->error('请完善信息');
        }

        $suppliers_model = new Fishery();
        // 检查是否申请过
        $info = $suppliers_model::where(['user_id' => $user_id, 'type' => $input['type']])->whereIn('logout_status', [1, 3])->find();
        if ($info) {
            $this->error('已提交过申请,不能重复提交');
        }

        $data = [
            'user_id' => $user_id,
            'type' => $input['type'],
            'certificates_type' => $input['certificates_type'],
            'certificates_image' => $input['certificates_image'],
            'cover_image' => array_key_exists('cover_image', $input) ? $input['cover_image'] : '',
            'video' => array_key_exists('video', $input) ? $input['video'] : '',
            'province_id' => $input['province_id'],
            'city_id' => $input['city_id'],
            'area_id' => $input['area_id'],
            'city' => city_name($input['province_id']) . city_name($input['city_id']) . city_name($input['area_id']),
            'address' => $input['address'],
            'lng' => $input['lng'],
            'lat' => $input['lat'],
            'fish_name' => array_key_exists('fish_name', $input) ? $input['fish_name'] : '',
            'name' => $input['name'],
            'phone' => $input['phone'],
            'pay_money' => config('site.release_price')
        ];
        Db::startTrans();
        try {
            $suppliers_id = $suppliers_model->insertGetId($data);

            //更新用户表
            if ($input['type'] == 1) {
                $user_data['is_pond'] = 1;
                $user_data['z_name'] = $input['z_name'];
                $user_data['z_phone'] = $input['z_phone'];
            } else {
                $user_data['is_fishery'] = 1;
            }
            $user_model = new User();
            $user_model->save($user_data, ['id' => $user_id]);
            //添加申请鱼塘信息
            if ($input['type'] == 1) {
                $yutang_model = new YutangModel();
                $yutang_data = [
                    'image' => array_key_exists('cover_image', $input) ? $input['cover_image'] : '',
                    'name' => array_key_exists('fish_name', $input) ? $input['fish_name'] : '',
                    'province' => $input['province_id'],
                    'city' => $input['city_id'],
                    'area' => $input['area_id'],
                    'address' => $input['address'],
                    'latitude' => $input['lat'],
                    'longitude' => $input['lng'],
                    'phone' => $input['phone'],
                    'video' => array_key_exists('video', $input) ? $input['video'] : '',
                    'license' => $input['certificates_image'],
                    'price' => config('site.release_price'),
                    'status' => 1,
                    'user_id' => $user_id,
                    'order_no' => time() . $user_id,
                    'fishery_id' => $suppliers_id
                ];
                $yutang_model->insert($yutang_data);
            }

            Db::commit();
            $this->success('申请成功,请耐心等待审核');

        } catch (ErrorException $e) {
            Db::rollback();
            $this->error('申请失败,请稍后重试');
        }
    }

    /**
     * 申请入驻-查看
     * @ApiMethod (POST)
     * @ApiParams (name=type, type="int", required=true,description="类型:1=塘主,2=渔场主")
     * @ApiReturnParams (name=has_apply, type="bool", required=true,description="true=有申请信息，false=没有申请信息")
     * @ApiReturnParams (name=detail, type="object", required=true,description="详细信息，参数见apply接口")
     * @ApiReturnParams (name=detail.status, type="int", required=true,description="状态:1=审核中,2=审核通过,3=审核失败,4缴费成功")
     * @ApiReturnParams (name=detail.refusal_reason, type="string", required=true,description="审核失败理由")
     * @ApiReturn ({"code":1,"msg":"ok","time":"1672390281","data":{"has_apply":true,"detail":{"id":3,"type":1,"user_id":3,"certificates_type":"营业执照","certificates_image":"11","cover_image":"1","video":"111","province_id":1,"city_id":2,"area_id":4,"city":"北京市北京市北京市","address":"address","lng":"123.1","lat":"40.5","fish_name":"余名","name":"佚名","phone":"13161001120","status":1,"refusal_reason":null,"createtime":1672387969,"updatetime":1672387969,"deletetime":null,"logout":0,"logout_reason":null,"pay_time":0,"pay_no":"","pay_money":"0.00","type_text":"Type 1","status_text":"Status 1","logout_text":""}}})
     */
    public function apply_detail()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['type'])) {
            $this->error('请完善信息');
        }

        if ($input['type'] != 1 && $input['type'] != 2) {
            $this->error('参数错误');
        }

        $fishery_model = new Fishery();
        // 申请的信息
        $info = $fishery_model::where(['user_id' => $user_id, 'type' => $input['type']])->order('id', 'desc')->find();
        $has_apply = false;
        if($info){
            $has_apply = true;
        }

        if ($info['logout_status'] == 2) {
            unset($info['id']);
        }

        $info['z_name'] = $this->auth->z_name;
        $info['z_phone'] = $this->auth->z_phone;

        $this->success('ok', ['has_apply' => $has_apply, 'detail' => $info]);
    }

    /**
     * 重新申请入驻塘主or渔场主
     * @ApiMethod (POST)
     * @ApiParams (name=id, type="int", required=true,description="申请id")
     * @ApiParams (name=type, type="int", required=true,description="类型:1=塘主,2=渔场主")
     * @ApiParams (name=certificates_type, type="string", required=true,description="证件类型:营业执照/租赁资格证")
     * @ApiParams (name=certificates_image,type="string", required=true,,description="证件图片")
     * @ApiParams (name=cover_image,type="string", required=true,description="封面图")
     * @ApiParams (name=video,type="string", required=true,description="视频")
     * @ApiParams (name=province_id,type="int", required=true,description="省")
     * @ApiParams (name=city_id,type="int", required=true,description="市")
     * @ApiParams (name=area_id,type="int", required=true,description="区")
     * @ApiParams (name=address,type="string", required=true,description="详细地址")
     * @ApiParams (name=lng,type="string", required=true,description="经度")
     * @ApiParams (name=lat,type="string", required=true,description="纬度")
     * @ApiParams (name=fish_name,type="string", required=true,description="鱼塘名称")
     * @ApiParams (name=name,type="string", required=true,description="姓名")
     * @ApiParams (name=phone,type="string", required=true,description="联系方式")
     * @ApiParams (name=z_name,type="string", required=true,description="支付宝姓名")
     * @ApiParams (name=z_phone,type="string", required=true,description="支付宝手机号")
     */
    public function re_apply()
    {
        $user_id = $this->auth->id;
        $input = input();
        if (empty($input['type']) || empty($input['certificates_type']) || empty($input['certificates_image']) || empty($input['province_id']) || empty($input['city_id']) || empty($input['area_id']) || empty($input['address']) || empty($input['lng']) || empty($input['lat']) || empty($input['name']) || empty($input['phone'])) {
            $this->error('请完善信息');
        }

        if ($input['type'] != 1 && $input['type'] != 2) {
            $this->error('参数错误');
        }

        // 申请塘主时
        if ($input['type'] == 1 && (empty($input['cover_image']) || empty($input['video']) || empty($input['fish_name']) || empty($input['z_name']) || empty($input['z_phone']))) {
            $this->error('请完善信息');
        }

        $suppliers_model = new Fishery();
        // 检查申请信息
        $info = $suppliers_model::get(['id' => $input['id'], 'user_id' => $user_id, 'type' => $input['type']]);
        if (!$info) {
            $this->error('信息不存在，不能重新申请');
        }

        $data = [
            'certificates_type' => $input['certificates_type'],
            'certificates_image' => $input['certificates_image'],
            'cover_image' => array_key_exists('cover_image', $input) ? $input['cover_image'] : '',
            'video' => array_key_exists('video', $input) ? $input['video'] : '',
            'province_id' => $input['province_id'],
            'city_id' => $input['city_id'],
            'area_id' => $input['area_id'],
            'city' => city_name($input['province_id']) . city_name($input['city_id']) . city_name($input['area_id']),
            'address' => $input['address'],
            'lng' => $input['lng'],
            'lat' => $input['lat'],
            'fish_name' => array_key_exists('fish_name', $input) ? $input['fish_name'] : '',
            'name' => $input['name'],
            'phone' => $input['phone'],
            'status' => 1,
            'logout_status' => 2,
            'refusal_reason' => "",
        ];
        Db::startTrans();
        try {
            $suppliers_model->save($data, ['id' => $input['id']]);

            //更新用户表
            if ($input['type'] == 1) {
                $user_data['is_pond'] = 1;
                $user_data['z_name'] = $input['z_name'];
                $user_data['z_phone'] = $input['z_phone'];
            } else {
                $user_data['is_fishery'] = 1;
            }
            $user_model = new User();
            $user_model->save($user_data, ['id' => $user_id]);

            Db::commit();
            $this->success('申请成功,请耐心等待审核');

        } catch (ErrorException $e) {
            Db::rollback();
            $this->error('申请失败,请稍后重试');
        }
    }

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

        $type = $this->request->post('type');
        if ($type != 'wechat' && $type != 'alipay') {
            $this->error('请选择支付类型');
        }
        $method = $this->request->post('mod');

        $fishery_model = new Fishery();
        $fishery_info = $fishery_model->where('user_id', $this->auth->id)
            ->where('type', 1)
            ->whereIn('status', [2, 5])
            ->find();
        if (!$fishery_info) {
            $this->error('提交的申请不存在');
        }

        // 订单号
        $orderid = 'RZ' . order_no_s($this->auth->id);

        Db::startTrans();
        try {
            $data = [
                'pay_money' => $money,//更新缴费金额
                'pay_no' => $orderid,
                'status' => 5
            ];
            $fishery_info->save($data);
            Db::commit();
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e);
        }

        // 兼容小程序登录选手机号，传openid
        $openID = input('wx_openid');
        if ($openID == '') {
            if ($type == 'wechat' && $method != 'app') {
                $third_model = new Third();
                $openID = $third_model->where('user_id', $this->auth->id)->where('platform', 'xcc')->value('openid');
                if ($openID == '') {
                    $this->error("openid");
                }
            }
        }

        $params = [
            'amount' => $money,
            'orderid' => $orderid,
            'type' => $type,
            'title' => "塘主(" . $fishery_info->id . ")支付入驻资金",
            'notifyurl' => common_url() . '/index.php/api/Notify/fishery_notify/type/' . $type,
            'returnurl' => common_url() . '/index.php/api/Notify/fishery_notify/type/' . $type . '/out_trade_no/' . $orderid,
            'method' => $method,
            'openid' => $openID,
        ];
        $pay = \addons\epay\library\Service::submitOrder($params);
        $this->success('ok', $pay);

    }

    /**
     * 账户注销-提交
     * @ApiMethod (POST)
     * @ApiParams (name=logout_reason,type="string", required=true,description="账户注销理由")
     * @ApiParams (name=logout_type,type="string", required=true,description="类型:1=塘主,2=渔场主")
     */
    public function user_logout()
    {
        $logout_reason = $this->request->post('logout_reason');
        $logout_type = $this->request->post('logout_type');
        if ($logout_reason == "" || $logout_type == '') {
            $this->error(__('Invalid parameters'));
        }

        $suppliers_model = new Fishery();
        // 检查申请信息
        if ($logout_type == 1) {
            $status = 4;
        } else {
            $status = 2;
        }
        $info = $suppliers_model::get(['user_id' => $this->auth->id, 'type' => $logout_type, 'status' => $status]);
        if (!$info) {
            $this->error('申请信息不存在');
        }

        $info->logout = 1;
        $info->logout_reason = $logout_reason;
        $info->logout_status = 1;
        $info->save();

        $this->success('成功');
    }
}