Merge branch 'dev' of https://gitea.lihaink.cn/mkm/shop-php into dev

2024-01-22 13:56:43 +08:00 · 2024-01-22 13:56:43 +08:00 · b2f006f51c
commit b2f006f51c
parent aa368d2520 ab0d2e62fe
18 changed files with 253 additions and 412 deletions
--- a/app/common/dao/store/StoreActivityOrderDao.php
+++ b/app/common/dao/store/StoreActivityOrderDao.php
@ -39,8 +39,8 @@ class StoreActivityOrderDao extends BaseDao
            ->find();
        if (!empty($consumptionDetail['amount'])) {
            // 当前订单使用现金抵扣红包 或 使用通用红包后实付金额不足红包金额的1.5倍，视为无效订单
-            $redPackType = StoreConsumptionUser::where('coupon_id', $consumptionDetail['coupon_user_id'])->value('type');
-            if ($redPackType == StoreConsumptionUser::TYPE_TWO || $consumptionDetail['pay_price'] < $consumptionDetail['amount'] * 1.5) {
+            $redPackType = StoreConsumptionUser::where('coupon_user_id', $consumptionDetail['coupon_user_id'])->value('type');
+            if ($redPackType == StoreConsumptionUser::TYPE_TWO || ($redPackType == StoreConsumptionUser::TYPE_TWO && $consumptionDetail['pay_price'] < $consumptionDetail['amount'] * 1.5)) {
                $model->status = StoreActivityOrder::STATUS_INVALID;
            }
        }
--- a/app/common/dao/store/StoreActivityUserDao.php
+++ b/app/common/dao/store/StoreActivityUserDao.php
@ -112,23 +112,36 @@ class StoreActivityUserDao extends BaseDao
        $consumption = StoreConsumption::where('coupon_id', $activityUser['value'])
            ->where('type', StoreConsumption::TYPE_PULL_CONSUMPTION)
            ->find();
+        $unReceiveConsumption = StoreConsumptionUser::where('uid', $userId)->where('status', StoreConsumptionUser::STATUS_UN_RECEIVE)->value('order_id_set');
+        if (!empty($unReceiveConsumption)) {
+            $groupOrderIds = explode(',', $unReceiveConsumption);
+            $groupOrderId = $groupOrderIds[0];
+            $myOrderWhere = ['group_order_id' => $groupOrderId];
+        } else {
+            $myOrderWhere = ['status' => StoreActivityOrder::STATUS_VALID];
+        }
        $myOrder = StoreActivityOrder::where('user_id', $userId)
            ->where('activity_id', $activityId)
-            ->where('status', StoreActivityOrder::STATUS_VALID)
+            ->where($myOrderWhere)
            ->find();
-        if (empty($myOrder)) {
+        if (empty($myOrder) || empty($myOrder['pay_price'])) {
            return ['target' => $target, 'allow_receive' => false, 'user_info' => $userInfo];
        }
-        $storeConsumptionUserDao = new StoreConsumptionUserDao();
-        $scope = $storeConsumptionUserDao->getScope($consumption, $myOrder['total_amount']);
        $userInfo = User::where('spread_uid', $userId)->field('uid,nickname,avatar')->select()->toArray();
-        $orders = StoreActivityOrder::where('spread_id', $userId)
+        $storeConsumptionUserDao = new StoreConsumptionUserDao();
+        $scope = $storeConsumptionUserDao->getScope($consumption, $myOrder['pay_price']);
+        $orderQuery = StoreActivityOrder::where('spread_id', $userId)
            ->whereIn('user_id', array_column($userInfo, 'uid'))
            ->where('activity_id', $activityId)
            ->where('is_first_order', StoreActivityOrder::IS_FIRST_ORDER)
-            ->where('total_amount', '>=', $scope['start'])
-            ->where('status', StoreActivityOrder::STATUS_VALID)
-            ->select()->toArray();
+            ->where('pay_price', '>=', $scope['start']);
+        if (!empty($groupOrderIds)) {
+            unset($groupOrderIds[0]);
+            $orderQuery->whereIn('group_order_id', $groupOrderIds);
+        } else {
+            $orderQuery->where('status', StoreActivityOrder::STATUS_VALID);
+        }
+        $orders = $orderQuery->select()->toArray();
        $orders = reset_index($orders, 'user_id');
        foreach ($userInfo as &$user) {
            $user['target_amount'] = $scope['start'];
@ -183,13 +196,19 @@ class StoreActivityUserDao extends BaseDao
            ->whereIn('type', $type)
            ->where('status', StoreConsumptionUser::STATUS_UNUSED)
            ->sum('balance');
-        $query = UserBill::with('storeConsumptionUser')
-            ->field('link_id,create_time')
+        $query = UserBill::field('link_id,create_time,number coupon_price,mark')
            ->where('uid', $userId)
            ->where('category', 'red_pack')
            ->where('type', "red_pack_{$type}");
        $count = $query->count();
        $record = $query->page($page)->limit($limit)->select()->toArray();
+        foreach ($record as &$item) {
+            $item['order_amount'] = 0;
+            if (mb_strpos($item['mark'], '订单金额：') !== false) {
+                $item['order_amount'] = mb_substr($item['mark'], mb_strpos($item['mark'], '订单金额：') + 5);
+            }
+            unset($item['mark']);
+        }
        return ['total_amount' => $totalAmount, 'count' => $count, 'record' => $record];
    }

@ -206,10 +225,24 @@ class StoreActivityUserDao extends BaseDao
            ->field('SUM(balance) as total_amount,type')
            ->group('type')
            ->select()->toArray();
-        foreach ($totalAmount as &$item) {
+        $totalAmount = reset_index($totalAmount, 'type');
+        $result = [
+            [
+                'type' => 1,
+                'total_amount' => 0.00
+            ],
+            [
+                'type' => 2,
+                'total_amount' => 0.00
+            ]
+        ];
+        foreach ($result as &$item) {
+            if (isset($totalAmount[$item['type']])) {
+                $item['total_amount'] = $totalAmount[$item['type']]['total_amount'];
+            }
            $item['type_cn'] = StoreConsumptionUser::TYPE_MAP[$item['type']];
        }
-        return $totalAmount;
+        return $result;
    }

 }
--- a/app/common/dao/store/consumption/StoreConsumptionDao.php
+++ b/app/common/dao/store/consumption/StoreConsumptionDao.php
@ -25,7 +25,15 @@ class StoreConsumptionDao extends BaseDao
     */
    public function getValidList()
    {
-        return StoreConsumption::whereIn('type', [StoreConsumption::TYPE_OWNER_CONSUMPTION, StoreConsumption::TYPE_PULL_CONSUMPTION])->where('status', StoreConsumption::STATUS_ENABLE)->field('coupon_id,start_time,end_time,title')->select();
+        return StoreConsumption::whereIn('type', [StoreConsumption::TYPE_OWNER_CONSUMPTION, StoreConsumption::TYPE_PULL_CONSUMPTION])->where('status', StoreConsumption::STATUS_ENABLE)
+        ->field('coupon_id,start_time,end_time,title')->select()->each(function ($item){
+                if($item['title']=='无门槛实物通用红包'){
+                    $item['title'] = '用户推荐拉新活动';
+                }else{
+                    $item['title'] = '用户消费补贴活动';
+                }
+                return $item;
+        });
    }

    public function getOne($id)
--- a/app/common/dao/store/consumption/StoreConsumptionUserDao.php
+++ b/app/common/dao/store/consumption/StoreConsumptionUserDao.php
@ -65,7 +65,7 @@ class StoreConsumptionUserDao extends BaseDao
        $orderValidAmount = min($groupOrder['pay_price'], $this->maxAmount);
        $scope = $this->getScope($consumption, $orderValidAmount);
        //用户没有达到 消费金活动 任一档次
-        if ($scope['rate'] <= 0) {
+        if (empty($scope) || $scope['rate'] <= 0) {
            return false;
        }
        Db::startTrans();
@ -73,7 +73,7 @@ class StoreConsumptionUserDao extends BaseDao
            $isFirstOrder = $this->isFirstOrder($userId, $consumption['start_time'], date('Y-m-d H:i:s', $endTime));
            $storeActivityOrderDao = new StoreActivityOrderDao();
            $storeActivityOrder = $storeActivityOrderDao->save($groupOrder, $spreadUserId, $isFirstOrder);
-            if ($consumption['type'] == StoreConsumption::TYPE_OWNER_CONSUMPTION && $storeActivityOrder['status'] == StoreActivityOrder::STATUS_VALID) {
+            if ($consumption['type'] == StoreConsumption::TYPE_OWNER_CONSUMPTION && $storeActivityOrder['status'] == StoreActivityOrder::STATUS_VALID && $storeActivityOrder['red_pack'] == 0) {
                $this->send($consumption, $scope['rate'], $userId, $groupOrder['group_order_id'], $orderValidAmount, StoreConsumptionUser::STATUS_UNUSED);
                $this->send($consumption, $scope['rate_two'], $userId, $groupOrder['group_order_id'], $orderValidAmount, StoreConsumptionUser::STATUS_UNUSED, StoreConsumptionUser::TYPE_TWO);
                $storeActivityOrderDao->repeal($groupOrder['group_order_id']);
@ -198,6 +198,7 @@ class StoreConsumptionUserDao extends BaseDao
     */
    public function send($consumption, float $rate, int $userId, string $groupOrderIds, float $amount, $status = -2, $type = 1)
    {
+        $title = $type == StoreConsumptionUser::TYPE_TWO ? '现金抵扣红包' : '无门槛实物通用红包';
        $model = StoreConsumptionUser::where('uid', $userId)->where('type', StoreConsumptionUser::TYPE_TWO)->find();
        $couponPrice = bcmul($amount, $rate, 2);
        if (!empty($model) && $model['type'] == $type) {
@ -207,7 +208,7 @@ class StoreConsumptionUserDao extends BaseDao
            $model = new StoreConsumptionUser();
            $model->coupon_id = $consumption['coupon_id'];
            $model->uid = $userId;
-            $model->coupon_title = $consumption['title'];
+            $model->coupon_title = $title;
            $model->order_id_set = $groupOrderIds;
            $model->coupon_price = $couponPrice;
            $model->balance = $model->coupon_price;
@ -221,7 +222,6 @@ class StoreConsumptionUserDao extends BaseDao
        if (!$model->save()) {
            throw new \Exception('发放失败');
        }
-        $title = $type == StoreConsumptionUser::TYPE_TWO ? '现金抵扣红包' : '无门槛实物通用红包';
        // 写入红包日志
        /** @var  $userBillRepository UserBillRepository */
        $userBillRepository = app()->make(UserBillRepository::class);
@ -230,7 +230,7 @@ class StoreConsumptionUserDao extends BaseDao
            'status' => 1,
            'title' => '获得' . $title,
            'number' => $couponPrice,
-            'mark' => '获得' . $title . $couponPrice,
+            'mark' => '获得' . $title . $couponPrice . ",订单金额：{$amount}",
            'balance' => 0
        ]);
    }
@ -258,4 +258,25 @@ class StoreConsumptionUserDao extends BaseDao
        return strtotime('+1 year', strtotime($datetime));
    }

+    /**
+     * 扣减红包余额
+     * @param $id
+     * @param $amount
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function reduce($id, $amount)
+    {
+        $storeConsumptionUser = StoreConsumptionUser::where('coupon_user_id', $id)->find();
+        if (empty($storeConsumptionUser) || $storeConsumptionUser->balance < $amount) {
+            throw new \Exception('红包余额不足');
+        }
+        $balance = bcsub($storeConsumptionUser->balance, $amount, 2);
+        $storeConsumptionUser->balance = max($balance, 0);
+        if (!$storeConsumptionUser->save()) {
+            throw new \Exception('红包余额更新出错');
+        }
+    }
+
 }
--- a/app/common/repositories/store/order/StoreOrderCreateRepository.php
+++ b/app/common/repositories/store/order/StoreOrderCreateRepository.php
@ -35,10 +35,12 @@ class StoreOrderCreateRepository extends StoreOrderRepository
 {
    protected $store_consumption_user;
    protected $consumption_money;
+    protected $balance;

    public function v2CartIdByOrderInfo($user, array $cartId, array $takes = null, array $useCoupon = null, bool $useIntegral = false, int $addressId = null, $createOrder = false, $consumption_id = 0)
    {
        $uid = $user->uid;
+        $this->balance = 0;
        $userIntegral = $user->integral;
        $key = md5(json_encode(compact('cartId', 'takes', 'useCoupon', 'useIntegral', 'addressId'))) . $uid;
        app()->make(StoreCouponUserRepository::class)->failCoupon();
@ -154,6 +156,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository

        if ($consumption_id > 0) {
            $this->store_consumption_user = Db::name('store_consumption_user')->where('coupon_user_id', $consumption_id)->where('uid', $uid)->find();
+            $this->balance=$this->store_consumption_user['balance'];
        }
        // 循环计算每个店铺的订单数据 委托商品是否设置收货方式 ?
        foreach ($merchantCartList as &$merchantCart) {
@ -446,7 +449,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository
                'platformCoupon' => $platformCoupon,
                'svip_coupon_merge' => $svip_coupon_merge,
                'postage_price' => $postage_price,
-                'isTake' => intval($allowDelivery == false),
+                'isTake' => intval($allowDelivery == false ||  count($takes) > 0),
                'total_num' => $total_num,
                'enabledCoupon' => $enabledCoupon,
                'useCouponIds' => $useCouponIds,
@ -565,33 +568,33 @@ class StoreOrderCreateRepository extends StoreOrderRepository
                $pay_price = $org_price;
            }
            //计算总红包金额
-            $a = 0;
            if ($consumption_id > 0 ) {
                if ($this->store_consumption_user) {
-                    if ($this->store_consumption_user['type'] == 2) {
+                    if ($this->store_consumption_user['type'] == 2 && $pay_price>=6) {
                        $a = bcdiv($pay_price, 6);
-                        if ($this->store_consumption_user['balance'] > $a) {
+                        if ($this->balance > $a) {
                            $pay_price = bcsub($pay_price, $a, 2);
-                            $this->consumption_money = bcadd($this->consumption_money, $a);
-                            $this->store_consumption_user['balance'] = bcsub($this->store_consumption_user['balance'], $a);
+                            $this->consumption_money = bcadd($this->consumption_money, $a, 2);
+                            $this->balance = bcsub($this->balance, $a, 2);
                        } else {
-                            $a = $this->store_consumption_user['balance'];
-                            $pay_price = bcsub($pay_price, $this->store_consumption_user['balance'], 2);
-                            $this->consumption_money = bcadd($this->consumption_money, $this->store_consumption_user['balance']);
-                            $this->store_consumption_user['balance'] = 0;
+                            $pay_price = bcsub($pay_price, $this->balance, 2);
+                            $this->consumption_money = bcadd($this->consumption_money, $this->balance, 2);
+                            $this->balance = 0;
                        }
                    }
                    if ($this->store_consumption_user['type'] == 1) {
-                        if ($pay_price > $this->store_consumption_user['balance']) {
-                            $pay_price = bcsub($pay_price, $this->store_consumption_user['balance'], 2);
-                            $this->consumption_money = $this->store_consumption_user['balance'];
-                            $a = $this->store_consumption_user['balance'];
+                        if ($pay_price > $this->balance) {
+                            $pay_price = bcsub($pay_price, $this->balance, 2);
+                            $this->consumption_money = bcadd($this->consumption_money, $this->balance, 2);
+                            $this->balance=0;
                        } else {
                            $this->consumption_money = $pay_price;
+                            $this->balance = bcsub($this->balance, $pay_price, 2);
                            $pay_price = 0;
-                            $a = $this->consumption_money;
+
                        }
                    }
+
                }
            }

@ -611,7 +614,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository
            $merchantCart['order']['postage_price'] = $merchantCart['order']['postage_price'];
            $merchantCart['order']['procure_price'] = $merchantCart['order']['procure_price'];
            $merchantCart['order']['consumption_id'] = $consumption_id;
-            $merchantCart['order']['consumption_money'] = $a;
+            $merchantCart['order']['consumption_money'] = $this->consumption_money;

            $order_price = bcadd($order_price, $pay_price, 2);
            $order_total_price = bcadd($order_total_price, $total_price, 2);
@ -638,7 +641,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository
        $openIntegral = $merIntegralFlag && !$order_type && $sysIntegralConfig['integral_status'] && $sysIntegralConfig['integral_money'] > 0;
        $total_coupon = bcadd($order_svip_discount, bcadd(bcadd($total_platform_coupon_price, $order_coupon_price, 2), $order_total_integral_price, 2), 2);
        $is_self_pickup = true;
-        if($order_type=='balance' &&$source!=103){
+        if($order_type=='balance' &&$source!=103 && $createOrder==true){
            throw new ValidateException('余额支付只能用于里海云仓');
        }
        return compact(
--- a/app/common/repositories/user/UserRepository.php
+++ b/app/common/repositories/user/UserRepository.php
@ -673,6 +673,10 @@ class UserRepository extends BaseRepository
        ];
        if($code){
            $data['promotion_code']=$code;
+            $shop=explode('shop_',$code);
+            if(count($shop)==2){
+                $data['spread_uid']=$shop[1];
+            }
            Cache::delete('promote_'.$ip);
        }
        return $this->create($user_type, $data);
--- a/app/controller/admin/store/StoreProduct.php
+++ b/app/controller/admin/store/StoreProduct.php
@ -18,6 +18,7 @@ use think\App;
 use crmeb\basic\BaseController;
 use app\validate\merchant\StoreProductAdminValidate as validate;
 use app\common\repositories\store\product\ProductRepository as repository;
+use think\facade\Db;
 use think\facade\Queue;

 class StoreProduct extends BaseController
@ -301,12 +302,28 @@ class StoreProduct extends BaseController
        $this->repository->updates($ids, $data);
        return app('json')->success('修改成功');
    }
-    public function copy(){
-        $product=$this->repository->getAdminOneProduct(6300,0);
-        $product = $product->toArray();
-        $product['mer_id']=113;
+    //**复制商品 */
+    public function copy($product_id = 0, $mer_id = 0, $street_code = 0, $type_id = 0, $category_id = 0)
+    {
+        if ($product_id == 0) return app('json')->fail('参数错误');
+        $products = $this->repository->getAdminOneProduct($product_id, 0);
+        $product = $products->toArray();
+        $product['mer_id'] = $mer_id;
        $product['old_product_id'] = $product['product_id'];
-        return $this->repository->create($product, 0,1);
-
+        $productId = $this->repository->create($product, 0, 1);
+        $data = [
+            'product_id' => $productId,
+            'mer_id' => $mer_id,
+            'source_mer_id' => $products['mer_id'],
+            'street_code' => $street_code,
+            'weight' => 1,
+            'status' => 1,
+            'create_time' => date('Y-m-d H:i:s'),
+            'type_id' => $type_id,
+            'category_id' => $category_id,
+            'cate_id' => $product['cate_id']
+        ];
+        Db::name('cloud_product')->insert($data);
+        return $productId;
    }
 }
--- a/app/controller/api/Auth.php
+++ b/app/controller/api/Auth.php
@ -410,6 +410,7 @@ class Auth extends BaseController
        }else{
            $data['show_controller_applet']=false;
        }
+        $data['red_pack_balance']=Db::name('store_consumption_user')->where('uid',$data['uid'])->where('status',0)->sum('balance');
        return app('json')->success($data);
    }

--- a/app/controller/api/Common.php
+++ b/app/controller/api/Common.php
@ -644,7 +644,7 @@ class Common extends BaseController
    public function Qrcode($data)
    {
        $siteUrl = systemConfig('site_url');
-        $name = md5('orcode' . date('Ymd')) . '.png';
+        $name = 'orcode'.$data['id'] .md5(date('Ymd')) . '.png';
        $attachmentRepository = app()->make(AttachmentRepository::class);
        $imageInfo = $attachmentRepository->getWhere(['attachment_name' => $name]);

@ -653,12 +653,7 @@ class Common extends BaseController
            $imageInfo = null;
        }
        if (!$imageInfo) {
-            $imageInfo = app()->make(QrcodeService::class)->getQRCodePath($data['code'], $name,['code'=>[
-                'r' => 255,
-                'g' => 221,
-                'b' => 167,
-                'a' => 0,
-            ]]);
+            $imageInfo = app()->make(QrcodeService::class)->getQRCodePath($data['code'], $name,['code'=>1]);
            if (is_string($imageInfo)) throw new ValidateException('二维码生成失败');

            $imageInfo['dir'] = tidy_url($imageInfo['dir'], null, $siteUrl);
--- a/app/controller/api/Demo.php
+++ b/app/controller/api/Demo.php
@ -19,7 +19,8 @@ use think\facade\Db;
 use crmeb\services\UploadService;
 use Exception;
 use ZipArchive;
-
+use think\facade\Queue;
+use crmeb\jobs\ProductCopyJob;
 /**
 * Class Auth
 * @package app\controller\api
@ -30,204 +31,17 @@ class Demo extends BaseController
 {
    public function index()
    {      
-        $data=[
+        return app('json')->success('修改成功');  
+        //[31,32,118,39,167,236,237,238,239]
+        // return app('json')->success('修改成功');>whereIn('mer_id',[110,116,149,227,226,35,117,148,156,104,137,151,136,183,140,229,79,133,235])->
+
+        $arr=Db::name('store_product')->whereIn('mer_id',[31,32,118,39,167,236,237,238,239])->where('is_show',1)->where('stock',0)->field('product_id')->select();
+        foreach($arr as $item){
+
+           Queue::push(ProductCopyJob::class, ['product_id' => $item['product_id']]);//短信通知

-            6923644264192,
-            6923644210151,
-            6921665735042,
-            6921665731693,
-            6921665731679,
-            6921665730825,
-            6921665707940,
-            6921665701054,
-            6920208995349,
-            6920208986163,
-            6920208960866,
-            6920208960064,
-            6920208924394,
-            6920208924035,
-            6920208924011,
-            6919188019961,
-            6919188019961,
-            6908791503943,
-            6908791006024,
-            6907992507385,
-        ];
-        $mer_id=167;
-        foreach ($data as $item) {
-            $store_product_attr_value=Db::name('store_product_attr_value')->alias('a')
-            ->join('store_product b','a.product_id=b.product_id and b.product_type=98')
-            ->where('a.bar_code',$item)->value('a.product_id');
-            if($store_product_attr_value){
-                $find=Db::name('store_product_attr_value')->alias('a')
-                ->join('store_product b','a.product_id=b.product_id and b.product_type=0 and b.mer_id='.$mer_id)
-                ->where('a.bar_code',$item)->field('a.product_id,b.cate_id')->find();
-                if($find){
-                    $cloud_product=Db::name('cloud_product')->where('product_id',$find['product_id'])->where('mer_id',$mer_id)->value('product_id');
-                    if(!$cloud_product){
-                        $source_mer_id = Db::name('store_product')->where('product_id', $store_product_attr_value)->value('mer_id');
-                        $datas = [
-                            'product_id' => $find['product_id'],
-                            'cate_id' => $find['cate_id'],
-                            'mer_id' => $mer_id,
-                            'source_mer_id' => $source_mer_id,
-                            'street_code' => 510521107,
-                            'type_id' => 17,
-                            'category_id' => 2566,
-                            'weight' => 1,
-                            'status' => 1,
-                            'create_time' => date('Y-m-d H:i:s'),
-                            'mer_labels' =>'',
-                        ];
-                        Db::name('cloud_product')->insert($datas);
-                    }
-                }
-            }
-        }
-        halt(1);
-        $mer_id = 104;
-        $file = request()->file('file');
-        $zip_name = explode('.', $file->getOriginalName())[0];
-        // 上传到本地服务器
-        $savename = \think\facade\Filesystem::putFile('zippic', $file);
-        $dir = date('Y-m-d_H-i-s') . '_' . $mer_id;
-        $path = public_path('uploads/pic').$dir;
-        try {
-            $zip = new ZipArchive;
-            $filePath = public_path('uploads') . $savename;
-            $zip->open($filePath);
-            for ($i = 0; $i < $zip->numFiles; $i++) {
-                $statInfo = $zip->statIndex($i, ZipArchive::FL_ENC_RAW);
-                $filename = $this->transcoding($statInfo['name']);
-                $mkdFile = explode('/',$filename);
-                if ($statInfo['crc'] == 0) {
-                    // 新建目录
-                    if (!file_exists($path . '/' . $filename)) {
-                        mkdir($path . '/' . $filename, 0777, true);
-                    }
-                } else {
-                    // 拷贝文件
-                    if(count($mkdFile)==3){
-                        if (!file_exists($path . '/' . $mkdFile[0].'/'.$mkdFile[1])) {
-                            mkdir($path . '/' .$mkdFile[0].'/'.$mkdFile[1], 0777, true);
-                        }
-                        copy('zip://' . $file . '#' . $zip->getNameIndex($i), $path . '/' . $filename);
-                    }
-                }
-            }
-            $zip->close();
-        } catch (\Exception $e) {
-            throw new \think\exception\HttpException(404, $e->getMessage() . '。line:' . $e->getLine());
        }
     
-        $directory = $path.'/'.$zip_name;
-        $files = scandir($directory);
-        $dir = 'def/' . date('Y-m-d');
-        $upload = UploadService::create();
-        /**循环目录 */
-        foreach ($files as $file) {
-            if ($file === '.' || $file === '..' || $file === '__MACOSX') {
-                continue;
-            }
-            if (!is_dir($directory . '/' . $file)) {
-                continue;
-            }
-            $files_two = scandir($directory . '/' . $file);
-
-            $image_extensions = array('jpg', 'jpeg', 'png');
-            $image = '';
-            $slider_image = [];
-            $details = [];
-            $sku_arr = [];
-            /**清洗图片 */
-            foreach ($files_two as $file_two) {
-                if ($file_two === '.' || $file_two === '..' || $file_two === '__MACOSX') {
-                    continue;
-                }
-                $arr = explode('.', $file_two);
-                if (in_array($arr[1], $image_extensions)) {
-                    /**首图 */
-                    $images[] = $file_two;
-                    if ($image == '' && is_numeric($arr[0])) {
-                        $image = $directory . '/' . $file . '/' . $file_two;
-                        continue;
-                    }
-                    /**轮播图 */
-                    if (is_numeric($arr[0]) && count($slider_image) < 4) {
-                        $slider_image[] = $directory . '/' . $file . '/' . $file_two;
-                        continue;
-                    }
-                    /**详情图 */
-                    if (is_numeric($arr[0])) {
-                        $details[] = $directory . '/' .$file.'/'. $file_two;
-                        continue;
-                    }
-                    /**sku图 */
-                    $sku = explode('==', $arr[0]);
-                    if ($sku) {
-                        $sku = implode(',', $sku);
-                        $sku_arr[$sku] = $directory . '/' . $file . '/' . $file_two;
-                    }
-                }
-            }
-            $where = ['mer_id' => $mer_id, 'is_del' => 0];
-            $update = [];
-            $update_content['title'] = '';
-            $update_content['image'] = [];
-            $update_content['type'] = 1;
-            $find = Db::name('store_product')->where($where)->where('store_name', $file)->find();
-            if ($find) {
-                try {
-                    /**更新商品图片 */
-                    $image = $upload->to($dir)->stream(file_get_contents($image));
-                    $update['image'] = $image->filePath;
-                    foreach ($slider_image as  $k => $v) {
-                        $oss = $upload->to($dir)->stream(file_get_contents($v));
-                        $update['slider_image'][] = $oss->filePath;
-                    }
-                    if (isset($update['slider_image'])) {
-                        $update['slider_image'] = implode(',', $update['slider_image']);
-                    }
-                    Db::name('store_product')->where('product_id', $find['product_id'])->update($update);
-                    /**更新规格图片 */
-                    foreach ($sku_arr as  $k => $v) {
-                        // $sku = explode(',', $k);
-                        // if(count($sku)==2){
-                        //     $sku_name=$sku[0];
-                        // }else{
-                        //     continue;
-                        // }
-                        $store_product_attr_value = Db::name('store_product_attr_value')->where(['mer_id' => $mer_id, 'product_id' => $find['product_id'], 'sku' => $k])->find();
-                        if ($store_product_attr_value) {
-                            $oss = $upload->to($dir)->stream(file_get_contents($v));
-                            Db::name('store_product_attr_value')
-                                ->where(['mer_id' => $mer_id, 'product_id' => $find['product_id'], 'sku' => $k])
-                                ->update(['image' => $oss->filePath]);
-                        }
-                    }
-                    /**更新详情图片 */
-                    $store_product_content = Db::name('store_product_content')->where(['product_id' => $find['product_id']])->find();
-                    foreach ($details as  $k => $v) {
-                        $oss = $upload->to($dir)->stream(file_get_contents($v));
-                        $update_content['image'][] = $oss->filePath;
-                    }
-                    if ($store_product_content) {
-                        if (isset($update_content['image']) && !empty($update_content['image'])) {
-                            Db::name('store_product_content')
-                                ->where(['product_id' => $find['product_id']])
-                                ->update(['content' => json_encode($update_content)]);
-                        }
-                    } else {
-                        $update_content['product_id'] = $find['product_id'];
-                        Db::name('store_product_content')
-                            ->insert(['product_id' => $find['product_id'], 'type' => 1, 'content' => json_encode($update_content)]);
-                    }
-                } catch (Exception $e) {
-                    halt($e->getMessage(), $e->getLine());
-                }
-            }
-        }
-        halt(1);
    }

    public function transcoding($fileName)
--- a/app/controller/api/store/product/CloudWarehouse.php
+++ b/app/controller/api/store/product/CloudWarehouse.php
@ -94,7 +94,7 @@ class CloudWarehouse extends BaseController
                        if ($value['mer_labels'] == ',5,') {
                            $list[$k]['mer_labels_name'] = '五日达';
                        } else {
-                            $list[$k]['mer_labels_name'] = '次日达';
+                            $list[$k]['mer_labels_name'] = '同城';
                        }
                    }
                }
--- a/app/controller/api/user/User.php
+++ b/app/controller/api/user/User.php
@ -541,7 +541,8 @@ class User extends BaseController
     */
    public function qrcode(){
        $common= app()->make(Common::class);
-       $data=$common->Qrcode(['code'=>'shop_'.$this->user->uid,'id'=>$this->user->uid]);
+        $siteUrl = systemConfig('site_url');
+       $data=$common->Qrcode(['code'=>$siteUrl.'download/index.html?code=shop_'.$this->user->uid,'id'=>$this->user->uid]);
       return app('json')->success(['url'=>$data]);
    }
 }
--- a/app/controller/merchant/store/product/Product.php
+++ b/app/controller/merchant/store/product/Product.php
@ -468,7 +468,7 @@ class Product extends BaseController
                        if ($value['mer_labels'] == ',5,') {
                            $select[$k]['mer_labels_name'] = '五日达';
                        } else {
-                            $select[$k]['mer_labels_name'] = '次日达';
+                            $select[$k]['mer_labels_name'] = '同城';
                        }
                    }
                }
--- a/app/listener/paySuccess.php
+++ b/app/listener/paySuccess.php
@ -37,6 +37,7 @@ class paySuccess
            $orderList = $event['groupOrder']['orderList'];
            $storeConsumptionUserDao = new StoreConsumptionUserDao();
            $storeConsumptionUserDao->check($event['groupOrder']['uid'], $event['groupOrder']['group_order_id']);
+//            $storeConsumptionUserDao->reduce($event['groupOrder']['consumption_id'], $event['groupOrder']['consumption_money']);
            foreach ($orderList as $k => $order) {
                //
                $StoreProcessing->AutomaticallyCreateOrders($order);
--- a/config/cache.php
+++ b/config/cache.php
@ -16,7 +16,7 @@

 return [
    // 默认缓存驱动
-    'default' => env('INSTALLED', false) ? env('cache.driver', 'redis') : 'file',
+    'default' => 'redis',

    // 缓存连接方式配置
    'stores'  => [
--- a/config/swoole.php
+++ b/config/swoole.php
@ -1,116 +0,0 @@
-<?php
-// +----------------------------------------------------------------------
-// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
-// +----------------------------------------------------------------------
-// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
-// +----------------------------------------------------------------------
-// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
-// +----------------------------------------------------------------------
-// | Author: CRMEB Team <admin@crmeb.com>
-// +----------------------------------------------------------------------
-
-
-use app\webscoket\Manager;
-use Swoole\Table;
-use think\swoole\websocket\socketio\Parser;
-
-return [
-    'server'     => [
-        'host'      => env('SWOOLE_HOST', '0.0.0.0'), // 监听地址
-        'port'      => env('SWOOLE_PORT', 8324), // 监听端口
-        'mode'      => SWOOLE_PROCESS, // 运行模式 默认为SWOOLE_PROCESS
-        'sock_type' => SWOOLE_SOCK_TCP, // sock type 默认为SWOOLE_SOCK_TCP
-        'options'   => [
-            'pid_file'              => runtime_path() . 'swoole.pid',
-            'log_file'              => runtime_path() . 'swoole.log',
-            'daemonize'             => false,
-            // Normally this value should be 1~4 times larger according to your cpu cores.
-            'reactor_num'           => swoole_cpu_num(),
-            'worker_num'            => swoole_cpu_num(),
-            'task_worker_num'       => swoole_cpu_num(),
-            'task_enable_coroutine' => false,
-            'task_max_request'      => 2000,
-            'enable_static_handler' => true,
-            'document_root'         => root_path('public'),
-            'package_max_length'    => 100 * 1024 * 1024,
-            'buffer_output_size'    => 10 * 1024 * 1024,
-            'socket_buffer_size'    => 128 * 1024 * 1024,
-            'max_request'           => 3000,
-            'send_yield'            => true,
-            'reload_async'          => true,
-        ],
-    ],
-    'websocket'  => [
-        'enable'        => true,
-        'handler'       => Manager::class,
-        'parser'        => Parser::class,
-        'ping_interval' => 25000, //1000 = 1秒
-        'ping_timeout'  => 60000, //1000 = 1秒
-        'room'          => [
-            'type'  => 'table',
-            'table' => [
-                'room_rows'   => 4096,
-                'room_size'   => 2048,
-                'client_rows' => 8192,
-                'client_size' => 2048,
-            ],
-            'redis' => [
-
-            ],
-        ],
-        'listen'        => [],
-        'subscribe'     => [],
-    ],
-    'rpc'        => [
-        'server' => [
-            'enable'   => false,
-            'port'     => 9000,
-            'services' => [
-            ],
-        ],
-        'client' => [
-        ],
-    ],
-    'hot_update' => [
-        'enable'  => env('APP_DEBUG', false),
-        'name'    => ['*.php'],
-        'include' => [app_path(),root_path().'crmeb'],
-        'exclude' => [],
-    ],
-    //连接池
-    'pool'       => [
-        'db'    => [
-            'enable'        => true,
-            'max_active'    => 3,
-            'max_wait_time' => 5,
-        ],
-        'cache' => [
-            'enable'        => true,
-            'max_active'    => 3,
-            'max_wait_time' => 5,
-        ],
-    ],
-    'coroutine'  => [
-        'enable' => false,
-        'flags'  => SWOOLE_HOOK_ALL,
-    ],
-    'tables' => [
-        'user' => [
-            'size' => 204800,
-            'columns' => [
-                ['name' => 'fd', 'type' => Table::TYPE_INT],
-                ['name' => 'type', 'type' => Table::TYPE_INT],
-                ['name' => 'uid', 'type' => Table::TYPE_INT]
-            ]
-        ]
-    ],
-    //每个worker里需要预加载以共用的实例
-    'concretes'  => [],
-    //重置器
-    'resetters'  => [],
-    //每次请求前需要清空的实例
-    'instances'  => [],
-    //每次请求前需要重新执行的服务
-    'services'   => [],
-    'locks' => ['group_buying'],
-];
--- a/crmeb/jobs/ProductCopyJob.php
+++ b/crmeb/jobs/ProductCopyJob.php
@ -0,0 +1,47 @@
+<?php
+
+// +----------------------------------------------------------------------
+// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
+// +----------------------------------------------------------------------
+// | Author: CRMEB Team <admin@crmeb.com>
+// +----------------------------------------------------------------------
+
+
+namespace crmeb\jobs;
+
+
+use crmeb\interfaces\JobInterface;
+use app\controller\admin\store\StoreProduct;
+use think\facade\Db;
+
+/**
+ * 本地跑远程线程专门使用
+ */
+class ProductCopyJob implements JobInterface
+{
+
+    public function fire($job, $data)
+    {
+        // $arrs= Db::name('store_product')->where('old_product_id',$data['product_id'])->select();
+        // foreach($arrs as $it){
+        //    $res= Db::name('store_product')->where('product_id',$it['product_id'])->update(['is_del'=>1,'is_show'=>0,'is_used'=>0,'status'=>-2]);
+        //     if($res){
+        //         Db::name('cloud_product')->where('product_id',$it['product_id'])->delete();
+
+        //     }
+        // }
+        // $make = app()->make(StoreProduct::class);
+        // $make->copy($data['product_id'],$data['mer_id'],$data['street_code'],$data['type_id'],$data['category_id']);
+        $job->delete();
+    }
+
+
+    public function failed($data)
+    {
+        // TODO: Implement failed() method.
+    }
+}
--- a/crmeb/services/QrcodeService.php
+++ b/crmeb/services/QrcodeService.php
@ -41,10 +41,22 @@ class QrcodeService
            if (!$siteUrl) return '请前往后台设置->系统设置->网站域名 填写您的域名格式为：http://域名';
            $info = [];
            $outfile = Config::get('qrcode.cache_dir');
-            $code = new QrCode($url);
+            $code = new QrCode();
            if(isset($data['code'])){
-                $code->setForegroundColor($data['code']);
+                $code->setForegroundColor([
+                    'r' => 248,
+                    'g' => 150,
+                    'b' => 46,
+                    'a' => 0,
+                ]);
+                $code->setBackgroundColor([
+                    'r' => 255,
+                    'g' => 246,
+                    'b' => 235,
+                    'a' => 0,
+                ]);
            }
+            $code->setText($url);
            if ($uploadType === 1) {
                if (!is_dir('./public/' . $outfile))
                    mkdir('./public/' . $outfile, 0777, true);