/*
文件名:FatalismStone.nut
路径:Dps_A/ProjectClass/FatalismStone/FatalismStone.nut
创建日期:2025-06-22	12:54
文件用途:
*/


class FatalismStone_Stone {
    //编号
    Id = null;
    //唯一ID
    Uuid = null;
    //类型
    StoneType = null;
    //洗练度
    CultivationDegree = null;


    constructor() {

    }


    //反序列化构造
    function Deserialize(StoneId, StoneUuid) {
        this.Id = StoneId;
        this.Uuid = StoneUuid;
        this.StoneType = ProjectInitFuncMap.P_FatalismStone.GetStoneData(this.Id)["stone type"];
    }

    function Blob2Hex(buf) {
        local str = "";
        for (local i = 0; i< buf.len(); i++) {
            str += format("%02X", buf[i]);
        }
        return str;
    }

    function Serialize() {
        local B = blob(0);
        B.writen(Id, 'i'); //写入ID
        B.writen(Uuid, 'i'); //写入Uuid
        return Blob2Hex(B);
    }
}

//魂石背包类
class FatalismStone_BackPack {

    //背包总格子数
    GridCount = 77;
    //穿戴总格子数
    WearCount = 6;
    StoneArr = null;

    constructor() {
        StoneArr = [];
    }

    //通过数据构造背包  反序列化
    function Deserialize(N_Data) {
        local BackpackData = N_Data[0][0];
        local WearData = N_Data[0][1];

        //转换背包数据
        local BackPackArr = [];
        for (local i = 0; i<(GridCount * 3); i++) {
            local StoneId = BackpackData.add(i * 8).readInt();
            local StoneUuid = BackpackData.add(i * 8 + 4).readInt();
            if (StoneId != 0 && StoneUuid != 0) {
                local StoneObj = FatalismStone_Stone();
                StoneObj.Deserialize(StoneId, StoneUuid)
                BackPackArr.push(StoneObj);
            } else {
                BackPackArr.push(null);
            }
        }
        //转化穿戴数据
        local WearArr = [];
        for (local i = 0; i< WearCount; i++) {
            local StoneId = WearData.add(i * 8).readInt();
            local StoneUuid = WearData.add(i * 8 + 4).readInt();
            if (StoneId != 0 && StoneUuid != 0) {
                local StoneObj = FatalismStone_Stone();
                StoneObj.Deserialize(StoneId, StoneUuid)
                WearArr.push(StoneObj);
            } else {
                WearArr.push(null);
            }
        }

        //两段数据放入总数据
        StoneArr.extend(BackPackArr);
        StoneArr.extend(WearArr);
    }

    //序列化
    function Serialize() {
        //背包数据
        local BackpackArr = StoneArr.slice(0, GridCount * 3);
        local BackpackHex = "0x";
        foreach(Pos, StoneObject in BackpackArr) {
            if (StoneObject) BackpackHex += StoneObject.Serialize();
            else BackpackHex += "0000000000000000";
        }
        //穿戴数据
        local WearArr = StoneArr.slice(GridCount * 3, GridCount * 3 + WearCount);
        local WearHex = "0x";
        foreach(Pos, StoneObject in WearArr) {
            if (StoneObject) WearHex += StoneObject.Serialize();
            else WearHex += "0000000000000000";
        }
        //返回
        return {
            inventory = BackpackHex,
            wear = WearHex
        };
    }

    //获取魂石的列表 3为身上穿戴的
    function GetList(Page) {
        local SliceLength = GridCount;
        if (Page == 3) SliceLength = WearCount;
        return StoneArr.slice(Page * 77, Page * 77 + SliceLength);
    }
}

class FatalismStone {

    //总格子数
    GridCount = 77;
    //总穿戴数
    WearCount = 6;

    //属性数据位数
    AttrCount = 2;

    //魂石Lst
    FatalismStoneLst = null;
    //魂石配置
    FatalismStoneConfig = null;

    constructor() {
        Script();
        local PoolObj = MysqlPool.GetInstance();
        PoolObj.SetBaseConfiguration("127.0.0.1", 3306, "game", "uu5!^%jg");
        //连接池大小
        PoolObj.PoolSize = 10;
        //初始化
        PoolObj.Init();

        //读取pvf的魂石相关数据
        InitFatalismStoneData();

        //创建新架构表
        SelectSql("CREATE TABLE `zyk`.`f_user_info`  (  `cid` int(250) NOT NULL,  `inventory` varbinary(1848) NULL,  `wear` varbinary(48) NULL,  PRIMARY KEY (`cid`));", []);
        SelectSql("CREATE TABLE `zyk`.`f_stone_map`  (  `uuid` int(250) NOT NULL AUTO_INCREMENT,  `cultivation` float NULL DEFAULT NULL,  PRIMARY KEY (`uuid`)  USING BTREE);", []);
        // UpdateNewMysqlData();



        //注册客户端收包
        RegisterClient();
        //注册调试命令
        RegisterDebugCmd();
    }


    //查询单个魂石的属性
    function GetStoneAttr(Uuid) {
        local Ret = SelectSql("select cultivation from zyk.f_stone_map where uuid = " + Uuid, ["float"]);
        if (Ret.len() == 0) {
            return null;
        } else {
            return Ret[0];
        }
    }

    //查询多个魂石的属性
    function GetStoneAttrArr(UuidArr) {
        local SqlStr = "select uuid,cultivation from zyk.f_stone_map where uuid in (";
        for (local i = 0; i< UuidArr.len(); i++) {
            SqlStr += UuidArr[i];
            if (i != UuidArr.len() - 1) {
                SqlStr += ",";
            }
        }
        SqlStr += ")";
        local Ret = SelectSql(SqlStr, ["int", "float"]);
        if (Ret.len() == 0) {
            return null;
        } else {
            return Ret;
        }
    }


    function RegisterClient() {

        //查询魂石背包数据
        ClientSocketPackFuncMap.rawset(21000001, function(SUser, Jso) {
            local Ret = GetInvenData(SUser);
            //没查到东西说明没有背包 第一次创建背包
            if (!Ret || Ret.len() == 0) {
                local SqlStr = format("INSERT INTO zyk.f_user_info (cid, inventory, wear) VALUES (%d,REPEAT(0x00, 1848),REPEAT(0x00, 48))", SUser.GetCID());
                SelectSql(SqlStr, []);
            }
            //有数据的读取
            else {
                local BackPackData = Ret[0][0];
                local WearData = Ret[0][1];
                local PackSize = 4 + 4 + BackPackData.Size + 4 + WearData.Size;
                local Pack = Packet();
                Pack.Put_Header(1, 131);
                Pack.Put_Byte(1);
                Pack.Put_Int(PackSize);
                Pack.Put_Int(21000002);
                Pack.Put_Int(BackPackData.Size);
                Pack.Put_BinaryEx(BackPackData.C_Object, BackPackData.Size);
                Pack.Put_Int(WearData.Size);
                Pack.Put_BinaryEx(WearData.C_Object, WearData.Size);
                Pack.Finalize(true);
                SUser.Send(Pack);
                Pack.Delete();

                //查询身上穿戴的魂石属性
                local BackPack = FatalismStone_BackPack();
                BackPack.Deserialize(Ret);
                local WearArr = BackPack.GetList(3);
                local UuidArr = [];
                for (local i = 0; i< WearArr.len(); i++) {
                    if (WearArr[i] != null) {
                        UuidArr.push(WearArr[i].Uuid);
                    }
                }
                if (UuidArr.len() > 0) {
                    local Attr = GetStoneAttrArr(UuidArr);
                    if (Attr) {
                        local PackSize = 4 + 4 + (Attr.len() * 4 * Attr[0].len());
                        local Pack = Packet();
                        Pack.Put_Header(1, 131);
                        Pack.Put_Byte(1);
                        Pack.Put_Int(PackSize);
                        Pack.Put_Int(21000014);
                        Pack.Put_Int(Attr.len());
                        for (local i = 0; i< Attr.len(); i++) {
                            for (local z = 0; z< Attr[i].len(); z++) {
                                Pack.Put_Int(Attr[i][z]);
                            }
                        }
                        Pack.Finalize(true);
                        SUser.Send(Pack);
                        Pack.Delete();
                    }
                }
            }
        }.bindenv(this));

        //查询魂石唯一属性
        ClientSocketPackFuncMap.rawset(21000011, function(SUser, Jso) {
            local Uuid = Jso.uuid;
            SendFatalismStoneData(SUser, Uuid);
        }.bindenv(this));

        //交换魂石位置
        ClientSocketPackFuncMap.rawset(21000003, function(SUser, Jso) {
            local OldType = Jso.oldtype;
            local OldIndex = Jso.oldpos;

            local NewType = Jso.newtype;
            local NewIndex = Jso.newpos;

            local BackPack = GetInven(SUser);
            if (!BackPack) return;

            //直接去交换位置
            local Buffer = BackPack.StoneArr[OldType * 77 + OldIndex];
            BackPack.StoneArr[OldType * 77 + OldIndex] = BackPack.StoneArr[NewType * 77 + NewIndex];
            BackPack.StoneArr[NewType * 77 + NewIndex] = Buffer;

            SaveInven(BackPack, SUser);
        }.bindenv(this));

        //魂石洗练
        ClientSocketPackFuncMap.rawset(21000005, function(SUser, Jso) {
            local Uuid = Jso.uuid;
            local rarity = Jso.rarity;
            //获取背包对象
            local InvenObj = SUser.GetInven();
            local Flag = InvenObj.DeleteItemCount(FatalismStoneConfig["wash_item"], FatalismStoneConfig["wash_cost"][rarity]);
            //扣除不成功
            if (!Flag) {
                SUser.SendNotiPacketMessage("精炼魂石所需的材料不足!", 8);
                return;
            }

            local Rand = MathClass.Rand(1, 105);
            if (Rand > 100) Rand = 100;

            //将新的精炼值写入数据库
            local Sql = "update zyk.f_stone_map set cultivation = " + Rand + " where uuid = " + Uuid;
            SelectSql(Sql, []);
            SendFatalismStoneData(SUser, Uuid)
        }.bindenv(this));

        Cb_User_Insert_Item_Leave_Func["宿命魂石"] <- function(args) {
            local SUser = User(NativePointer(args[0]).readPointer());
            local InvenObj = SUser.GetInven();
            local idx = args.pop();
            if (idx > 0) {
                local inven_item = InvenObj.GetSlot(1, idx);
                local item_id = inven_item.GetIndex();
                if (item_id >= 200625000 && item_id< 200626000) {
                    local Ret = AddFatalismStone(SUser, item_id - 200625000);
                    //删除原道具
                    Timer.SetTimeOut(function() {
                        inven_item.Delete();
                        SUser.SendUpdateItemList(1, 0, idx);
                    }, 1000);
                    //如果满了就发邮件
                    if (!Ret) {
                        local T = {};
                        T.rawset(item_id, 1);
                        SUser.SendMail(T, {
                            Title = "系统",
                            Text = "由于你的魂石包裹已满, 请留出足够的空间来接收道具."
                        });
                    }
                    SUser.SendItemSpace(0);
                }
            }
        }.bindenv(this);
    }


    function RegisterDebugCmd() {
        Gm_InputFunc_Handle["给魂石"] <- function(SUser, CmdString) {
            local count = -1;
            local pos = 0;
            local handler = [];
            do {
                local start = pos;
                pos = CmdString.find(" ", pos + 1);
                if (pos != null) {
                    handler.append(CmdString.slice(start + 1, pos));
                } else
                    handler.append(CmdString.slice(start + 1));
                count = count + 1
            } while (pos != null)

            //得到空格数量
            if (count == 1) {
                AddFatalismStone(SUser, handler[1].tointeger());
            }
        }.bindenv(this);
    }

    //获取玩家背包数据
    function GetInvenData(SUser) {
        local Ret = SelectSql("select inventory,wear from zyk.f_user_info where cid = " + SUser.GetCID(), ["binary", "binary"]);
        if (!Ret || Ret.len() == 0) return null;
        else return Ret;
    }

    //获取玩家背包
    function GetInven(SUser) {
        local Ret = GetInvenData(SUser);
        if (Ret) {
            local BackPack = FatalismStone_BackPack();
            BackPack.Deserialize(Ret);
            return BackPack;
        } else return null;
    }

    //固化背包数据到数据库
    function SaveInven(Inven, SUser) {
        //获取背包整体信息并储存
        local Hex = Inven.Serialize();
        //更新数据库
        local Sql = "update zyk.f_user_info set inventory = " + Hex.inventory + ",wear = " + Hex.wear + " where cid = " + SUser.GetCID();
        SelectSql(Sql, []);
    }

    //发送uuid的魂石数据给客户端
    function SendFatalismStoneData(SUser, Uuid) {
        local Attr = GetStoneAttr(Uuid);
        if (!Attr) {
            SUser.SendNotiPacketMessage("魂石属性异常,请联系管理员！", 8);
        } else {
            local Cultivation = Attr[0];
            local PackSize = 4 + 4 + 4;
            local Pack = Packet();
            Pack.Put_Header(1, 131);
            Pack.Put_Byte(1);
            Pack.Put_Int(PackSize);
            Pack.Put_Int(21000012);
            Pack.Put_Int(Uuid);
            Pack.Put_Int(Cultivation);
            Pack.Finalize(true);
            SUser.Send(Pack);
            Pack.Delete();
        }
    }

    //给指定玩家新增魂石
    function AddFatalismStone(SUser, FatalismStoneID) {
        local CID = SUser.GetCID();


    }


    function InitFatalismStoneData() {
        // Script();
        FatalismStoneLst = {};
        ScriptData.GetFileData("fatalismstone/fatalismstone.lst", function(DataTable, Data) {
            while (!Data.Eof()) {
                local Id = Data.Get();
                local Path = Data.Get();
                FatalismStoneLst.rawset(Id, Path);
            }
        }.bindenv(this));

        FatalismStoneConfig = ScriptData.GetFileData("fatalismstone/fatalismstone.etc", function(DataTable, Data) {
            while (!Data.Eof()) {
                local Str = Data.Get();
                if (Str == "[wash item]") {
                    DataTable.wash_item <- Data.Get();
                } else if (Str == "[wash cost]") {
                    DataTable.wash_cost <- [Data.Get(), Data.Get(), Data.Get(), Data.Get(), Data.Get(), Data.Get(), Data.Get()];
                }
            }
        }.bindenv(this));
    }

    function GetStoneData(Index) {
        if (FatalismStoneLst.rawin(Index)) {
            //还是路径就读取数据
            if (typeof FatalismStoneLst[Index] == "string") {
                FatalismStoneLst[Index] = ScriptData.GetFileData("fatalismstone/" + FatalismStoneLst[Index], function(DataTable, Data) {
                    DataTable.Attribute <- {};
                    while (!Data.Eof()) {
                        local Key = Data.Get();
                        if (Key == "[rarity]" || Key == "[stone type]" || Key == "[move wav]" || Key == "[front effect]" || Key == "[back effect]") {
                            DataTable[Key.slice(1, -1)] <- Data.Get();
                        } else if (Key == "[icon]") {
                            DataTable.icon <- {
                                img = Data.Get(),
                                index = Data.Get()
                            }
                        }
                    }
                });
            }
            return FatalismStoneLst[Index];
        } else error("没有ID为: " + Index + " 的魂石数据！");
    }






























































    //执行数据库命令
    function SelectSql(Sql, Type) {
        local SqlObj = MysqlPool.GetInstance().GetConnect();
        local Ret = SqlObj.Select(Sql, Type);
        //把连接还池子
        MysqlPool.GetInstance().PutConnect(SqlObj);
        return Ret;
    }


    //UpdateNewMysqlData
    function UpdateNewMysqlData() {

        local Ret = SelectSql("select * from zyk.fatalismstone", ["int", "binary", "binary"]);

        foreach(Index, Info in Ret) {
            local cid = Info[0];
            local inventory = Info[1];
            local wear = Info[2];

            //处理背包里的魂石
            local NewBlob = blob();
            for (local i = 0; i< 462; i += 2) {
                local item_id = inventory.add(i * 4).readInt();
                local cultivation = inventory.add(i * 4 + 4).readInt();
                if (item_id > 0) {
                    //在新表中建立这件装备的uuid
                    local Sql = "insert into zyk.f_stone_map (cultivation) values (" + cultivation + ")";
                    SelectSql(Sql, []);
                    //查询最后新增条目的uuid
                    Sql = "select LAST_INSERT_ID() as uuid";
                    local uuid = SelectSql(Sql, ["int"])[0][0];

                    NewBlob.writen(item_id, 'i');
                    NewBlob.writen(uuid, 'i');
                } else {
                    NewBlob.writen(0, 'i');
                    NewBlob.writen(0, 'i');
                }
            }
            local inventoryBinary = "0x" + Blob2Hex(NewBlob);

            //处理身上穿戴的魂石
            NewBlob.resize(0);
            for (local i = 0; i< 12; i += 2) {
                local item_id = wear.add(i * 4).readInt();
                print(item_id);

                local cultivation = wear.add(i * 4 + 4).readInt();
                if (item_id > 0) {
                    //在新表中建立这件装备的uuid
                    local Sql = "insert into zyk.f_stone_map (cultivation) values (" + cultivation + ")";
                    SelectSql(Sql, []);
                    //查询最后新增条目的uuid
                    Sql = "select LAST_INSERT_ID() as uuid";
                    local uuid = SelectSql(Sql, ["int"])[0][0];

                    NewBlob.writen(item_id, 'i');
                    NewBlob.writen(uuid, 'i');
                } else {
                    NewBlob.writen(0, 'i');
                    NewBlob.writen(0, 'i');
                }
            }
            local wearBinary = "0x" + Blob2Hex(NewBlob);

            local Sql = "insert into zyk.f_user_info (cid,inventory, wear) values (" + cid + "," + inventoryBinary + "," + wearBinary + ")";
            SelectSql(Sql, []);
        }
    }

    function Blob2Hex(buf) {
        local str = "";
        for (local i = 0; i< buf.len(); i++) {
            str += format("%02X", buf[i]);
        }
        return str;
    }
}




ProjectInitFuncMap.P_FatalismStone <- FatalismStone();