everlight.eap/backend/UFP/DllUfpDal/RoleDal.cs

using System;
using System.Collections.Generic;
using System.Text;
using Cksoft.Data;
using DllUfpEntity;
using System.Linq;

namespace DllUfpDal
{
    public class RoleDal
    {
        private IDatabase CurrDb;
        public RoleDal(IDatabase db)
        {
            this.CurrDb = db;
        }

        public IEnumerable<Role> Get(int start, int length, string order, string sort, string filter, string errorinfo)
        {
            var roles = CurrDb.FindListForCondition<Role>($" {filter} order by {sort} {order} limit {start - 1},{length}", ref errorinfo);
            return roles;
        }

        public int GetCount(string filter)
        {
            string sql = $"select count(1) from Role a where 1=1 {filter}";
            return Convert.ToInt32(CurrDb.FindList<string>(sql).FirstOrDefault() ?? "0");
        }

        public Role Get(string id)
        {
            return CurrDb.FindEntityFor<Role>(id);
        }

        /// <summary>
        /// 添加角色并返回角色Id
        /// </summary>
        /// <param name="role"></param>
        /// <param name="userCode"></param>
        /// <returns></returns>
        public int Add(Role role, string userCode)
        {
            role.RecCode = role.ModCode = userCode;
            role.RecTime = role.ModTime = DateTime.Now;
            string sql = $"insert into Role (FCode,FName,Remark,RecCode,RecTime,ModCode,ModTime,SystemId) " +
                $"values ('{role.FCode}','{role.FName}','{role.Remark}','{role.RecCode}','{role.RecTime.ToString("yyyy-MM-dd")}','{role.ModCode}','{role.ModTime.ToString("yyyy-MM-dd")}','{role.SystemId}');";
            sql += "select @@identity;";
            var id = Convert.ToInt32(CurrDb.FindList<string>(sql).FirstOrDefault() ?? "-1");
            return id;
        }

        public int Update(Role role, string userCode)
        {
            return CurrDb.UpdateFor(role, userCode);
        }
        public IEnumerable<StaffRole> getStaffRole(int id)
        {
            string sql = $"select * from StaffRole where RoleId='{id}'";
            return CurrDb.FindList<StaffRole>(sql);
        }
        public IEnumerable<RoleFunc> getRoleFunc(int id)
        {
            string sql = $"select * from RoleFunc where RoleId='{id}'";
            return CurrDb.FindList<RoleFunc>(sql);
        }
        public int Delete(int id, ref string msg)
        {
            string sql = $"delete from StaffRole where RoleId='{id}'";
            var res = CurrDb.ExecuteBySql(sql);
            if (res < 0)
            {
                msg = "删除用户角色时失败";
                return -1;
            }
            sql = $"delete from RoleFunc where RoleId='{id}'";
            res = CurrDb.ExecuteBySql(sql);
            if (res < 0)
            {
                msg = "删除角色功能时失败";
                return -1;
            }
            res = CurrDb.DeleteFor<Role>(id);
            if (res < 0)
            {
                msg = "删除角色主表时失败";
                return -1;
            }
            return 1;
        }
    }
}