s_cherry_e/sr/nodes/map/internal/db/ver_00006.go

package db

import (
	capp "f1-game/internal/cherry_app"
	"fmt"

	clog "github.com/cherry-game/cherry/logger"
)

// ver00006 修正MarchViewID
type ver00006 struct {
}

// Version 手动自增，必需唯一
func (ver00006) Version() int32 {
	return 6
}

func (ver00006) Enable() bool {
	return false
}

func (p ver00006) Execute() bool {
	clog.Infof("Execute %v, nodeID = %s", p.Version(), capp.NodeID())

	// ctx := context.Background()
	// mapBornPointCollection := dbComponent.DB().Collection(nameDB.Table_MapBornPoint)
	// filter := bson.M{
	// 	"NodeID": capp.NodeID(),
	// }

	// bornPoint := &MapBornPointTable{}
	// err := mapBornPointCollection.FindOne(ctx, filter).Decode(bornPoint)
	// if err != nil {
	// 	clog.Errorf("[migrator - %d] find map born point table error: %v", p.Version(), err)
	// 	return false
	// }

	// bornPoint.FreePoints = append(bornPoint.FreePoints, bornPoint.BlockedPoints...)
	// bornPoint.BlockedPoints = nil

	// tableBytes, _ := bson.Marshal(bornPoint)
	// update := bson.D{{Key: "$set", Value: bson.Raw(tableBytes)}}
	// filter = bson.M{
	// 	"_id": bornPoint.PrimaryValue(), // 利用自带的_id主键进行条件过滤
	// }
	// _, err = dbComponent.DB().
	// 	Collection(bornPoint.TableName()).
	// 	UpdateOne(ctx, filter, update, options.UpdateOne().SetUpsert(true))
	// if err != nil {
	// 	clog.Fatalf("[migrator - %d] update map born point table error: %v", p.Version(), err)
	// }

	clog.Infof("[migrator - %d] bulk write map born point table success", p.Version())

	return true
}

func (p ver00006) Desc() string {
	return fmt.Sprintf("[migrator - %d] Fix MarchViewID", p.Version())
}