<?php
namespace app\admin\service\member;
use app\common\Tree;
use app\model\Card;
use app\model\ClientPoints;
use app\model\CouponDetail;
use app\model\Device;
use app\model\Family;
use app\model\FamilyMember;
use app\model\Goods;
use app\model\Member;
use app\model\MemberAccount;
use app\model\MemberAccountList;
use app\model\MemberCert;
use app\model\MemberDevice;
use app\model\MemberInfo;
use app\model\MemberRole;
use app\model\Order;
use app\model\OrderSheet;
use app\model\PayDetail;
use app\model\SysCategory;
use app\model\SysDept;
use app\model\SysSerial;
use app\model\SysUser;
use support\Db;
use support\exception\BusinessException;
use support\Log;
use support\Request;
use support\Response;
class MemberService
{
public static function list(Request $request)
{
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 10);
$name = $request->get('name', '');
$nickname = $request->get('nickname', '');
$mobile = $request->get('mobile', '');
$level = $request->get('level', '');
$isAuth = $request->get('is_auth', '');
$addtime = $request->get('member_addtimes', []);
$type = $request->get('type', '');
$status = $request->get('member_status', '');
$memberIsPartner = $request->get('member_is_partner', '');
$memberIsReferrer = $request->get('member_is_referrer', '');
// 兼容老等级搜索
$levelIds = [];
if (!empty($level)) {
$levelName = MemberRole::where('member_role_id', $level)->value('member_role_name');
if (!empty($levelName)) {
$levelIds = MemberRole::where('member_role_name', $levelName)->pluck('member_role_id')->toArray();
}
}
$rows = Member::with([
'account'
])->where('member_is_owner', 'N')
->where('member_mobile', '<>', '0000')
->leftJoin('member_info', 'member_info.join_info_member_id', 'member.member_id')
->leftJoin('member_cert', 'member_cert.join_cert_member_id', 'member.member_id')
->leftJoin('member_role', 'member_role.member_role_id', 'member.join_member_role_id')
->when($name != '', function ($query) use ($name) {
$query->where('member_cert.member_cert_name', 'like', '%' . $name . '%');
})->when($mobile != '', function ($query) use ($mobile) {
$query->where('member.member_mobile', 'like', '%' . $mobile . '%');
})->when($level != '', function ($query) use ($level, $levelIds) {
if ($level == 'other') {
$query->where('member.join_member_role_id', NULL)->orWhere('member.join_member_role_id', '');
} else if ($level == 'VIP') {
$query->where('member.member_is_vip', 'Y');
} else if (!empty($levelIds)) {
$query->whereIn('member_role.member_role_id', $levelIds);
} else {
$query->where('member_role.member_role_id', $level);
}
})->when($isAuth != '', function ($query) use ($isAuth) {
if ($isAuth == 'Y') {
$query->where('member_cert.member_cert_name', '<>', NULL)->where('member_cert.member_cert_nbr', '<>', NULL)->where('member_cert.member_cert_name', '<>', '')->where('member_cert.member_cert_nbr', '<>', '');
} else {
$query->where('member_cert.member_cert_name', NULL)->orWhere('member_cert.member_cert_nbr', NULL)->orWhere('member_cert.member_cert_name', '')->orWhere('member_cert.member_cert_nbr', '');
}
})->when(!empty($addtime), function ($query) use ($addtime) {
$addtime[0] = strtotime($addtime[0]);
$addtime[1] = strtotime($addtime[1]);
$query->whereBetween('member.member_addtimes', $addtime);
})->when(!empty($type), function ($query) use ($type) {
if ($type == 'todayAdd') {
$addtime[0] = strtotime(date('Y-m-d') . ' 00:00:00');
$addtime[1] = strtotime(date('Y-m-d') . ' 23:59:59');
} else if ($type == 'monthAdd') {
$addtime[0] = strtotime(date('Y-m-01') . ' 00:00:00');
$addtime[1] = strtotime(date('Y-m-t') . ' 23:59:59');
}
$query->whereBetween('member.member_addtimes', $addtime);
})->when(!empty($nickname), function ($query) use ($nickname) {
$query->where(function ($query2) use ($nickname) {
$query2->where('member_info.member_info_nickname', 'like', '%' . $nickname . '%')->orWhere('member.member_mobile', 'like', '%' . $nickname . '%');
});
})->when(!empty($status), function ($query) use ($status) {
$query->where('member_status', $status);
})->when(!empty($memberIsPartner), function ($query) use ($memberIsPartner) {
if ($memberIsPartner == 'Y') {
$query->where('member_is_partner', 'Y');
}
})->when(!empty($memberIsReferrer), function ($query) use ($memberIsReferrer) {
if ($memberIsReferrer == 'Y') {
$query->where('member_is_referrer', 'Y');
}
})
->select('member_id', 'member_is_vip', 'member_is_owner', 'join_invite_member_id', 'member_is_partner', 'member_partner_json', 'member_is_referrer', 'member_referrer_json', 'member_is_franchisee', 'member_franchisee_json', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes', 'member_extend_json',
'member_info.member_info_nickname', 'member_info.member_info_headimg', 'member_info.member_info_referee', 'member_info.member_info_business', 'member_info.member_info_service', 'member_info.member_info_city', 'member_info.member_info_address', 'member_info.member_info_gender', 'member_info.member_info_birthday',
'member_role.member_role_id', 'member_role.member_role_name',
'member_cert.member_cert_birth', 'member_cert.member_cert_gender', 'member_cert.member_cert_name', 'member_cert.member_cert_nbr', 'member_cert.member_cert_province', 'member_cert.member_cert_addr', 'member_cert.member_cert_face', 'member_cert.member_cert_photo', 'member_cert.member_cert_nation'
// 'member_account.member_account_surplus'
);
// 总条数
$total = $rows->count('member_id');
// 已认证条数
$authModel = clone $rows;
$authTotal = $authModel->where('member_cert.member_cert_name', '<>', '')
->where('member_cert.member_cert_nbr', '<>', '')
->count();
$rows = $rows->orderBy('member_addtimes', 'DESC')
->forPage($page, $pageSize)
->get()
->toArray();
foreach ($rows as &$row) {
$row['coupon_count'] = CouponDetail::where('join_coupon_detail_member_id', $row['member_id'])->count();
$row['member_mobile'] = substr($row['member_mobile'], 0, 3) . '****' . substr($row['member_mobile'], 7);
// 推荐人
if (!empty($row['join_invite_member_id'])) {
$row['referrer_name'] = MemberService::getMemberNameByMemberId($row['join_invite_member_id']);
}
$row['info'] = [
'member_info_nickname' => !empty($row['member_info_nickname']) ? $row['member_info_nickname'] : substr($row['member_mobile'], -4, 4) . '会员',
'member_info_headimg' => !empty($row['member_info_headimg']) ? $row['member_info_headimg'] : '',
'member_info_referee' => !empty($row['member_info_referee']) ? $row['member_info_referee'] : '',
'member_info_business' => !empty($row['member_info_business']) ? $row['member_info_business'] : '',
'member_info_service' => !empty($row['member_info_service']) ? $row['member_info_service'] : '',
'member_info_city' => !empty($row['member_info_city']) ? explode('-', $row['member_info_city']) : '',
'member_info_address' => !empty($row['member_info_address']) ? $row['member_info_address'] : '',
'member_info_birthday' => !empty($row['member_info_birthday']) ? $row['member_info_birthday'] : '',
'member_info_gender' => !empty($row['member_info_gender']) ? $row['member_info_gender'] : '',
];
if (substr($row['info']['member_info_headimg'], 0, 2) == '..') {
$row['info']['member_info_headimg'] = '';
}
if (!empty($row['info']['member_info_address']) && in_array($row['info']['member_info_address'], ['请选择', '省-市-区'])) {
$row['info']['member_info_address'] = '';
}
$row['cert'] = [
'member_cert_birth' => $row['member_cert_birth'],
'member_cert_gender' => $row['member_cert_gender'],
'member_cert_name' => $row['member_cert_name'],
'member_cert_nbr' => $row['member_cert_nbr'],
'member_cert_province' => !empty($row['member_cert_province']) && is_json($row['member_cert_province']) ? json_decode($row['member_cert_province']) : '',
'member_cert_addr' => $row['member_cert_addr'],
'member_cert_face' => !empty($row['member_cert_face']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_face'] : '',
'member_cert_photo' => !empty($row['member_cert_photo']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_photo'] : '',
'member_cert_nation' => $row['member_cert_nation'],
];
$account = [];
if (!empty($row['account'])) {
foreach ($row['account'] as $item) {
if ($item['member_account_classify'] == 'WELFARE') {
$account['welfare'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'POINTS') {
$account['points'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'CASH') {
$account['cash'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'CARD') {
if (isset($account['card'])) {
$account['card']['member_account_income'] += $item['member_account_income'];
$account['card']['member_account_expend'] += $item['member_account_expend'];
$account['card']['member_account_surplus'] += $item['member_account_surplus'];
$account['card']['member_account_added'] += $item['member_account_added'];
} else {
$account['card'] = [
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
}
} else if ($item['member_account_classify'] == 'VIP') {
$account['vip'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
}
}
}
$row['account'] = $account;
$row['is_auth'] = "未认证";
if (!empty($row['member_cert_nbr']) && !empty($row['member_cert_name'])) {
$row['is_auth'] = "已认证";
}
$row['source'] = "APP";
$row['belong'] = [];
$row['referee'] = [];
if (!empty($row['member_extend_json'])) {
$extendJson = json_decode($row['member_extend_json'], true);
if (isset($extendJson['come_from'])) {
$row['source'] = $extendJson['come_from'] ?? '';
}
if (isset($extendJson['belong'])) {
$user = SysUser::where('user_id', $extendJson['belong']['user_id'])->select('user_name', 'user_mobile')->first();
if ($user) {
$row['belong']['user_id'] = $extendJson['belong']['user_id'];
$row['belong']['username'] = $user->user_name;
$row['belong']['user_mobile'] = $user->user_mobile;
}
$row['belong']['deptName'] = SysDept::where('dept_id', $extendJson['belong']['premises'])->value('dept_name');
}
if (isset($extendJson['referee'])) {
foreach ($extendJson['referee'] as $key => $referee) {
if (preg_match('/^1[3-9]\d{9}$/', $referee)) {
$member = Member::with([
'cert' => function ($query) {
$query->select('join_cert_member_id', 'member_cert_name');
}
])->where('member_mobile', $referee)->where('member_status', 'ACTIVED')
->first();
if ($member->cert && $member->cert->member_cert_name) {
$referee = $member->cert->member_cert_name . '-' . $referee;
}
}
$row['referee'][] = [
'name' => $referee,
'time' => $key
];
}
}
}
// 粉丝
$fans1 = Member::where('join_invite_member_id', $row['member_id'])
->select('member_id')
->get()
->toArray();
$fans1Ids = array_column($fans1, 'member_id');
$fans2Count = Member::whereIn('join_invite_member_id', $fans1Ids)
->count();
$row['fans_total'] = count($fans1) + $fans2Count;
// 合伙人信息
if ($row['member_is_partner'] == 'Y' && !empty($row['member_partner_json'])) {
$partnerJson = json_decode($row['member_partner_json'], true);
$row['partner_add_times'] = $partnerJson['datetime'] ?? '';
unset($row['member_partner_json']);
}
// 推荐信息
if ($row['member_is_referrer'] == 'Y' && !empty($row['member_referrer_json'])) {
$referrerJson = json_decode($row['member_referrer_json'], true);
$row['referrer_add_times'] = $referrerJson['datetime'] ?? '';
unset($row['member_referrer_json']);
}
}
return json_success('', compact('rows', 'page', 'pageSize', 'total', 'authTotal'));
}
public static function exportMember(Request $request)
{
$memberIds = $request->get('member_id', '');
$name = $request->get('name', '');
$mobile = $request->get('mobile', '');
$level = $request->get('level', '');
$isAuth = $request->get('is_auth', '');
$addtime = $request->get('member_addtimes', []);
$isPartner = $request->get('member_is_partner', '');
$isReferrer = $request->get('member_is_referrer', '');
$rows = Member::with('account')
->where('member_is_owner', 'N')
->where('member_mobile', '<>', '0000')
->leftJoin('member_info', 'member_info.join_info_member_id', 'member.member_id')
->leftJoin('member_cert', 'member_cert.join_cert_member_id', 'member.member_id')
// ->leftjoin('member_account', 'member.member_id', '=', 'member_account.join_account_member_id')
->leftJoin('member_role', 'member_role.member_role_id', 'member.join_member_role_id')
// ->where('member_account.member_account_classify', 'CASH')
->when($memberIds != '', function ($query) use ($memberIds) {
$query->whereIn('member.member_id', $memberIds);
})->when($name != '', function ($query) use ($name) {
$query->where('member_cert.member_cert_name', 'like', '%' . $name . '%');
})->when($mobile != '', function ($query) use ($mobile) {
$query->where('member.member_mobile', 'like', '%' . $mobile . '%');
})->when($isPartner != '', function ($query) use ($isPartner) {
$query->where('member.member_is_partner', $isPartner);
})->when($isReferrer != '', function ($query) use ($isReferrer) {
$query->where('member.member_is_referrer', $isReferrer);
})->when($level != '', function ($query) use ($level) {
if ($level == 'other') {
$query->where('member.join_member_role_id', NULL)->orWhere('member.join_member_role_id', '');
} else {
$query->where('member_role.member_role_id', $level);
}
})->when($isAuth != '', function ($query) use ($isAuth) {
if ($isAuth == 'Y') {
$query->where('member_cert.member_cert_name', '<>', NULL)->where('member_cert.member_cert_nbr', '<>', NULL)->where('member_cert.member_cert_name', '<>', '')->where('member_cert.member_cert_nbr', '<>', '');
} else {
$query->where('member_cert.member_cert_name', NULL)->where('member_cert.member_cert_nbr', NULL)->where('member_cert.member_cert_name', '')->where('member_cert.member_cert_nbr', '');
}
})->when(!empty($addtime), function ($query) use ($addtime) {
$addtime[0] = strtotime($addtime[0]);
$addtime[1] = strtotime($addtime[1]);
$query->whereBetween('member.member_addtimes', $addtime);
})->select('member_id', 'join_invite_member_id', 'member_is_owner', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes', 'member_extend_json',
'member_info.member_info_nickname', 'member_info.member_info_headimg', 'member_info.member_info_referee', 'member_info.member_info_business', 'member_info.member_info_service',
'member_role.member_role_id', 'member_role.member_role_name',
'member_cert.member_cert_birth', 'member_cert.member_cert_gender', 'member_cert.member_cert_name', 'member_cert.member_cert_nbr', 'member_cert.member_cert_province', 'member_cert.member_cert_addr', 'member_cert.member_cert_face', 'member_cert.member_cert_photo', 'member_cert.member_cert_nation',
// 'member_account.member_account_surplus'
)->orderBy('member_addtimes', 'DESC')
->get()
->toArray();
$exportData = [];
foreach ($rows as $row) {// 推荐人
if (!empty($row['join_invite_member_id'])) {
$row['referrer_name'] = MemberService::getMemberNameByMemberId($row['join_invite_member_id']);
}
$row['info'] = [
'member_info_nickname' => !empty($row['member_info_nickname']) ? $row['member_info_nickname'] : substr($row['member_mobile'], -4, 4) . '会员',
'member_info_headimg' => !empty($row['member_info_headimg']) ? $row['member_info_headimg'] : '',
'member_info_referee' => !empty($row['member_info_referee']) ? $row['member_info_referee'] : '',
'member_info_business' => !empty($row['member_info_business']) ? $row['member_info_business'] : '',
'member_info_service' => !empty($row['member_info_service']) ? $row['member_info_service'] : ''
];
$row['cert'] = [
'member_cert_name' => $row['member_cert_name'],
];
$account = [];
if (!empty($row['account'])) {
foreach ($row['account'] as $item) {
if ($item['member_account_classify'] == 'POINTS') {
$account['points'] = [
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'CASH') {
$account['cash'] = [
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'CARD') {
$account['card'] = [
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
}
}
}
// $row['account'] = $account;
$row['is_auth'] = "未认证";
if (!empty($row['member_cert_nbr']) && !empty($row['member_cert_name'])) {
$row['is_auth'] = "已认证";
}
$row['source'] = "APP";
if (!empty($row['member_extend_json'])) {
$extendJson = json_decode($row['member_extend_json'], true);
if (isset($extendJson['come_from'])) {
$row['source'] = $extendJson['come_from'] ?? '';
}
}
$sourceStr = ['APP' => "APP", 'CUSTOMER' => "客户管理", 'SYSTEM' => "后台"];
$exportData[] = [
'member_id' => $row['member_id'],
'member_info_nickname' => $row['info']['member_info_nickname'] ?? '',
'member_mobile' => $row['member_mobile'] ?? '',
'member_cert_name' => $row['cert']['member_cert_name'] ?? '',
'source' => in_array($row['source'], $sourceStr) ? $sourceStr[$row['source']] : 'APP',
'cash' => isset($account['cash']) ? $account['cash']['member_account_surplus'] + $account['cash']['member_account_added'] : 0,
'points' => isset($account['points']) ? $account['points']['member_account_surplus'] + $account['points']['member_account_added'] : 0,
'is_auth' => $row['is_auth'],
'level' => $row['member_role_name'] ?? '普通会员',
'member_addtimes' => $row['member_addtimes'],
'referrer_name' => $row['referrer_name'] ?? '',
'member_info_business' => $row['info']['member_info_business'] ?? '',
'member_info_service' => $row['info']['member_info_service'] ?? '',
];
}
return json_success('', $exportData);
}
public static function info($memberId)
{
$member = Member::with([
'cert',
'info',
'role' => function ($query) {
$query->select('member_role_id', 'member_role_name');
},
'account'
])
->where('member_id', $memberId)
->first();
if (!$member) {
return json_fail('查询错误');
}
$member = $member->toArray();
unset($member['member_password']);
$member['info'] = [
'member_info_nickname' => !empty($member['info']) && !empty($member['info']['member_info_nickname']) ? $member['info']['member_info_nickname'] : substr($member['member_mobile'], -4, 4) . '会员',
'member_info_headimg' => !empty($member['info']) && !empty($member['info']['member_info_headimg']) ? $member['info']['member_info_headimg'] : '',
'member_info_referee' => !empty($member['info']) && !empty($member['info']['member_info_referee']) ? $member['info']['member_info_referee'] : '',
'member_info_business' => !empty($member['info']) && !empty($member['info']['member_info_business']) ? $member['info']['member_info_business'] : '',
'member_info_service' => !empty($member['info']) && !empty($member['info']['member_info_service']) ? $member['info']['member_info_service'] : '',
'member_info_city' => !empty($member['info']) && !empty($member['info']['member_info_city']) ? explode('-', $member['info']['member_info_city']) : '',
'member_info_address' => !empty($member['info']) && !empty($member['info']['member_info_address']) ? $member['info']['member_info_address'] : '',
'member_info_gender' => !empty($member['info']) && !empty($member['info']['member_info_gender']) ? $member['info']['member_info_gender'] : '',
'member_info_birthday' => !empty($member['info']) && !empty($member['info']['member_info_birthday']) ? $member['info']['member_info_birthday'] : '',
];
if (!empty($member['info']['member_info_address']) && in_array($member['info']['member_info_address'], ['请选择', '省-市-区'])) {
$member['info']['member_info_address'] = '';
}
$member['cert'] = [
'member_cert_birth' => $member['cert']['member_cert_birth'] ?? '',
'member_cert_gender' => $member['cert']['member_cert_gender'] ?? '',
'member_cert_name' => $member['cert']['member_cert_name'] ?? '',
'member_cert_nbr' => $member['cert']['member_cert_nbr'] ?? '',
'member_cert_province' => !empty($member['cert']) && !empty($member['cert']['member_cert_province']) && is_json($member['cert']['member_cert_province']) ? json_decode($member['cert']['member_cert_province']) : '',
'member_cert_addr' => $member['cert']['member_cert_addr'] ?? '',
'member_cert_face' => !empty($member['cert']) && !empty($member['cert']['member_cert_face']) ? getenv('STORAGE_DOMAIN') . $member['cert']['member_cert_face'] : '',
'member_cert_photo' => !empty($member['cert']) && !empty($member['cert']['member_cert_photo']) ? getenv('STORAGE_DOMAIN') . $member['cert']['member_cert_photo'] : '',
'member_cert_nation' => $member['cert']['member_cert_nation'] ?? '',
'member_cert_addtimes' => $member['cert']['member_cert_addtimes'] ?? '',
];
if (!empty($member['cert']['member_cert_addtimes'])) {
$member['cert']['member_cert_addtimes'] = date('Y-m-d', $member['cert']['member_cert_addtimes']);
} else {
$member['cert']['member_cert_addtimes'] = date('Y-m-d', strtotime($member['member_addtimes']));
}
if (!empty($member['join_invite_member_id'])) {
$inviteMember = Member::with([
'info' => function ($query) {
$query->select('join_info_member_id', 'member_info_nickname');
},
'cert' => function ($query) {
$query->select('join_cert_member_id', 'member_cert_name');
}
])->where('member_id', $member['join_invite_member_id'])
->first();
$inviteMemberName = '';
if (!empty($inviteMember->cert) && !empty($inviteMember->cert->member_cert_name)) {
$inviteMemberName = $inviteMember->cert->member_cert_name;
} elseif (!empty($inviteMemberName->info) && !empty($inviteMemberName->info->member_info_nickname)) {
$inviteMemberName = $inviteMember->info->member_info_nickname;
}
$member['invite_member'] = $inviteMemberName . (!empty($inviteMember->member_invite_code) ? '(' . $inviteMember->member_invite_code . ')' : '');
}
$member['is_auth'] = "未认证";
if (!empty($member['cert']['member_cert_nbr']) && !empty($member['cert']['member_cert_name'])) {
$member['is_auth'] = "已认证";
}
$member['source'] = "APP";
$member['belong'] = [];
$member['referee'] = [];
if (!empty($member['member_extend_json'])) {
$extendJson = json_decode($member['member_extend_json'], true);
if (isset($extendJson['come_from'])) {
$member['source'] = $extendJson['come_from'] ?? '';
}
if (isset($extendJson['belong'])) {
$user = SysUser::where('user_id', $extendJson['belong']['user_id'])->select('user_name', 'user_mobile')->first();
if ($user) {
$member['belong']['user_id'] = $extendJson['belong']['user_id'];
$member['belong']['username'] = $user->user_name;
$member['belong']['user_mobile'] = $user->user_mobile;
}
$member['belong']['deptName'] = SysDept::where('dept_id', $extendJson['belong']['premises'])->value('dept_name');
}
if (isset($extendJson['referee'])) {
foreach ($extendJson['referee'] as $key => $referee) {
if (preg_match('/^1[3-9]\d{9}$/', $referee)) {
$refereeMember = Member::with([
'cert' => function ($query) {
$query->select('join_cert_member_id', 'member_cert_name');
}
])->where('member_mobile', $referee)->where('member_status', 'ACTIVED')
->first();
if ($refereeMember->cert && $refereeMember->cert->member_cert_name) {
$referee = $refereeMember->cert->member_cert_name . '-' . $referee;
}
}
$member['referee'][] = [
'name' => $referee,
'time' => $key
];
}
}
}
if (!empty($member['join_invite_member_id'])) {
$inviteMember = Member::with('cert', 'info')
->where('member_id', $member['join_invite_member_id'])
->select('member_id', 'member_mobile', 'member_invite_code')
->first();
if (!empty($inviteMember)) {
$inviteMember = $inviteMember->toArray();
$mobile = '';
if (!empty($inviteMember['member_mobile'])) {
$mobile = $inviteMember['member_mobile'];
}
$nickname = '';
if (!empty($inviteMember['info']) && !empty($inviteMember['info']['member_info_nickname'])) {
$nickname = $inviteMember['info']['member_info_nickname'];
}
$certname = '';
if (!empty($inviteMember['cert']) && !empty($inviteMember['cert']['member_cert_name'])) {
$certname = $inviteMember['cert']['member_cert_name'];
}
$member['invite_name'] = MemberService::getMemberName($mobile, $certname, $nickname);
$member['invite_code'] = $inviteMember['member_invite_code'] ?? '';
}
}
if (!empty($member['member_partner_json'])) {
$partnerJson = json_decode($member['member_partner_json'], true);
if (isset($partnerJson['duedate'])) {
$member['partner_info'] = [
'add_times' => $partnerJson['datetime'],
'surplus' => ceil((strtotime($partnerJson['duedate'] . ' 23:59:59') - time()) / (3600 * 24)),
'dates' => date('Y/m/d 00:00:00', strtotime($partnerJson['datetime'])) . '-' . date('Y/m/d 23:59:59', strtotime($partnerJson['duedate']))
];
}
}
if (!empty($member['member_referrer_json'])) {
$referrerJson = json_decode($member['member_referrer_json'], true);
if (isset($referrerJson['duedate'])) {
$member['referrer_info'] = [
'add_times' => $referrerJson['datetime'],
'surplus' => ceil((strtotime($referrerJson['duedate'] . ' 23:59:59') - time()) / (3600 * 24)),
'dates' => date('Y/m/d 00:00:00', strtotime($referrerJson['datetime'])) . '-' . date('Y/m/d 23:59:59', strtotime($referrerJson['duedate']))
];
}
}
if (!empty($member['member_franchisee_json'])) {
$franchiseeJson = json_decode($member['member_franchisee_json'], true);
if (isset($franchiseeJson['duedate'])) {
$member['franchisee_info'] = [
'add_times' => $franchiseeJson['datetime'],
'surplus' => ceil((strtotime($franchiseeJson['duedate'] . ' 23:59:59') - time()) / (3600 * 24)),
'dates' => date('Y/m/d 00:00:00', strtotime($franchiseeJson['datetime'])) . '-' . date('Y/m/d 23:59:59', strtotime($franchiseeJson['duedate']))
];
}
}
$account = [];
if (!empty($member['account'])) {
foreach ($member['account'] as $item) {
if ($item['member_account_classify'] == 'WELFARE') {
$account['welfare'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'POINTS') {
$account['points'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'CASH') {
$account['cash'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'CARD') {
$account['card'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
} else if ($item['member_account_classify'] == 'VIP') {
$account['vip'] = [
'member_account_name' => $item['member_account_name'],
'member_account_income' => $item['member_account_income'],
'member_account_expend' => $item['member_account_expend'],
'member_account_surplus' => $item['member_account_surplus'],
'member_account_added' => $item['member_account_added'],
];
}
}
}
$member['account'] = $account;
return json_success('', $member);
}
/**
* VIP账户明细
*/
public static function vipInfo(Request $request)
{
$memberId = $request->get('member_id', '');
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 20);
$account = MemberAccount::where('join_account_member_id', $memberId)
->where('member_account_classify', 'VIP')
->first();
if (!$account) {
return json_fail('暂无数据');
}
$balance = $account->member_account_surplus + $account->member_account_added;
$info = PayDetail::where(function ($query) use ($memberId) {
$query->where('join_pay_member_id', $memberId)
// ->whereIn('pay_prepayid', ['W06', 'A01'])
->where('pay_category', 'VIP')
->where('pay_status', 'SUCCESS');
})->orWhere(function ($query) use ($memberId) {
$query->where('join_pay_member_id', $memberId)
->where('pay_prepayid', 'like', '%VIP%')
->where('pay_status', 'SUCCESS');
})->orderByDesc('pay_addtimes')
->get()
->toArray();
$data = [];
foreach ($info as $key => $item) {
$categoryIds = [];
if (!empty($item['join_pay_order_id'])) {
$orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
$goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
$categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
}
$categoryName = [];
foreach ($categoryIds as $id) {
$category = SysCategory::where('category_id', $id)->first();
if (!empty($category->category_super_path)) {
$path = explode('#', $category->category_super_path);
$ids = array_filter($path);
$categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
} else {
$categoryName[] = $category->category_name;
}
}
$item['goods_category'] = implode(',', array_unique($categoryName));
if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
$item['goods_category'] = '自定义金额充值';
}
if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
$item['balance_type'] = 'add';
} else {
$item['balance_type'] = 'cut';
}
if ($key == 0 && in_array($item['pay_category'], ['VIP', 'REFUND'])) {
if (!empty($item['pay_extend_json'])) {
$extendJson = json_decode($item['pay_extend_json'], true);
if (!isset($extendJson['added_amount'])) {
$extendJson['added_amount'] = 0;
}
if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => 'ADDED',
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
];
}
$balance = $balance - $extendJson['added_amount'];
}
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance - $item['pay_amount'];
$data[] = $item;
continue;
}
if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
if (!empty($item['pay_extend_json'])) {
$extendJson = json_decode($item['pay_extend_json'], true);
if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => 'ADDED',
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
];
$balance = $balance - $extendJson['added_amount'];
}
}
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance - $item['pay_amount'];
} else {
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance + $item['pay_amount'];
}
$data[] = $item;
}
$total = count($data);
$start = ($page - 1) * $pageSize;
$rows = array_slice($data, $start, $pageSize);
return json_success('', compact('rows', 'page', 'pageSize', 'total'));
}
/**
* @Desc 我的储值卡列表
* @Author Gorden
* @Date 2024/12/2 17:12
*
* @param Request $request
* @return Response
*/
public static function cardList(Request $request)
{
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 20);
$memberId = $request->get('member_id');
$accounts = MemberAccount::where('join_account_member_id', $memberId)->where('member_account_classify', 'CARD');
$total = $accounts->count();
$rows = $accounts->orderByDesc('member_account_addtimes')
->forPage($page, $pageSize)
->get()
->toArray();
foreach ($rows as &$row) {
$row['member_account_surplus'] += $row['member_account_added'];
}
return json_success('success', compact('total', 'rows', 'page', 'pageSize'));
}
/**
* @Desc 储值卡账户明细
* @Author Gorden
* @Date 2024/11/19 11:48
*
* @param Request $request
* @return Response
*/
public static function cardInfo(Request $request)
{
$memberId = $request->get('member_id', '');
$accountNbr = $request->get('account_nbr', '');
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 20);
$account = MemberAccount::where('join_account_member_id', $memberId)
->where('member_account_nbr', $accountNbr)
->where('member_account_classify', 'CARD')
->first();
if (!$account) {
return json_fail('暂无数据');
}
$balance = $account->member_account_surplus + $account->member_account_added;
$info = PayDetail::where('pay_prepayid', $accountNbr)
->where('pay_status', 'SUCCESS')
->orderByDesc('pay_addtimes')
->get()
->toArray();
$data = [];
foreach ($info as $key => $item) {
unset($item['pay_json_request']);
$categoryIds = [];
if (!empty($item['join_pay_order_id'])) {
$orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id')->toArray();
$goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id')->toArray();
$categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id')->toArray();
}
$categoryName = [];
foreach ($categoryIds as $id) {
$category = SysCategory::where('category_id', $id)->first();
if (!empty($category->category_super_path)) {
$path = explode('#', $category->category_super_path);
$ids = array_filter($path);
$categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
} else {
$categoryName[] = $category->category_name;
}
}
$item['goods_category'] = implode(',', array_unique($categoryName));
if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
$item['balance_type'] = 'add';
} else {
$item['balance_type'] = 'cut';
}
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance + $item['pay_amount'];
$data[] = $item;
}
// 绑定记录
$memberAccountLists = MemberAccountList::where('join_list_member_account_nbr', $accountNbr)
->where('member_account_list_attr', 'IN')
->select('member_account_list_amount', 'member_account_list_datetime', 'member_account_list_attr', 'join_list_member_account_nbr', 'member_account_list_addtimes')
->get()
->toArray();
foreach ($memberAccountLists as $item) {
$data[] = [
'goods_category' => '',
'balance' => $item['member_account_list_amount'],
'pay_amount' => $item['member_account_list_amount'],
'pay_category' => 'BIND',
'balance_type' => 'add',
'pay_addtimes' => $item['member_account_list_addtimes'],
];
}
$total = count($data);
$start = ($page - 1) * $pageSize;
$rows = array_slice($data, $start, $pageSize);
return json_success('', compact('rows', 'page', 'pageSize', 'total'));
}
public static function welfareInfo(Request $request)
{
$memberId = $request->get('member_id', '');
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 20);
$account = MemberAccount::where('join_account_member_id', $memberId)
->where('member_account_classify', 'WELFARE')
->first();
if (!$account) {
return json_fail('暂无数据');
}
$balance = $account->member_account_surplus + $account->member_account_added;
$info = PayDetail::where(function ($query) use ($memberId) {
$query->where('join_pay_member_id', $memberId)
// ->whereIn('pay_prepayid', ['W06', 'A01'])
->where('pay_category', 'RECHARGE')
->where('pay_prepayid', 'WELFARE')
->where('pay_status', 'SUCCESS');
})->orWhere(function ($query) use ($memberId) {
$query->where('join_pay_member_id', $memberId)
->where('pay_prepayid', 'like', '%WELFARE%')
->where('pay_status', 'SUCCESS');
})->orderByDesc('pay_addtimes')
->get()
->toArray();
$data = [];
foreach ($info as $key => $item) {
$categoryIds = [];
if (!empty($item['join_pay_order_id'])) {
$orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
$goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
$categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
}
$categoryName = [];
foreach ($categoryIds as $id) {
$category = SysCategory::where('category_id', $id)->first();
if (!empty($category->category_super_path)) {
$path = explode('#', $category->category_super_path);
$ids = array_filter($path);
$categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
} else {
$categoryName[] = $category->category_name;
}
}
$item['goods_category'] = implode(',', array_unique($categoryName));
if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
$item['goods_category'] = '自定义金额充值';
}
if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
$item['balance_type'] = 'add';
} else {
$item['balance_type'] = 'cut';
}
if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
if (!empty($item['pay_extend_json'])) {
$extendJson = json_decode($item['pay_extend_json'], true);
if (!isset($extendJson['added_amount'])) {
$extendJson['added_amount'] = 0;
}
if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => 'ADDED',
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
];
}
$balance = $balance - $extendJson['added_amount'];
}
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance - $item['pay_amount'];
$data[] = $item;
continue;
}
if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
if (!empty($item['pay_extend_json'])) {
$extendJson = json_decode($item['pay_extend_json'], true);
if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => 'ADDED',
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
];
$balance = $balance - $extendJson['added_amount'];
}
}
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance - $item['pay_amount'];
} else {
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance + $item['pay_amount'];
}
$data[] = $item;
}
$total = count($data);
$start = ($page - 1) * $pageSize;
$rows = array_slice($data, $start, $pageSize);
return json_success('', compact('rows', 'page', 'pageSize', 'total'));
}
/**
* @Desc 佣金记录
* @Author Gorden
* @Date 2024/9/30 14:52
*
* @param Request $request
* @return Response
*/
public static function commissionList(Request $request)
{
$memberId = $request->get('member_id');
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 20);
$rows = MemberAccountList::where('join_member_account_list_member_id', $memberId)
->where('member_account_list_attr', 'IN');
$total = $rows->count();
$rows = $rows->forPage($page, $pageSize)
->get()
->toArray();
foreach ($rows as &$row) {
if (!empty($row['member_account_list_json'])) {
$memberAccountListJson = json_decode($row['member_account_list_json'], true);
if ($memberAccountListJson['master_member_id']) {
$row['master_member_name'] = MemberService::getMemberNameByMemberId($memberAccountListJson['master_member_id']);
}
}
}
return json_success('', compact('rows', 'page', 'pageSize', 'total'));
}
/**
* @Desc 我的粉丝列表
* @Author Gorden
* @Date 2024/9/20 10:22
*
* @param Request $request
*/
public static function fansList(Request $request)
{
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 1000);
$memberId = $request->get('member_id');
$name = $request->get('name', '');
$mobile = $request->get('mobile', '');
$memberIds = [];
$memberInviteIds = [];
if (!empty($name)) {
$memberIds = MemberCert::where('member_cert_name', 'like', '%' . $name . '%')->pluck('join_cert_member_id')->toArray();
$memberInviteIds = Member::whereIn('member_id', $memberIds)->pluck('join_invite_member_id')->toArray();
}
if (!empty($mobile)) {
$members = Member::where('member_mobile', 'like', '%' . $mobile . '%')
->select('member_id', 'join_invite_member_id')
->get()
->toArray();
$memberIds2 = array_column($members, 'member_id');
$memberInviteIds2 = array_column($members, 'join_invite_member_id');
$memberIds = array_merge($memberIds, $memberIds2);
$memberInviteIds = array_merge($memberInviteIds, $memberInviteIds2);
}
$fans1 = Member::with([
'info' => function ($query) {
$query->select('join_info_member_id', 'member_info_nickname', 'member_info_headimg');
},
'cert' => function ($query) {
$query->select('join_cert_member_id', 'member_cert_name');
},
'role' => function ($query) {
$query->select('member_role_id', 'member_role_name');
}
])->where('join_invite_member_id', $memberId)
->when(!empty($memberIds), function ($query) use ($memberIds, $memberInviteIds) {
$allSub = array_merge($memberIds, $memberInviteIds);
$query->whereIn('member_id', $allSub);
})
->select('member_id', 'join_member_role_id', 'member_id as id', 'join_invite_member_id as pid', 'member_partner_json', 'member_mobile', 'member_addtimes', 'member_is_owner', 'member_is_vip', 'member_is_partner', 'member_is_referrer')
->get()
->toArray();
$fans1Ids = array_column($fans1, 'id');
$fans2 = Member::with([
'info' => function ($query) {
$query->select('join_info_member_id', 'member_info_nickname', 'member_info_headimg');
},
'cert' => function ($query) {
$query->select('join_cert_member_id', 'member_cert_name');
},
'role' => function ($query) {
$query->select('member_role_id', 'member_role_name');
}
])->whereIn('join_invite_member_id', $fans1Ids)
->when(!empty($memberIds), function ($query) use ($memberIds) {
$query->whereIn('member_id', $memberIds);
})
->select('member_id', 'join_member_role_id', 'member_id as id', 'join_invite_member_id as pid', 'member_partner_json', 'member_mobile', 'member_addtimes', 'member_is_owner', 'member_is_vip', 'member_is_partner', 'member_is_referrer')
->get()
->toArray();
$fans = array_merge($fans1, $fans2);
foreach ($fans as &$fan) {
$memberMobile = $fan['member_mobile'] ?? '';
// $memberNickname = $fan['info'] && $fan['info']['member_info_nickname'] ? $fan['info']['member_info_nickname'] : '';
$memberCertName = $fan['cert'] && $fan['cert']['member_cert_name'] ? $fan['cert']['member_cert_name'] : '';
$fan['member_name'] = '';
if (!empty($memberCertName) && !empty($memberMobile)) {
$fan['member_name'] = $memberCertName . '-' . $memberMobile;
} elseif (!empty($memberCertName)) {
$fan['member_name'] = $memberCertName;
} elseif (!empty($memberMobile)) {
$fan['member_name'] = $memberMobile;
}
if (!empty($fan['info']) && substr($fan['info']['member_info_headimg'], 0, 4) == 'http') {
$fan['member_info_headimg'] = $fan['info']['member_info_headimg'];
} else {
$fan['member_info_headimg'] = 'https://img.wanyuewellness.com.cn/images/avatar_default.png';
}
// 等级名称
$fan['role_name'] = $fan['role'] && $fan['role']['member_role_name'] ? $fan['role']['member_role_name'] : '';
unset($fan['info'], $fan['cert'], $fan['role']);
}
$tree = (new Tree($fans))->getTree();
$total = count($tree);
$start = ($page - 1) * $pageSize;
$rows = array_splice($tree, $start, $pageSize);
return json_success('success', compact('rows','total','page','pageSize'));
}
/**
* 格式化树
* @param $items
* @return Response
*/
protected static function formatTree($items): Response
{
$format_items = [];
foreach ($items as $item) {
$format_items[] = [
'name' => $item->title ?? $item->name ?? $item->id,
'value' => (string)$item->id,
'id' => $item->id,
'pid' => $item->pid,
];
}
$tree = new Tree($format_items);
return json_success('success', $tree->getTree());
}
public static function clearWelfare(Request $request)
{
$memberId = $request->post('member_id');
$payTime = $request->post('pay_paytimes', date('Y-m-d H:i:s'));
$payTime = date('Y-m-d H:i:s', strtotime($payTime));
$payRemark = $request->post('pay_remark', '');
$clearPwd = $request->post('clear_password');
if (!$clearPwd || $clearPwd != '123456') {
return json_fail('清零密码错误');
}
Db::beginTransaction();
try {
$account = MemberAccount::where('join_account_member_id', $memberId)
->where('member_account_classify', 'WELFARE')
->where('member_account_status', 'ACTIVED')
->first();
if (!$account) {
throw new BusinessException("账户异常");
}
if ($account->member_account_surplus <= 0) {
throw new BusinessException("账户余额为0，无需清零");
}
// 创建清除记录
PayDetail::insert([
'join_pay_member_id' => $memberId,
'pay_status' => 'SUCCESS',
'pay_category' => 'CLEAR',
'pay_amount' => $account->member_account_surplus,
'pay_paytimes' => $payTime,
'pay_prepayid' => $memberId . '-WELFARE',
'pay_remark' => $payRemark,
'pay_addtimes' => time()
]);
// 账户归零
$account->member_account_expend = $account->member_account_expend + $account->member_account_surplus;
$account->member_account_surplus = 0;
$account->save();
Db::commit();
return json_success('success');
} catch (BusinessException $e) {
Db::rollBack();
return json_fail($e->getMessage());
} catch (\Exception $e) {
dump($e->getMessage());
Db::rollBack();
return json_fail('清零失败');
}
}
public static function balanceInfo(Request $request)
{
$memberId = $request->get('member_id', '');
$page = $request->get('page', 1);
$pageSize = $request->get('pageSize', 20);
$account = MemberAccount::where('join_account_member_id', $memberId)
->where('member_account_classify', 'CASH')
->first();
if (!$account) {
return json_fail('暂无数据');
}
$balance = $account->member_account_surplus + $account->member_account_added;
$info = PayDetail::where(function ($query) use ($memberId) {
$query->where('join_pay_member_id', $memberId)
->whereIn('pay_category', ['RECHARGE'])
->where('pay_prepayid', '<>', $memberId . '-WELFARE')
->where('pay_status', 'SUCCESS');
})->orWhere(function ($query) use ($memberId) {
$query->where('join_pay_member_id', $memberId)
->where('pay_prepayid', 'like', '%CASH%')
->where('pay_status', 'SUCCESS');
})->select('join_pay_object_json', 'join_pay_member_id', 'pay_category', 'join_pay_order_id', 'pay_extend_json', 'pay_addtimes', 'pay_amount');
// ->orderByDesc('pay_addtimes')
// ->get()
// ->toArray();
$memberAccountList = MemberAccountList::where('join_member_account_list_member_id', $memberId)
->whereIn('member_account_list_classify',['PARTNER','REFERRER','FRANCHISE'])
->where('member_account_list_status', 'ACTIVED')
->selectRaw('
member_account_list_extend_json as join_pay_object_json,
join_member_account_list_member_id as join_pay_member_id,
member_account_list_attr as pay_category,
join_list_member_account_nbr as pay_prepayid,
member_account_list_extend_json as pay_extend_json,
member_account_list_addtimes as pay_addtimes,
member_account_list_amount as pay_amount');
$info = $info->union($memberAccountList)
->orderByDesc('pay_addtimes')
->get()
->toArray();
$data = [];
foreach ($info as $key => $item) {
$payObjectJson = [];
if (!empty($item['join_pay_object_json'])) {
$payObjectJson = json_decode($item['join_pay_object_json'], true);
}
$categoryIds = [];
if (!empty($item['join_pay_order_id'])) {
$goodsIds = [];
if (in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE', 'REFERRER', 'FRANCHISEE'])) {
if (isset($payObjectJson['recharge_goods_id'])) {
$goodsIds = [$payObjectJson['recharge_goods_id']];
}
} else {
$orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
$goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
}
$categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
}
$categoryName = [];
foreach ($categoryIds as $id) {
$category = SysCategory::where('category_id', $id)->first();
if (!empty($category->category_super_path)) {
$path = explode('#', $category->category_super_path);
$ids = array_filter($path);
$categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
} else {
$categoryName[] = $category->category_name;
}
}
$item['goods_category'] = implode(',', array_unique($categoryName));
if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
$item['goods_category'] = '自定义金额充值';
} else if (mb_substr($item['goods_category'], 0, 7) == '会员合伙人产品') {
$item['goods_category'] = '会员合伙人充值';
}
$goodsCategory = '';
if ($item['join_pay_order_id'] == 'FRANCHISEE') {
$goodsCategory = '加盟合伙人充值';
}
if (in_array($item['pay_category'], ['RECHARGE', 'REFUND', 'GIVE', 'CROWN_CONTINUE', 'PARTNER', 'FRANCHISEE', 'IN'])) {
$item['balance_type'] = 'add';
} else {
$item['balance_type'] = 'cut';
}
if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND', 'GIVE', 'FRANCHISEE', 'CROWN_CONTINUE'])) {
if (!empty($item['pay_extend_json']) && !in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE', 'FRANCHISEE'])) {
$extendJson = json_decode($item['pay_extend_json'], true);
if (!isset($extendJson['added_amount'])) {
$extendJson['added_amount'] = 0;
}
if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
$payCategory = 'ADDED';
if ($item['pay_category'] == 'GIVE') {
$payCategory = 'GIVE';
} elseif ($item['pay_category'] == 'CROWN_CONTINUE') {
$payCategory = 'CROWN_CONTINUE';
}
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => $payCategory,
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
'goods_category' => $goodsCategory
];
} elseif (!empty($payObjectJson['recharge_config']) && $payObjectJson['recharge_config']['nbr'] > 0) {
$payCategory = 'ADDED';
if ($item['pay_category'] == 'GIVE') {
$payCategory = 'GIVE';
} elseif ($item['pay_category'] == 'CROWN_CONTINUE') {
$payCategory = 'CROWN_CONTINUE';
}
$extendJson['added_amount'] = $item['pay_amount'] * $payObjectJson['recharge_config']['nbr'];
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => $payCategory,
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
];
}
$balance = $balance - $extendJson['added_amount'];
}
if (in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE', 'FRANCHISEE'])) {
$addedAmount = 0;
if (!isset($payObjectJson['recharge_config'])) {
$addedAmount = 0;
}
if (isset($payObjectJson['recharge_config']) && !empty($payObjectJson['recharge_config']['nbr']) && floatval($payObjectJson['recharge_config']['nbr'] > 0)) {
$addedAmount = $payObjectJson['recharge_config']['nbr'];
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $addedAmount,
'pay_category' => 'ADDED',
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
'goods_category' => $goodsCategory
];
}
$balance = $balance - $addedAmount;
}
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance - $item['pay_amount'];
if (!in_array($item['pay_category'], ['GIVE', 'CROWN_CONTINUE']) && !in_array($item['join_pay_order_id'], ['FRANCHISEE'])) {
$data[] = $item;
}
continue;
}
if (in_array($item['pay_category'], ['RECHARGE', 'REFUND', 'GIVE', 'CROWN_CONTINUE', 'PARTNER', 'COMBINE', 'FRANCHISEE', 'IN'])) {
if (!empty($item['pay_extend_json']) && !in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE', 'FRANCHISEE'])) {
$extendJson = json_decode($item['pay_extend_json'], true);
if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
$payCategory = 'ADDED';
if ($item['pay_category'] == 'GIVE') {
$payCategory = 'GIVE';
} elseif ($item['pay_category'] == 'CROWN_CONTINUE') {
$payCategory = 'CROWN_CONTINUE';
}
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => $payCategory,
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
'goods_category' => $goodsCategory
];
$balance = $balance - $extendJson['added_amount'];
} elseif (!empty($payObjectJson['recharge_config']) && $payObjectJson['recharge_config']['nbr'] > 0) {
$payCategory = 'ADDED';
if ($item['pay_category'] == 'GIVE') {
$payCategory = 'GIVE';
} elseif ($item['pay_category'] == 'CROWN_CONTINUE') {
$payCategory = 'CROWN_CONTINUE';
}
$extendJson['added_amount'] = $item['pay_amount'] * $payObjectJson['recharge_config']['nbr'];
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $extendJson['added_amount'],
'pay_category' => $payCategory,
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
'goods_category' => $goodsCategory
];
$balance = $balance - $extendJson['added_amount'];
}
}
if (in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE', 'FRANCHISEE'])) {
$addedAmount = 0;
if (!isset($payObjectJson['recharge_config'])) {
$addedAmount = 0;
}
if (isset($payObjectJson['recharge_config']) && !empty($payObjectJson['recharge_config']['nbr']) && floatval($payObjectJson['recharge_config']['nbr'] > 0)) {
$addedAmount = $payObjectJson['recharge_config']['nbr'];
$data[] = [
'join_pay_member_id' => $item['join_pay_member_id'],
'pay_addtimes' => $item['pay_addtimes'],
'pay_amount' => $addedAmount,
'pay_category' => 'ADDED',
'balance' => number_format($balance, 2, '.', ''),
'balance_type' => 'add',
'goods_category' => $goodsCategory
];
}
$balance = $balance - $addedAmount;
}
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance - $item['pay_amount'];
} else {
$item['balance'] = number_format($balance, 2, '.', '');
$balance = $balance + $item['pay_amount'];
}
if (!in_array($item['pay_category'], ['GIVE', 'CROWN_CONTINUE']) && !in_array($item['join_pay_order_id'], ['FRANCHISEE'])) {
$data[] = $item;
}
}
$total = count($data);
$start = ($page - 1) * $pageSize;
$rows = array_slice($data, $start, $pageSize);
return json_success('', compact('rows', 'page', 'pageSize', 'total'));
}
public static function pointInfo($memberId)
{
$account = MemberAccount::where('join_account_member_id', $memberId)
->where('member_account_classify', 'POINTS')
->first();
if (!$account) {
return json_fail('暂无数据');
}
$balance = $account->member_account_surplus + $account->member_account_added;
$points = ClientPoints::where('join_client_points_member_id', $memberId)->orderBy('client_points_addtimes', 'DESC')->get()->toArray();
$nowPoint = 0;
foreach ($points as $key => &$point) {
$point['goods_category'] = '其他';
if (!empty($point['join_client_points_goods_id'])) {
$categoryId = Goods::where('goods_id', $point['join_client_points_goods_id'])->pluck('join_goods_category_id');
$category = SysCategory::where('category_id', $categoryId)->first();
if (!empty($category->category_super_path)) {
$path = explode('#', $category->category_super_path);
$ids = array_filter($path);
$point['goods_category'] = SysCategory::where('category_id', current($ids))->value('category_name');
} else {
$point['goods_category'] = $category->category_name;
}
}
if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
$point['balance_type'] = 'add';
} else {
$point['balance_type'] = 'cut';
}
if ($key == 0) {
$point['balance'] = number_format($balance, 2, '.', '');
if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
$balance = $balance - $point['client_points_nbr'];
} else {
$balance = $balance + $point['client_points_nbr'];
}
continue;
}
if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
$point['balance'] = number_format($balance, 2, '.', '');
$balance = $balance - $point['client_points_nbr'];
// $point['balance'] = $balance = $nowPoint = number_format($balance - $point['client_points_nbr'], 2, '.', '');
} else {
$point['balance'] = number_format($balance, 2, '.', '');
$balance = $balance + $point['client_points_nbr'];
// $point['balance'] = $balance = $nowPoint = number_format($balance + $point['client_points_nbr'], 2, '.', '');
}
}
return json_success('', $points);
}
/**
* @Desc 添加会员
* @Author Gorden
* @Date 2024/3/25 13:40
*
* @param $params
* @return \support\Response
*/
public static function add($params)
{
Db::beginTransaction();
try {
// 排重
if (Member::where('member_mobile', $params['mobile'])->where('member_status', 'ACTIVED')->exists()) {
throw new BusinessException("会员已存在");
}
$memberId = self::generateMemberId();
// 先写主表，要ID
$memberData = [
'member_id' => $memberId,
'member_is_owner' => $params['is_owner'] ?? 'N',
'member_classify' => $params['classify'] ?? '',
'member_status' => $params['status'] ?? 'PENDING',
'member_mobile' => $params['mobile'] ?? '',
'member_category' => $params['member_category'] ?? '后台添加',
'member_invite_code' => self::generateInviteCode(),
// 'member_from' => $params['source'],
// 'member_extend_json' => json_encode(['come_from' => $params['source']]),
'member_addtimes' => time(),
];
$extendJson['come_from'] = $params['source'];
if (!empty($params['user_id'])) {
$deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
if (!$deptId) {
throw new BusinessException('请先关联业务员和门店');
}
$extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
}
$memberData['member_extend_json'] = json_encode($extendJson);
Member::insert($memberData);
// 账户表
$accountData = [
'join_account_member_id' => $memberId,
'member_account_classify' => 'POINTS',
'member_account_status' => 'ACTIVED',
'member_account_category' => 'NORMAL',
'member_account_nbr' => $memberId . '-POINTS',
'member_account_name' => '积分账户',
'member_account_addtimes' => time()
];
// 积分账户
MemberAccount::insert($accountData);
$accountData['member_account_classify'] = 'CASH';
$accountData['member_account_nbr'] = $memberId . '-CASH';
$accountData['member_account_name'] = '余额账户';
// 现金/余额账户
MemberAccount::insert($accountData);
// 福利账户
// if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY'){
// $welfareData = [
// 'join_account_member_id'=>$memberId,
// 'member_account_classify'=>'WELFARE',
// 'member_account_status'=>'ACTIVED',
// 'member_account_category'=>'NORMAL',
// 'member_account_nbr'=>$memberId.'-WELFARE',
// 'member_account_name'=>'福利账户',
// 'member_account_addtimes'=>time()
// ];
// MemberAccount::insert($welfareData);
// }
// member cert
$certData = [
'join_cert_member_id' => $memberId,
'member_cert_nation' => $params['member_cert_nation'] ?? '',
'member_cert_name' => $params['cert_name'] ?? '',
'member_cert_nbr' => $params['cert_nbr'] ?? '',
'member_cert_birth' => !empty($params['birth']) ? date('Y-m-d', strtotime($params['birth'])) : '',
'member_cert_gender' => $params['gender'] ?? '',
// 'member_cert_province' => !empty($params['province']) ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
// 'member_cert_city' => $params['city'] ?? '',
// 'member_cert_addr' => $params['addr'] ?? '',
// 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
// 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
];
MemberCert::insert($certData);
// member info
$infoData = [
'join_info_member_id' => $memberId,
'member_info_nickname' => $params['account_name'] ?? '',
'member_info_headimg' => !empty($params['avatar']) ? getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']) : '',
'member_info_referee' => $params['member_info_referee'] ?? '',
'member_info_business' => $params['member_info_business'] ?? '',
'member_info_service' => $params['member_info_service'] ?? '',
'member_info_city' => !empty($params['province']) ? implode('-', $params['province']) : '',
'member_info_address' => $params['member_info_address'] ?? '',
'member_info_birthday' => !empty($params['birth']) ? date('Y-m-d', strtotime($params['birth'])) : '',
'member_info_gender' => $params['gender'] ?? '',
];
MemberInfo::insert($infoData);
Db::commit();
} catch (BusinessException $e) {
Db::rollBack();
return json_fail($e->getMessage());
} catch (\Exception $e) {
Db::rollBack();
dump($e->getMessage() . ';line:' . $e->getLine());
return json_fail("数据添加失败");
}
return json_success('数据添加成功', ['member_id' => $memberId]);
}
/**
* @Desc 编辑会员/ 业主
* @Author Gorden
* @Date 2024/4/20 15:18
*
* @param $params
* @return \support\Response
*/
public static function update($params)
{
Db::beginTransaction();
try {
$memberId = $params['member_id'];
$member = Member::where('member_id', $params['member_id'])->first();
if (!$member) {
throw new BusinessException('数据异常');
}
$extendJson = [];
if (!empty($member->member_extend_json)) {
$extendJson = json_decode($member->member_extend_json, true);
}
$extendJson['come_from'] = $params['source'];
// 门店、业务员
if (!empty($params['user_id'])) {
$deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
if (!$deptId) {
throw new BusinessException('您选择的业务员没有关联门店');
}
$extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
}
// 先写主表，要ID
$memberData = [
'member_id' => $memberId,
'member_is_owner' => $params['is_owner'],
'member_classify' => $params['member_classify'],
'member_status' => $params['status'],
// 'member_mobile' => $params['mobile'],
// 'member_from' => $params['source'],
'member_extend_json' => json_encode($extendJson)
];
Member::where('member_id', $params['member_id'])->update($memberData);
// member cert
$certData = [
'join_cert_member_id' => $memberId,
'member_cert_nation' => $params['member_cert_nation'] ?? '',
'member_cert_name' => $params['cert_name'] ?? '',
'member_cert_nbr' => $params['cert_nbr'] ?? '',
'member_cert_birth' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
'member_cert_gender' => $params['gender'] ?? '',
// 'member_cert_province' => $params['province'] ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
// 'member_cert_city' => $params['city'] ?? '',
// 'member_cert_addr' => $params['addr'] ?? '',
'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
];
if (!MemberCert::where('join_cert_member_id', $memberId)->exists()) {
MemberCert::insert($certData);
} else {
MemberCert::where('join_cert_member_id', $params['member_id'])->update($certData);
}
// member info
$avatar = '';
if ($params['avatar'] && (strpos($params['avatar'], getenv('APP_IMAGE_DOMAIN')) !== false || strpos($params['avatar'], getenv('SYSTEM_AVATAR_DOMAIN')) !== false)) {
$avatar = $params['avatar'];
} else if ($params['avatar']) {
$avatar = getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']);
}
$infoData = [
'join_info_member_id' => $memberId,
'member_info_nickname' => $params['account_name'],
'member_info_headimg' => $avatar,
'member_info_referee' => $params['member_info_referee'] ?? '',
'member_info_business' => $params['member_info_business'] ?? '',
'member_info_service' => $params['member_info_service'] ?? '',
'member_info_city' => !empty($params['province']) ? implode('-', $params['province']) : '',
'member_info_address' => $params['member_info_address'] ?? '',
'member_info_birthday' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
'member_info_gender' => $params['gender'] ?? '',
];
if (!MemberInfo::where('join_info_member_id', $params['member_id'])->exists()) {
MemberInfo::insert($infoData);
} else {
MemberInfo::where('join_info_member_id', $params['member_id'])->update($infoData);
}
// 福利账户
if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY' && !MemberAccount::where('member_account_nbr', $memberId . '-WELFARE')->exists()) {
$welfareData = [
'join_account_member_id' => $memberId,
'member_account_classify' => 'WELFARE',
'member_account_status' => 'ACTIVED',
'member_account_category' => 'NORMAL',
'member_account_nbr' => $memberId . '-WELFARE',
'member_account_name' => '福利账户',
'member_account_addtimes' => time()
];
MemberAccount::insert($welfareData);
}
Db::commit();
} catch (BusinessException $e) {
Db::rollBack();
dump($e->getMessage() . ';line:' . $e->getLine());
return json_fail($e->getMessage());
} catch (\Exception $e) {
Db::rollBack();
dump($e->getMessage() . ';line:' . $e->getLine());
return json_fail("数据更新失败");
}
return json_success('数据更新成功');
}
/**
* @Desc 会员关联设备列表
* @Author Gorden
* @Date 2024/4/7 9:52
*
* @param $id
* @return \support\Response
*/
public static function deviceList($id)
{
$family = Family::where('join_family_creator_member_id', $id)->get()->toArray();
$familyMemberIds = '';
if ($family) {
$familyIds = array_column($family, 'family_id');
$familyMember = FamilyMember::whereIn('join_family_id', $familyIds)->get()->toArray();
$familyMemberIds = array_column($familyMember, 'join_family_member_id');
}
$rows = MemberDevice::leftJoin('device', 'device.device_id', '=', 'member_device.join_member_device_id')
->leftJoin('member', 'member.member_id', '=', 'member_device.join_device_member_id')
->leftJoin('family_member', 'family_member.join_family_member_id', '=', 'member_device.join_device_member_id')
->select('device.device_category', 'device.device_name', 'device.device_type', 'member.member_mobile', 'member_device.*', 'family_member.family_member_name')
->when(!empty($familyMemberIds), function ($query) use ($familyMemberIds) {
$query->whereIn('member_device.join_device_master_member_id', $familyMemberIds);
})
->when(empty($familyMemberIds), function ($query) use ($id) {
$query->where('member_device.join_device_master_member_id', $id);
})->orderBy('member_device_addtimes', 'desc')
->get()
->toArray();
return json_success('', ['rows' => $rows]);
}
/**
* @Desc 绑定设备
* @Author Gorden
* @Date 2024/4/7 10:27
*
* @param Request $request
* @return \support\Response
*/
public static function addDevice(Request $request)
{
$params = $request->post();
Db::beginTransaction();
try {
$data = [
'join_device_member_id' => $params['join_device_member_id'] ?? '',
'join_device_master_member_id' => $params['join_device_master_member_id'],
'join_member_device_id' => $params['join_member_device_id'],
'member_device_status' => $params['member_device_status'],
'member_device_key' => $params['member_device_key'] ?? '',
'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
'member_device_remark' => $params['member_device_remark'] ?? null,
'member_device_addtimes' => time(),
];
MemberDevice::insert($data);
$device = Device::where('device_id', $params['join_member_device_id'])->whereIn('device_status', ['PROCESSING', 'PENDING'])->first();
// 激活设备
if (!$device) {
Db::rollBack();
return json_fail('当前设备不是可激活状态');
}
$device->device_status = 'ACTIVED';
$device->save();
Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => 'ACTIVED']);
_syslog("绑定设备", "用户【" . ($params['join_device_member_id'] ?? $params['join_device_master_member_id']) . '】，绑定设备【' . $device->device_name . '】');
Db::commit();
} catch (\Exception $e) {
Db::rollBack();
dump($e->getMessage());
return json_fail('绑定失败');
}
return json_success('绑定成功');
}
public static function updateDevice(Request $request)
{
$params = $request->post();
Db::beginTransaction();
try {
$data = [
'member_device_status' => $params['member_device_status'],
'member_device_key' => $params['member_device_key'],
'join_device_member_id' => $params['join_device_member_id'],
'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
'member_device_remark' => $params['member_device_remark'] ?? null,
];
MemberDevice::where('member_device_id', $request->post('member_device_id'))->update($data);
$device = Device::where('device_id', $params['join_member_device_id'])->first();
if ($device->device_status != $params['member_device_status']) {
$device->device_status = $params['member_device_status'];
$device->save();
}
// Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => $params['member_device_status']]);
Db::commit();
_syslog("更新绑定设备", "用户【" . ($params['join_device_member_id'] == "" ? $params['join_device_member_id'] : $params['join_device_master_member_id']) . '】，绑定设备【' . $device->device_name . '】');
} catch (\Exception $e) {
Db::rollBack();
dump($e->getMessage());
return json_fail('绑定更新失败');
}
return json_success('绑定更新成功');
}
public static function deleteDevice(Request $request)
{
try {
Db::beginTransaction();
$memberDevice = MemberDevice::where('member_device_id', $request->post('member_device_id'))->first();
if (!$memberDevice) {
return json_fail('数据不存在');
}
$device = Device::where('device_id', $memberDevice->join_member_device_id)->first();
$device->device_status = "DISABLED";
$device->save();
// Device::where('device_id', $memberDevice->join_member_device_id)->update(['device_status' => 'DISABLED']);
$memberDevice->delete();
Db::commit();
_syslog("解除绑定设备", "用户【" . ($memberDevice->join_device_member_id == "" ? $memberDevice->join_device_member_id : $memberDevice->join_device_master_member_id) . '】，解除绑定设备【' . $device->device_name . '】');
return json_success('解除绑定成功');
} catch (\Exception $e) {
Db::rollBack();
return json_fail('绑定失败');
}
}
/**
* 手动创建会员
*/
public static function createMember($params)
{
$memberId = $params['member_id'] ?? '';
if (!$memberId) {
throw new BusinessException("参数异常");
}
// 主表
$memberData = [
'member_id' => $memberId,
'member_is_owner' => 'N',
'member_classify' => 'MEMBER',
'member_status' => 'ACTIVED',
'member_mobile' => $params['mobile'],
'member_invite_code' => self::generateInviteCode(),
'member_extend_json' => json_encode(['come_from' => 'SYSTEM']),
'member_addtimes' => time()
];
Member::insert($memberData);
// 账户表
$accountData = [
'join_account_member_id' => $memberId,
'member_account_classify' => 'POINTS',
'member_account_status' => 'ACTIVED',
'member_account_category' => 'NORMAL',
'member_account_nbr' => $memberId . '-POINTS',
'member_account_name' => '积分账户',
'member_account_addtimes' => time()
];
// 积分账户
MemberAccount::insert($accountData);
$accountData['member_account_classify'] = 'CASH';
$accountData['member_account_nbr'] = $memberId . '-CASH';
$accountData['member_account_name'] = '余额账户';
// 现金/余额账户
MemberAccount::insert($accountData);
// info
$infoData = [
'join_info_member_id' => $memberId,
'member_info_nickname' => $params['username']
];
MemberInfo::insert($infoData);
}
private static function generateMemberId()
{
$id = SysSerial::getSerial();
return "MR" . date('ymdHi') . random_string(4, 'up');
}
public static function getMemberName($mobile, $certName, $nickname)
{
$name = '';
if (!empty($certName)) {
$name = $certName;
} elseif (!empty($nickname)) {
$name = $nickname;
}
if (!empty($name) && !empty($mobile)) {
$name .= '-' . $mobile;
} elseif (!empty($mobile)) {
$name = $mobile;
}
return $name;
}
public static function getMemberCertName($mobile, $certName, $nickname)
{
$name = '';
if (!empty($certName)) {
$name = $certName;
}
if (!empty($name) && !empty($mobile)) {
$name .= '-' . $mobile;
} elseif (!empty($mobile)) {
$name = $mobile;
}
return $name;
}
public static function getMemberNickname($mobile)
{
if (empty($mobile)) {
return '';
}
return substr($mobile, -4, 4) . '会员';
}
public static function getMemberNameByMemberId($memberId)
{
$member = Member::with([
'cert' => function ($query) {
$query->select('join_cert_member_id', 'member_cert_name');
},
'info' => function ($query) {
$query->select('join_info_member_id', 'member_info_nickname');
},
]
)->where('member_id', $memberId)
->first();
if (empty($member)) {
return;
}
$member = $member->toArray();
$mobile = $certName = $nickname = '';
if (!empty($member['member_mobile'])) {
$mobile = $member['member_mobile'];
}
if (!empty($member['cert']) && !empty($member['cert']['member_cert_name'])) {
$certName = $member['cert']['member_cert_name'];
}
if (!empty($member['info']) && !empty($member['info']['member_info_nickname'])) {
$nickname = $member['info']['member_info_nickname'];
}
return self::getMemberName($mobile, $certName, $nickname);
}
/**
* @Desc 生成推荐码
* @Author Gorden
* @Date 2024/9/6 9:05
*
* @return string
*/
public static function generateInviteCode()
{
$code = random_string(8, 'number');
if (Member::where('member_invite_code', $code)->exists()) {
return self::generateInviteCode();
} else {
return $code;
}
}
public static function getAvatarUrl($url)
{
if (substr($url, 0, 1) == '.' || substr($url, 0, 1) == '/' || empty($url)) {
$url = "https://img.wanyuewellness.com.cn/images/avatar_default.png";
}
return $url;
}
/**
* @Desc 获取昵称
* @Author Gorden
* @Date 2024/10/23 11:50
*
* @param $nickname
* @param $mobile
* @return mixed|string
*/
public static function getNickname($nickname, $mobile)
{
if (!empty($nickname)) {
return $nickname;
} else if (!empty($mobile)) {
return substr($mobile, -4, 4) . '会员';
} else {
return '';
}
}
public static function getRoleName($roleId)
{
if (empty($roleId)) {
return '';
}
return MemberRole::where('member_role_id', $roleId)->value('member_role_name');
}
/**
* @Desc 获取身份-合伙人，推荐官
* @Author Gorden
* @Date 2024/9/28 13:41
*
* @param $isPartner
* @param $isReferrer
* @return string
*/
public static function getIdentity($isPartner, $isReferrer, $isFranchisee)
{
if ($isPartner == 'Y') {
return "PARTNER";
} elseif ($isReferrer == 'Y') {
return "REFERRER";
} elseif ($isFranchisee == 'Y') {
return "FRANCHISEE";
} else {
return 'NON';
}
}
/**
* @Desc 会员合伙人过期
* @Author Gorden
* @Date 2024/10/10 9:50
*
* @return void
*/
public static function partnerExpired()
{
$members = Member::where('member_is_partner', 'Y')->get()->toArray();
foreach ($members as $member) {
$partnerJson = ['member_id' => $member['member_id']];
if (!empty($member['member_partner_json'])) {
$partnerJson = json_decode($member['member_partner_json'], true);
}
if (isset($partnerJson['duedate'])) {
$duedateUnix = strtotime($partnerJson['duedate'] . ' 23:59:59');
if ($duedateUnix > time()) {
continue;
}
}
Member::where('member_id', $member['member_id'])->update(['member_is_partner' => 'N', 'member_partner_json' => '[]']);
_syslog("会员合伙人过期", "取消身份", false, $partnerJson, 1001);
Log::info("会员【" . $member['member_id'] . '】会员合伙人身份已过期', $partnerJson);
}
}
/**
* @Desc 康养推荐官过期
* @Author Gorden
* @Date 2024/10/10 10:14
*
* @return void
*/
public static function referrerExpired()
{
$members = Member::where('member_is_referrer', 'Y')->get()->toArray();
foreach ($members as $member) {
$referrerJson = ['member_id' => $member['member_id']];
if (!empty($member['member_referrer_json'])) {
$referrerJson = json_decode($member['member_referrer_json'], true);
}
if (isset($referrerJson['duedate'])) {
$duedateUnix = strtotime($referrerJson['duedate'] . ' 23:59:59');
if ($duedateUnix > time()) {
continue;
}
}
Member::where('member_id', $member['member_id'])->update(['member_is_referrer' => 'N', 'member_referrer_json' => '[]']);
_syslog("康养推荐官过期", "取消身份", false, $referrerJson, 1001);
Log::info("会员【" . $member['member_id'] . '】康养推荐官身份已过期', $referrerJson);
}
}
/**
* @Desc 会员等级变更计划任务
* @Author Gorden
* @Date 2024/10/16 14:46
*
* @return void
*/
public static function roleExpired()
{
$members = Member::where('join_member_role_id', '<>', '')->get()->toArray();
foreach ($members as $member) {
if (empty($member['member_role_begintime'])) {
continue;
}
$endDateTime = date('Y-m-d 23:59:59', strtotime($member['member_role_begintime'] . ' +364 days'));
if (strtotime($endDateTime) > time()) {
continue;
}
$memberUpdate = [
'join_member_role_id' => '',
'member_role_begintime' => '',
'member_role_config_json' => '[]'
];
if (!empty($member['member_role_config_json'])) {
$roleConfigJson = json_decode($member['member_role_config_json'], true);
if (!empty($roleConfigJson['next'])) {
$memberUpdate['join_member_role_id'] = $roleConfigJson['next'][0]['member_role_id'];
$memberUpdate['member_role_begintime'] = $roleConfigJson['next'][0]['member_role_begintime'];
unset($roleConfigJson['next'][0]);
$memberUpdate['member_role_config_json'] = json_encode($roleConfigJson);
}
}
Member::where('member_id', $member['member_id'])->update($memberUpdate);
Log::info("会员过期", ['member_id' => $member['member_id'], 'role_id' => $member['join_member_role_id']]);
}
}
/**
* @Desc 加盟合伙人过期
* @Author Gorden
* @Date 2024/11/13 8:48
*
* @return void
*/
public static function franchiseeExpired()
{
$members = Member::where('member_is_franchisee', 'Y')->get()->toArray();
foreach ($members as $member) {
$franchiseeJson = ['member_id' => $member['member_id']];
if (!empty($member['member_franchisee_json'])) {
$franchiseeJson = json_decode($member['member_franchisee_json'], true);
}
if (isset($franchiseeJson['duedate'])) {
$duedateUnix = strtotime($franchiseeJson['duedate'] . ' 23:59:59');
if ($duedateUnix > time()) {
continue;
}
}
Member::where('member_id', $member['member_id'])->update(['member_is_franchisee' => 'N', 'member_franchisee_json' => '[]']);
_syslog("加盟合伙人过期", "取消身份", false, $franchiseeJson, 1001);
Log::info("会员【" . $member['member_id'] . '】加盟合伙人身份已过期', $franchiseeJson);
}
}
/**
* @Desc 加盟合伙人每年发20%
* @Author Gorden
* @Date 2024/11/13 9:16
*
* @return void
*/
public static function franchiseeAdded()
{
try {
$members = Member::where('member_is_franchisee', 'Y')->get()->toArray();
foreach ($members as $member) {
$franchiseeJson = [];
if (!empty($member['member_franchisee_json'])) {
$franchiseeJson = json_decode($member['member_franchisee_json'], true);
}
if (isset($franchiseeJson['datetime'])) {
if (date('Ymd', strtotime($franchiseeJson['datetime'])) == date('Ymd')) {
continue;
}
}
if (isset($franchiseeJson['duedate'])) {
$duedateUnix = strtotime($franchiseeJson['duedate']);
$todayUnix = strtotime(date('Y-m-d'));
if (in_array(($duedateUnix - $todayUnix) / (3600 * 24 * 365), [1, 2, 3, 4])) {
$payDetail = PayDetail::where('join_pay_member_id', $member['member_id'])
->where('join_pay_order_id', 'FRANCHISEE')
->orderBy('pay_addtimes', 'DESC')
->first();
if (date('Ymd') == date('Ymd', strtotime($payDetail->pay_addtimes))) {
continue;
}
$payObjectJson = [];
if (!empty($payDetail->join_pay_object_json)) {
$payObjectJson = json_decode($payDetail->join_pay_object_json, true);
}
// 创建赠送记录
PayDetail::insert([
'join_pay_member_id' => $payDetail->join_pay_member_id,
'join_pay_order_id' => $payDetail->join_pay_order_id,
'join_pay_object_json' => $payDetail->join_pay_object_json,
'pay_status' => $payDetail->pay_status,
'pay_category' => $payDetail->pay_category,
'pay_amount' => $payDetail->pay_amount,
'pay_paytimes' => date('Y-m-d H:i:s'),
'pay_prepayid' => $payDetail->pay_prepayid,
'pay_addtimes' => time()
]);
// 赠送加入账户余额
$account = MemberAccount::where('join_account_member_id', $member['member_id'])
->where('member_account_classify', 'CASH')
->first();
$account->member_account_income = $account->member_account_income + $payObjectJson['recharge_config']['nbr'];
$account->member_account_surplus = $account->member_account_surplus + $payObjectJson['recharge_config']['nbr'];
$account->save();
Log::info("加盟合伙人赠送成功");
_syslog("加盟合伙人", "赠送20%成功", false, ['member_id' => $member['member_id']], 1001);
}
}
}
} catch (\Exception $e) {
Log::error("加盟合伙人赠送失败", ['member_id' => $member['member_id'], 'msg' => $e->getMessage()]);
_syslog("加盟合伙人", "赠送20%失败", false, ['member_id' => $member['member_id'], 'msg' => $e->getMessage()], 1001);
}
}
/**
* 卡用完了
*/
public static function accountToDone($accountId, $surplus, $added)
{
try {
$account = MemberAccount::where('member_account_id', $accountId)
->where('member_account_classify', 'CARD')
->first();
if (!empty($account) && $surplus <= 0 && $added <= 0) {
// 卡已完成
$card = Card::where('join_card_member_account_id', $accountId)->first();
$cardExtendJson = [];
if (!empty($card->card_extend_json)) {
$cardExtendJson = json_decode($card->card_extend_json, true);
}
$cardExtendJson['done_time'] = date('Y-m-d H:i:s');
$card->card_status = 'DONE';
$card->card_extend_json = json_encode($cardExtendJson);
$card->save();
// 卡账户已完成
$account->member_account_status = 'DONE';
$account->save();
}
} catch (\Exception $e) {
Log::error("卡完成状态处理失败");
}
}
}