mp-ap/Areas/Api/Controllers/v1/Pos/OrdersController.cs

using System;
using System.Collections.Generic;
using System.Linq;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Microsoft.AspNetCore.Authorization;
using System.Web;
using MySystem.Models;
using MySystem.MainModels;
using LitJson;
using Library;

namespace MySystem.Areas.Api.Controllers.v1.pos
{
    [Area("Api")]
    [Route("Api/v1/pos/[controller]/[action]")]
    public class OrdersController : BaseController
    {
        public OrdersController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
        {
        }


        
        #region 商城-确认订单
        [Authorize]
        public JsonResult ConfirmOrder(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            AppResultJson result = ConfirmOrderDo(value);
            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
        }
        public AppResultJson ConfirmOrderDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客
            int StoreId = int.Parse(function.CheckInt(data["StoreId"].ToString())); //仓库
            int DeliveryType = int.Parse(function.CheckInt(data["DeliveryType"].ToString())); //提货类型
            string Remark = data["Remark"].ToString(); //订单备注
            int AddressId = int.Parse(function.CheckInt(data["AddressId"].ToString()));  //收货地址Id
            JsonData ProductJson = data["ProductJson"]; //商品信息
            Dictionary<string, object> Obj = new Dictionary<string, object>();
            string OrderNo = "BM61" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
            UserAddress address = UserAddressDbconn.Instance.Get(AddressId) ?? new UserAddress();
            StoreHouse store = StoreHouseDbconn.Instance.Get(StoreId) ?? new StoreHouse();
            Users storeUser = UsersDbconn.Instance.Get(store.ManageUserId) ?? new Users();
            Users user = UsersDbconn.Instance.Get(UserId) ?? new Users();
            int TopUserId = PublicFunction.GetTopUserId(user.ParentNav);
            decimal TotalPrice = 0; //订单总额
            Orders query = maindb.Orders.Add(new Orders()
            {
                OrderNo = OrderNo,
                RealName = address.RealName,
                Mobile = address.Mobile,
                Areas = address.Areas,
                Address = address.Address,
                StoreContact = storeUser.RealName,
                StoreContactMobile = store.ManageMobile,
                StoreUserId = store.UserId,
                StoreType = store.StoreType,
                CreateDate = DateTime.Now, //创建时间
                UserId = UserId, //创客
                StoreId = StoreId, //仓库
                TopUserId = TopUserId, //顶级创客
                DeliveryType = DeliveryType, //提货类型
                BuyCount = 0,
                TotalPrice = TotalPrice, //订单总额
                Remark = Remark, //订单备注
            }).Entity;
            maindb.SaveChanges();
            for (int i = 0; i < ProductJson.Count; i++)
            {
                JsonData item = ProductJson[i];
                int ProductId = int.Parse(function.CheckInt(item["ProductId"].ToString()));
                int NormId = int.Parse(function.CheckInt(item["NormId"].ToString()));
                int BuyCount = int.Parse(function.CheckInt(item["BuyCount"].ToString()));
                Products product = ProductsDbconn.Instance.Get(ProductId) ?? new Products();
                ProductNorm norm = ProductNormDbconn.Instance.Get(NormId) ?? new ProductNorm();
                OrderProduct pro = maindb.OrderProduct.Add(new OrderProduct()
                {
                    CreateDate = DateTime.Now, //创建时间
                    OrderId = query.Id,
                    ProductId = ProductId,
                    ProductCount = BuyCount,
                    NormId = NormId.ToString(),
                    NormDetail = norm.ColName,
                    ProductPrice = norm.Price,
                    TotalPrice = norm.Price * BuyCount,
                    ProductCode = product.ProductCode,
                    UserId = UserId,
                    StoreId = StoreId,
                }).Entity;
                TotalPrice += norm.Price * BuyCount;
            }
            query.TotalPrice = TotalPrice;
            maindb.SaveChanges();
            Obj.Add("Id", query.Id); //Id
            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
        }
        #endregion

        #region 首页-客小爽产品-机具管理-机具申请-要兑换的机具
        [Authorize]
        public JsonResult ExchangeMachines(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            Dictionary<string, object> Other = new Dictionary<string, object>();
            List<Dictionary<string, object>> dataList = ExchangeMachinesDo(value, out Other);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList, Other = Other });
        }
        public List<Dictionary<string, object>> ExchangeMachinesDo(string value, out Dictionary<string, object> Other)
        {
            JsonData data = JsonMapper.ToObject(value);
            int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客
            int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString()));
            int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString()));
            int ProductType = int.Parse(function.CheckInt(data["ProductType"].ToString()));
            DateTime now = DateTime.Now;
            List<Dictionary<string, object>> dataList = new List<Dictionary<string, object>>();
            IQueryable<PosMachinesTwo> query = maindb.PosMachinesTwo.Where(m => m.Status > -1 && m.BuyUserId == UserId && m.BrandId == ProductType && m.IsPurchase == 0);
            int ExpiredCount = query.Count(m => m.RecycEndDate < now);
            int ActCount = query.Count(m => m.ActivationState == 1);
            query = query.Where(m => m.RecycEndDate >= now && m.ActivationState == 1);
            if (PageNum == 1)
            {
                query = query.Take(PageSize);
            }
            else
            {
                int skipNum = PageSize * (PageNum - 1);
                query = query.Skip(skipNum).Take(PageSize);
            }
            foreach (var subdata in query.ToList())
            {
                Dictionary<string, object> curData = new Dictionary<string, object>();
                curData.Add("SnId", subdata.Id); //机具Id
                curData.Add("SnNo", subdata.PosSn); //SN号
                curData.Add("MachineType", RelationClass.GetPosSnTypeInfo(subdata.PosSnType)); //机具类型
                int day = 0;
                if (subdata.RecycEndDate != null)
                {
                    TimeSpan ts = subdata.RecycEndDate.Value - DateTime.Now;
                    day = ts.Days;
                }
                curData.Add("RecycDays", day); //循环剩余天数
                curData.Add("EndDate", subdata.RecycEndDate == null ? "" : subdata.RecycEndDate.Value.ToString("yyyy-MM-dd")); //截止日期
                List<KqProducts> pros = KqProductsDbconn.Instance.GetList();
                string BrandIdString = "";
                foreach (KqProducts pro in pros)
                {
                    BrandIdString += pro.Name.Substring(0, 1) + "=" + pro.Id + ",";
                }
                curData.Add("ProductType", BrandIdString.TrimEnd(',')); //产品类型 // TODO:数据需要组合，格式：大=1,签=2,超=3
                dataList.Add(curData);
            }
            Other = new Dictionary<string, object>();
            Other.Add("ActCount", ActCount); //激活数
            Other.Add("ExpiredCount", ExpiredCount); //过期数
            Other.Add("MinCount", 1); //最少领取数
            return dataList;
        }
        #endregion
        
        #region 首页-客小爽产品-机具管理-机具申请-要兑换的机具-V2
        [Authorize]
        public JsonResult ExchangeMachines2(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            Dictionary<string, object> Other = new Dictionary<string, object>();
            List<Dictionary<string, object>> dataList = ExchangeMachines2Do(value, out Other);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList, Other = Other });
        }
        public List<Dictionary<string, object>> ExchangeMachines2Do(string value, out Dictionary<string, object> Other)
        {
            JsonData data = JsonMapper.ToObject(value);
            int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客
            int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString()));
            int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString()));
            int ProductType = int.Parse(function.CheckInt(data["ProductType"].ToString()));
            DateTime now = DateTime.Now;
            List<Dictionary<string, object>> dataList = new List<Dictionary<string, object>>();
            IQueryable<PosMachinesTwo> query = maindb.PosMachinesTwo.Where(m => m.Status > -1 && m.BuyUserId == UserId && m.BrandId == ProductType && m.IsPurchase == 0);
            int ExpiredCount = query.Count(m => m.RecycEndDate < now);
            int ActCount = query.Count(m => m.ActivationState == 1);
            query = query.Where(m => m.RecycEndDate >= now && (m.ActivationState == 1 || (!string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0")));
            if (PageNum == 1)
            {
                query = query.Take(PageSize);
            }
            else
            {
                int skipNum = PageSize * (PageNum - 1);
                query = query.Skip(skipNum).Take(PageSize);
            }
            foreach (var subdata in query.ToList())
            {
                Dictionary<string, object> curData = new Dictionary<string, object>();
                int IsLeader = 0;//是否为大盟主机(0-否 1-是)
                if (subdata.LeaderUserId > 0)
                {
                    IsLeader = 1;
                }
                else
                {
                    IsLeader = 0;
                }
                curData.Add("SnId", subdata.Id); //机具Id
                curData.Add("SnNo", subdata.PosSn); //SN号
                curData.Add("MachineType", RelationClass.GetPosSnTypeInfo(subdata.PosSnType)); //机具类型
                int day = 0;
                if (subdata.RecycEndDate != null)
                {
                    TimeSpan ts = subdata.RecycEndDate.Value - DateTime.Now;
                    day = ts.Days;
                }
                curData.Add("RecycDays", day); //循环剩余天数
                curData.Add("EndDate", subdata.RecycEndDate == null ? "" : subdata.RecycEndDate.Value.ToString("yyyy-MM-dd")); //截止日期
                // List<KqProducts> pros = KqProductsDbconn.Instance.GetList();
                List<int> BrandIds = new List<int>();
                // foreach (KqProducts pro in pros)
                // {
                //     BrandIds.Add(pro.Id);
                // }
                if (ProductType == 1 || ProductType == 2 || ProductType == 4 || ProductType == 6 || ProductType == 7 || ProductType == 8 || ProductType == 10)
                { 
                    BrandIds.Add(1);
                    BrandIds.Add(2);
                    BrandIds.Add(4);
                    BrandIds.Add(6);
                    BrandIds.Add(7);
                    BrandIds.Add(8);
                    BrandIds.Add(10);
                }
                else
                { 
                    BrandIds.Add(3);
                    BrandIds.Add(5);
                    BrandIds.Add(9);
                    BrandIds.Add(11);
                }
                curData.Add("ProductType", BrandIds); //产品类型 // TODO:数据需要组合，格式：大=1,签=2,超=3
                curData.Add("IsLeader",IsLeader);
                dataList.Add(curData);
            }
            Other = new Dictionary<string, object>();
            Other.Add("ActCount", ActCount); //激活数
            Other.Add("ExpiredCount", ExpiredCount); //过期数
            Other.Add("MinCount", 1); //最少领取数
            return dataList;
        }
        #endregion




        #region 首页-仓库管理-订单列表
        [Authorize]
        public JsonResult StoreOrderList(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            List<Dictionary<string, object>> dataList = StoreOrderListDo(value);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList });
        }
        public List<Dictionary<string, object>> StoreOrderListDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            string SearchKey = data["SearchKey"].ToString(); //手机号
            int StoreId = int.Parse(function.CheckInt(data["StoreId"].ToString())); //仓库
            int Status = int.Parse(function.CheckInt(data["Status"].ToString())); //订单状态
            string StartDate = data["StartDate"].ToString(); //下单开始时间
            string EndDate = data["EndDate"].ToString(); //下单结束时间
            int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString()));
            int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString()));
            List<Dictionary<string, object>> dataList = new List<Dictionary<string, object>>();
            List<StoreOrders> query = RedisDbconn.Instance.GetList<StoreOrders>("StoreOrders:" + StoreId, 1, 100000);
            if (!string.IsNullOrEmpty(SearchKey))
            {
                query = query.Where(m => m.RealName == SearchKey || m.Mobile == SearchKey).ToList();
            }
            if (!string.IsNullOrEmpty(StartDate))
            {
                DateTime time = DateTime.Parse(StartDate.Substring(0, 4) + "-" + StartDate.Substring(4, 2) + "-" + StartDate.Substring(6, 2) + " 00:00:00");
                query = query.Where(m => m.CreateDate >= time).ToList();
            }
            if (!string.IsNullOrEmpty(EndDate))
            {
                DateTime time = DateTime.Parse(EndDate.Substring(0, 4) + "-" + EndDate.Substring(4, 2) + "-" + EndDate.Substring(6, 2) + " 23:59:59");
                query = query.Where(m => m.CreateDate <= time).ToList();
            }
            if (Status > 0)
            { 
                if(Status == 2) Status = 0;
                query = query.Where(m => m.SendStatus == Status).ToList();
            }
            if (PageNum == 1)
            {
                query = query.Take(PageSize).ToList();
            }
            else
            {
                int skipNum = PageSize * (PageNum - 1);
                query = query.Skip(skipNum).Take(PageSize).ToList();
            }
            foreach (var item in query)
            {
                Orders subdata = OrdersDbconn.Instance.Get(item.Id) ?? new Orders();
                Dictionary<string, object> curData = new Dictionary<string, object>();
                curData.Add("OrderNo", subdata.OrderNo); //订单号
                curData.Add("RealName", subdata.RealName); //姓名
                curData.Add("Mobile", subdata.Mobile); //手机号
                curData.Add("Areas", subdata.Areas); //所在地区
                curData.Add("Address", subdata.Address); //详细地址
                curData.Add("DeliveryType", subdata.DeliveryType); //提货类型
                curData.Add("BuyCount", subdata.BuyCount); //下单数量
                curData.Add("SnNos", subdata.SnNos); //SN编号
                curData.Add("Id", subdata.Id); //Id
                curData.Add("CreateDate", subdata.CreateDate == null ? "" : subdata.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss")); //CreateDate
                Products pro = ProductsDbconn.Instance.Get(subdata.ProductId) ?? new Products();
                curData.Add("ProductName", pro.ProductName); //商品名称
                Users user = UsersDbconn.Instance.Get(subdata.UserId) ?? new Users();
                curData.Add("OrderRealName", user.RealName); //下单人姓名
                curData.Add("OrderMakerCode", user.MakerCode); //下单人编号
                curData.Add("OrderKind", subdata.Sort > 0 ? "机具申请" : "商城购买"); //订单类型
                curData.Add("SendStatus", item.SendStatus);
                dataList.Add(curData);
            }
            return dataList;
        }
        #endregion

        #region 首页-仓库管理-订单详情
        [Authorize]
        public JsonResult StoreOrderDetail(string value)
        {
            value = DesDecrypt(value);
            JsonData data = JsonMapper.ToObject(value);
            Dictionary<string, object> Obj = StoreOrderDetailDo(value);
            return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj });
        }
        public Dictionary<string, object> StoreOrderDetailDo(string value)
        {
            JsonData data = JsonMapper.ToObject(value);
            int Id = int.Parse(function.CheckInt(data["Id"].ToString()));
            Dictionary<string, object> Obj = new Dictionary<string, object>();
            Orders query = OrdersDbconn.Instance.Get(Id) ?? new Orders();
            Obj.Add("UserId", RelationClass.GetUsersInfo(query.UserId)); //创客
            Obj.Add("RealName", query.RealName); //姓名
            Obj.Add("Mobile", query.Mobile); //手机号
            Obj.Add("Areas", function.CheckNull(query.Areas).Replace(",", "")); //所在地区
            Obj.Add("Address", query.Address); //详细地址
            Obj.Add("DeliveryType", query.DeliveryType); //提货类型
            Obj.Add("BuyCount", query.BuyCount); //下单数量
            Obj.Add("SnNos", query.SnNos); //SN编号
            Obj.Add("CreateDate", query.CreateDate == null ? "" : query.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss")); //CreateDate
            Products pro = RedisDbconn.Instance.Get<Products>("Products:" + query.ProductId) ?? new Products();
            Obj.Add("ProductName", pro.ProductName); //商品名称
            return Obj;
        }
        #endregion



        #region 检查签名是否合法，合法返回1，不合法返回提示信息

        /// <summary>
        /// 检查签名是否合法，合法返回1，不合法返回提示信息
        /// </summary>
        /// <param name="value">请求的参数(json字符串)</param>
        /// <param name="signField">要签名的字段</param>
        /// <returns></returns>
        private string CheckSign(string value, string[] signField)
        {
            JsonData json = JsonMapper.ToObject(value);
            Dictionary<string, string> dic = new Dictionary<string, string>();
            for (int i = 0; i < signField.Length; i++)
            {
                dic.Add(signField[i], json[signField[i]].ToString());
            }
            string sign = json["sign"].ToString(); //客户端签名字符串
            return new Sign().sign(dic, sign);
        }

        #endregion

    }
}