123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890 |
- <?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\wap\model\store;
- use app\index\controller\PushJob;
- use app\wap\model\special\Special;
- use app\wap\model\special\SpecialBuy;
- use app\wap\model\user\User;
- use app\wap\model\user\WechatUser;
- use basic\ModelBasic;
- use service\WechatTemplateService;
- use service\SystemConfigService;
- use think\Url;
- use traits\ModelTrait;
- use app\wap\model\routine\RoutineTemplate;
- use app\wap\model\topic\TestPaperObtain;
- use app\wap\model\material\DataDownloadBuy;
- /**
- * 拼团Model
- * Class StorePink
- * @package app\wap\model\store
- */
- class StorePink extends ModelBasic
- {
- use ModelTrait;
- public static function getPinkIngCount($k_id)
- {
- return self::where('a')->where('k_id', $k_id)->count() + 1;
- }
- public static function getPinkStatusIng($pinkId)
- {
- return self::where('id', $pinkId)->value('status') == 1 ? false : true;
- }
- /**
- * 助力拼团
- * @param int $painId 拼团id
- * @return boolen
- * */
- public static function helpePink($pinId, $nickname, $avatar)
- {
- $pink = self::where('id', $pinId)->find();
- if (!$pink) return self::setErrorInfo('拼团信息暂未查到');
- if ($pink->status != 1) return self::setErrorInfo('拼团暂时无法助力');
- self::beginTrans();
- try {
- //获取参团人和团长和拼团总人数
- list($pinkAll, $pinkT, $count) = self::getPinkMemberAndPinkK($pink);
- //拼团是否完成
- if (!$count || $count < 0) return self::setErrorInfo('拼团已完成无法助力');
- //拼团超时
- if ($pinkT['stop_time'] < time()) return self::setErrorInfo('拼团超时无法助力');
- $data = [
- 'uid' => 0,
- 'type' => 1,
- 'order_id' => '',
- 'order_id_key' => 0,
- 'total_num' => 1,
- 'total_price' => $pinkT['total_price'],
- 'cid' => $pinkT['cid'],
- 'pid' => $pinkT['pid'],
- 'price' => $pinkT['price'],
- 'add_time' => time(),
- 'stop_time' => $pinkT['stop_time'],
- 'k_id' => $pinkT['id'],
- 'is_tpl' => 0,
- 'is_refund' => 0,
- 'is_false' => 1,
- 'status' => 1,
- ];
- $pink_false = self::set($data);
- if (!$pink_false) return self::setErrorInfo('写入助力拼团失败', true);
- $res = self::getDb('store_pink_false')->insert(['pink_id' => $pink_false['id'], 'nickname' => $nickname, 'avatar' => $avatar, 'add_time' => time()]);
- if (!$res) return self::setErrorInfo('写入助力拼团虚拟用户失败', true);
- //助力拼团加1人判断是否拼团完成;
- if (!($count - 1)) {
- $idAll = [];
- $uidAll = [];
- foreach ($pinkAll as $k => $v) {
- $idAll[$k] = $v['id'];
- if ($v['uid']) $uidAll[$k] = $v['uid'];
- }
- $idAll[] = $pinkT['id'];
- $uidAll[] = $pinkT['uid'];
- if (self::setPinkStatus($idAll)) {
- self::setPinkStopTime($idAll);
- if (self::isTpl($uidAll, $pinkT['id'])) self::orderPinkAfter($uidAll, $pinkT['id']);
- }
- }
- self::commitTrans();
- return true;
- } catch (\Exception $e) {
- self::rollbackTrans();
- return self::setErrorInfo($e->getMessage());
- }
- }
- /**
- * 获取参团人和团长和拼团总人数
- * @param array $pink
- * @return array
- * */
- public static function getPinkMemberAndPinkK($pink)
- {
- //查找拼团团员和团长
- if ($pink['k_id']) {
- $pinkAll = self::getPinkMember($pink['k_id']);
- $pinkT = self::getPinkUserOne($pink['k_id']);
- } else {
- $pinkAll = self::getPinkMember($pink['id']);
- $pinkT = $pink;
- }
- //获取虚拟拼团团员
- $pinkAll = self::getPinkTFalseList($pinkAll, $pinkT['id'], $pinkT['cid']);
- $count = count($pinkAll) + 1;
- $count = (int)$pinkT['people'] - $count;
- $idAll = [];
- $uidAll = [];
- //收集拼团用户id和拼团id
- foreach ($pinkAll as $k => $v) {
- $idAll[$k] = $v['id'];
- $uidAll[$k] = $v['uid'];
- }
- $idAll[] = $pinkT['id'];
- $uidAll[] = $pinkT['uid'];
- return [$pinkAll, $pinkT, $count, $idAll, $uidAll];
- }
- /**
- * 获取某个团的虚拟拼团人物和团
- * @param array 团员
- * @param int $pinkTId 团长id
- * @param int $cid 专题id
- * @return array
- * */
- public static function getPinkTFalseList($pinkAll, $pinkTId, $cid)
- {
- if (!is_array($pinkAll)) $pinkAll = [];
- $falseList = self::where(['a.order_id' => '', 'a.cid' => $cid, 'a.k_id' => $pinkTId, 'a.is_false' => 1, 'a.is_refund' => 0])
- ->alias('a')->join('__STORE_PINK_FALSE__ f', 'a.id=f.pink_id')->field(['a.*', 'f.nickname', 'f.avatar'])->select();
- $falseList = count($falseList) ? $falseList->toArray() : [];
- return array_merge($pinkAll, $falseList);
- }
- /**
- * 拼团完成更改数据写入内容
- * @param array $uidAll 当前拼团uid
- * @param array $idAll 当前拼团pink_id
- * @param array $pinkT 团长信息
- * @return int
- * */
- public static function PinkComplete($uidAll, $idAll, $uid, $pinkT)
- {
- $pinkBool = 6;
- if (self::setPinkStatus($idAll)) {
- self::setPinkStopTime($idAll);
- if (in_array($uid, $uidAll)) {
- if (self::isTpl($uidAll, $pinkT['id'])) self::orderPinkAfter($uidAll, $pinkT['id']);
- $pinkBool = 1;
- } else $pinkBool = 3;
- }
- return $pinkBool;
- }
- /**
- * 拼团失败 退款
- * @param array $pinkAll 拼团数据,不包括团长
- * @param array $pinkT 团长数据
- * @param int $count 差几人 0为拼团成功
- * @param int $pinkBool
- * @param array $uidAll 用户uid避免虚拟用户头像重复
- * @param boolen $isRunErr 是否返回错误信息
- * @param boolen $isIds 是否返回记录所有拼团id
- * @return int| boolen
- * */
- public static function PinkFail($uid, $idAll, $pinkAll, $pinkT, $count, $pinkBool, $uidAll, $isRunErr = false, $isIds = false, $fakeUrl = '/public/system/images/fake.png')
- {
- self::startTrans();
- $pinkIds = [];
- try {
- if ($pinkT['stop_time'] < time()) {//拼团时间超时 退款
- $special = Special::PreWhere()->where(['id' => $pinkT['cid']])->find();
- //检查专题是否有虚拟成团
- if ($special && $special->is_fake_pink && $special->fake_pink_number && $count) {
- // fake_pink_number/100 =补齐比例 $pinkT['people']*补齐比例=补齐人数 人数小数点全部舍去
- $fake = bcdiv($special->fake_pink_number, 100, 2);
- $num = bcmul($pinkT['people'], $fake, 0);
- if ($num > $count) $num = $count;
- if (($count - (int)$num) <= 0) {
- //获取虚拟用户头像
- $userAvatar = User::where('status', 1)->where('uid', 'not in', $uidAll)->limit(0, $num)->column('avatar');
- if (count($userAvatar) < $num) {
- $usercount = $num - count($userAvatar);
- for ($i = 0; $i < $usercount; $i++) {
- array_push($userAvatar, $fakeUrl);
- }
- }
- //写入虚拟拼团
- foreach ($userAvatar as $item) {
- $data = [
- 'uid' => 0,
- 'type' => 1,
- 'order_id' => '',
- 'order_id_key' => 0,
- 'total_num' => 1,
- 'total_price' => $pinkT['total_price'],
- 'cid' => $pinkT['cid'],
- 'pid' => $pinkT['pid'],
- 'price' => $pinkT['price'],
- 'add_time' => time(),
- 'stop_time' => $pinkT['stop_time'],
- 'k_id' => $pinkT['id'],
- 'is_tpl' => 0,
- 'is_refund' => 0,
- 'is_false' => 1,
- 'status' => 1,
- ];
- $pink_false = self::set($data);
- if (!$pink_false) return self::setErrorInfo('写入助力拼团失败', true);
- $res = self::getDb('store_pink_false')->insert(['pink_id' => $pink_false['id'], 'nickname' => '虚拟用户', 'avatar' => $item, 'add_time' => time()]);
- if (!$res) return self::setErrorInfo('写入助力拼团虚拟用户失败', true);
- }
- //拼团完成处理
- $pinkBool = self::PinkComplete($uidAll, $idAll, $uid, $pinkT);
- if ($pinkBool === false) return false;
- self::commit();
- return $pinkBool;
- }
- }
- $data = ['pics' => [], 'refund_reason' => '拼团时间超时', 'remarks' => '拼团活动结束拼团未成功,给用户退款'];
- //团员退款
- foreach ($pinkAll as $v) {
- if (StoreOrder::orderApplyRefund(StoreOrder::getPinkOrderId($v['order_id_key']), $v['uid'], $data) && self::isTpl($v['uid'], $pinkT['id'])) {
- self::orderPinkAfterNo($v['uid'], $v['k_id']);
- if ($isIds) array_push($pinkIds, $v['id']);
- $pinkBool = 2;
- } else {
- if ($isRunErr) return self::setErrorInfo(StoreOrder::getErrorInfo(), true);
- }
- }
- //团长退款
- if (StoreOrder::orderApplyRefund(StoreOrder::getPinkOrderId($pinkT['order_id_key']), $pinkT['uid'], $data) && self::isTpl($pinkT['uid'], $pinkT['id'])) {
- self::orderPinkAfterNo($pinkT['uid'], $pinkT['id']);
- if ($isIds) array_push($pinkIds, $pinkT['id']);
- $pinkBool = 2;
- } else {
- if ($isRunErr) return self::setErrorInfo(StoreOrder::getErrorInfo(), true);
- }
- if (!$pinkBool) $pinkBool = 3;
- }
- self::commit();
- if ($isIds) return $pinkIds;
- return $pinkBool;
- } catch (\Exception $e) {
- self::rollback();
- return self::setErrorInfo($e->getMessage());
- }
- }
- /**
- * 拼团下架
- * @param int $painId 拼团id
- * @return boolen
- * */
- public static function downPink($pinId)
- {
- $pink = self::where('id', $pinId)->find();
- if (!$pink) return self::setErrorInfo('拼团信息暂未查到');
- if ($pink->status != 1) return self::setErrorInfo('拼团暂时无法下架');
- self::beginTrans();
- try {
- //获取参团人和团长和拼团总人数
- list($pinkAll, $pinkT, $count, $idAll, $uidAll) = StorePink::getPinkMemberAndPinkK($pink);
- if (!$count) return self::setErrorInfo('拼团已完成无法下架');
- //拼团失败处理退款
- $pinkIds = self::PinkFail($pink['uid'], $idAll, $pinkAll, $pinkT, $count, 1, [], true, true);
- if ($pinkIds === false) return false;
- //更新当前拼团过期时间为当前
- self::where('id', 'in', $pinkIds)->update(['stop_time' => time()]);
- self::commitTrans();
- return true;
- } catch (\Exception $e) {
- return self::setErrorInfo($e->getMessage(), true);
- }
- }
- /**
- * 获取一条拼团数据
- * @param $id
- * @return mixed
- */
- public static function getPinkUserOne($id)
- {
- $model = new self();
- $model = $model->alias('p');
- $model = $model->field('p.*,u.nickname,u.avatar');
- $model = $model->where('p.id', $id);
- $model = $model->join('__USER__ u', 'u.uid = p.uid');
- $list = $model->find();
- if ($list) return $list->toArray();
- else return [];
- }
- /**
- * 获取拼团的团员
- * @param $id
- * @return mixed
- */
- public static function getPinkMember($id, $retrn_array = false)
- {
- $model = new self();
- $model = $model->alias('p');
- $model = $model->field('p.*,u.nickname,u.avatar');
- $model = $model->where('p.k_id', $id);
- $model = $model->where('p.is_refund', 0);
- $model = $model->join('__USER__ u', 'u.uid = p.uid');
- $model = $model->order('p.id asc');
- if ($retrn_array) return $model->count();
- $list = $model->select();
- if ($list) return $list->toArray();
- else return [];
- }
- /**
- * 设置结束时间
- * @param $idAll
- * @return $this
- */
- public static function setPinkStopTime($idAll)
- {
- $model = new self();
- $model = $model->where('id', 'IN', $idAll);
- self::setSpecialBuy($idAll);
- return $model->update(['stop_time' => time(), 'status' => 2]);
- }
- public static function setSpecialBuy($idAll)
- {
- $allOrderId = self::where('id', 'in', $idAll)->column('order_id');
- foreach ($allOrderId as $order_id) {
- if ($order = StoreOrder::where(['order_id' => $order_id, 'paid' => 1])->find()) {
- SpecialBuy::setAllBuySpecial($order['order_id'], $order['uid'], $order['cart_id'], 1);
- TestPaperObtain::setTestPaper($order['order_id'], $order['uid'], $order['cart_id'], 1);
- DataDownloadBuy::setDataDownload($order['order_id'], $order['uid'], $order['cart_id'], 0);
- }
- }
- }
- /**
- * 获取正在拼团的数据 团长
- * @return mixed
- */
- public static function getPinkAll($cid, $pinkId = 0, $limit = 0)
- {
- $model = new self();
- $model = $model->alias('p');
- $model = $model->field('p.*,u.nickname,u.avatar');
- $model = $model->where('p.stop_time', 'GT', time());
- $model = $model->where('p.cid', $cid);
- $model = $model->where('p.k_id', 0);
- $model = $model->where('p.is_refund', 0);
- $model = $model->where('p.status', 1);
- $model = $model->order('p.add_time desc');
- $model = $model->join('__USER__ u', 'u.uid = p.uid');
- if ($limit) $model = $model->limit($limit);
- if ($pinkId) $model = $model->where('p.id', 'neq', $pinkId);
- $list = $model->select();
- if ($list) return $list->toArray();
- else return [];
- }
- public static function setPinkIng($pink, $uid)
- {
- list($pinkAll, $pinkT, $count, $idAll, $uidAll) = StorePink::getPinkMemberAndPinkK($pink);
- if ($pinkT['status'] != 2) {
- if (!$count) {//组团完成
- self::PinkComplete($uidAll, $idAll, $uid, $pinkT);
- } else {
- //组团时间到退款
- self::PinkFail($uid, $idAll, $pinkAll, $pinkT, $count, 0, $uidAll);
- }
- }
- }
- /**
- * 参加拼团的人 商品id
- * @return mixed
- */
- public static function getPinkAttend($cid, $type = 1)
- {
- $model = new self();
- $model = $model->alias('p');
- $model = $model->field('u.avatar');
- $model = $model->where(['p.cid' => $cid, 'p.type' => $type, 'p.is_refund' => 0]);
- $model = $model->order('p.add_time desc');
- $model = $model->join('__USER__ u', 'u.uid = p.uid');
- $list = $model->distinct(true)->select();
- if ($list) return $list->toArray();
- else return [];
- }
- public static function getPinkAttendFalse($cid, $type = 1, $limit = 20)
- {
- $userList = self::where(['a.cid' => $cid, 'a.type' => $type, 'a.is_refund' => 0])
- ->distinct(true)->order('a.add_time desc')->alias('a')
- ->join('__STORE_PINK_FALSE__ s', 's.pink_id=a.id')
- ->field('s.avatar')->limit($limit)->select();
- return count($userList) ? $userList->toArray() : [];
- }
- /**
- * 获取还差几人
- */
- public static function getPinkPeople($kid, $people)
- {
- $model = new self();
- $model = $model->where('k_id', $kid)->where('is_refund', 0);
- $count = bcadd($model->count(), 1, 0);
- return bcsub($people, $count, 0);
- }
- /**
- * 判断订单是否在当前的拼团中
- * @param $orderId
- * @param $kid
- * @return bool
- */
- public static function getOrderIdAndPink($orderId, $kid)
- {
- $model = new self();
- $pink = $model->where('k_id', $kid)->whereOr('id', $kid)->column('order_id');
- if (in_array($orderId, $pink)) return true;
- else return false;
- }
- /**
- * 判断用户是否在团内
- * @param $id
- * @return int|string
- */
- public static function getIsPinkUid($id)
- {
- $uid = User::getActiveUid();
- $pinkT = self::where('id', $id)->where('uid', $uid)->where('is_refund', 0)->count();
- $pink = self::whereOr('k_id', $id)->where('uid', $uid)->where('is_refund', 0)->count();
- if ($pinkT) return true;
- if ($pink) return true;
- else return false;
- }
- /**
- * 判断是否发送模板消息 0 未发送 1已发送
- * @param $uidAll
- * @return int|string
- */
- public static function isTpl($uidAll, $pid)
- {
- if (is_array($uidAll)) {
- $countK = self::where('uid', 'IN', implode(',', $uidAll))->where('is_tpl', 0)->where('id', $pid)->count();
- $count = self::where('uid', 'IN', implode(',', $uidAll))->where('is_tpl', 0)->where('k_id', $pid)->count();
- } else {
- $countK = self::where('uid', $uidAll)->where('is_tpl', 0)->where('id', $pid)->count();
- $count = self::where('uid', $uidAll)->where('is_tpl', 0)->where('k_id', $pid)->count();
- }
- return bcadd($countK, $count, 0);
- }
- /**
- * 拼团成功提示模板消息
- * @param $uidAll
- * @param $pid
- */
- public static function orderPinkAfter($uidAll, $pid)
- {
- foreach ($uidAll as $v) {
- try {
- if ($openid = WechatUser::uidToOpenid($v)) {
- $cart_id = self::alias('p')->where('p.id', $pid)->whereOr('p.k_id', $pid)->where('p.uid', $v)->join('__STORE_ORDER__ a', 'a.order_id=p.order_id')->value('a.cart_id');
- $wechat_notification_message = SystemConfigService::get('wechat_notification_message');
- $order_id = self::where('id', $pid)->whereOr('k_id', $pid)->where('uid', $v)->value('order_id');
- $title = Special::PreWhere()->where('id', $cart_id)->value('title');
- if ($wechat_notification_message == 1) {
- WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_SUCCESS, [
- 'first' => '亲,您的拼团已经完成了',
- 'keyword1' => $order_id,
- 'keyword2' => $title,
- 'remark' => '点击查看订单详情'
- ], Url::build('wap/special/order_pink', ['pink_id' => $pid], true, true));
- } else {
- $data['character_string10']['value'] = $order_id;
- $data['thing7']['value'] = $title;
- $data['thing9']['value'] = '亲,您的拼团已经完成了';
- RoutineTemplate::sendOrderSuccessfully($data, $v, Url::build('wap/special/order_pink', ['pink_id' => $pid], true, true));
- }
- }
- } catch (\Exception $e) {
- break;
- }
- }
- self::where('uid', 'IN', implode(',', $uidAll))->where('id', $pid)->whereOr('k_id', $pid)->update(['is_tpl' => 1]);
- }
- /**
- * 拼团失败发送的模板消息
- * @param $uid
- * @param $pid
- */
- public static function orderPinkAfterNo($uid, $pid)
- {
- $openid = WechatUser::uidToOpenid($uid);
- $wechat_notification_message = SystemConfigService::get('wechat_notification_message');
- $title = self::alias('p')->where('p.id', $pid)->whereOr('p.k_id', $pid)->where('p.uid', $uid)->join('__SPECIAL__ c', 'c.id=p.cid')->value('c.title');
- $price = self::where('id', $pid)->whereOr('k_id', $pid)->where('uid', $uid)->value('price');
- $pay_price = self::alias('p')->where('p.id', $pid)->whereOr('p.k_id', $pid)->where('p.uid', $uid)->join('__STORE_ORDER__ c', 'c.order_id=p.order_id')->value('c.pay_price');
- if ($wechat_notification_message == 1) {
- WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_LOSE, [
- 'first' => '亲,您的拼团失败',
- 'keyword1' => $title,
- 'keyword2' => $price,
- 'keyword3' => $pay_price,
- 'remark' => '点击查看订单详情'
- ], Url::build('wap/special/order_pink', ['pink_id' => $pid], true, true));
- } else {
- $data['thing1']['value'] = $title;
- $data['amount8']['value'] = $price;
- $data['amount5']['value'] = $pay_price;
- RoutineTemplate::sendOrderFail($data, $uid, Url::build('wap/special/order_pink', ['pink_id' => $pid], true, true));
- }
- self::where('id', $pid)->update(['status' => 3]);
- self::where('k_id', $pid)->update(['status' => 3]);
- }
- /**
- * 获取当前拼团数据返回订单编号
- * @param $id
- * @return array|false|\PDOStatement|string|\think\Model
- */
- public static function getCurrentPink($id)
- {
- $uid = User::getActiveUid();//获取当前登录人的uid
- $pink = self::where('id', $id)->where('uid', $uid)->find();
- if (!$pink) $pink = self::where('k_id', $id)->where('uid', $uid)->find();
- if($pink){
- return StoreOrder::where('id', $pink['order_id_key'])->value('order_id');
- }else{
- return '';
- }
- }
- /**
- * 设置where条件
- * @param $where
- * @param string $alias
- * @return $this|StorePink
- */
- public static function setWhere($where, $alias = '')
- {
- self::setPinkStop((int)$where['page']);
- $model = new self;
- if ($alias) {
- $model = $model->alias($alias);
- $alias .= '.';
- }
- if ($where['data'] !== '~' && !empty($where['data'])) {
- list($startTime, $endTime) = explode('~', $where['data']);
- $model = $model->where($alias . 'add_time', '>', strtotime($startTime));
- $model = $model->where($alias . 'add_time', '<', strtotime($endTime));
- }
- if (isset($where['status']) && $where['status']) $model = $model->where($alias . 'status', $where['status']);
- if (isset($where['cid']) && $where['cid']) $model = $model->where($alias . 'cid', $where['cid']);
- if (isset($where['nickname']) && $where['nickname']) $model = $model->where($alias . 'order_id|' . $alias . 'order_id_key|' . $alias . 'uid', 'LIKE', "%$where[nickname]%");
- if (isset($where['mer_id']) && $where['mer_id']) $model = $model->where('s.mer_id', $where['mer_id']);
- $model = $model->where($alias . 'k_id', 0);
- $model = $model->join('__USER__ u', 'u.uid=a.uid', 'LEFT');
- $model = $model->join('__SPECIAL__ s', 's.id=a.pid', 'LEFT');
- return $model;
- }
- /**
- * @param $where
- * @return array
- * @throws \think\Exception
- */
- public static function getPinkList($where)
- {
- $data = self::setWhere($where, 'a')->field(['a.*', 'u.nickname', 's.mer_id,s.id as special_id'])->order('a.id desc')
- ->page((int)$where['page'], (int)$where['limit'])->select();
- foreach ($data as &$item) {
- if ($item['status'] == 1 && $item['stop_time'] < time()) {
- $pinkall = self::where(['k_id' => $item['id']])->column('id');
- array_push($pinkall, $item['id']);
- if (!($item['people'] - count($pinkall))) {
- self::where('id', 'in', $pinkall)->update(['status' => 2]);
- $item['status'] = 2;
- } else {
- self::where('id', 'in', $pinkall)->update(['status' => 3]);
- $item['status'] = 3;
- $pink = self::where('id', $item['id'])->find();
- list($pinkAll, $pinkT, $count, $idAll, $uidAll) = StorePink::getPinkMemberAndPinkK($pink);
- //拼团失败处理退款
- self::PinkFail($pink['uid'], $idAll, $pinkAll, $pinkT, $count, 1, [], true, true);
- }
- }
- if (!$item['nickname']) $item['nickname'] = '暂无昵称';
- $item['count_people'] = bcadd(self::where('k_id', $item['id'])->count(), 1, 0);
- $item['title'] = Special::where('id', $item['cid'])->value('title');
- $item['add_time'] = date('Y-m-d H:i', $item['add_time']);
- $item['stop_time'] = date('Y-m-d H:i', $item['stop_time']);
- $item['people_true'] = self::where(['k_id' => $item['id'], 'is_false' => 0])->count() + 1;
- }
- $count = self::setWhere($where, 'a')->count();
- return compact('data', 'count');
- }
- /**
- * 处理拼团结束
- * @param int $page
- */
- public static function setPinkStop($page = 1)
- {
- $list = self::where(['k_id' => 0, 'status' => 1])->where('stop_time', '<', time())->page($page, 10)->select();
- foreach ($list as $item) {
- //获取参团人和团长和拼团总人数
- list($pinkAll, $pinkT, $count, $idAll) = StorePink::getPinkMemberAndPinkK($item);
- //拼团失败处理退款
- self::PinkFail($item['uid'], $idAll, $pinkAll, $pinkT, $count, 1, [], true, true);
- }
- }
- public static function systemPage($where)
- {
- $model = new self;
- $model = $model->alias('p');
- $model = $model->field('p.*');
- if ($where['data'] !== '') {
- list($startTime, $endTime) = explode(' - ', $where['data']);
- $model = $model->where('add_time', '>', strtotime($startTime));
- $model = $model->where('add_time', '<', strtotime($endTime));
- }
- if ($where['status']) $model = $model->where('status', $where['status']);
- $model = $model->where('k_id', 0);
- $model = $model->order('id desc');
- return self::page($model, function ($item) use ($where) {
- $item['count_people'] = bcadd(self::where('k_id', $item['id'])->count(), 1, 0);
- $item['title'] = Special::where('id', $item['cid'])->value('title');
- }, $where);
- }
- public static function isPinkBe($data, $id)
- {
- $data['id'] = $id;
- $count = self::where($data)->count();
- if ($count) return $count;
- $data['k_id'] = $id;
- $count = self::where($data)->count();
- if ($count) return $count;
- else return 0;
- }
- public static function isPinkStatus($pinkId)
- {
- if (!$pinkId) return false;
- $stopTime = self::where('id', $pinkId)->value('stop_time');
- if ($stopTime < time()) return true; //拼团结束
- else return false;//拼团未结束
- }
- /**
- * 判断拼团结束 后的状态
- * @param $pinkId
- * @return bool
- */
- public static function isSetPinkOver($pinkId)
- {
- $people = self::where('id', $pinkId)->value('people');
- $stopTime = self::where('id', $pinkId)->value('stop_time');
- if ($stopTime < time()) {
- $countNum = self::getPinkPeople($pinkId, $people);
- if ($countNum) return false;//拼团失败
- else return true;//拼团成功
- } else return true;
- }
- /**
- * 拼团退款
- * @param $id
- * @return bool
- */
- public static function setRefundPink($oid)
- {
- $res = true;
- $order = StoreOrder::where('id', $oid)->find();
- if ($order['pink_id']) $id = $order['pink_id'];
- else return $res;
- $count = self::where('id', $id)->where('uid', $order['uid'])->find();//正在拼团 团长
- $countY = self::where('k_id', $id)->where('uid', $order['uid'])->find();//正在拼团 团员
- if (!$count && !$countY) return $res;
- if ($count) {//团长
- //判断团内是否还有其他人 如果有 团长为第二个进团的人
- $kCount = self::where('k_id', $id)->order('add_time asc')->find();
- if ($kCount) {
- $res11 = self::where('k_id', $id)->update(['k_id' => $kCount['id']]);
- $res12 = self::where('id', $kCount['id'])->update(['stop_time' => $count['add_time'] + 86400, 'k_id' => 0]);
- $res1 = $res11 && $res12;
- $res2 = self::where('id', $id)->update(['stop_time' => time() - 1, 'k_id' => 0, 'is_refund' => $kCount['id'], 'status' => 3]);
- } else {
- $res1 = true;
- $res2 = self::where('id', $id)->update(['stop_time' => time() - 1, 'k_id' => 0, 'is_refund' => $id, 'status' => 3]);
- }
- //修改结束时间为前一秒 团长ID为0
- $res = $res1 && $res2;
- } else if ($countY) {//团员
- $res = self::where('id', $countY['id'])->update(['stop_time' => time() - 1, 'k_id' => 0, 'is_refund' => $id, 'status' => 3]);
- }
- return $res;
- }
- /**
- * 拼团人数完成时,判断全部人都是未退款状态
- * @param $pinkIds
- * @return bool
- */
- public static function setPinkStatus($pinkIds)
- {
- $orderPink = self::where('id', 'IN', $pinkIds)->where('is_refund', 1)->count();
- if (!$orderPink) return true;
- else return false;
- }
- /**
- * 创建拼团
- * @param $order
- * @return mixed
- */
- public static function createPink($order)
- {
- $order = StoreOrder::tidyOrder($order, true)->toArray();
- $wechat_notification_message = SystemConfigService::get('wechat_notification_message');
- //开团的用户走else
- if ($order['pink_id']) {//拼团存在
- $res = false;
- $pink['uid'] = $order['uid'];//用户id
- if (self::isPinkBe($pink, $order['pink_id'])) return false;
- $pink['type'] = 1;
- $pink['order_id'] = $order['order_id'];//订单id 生成
- $pink['order_id_key'] = $order['id'];//订单id 数据库id
- $pink['total_num'] = $order['total_num'];//购买个数
- $pink['total_price'] = $order['pay_price'];//总金额
- $pink['k_id'] = $order['pink_id'];//拼团id
- $special = Special::PreWhere()->where('id', $order['cart_id'])->find();
- if (!$special) return false;
- $pink['cid'] = $order['combination_id'];//拼团产品id
- $pink['pid'] = $order['cart_id'];//产品id
- $pink['people'] = $special['pink_number'];//几人拼团
- $pink['price'] = $special['is_fake_pink'] ? $special['pink_money'] : $special['money'];//单价
- $pink['stop_time'] = 0;//结束时间
- $pink['add_time'] = time();//开团时间
- $res = $res1 = self::set($pink)->toArray();
- $openid = WechatUser::uidToOpenid($order['uid']) ? WechatUser::uidToOpenid($order['uid']) : "";
- if ($openid) {
- if ($wechat_notification_message == 1) {
- WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_SUCCESS, [
- 'first' => '恭喜您拼团成功,点击查看拼团详情~',
- 'keyword1' => $order['order_id'],
- 'keyword2' => self::alias('p')->where('p.id', $res1['id'])->where('p.uid', $res1['uid'])->join('__SPECIAL__ c', 'c.id=p.cid')->value('c.title'),
- 'remark' => '分享至朋友圈或好友群,成团速度更快哦~'
- ], Url::build('wap/special/order_pink', ['pink_id' => $res1['id']], true, true));
- } else {
- $data['character_string10']['value'] = $order['order_id'];
- $data['thing7']['value'] = self::alias('p')->where('p.id', $res1['id'])->where('p.uid', $res1['uid'])->join('__SPECIAL__ c', 'c.id=p.cid')->value('c.title');
- $data['thing9']['value'] = '恭喜您拼团成功';
- RoutineTemplate::sendOrderSuccessfully($data, $order['uid'], Url::build('wap/special/order_pink', ['pink_id' => $res1['id']], true, true));
- }
- }
- if ($people = self::getPinkPeople($order['pink_id'], $special['pink_number'])) {
- $userInfo = User::where('uid', $order['uid'])->find();
- if (!$userInfo->is_promoter && $userInfo->spread_uid) {
- if ($wechat_notification_message == 1) {
- $spreadOpenid = WechatUser::uidToOpenid($userInfo->spread_uid);
- WechatTemplateService::sendTemplate($spreadOpenid, WechatTemplateService::PINK_ORDER_REMIND, [
- 'first' => '您的好友【' . $userInfo->nickname . '】通过您的邀请开始了【' . $special['title'] . '】的拼团!',
- 'keyword1' => $special['title'],
- 'keyword2' => '差' . $people . '人',
- 'remark' => '点我立即协助【' . $userInfo->nickname . '】拼团,拼团成功即可获得佣金!'
- ], Url::build('wap/special/order_pink', ['pink_id' => $res1['id'], 'is_help' => 1], true, true));
- } else {
- $data['thing1']['value'] = $special['title'];
- $data['number6']['value'] = self::where('k_id', $order['pink_id'])->where('is_refund', 0)->count();
- RoutineTemplate::sendListProgress($data, $userInfo->spread_uid, Url::build('wap/special/order_pink', ['pink_id' => $res1['id'], 'is_help' => 1], true, true));
- }
- }
- }
- //处理拼团完成
- list($pinkAll, $pinkT, $count, $idAll, $uidAll) = self::getPinkMemberAndPinkK($pink);
- if ($pinkT['status'] == 1) {
- if (!$count || $count < 0)//组团完成
- self::PinkComplete($uidAll, $idAll, $pink['uid'], $pinkT);
- else
- self::PinkFail($pink['uid'], $idAll, $pinkAll, $pinkT, $count, 0, $uidAll);
- } else if ($pinkT['status'] == 2) {
- SpecialBuy::setAllBuySpecial($order['order_id'], $order['uid'], $order['cart_id'], 1);
- TestPaperObtain::setTestPaper($order['order_id'], $order['uid'], $order['cart_id'], 1);
- DataDownloadBuy::setDataDownload($order['order_id'], $order['uid'], $order['cart_id'], 0);
- self::where('id', $res1['id'])->update(['is_tpl' => 1, 'stop_time' => time(), 'status' => 2]);
- }
- if ($res) return true;
- else return false;
- } else {
- $res = false;
- $pink['type'] = 1;
- $pink['uid'] = $order['uid'];//用户id
- $pink['order_id'] = $order['order_id'];//订单id 生成
- $pink['order_id_key'] = $order['id'];//订单id 数据库id
- $pink['total_num'] = $order['total_num'];//购买个数
- $pink['total_price'] = $order['pay_price'];//总金额
- $pink['k_id'] = 0;//拼团id
- $pink['cid'] = $order['combination_id'];//拼团产品id
- $pink['pid'] = $order['cart_id'];//产品id
- $special = Special::PreWhere()->where('id', $order['cart_id'])->find();
- if (!$special) return false;
- $pink['people'] = $special['pink_number'];//几人拼团
- $pink['price'] = $special['is_fake_pink'] ? $special['pink_money'] : $special['money'];//单价
- $stop_time = bcadd(time(), bcmul($order['pink_time'], 3600, 0), 0);
- $pink_end_time = strtotime($special['pink_end_time']);
- if (bcsub($pink_end_time, $stop_time, 0) < 0) {
- $stop_time = $pink_end_time;
- }
- $pink['stop_time'] = $stop_time;//结束时间
- $pink['add_time'] = time();//开团时间
- $res1 = self::set($pink)->toArray();
- $do_job_pink['pink_id'] = $res1['id'];
- $do_job_pink['pink_time'] = bcmul($order['pink_time'], 3600, 0);
- $res2 = StoreOrder::where('id', $order['id'])->update(['pink_id' => $res1['id']]);
- $res = $res1 && $res2;
- $openid = WechatUser::uidToOpenid($order['uid']);
- if ($wechat_notification_message == 1) {
- WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_SUCCESS, [
- 'first' => '恭喜您拼团成功,点击查看拼团详情~',
- 'keyword1' => $order['order_id'],
- 'keyword2' => $special['title'],
- 'remark' => '分享至朋友圈或好友群,成团速度更快哦~'
- ], Url::build('wap/special/order_pink', ['pink_id' => $res1['id']], true, true));
- } else {
- $data['character_string10']['value'] = $order['order_id'];
- $data['thing7']['value'] = $special['title'];
- $data['thing9']['value'] = '恭喜您拼团成功';
- RoutineTemplate::sendOrderSuccessfully($data, $order['uid'], Url::build('wap/special/order_pink', ['pink_id' => $res1['id']], true, true));
- }
- $userInfo = User::where('uid', $order['uid'])->find();
- try {
- if ($userInfo && !$userInfo->is_promoter && $userInfo->spread_uid) {
- if ($wechat_notification_message == 1) {
- $spreadOpenid = WechatUser::uidToOpenid($userInfo->spread_uid);
- $people = self::getPinkPeople($res1['id'], $special['pink_number']);
- WechatTemplateService::sendTemplate($spreadOpenid, WechatTemplateService::PINK_ORDER_REMIND, [
- 'first' => '您的好友【' . $userInfo->nickname . '】通过您的邀请开始了【' . $special['title'] . '】的拼团!',
- 'keyword1' => $special['title'],
- 'keyword2' => '差' . $people . '人',
- 'remark' => '点我立即协助【' . $userInfo->nickname . '】拼团,拼团成功即可获得佣金!'
- ], Url::build('wap/special/order_pink', ['pink_id' => $res1['id'], 'is_help' => 1], true, true));
- } else {
- $data['thing1']['value'] = $special['title'];
- $data['number6']['value'] = self::where('k_id', $res1['id'])->where('is_refund', 0)->count();
- RoutineTemplate::sendListProgress($data, $userInfo->spread_uid, Url::build('wap/special/order_pink', ['pink_id' => $res1['id'], 'is_help' => 1], true, true));
- }
- }
- } catch (\Exception $e) {
- }
- PushJob::actionWithDoPinkJob($do_job_pink);
- if ($res) return true;
- else return false;
- }
- }
- }
|