<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team < admin @ crmeb . com >
// +----------------------------------------------------------------------
namespace app\common\repositories\user;
use app\common\dao\user\UserAssetsLogDao;
use app\common\repositories\BaseRepository;
use app\common\repositories\store\product\ProductAssistRepository;
use app\common\repositories\store\product\ProductRepository;
use app\common\repositories\system\groupData\GroupDataRepository;
use app\common\repositories\system\merchant\MerchantRepository;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\facade\Log;
/**
* @mixin UserAssetsLogDao
*/
class UserAssetsLogRepository extends BaseRepository
{
const ASSET_TYPE_CONSUME = 1; // 消费积分
const ASSET_TYPE_SHARE_POINT = 2; // 分红点
const ASSET_TYPE_WELFARE = 3; // 福利积分
const ASSET_TYPE_HUITONG = 4; // 惠通宝
const ASSET_TYPE_CONTRIBUTION = 5; // 贡献值
const CHANGE_TYPE_ORDER_GET = 1; // 订单获取
const CHANGE_TYPE_SIGN = 2; // 签到
const CHANGE_TYPE_SHARE = 3; // 分红
const CHANGE_TYPE_ORDER_PAY = 4; // 订单消费
const CHANGE_TYPE_SPREAD = 5; // 推广
const CHANGE_TYPE_CULTIVATE = 6; // 培育
const CHANGE_TYPE_TRANSFER = 7; // 赠与
const CHANGE_TYPE_EXCHANGE = 8; // 兑换
const STATUS_FROZEN = 0; // 冻结
const STATUS_SUCCESS = 1; // 成功
const STATUS_REFUND = 2; // 退款
public function __construct(UserAssetsLogDao $dao, UserAssetsRepository $userAssetsRepository, ProductRepository $productRepository, GroupDataRepository $groupRepository)
{
$this->dao = $dao;
$this->userAssetsRepository = $userAssetsRepository;
$this->productRepository = $productRepository;
$this->groupDataRepository = $groupRepository;
}
/**
* notes 获取资产变动类型
* @return string[]
* @create 2024/3/15 15:30
* @update 2024/3/15 15:30
* @author zhangkxiang
* @editor
*/
public function getChangeType()
{
return array(
self::CHANGE_TYPE_ORDER_GET => "订单获取",
self::CHANGE_TYPE_SIGN => "签到",
self::CHANGE_TYPE_SHARE => "分红",
self::CHANGE_TYPE_ORDER_PAY => "订单消费",
self::CHANGE_TYPE_SPREAD => "推广",
self::CHANGE_TYPE_CULTIVATE => "培育",
self::CHANGE_TYPE_TRANSFER => "赠与",
self::CHANGE_TYPE_EXCHANGE => "兑换",
);
}
public function getList(array $where, $page, $limit)
{
$query = $this->dao->search($where);
$count = $query->count();
$list = $query->page($page, $limit)->with(['spread' => function ($query) {
$query->field('uid,nickname,avatar');
}])->select();
return compact('count', 'list');
}
/**
* notes 用户支付订单时间处理
* @param $groupOrder
* @create 2024/3/15 17:22
* @update 2024/3/15 17:22
* @author zhangkxiang
* @editor
*
* {"name":"福利积分--项目经理", "value":10, "key":"welfare_project"}
* {"name":"福利积分--一星经理", "value":30, "key":"welfare_project_1"}
* {"name":"福利积分--二星经理", "value":50, "key":"welfare_project_2"}
* {"name":"福利积分--三星经理", "value":80, "key":"welfare_project_3"}
* {"name":"贡献值--用户", "value":1, "key":"contribution_user"}
* {"name":"贡献值--项目经理", "value":1, "key":"contribution_project"}
* {"name":"贡献值--一星经理", "value":2, "key":"contribution_project_1"}
* {"name":"贡献值--二星经理", "value":3, "key":"contribution_project_2"}
* {"name":"贡献值--三星经理", "value":4, "key":"contribution_project_3"}
* {"name":"惠通宝--用户", "value":5, "key":"huitong_user"}
* {"name":"惠通宝--项目经理", "value":10, "key":"huitong_project"}
* {"name":"惠通宝--一星经理", "value":30, "key":"huitong_project_1"}
* {"name":"惠通宝--二星经理", "value":50, "key":"huitong_project_2"}
* {"name":"惠通宝--三星经理", "value":80, "key":"huitong_project_3"}
* {"name":"福利积分--区域代理--区域代理奖", "value":1, "key":"welfare_agent"}
* {"name":"福利积分--区域代理--推荐商家奖", "value":1, "key":"welfare_agent_recommend"}
* {"name":"福利积分--项目经理--推荐商家奖", "value":1, "key":"welfare_project_recommend"}
* {"name":"福利积分--商户--推荐商家奖", "value":1, "key":"welfare_merchant_recommend"}
* {"name":"惠通宝增值幅度比例配置", "value":10, "key":"huitong_add"}
* {"name":"福利积分--存在分红点用户奖励", "value":10, "key":"share_award"}
*/
public function userPayEvent($groupOrder)
{
// 配置信息
$config = $this->groupDataRepository->getGroupDataLst(0, 100, 1, 100);
$config = array_column($config['list'], "value", 'key');
foreach ($groupOrder['orderList'] as $orderItem) {
$base = 0;
foreach ($orderItem['orderProduct'] as $orderProduct) {
// 获取商品详情(奖励积分
$product = $this->productRepository->detail($orderProduct['product_id'], null);
Log::info("product" . json_encode($product));
$rate = floatval($orderProduct['total_price']) / floatval($orderProduct['product_price']) * 100;
if ($rate >= $product['cash_rate']) {
$base += $product['base'];
}
}
// 1. 用户资产
$this->userAssets($orderItem, $config, $base);
if ($base) {
// 2. 项目经理资产
$startProjectUid = $this->projectAssets($orderItem, $config, $base);
// 3. 培育经理资产
$this->breedAssets($startProjectUid, $orderItem['order_id'], $config, $base);
// 4.区域代理资产
$this->agentAssets($orderItem['district_id'], $orderItem['order_id'], $config, $base);
// 5. 推荐资产
$this->recommendAssets($orderItem['mer_id'], $orderItem['order_id'], $config, $base);
}
// 6. 商户和平台资产
// $this->merchantAndPlatformAssets($orderItem);
}
}
public function merchantAndPlatformAssets($orderItem){
/**
* @var MerchantRepository $merchantRepository
*/
$merchantRepository = app(MerchantRepository::class);
$merchant = $merchantRepository->get($orderItem['mer_id']);
if(empty($merchant)){
return;
}
/**
* @var UserRepository $userRepository
*/
$userRepository = app(UserRepository::class);
$user = $userRepository->searchOne(['phone' => $merchant['mer_phone']]);
$logList = array();
$welfare = $huitong = $contribution = 0;
if($user){
$logList[] = array(
'uid' => $user['uid'],
'asset_type' => self::ASSET_TYPE_WELFARE,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderItem['order_id'],
'count' => $welfare,
'mer_id' => $merchant['id'],
);
}
}
/**
* notes 推荐资产
* @param $merId
* @param $orderId
* @param $config
* @param $base
* @throws DataNotFoundException
* @throws DbException
* @throws ModelNotFoundException
* @create 2024/3/17 23:08
* @update 2024/3/17 23:08
* @author zhangkxiang
* @editor
*/
public function recommendAssets($merId, $orderId, $config, $base){
$consume = $welfare = $huitong = $contribution = 0;
/**
* @var MerchantRepository $merRepository
*/
$merRepository = app(MerchantRepository::class);
$merchant = $merRepository->get($merId);
if (empty($merchant)) {
return;
}
if($merchant['spread_uid'] == 0){
return;
}
/**
* @var UserRepository $userRepository
*/
$userRepository = app(UserRepository::class);
$user = $userRepository->get($merchant['spread_uid']);
if (empty($user)) {
return;
}
$log= array(
'uid' => $user['uid'],
'asset_type' => self::ASSET_TYPE_WELFARE,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
);
if($user['agent_district_id']){
// 区域代理
$orderWelfare = round($base * $config['welfare_agent_recommend'] / 100, 2);
$welfare = $this->_getValue($orderWelfare);
$ext = array('district_id' => $user['agent_district_id'], 'name' => "区域代理推荐商家");
}elseif ($user['group_id']){
// 项目经理
$orderWelfare = round($base * $config['welfare_project_recommend'] / 100, 2);
$welfare = $this->_getValue($orderWelfare);
$ext = array('group_id' => $user['group_id'], 'name' => "项目经理推荐商家");
}elseif ($user['mer_id']){
// 商家
$orderWelfare = round($base * $config['welfare_merchant_recommend'] / 100, 2);
$welfare = $this->_getValue($orderWelfare);
$ext = array('mer_id' => $user['mer_id'], 'name' => "商家推荐商家");
} else{
return ;
}
$log['count'] = $welfare;
$log['ext'] = $ext;
$this->addLog([$log]);
$this->userAssetsRepository->orderEvent($user['uid'], self::STATUS_FROZEN, compact('consume', 'welfare', 'huitong', 'contribution'));
}
/**
* notes 区域推荐奖励
* @param $districtId
* @param $orderId
* @param $config
* @param $base
* @throws DataNotFoundException
* @throws DbException
* @throws ModelNotFoundException
* @create 2024/3/17 22:49
* @update 2024/3/17 22:49
* @author zhangkxiang
* @editor
*/
public function agentAssets($districtId, $orderId, $config, $base){
$consume = $welfare = $huitong = $contribution = 0;
/**
* @var UserRepository $userRepository
*/
$userRepository = app(UserRepository::class);
$user = $userRepository->getWhere(array('agent_district_id' => $districtId));
if (empty($user)) {
return;
}
// 1. 项目经理的福利积分
$orderWelfare = round($base * $config['welfare_agent'] / 100, 2);
$welfare = $this->_getValue($orderWelfare);
$logList[] = array(
'uid' => $user['uid'],
'asset_type' => self::ASSET_TYPE_WELFARE,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
'count' => $welfare,
'ext' => array('district_id' => $districtId, 'name' => "区域代理"),
);
$this->addLog($logList);
$this->userAssetsRepository->orderEvent($user['uid'], self::STATUS_FROZEN, compact('consume', 'welfare', 'huitong', 'contribution'));
}
/**
* notes
* @param $startProjectUid
* @param $orderId
* @param $config
* @param $base
* @throws DataNotFoundException
* @throws DbException
* @throws ModelNotFoundException
* @create 2024/3/17 19:32
* @update 2024/3/17 19:32
* @author zhangkxiang
* @editor
*/
public function breedAssets($startProjectUid, $orderId, $config, $base)
{
$consume = 0;
$userRepository = app(UserRepository::class);
$userProject = $userRepository->get($startProjectUid);
if (empty($userProject)) {
return;
}
if ($userProject['group_id'] > 4 or $userProject['group_id'] < = 1) {
return;
}
$group = $userProject['group_id'] - 1;
// 1. 项目经理的福利积分
$orderWelfare = round($base * $config['welfare_project'] * $config['welfare_project_' . $group] / 10000, 2);
$welfare = $this->_getValue($orderWelfare);
$logList[] = array(
'uid' => $userProject['uid'],
'asset_type' => self::ASSET_TYPE_WELFARE,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
'count' => $welfare,
);
// 2. 项目经理的惠通宝
$orderHuitong = round($base * $config['huitong_project'] * $config['huitong_project_' . $group] / 10000, 2);
$huitong = $this->_getValue($orderHuitong);
$logList[] = array(
'uid' => $userProject['uid'],
'asset_type' => self::ASSET_TYPE_HUITONG,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
'count' => $huitong,
);
// 3. 项目经理的贡献值
$orderContribution = round($base * $config['contribution_project'] * $config['contribution_project_' . $group] / 10000, 2);
$contribution = $this->_getValue($orderContribution);
$logList[] = array(
'uid' => $userProject['uid'],
'asset_type' => self::ASSET_TYPE_CONTRIBUTION,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
'count' => $contribution,
);
$this->addLog($logList);
$this->userAssetsRepository->orderEvent($userProject['uid'], self::STATUS_FROZEN, compact('consume', 'welfare', 'huitong', 'contribution'));
}
/**
* notes
* @param $orderItem
* @param $config
* @param $base
* @create 2024/3/17 19:32
* @update 2024/3/17 19:32
* @author zhangkxiang
* @editor
*/
public function projectAssets($orderItem, $config, $base)
{
$consume = 0;
$uid = $orderItem['uid'];
$orderId = $orderItem['order_id'];
$userProject = null;
$userRepository = app(UserRepository::class);
$user = $userRepository->get($uid);
if (empty($user)) {
return 0;
}
// 查找第一个项目经理
while (!$userProject) {
$user = $userRepository->get($user['spread_uid']);
if (empty($user)) {
return 0;
}
if ($user['group_id']) {
$userProject = $user;
}
}
if (empty($userProject)) {
return 0;
}
$logList = array();
// 1. 项目经理的福利积分
$orderWelfare = round($base * $config['welfare_project'] / 100, 2);
$welfare = $this->_getValue($orderWelfare);
$logList[] = array(
'uid' => $userProject['uid'],
'asset_type' => self::ASSET_TYPE_WELFARE,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
'count' => $welfare,
);
// 2. 项目经理的惠通宝
$orderHuitong = round($base * $config['huitong_project'] / 100, 2);
$huitong = $this->_getValue($orderHuitong);
$logList[] = array(
'uid' => $userProject['uid'],
'asset_type' => self::ASSET_TYPE_HUITONG,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
'count' => $huitong,
);
// 3. 项目经理的贡献值
$orderContribution = round($base * $config['contribution_project'] / 100, 2);
$contribution = $this->_getValue($orderContribution);
$logList[] = array(
'uid' => $userProject['uid'],
'asset_type' => self::ASSET_TYPE_CONTRIBUTION,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderId,
'count' => $contribution,
);
$this->addLog($logList);
$this->userAssetsRepository->orderEvent($userProject['uid'], self::STATUS_FROZEN, compact('consume', 'welfare', 'huitong', 'contribution'));
return $userProject['spread_uid'];
}
/**
* notes 用户资产变动
* @param $orderItem
* @param $config
* @param $base
* @throws DataNotFoundException
* @throws DbException
* @throws ModelNotFoundException
* @create 2024/3/17 17:06
* @update 2024/3/17 17:06
* @author zhangkxiang
* @editor
*/
public function userAssets($orderItem, $config, $base)
{
$logList = array();
$welfare = $huitong = $contribution = 0;
// 1. 本人的消费积分
$logList[] = array(
'uid' => $orderItem['uid'],
'asset_type' => self::ASSET_TYPE_CONSUME,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderItem['order_id'],
'count' => $orderItem['pay_price'],
);
$consume = $orderItem['pay_price'];
// 如果该订单奖励基数大于0
if ($base) {
// 2. 本人的福利积分
$orderWelfare = round($base * 0.1, 2);
$welfare = $this->_getValue($orderWelfare);
$logList[] = array(
'uid' => $orderItem['uid'],
'asset_type' => self::ASSET_TYPE_WELFARE,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderItem['order_id'],
'count' => $welfare,
);
// 3. 本人的惠通宝
$orderHuitong = round($base * $config['huitong_user'] / 100, 2);
$huitong = $this->_getValue($orderHuitong);
$logList[] = array(
'uid' => $orderItem['uid'],
'asset_type' => self::ASSET_TYPE_HUITONG,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderItem['order_id'],
'count' => $huitong,
);
// 4. 本人的贡献值
$orderContribution = round($base * $config['contribution_user'] / 100, 2);
$contribution = $this->_getValue($orderContribution);
$logList[] = array(
'uid' => $orderItem['uid'],
'asset_type' => self::ASSET_TYPE_CONTRIBUTION,
'type' => self::CHANGE_TYPE_ORDER_GET,
'status' => self::STATUS_FROZEN,
'order_id' => $orderItem['order_id'],
'count' => $contribution,
);
}
$this->addLog($logList);
$this->userAssetsRepository->orderEvent($orderItem['uid'], self::STATUS_FROZEN, compact('consume', 'welfare', 'huitong', 'contribution'));
}
private function _getValue($value){
if($value < 0.01 ) {
return 0.01;
}
return $value;
}
/**
* notes 插入变动日志，如果小于0.01则插入0.01
* @param $list
* @create 2024/3/17 22:09
* @update 2024/3/17 22:09
* @author zhangkxiang
* @editor
*/
public function addLog($list)
{
foreach ($list as $key => $item) {
$list[$key]['ext'] = $item['ext'] ?? array();
}
$this->dao->insertAll($list);
}
/**
* notes 获取资产变动日志
* @param $uid
* @param $where
* @param $page
* @param $limit
* @return array
* @throws DataNotFoundException
* @throws DbException
* @throws ModelNotFoundException
* @create 2024/3/18 17:37
* @update 2024/3/18 17:37
* @author zhangkxiang
* @editor
*/
public function list($uid, $where, $page, $limit){
$query = $this->dao->search($uid, $where);
$count = $query->count();
$data = $query->page($page, $limit)->select();
$list = array();
$changeType = $this->getChangeType();
foreach ($data as $item){
$item['type'] = $changeType[$item['type']];
$list[] = $item;
}
return compact('count', 'list');
}
public function userRefund()
{
}
}
