import { EErrorCode } from '../Config/_error_';
import * as _ from "underscore"
import { GExtUserSer } from './ExtUserService';
import { MongoBaseService } from 'cgserver';
import { MongoBaseModel } from 'cgserver';
import { ERoleGroup } from 'cgserver';

export class ProxyUserModel extends MongoBaseModel
{
    user_id:number=-1
    pre_user_id:number=-1
    coin:number=0
    create_time:number=-1
    level:number=-1
    user_num:number=0
    proxy_num:number=0
}
export let GProxyUserSer:ProxyUserService=null
class ProxyUserService extends MongoBaseService<ProxyUserModel>
{
    async getAllNext(user_id)
    {
        let list=await this.gets(null,{pre_user_id:user_id})
        return list
    }
    async isProxy(user_id:number)
    {
        let pum = await this.get({_id:1},{user_id:user_id})
        if(!pum)
        {
            return false
        }
        return true
    }
    async addProxy(from_user_id:number,user_id:number,level:number)
    {
        let rs = {prm:<ProxyUserModel>null,error:null}
        let prm = await this.get(null,{user_id:user_id})
        if(prm)
        {
            rs.error = EErrorCode.Was_Proxy
            //已经是了
            return rs
        }
        prm = await this.get(null,{user_id:from_user_id})
        if(!prm||prm.level<level)
        {
            rs.error = EErrorCode.Proxy_Level_Too_High
            //不能越级
            return rs
        }
        let dm = new ProxyUserModel()
        dm.user_id = user_id
        dm.pre_user_id = prm.user_id
        dm.coin = 0
        dm.create_time=new Date().getTime()
        dm.level = level
        GExtUserSer.updateOne({pre_user_id:from_user_id,role_group:ERoleGroup.Proxy},{id:user_id})
        this.updateOne({$inc:{proxy_num:1}},{user_id:from_user_id})
        let sr = await this.insert(dm)
        dm._id=sr.rs.insertedId
        rs.prm = dm
        return rs
    }
    async onBind(user_id,pre_user_id)
    {
        if(user_id==pre_user_id)
        {
            return EErrorCode.Proxy_Not_Bind_Self
        }
        let user = await GExtUserSer.getById(user_id)
        if(!user||user.pre_user_id)
        {
            return EErrorCode.Was_Binded
        }
        let prm = await this.get(pre_user_id)
        if(!prm)
        {
            return EErrorCode.Proxy_Code_Not_Exist
        }
        GExtUserSer.updateOne({pre_user_id:pre_user_id},{id:user_id})
        this.updateOne({$inc:{user_num:1}},{user_id:pre_user_id})
        return
    }
    async getMembers(user_id:number,begin:number,num:number)
    {
        begin=begin||0
        num=num||10
        let mbs = await GExtUserSer.gets({id:1,nickname:1,coin:1},{pre_user_id:user_id},null,begin,num)
        return mbs
    }
}
GProxyUserSer = new ProxyUserService("proxy_user",ProxyUserModel)