2024-08-03 10:04:14 +08:00
< ? php
namespace app\api\controller ;
use app\api\logic\OrderInvoiceLogic ;
use app\api\logic\OrderLogic ;
use app\api\validate\OrderValidate ;
use app\common\basics\Api ;
use app\common\server\JsonServer ;
use think\facade\Db ;
use app\common\model\after_sale\AfterSale ;
use app\common\model\order\Order as Morder ;
use app\common\model\user\User ;
use app\common\server\ConfigServer ;
use app\common\model\AccountLog ;
use app\common\model\shop\Shop ;
use app\common\model\user\UserDistribution ;
use app\shop\logic\order\OrderLogic as Express ;
class Order extends Api
{
public $like_not_need_login = [ 'testPromotion' ];
/**
* @ notes 下单
* @ return \think\response\Json
* @ throws \think\Exception
* @ author suny
* @ date 2021 / 7 / 13 6 : 11 下午
*/
public function submitOrder ()
{
$post = $this -> request -> post ();
$post [ 'user_id' ] = $this -> user_id ;
$post [ 'client' ] = $this -> client ;
( new OrderValidate ()) -> goCheck ( 'add' , $post );
$order = OrderLogic :: add ( $post );
if ( false === $order ) {
return JsonServer :: error ( OrderLogic :: getError ());
}
return JsonServer :: success ( '下单成功!' , $order );
}
public function testPromotion (){ ///无相测试使用
$time = time ();
$afterSaleTime = ConfigServer :: get ( 'distribution' , 'settlement_days' , 7 );
$afterSaleTime = intval ( $afterSaleTime * 24 * 60 * 60 );
//2.查询所有未分销结算的订单,推荐人提成计算 //无相增加
$promotionOrders_rz = Morder :: alias ( 'O' ) //入驻店铺
-> field ([ 'O.id' , 'O.order_sn' , 'O.total_amount' , 'O.user_id' , 'U.first_leader' , 'S.type as stype' , 'U.second_leader' , 'U.third_leader' , 'S.id as sid' , 'U.id as uid' , 'S.trade_promotion_fee' , 'S.promotion_buy_fee' , 'S.team_first_fee' , 'S.team_second_fee' , 'S.team_third_fee' ])
-> join ( 'shop S' , 'O.shop_id = S.id' )
-> join ( 'shop_admin SA' , 'O.shop_id = SA.shop_id' )
-> join ( 'shop_apply SAP' , 'SAP.account = SA.account' )
-> join ( 'procurement U' , 'SAP.user_id = U.id' )
-> whereRaw ( " O.confirm_take_time+ $afterSaleTime < $time " )
-> where ([[ 'O.confirm_take_time' , '>' , 0 ],[ 'O.promotion_settle' , " = " , 0 ],[ 'S.type' , '=' , 2 ]]) //已确认收货且没有结算的订单,商家为入驻商家
-> limit ( 100 )
-> select () -> toArray ();
$promotionOrders_zy = Morder :: alias ( 'O' ) //自营店铺
-> field ([ 'O.id' , 'O.order_sn' , 'O.total_amount' , 'U.first_leader' , 'U.second_leader' , 'U.third_leader' , 'S.id as sid' , 'U.id as uid' , 'S.trade_promotion_fee' , 'S.promotion_buy_fee' , 'S.team_first_fee' , 'S.team_second_fee' , 'S.team_third_fee' , 'S.type as stype' ])
-> join ( 'shop S' , 'O.shop_id = S.id' )
-> join ( 'procurement U' , 'O.user_id = U.id' )
-> whereRaw ( " O.confirm_take_time+ $afterSaleTime < $time " )
-> where ([[ 'O.confirm_take_time' , '>' , 0 ],[ 'O.promotion_settle' , " = " , 0 ],[ 'S.type' , '=' , 1 ]]) //已确认收货且没有结算的订单,商家为入驻商家
-> limit ( 100 )
-> select () -> toArray ();
$promotionOrders = array_merge ( $promotionOrders_rz , $promotionOrders_zy );
//dump($promotionOrders);die();
foreach ( $promotionOrders as & $order ) {
// 增加用户佣金,推广者如果是个人，就直接返推广点，否者按推广层级进行返点
if ( $order [ " stype " ] == 1 ){ //如果是自营店铺，直接给购买人提成
$buyer = User :: where ( 'id' , $order [ 'uid' ]) -> find (); //购买者
$wallet = Shop :: where ( 'id' , $order [ 'sid' ]) -> value ( 'wallet' ); //商家减去佣金
$earnings_buy = User :: where ( 'id' , $buyer [ 'first_leader' ]) -> value ( 'earnings' );
if ( $earnings_buy ){ //如果购买者有推荐人，就发推荐奖励
$money_buy = $order [ 'total_amount' ] * $order [ 'promotion_buy_fee' ] / 100 ;
User :: update ([
'earnings' => $earnings_buy + $money_buy ,
'update_time' => $time ,
'id' => $buyer [ 'first_leader' ]
]);
Shop :: update ([
'wallet' => $wallet - $money_buy ,
'update_time' => $time ,
'id' => $order [ 'sid' ]
]);
UserDistribution :: where ( " user_id " , $buyer [ 'id' ]) -> update ([
'order_num' => Db :: raw ( 'order_num+1' ),
'distribution_money' => $money_buy ,
'order_amount' => Db :: raw ( " order_amount+ " . $order [ 'total_amount' ]),
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $buyer [ 'first_leader' ],
'source_type' => AccountLog :: distribution_inc_earnings ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money_buy ,
'left_amount' => $earnings_buy + $money_buy ,
'change_type' => 1 ,
'remark' => '推广佣金增加'
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'uid' ],
'source_type' => AccountLog :: shop_reduce_wallet ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money_buy ,
'left_amount' => $wallet - $money_buy ,
'change_type' => 1 ,
'remark' => '商铺钱包余额减少'
]);
}
} else {
// 商家钱包金额
$wallet = Shop :: where ( 'id' , $order [ 'sid' ]) -> value ( 'wallet' ); //商家减去佣金
//先执行推荐购买返点
$buyer = User :: where ( 'id' , $order [ 'user_id' ]) -> find (); //购买者
$earnings_buy = User :: where ( 'id' , $buyer [ 'first_leader' ]) -> value ( 'earnings' );
if ( $earnings_buy ){ //如果购买者有推荐人，就发推荐奖励
$money_buy = $order [ 'total_amount' ] * $order [ 'promotion_buy_fee' ] / 100 ;
User :: update ([
'earnings' => $earnings_buy + $money_buy ,
'update_time' => $time ,
'id' => $buyer [ 'first_leader' ]
]);
Shop :: update ([
'wallet' => $wallet - $money_buy ,
'update_time' => $time ,
'id' => $order [ 'sid' ]
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $buyer [ 'first_leader' ],
'source_type' => AccountLog :: distribution_inc_earnings ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money_buy ,
'left_amount' => $earnings_buy + $money_buy ,
'change_type' => 1 ,
'remark' => '推广佣金增加'
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'uid' ],
'source_type' => AccountLog :: shop_reduce_wallet ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money_buy ,
'left_amount' => $wallet - $money_buy ,
'change_type' => 1 ,
'remark' => '商铺钱包余额减少'
]);
}
//获取店铺
$promoter = User :: where ( 'id' , $order [ 'first_leader' ]) -> find (); //查询推广者
if ( $promoter ){
if ( ! $promoter [ " is_team " ]){ //不是团队就直接分账
$earnings = User :: where ( 'id' , $order [ 'first_leader' ]) -> value ( 'earnings' ); //给推广者增加佣金
$money = $order [ 'total_amount' ] * $order [ 'trade_promotion_fee' ] / 100 ;
User :: update ([
'earnings' => $earnings + $money ,
'update_time' => $time ,
'id' => $order [ 'first_leader' ]
]);
Shop :: update ([
'wallet' => $wallet - $money ,
'update_time' => $time ,
'id' => $order [ 'sid' ]
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'first_leader' ],
'source_type' => AccountLog :: distribution_inc_earnings ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $earnings + $money ,
'change_type' => 1 ,
'remark' => '推广佣金增加'
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'uid' ],
'source_type' => AccountLog :: shop_reduce_wallet ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $wallet - $money ,
'change_type' => 1 ,
'remark' => '商铺钱包余额减少'
]);
} else { //如果是团队需要按三级分成
//一级
$earnings = User :: where ( 'id' , $order [ 'first_leader' ]) -> value ( 'earnings' ); //给推广者增加佣金
$money = $order [ 'total_amount' ] * $order [ 'team_first_fee' ] / 100 ;
User :: update ([
'earnings' => $earnings + $money ,
'update_time' => $time ,
'id' => $order [ 'first_leader' ]
]);
Shop :: update ([
'wallet' => $wallet - $money ,
'update_time' => $time ,
'id' => $order [ 'sid' ]
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'first_leader' ],
'source_type' => AccountLog :: distribution_inc_earnings ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $earnings + $money ,
'change_type' => 1 ,
'remark' => '推广佣金增加'
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'uid' ],
'source_type' => AccountLog :: shop_reduce_wallet ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $wallet - $money ,
'change_type' => 1 ,
'remark' => '商铺钱包余额减少'
]);
//二级
$promoter_2 = User :: where ( 'id' , $order [ 'second_leader' ]) -> find (); //给推广者增加佣金
if ( $promoter_2 ){
$earnings = User :: where ( 'id' , $order [ 'second_leader' ]) -> value ( 'earnings' ); //给推广者增加佣金
$money = $order [ 'total_amount' ] * $order [ 'team_second_fee' ] / 100 ;
User :: update ([
'earnings' => $earnings + $money ,
'update_time' => $time ,
'id' => $order [ 'second_leader' ]
]);
Shop :: update ([
'wallet' => $wallet - $money ,
'update_time' => $time ,
'id' => $order [ 'sid' ]
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'second_leader' ],
'source_type' => AccountLog :: distribution_inc_earnings ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $earnings + $money ,
'change_type' => 1 ,
'remark' => '推广佣金增加'
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'uid' ],
'source_type' => AccountLog :: shop_reduce_wallet ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $wallet - $money ,
'change_type' => 1 ,
'remark' => '商铺钱包余额减少'
]);
}
//三级
$promoter_3 = User :: where ( 'id' , $order [ 'third_leader' ]) -> find (); //给推广者增加佣金
if ( $promoter_3 ){
$earnings = User :: where ( 'id' , $order [ 'third_leader' ]) -> value ( 'earnings' ); //给推广者增加佣金
$money = $order [ 'total_amount' ] * $order [ 'team_third_fee' ] / 100 ;
User :: update ([
'earnings' => $earnings + $money ,
'update_time' => $time ,
'id' => $order [ 'third_leader' ]
]);
Shop :: update ([
'wallet' => $wallet - $money ,
'update_time' => $time ,
'id' => $order [ 'sid' ]
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'third_leader' ],
'source_type' => AccountLog :: distribution_inc_earnings ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $earnings + $money ,
'change_type' => 1 ,
'remark' => '推广佣金增加'
]);
// 记录流水
AccountLog :: create ([
'log_sn' => createSn ( 'account_log' , 'log_sn' , '' , 4 ),
'user_id' => $order [ 'uid' ],
'source_type' => AccountLog :: shop_reduce_wallet ,
'source_id' => $order [ 'id' ],
'source_sn' => $order [ 'order_sn' ],
'change_amount' => $money ,
'left_amount' => $wallet - $money ,
'change_type' => 1 ,
'remark' => '商铺钱包余额减少'
]);
}
}
}
} ///入驻店铺结束
//更新订单推广状态
Morder :: update ([
'promotion_settle' => 1 ,
'update_time' => $time ,
'id' => $order [ 'id' ]
]);
}
//var_dump($promotionOrders);die();
return JsonServer :: success ( '获取成功' , $promotionOrders );
}
/**
* @ notes 结算页数据
* @ return \think\response\Json
* @ author suny
* @ date 2021 / 7 / 13 6 : 11 下午
*/
public function settlement ()
{
$post = $this -> request -> post ();
$post [ 'user_id' ] = $this -> user_id ;
$post [ 'client' ] = $this -> client ;
$result = OrderLogic :: settlement ( $post );
if ( $result === false ) {
return JsonServer :: error ( OrderLogic :: getError (), [], 301 );
}
return JsonServer :: success ( '获取成功' , $result );
}
/**
* @ notes 订单列表
* @ return \think\response\Json
* @ author suny
* @ date 2021 / 7 / 13 6 : 11 下午
*/
public function lists ()
{
$type = $this -> request -> get ( 'type' , 'all' );
$order_list = OrderLogic :: getOrderList ( $this -> user_id , $type , $this -> page_no , $this -> page_size );
return JsonServer :: success ( '获取成功' , $order_list );
}
/**
* @ notes 获取订单详情
* @ return \think\response\Json
* @ author suny
* @ date 2021 / 7 / 13 6 : 11 下午
*/
public function getOrderDetail ()
{
$get = $this -> request -> get ();
( new OrderValidate ()) -> goCheck ( 'detail' , $get );
$detail = OrderLogic :: getOrderDetail ( $get [ 'id' ]);
return JsonServer :: success ( '获取成功' , $detail );
}
// public function getOrder1()
// {
// $detail = OrderLogic::billions();
// }
/**
* @ notes 取消订单
* @ return array | \think\response\Json
* @ throws \think\db\exception\DataNotFoundException
* @ throws \think\db\exception\ModelNotFoundException
* @ throws \think\exception\DbException
* @ author suny
* @ date 2021 / 7 / 13 6 : 11 下午
*/
public function cancel ()
{
$order_id = $this -> request -> post ( 'id' );
if ( empty ( $order_id )) {
return JsonServer :: error ( '参数错误' );
}
return OrderLogic :: cancel ( $order_id , $this -> user_id );
}
/**
* @ notes 确认收货
* @ return array | \think\response\Json
* @ author suny
* @ date 2021 / 7 / 13 6 : 11 下午
*/
public function confirm ()
{
$order_id = $this -> request -> post ( 'id' );
if ( empty ( $order_id )) {
return JsonServer :: error ( '参数错误' );
}
$result = OrderLogic :: billions ( $order_id );
if ( $result === - 2 ){
return JsonServer :: error ( '账户被禁用' );
}
if ( $result === - 3 ){
return JsonServer :: error ( '更新余额状态失败' );
}
if ( $result === - 4 ){
return JsonServer :: error ( '更新余额失败' );
}
if ( $result === - 5 ){
return JsonServer :: error ( '插入记录失败' );
}
return OrderLogic :: confirm ( $order_id , $this -> user_id );
}
/**
* @ notes 删除订单
* @ return array | \think\response\Json
* @ author suny
* @ date 2021 / 7 / 13 6 : 12 下午
*/
public function del ()
{
$order_id = $this -> request -> post ( 'id' );
if ( empty ( $order_id )) {
return JsonServer :: error ( '参数错误' );
}
return OrderLogic :: del ( $order_id , $this -> user_id );
}
/**
* @ notes 订单支付结果页面数据
* @ return \think\response\Json
* @ author suny
* @ date 2021 / 7 / 13 6 : 12 下午
*/
public function pay_result ()
{
$id = $this -> request -> get ( 'id' );
$from = $this -> request -> get ( 'from' ); //标识： ： ， ：
$result = OrderLogic :: pay_result ( $id , $from );
if ( $result !== false ) {
return JsonServer :: success ( '' , $result );
} else {
return JsonServer :: error ( '参数错误' );
}
}
/**
* @ notes 获取支付方式
* @ return \think\response\Json
* @ author suny
* @ date 2021 / 7 / 13 6 : 12 下午
*/
public function getPayWay ()
{
$params = $this -> request -> get ();
if ( ! isset ( $params [ 'from' ]) || ! isset ( $params [ 'order_id' ])) {
return JsonServer :: error ( '参数缺失' );
}
$pay_way = OrderLogic :: getPayWay ( $this -> user_id , $this -> client , $params );
return JsonServer :: success ( '' , $pay_way );
}
/**
* @ notes 物流查询
* @ return \think\response\Json
* @ throws \think\db\exception\DataNotFoundException
* @ throws \think\db\exception\DbException
* @ throws \think\db\exception\ModelNotFoundException
* @ throws \think\exception\DbException
* @ author suny
* @ date 2021 / 7 / 13 6 : 12 下午
*/
2024-08-17 16:14:33 +08:00
// public function orderTraces()
// {
// $order_id = $this->request->get('id');
// $tips = '参数错误';
// if ($order_id) {
// $traces = OrderLogic::orderTraces($order_id, $this->user_id);
// if ($traces) {
// return JsonServer::success('获取成功', $traces);
// }
// $tips = '暂无物流信息';
// }
// return JsonServer::error($tips);
// }
2024-08-03 10:04:14 +08:00
public function orderTraces ()
{
2024-08-17 16:14:33 +08:00
$id = $this -> request -> get ( 'id' );
2024-08-03 10:04:14 +08:00
$tips = '参数错误' ;
2024-08-17 16:14:33 +08:00
if ( $id ) {
$traces = OrderLogic :: getExpress ( $id , $this -> user_id );
2024-08-03 10:04:14 +08:00
if ( $traces ) {
return JsonServer :: success ( '获取成功' , $traces );
}
$tips = '暂无物流信息' ;
}
return JsonServer :: error ( $tips );
}
/**
* @ notes PC获取支付状态
* @ return \think\response\Json
* @ author suny
* @ date 2021 / 10 / 29 3 : 52 下午
*/
public function getPayStatus ()
{
$id = $this -> request -> get ( 'id' );
$from = $this -> request -> get ( 'from' ); //标识： ： ， ：
$result = OrderLogic :: getPayStatus ( $id , $from );
if ( $result !== false ) {
return JsonServer :: success ( '' , $result );
} else {
return JsonServer :: error ( '参数错误' );
}
}
/**
* @ notes 发票详情
* @ return \think\response\Json
* @ author 段誉
* @ date 2022 / 4 / 12 9 : 25
*/
public function invoice ()
{
$id = $this -> request -> get ( 'id' );
$result = OrderInvoiceLogic :: getInvoiceDetailByOrderId ( $id );
return JsonServer :: success ( '获取成功' , $result );
}
/*提交集采订单*/
public function submitJicai (){
$post = $this -> request -> post ();
$post [ " user_id " ] = $this -> user_id ;
$post [ " status " ] = 0 ;
$post [ " create_time " ] = time ();
$post [ " get_time " ] = strtotime ( $post [ " get_time " ]);
$res = Db :: name ( " jicai " ) -> insert ( $post );
if ( $res ){
return JsonServer :: success ( '提交成功' );
}
}
/**
* 获取物流地址
*/
public function express ()
{
$order_id = $this -> request -> get ( 'order_id' );
$result = Express :: getShipping ( $order_id );
return JsonServer :: success ( '获取成功' , []);
try {
$result = json_decode ( $result , true );
if ( isset ( $result [ 'returnCode' ]) && $result [ 'returnCode' ] == 500 ) {
return JsonServer :: success ( '获取成功' , []);
}
} catch ( \Exception $e ) {
}
//return JsonServer::success('获取成功', []);
if ( $result == '暂无物流信息' ) {
return JsonServer :: success ( '获取成功' );
} else if ( isset ( $result [ 'returnCode' ]) && $result [ 'returnCode' ] == 200 ) {
return JsonServer :: success ( '获取成功' , $result );
} else if ( isset ( $result [ 'state' ])) {
return JsonServer :: success ( '获取成功' , $result );
} else if ( isset ( $result [ 'returnCode' ]) && $result [ 'returnCode' ] != 200 ) {
return JsonServer :: success ( '获取成功' , []);
2024-08-17 16:51:46 +08:00
}
2024-08-03 10:04:14 +08:00
}
}
