$this->mall_id], ['addons_name' => GroupBuyEnum::ADDONS_NAME], ['status' => StatusEnum::ENABLED]]); if ($data == false) return $this->error(AddonsMarketingSetting::getStaticError()); return $this->success('', $data); } /** * @desc:拼团商品列表 * @Author: hua * @Date: 2021/12/14 * @Time: 15:52 * @Copyright: copyright (c) 2021 广东七件事集团 * @return mixed|void */ public function actionActiveList() { $get = \Yii::$app->request->get(); $where[] = ['mall_id' => $this->mall_id]; $where[] = ['status' => StatusEnum::ENABLED]; if (isset($get['group_status'])) { $where[] = ['group_status' => $get['group_status']]; } else { $where[] = ['group_status' => [GroupBuyEnum::NOT_STARTED, GroupBuyEnum::OPEN_GROUP]]; } if (!empty($get['cate_id'])) $where[] = ['cate_id' => $get['cate_id']]; if (isset($get['id'])) $where[] = ['id' => json_decode($get['id'], true)]; $list = GroupBuyActive::getActiveList($where, true); $list['group_status_map'] = GroupBuyEnum::getGroupStatusMap(); return $this->success('操作成功', $list); } /** * @desc:商品详情 * @Author: hua * @Date: 2021/12/14 * @Time: 16:01 * @Copyright: copyright (c) 2021 广东七件事集团 */ public function actionActiveGoodsDetail() { $get = \Yii::$app->request->get(); $res = \Yii::$app->services->validate->validate($get, [ [['active_id'], 'required'], ]); if ($res === false) return $this->error(\Yii::$app->services->validate->getErrorMessage()); $where[] = ['mall_id' => $this->mall_id]; $where[] = ['id' => $get['active_id']]; $with = [ 'activeGoodsAttr' => function ($query) { $query->where(['status' => StatusEnum::ENABLED]) ->select('id,group_buy_active_id,attr_id,group_buy_price,stock')->indexBy('attr_id'); } ]; //查询拼团活动 $group_buy_active = GroupBuyActive::getOne($where, true, $with, false, 'id,goods_id,status,effective_time,group_size,limit_buy_num,total_num,start_at,end_at,group_status, restrict_rule_num'); if ($group_buy_active == false) return $this->error(GroupBuyActive::getStaticError()); if($group_buy_active['status']==StatusEnum::DISABLED) return $this->error('活动已禁用'); if($group_buy_active['status']==StatusEnum::DELETE) return $this->error('活动已删除'); $group_buy_active['surplus_stock'] = array_sum(array_column($group_buy_active['activeGoodsAttr'], 'stock'));//剩余库存 $select = 'id,is_on_sale,goods_name,price,original_price,unit,attr_groups_format,attr_groups,area_limit,is_attr,is_show_stock,video_url,stock,video_cover_pic,cover_pic,bannar_pic,sales_num,virtual_sales,is_show_sales,detail,services'; $params['mall_id'] = $this->mall_id; $params['where'] = [['id' => $group_buy_active['goods_id']], ['mall_id' => $this->mall_id], ['status' => StatusEnum::ENABLED]]; $params['is_array'] = true; $params['with'] = ['attr' => function ($query) { $query->orderBy('price asc')->select('id,goods_id,goods_no,name,original_price,pic_url,price,sign_id,sort,status,version,weight,stock,is_show'); }]; $params['order'] = false; $params['select'] = $select; //查询商品 $goods = Goods::getGoodsDetail($params); unset($goods['is_member_price']); unset($goods['price_type']); $goods['attr_id'] = 0; //把拼团价,拼团库存放置商品数组 foreach ($goods['attr'] as &$item) { $item['group_buy_price'] = $group_buy_active['activeGoodsAttr'][$item['id']]['group_buy_price']; $item['group_buy_stock'] = $group_buy_active['activeGoodsAttr'][$item['id']]['stock']; $goods['attr_id'] <= 0 && $item['is_show'] == StatusEnum::ENABLED && $goods['attr_id'] = $item['id']; } $params = []; $params['where'] = [ ['mall_id' => $this->mall_id], ['group_buy_active_id' => $get['active_id']], ['is_commander' => GroupBuyEnum::IS_COMMANDER], ['order_status' => GroupBuyEnum::OPEN_GROUP], ]; $params['select'] = 'id as open_group_id,commander_id,user_id,group_buy_active_id,created_at'; $params['with'] = [ 'user' => function ($query) { $query->select('id,nickname,avatar_url'); }, 'groupBuyActive' => function ($query) { $query->select('id,effective_time,group_size,is_virtual,virtual_group_size'); } ]; //查询正在开团的活动 $commander_list = GroupBuyOrder::lists($params); //开团列表 if (!empty($commander_list)) { $time = time(); $open_group_id_arr = array_column($commander_list, 'open_group_id'); $params = []; $params['where'] = [ ['mall_id' => $this->mall_id], ['open_group_id' => $open_group_id_arr], ['order_status' => GroupBuyEnum::OPEN_GROUP], ]; $params['order'] = 'id asc'; $group_buy_order_list = GroupBuyOrder::lists($params); $user_id_arr = array_column($group_buy_order_list, 'user_id'); $user_list = User::lists(['where' => [['id' => $user_id_arr]], 'select' => 'id,nickname,avatar_url', 'index' => 'id']); $counts_arr = $team_list = $team_user_id_arr = []; foreach ($group_buy_order_list as $val) { if (isset($counts_arr[$val['open_group_id']])) { $counts_arr[$val['open_group_id']]++; } else { $counts_arr[$val['open_group_id']] = 1; } $team_list[$val['open_group_id']][] = $user_list[$val['user_id']]; $team_user_id_arr[$val['open_group_id']][] = $val['user_id']; } foreach ($commander_list as &$item) { $effective_time = $item['groupBuyActive']['effective_time'] * 60; $group_size = $item['groupBuyActive']['group_size']; $virtual_group_size = $item['groupBuyActive']['virtual_group_size']; $is_virtual = $item['groupBuyActive']['is_virtual']; $item['surplus_time'] = ($time - $item['created_at']) > $effective_time ? 0 : $effective_time - ($time - $item['created_at']);//剩余时间 $surplus_size = $group_size - $counts_arr[$item['open_group_id']]; // if ($is_virtual) $surplus_size -= $virtual_group_size; $item['surplus_size'] = $surplus_size;//剩余参团人数 $item['team_list'] = $team_list[$item['open_group_id']] ?? []; $item['is_join'] = in_array($this->user_id, $team_user_id_arr[$item['open_group_id']]) ? 1 : 0; unset($item['groupBuyActive']); } } // 判断当前活动是否开启个人参团次数限制 $group_buy_active['is_restrict_rule'] = false; if (!empty($group_buy_active['restrict_rule_num'])) { // 获取当前用户参与次拼团活动成功或者参团次数 $joinNum = GroupBuyOrder::find() ->where(['status' => StatusEnum::ENABLED, 'user_id' => $this->user_id, 'is_commander' => 0]) ->andWhere(['group_buy_active_id' => $get['active_id'], 'order_status' => [GroupBuyEnum::GROUP_SUCCESS, GroupBuyEnum::JOINING]]) ->groupBy('open_group_id') ->count(); if ($joinNum >= $group_buy_active['restrict_rule_num']) { $group_buy_active['is_restrict_rule'] = true; } } $group_buy_active['commander'] = $commander_list;//团长开团列表 $counts = GroupBuyOrder::find()->where(['mall_id' => $this->mall_id, 'group_buy_active_id' => $get['active_id'], 'order_status' => GroupBuyEnum::JOINING])->count(); $group_buy_active['count'] = $counts;//参团中的人数 $group_buy_active['group_status_map'] = GroupBuyEnum::getGroupStatusMap(); $goods['member_buy_limit_setting'] = [ 'every_day_num' => 0, 'every_month_num' => 0, 'every_week_num' => 0, 'nums' => 0, 'total_num' => 0, 'member_level' => [], 'every_num' => $group_buy_active['limit_buy_num']??0, ]; $group_buy_active['goods'] = $goods; unset($group_buy_active['activeGoodsAttr']); return $this->success('操作成功', $group_buy_active); } /** * @desc:拼团详情 * @Author: hua * @Date: 2021/12/14 * @Time: 16:02 * @Copyright: copyright (c) 2021 广东七件事集团 */ public function actionOrderDetail() { $get = \Yii::$app->request->get(); $res = \Yii::$app->services->validate->validate($get, [ [['open_group_id'], 'required'], [['order_status', 'open_group_id'], 'integer'], ]); if ($res === false) return $this->error(\Yii::$app->services->validate->getErrorMessage()); $params['where'] = [ ['mall_id' => $this->mall_id], ['open_group_id' => $get['open_group_id']], ['is_pay'=>1] ]; $params['order'] = 'id asc'; $params['select'] = 'id,user_id,commander_id,is_commander,win_time,group_buy_active_id,created_at,goods_id,goods_attr_name,goods_attr_id,num,order_status'; $list = GroupBuyOrder::lists($params); $user_id_arr = array_column($list, 'user_id'); $user_map = User::lists(['where' => [['id' => $user_id_arr]], 'select' => 'id,nickname,avatar_url', 'index' => 'id']); $group_buy_active_id = $list[0]['group_buy_active_id'] ?? 0; $open_time = 0; $is_success = $commander_id = $num = $goods_attr_id = 0; $order_status = $is_join = 0; $goods_attr_name = ''; $win_time = 0; $commander_name = ''; foreach ($list as &$value) { $value['avatar_url'] = $user_map[$value['user_id']]['avatar_url'] ?? ''; $value['nickname'] = $user_map[$value['user_id']]['nickname'] ?? ''; $order_status = $value['order_status']; $commander_id = $value['commander_id']; if ($value['order_status'] == GroupBuyEnum::GROUP_SUCCESS) $is_success = 1; if ($value['is_commander']) $open_time = $value['created_at']; if ($value['user_id'] == $this->user_id) { $is_join = 1; $num = $value['num']; $goods_attr_id = $value['goods_attr_id']; $goods_attr_name = $value['goods_attr_name']; } $win_time = $value['win_time'] ? date('Y-m-d H:i:s', $value['win_time']) : 0; if ($value['is_commander']) { $commander_name = $value['nickname']; $value['nickname'] = '团长'; } unset($value['created_at']); unset($value['group_buy_active_id']); unset($value['commander_id']); unset($value['id']); unset($value['user_id']); unset($value['goods_id']); unset($value['goods_attr_name']); unset($value['goods_attr_id']); unset($value['num']); unset($value['order_status']); } $group_buy_active = []; if ($group_buy_active_id) { $group_buy_active = GroupBuyActive::getOne([['id' => $group_buy_active_id], ['mall_id' => $this->mall_id]], true, [ 'goods' => function ($query) { $query->where(['status' => StatusEnum::ENABLED]) ->select('id,goods_name,cover_pic,attr_groups')->with(['attr' => function ($query) { $query->select('id,goods_id,goods_no,name,original_price,pic_url,price,sign_id,sort,status,version,weight,stock'); }]); }, 'activeGoodsAttr' => function ($query) { $query->where(['status' => StatusEnum::ENABLED]) ->select('id,group_buy_active_id,attr_id,group_buy_price')->with(['goodsAttr']); } ], false, 'id,goods_id,is_virtual,virtual_group_size,effective_time,group_size,group_status,limit_buy_num, is_show_participant_nickname, virtual_group_type, is_show_virtual_avatar, restrict_rule_num'); $group_buy_active['group_buy_price'] = $group_buy_active['activeGoodsAttr'][0]['group_buy_price']??0; $group_buy_active['price'] = $group_buy_active['activeGoodsAttr'][0]['goodsAttr']['price']??0; $active_goods_attr_arr = array_column($group_buy_active['activeGoodsAttr'], 'group_buy_price', 'attr_id'); foreach ($group_buy_active['goods']['attr'] as &$attr) { $attr['group_buy_price'] = $active_goods_attr_arr[$attr['id']] ?? 0; } unset($group_buy_active['activeGoodsAttr']); //参团中 if ($order_status == GroupBuyEnum::JOINING) { $time = time(); $effective_time = $group_buy_active['effective_time'] * 60; $group_buy_active['surplus_time'] = ($time - $open_time) > $effective_time ? 0 : $effective_time - ($time - $open_time);//剩余时间 $surplus_size = $group_buy_active['group_size'] - count($list); // if ($group_buy_active['is_virtual']) $surplus_size -= $group_buy_active['virtual_group_size']; $group_buy_active['surplus_size'] = $surplus_size; } if ($order_status == GroupBuyEnum::GROUP_SUCCESS) { //拼团成功 $group_buy_active['win_time'] = $win_time; } // 判断当前活动是否开启个人参团次数限制 $group_buy_active['is_restrict_rule'] = false; if (!empty($group_buy_active['restrict_rule_num'])) { // 获取当前用户参与次拼团活动成功或者参团次数 $joinNum = GroupBuyOrder::find() ->where(['status' => StatusEnum::ENABLED, 'user_id' => $this->user_id, 'is_commander' => 0]) ->andWhere(['group_buy_active_id' => $group_buy_active_id, 'order_status' => [GroupBuyEnum::GROUP_SUCCESS, GroupBuyEnum::JOINING]]) ->groupBy('open_group_id') ->count(); if ($joinNum >= $group_buy_active['restrict_rule_num']) { $group_buy_active['is_restrict_rule'] = true; } } $group_buy_active['goods_attr_id'] = $goods_attr_id; $group_buy_active['goods_attr_name'] = $goods_attr_name; $group_buy_active['num'] = $num; $group_buy_active['goods']['member_buy_limit_setting'] = [ 'every_day_num' => 0, 'every_month_num' => 0, 'every_week_num' => 0, 'nums' => 0, 'total_num' => 0, 'member_level' => [], 'every_num' => $group_buy_active['limit_buy_num']??0, ]; } if ($is_success) { $counts = count($list); $group_size = $group_buy_active['group_size']; if (!empty($group_buy_active['is_virtual']) && $group_buy_active['virtual_group_type'] == 3 && empty($group_buy_active['is_show_virtual_avatar'])) { $number = 0; } else { $number = $group_size - $counts; } for ($i = 0; $i < $number; $i++) { $k = ($commander_id + $i) % 500; $virtual_winer = [ 'is_commander' => 0, 'avatar_url' => Yii::getAlias('@apiUrl') . '/resources/img/def-virtual-avatar/' . $k . '.png', 'nickname' => '商城用户', ]; $list[] = $virtual_winer; } } if (empty($group_buy_active['is_show_participant_nickname'])) { foreach ($list as &$item) { unset($item['nickname']); } } else { foreach ($list as &$item) { $item['nickname'] = $this->truncateString($item['nickname']); } $group_buy_active['commander_name'] = $commander_name; } unset($group_buy_active['is_virtual']); unset($group_buy_active['virtual_group_size'], $group_buy_active['is_show_virtual_avatar'], $group_buy_active['virtual_group_type']); // \Yii::$app->services->rabbitMq->push(RabbitMqEnum::EXCHANGE_TASK, // RabbitMqEnum::TASK_QUEUE, ['mall_id'=>$this->mall_id,'open_group_id'=>$get['open_group_id']], GroupBuyOrder::class, 'finishGroupBuyOrderSync'); return $this->success('操作成功', ['list' => $list, 'group_buy_active' => $group_buy_active, 'is_join' => $is_join, 'order_status' => $order_status, 'order_status_map' => GroupBuyEnum::getOrderStatusMap()]); } private function truncateString($str, $length = 4) { if (mb_strlen($str) <= $length) { return $str; } return mb_substr($str, 0, $length) . '...'; } /** * @desc:订单预览 * @Author: hua * @Date: 2021/12/14 * @Time: 18:36 * @Copyright: copyright (c) 2021 广东七件事集团 */ public function actionPreview() { $params = \Yii::$app->request->post(); $params['mall_id'] = $this->mall_id; $params['user_id'] = $this->user_id; $orderFormLogic = new OrderFormLogic(); $form = $orderFormLogic->getDefaultform($this->mall_id, $this->user_id); $form->attributes = Yii::$app->request->post(); $form['action'] = AppEnum::ACTION_PREVIEW; !empty($form->shipping_type) && $form->shipping_type = ShippingTypeEnum::LOGISTICS; // 初始化订单数据 $orderInitDataLogic = new OrderInitDataLogic(); $form = $orderInitDataLogic->execute($form, PreviewTypeEnum::BUY_NOW); if ($form === false) return $this->error($orderInitDataLogic->getError()); // 购买验证 $orderLimitLogic = new OrderLimitLogic(); $form = $orderLimitLogic->run($form); if ($form === false) return $this->error($orderLimitLogic->getError()); // 获取收货地址 $address_info = UserAddress::getUserAddress($this->user_id, $form->address_id); $form->address_id = $address_info['id']??0; // 运费 $orderMarketingLogic = new OrderMarketingLogic(); $form = $orderMarketingLogic->run($form); if ($form === false) return $this->error($orderMarketingLogic->getError()); $group_order_goods = $form['group_order_goods']; $group_order_goods = array_values($group_order_goods); $marketing = $form['marketing']; $pay_type_list = \Yii::$app->services->pay->getEnablePayment($this->mall_id, $this->platform); $shipping_type_list = ShippingTypeEnum::getMap(); $info = compact('group_order_goods', 'marketing', 'address_info', 'pay_type_list', 'shipping_type_list'); $info['total_pay_money'] = $form['total_pay_money']; $info['is_address'] = $form['is_address'] ?? 0; return $this->success('操作成功', $info); } /** * 创建订单 * @Author bing * @DateTime 2021-09-22 09:31:22 * @return void * @copyright: Copyright (c) 2020 广东七件事集团 */ public function actionCreate() { $params = \Yii::$app->request->post(); $params['mall_id'] = $this->mall_id; $params['user_id'] = $this->user_id; $orderFormLogic = new OrderFormLogic(); $form = $orderFormLogic->getDefaultform($this->mall_id, $this->user_id); $form->attributes = Yii::$app->request->post(); $form['action'] = AppEnum::ACTION_CREATE; !empty($form->shipping_type) && $form->shipping_type = ShippingTypeEnum::LOGISTICS; // 初始化订单数据 $orderInitDataLogic = new OrderInitDataLogic(); $form = $orderInitDataLogic->execute($form, PreviewTypeEnum::BUY_NOW); if ($form === false) return $this->error($orderInitDataLogic->getError()); // 购买验证 $orderLimitLogic = new OrderLimitLogic(); $form = $orderLimitLogic->run($form); if ($form === false) return $this->error($orderLimitLogic->getError()); // 获取收货地址 $address_info = UserAddress::getUserAddress($this->user_id, $form->address_id); $form->address_id = $address_info['id']; // 运费 $orderMarketingLogic = new OrderMarketingLogic(); $form = $orderMarketingLogic->run($form); if ($form === false) return $this->error($orderMarketingLogic->getError()); $res = GroupBuyOrder::createOrder($form); if ($res === false) return $this->error(GroupBuyOrder::getStaticError()); return $this->success('操作成功', $res); } /** * @desc:拼团订单列表 * @Author: hua * @Date: 2021/12/17 * @Time: 18:49 * @Copyright: copyright (c) 2021 广东七件事集团 * @return mixed|void */ public function actionOrderList() { $params = \Yii::$app->request->get(); $params['mall_id'] = $this->mall_id; $params['user_id'] = $this->user_id; $where[] = ['mall_id' => $this->mall_id]; $where[] = ['user_id' => $this->user_id]; $where[] = ['status' => StatusEnum::ENABLED]; if (isset($params['order_status'])) $where[] = ['order_status' => $params['order_status']]; $params['where'] = $where; $params['order'] = "id desc"; $params['select'] = 'id,pic_url,goods_name,order_no,goods_attr_name,open_group_id,order_id,price,group_buy_price,num,order_status,total_pay_price'; $list = GroupBuyOrder::listPage($params); if (!empty($list['list'])) { $order_no_arr = array_column($list['list'], 'order_no'); $payment_trade_order_list = PaymentTradeOrder::lists(['where' => [['order_no' => $order_no_arr], ['order_type' => GroupBuyEnum::ADDONS_NAME]], 'select' => 'order_no,trade_id']); $payment_trade_order_arr = array_column($payment_trade_order_list, 'trade_id', 'order_no'); $payment_trade_list = PaymentTrade::lists(['where' => [['id' => $payment_trade_order_arr], ['mall_id' => $this->mall_id], ['user_id' => $this->user_id]], 'select' => 'id,out_trade_no']); $payment_trade_arr = array_column($payment_trade_list, 'out_trade_no', 'id'); foreach ($list['list'] as &$item) { $item['out_trade_no'] = $payment_trade_arr[$payment_trade_order_arr[$item['order_no']]] ?? ''; } } $list['order_status_map'] = GroupBuyEnum::getOrderStatusMap(); return $this->success('操作成功', $list); } /** * @desc:调试用,发起微信退款或查询退款 * @Author: hua * @Date: 2021/12/20 * @Time: 15:02 * @Copyright: copyright (c) 2021 广东七件事集团 * @return mixed|void */ public function actionRefundOrder() { try { $params = \Yii::$app->request->get(); if ($params['type'] == 2) { $re_order_no = $params['re_order_no']; $config = Yii::$app->services->pay->getWechatConfig($this->mall_id); $wechatConfig = [ 'app_id' => $config['app_id'], 'mch_id' => $config['wechat_mch_id'], 'key' => $config['wechat_pay_secret'], // API 密钥 'cert_path' => dirname(Yii::$app->basePath) . '/' . $config['wechat_cert_pem_file'], 'key_path' => dirname(Yii::$app->basePath) . '/' . $config['wechat_key_pem_file'], 'notify_url' => ''//回调地址 ]; $payment = Factory::payment($wechatConfig); $res = $payment->refund->queryByOutRefundNumber($re_order_no); } else { $order = Order::findOne(['id' => 5230]); $payment_order = PaymentTradeOrder::findOne(['order_no' => $order->order_no]); $payment_trade = PaymentTrade::findOne(['id' => $payment_order->trade_id]); $res = Yii::$app->services->pay->refund($payment_trade->pay_fee, $payment_trade->pay_fee, $payment_trade->out_trade_no, $order, '', '', ''); } } catch (\Exception $e) { return $this->error($e->getMessage()); } } }