commit

dsBaseRpc/RpcService/BaseRoleMenu/BaseRoleMenuDao/BaseRoleMenuDao.go

@@ -1,8 +1,11 @@
 package BaseRoleMenuDao
 
 import (
+	"dsBaseRpc/RpcService/BaseRoleMenu/BaseRoleMenuProto"
 	"dsBaseRpc/Utils/DbUtil"
+	"dsBaseRpc/Utils/SqlKit"
 	"dsBaseRpc/models"
+	"github.com/xormplus/builder"
 )
 
 var db = DbUtil.Engine
@@ -10,3 +13,19 @@ var db = DbUtil.Engine
 func SetBaseRoleMenuCorr(ms []models.TBaseRoleMenu) (int64, error) {
 	return db.Insert(ms)
 }
+
+//分页查询
+func GetBaseRoleMenuCorr(in *BaseRoleMenuProto.GetCorrArg) ([]map[string]interface{}, int32, error) {
+	//接收传入参数
+	var myBuilder = builder.Dialect(builder.MYSQL).Select("t1.*").From("t_base_role_menu as t1")
+	myBuilder.And(builder.Eq{"t1.role_id": in.RoleId})
+	myBuilder.And(builder.Eq{"t1.b_use": 1})
+	//获取拼接完成的SQL语句
+	sql, err := myBuilder.ToBoundSQL()
+	if err != nil {
+		return nil, 0, err
+	}
+	//调用多查询字段通用方法
+	list, count, err := SqlKit.Query(sql)
+	return list, count, err
+}

dsBaseRpc/RpcService/BaseRoleMenu/BaseRoleMenuService/BaseRoleMenuService.go

@@ -22,10 +22,20 @@ func (s *Rpc) GetBaseRoleMenuCorr(ctx context.Context, in *BaseRoleMenuProto.Get
 			fmt.Printf("%s\n", err)
 		}
 	}()
-
-	//in.RoleId--->哪些菜单？
 	//rpc响应
 	var reply BaseRoleMenuProto.Reply
+	list, count, err := BaseRoleMenuDao.GetBaseRoleMenuCorr(in)
+	//错误处理
+	if err != nil {
+		reply.Success = false
+		reply.Message = Const.DataBaseActionError
+		LogUtil.Error(ErrorConst.SqlQueryError, "执行GetBaseRoleMenuCorr时发生严重错误："+err.Error())
+		return &reply, err
+	}
+	reply.Count = count
+	reply.Success = true
+	reply.Message = Const.SuccessDataBaseAction
+	reply.List = CommonUtil.SerializeToString(list)
 	return &reply, nil
 }