import * as _ from "underscore"
import { BaseHallController } from './BaseHallController';
import { UserValidate } from '../Decorator/UserValidate';
import { EErrorCode } from '../Config/_error_';
import { GOrderSer } from '../../../Common/Service/OrderService';
import { ETaskType, GTaskSer } from '../../../Common/Service/TaskService';
import { GExtUserSer } from '../../../Common/Service/ExtUserService';
import { GItemRecordService as GItemRecordSer } from '../../../Common/Service/ItemRecordService';
import { GGiveSer } from '../../../Common/Service/GiveService';
import { GOrderCfg } from '../Config/OrderConfig';
import { GAlipayTool, GAsyncQueueTool, GLog } from "cgserver";
import { AlipayCallBack, AlipayResult } from "cgserver/dist/types/ThirdParty/AlipayTool";

export class OrderController extends BaseHallController
{
    @UserValidate
    onGetConfig()
    {
        let config = GOrderCfg.getAll()
        this.showJson({config:config})
    }
    @UserValidate
    onGetProducts()
    {
        let config = GOrderCfg.getAll()
        this.showJson({products:config.products})
    }
    /*
        获取新订单
    */
    @UserValidate
    async onGetNewOrder()
    {
        let user_id = this.selfUser.id
        let from = this.postData.from
        let product_id=this.postData.product_id
        let product = GOrderCfg.getProduct(product_id)
        if(!product)
        {
            this.showJson({errcode:EErrorCode.Wrong_Param})
            return
        }
        let money = product.money
        let order = await GOrderSer.createNewOrder(user_id,from,product_id,money)
        this.showJson({order:order})
    }
    @UserValidate
    async onGetOrderInfo()
    {
        let user_id = this.selfUser.id
        let from = this.postData.from
        let product_id=this.postData.product_id
        let product = GOrderCfg.getProduct(product_id)
        if(!product)
        {
            this.showJson({errcode:EErrorCode.Wrong_Param})
            return
        }
        let money = product.money
        let order = await GOrderSer.createNewOrder(user_id,from,product_id,money)
        let order_info = GAlipayTool.getOrderInfo(order._id.toString(),order.money,product.title,"")
        this.showJson({order_info:order_info,order_id:order._id})
    }
    @UserValidate
    async onCancel()
    {
        let user_id = this.selfUser.id
        let order_id=this.postData.order_id
        let errcode = await GOrderSer.cancelOrder(order_id,user_id)
        this.showJson({errcode:errcode})
    }
    @UserValidate
    async onRecharge()
    {
        let user_id = this.selfUser.id
        let order_id = this.postData.order_id
        let transaction = this.postData.transaction
        let receipt = this.postData.receipt

        let rs = await GOrderSer.completeOrder(order_id,transaction,receipt)
        if(rs.errcode)
        {
            this.showJson({errcode:rs.errcode})
            return
        }
        //触发任务
        GTaskSer.onUserAction(user_id,ETaskType.Charge,rs.product.money)
        this.update_user(this.selfUser.id)
        this.showJson({crystal:this.selfUser.crystal,coin:this.selfUser.coin})
    }
    @UserValidate
    async onPayComplete()
    {
        let params = this.postData
        let ret = await GOrderSer.onComplete(params.order_id,params.money)
        this.showJson({crystal:ret.crystal,coin:ret.coin,vip_exp:ret.vip_exp,errcode:ret.errcode})
    }
    //客户端主动请求
    @UserValidate
    async onAlipayComplete()
    {
        let params = this.postData
        let alipay:AlipayResult=params.result
        if(!alipay||alipay.alipay_trade_app_pay_response?.msg!="Success")
        {
            this.showJson()
            return
        }
        let order_id = alipay.alipay_trade_app_pay_response.out_trade_no
        let rs=await GAsyncQueueTool.add("order",GOrderSer.completeOrder.bind(this),null,order_id)
        this.showJson(rs)
    }
    //alipay 回调
    @UserValidate
    async onAlipay()
    {
        let params = this.postData
        let alipay:AlipayCallBack=params
        if(!alipay||(alipay.trade_status!="TRADE_SUCCESS"&&alipay.trade_status!="TRADE_FINISHED"))
        {
            this.showJson()
            return
        }
        let order_id = alipay.out_trade_no
        let rs:any=await GAsyncQueueTool.add("order",GOrderSer.completeOrder.bind(this),null,order_id)
        if(!rs.errcode)
        {
            this.showJson('success')
            return
        }
        this.showJson('failure')
    }
    @UserValidate
    async onBuyCoin()
    {
        let coin_id = this.postData.coin_id
        let item = GOrderCfg.getCoin(coin_id)
        if(!item)
        {
            this.showJson({errcode:EErrorCode.Wrong_Param})
            return
        }
        if(this.selfUser.crystal<item.crystal)
        {
            this.showJson({errcode:EErrorCode.Not_Enough_Crystal})
            return
        }
        let ret = await GExtUserSer.updateOne({$inc:{coin:item.coin,crystal:-item.crystal}},{id:this.selfUser.id})
        if(ret.errcode)
        {
            this.showJson({errcode:ret.errcode})
            return
        }
        await this.update_user(this.selfUser.id)
        this.showJson({coin:this.selfUser.coin,crystal:this.selfUser.crystal,dtcoin:item.coin})
    }
    ////////
    @UserValidate/////////////////////////////////////////////////////////////////////道具关功能/////////////////
    async onBuyItem()
    {
        let user_id = this.selfUser.id
        let item_id = this.postData.item_id
        let count = this.postData.count
        if(!count)
        {
            this.showJson({errcode:EErrorCode.Wrong_Param})
            return
        }
        let item = GOrderCfg.getGoods(item_id)
        if(!item)
        {
            this.showJson({errcode:EErrorCode.Wrong_Param})
            return
        }
        if(this.selfUser.coin<item.coin_price*count
            ||this.selfUser.crystal<item.crystal_price*count)
        {
            this.showJson({errcode:EErrorCode.Not_Enough_Coin})
            return
        }
        let ret = await GExtUserSer.updateOne({"items":{$inc:{count:count}}},{id:user_id,"items.$.item_id":item_id})
        if(ret.errcode)
        {
            this.showJson({errcode:ret.errcode})
            return
        }
        GExtUserSer.updateOne({$inc:{coin:-item.coin_price*count,crystal:-item.crystal_price*count}},{id:this.selfUser.id})
        this.update_user(this.selfUser.id)
        this.showJson()
    }
    @UserValidate
    async onSaleItem()
    {
        let user_id = this.selfUser.id
        let item_id = this.postData.item_id
        let count = this.postData.count
        if(!count
            ||count<0)
        {
            this.showJson({errcode:EErrorCode.Wrong_Param})
            return
        }
        let item = GOrderCfg.getGoods(item_id)
        if(!item)
        {
            this.showJson({errcode:EErrorCode.Wrong_Param})
            return
        }

        let ret = await GExtUserSer.updateOne({"items":{$inc:{count:-count}}},{id:user_id,"items.$.item_id":item_id})
        if(ret.errcode)
        {
            this.showJson({errcode:ret.errcode})
            return
        }
        GExtUserSer.updateOne({$inc:{coin:item.coin_price*count,crystal:item.crystal_price*count}},{id:user_id})
        this.update_user(this.selfUser.id)
        this.showJson()
    }
    //赠送道
    @UserValidate
    async onGiveItem()
    {
        let user_id = this.selfUser.id
        let to_user_id = this.postData.to_user_id
        let item_id = this.postData.item_id
        let count = this.postData.count

        GExtUserSer.updateOne({"items":{$inc:{count:-count}}},{id:user_id,"items.$.item_id":item_id})
        GExtUserSer.updateOne({"items":{$inc:{count:count}}},{id:to_user_id,"items.$.item_id":item_id})
        this.showJson()
    }
    @UserValidate
    async onget_item_records()
    {
        let user_id = this.selfUser.id
        let records = await GItemRecordSer.gets(null,{user_id:user_id},{create_time:1},0,10)
        this.showJson({records:records})
    }
    @UserValidate
    async onGetBag()
    {
        let user_id = this.selfUser.id
        let bm = await GExtUserSer.get({items:1},{id:user_id})
        let items = bm?.items
        this.showJson({items:items})
    }
    ////////////////////////////////////////////////////////////////////////////赠送相关////////////////////////////////////
    /**
     * 收到来自客户端的赠送请求
     * @param this.postData 来自客户端的数据
     */
    @UserValidate
    async onGive()
    {
        let user_id = this.selfUser.id
        let target_user_id = this.postData.target_user_id
        let num = this.postData.num
        let rs = await GGiveSer.give(this.postData.club_id,user_id,target_user_id,num)
        this.showJson({grm:rs.grm,errcode:rs.errcode})
    }
    @UserValidate
    async onGetGiveHistory()
    {
        let p_give_list = GGiveSer.gets(null,{club_id:this.postData.club_id,src_user_id:this.selfUser.id},{create_time:1},0,this.postData.num)
        let p_get_list = GGiveSer.gets(null,{club_id:this.postData.club_id,dest_user_id:this.selfUser.id},{create_time:1},0,this.postData.num)
        let give_list = await p_give_list
        let get_list = await p_get_list
        this.showJson({give_list:give_list,get_list:get_list})
    }
}