From 513e4cded9b83f642e9413125d7cb38d773fb4d5 Mon Sep 17 00:00:00 2001 From: fengxinyhyl Date: Mon, 8 Apr 2024 00:27:15 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/common/dao/user/UserAssetsDao.php | 49 ++++ app/common/dao/user/UserAssetsLogDao.php | 65 +++++ app/common/model/user/UserAssets.php | 35 +++ app/common/model/user/UserAssetsLog.php | 40 ++++ .../system/merchant/MerchantRepository.php | 13 + .../user/UserAssetsLogRepository.php | 208 ++++++++++++++++ .../user/UserAssetsRepository.php | 225 ++++++++++++++++++ 7 files changed, 635 insertions(+) create mode 100644 app/common/dao/user/UserAssetsDao.php create mode 100644 app/common/dao/user/UserAssetsLogDao.php create mode 100644 app/common/model/user/UserAssets.php create mode 100644 app/common/model/user/UserAssetsLog.php create mode 100644 app/common/repositories/user/UserAssetsLogRepository.php create mode 100644 app/common/repositories/user/UserAssetsRepository.php diff --git a/app/common/dao/user/UserAssetsDao.php b/app/common/dao/user/UserAssetsDao.php new file mode 100644 index 0000000..0eaefed --- /dev/null +++ b/app/common/dao/user/UserAssetsDao.php @@ -0,0 +1,49 @@ + +// +---------------------------------------------------------------------- + + +namespace app\common\dao\user; + + +use app\common\dao\BaseDao; +use app\common\model\user\UserAssets; +use app\common\model\user\UserSpreadLog; + +class UserAssetsDao extends BaseDao +{ + protected function getModel(): string + { + return UserAssets::class; + } + + public function add($uid, $spread_uid, $old_spread_uid, $admin_id = 0) + { + $this->create(compact('uid', 'spread_uid', 'admin_id', 'old_spread_uid')); + } + + + public function getShareData(){ + $total = UserAssets::sum('share_point'); + $list = UserAssets::where('share_point','>',0)->field("uid, share_point")->select(); + if($total){ + return array('total'=>$total, 'list'=>$list->toArray()); + } + return array('total'=>0, 'list'=>[]); + } + + public function getTotalHuitong(){ + return UserAssets::sum('huitong'); + } + + public function getSum($field){ + return UserAssets::sum($field); + } +} diff --git a/app/common/dao/user/UserAssetsLogDao.php b/app/common/dao/user/UserAssetsLogDao.php new file mode 100644 index 0000000..925f5aa --- /dev/null +++ b/app/common/dao/user/UserAssetsLogDao.php @@ -0,0 +1,65 @@ + +// +---------------------------------------------------------------------- + + +namespace app\common\dao\user; + + +use app\common\dao\BaseDao; +use app\common\model\user\UserAssetsLog; + +class UserAssetsLogDao extends BaseDao +{ + /** + * notes + * @return UserAssetsLog + * @create 2024/3/18 15:16 + * @update 2024/3/18 15:16 + * @author zhangkxiang + * @editor + */ + protected function getModel(): string + { + return UserAssetsLog::class; + } + + public function add($uid, $spread_uid, $old_spread_uid, $admin_id = 0) + { + $this->create(compact('uid', 'spread_uid', 'admin_id', 'old_spread_uid')); + } + + + public function search(int $uid, array $where) + { + $userWhere = array(); + if($uid){ + $userWhere[] = array('uid', '=', $uid); + } + $query = UserAssetsLog::getDB()->where($userWhere)->where($where); + return $query; + } + + public function orderData(int $orderId, array $where) + { + return UserAssetsLog::getDB()->where('order_id', $orderId)->where($where)->group('uid, asset_type')->field('uid,asset_type, sum(count) as count')->select(); + } + + + public function updateOrderStatus($orderId, $status){ + return UserAssetsLog::where('order_id', $orderId)->update(array('status' => $status)); + } + + public function getSum($where){ + return UserAssetsLog::where($where)->sum('count'); + } + + +} diff --git a/app/common/model/user/UserAssets.php b/app/common/model/user/UserAssets.php new file mode 100644 index 0000000..88736ce --- /dev/null +++ b/app/common/model/user/UserAssets.php @@ -0,0 +1,35 @@ + +// +---------------------------------------------------------------------- + + +namespace app\common\model\user; + + +use app\common\model\BaseModel; + +class UserAssets extends BaseModel +{ + + public static function tablePk(): ?string + { + return 'uid'; + } + + public static function tableName(): string + { + return 'user_assets'; + } + + public function user() + { + return $this->hasOne(User::class, 'uid', 'uid'); + } +} diff --git a/app/common/model/user/UserAssetsLog.php b/app/common/model/user/UserAssetsLog.php new file mode 100644 index 0000000..e127832 --- /dev/null +++ b/app/common/model/user/UserAssetsLog.php @@ -0,0 +1,40 @@ + +// +---------------------------------------------------------------------- + + +namespace app\common\model\user; + + +use app\common\model\BaseModel; + +class UserAssetsLog extends BaseModel +{ + // 设置json类型字段 + protected $json = ['ext']; + + // 设置JSON数据返回数组 + protected $jsonAssoc = true; + + public static function tablePk(): ?string + { + return 'id'; + } + + public static function tableName(): string + { + return 'user_assets_log'; + } + + public function user() + { + return $this->hasOne(User::class, 'uid', 'uid'); + } +} diff --git a/app/common/repositories/system/merchant/MerchantRepository.php b/app/common/repositories/system/merchant/MerchantRepository.php index 4c812f3..c5a9fb8 100755 --- a/app/common/repositories/system/merchant/MerchantRepository.php +++ b/app/common/repositories/system/merchant/MerchantRepository.php @@ -29,6 +29,8 @@ use app\common\repositories\store\shipping\ShippingTemplateRepository; use app\common\repositories\store\StoreCategoryRepository; use app\common\repositories\system\attachment\AttachmentCategoryRepository; use app\common\repositories\system\attachment\AttachmentRepository; +use app\common\repositories\system\config\ConfigClassifyRepository; +use app\common\repositories\system\config\ConfigValueRepository; use app\common\repositories\system\operate\OperateLogRepository; use app\common\repositories\system\serve\ServeOrderRepository; use app\common\repositories\user\UserBillRepository; @@ -250,6 +252,17 @@ class MerchantRepository extends BaseRepository app()->make(ShippingTemplateRepository::class)->createDefault($merchant->mer_id); app()->make(ProductCopyRepository::class)->defaulCopyNum($merchant->mer_id); + /** @var ConfigClassifyRepository $make */ + $make = app()->make(ConfigClassifyRepository::class); + $cid = $make->keyById("integral"); + if($cid){ + $children = array_column($make->children($cid, 'config_classify_id')->toArray(), 'config_classify_id'); + $children[] = $cid; + + $configValue = app()->make(ConfigValueRepository::class); + $configValue->save($children, array('mer_integral_rate' => 100, 'mer_integral_status' => '1'), $merchant['mer_id']); + } + // 记录商户创建日志 if (!empty($admin_info) && !empty($update_infos)) { event('create_operate_log', [ diff --git a/app/common/repositories/user/UserAssetsLogRepository.php b/app/common/repositories/user/UserAssetsLogRepository.php new file mode 100644 index 0000000..f7b22c4 --- /dev/null +++ b/app/common/repositories/user/UserAssetsLogRepository.php @@ -0,0 +1,208 @@ + +// +---------------------------------------------------------------------- + + +namespace app\common\repositories\user; + + +use app\common\dao\user\UserAssetsLogDao; +use app\common\repositories\BaseRepository; +use app\common\repositories\store\product\ProductRepository; +use app\common\repositories\system\groupData\GroupDataRepository; +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_INTEGRAL = 1; // 积分 + const ASSET_TYPE_DIAMOND = 2; // 钻石 + const ASSET_TYPE_STOCK = 3; // 本票 + + const CHANGE_TYPE_RECOMMEND_PRODUCT = 1; // 爆单商品 + const CHANGE_TYPE_SHARE = 2; // 分享奖 + const CHANGE_TYPE_SERVER = 3; // 服务奖 + const CHANGE_TYPE_SAVE = 4; // 预存 + const CHANGE_TYPE_WITHDRAW = 5; // 积分提现 + const CHANGE_TYPE_INTEGRAL_SEND = 6; // 积分转让 + const CHANGE_TYPE_INTEGRAL_GET = 7; // 积分接收 + const CHANGE_TYPE_DIAMOND_SEND = 8; // 钻石转让 + const CHANGE_TYPE_DIAMOND_GET = 9; // 钻石接收 + const CHANGE_TYPE_DIAMOND_LOTTERY = 10; // 抽奖 + const CHANGE_TYPE_DIAMOND = 11; // 兑换钻石 + const CHANGE_TYPE_STOCK = 12; // 兑换本票 + + const STATUS_GET = 1; // 获取 + const STATUS_USE = 2; // 使用 + const STATUS_WITHDRAW = 3; // 提现 + + + 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_RECOMMEND_PRODUCT => '爆单商品', + self::CHANGE_TYPE_SHARE => '分享奖', + self::CHANGE_TYPE_SERVER => '服务奖', + self::CHANGE_TYPE_SAVE => '预存', + self::CHANGE_TYPE_WITHDRAW => '积分提现', + self::CHANGE_TYPE_INTEGRAL_SEND => '积分转让', + self::CHANGE_TYPE_INTEGRAL_GET => '积分接收', + self::CHANGE_TYPE_DIAMOND_SEND => '钻石转让', + self::CHANGE_TYPE_DIAMOND_GET => '钻石接收', + self::CHANGE_TYPE_DIAMOND_LOTTERY => '抽奖', + self::CHANGE_TYPE_DIAMOND => '兑换钻石', + self::CHANGE_TYPE_STOCK => '兑换本票', + ); + } + + public function getAssetType() + { + return array( + self::ASSET_TYPE_INTEGRAL => '积分', + self::ASSET_TYPE_DIAMOND => '钻石', + self::ASSET_TYPE_STOCK => '本票', + ); + } + + 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 $orderItem + * @throws DataNotFoundException + * @throws DbException + * @throws ModelNotFoundException + * @create 2024/3/19 15:03 + * @update 2024/3/19 15:03 + * @author zhangkxiang + * @editor + */ + public function userTakeEvent($orderItem) + { + // 订单发送冻结资产发放 + $refundList = $this->_getOrderData($orderItem['order_id'], self::STATUS_FROZEN); + if ($refundList) { + foreach ($refundList as $refund) { + $this->userAssetsRepository->orderEvent($refund['uid'], self::STATUS_SUCCESS, $refund); + } + } + + // 更新该订单的所有数据为退款状态 + $this->dao->updateOrderStatus($orderItem['order_id'], self::STATUS_SUCCESS); + } + + + 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)->order('id desc')->select(); + $list = array(); + $changeType = $this->getChangeType(); + $assetsType = $this->getAssetType(); + $userRepository = app(UserRepository::class); + foreach ($data as $item) { + $item['type'] = $changeType[$item['type']] ?? '未知'; + $item['asset_type'] = $assetsType[$item['asset_type']] ?? '未知'; + if ($item['count'] > 0) { + $item['count'] = "+" . $item['count']; + } + $user = $userRepository->get($item['uid']); + if ($user) { + $item['user_nickname'] = $user['nickname']; + $item['user_phone'] = $user['phone']; + } else { + $item['user_nickname'] = '平台'; + $item['user_phone'] = '未知'; + } + $list[] = $item; + } + return compact('count', 'list'); + } + + + public function getSum($where) + { + return $this->dao->getSum($where); + } +} diff --git a/app/common/repositories/user/UserAssetsRepository.php b/app/common/repositories/user/UserAssetsRepository.php new file mode 100644 index 0000000..a7620f9 --- /dev/null +++ b/app/common/repositories/user/UserAssetsRepository.php @@ -0,0 +1,225 @@ + +// +---------------------------------------------------------------------- + + +namespace app\common\repositories\user; + + +use app\common\dao\user\UserAssetsDao; +use app\common\repositories\BaseRepository; +use app\common\repositories\system\groupData\GroupDataRepository; +use think\db\exception\DataNotFoundException; +use think\db\exception\DbException; +use think\db\exception\ModelNotFoundException; + +/** + * @mixin UserAssetsDao + */ +class UserAssetsRepository extends BaseRepository +{ + + + public function __construct(UserAssetsDao $dao) + { + $this->dao = $dao; + } + + public function getConfig() + { + // 配置信息 + /** + * @var GroupDataRepository $groupDataRepository + */ + $groupDataRepository = app()->make(GroupDataRepository::class); + $config = $groupDataRepository->getGroupDataLst(0, 100, 1, 100); + return array_column($config['list'], "value", 'key'); + } + + + /** + * notes 获取用户资产 + * @param $uid + * @return array + * @create 2024/3/18 14:48 + * @update 2024/3/18 14:48 + * @author zhangkxiang + * @editor + */ + public function assets($uid) + { + $item = $this->dao->get($uid); + if ($item) { + return $item->toArray(); + }else{ + $ret = array( + 'uid' => $uid, + 'integral_buy' => 0.00, + 'integral_withdraw' => 0.00, + 'diamond' => 0.00, + 'stock' => 0.00, + ); + $this->dao->create($ret); + return $ret; + } + + } + + + /** + * notes + * @param $uid + * @param $count + * @throws DataNotFoundException + * @throws DbException + * @throws ModelNotFoundException + * @create 2024/3/19 22:33 + * @update 2024/3/19 22:33 + * @author zhangkxiang + * @editor + */ + public function consumeToShare($uid, $count) + { + $config = $this->getConfig(); + $assets = $this->assets($uid); + if ($assets['consume'] < $config['consume_to_share'] * $count) { + throw new \Exception('消费积分不足'); + } + $logList = array(); + $consume = -1 * $config['consume_to_share'] * $count; + $logList[] = array( + 'uid' => $uid, + 'asset_type' => UserAssetsLogRepository::ASSET_TYPE_CONSUME, + 'type' => UserAssetsLogRepository::CHANGE_TYPE_SHARE_EXCHANGE, + 'status' => UserAssetsLogRepository::STATUS_SUCCESS, + 'count' => $consume, + ); + $logList[] = array( + 'uid' => $uid, + 'asset_type' => UserAssetsLogRepository::ASSET_TYPE_SHARE_POINT, + 'type' => UserAssetsLogRepository::CHANGE_TYPE_SHARE_EXCHANGE, + 'status' => UserAssetsLogRepository::STATUS_SUCCESS, + 'count' => $count, + ); + app()->make(UserAssetsLogRepository::class)->addLog($logList); + $this->dao->update($uid, array('consume' => $assets['consume'] + $consume, 'share_point' => $assets['share_point'] + $count, 'share_point_time' => time())); + } + + + /** + * notes 惠通宝转账 + * @param $uid + * @param $phone + * @param $count + * @throws DataNotFoundException + * @throws DbException + * @throws ModelNotFoundException + * @create 2024/3/20 11:01 + * @update 2024/3/20 11:01 + * @author zhangkxiang + * @editor + */ + public function sendHuitong($uid, $phone, $count) + { + $assets = $this->assets($uid); + if ($assets['huitong'] < $count) { + throw new \Exception('惠通宝不足'); + } + /** + * @var UserRepository $userRepository + */ + $userRepository = app()->make(UserRepository::class); + $toUser = $userRepository->getUserByPhone($phone); + if (!$toUser) { + throw new \Exception('用户不存在'); + } + + $fromUser = $userRepository->get($uid); + + $logList[] = array( + 'uid' => $toUser['uid'], + 'asset_type' => UserAssetsLogRepository::ASSET_TYPE_HUITONG, + 'type' => UserAssetsLogRepository::CHANGE_TYPE_HUITONG_GET, + 'status' => UserAssetsLogRepository::STATUS_SUCCESS, + 'count' => $count, + 'ext' => array( + 'from_uid' => $uid, + 'from_phone' => $fromUser['phone'], + ), + ); + $logList[] = array( + 'uid' => $uid, + 'asset_type' => UserAssetsLogRepository::ASSET_TYPE_HUITONG, + 'type' => UserAssetsLogRepository::CHANGE_TYPE_HUITONG_SEND, + 'status' => UserAssetsLogRepository::STATUS_SUCCESS, + 'count' => -1 * $count, + 'ext' => array( + 'to_uid' => $toUser['uid'], + 'to_phone' => $toUser['phone'], + ), + ); + app()->make(UserAssetsLogRepository::class)->addLog($logList); + $this->dao->update($uid, array('huitong' => $assets['huitong'] - $count)); + $toAssets = $this->assets($toUser['uid']); + $this->dao->update($toUser['uid'], array('huitong' => $toAssets['huitong'] + $count)); + } + + + /** + * notes + * @param $uid + * @param $count + * @throws DataNotFoundException + * @throws DbException + * @throws ModelNotFoundException + * @create 2024/3/19 22:33 + * @update 2024/3/19 22:33 + * @author zhangkxiang + * @editor + */ + public function huitongToConsume($uid, $count) + { + $current = app(HuitongRepository::class)->getCurrent(); + $assets = $this->assets($uid); + if ($assets['huitong'] < $count) { + throw new \Exception('惠通宝不足'); + } + $logList = array(); + $consume = $current * $count; + $logList[] = array( + 'uid' => $uid, + 'asset_type' => UserAssetsLogRepository::ASSET_TYPE_CONSUME, + 'type' => UserAssetsLogRepository::CHANGE_TYPE_HUITONG, + 'status' => UserAssetsLogRepository::STATUS_SUCCESS, + 'count' => $consume, + ); + $huitong = -1 * $count; + $logList[] = array( + 'uid' => $uid, + 'asset_type' => UserAssetsLogRepository::ASSET_TYPE_HUITONG, + 'type' => UserAssetsLogRepository::CHANGE_TYPE_HUITONG, + 'status' => UserAssetsLogRepository::STATUS_SUCCESS, + 'count' => $huitong, + ); + app()->make(UserAssetsLogRepository::class)->addLog($logList); + $this->dao->update($uid, array('consume' => $assets['consume'] + $consume, 'huitong' => $assets['huitong'] + $huitong)); + } + + + public function getSum($field) + { + return $this->dao->getSum($field); + } + + public function getWhereCount($where) + { + return $this->dao->getWhereCount($where); + } +}