php
/
xunxibaoapi.yaoyz.com
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
租房掌柜微信小程序Api以及小程序前端模板
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
10 Commits
1 Branch
0 Tags
14 MiB
 
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
xunxibaoapi.yaoyz.com/application/store/controller/api/member/Order.php

313 lines
13 KiB
Raw Permalink Blame History

<?php
// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------
namespace app\store\controller\api\member;
use app\store\controller\api\Member;
use app\store\service\GoodsService;
use app\store\service\OrderService;
use library\tools\Data;
use think\Db;
use think\exception\HttpResponseException;
/**
* 订单接口管理
* Class Order
* @package app\store\controller\api\member
*/
class Order extends Member
{
/**
* 创建商城订单
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* 商品ID1@商品规格1@商品数量1||商品ID2@商品规格2@商品数量2
*/
public function set()
{
// 商品规则
$rule = $this->request->post('rule', '');
if (empty($rule)) $this->error('下单商品规则不能为空！');
// 订单处理
list($orderList, $order) = [[], [
'status' => '1', 'mid' => $this->mid,
'order_no' => Data::uniqidNumberCode(12),
'from_mid' => $this->request->post('from_mid', '0'),
]];
// 推荐人处理
if (intval($order['from_mid']) === intval($this->mid)) {
$order['from_mid'] = '0';
} elseif ($order['from_mid'] > 0) {
if (Db::name('StoreMember')->where(['id' => $order['from_mid']])->count() < 1) {
$this->error('无效的推荐会员ID，稍候再试！');
}
}
foreach (explode('||', $rule) as $item) {
list($goods_id, $goods_spec, $number) = explode('@', $item);
// 商品信息检查
$goods = Db::name('StoreGoods')->where(['id' => $goods_id, 'status' => '1', 'is_deleted' => '0'])->find();
if (empty($goods)) $this->error('查询商品主体信息失败，请稍候再试！');
$spec = Db::name('StoreGoodsList')->where(['goods_id' => $goods_id, 'goods_spec' => $goods_spec])->find();
if (empty($spec)) $this->error('查询商品规则信息失败，请稍候再试！');
// 商品库存检查
if ($spec['number_sales'] + $number > $spec['number_stock']) {
$this->error('商品库存不足，请购买其它商品！');
}
// 订单详情处理
array_push($orderList, [
'mid' => $order['mid'],
'from_mid' => $order['from_mid'],
'order_no' => $order['order_no'],
// 商品信息字段管理
'goods_id' => $goods_id,
'goods_spec' => $goods_spec,
'goods_logo' => $goods['logo'],
'goods_title' => $goods['title'],
'number_goods' => $number,
'number_express' => $spec['number_express'],
// 费用字段处理
'price_market' => $spec['price_market'],
'price_selling' => $spec['price_selling'],
'price_real' => $spec['price_selling'] * $number,
'price_express' => $goods['price_express'],
// 返利字段处理
'price_rate' => $goods['price_rate'],
'price_rate_amount' => $spec['price_selling'] * $number * $goods['price_rate'] / 100,
]);
}
$order['price_goods'] = array_sum(array_column($orderList, 'price_real')) + 0;
$order['price_express'] = max(array_column($orderList, 'price_express')) + 0;
$order['price_total'] = $order['price_goods'] + $order['price_express'];
$order['price_rate_amount'] = array_sum(array_column($orderList, 'price_rate_amount')) + 0;
try {
// 订单数据写入
Db::name('StoreOrder')->insert($order);
Db::name('StoreOrderList')->insertAll($orderList);
// 同步商品库存及销量
foreach (array_unique(array_column($orderList, 'goods_id')) as $goodsId) GoodsService::syncStock($goodsId);
$this->success('订单创建成功，请补全收货信息后支付！', ['order' => $order]);
} catch (HttpResponseException $exception) {
throw $exception;
} catch (\Exception $e) {
$this->error("创建订单失败，请稍候再试！{$e->getMessage()}");
}
}
/**
* 订单信息完成
* @throws \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function perfect()
{
$data = $this->_input([
'order_no' => $this->request->post('order_no'),
'address_id' => $this->request->post('address_id'),
], [
'order_no' => 'require',
'address_id' => 'require',
], [
'order_no.require' => '订单号不能为空！',
'address_id.require' => '收货地址ID不能为空（0自提可以为空）',
]);
$map = ['order_no' => $data['order_no'], 'mid' => $this->member['id']];
$order = Db::name('StoreOrder')->whereIn('status', ['1', '2'])->where($map)->find();
if (empty($order)) $this->error('订单异常，请返回商品重新下单！');
$update = ['status' => '2'];
$where = ['id' => $data['address_id'], 'mid' => $this->member['id']];
$address = Db::name('StoreMemberAddress')->where($where)->find();
if (empty($address)) $this->error('会员收货地址异常，请刷新页面重试！');
$update['express_address_id'] = $data['address_id'];
$update['express_name'] = $address['name'];
$update['express_phone'] = $address['phone'];
$update['express_province'] = $address['province'];
$update['express_city'] = $address['city'];
$update['express_area'] = $address['area'];
$update['express_address'] = $address['address'];
if (Db::name('StoreOrder')->where($map)->update($update) !== false) {
$params = $this->getPayParams($order['order_no'], $order['price_total']);
$this->success('更新订单会员信息成功！', $params);
} else {
$this->error('更新订单会员信息失败，请稍候再试！');
}
}
/**
* 获取订单支付状态
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function pay()
{
$order_no = $this->request->post('order_no');
$order = Db::name('StoreOrder')->where(['order_no' => $order_no])->find();
if (empty($order_no)) $this->error('获取订单信息异常，请稍候再试！');
if ($order['pay_state']) $this->error('订单已经完成支付，不需要再次支付！');
if ($order['status'] <> 2) $this->error('该订单不能发起支付哦！');
try {
$param = $this->getPayParams($order['order_no'], $order['price_total']);
$this->success('获取订单支付参数成功！', $param);
} catch (HttpResponseException $exception) {
throw $exception;
} catch (\Exception $e) {
$this->error("获取订单支付参数失败，{$e->getMessage()}");
}
}
/**
* 获取订单支付参数
* @param string $order_no
* @param string $pay_price
* @return array
*/
private function getPayParams($order_no, $pay_price)
{
$options = [
'body' => '商城订单支付',
'openid' => $this->openid,
'out_trade_no' => $order_no,
// 'total_fee' => '1',
'total_fee' => $pay_price * 100,
'trade_type' => 'JSAPI',
'notify_url' => url('@store/api.notify/wxpay', '', false, true),
'spbill_create_ip' => $this->request->ip(),
];
try {
$pay = \We::WePayOrder(config('wechat.miniapp'));
$info = $pay->create($options);
if ($info['return_code'] === 'SUCCESS' && $info['result_code'] === 'SUCCESS') {
return $pay->jsapiParams($info['prepay_id']);
}
if (isset($info['err_code_des'])) {
throw new \think\Exception($info['err_code_des']);
}
} catch (\Exception $e) {
$this->error("创建订单失败参数失败，{$e->getMessage()}");
}
}
/**
* 获取订单列表
* @throws \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function gets()
{
$where = [['mid', 'eq', $this->mid]];
if ($this->request->has('order_no', 'post', true)) {
$where[] = ['order_no', 'eq', $this->request->post('order_no')];
} else {
$where[] = ['status', 'in', ['0', '2', '3', '4', '5']];
}
if ($this->request->has('status', 'post', true)) {
$where[] = ['status', 'eq', $this->request->post('status')];
}
$result = $this->_query('StoreOrder')->where($where)->order('id desc')->page(true, false, false, 20);
$glist = Db::name('StoreOrderList')->whereIn('order_no', array_unique(array_column($result['list'], 'order_no')))->select();
foreach ($result['list'] as &$vo) {
list($vo['goods_count'], $vo['list']) = [0, []];
foreach ($glist as $goods) if ($vo['order_no'] === $goods['order_no']) {
$vo['list'][] = $goods;
$vo['goods_count'] += $goods['number_goods'];
}
}
$this->success('获取订单列表成功！', $result);
}
/**
* 订单取消
* @throws \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function cancel()
{
$where = [
'mid' => $this->member['id'],
'order_no' => $this->request->post('order_no'),
];
$order = Db::name('StoreOrder')->where($where)->find();
if (empty($order)) $this->error('待取消的订单不存在，请稍候再试！');
if (in_array($order['status'], ['1', '2'])) {
$result = Db::name('StoreOrder')->where($where)->update([
'status' => '0',
'cancel_state' => '1',
'cancel_at' => date('Y-m-d H:i:s'),
'cancel_desc' => '用户主动取消订单！',
]);
if ($result !== false && OrderService::syncStock($order['order_no'])) {
$this->success('订单取消成功！');
} else {
$this->error('订单取消失败，请稍候再试！');
}
} else {
$this->error('该订单状态不允许取消哦~');
}
}
/**
* 订单确认收货
* @throws \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function confirm()
{
$where = [
'mid' => $this->member['id'],
'order_no' => $this->request->post('order_no'),
];
$order = Db::name('StoreOrder')->where($where)->find();
if (empty($order)) $this->error('待确认的订单不存在，请稍候再试！');
if (in_array($order['status'], ['4'])) {
if (Db::name('StoreOrder')->where($where)->update(['status' => '5']) !== false) {
$this->success('订单确认成功！');
} else {
$this->error('订单取确认失败，请稍候再试！');
}
} else {
$this->error('该订单状态不允许确认哦~');
}
}
/**
* 订单状态统计
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function total()
{
$result = Db::name('StoreOrder')
->fieldRaw('mid,status,count(1) count')
->where(['mid' => $this->mid])
->group('status')
->select();
$this->success('获取订单统计记录！', $result);
}
}