perms-system-server/internal/model/perm/sysPermModel_test.go

package perm_test

import (
	"context"
	"errors"
	"github.com/go-sql-driver/mysql"
	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
	"github.com/zeromicro/go-zero/core/stores/sqlx"
	"perms-system-server/internal/model/perm"
	"perms-system-server/internal/testutil"
	"sort"
	"testing"
	"time"
)

func newTestSysPermModel(t *testing.T) perm.SysPermModel {
	t.Helper()
	return perm.NewSysPermModel(
		testutil.GetTestSqlConn(),
		testutil.GetTestCacheConf(),
		testutil.GetTestCachePrefix(),
	)
}

func sortPermsByID(list []*perm.SysPerm) {
	sort.Slice(list, func(i, j int) bool { return list[i].Id < list[j].Id })
}

func isDuplicateKeyError(err error) bool {
	var me *mysql.MySQLError
	return errors.As(err, &me) && me.Number == 1062
}

// TC-0310: 正常插入
func TestSysPermModel_CRUD(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()

	data := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "perm-name",
		Code:        code,
		Remark:      "r1",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}

	res, err := m.Insert(ctx, data)
	require.NoError(t, err)
	id, err := res.LastInsertId()
	require.NoError(t, err)
	require.NotZero(t, id)

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", id)
	})

	one, err := m.FindOne(ctx, id)
	require.NoError(t, err)
	require.Equal(t, id, one.Id)
	require.Equal(t, productCode, one.ProductCode)
	require.Equal(t, "perm-name", one.Name)
	require.Equal(t, code, one.Code)
	require.Equal(t, int64(1), one.Status)

	now2 := time.Now().Unix()
	data.Id = id
	data.Name = "updated-name"
	data.Remark = "r2"
	data.Status = 2
	data.UpdateTime = now2
	require.NoError(t, m.Update(ctx, data))

	after, err := m.FindOne(ctx, id)
	require.NoError(t, err)
	require.Equal(t, "updated-name", after.Name)
	require.Equal(t, int64(2), after.Status)
	require.Equal(t, now2, after.UpdateTime)

	require.NoError(t, m.Delete(ctx, id))

	_, err = m.FindOne(ctx, id)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0371: FindOneByProductCodeCode
func TestSysPermModel_FindOneByProductCodeCode(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()

	data := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "n",
		Code:        code,
		Remark:      "",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}
	res, err := m.Insert(ctx, data)
	require.NoError(t, err)
	id, err := res.LastInsertId()
	require.NoError(t, err)

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", id)
	})

	found, err := m.FindOneByProductCodeCode(ctx, productCode, code)
	require.NoError(t, err)
	require.Equal(t, id, found.Id)
	require.Equal(t, code, found.Code)

	_, err = m.FindOneByProductCodeCode(ctx, productCode, testutil.UniqueId()+"_missing")
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0426: 正常分页
func TestSysPermModel_FindListByProductCode_Pagination(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	ids := make([]int64, 0, 5)

	for i := 0; i < 5; i++ {
		data := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "p",
			Code:        testutil.UniqueId(),
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, data)
		require.NoError(t, err)
		id, err := res.LastInsertId()
		require.NoError(t, err)
		ids = append(ids, id)
	}

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", ids...)
	})

	all, cnt, err := m.FindListByProductCode(ctx, productCode, 1, 100)
	require.NoError(t, err)
	require.Len(t, all, 5)
	require.Equal(t, int64(5), cnt)

	page1, tot, err := m.FindListByProductCode(ctx, productCode, 1, 2)
	require.NoError(t, err)
	require.Equal(t, int64(5), tot)
	require.Len(t, page1, 2)
	// id desc: first page has largest ids
	require.Greater(t, page1[0].Id, page1[1].Id)

	page2, _, err := m.FindListByProductCode(ctx, productCode, 2, 2)
	require.NoError(t, err)
	require.Len(t, page2, 2)

	page3, _, err := m.FindListByProductCode(ctx, productCode, 3, 2)
	require.NoError(t, err)
	require.Len(t, page3, 1)
}

// TC-0428: 正常查询
func TestSysPermModel_FindAllCodesByProductCode_OnlyEnabled(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	codeOn := testutil.UniqueId()
	codeOff := testutil.UniqueId()
	ids := make([]int64, 0, 2)

	ins := []struct {
		code   string
		status int64
	}{
		{codeOn, 1},
		{codeOff, 2},
	}
	for _, row := range ins {
		data := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "c",
			Code:        row.code,
			Remark:      "",
			Status:      row.status,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, data)
		require.NoError(t, err)
		id, err := res.LastInsertId()
		require.NoError(t, err)
		ids = append(ids, id)
	}

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", ids...)
	})

	codes, err := m.FindAllCodesByProductCode(ctx, productCode)
	require.NoError(t, err)
	require.Equal(t, []string{codeOn}, codes)
}

// TC-0430: 正常
func TestSysPermModel_FindByIds(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()

	var id1, id2 int64
	for i := 0; i < 2; i++ {
		data := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "f",
			Code:        testutil.UniqueId(),
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, data)
		require.NoError(t, err)
		id, err := res.LastInsertId()
		require.NoError(t, err)
		if i == 0 {
			id1 = id
		} else {
			id2 = id
		}
	}

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", id1, id2)
	})

	t.Run("normal", func(t *testing.T) {
		list, err := m.FindByIds(ctx, []int64{id1, id2})
		require.NoError(t, err)
		require.Len(t, list, 2)
		sortPermsByID(list)
		require.Equal(t, id1, list[0].Id)
		require.Equal(t, id2, list[1].Id)
	})

	t.Run("empty", func(t *testing.T) {
		list, err := m.FindByIds(ctx, nil)
		require.NoError(t, err)
		require.Nil(t, list)
		list2, err := m.FindByIds(ctx, []int64{})
		require.NoError(t, err)
		require.Nil(t, list2)
	})

	t.Run("partial", func(t *testing.T) {
		list, err := m.FindByIds(ctx, []int64{999999999999, id1})
		require.NoError(t, err)
		require.Len(t, list, 1)
		require.Equal(t, id1, list[0].Id)
	})
}

// TC-0432: 正常查询（ 后 FindMapByProductCode 非事务版被移除，这里改走事务版覆盖等价语义）
func TestSysPermModel_FindMapByProductCode(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	c1 := testutil.UniqueId()
	c2 := testutil.UniqueId()
	now := time.Now().Unix()
	ids := make([]int64, 0, 2)

	for _, code := range []string{c1, c2} {
		data := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "m",
			Code:        code,
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, data)
		require.NoError(t, err)
		id, err := res.LastInsertId()
		require.NoError(t, err)
		ids = append(ids, id)
	}

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", ids...)
	})

	var mp map[string]*perm.SysPerm
	require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		var e error
		mp, e = m.FindMapByProductCodeWithTx(c, session, productCode)
		return e
	}))
	require.Len(t, mp, 2)
	require.Contains(t, mp, c1)
	require.Contains(t, mp, c2)
	require.Equal(t, c1, mp[c1].Code)
	require.Equal(t, productCode, mp[c2].ProductCode)
}

// TC-0435: codes非空-正常
func TestSysPermModel_DisableNotInCodes(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	k1 := testutil.UniqueId()
	k2 := testutil.UniqueId()
	k3 := testutil.UniqueId()
	ids := make([]int64, 0, 3)

	for _, code := range []string{k1, k2, k3} {
		data := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "d",
			Code:        code,
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, data)
		require.NoError(t, err)
		id, err := res.LastInsertId()
		require.NoError(t, err)
		ids = append(ids, id)
	}

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", ids...)
	})

	t.Run("with_codes_keeps_subset", func(t *testing.T) {
		ts := time.Now().Unix()
		var n int64
		require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
			var e error
			n, e = m.DisableNotInCodesWithTx(c, session, productCode, []string{k1, k2}, ts)
			return e
		}))
		require.Equal(t, int64(1), n)

		codes, err := m.FindAllCodesByProductCode(ctx, productCode)
		require.NoError(t, err)
		assert.ElementsMatch(t, []string{k1, k2}, codes)

		p3, err := m.FindOneByProductCodeCode(ctx, productCode, k3)
		require.NoError(t, err)
		require.Equal(t, int64(2), p3.Status)
		require.Equal(t, ts, p3.UpdateTime)
	})

	t.Run("empty_codes_disables_all_enabled", func(t *testing.T) {
		// reset rows: re-insert three enabled for a fresh product
		pc := testutil.UniqueId()
		ids2 := make([]int64, 0, 3)
		for i := 0; i < 3; i++ {
			data := &perm.SysPerm{
				ProductCode: pc,
				Name:        "d2",
				Code:        testutil.UniqueId(),
				Remark:      "",
				Status:      1,
				CreateTime:  now,
				UpdateTime:  now,
			}
			res, err := m.Insert(ctx, data)
			require.NoError(t, err)
			id, err := res.LastInsertId()
			require.NoError(t, err)
			ids2 = append(ids2, id)
		}
		t.Cleanup(func() {
			testutil.CleanTable(ctx, conn, "sys_perm", ids2...)
		})

		ts := time.Now().Unix()
		var n int64
		require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
			var e error
			n, e = m.DisableNotInCodesWithTx(c, session, pc, nil, ts)
			return e
		}))
		require.Equal(t, int64(3), n)

		enabledCodes, err := m.FindAllCodesByProductCode(ctx, pc)
		require.NoError(t, err)
		require.Len(t, enabledCodes, 0)
	})

	t.Run("no_need_to_disable", func(t *testing.T) {
		pc := testutil.UniqueId()
		ca := testutil.UniqueId()
		cb := testutil.UniqueId()
		ids3 := make([]int64, 0, 2)
		for _, code := range []string{ca, cb} {
			data := &perm.SysPerm{
				ProductCode: pc,
				Name:        "d3",
				Code:        code,
				Remark:      "",
				Status:      1,
				CreateTime:  now,
				UpdateTime:  now,
			}
			res, err := m.Insert(ctx, data)
			require.NoError(t, err)
			id, err := res.LastInsertId()
			require.NoError(t, err)
			ids3 = append(ids3, id)
		}
		t.Cleanup(func() {
			testutil.CleanTable(ctx, conn, "sys_perm", ids3...)
		})

		ts := time.Now().Unix()
		var n int64
		require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
			var e error
			n, e = m.DisableNotInCodesWithTx(c, session, pc, []string{ca, cb}, ts)
			return e
		}))
		require.Equal(t, int64(0), n)

		for _, code := range []string{ca, cb} {
			p, err := m.FindOneByProductCodeCode(ctx, pc, code)
			require.NoError(t, err)
			require.Equal(t, int64(1), p.Status)
		}
	})
}

// TC-0336: 多条记录(3条)
func TestSysPermModel_BatchInsert_BatchDelete(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()

	list := []*perm.SysPerm{
		{
			ProductCode: productCode,
			Name:        "b1",
			Code:        testutil.UniqueId(),
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		},
		{
			ProductCode: productCode,
			Name:        "b2",
			Code:        testutil.UniqueId(),
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		},
	}

	require.NoError(t, m.BatchInsert(ctx, list))

	var ids []int64
	for _, code := range []string{list[0].Code, list[1].Code} {
		p, err := m.FindOneByProductCodeCode(ctx, productCode, code)
		require.NoError(t, err)
		ids = append(ids, p.Id)
	}

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", ids...)
	})

	require.NoError(t, m.BatchDelete(ctx, ids))

	for _, id := range ids {
		_, err := m.FindOne(ctx, id)
		require.ErrorIs(t, err, perm.ErrNotFound)
	}
}

// TC-0312: 唯一索引冲突
func TestSysPermModel_InsertDuplicateProductCodeCode(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()

	data := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "dup",
		Code:        code,
		Remark:      "",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}
	res, err := m.Insert(ctx, data)
	require.NoError(t, err)
	id, err := res.LastInsertId()
	require.NoError(t, err)

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", id)
	})

	dup := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "other",
		Code:        code,
		Remark:      "",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}
	_, err = m.Insert(ctx, dup)
	require.Error(t, err)
	assert.True(t, isDuplicateKeyError(err), "expected MySQL duplicate key error, got: %v", err)
}

// TC-0319: 记录不存在
func TestSysPermModel_FindOne_NotFound(t *testing.T) {
	m := newTestSysPermModel(t)
	_, err := m.FindOne(context.Background(), 999999999999)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0326: 记录不存在
func TestSysPermModel_Update_NotFound(t *testing.T) {
	m := newTestSysPermModel(t)
	err := m.Update(context.Background(), &perm.SysPerm{
		Id: 999999999999, ProductCode: "x", Name: "n", Code: "c",
		Status: 1, CreateTime: time.Now().Unix(), UpdateTime: time.Now().Unix(),
	})
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0329: 记录不存在
func TestSysPermModel_Delete_NotFound(t *testing.T) {
	m := newTestSysPermModel(t)
	err := m.Delete(context.Background(), 999999999999)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0334: 空列表
func TestSysPermModel_BatchInsert_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	require.NoError(t, m.BatchInsert(context.Background(), nil))
	require.NoError(t, m.BatchInsert(context.Background(), []*perm.SysPerm{}))
}

// TC-0353: 空ids
func TestSysPermModel_BatchDelete_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	require.NoError(t, m.BatchDelete(context.Background(), nil))
	require.NoError(t, m.BatchDelete(context.Background(), []int64{}))
}

// TC-0427: 不存在的productCode
func TestSysPermModel_FindListByProductCode_NotExistProduct(t *testing.T) {
	m := newTestSysPermModel(t)
	list, total, err := m.FindListByProductCode(context.Background(), "notexist_"+testutil.UniqueId(), 1, 10)
	require.NoError(t, err)
	require.Equal(t, int64(0), total)
	require.Len(t, list, 0)
}

// TC-0429: 空结果
func TestSysPermModel_FindAllCodesByProductCode_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	codes, err := m.FindAllCodesByProductCode(context.Background(), "empty_"+testutil.UniqueId())
	require.NoError(t, err)
	require.Empty(t, codes)
}

// TC-0433: 空结果（ 清理后只保留事务版）
func TestSysPermModel_FindMapByProductCode_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	ctx := context.Background()
	var mp map[string]*perm.SysPerm
	require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		var e error
		mp, e = m.FindMapByProductCodeWithTx(c, session, "empty_"+testutil.UniqueId())
		return e
	}))
	require.Empty(t, mp)
}

// TC-0314: 事务内插入
func TestSysPermModel_InsertWithTx_Normal(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()
	data := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "tx_insert",
		Code:        code,
		Remark:      "",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}

	var insertedID int64
	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		res, err := m.InsertWithTx(c, session, data)
		if err != nil {
			return err
		}
		insertedID, err = res.LastInsertId()
		return err
	})
	require.NoError(t, err)
	require.Greater(t, insertedID, int64(0))
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", insertedID) })

	got, err := m.FindOne(ctx, insertedID)
	require.NoError(t, err)
	require.Equal(t, productCode, got.ProductCode)
	require.Equal(t, code, got.Code)
}

// TC-0316: 事务回滚后无数据
func TestSysPermModel_InsertWithTx_Rollback(t *testing.T) {
	ctx := context.Background()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()
	data := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "tx_rollback",
		Code:        code,
		Remark:      "",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}

	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		if _, e := m.InsertWithTx(c, session, data); e != nil {
			return e
		}
		return errors.New("force rollback")
	})
	require.Error(t, err)

	_, err = m.FindOneByProductCodeCode(ctx, productCode, code)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0327: 事务内更新
func TestSysPermModel_UpdateWithTx(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()
	data := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "before",
		Code:        code,
		Remark:      "",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}
	res, err := m.Insert(ctx, data)
	require.NoError(t, err)
	id, err := res.LastInsertId()
	require.NoError(t, err)
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id) })

	err = m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		data.Id = id
		data.Name = "after"
		data.UpdateTime = time.Now().Unix()
		return m.UpdateWithTx(c, session, data)
	})
	require.NoError(t, err)

	got, err := m.FindOne(ctx, id)
	require.NoError(t, err)
	require.Equal(t, "after", got.Name)
}

// TC-0330: 事务内删除
func TestSysPermModel_DeleteWithTx(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()
	data := &perm.SysPerm{
		ProductCode: productCode,
		Name:        "del",
		Code:        code,
		Remark:      "",
		Status:      1,
		CreateTime:  now,
		UpdateTime:  now,
	}
	res, err := m.Insert(ctx, data)
	require.NoError(t, err)
	id, err := res.LastInsertId()
	require.NoError(t, err)
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id) })

	err = m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		return m.DeleteWithTx(c, session, id)
	})
	require.NoError(t, err)

	_, err = m.FindOne(ctx, id)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0331: 正常事务
func TestSysPermModel_TransactCtx_CommitAndRollback(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	now := time.Now().Unix()

	pc1 := testutil.UniqueId()
	c1 := testutil.UniqueId()
	var id1 int64
	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		res, err := m.InsertWithTx(c, session, &perm.SysPerm{
			ProductCode: pc1, Name: "commit", Code: c1, Status: 1, CreateTime: now, UpdateTime: now,
		})
		if err != nil {
			return err
		}
		id1, err = res.LastInsertId()
		return err
	})
	require.NoError(t, err)
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id1) })

	_, err = m.FindOne(ctx, id1)
	require.NoError(t, err)

	pc2 := testutil.UniqueId()
	c2 := testutil.UniqueId()
	err = m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		if _, e := m.InsertWithTx(c, session, &perm.SysPerm{
			ProductCode: pc2, Name: "rollback", Code: c2, Status: 1, CreateTime: now, UpdateTime: now,
		}); e != nil {
			return e
		}
		return errors.New("force rollback")
	})
	require.Error(t, err)

	_, err = m.FindOneByProductCodeCode(ctx, pc2, c2)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0333: 获取表名
func TestSysPermModel_TableName(t *testing.T) {
	m := newTestSysPermModel(t)
	require.Equal(t, "`sys_perm`", m.TableName())
}

// TC-0335: 单条记录
func TestSysPermModel_BatchInsert_Single(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()

	require.NoError(t, m.BatchInsert(ctx, []*perm.SysPerm{
		{ProductCode: productCode, Name: "single", Code: code, Status: 1, CreateTime: now, UpdateTime: now},
	}))

	found, err := m.FindOneByProductCodeCode(ctx, productCode, code)
	require.NoError(t, err)
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", found.Id) })
	require.Equal(t, code, found.Code)
}

// TC-0338: 唯一索引冲突
func TestSysPermModel_BatchInsert_UniqueConflict(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()

	list := []*perm.SysPerm{
		{ProductCode: productCode, Name: "dup1", Code: code, Status: 1, CreateTime: now, UpdateTime: now},
		{ProductCode: productCode, Name: "dup2", Code: code, Status: 1, CreateTime: now, UpdateTime: now},
	}
	err := m.BatchInsert(ctx, list)
	require.Error(t, err)
	require.True(t, isDuplicateKeyError(err))

	t.Cleanup(func() {
		if found, e := m.FindOneByProductCodeCode(ctx, productCode, code); e == nil {
			testutil.CleanTable(ctx, conn, "sys_perm", found.Id)
		}
	})
}

// TC-0343: 空列表
func TestSysPermModel_BatchUpdate_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	require.NoError(t, m.BatchUpdate(context.Background(), nil))
	require.NoError(t, m.BatchUpdate(context.Background(), []*perm.SysPerm{}))
}

// TC-0345: 多条记录(3条)
func TestSysPermModel_BatchUpdate_Multi(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()

	d1 := &perm.SysPerm{ProductCode: productCode, Name: "u1", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	d2 := &perm.SysPerm{ProductCode: productCode, Name: "u2", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	r1, err := m.Insert(ctx, d1)
	require.NoError(t, err)
	id1, _ := r1.LastInsertId()
	r2, err := m.Insert(ctx, d2)
	require.NoError(t, err)
	id2, _ := r2.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id1, id2) })

	now2 := time.Now().Unix()
	upd := []*perm.SysPerm{
		{Id: id1, ProductCode: productCode, Name: "u1_new", Code: d1.Code, Status: 2, CreateTime: now, UpdateTime: now2},
		{Id: id2, ProductCode: productCode, Name: "u2_new", Code: d2.Code, Status: 1, CreateTime: now, UpdateTime: now2},
	}
	require.NoError(t, m.BatchUpdate(ctx, upd))

	g1, err := m.FindOne(ctx, id1)
	require.NoError(t, err)
	require.Equal(t, "u1_new", g1.Name)
	require.Equal(t, int64(2), g1.Status)

	g2, err := m.FindOne(ctx, id2)
	require.NoError(t, err)
	require.Equal(t, "u2_new", g2.Name)
}

// TC-0341: 正常多条
func TestSysPermModel_BatchInsertWithTx_Normal(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	c1 := testutil.UniqueId()
	c2 := testutil.UniqueId()
	now := time.Now().Unix()

	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		return m.BatchInsertWithTx(c, session, []*perm.SysPerm{
			{ProductCode: productCode, Name: "tx1", Code: c1, Status: 1, CreateTime: now, UpdateTime: now},
			{ProductCode: productCode, Name: "tx2", Code: c2, Status: 1, CreateTime: now, UpdateTime: now},
		})
	})
	require.NoError(t, err)

	f1, err := m.FindOneByProductCodeCode(ctx, productCode, c1)
	require.NoError(t, err)
	f2, err := m.FindOneByProductCodeCode(ctx, productCode, c2)
	require.NoError(t, err)
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", f1.Id, f2.Id) })

	require.Equal(t, c1, f1.Code)
	require.Equal(t, c2, f2.Code)
}

// TC-0340: 空列表
func TestSysPermModel_BatchInsertWithTx_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	err := m.TransactCtx(context.Background(), func(c context.Context, session sqlx.Session) error {
		return m.BatchInsertWithTx(c, session, nil)
	})
	require.NoError(t, err)
}

// TC-0342: 事务回滚
func TestSysPermModel_BatchInsertWithTx_Rollback(t *testing.T) {
	ctx := context.Background()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()

	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		if e := m.BatchInsertWithTx(c, session, []*perm.SysPerm{
			{ProductCode: productCode, Name: "rb", Code: code, Status: 1, CreateTime: now, UpdateTime: now},
		}); e != nil {
			return e
		}
		return errors.New("force rollback")
	})
	require.Error(t, err)

	_, err = m.FindOneByProductCodeCode(ctx, productCode, code)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0349: 正常多条
func TestSysPermModel_BatchUpdateWithTx_Normal(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	d1 := &perm.SysPerm{ProductCode: productCode, Name: "bu1", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	d2 := &perm.SysPerm{ProductCode: productCode, Name: "bu2", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	r1, err := m.Insert(ctx, d1)
	require.NoError(t, err)
	id1, _ := r1.LastInsertId()
	r2, err := m.Insert(ctx, d2)
	require.NoError(t, err)
	id2, _ := r2.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id1, id2) })

	now2 := time.Now().Unix()
	err = m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		return m.BatchUpdateWithTx(c, session, []*perm.SysPerm{
			{Id: id1, ProductCode: productCode, Name: "bu1_tx", Code: d1.Code, Status: 1, CreateTime: now, UpdateTime: now2},
			{Id: id2, ProductCode: productCode, Name: "bu2_tx", Code: d2.Code, Status: 2, CreateTime: now, UpdateTime: now2},
		})
	})
	require.NoError(t, err)

	g1, err := m.FindOne(ctx, id1)
	require.NoError(t, err)
	require.Equal(t, "bu1_tx", g1.Name)

	g2, err := m.FindOne(ctx, id2)
	require.NoError(t, err)
	require.Equal(t, "bu2_tx", g2.Name)
	require.Equal(t, int64(2), g2.Status)
}

// TC-0348: 空列表
func TestSysPermModel_BatchUpdateWithTx_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	err := m.TransactCtx(context.Background(), func(c context.Context, session sqlx.Session) error {
		return m.BatchUpdateWithTx(c, session, nil)
	})
	require.NoError(t, err)
}

// TC-0354: 单个id
func TestSysPermModel_BatchDelete_Single(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	d := &perm.SysPerm{ProductCode: productCode, Name: "bd", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	res, err := m.Insert(ctx, d)
	require.NoError(t, err)
	id, _ := res.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id) })

	require.NoError(t, m.BatchDelete(ctx, []int64{id}))

	_, err = m.FindOne(ctx, id)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0356: 包含不存在id
func TestSysPermModel_BatchDelete_ContainsNonExist(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	d := &perm.SysPerm{ProductCode: productCode, Name: "bdne", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	res, err := m.Insert(ctx, d)
	require.NoError(t, err)
	id, _ := res.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id) })

	require.NoError(t, m.BatchDelete(ctx, []int64{id, 999999999}))

	_, err = m.FindOne(ctx, id)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0358: 正常多条
func TestSysPermModel_BatchDeleteWithTx_Normal(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	d1 := &perm.SysPerm{ProductCode: productCode, Name: "bdtx1", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	d2 := &perm.SysPerm{ProductCode: productCode, Name: "bdtx2", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	r1, err := m.Insert(ctx, d1)
	require.NoError(t, err)
	id1, _ := r1.LastInsertId()
	r2, err := m.Insert(ctx, d2)
	require.NoError(t, err)
	id2, _ := r2.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id1, id2) })

	err = m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		return m.BatchDeleteWithTx(c, session, []int64{id1, id2})
	})
	require.NoError(t, err)

	_, err = m.FindOne(ctx, id1)
	require.ErrorIs(t, err, perm.ErrNotFound)
	_, err = m.FindOne(ctx, id2)
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0357: 空ids
func TestSysPermModel_BatchDeleteWithTx_Empty(t *testing.T) {
	m := newTestSysPermModel(t)
	err := m.TransactCtx(context.Background(), func(c context.Context, session sqlx.Session) error {
		return m.BatchDeleteWithTx(c, session, nil)
	})
	require.NoError(t, err)
}

// TC-0397: 无启用权限 (验证 FindAllCodesByProductCode 只返回启用的)
func TestSysPermModel_FindAllCodesByProductCode_AllDisabled(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	ids := make([]int64, 0, 3)

	for i := 0; i < 3; i++ {
		d := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "disabled",
			Code:        testutil.UniqueId(),
			Status:      2,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, d)
		require.NoError(t, err)
		id, _ := res.LastInsertId()
		ids = append(ids, id)
	}
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", ids...) })

	codes, err := m.FindAllCodesByProductCode(ctx, productCode)
	require.NoError(t, err)
	require.Empty(t, codes)
}

// TC-0323: 事务内可见性
func TestSysPermModel_FindOneWithTx_InsertThenFind(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()
	var foundInTx *perm.SysPerm
	var insertedId int64

	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		res, err := m.InsertWithTx(c, session, &perm.SysPerm{
			ProductCode: productCode,
			Name:        "ftx_perm_" + testutil.UniqueId(),
			Code:        code,
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		})
		if err != nil {
			return err
		}
		insertedId, _ = res.LastInsertId()
		foundInTx, err = m.FindOneWithTx(c, session, insertedId)
		return err
	})
	require.NoError(t, err)
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", insertedId) })

	require.NotNil(t, foundInTx)
	assert.Equal(t, insertedId, foundInTx.Id)
	assert.Equal(t, productCode, foundInTx.ProductCode)
	assert.Equal(t, code, foundInTx.Code)
}

// TC-0322: 事务内记录不存在
func TestSysPermModel_FindOneWithTx_NotFound(t *testing.T) {
	ctx := context.Background()
	m := newTestSysPermModel(t)

	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		_, err := m.FindOneWithTx(c, session, 999999999999)
		return err
	})
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0373: FindOneByProductCodeCodeWithTx
func TestSysPermModel_FindOneByProductCodeCodeWithTx_InsertThenFind(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()
	var foundByKey *perm.SysPerm
	var insertedId int64

	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		res, err := m.InsertWithTx(c, session, &perm.SysPerm{
			ProductCode: productCode,
			Name:        "ftx_bykey_" + testutil.UniqueId(),
			Code:        code,
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		})
		if err != nil {
			return err
		}
		insertedId, _ = res.LastInsertId()
		foundByKey, err = m.FindOneByProductCodeCodeWithTx(c, session, productCode, code)
		return err
	})
	require.NoError(t, err)
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", insertedId) })

	require.NotNil(t, foundByKey)
	assert.Equal(t, insertedId, foundByKey.Id)
	assert.Equal(t, productCode, foundByKey.ProductCode)
	assert.Equal(t, code, foundByKey.Code)
}

// TC-0374: FindOneByProductCodeCodeWithTx
func TestSysPermModel_FindOneByProductCodeCodeWithTx_NotFound(t *testing.T) {
	ctx := context.Background()
	m := newTestSysPermModel(t)

	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		_, err := m.FindOneByProductCodeCodeWithTx(c, session, "notexist_pc_"+testutil.UniqueId(), "notexist_code_"+testutil.UniqueId())
		return err
	})
	require.ErrorIs(t, err, perm.ErrNotFound)
}

// TC-0439: FindAllCodesByProductCode 返回仅启用的权限code
func TestSysPermModel_FindAllCodesByProductCode_OnlyEnabledCodes(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	codeA := testutil.UniqueId()
	codeB := testutil.UniqueId()
	codeDisabled := testutil.UniqueId()
	ids := make([]int64, 0, 3)

	for _, row := range []struct {
		code   string
		status int64
	}{
		{codeA, 1},
		{codeB, 1},
		{codeDisabled, 2},
	} {
		data := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "tc0494",
			Code:        row.code,
			Remark:      "",
			Status:      row.status,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, data)
		require.NoError(t, err)
		id, err := res.LastInsertId()
		require.NoError(t, err)
		ids = append(ids, id)
	}

	t.Cleanup(func() {
		testutil.CleanTable(ctx, conn, "sys_perm", ids...)
	})

	codes, err := m.FindAllCodesByProductCode(ctx, productCode)
	require.NoError(t, err)
	require.Len(t, codes, 2)
	assert.ElementsMatch(t, []string{codeA, codeB}, codes)
}

// TC-0440: FindAllCodesByProductCode 不存在的product返回空
func TestSysPermModel_FindAllCodesByProductCode_NonExistentProduct(t *testing.T) {
	m := newTestSysPermModel(t)
	codes, err := m.FindAllCodesByProductCode(context.Background(), "nonexist_"+testutil.UniqueId())
	require.NoError(t, err)
	require.Empty(t, codes)
}

// TC-0339: BatchInsert 大批量(1000条)
func TestSysPermModel_BatchInsert_Bulk1000(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()

	list := make([]*perm.SysPerm, 1000)
	for i := range list {
		list[i] = &perm.SysPerm{
			ProductCode: productCode,
			Name:        "bulk",
			Code:        testutil.UniqueId(),
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		}
	}

	require.NoError(t, m.BatchInsert(ctx, list))

	t.Cleanup(func() {
		conn.ExecCtx(ctx, "DELETE FROM `sys_perm` WHERE `productCode` = ?", productCode)
	})

	_, cnt, err := m.FindListByProductCode(ctx, productCode, 1, 1100)
	require.NoError(t, err)
	require.Equal(t, int64(1000), cnt)
}

// TC-0344: BatchUpdate 单条记录
func TestSysPermModel_BatchUpdate_Single(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	code := testutil.UniqueId()
	now := time.Now().Unix()

	d := &perm.SysPerm{ProductCode: productCode, Name: "bu_single", Code: code, Status: 1, CreateTime: now, UpdateTime: now}
	res, err := m.Insert(ctx, d)
	require.NoError(t, err)
	id, _ := res.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id) })

	now2 := time.Now().Unix()
	upd := []*perm.SysPerm{
		{Id: id, ProductCode: productCode, Name: "bu_single_new", Code: code, Status: 2, CreateTime: now, UpdateTime: now2},
	}
	require.NoError(t, m.BatchUpdate(ctx, upd))

	got, err := m.FindOne(ctx, id)
	require.NoError(t, err)
	require.Equal(t, "bu_single_new", got.Name)
	require.Equal(t, int64(2), got.Status)
	require.Equal(t, now2, got.UpdateTime)
}

// TC-0347: BatchUpdate 部分id不存在
func TestSysPermModel_BatchUpdate_PartialIdNotExist(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	d1 := &perm.SysPerm{ProductCode: productCode, Name: "bu_p1", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	d2 := &perm.SysPerm{ProductCode: productCode, Name: "bu_p2", Code: testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now}
	r1, err := m.Insert(ctx, d1)
	require.NoError(t, err)
	id1, _ := r1.LastInsertId()
	r2, err := m.Insert(ctx, d2)
	require.NoError(t, err)
	id2, _ := r2.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", id1, id2) })

	now2 := time.Now().Unix()
	upd := []*perm.SysPerm{
		{Id: id1, ProductCode: productCode, Name: "bu_p1_new", Code: d1.Code, Status: 2, CreateTime: now, UpdateTime: now2},
		{Id: id2, ProductCode: productCode, Name: "bu_p2_new", Code: d2.Code, Status: 2, CreateTime: now, UpdateTime: now2},
		{Id: 999999999, ProductCode: productCode, Name: "ghost", Code: "ghost_" + testutil.UniqueId(), Status: 1, CreateTime: now, UpdateTime: now2},
	}
	require.NoError(t, m.BatchUpdate(ctx, upd))

	g1, err := m.FindOne(ctx, id1)
	require.NoError(t, err)
	require.Equal(t, "bu_p1_new", g1.Name)
	require.Equal(t, int64(2), g1.Status)

	g2, err := m.FindOne(ctx, id2)
	require.NoError(t, err)
	require.Equal(t, "bu_p2_new", g2.Name)
}

// TC-0434: FindMapByProductCode key唯一性
func TestSysPermModel_FindMapByProductCode_KeyUniqueness(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := testutil.UniqueId()
	now := time.Now().Unix()
	c1, c2, c3 := testutil.UniqueId(), testutil.UniqueId(), testutil.UniqueId()
	ids := make([]int64, 0, 3)

	for _, code := range []string{c1, c2, c3} {
		data := &perm.SysPerm{
			ProductCode: productCode,
			Name:        "map_key",
			Code:        code,
			Remark:      "",
			Status:      1,
			CreateTime:  now,
			UpdateTime:  now,
		}
		res, err := m.Insert(ctx, data)
		require.NoError(t, err)
		id, err := res.LastInsertId()
		require.NoError(t, err)
		ids = append(ids, id)
	}
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", ids...) })

	var mp map[string]*perm.SysPerm
	require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		var e error
		mp, e = m.FindMapByProductCodeWithTx(c, session, productCode)
		return e
	}))
	require.Len(t, mp, 3)
	require.Contains(t, mp, c1)
	require.Contains(t, mp, c2)
	require.Contains(t, mp, c3)
	require.Equal(t, c1, mp[c1].Code)
	require.Equal(t, c2, mp[c2].Code)
	require.Equal(t, c3, mp[c3].Code)
}

func TestSysPermModel_FindMapByProductCodeWithTx_EqualsNonTx(t *testing.T) {
	ctx := context.Background()
	m := newTestSysPermModel(t)
	conn := testutil.GetTestSqlConn()
	productCode := "pc_fmwtx_" + testutil.UniqueId()
	now := time.Now().Unix()

	codeA := "a_" + testutil.UniqueId()
	codeB := "b_" + testutil.UniqueId()

	res1, err := m.Insert(ctx, &perm.SysPerm{
		ProductCode: productCode, Name: "a", Code: codeA,
		Status: 1, CreateTime: now, UpdateTime: now,
	})
	require.NoError(t, err)
	id1, _ := res1.LastInsertId()
	res2, err := m.Insert(ctx, &perm.SysPerm{
		ProductCode: productCode, Name: "b", Code: codeB,
		Status: 2, CreateTime: now, UpdateTime: now, // 禁用行也必须被 Map 出来
	})
	require.NoError(t, err)
	id2, _ := res2.LastInsertId()
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "`sys_perm`", id1, id2) })

	var withTx map[string]*perm.SysPerm
	require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		var err error
		withTx, err = m.FindMapByProductCodeWithTx(c, session, productCode)
		return err
	}))
	require.Len(t, withTx, 2)

	pA, ok := withTx[codeA]
	require.True(t, ok, "map key 必须等于 SysPerm.Code")
	assert.Equal(t, id1, pA.Id)
	assert.Equal(t, int64(1), pA.Status)
	assert.Equal(t, "a", pA.Name)

	pB, ok := withTx[codeB]
	require.True(t, ok, "禁用行同样必须出现在 map 中（依赖它识别 disabled 重启）")
	assert.Equal(t, id2, pB.Id)
	assert.Equal(t, int64(2), pB.Status, "status 必须真实透传，不得被过滤")
}

// TC-0808: 空 productCode 下 FindMapByProductCodeWithTx 返回非 nil 的空 map。
// 上层同步逻辑里会对 map 直接做 `_, ok := existingMap[item.Code]`；如果是 nil 依然安全，
// 但若不慎写成 `existingMap[item.Code] = ...` 就会炸，因此约定为"空 map"更稳。
func TestSysPermModel_FindMapByProductCodeWithTx_EmptyIsNonNil(t *testing.T) {
	ctx := context.Background()
	m := newTestSysPermModel(t)
	productCode := "pc_empty_" + testutil.UniqueId()

	var withTx map[string]*perm.SysPerm
	require.NoError(t, m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		var err error
		withTx, err = m.FindMapByProductCodeWithTx(c, session, productCode)
		return err
	}))
	require.NotNil(t, withTx, "空集必须是 empty map，而不是 nil（避免上层误用 map 赋值时 panic）")
	assert.Empty(t, withTx)
}

func TestSysPermModel_L1_FindAllCodes_StrictlyEqualEnabled(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := "l1_strict_" + testutil.UniqueId()
	now := time.Now().Unix()

	rows := []struct {
		code   string
		status int64
	}{
		{"ena_" + testutil.UniqueId(), 1},
		{"dis_" + testutil.UniqueId(), 2},
		{"rev_" + testutil.UniqueId(), 99},
	}
	ids := make([]int64, 0, len(rows))
	for _, r := range rows {
		res, err := m.Insert(ctx, &perm.SysPerm{
			ProductCode: productCode, Name: "n", Code: r.code,
			Status: r.status, CreateTime: now, UpdateTime: now,
		})
		require.NoError(t, err)
		id, _ := res.LastInsertId()
		ids = append(ids, id)
	}
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", ids...) })

	codes, err := m.FindAllCodesByProductCode(ctx, productCode)
	require.NoError(t, err)
	assert.Len(t, codes, 1,
		"只应返回 status=1 的 code；99 不得被误判为启用（那说明 SQL 里不是严格的 `=` ?）")
	assert.Equal(t, rows[0].code, codes[0])
}

// TC-0987: DisableNotInCodesWithTx 不得触碰 status≠1 的行。
func TestSysPermModel_L1_DisableNotInCodes_LeavesNonEnabledAlone(t *testing.T) {
	ctx := context.Background()
	conn := testutil.GetTestSqlConn()
	m := newTestSysPermModel(t)

	productCode := "l1_dis_" + testutil.UniqueId()
	now := time.Now().Unix()

	rows := []struct {
		code   string
		status int64
	}{
		{"k_on_" + testutil.UniqueId(), 1},  // 在白名单，保留
		{"k_rm_" + testutil.UniqueId(), 1},  // 不在白名单，会 1→2
		{"k_off_" + testutil.UniqueId(), 2}, // 已禁用，不动
		{"k_rv_" + testutil.UniqueId(), 99}, // 未来枚举值，不得被误改
	}
	ids := make([]int64, 0, len(rows))
	for _, r := range rows {
		res, err := m.Insert(ctx, &perm.SysPerm{
			ProductCode: productCode, Name: "n", Code: r.code,
			Status: r.status, CreateTime: now, UpdateTime: now,
		})
		require.NoError(t, err)
		id, _ := res.LastInsertId()
		ids = append(ids, id)
	}
	t.Cleanup(func() { testutil.CleanTable(ctx, conn, "sys_perm", ids...) })

	var disabled int64
	err := m.TransactCtx(ctx, func(c context.Context, session sqlx.Session) error {
		var e error
		disabled, e = m.DisableNotInCodesWithTx(c, session, productCode, []string{rows[0].code}, now)
		return e
	})
	require.NoError(t, err)
	assert.Equal(t, int64(1), disabled, "只有 status=1 且不在白名单的 1 行会被禁用")

	// 逐行校验状态。
	for i := range rows {
		p, err := m.FindOne(ctx, ids[i])
		require.NoError(t, err)
		switch i {
		case 0:
			assert.Equal(t, int64(1), p.Status, "白名单内 status=1 必须保留为 1")
		case 1:
			assert.Equal(t, int64(2), p.Status, "不在白名单 status=1 必须变 2")
		case 2:
			assert.Equal(t, int64(2), p.Status, "已是 2 的行继续 2")
		case 3:
			assert.Equal(t, int64(99), p.Status,
				"status=99 不得被 SQL 触及。若变成 2，说明 WHERE 里的 `status=?` 被误写成 `status!=2`")
		}
	}
}