package {{.tableName}}Dao

import (
	"dsBaseRpc/RpcService/{{.tableName}}/{{.tableName}}Proto"
	"dsBaseRpc/Utils/SqlKit"
	"dsBaseRpc/Utils/CommonUtil"
	"dsBaseRpc/Utils/DbUtil"
	"dsBaseRpc/models"
	"github.com/xormplus/builder"
)

var db = DbUtil.Engine

//增加
func Add{{.tableName}}(model models.T{{.tableName}})  (int64, error) {
	return db.Insert(model)
}


//修改
func Update{{.tableName}}(model models.T{{.tableName}},ForceUpdateFields []string)  (int64, error) {
	//1、清除Redis缓存
    var ids = []string{model.{{.pkView}}}
    var selector = SqlKit.GetBean("{{.realTableName}}")
    SqlKit.DeleteCacheByIds(ids, selector)
    //2、计算本次操作，有哪些字段需要更新
    NeedUpdateFields := CommonUtil.GetNeedUpdateFields(model)
    //3、合并强制更新的字段
    ForceUpdateFields = append(ForceUpdateFields, NeedUpdateFields...)
    //4、去重
    ForceUpdateFields = CommonUtil.RemoveDuplicatesAndEmpty(ForceUpdateFields)

    //更改排序号
    //（1）权限排序号的范围是parent_id
    var myBuilder = builder.Dialect(builder.MYSQL).Select("{{.pk}}").From("{{.realTableName}}")
    myBuilder.ToBoundSQL()

    //(2)查询获取到parent_id
    var m1 models.T{{.tableName}}
    db.ID(model.{{.pkView}}).Get(&m1)

    //5、更新操作,强制更新这些列
    affected, err := db.ID(model.{{.pkView}}).Cols(ForceUpdateFields...).Update(model)
    return affected, err
}

//分页查询
func Page{{.tableName}}(in *{{.tableName}}Proto.QueryArg)([]map[string]interface{}, int32, error)  {
	//接收传入参数
   	var limit = int(in.Limit)
   	var offset = int((in.Page - 1) * in.Limit)

	var myBuilder = builder.Dialect(builder.MYSQL).Select("{{.pk}}").From("{{.realTableName}}")
	//myBuilder.Where(builder.Eq{"master_code": in.AreaCode})

	//获取拼接完成的SQL语句
	sql, _ := myBuilder.OrderBy("{{.pk}} asc").ToBoundSQL()
    //分页
	myBuilder.Limit(limit, offset)

	list, count, err := SqlKit.PagePkSql(sql)
	return  list,count, err
}