From c0ff1742fdef3a05bb3fead895d1f2af24eeeabd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BD=AD=E6=A1=83?= <1098598843@qq.com> Date: Fri, 7 Apr 2023 17:39:42 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/admin/controller/StoreProduct.php | 468 ++++++++++++++++++- app/admin/view/store_product/tixian.html | 393 ++++++++++++++++ app/admin/view/store_product/withdrawal.html | 128 +++++ app/api/controller/PayNotify.php | 110 ++++- 4 files changed, 1079 insertions(+), 20 deletions(-) create mode 100644 app/admin/view/store_product/tixian.html create mode 100644 app/admin/view/store_product/withdrawal.html diff --git a/app/admin/controller/StoreProduct.php b/app/admin/controller/StoreProduct.php index 7d2dbc9..91bf9e5 100644 --- a/app/admin/controller/StoreProduct.php +++ b/app/admin/controller/StoreProduct.php @@ -4,8 +4,7 @@ * @license https://opensource.org/licenses/Apache-2.0 * @link https://www.gougucms.com */ - -declare (strict_types = 1); + namespace app\admin\controller; @@ -51,6 +50,7 @@ class StoreProduct extends BaseController $list[$k]['brand_id'] = Db::connect('shop')->table('eb_store_brand')->where($www)->value('brand_name'); $www2['store_category_id'] = $v['cate_id']; $list[$k]['cate_id'] = Db::connect('shop')->table('eb_store_category')->where($www2)->value('cate_name'); + $list[$k]['shangjia'] = Db::table('cms_admin')->where('id',$this->uid)->value('nickname'); } return table_assign(0, '', $list); } @@ -343,6 +343,7 @@ class StoreProduct extends BaseController $list[$k]['brand_id'] = Db::connect('shop')->table('eb_store_brand')->where($www)->value('brand_name'); $www2['store_category_id'] = $v['cate_id']; $list[$k]['cate_id'] = Db::connect('shop')->table('eb_store_category')->where($www2)->value('cate_name'); + $list[$k]['shangjia'] = Db::table('cms_admin')->where('id',$this->uid)->value('nickname'); } return table_assign(0, '', $list); } @@ -383,6 +384,8 @@ class StoreProduct extends BaseController 'key' => '95d195Dcf6ec66156dfeeb4E7435faef',//支付秘钥 'secret' => 'c02aa7ad9e4a5c423862e068b6cb4ad4', 'notify_url' => Request::instance()->domain().'/api/PayNotify/notify',//异步回调通知地址 +// 'notify_url' => 'http://t7kqa2.natappfree.cc/api/PayNotify/notify',//异步回调通知地址 + ]; // 这个就是 easywechat 封装的了, 一行代码搞定, 照着写就行了 $app = Factory::payment($config); @@ -419,13 +422,14 @@ class StoreProduct extends BaseController 'product_id' => $id, 'number' => $number, 'admin_id' =>$admin_id, + 'create_time'=>time(), ]; Db::table('cms_store_product_paylog')->strict(false)->field(true)->insert($param); add_log('buy', $id, $param); $app = $this->payment(); -// $total_fee = env('APP_DEBUG') ? 1 : $post_price; - $total_fee = $post_price; + $total_fee = env('APP_DEBUG') ? 1 : $post_price; +// $total_fee = $post_price; // 用 easywechat 封装的方法请求微信的统一下单接口 $result = $app->order->unify([ 'trade_type' => 'NATIVE', // 原生支付即扫码支付，商户根据微信支付协议格式生成的二维码，用户通过微信“扫一扫”扫描二维码后即进入付款确认界面，输入密码即完成支付。 @@ -482,24 +486,198 @@ class StoreProduct extends BaseController public function order(){ if (request()->isAjax()) { $param = get_params(); - $where[] = ['a.admin_id','=',$this->uid]; - if (isset($param['keywords']) && !empty($param['keywords'])){ - $where[]=['b.store_name','like','%'.$param['keywords'].'%']; + if(!isset($param['type'])){ + $type = 1; + }else{ + $type = $param['type']; } - if (isset($param['store_cate']) && !empty($param['store_cate'])){ - $where[]=['b.cate_id','=',$param['store_cate']]; + + if($type == 2){ + $where[] = ['a.admin_id','=',$this->uid]; + if (isset($param['keywords']) && !empty($param['keywords'])){ + $where[]=['b.store_name','like','%'.$param['keywords'].'%']; + } + if (isset($param['store_cate']) && !empty($param['store_cate'])){ + $where[]=['b.cate_id','=',$param['store_cate']]; + } + $rows = empty($param['limit']) ? get_config('app . page_size') : $param['limit']; + $list = Db::table('cms_store_product_order') + ->alias('a') + ->join('cms_store_product b','a.product_id = b.product_id') + ->field('a.*,b.image,b.store_name') + ->withAttr('paid_at',function ($value,$data){ + return date('Y-m-d H:i:s',(int)$value); + }) + ->withAttr('product',function ($value,$data){ + if($data['cart_id']){ + $product_id = Db::table('cms_store_cart')->where('cart_id','in',$data['cart_id'])->column('product_id'); + $product = Db::table('cms_store_product')->where('product_id','in',$product_id)->field('image,store_name')->select()->toArray(); + return $product; + }else{ + $product[0]['store_name'] = $data['store_name']; + $product[0]['image'] = $data['image']; + return $product; + } + }) + ->where($where) + ->order('a.id desc,a.paid_at desc') + ->paginate($rows, false, ['query' => $param]); + + return table_assign(0, '', $list); + }else{ + $where[] = ['admin_id','=',$this->uid]; + if (isset($param['keywords']) && !empty($param['keywords'])){ + $where[]=['store_name','like','%'.$param['keywords'].'%']; + } +// if (isset($param['store_cate']) && !empty($param['store_cate'])){ +// $where[]=['b.cate_id','=',$param['store_cate']]; +// } + $rows = empty($param['limit']) ? get_config('app . page_size') : $param['limit']; + $list = Db::table('cms_store_product_paylog') + ->withAttr('product',function ($value,$data){ + if($data['cart_id']){ + $product_id = Db::table('cms_store_cart')->where('cart_id','in',$data['cart_id'])->column('product_id'); + $product = Db::table('cms_store_product')->where('product_id','in',$product_id)->field('image,store_name')->select()->toArray(); + return $product; + }else{ + $arr = Db::table('cms_store_product')->where('product_id','=',$data['product_id'])->field('image,store_name')->find(); + $product[0]['store_name'] = $arr['store_name']; + $product[0]['image'] = $arr['image']; + return $product; + } + }) + ->withAttr('paid_at',function ($value,$data){ + return ''; + }) + ->where($where) + ->order('id desc') + ->paginate($rows, false, ['query' => $param]); + + return table_assign(0, '', $list); + } + } + else{ + return view(); + } + } +//一条龙,丧葬商品,宴席,婚礼策划,婚纱礼服,婚娶服务,婚车租赁,婚品服务,宴席,水果类,蔬菜类,粮食类,生鲜类,蛋奶类,肉禽类,种子,化肥,农药,农机,农具,禽苗,家政保洁,家电维修,保姆月嫂,洗涤护理,法律咨询,求职招聘,开锁换钥,洗漱用品,化妆品,纸巾,洗衣粉,日常调料,酒水,饮料,零食,日杂百货,休闲食品,生活用品 +// 加入购物车 + public function joincar(){ + $data = get_params(); + $result = $this->cartCheck($data,$this->uid); + if ($cart = $result['cart']) { + //更新购物车 + $cart_id = $cart['cart_id']; + $cart_num = ['cart_num' => ($cart['cart_num'] + $data['cart_num'])]; + $where = [ + 'cart_id' => $cart_id, + ]; + $storeCart = Db::table('cms_store_cart')->where($where)->update($cart_num); + } else { + //添加购物车 + $data['uid'] = $this->uid; + $data['mer_id'] = $result['product']['admin_id']; + $cart = $storeCart = Db::table('cms_store_cart')->insert($data); + } + return to_assign(200, '操作成功',$storeCart); + } + + /** + * TODO 普通商品加入购物车检测 + * @param int $prodcutId + * @param string $unique + * @param int $cartNum + * @author Qinii + * @day 2020-10-20 + */ + public function cartCheck(array $data, $userInfo) + { + $cart = null; + $where = [ + 'status' => 1, + 'is_used' => 1, + 'product_type' => 0, + 'is_gift_bag' => 0, + ]; + $where['product_id'] = $data['product_id']; + unset($where['is_gift_bag']); + $product = Db::table('cms_store_product')->where($where)->find(); + + if (!$product) throw new ValidateException('商品已下架'); +// if ($product['type'] && !$data['is_new']) throw new ValidateException('虚拟商品不可加入购物车'); +// $value_make = app()->make(ProductAttrValueRepository::class); +// $sku = $value_make->getOptionByUnique($data['product_attr_unique']); +// if (!$sku) throw new ValidateException('SKU不存在'); + + + //立即购买 限购 + if ($data['is_new']) { + $cart_num = $data['cart_num']; + } else { + //加入购物车 + //购物车现有 + $_num = $this->productOnceCountCart($where['product_id'],$data['product_attr_unique'], $userInfo); + $cart_num = $_num + $data['cart_num']; + } + if ($product['stock'] < $cart_num ){ + return to_assign(0, '库存不足'); + } + + //添加购物车 +// if (!$data['is_new']) { +// $cart = app()->make(StoreCartRepository::class)->getCartByProductSku($data['product_attr_unique'], $userInfo); +// } + return compact('product', 'cart'); + } + + /** + * TODO 购物车单商品数量 + * @param $productId + * @param $uid + * @param $num + * @author Qinii + * @day 5/26/21 + */ + public function productOnceCountCart($productId,$product_attr_unique,$uid) + { + $where = [ + 'is_pay' => 0, + 'is_del' => 0, + 'is_new' => 0, + 'is_fail' => 0, + 'is_dg' => 0, + 'product_type' => 0, + 'product_id' => $productId, + 'uid' => $uid, + ]; + $cart_num = Db::table('cms_store_cart')->where($where)->sum('cart_num'); + return $cart_num; + } + + +// 购物车列表 + public function carlist(){ + if (request()->isAjax()) { + $param = get_params(); + $where[] = ['a.uid','=',$this->uid]; + $where[] = ['a.is_pay','=',0]; + $where[] = ['a.is_del','=',0]; + $where[] = ['a.is_fail','=',0]; + if (isset($param['keywords']) && !empty($param['keywords'])){ + $where[]=['b.nickname','like','%'.$param['keywords'].'%']; + } + if (isset($param['product_id']) && !empty($param['product_id'])){ + $where[]=['c.product_id','=',$param['product_id']]; } $rows = empty($param['limit']) ? get_config('app . page_size') : $param['limit']; - $list = Db::table('cms_store_product_order') - ->alias('a') - ->join('cms_store_product b','a.product_id = b.product_id') - ->field('a.*,b.image,b.store_name') - ->withAttr('paid_at',function ($value,$data){ - return date('Y-m-d H:i:s',(int)$value); - }) + $list = Db::table('cms_store_cart') + ->alias('a') + ->join('cms_admin b','a.uid = b.id') + ->join('cms_store_product c','a.product_id = c.product_id') + ->field('a.*,c.image,b.nickname,c.store_name') ->where($where) - ->order('a.id desc,a.paid_at desc') - ->paginate($rows, false, ['query' => $param]);; + ->order('a.cart_id desc') + ->paginate($rows, false, ['query' => $param]); return table_assign(0, '', $list); } else{ @@ -507,5 +685,259 @@ class StoreProduct extends BaseController } } +// 购物车支付 + public function paycar(){ + $param = get_params(); + $id = $param['cart_id']; + if($id){ + if(strpos($id,',')){ //多选购物车 + + $ids = explode(',',$id); + $post_price = '0'; + $number = 0; + foreach ($ids as $k=>$v){ + // 根据 id 查出价格 + $where['cart_id'] = $v; + $where['uid'] = $this->uid; + $cart = Db::table('cms_store_cart')->where($where)->lock(true)->find(); + if (empty($cart)) { + return to_assign(0,'查询的数据不存在'); + } + + + $wwww['product_id'] = $cart['product_id']; + $store_product = Db::table('cms_store_product')->where($wwww)->lock(true)->find(); + if (empty($store_product)) { + return to_assign(0,'查询的数据不存在'); + } +// 判断库存 + if($store_product['stock'] < $number){ + return to_assign(0,'超过库存数量'); + } + $number += $cart['cart_num']; + $post_price = bcadd($post_price,bcmul(bcmul((string)$store_product['price'],(string)$number),'100')); + + } + }else{ + + // 根据 id 查出价格 + $where['cart_id'] = $id; + $where['uid'] = $this->uid; + $cart = Db::table('cms_store_cart')->where($where)->lock(true)->find(); + if (empty($cart)) { + return to_assign(0,'查询的数据不存在'); + } + $number = $cart['cart_num']; + $wwww['product_id'] = $cart['product_id']; + $store_product = Db::table('cms_store_product')->where($wwww)->lock(true)->find(); + if (empty($store_product)) { + return to_assign(0,'查询的数据不存在'); + } +// 判断库存 + if($store_product['stock'] < $number){ + return to_assign(0,'超过库存数量'); + } + + $post_price = bcmul(bcmul((string)$store_product['price'],(string)$number),'100'); + } + }else{ + return to_assign(0, '请选择需要支付的商品'); + } + + Db::startTrans();//开启事务 + // 因为没有先创建订单, 所以这里先生成一个随机的订单号, 存在 pay_log 里, 用来标识订单, 支付成功后再把这个订单号存到 order 表里 + $order_sn = date('ymd').substr((string)time(),-5).substr(microtime(),2,5); + $admin_id = get_login_admin('id'); + // 创建 Paylog 记录 + $param =[ + 'appid' => 'wx0b3defb62f0f910b', + 'mch_id' => '1635725673', + 'out_trade_no' => $order_sn, + 'product_id' => $id, + 'number' => $number, + 'admin_id' =>$admin_id, + 'cart_id' =>$id, + 'create_time'=>time() + ]; + + Db::table('cms_store_product_paylog')->strict(false)->field(true)->insert($param); + add_log('buy', $id, $param); + $app = $this->payment(); + + $total_fee = env('APP_DEBUG') ? 1 : $post_price; +// $total_fee = $post_price; + // 用 easywechat 封装的方法请求微信的统一下单接口 + $result = $app->order->unify([ + 'trade_type' => 'NATIVE', // 原生支付即扫码支付，商户根据微信支付协议格式生成的二维码，用户通过微信“扫一扫”扫描二维码后即进入付款确认界面，输入密码即完成支付。 + 'body' => '购物车商品-订单支付', // 这个就是会展示在用户手机上巨款界面的一句话, 随便写的 + 'out_trade_no' => $order_sn, + 'total_fee' => $total_fee, + 'spbill_create_ip' => request()->ip(), // 可选，如不传该参数，SDK 将会自动获取相应 IP 地址 + ]); + if ($result['result_code'] == 'SUCCESS') { + // 如果请求成功, 微信会返回一个 'code_url' 用于生成二维码 + $code_url = $result['code_url']; + // 生成二维码 + // 引用二维码生成方法 + require '../vendor/phpqrcode/phpqrcode.php'; + + $errorCorrectionLevel = 'L'; //容错级别 + $matrixPointSize = 5; //生成图片大小 + //生成二维码图片 + // 判断是否有这个文件夹 没有的话就创建一个 + if(!is_dir("static/qrcode")){ + // 创建文件加 + mkdir("static/qrcode"); + } + //设置二维码文件名 + $filename = 'static/qrcode/'.time().rand(10000,9999999).'.png'; + //生成二维码 + \QRcode::png($code_url,$filename , $errorCorrectionLevel, $matrixPointSize, 2); + // 订单编号, 用于在当前页面向微信服务器发起订单状态查询请求 + $data['order_sn'] = $order_sn; + $data['html'] = Request::instance()->domain().'/'.$filename; + Db::commit(); + return to_assign(200,'操作成功',$data); + } + return to_assign(0,'操作失败'); + } + + + public function delcar(){ + $param = get_params(); + $where['cart_id'] = $param['cart_id']; + $res = Db::table('cms_store_cart')->where($where)->delete(); + if($res){ + return to_assign(200, '删除成功'); + }else{ + return to_assign(0, '删除失败'); + } + } + +// 提现记录列表 + public function tixian(){ + if (request()->isAjax()) { + $param = get_params(); + $where[] = ['admin_id','=',$this->uid]; + $where[] = ['type','=',1]; + if (isset($param['status']) && !empty($param['status'])){ + $where[]=['status','=',$param['status']]; + } + + $rows = empty($param['limit']) ? get_config('app . page_size') : $param['limit']; + $list = Db::table('cms_admin_money_log') + ->where($where) + ->withAttr('nickname',function ($value,$data){ + return Db::table('cms_admin')->where('id',$this->uid)->value('nickname'); + }) + ->withAttr('adminUser',function ($value,$data){ + return Db::table('cms_admin')->where('id',$data['sh_admin_id'])->value('nickname'); + }) + ->order('create_time desc') + ->paginate($rows, false, ['query' => $param]); + + return table_assign(0, '', $list); + } + else{ + return view(); + } + } + +// 申请提现 + public function withdrawal(){ + if (request()->isAjax()) { + $param = get_params(); + if($param['num'] < 100 ){ + return to_assign(0, '最少提现100'); + }else{ + $arr = Db::table('cms_admin_money')->where('admin_id',$this->uid)->find(); + if($arr && $arr['money'] >= $param['num']){ + //写入后台余额记录表 + $log_arr['type'] = 1; + $log_arr['admin_id'] = $this->uid; + $log_arr['num'] = $param['num']; + $log_arr['create_time'] = time(); + $log_arr['status'] = 2; + $log_arr['mark'] = $param['mark']; + $res = Db::table('cms_admin_money_log')->where('admin_id',$this->uid)->strict(false)->field(true)->insert($log_arr); + if($res){ + return to_assign(200, '申请成功'); + }else{ + return to_assign(0, '申请失败'); + } + }else{ + return to_assign(0, '余额不足'); + } + } + }else{ + return view(); + } + } + +// 同意提现 + public function pass(){ + $param = get_params(); + if(empty($param['id'])){ + return to_assign(0, '请选择要操作的数据'); + }else{ + // 启动事务 + Db::startTrans(); + try { + + $find = Db::table('cms_admin_money_log')->where('id',$param['id'])->find(); + if(empty($find)){ + return to_assign(0, '数据未找到'); + } + + $money = Db::table('cms_admin_money')->where('id',$find['admin_id'])->find(); + if($find['num'] > $money['money']){ + return to_assign(0, '余额不足'); + } + $data['status'] = 3; + $data['sh_admin_id'] = $this->uid; + Db::table('cms_admin_money_log')->where('id',$param['id'])->update($data); +// 扣除余额 + Db::table('cms_admin_money')->where('id',$find['admin_id'])->dec('money',$find['num'])->update(); + // 提交事务 + Db::commit(); + } catch (\Exception $e) { + // 回滚事务 + Db::rollback(); + return to_assign(0, '操作失败:' . $e->getMessage()); + } + return to_assign(200); + } + } + +// 拒绝提现 + public function afuse(){ + $param = get_params(); + if(empty($param['id'])){ + return to_assign(0, '请选择要操作的数据'); + }else{ + // 启动事务 + Db::startTrans(); + try { + $find = Db::table('cms_admin_money_log')->where('id',$param['id'])->find(); + if(empty($find)){ + return to_assign(0, '数据未找到'); + } + + $data['status'] = 4; + $data['sh_admin_id'] = $this->uid; + $data['fail_msg'] = $param['fail_msg']; + Db::table('cms_admin_money_log')->where('id',$param['id'])->update($data); + Db::commit(); + } catch (\Exception $e) { + // 回滚事务 + Db::rollback(); + return to_assign(0, '操作失败:' . $e->getMessage()); + } + return to_assign(200); + } + } + + + } diff --git a/app/admin/view/store_product/tixian.html b/app/admin/view/store_product/tixian.html new file mode 100644 index 0000000..b6be53e --- /dev/null +++ b/app/admin/view/store_product/tixian.html @@ -0,0 +1,393 @@ +{extend name="common/base"/} + +{block name="body"} + +
+
+ + +
+
+ +
+ +
+
+
+ +
+
+
+ + + + + + + + +{/block} + + +{block name="script"} + +{/block} + \ No newline at end of file diff --git a/app/admin/view/store_product/withdrawal.html b/app/admin/view/store_product/withdrawal.html new file mode 100644 index 0000000..4b6b092 --- /dev/null +++ b/app/admin/view/store_product/withdrawal.html @@ -0,0 +1,128 @@ +{extend name="common/base"/} +{block name="style"} + +{/block} + +{block name="body"} +
+

申请提现

+ + + + + + + + + + + + + + +
提现金额*
银行卡号*
+
+ + +
+
+{/block} + + + +{block name="script"} + + +{/block} + \ No newline at end of file diff --git a/app/api/controller/PayNotify.php b/app/api/controller/PayNotify.php index 26ceb4c..56072ac 100644 --- a/app/api/controller/PayNotify.php +++ b/app/api/controller/PayNotify.php @@ -105,10 +105,9 @@ class PayNotify extends BaseController 'paid_at' => $paid_at, 'product_id' => $post_id, 'number' => $payLog['number'], + 'cart_id' => $payLog['cart_id'], ]; Db::table('cms_store_product_order')->strict(false)->field(true)->insert($order_arr); -// 减库存 - Db::table('cms_store_product')->where('product_id', $post_id)->dec('stock',$payLog['number'])->update(); // 更新 PayLog, 这里的字段都是根据微信支付结果通知的字段设置的(https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=9_7&index=8) $pay_log = [ @@ -129,6 +128,113 @@ class PayNotify extends BaseController 'return_code' => $message['return_code'], ]; Db::table('cms_store_product_paylog')->where('out_trade_no', $message['out_trade_no'])->update($pay_log); +// 写入商户余额表 + if($payLog['cart_id']){ //购物车 + $time = time(); + if(strpos($payLog['cart_id'],',')){ + $cart_ids = explode(',',$payLog['cart_id']); + foreach ($cart_ids as $k=>$v){ + // 根据 id 查出价格 + $where['cart_id'] = $v; + $cart = Db::table('cms_store_cart')->where($where)->lock(true)->find(); + if (empty($cart)) { + continue; + } +// 根据商品id获取商户admin_id + $wwww['product_id'] = $cart['product_id']; + $store_product = Db::table('cms_store_product')->where($wwww)->lock(true)->find(); + if (empty($store_product)) { + continue; + } +// 更新购物车 + $c_data['is_pay'] = 1; + Db::table('cms_store_cart')->where($where)->update($c_data); + // 减库存 + Db::table('cms_store_product')->where('product_id', $cart['product_id'])->dec('stock',$cart['cart_num'])->update(); + +// 写入后台余额表 + $is_money = Db::table('cms_admin_money')->where('admin_id',$store_product['admin_id'])->lock(true)->find(); + if($is_money){ + $total_fee = bcmul((string)$store_product['price'],(string)$cart['cart_num']); + Db::table('cms_admin_money')->where('admin_id',$store_product['admin_id'])->inc('money',$total_fee)->update(); + }else{ + $total_fee = bcmul((string)$store_product['price'],(string)$cart['cart_num']); + $m_data['admin_id'] = $store_product['admin_id']; + $m_data['money'] = $total_fee; + Db::table('cms_admin_money')->insert($m_data); + } + //写入后台余额记录表 + $log_arr['type'] = 0; + $log_arr['admin_id'] = $store_product['admin_id']; + $log_arr['num'] = $total_fee; + $log_arr['create_time'] = $time; + $log_arr['status'] = 1; + Db::table('cms_admin_money_log')->where('admin_id',$store_product['admin_id'])->strict(false)->field(true)->insert($log_arr); + } + }else{ + $where['cart_id'] = $payLog['cart_id']; + $cart = Db::table('cms_store_cart')->where($where)->lock(true)->find(); + if ($cart) { + // 根据商品id获取商户admin_id + $wwww['product_id'] = $cart['product_id']; + $store_product = Db::table('cms_store_product')->where($wwww)->lock(true)->find(); + if ($store_product) { + // 更新购物车 + $c_data['is_pay'] = 1; + Db::table('cms_store_cart')->where($where)->update($c_data); + // 减库存 + Db::table('cms_store_product')->where('product_id', $cart['product_id'])->dec('stock',$cart['cart_num'])->update(); + //写入后台余额表 + $is_money = Db::table('cms_admin_money')->where('admin_id',$store_product['admin_id'])->lock(true)->find(); + if($is_money){ + $total_fee = bcmul((string)$store_product['price'],(string)$cart['cart_num']); + Db::table('cms_admin_money')->where('admin_id',$store_product['admin_id'])->inc('money',$total_fee)->update(); + }else{ + $total_fee = bcmul((string)$store_product['price'],(string)$cart['cart_num']); + $m_data['admin_id'] = $store_product['admin_id']; + $m_data['money'] = $total_fee; + Db::table('cms_admin_money')->insert($m_data); + } + + //写入后台余额记录表 + $log_arr['type'] = 0; + $log_arr['admin_id'] = $store_product['admin_id']; + $log_arr['num'] = $total_fee; + $log_arr['create_time'] = $time; + $log_arr['status'] = 1; + Db::table('cms_admin_money_log')->where('admin_id',$store_product['admin_id'])->strict(false)->field(true)->insert($log_arr); + } + } + } + + }else{ + +// 根据商品id获取商户admin_id + $www['product_id'] = $post_id; + $store_product = Db::table('cms_store_product')->where($www)->find(); + if (!empty($store_product)) { + // 减库存 + Db::table('cms_store_product')->where('product_id', $post_id)->dec('stock',$payLog['number'])->update(); + //写入后台余额表 + $is_money = Db::table('cms_admin_money')->where('admin_id',$store_product['admin_id'])->lock(true)->find(); + if($is_money){ + $total_fee = bcdiv($message['total_fee'],'100',2); + Db::table('cms_admin_money')->where('admin_id',$store_product['admin_id'])->inc('money',$total_fee)->update(); + }else{ + $total_fee = bcdiv($message['total_fee'],'100',2); + $m_data['admin_id'] = $store_product['admin_id']; + $m_data['money'] = $total_fee; + Db::table('cms_admin_money')->insert($m_data); + } + //写入后台余额记录表 + $log_arr['type'] = 0; + $log_arr['admin_id'] = $store_product['admin_id']; + $log_arr['num'] = $total_fee; + $log_arr['create_time'] = time(); + $log_arr['status'] = 1; + Db::table('cms_admin_money_log')->where('admin_id',$store_product['admin_id'])->strict(false)->field(true)->insert($log_arr); + } + } } } else { // 如果支付失败, 也更新 PayLog, 跟上面一样, 就是多了 error 信息