// +---------------------------------------------------------------------- namespace App\Services; use App\Models\DynamicNoticeModel; use App\Models\EnshrineActionModel; use App\Models\EnshrineOrdersModel; use App\Models\EnshrineRecordModel; use App\Models\FoxiangModel; use App\Models\MemberModel; use App\Models\OfferingsModel; use App\Models\TradeModel; /** * 供奉管理-服务类 * @author wesmiler * @since 2020/11/11 * Class EnshrineService * @package App\Services */ class EnshrineService extends BaseService { protected static $instance = null; /** * 构造函数 * @author wesmiler * @since 2020/11/11 * EnshrineOrdersService constructor. */ public function __construct() { $this->model = new EnshrineRecordModel(); } /** * 静态入口 * @return EnshrineOrdersService|null */ public static function make() { if (!self::$instance) { self::$instance = new EnshrineOrdersService(); } return self::$instance; } /** * 供奉记录 * @return array */ public function getDataList($userId) { $params = request()->all(); $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE; $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE; $showType = isset($params['show_type']) ? intval($params['show_type']) : 1; $size = ConfigService::make()->getConfigByCode('qifu_limit'); $pageSize = $size ? $size : $pageSize; $dataList = $this->model::from('enshrine_records as a') ->leftJoin('foxiang as f', 'f.id', '=', 'a.fo_id') ->leftJoin('foxiang_cates as c', 'c.id', '=', 'f.cate_id') ->where(['a.user_id' => $userId]) ->where(function ($query) use ($params) { $query->where(['a.mark' => 1, 'a.status' => 1]); $type = isset($params['type']) ? $params['type'] : 0; if ($type) { $query->where('a.type', $type); } }) ->select(['a.*', 'f.name', 'f.thumb', 'f.image', 'f.file_url', 'c.name as cate_name']) ->orderBy('a.create_time', 'desc') ->paginate($pageSize); $dataList = $dataList ? $dataList->toArray() : []; if ($dataList) { foreach ($dataList['data'] as &$item) { $item['thumb'] = $item['thumb'] ? get_image_url($item['thumb']) : ''; $item['image'] = $item['image'] ? get_image_url($item['image']) : ''; $item['file_url'] = $item['file_url'] ? get_image_url($item['file_url']) : ''; $item['bg_music_url'] = get_image_url('/file/music/bg_' . $item['type'] . '.mp3'); $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : ''; $item['time'] = $item['create_time'] ? format_time(strtotime($item['create_time'])) : ''; $item['time_close'] = 0; if ($item['create_time'] <= date('Y-m-d H:i:s', time() - 24 * 3600)) { $item['time_close'] = 1; } if ($showType == 1) { $guibai = EnshrineActionModel::where(['source_id' => $item['id'], 'user_id' => $userId, 'type' => 1, 'mark' => 1, 'status' => 1]) ->where('create_time', '>=', time() - 3600) ->value('id'); $item['guibai'] = 0; $item['guibai_check'] = $guibai ? $guibai : 0; $wash = EnshrineActionModel::where(['source_id' => $item['id'], 'user_id' => $userId, 'type' => 2, 'mark' => 1, 'status' => 1]) ->where('create_time', '>=', time() - 3600) ->value('id'); $item['wash'] = 0; $item['guibai_check'] = $wash ? $wash : 0; // 花 $item['hua'] = ['id' => 0, 'icon' => '', 'icon_real' => '']; $hua = $this->getOrderGoodsInfo($item['id'], $userId, $item['type'], 2); if ($hua) { $item['hua'] = $hua; } // 水果 $item['guo'] = ['id' => 0, 'icon' => '', 'icon_real' => '']; $guo = $this->getOrderGoodsInfo($item['id'], $userId, $item['type'], 3); if ($guo) { $item['guo'] = $guo; } // 香烛 $item['xiang'] = ['id' => 0, 'icon' => '', 'icon_real' => '']; $xiang = $this->getOrderGoodsInfo($item['id'], $userId, $item['type'], 4); if ($xiang) { $item['xiang'] = $xiang; } } } unset($item); } return [ 'code' => 0, 'success' => true, 'msg' => '操作成功', 'count' => isset($dataList['total']) ? $dataList['total'] : 0, 'data' => isset($dataList['data']) ? $dataList['data'] : 0, ]; } /** * 获取已经购买供奉物品信息 * @param $sid * @param $userId * @param $type * @param $goodsType * @return array|mixed */ public function getOrderGoodsInfo($sid, $userId, $type, $goodsType) { $cacheKey = "caches:enshrine:orders_goods:u{$userId}_s{$sid}_{$type}_{$goodsType}"; $info = RedisService::get($cacheKey); if ($info) { return $info; } $expireTime = ConfigService::make()->getConfigByCode("enshrine_expire_time_{$type}"); $expireTime = $expireTime ? $expireTime : 0; $info = EnshrineOrdersModel::from('enshrine_orders as eo') ->leftJoin('offerings as g', 'g.id', '=', 'eo.goods_id') ->where(['eo.source_id' => $sid, 'eo.user_id' => $userId, 'eo.type' => $type, 'g.goods_type' => $goodsType]) ->where(function ($query) use ($expireTime) { if ($expireTime > 0) { $query->where('eo.create_time', '>=', time() - $expireTime * 3600); } }) ->select(['g.id', 'g.name', 'g.goods_type', 'g.code', 'g.icon', 'g.icon_real', 'eo.source_id', 'eo.status', 'eo.create_time']) ->orderBy('eo.create_time', 'desc') ->first(); $info = $info ? $info->toArray() : []; if ($info) { $info['icon'] = $info['icon'] ? get_image_url($info['icon']) : ''; $info['create_time_text'] = $info['create_time'] ? datetime($info['create_time'], 'Y-m-d H:i:s') : ''; $info['create_time'] = $info['create_time'] ? strtotime(datetime($info['create_time'], 'Y-m-d H:i:s')) : time(); $info['icon_real'] = $info['icon_real'] ? get_image_url($info['icon_real']) : ''; RedisService::set($cacheKey, $info, rand(3, 5)); } return $info; } /** * 物品 * @return array */ public function goods() { $params = request()->all(); $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE; $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE; $dataList = $this->model::from('offerings as a') ->where(function ($query) use ($params) { $query->where(['a.mark' => 1, 'a.status' => 1]); $type = isset($params['type']) ? $params['type'] : 0; if ($type) { $query->where('a.type', $type); } $goodsType = isset($params['goods_type']) ? $params['goods_type'] : 0; if ($goodsType) { $query->where('a.goods_type', $goodsType); } }) ->select(['a.*']) ->orderBy('a.sort', 'asc') ->orderBy('a.create_time', 'desc') ->paginate($pageSize); $dataList = $dataList ? $dataList->toArray() : []; if ($dataList) { foreach ($dataList['data'] as &$item) { $item['icon'] = $item['icon'] ? get_image_url($item['icon']) : ''; $item['icon_real'] = $item['icon_real'] ? get_image_url($item['icon_real']) : ''; $item['create_time'] = $item['create_time'] ? datetime($item['create_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, ]; } /** * 请佛 * @param $userId * @return array */ public function select($userId) { $id = request()->get('id', 0); if ($id <= 0) { return message('参数错误', false); } $foInfo = FoxiangModel::where(['id' => $id, 'mark' => 1, 'status' => 1]) ->select(['id', 'name']) ->first(); if (!$foInfo) { return message('佛像不存在,请选择其他佛像', false); } $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'nickname']) ->first(); if (!$memberInfo) { return message('您的账号不可操作或已冻结,请联系客服', false); } // 验证是否正在供奉该佛像 $type = request()->get('type', 1); $params = request()->all(); switch ($type) { case 1: // 祈福 $limitNum = ConfigService::make()->getConfigByCode('qifu_limit'); if ($limitNum) { $num = $this->model::where(['user_id' => $userId, 'type' => 1, 'mark' => 1, 'status' => 1]) ->count('id'); if ($num >= $limitNum) { return message("最多只能同时供奉{$limitNum}尊佛像,请送圣后再操作", false); } } $record = $this->model::where(['fo_id' => $id, 'user_id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'fo_id', 'user_id']) ->first(); if ($record) { return message('抱歉该佛像您正在供奉中,请24小时后再继续供奉或选择其他佛像', false); } break; case 2: // 超度 break; case 3: // 放生 break; } $data = [ 'fo_id' => $id, 'type' => $type, 'user_id' => $userId, 'used_name' => isset($params['used_name']) ? trim($params['used_name']) : '', 'user_name' => isset($params['user_name']) ? trim($params['user_name']) : '', 'relation' => isset($params['relation']) ? trim($params['relation']) : '', 'description' => isset($params['description']) ? trim($params['description']) : '', 'image' => isset($params['image']) ? trim($params['image']) : '', 'create_time' => time(), 'update_time' => time(), 'mark' => 1, 'status' => 1, ]; if ($this->model::insertGetId($data)) { PracticesService::make()->saveLog($userId,1, "祈福供奉{$foInfo->name}佛像"); return message('请佛成功', true); } else { return message('请佛失败', true); } } /** * 送圣 * @param $userId * @return array */ public function packoff($userId) { $id = request()->get('id', 0); $type = request()->get('type', 0); if (!$id || !$type) { return message('参数错误', false); } $enshrine = $this->model::where(['fo_id' => $id, 'user_id' => $userId, 'type' => $type, 'mark' => 1, 'status' => 1]) ->select(['id', 'fo_id', 'user_id', 'status']) ->first(); if (!$enshrine) { return message('佛像信息不存在', false); } $enshrine->status = 2; if ($enshrine->save()) { return message('送圣成功', true); } else { return message('送圣失败', false); } } /** * 新增牌位 * @param $userId * @return array */ public function chaodu($userId) { $params = request()->all(); $id = isset($params['id']) ? $params['id'] : 0; if (!$id) { return message('请选择佛像', false); } $foInfo = FoxiangModel::where(['id' => $id, 'mark' => 1, 'status' => 1]) ->select(['id', 'name']) ->first(); if (!$foInfo) { return message('佛像不存在,请选择其他佛像', false); } $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'nickname']) ->first(); if (!$memberInfo) { return message('您的账号不可操作或已冻结,请联系客服', false); } // 验证是否正在供奉该佛像 $limitNum = ConfigService::make()->getConfigByCode('chaodu_limit'); if ($limitNum) { $num = $this->model::where(['user_id' => $userId, 'type' => 2, 'mark' => 1, 'status' => 1]) ->count('id'); if ($num >= $limitNum) { return message("最多只能同时超度{$limitNum}个牌位,请到期后再操作", false); } } $data = [ 'fo_id' => $id, 'type' => 2, 'user_id' => $userId, 'used_name' => isset($params['used_name']) ? trim($params['used_name']) : '', 'user_name' => isset($params['user_name']) ? trim($params['user_name']) : '', 'relation' => isset($params['relation']) ? trim($params['relation']) : '', 'description' => isset($params['description']) ? trim($params['description']) : '', 'image' => isset($params['image']) ? trim($params['image']) : '', 'create_time' => time(), 'update_time' => time(), 'mark' => 1, 'status' => 1, ]; if ($this->model::insertGetId($data)) { PracticesService::make()->saveLog($userId,2, "超度供奉{$foInfo->name}佛像牌位"); return message('超度成功', true); } else { return message('超度失败', true); } } /** * 供奉操作记录 * @param $userId * @return array */ public function actionRecord($userId) { $params = request()->all(); $id = isset($params['id']) ? $params['id'] : 0; $type = isset($params['type']) ? $params['type'] : 0; if ($id <= 0 || $type <= 0) { return message('参数错误', false); } $enshrine = $this->model::where(['id' => $id, 'user_id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'fo_id', 'user_id']) ->first(); if (!$enshrine) { return message('供奉记录信息不存在,无法操作', false); } $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'nickname', 'merits_num']) ->first(); if (!$memberInfo) { return message('您的账号不可操作或已冻结,请联系客服', false); } \DB::beginTransaction(); $data = [ 'source_id' => $id, 'user_id' => $userId, 'type' => $type, 'description' => isset($params['description']) ? $params['description'] : '', 'create_time' => time(), 'update_time' => time(), 'status' => 1 ]; if (!EnshrineActionModel::insertGetId($data)) { \DB::rollBack(); return message('操作失败', false); } $giveGd = 0; $fields = ['1' => 'qifu_guibai_give_gd', '2' => 'qifu_wash_give_gd', '3' => 'qifu_xuyuan_give_gd']; $field = isset($fields[$type]) ? $fields[$type] : ''; if ($field) { $giveGd = ConfigService::make()->getConfigByCode($field); } // 功德值 if ($giveGd > 0) { if (!MemberModel::where(['id' => $userId, 'mark' => 1])->increment('merits_num', $giveGd)) { \DB::rollBack(); return message("更新功德账户失败", false); } $data = [ 'user_id' => $userId, 'source_uid' => 0, 'type' => 3, 'coin_type' => 4, 'pay_type' => 4, 'money' => $giveGd, 'change_type' => 1, 'balance' => $memberInfo->merits_num, 'create_time' => time(), 'remark' => $type == 1 ? "跪拜祈福" : '洗手祈福', 'status' => 1, ]; if (!TradeModel::insertGetId($data)) { \DB::rollBack(); return message("处理功德奖励失败", false); } \DB::commit(); return message("获得功德值{$giveGd}", true); } \DB::commit(); return message("操作成功", true); } /** * 购买物品 * @param $userId * @return array */ public function buy($userId) { $params = request()->all(); $id = isset($params['id']) ? $params['id'] : 0; $enshrineId = isset($params['enshrine_id']) ? $params['enshrine_id'] : 0; $type = isset($params['type']) ? $params['type'] : 0; $num = isset($params['num']) ? $params['num'] : 0; if ($id <= 0 || $type <= 0 || ($enshrineId <= 0 && $type!=3) || $num <= 0) { return message('参数错误', false); } if($type != 3){ $enshrine = $this->model::where(['id' => $enshrineId, 'user_id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'fo_id', 'user_id']) ->first(); if (!$enshrine) { return message('供奉记录信息不存在,无法操作', false); } } $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'nickname', 'merits_num', 'coupon']) ->first(); if (!$memberInfo) { return message('您的账号不可操作或已冻结,请联系客服', false); } // 物品 $goodsInfo = OfferingsModel::where(['id' => $id, 'mark' => 1, 'status' => 1]) ->select(['id', 'type', 'goods_type', 'name', 'price']) ->first(); if (!$goodsInfo) { return message('物品不存在或已下架,请刷新重试', false); } // 是否未到期 $expireTime = ConfigService::make()->getConfigByCode("enshrine_expire_time_{$type}"); $expireTime = $expireTime ? $expireTime : 0; $info = $this->getOrderGoodsInfo($enshrineId, $userId, $type, $goodsInfo->goods_type); if ($info) { $createTime = isset($info['create_time']) ? intval($info['create_time']) : time(); $enshrineTime = time() - $createTime; $hour = intval($enshrineTime / 3600); $minute = ceil(($enshrineTime % 3600) / 60); $enshrineTime1 = ($createTime + $expireTime * 3600 - time()); $enshrineTime1 = $enshrineTime1>0? $enshrineTime1 : 0; $hour1 = intval($enshrineTime1 / 3600); $minute1 = intval(($enshrineTime1 % 3600) / 60); $time = date('H点i分', $createTime + $expireTime * 3600); $msg = "您已经恭请{$goodsInfo->name}供佛{$hour}小时{$minute}分,还有{$hour1}小时{$minute1}分($time)到期,每天更换贡品代表恭敬佛菩萨,阿弥陀佛"; return message($msg, false, ['show' => true, 'time' => $enshrineTime, 'hour' => $hour, 'minute' => $minute]); } $total = intval($goodsInfo->price * $num); \DB::beginTransaction(); $data = [ 'source_id' => $enshrineId, 'goods_id' => $id, 'user_id' => $userId, 'type' => $type, 'order_sn' => get_order_num('F'), 'num' => $num, 'price' => $goodsInfo->price, 'total' => $total, 'gd_name' => isset($params['gd_name']) ? $params['gd_name'] : '', 'pay_at' => date('Y-m-d H:i:s'), 'remark' => isset($params['remark']) ? $params['remark'] : '', 'create_time' => time(), 'update_time' => time(), 'status' => 2 ]; if (!EnshrineOrdersModel::insertGetId($data)) { \DB::rollBack(); return message('供奉物品失败', false); } // 扣款奖励处理 if ($total > 0) { if ($memberInfo->coupon < $total) { \DB::rollBack(); return message("账户花灯券不足,请先充值", false, [], 10003); } if (!MemberModel::where(['id' => $userId, 'mark' => 1])->decrement('coupon', $total)) { \DB::rollBack(); return message("更新花灯券账户失败", false); } $data = [ 'user_id' => $userId, 'source_uid' => 0, 'type' => 1, 'coin_type' => 1, 'pay_type' => 1, 'money' => $total, 'change_type' => 2, 'balance' => $memberInfo->coupon, 'create_time' => time(), 'remark' => $type == 1 ? "祈福供奉{$goodsInfo->name}" : ($type == 3 ? "放生{$goodsInfo->name}" : "超度供奉{$goodsInfo->name}"), 'status' => 1, ]; if (!TradeModel::insertGetId($data)) { \DB::rollBack(); return message("处理账户明细失败", false); } } // 奖励 $giveGd = ConfigService::make()->getConfigByCode('enshrine_give_gd'); $giveGd = $giveGd ? $giveGd : 0; $totalGd = $giveGd * $num; if ($totalGd > 0) { if (!MemberModel::where(['id' => $userId, 'mark' => 1])->increment('merits_num', $totalGd)) { \DB::rollBack(); return message("更新功德账户失败", false); } $data = [ 'user_id' => $userId, 'source_uid' => 0, 'type' => 3, 'coin_type' => 4, 'pay_type' => 4, 'money' => $totalGd, 'change_type' => 1, 'balance' => $memberInfo->merits_num, 'create_time' => time(), 'remark' => $type == 1 ? "祈福供奉{$goodsInfo->name}" : ($type == 3 ? "放生{$goodsInfo->name}" : "超度供奉{{$goodsInfo->name}}"), 'status' => 1, ]; if (!TradeModel::insertGetId($data)) { \DB::rollBack(); return message("处理功德奖励失败", false); } } // 动态 $data = [ 'type' => $type + 1, 'user_id' => $userId, 'remark' => $type == 1 ? "供奉{$goodsInfo->name}" : ($type == 3 ? "放生{$goodsInfo->name}" : '超度普渡众生'), 'update_time' => time(), 'create_time' => time(), 'status' => 1 ]; DynamicNoticeModel::insertGetId($data); \DB::commit(); // 完成修行项目 PracticesService::make()->saveLog($userId,$type, $type == 1 ? "供奉{$goodsInfo->name}" : ($type == 3 ? "放生{$goodsInfo->name}" : '超度普渡众生'), ); if ($totalGd > 0) { return message("获得功德值{$totalGd}", true, ['num' => $totalGd]); } else { return message("操作成功", true); } } /** * 心愿记录 * @param $userId * @return array */ public function actionList($userId) { $params = request()->all(); $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE; $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE; $dataList = $this->model::from('enshrine_actions as a') ->where(['a.type' => 3, 'a.mark' => 1, 'a.user_id' => $userId]) ->whereIn('a.status', [1, 2]) ->select(['a.*']) ->orderBy('a.create_time', 'desc') ->paginate($pageSize); $dataList = $dataList ? $dataList->toArray() : []; if ($dataList) { foreach ($dataList['data'] as &$item) { $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : ''; $item['description'] = $item['description'] ? str_replace("\n", '
', $item['description']) : ''; } unset($item); } return [ 'code' => 0, 'success' => true, 'msg' => '操作成功', 'count' => isset($dataList['total']) ? $dataList['total'] : 0, 'data' => isset($dataList['data']) ? $dataList['data'] : 0, ]; } /** * 购买记录 * @param $userId * @return array */ public function orderList($uid) { $params = request()->all(); $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE; $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE; $type = isset($params['type']) ? intval($params['type']) : 0; $where = ['a.mark' => 1,'a.status'=> 2]; if($type){ $where['a.type'] = $type; } $dataList = $this->model::from('enshrine_orders as a') ->leftJoin('member as m', 'm.id', '=', 'a.user_id') ->leftJoin('offerings as g', 'g.id', '=', 'a.goods_id') ->where($where) ->select(['a.*','m.avatar','m.nickname','g.name as goods_name','g.spec','g.icon']) ->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['icon'] = $item['icon']? get_image_url($item['icon']) : ''; $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : ''; $item['time'] = $item['create_time'] ? format_time(strtotime($item['create_time'])) : ''; $item['remark'] = $item['remark'] ? str_replace("\n", '
', $item['remark']) : ''; $item['total'] = moneyFormat($item['total'], 0); } unset($item); } return [ 'code' => 0, 'success' => true, 'msg' => '操作成功', 'count' => isset($dataList['total']) ? $dataList['total'] : 0, 'data' => isset($dataList['data']) ? $dataList['data'] : 0, ]; } /** * 许愿记录处理 * @param $userId * @return array */ public function catchXuyuan($userId) { $params = request()->all(); $id = isset($params['id']) ? $params['id'] : 0; $type = isset($params['type']) ? $params['type'] : 1; if ($id <= 0 || $id <= 0) { return message('参数错误', false); } $info = EnshrineActionModel::where(['id' => $id, 'user_id' => $userId, 'type' => 3, 'mark' => 1, 'status' => 1]) ->select(['id', 'user_id', 'status']) ->first(); if (!$info) { return message('许愿信息不存在或已处理', false); } $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1]) ->select(['id', 'nickname', 'merits_num', 'coupon']) ->first(); if (!$memberInfo) { return message('您的账号不可操作或已冻结,请联系客服', false); } if ($type == 2) { if (EnshrineActionModel::where(['id' => $id, 'user_id' => $userId, 'type' => 3, 'mark' => 1, 'status' => 1])->delete()) { return message('删除成功', true); } else { return message('删除失败', false); } } else { $info->status = 2; if ($info->save()) { return message('操作成功', true); } else { return message('操作失败', false); } } } }