// +---------------------------------------------------------------------- namespace app\common\repositories\user; use app\common\dao\user\UserAssetsLogDao; use app\common\repositories\BaseRepository; use app\common\repositories\store\order\StoreOrderBaseRepository; use app\common\repositories\store\order\StoreOrderRepository; 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\MerchantCategoryRepository; 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 = 1; // 个人下单 const CHANGE_TYPE_SIGN = 2; // 签到 const CHANGE_TYPE_SHARE_EXCHANGE = 3; // 消费积分兑换分红点 const CHANGE_TYPE_SHARE_GET = 4; // 分红点返佣 const CHANGE_TYPE_SPREAD_GET = 5; // 推广返佣 const CHANGE_TYPE_CULTIVATE = 6; // 培育奖 const CHANGE_TYPE_AGENT = 7; // 区域代理奖 const CHANGE_TYPE_HUITONG = 8; // 惠通宝兑换消费积分 const CHANGE_TYPE_HUITONG_SEND = 9; // 转让他人 const CHANGE_TYPE_HUITONG_GET = 10; // 他人转让 const STATUS_FROZEN = 0; // 冻结 const STATUS_SUCCESS = 1; // 成功 const STATUS_REFUND = 2; // 退款 const STATUS_USED = 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_ORDER => '个人下单', self::CHANGE_TYPE_SIGN => '签到', self::CHANGE_TYPE_SHARE_EXCHANGE => '消费积分兑换分红点', self::CHANGE_TYPE_SHARE_GET => '分红点返佣', self::CHANGE_TYPE_SPREAD_GET => '推广返佣', self::CHANGE_TYPE_CULTIVATE => '培育奖', self::CHANGE_TYPE_AGENT => '区域代理奖', self::CHANGE_TYPE_HUITONG => '惠通宝兑换消费积分', self::CHANGE_TYPE_HUITONG_SEND => '转让他人', self::CHANGE_TYPE_HUITONG_GET => '他人转让', ); } public function getAssetType(){ return array( self::ASSET_TYPE_CONSUME => '消费积分', self::ASSET_TYPE_SHARE_POINT => '分红点', self::ASSET_TYPE_WELFARE => '福利积分', self::ASSET_TYPE_HUITONG => '惠通宝', self::ASSET_TYPE_CONTRIBUTION => '贡献值', ); } 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"} * {"name":"消费积分兑换分红点", "value":100, "key":"consume_to_share"} */ public function userPayEvent($groupOrder) { // 配置信息 $config = $this->userAssetsRepository->getConfig(); $baseList = array(); 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)); if($orderProduct['total_price']){ $rate = floatval($orderProduct['product_price']) / floatval($orderProduct['total_price']) * 100; if ($rate >= $product['cash_rate']) { $base += $product['base'] * $orderProduct['product_num']; } } } // 1. 用户资产 $this->userAssets($orderItem, $config, $base); if ($base) { $baseList[] = array('order_id' => $orderItem['order_id'], 'base' => $base); // 2. 项目经理资产 $startProjectUid = $this->projectAssets($orderItem, $config, $base); // 3. 培育经理资产 $this->breedAssets($startProjectUid, $orderItem['order_id'], $config, $base); // 4.区域代理资产 $this->agentAssets($orderItem['mer_id'], $orderItem['order_id'], $config, $base); // 5. 推荐资产 $this->recommendAssets($orderItem['mer_id'], $orderItem['order_id'], $config, $base); } // 6. 商户和平台资产 $this->merchantAndPlatformAssets($orderItem); } if ($baseList) { app(StoreOrderBaseRepository::class)->insertBase($baseList); } } public function merchantAndPlatformAssets($orderItem) { /** * @var UserRepository $userRepository */ $userRepository = app(UserRepository::class); $user = $userRepository->searchOne(['mer_id' => $orderItem['mer_id']]); if ($user) { $logList = array(); $welfare = $consume = $huitong = $contribution = 0; $consume = round($orderItem['total_price'] * $orderItem['commission_rate'] / 100, 2); $consume = $this->_getValue($consume); Log::info("+++++++++++++merchantAndPlatformAssets uid is ".$user['uid']); $logList[] = array( 'uid' => $user['uid'], 'asset_type' => self::ASSET_TYPE_CONSUME, 'type' => self::CHANGE_TYPE_ORDER, 'status' => self::STATUS_FROZEN, 'order_id' => $orderItem['order_id'], 'count' => $consume, 'mer_id' => $orderItem['mer_id'], ); if ($orderItem['integral']) { $welfare = round($orderItem['integral'] * (100 - $orderItem['commission_rate']) / 100, 2); $welfare = $this->_getValue($welfare); $logList[] = array( 'uid' => $user['uid'], 'asset_type' => self::ASSET_TYPE_WELFARE, 'type' => self::CHANGE_TYPE_ORDER, 'status' => self::STATUS_FROZEN, 'order_id' => $orderItem['order_id'], 'count' => $welfare, 'mer_id' => $orderItem['mer_id'], ); } $this->addLog($logList); $this->userAssetsRepository->orderEvent($user['uid'], self::STATUS_FROZEN, compact('consume', 'welfare', 'huitong', 'contribution')); } if ($orderItem['integral']) { $welfare = round($orderItem['integral'] * $orderItem['commission_rate'] / 100, 2); $welfare = $this->_getValue($welfare); $log = array( 'uid' => 0, 'asset_type' => self::ASSET_TYPE_WELFARE, 'type' => self::CHANGE_TYPE_ORDER, 'status' => self::STATUS_FROZEN, 'order_id' => $orderItem['order_id'], 'count' => $welfare, 'mer_id' => 0, ); $this->addLog([$log]); } } /** * 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_SPREAD_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($merId, $orderId, $config, $base) { $consume = $welfare = $huitong = $contribution = 0; $merRepository = app(MerchantRepository::class); $merchant = $merRepository->get($merId); if(empty($merchant)){ return ; } $districtArr = explode(',', $merchant['district_id']); if(count($districtArr) != 3){ return ; } $districtId = $districtArr[2]; Log::info("agentAssets districtId is {$districtId}"); /** * @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_AGENT, '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_CULTIVATE, '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_CULTIVATE, '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_CULTIVATE, '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_SPREAD_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_SPREAD_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_SPREAD_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. 本人的消费积分 if(floatval($orderItem['pay_price']) > 0){ $logList[] = array( 'uid' => $orderItem['uid'], 'asset_type' => self::ASSET_TYPE_CONSUME, 'type' => self::CHANGE_TYPE_ORDER, 'status' => self::STATUS_FROZEN, 'order_id' => $orderItem['order_id'], 'count' => $orderItem['pay_price'], ); } $consume = $orderItem['pay_price']; // 如果该订单奖励基数大于0 if ($base) { // 2. 本人的福利积分 $orderWelfare = round($base * $config['welfare_user'] / 100, 2); $welfare = $this->_getValue($orderWelfare); $logList[] = array( 'uid' => $orderItem['uid'], 'asset_type' => self::ASSET_TYPE_WELFARE, 'type' => self::CHANGE_TYPE_ORDER, '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, '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, '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')); // 5. 本人使用的福利积分 if ($orderItem['integral']) { $consume = $welfare = $huitong = $contribution = 0; $welfare = $orderItem['integral']; $log = array('uid' => $orderItem['uid'], 'asset_type' => self::ASSET_TYPE_WELFARE, 'type' => self::CHANGE_TYPE_ORDER, 'status' => self::STATUS_USED, 'order_id' => $orderItem['order_id'], 'count' => -$orderItem['integral'], ); $this->addLog([$log]); $this->userAssetsRepository->orderEvent($orderItem['uid'], self::STATUS_USED, compact('consume', 'welfare', 'huitong', 'contribution')); } } /** * 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); } /** * notes 订单退款事件处理 * @param $orderItem * @throws DataNotFoundException * @throws DbException * @throws ModelNotFoundException * @create 2024/3/19 11:01 * @update 2024/3/19 11:01 * @author zhangkxiang * @editor */ public function userRefundEvent($orderItem) { // 订单发送冻结资产收回 $refundList = $this->_getOrderData($orderItem['order_id'], self::STATUS_FROZEN); if ($refundList) { foreach ($refundList as $refund) { $this->userAssetsRepository->orderEvent($refund['uid'], self::STATUS_REFUND, $refund); } } // 返回用户支付的福利积分 $usedList = $this->_getOrderData($orderItem['order_id'], self::STATUS_USED); if ($usedList) { foreach ($usedList as $used) { if ($used['welfare']) { $info = $this->userAssetsRepository->get($used['uid']); $this->userAssetsRepository->update($used['uid'], array('welfare' => $info['welfare'] - $used['welfare'])); } } } // 退款删除订单 app(StoreOrderBaseRepository::class)->deleteByOrderId($orderItem['order_id']); // 更新该订单的所有数据为退款状态 $this->dao->updateOrderStatus($orderItem['order_id'], self::STATUS_REFUND); } private function _getOrderData($orderId, $status) { $data = $this->dao->orderData($orderId, ['status' => $status]); // 订单发送冻结资产收回 if (!$data->isEmpty()) { $list = array(); foreach ($data as $item) { if (!isset($list[$item['uid']])) { $list[$item['uid']] = array( 'uid' => $item['uid'], 'consume' => 0, 'welfare' => 0, 'huitong' => 0, 'contribution' => 0, ); } switch ($item['asset_type']) { case self::ASSET_TYPE_CONSUME: $list[$item['uid']]['consume'] += $item['count']; break; case self::ASSET_TYPE_WELFARE: $list[$item['uid']]['welfare'] += $item['count']; break; case self::ASSET_TYPE_HUITONG: $list[$item['uid']]['huitong'] += $item['count']; break; case self::ASSET_TYPE_CONTRIBUTION: $list[$item['uid']]['contribution'] += $item['count']; break; } } return $list; } return array(); } 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); $orderRepository = app(StoreOrderRepository::class); foreach ($data as $item) { $item['type'] = $changeType[$item['type']] ?? '未知'; $item['asset_type'] = $assetsType[$item['asset_type']] ?? '未知'; if($item['status'] == self::STATUS_REFUND){ $item['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'] = '未知'; } $item['order_sn'] = ''; $item['order'] = array(); if($item['order_id']){ $order = $orderRepository->getDetail($item['order_id']); $item['order_sn'] = $order['order_sn']; $item['order'] = $order; } $list[] = $item; } return compact('count', 'list'); } public function getSum($where){ return $this->dao->getSum($where); } }