NN2021052501/app/Services/GongdengOrderService.php

<?php
// +----------------------------------------------------------------------
// | Laravel框架 [ Laravel ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 Laravel研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: wesmiler <12345678@qq.com>
// +----------------------------------------------------------------------

namespace App\Services;

use App\Models\CardModel;
use App\Models\DynamicNoticeModel;
use App\Models\GongdengFoxiangModel;
use App\Models\GongdengOrderModel;
use App\Models\LampMealsModel;
use App\Models\MemberModel;

/**
 * 供灯管理-服务类
 * @author wesmiler
 * @since 2020/11/11
 * Class GongdengOrderService
 * @package App\Services
 */
class GongdengOrderService extends BaseService
{
    protected static $instance = null;
    /**
     * 构造函数
     * @author wesmiler
     * @since 2020/11/11
     * GongdengOrderService constructor.
     */
    public function __construct()
    {
        $this->model = new GongdengOrderModel();
    }

    /**
     * 静态入口
     * @return GongdengOrderService|null
     */
    public static function make(){
        if(!self::$instance){
            self::$instance = new GongdengOrderService();
        }

        return self::$instance;
    }

    public function getList()
    {
        $params = request()->all();
        $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE;
        $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE;

        $dataList = $this->model::from('gongdeng_orders as a')
            ->leftJoin('gongdeng_foxiang as gf', 'gf.id', '=', 'a.source_id')
            ->leftJoin('member as m', 'a.user_id', '=', 'm.id')
            ->where(function ($query) use ($params) {
                $query->where('a.mark', 1);

                $status = isset($params['status']) ? $params['status'] : 0;
                if ($status > 0) {
                    $query->where('a.status', $status);
                } else {
                    $query->where('a.status', '>', 0);
                }

            })
            ->where(function ($query) use ($params) {
                $keyword = isset($params['keyword']) ? trim($params['keyword']) : '';
                if (!empty($keyword)) {
                    $query->where('a.order_sn', 'like', "%{$keyword}%")
                        ->orWhere('m.nickname', 'like', "%{$keyword}%");
                }
            })
            ->select(['a.id', 'a.source_id', 'a.user_id','a.pay_money','a.pay_type','a.total','a.num','a.device_num','a.is_hide','a.order_sn','a.buy_type','a.trade_no', 'a.sf_name', 'a.qf_content', 'a.is_hide', 'gf.name as fx_name', 'gf.thumb as fx_thumb', 'm.nickname', 'm.avatar', 'a.status','a.lamp_status', 'a.create_time', 'a.pay_at','a.expire_time', 'a.update_time'])
            ->orderBy('a.pay_at', 'desc')
            ->orderBy('a.create_time', 'desc')
            ->paginate($pageSize);

        $dataList = $dataList ? $dataList->toArray() : [];
        if ($dataList) {
            foreach ($dataList['data'] as &$item) {
                $item['avatar'] = $item['avatar'] ? get_image_url($item['avatar']) : '';
                $item['fx_thumb'] = $item['fx_thumb'] ? get_image_url($item['fx_thumb']) : '';
                $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : '';
                $item['expire_at'] = $item['expire_time'] ? datetime($item['expire_time'], 'Y-m-d H:i:s') : '';
            }
            unset($item);
        }

        return [
            'code' => 0,
            'success' => true,
            'msg' => '操作成功',
            'count' => isset($dataList['total']) ? $dataList['total'] : 0,
            'data' => isset($dataList['data']) ? $dataList['data'] : 0,
        ];
    }

    /**
     * 功德列表
     */
    public function getGdList()
    {
        $params = request()->all();
        $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE;
        $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE;

        $dataList = $this->model::from('gongdeng_orders as a')
            ->leftJoin('gongdeng_foxiang as gf', 'gf.id', '=', 'a.source_id')
            ->leftJoin('member as m', 'a.user_id', '=', 'm.id')
            ->where(['a.mark' => 1, 'a.status' => 2])
            ->select(['a.id', 'a.source_id', 'a.user_id', 'a.sf_name', 'a.qf_content', 'a.is_hide', 'gf.name as fx_name', 'm.nickname', 'm.avatar', 'a.status', 'a.create_time', 'a.pay_at', 'a.update_time'])
            ->orderBy('a.pay_at', 'desc')
            ->orderBy('a.create_time', 'desc')
            ->paginate($pageSize);

        $dataList = $dataList ? $dataList->toArray() : [];
        if ($dataList) {
            foreach ($dataList['data'] as &$item) {
                $item['avatar'] = $item['avatar'] ? get_image_url($item['avatar']) : '';
                $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : '';
                $time = $item['pay_at'] ? $item['pay_at'] : $item['create_time'];
                $item['time_text'] = $time ? format_time(strtotime($time)) : '刚刚';
                if ($item['is_hide']) {
                    $item['nickname'] = formatName($item['nickname']);
                }
            }
            unset($item);
        }

        return [
            'code' => 0,
            'success' => true,
            'msg' => '操作成功',
            'count' => isset($dataList['total']) ? $dataList['total'] : 0,
            'data' => isset($dataList['data']) ? $dataList['data'] : 0,
        ];
    }

    /**
     * 我的供灯列表
     */
    public function getMyGdList($userId)
    {
        $params = request()->all();
        $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE;
        $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE;

        $dataList = $this->model::from('gongdeng_orders as a')
            ->leftJoin('gongdeng_foxiang as gf', 'gf.id', '=', 'a.source_id')
            ->leftJoin('member as m', 'a.user_id', '=', 'm.id')
            ->where(['a.mark' => 1,'a.user_id'=> $userId])
            ->whereIn('a.status',[1,2,3])
            ->select(['a.id', 'a.source_id','a.order_sn', 'a.user_id', 'a.sf_name','gf.thumb as fx_thumb','a.buy_type','a.pay_money', 'a.qf_content','a.lamp_status','a.device_num', 'a.is_hide','a.expire_time', 'gf.name as fx_name', 'm.nickname', 'm.avatar', 'a.status', 'a.create_time', 'a.pay_at', 'a.update_time'])
            ->orderBy('a.pay_at', 'desc')
            ->orderBy('a.create_time', 'desc')
            ->paginate($pageSize);

        $dataList = $dataList ? $dataList->toArray() : [];
        if ($dataList) {
            foreach ($dataList['data'] as &$item) {
                $item['avatar'] = $item['avatar'] ? get_image_url($item['avatar']) : '';
                $item['fx_thumb'] = $item['fx_thumb'] ? get_image_url($item['fx_thumb']) : '';
                $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : '';
                $item['expire_at'] = $item['expire_time'] ? datetime($item['expire_time'], 'Y-m-d H:i:s') : '';
                $time = $item['pay_at'] ? $item['pay_at'] : $item['create_time'];
                $item['time_text'] = $time ? format_time(strtotime($time)) : '刚刚';
//                $item['nickname'] = iconv('utf8','utf8mb4', $item['nickname']);
                if ($item['is_hide']) {
                    $item['nickname'] = formatName($item['nickname']);
                }
            }
            unset($item);
        }

        return [
            'code' => 0,
            'success' => true,
            'msg' => '操作成功',
            'count' => isset($dataList['total']) ? $dataList['total'] : 0,
            'data' => isset($dataList['data']) ? $dataList['data'] : 0,
        ];
    }

    /**
     * 获取订单信息
     * @param $orderSn
     * @return array
     */
    public function orderInfo($orderSn){
        $info = $this->model::where(['order_sn'=> $orderSn, 'mark'=> 1])
            ->whereIn('status',[1,2,3])
            ->select(['id','order_sn as out_trade_no','source_id','user_id','pay_money','total','status'])
            ->first();
        $info = $info? $info->toArray() : [];
        if($info){
            $info['type'] = 1;
            $info['pay_money'] =  $info['pay_money']?  $info['pay_money'] : $info['total'];
        }
        return $info;
    }

    /**
     * 统计表数据
     * @param $dateType
     * @return array
     */
    public function tableData($dateType){
        $cacheKey = "caches:statistics:table_gd_{$dateType}";
        $datas = RedisService::get($cacheKey);
        if($datas){
            return $datas;
        }

        $firstTime = strtotime(date('Y-m-d'));
        if($dateType == 0){
            $formatStr = "%Y-%m-%d %H:00";
            $firstTime = strtotime(date('Y-m-d'));
            for($i = 0; $i<24; $i++){
                $i = $i<10? '0'.$i : $i;
                $ks = date('Y-m-d')." {$i}:00";
                $datas[$ks] = [
                    'date'=> $i.'点',
                    'ks'=> $ks,
                    'value'=> 0,
                ];
            }
        }else if($dateType == 1){
            $formatStr = "%Y-%m-%d";
            $firstTime =  strtotime('monday this week');
            $weeks = ['周一','周二','周三','周四','周五','周六','周日'];
            for($i = 0; $i<7; $i++){
                $ks = date('Y-m-d', $firstTime+$i*86400);
                $datas[$ks] = [
                    'date'=> $weeks[$i],
                    'ks'=> $ks,
                    'value'=> 0,
                ];
            }
        }else if($dateType == 2){
            $formatStr = "%Y-%m-%d";
            $firstTime = strtotime(date('Y-m-01'));
            $num = cal_days_in_month(CAL_GREGORIAN, date('m'), date('Y'));
            for($i = 1; $i<=$num; $i++){
                $i = $i<10? '0'.$i : $i;
                $ks = date('Y-m')."-{$i}";
                $datas[$ks] = [
                    'date'=> $i.'号',
                    'ks'=> $ks,
                    'value'=> 0,
                ];
            }
        }else if($dateType == 3){
            $formatStr = "%Y-%m";
            $firstTime = strtotime(date('Y-01-01'));
            for($i = 1; $i<=12; $i++){
                $ks = date('Y')."-".($i<10? '0'.$i : $i);
                $datas[$ks] = [
                    'date'=> $i.'月',
                    'ks'=> $ks,
                    'value'=> 0,
                ];
            }
        }

        $counts = $this->model::from('gongdeng_orders as a')
            ->leftJoin('member as m', 'm.id', '=', 'a.user_id')
            ->where(['a.mark'=> 1,'m.mark'=> 1,'a.status'=> 2])
            ->where('a.create_time','>=', $firstTime)
            ->where('a.create_time','<=', time())
            ->select([\DB::raw('count('.env('DB_PREFIX').'a.`id`) as value'),\DB::raw('FROM_UNIXTIME('.env('DB_PREFIX')."a.create_time,'{$formatStr}') as ks")])
            ->groupBy(\DB::raw('FROM_UNIXTIME('.env('DB_PREFIX')."a.create_time,'{$formatStr}')"))
            ->get();

        $counts = $counts? $counts->toArray() : [];
        if($counts){
            foreach ($counts as $v){
                if(isset($datas[$v['ks']])){
                    $datas[$v['ks']]['value'] = $v['value'];
                }
            }
        }

        $datas = array_values($datas);
        RedisService::set($cacheKey, $datas, rand(5, 10));

        return $datas;
    }

    /**
     * 供灯下单卡支付
     */
    public function cardBuy()
    {
        $params = request()->all();
        $userId = isset($params['user_id'])? intval($params['user_id']) : 0;

        // 验证佛像信息
        $fid = isset($params['fid']) ? $params['fid'] : 0;
        $foInfo = GongdengFoxiangModel::where(['id' => $fid, 'status' => 1, 'mark' => 1])
            ->select(['id', 'name'])
            ->first();
        if (!$foInfo || $fid <= 0) {
            return message('供灯佛像信息不存在', false);
        }

        $payType = isset($params['payType']) ? $params['payType'] : 0;
        if (!in_array($payType, [3])) {
            return message('支付方式暂不支持', false);
        }

        // 套餐信息
        $mid = isset($params['mid']) ? $params['mid'] : 0;
        $mealInfo = LampMealsModel::where(['id' => $mid, 'status' => 1, 'mark' => 1])
            ->select(['id', 'name', 'price', 'num'])
            ->first();
        if (!$mealInfo) {
            return message('供灯套餐不存在或已下架', false);
        }

        // 验证用户是否已授权
        $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1])
            ->select('id', 'openid', 'nickname')
            ->first();
        if (!$memberInfo) {
            return message('账号已被冻结，请联系客服', false);
        }

        // 验证是否供灯过
        $buyType = 1;
        $gdCheckData = GongdengOrderModel::where(['source_id' => $fid, 'user_id' => $userId,'lamp_status'=> 2, 'status' => 2, 'mark' => 1])
            ->where('expire_time', '>=', time())
            ->select(['id', 'source_id', 'user_id','device_num', 'expire_time', 'params'])
            ->first();

        // 续费
        if ($gdCheckData && $gdCheckData->id) {
            $buyType = 2;
        }

        // 创建订单
        $expireTime = ($mealInfo->num * 24 * 3600) + time();
        $order = [
            'source_id' => $fid,
            'user_id' => $userId,
            'pay_type' => $payType,
            'buy_type' => $buyType,
            'order_sn' => get_order_num('G'),
            'num' => 1,
            'price' => $mealInfo->price,
            'total' => $mealInfo->price,
            'sf_name' => isset($params['sf_name']) ? trim($params['sf_name']) : '',
            'qf_content' => isset($params['qf_content']) ? trim($params['qf_content']) : '',
            'is_hide' => isset($params['is_hide']) ? intval($params['is_hide']) : 0,
            'expire_time' => $expireTime,
            'create_time' => time(),
            'status' => 1,
        ];

        if($gdCheckData){
            $data['device_num'] = $gdCheckData->device_num;
            $data['params'] = $gdCheckData->params;
        }

        // 订单
        if (!$oid = GongdengOrderModel::insertGetId($order)) {
            return message('供灯订单创建失败', false);
        }

        $cardInfo = CardModel::where(['user_id'=> $userId,'mark'=> 1,'status'=> 1])->first();
        if(!$cardInfo) {
            return message('卡状态无法操作', false);
        }

        if($cardInfo->quota < $order['total']){
            return message('当前卡额度不足，请先到开卡管理菜单处充值', false);
        }

        $params = [
            'CommandType'=> 2, // 执行命令方式：1-充值，2-扣款
            'data'=> $order['total']
        ];
        $dataStr = [];
        foreach($params as $k => $v){
            $dataStr[] = $k.'='.$v;
        }

        // 调用亮灯接口处理
        $errorKey = "caches:cards:payGongdeng:{$userId}";
        $dataStr = implode('&', $dataStr);
        $headers = ["Content-Type:application/x-www-form-urlencoded; charset=UTF-8"];
        $apiUrl = ConfigService::make()->getConfigByCode('gd_api_url').'/ICcontrol.ashx';
        RedisService::set($errorKey.':request', ['url'=> $apiUrl,'data'=> $params], 3600);
        $result = httpHeaderRequest($apiUrl, $dataStr,'post',$headers,'text',3);
        RedisService::set($errorKey.':result', ['result'=>$result], 3600);
        if($result !== 0){
            return message('卡扣款失败', false);
        }

        \DB::beginTransaction();
        if(!CardModel::where(['user_id'=> $userId,'mark'=> 1])->decrement('quota',$order['total'])){
            \DB::rollBack();
            return message('卡扣款处理失败', false);
        }

        // 处理支付明细
        $data = [
            'user_id'=> $userId,
            'type'=> 1,
            'coin_type'=> 5,
            'pay_type'=> 4,
            'money'=> $order['total'],
            'change_type'=> 2,
            'balance'=> $cardInfo->quota,
            'create_time'=> time(),
            'remark'=> '供灯订单卡支付',
            'status'=> 1
        ];

        if(!TradeModel::insertGetId($data)){
            \DB::rollBack();
            return message('处理交易明细失败', false);
        }

        // 项目完成
        $giveGd = ConfigService::make()->getConfigByCode('gongdeng_give_gd');
        $giveGd = $giveGd? $giveGd : 0;
        if($giveGd>0){
            $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1])
                ->select('id', 'openid', 'nickname','merits_num')
                ->first();

            if(!MemberModel::where(['id'=> $userId])->increment('merits_num', $giveGd)){
                \DB::rollBack();
                return message('奖励功德失败', false);
            }

            $data = [
                'user_id'=> $userId,
                'type'=> 3,
                'coin_type'=> 4,
                'pay_type'=> 4,
                'money'=> $giveGd,
                'change_type'=> 1,
                'balance'=> $memberInfo->merits_num? $memberInfo->merits_num : 0,
                'create_time'=> time(),
                'remark'=> '供灯奖励',
                'status'=> 1
            ];
            if(!TradeModel::insertGetId($data)){
                \DB::rollBack();
                return message('功德奖励处理失败', false);
            }

            // 完成供灯项目
            PracticesService::make()->saveLog($userId, 4,'供灯祈福');
        }

        \DB::commit();

        // 记录
        $data = [
            'user_id'=> $userId,
            'remark'=> "供灯祈福，福报绵延。",
            'create_time'=> time(),
            'update_time'=> time(),
            'status'=> 1,
        ];
        RedisService::set("caches:dynamic:notice_{$userId}", $data, 300);
        DynamicNoticeModel::insertGetId($data);


        // 开灯处理，续费不处理
        if($buyType == 1){
            $order['id'] = $oid;
            DevicesService::make()->catchLamp($order[''], $order);
        }

        return message('供灯订单支付成功', false);
    }


    /**
     * 供灯下单
     */
    public function buy($userId)
    {
        $params = request()->all();
        // 验证佛像信息
        $fid = isset($params['fid']) ? $params['fid'] : 0;
        $foInfo = GongdengFoxiangModel::where(['id' => $fid, 'status' => 1, 'mark' => 1])
            ->select(['id', 'name'])
            ->first();
        if (!$foInfo || $fid <= 0) {
            return message('供灯佛像信息不存在', false);
        }

        $payType = isset($params['payType']) ? $params['payType'] : 0;
        if (!in_array($payType, [1])) {
            return message('支付方式暂不支持', false);
        }

        // 套餐信息
        $mid = isset($params['mid']) ? $params['mid'] : 0;
        $mealInfo = LampMealsModel::where(['id' => $mid, 'status' => 1, 'mark' => 1])
            ->select(['id', 'name', 'price', 'num'])
            ->first();
        if (!$mealInfo) {
            return message('供灯套餐不存在或已下架', false);
        }

        // 验证用户是否已授权
        $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1])
            ->select('id', 'openid', 'nickname')
            ->first();
        $openid = isset($memberInfo['openid']) ? trim($memberInfo['openid']) : '';
        if (!$memberInfo) {
            return message('账号已被冻结，请联系客服', false);
        }

        if (empty($openid)) {
            return message('账号获取授权参数失败，请退出重试', false);
        }

        // 验证是否供灯过
        $buyType = 1;
        $gdCheckData = GongdengOrderModel::where(['source_id' => $fid, 'user_id' => $userId,'lamp_status'=> 2, 'status' => 2, 'mark' => 1])
            ->where('expire_time', '>=', time())
            ->select(['id', 'source_id', 'user_id','device_num', 'expire_time', 'params'])
            ->first();

        // 续费
        if ($gdCheckData && $gdCheckData->id) {
            $buyType = 2;
        }

        // 创建订单
        $expireTime = ($mealInfo->num * 24 * 3600) + time();
        $data = [
            'source_id' => $fid,
            'user_id' => $userId,
            'pay_type' => $payType,
            'buy_type' => $buyType,
            'order_sn' => get_order_num('G'),
            'num' => 1,
            'price' => $mealInfo->price,
            'total' => $mealInfo->price,
            'sf_name' => isset($params['sf_name']) ? trim($params['sf_name']) : '',
            'qf_content' => isset($params['qf_content']) ? trim($params['qf_content']) : '',
            'is_hide' => isset($params['is_hide']) ? intval($params['is_hide']) : 0,
            'expire_time' => $expireTime,
            'create_time' => time(),
            'status' => 1,
        ];

        if($gdCheckData){
            $data['device_num'] = $gdCheckData->device_num;
            $data['params'] = $gdCheckData->params;
        }

        // 订单
        if (!$oid = GongdengOrderModel::insertGetId($data)) {
            return message('供灯订单创建失败', false);
        }


        // 支付参数
        switch ($payType) {
            case 1: // 微信支付
                $order = [
                    'openid' => $openid,
                    'orderNo' => $data['order_sn'],
                    'amount' => $data['total'],
                    'body' => '供灯订单支付',
                ];

                $jsapiParams = WechatService::jsapiUnifiedorder($order);
                $code = isset($jsapiParams['code']) ? $jsapiParams['code'] : '';
                if ($code == 'error' || empty($jsapiParams)) {
                    $message = isset($jsapiParams['message']) && $jsapiParams['message'] ? $jsapiParams['message'] : '订单支付处理失败';
                    return message($message, false);
                }
                return message('订单创建成功', true, ['id' => $oid, 'params' => $jsapiParams]);
                break;
            default:
                break;
        }

        return message('支付处理失败', false);
    }
}