<?php

namespace App\Http\Controllers;

use App\GoodInfo;
use App\Message;
use App\Transaction;
use App\TransactionLog;
use App\User;
use App\MessageContact;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Redirect;
use App\Ticket;
use App\UserInfo;
use Illuminate\Support\Facades\View;

class TransactionController extends Controller
{
    // 0 取消的订单
    // 1 买家已购买
    // 2 卖家已确认交易
    // 3 交易失败
    // 4 交易成功待评价
    // 5 交易成功已评价

    public function add(Request $request, $good_id)
    {
        $user_id = $request->session()->get('user_id');
        $user = User::find($user_id);
        if(!$user || $user->baned)
            return Redirect::back()->withInput()->withErrors('您的账号被封禁，请联系系统管理员');
        if(UserInfo::where('user_id', $user_id)->count() == 0)
            return Redirect::back()->withInput()->withErrors('你必须添加联系方式才能购买');
        $count = $request->count;
        $result = $this->buy($good_id, $user_id, $count, $request->ip());
        $result = json_decode($result, true);
        if($result['result'])
            return Redirect::to('/user/trans');
        else
            return Redirect::back()->withInput()->withErrors($result['msg']);
    }

    public function go(Request $request, $trans_id)
    {
        $user_id = $request->session()->get('user_id');
        $trans = Transaction::find($trans_id);
        switch ($trans->status) {
            case 1:
                $result = $this->sell($trans, $user_id, $request->ip());
                break;
            case 2:
                $result = $this->finish($trans, $user_id, $request->result, $request->ip());
                break;
            default:
                $result = json_encode(['result' => false, 'msg' => 'invalid']);
        }
        $result = json_decode($result, true);
        if($result['result'])
            return Redirect::to('/user/sell/trans');
        else
            return Redirect::back()->withInput()->withErrors($result['msg']);

    }

    public function cancel(Request $request, $trans_id)
    {
        $user_id = $request->session()->get('user_id');
        $trans = Transaction::find($trans_id);
        $result = $this->cancelBuy($trans, $user_id, $request->ip(), $request->reason);
        $result = json_decode($result, true);
        if($result['result']) {
            if($result['character'] == "seller")
                return Redirect::to('/user/sell/trans');
            else
                return Redirect::to('/user/trans');
        }
        else
            return Redirect::back()->withInput()->withErrors($result['msg']);
    }

    public function edit(Request $request, $trans_id)
    {
        $user_id = $request->session()->get('user_id');
        $trans = Transaction::find($trans_id);
        $result = $this->update($trans, $user_id, $request->number, $request->ip());
        $result = json_decode($result);
        if($result['result']) {
            return Redirect::to('/user/sell/trans');
        }
        else
            return Redirect::back()->withInput()->withErrors($result['msg']);
    }

    private function buy($good_id, $buyer_id, $count, $request_ip)
    {
        if (GoodInfo::where('id', $good_id)->where('baned', false)->count() == 0)
            return json_encode(['result' => false, 'msg' => '没有此商品']);
        $good = GoodInfo::find($good_id);
        $buyer = User::find($buyer_id);
        if ($count > $good->count)
            return json_encode(['result' => false, 'msg' => '商品缺货']);

        $trans = new Transaction();
        $trans->good_id = $good_id;
        $trans->buyer_id = $buyer_id;
        $trans->number = $count;
        $trans->status = 1;
        $trans->save();

        $translog = new TransactionLog();
        $translog->ip = $request_ip;
        $translog->user_id = $buyer_id;
        $translog->trans_id = $trans->id;
        $translog->event = "buy";
        $translog->save();

        $message = new Message();
        $message->sender_id = 0;
        $message->receiver_id = $good->user_id;
        $message->content = '您好！<a href="/user/' . $buyer_id . '">' . $buyer->not_null_nickname . '</a>购买了你的<a href="/good/' . $good_id . '">' . $good->good_name . '</a>，请及时前往<a href="/user/sell/trans">交易订单页</a>确认。';
        $message->save();

        //Create or Update MessageContact
        $contact = MessageContact::firstOrNew([
            'user_id' => $message->receiver_id,
            'contact_id' => 0
        ]);
        $contact->unread_count += 1;
        $contact->last_contact_time = time();
        $contact->save();
        return json_encode(['result' => true, 'msg' => 'success']);
    }

    private function cancelBuy($trans, $user_id, $request_ip, $reason)
    {
        switch ($user_id) {
            case $trans->buyer_id:
                $trans->status = 0;
                $trans->reason = $reason;
                $trans->save();

                $translog = new TransactionLog();
                $translog->ip = $request_ip;
                $translog->user_id = $user_id;
                $translog->trans_id = $trans->id;
                $translog->event = "buyerCancelTrans";
                $translog->save();

                $message = new Message();
                $message->sender_id = 0;
                $good = $trans->good;
                $message->receiver_id = $good->user_id;
                $message->content = '您好！您的<a href="/good/' . $good->id . '">' . $good->good_name . '</a>的一个订单被买家取消，你可以前往<a href="/user/sell/trans">交易订单页</a>查看。';
                $message->save();
                //Create or Update MessageContact
                $contact = MessageContact::firstOrNew([
                    'user_id' => $message->receiver_id,
                    'contact_id' => 0
                ]);
                $contact->unread_count += 1;
                $contact->last_contact_time = time();
                $contact->save();
                return json_encode(['result' => true, 'character' => 'buyer', 'msg' => 'success']);
                break;
            case $trans->seller_id:
                $trans->status = 0;
                $trans->reason = $reason;
                $trans->save();

                $translog = new TransactionLog();
                $translog->ip = $request_ip;
                $translog->user_id = $user_id;
                $translog->trans_id = $trans->id;
                $translog->event = "sellerCancelTrans";
                $translog->save();

                $message = new Message();
                $message->sender_id = 0;
                $good = $trans->good;
                $message->receiver_id = $trans->buyer_id;
                $message->content = '您好！您购买的<a href="/good/' . $good->id . '">' . $good->good_name . '</a>的一个订单被卖家驳回，你可以前往<a href="/user/trans">交易订单页</a>查看。';
                $message->save();
                //Create or Update MessageContact
                $contact = MessageContact::firstOrNew([
                    'user_id' => $message->receiver_id,
                    'contact_id' => 0
                ]);
                $contact->unread_count += 1;
                $contact->last_contact_time = time();
                $contact->save();
                return json_encode(['result' => true, 'character' => 'seller', 'msg' => 'success']);
                break;
            default:
                return json_encode(['result' => false, 'msg' => '未授权的访问']);
        }
    }

    private function sell($trans, $user_id, $request_ip)
    {
        if ($trans->seller_id != $user_id)
            return json_encode(['result' => false, 'msg' => '未授权的访问']);
        if($trans->status != 1)
            return json_encode(['result' => false, 'msg' => '无效的请求']);
        $good = $trans->good;
        if ($trans->number > $good->count)
            return json_encode(['result' => false, 'msg' => '商品缺货']);
        $good->count = $good->count - $trans->number;
        $good->save();
        $trans->status = 2;
        $trans->save();

        $translog = new TransactionLog();
        $translog->ip = $request_ip;
        $translog->user_id = $user_id;
        $translog->trans_id = $trans->id;
        $translog->event = "sell";
        $translog->save();

        $message = new Message();
        $message->sender_id = 0;
        $message->receiver_id = $trans->buyer_id;
        $message->content = '您好！你订购的<a href="/good/' . $good->id . '">' . $good->good_name . '</a>已被卖家确认，你们现在可以去<a href="/trans/' . $trans->id . '">查看对方的联系方式</a>并且交♂易啦。';
        $message->save();
        //Create or Update MessageContact
        $contact = MessageContact::firstOrNew([
            'user_id' => $message->receiver_id,
            'contact_id' => 0
        ]);
        $contact->unread_count += 1;
        $contact->last_contact_time = time();
        $contact->save();
        return json_encode(['result' => true, 'msg' => 'success']);
    }

    private function update($trans, $user_id, $number, $request_ip)
    {
        if ($trans->seller_id != $user_id)
            return json_encode(['result' => false, 'msg' => '未授权的访问']);
        if($trans->status != 2)
            return json_encode(['result' => false, 'msg' => '无效的请求']);
        $trans->number = $number;
        $trans->save();

        $translog = new TransactionLog();
        $translog->ip = $request_ip;
        $translog->user_id = $user_id;
        $translog->trans_id = $trans->id;
        $translog->event = "sellerUpdateNum";
        $translog->save();

        return json_encode(['result' => true, 'msg' => 'success']);
    }

    private function finish($trans, $user_id, $result, $request_ip)
    {
        if ($trans->seller_id != $user_id)
            return json_encode(['result' => false, 'msg' => '未授权的访问']);
        if($trans->status != 2)
            return json_encode(['result' => false, 'msg' => '无效的请求']);
        if(!$result) {
            $trans->good->count = $trans->good->count + $trans->number;
            $trans->good->save();
        }
        if($result)
            $trans->status = 4;
        else
            $trans->status = 3;
        $trans->save();

        $translog = new TransactionLog();
        $translog->ip = $request_ip;
        $translog->user_id = $user_id;
        $translog->trans_id = $trans->id;
        if($result)
            $translog->event = "finishTrue";
        else
            $translog->event = "finishFalse";
        $translog->save();

        $message = new Message();
        $message->sender_id = 0;
        $message->receiver_id = $trans->buyer_id;
        $good = $trans->good;
        if($result)
            $message->content = '您好！你订购的<a href="/good/' . $good->id . '">' . $good->good_name . '</a>的订单已被卖家标记为交易成功，你现在可以去<a href="/user/trans">评价此单交易</a>啦。';
        else
            $message->content = '您好！你订购的<a href="/good/' . $good->id . '">' . $good->good_name . '</a>的订单已被卖家标记为交易失败。';
        $message->save();
        //Create or Update MessageContact
        $contact = MessageContact::firstOrNew([
            'user_id' => $message->receiver_id,
            'contact_id' => 0
        ]);
        $contact->unread_count += 1;
        $contact->last_contact_time = time();
        $contact->save();
        return json_encode(['result' => true, 'msg' => 'success']);
    }

    public function showTrans(Request $request, $trans_id)
    {
        $user_id = $request->session()->get('user_id');
        $trans = Transaction::find($trans_id);
        if(!$trans || $trans->status < 2)
            return View::make('common.errorPage')->withErrors('交易ID错误！');
        $seller = User::with('user_infos')->find($trans->seller_id);
        $buyer = User::with('user_infos')->find($trans->buyer_id);
        if($user_id != $trans->buyer_id
            && (GoodInfo::where('id', $trans->good_id)->count() == 0 || $user_id != $trans->seller_id))
            return View::make('common.errorPage')->withErrors('交易ID错误！');
        $data['tran'] = $trans;
        $data['seller'] = $seller;
        $data['buyer'] = $buyer;
        return view('transaction')->with($data);
    }

	public function comment(Request $request, $trans_id)
	{
		$data = [];
		$data['trans_id'] = $trans_id;
		return view('comment')->with($data);
	}

	public function sendComment(Request $request, $trans_id)
	{
		$input = $request->all();
		$ticket = new Ticket;
		$ticket->sender_id = $request->session()->get('user_id');
		$ticket->trans_id = $trans_id;
		$trans = Transaction::find($trans_id);
		$ticket->receiver_id = $trans->seller->id;
		$ticket->type = 1;
		$ticket->message = $input['comment'];
		$ticket->save();
		$trans->status = 5; 
		$trans->save();
		return Redirect::to('/user/trans');
	}
}