<?php
|
namespace app\api\logic\order;
|
|
use think\Db;
|
use app\common\logic\Basic as BasicLogic;
|
use app\common\model\order\TaobaoOrder as ModelTaobaoOrder;
|
use app\api\logic\commission\Tb as LogicTbCommission;
|
|
class TbOrder extends BasicLogic
|
{
|
protected $model;
|
|
protected static $userRate = 0; //用户反佣比例
|
|
|
public function __construct(){
|
$this->model = new ModelTaobaoOrder();
|
}
|
|
|
/**
|
* 淘宝订单入库和更新
|
*
|
* @return void
|
*/
|
public function fanliOrder($order)
|
{
|
$trade_id = isset($order['trade_id']) ? $order['trade_id'] : '';
|
if(empty($trade_id)) return ['status'=>false,'info'=>'订单号为空'];
|
Db::startTrans();
|
$find_order = $this->model->where(['trade_id'=>$trade_id])->find();
|
$save_order = [
|
'tb_paid_time' => isset($order['tb_paid_time']) ? $order['tb_paid_time'] : '',
|
'tk_paid_time' => isset($order['tk_paid_time']) ? $order['tk_paid_time'] : '',
|
'pay_price' => isset($order['pay_price']) ? $order['pay_price'] : '',
|
'pub_share_fee' => isset($order['pub_share_fee']) ? $order['pub_share_fee'] : 0,
|
'trade_id' => $trade_id,
|
'tk_order_role' => isset($order['tk_order_role']) ? $order['tk_order_role'] : '',
|
'tk_earning_time' => isset($order['tk_earning_time']) ? $order['tk_earning_time'] : '',
|
'adzone_id' => isset($order['adzone_id']) ? $order['adzone_id'] : '',
|
'pub_share_rate' => isset($order['pub_share_rate']) ? $order['pub_share_rate'] : '',
|
'refund_tag' => isset($order['refund_tag']) ? $order['refund_tag'] : '',
|
'subsidy_rate' => isset($order['subsidy_rate']) ? $order['subsidy_rate'] : '',
|
'tk_total_rate' => isset($order['tk_total_rate']) ? $order['tk_total_rate'] : '',
|
'item_category_name' => isset($order['item_category_name']) ? $order['item_category_name'] : '',
|
'seller_nick' => isset($order['seller_nick']) ? $order['seller_nick'] : '',
|
'pub_id' => isset($order['pub_id']) ? $order['pub_id'] : '',
|
'alimama_rate' => isset($order['alimama_rate']) ? $order['alimama_rate'] : '',
|
'subsidy_type' => isset($order['subsidy_type']) ? $order['subsidy_type'] : '',
|
'item_img' => isset($order['item_img']) ? $order['item_img'] : '',
|
'pub_share_pre_fee' => isset($order['pub_share_pre_fee']) ? $order['pub_share_pre_fee'] : '',
|
'alipay_total_price' => isset($order['alipay_total_price']) ? $order['alipay_total_price'] : '',
|
'item_title' => isset($order['item_title']) ? $order['item_title'] : '',
|
'site_name' => isset($order['site_name']) ? $order['site_name'] : '',
|
'item_num' => isset($order['item_num']) ? $order['item_num'] : '',
|
'subsidy_fee' => isset($order['subsidy_fee']) ? $order['subsidy_fee'] : '',
|
'alimama_share_fee' => isset($order['alimama_share_fee']) ? $order['alimama_share_fee'] : '',
|
'trade_parent_id' => isset($order['trade_parent_id']) ? $order['trade_parent_id'] : '',
|
'order_type' => isset($order['order_type']) ? $order['order_type'] : '',
|
'tk_create_time' => isset($order['tk_create_time']) ? $order['tk_create_time'] : '',
|
'flow_source' => isset($order['flow_source']) ? $order['flow_source'] : '',
|
'terminal_type' => isset($order['terminal_type']) ? $order['terminal_type'] : '',
|
'click_time' => isset($order['click_time']) ? $order['click_time'] : '',
|
'tk_status' => isset($order['tk_status']) ? $order['tk_status'] : '',
|
'item_price' => isset($order['item_price']) ? $order['item_price'] : '',
|
'item_id' => isset($order['item_id']) ? $order['item_id'] : '',
|
'adzone_name' => isset($order['adzone_name']) ? $order['adzone_name'] : '',
|
'total_commission_rate' => isset($order['total_commission_rate']) ? $order['total_commission_rate'] : '',
|
'item_link' => isset($order['item_link']) ? $order['item_link'] : '',
|
'site_id' => isset($order['site_id']) ? $order['site_id'] : '',
|
'seller_shop_title' => isset($order['seller_shop_title']) ? $order['seller_shop_title'] : '',
|
'income_rate' => isset($order['income_rate']) ? $order['income_rate'] : '',
|
'total_commission_fee' => isset($order['total_commission_fee']) ? $order['total_commission_fee'] : '',
|
'tk_commission_pre_fee_for_media_platform' => isset($order['tk_commission_pre_fee_for_media_platform']) ? $order['tk_commission_pre_fee_for_media_platform'] : '',
|
'tk_commission_fee_for_media_platform' => isset($order['tk_commission_fee_for_media_platform']) ? $order['tk_commission_fee_for_media_platform'] : '',
|
'tk_commission_rate_for_media_platform' => isset($order['tk_commission_rate_for_media_platform']) ? $order['tk_commission_rate_for_media_platform'] : '',
|
'special_id' => isset($order['special_id']) ? $order['special_id'] : '',
|
'relation_id' => isset($order['relation_id']) ? $order['relation_id'] : '',
|
'deposit_price' => isset($order['deposit_price']) ? $order['deposit_price'] : '',
|
'tb_deposit_time' => isset($order['tb_deposit_time']) ? $order['tb_deposit_time'] : '',
|
'tk_deposit_time' => isset($order['tk_deposit_time']) ? $order['tk_deposit_time'] : '',
|
'alsc_id' => isset($order['alsc_id']) ? $order['alsc_id'] : '',
|
'alsc_pid' => isset($order['alsc_pid']) ? $order['alsc_pid'] : '',
|
'tk_share_role_type' => isset($order['tk_share_role_type']) ? $order['tk_share_role_type'] : '',
|
'share_relative_rate' => isset($order['share_relative_rate']) ? $order['share_relative_rate'] : '',
|
'share_fee' => isset($order['share_fee']) ? $order['share_fee'] : '',
|
'share_pre_fee' => isset($order['share_pre_fee']) ? $order['share_pre_fee'] : '',
|
'deposit_price' => isset($order['deposit_price']) ? $order['deposit_price'] : '',
|
];
|
if(empty($find_order)){
|
$save_order['is_distribution'] = (empty($save_order['relation_id']) || $save_order['tk_status'] == 13) ? 2 : 0; //如果没有渠道关系ID则该订单无须反佣
|
$save_order['create_time'] = time();
|
$save_order['one_sign'] = md5($save_order['alipay_total_price'].$order['tk_status']);
|
$save_order['two_sign'] = $save_order['one_sign'];
|
$res = $this->model->insert($save_order);
|
if(!$res){
|
Db::rollback();
|
return ['status'=>false,'info'=>'订单添加失败，订单trade_id：'.$trade_id];
|
}
|
}else{
|
$two_sign = md5($save_order['alipay_total_price'].$order['tk_status']);
|
if($find_order['one_sign'] != $two_sign){ //订单发生改变，更新订单
|
$save_order['two_sign'] = $two_sign;
|
$save_order['update_time'] = time();
|
$res_update = $this->model->where(['trade_id'=> $trade_id])->update($save_order);
|
if(!$res_update){
|
Db::rollback();
|
return ['status'=>false,'info'=>'订单更新失败，订单trade_id：'.$trade_id];
|
}
|
}
|
}
|
Db::commit();
|
return ['status'=>true,'info'=>'订单逻辑处理完成'];
|
}
|
|
|
/**
|
* 拆分订单
|
*
|
* @return void
|
*/
|
public function chaifenOrder()
|
{
|
$list = $this->model->where(['is_distribution'=>0,'relation_id'=>['neq',''],'tk_paid_time'=>['neq','']])->whereOr("is_distribution = 1 And one_sign != two_sign And relation_id !='' And tk_paid_time !=''")->limit(50)->order('id desc')->select();
|
if(!empty($list)){
|
$LogicTbCommission = new LogicTbCommission();
|
foreach($list as $order){
|
// $result = $LogicTbCommission->fanliCommission($order);
|
//新加首单返利
|
$result = $LogicTbCommission->fanliCommissionNew($order);
|
if(!$result){
|
mylog('订单拆分错误',$result['info'],"errorInfo");
|
}
|
dump($result);
|
}
|
}
|
return ['status'=>true,'info'=>'拆分逻辑执行完成'];
|
}
|
|
}
|
