xmpt/app/models/store/StorePink.php

<?php
/**
 *
 * @author: xaboy<365615158@qq.com>
 * @day: 2017/12/18
 */

namespace app\models\store;

use app\models\store\StoreOrder as StoreOrderModel;
use app\admin\model\order\StoreOrderStatus;
use app\models\routine\RoutineFormId;
use app\models\routine\RoutineTemplate;
use app\models\system\SystemUserLevel;
use app\models\user\User;
use app\models\user\UserBill;
use app\models\user\UserLevel;
use app\models\user\WechatUser;
use crmeb\basic\BaseModel;
use crmeb\repositories\OrderRepository;
use crmeb\services\JsonService as Json;
use crmeb\services\MiniProgramService;
use crmeb\services\UtilService;
use crmeb\services\WechatService;
use crmeb\services\WechatTemplateService;
use crmeb\traits\ModelTrait;
use function dump;
use function implode;
use function is_array;
use think\Exception;
use think\facade\Db;
use think\facade\Log;
use think\facade\Route;

/**
 * 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,u.spread_uid');
//        $model = $model->where('id', $id);
//        $model = $model->join('user u', 'u.uid = p.uid');
        $model = $model->field('p.*,u.nickname,u.spread_uid,u.avatar,s.use_integral_pink,u.level,s.pay_price');
        $model = $model->where("p.id={$id}");
//        $model = $model->where('p.is_refund', 0);
//        $model = $model->where('p.status!=3');
        $model = $model->join('user u', 'u.uid = p.uid');
        $model = $model->join('store_order s', 's.order_id = p.order_id');
        $model = $model->order('p.id asc');
        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.spread_uid,u.avatar,s.use_integral_pink');
//        $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->join('store_order s', 's.order_id = p.order_id');
//        $model = $model->order('p.id asc');
        $model = $model->field('p.*,u.nickname,u.spread_uid,u.avatar,s.use_integral_pink,u.level,s.pay_price');
        $model = $model->where("p.k_id={$id}");
//        $model = $model->where('p.is_refund', 0);
//        $model = $model->where('p.status!=3');
        $model = $model->join('user u', 'u.uid = p.uid');
        $model = $model->join('store_order s', 's.order_id = p.order_id');
        $model = $model->order('p.id asc');
        return $model->select();
    }

    /**
     * 获取拼团的所有成员，包括团长
     * @param $id
     * @return mixed
     */
    public static function getPinkAllMember($id)
    {
        $model = new self();
        $model = $model->alias('p');
        $model = $model->field('p.*,u.nickname,u.spread_uid,u.avatar,s.use_integral_pink,u.level,s.pay_price');
        $model = $model->where("p.k_id={$id} or p.id={$id}");
//        $model = $model->where('p.is_refund', 0);
//        $model = $model->where('p.status!=3');
        $model = $model->join('user u', 'u.uid = p.uid', "left");
        $model = $model->join('store_order s', 's.order_id = p.order_id', "left");
        $model = $model->order('p.id asc');
        $rs = $model->select();
        return $rs;
    }

    /**
     * 设置结束时间
     * @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,p.order_id,p.total_price');
        $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'];
                //获取unique
                $cartId = StoreOrderModel::where('order_id', $v['order_id'])->value('cart_id');
                $cartId = str_replace('[', '', $cartId);
                $cartId = str_replace(']', '', $cartId);
                $v['unique'] = Db::name('store_cart')->where('id', '=', $cartId)->value('product_attr_unique');
            }
            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();
                $urlWeChat = config('wx.wx_notify_jump_url') . $keyword1WeChat;
                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();
                $urlWeChat = config('wx.wx_notify_jump_url') . $pink->order_id;
                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();
                $urlWeChat = config('wx.wx_notify_jump_url') . $pink->order_id;
                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, '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)
    {
        @file_put_contents('zxr1.txt', json_encode($order));
        //获取一天最大的营业
        // $top_num=sys_config('pink_suceess_num');
        $order = StoreOrder::tidyOrder($order, true);
        @file_put_contents('zxr.txt', $order['pink_id']);
        //获取这个用户今日拼中几次
        //$user_pink_num=self::where('uid',$order['uid'])->where('status',2)->whereTime('add_time','today')->count();
        //if($user_pink_num>=$top_num) return false;
        $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();
        $people = StorePink::where("id", $order['pink_id'])->value('people');
        $count = StorePink::where('k_id', $order['pink_id'])->count();
        $count = $count + 1;
        if ($count >= $people) {
            $order['pink_id'] = 0;
        }
        if ($order['pink_id']) {
            if (StorePink::getIsPinkUid($order['pink_id'], $order['uid'])) {
                return false;
            };
        }
        if ($product) {
            if ($order['pink_id']) {//拼团存在
                @file_put_contents('zxc.txt', $order['pink_id']);
                $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();//开团时间
//                    Log::write('pink1-'.json_encode($pink),'error');
                    $res = self::create($pink)->toArray();
                }
                if ($openid) { //公众号模板消息
//                    $urlWeChat = Route::buildUrl('order/detail/' . $order['order_id'])->suffix('')->domain(true)->build();
                    $urlWeChat = config('wx.wx_notify_jump_url') . $order['order_id'];
                    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);
                        self::makerandpink($pinkT['id']);
                    } else
                        self::PinkFail($pinkAll, $pinkT, 0);
                }
                if ($res) 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(), bcmul($product->effective_time, 3600, 0), 0);//结束时间
                    $pink['add_time'] = time();//开团时间
//                    Log::write('pink2-'.json_encode($pink),'error');
                    $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();
                    $urlWeChat = config('wx.wx_notify_jump_url') . $pink['order_id'];
                    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) return true;
                else return false;
            }
        } else {
            Log::error('拼团支付成功读取产品数据失败订单号：' . $order['order_id']);
        }
    }

    public static function autoPink($order)
    {
        //$order = StoreOrder::tidyOrder($order, true)->toArray();
        //$time = time();
        try {
            //$openid = WechatUser::uidToOpenid($order['uid'], 'openid');//
            //$routineOpenid = WechatUser::uidToOpenid($order['uid'], 'routine_openid');//
            //查找所有拼团正在进行中的
            $all_pink = StorePink::where('is_refund', 0)->where('status', 1)->order('add_time asc')->select()->toArray();
            @file_put_contents('qaz.txt', json_encode($all_pink));
            $p = false;
            //$arr=[];//又满足条件拼团
            if ($all_pink) {
                foreach ($all_pink as $value) {
                    $people = StorePink::where("id", $value['id'])->value('people');
                    $count = StorePink::where('k_id', $value['id'])->count();
                    $count = $count + 1;
                    if ($people > $count) {//表示没有拼满
                        $data['pink_id'] = $value['id'];
                        @file_put_contents('qaq.txt', json_encode($data));
                        StoreOrderModel::edit($data, $order['id']);
                        $order = StoreOrderModel::where('id', $order['id'])->find();
                        @file_put_contents('qaq1.txt', json_encode($data));
                        self::createPink($order);
                        break;
                    }

                }
                return true;
            }
            @file_put_contents('qae.txt', $p);
            if ($p == false) {
                $data['pink_id'] = 0;
                StoreOrderModel::edit($data, $order['id']);
                $order = StoreOrderModel::where('id', $order['id'])->find();
                self::createPink($order);
            }
            return true;
            //$pinkingCount = StoreOrder::where("is_del=0 and is_system_del=0 and paid=1 and refund_status=0 and is_auto_pink=1 and is_ok=0 and combination_id={$order['combination_id']} and pay_price={$order['pay_price']} and close_time>{$time} and uid!={$order['uid']}")->count();
            //$people = StoreCombination::where('id', $order['combination_id'])->value('people');
//            Db::startTrans();
//
//            $res1 = null;
//            if (($pinkingCount >= $people - 1) && !cache('pinking_' . $order['combination_id'])) { //满足自动开团人数，且没有正在自动组团
//                Log::write('开始自动拼团-'.$order['id'], 'error');
//                cache('pinking_' . $order['combination_id'], 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
//                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'] = time();//结束时间
//                    $pink['add_time'] = time();//开团时间
//                    $pink['status'] = 2;//开团状态，设置为2完成
//                    $res1 = self::create($pink)->toArray();
//                    $res2 = StoreOrder::where('id', $order['id'])->update(['pink_id' => $res1['id'], 'is_ok' => 1]);
//                }
//
//                $orderJoin = StoreOrder::where("is_del=0 and is_system_del=0 and paid=1 and refund_status=0 and is_auto_pink=1 and is_ok=0 and combination_id={$order['combination_id']} and pay_price={$order['pay_price']} and close_time>{$time} and uid!={$order['uid']}")
//                    ->order('id asc')
//                    ->limit($people - 1)->select();  //这些当做团员
//                foreach ($orderJoin as $key => $val) {
//                    $orderTemp = StoreOrder::tidyOrder($val, true)->toArray();
//                    $pink['uid'] = $orderTemp['uid'];//用户id
//                    $pink['order_id'] = $orderTemp['order_id'];//订单id  生成
//                    $pink['order_id_key'] = $orderTemp['id'];//订单id  数据库id
//                    $pink['total_num'] = $orderTemp['total_num'];//购买个数
//                    $pink['total_price'] = $orderTemp['pay_price'];//总金额
//                    $pink['k_id'] = $res1['id'];//拼团id
//                    foreach ($orderTemp['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'] = time();//结束时间
//                        $pink['add_time'] = time();//开团时间
//                        $pink['status'] = 2;//开团状态，设置为2完成
//                        self::create($pink)->toArray();
//                        StoreOrder::where('id', $orderTemp['id'])->update(['pink_id' => $res1['id'], 'is_ok' => 1]);
//                    }
//                }
//            }
//
//            Db::commit();
//            if ($res1) {    //创建拼团成功
//                cache('pinking_' . $order['combination_id'], null);  //删除缓存
//                $pinkList = self::where('k_id', $res1['id'])->column('id', 'id');
//                $pinkList[] = $res1['id'];
//
//                $pinkUidList = self::isTplPink($pinkList);//获取未发送模板消息的用户
//                if (count($pinkUidList)) self::sendPinkTemplateMessageSuccess($pinkUidList, $res1['id']);//发送模板消息
//
//                event('AfterAutoPink', [$res1['id']]);  //自动拼团后，计算奖励
//            }
//            return true;
//
        } catch (Exception $e) {
            Log::write('自动组团失败-' . $order['order_id'], 'error');
            Db::rollback();
            cache('pinking_' . $order['combination_id'], null);  //删除缓存
            return false;
        }
    }

    public static function closeAutoPink()
    {
        $time = time();
        $arr = StoreOrder::where("paid=1 and refund_status=0 and is_auto_pink=1 and is_ok=0 and close_time<{$time}")->select()->toArray();
        foreach ($arr as $item) {    //超过时间，自动退款关闭订单
            self::updateRefundY2($item['id'], $item['pay_price'], 1);
        }
    }

    /*
     * 获取一条今天正在拼团的人的头像和名称
     * */
    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) {
            Log::write($pinkT['id'] . '||' . $e->getMessage() . '||' . $e->getTraceAsString(), 'error');
            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) {
                    //Log::write('PinkFail1', 'error');
                    if (self::isTpl($v['uid'], $pinkT['id'])) {
                        //Log::write('PinkFail2', 'error');
                        self::isTpl($v['uid'], $pinkT['id']);
                        if ($v['pay_price'] && $v['pay_price'] > 0) {
                            self::updateRefundY2($v['order_id_key'], $v['pay_price']);
                        }
                        Db::name('store_pink')->where('id', '=', $v['id'])->update(['is_refund' => 1]);
//                        self::updateRefundY($v['order_id_key']);
//                        self::where('id', '=', $v['id'])->update(['is_refund' => 1]);
                        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);
            } 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;
        Log::write('拼团成功记录', 'error');
        Log::write(json_encode($pinkRegimental), 'error');
        try {
            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);//发送模板消息
                self::makerandpink($item);
            }
        } catch (Exception $e) {
            Log::write($e->getMessage() . '||' . $e->getTraceAsString(), 'error');
        }
        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;
        Log::write('拼团失败记录', 'error');
        Log::write(json_encode($pinkRegimental), 'error');
        foreach ($pinkRegimental as $key => &$item) {
//            $pinkList = self::where('k_id', $item)->column('id', 'id');
//            $pinkList[] = $item;
//            $pinkList = implode(',', $pinkList);
//            self::refundPink($pinkList);//申请退款
            //处理返现红包及退款
            $list = self::getPinkAllMember($item);
            $list = $list->toArray();
//            Log::write(json_encode($list), 'error');
            $pinkList = [];
            $uids = [];
            foreach ($list as $v) {
//                StoreOrder::orderApplyRefund($v['order_id'], $v['uid'], '拼团失败退款');
//                self::updateRefundY($v['order_id_key']);
//                Db::name('store_pink')->where('id', '=', $v['id'])->update(['is_refund' => 1]);
                if (isset($v['pay_price']) && $v['pay_price'] > 0) {
                    self::updateRefundY2($v['order_id_key'], $v['pay_price']);
                }
                $pinkList[] = $v['id'];
                $uids[] = $v['uid'];
//                Db::name('store_pink')->where('id', '=', $v['id'])->update(['is_refund' => 1]);
            }
//            $pinkList = implode(',', $pinkList);
            self::pinkStopStatus($pinkList);//修改状态
//            $pinkUidList = self::isTplPink($pinkList);//获取未发送模板消息的用户
            if (count($uids)) self::sendPinkTemplateMessageError($uids, $pinkList);//发送模板消息
        }
        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, $pinkList)
    {
        try {
            $uidArr = [];
            $len = sizeof($pinkUidList);
            for ($i = 0; $i < $len; $i++) {
//            foreach ($pinkUidList as $key => &$item) {
                $uidArr[] = $pinkUidList[$i];
                $openid = WechatUser::uidToOpenid($pinkUidList[$i], 'openid');
                $routineOpenid = WechatUser::uidToOpenid($pinkUidList[$i], 'routine_openid');
                $store = self::alias('p')->where('p.id', $pinkList[$i])->field('c.*')->join('store_combination c', 'c.id = p.cid')->find();
                $pink = self::where('id', $pinkList[$i])->find();
                if ($openid) {
                    //公众号模板消息
//                $urlWeChat = Route::buildUrl('order/detail/' . $pink->order_id)->suffix('')->domain(true)->build();
                    $urlWeChat = config('wx.wx_notify_jump_url') . $pink->order_id;
                    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(
                        $pinkUidList[$i],
                        $store['title'],
                        $pink['people'],
                        '亲，您拼团失败，自动为您申请退款，退款金额为：' . $pink['price'],
                        '/pages/order_details/index?order_id=' . $pink['order_id']
                    );
                }
                self::where('id', $pinkList[$i])->update(['is_tpl' => 1]);
            }
//            self::where('uid', 'in', $uidArr)->where('id|k_id', $pink)->update(['is_tpl' => 1]);
        } catch (Exception $e) {
            Log::write($e->getMessage() . '||' . $e->getFile() . '||' . $e->getLine() . '||' . $e->getTraceAsString(), 'error');
        }
    }

    /**
     * 拼团失败 申请退款
     * @param $pinkList
     * @return bool
     */
    public static function refundPink($pinkList)
    {
        //Log::write('refundPink1', 'error');
        $refundPinkList = self::where('id', 'IN', $pinkList)->column('order_id,uid,order_id_key,id', 'id');
        if (!count($refundPinkList)) return true;
        foreach ($refundPinkList as $key => &$item) {
//            StoreOrder::orderApplyRefund($item['order_id'], $item['uid'], '拼团时间超时');//申请退款
            StoreOrder::orderApplyRefund($item['order_id'], $item['uid'], '拼团时间超时');
            self::updateRefundY($item['order_id_key']);
            Db::name('store_pink')->where('id', '=', $item['id'])->update(['is_refund' => 1]);
        }
    }

    /**
     * 拼团结束修改状态
     * @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');
        return self::where('id', 'in', $pinkList)->field('uid')->where('is_tpl', 0)->select()->toArray();
    }

    /**
     * 发送模板消息  成功
     * @param array $pinkUidList 拼团用户编号
     * @param $pink  团长编号
     * @throws \Exception
     */
    public static function sendPinkTemplateMessageSuccess(array $pinkUidList, $pink)
    {
        $uids = [];
        foreach ($pinkUidList as $key => &$item) {
            $uids[] = $item['uid'];
            $openid = WechatUser::uidToOpenid($item['uid'], 'openid');
            $routineOpenid = WechatUser::uidToOpenid($item['uid'], '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['uid'])->value('order_id');
                $keyword2WeChat = self::alias('p')->where('p.id|p.k_id', $pink)->where('p.uid', $item['uid'])->join('store_combination c', 'c.id=p.cid')->value('c.title');
                $remarkWeChat = '点击查看订单详情';
//                $urlWeChat = Route::buildUrl('order/detail/' . $keyword1WeChat)->suffix('')->domain(true)->build();
                $urlWeChat = config('wx.wx_notify_jump_url') . $keyword1WeChat;
                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['uid'])
                    ->field(['k.order_id', 'k.people', 'k.add_time', 'c.title'])
                    ->join('store_combination c', 'c.id = k.cid')->find();
                RoutineTemplate::sendPinkSuccess(
                    $item['uid'], $pinkInfo['title'] ?? '',
                    $nickname,
                    $pinkInfo['add_time'] ?? 0,
                    $pinkInfo['people'] ?? 0,
                    '/pages/order_details/index?order_id=' . $pinkInfo['order_id'] ?? ''
                );
            }
        }
        self::where('uid', 'IN', $uids)->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'])
                $successPinkList[] = $value['id'];
            else
                $failPinkList[] = $value['id'];
        }
        $success = self::successPinkEdit($successPinkList);
        $error = self::failPinkEdit($failPinkList);
        $res = $success && $error;
        if (!$res)
            throw new \Exception('拼团订单取消失败！');
    }

    /**
     * 处理退款
     * @param $id
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    private static function updateRefundY($id)
    {
        $product = StoreOrder::get($id);

        $refund_price = $product->pay_price;
        $data['refund_price'] = $product->pay_price;
        $data['refund_status'] = 2;
        $refund_data['pay_price'] = $product['pay_price'];
        $refund_data['refund_price'] = $product['pay_price'];
        $usermoney = User::where('uid', $product['uid'])->value('now_money');
        $res1 = User::bcInc($product['uid'], 'now_money', $refund_price, 'uid');
        $res2 = UserBill::income('商品退款', $product['uid'], 'now_money', 'pay_product_refund', $refund_price, $product['id'], bcadd($usermoney, $refund_price, 2), '订单退款到余额' . floatval($refund_price) . '元');
        OrderRepository::storeOrderYueRefund($product, $refund_data);
        $resEdit = StoreOrder::edit($data, $id);
        OrderRepository::storeProductOrderRefundY($data, $id);
        \app\admin\model\order\StoreOrderStatus::setStatus($id, 'refund_price', '退款给用户' . $refund_price . '元');
    }

    /**
     * 获取中奖用户编号
     * 先根据投入积分求出未中奖用户，然后在获取中奖用户
     * @param $user
     * @return array
     */
    public static function getrand($user, $prize_person_num = 1)
    {
//        $prize_person_num = sys_config('pink_pay_person', 2);   //中奖人数
        $user_arr = []; //随机数组
        $n = 0;
        $count = 0;
        $sum = 0;
        foreach ($user as $v) {
            $sum += bcadd(100, $v['use_integral_pink'], 0);
        }
        foreach ($user as $v) {
            $user_arr [$n] = [
                'id' => $v['uid'],
                "start" => $count,
                "end" => $count + ($sum - bcadd(100, $v['use_integral_pink'], 0)),
            ];
            $n++;
            $count += ($sum - bcadd(100, $v['use_integral_pink'], 0)) + 1;
        }
        $prize_arr = [];
        $n = $prize_person_num;   //中奖人数
        while (sizeof($prize_arr) < $n) {
            $random = mt_rand(0, $count);   //随机数
            foreach ($user_arr as $item) {
                if ($random >= $item['start'] && $random <= $item['end'] && !isset($prize_arr[$item['id']])) {
                    $prize_arr[$item['id']] = $item['id'];
                    break;
                }
            }
        }
        return $prize_arr;
    }

    /**
     * 处理中奖及退款
     * @param $k_id
     */
    public static function makerandpink($k_id)
    {
        //BaseModel::beginTrans();
        try {

            $list = self::getPinkAllMember($k_id);//获取这个团所有的成员
            $list = $list->toArray();
            $arrq = $list;

            $pink_pay_person = Db::name('store_product')->where('id', '=', $list[0]['pid'])->value('pink_pay_person');  //拼团中奖人数
            $uids = self::getrand($list, $pink_pay_person); //获取所有中奖用户uid
            $pro = StoreProduct::where('id', $list[0]['pid'])->find();
            foreach ($list as &$item) {
                $item['pink_num'] = StoreOrder::where('id', $item['order_id_key'])->value('pink_num');
            }
            Log::write("测试拼团1", 'error');
            //处理返现红包及退款
            foreach ($arrq as $v) {
                if (!in_array($v['uid'], $uids)) {
//                    StoreOrder::orderApplyRefund($v['order_id'], $v['uid'], '未抽中分红退款');
//                    self::updateRefundY($v['order_id_key']);
//                    Db::name('store_pink')->where('id', '=', $v['id'])->update(['is_refund' => 1]);
                    if (isset($v['pay_price']) && $v['pay_price'] > 0) {
                        self::updateRefundY2($v['order_id_key'], $v['pay_price']);
                    }
                    Db::name('store_pink')->where('id', '=', $v['id'])->update(['is_refund' => 1]);
                    //拼团成功送wdc
                    $wdc = $pro['fail_wdc'] * $v['total_num'];
                    WechatUser::failGiveWdc($v['uid'], $wdc);
                    //拼中助力上级
                    WechatUser::OverLikeNum($v['uid']);
                    @file_put_contents('aa2.txt', 1111);
                    Log::write("未中奖退款" . $v['id'], 'error');
                } else {
                    //拼团成功送wdc
                    //$product = StoreOrderModel::get($v['order_id_key']);
                    $data['is_ok'] = 1;
                    $data['pink_num'] = 0;
                    StoreOrderModel::edit($data, $v['order_id_key']);
                    $wdc = $pro['success_wdc'] * $v['total_num'];
                    WechatUser::successGiveWdc($v['uid'], $wdc);
                    @file_put_contents('aa3.txt', 33333);
                }
                Db::name('store_pink')->where('id', '=', $v['id'])->update(['status' => 2]);    //评团成功，状态是2
                UserLevel::setLevelComplete($v['uid']);
            }
            Log::write("测试拼团2", 'error');

//            $profits = [];  //拼团总利润
//            $pink_reward_rate = 0;  //商品拼团奖励
//            $level1_reward_rate = 0;    //极差1奖励
//            $level2_reward_rate = 0;    //极差2奖励
//            $level3_reward_rate = 0;    //极差3奖励
//            $samelevel_reward_rate = 0; ///平级奖励
//            $pink_zhitui_prize = 0; ///直推奖励
//            $samelevelPerson = 0; ///平级中奖人数
            $pk_info = self::where('id', $k_id)->find();
            $pid = $pk_info['pid'];
            $res = StoreProduct::where('id', $pid)->find();
            $level1_reward_rate = $res['level1_reward_rate'] > 0 ? $res['level1_reward_rate'] : 0;
            $level1_reward_rate = bcmul($level1_reward_rate * 0.01, $pk_info['total_price'], 2);
            $level2_reward_rate = $res['level2_reward_rate'] > 0 ? $res['level2_reward_rate'] : 0;
            $level2_reward_rate = bcmul($level2_reward_rate * 0.01, $pk_info['total_price'], 2);
            $level3_reward_rate = $res['level3_reward_rate'] > 0 ? $res['level3_reward_rate'] : 0;
            $level3_reward_rate = bcmul($level3_reward_rate * 0.01, $pk_info['total_price'], 2);
            $samelevel_reward_rate = $res['samelevel_reward_rate'] > 0 ? $res['samelevel_reward_rate'] : 0;
            $samelevel_reward_rate = bcmul($samelevel_reward_rate * 0.01, $pk_info['total_price'], 2);
            $pink_zhitui_prize = $res['pink_zhitui_prize'] > 0 ? $res['pink_zhitui_prize'] : 0;
            $samelevelPerson = $res['samelevel_prise_maxperson'] > 0 ? $res['samelevel_prise_maxperson'] : 0;
//            foreach ($list as $item) {
//                if (in_array($item['uid'], $uids)) {    //计算中奖用户订单的利润
//                    @file_put_contents('aa112.txt',json_encode($item['uid']));
//                    @file_put_contents('aa113.txt',json_encode($item['order_id']));
//                    $res = Db::name('store_pink')->field('pro.pink_zhitui_prize,pro.samelevel_prise_maxperson,order.cost,pro.pink_reward_rate,pro.level1_reward_rate,pro.level2_reward_rate,pro.level3_reward_rate,pro.samelevel_reward_rate,pink.total_num,order.pay_price,order.pay_postage')->alias('pink')->where('pink.order_id', $item['order_id'])->join('store_product pro', 'pro.id=pink.pid')->join('store_order order', 'order.order_id=pink.order_id')->find();
//                    @file_put_contents('aa111.txt',json_encode($res));
//                    if (!$res) self::setErrorInfo('数据库里找不到数据', true);
//                    $p = ($res['pay_price'] - $res['pay_postage'] - $res['cost'] * $res['total_num']);
//                    $profits[] = $p > 0 ? $p : 0;
////                    $profits[] = $res['pay_price'];
//                    $pink_reward_rate = $res['pink_reward_rate'];
//                    $level1_reward_rate = $res['level1_reward_rate'];
//                    $level2_reward_rate = $res['level2_reward_rate'];
//                    $level3_reward_rate = $res['level3_reward_rate'];
//                    $samelevel_reward_rate = $res['samelevel_reward_rate'];
//                    $pink_zhitui_prize = $res['pink_zhitui_prize'];
//                    $samelevelPerson = $res['samelevel_prise_maxperson'];
//                }
//            }

//            Log::write($pink_reward_rate . '-' . $level1_reward_rate. '-' . $level2_reward_rate. '-' . $level3_reward_rate. '-' . $samelevel_reward_rate. '-' . $pink_zhitui_prize. '-' . $samelevelPerson, 'error');
//            Log::write(json_encode($profits), 'error');

            Log::write("测试拼团3", 'error');

//            $profit = 0;
//            foreach ($profits as $item) {
//                $profit += $item;
//            }
//
//            if($profit<=0){
//                Log::write('利润为0，直接返回','error');
//                BaseModel::commitTrans();
//                return;
//            }

            //直推奖励
//            $zhitui_person_nums = 0;    //计算直推奖人数
//            foreach ($list as $v) {
//                $spread_id = $v['spread_uid'];
//                if ($spread_id > 0 && User::be(['uid' => $spread_id])) {
//                    $zhitui_person_nums++;
//                }
//            }
//            if ($pink_zhitui_prize > 0 && $zhitui_person_nums) {
//                $pink_zhitui_prize = bcdiv($pink_zhitui_prize, $zhitui_person_nums, 2);
//                foreach ($list as $v) {
//                    $spread_id = $v['spread_uid'];
//                    if ($spread_id > 0) {
//                        if (User::be(['uid' => $spread_id])) {
//                            User::where('uid', $spread_id)->inc('wdc',$pink_zhitui_prize )->update();
//                            $balance = User::where('uid', $spread_id)->value('wdc');
//                            //Log::write("a1:".$balance,'error');
//                            UserBill::income('开团成功，直推奖励', $spread_id, 'wdc', 'wdc_brokerage', $pink_zhitui_prize , 0, $balance, '直推奖励', 1);
//                        }
//                    }
//                }
//            }

            Log::write("测试拼团3", 'error');
            //处理团长直推奖励
//            $spread_id = $pinkt['spread_uid'];
//            if ($spread_id > 0) {
//                User::where('uid', $spread_id)->inc('brokerage_price', bcmul($profit, sys_config('pink_zhitui_prize') * 0.01, 2))->update();
//                $balance = User::where('uid', $pinkt['uid'])->value('brokerage_price');
//                //Log::write("a2:".$balance,'error');
//                UserBill::income('开团成功，直推奖励', $spread_id, 'now_money', 'brokerage', bcmul($profit, sys_config('pink_zhitui_prize') * 0.01, 2), 0, $balance, '直推奖励', 1);
//            }

            //计算拼团佣金
//            $pNums = $list[0]['people'] - sizeof($uids);
//            if ($pNums > 0) {
//                Log::write($profit . '-' . $pNums . '-' . $pink_reward_rate, 'error');
//                $prizePink = bcmul($profit / $pNums, $pink_reward_rate * 0.01, 2);    //每个人拿到多少拼团奖励
////                Log::write(strval($prizePink) . "-222", 'error');
//                if ($prizePink > 0) {
//                    foreach ($list as $item) {
//                        if (!in_array($item['uid'], $uids)) {
//                            User::where('uid', $item['uid'])->inc('wdc', $prizePink)->update();
//                            $balance = User::where('uid', $item['uid'])->value('wdc');
//                            //Log::write("a3:".$balance,'error');
//                            UserBill::income('开团成功，拼团奖励', $item['uid'], 'wdc', 'brokerage', $prizePink, $item['order_id_key'], $balance, '拼团奖励', 1);
//
//                        }
//                    }
//                }
//            }

            //处理团长拼团佣金
//            User::where('uid', $pinkt['uid'])->inc('brokerage_price', $prizePink)->update();
//            $balance = User::where('uid', $pinkt['uid'])->value('brokerage_price');
//            //Log::write("a4:".$balance,'error');
//            UserBill::income('开团成功，拼团奖励', $pinkt['uid'], 'now_money', 'brokerage', $prizePink, 0, $balance, '拼团奖励', 1);
            Log::write("测试拼团4", 'error');
            //计算极差佣金
            $userList = User::select()->toArray();
            $qwe = [];
            $qww = [];
            foreach ($arrq as $key => $item) {
                $qwe[] = $item['uid'];
                $level = UserLevel::getUserLevel($item['uid']);
                $level_id_origin = 0;   //中奖用户等级
                if ($level !== false) {
                    $level_id_origin = UserLevel::getUserLevelInfo($level, 'grade');
                }
                // $profit = $profits[$key];
                $max_prize = max([$level1_reward_rate, $level2_reward_rate, $level3_reward_rate]);
                $levelPrizeLeave = $max_prize;
                $prevUser = null;
                $pids = [];
                UtilService::getparentid($userList, $item['uid'], $pids);
                @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]pids:" . json_encode($pids), 8);
                foreach ($pids as $k => $v) {
                    $qww[] = $v;
                    $user = User::where('uid', '=', $v)->find();
                    @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]prevUser:" . json_encode($prevUser) ?? 'no' . PHP_EOL, 8);
                    @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]user['uid']:" . $user['uid'] ?? 'no' . PHP_EOL, 8);
                    @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]user['wdc']:" . $user['wdc'] ?? 'no' . PHP_EOL, 8);
                    if (!$user)
                        continue;
                    $level = UserLevel::getUserLevel($v);
                    $level_id = 0;
                    if ($level !== false) {
                        $level_id = UserLevel::getUserLevelInfo($level, 'grade');
                    }
                    $user['level_id'] = $level_id;
                    @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]user['level_id']:" . $user['level_id'] . PHP_EOL, 8);
                    if ($prevUser == null) {
//                        if ($level_id <= $level_id_origin) {
//                            continue;
//                        }
                        try {
                            if ($level_id == 1) {
                                if ($level1_reward_rate > 0) {
                                    @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]user['UID']:" . $v . PHP_EOL, 8);
                                    User::where('uid', $v)->inc('wdc', $level1_reward_rate)->update();
                                    User::where('uid', $v)->inc('wdc_all', $level1_reward_rate)->update();
                                    $balance = $user['wdc'] + $level1_reward_rate;
                                    //Log::write("a5:".$balance,'error');
                                    UserBill::income('开团成功，推广奖励', $v, 'wdc', 'wdc_brokerage', $level1_reward_rate, 0, $balance, '推广奖励', 1);
                                    $levelPrizeLeave = $max_prize - $level1_reward_rate;
                                    $user['prevPrize'] = $level1_reward_rate;
                                }
                            } else if ($level_id == 2) {
                                if ($level2_reward_rate > 0) {
                                    @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]user['UID']:" . $v . PHP_EOL, 8);
                                    User::where('uid', $v)->inc('wdc', $level2_reward_rate)->update();
                                    User::where('uid', $v)->inc('wdc_all', $level2_reward_rate)->update();
                                    $balance = $user['wdc'] + $level2_reward_rate;
                                    //Log::write("a6:".$balance,'error');
                                    UserBill::income('开团成功，推广奖励', $v, 'wdc', 'wdc_brokerage', $level2_reward_rate, 0, $balance, '推广奖励', 1);
                                    $levelPrizeLeave = $max_prize - $level2_reward_rate;
                                    $user['prevPrize'] = $level2_reward_rate;
                                }
                            } else if ($level_id == 3) {
                                if ($level3_reward_rate > 0) {
                                    @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]user['UID']:" . $v . PHP_EOL, 8);
                                    User::where('uid', $v)->inc('wdc', $level3_reward_rate)->update();
                                    User::where('uid', $v)->inc('wdc_all', $level3_reward_rate)->update();
                                    $balance = $user['wdc'] + $level3_reward_rate;
                                    //Log::write("a7:".$balance,'error');
                                    UserBill::income('开团成功，推广奖励', $v, 'wdc', 'wdc_brokerage', $level3_reward_rate, 0, $balance, '推广奖励', 1);
                                    $levelPrizeLeave = $max_prize - $level3_reward_rate;
                                    $user['prevPrize'] = $level3_reward_rate;
                                }
                            }
                        } catch (\Exception $e) {
                            @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]error:" . $e->getMessage() . PHP_EOL, 8);
                        }

                        @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]levelPrizeLeave:" . $levelPrizeLeave . PHP_EOL, 8);
                    } else {
                        if ($level_id <= $prevUser['level_id']) {
                            continue;
                        } else {
                            if ($level_id == 2) {
                                if ($levelPrizeLeave > ($level2_reward_rate - $prevUser['prevPrize'])) {
                                    if (($level2_reward_rate - $prevUser['prevPrize']) > 0) {
                                        User::where('uid', $v)->inc('wdc', ($level2_reward_rate - $prevUser['prevPrize']))->update();
                                        User::where('uid', $v)->inc('wdc_all', ($level2_reward_rate - $prevUser['prevPrize']))->update();
                                        $balance = $user['wdc'] + ($level2_reward_rate - $prevUser['prevPrize']);
                                        //Log::write("a10:".$balance,'error');
                                        UserBill::income('开团成功，推广奖励', $v, 'wdc', 'wdc_brokerage', ($level2_reward_rate - $prevUser['prevPrize']), 0, $balance, '推广奖励', 1);
                                        $levelPrizeLeave -= ($level2_reward_rate - $prevUser['prevPrize']);
                                        $user['prevPrize'] = $level2_reward_rate;
                                    }
                                } else {
                                    if ($levelPrizeLeave > 0) {
                                        User::where('uid', $v)->inc('wdc', $levelPrizeLeave)->update();
                                        User::where('uid', $v)->inc('wdc_all', $levelPrizeLeave)->update();
                                        $balance = $user['wdc'] + $levelPrizeLeave;
                                        //Log::write("a11:".$balance,'error');
                                        UserBill::income('开团成功，推广奖励', $v, 'wdc', 'wdc_brokerage', $levelPrizeLeave, 0, $balance, '推广奖励', 1);
                                        $levelPrizeLeave = 0;
                                    }
                                }
                            } else if ($level_id == 3) {
                                if ($levelPrizeLeave > ($level3_reward_rate - $prevUser['prevPrize'])) {
                                    if (($level3_reward_rate - $prevUser['prevPrize']) > 0) {
                                        User::where('uid', $v)->inc('wdc', ($level3_reward_rate - $prevUser['prevPrize']))->update();
                                        User::where('uid', $v)->inc('wdc_all', ($level3_reward_rate - $prevUser['prevPrize']))->update();
                                        $balance = $user['wdc'] + ($level3_reward_rate - $prevUser['prevPrize']);
                                        //Log::write("a12:".$balance,'error');
                                        UserBill::income('开团成功，推广奖励', $v, 'wdc', 'wdc_brokerage', ($level3_reward_rate - $prevUser['prevPrize']), 0, $balance, '推广奖励', 1);
                                        $levelPrizeLeave -= ($level3_reward_rate - $prevUser['prevPrize']);
                                        $user['prevPrize'] = $level3_reward_rate;
                                    }
                                } else {
                                    if ($levelPrizeLeave > 0) {
                                        User::where('uid', $v)->inc('wdc', $levelPrizeLeave)->update();
                                        User::where('uid', $v)->inc('wdc_all', $levelPrizeLeave)->update();
                                        $balance = $user['wdc'] + $levelPrizeLeave;
                                        //Log::write("a13:".$balance,'error');
                                        UserBill::income('开团成功，推广奖励', $v, 'wdc', 'wdc_brokerage', $levelPrizeLeave, 0, $balance, '推广奖励', 1);
                                        $levelPrizeLeave = 0;
                                    }
                                }
                            }
                            @file_put_contents('fuck_dubug.txt', "[" . date('Y-m-d H:i:s') . "]levelPrizeLeave2:" . $levelPrizeLeave . PHP_EOL, 8);
                        }
                    }

                    $prevUser = $user;
                    if ($levelPrizeLeave <= 0) {//剩余极差为0，结束
                        break;
                    }
                }
            }
            Log::write("测试拼团5", 'error');
            //计算平级佣金
            if ($samelevel_reward_rate) {
                foreach ($arrq as $key => $item) {
                    //$profit = $profits[$key];
                    $pids = [];
                    UtilService::getparentid($userList, $item['uid'], $pids);
//                    Log::write('平级1:' . implode('-', $pids), 'error');
//                $samelevelPerson = sys_config('samelevel_prise_maxperson', 2);   //平级奖励人数
                    $samelevelArr = [];
                    $samelevelPrizeArr = [];
                    for ($i = 2; $i <= 4; $i++) {
                        $res = Db::name('system_user_level')->where('grade', '=', $i)->value('is_samelevel');
                        if ($res == 1) {
                            $samelevelArr[$i] = 0;
                        }
                    }
                    $level = UserLevel::getUserLevel($item['uid']);
                    $level_id_origin = 0;   //中奖用户等级
                    if ($level !== false) {
                        $level_id_origin = UserLevel::getUserLevelInfo($level, 'grade');
                    }
//                    Log::write('平级2:' . implode('-', $samelevelArr), 'error');
                    if (!empty($samelevelArr)) {
                        $cur = null;    //当前考察的等级
                        foreach ($pids as $v) {
                            $user = User::where('uid', '=', $v)->find();
                            if (!$user)
                                continue;
                            $level = UserLevel::getUserLevel($v);
                            $level_id = 0;
                            if ($level !== false) {
                                $level_id = UserLevel::getUserLevelInfo($level, 'grade');
                            }
                            if ($cur == null) {
                                if ($level_id <= $level_id_origin) {
                                    continue;
                                }
                                if (array_key_exists($level_id, $samelevelArr)) {
                                    $cur = $level_id;
                                    $samelevelArr[$cur] = 1;
                                }
                            } else {
                                if ($level_id == $cur) {
                                    if ($samelevelArr[$cur] < $samelevelPerson + 1) {
                                        $samelevelPrizeArr[] = $v;
                                        $samelevelArr[$cur] += 1;
                                    }
                                } else if ($level_id > $cur && $level_id <= 4) {
                                    if (array_key_exists($level_id, $samelevelArr)) {
                                        $cur = $level_id;
                                        $samelevelArr[$cur] = 1;
                                    }
                                } else if ($level_id > $cur && $level_id > 4) {
                                    break;
                                }
                            }
                        }

                        if (!empty($samelevelPrizeArr) && $samelevel_reward_rate > 0) {
                            Log::write('平级3:' . implode('-', $samelevelPrizeArr), 'error');
                            $samelevelPrize = bcdiv($samelevel_reward_rate, sizeof($samelevelPrizeArr), 2);
                            foreach ($samelevelPrizeArr as $v) {  //发放平级佣金
                                User::where('uid', $v)->inc('wdc', $samelevelPrize)->update();
                                User::where('uid', $v)->inc('wdc_all', $samelevelPrize)->update();
                                $balance = User::where('uid', $v)->value('wdc');
                                //Log::write("a14:".$balance,'error');
                                UserBill::income('开团成功，平级奖励', $v, 'wdc', 'wdc_brokerage', $samelevelPrize, 0, $balance, '平级奖励', 1);
                            }
                        }
                    }
                }
            }
            BaseModel::commitTrans();
            Log::write("测试拼团-end", 'error');
        } catch (Exception $e) {
            Log::write('数据库异常:' . $e->getMessage() . '||' . $e->getFile() . "||" . $e->getLine(), 'error');
            BaseModel::rollbackTrans();
        }
    }

    /**
     * 获取用户所有团
     * @param $where 条件
     */
    public static function getuserlist($where)
    {
        $model = new self;
        $model = $model->alias('a');
        if (isset($where['uid']) && intval($where['uid']) > 0) $model = $model->where("a.uid", $where['uid']);
        if (isset($where['status']) && intval($where['status']) > 0) $model = $model->where("a.status", $where['status']);
        $model = $model->where('a.k_id', 0);
        $model->join('store_combination b', 'a.cid=b.id', "left")->field('a.*,b.image,b.title,b.price')->order("a.id DESC");

        return self::page($model, function ($item) {
            $model = new self();
            $item->members = $model->alias('p')->join("user u", "p.uid=u.uid", "left")->field('p.*,u.nickname,u.avatar')->where('p.id|p.k_id', $item['id'])->order('p.id asc')->select()->toArray();
            $row = self::alias('p')->join("user u", "p.uid=u.uid", "left")->field('p.*,u.nickname,u.avatar')->where('p.id|p.k_id', $item['id'])->where('p.is_get', 1)->find();
            if ($row) {
                $item->getnickname = $row['nickname'];
                $item->gettime = date("Y-m-d H:i", $row['get_time']);
            }
            $success_profit = floatval(User::alias('u')->join("system_user_level l", "u.level=l.id", "left")->where('u.uid', $item->members[0]['uid'])->value('success_profit')) / 100;
            $item->success_profit = bcmul($item['price'], $success_profit, 2);
        }, $where);
    }

    /**
     * 获取用户所有团
     * @param $where 条件
     */
    public static function getuserpink($where)
    {
        $model = new self;
        $model = $model->alias('a');
        if (isset($where['uid']) && intval($where['uid']) > 0) $model = $model->where("a.uid", $where['uid']);
        if (isset($where['status']) && intval($where['status']) > 0) $model = $model->where("a.status", $where['status']);
        if (isset($where['status'])) $model = $model->where("a.is_show", $where['is_show']);
        $model->join('store_combination b', 'a.cid=b.id', "left")->field('a.*,b.image,b.title,b.price')->order("a.id DESC");
        return self::page($model, function ($item) {

            $item->joins = self::alias('a')->join('user b', 'a.uid = b.uid', 'left')->where(['a.k_id|a.id' => $item['k_id'] > 0 ? $item['k_id'] : $item['id']])->field('a.people,a.id,b.uid,b.nickname,b.avatar')->select()->toarray();
//            $item->joins_peopleweo = self::getPinkPeople($item['k_id'] > 0 ? $item['k_id'] : $item['id'], $item['people']);
            $item->joins_peopleweo = sizeof($item['joins']);

        }, $where);

    }

    /**
     * 退款处理
     * @param $id
     */
    public static function updateRefundY2($id, $refund_price, $type = 1)
    {
        $data = [
            'refund_price' => $refund_price,
            'type' => $type,
        ];
        try {
            if (!$id) return false;
            $product = StoreOrderModel::get($id);
            if (!$product) return false;

            //if ($product['pay_price'] == $product['refund_price']) return false;
            //if (!$data['refund_price']) return false;
            $refund_price = $data['refund_price'];
            $data['refund_price'] = bcadd($data['refund_price'], $product['refund_price'], 2);
            // $bj = bccomp((float)$product['pay_price'], (float)$data['refund_price'], 2);
            //if ($bj < 0) return false;
            if ($product['is_auto_pink'] && $product['pink_num']) {
                if ($product['pink_num'] > 1) {
                    $data['type'] = 2;
                    $data['pink_id'] = 0;
                    $add = rand(120, 240);
                    $data['begin_time'] = bcadd(time(), $add, 2);
                }
            }
            $data['pink_num'] = $product['pink_num'] - 1;
            if (!$data['pink_num']) {
                $data['is_ok'] = 1;
            }
            if ($data['type'] == 1) {
                $data['refund_status'] = 2;
            } else if ($data['type'] == 2) {
                $data['refund_status'] = 0;
            }
            $type = $data['type'];
            unset($data['type']);
            $refund_data['pay_price'] = $product['pay_price'];
            $refund_data['refund_price'] = $refund_price;
            @file_put_contents('aa1.txt', json_encode($data));
            if (!$data['pink_num']) {
                if ($product['pay_type'] == 'weixin') {
                    $order_refund = sys_config('order_refund');
                    if (intval($order_refund) == 0) {
                        if ($product['is_channel'] == 1) {//小程序
                            try {
                                MiniProgramService::payOrderRefund($product['order_id'], $refund_data);//2.5.36
                            } catch (\Exception $e) {
                                Log::write($e->getMessage() . '11', 'error');
                                return false;
                            }
                        } else {//TODO 公众号
                            try {
                                WechatService::payOrderRefund($product['order_id'], $refund_data);
                            } catch (\Exception $e) {
                                Log::write($e->getMessage() . '22', 'error');
                                return false;
                            }
                        }
                    } else {

                        $usermoney = \app\admin\model\user\User::where('uid', $product['uid'])->value('now_money');
                        $res1 = User::bcInc($product['uid'], 'now_money', $refund_price, 'uid');
                        $res2 = \app\admin\model\user\UserBill::income('商品退款', $product['uid'], 'now_money', 'pay_product_refund', $refund_price, $product['id'], bcadd($usermoney, $refund_price, 2), '订单退款到余额' . floatval($refund_price) . '元');
                    }

                    //                $usermoney = \app\admin\model\user\User::where('uid', $product['uid'])->value('now_money');
                    //                $res1 = User::bcInc($product['uid'], 'now_money', $refund_price, 'uid');
                    //                $res2 = \app\admin\model\user\UserBill::income('商品退款', $product['uid'], 'now_money', 'pay_product_refund', $refund_price, $product['id'], bcadd($usermoney, $refund_price, 2), '订单退款到余额' . floatval($refund_price) . '元');
                    ////                Log::write('微信退款', 'error');

                } else if ($product['pay_type'] == 'yue') {
                    BaseModel::beginTrans();
                    $usermoney = \app\admin\model\user\User::where('uid', $product['uid'])->value('now_money');
                    $res1 = User::bcInc($product['uid'], 'now_money', $refund_price, 'uid');
                    $res2 = \app\admin\model\user\UserBill::income('商品退款', $product['uid'], 'now_money', 'pay_product_refund', $refund_price, $product['id'], bcadd($usermoney, $refund_price, 2), '订单退款到余额' . floatval($refund_price) . '元');
                    //                try {
                    //                    OrderRepository::storeOrderYueRefund($product, $refund_data);
                    //                } catch (\Exception $e) {
                    //                    BaseModel::rollbackTrans();
                    //                    Log::write('微信退款-失败3', 'error');
                    //                    return Json::fail($e->getMessage());
                    //                }
                    $res = $res1 && $res2;
                    BaseModel::checkTrans($res);
                    Log::write('余额退款', 'error');
                    if (!$res) return false;
                } else if ($product['pay_type'] == 'integral') {
                    BaseModel::beginTrans();
                    $usermoney = \app\admin\model\user\User::where('uid', $product['uid'])->value('integral');
                    $res1 = User::bcInc($product['uid'], 'integral', $refund_price, 'uid');
                    $res2 = \app\admin\model\user\UserBill::income('商品退款', $product['uid'], 'integral', 'pay_product_refund', $refund_price, $product['id'], bcadd($usermoney, $refund_price, 2), '订单退款到积分' . floatval($refund_price) . '分');
                    //                try {
                    //                    OrderRepository::storeOrderYueRefund($product, $refund_data);
                    //                } catch (\Exception $e) {
                    //                    BaseModel::rollbackTrans();
                    //                    Log::write('微信退款-失败3', 'error');
                    //                    return Json::fail($e->getMessage());
                    //                }
                    $res = $res1 && $res2;
                    BaseModel::checkTrans($res);
                    Log::write('积分退款', 'error');
                    if (!$res) return false;
                }
            }

            $resEdit = StoreOrderModel::edit($data, $id);
//            Log::write('微信退款-1', 'error');
            $res = true;
            if ($resEdit) {
//                Log::write('微信退款-2', 'error');
//                BaseModel::beginTrans();
//                $data['type'] = $type;
//                if ($data['type'] == 1) $res = \app\admin\model\ump\StorePink::setRefundPink($id);
//                if (!$res) return Json::fail('修改失败');
//                Log::write('微信退款-3', 'error');
//                try {
//                    OrderRepository::storeProductOrderRefundY($data, $id);
//                } catch (\Exception $e) {
//                    BaseModel::rollbackTrans();
//                    Log::write('微信退款-失败1', 'error');
//                    return false;
//                }
//                Log::write('微信退款-4', 'error');
                StoreOrderStatus::setStatus($id, 'refund_price', '退款给用户' . $refund_price . '元');
//                Log::write('微信退款-2', 'error');
//                Log::write('微信退款-5', 'error');
                //退佣金
//                $brokerage_list = UserBill::where('category', 'now_money')
//                    ->where('type', 'brokerage')
//                    ->where('link_id', $id)
//                    ->where('pm', 1)
//                    ->select()->toArray();
//
//                if ($brokerage_list)
//                    foreach ($brokerage_list as $item) {
//                        $usermoney = User::where('uid', $item['uid'])->value('brokerage_price');
//                        if ($item['number'] > $usermoney)
//                            $item['number'] = $usermoney;
//                        User::bcDec($item['uid'], 'brokerage_price', $item['number'], 'uid');
//                        UserBill::expend('退款退佣金', $item['uid'], 'now_money', 'brokerage', $item['number'], $id, bcsub($usermoney, $item['number'], 2), '订单退款扣除佣金' . floatval($item['number']) . '元');
//                    }
//                BaseModel::commitTrans();
//                Log::write('微信退款-6', 'error');
                //return Json::successful('修改成功!');
//                Log::write('微信-ok', 'error');
            } else {
                Log::write('微信退款-失败2', 'error');
                StoreOrderStatus::setStatus($id, 'refund_price', '退款给用户' . $refund_price . '元失败');
                return false;
            }
        } catch (Exception $e) {
            Log::write('退款出错:' . $e->getMessage() . '||' . $e->getFile() . '||' . $e->getLine() . '||' . $e->getTraceAsString(), 'error');
            return false;
        }
    }
}