infantServiceApi/app/api/controller/User.php

<?php
// +----------------------------------------------------------------------
// | [ WE CAN DO IT MORE SIMPLE  ]
// +----------------------------------------------------------------------
// | Copyright (c) 2018-2020 rights reserved.
// +----------------------------------------------------------------------
// | Author: TABLE ME
// +----------------------------------------------------------------------
// | Date: 2020-08-25 17:23
// +----------------------------------------------------------------------
declare (strict_types=1);

namespace app\api\controller;

use app\BaseController;

use app\model\api\User as UserModel;
use app\model\api\UserDetail as UserDetailModel;
use app\model\api\ServiceType as ServiceTypeModel;
use app\model\api\InfoAudit;
use app\model\api\TypeAudit;
use app\model\api\UserAudit;
use app\model\api\ServiceType;
use app\model\api\ServiceTimeType;
use app\model\api\City as CityModel;
use app\model\api\Sys as SysModel;
use app\model\api\ShowTemplate;
use app\model\api\ShowTemplateOrder;
use app\model\api\UserShowTemplate;
use app\model\api\PayTrade as PayTradeModel;

use app\Request;
use library\services\UtilService;
use library\utils\QRcodeComm;
use library\utils\WxpayV2 as wxpayApi;
use think\db\exception\DbException;
use library\lib\weixina;
use think\facade\Db;
use think\Image;
use think\Route;

class User extends BaseController
{
    
    /**
     * 获取用户详情
     * @param Request $request
     */
    public function userInfo(Request $request){
        //资料审核信息
        $infoAuditData = (new InfoAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
        $userAuditData = (new UserAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
        $typeAuditData = (new TypeAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
        $data = [];
        $data['nickname']          = $request->user['nickname'];
        $data['avatar']            = $request->user['avatar'];
        $data['name']              = $request->user['name'];
        $data['info_audit_status'] = empty($infoAuditData)?-2:$infoAuditData["status"];
        $data['user_audit_status'] = empty($userAuditData)?-2:$userAuditData["status"];
        $data['type_audit_status'] = empty($typeAuditData)?-2:$typeAuditData["status"];
        return app('json')->success($data);
    }
    
    /**
     * 设置用户信息
     * @param Request $request
     */
    public function setUserInfo(Request $request){
        $post = UtilService::getMore([
            ['avatar',''],
            ['nickname',''],
            ['name',''],
            ['mobile',''],
            ['sex', ''],
        ],$request);
        $save=[];
        if(!empty($post["avatar"])){
            $save["avatar"] = $post["avatar"];
        }
        if(!empty($post["nickname"])){
            $save["nickname"] = $post["nickname"];
        }
        if(!empty($post["name"])){
            $save["name"] = $post["name"];
        }
        if(!empty($post["mobile"])){
            if(is_mobile($post["mobile"])){
                return app("json")->fail("请输入正确的手机号码"); 
            }
            $save["mobile"] = $post["mobile"];
        }
        if(in_array((string)$post["sex"],["0","1","2"])){
            $save["sex"] = (int)$post["sex"];
        }
        if(empty($save)){
            return app("json")->fail("提交数据为空");
        }
        //是否需要审核
        $isInfoAudit = 0;
        if($isInfoAudit==0){
            $r = (new UserModel)->where("uid",$request->user["uid"])->update($save);
            if(!$r){
               return app("json")->fail("提交数据为空"); 
            }
        }else{
            $data = (new UserAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
            if(!empty($data) && $data["status"]==0){
                return app('json')->fail("资料审核中,请勿重复提交");
            }
            $save["uid"] = $request->user["uid"];
            $save["status"] = 0; 
            $r = (new UserAudit)->insert($save);
            if(!$r){
               return app("json")->fail("提交数据为空"); 
            }
        }
        return app("json")->success("提交成功");
        
    }
    
    
    /**
     * 提交资料审核
     * @param Request $request
     */
    public function subInfoAudit(Request $request){
        $data = (new InfoAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
        if(!empty($data) && $data["status"]==0){
            return app('json')->fail("资料审核中,请勿重复提交");
        }
        $post = UtilService::getMore([
            ['avatar',''],
            ['name','','empty','请输入真实姓名'],
            ['mobile','','is_moblie','请输入正确的手机号码'],
            ['idcard','','empty','请输入正确的身份证号码'],
            ['birthday',''],
            ['service_type',''],
            ['service_price',''],
            ['service_min_price',''],
            ['service_max_price',''],
            ['service_area',[]],
            ['service_project',[]],
            ['service_intro_content',''],
            ['service_intro_imgs',[]],
            ['service_audit_imgs',[]],
        ],$request);
        $save=[];
        $save["avatar"]   = empty($post["avatar"])  ? "" : $post["avatar"];
        $save["name"]     = empty($post["name"])    ? "" : $post["name"];
        $save["mobile"]   = empty($post["mobile"])  ? "" : $post["mobile"];
        $save["idcard"]   = empty($post["idcard"])  ? "" : $post["idcard"];
        $save["birthday"] = empty($post["birthday"])? 0  : strtotime($post["birthday"]);
        //服务类型
        if(!empty($post["service_type"])){
            $timeTypeData = (new ServiceTimeType)->where("code",$post["service_type"])->where("status",1)->select();
            if(empty($timeTypeData)){
                return app('json')->fail("服务时长类型不存在");
            }
            $save["service_type"] = $post["service_type"];
        }
        //服务价格区间
        $save["service_price"] = empty($post["service_price"]) ? "" : $post["service_price"];
        $save["service_min_price"] = empty($post["service_min_price"]) ? 0 : $post["service_min_price"];
        $save["service_max_price"] = empty($post["service_max_price"]) ? 0 : $post["service_max_price"];
        //服务区域
        $cityModel = new CityModel();
        if(!empty($post["service_area"]) && is_array($post["service_area"])){
            $saveAre=[];
            foreach($post["service_area"] as $k=>$v){
                if(empty(trim($v))){
                    continue;
                }
                $itemData = $cityModel->where("name",trim($v))->where("level",2)->find();
                if(!empty($itemData)){
                    $saveAre[]=$itemData["id"];
                }
            }
            if(!empty($saveAre)){
                $save["service_area"] = implode(",", $saveAre);
            }
        }
        //服务内容
        $serviceTypeModel = new ServiceTypeModel();
        if(!empty($post["service_project"]) && is_array($post["service_project"])){
            $saveCon=[];
            foreach($post["service_project"] as $k=>$v){
                if(empty(trim($v))){
                    continue;
                }
                $itemData = $serviceTypeModel->where("id",(int)$v)->where("status",1)->find();
                if(!empty($itemData)){
                    $saveCon[]=$itemData["id"];
                }
            }
            if(!empty($saveCon)){
                $save["service_project"] = implode(",", $saveCon);
            }
        }
        $save["service_intro_content"]  = empty($post["service_intro_content"])?"": $post["service_intro_content"];
        $save["service_intro_imgs"]     = empty($post["service_intro_imgs"])   ?"": implode(",", $post["service_intro_imgs"]);
        $save["service_audit_imgs"]     = empty($post["service_audit_imgs"])   ?"": implode(",", $post["service_audit_imgs"]);
        $save["status"] = 0;
        $save["time"]   = time();
        $save["uid"]    = $request->user["uid"];
        $r = (new InfoAudit)->insert($save);
        if(!$r){
            return app('json')->fail("系统错误");
        }
        return app('json')->success("提交成功,请耐心等待审核");
    }
    /**
     * 提交资料审核2
     * @param Request $request
     */
    public function subTypeAudit(Request $request){
        $data = (new TypeAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
        if(!empty($data) && $data["status"]==0){
            return app('json')->fail("资料审核中,请勿重复提交");
        }
        $post = UtilService::getMore([
            ['avatar',''],
            ['name','','empty','请输入真实姓名'],
            ['mobile','','is_moblie','请输入正确的手机号码'],
            ['idcard','','empty','请输入正确的身份证号码'],
            ['birthday',''],
            ['service_type',''],
            ['service_price',''],
            ['service_area',[]],
            ['service_project',[]],
            ['service_intro_content',''],
            ['service_intro_imgs',[]],
            ['service_audit_imgs',[]],
        ],$request);
        $save=[];
        $save["avatar"]   = empty($post["avatar"])  ? "" : $post["avatar"];
        $save["name"]     = empty($post["name"])    ? "" : $post["name"];
        $save["mobile"]   = empty($post["mobile"])  ? "" : $post["mobile"];
        $save["idcard"]   = empty($post["idcard"])  ? "" : $post["idcard"];
        $save["birthday"] = empty($post["birthday"])? 0  : strtotime($post["birthday"]);
        //服务类型
        if(!empty($post["service_type"])){
            $timeTypeData = (new ServiceTimeType)->where("code",$post["service_type"])->where("status",1)->select();
            if(empty($timeTypeData)){
                return app('json')->fail("服务时长类型不存在");
            }
            $save["service_type"] = $post["service_type"];
        }
        //服务价格区间
        $save["service_price"] = empty($post["service_price"]) ? "" : $post["service_price"];
        //服务区域
        $cityModel = new CityModel();
        if(!empty($post["service_area"]) && is_array($post["service_area"])){
            $saveAre=[];
            foreach($post["service_area"] as $k=>$v){
                if(empty(trim($v))){
                    continue;
                }
                $itemData = $cityModel->where("name",trim($v))->where("level",2)->find();
                if(!empty($itemData)){
                    $saveAre[]=$itemData["id"];
                }
            }
            if(!empty($saveAre)){
                $save["service_area"] = implode(",", $saveAre);
            }
        }
        //服务内容
        $serviceTypeModel = new ServiceTypeModel();
        if(!empty($post["service_project"]) && is_array($post["service_project"])){
            $saveCon=[];
            foreach($post["service_project"] as $k=>$v){
                if(empty(trim($v))){
                    continue;
                }
                $itemData = $serviceTypeModel->where("id",(int)$v)->where("status",1)->find();
                if(!empty($itemData)){
                    $saveCon[]=$itemData["id"];
                }
            }
            if(!empty($saveCon)){
                $save["service_project"] = implode(",", $saveCon);
            }
        }
        $save["service_intro_content"]  = empty($post["service_intro_content"])?"": $post["service_intro_content"];
        $save["service_intro_imgs"]     = empty($post["service_intro_imgs"])   ?"": implode(",", $post["service_intro_imgs"]);
        $save["service_audit_imgs"]     = empty($post["service_audit_imgs"])   ?"": implode(",", $post["service_audit_imgs"]);
        $save["status"] = 0;
        $save["time"]   = time();
        $save["uid"]    = $request->user["uid"];
        $r = (new TypeAudit)->insert($save);
        if(!$r){
            return app('json')->fail("系统错误");
        }
        return app('json')->success("提交成功,请耐心等待审核");
    }
    
    
    /**
     * 模板订单提交[第一步]
     * @param Request $request
     */
    public function subShowTemplateOrder(Request $request){
        [$id,$pay_type] = UtilService::getMore([
            ['id','','empty','参数错误'],
            ['pay_type','','empty','请选择支付方式'],
        ],$request,true);
        
        if(!in_array($pay_type,["wxpay","balance"])){
            return app('json')->fail('不支持该支付方式！');
        }
        //缓存
        $redis = \think\facade\Cache::store('redis');
        $key   = 'show_template_order_sub_' . $request->user['uid'];
        $bool  = $redis->handler()->exists($key);
        if ($bool) {
            return app('json')->fail('请务重复操作，请稍等在重试！');
        }
        $redis->set($key,1,5);//5秒缓存
        $proData = (new ShowTemplate)->where("id",$id)->where("status",1)->find();
        if(empty($proData)){
            return app('json')->fail("当前模板已下架");
        }
        $proData = $proData->toArray();
        $count = (new UserShowTemplate)->where("uid",$request->user['uid'])->where("show_template_id",$id)->count();
        if($count>0){
            return app('json')->fail("您已购买过当前模板");
        }
        //验证
        $orderCount = (new ShowTemplateOrder)->where("uid",$request->user['uid'])->where("show_template_id",$id)->where("status",1)->count();
        if($orderCount>0){
            return app('json')->fail("您已下单该模板,请勿重复下单");
        }
        $price = floatval($proData["price"]);
//        if($price<0.01){
//            return app('json')->fail("模板信息错误");
//        }
        $allMoney    = $price;//订单商品费用
        $total_money = $allMoney;//订单总费用
        $payMoney    = $total_money;//订单需支付费用
        $payMoney    = $payMoney <= 0 ? 0 : $payMoney;
        $nowTime     = time();
        
        //余额支付验证
        if($pay_type=="balance" && $payMoney > $request->user["money"]){
            return app('json')->fail("当前余额不足");
        }

        //主订单数据
        $save=[];
        $save['uid']          = $request->user['uid'];
        $save['order_id']     =  makeOrderId($request->user['uid'],"ST");
        $save['pay_type']     = $pay_type;//
        $save['total_money']  = $total_money;//订单总金额
        $save['all_money']    = $allMoney;//商品中金额
        $save['pay_money']    = $payMoney;//实际支付金额
        $save['balance']      = 0;//余额支付了多少(目前不用)
        $save['status']       = $payMoney <= 0 ? 1 : 0;
        $save['pay_time']     = $payMoney <= 0 ? time() : 0;
        $save['time']         = $nowTime;
        
        $save['show_template_id']    = $proData["id"];
        $save['show_template_title'] = $proData["title"];;
        $save['show_template_price'] = $proData["price"];
        $save['show_template_img']   = empty($proData["imgs"]) ? "" : explode(",", $proData["imgs"])[0];
        $save['show_template_code']  = $proData["code"];
        //余额实时支付
        if($pay_type=="balance"){
            $save['status']       = 1;
            $save['pay_time']     = time();
        }
        try{
            Db::startTrans();
            $o_id = (new ShowTemplateOrder)->insertGetId($save);
            if(empty($o_id)){
                return app('json')->fail("订单提交失败");
            }
            //不需要支付
            if($payMoney<=0 && $save['status']==1){
                //验证并绑定当前模板
                (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
                Db::commit();
                return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
            }
            //余额支付
            if($pay_type=="balance"){
                //验证并绑定当前模板
                (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
                //修改用户余额
                $res = (new UserDetailModel)->balancePay($request->user["uid"],$payMoney,"show_temp_pay",["to_id"=>$o_id]);
                if(!$res){
                    Db::rollback();
                    return app('json')->fail("余额支付失败");
                }
                Db::commit();
                return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
            }
            //微信支付
            if(empty($request->user['openid'])){
                Db::rollback();
                return app('json')->fail('用户还未绑定微信！');
            }
            //清理之前支付凭证 || 防止重复购买
            $payTrade = (new PayTradeModel)
                    ->where("uid",$request->user["uid"])
                    ->where("o_id",$o_id)
                    ->where("type","temp")
                    ->where("status",0)
                    ->where("time","<",time() - 7*24*60*60)
                    ->select()
                    ->toArray();
            $wxpay = new wxpayApi();
            foreach ($payTrade as $v) {
//                if($v['pay_type'] == 'wxpay') {
//                    $result = $wxpay->closeOrder($v['pay_no']);
//                }
                (new PayTradeModel)->where("id",$v['id'])->where("status",0)->delete();
            }
            $mtime = microtime(true)*10000;
            $payOn = "T".date("Ymd").$mtime .rand(100,999) . $request->user['uid'];
            $out_trade_no="";
            $payType  = $save["pay_type"];
            //添加交易记录
            $trade = [
                'uid'      => $request->user['uid'],
                'o_id'     => $o_id,
                'order_id' =>$save["order_id"],
                'pay_no'   => $payOn,
                'out_trade_no' => empty($out_trade_no) ? $payOn : $out_trade_no,
                'pay_type' => $payType,
                'money'    => $payMoney,
                'type'     => 'temp',
                'd_json'   => serialize(['orderId'=>$save["order_id"],"give_score"=>0]),
                'time'     => time(),
                'status'   => 0,
            ];
            $r=(new PayTradeModel)->insert($trade);
            if(!$r){
                Db::rollback();
                return app('json')->fail('支付信息获取失败！');
            }
            $clictip = get_client_ip();
            if(empty($clictip)){
                $clictip = $request->ip();
            }
            $payData =  $wxpay->wxmpPay([
                'body'            => "微信小程序购买模板",
                'out_trade_no'    => $payOn,
                'total'           => $payMoney,
                'openid'          => $request->user['openid'],
                'payer_client_ip' => $clictip,
            ]);
            if(empty($payData)){
                Db::rollback();
                return app('json')->fail($wxpay->errorMsg);
            }
            Db::commit();
            $redis->delete($key);
            return app('json')->success([
                'jsApiParameters'=> $payData,
                'pay_no'         => $payOn,
                'order_id'       => $save["order_id"],
                "status"         => $save['status'],
                "money"          => $payMoney,
            ]);
        } catch (DbException $db){
            Db::rollback();
            return app('json')->fail("订单生成失败");
        }
    }
    /**
     * 获取模板购买订单详情
     * @param Request $request
     */
    public function payShowTemplateOrderInfo(Request $request){
        [$order_id] = UtilService::getMore([
            ['order_id','','empty','参数错误'],
        ],$request,true);
        $data = (new ShowTemplateOrder)
                ->field("order_id,total_money,all_money,pay_money,status,time")
                ->where("order_id",$order_id)
                ->where("uid",$request->user["uid"])
                ->find();
        if(empty($data)){
            return app('json')->fail('信息不存在！');
        }
        $data=$data->toArray();
        if($data["status"]==0 && $data["time"]<time() - 30*60){
            (new ShowTemplateOrder)->where("id",$data["id"])->where("uid",$request->user["uid"])->update(["status"=>-1]);
            $data["status"]==-1;
        }
        $data["time"] = date("Y-m-d H:i:s",$data["time"]);
        return app('json')->success($data);
    }
    
    
    /**
     * 用户模板列表
     * @param Request $request
     */
    public function userShowTemplateList(Request $request){
        $post = UtilService::getMore([
            ['page', 1],
            ['pageSize', 50],
        ], $request);
        $post["pageSize"] = $post["pageSize"]>50 ? 50 : (int)$post["pageSize"];
        $post["page"]     = $post["page"]<=0 ? 1 : (int)$post["page"];
        $where=[];
//        $where[]=["status","=",1];
        $totalCount = (new UserShowTemplate)->where($where)->count();
        $data=null;
        if($totalCount>0){
            $data = (new UserShowTemplate)
                ->field("t.id,t.title,t.price,t.old_price,t.status,t.imgs,t.is_hot,t.is_recommend,t.code,look_count,t.real_sales,t.unreal_sales,ut.is_default")
                ->alias("ut")
                ->join("show_template t", "t.id = ut.show_template_id","left")
                ->where($where)
                ->order("ut.is_default", "desc")
                ->order("ut.id", "desc")
                ->page($post["page"], $post["pageSize"])
                ->select();
            foreach($data as $k=>$v){
                $data[$k]["is_use"]      = 1;//是否已经购买或者可以使用
                $data[$k]["imgs"]        = getImageAr($v["imgs"]);
                $data[$k]["img"]         = empty($data[$k]["imgs"]) ? "" : $data[$k]["imgs"][0];
                $data[$k]["sales_count"] = $data[$k]["real_sales"] + $data[$k]["unreal_sales"];
                unset($data[$k]["real_sales"]);
                unset($data[$k]["unreal_sales"]);
            }
        }
        $data = empty($data)?[]:$data;
        return app('json')->success(["list" => $data, "pageSize" => $post["pageSize"],"page"=>$post["page"],"totalCount"=>$totalCount]);
    }
    
    
   
    
    
    
   
    
    
    
    
    /**
     * 发布圈子
     * @param Request $request
     */
    public function upCircle(Request $request){
        $post = UtilService::getMore([
            ['id',''],
            ['title',''],
            ['content','','empty','请输入动态内容'],
            ['imgs',[]],
            ['video',''],
            ['video_img',''],
            ['video_time',0],
            ['pro_id',''],
        ],$request);
        
        $post["status"]=0;
        
        $post["imgs"] = empty($post["imgs"]) ? "" : $post["imgs"];
        $post["update_time"] = time();
        if(empty($post["imgs"]) && empty($post["video"])){
            return app('json')->fail("请至少上传一张主图");
        }
        if(!empty($post["imgs"])){
            $post["video"]="";
            $post["video_img"]="";
            $post["video_time"]=0;
        }
        if(!empty($post["video"])){
            $post["imgs"]="";
            if(empty($post["video_img"])){
                return app('json')->fail("视频封面错误");
            }
            if(empty($post["video_time"]) || (int)$post["video_time"]<=0){
                return app('json')->fail("视频时长错误");
            }
        }
        if(!empty($post["pro_id"])){
            $proData = (new Goods)->where("id",$post["pro_id"])->where("status",1)->find();
            if(empty($proData)){
                return app('json')->fail("当前商品不可选中");
            }
        }else{
            $post["pro_id"]=0;
        }
        $id = $post["id"];
        unset($post["id"]);
        $r=0;
        if(empty($id) || $id=="0"){
            $post["time"] = time();
            $post["uid"] = $request->user["uid"];
            $r = (new UserCircle)->insert($post);
        }else{
            $r = (new UserCircle)->where("id",$id)->update($post);
        }
        if($r){
            return app('json')->success("发布成功，等待客服审核。");
        }else{
            return app('json')->fail("数据保存失败");
        }
    }
    
    
    /**
     * 图片上传
     * @param Request $request
     * @return type
     */
    public function upload(Request $request){
        $sysData = (new SysModel())->where("id",1)->find();
        $file = $request->file('file');
        $code = $request->post("code","image");
        if(empty($file)) {
            return app('json')->fail("未上传文件");
        }
        if(!in_array($code, ["avatar","video","image","circle","advert","goods","activity"])){
            return app('json')->fail("上传路径错误");
        }
        $ext = $file->extension();
        if(!in_array($ext, array("png","jpeg","gif","jpg"))){
            return app('json')->fail("图片类型错误");
        }
        $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
        if(!$upPath){
            return app('json')->fail("上传失败01");
        }
        $savePath = $sysData['file_url'].'/resource/' . $upPath;
        $imgUrl = str_replace("\\", "/", $savePath);
        return app('json')->success(['img'=>$imgUrl]);
    }
    
    /**
     * 视频上传
     * @param Request $request
     * @return type
     */
    public function uploadVideo(Request $request){
        $sysData = (new SysModel())->where("id",1)->find();
        $file = $request->file('file');
        $code = $request->post("code","video");
        if(empty($file)) {
            return app('json')->fail("未上传文件");
        }
        if(!in_array($code, ["video"])){
            return app('json')->fail("上传路径错误");
        }
        $ext = $file->extension();
        if(!in_array($ext, array("mp4","megp4"))){
            return app('json')->fail("视频类型错误");
        }
        $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
        if(!$upPath){
            return app('json')->fail("上传失败01");
        }
        $savePath = $sysData['system_url'].'/resource/' . $upPath;
        $imgUrl = str_replace("\\", "/", $savePath);
        return app('json')->success(['video'=>$imgUrl]);
    }
    
   
    
    
}