mirror of
https://github.com/crmeb/CRMEB.git
synced 2025-12-25 04:10:19 +00:00
897 lines
37 KiB
PHP
897 lines
37 KiB
PHP
<?php
|
|
/**
|
|
*
|
|
* @author: xaboy<365615158@qq.com>
|
|
* @day: 2017/12/18
|
|
*/
|
|
|
|
namespace app\models\store;
|
|
|
|
use app\models\routine\RoutineFormId;
|
|
use app\models\routine\RoutineTemplate;
|
|
use app\models\user\User;
|
|
use app\models\user\WechatUser;
|
|
use crmeb\basic\BaseModel;
|
|
use crmeb\services\WechatTemplateService;
|
|
use crmeb\traits\ModelTrait;
|
|
use think\facade\Log;
|
|
use think\facade\Route;
|
|
use think\facade\Cache;
|
|
|
|
/**
|
|
* TODO 拼团Model
|
|
* Class StorePink
|
|
* @package app\models\store
|
|
*/
|
|
class StorePink extends BaseModel
|
|
{
|
|
/**
|
|
* 数据表主键
|
|
* @var string
|
|
*/
|
|
protected $pk = 'id';
|
|
|
|
/**
|
|
* 模型名称
|
|
* @var string
|
|
*/
|
|
protected $name = 'store_pink';
|
|
|
|
use ModelTrait;
|
|
|
|
/**
|
|
* 获取拼团完成的用户
|
|
* @param $uid
|
|
* @return array
|
|
*/
|
|
public static function getPinkOkList($uid)
|
|
{
|
|
$list = self::alias('a')->where('a.status', 2)->where('a.is_refund', 0)->where('a.uid', '<>', $uid)->join('User u', 'u.uid=a.uid', 'right')->column('nickname', 'id');
|
|
$msg = [];
|
|
foreach ($list as &$item) {
|
|
$msg[] = $item .= '拼团成功';
|
|
}
|
|
return $msg;
|
|
}
|
|
|
|
/*
|
|
* 获取拼团完成的商品总件数
|
|
* */
|
|
public static function getPinkOkSumTotalNum($id)
|
|
{
|
|
|
|
return self::where('status', 2)->where('is_refund', 0)->sum('total_num');
|
|
}
|
|
|
|
/**
|
|
* 获取一条拼团数据
|
|
* @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('id', $id);
|
|
$model = $model->join('user u', 'u.uid = p.uid');
|
|
return $model->find();
|
|
}
|
|
|
|
/**
|
|
* 获取拼团的团员
|
|
* @param $id
|
|
* @return mixed
|
|
*/
|
|
public static function getPinkMember($id)
|
|
{
|
|
$model = new self();
|
|
$model = $model->alias('p');
|
|
$model = $model->field('p.*,u.nickname,u.avatar');
|
|
$model = $model->where('k_id', $id);
|
|
$model = $model->where('is_refund', 0);
|
|
$model = $model->join('user u', 'u.uid = p.uid');
|
|
$model = $model->order('id asc');
|
|
return $model->select();
|
|
}
|
|
|
|
/**
|
|
* 设置结束时间
|
|
* @param $idAll
|
|
* @return $this
|
|
*/
|
|
public static function setPinkStopTime($idAll)
|
|
{
|
|
$model = new self();
|
|
$model = $model->where('id', 'IN', $idAll);
|
|
return $model->update(['stop_time' => time(), 'status' => 2]);
|
|
}
|
|
|
|
/**
|
|
* 获取正在拼团的数据 团长
|
|
* @param int $cid 产品id
|
|
* @param int $isAll 是否查找所有拼团
|
|
* @return array
|
|
*/
|
|
public static function getPinkAll($cid, $isAll = false)
|
|
{
|
|
$model = new self();
|
|
$model = $model->alias('p');
|
|
$model = $model->field('p.id,p.uid,p.people,p.price,p.stop_time,u.nickname,u.avatar');
|
|
$model = $model->where('stop_time', '>', time());
|
|
$model = $model->where('p.cid', $cid);
|
|
$model = $model->where('p.k_id', 0);
|
|
$model = $model->where('p.is_refund', 0);
|
|
$model = $model->order('p.add_time desc');
|
|
$model = $model->join('user u', 'u.uid = p.uid');
|
|
$list = $model->select();
|
|
$list = count($list) ? $list->toArray() : [];
|
|
if ($isAll) {
|
|
$pindAll = [];
|
|
foreach ($list as &$v) {
|
|
$v['count'] = self::getPinkPeople($v['id'], $v['people']);
|
|
$v['h'] = date('H', $v['stop_time']);
|
|
$v['i'] = date('i', $v['stop_time']);
|
|
$v['s'] = date('s', $v['stop_time']);
|
|
$pindAll[] = $v['id'];//开团团长ID
|
|
$v['stop_time'] = (int)$v['stop_time'];
|
|
}
|
|
return [$list, $pindAll];
|
|
}
|
|
return $list;
|
|
}
|
|
|
|
/**
|
|
* 获取还差几人
|
|
* @param $kid
|
|
* @param $people
|
|
* @return string
|
|
*/
|
|
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|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 = 0, $uid = 0)
|
|
{
|
|
$pink = self::where('k_id|id', $id)->where('uid', $uid)->where('is_refund', 0)->count();
|
|
if ($pink) return true;
|
|
else return false;
|
|
}
|
|
|
|
|
|
/**
|
|
* 判断是否发送模板消息 0 未发送 1已发送
|
|
* @param $uidAll
|
|
* @return int|string
|
|
*/
|
|
public static function isTpl($uidAll, $pid)
|
|
{
|
|
if (is_array($uidAll))
|
|
$count = self::where('uid', 'IN', implode(',', $uidAll))->where('is_tpl', 0)->where('id|k_id', $pid)->count();
|
|
else
|
|
$count = self::where('uid', $uidAll)->where('is_tpl', 0)->where('k_id|id', $pid)->count();
|
|
return $count;
|
|
}
|
|
|
|
/**
|
|
* 拼团成功提示模板消息
|
|
* @param $uidAll
|
|
* @param $pid
|
|
*/
|
|
public static function orderPinkAfter($uidAll, $pid)
|
|
{
|
|
$pinkInfo = self::where('p.id|p.k_id', $pid)->alias('p')->field(['p.people', 't.title', 'p.add_time', 'p.order_id', 'u.nickname'])->join('user u', 'u.uid = p.uid')->join('store_combination t', 'p.cid = t.id')->find();
|
|
if (!$pinkInfo) return false;
|
|
foreach ($uidAll as $key => &$item) {
|
|
$openid = WechatUser::uidToOpenid($item, 'openid');
|
|
$routineOpenid = WechatUser::uidToOpenid($item, 'routine_openid');
|
|
if ($openid) { //公众号模板消息
|
|
$firstWeChat = '亲，您的拼团已经完成了';
|
|
$keyword1WeChat = self::where('id|k_id', $pid)->where('uid', $item)->value('order_id');
|
|
$keyword2WeChat = self::alias('p')->where('p.id|p.k_id', $pid)->where('p.uid', $item)->join('store_combination c', 'c.id=p.cid')->value('c.title');
|
|
$remarkWeChat = '点击查看订单详情';
|
|
$urlWeChat = Route::buildUrl('order/detail/' . $keyword1WeChat)->suffix('')->domain(true)->build();
|
|
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_SUCCESS, [
|
|
'first' => $firstWeChat,
|
|
'keyword1' => $keyword1WeChat,
|
|
'keyword2' => $keyword2WeChat,
|
|
'remark' => $remarkWeChat
|
|
], $urlWeChat);
|
|
} else if ($routineOpenid) {// 小程序模板消息
|
|
RoutineTemplate::sendPinkSuccess($item, $pinkInfo['title'], $pinkInfo['nickname'] ?? '', $pinkInfo['add_time'], $pinkInfo['people'], '/pages/order_details/index?order_id=' . $pinkInfo['order_id']);
|
|
}
|
|
}
|
|
self::beginTrans();
|
|
$res1 = self::where('uid', 'IN', implode(',', $uidAll))->where('id|k_id', $pid)->update(['is_tpl' => 1]);
|
|
self::checkTrans($res1);
|
|
}
|
|
|
|
/**
|
|
* 拼团失败发送的模板消息
|
|
* @param $uid
|
|
* @param $pid
|
|
*/
|
|
public static function orderPinkAfterNo($uid, $pid, $formId = '', $fillTilt = '', $isRemove = false)
|
|
{
|
|
$store = self::alias('p')->where('p.id|p.k_id', $pid)->field('c.*')->where('p.uid', $uid)->join('store_combination c', 'c.id=p.cid')->find();
|
|
$pink = self::where('id|k_id', $pid)->where('uid', $uid)->find();
|
|
$openid = WechatUser::uidToOpenid($uid, 'openid');
|
|
$routineOpenid = WechatUser::uidToOpenid($uid, 'routine_openid');
|
|
if ($isRemove) {
|
|
if ($openid) {//公众号发送模板消息
|
|
$urlWeChat = Route::buildUrl('order/detail/' . $pink->order_id)->suffix('')->domain(true)->build();
|
|
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_LOSE, [
|
|
'first' => '亲，您的拼团取消',
|
|
'keyword1' => $store->title,
|
|
'keyword2' => $pink->price,
|
|
'keyword3' => $pink->price,
|
|
'remark' => '点击查看订单详情'
|
|
], $urlWeChat);
|
|
} else if ($routineOpenid) {//小程序发送模板消息
|
|
RoutineTemplate::sendPinkFail($uid, $store->title, $pink->people, '亲，您的拼团取消，点击查看订单详情', '/pages/order_details/index?order_id=' . $pink->order_id);
|
|
}
|
|
} else {
|
|
if ($openid) {//公众号发送模板消息
|
|
$urlWeChat = Route::buildUrl('order/detail/' . $pink->order_id)->suffix('')->domain(true)->build();
|
|
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_LOSE, [
|
|
'first' => '亲，您的拼团失败',
|
|
'keyword1' => $store->title,
|
|
'keyword2' => $pink->price,
|
|
'keyword3' => $pink->price,
|
|
'remark' => '点击查看订单详情'
|
|
], $urlWeChat);
|
|
} else if ($routineOpenid) {//小程序发送模板消息
|
|
RoutineTemplate::sendPinkFail(
|
|
$uid,
|
|
$store->title,
|
|
$pink->people,
|
|
'亲，您拼团失败，自动为您申请退款，退款金额为：' . $pink->price,
|
|
'/pages/order_details/index?order_id=' . $pink->order_id
|
|
);
|
|
}
|
|
}
|
|
self::where('id', $pid)->update(['status' => 3, 'stop_time' => time()]);
|
|
self::where('k_id', $pid)->update(['status' => 3, 'stop_time' => time()]);
|
|
}
|
|
|
|
/**
|
|
* 获取当前拼团数据返回订单编号
|
|
* @param $id
|
|
* @return array|false|\PDOStatement|string|\think\Model
|
|
*/
|
|
public static function getCurrentPink($id, $uid)
|
|
{
|
|
$pink = self::where('id', $id)->where('uid', $uid)->find();
|
|
if (!$pink) $pink = self::where('k_id', $id)->where('uid', $uid)->find();
|
|
return StoreOrder::where('id', $pink['order_id_key'])->value('order_id');
|
|
}
|
|
|
|
public static function systemPage($where)
|
|
{
|
|
$model = new self;
|
|
$model = $model->alias('p');
|
|
$model = $model->field('p.*,c.title');
|
|
if ($where['data'] !== '') {
|
|
list($startTime, $endTime) = explode(' - ', $where['data']);
|
|
$model = $model->where('p.add_time', '>', strtotime($startTime));
|
|
$model = $model->where('p.add_time', '<', strtotime($endTime));
|
|
}
|
|
if ($where['status']) $model = $model->where('p.status', $where['status']);
|
|
$model = $model->where('p.k_id', 0);
|
|
$model = $model->order('p.id desc');
|
|
$model = $model->join('StoreCombination c', 'c.id=p.cid');
|
|
return self::page($model, function ($item) use ($where) {
|
|
$item['count_people'] = bcadd(self::where('k_id', $item['id'])->count(), 1, 0);
|
|
}, $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();
|
|
$openid = WechatUser::uidToOpenid($order['uid'], 'openid');
|
|
$routineOpenid = WechatUser::uidToOpenid($order['uid'], 'routine_openid');
|
|
$product = StoreCombination::where('id', $order['combination_id'])->field('effective_time,title')->find();
|
|
if ($product) {
|
|
$stop_time = bcmul($product->effective_time, 3600, 0);
|
|
if ($order['pink_id']) {//拼团存在
|
|
$pink_id = $order['pink_id'];
|
|
$pink_one = self::where('id', $order['pink_id'])->find();
|
|
if($pink_one['kid']){
|
|
$pink_id = $pink_one['k_id'];
|
|
$pink_one = self::where('id', $pink_id)->find();
|
|
}
|
|
$res = false;
|
|
$pink['uid'] = $order['uid'];//用户id
|
|
if (self::isPinkBe($pink, $order['pink_id'])) return false;
|
|
$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
|
|
foreach ($order['cartInfo'] as $v) {
|
|
$pink['cid'] = $v['combination_id'];//拼团产品id
|
|
$pink['pid'] = $v['product_id'];//产品id
|
|
$pink['people'] = StoreCombination::where('id', $v['combination_id'])->value('people');//几人拼团
|
|
$pink['price'] = $v['productInfo']['price'];//单价
|
|
$pink['stop_time'] = 0;//结束时间
|
|
$pink['add_time'] = time();//开团时间
|
|
$res = self::create($pink)->toArray();
|
|
}
|
|
if ($openid) { //公众号模板消息
|
|
$urlWeChat = Route::buildUrl('order/detail/' . $order['order_id'])->suffix('')->domain(true)->build();
|
|
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_SUCCESS, [
|
|
'first' => '亲，您已成功参与拼团',
|
|
'keyword1' => $order['order_id'],
|
|
'keyword2' => $product->title,
|
|
'remark' => '点击查看订单详情'
|
|
], $urlWeChat);
|
|
} else if ($routineOpenid) {
|
|
$nickname = User::where('uid', self::where('id', $pink['k_id'])->value('uid'))->value('nickname');
|
|
RoutineTemplate::sendPinkSuccess(
|
|
$order['uid'], $product->title,
|
|
$nickname,
|
|
$pink['add_time'],
|
|
$pink['people'],
|
|
'/pages/order_details/index?order_id=' . $pink['order_id']
|
|
);
|
|
}
|
|
//处理拼团完成
|
|
list($pinkAll, $pinkT, $count, $idAll, $uidAll) = self::getPinkMemberAndPinkK($pink);
|
|
if ($pinkT['status'] == 1) {
|
|
if (!$count)//组团完成
|
|
self::PinkComplete($uidAll, $idAll, $pink['uid'], $pinkT);
|
|
else
|
|
self::PinkFail($pinkAll, $pinkT, 0);
|
|
}
|
|
if ($res) {
|
|
$cache_pink = Cache::get(md5('store_pink_'.$pink_id));
|
|
$number = 1;
|
|
if($cache_pink){
|
|
$number = bcadd($cache_pink['now_people'], $number, 0);
|
|
}
|
|
//设置团内人数
|
|
Cache::set(md5('store_pink_'.$pink_id), ['people' => $pink_one['people'], 'now_people' => $number], bcsub($pink_one['stop_time'], time(), 0));
|
|
return true;
|
|
} else return false;
|
|
} else {
|
|
$res = false;
|
|
$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
|
|
foreach ($order['cartInfo'] as $v) {
|
|
$pink['cid'] = $v['combination_id'];//拼团产品id
|
|
$pink['pid'] = $v['product_id'];//产品id
|
|
$pink['people'] = StoreCombination::where('id', $v['combination_id'])->value('people');//几人拼团
|
|
$pink['price'] = $v['productInfo']['price'];//单价
|
|
$pink['stop_time'] = bcadd(time(), $stop_time, 0);//结束时间
|
|
$pink['add_time'] = time();//开团时间
|
|
$res1 = self::create($pink)->toArray();
|
|
$res2 = StoreOrder::where('id', $order['id'])->update(['pink_id' => $res1['id']]);
|
|
$res = $res1 && $res2;
|
|
}
|
|
// 开团成功发送模板消息
|
|
if ($openid && $order['is_channel'] != 1) { //公众号模板消息
|
|
$urlWeChat = Route::buildUrl('/order/detail/' . $pink['order_id'])->suffix('')->domain(true)->build();
|
|
WechatTemplateService::sendTemplate($openid, WechatTemplateService::OPEN_PINK_SUCCESS, [
|
|
'first' => '您好，您已成功开团！赶紧与小伙伴们分享吧！！！',
|
|
'keyword1' => $product->title,
|
|
'keyword2' => $pink['total_price'],
|
|
'keyword3' => $pink['people'],
|
|
'remark' => '点击查看订单详情'
|
|
], $urlWeChat);
|
|
} else if ($routineOpenid && $order['is_channel'] == 1) {
|
|
$nickname = User::where('uid', $order['uid'])->value('nickname');
|
|
RoutineTemplate::sendPinkSuccess(
|
|
$order['uid'], $product->title,
|
|
$nickname,
|
|
$pink['add_time'],
|
|
$pink['people'],
|
|
'/pages/order_details/index?order_id=' . $pink['order_id']
|
|
);
|
|
}
|
|
if ($res){
|
|
//存入缓存
|
|
Cache::set(md5('store_pink_'.$res1['id']), ['people' => $pink['people'], 'now_people' => 1], $stop_time);
|
|
return true;
|
|
} else return false;
|
|
}
|
|
} else {
|
|
Log::error('拼团支付成功读取产品数据失败订单号：' . $order['order_id']);
|
|
}
|
|
}
|
|
|
|
/*
|
|
* 获取一条今天正在拼团的人的头像和名称
|
|
* */
|
|
public static function getPinkSecondOne()
|
|
{
|
|
$addTime = mt_rand(time() - 30000, time());
|
|
return self::where('p.add_time', '>', $addTime)->alias('p')->where('p.status', 1)->join('User u', 'u.uid=p.uid')->field('u.nickname,u.avatar as src')->find();
|
|
}
|
|
/**
|
|
* 拼团成功后给团长返佣金
|
|
* @param int $id
|
|
* @return bool
|
|
*/
|
|
// public static function setRakeBackColonel($id = 0){
|
|
// if(!$id) return false;
|
|
// $pinkRakeBack = self::where('id',$id)->field('people,price,uid,id')->find()->toArray();
|
|
// $countPrice = bcmul($pinkRakeBack['people'],$pinkRakeBack['price'],2);
|
|
// if(bcsub((float)$countPrice,0,2) <= 0) return true;
|
|
// $rakeBack = (sys_config('rake_back_colonel') ?: 0)/100;
|
|
// if($rakeBack <= 0) return true;
|
|
// $rakeBackPrice = bcmul($countPrice,$rakeBack,2);
|
|
// if($rakeBackPrice <= 0) return true;
|
|
// $mark = '拼团成功,奖励佣金'.floatval($rakeBackPrice);
|
|
// self::beginTrans();
|
|
// $res1 = UserBill::income('获得拼团佣金',$pinkRakeBack['uid'],'now_money','colonel',$rakeBackPrice,$id,0,$mark);
|
|
// $res2 = User::bcInc($pinkRakeBack['uid'],'now_money',$rakeBackPrice,'uid');
|
|
// $res = $res1 && $res2;
|
|
// self::checkTrans($res);
|
|
// return $res;
|
|
// }
|
|
|
|
/*
|
|
* 拼团完成更改数据写入内容
|
|
* @param array $uidAll 当前拼团uid
|
|
* @param array $idAll 当前拼团pink_id
|
|
* @param array $pinkT 团长信息
|
|
* @return int
|
|
* */
|
|
public static function PinkComplete($uidAll, $idAll, $uid, $pinkT)
|
|
{
|
|
$pinkBool = 6;
|
|
try {
|
|
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;
|
|
} catch (\Exception $e) {
|
|
self::setErrorInfo($e->getMessage());
|
|
return $pinkBool;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* 拼团失败 退款
|
|
* @param array $pinkAll 拼团数据,不包括团长
|
|
* @param array $pinkT 团长数据
|
|
* @param int $pinkBool
|
|
* @param boolen $isRunErr 是否返回错误信息
|
|
* @param boolen $isIds 是否返回记录所有拼团id
|
|
* @return int| boolen
|
|
* */
|
|
public static function PinkFail($pinkAll, $pinkT, $pinkBool, $isRunErr = true, $isIds = false)
|
|
{
|
|
self::startTrans();
|
|
$pinkIds = [];
|
|
try {
|
|
if ($pinkT['stop_time'] < time()) {//拼团时间超时 退款
|
|
$pinkBool = -1;
|
|
array_push($pinkAll, $pinkT);
|
|
foreach ($pinkAll as $v) {
|
|
if (StoreOrder::orderApplyRefund(StoreOrder::getPinkOrderId($v['order_id_key']), $v['uid'], '拼团时间超时') && self::isTpl($v['uid'], $pinkT['id'])) {
|
|
if ($isIds) array_push($pinkIds, $v['id']);
|
|
self::orderPinkAfterNo($pinkT['uid'], $pinkT['id']);
|
|
} else {
|
|
if ($isRunErr) return $pinkBool;
|
|
}
|
|
}
|
|
}
|
|
self::commit();
|
|
if ($isIds) return $pinkIds;
|
|
return $pinkBool;
|
|
} catch (\Exception $e) {
|
|
self::rollback();
|
|
return $pinkBool;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* 获取参团人和团长和拼团总人数
|
|
* @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;
|
|
}
|
|
$pinkT = $pinkT->hidden(['order_id', 'total_price', 'cid', 'pid', 'add_time', 'k_id', 'is_tpl', 'is_refund'])->toArray();
|
|
$pinkAll = $pinkAll->hidden(['total_price', 'cid', 'pid', 'add_time', 'k_id', 'is_tpl', 'is_refund'])->toArray();
|
|
$count = (int)bcadd(count($pinkAll), 1, 0);
|
|
$count = (int)bcsub($pinkT['people'], $count, 0);
|
|
$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 int $uid 用户id
|
|
* @param int $pink_id 团长id
|
|
* @return boolean
|
|
* */
|
|
public static function removePink($uid, $cid, $pink_id, $nextPinkT = null)
|
|
{
|
|
$pinkT = self::where('uid', $uid)
|
|
->where('id', $pink_id)
|
|
->where('cid', $cid)
|
|
->where('k_id', 0)
|
|
->where('is_refund', 0)
|
|
->where('status', 1)
|
|
->where('stop_time', '>', time())
|
|
->find();
|
|
if (!$pinkT) return self::setErrorInfo('未查到拼团信息，无法取消');
|
|
self::startTrans();
|
|
try {
|
|
list($pinkAll, $pinkT, $count, $idAll, $uidAll) = self::getPinkMemberAndPinkK($pinkT);
|
|
if (count($pinkAll)) {
|
|
if (self::getPinkPeople($pink_id, $pinkT['people'])) {
|
|
//拼团未完成，拼团有成员取消开团取 紧跟团长后拼团的人
|
|
if (isset($pinkAll[0])) $nextPinkT = $pinkAll[0];
|
|
} else {
|
|
//拼团完成
|
|
self::PinkComplete($uidAll, $idAll, $uid, $pinkT);
|
|
return self::setErrorInfo(['status' => 200, 'msg' => '拼团已完成，无法取消']);
|
|
}
|
|
}
|
|
//取消开团
|
|
if (StoreOrder::orderApplyRefund(StoreOrder::getPinkOrderId($pinkT['order_id_key']), $pinkT['uid'], '拼团取消开团') && self::isTpl($pinkT['uid'], $pinkT['id'])) {
|
|
$formId = RoutineFormId::getFormIdOne($uid);
|
|
if ($formId) RoutineFormId::delFormIdOne($formId);
|
|
self::orderPinkAfterNo($pinkT['uid'], $pinkT['id'], $formId, '拼团取消开团', true);
|
|
$cache_pink = Cache::get(md5('store_pink_'.$pinkT['id']));
|
|
if($cache_pink){
|
|
$number = bcsub($cache_pink['now_people'], 1, 0);
|
|
$cache_pink['now_people'] = $number;
|
|
Cache::set(md5('store_pink_'.$pinkT['id']), $cache_pink, bcsub($pinkT['stop_time'], time(), 0));
|
|
}
|
|
} else
|
|
return self::setErrorInfo(['status' => 200, 'msg' => StoreOrder::getErrorInfo()], true);
|
|
//当前团有人的时候
|
|
if (is_array($nextPinkT)) {
|
|
self::where('id', $nextPinkT['id'])->update(['k_id' => 0, 'status' => 1, 'stop_time' => $pinkT['stop_time']]);
|
|
self::where('k_id', $pinkT['id'])->update(['k_id' => $nextPinkT['id']]);
|
|
StoreOrder::where('order_id', $nextPinkT['order_id'])->update(['pink_id' => $nextPinkT['id']]);
|
|
}
|
|
self::commitTrans();
|
|
return true;
|
|
} catch (\Exception $e) {
|
|
return self::setErrorInfo($e->getLine() . ':' . $e->getMessage() . ':' . $e->getFile(), true);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取用户拼团到结束时间后还是拼团中的拼团
|
|
* @return mixed
|
|
*/
|
|
public static function pinkListEnd()
|
|
{
|
|
$model = new self;
|
|
$model = $model->field('id,people');//开团编号
|
|
$model = $model->where('stop_time', '<=', time());//小于当前时间
|
|
$model = $model->where('status', 1);//进行中的拼团
|
|
$model = $model->where('k_id', 0);//团长
|
|
$model = $model->where('is_refund', 0);//未退款
|
|
return $model->select();
|
|
}
|
|
|
|
/**
|
|
* 拼团成功
|
|
* @param array $pinkRegimental 成功的团长编号
|
|
* @return bool
|
|
* @throws \Exception
|
|
*/
|
|
public static function successPinkEdit(array $pinkRegimental)
|
|
{
|
|
if (!count($pinkRegimental)) return true;
|
|
foreach ($pinkRegimental as $key => &$item) {
|
|
$pinkList = self::where('k_id', $item)->column('id', 'id');
|
|
$pinkList[] = $item;
|
|
$pinkList = implode(',', $pinkList);
|
|
self::setPinkStatus($pinkList);//修改完成状态
|
|
self::setPinkStopTime($pinkList);//修改结束时间
|
|
$pinkUidList = self::isTplPink($pinkList);//获取未发送模板消息的用户
|
|
if (count($pinkUidList)) self::sendPinkTemplateMessageSuccess($pinkUidList, $item);//发送模板消息
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 拼团失败
|
|
* @param array $pinkRegimental 失败的团长编号
|
|
* @return bool
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function failPinkEdit(array $pinkRegimental)
|
|
{
|
|
if (!count($pinkRegimental)) return true;
|
|
foreach ($pinkRegimental as $key => &$item) {
|
|
$pinkList = self::where('k_id', $item)->column('id', 'id');
|
|
$pinkList[] = $item;
|
|
$pinkList = implode(',', $pinkList);
|
|
self::refundPink($pinkList);//申请退款
|
|
self::pinkStopStatus($pinkList);//修改状态
|
|
$pinkUidList = self::isTplPink($pinkList);//获取未发送模板消息的用户
|
|
if (count($pinkUidList)) self::sendPinkTemplateMessageError($pinkUidList, $item);//发送模板消息
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 发送模板消息 失败
|
|
* @param array $pinkUidList 拼团用户编号
|
|
* @param $pink 团长编号
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function sendPinkTemplateMessageError(array $pinkUidList, $pink)
|
|
{
|
|
foreach ($pinkUidList as $key => &$item) {
|
|
$openid = WechatUser::uidToOpenid($item, 'openid');
|
|
$routineOpenid = WechatUser::uidToOpenid($item, 'routine_openid');
|
|
$store = self::alias('p')->where('p.id|p.k_id', $pink)->field('c.*')->where('p.uid', $item)->join('store_combination c', 'c.id = p.cid')->find();
|
|
$pink = self::where('id|k_id', $pink)->where('uid', $item)->find();
|
|
if ($openid) {
|
|
//公众号模板消息
|
|
$urlWeChat = Route::buildUrl('order/detail/' . $pink->order_id)->suffix('')->domain(true)->build();
|
|
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_LOSE, [
|
|
'first' => '亲，您的拼团失败',
|
|
'keyword1' => $store->title,
|
|
'keyword2' => $pink->price,
|
|
'keyword3' => $pink->price,
|
|
'remark' => '点击查看订单详情'
|
|
], $urlWeChat);
|
|
} else if ($routineOpenid) {
|
|
//小程序模板消息
|
|
RoutineTemplate::sendPinkFail(
|
|
$item,
|
|
$store->title,
|
|
$pink->people,
|
|
'亲，您拼团失败，自动为您申请退款，退款金额为：' . $pink->price,
|
|
'/pages/order_details/index?order_id=' . $pink->order_id
|
|
);
|
|
}
|
|
}
|
|
self::where('uid', 'IN', implode(',', $pinkUidList))->where('id|k_id', $pink)->update(['is_tpl' => 1]);
|
|
}
|
|
|
|
/**
|
|
* 拼团失败 申请退款
|
|
* @param $pinkList
|
|
* @return bool
|
|
*/
|
|
public static function refundPink($pinkList)
|
|
{
|
|
$refundPinkList = self::where('id', 'IN', $pinkList)->column('order_id,uid', 'id');
|
|
if (!count($refundPinkList)) return true;
|
|
foreach ($refundPinkList as $key => &$item) {
|
|
StoreOrder::orderApplyRefund($item['order_id'], $item['uid'], '拼团时间超时');//申请退款
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 拼团结束修改状态
|
|
* @param $pinkList
|
|
* @return StorePink
|
|
*/
|
|
public static function pinkStopStatus($pinkList)
|
|
{
|
|
return self::where('id', 'IN', $pinkList)->update(['status' => 3]);
|
|
}
|
|
|
|
/**
|
|
* 获取未发送模板消息的用户
|
|
* @param $pinkList 拼团编号
|
|
* @return array
|
|
*/
|
|
public static function isTplPink($pinkList)
|
|
{
|
|
return self::where('id', 'IN', $pinkList)->where('is_tpl', 0)->column('uid', 'uid');
|
|
}
|
|
|
|
/**
|
|
* 发送模板消息 成功
|
|
* @param array $pinkUidList 拼团用户编号
|
|
* @param $pink 团长编号
|
|
* @throws \Exception
|
|
*/
|
|
public static function sendPinkTemplateMessageSuccess(array $pinkUidList, $pink)
|
|
{
|
|
foreach ($pinkUidList as $key => &$item) {
|
|
$openid = WechatUser::uidToOpenid($item, 'openid');
|
|
$routineOpenid = WechatUser::uidToOpenid($item, 'routine_openid');
|
|
$nickname = WechatUser::uidToOpenid(self::where('id', $pink)->value('uid'), 'nickname');
|
|
if ($openid) {
|
|
//公众号模板消息
|
|
$firstWeChat = '亲，您的拼团已经完成了';
|
|
$keyword1WeChat = self::where('id|k_id', $pink)->where('uid', $item)->value('order_id');
|
|
$keyword2WeChat = self::alias('p')->where('p.id|p.k_id', $pink)->where('p.uid', $item)->join('store_combination c', 'c.id=p.cid')->value('c.title');
|
|
$remarkWeChat = '点击查看订单详情';
|
|
$urlWeChat = Route::buildUrl('order/detail/' . $keyword1WeChat)->suffix('')->domain(true)->build();
|
|
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_USER_GROUPS_SUCCESS, [
|
|
'first' => $firstWeChat,
|
|
'keyword1' => $keyword1WeChat,
|
|
'keyword2' => $keyword2WeChat,
|
|
'remark' => $remarkWeChat
|
|
], $urlWeChat);
|
|
} else if ($routineOpenid) {
|
|
//小程序模板消息
|
|
$pinkInfo = self::where('k.id|k.k_id', $pink)->alias('k')->where('k.uid', $item)
|
|
->field(['k.order_id', 'k.people', 'k.add_time', 'c.title'])
|
|
->join('store_combination c', 'c.id = k.cid')->find();
|
|
RoutineTemplate::sendPinkSuccess(
|
|
$item, $pinkInfo['title'] ?? '',
|
|
$nickname,
|
|
$pinkInfo['add_time'] ?? 0,
|
|
$pinkInfo['people'] ?? 0,
|
|
'/pages/order_details/index?order_id=' . $pinkInfo['order_id'] ?? ''
|
|
);
|
|
}
|
|
}
|
|
self::where('uid', 'IN', implode(',', $pinkUidList))->where('id|k_id', $pink)->update(['is_tpl' => 1]);
|
|
}
|
|
|
|
/**
|
|
* 修改到期的拼团状态
|
|
* @return bool
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
*/
|
|
public static function statusPink()
|
|
{
|
|
$pinkListEnd = self::pinkListEnd();
|
|
if (!$pinkListEnd) return true;
|
|
$pinkListEnd = $pinkListEnd->toArray();
|
|
$failPinkList = [];//拼团失败
|
|
$successPinkList = [];//拼团失败
|
|
foreach ($pinkListEnd as $key => &$value) {
|
|
$countPeople = (int)bcadd(self::where('k_id', $value['id'])->count(), 1, 0);
|
|
if ($countPeople < $value['people'])
|
|
$failPinkList[] = $value['id'];
|
|
else
|
|
$successPinkList[] = $value['id'];
|
|
}
|
|
$success = self::successPinkEdit($successPinkList);
|
|
$error = self::failPinkEdit($failPinkList);
|
|
$res = $success && $error;
|
|
if (!$res)
|
|
throw new \Exception('拼团订单取消失败！');
|
|
}
|
|
} |