/**
功能：{{.description}}
作者：{{.authorName}}
时间：{{.CurrentTime}}
*/

//操作数据库的变量
var db = DbUtil.Engine

{{if .ModelArg}}
func {{.interfaceName}}(in *{{.tableName}}Proto.ModelArg)(int64, error) {
	return db.Insert(model)

    //1、清除Redis缓存
    //var ids = []string{model.OrgId}
    //var selector = CacheUtil.GetBean("t_base_organization")
    //CacheUtil.DeleteCacheByIds(ids, selector)

    //2、计算本次操作，有哪些字段需要更新
    //NeedUpdateFields := CommonUtil.GetNeedUpdateFields(model)

    //3、合并强制更新的字段
    //ForceUpdateFields = append(ForceUpdateFields, NeedUpdateFields...)

    //4、去重
    //ForceUpdateFields = CommonUtil.RemoveDuplicatesAndEmpty(ForceUpdateFields)

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

{{if .QueryArg}}
func {{.interfaceName}}(in *{{.tableName}}Proto.QueryArg) ([]map[string]interface{}, int32, error){
	var myBuilder = builder.Dialect(builder.MYSQL).Select("org_id").From("t_base_organization")
    areaCode := in.AreaCode
    if strings.HasSuffix(areaCode, "00") { //市
        myBuilder = myBuilder.Where(builder.Eq{"city_code": areaCode})
    } else { //区
        myBuilder = myBuilder.Where(builder.Eq{"district_code": areaCode})
    }
    //是全部，还是要启用，禁用的？
    if in.BUse != 0 {
        myBuilder = myBuilder.Where(builder.Eq{"b_use": in.BUse})
    }
    //是哪个单位类型的
    if in.OrgType != 0 {
        myBuilder = myBuilder.Where(builder.Eq{"org_type": in.OrgType})
    }
    //学校办学类型 0为查询全部
    if in.Xxbxlxm != "0" {
        myBuilder = myBuilder.Where(builder.Eq{"xxbxlxm": in.Xxbxlxm})
    }
    //关键字查询
    sql, _ := myBuilder.Where(builder.Like{"org_name", in.OrgName}).OrderBy("sort_id asc").ToBoundSQL()
    //通过SQL获取带缓存的数据
    list, count, err := CacheUtil.Page(sql, in.Limit, (in.Page-1)*in.Limit)
    return list, count, err
}
{{end}}