seafood/app/Http/Controllers/Api/OrderControl...

<?php

/**
 * Created by PhpStorm.
 * User: Apiistrator
 * Date: 2018-02-22
 * Time: 10:32
 */

namespace App\Http\Controllers\Api;

use App\Http\Controllers\Controller;
use Illuminate\Http\Request;
use App\Log;
use App\Admin;
use App\Order;
use App\Oplog;
use App\RedisModel;
use App\Goods;
use App\GoodsSkus;
use App\OrderGoodsSkus;
use App\CustomerInfo;
use App\CustomerConsum;
use Illuminate\Support\Facades\DB;

class OrderController extends Controller {
    /**
     * 订单列表
     */
    public function orderList(Request $request){
        $admin_id = (int)$request->input('admin_id');
        $page = (int)$request->input('page');
        $pageSize = 20;
        if($page<=0){
            $page = 1;
        }
        $offset = ($page-1) * $pageSize; 

        $count = Order::where('is_del', 0)->where('warehouse', 3)->where(function($query) use($admin_id){
            if($admin_id>0) $query->where('admin_id', $admin_id);
        })->count();
        if ($count > 1) {
            // 总页数
            $pages = ceil($count/$pageSize);
        }else{
            // 总页数
            $pages = 1;
        }

        $result = Order::select('id', 'status', 'orderCode', 'customerName', 'receiverName', 'receiverMobile', 'receiverState','receiverCity','receiverAddress','receivedAmount','buyerMemo','sellerMemo','createTime','admin_id','admin_name','cost', 'logistics_id','is_refund','warehouse','delivery_date','refund_price','refund_type','send_note','freight_cost','payment_type','refuse_reason','refund_note','verify_time','aftersale_fee','aftersale_reason','aftersale_time','refund_time','send_time','should_amount')->where('is_del', 0)->where('warehouse', 3)->where(function($query) use($admin_id){
            if($admin_id>0) $query->where('admin_id', $admin_id);
        })->orderBy('id', 'desc')->offset($offset)->limit($pageSize)->get();
        $result = json_decode(json_encode($result),true);
        
        $status_arr = array(
            0 => '已录入',
            1 => '待审核',
            2 => '已审核',
            3 => '已发货',
            4 => '已退款'
        );

        foreach($result as $k=>&$v){           
            $goods = DB::table('order_goods_skus')->where('order_id', $v['id'])->where('is_del', 0)->get();
            if(!empty($goods)){
                foreach($goods as &$item){
                    $item->goods_name = Goods::where('id', $item->goods_id)->pluck('name');
                    $goods_sku_info = GoodsSkus::select('propsName', 'is_weigh')->where('id', $item->sku_id)->first();

                    if(!empty($goods_sku_info)){
                        $item->props_name = $goods_sku_info->propsName;
                        $item->is_weigh = $goods_sku_info->is_weigh;
                    }else{
                        $item->props_name = '';
                        $item->is_weigh = 0;
                    }
                    
                }
            }
            $v['skus'] = $goods;
            
            #加粉时间
            $fanTime = DB::table('customers')->select('fanTime')->where('phone', $v['receiverMobile'])->first();
            $v['fanTime'] = isset($fanTime->fanTime) ? $fanTime->fanTime : '';
            //$v['receiverMobile'] = substr($v['receiverMobile'], 0, 3).'****'.substr($v['receiverMobile'], 7);
            $v['status_name'] = $status_arr[$v['status']]; 

        }
        $pageInfo = [
            'page' => $page,
            'total' => $count,
            'pageSize' => $pageSize,
            'pages' => $pages,
        ];
        return self::returnValue(['data'=>$result, 'page_info'=>$pageInfo]);
    }

     /**
     * 分组管理-进行添加操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function orderstore(Request $request)
    {       
        $admin_id = (int)$request->input('admin_id'); 
        if(empty($admin_id)){
            return self::returnValue(['msg'=>'登录过期'], 2001); 
        }
        $phone = $request->input('receiverMobile'); 
        if(!preg_match('/^1\d{10}$/', $phone)){
            return self::returnValue(['msg'=>'手机号格式有误'], 2001); 
        }
        $customerName = $request->input('customerName');
        if(empty($customerName)){
            return self::returnValue(['msg'=>'买家姓名不能为空'], 2001); 
        } 
        $receiverName = $request->input('receiverName'); 
        if(empty($receiverName)){
            return self::returnValue(['msg'=>'收货人姓名不能为空'], 2001); 
        } 
        $receiverState = $request->input('receiverState'); 
        if(empty($receiverState)){
            return self::returnValue(['msg'=>'省份不能为空'], 2001); 
        } 
        $receiverCity = $request->input('receiverCity'); 
        if(empty($receiverCity)){
            return self::returnValue(['msg'=>'市不能为空'], 2001); 
        }
        $receiverAddress = $request->input('receiverAddress'); 
        if(empty($receiverAddress)){
            return self::returnValue(['msg'=>'详细地址不能为空'], 2001); 
        }
        $delivery_date = $request->input('delivery_date'); 
        if(empty($delivery_date)){
            return self::returnValue(['msg'=>'预发货时间不能为空'], 2001); 
        }
        $receivedAmount = $request->input('receivedAmount'); 
        if(empty($receivedAmount)){
            return self::returnValue(['msg'=>'实付金额不能为空'], 2001); 
        }
        $skus = $request->input('skus'); 
        if(empty($skus)){
            return self::returnValue(['msg'=>'必须添加商品'], 2001);
        }
        $payment_type = (int)$request->input('payment_type'); 
        if(empty($payment_type)){
            return self::returnValue(['msg'=>'必选支付方式'], 2001);
        }

        /*     
        $redisKey = 'seafood.order_phone_add.'.$phone;
        $res = RedisModel::setnx($redisKey, 1);
        if( $res == 0 ){
            $msg = '操作过于频繁，请一分钟后继续操作';
            return self::returnValue(['msg'=>$msg], 2001);
        }
        $res = RedisModel::expire( $redisKey, 60 );
        */
        //数据库-新增数据
        $order = array();
        $order['eshopCode'] = config('constants.ESHOP_CODE'); //默认
        $order['outerCode'] = Order::createOuterCode();//随机生成
        $order['status'] = (int)$request->input('status');                                   
        $order['customerName'] = trim($request->input('customerName')); //买家名称
        $order['shippingType'] = '卖家包邮';
        $order['expressCompanyCode'] = '10084';
        $order['expressCompanyName'] = '顺丰快递';
        $order['receiverName'] = trim($request->input('receiverName')); //收件人
        $order['receiverMobile'] = trim($request->input('receiverMobile')); //收件人手机
        $order['receiverPhone'] = trim($request->input('receiverMobile')); //收件人手机
        $order['receiverState'] = trim($request->input('receiverState')); //省份
        $order['receiverCity'] = trim($request->input('receiverCity')); //市
        #省市格式处理
        $order['receiverState'] = str_replace(['省', '市'], '', $order['receiverState']);
        $order['receiverCity'] = str_replace('市', '', $order['receiverCity']);

        $order['receiverDistrict'] = trim($request->input('receiverDistrict')); //区
        $order['receiverStreet'] = trim($request->input('receiverStreet')); //街道
        $order['receiverAddress'] = trim($request->input('receiverAddress')); //详细地址
        $order['buyerPostageFee'] = 0; //买家邮费
        $order['discountFee'] = 0; //订单优惠
        $order['adjustFee'] = 0; //订单调价
        $order['serviceFee'] = 0; //服务费
        $order['paymentMethod'] = '在线付款';
        $order['paymentType'] = '网银';
        $order['paymentAccount'] = '18322225555'; // 付款账号，暂时默认写死
        $order['paymentTime'] = date('Y-m-d H:i:s'); // 付款时间
        $order['receivedAmount'] = trim($request->input('receivedAmount')); //付款金额        
        $order['buyerMemo'] = trim($request->input('buyerMemo', '')); // 买家备注
        $order['sellerMemo'] = trim($request->input('sellerMemo', '')); // 卖家备注
        $order['createTime'] = date('Y-m-d H:i:s'); // 订单创建时间
        $order['modifyTime'] = date('Y-m-d H:i:s'); // 订单修改时间
        $order['should_amount'] = $request->input('should_amount');
        if(!$order['should_amount']) $order['should_amount'] = null;

        //商品信息
        $skus = $request->input('skus');
        $gnum = $request->input('gnum');
        $order_goods = array();
        if(!empty($skus)){
            foreach($skus as $k=>$sku_id){
                $sku_info = GoodsSkus::where('id', $sku_id)->first();
                $goods_info = Goods::where('id', $sku_info->goodsCode)->first();
                $params = array();
                $params['outerCode'] = $order['outerCode']+$k+1; //外部平台中子订单编码
                $params['outerParentCode'] = $order['outerCode']; //外部平台中订单编码
                $params['goodsCode'] = $sku_info->goodsCode;// strstr($goods->code,'-',true); 
                $params['skuCode'] = $sku_id; 
                #商品名称
                $params['goodsName'] = $goods_info->name;
                $params['propertiesName'] = $sku_info->propsName;
                $params['price'] = $sku_info->price;
                
                $params['quantity'] = $gnum[$k];
                $params['discountFee'] = 0;
                $params['adjustFee'] = 0;
                $params['refundStatus'] = '正常';
                $order_goods[] = $params;
            }
        }

        //本系统订单额外参数
        $order['warehouse'] = 3; //仓库
        $order['delivery_date'] = !empty($request->input('delivery_date')) ? $request->input('delivery_date') : date('Y-m-d'); //发货日期
        $order['payment_type'] = (int)$request->input('payment_type'); //支付方式
       
        //充值卡验证余额
        if($order['payment_type'] == 4){
            $deposit_phone = $order['receiverMobile'];//$request->input('deposit_phone'); //暂且只能使用自己充值卡
            $customerInfo = CustomerInfo::where('phone', $deposit_phone)->first();
            $balance = isset($customerInfo->balance) ? $customerInfo->balance : 0;
            if($balance < $order['receivedAmount']){
                $msg = '余额不足';
                return self::returnValue(['msg'=>$msg], 2003);
            }
        }

        $admin_id = (int)$request->input('admin_id');
        DB::beginTransaction();
        try{      

            #更新客户表
            $customer = array();
            $customers['name'] = $order['receiverName'];
            $customers['receiverState'] = $order['receiverState'];
            $customers['receiverCity'] = $order['receiverCity'];
            $customers['receiverDistrict'] = $order['receiverDistrict'];
            $customers['receiverStreet'] = $order['receiverStreet'];
            $customers['receiverAddress'] = $order['receiverAddress'];

            $if_e = DB::table('customers')->select('id', 'fanTime')->where('phone', $order['receiverMobile'])->first();
            if(isset($if_e->id)){               
                $customers['is_fugou'] = 1;
                $order['is_fugou'] = 1;
                $up_c = DB::table('customers')->where('id', $if_e->id)->update($customers);
            }else{
                $customers['phone'] = $order['receiverMobile'];                
                $customers['is_fugou'] = 0;
                $customers['fanTime'] = $request->input('fanTime');
                $customers['admin_id'] = $admin_id;
                $in_c = DB::table('customers')->insert($customers);
            }
               
            $admin_info = DB::table('admin')->select('realname', 'team_id')->where('id', $admin_id)->first();
            $order['admin_id'] = $admin_id;
            $order['admin_name'] = $admin_info->realname;
            $order['team_id'] = $admin_info->team_id;
            
            //新加is_able 9.4之前粉丝不参与销售复购统计
            $fanTime = $request->input('fanTime');
            if(!$fanTime && isset($if_e->id)) $fanTime = $if_e->fanTime;
            if($fanTime < '2019-09-04'){
                $order['is_able'] = 0;
            }
            $res = DB::table('order')->insertGetId($order);
            if($res){
                if(!empty($skus)){
                    //订单商品插入
                    $order_skus = array();
                    foreach($order_goods as $k=>$sku){
                        $order_skus[$k]['sku_id'] = $sku['skuCode'];
                        $order_skus[$k]['order_id'] = $res;
                        $order_skus[$k]['goods_id'] = $sku['goodsCode'];
                        $order_skus[$k]['num'] = $sku['quantity'];
                        $order_skus[$k]['price'] = $sku['price'];
                    }
                    $order_skus_insert = DB::table('order_goods_skus')->insert($order_skus);
                }

                #新加逻辑，若付款方式为充值卡/消费记录
                if($order['payment_type'] == 4){
                    $consum = new CustomerConsum();
                    $consum->phone = $deposit_phone;
                    $consum->order_id = $res;
                    $consum->money = $order['receivedAmount'];
                    $consum->save();
                    //更新余额                   
                    $customerInfo->balance = $customerInfo->balance - $order['receivedAmount'];
                    $customerInfo->save();
                }
                #记录操作日志
                $self_id = $admin_id;
                $self_name = $admin_info->realname;
                if($order['status'] == 0){
                    $status_text = '仅录入';
                }else{
                    $status_text = '录入并提审';
                }
                $context = "录入订单：".$status_text;
                $type = 0; //订单录入
                $tables = 'order';
                $data_id = $res;
                Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);
            }
            
            DB::commit();
        }catch (Exception $e){
            DB::rollback();
        }   

        return self::returnValue(['msg'=>'添加成功']);
        
    }

    /**
     * 根据手机号获取默认地址信息
     *
     */
    public function getAddress(Request $request){
        $phone = $request->input('phone');
        if(!preg_match('/^1\d{10}$/', $phone)){
            return self::returnValue([],2001);
        }

        $result = DB::table('customers')->select('receiverState', 'receiverCity', 'receiverAddress', 'fanTime')->where('phone', $phone)->first();
        $result = json_decode(json_encode($result), true);
        return self::returnValue(['data'=>$result]);
    }

    //获余额
    public function getBalance(Request $request){
        $phone = $request->input('phone');
        if(!preg_match('/^1\d{10}$/', $phone)){
            return self::returnValue([],2001);
        }
        $result = CustomerInfo::where('phone', $phone)->pluck('balance');
        if(empty($result)) $result = 0;
        return self::returnValue(['balance'=>$result]);
    }

     /**
     * 分组管理-进行编辑操作
     * @param Request $request
     * @return \Illuminate\Http\RedirectResponse
     */
    public function orderupdate(Request $request)
    {   
        $admin_id = (int)$request->input('admin_id'); 
        if(empty($admin_id)){
            return self::returnValue(['msg'=>'登录过期'], 2001); 
        }
        $id = (int)$request->input('id'); 
        if(empty($id)){
            return self::returnValue(['msg'=>'订单id有误'], 2001); 
        }
        $phone = $request->input('receiverMobile'); 
        if(!preg_match('/^1\d{10}$/', $phone)){
            return self::returnValue(['msg'=>'手机号格式有误'], 2001); 
        }
        $customerName = $request->input('customerName');
        if(empty($customerName)){
            return self::returnValue(['msg'=>'买家姓名不能为空'], 2001); 
        } 
        $receiverName = $request->input('receiverName'); 
        if(empty($receiverName)){
            return self::returnValue(['msg'=>'收货人姓名不能为空'], 2001); 
        } 
        $receiverState = $request->input('receiverState'); 
        if(empty($receiverState)){
            return self::returnValue(['msg'=>'省份不能为空'], 2001); 
        } 
        $receiverCity = $request->input('receiverCity'); 
        if(empty($receiverCity)){
            return self::returnValue(['msg'=>'市不能为空'], 2001); 
        }
        $receiverAddress = $request->input('receiverAddress'); 
        if(empty($receiverAddress)){
            return self::returnValue(['msg'=>'详细地址不能为空'], 2001); 
        }
        $delivery_date = $request->input('delivery_date'); 
        if(empty($delivery_date)){
            return self::returnValue(['msg'=>'预发货时间不能为空'], 2001); 
        }
        $receivedAmount = $request->input('receivedAmount'); 
        if(empty($receivedAmount)){
            return self::returnValue(['msg'=>'实付金额不能为空'], 2001); 
        }
        $skus = $request->input('skus'); 
        if(empty($skus)){
            return self::returnValue(['msg'=>'必须添加商品'], 2001);
        }
        $payment_type = (int)$request->input('payment_type'); 
        if(empty($payment_type)){
            return self::returnValue(['msg'=>'必选支付方式'], 2001);
        }
      
        //更新数据
        $order = array();
        $order['customerName'] = trim($request->input('customerName')); //买家名称
        $order['receiverName'] = trim($request->input('receiverName')); //收件人
        if(preg_match('/^1\d{10}$/', $phone)) $order['receiverMobile'] = $phone; //收件人手机
        $order['receiverState'] = trim($request->input('receiverState')); //省份
        $order['receiverCity'] = trim($request->input('receiverCity')); //市
        
        $order['receiverState'] = str_replace(['省', '市'], '', $order['receiverState']);
        $order['receiverCity'] = str_replace('市', '', $order['receiverCity']);

        $order['receiverAddress'] = trim($request->input('receiverAddress')); //详细地址
        $order['receivedAmount'] = trim($request->input('receivedAmount')); //付款金额        
        $order['buyerMemo'] = trim($request->input('buyerMemo', '')); // 买家备注
        $order['sellerMemo'] = trim($request->input('sellerMemo', '')); // 卖家备注
        $order['delivery_date'] = !empty($request->input('delivery_date')) ? $request->input('delivery_date') : date('Y-m-d'); //发货日期
        $order['payment_type'] = (int)$request->input('payment_type'); //支付方式

        $order['status'] = (int)$request->input('status');
        $order['should_amount'] = $request->input('should_amount');
        if(!$order['should_amount']) $order['should_amount'] = null;
        
        $id = (int)$request->input('id');
        //获取订单原信息
        $old_order = DB::table('order')->where('id', $id)->first();
        // ++++++充值卡验证余额逻辑 +++++++ //
        if($order['payment_type'] == 4){
            $deposit_phone = $phone;//$request->input('deposit_phone');
            if($old_order->payment_type != 4){                            
                $customerInfo = CustomerInfo::where('phone', $deposit_phone)->first();
                $balance = isset($customerInfo->balance) ? $customerInfo->balance : 0 ;
                if($balance < $order['receivedAmount']){
                    //余额不足
                    return self::returnValue(['msg'=>'充值卡余额不足'], 2001); 
                }               
            }elseif($old_order->receivedAmount != $order['receivedAmount']){              
                $customerInfo = CustomerInfo::where('phone', $deposit_phone)->first();
                $balance = $customerInfo->balance;
                if( $balance < $order['receivedAmount']-$old_order->receivedAmount ){
                    //余额不足
                    return self::returnValue(['msg'=>'充值卡余额不足'], 2001);             
                }
            }
        }

        $today_date = date('Y-m-d');
        DB::beginTransaction();
        try{
            $res = DB::table('order')->where('id', $id)->update($order); 
            //商品信息
            $skus = $request->input('skus');
            $gnum = $request->input('gnum');
            if(empty($skus)) $skus = [];
            //先删除
            $del_re = DB::table('order_goods_skus')->where('order_id', $id)->whereNotIn('sku_id', $skus)->update(['is_del'=>1]);
            if(!empty($skus)){            
                //再同步
                foreach($skus as $k=>$sku_id){
                    $sku_info = GoodsSkus::select('goodsCode', 'price', 'propsName','is_weigh')->where('id', $sku_id)->first();
                    $sync_re = OrderGoodsSkus::updateOrCreate(['order_id'=>$id, 'sku_id'=>$sku_id, 'goods_id'=>$sku_info->goodsCode], ['num'=>$gnum[$k], 'is_del'=>0, 'price'=>$sku_info->price]);
                }

            }
  
            if($res){        
                #新加逻辑，若付款方式为充值卡/消费记录
                if($order['payment_type'] == 4 ){
                    if($old_order->payment_type != 4 ){
                        $consum = new CustomerConsum();
                        $consum->phone = $deposit_phone;
                        $consum->order_id = $id;
                        $consum->money = $order['receivedAmount'];
                        $consum->save();
                        //更新余额                   
                        $customerInfo->balance = $customerInfo->balance - $order['receivedAmount'];
                        $customerInfo->save();
                    }elseif($old_order->receivedAmount != $order['receivedAmount']){
                        $consum = CustomerConsum::where('order_id', $id)->first();                       
                        $consum->money = $order['receivedAmount'];
                        $consum->save();
                        //更新余额
                        $add_amount = $order['receivedAmount'] - $old_order->receivedAmount; //新增消费额，有可能为负数
                        $customerInfo->balance = $customerInfo->balance - $add_amount;
                        $customerInfo->save();
                    }
                }

                #记录操作日志
                $self_id = (int)$request->input('admin_id');
                $self_name = Admin::where('id', $self_id)->pluck('realname');            
                $context = "修改订单";
                $type = 0; 
                $tables = 'order';
                $data_id = $id;
                Oplog::addLog($self_id, $self_name, $context, $type, $tables, $data_id);

            }  

            DB::commit();
        }catch (Exception $e){
            DB::rollback();
            Log::errorLog($request,['error'=>$e->getMessage()],"order/update",0,'');
            return self::returnValue(['msg'=>$e->getMessage()], 2001); 
        }     

        return self::returnValue(['msg' => '更新成功']);         
    }
}