model = new ModelDyOrder(); } /** * 订单入库和更新 * * @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'=>$order['trade_id']])->find(); $save_order = [ 'shop_name' => isset($order['shop_name']) ? $order['shop_name'] : '', 'item_title' => isset($order['item_title']) ? $order['item_title'] : '', 'item_img' => isset($order['item_img']) ? $order['item_img'] : '', 'paid_time' => isset($order['paid_time']) ? $order['paid_time'] : '', 'trade_id' => $trade_id, 'trade_parent_id' => isset($order['trade_parent_id']) ? $order['trade_parent_id'] : '', 'refund_time' => isset($order['refund_time']) ? $order['refund_time'] : '', 'create_time' => isset($order['create_time']) ? $order['create_time'] : '', 'settled_status' => isset($order['settled_status']) ? $order['settled_status'] : '', 'pay_price' => isset($order['pay_price']) ? $order['pay_price'] : '', 'predict_money' => isset($order['predict_money']) ? $order['predict_money'] : '', 'actual_money' => isset($order['actual_money']) ? $order['actual_money'] : '', 'shop_id' => isset($order['shop_id']) ? $order['shop_id'] : '', 'channel_code' => isset($order['channel_code']) ? $order['channel_code'] : '', 'update_time' => isset($order['update_time']) ? $order['update_time'] : '', 'item_num' => isset($order['item_num']) ? $order['item_num'] : '', 'product_id' => isset($order['product_id']) ? $order['product_id'] : '', 'order_status' => isset($order['order_status']) ? $order['order_status'] : '', 'earning_time' => isset($order['earning_time']) ? $order['earning_time'] : '', 'media_type' => isset($order['media_type']) ? $order['media_type'] : '', ]; if(empty($find_order)){ $save_order['tk_z_status'] = 1; $save_order['is_distribution'] = (empty($save_order['channel_code']) || $save_order['channel_code'] == 0) ? 2 : 0; //如果没有渠道关系ID则该订单无须反佣 $save_order['reate_time'] = time(); $res = $this->model->insert($save_order); if(!$res){ Db::rollback(); return ['status'=>false,'info'=>'订单添加失败,订单trade_id:'.$order['trade_id']]; } }else{ if($find_order['order_status'] != $save_order['order_status']){ //订单发生改变,更新订单 $save_order['change_time'] = time(); $save_order['tk_z_status'] = 2; $res_update = $this->model->where(['id'=> $find_order['id']])->update($save_order); if(!$res_update){ Db::rollback(); return ['status'=>false,'info'=>'订单更新失败,订单trade_id:'.$order['trade_id']]; } } } Db::commit(); return ['status'=>true,'info'=>'订单逻辑处理完成']; } /** * 拆分订单 * * @return void */ public function chaifenOrder() { $list = $this->model->where(['is_distribution'=>0,'channel_code'=>['neq',''],'channel_code'=>['neq',0]])->whereOr("is_distribution = 1 And tk_z_status = 2 And channel_code !=''")->limit(20)->order('id desc')->select(); if(!empty($list)){ $LogicDyCommission = new LogicDyCommission(); foreach($list as $order){ $result = $LogicDyCommission->fanliCommissionNew($order); // $result = $LogicDyCommission->fanliCommission($order); if(!$result){ mylog('订单拆分错误',$result['info'],"errorInfo"); } } } return ['status'=>true,'info'=>'拆分逻辑执行完成']; } }