kxs-admin/Areas/Admin/Controllers/OperateServer/SysAdminOperateController.cs

/*
 * 运营中心
 */

using System;
using System.Web;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using MySystem.OpModels;
using Library;
using LitJson;
using MySystemLib;

namespace MySystem.Areas.Admin.Controllers
{
    [Area("Admin")]
    [Route("Admin/[controller]/[action]")]
    public class SysAdminOperateController : BaseController
    {
        public SysAdminOperateController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
        {
            OtherMySqlConn.connstr = ConfigurationManager.AppSettings["OpSqlConnStr"].ToString();
        }

        #region 运营中心列表

        /// <summary>
        /// 根据条件查询运营中心列表
        /// </summary>
        /// <returns></returns>
        public IActionResult Index(SysAdmin data, string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;


            string Condition = "";
            Condition += "AdminName:\"" + data.AdminName + "\",";
            Condition += "RealName:\"" + data.RealName + "\",";
            Condition += "Role:\"" + data.Role + "\",";

            if (!string.IsNullOrEmpty(Condition))
            {
                Condition = Condition.TrimEnd(',');
                Condition = ", where: {" + Condition + "}";
            }
            ViewBag.Condition = Condition;
            return View();
        }

        #endregion

        #region 根据条件查询运营中心列表

        /// <summary>
        /// 运营中心列表
        /// </summary>
        /// <returns></returns>
        public JsonResult IndexData(SysAdmin data, string OpCode, string RealName, string CreateDateData, int page = 1, int limit = 30)
        {

            Dictionary<string, string> Fields = new Dictionary<string, string>();

            Fields.Add("RealName", "2"); //名称

            string condition = " and Status>-1";
            //运营中心编号
            if (!string.IsNullOrEmpty(OpCode))
            {
                condition += " and Id in (select OpId from OperateForCode where OpCode='" + OpCode + "')";
            }
            // //运营中心名称
            // if (!string.IsNullOrEmpty(RealName))
            // {
            //     condition += " and UserId in (select UserId from UserForRealName where RealName='" + RealName + "')";
            // }
            //创建时间
            if (!string.IsNullOrEmpty(CreateDateData))
            {
                string[] datelist = CreateDateData.Split(new string[] { " - " }, StringSplitOptions.None);
                string start = datelist[0];
                string end = datelist[1];
                condition += " and CreateDate>='" + start + " 00:00:00' and CreateDate<='" + end + " 23:59:59'";
            }

            Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).IndexData("SysAdmin", Fields, "Id desc", "0", page, limit, condition);
            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
            foreach (Dictionary<string, object> dic in diclist)
            {
                //所属人信息
                int Id = int.Parse(dic["Id"].ToString());
                SysAdmin sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
                dic["MakerCode"] = sysAdmin.MakerCode;
                dic["MakerName"] = sysAdmin.MakerName;

                //实缴额度
                UserAccount userAccount = opdb.UserAccount.FirstOrDefault(m => m.UserId == Id) ?? new UserAccount();
                dic["TotalAmt"] = userAccount.TotalAmt;

                //当前额度
                dic["ValidAmount"] = userAccount.ValidAmount;

                //已提现金额
                dic["WithdrawAmount"] = userAccount.WithdrawAmount;

                //提现中金额
                dic["WithdrawingAmount"] = userAccount.WithdrawingAmount;

                //分仓数量 StoreForOperate
                // dic["StoreCount"] = opdb.StoreForOperate.Where(m => m.OpId == Id).Count();

            }
            return Json(obj);
        }

        #endregion

        #region 增加运营中心

        /// <summary>
        /// 增加或修改运营中心信息
        /// </summary>
        /// <returns></returns>
        public IActionResult Add(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;


            return View();
        }

        #endregion

        #region 增加运营中心

        /// <summary>
        /// 增加或修改运营中心信息
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public string Add(SysAdmin data, UserAccount userAccount, string Areas, string Address)
        {
            Dictionary<string, object> Fields = new Dictionary<string, object>();
            Dictionary<string, object> Field = new Dictionary<string, object>();

            // Models.WebCMSEntities db = new Models.WebCMSEntities();
            var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == data.MakerCode) ?? new Models.UserForMakerCode();
            if (userForMakerCode.UserId > 0)
            {
                var userInfo = db.Users.FirstOrDefault(m => m.Id == userForMakerCode.UserId && m.Mobile == data.MakerMobile) ?? new Models.Users();
                if (userInfo.Id > 0)
                {
                    var check = opdb.SysAdmin.Any(m => m.AdminName == data.AdminName);
                    var checks = opdb.SysAdmin.Any(m => m.UserId == userInfo.Id);
                    if (check)
                    {
                        return "该用户名已存在，请重新输入";
                    }
                    if (checks)
                    {
                        return "该用户已存在运营中心，请重新输入";
                    }
                    Fields.Add("RealName", data.RealName); //运营中心名称
                    Fields.Add("MakerCode", data.MakerCode); //创客编号
                    Fields.Add("MakerMobile", data.MakerMobile); //手机号
                    Fields.Add("UserId", userInfo.Id); //创客Id
                    Fields.Add("MakerName", userInfo.RealName); //创客真实姓名
                    Fields.Add("AdminName", data.AdminName); //用户名
                    Fields.Add("Password", function.MD5_32(data.Password)); //密码
                    Fields.Add("FilePath", data.FilePath); //附件

                    int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Add("SysAdmin", Fields, 0);
                    SysAdmin edit = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id);
                    string No = Id.ToString();
                    for (int i = 0; i < 7 - Id.ToString().Length; i++)
                    {
                        No = "0" + No;
                    }
                    No = "YZ" + No;
                    edit.OpCode = No;
                    edit.QueryCount = Id;
                    AddSysLog(data.Id.ToString(), "SysAdmin", "add");
                    opdb.SaveChanges();

                    var info = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id);
                    if (info != null)
                    {
                        Field.Add("TotalAmt", userAccount.TotalAmt); //初始额度
                        Field.Add("ValidAmount", userAccount.TotalAmt); //可用额度
                        Field.Add("UserId", Id); //运营中心Id
                        int Ids = new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Add("UserAccount", Field, 0);
                        AddSysLog(userAccount.Id.ToString(), "UserAccount", "add");
                        opdb.SaveChanges();
                    }
                    userInfo.UserType = 1;//设置创客为运营中心
                    db.SaveChanges();

                    var kqProduct = db.KqProducts.ToList();
                    foreach (var item in kqProduct)
                    {
                        string Nos = "YC000" + item.Id + info.Id;
                        var query = db.StoreHouse.Add(new Models.StoreHouse()
                        {
                            CreateDate = DateTime.Now, //创建时间
                            CreateMan = SysUserName,
                            ManageMobile = data.MakerMobile, //手机号
                            UserId = info.UserId, //运营中心创客Id
                            Address = Address,//仓库地址
                            Areas = Areas,//所属地区
                            ManageUserId = info.UserId,//仓库管理员
                            StoreName = item.Name + "运营分仓", //仓库名称
                            StoreNo = Nos, //仓库编号
                            Sort = info.Id,//运营中心Id
                            Status = 1,
                            BrandId = item.Id.ToString(),

                        }).Entity;
                        db.SaveChanges();
                    }
                }
                else
                {
                    return "创客编号和手机号不匹配";
                }
            }

            return "success";
        }

        #endregion

        #region 修改运营中心

        /// <summary>
        /// 增加或修改运营中心信息
        /// </summary>
        /// <returns></returns>
        public IActionResult Edit(string right, int Id = 0)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;


            SysAdmin editData = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
            UserAccount editDatas = opdb.UserAccount.FirstOrDefault(m => m.UserId == Id) ?? new UserAccount();
            ViewBag.data = editData;
            ViewBag.datas = editDatas;
            return View();
        }

        #endregion

        #region 修改运营中心

        /// <summary>
        /// 增加或修改运营中心信息
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public string Edit(SysAdmin data, UserAccount userAccount, string Areas, string Address)
        {
            Dictionary<string, object> Fields = new Dictionary<string, object>();
            Dictionary<string, object> Field = new Dictionary<string, object>();

            Models.WebCMSEntities db = new Models.WebCMSEntities();
            var userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == data.MakerCode) ?? new Models.UserForMakerCode();
            if (userForMakerCode.UserId > 0)
            {
                var userInfo = db.Users.FirstOrDefault(m => m.Id == userForMakerCode.UserId && m.Mobile == data.MakerMobile) ?? new Models.Users();
                if (userInfo.Id > 0)
                {
                    Fields.Add("RealName", data.RealName); //运营中心名称
                    Fields.Add("MakerCode", data.MakerCode); //创客编号
                    Fields.Add("MakerMobile", data.MakerMobile); //手机号
                    Fields.Add("AdminName", data.AdminName); //用户名
                    Fields.Add("UserId", userInfo.Id); //创客Id
                    Fields.Add("MakerName", userInfo.RealName); //创客真实姓名
                    if (!string.IsNullOrEmpty(data.Password)) //密码不为空就修改密码，否则不操作
                    {
                        Fields.Add("Password", function.MD5_32(data.Password)); //密码
                    }
                    Fields.Add("FilePath", data.FilePath); //附件
                    Field.Add("TotalAmt", userAccount.TotalAmt); //初始额度
                    Field.Add("ValidAmount", userAccount.TotalAmt); //可用额度
                    Field.Add("UserId", data.Id); //运营中心Id

                    var suser = opdb.SysAdmin.FirstOrDefault(m => m.Id == data.Id);
                    var user = db.Users.FirstOrDefault(m => m.Id == suser.UserId) ?? new Models.Users();
                    if (user.Id > 0)
                    {
                        user.UserType = 0;//取消运营中心标记
                        var storeHouse = db.StoreHouse.Where(m => m.Sort == data.Id && m.Status == 1).ToList();
                        foreach (var item in storeHouse)
                        {
                            var list = db.StoreHouse.FirstOrDefault(m => m.Sort == item.Sort && m.Status == 1 && m.UserId == user.Id) ?? new Models.StoreHouse();
                            if (list.Id > 0)
                            {
                                list.UserId = userInfo.Id;
                                list.ManageUserId = userInfo.Id;
                                list.ManageMobile = userInfo.Mobile;
                                list.UpdateDate = DateTime.Now;
                                list.UpdateMan = SysUserName + "-" + SysRealName;
                                db.SaveChanges();
                            }
                        }
                        db.SaveChanges();
                    }
                    new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Edit("SysAdmin", Fields, data.Id);
                    SysAdmin edit = opdb.SysAdmin.FirstOrDefault(m => m.Id == data.Id);
                    edit.CreateDate = edit.CreateDate;
                    AddSysLog(data.Id.ToString(), "SysAdmin", "update");
                    opdb.SaveChanges();
                    new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Edit("UserAccount", Field, userAccount.Id);
                    UserAccount edits = opdb.UserAccount.FirstOrDefault(m => m.UserId == data.Id);
                    edits.CreateDate = edits.CreateDate;
                    AddSysLog(userAccount.Id.ToString(), "UserAccount", "update");
                    opdb.SaveChanges();

                    userInfo.UserType = 1;//设置创客为运营中心
                    db.SaveChanges();
                }
                else
                {
                    return "创客编号和手机号不匹配";
                }
            }

            return "success";
        }

        #endregion

        #region 删除运营中心信息

        /// <summary>
        /// 删除运营中心信息
        /// </summary>
        /// <returns></returns>
        public string Delete(string Id)
        {
            string[] idlist = Id.Split(new char[] { ',' });
            AddSysLog(Id, "SysAdmin", "del");
            foreach (string subid in idlist)
            {
                int id = int.Parse(subid);
                var storeHouse = db.StoreHouse.Where(m => m.Sort == id && m.Status == 1).ToList();
                foreach (var item in storeHouse)
                {
                    var list = db.StoreHouse.FirstOrDefault(m => m.Sort == id && m.Status == 1) ?? new Models.StoreHouse();
                    if (list.Id > 0)
                    {
                        list.Status = -1;
                        list.UpdateDate = DateTime.Now;
                        list.UpdateMan = SysUserName + "-" + SysRealName;
                        db.SaveChanges();
                    }
                }
                var sysAdmin = opdb.SysAdmin.FirstOrDefault(m => m.UserId == id) ?? new OpModels.SysAdmin();
                if (sysAdmin.Id > 0)
                {
                    sysAdmin.Status = -1;
                    opdb.SaveChanges();
                }
                Dictionary<string, object> Fields = new Dictionary<string, object>();
                Fields.Add("Status", -1);
                new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Edit("SysAdmin", Fields, id);
            }
            opdb.SaveChanges();

            return "success";
        }

        #endregion

        #region 开启

        /// <summary>
        /// 开启
        /// </summary>
        /// <returns></returns>
        public string Open(string Id)
        {
            string[] idlist = Id.Split(new char[] { ',' });
            AddSysLog(Id, "SysAdmin", "open");
            foreach (string subid in idlist)
            {
                int id = int.Parse(subid);
                Dictionary<string, object> Fields = new Dictionary<string, object>();
                Fields.Add("Status", 1);
                new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Edit("SysAdmin", Fields, id);
            }
            opdb.SaveChanges();
            return "success";
        }

        #endregion

        #region 关闭

        /// <summary>
        /// 关闭
        /// </summary>
        /// <returns></returns>
        public string Close(string Id)
        {
            string[] idlist = Id.Split(new char[] { ',' });
            AddSysLog(Id, "SysAdmin", "close");
            foreach (string subid in idlist)
            {
                int id = int.Parse(subid);
                Dictionary<string, object> Fields = new Dictionary<string, object>();
                Fields.Add("Status", 0);
                new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Edit("SysAdmin", Fields, id);
            }
            opdb.SaveChanges();
            return "success";
        }

        #endregion

        #region 排序
        /// <summary>
        /// 排序
        /// </summary>
        /// <param name="Id"></param>
        public string Sort(int Id, int Sort)
        {
            new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).Sort("SysAdmin", Sort, Id);

            AddSysLog(Id.ToString(), "SysAdmin", "sort");
            return "success";
        }
        #endregion

        #region 导入数据
        /// <summary>
        /// 导入数据
        /// </summary>
        /// <param name="ExcelData"></param>
        public string Import(string ExcelData)
        {
            ExcelData = HttpUtility.UrlDecode(ExcelData);
            JsonData list = JsonMapper.ToObject(ExcelData);
            for (int i = 1; i < list.Count; i++)
            {
                JsonData dr = list[i];

                opdb.SysAdmin.Add(new SysAdmin()
                {
                    CreateDate = DateTime.Now,
                    UpdateDate = DateTime.Now,

                });
                opdb.SaveChanges();
            }
            AddSysLog("0", "SysAdmin", "Import");
            return "success";
        }
        #endregion

        #region 导出Excel

        /// <summary>
        /// 导出Excel
        /// </summary>
        /// <returns></returns>
        public JsonResult ExportExcel(SysAdmin data)
        {
            Dictionary<string, string> Fields = new Dictionary<string, string>();
            Fields.Add("AdminName", "2"); //用户名
            Fields.Add("RealName", "2"); //名称
            Fields.Add("Role", "1"); //角色
            Fields.Add("LastLoginDate", "3"); //最后登录时间

            Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.OpTables).IndexData("SysAdmin", Fields, "Id desc", "0", 1, 20000, "", "", false);
            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
            foreach (Dictionary<string, object> dic in diclist)
            {

            }

            Dictionary<string, object> result = new Dictionary<string, object>();
            result.Add("Status", "1");
            result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
            result.Add("Obj", diclist);
            Dictionary<string, object> ReturnFields = new Dictionary<string, object>();

            result.Add("Fields", ReturnFields);
            AddSysLog("0", "SysAdmin", "ExportExcel");
            return Json(result);
        }

        #endregion


        #region 修改运营中心账户金额

        public IActionResult EditAmt(string right, int Id = 0)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;
            SysAdmin editData = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
            ViewBag.data = editData;
            return View();
        }

        #endregion


        #region 修改运营中心账户金额

        [HttpPost]
        public string EditAmt(SysAdmin data, string OperationAmount, string Note, int Kind)
        {
            int OpId = data.Id;
            var account = opdb.UserAccount.FirstOrDefault(m => m.UserId == OpId);
            //扣减
            if (Kind == 1 && decimal.Parse(OperationAmount) > account.ValidAmount)
            {
                return "账号额度不足";
            }
            int OperateType = 0;
            if (Kind == 1 && decimal.Parse(OperationAmount) <= account.ValidAmount)
            {
                account.ValidAmount -= decimal.Parse(OperationAmount);
                OperateType = 1;//系统扣减
            }
            else if (Kind == 1 && decimal.Parse(OperationAmount) > account.ValidAmount)
            {
                return "扣减金额大于可用额度";
            }
            //增加
            else if (Kind == 2)
            {
                account.ValidAmount += decimal.Parse(OperationAmount);
                OperateType = 2;//系统增加
            }
            AmountRecord amountRecord = opdb.AmountRecord.Add(new AmountRecord()
            {
                CreateDate = DateTime.Now,
                UserId = OpId, //运营中心Id
                CreateMan = SysUserName + "-" + SysRealName,
                UpdateMan = SysUserName + "-" + SysRealName,
                UseAmount = decimal.Parse(OperationAmount),//操作金额
                BeforeAmount = account.ValidAmount,//使用前剩余额度
                AfterAmount = account.ValidAmount + decimal.Parse(OperationAmount),//使用后剩余额度
                OperateType = OperateType,//操作类别
            }).Entity;
            opdb.SaveChanges();
            RedisDbconn.Instance.Set("OpUserAccount:" + OpId, account);
            AddSysLog(data.Id.ToString(), "SysAdmin", "EditAmt");
            opdb.SaveChanges();
            return "success";
        }

        #endregion


        #region 修改账户金额

        public IActionResult EditBalance(string right, int Id = 0)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;
            SysAdmin editData = opdb.SysAdmin.FirstOrDefault(m => m.Id == Id) ?? new SysAdmin();
            ViewBag.data = editData;
            return View();
        }

        #endregion

        #region 修改账户金额

        [HttpPost]
        public string EditBalance(SysAdmin data, string OperationAmount, string Note, int Kind)
        {
            int OpId = data.Id;
            var account = opdb.UserAccount.FirstOrDefault(m => m.UserId == OpId);
            if ((Kind == 1 || Kind == 3) && decimal.Parse(OperationAmount) > account.BalanceAmount)
            {
                return "账号余额不足";
            }
            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
            int ChangeType = 0;
            if (Kind == 1 && decimal.Parse(OperationAmount) <= account.BalanceAmount)
            {
                account.BalanceAmount -= decimal.Parse(OperationAmount);
                account.FreezeAmount += decimal.Parse(OperationAmount);
                ChangeType = 61;
            }
            else if (Kind == 1 && decimal.Parse(OperationAmount) > account.BalanceAmount)
            {
                return "冻结金额大于余额";
            }
            else if (Kind == 2 && decimal.Parse(OperationAmount) <= account.FreezeAmount)
            {
                account.BalanceAmount += decimal.Parse(OperationAmount);
                account.FreezeAmount -= decimal.Parse(OperationAmount);
                ChangeType = 62;
            }
            else if (Kind == 2 && decimal.Parse(OperationAmount) > account.FreezeAmount)
            {
                return "解冻金额大于冻结金额";
            }
            else if (Kind == 3 && decimal.Parse(OperationAmount) <= account.BalanceAmount)
            {
                account.TotalAmount -= decimal.Parse(OperationAmount);
                account.BalanceAmount -= decimal.Parse(OperationAmount);
                ChangeType = 63;
            }
            else if (Kind == 3 && decimal.Parse(OperationAmount) > account.BalanceAmount)
            {
                return "扣减金额大于余额";
            }
            else if (Kind == 4)
            {
                account.TotalAmount += decimal.Parse(OperationAmount);
                account.BalanceAmount += decimal.Parse(OperationAmount);
                ChangeType = 64;
            }
            decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
            decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
            decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
            UserAccountRecord userAccountRecord = opdb.UserAccountRecord.Add(new UserAccountRecord()
            {
                CreateDate = DateTime.Now,
                CreateMan = SysUserName + "-" + SysRealName,
                UpdateMan = SysUserName + "-" + SysRealName,
                UserId = OpId, //运营中心Id
                ChangeType = ChangeType, //变动类型
                ChangeAmount = decimal.Parse(OperationAmount), //变更金额
                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                AfterTotalAmount = AfterTotalAmount, //变更后总金额
                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                Remark = Note,
            }).Entity;
            opdb.SaveChanges();
            RedisDbconn.Instance.Set("OpUserAccount:" + OpId, account);
            AddSysLog(data.Id.ToString(), "SysAdmin", "EditBalance");
            opdb.SaveChanges();
            return "success";
        }

        #endregion

    }
}