kxs-admin/Areas/Admin/Controllers/MainServer/SysToolsController.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.Models;
using Library;
using LitJson;
using MySystemLib;
using System.Text.RegularExpressions;
using System.Security.Cryptography;
using System.Text;

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


        #region 关联上下级

        public IActionResult RelationForUser(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string RelationForUserDo(string MakerCode, string ParentMakerCode, int IsTeam = 1)
        {
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            if (string.IsNullOrEmpty(ParentMakerCode))
            {
                return "请输入上级创客编号";
            }
            MakerCode = MakerCode.ToUpper();
            ParentMakerCode = ParentMakerCode.ToUpper();
            Users puser = db.Users.FirstOrDefault(m => m.MakerCode == ParentMakerCode);
            if (puser != null)
            {
                Users user = db.Users.FirstOrDefault(m => m.MakerCode == MakerCode);
                if (user != null)
                {
                    if (IsTeam == 1)
                    {
                        RelationForUserSub(user.Id, user);
                    }
                    user.ParentUserId = puser.Id;
                    user.ParentNav = puser.ParentNav + "," + puser.Id + ",";
                    db.SaveChanges();
                    function.WriteLog(DateTime.Now.ToString() + ":下级：" + MakerCode + ", 上级：" + ParentMakerCode, "换线日志");
                    return "success";
                }
                return "创客编号不存在";
            }
            return "上级创客编号不存在";
        }
        private void RelationForUserSub(int ParentUserId, Users puser)
        {
            var subusers = db.Users.Select(m => new { m.Id, m.ParentUserId, m.ParentNav }).Where(m => m.ParentUserId == ParentUserId).ToList();
            foreach (var subuser in subusers)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == subuser.Id);
                if (user != null)
                {
                    user.ParentUserId = puser.Id;
                    user.ParentNav = puser.ParentNav + "," + puser.Id + ",";
                    db.SaveChanges();
                    RelationForUserSub(user.Id, user);
                }
            }
        }

        #endregion

        #region 机具补录

        public IActionResult CheckMachine(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string CheckMachineDo(string MakerCode, string PosSn, string MerNo = "", int AddActPrize = 0, int IsPre = 0, int IsSend = 0)
        {
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN";
            }
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn);
            KqProducts kqProducts = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId);
            if (pos == null)
            {
                return "机具SN不存在";
            }
            Users user = db.Users.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (user == null)
            {
                return "创客编号不存在";
            }
            if (IsPre == 1)
            {
                if (pos.BuyUserId == 0)
                {
                    pos.BuyUserId = user.Id;
                }
                if (pos.UserId == 0)
                {
                    pos.UserId = user.Id;
                }
            }
            if (pos.BindingState == 0)
            {
                SpModels.BindRecord bind = spdb.BindRecord.FirstOrDefault(m => m.MerSnNo == PosSn);
                if (bind != null)
                {
                    pos.BindingState = 1;
                    pos.BindingTime = bind.CreateTime;
                    db.SaveChanges();
                    MerNo = bind.MerNo;
                }
            }
            decimal CreditTrade = 0;
            string BindingTime = pos.BindingTime == null ? DateTime.Now.AddMonths(-1).ToString("yyyyMM") : pos.BindingTime.Value.ToString("yyyyMM");
            string SpTradeRecordId = function.ReadInstance("/PublicParams/SpTradeRecordId" + BindingTime + ".txt");
            int StartId = int.Parse(function.CheckInt(SpTradeRecordId));
            bool check = spdb.TradeRecord.Any(m => m.Id > StartId && m.TradeSnNo == pos.PosSn);
            if (check)
            {
                if (pos.BrandId == 1)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "1" && m.SerEntryMode != "N" && m.MerNo.StartsWith("M700")).Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 2)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "2").Sum(m => m.TradeAmount);
                }
                else if (pos.BrandId == 3)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "1" && m.SerEntryMode != "N" && m.MerNo.StartsWith("M900")).Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 4 || pos.BrandId == 5)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "4").Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 6)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "6").Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 7)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "7" && m.TradeStatus == "00").Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 8)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "8").Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 9)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId && m.TradeSnNo == pos.PosSn && m.ProductType == "9").Sum(m => m.TradeAmount) / 100;
                }
                pos.CreditTrade = CreditTrade;
                db.SaveChanges();
                StatTradeAmount(pos.PosSn, StartId);
            }
            if (AddActPrize == 1)
            {
                if (pos.BuyUserId == 0)
                {
                    return "机具未划拨，无法补录激活奖励";
                }
                if (string.IsNullOrEmpty(pos.SeoKeyword) || pos.SeoKeyword == "0")
                {
                    bool has = spdb.ActivateRecord.Any(m => m.SnNo == pos.PosSn);
                    if (has)
                    {
                        SpModels.ActivateRecord chkAct = spdb.ActivateRecord.Where(m => m.SnNo == pos.PosSn).OrderByDescending(m => m.Id).FirstOrDefault() ?? new SpModels.ActivateRecord();
                        pos.SeoKeyword = chkAct.SeoTitle;
                        db.SaveChanges();
                    }
                }
                if (pos.BindingTime != null && pos.ActivationTime != null)
                {
                    TimeSpan ts = pos.ActivationTime.Value - pos.BindingTime.Value;
                    if (ts.TotalDays <= 30 || SysUserName == "admin")
                    {
                        AddAct(pos.Id);
                    }
                }
            }
            decimal CheckMoney = 1000;
            if (pos.BrandId == 6)
            {
                CheckMoney = 5000;
            }
            if (pos.BuyUserId > 0)
            {
                if (pos.CreditTrade < CheckMoney)
                {
                    return "该机具贷记卡累计交易不足" + CheckMoney;
                }
                if (pos.BindingTime != null && pos.ActivationTime != null)
                {
                    TimeSpan ts = pos.ActivationTime.Value - pos.BindingTime.Value;
                    if (ts.TotalDays > 30 && SysUserName != "admin")
                    {
                        return "机具划拨后已超过30天";
                    }
                }
                if (pos.CreditTrade >= CheckMoney && pos.ActivationState == 0)
                {
                    pos.ActivationState = 1;
                    pos.ActivationTime = DateTime.Now;
                    PosMerchantInfo mer = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                    if (pos.ActivationState == 1 && mer != null)
                    {
                        mer.ActiveStatus = 1;
                        mer.MerStandardDate = DateTime.Now;
                    }
                }
                else if (pos.CreditTrade >= CheckMoney && pos.ActivationState == 1)
                {
                    if (AddActPrize == 1)
                    {
                        if (IsSend == 1)
                        {
                            RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                            {
                                UserId = pos.BuyUserId, //接收创客
                                MsgType = 2,
                                Title = "补录成功通知", //标题
                                Summary = "您的 " + kqProducts.Name + " SN:" + pos.PosSn + "已经成功补录，请查收。",
                                CreateDate = DateTime.Now,

                            }));
                        }
                        return "激活奖励已补录";
                    }
                    else
                    {
                        return "数据正常，无需补录";
                    }
                }
                db.SaveChanges();
                return "success";
            }
            pos.UserId = user.Id;
            pos.BuyUserId = user.Id;
            if (pos.CreditTrade >= CheckMoney && pos.ActivationState == 0 && (pos.BindingTime > DateTime.Now.AddDays(-30) || SysUserName == "admin"))
            {
                // pos.IsPurchase = 0;
                pos.ActivationState = 1;
                pos.ActivationTime = DateTime.Now;
            }
            PosMerchantInfo merchant = new PosMerchantInfo();
            if (!string.IsNullOrEmpty(MerNo))
            {
                merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo);
                if (merchant == null)
                {
                    int TopUserId = 0;
                    if (!string.IsNullOrEmpty(user.ParentNav))
                    {
                        TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                    }
                    SpModels.BindRecord bind = spdb.BindRecord.FirstOrDefault(m => m.MerNo == MerNo);
                    if (bind == null)
                    {
                        return "该机具尚未绑定";
                    }
                    SpModels.Merchants Mer = spdb.Merchants.FirstOrDefault(m => m.MerNo == MerNo);
                    if (Mer == null)
                    {
                        return "该机具尚未绑定";
                    }
                    PosMerchantInfo add = db.PosMerchantInfo.Add(new PosMerchantInfo()
                    {
                        CreateDate = Mer.CreateTime,
                        UpdateDate = Mer.UpdateTime,
                        TopUserId = TopUserId,
                        MerUserType = user.MerchantType,
                        BrandId = int.Parse(Mer.ProductType),
                        SnStoreId = pos.StoreId,
                        SnType = pos.PosSnType,
                        UserId = user.Id,
                        MgrName = Mer.AgentName,
                        MerStatus = 1,
                        KqSnNo = Mer.SnNo,
                        KqMerNo = Mer.MerNo,
                        MerIdcardNo = Mer.MerIdcardNo,
                        MerRealName = Mer.MerRealName,
                        MerchantMobile = Mer.MerMobile,
                        MerchantName = Mer.MerName,
                        MerchantNo = Mer.MerNo,
                    }).Entity;
                    MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == Mer.MerNo);
                    if (forMerNo == null)
                    {
                        forMerNo = db.MachineForMerNo.Add(new MachineForMerNo()
                        {
                            MerNo = Mer.MerNo,
                            SnId = pos.Id,
                        }).Entity;
                    }
                    else
                    {
                        forMerNo.SnId = pos.Id;
                    }
                }
            }
            else
            {
                if (pos.BindMerchantId > 0)
                {
                    merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                }
                else
                {
                    return "找不到机具所属商户";
                }
            }
            merchant.UserId = user.Id;
            if (pos.ActivationState == 1)
            {
                merchant.ActiveStatus = 1;
                merchant.MerStandardDate = DateTime.Now;
            }
            if (pos.BindMerchantId == 0)
            {
                pos.BindMerchantId = merchant.Id;
            }
            db.SaveChanges();
            function.WriteLog(DateTime.Now.ToString() + "\n" + SysUserName + "\nMakerCode:" + MakerCode + ", PosSn:" + PosSn + ", MerNo:" + MerNo + ", AddActPrize:" + AddActPrize + ", IsPre:" + IsPre, "机具补录日志");
            return "success";
        }
        public IActionResult CheckMachine2(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string CheckMachine2Do(string MakerCode, string PosSn, string MerNo = "", int AddActPrize = 0)
        {
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN";
            }
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn);
            if (pos == null)
            {
                return "机具SN不存在";
            }
            Users user = db.Users.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (user == null)
            {
                return "创客编号不存在";
            }
            if (pos.BindingState == 0)
            {
                SpModels.BindRecord bind = spdb.BindRecord.FirstOrDefault(m => m.MerSnNo == PosSn);
                if (bind != null)
                {
                    pos.BindingState = 1;
                    pos.BindingTime = bind.CreateTime;
                    db.SaveChanges();
                    MerNo = bind.MerNo;
                }
            }
            decimal CreditTrade = 0;
            bool check = spdb.TradeRecord.Any(m => m.TradeSnNo == pos.PosSn);
            if (check)
            {
                string BindingTime = pos.BindingTime == null ? DateTime.Now.AddMonths(-1).ToString("yyyyMM") : pos.BindingTime.Value.ToString("yyyyMM");
                string SpTradeRecordId = function.ReadInstance("/PublicParams/SpTradeRecordId" + BindingTime + ".txt");
                int StartId = int.Parse(function.CheckInt(SpTradeRecordId));
                if (pos.BrandId == 1)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId &&m.TradeSnNo == pos.PosSn && m.ProductType == "1" && m.SerEntryMode != "N" && m.MerNo.StartsWith("M700")).Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 2)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId &&m.TradeSnNo == pos.PosSn && m.ProductType == "2").Sum(m => m.TradeAmount);
                }
                else if (pos.BrandId == 3)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId &&m.TradeSnNo == pos.PosSn && m.ProductType == "1" && m.SerEntryMode != "N" && m.MerNo.StartsWith("M900")).Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 4 || pos.BrandId == 5)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId &&m.TradeSnNo == pos.PosSn && m.ProductType == "4").Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 6)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId &&m.TradeSnNo == pos.PosSn && m.ProductType == "6").Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 8)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId &&m.TradeSnNo == pos.PosSn && m.ProductType == "8").Sum(m => m.TradeAmount) / 100;
                }
                else if (pos.BrandId == 9)
                {
                    CreditTrade = spdb.TradeRecord.Where(m => m.Id > StartId &&m.TradeSnNo == pos.PosSn && m.ProductType == "9").Sum(m => m.TradeAmount) / 100;
                }
                pos.CreditTrade = CreditTrade;
                db.SaveChanges();
                StatTradeAmount(pos.PosSn);
            }
            if (AddActPrize == 1)
            {
                if (string.IsNullOrEmpty(pos.SeoKeyword) || pos.SeoKeyword == "0")
                {
                    bool has = spdb.ActivateRecord.Any(m => m.SnNo == pos.PosSn);
                    if (has)
                    {
                        SpModels.ActivateRecord chkAct = spdb.ActivateRecord.Where(m => m.SnNo == pos.PosSn).OrderByDescending(m => m.Id).FirstOrDefault() ?? new SpModels.ActivateRecord();
                        pos.SeoKeyword = chkAct.SeoTitle;
                        db.SaveChanges();
                    }
                }
                AddAct(pos.Id);
            }
            if (pos.BuyUserId > 0)
            {
                if (pos.CreditTrade < 1000)
                {
                    // pos.IsPurchase = 99;
                    db.SaveChanges();
                    return "该机具贷记卡累计交易不足1000";
                }
                if (pos.CreditTrade >= 1000 && pos.ActivationState == 0)
                {
                    // pos.IsPurchase = 0;
                    pos.ActivationState = 1;
                    pos.ActivationTime = DateTime.Now;
                    PosMerchantInfo mer = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                    if (pos.ActivationState == 1 && mer != null)
                    {
                        mer.ActiveStatus = 1;
                        mer.MerStandardDate = DateTime.Now;
                        RedisDbconn.Instance.Clear("PosMerchantInfo:" + mer.Id);
                    }
                }
                else if (pos.CreditTrade >= 1000 && pos.ActivationState == 1)
                {
                    if (AddActPrize == 1)
                    {
                        return "激活奖励已补录";
                    }
                    else
                    {
                        return "数据正常，无需补录";
                    }
                }
                db.SaveChanges();
                RedisDbconn.Instance.Clear("PosMachinesTwo:" + pos.Id);
                return "success";
            }
            pos.UserId = user.Id;
            pos.BuyUserId = user.Id;
            // if (pos.CreditTrade < 1000)
            // {
            //     pos.IsPurchase = 99;
            // }
            if (pos.CreditTrade >= 1000 && pos.ActivationState == 0)
            {
                // pos.IsPurchase = 0;
                pos.ActivationState = 1;
                pos.ActivationTime = DateTime.Now;
            }
            PosMerchantInfo merchant = new PosMerchantInfo();
            if (!string.IsNullOrEmpty(MerNo))
            {
                merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo);
                if (merchant == null)
                {
                    int TopUserId = 0;
                    if (!string.IsNullOrEmpty(user.ParentNav))
                    {
                        TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                    }
                    SpModels.BindRecord bind = spdb.BindRecord.FirstOrDefault(m => m.MerNo == MerNo);
                    if (bind == null)
                    {
                        return "该机具尚未绑定";
                    }
                    SpModels.Merchants Mer = spdb.Merchants.FirstOrDefault(m => m.MerNo == MerNo);
                    if (Mer == null)
                    {
                        return "该机具尚未绑定";
                    }
                    PosMerchantInfo add = db.PosMerchantInfo.Add(new PosMerchantInfo()
                    {
                        CreateDate = Mer.CreateTime,
                        UpdateDate = Mer.UpdateTime,
                        TopUserId = TopUserId,
                        MerUserType = user.MerchantType,
                        BrandId = int.Parse(Mer.ProductType),
                        SnStoreId = pos.StoreId,
                        SnType = pos.PosSnType,
                        UserId = user.Id,
                        MgrName = Mer.AgentName,
                        MerStatus = 1,
                        KqSnNo = Mer.SnNo,
                        KqMerNo = Mer.MerNo,
                        MerIdcardNo = Mer.MerIdcardNo,
                        MerRealName = Mer.MerRealName,
                        MerchantMobile = Mer.MerMobile,
                        MerchantName = Mer.MerName,
                        MerchantNo = Mer.MerNo,
                    }).Entity;
                    MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == Mer.MerNo);
                    if (forMerNo == null)
                    {
                        forMerNo = db.MachineForMerNo.Add(new MachineForMerNo()
                        {
                            MerNo = Mer.MerNo,
                            SnId = pos.Id,
                        }).Entity;
                    }
                    else
                    {
                        forMerNo.SnId = pos.Id;
                    }
                }
            }
            else
            {
                if (pos.BindMerchantId > 0)
                {
                    merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                }
                else
                {
                    return "找不到机具所属商户";
                }
            }
            merchant.UserId = user.Id;
            if (pos.ActivationState == 1)
            {
                merchant.ActiveStatus = 1;
                merchant.MerStandardDate = DateTime.Now;
            }
            if (pos.BindMerchantId == 0)
            {
                pos.BindMerchantId = merchant.Id;
            }
            db.SaveChanges();
            RedisDbconn.Instance.Clear("PosMerchantInfo:" + merchant.Id);
            RedisDbconn.Instance.Clear("PosMachinesTwo:" + pos.Id);
            return "success";
        }
        public void AddAct(int posid = 0)
        {
            WebCMSEntities db = new WebCMSEntities();
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.ActivationState == 1 && !string.IsNullOrEmpty(m.SeoKeyword) && m.Id == posid);
            if (pos != null)
            {
                // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
                PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                if (merchant != null)
                {
                    // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0);
                    // if (otherInfo != null)
                    // {
                    //     otherInfo.PrizeFlag1 = 1;
                    //     db.SaveChanges();
                    string ParentNav = "";
                    Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
                    if (user != null)
                    {
                        int GetUserId = user.Id;
                        ParentNav = user.ParentNav;
                        int TopUserId = 1;
                        if (!string.IsNullOrEmpty(ParentNav))
                        {
                            string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                            if (ParentNavList.Length > 1)
                            {
                                TopUserId = int.Parse(ParentNavList[1]);
                            }
                            else if (ParentNavList.Length == 1)
                            {
                                TopUserId = int.Parse(ParentNavList[0]);
                            }
                        }
                        List<decimal> prizes = new List<decimal>();
                        decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
                        if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 4 || pos.BrandId == 5 || pos.BrandId == 6 || pos.BrandId == 8 || pos.BrandId == 9)
                        {
                            ActPrize = ActPrize / 100;
                        }
                        if (ActPrize > 0)
                        {
                            if (ActPrize == 99)
                            {
                                ActPrize = 100;
                            }
                            else if (ActPrize == 199)
                            {
                                ActPrize = 200;
                            }
                            else if (ActPrize == 299)
                            {
                                ActPrize = 300;
                            }
                            else if (ActPrize == 249)
                            {
                                ActPrize = 260;
                            }
                            prizes.Add(ActPrize);
                            if (pos.BrandId == 6 && pos.ActivationState == 1 && pos.CreditTrade >= 10000 && pos.BindingTime > DateTime.Now.AddDays(-60))
                            {
                                prizes.Add(40);
                            }
                        }
                        else if (pos.BrandId == 6 && ActPrize == 0)
                        {
                            prizes.Add(50);
                        }
                        foreach (decimal prize in prizes)
                        {
                            int ChangeType = prize == 40 ? 12 : 0;
                            bool check = db.ActiveReward.Any(m => m.KqSnNo == pos.PosSn && m.RewardAmount == prize);
                            if (!check)
                            {
                                Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                                db.ActiveReward.Add(new ActiveReward()
                                {
                                    CreateDate = DateTime.Now,
                                    UpdateDate = DateTime.Now,
                                    UserId = GetUserId, //创客
                                    MerchantId = pos.BindMerchantId, //商户
                                    StandardDate = pos.ActivationTime, //达标日期
                                    RewardAmount = prize, //奖励金额
                                    BrandId = pos.BrandId, //品牌
                                    UserNav = ParentNav, //创客父级
                                    DirectBuddyNo = merchant.UserId, //商户直属创客
                                    KqMerNo = merchant.KqMerNo, //渠道商户编号
                                    KqSnNo = pos.PosSn, //渠道SN号
                                    SnType = pos.PosSnType, //机具类型
                                    SnApplyUserId = pos.BuyUserId, //机具申请创客
                                    ActType = 0, //激活类型
                                    SnStoreId = pos.StoreId, //SN仓库
                                    RewardTips = "激活奖励", //奖励描述
                                    Remark = "激活奖励", //备注
                                    ActDate = pos.ActivationTime, //激活时间
                                    TopUserId = TopUserId, //顶级创客
                                    SeoTitle = machineUser.RealName,
                                });
                                db.SaveChanges();
                                string IdBrand = GetUserId + "_" + pos.BrandId;
                                UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                                if (userData == null)
                                {
                                    userData = db.UserMachineData.Add(new UserMachineData()
                                    {
                                        IdBrand = IdBrand,
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                userData.ActProfit += prize;
                                db.SaveChanges();
                                RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                                UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                                if (account == null)
                                {
                                    account = db.UserAccount.Add(new UserAccount()
                                    {
                                        Id = GetUserId,
                                        UserId = GetUserId,
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                                decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                                decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                                account.BalanceAmount += prize;
                                account.TotalAmount += prize;
                                decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                                decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                                decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                                UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                                {
                                    CreateDate = DateTime.Now,
                                    UpdateDate = DateTime.Now,
                                    UserId = GetUserId, //创客
                                    ChangeType = ChangeType, //变动类型
                                    ProductType = pos.BrandId, //产品类型
                                    ChangeAmount = prize, //变更金额
                                    BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                                    AfterTotalAmount = AfterTotalAmount, //变更后总金额
                                    BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                                    AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                                    BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                                    AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                                }).Entity;
                                db.SaveChanges();
                                RedisDbconn.Instance.Set("UserAccount:" + GetUserId, account);

                                string dateString = pos.ActivationTime.Value.ToString("yyyyMMdd");
                                string monthString = pos.ActivationTime.Value.ToString("yyyyMM");
                                // 激活奖励列表
                                List<string> dates = RedisDbconn.Instance.GetList<string>("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId);
                                if (!dates.Contains(dateString))
                                {
                                    RedisDbconn.Instance.AddList("ActiveRewardDay:" + GetUserId + ":" + pos.BrandId, dateString);
                                }
                                RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + dateString, prize);

                                List<string> months = RedisDbconn.Instance.GetList<string>("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId);
                                if (!months.Contains(monthString))
                                {
                                    RedisDbconn.Instance.AddList("ActiveRewardMonth:" + GetUserId + ":" + pos.BrandId, monthString);
                                }
                                RedisDbconn.Instance.AddNumber("ActiveRewardAmt:" + GetUserId + ":" + pos.BrandId + ":" + monthString, prize);

                                // 激活奖励详情
                                List<int> actPrizeList = RedisDbconn.Instance.GetList<int>("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString);
                                if (!actPrizeList.Contains(pos.BindMerchantId))
                                {
                                    RedisDbconn.Instance.AddList("ActiveRewardDetail:" + GetUserId + ":" + pos.BrandId + ":" + dateString, pos.BindMerchantId);
                                }
                                RedisDbconn.Instance.AddNumber("ActiveRewardAmt:mer:" + pos.BindMerchantId + ":" + pos.BrandId + ":" + dateString, prize);

                                //收支明细
                                RedisDbconn.Instance.AddList("UserAccountRecord:" + GetUserId + ":1:" + monthString, userAccountRecord);
                                RedisDbconn.Instance.AddNumber("UserAccount:" + GetUserId + ":1:" + monthString, prize);
                            }
                        }
                    }
                    // }
                }
            }
            db.Dispose();
        }
        //重置交易额
        public void StatTradeAmount(string PosSn, int StartId = 0)
        {
            DateTime start = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
            if (DateTime.Now.Day == 1)
            {
                start = DateTime.Parse(DateTime.Now.AddMonths(-1).ToString("yyyy-MM") + "-01 00:00:00");
            }
            DateTime end = DateTime.Now;
            SycnSpTradeService.Instance.Start(PosSn, start, end, StartId);
            RedisDbconn.Instance.AddList("ResetTradeAmountList", PosSn);
        }

        #endregion

        #region 设置商户代理

        public IActionResult SetMerAgent(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string SetMerAgentDo(string MakerCode, string PosSn, string MerNo, int IsSend = 0)
        {
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN";
            }
            if (string.IsNullOrEmpty(MerNo))
            {
                return "请输入商户编号";
            }
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn);
            KqProducts kqProducts = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId);
            if (pos == null)
            {
                return "机具SN不存在";
            }
            Users user = db.Users.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (user == null)
            {
                return "创客编号不存在";
            }
            PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo);
            if (merchant == null)
            {
                return "商户编号不存在";
            }
            pos.SeoTitle = user.Id.ToString();
            pos.UserId = user.Id;
            if (pos.BindMerchantId == 0)
            {
                pos.BindMerchantId = merchant.Id;
                if (IsSend == 1)
                {
                    RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                    {
                        UserId = pos.BuyUserId, //接收创客
                        MsgType = 2,
                        Title = "商户型代理设置成功", //标题
                        Summary = "您的 " + kqProducts.Name + " SN:" + pos.PosSn + "已经成功给下级代理" + user.RealName + "" + MakerCode + "，设置为商户型代理，设置成功后的新增交易的分润归商户型代理所有",
                        CreateDate = DateTime.Now,
                    }));
                }
            }
            user.MerchantType = 1;
            merchant.UserId = user.Id;
            merchant.MerUserType = 1;
            db.SetMerchantTypeRecord.Add(new SetMerchantTypeRecord()
            {
                CreateDate = DateTime.Now,
                IsRecyc = (ulong)pos.IsPurchase,
                CreditAmount = pos.CreditTrade,
                PosSnType = pos.PosSnType,
                ActDate = pos.ActivationTime,
                BindDate = pos.BindingTime,
                ActStatus = (ulong)pos.ActivationState,
                BindStatus = (ulong)pos.BindingState,
                MerNo = MerNo,
                PosSn = pos.PosSn,
                Note = "后台设置商户型创客",
                ToUserId = user.Id,
                FromUserId = pos.BuyUserId,
            });
            db.SaveChanges();
            return "success";
        }

        #endregion


        #region 取消商户代理

        public IActionResult CancelMerAgent(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string CancelMerAgentDo(string MakerCode, string PosSn, int IsSend = 0)
        {
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN";
            }
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn);
            KqProducts kqProducts = db.KqProducts.FirstOrDefault(m => m.Id == pos.BrandId);
            if (pos == null)
            {
                return "机具SN不存在";
            }
            Users user = db.Users.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (user == null)
            {
                return "创客编号不存在";
            }
            PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == PosSn);
            pos.UserId = pos.BuyUserId;
            merchant.UserId = pos.BuyUserId;
            merchant.MerUserType = 0;
            user.MerchantType = 0;
            db.SaveChanges();
            if (pos.BindMerchantId == 0)
            {
                pos.BindMerchantId = merchant.Id;
                if (IsSend == 1)
                {
                    RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                    {
                        UserId = pos.BuyUserId, //接收创客
                        MsgType = 2,
                        Title = "商户型代理取消成功", //标题
                        Summary = "您的 " + kqProducts.Name + " SN:" + pos.PosSn + "已给下级代理" + user.RealName + "" + MakerCode + "取消成功",
                        CreateDate = DateTime.Now,
                    }));
                }
            }
            string text = string.Format("取消商户代理，创客编号: " + user.MakerCode + "，机具SN：" + pos.PosSn + "，操作人：" + SysRealName + "，Time：" + DateTime.Now + "");
            function.WriteLog(text, "CancelMerAgent");//取消商户型代理日志

            return "success";
        }

        #endregion


        #region 查看SP原始数据日志

        public IActionResult SeeSpLog(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        #endregion

        #region 查询机具信息

        public IActionResult SeeSnDetail(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string SeeSnDetailDo(string PosSn)
        {
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN";
            }
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosSn);
            if (pos == null)
            {
                return "机具SN不存在";
            }
            if (pos.Status == -1)
            {
                Users posUsers = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                decimal Deposits = decimal.Parse(function.CheckNum(pos.SeoKeyword));
                if (pos.BrandId != 2 && pos.BrandId != 7)
                {
                    Deposits = Deposits / 100;
                }
                string DepositGets = "未领取";
                string DepositUsers = "";
                ActiveReward rewards = db.ActiveReward.FirstOrDefault(m => m.KqSnNo == pos.PosSn && m.RewardAmount != 40) ?? new ActiveReward();
                if (rewards.Id > 0)
                {
                    Users user = db.Users.FirstOrDefault(m => m.Id == rewards.UserId) ?? new Users();
                    DepositGets = "已领取";
                    DepositUsers = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
                }
                string ActiveTimes = rewards.CreateDate == null ? "" : rewards.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
                string results = "该机具为故障机" + "\n";
                results += "押金返现实际返现对象：" + DepositUsers + "\n";
                results += "押金：" + Deposits + "\n";
                results += "是否返现：" + DepositGets + "，领取时间：" + ActiveTimes + "\n";
                return results;
            }
            string merInfo = "";
            string merName = "";
            PosMerchantInfo mer = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
            if (mer != null)
            {
                merInfo = mer.KqMerNo;
                merName = mer.MerchantName;
            }
            else
            {
                merInfo = "未找到商户";
            }
            StoreHouse store = db.StoreHouse.FirstOrDefault(m => m.Id == pos.StoreId) ?? new StoreHouse();
            Users posUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
            Users posSubUser = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new Users();
            int TopUserId = 0;
            if (!string.IsNullOrEmpty(posUser.ParentNav))
            {
                string[] ParentNavs = posUser.ParentNav.Trim(',').Replace(",,", ",").Split(',');
                if (ParentNavs.Length > 1)
                {
                    TopUserId = int.Parse(ParentNavs[1]);
                }
                if (ParentNavs.Length == 1)
                {
                    TopUserId = int.Parse(ParentNavs[0]);
                }
            }
            Users posTopUser = db.Users.FirstOrDefault(m => m.Id == TopUserId) ?? new Users();
            string bindResult = "", bindTime = "";
            if (pos.BindingState == 0)
            {
                SpModels.BindRecord bind = spdb.BindRecord.FirstOrDefault(m => m.MerSnNo == pos.PosSn);
                if (bind != null)
                {
                    if (bind.Status != 1)
                    {
                        bindResult = "执行中";
                    }
                }
                else
                {
                    bindResult = "未绑定";
                }
            }
            else
            {
                bindResult = "已绑定";
                bindTime = pos.BindingTime.Value.ToString("yyyy-MM-dd HH:mm:ss");
            }
            string activeResult = "", activeTime = "";
            if (pos.ActivationState == 0)
            {
                if (pos.CreditTrade < 1000)
                {
                    activeResult = "未刷满1000";
                }
                else if (pos.TransferTime == null)
                {
                    activeResult = "未激活, 需补录";
                }
            }
            else
            {
                activeResult = "已激活";
                activeTime = pos.ActivationTime.Value.ToString("yyyy-MM-dd HH:mm:ss");
            }
            string tradeAmount = pos.CreditTrade.ToString();
            decimal Deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword));
            if (pos.BrandId != 2 && pos.BrandId != 7)
            {
                Deposit = Deposit / 100;
            }

            string DepositGet = "未领取";
            string DepositUser = "";
            string DepositToUser = "";
            decimal headAmount = 0;
            decimal footAmount = 0;
            ActiveReward reward = db.ActiveReward.FirstOrDefault(m => m.KqSnNo == pos.PosSn && m.RewardAmount != 40) ?? new ActiveReward();
            if (reward.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == reward.UserId) ?? new Users();
                DepositGet = "已领取";
                DepositUser = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
                var fAmount = db.ActiveReward.FirstOrDefault(m => m.KqSnNo == pos.PosSn && m.ActType == 0);
                var lAmount = db.ActiveReward.FirstOrDefault(m => m.KqSnNo == pos.PosSn && m.ActType == 1);
                if (fAmount != null && lAmount != null)
                {
                    headAmount = fAmount.RewardAmount;
                    footAmount = lAmount.RewardAmount;
                }
            }
            string DepositGet6 = "未领取";
            string DepositUser6 = "";
            ActiveReward lisreward = db.ActiveReward.FirstOrDefault(m => m.KqSnNo == pos.PosSn && m.BrandId == 6 && m.RewardAmount == 40) ?? new ActiveReward();
            if (lisreward.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == lisreward.UserId) ?? new Users();
                DepositGet6 = "已领取";
                DepositUser6 = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
            }
            string FluxGet6 = "未领取";
            string FluxUser6 = "";
            FluxProfitDetail flux = db.FluxProfitDetail.FirstOrDefault(m => m.SnNo == pos.PosSn) ?? new FluxProfitDetail();
            if (flux.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == flux.UserId) ?? new Users();
                FluxGet6 = "已领取（领取时间：" + flux.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") + "）";
                FluxUser6 = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
            }
            Users touser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
            DepositToUser = "创客编号：" + touser.MakerCode + "，姓名：" + touser.RealName + "，手机号：" + touser.Mobile;
            string OpenUser10 = "未领取";
            string OpenUser20 = "未领取";
            var OpenRewardDetail = db.OpenRewardDetail.Where(m => m.SnNo == pos.PosSn).ToList();
            OpenRewardDetail openreward = OpenRewardDetail.FirstOrDefault(m => m.CreditRewardAmount == 20) ?? new OpenRewardDetail();
            if (openreward.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == openreward.UserId) ?? new Users();
                OpenUser20 = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
            }
            openreward = OpenRewardDetail.FirstOrDefault(m => m.CreditRewardAmount == 10) ?? new OpenRewardDetail();
            if (openreward.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == openreward.UserId) ?? new Users();
                OpenUser10 = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
            }
            MachineApply apply = db.MachineApply.FirstOrDefault(m => m.SwapSnExpand.Contains(pos.PosSn)) ?? new MachineApply();
            Orders applyorder = db.Orders.FirstOrDefault(m => m.Id == apply.QueryCount) ?? new Orders();
            MachineChangeDetail change = db.MachineChangeDetail.FirstOrDefault(m => m.OutSnNo == pos.PosSn) ?? new MachineChangeDetail();

            string RecycFlag = pos.IsPurchase == 1 ? "已申请循环" : "未申请循环";
            string SendStatus = applyorder.SendStatus == 1 ? "已发货" : "未发货";
            string ApplyDate = apply.CreateDate == null ? "" : apply.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string SendDate = applyorder.SendDate == null ? "" : applyorder.SendDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string CreateDate = pos.CreateDate == null ? "" : pos.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string TransferTime = pos.TransferTime == null ? "" : pos.TransferTime.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string RecycEndDate = pos.RecycEndDate == null ? "" : pos.RecycEndDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string ActiveTime = reward.CreateDate == null ? "" : reward.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string ActiveTime6 = lisreward.CreateDate == null ? "" : lisreward.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string result = "";
            result += "机具SN：" + pos.PosSn + "\n";
            result += "商户编号：" + merInfo + "，商户姓名：" + merName + "\n";
            result += "商户型机器/直拓机器：创客编号：" + posSubUser.MakerCode + "，姓名：" + posSubUser.RealName + "，手机号：" + posSubUser.Mobile + "\n";
            if (change.Id > 0)
            {
                result += "换机来源机具SN：" + change.BackSnNo + "\n";
            }
            result += "机具所属人：创客编号：" + posUser.MakerCode + "，姓名：" + posUser.RealName + "，手机号：" + posUser.Mobile + "\n";
            result += "机器持有人顶级：创客编号：" + posTopUser.MakerCode + "，姓名：" + posTopUser.RealName + "，手机号：" + posTopUser.Mobile + "\n";
            result += "机器所属仓库：仓库编号：" + store.StoreNo + "，仓库名称：" + store.StoreName + "\n";
            if (pos.PreUserId > 0)
            {
                Users smallStoreUser = db.Users.FirstOrDefault(m => m.Id == pos.PreUserId) ?? new Users();
                PreSendStockDetail preSend = db.PreSendStockDetail.FirstOrDefault(m => m.SnId == pos.Id && m.ToUserId == pos.PreUserId && m.Status == 1) ?? new PreSendStockDetail();
                string preSendDate = preSend.CreateDate == null ? "" : preSend.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
                result += "机具所属小分仓：创客编号：" + smallStoreUser.MakerCode + "，姓名：" + smallStoreUser.RealName + "，手机号：" + smallStoreUser.Mobile + "，预发时间：" + preSendDate + "\n";
            }
            else
            {
                result += "机具所属小分仓：暂无小分仓\n";
            }
            result += "入库时间：" + CreateDate + "\n";
            result += "循环到期时间：" + RecycEndDate + "\n";
            result += "划拨时间：" + TransferTime + "\n";
            result += "绑定状态：" + bindResult + "(绑定时间：" + bindTime + ")\n";
            result += "激活状态：" + activeResult + "(激活时间：" + activeTime + ")\n";
            result += "贷记卡（总）交易额：" + tradeAmount + "\n";
            result += "是否循环：" + RecycFlag + "，申请循环时间：" + ApplyDate + "\n";
            result += "申请循环后的SN：" + applyorder.SnNos + "\n";
            result += "是否发货：" + SendStatus + "，发货时间：" + SendDate + "\n";
            result += "押金：" + Deposit + "\n";
            result += "是否返现：" + DepositGet + "，领取时间：" + ActiveTime + "\n";
            result += "返现金额：" + headAmount + " " + " " + footAmount + "\n";//TODO: 添加返现金额和额外奖励
            result += "押金返现应返现对象：" + DepositToUser + "\n";
            result += "押金返现实际返现对象：" + DepositUser + "\n";
            if (pos.BrandId == 6)
            {
                result += "立刷10000奖励：" + DepositGet6 + "，领取时间：" + ActiveTime6 + "\n";
                result += "立刷10000奖励发放人：" + DepositUser6 + "\n";
            }
            result += "流量费：" + FluxGet6 + "\n";
            result += "流量费发放对象：" + FluxUser6 + "\n";
            result += "开机奖20：" + OpenUser20 + "\n";
            result += "开机奖10：" + OpenUser10 + "\n";
            return result;
        }
        //解析金控日志
        // public decimal CheckLog(DateTime startDate, string PosSn)
        // {
        //     bool op = true;
        //     decimal result = 0;
        //     DateTime today = DateTime.Now;
        //     int i = 0;
        //     while (op)
        //     {
        //         DateTime check = DateTime.Parse(startDate.ToString("yyyy-MM-dd") + " 00:00:00").AddDays(i);
        //         if (check <= today)
        //         {
        //             string source = function.GetWebRequest("http://sp.kexiaoshuang.com/api/test/GetLog?date=" + check.Year + "-" + check.Month + "-" + check.Day);
        //             MatchCollection mc = Regex.Matches(source, "{.*?2022年飞天系列-小宝电签.*?}"); //激活
        //             foreach (Match sub in mc)
        //             {
        //                 string content = sub.Value;
        //                 JsonData jsonObj = JsonMapper.ToObject(content);
        //                 decimal serviceAmount = decimal.Parse(jsonObj["serviceAmount"].ToString());
        //                 string posSnCheck = jsonObj["posSn"].ToString();
        //                 if (posSnCheck == PosSn && serviceAmount > 0)
        //                 {
        //                     result = serviceAmount / 100;
        //                     op = false;
        //                 }
        //             }
        //         }
        //         else
        //         {
        //             op = false;
        //         }
        //         i += 1;
        //     }
        //     return result;
        // }

        #endregion

        #region 生成机具兑换码

        public IActionResult MakeCoupons(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string MakeCouponsDo(int Kind, int Number)
        {
            DateTime checkTime = DateTime.Parse("1900-01-01");
            string checkTimeString = RedisDbconn.Instance.Get<string>("MakerCouponsQueueCheckTime");
            if (!string.IsNullOrEmpty(checkTimeString))
            {
                checkTime = DateTime.Parse(checkTimeString);
            }
            if (checkTime.AddHours(1) < DateTime.Now)
            {
                RedisDbconn.Instance.Set("MakerCouponsQueueCheckTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                RedisDbconn.Instance.AddList("MakerCouponsQueue:" + Kind, Number);
                return "生成程序已执行";
            }
            return "请稍后再试";
        }
        #endregion

        #region 导出没有刷满1000的机具

        public IActionResult ExportPos(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public JsonResult ExportPosDo()
        {
            WebCMSEntities db = new WebCMSEntities();
            List<PosMachinesTwo> poses = db.PosMachinesTwo.Where(m => m.CreditTrade < 1000 && m.BindingState == 1).ToList();
            int total = poses.Count;
            int index = 0;
            List<Dictionary<string, object>> list = new List<Dictionary<string, object>>();
            foreach (PosMachinesTwo pos in poses)
            {
                index += 1;
                PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PosMerchantInfo();
                Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                Users puser = db.Users.FirstOrDefault(m => m.Id == user.ParentUserId) ?? new Users();
                Users ppuser = db.Users.FirstOrDefault(m => m.Id == puser.ParentUserId) ?? new Users();
                Dictionary<string, object> item = new Dictionary<string, object>();
                string TopRealName = "";
                string TopMakerCode = "";
                string TopMobile = "";
                string ParentNav = user.ParentNav;
                if (!string.IsNullOrEmpty(ParentNav))
                {
                    string[] navlist = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                    if (navlist.Length > 1)
                    {
                        int TopId = int.Parse(function.CheckInt(navlist[1]));
                        Users tuser = db.Users.FirstOrDefault(m => m.Id == TopId) ?? new Users();
                        TopRealName = tuser.RealName;
                        TopMakerCode = tuser.MakerCode;
                        TopMobile = tuser.Mobile;
                    }
                }
                item.Add("TopRealName", TopRealName); //顶级姓名
                item.Add("TopMakerCode", TopMakerCode); //顶级编号
                item.Add("UpUpRealName", ppuser.RealName); //上上级姓名
                item.Add("UpRealName", puser.RealName); //上级姓名
                item.Add("RealName", user.RealName); //代理姓名
                item.Add("MakerCode", user.MakerCode); //代理编号
                item.Add("Mobile", user.Mobile); //代理手机号
                item.Add("MerchantName", merchant.MerchantName); //客户姓名
                item.Add("MerchantMobile", merchant.MerchantMobile); //客户电话
                item.Add("OpenTime", pos.BindingTime == null ? "" : pos.BindingTime.Value.ToString("yyyy-MM-dd HH:mm:ss")); //开机日期
                item.Add("Sn", pos.PosSn); //SN
                list.Add(item);
                RedisDbconn.Instance.Set("ExportPosCheck", index + " / " + total);
            }
            db.Dispose();
            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", list);
            Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
            ReturnFields.Add("TopRealName", "顶级姓名"); //顶级姓名
            ReturnFields.Add("TopMakerCode", "顶级编号"); //顶级编号
            ReturnFields.Add("UpUpRealName", "上上级姓名"); //上上级姓名
            ReturnFields.Add("UpRealName", "上级姓名"); //上级姓名
            ReturnFields.Add("RealName", "代理姓名"); //代理姓名
            ReturnFields.Add("MakerCode", "代理编号"); //代理编号
            ReturnFields.Add("Mobile", "代理手机号"); //代理手机号
            ReturnFields.Add("MerchantName", "客户姓名"); //客户姓名
            ReturnFields.Add("MerchantMobile", "客户电话"); //客户电话
            ReturnFields.Add("OpenTime", "开机日期"); //开机日期
            ReturnFields.Add("Sn", "SN"); //SN
            result.Add("Fields", ReturnFields);
            RedisDbconn.Instance.Set("ExportPosCheck", "finish");
            return Json(result);
        }
        public string ExportPosCheck()
        {
            string content = RedisDbconn.Instance.Get<string>("ExportPosCheck");
            if (content == "finish")
            {
                RedisDbconn.Instance.Clear("ExportPosCheck");
            }
            return content;
        }
        #endregion

        #region 更换机具

        public IActionResult ChangePos(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string ChangePosDo(string OldSn, string NewSn, string BackStoreNo, string OutStoreNo, string MerNo = "", int IsSend = 0)
        {
            if (string.IsNullOrEmpty(OldSn))
            {
                return "请输入原机具SN";
            }
            if (string.IsNullOrEmpty(NewSn))
            {
                return "请输入新机具SN";
            }
            string[] OldSnList = OldSn.Split('\n');
            string[] NewSnList = NewSn.Split('\n');
            if (OldSnList.Length != NewSnList.Length)
            {
                return "原机具SN数量和新机具SN数量不一致";
            }
            WebCMSEntities db = new WebCMSEntities();
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == OldSn);
            StoreForCode storeForBack = db.StoreForCode.FirstOrDefault(m => m.Code == BackStoreNo) ?? new StoreForCode();
            StoreForCode storeForOut = db.StoreForCode.FirstOrDefault(m => m.Code == OutStoreNo) ?? new StoreForCode();
            StoreHouse BackStore = db.StoreHouse.FirstOrDefault(m => m.Id == storeForBack.StoreId) ?? new StoreHouse();
            StoreHouse OutStore = db.StoreHouse.FirstOrDefault(m => m.Id == storeForOut.StoreId) ?? new StoreHouse();
            string ChangeNo = "BMC" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(3);
            KqProducts oldPosBrand = new KqProducts();
            KqProducts newPosBrand = new KqProducts();
            MachineChange add = db.MachineChange.Add(new MachineChange()
            {
                CreateDate = DateTime.Now,
                UpdateDate = DateTime.Now,
                CreateMan = SysUserName + "-" + SysRealName,
                ChangeNo = ChangeNo, //转换单号
                UserId = 0, //创客
                ChangeTime = DateTime.Now, //转换时间
                BackStoreId = BackStore.Id, //退回仓库
                BackStoreName = BackStore.StoreName, //退回仓库名称
                Remark = "机具更换", //订单备注
                BackStoreUserId = BackStore.UserId, //退回仓库归属人
                OutProductType = int.Parse(OutStore.BrandId), //出库产品类型
                OutProductName = OutStore.ProductName, //出库产品名称
                OutStoreId = OutStore.Id, //出库仓库
                OutStoreName = OutStore.StoreName, //出库仓库名称
                OutStoreAreas = OutStore.Areas, //出库仓库所在地区
                OutStoreAddress = OutStore.Address, //出库仓库地址
                OutStoreManager = "", //出库仓库联系人
                OutStoreManagerMobile = OutStore.ManageMobile, //出库仓库联系人手机号
            }).Entity;
            db.SaveChanges();
            int BackProductType = 0;
            string BackProductName = "";
            string ChangeDeviceName = "";
            string ChangeSnExpand = "";
            for (int i = 0; i < OldSnList.Length; i++)
            {
                string OldSnNum = OldSnList[i];
                string NewSnNum = NewSnList[i];
                MachineForSnNo oldForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == OldSnNum) ?? new MachineForSnNo();
                MachineForSnNo newForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == NewSnNum) ?? new MachineForSnNo();
                PosMachinesTwo oldpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == oldForSnNo.SnId);
                if (oldpos == null)
                {
                    return "原机具SN不正确";
                }
                // if (oldpos.BindingState != 1)
                // {
                //     return "原机具未绑定";
                // }
                PosMachinesTwo newpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == newForSnNo.SnId);
                if (newpos == null)
                {
                    return "新机具SN不正确";
                }
                oldPosBrand = db.KqProducts.FirstOrDefault(m => m.Id == oldpos.BrandId) ?? new KqProducts();
                newPosBrand = db.KqProducts.FirstOrDefault(m => m.Id == newpos.BrandId) ?? new KqProducts();
                PosMerchantInfo merchant = new PosMerchantInfo();
                if (!string.IsNullOrEmpty(MerNo))
                {
                    merchant = db.PosMerchantInfo.FirstOrDefault(m => m.KqMerNo == MerNo) ?? new PosMerchantInfo();
                }
                else
                {
                    merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == oldpos.BindMerchantId) ?? new PosMerchantInfo();
                }
                newpos.BindMerchantId = merchant.Id;
                newpos.BuyUserId = oldpos.BuyUserId;
                newpos.UserId = oldpos.UserId;
                newpos.RecycEndDate = oldpos.RecycEndDate;
                newpos.ScanQrTrade = oldpos.ScanQrTrade;
                newpos.DebitCardTrade = oldpos.DebitCardTrade;
                newpos.CreditTrade = oldpos.CreditTrade;
                newpos.PosSnType = oldpos.PosSnType;
                newpos.TransferTime = oldpos.TransferTime;
                newpos.IsPurchase = oldpos.IsPurchase;
                newpos.BindingState = oldpos.BindingState;
                newpos.ActivationState = oldpos.ActivationState;
                newpos.BindingTime = oldpos.BindingTime;
                newpos.ActivationTime = oldpos.ActivationTime;
                newpos.IsFirst = oldpos.IsFirst;
                // bool checkActReward = db.ActiveReward.Any(m => m.KqMerNo == merchant.KqMerNo);
                // if (!checkActReward)
                // {
                newpos.SeoKeyword = oldpos.SeoKeyword;
                newpos.PrizeParams = oldpos.PrizeParams;
                newpos.LeaderUserId = oldpos.LeaderUserId;
                // }
                // oldpos.BuyUserId = 0;
                // oldpos.UserId = 0;
                oldpos.Status = -1;

                //对应调整客小爽企业版数据
                var posInfo = db.BusinessPartnerPos.FirstOrDefault(m => m.PosId == oldpos.Id);
                if (posInfo != null)
                {
                    posInfo.PosSn = newpos.PosSn;
                    posInfo.PosId = newpos.Id;
                    db.SaveChanges();
                }

                MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == merchant.KqMerNo);
                if (forMerNo != null)
                {
                    forMerNo.SnId = newpos.Id;
                }
                merchant.KqSnNo = NewSn;
                db.MachineChangeDetail.Add(new MachineChangeDetail()
                {
                    CreateDate = DateTime.Now,
                    UpdateDate = DateTime.Now,
                    CreateMan = SysUserName + "-" + SysRealName,
                    ChangeNo = ChangeNo, //订单号
                    ChangeId = add.Id, //订单Id
                    BackProductType = oldpos.BrandId, //退回产品类型
                    BackProductName = oldPosBrand.Name, //退回产品名称
                    UserId = 0, //创客
                    BackSnNo = oldpos.PosSn, //设备SN编号
                    OutProductType = newpos.BrandId, //出库产品类型
                    OutProductName = newPosBrand.Name, //出库产品名称
                    OutSnNo = newpos.PosSn, //出库设备SN编号
                    OutSnType = newpos.PosSnType, //出库SN机具类型
                    Remark = "机具更换", //备注
                    BackSnType = oldpos.PosSnType, //退回SN机具类型
                });
                db.SaveChanges();
                BackProductType = oldpos.BrandId;
                BackProductName = newPosBrand.Name;
                ChangeDeviceName = oldpos.DeviceName;
                ChangeSnExpand += oldpos.PosSn + "\n";
                PublicFunction.SycnMachineCount(oldpos.BuyUserId, oldpos.BrandId);
            }
            add.BackProductType = BackProductType; //退回产品类型
            add.BackProductName = BackProductName; //退回产品名称
            add.ChangeDeviceName = ChangeDeviceName; //转换机具名称
            add.ChangeDeviceNum = OldSnList.Length; //转换机具数量
            add.ChangeSnExpand = ChangeSnExpand; //机具SN
            BackStore.LaveNum += OldSnList.Length; //退回仓库库存
            OutStore.LaveNum -= OldSnList.Length; //出货仓库库存
            db.SaveChanges();
            db.Dispose();
            if (IsSend == 1)
            {
                RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                {
                    UserId = pos.BuyUserId, //接收创客
                    MsgType = 2,
                    Title = "换绑成功通知", //标题
                    Summary = "您的 " + oldPosBrand.Name + " SN:" + OldSn + "已经成功为客户换绑为" + newPosBrand.Name + "SN:" + NewSn + "请告知客户进行绑定。",
                    CreateDate = DateTime.Now,

                }));
            }
            return "success";
        }
        #endregion


        #region 坏机换新

        public IActionResult ChangeBadPos(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string ChangeBadPosDo(string ChangeType, string MakerCode, string StoreCode, string OldSn, string NewSn, string FromStoreNo, string BackStoreNo, int IsSend = 0)
        {
            string[] OldSnList;
            string[] NewSnList;
            decimal amount = 0;
            //创客坏机换新
            if (ChangeType == "0")
            {
                if (string.IsNullOrEmpty(MakerCode))
                {
                    return "请输入创客编号";
                }
                if (string.IsNullOrEmpty(OldSn))
                {
                    return "请输入坏机SN";
                }
                if (string.IsNullOrEmpty(NewSn))
                {
                    return "请输入新机SN";
                }
                if (string.IsNullOrEmpty(FromStoreNo))
                {
                    return "请输入新机发货仓库编号";
                }
                if (string.IsNullOrEmpty(BackStoreNo))
                {
                    return "请输入坏机退回仓库编号";
                }
                OldSnList = OldSn.Split('\n');
                NewSnList = NewSn.Split('\n');
                if (OldSnList.Length != NewSnList.Length)
                {
                    return "原机具SN数量和新机具SN数量不一致";
                }

                for (int i = 0; i < OldSnList.Length; i++)
                {
                    string OldSnNum = OldSnList[i];
                    string NewSnNum = NewSnList[i];
                    UserForMakerCode userForMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new UserForMakerCode();
                    StoreForCode storeForCodeFrom = db.StoreForCode.FirstOrDefault(m => m.Code == FromStoreNo) ?? new StoreForCode();
                    if (storeForCodeFrom.StoreId == 0)
                    {
                        return "您输入的新机发货仓库编号不存在";
                    }
                    StoreForCode storeForCodeBack = db.StoreForCode.FirstOrDefault(m => m.Code == BackStoreNo) ?? new StoreForCode();
                    if (storeForCodeBack.StoreId == 0)
                    {
                        return "您输入的坏机退回仓库编号不存在";
                    }
                    MachineForSnNo oldForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == OldSnNum) ?? new MachineForSnNo();
                    MachineForSnNo newForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == NewSnNum) ?? new MachineForSnNo();
                    PosMachinesTwo oldpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == oldForSnNo.SnId && m.BindingState == 0 && m.BuyUserId == userForMakerCode.UserId) ?? new PosMachinesTwo();
                    if (oldpos.Id == 0)
                    {
                        return "您输入的坏机SN不存在或者不在" + MakerCode + "名下";
                    }
                    PosMachinesTwo newpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == newForSnNo.SnId && m.BindingState == 0) ?? new PosMachinesTwo();
                    if (newpos.Id == 0)
                    {
                        return "您输入的新机SN不存在";
                    }
                    StoreHouse storeFrom = db.StoreHouse.FirstOrDefault(m => m.Id == storeForCodeFrom.StoreId);
                    if (Convert.ToInt32(storeFrom.BrandId) != Convert.ToInt32(oldpos.BrandId))
                    {
                        return "您输入的新机发货仓库不符新机机具对应品牌";
                    }
                    if (newpos.StoreId != storeFrom.Id)
                    {
                        return "您输入的新机SN不在新机发货仓库";
                    }
                    StoreHouse storeBack = db.StoreHouse.FirstOrDefault(m => m.Id == storeForCodeBack.StoreId);
                    if (Convert.ToInt32(storeBack.BrandId) != Convert.ToInt32(oldpos.BrandId))
                    {
                        return "您输入的坏机退回仓库不符坏机机具对应品牌";
                    }
                    var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == oldpos.BrandId) ?? new KqProducts();
                    if (brandInfo.Name.Contains("大POS"))
                    {
                        amount = 300;
                    }
                    if (brandInfo.Name.Contains("电签"))
                    {
                        amount = 200;
                    }
                    // var storeUserAcount = db.UserAccount.FirstOrDefault(m => m.Id == store.UserId) ?? new UserAccount();
                    var storeFromUserAcount = db.UserAccount.FirstOrDefault(m => m.Id == storeFrom.UserId) ?? new UserAccount();
                    var storeBackUserAcount = db.UserAccount.FirstOrDefault(m => m.Id == storeBack.UserId) ?? new UserAccount();
                    // storeUserAcount.ValidAmount += amount;
                    storeFromUserAcount.ValidAmount += amount;
                    storeBackUserAcount.ValidAmount -= amount;


                    newpos.BuyUserId = oldpos.BuyUserId;
                    newpos.UserId = oldpos.UserId;
                    newpos.RecycEndDate = oldpos.RecycEndDate;
                    newpos.ScanQrTrade = oldpos.ScanQrTrade;
                    newpos.DebitCardTrade = oldpos.DebitCardTrade;
                    newpos.CreditTrade = oldpos.CreditTrade;
                    newpos.PosSnType = oldpos.PosSnType;
                    newpos.TransferTime = oldpos.TransferTime;
                    newpos.IsPurchase = oldpos.IsPurchase;
                    newpos.BindingState = oldpos.BindingState;
                    newpos.ActivationState = oldpos.ActivationState;
                    newpos.BindingTime = oldpos.BindingTime;
                    newpos.ActivationTime = oldpos.ActivationTime;
                    newpos.IsFirst = oldpos.IsFirst;
                    newpos.SeoKeyword = oldpos.SeoKeyword;
                    newpos.PrizeParams = oldpos.PrizeParams;
                    newpos.LeaderUserId = oldpos.LeaderUserId;

                    newpos.StoreId = oldpos.StoreId;
                    newpos.UserId = oldpos.UserId;
                    newpos.PreUserId = oldpos.PreUserId;

                    oldpos.StoreId = storeBack.Id;
                    oldpos.BuyUserId = 0;
                    oldpos.UserId = 0;
                    oldpos.Status = -1;
                    db.SaveChanges();

                    BrokenMachineChange add = db.BrokenMachineChange.Add(new BrokenMachineChange()
                    {
                        CreateDate = DateTime.Now,
                        CreateMan = SysUserName + "-" + SysRealName,
                        ChangeNo = "BPC" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(3), //转换单号
                        OutStoreId = storeFrom.Id,
                        BackStoreId = storeBack.Id,
                        OutProductType = newpos.BrandId,
                        BackProductType = oldpos.BrandId,
                        UserId = userForMakerCode.UserId, //创客
                    }).Entity;
                    db.SaveChanges();
                    BrokenMachineChangeDetail adds = db.BrokenMachineChangeDetail.Add(new BrokenMachineChangeDetail()
                    {
                        CreateDate = DateTime.Now,
                        CreateMan = SysUserName + "-" + SysRealName,
                        OutSnNo = OldSnNum,
                        BackSnNo = NewSnNum,
                        ChangeNo = add.ChangeNo, //转换单号
                        ChangeId = add.Id, //转换记录Id
                        UserId = add.UserId, //创客
                    }).Entity;
                    db.SaveChanges();
                    var oldPosBrand = db.KqProducts.FirstOrDefault(m => m.Id == oldpos.BrandId) ?? new KqProducts();
                    if (IsSend == 1)
                    {
                        RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                        {
                            UserId = userForMakerCode.UserId, //接收创客
                            MsgType = 2,
                            Title = "坏机换新成功通知", //标题
                            Summary = "您的坏机 " + oldPosBrand.Name + " SN:" + OldSnNum + "已经成功为您换为" + oldPosBrand.Name + "SN:" + NewSnNum + "。",
                            CreateDate = DateTime.Now,

                        }));
                    }
                }
            }
            //仓库坏机换新
            else
            {
                if (string.IsNullOrEmpty(StoreCode))
                {
                    return "请输入仓库编号";
                }
                if (string.IsNullOrEmpty(OldSn))
                {
                    return "请输入坏机SN";
                }
                if (string.IsNullOrEmpty(NewSn))
                {
                    return "请输入新机SN";
                }
                if (string.IsNullOrEmpty(FromStoreNo))
                {
                    return "请输入新机发货仓库编号";
                }
                if (string.IsNullOrEmpty(BackStoreNo))
                {
                    return "请输入坏机退回仓库编号";
                }
                OldSnList = OldSn.Split('\n');
                NewSnList = NewSn.Split('\n');
                if (OldSnList.Length != NewSnList.Length)
                {
                    return "原机具SN数量和新机具SN数量不一致";
                }

                for (int i = 0; i < OldSnList.Length; i++)
                {
                    string OldSnNum = OldSnList[i];
                    string NewSnNum = NewSnList[i];
                    StoreHouse store = new StoreHouse();
                    StoreForCode storeForBadCode = db.StoreForCode.FirstOrDefault(m => m.Code == StoreCode) ?? new StoreForCode();
                    if (storeForBadCode.StoreId > 0)
                    {
                        store = db.StoreHouse.FirstOrDefault(m => m.Id == storeForBadCode.StoreId);
                    }
                    StoreForCode storeForCodeFrom = db.StoreForCode.FirstOrDefault(m => m.Code == FromStoreNo) ?? new StoreForCode();
                    if (storeForCodeFrom.StoreId == 0)
                    {
                        return "您输入的新机发货仓库编号不存在";
                    }
                    StoreForCode storeForCodeBack = db.StoreForCode.FirstOrDefault(m => m.Code == BackStoreNo) ?? new StoreForCode();
                    if (storeForCodeBack.StoreId == 0)
                    {
                        return "您输入的坏机退回仓库编号不存在";
                    }
                    MachineForSnNo oldForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == OldSnNum) ?? new MachineForSnNo();
                    MachineForSnNo newForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == NewSnNum) ?? new MachineForSnNo();
                    PosMachinesTwo oldpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == oldForSnNo.SnId && m.BindingState == 0 && m.StoreId == storeForBadCode.StoreId) ?? new PosMachinesTwo();
                    if (oldpos.Id == 0)
                    {
                        return "您输入的坏机SN不存在或者不在仓库" + StoreCode + "中";
                    }
                    PosMachinesTwo newpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == newForSnNo.SnId && m.BindingState == 0) ?? new PosMachinesTwo();
                    if (newpos.Id == 0)
                    {
                        return "您输入的新机SN不存在";
                    }
                    StoreHouse storeFrom = db.StoreHouse.FirstOrDefault(m => m.Id == storeForCodeFrom.StoreId);
                    if (Convert.ToInt32(storeFrom.BrandId) != Convert.ToInt32(oldpos.BrandId))
                    {
                        return "您输入的新机发货仓库不符新机机具对应品牌";
                    }
                    if (newpos.StoreId != storeFrom.Id)
                    {
                        return "您输入的新机SN不在新机发货仓库";
                    }
                    StoreHouse storeBack = db.StoreHouse.FirstOrDefault(m => m.Id == storeForCodeBack.StoreId);
                    if (Convert.ToInt32(storeBack.BrandId) != Convert.ToInt32(oldpos.BrandId))
                    {
                        return "您输入的坏机退回仓库不符坏机机具对应品牌";
                    }
                    var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == oldpos.BrandId) ?? new KqProducts();
                    if (brandInfo.Name.Contains("大POS"))
                    {
                        amount = 300;
                    }
                    if (brandInfo.Name.Contains("电签"))
                    {
                        amount = 200;
                    }
                    var storeUserAcount = db.UserAccount.FirstOrDefault(m => m.Id == store.UserId) ?? new UserAccount();
                    var storeFromUserAcount = db.UserAccount.FirstOrDefault(m => m.Id == storeFrom.UserId) ?? new UserAccount();
                    var storeBackUserAcount = db.UserAccount.FirstOrDefault(m => m.Id == storeBack.UserId) ?? new UserAccount();
                    // storeUserAcount.ValidAmount += amount;
                    storeFromUserAcount.ValidAmount += amount;
                    storeBackUserAcount.ValidAmount -= amount;
                    newpos.StoreId = oldpos.StoreId;
                    newpos.BuyUserId = oldpos.BuyUserId;
                    newpos.UserId = oldpos.UserId;
                    newpos.LeaderUserId = oldpos.LeaderUserId;
                    newpos.PreUserId = oldpos.PreUserId;
                    newpos.IsFirst = oldpos.IsFirst;
                    newpos.TransferTime = oldpos.TransferTime;

                    oldpos.StoreId = storeBack.Id;
                    oldpos.BuyUserId = 0;
                    oldpos.UserId = 0;
                    db.SaveChanges();

                    BrokenMachineChange add = db.BrokenMachineChange.Add(new BrokenMachineChange()
                    {
                        CreateDate = DateTime.Now,
                        CreateMan = SysUserName + "-" + SysRealName,
                        ChangeNo = "BPC" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(3), //转换单号
                        OutStoreId = storeFrom.Id,
                        BackStoreId = storeBack.Id,
                        OutProductType = newpos.BrandId,
                        BackProductType = oldpos.BrandId,
                        UserId = store.UserId, //创客
                    }).Entity;
                    db.SaveChanges();
                    BrokenMachineChangeDetail adds = db.BrokenMachineChangeDetail.Add(new BrokenMachineChangeDetail()
                    {
                        CreateDate = DateTime.Now,
                        CreateMan = SysUserName + "-" + SysRealName,
                        OutSnNo = OldSnNum,
                        BackSnNo = NewSnNum,
                        ChangeNo = add.ChangeNo, //转换单号
                        ChangeId = add.Id, //转换记录Id
                        UserId = add.UserId, //创客
                    }).Entity;
                    db.SaveChanges();
                    var oldPosBrand = db.KqProducts.FirstOrDefault(m => m.Id == oldpos.BrandId) ?? new KqProducts();
                    if (IsSend == 1)
                    {
                        RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                        {
                            UserId = store.UserId, //接收创客
                            MsgType = 2,
                            Title = "坏机换新成功通知", //标题
                            Summary = "您的坏机 " + oldPosBrand.Name + " SN:" + OldSnNum + "已经成功为您换为" + oldPosBrand.Name + "SN:" + NewSnNum + "。",
                            CreateDate = DateTime.Now,

                        }));
                    }
                }
            }
            // for (int i = 0; i < OldSnList.Length; i++)
            // {
            //     string OldSnNum = OldSnList[i];
            //     string NewSnNum = NewSnList[i];
            //     StoreForCode storeForCode = db.StoreForCode.FirstOrDefault(m => m.Code == BackStoreNo) ?? new StoreForCode();
            //     MachineForSnNo oldForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == OldSnNum) ?? new MachineForSnNo();
            //     MachineForSnNo newForSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == NewSnNum) ?? new MachineForSnNo();
            //     StoreHouse oldStore = new StoreHouse();
            //     PosMachinesTwo oldpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == oldForSnNo.SnId && m.BindingState == 0);
            //     if (storeForCode.StoreId > 0)
            //     {
            //         StoreHouse store = db.StoreHouse.FirstOrDefault(m => m.Id == storeForCode.StoreId);
            //         if (Convert.ToInt32(store.BrandId) != Convert.ToInt32(oldpos.BrandId))
            //         {
            //             return "您输入的仓库不符机具对应品牌";
            //         }
            //         oldStore = db.StoreHouse.FirstOrDefault(m => m.Id == oldpos.StoreId);
            //         oldpos.Status = -1;
            //         oldpos.StoreId = store.Id;
            //     }
            //     if (oldpos == null)
            //     {
            //         return "原机具SN不正确或者不符合换机条件";
            //     }
            //     PosMachinesTwo newpos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == newForSnNo.SnId && m.BuyUserId == 0 && m.UserId == 0 && m.BindingState == 0);
            //     if (newpos == null)
            //     {
            //         return "新机具SN不正确或者不为仓库机";
            //     }
            //     if (oldpos.BrandId != newpos.BrandId)
            //     {
            //         return "新机具和旧机具品牌不相同";
            //     }

            //     var brandInfo = db.KqProducts.FirstOrDefault(m => m.Id == newpos.BrandId) ?? new KqProducts();
            //     if (brandInfo.Name.Contains("大POS"))
            //     {
            //         amount = 300;
            //     }
            //     if (brandInfo.Name.Contains("电签"))
            //     {
            //         amount = 200;
            //     }
            //     var storehouse = db.StoreHouse.FirstOrDefault(m => m.Id == newpos.StoreId) ?? new StoreHouse();
            //     storehouse.LaveNum -= 1;
            //     var userAcount = db.UserAccount.FirstOrDefault(m => m.Id == storehouse.UserId) ?? new UserAccount();
            //     if (oldpos.StoreId != newpos.StoreId)
            //     {
            //         userAcount.ValidAmount += amount;
            //         newpos.StoreId = oldpos.StoreId;
            //         newpos.BuyUserId = oldpos.BuyUserId;
            //         newpos.UserId = oldpos.UserId;
            //         newpos.LeaderUserId = oldpos.LeaderUserId;
            //         newpos.PreUserId = oldpos.PreUserId;
            //         newpos.IsFirst = oldpos.IsFirst;
            //         newpos.TransferTime = oldpos.TransferTime;
            //     }
            //     else
            //     {
            //         newpos.BuyUserId = oldpos.BuyUserId;
            //         newpos.UserId = oldpos.UserId;
            //         newpos.LeaderUserId = oldpos.LeaderUserId;
            //         newpos.PreUserId = oldpos.PreUserId;
            //         newpos.IsFirst = oldpos.IsFirst;
            //         newpos.TransferTime = oldpos.TransferTime;
            //     }
            //     db.SaveChanges();

            //     var oldPosBrand = db.KqProducts.FirstOrDefault(m => m.Id == oldpos.BrandId) ?? new KqProducts();
            //     var newPosBrand = db.KqProducts.FirstOrDefault(m => m.Id == newpos.BrandId) ?? new KqProducts();
            //     var UserId = 0;
            //     if (oldpos.BuyUserId == 0)
            //     {
            //         UserId = oldStore.UserId;
            //     }
            //     else
            //     {
            //         UserId = oldpos.BuyUserId;
            //     }
            //     BrokenMachineChange add = db.BrokenMachineChange.Add(new BrokenMachineChange()
            //     {
            //         CreateDate = DateTime.Now,
            //         CreateMan = SysUserName + "-" + SysRealName,
            //         ChangeNo = "BPC" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(3), //转换单号
            //         UserId = UserId, //创客
            //     }).Entity;
            //     db.SaveChanges();
            //     BrokenMachineChangeDetail adds = db.BrokenMachineChangeDetail.Add(new BrokenMachineChangeDetail()
            //     {
            //         CreateDate = DateTime.Now,
            //         CreateMan = SysUserName + "-" + SysRealName,
            //         OutSnNo = OldSnNum,
            //         BackSnNo = NewSnNum,
            //         ChangeNo = add.ChangeNo, //转换单号
            //         ChangeId = add.Id, //转换记录Id
            //         UserId = add.UserId, //创客
            //     }).Entity;
            //     db.SaveChanges();
            //     if (IsSend == 1)
            //     {
            //         RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
            //         {
            //             UserId = UserId, //接收创客
            //             MsgType = 2,
            //             Title = "坏机换新成功通知", //标题
            //             Summary = "您的坏机 " + oldPosBrand.Name + " SN:" + OldSn + "已经成功为您换为" + newPosBrand.Name + "SN:" + NewSn + "。",
            //             CreateDate = DateTime.Now,

            //         }));
            //     }
            // }
            return "success";
        }
        #endregion


        #region 机具解绑

        public IActionResult Unbind(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string UnbindDo(string PosSn, string MakerCode, string MerNo, int IsSend = 0)
        {
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN";
            }
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == PosSn);
            if (forSnNo == null)
            {
                return "机具SN不存在";
            }
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId);
            if (pos == null)
            {
                return "机具SN不存在";
            }
            if (string.IsNullOrEmpty(MerNo) && pos.BrandId != 1 && pos.BrandId != 3)
            {
                return "请输入商户编号";
            }
            UserForMakerCode forMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (forMakerCode == null)
            {
                return "创客不存在";
            }
            MachineForMerNo forMerNo = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == MerNo);
            if (forMerNo == null && pos.BrandId != 1 && pos.BrandId != 3)
            {
                return "商户编号不存在";
            }
            if (pos.BuyUserId != forMakerCode.UserId)
            {
                return "机具SN和创客不匹配";
            }
            if (pos.ActivationState == 1)
            {
                return "机具已激活，不能解绑";
            }
            if (pos.BuyUserId == 0)
            {
                return "机具是仓库机，不支持解绑";
            }
            if (pos.BindingState == 0)
            {
                return "机具未绑定，不支持解绑";
            }
            if (pos.BindingTime < DateTime.Now.AddDays(-30) && SysUserName != "admin")
            {
                return "机具绑定已超过30天，不支持解绑";
            }
            if (forMerNo != null)
            {
                PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                if (merchant != null)
                {
                    //机具解绑删除客小爽企业版对应数据
                    var merInfo = db.BusinessPartnerMerchant.FirstOrDefault(m => m.MerchantId == merchant.Id);
                    if (merInfo != null)
                    {
                        db.BusinessPartnerMerchant.Remove(merInfo);
                    }
                    var posInfo = db.BusinessPartnerPos.FirstOrDefault(m => m.PosId == pos.Id);
                    if (posInfo != null)
                    {
                        db.BusinessPartnerPos.Remove(posInfo);
                    }

                    db.PosMerchantInfo.Remove(merchant);
                }
                db.MachineForMerNo.Remove(forMerNo);
                db.SaveChanges();
            }
            db.MachineUnBind.Add(new MachineUnBind()
            {
                CreateDate = DateTime.Now,
                SeoTitle = SysUserName + "-" + SysRealName,
                MerchantId = pos.BindMerchantId,
                AuditDate = DateTime.Now,
                AuditDesc = "平台操作解绑",
                AuditStatus = 1,
                SnNo = pos.PosSn,
                BrandId = pos.BrandId,
                UserId = pos.BuyUserId,
                ApplyNo = "U" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8),
            });
            pos.BindMerchantId = 0;
            pos.BindingState = 0;
            pos.BindingTime = DateTime.Parse("1900-01-01");
            pos.UserId = pos.BuyUserId;
            string IdBrand = pos.BuyUserId + "_" + pos.BrandId;
            db.SaveChanges();
            PublicFunction.SycnMachineCount(pos.BuyUserId, pos.BrandId);
            if (IsSend == 1)
            {
                RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                {
                    UserId = pos.BuyUserId, //接收创客
                    MsgType = 2,
                    Title = "解绑成功通知", //标题
                    Summary = "" + PosSn + "机具已成功解绑，当前机具如需绑定同一客户请再2个工作日后再进行绑定，直接绑定会导致数控异常，相关损失由您本人承担。",
                    CreateDate = DateTime.Now,
                }));
            }
            return "success";
        }
        #endregion


        #region 通过券码修改盟主标记

        public IActionResult ChangeSignQuan(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string ChangeSignQuanDo(string Coupons, string MakerCode)
        {
            if (string.IsNullOrEmpty(Coupons))
            {
                return "请输入机具券码，多个券码用回车分隔";
            }
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            UserForMakerCode forMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (forMakerCode == null)
            {
                return "创客不存在";
            }
            string[] SnList = Coupons.Split('\n');
            foreach (var item in SnList)
            {
                var coupos = db.PosCoupons.FirstOrDefault(m => m.ExchangeCode == item && m.LeaderUserId == 0);
                if (coupos == null)
                {
                    return "机具券不存在";
                }
                else
                {
                    coupos.LeaderUserId = forMakerCode.UserId;
                }
            }
            db.SaveChanges();
            return "success";
        }
        #endregion


        #region 通过机具SN修改盟主标记

        public IActionResult ChangeSignSn(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string ChangeSignSnDo(string PosSn, string MakerCode)
        {
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN，多个SN用回车分隔";
            }
            if (string.IsNullOrEmpty(MakerCode))
            {
                return "请输入创客编号";
            }
            UserForMakerCode forMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (forMakerCode == null)
            {
                return "创客不存在";
            }
            string[] SnList = PosSn.Split('\n');
            foreach (var item in SnList)
            {
                var pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == item && m.LeaderUserId == 0);
                if (pos == null)
                {
                    return "该机具不存在";
                }
                else
                {
                    pos.LeaderUserId = forMakerCode.UserId;
                }
            }
            db.SaveChanges();
            return "success";
        }
        #endregion


        #region 机具循环列表

        /// <summary>
        /// 根据条件查询机具循环列表
        /// </summary>
        /// <returns></returns>
        public IActionResult Loop(string right, string SwapSnExpand, string SnNos)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;
            ViewBag.SwapSnExpand = SwapSnExpand;
            ViewBag.SnNos = SnNos;

            return View();
        }

        #endregion

        #region 根据条件查询机具循环列表

        /// <summary>
        /// 机具循环列表
        /// </summary>
        /// <returns></returns>

        public IActionResult LoopData(string SwapSnExpand, string SnNos, int page = 1, int limit = 30)
        {
            Dictionary<string, string> Fields = new Dictionary<string, string>();
            Fields.Add("SwapSnExpand", "1"); //申请机具SN
            Fields.Add("SnNos", "1"); //发货机具SN
            List<Dictionary<string, object>> dataList = new List<Dictionary<string, object>>();

            if (!string.IsNullOrEmpty(SwapSnExpand))
            {
                var apply = db.MachineApply.FirstOrDefault(m => m.Status > -1 && m.SwapSnExpand.Contains(SwapSnExpand)) ?? new MachineApply();
                var order = db.Orders.FirstOrDefault(m => m.Id == apply.QueryCount) ?? new Orders();
                var user = db.Users.FirstOrDefault(m => m.Id == apply.UserId) ?? new Users();
                string[] SnNoList = function.CheckNull(apply.SwapSnExpand).TrimEnd('\n').Split('\n');
                string[] OrderSnNo = function.CheckNull(order.SnNos).Split(',');
                for (int i = 0; i < SnNoList.Length; i++)
                {
                    Dictionary<string, object> data = new Dictionary<string, object>();
                    data["ApplyNo"] = apply.ApplyNo;
                    data["OrderNo"] = order.OrderNo;
                    data["MakerCode"] = user.MakerCode;
                    data["RealName"] = user.RealName;
                    if(SnNoList.Length > i)
                    {
                        data["ComeSn"] = SnNoList[i];
                        data["ComeSnParam"] = SnNoList[i].Split(':')[0];
                    }
                    if(OrderSnNo.Length > i)
                    {
                        data["SendSn"] = OrderSnNo[i];
                    }
                    data["CreateDate"] = apply.CreateDate == null ? "" : apply.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
                    data["Status"] = order.Status == 2 ? "已发货" : "未发货";
                    dataList.Add(data);
                }
            }
            else if (!string.IsNullOrEmpty(SnNos))
            {
                var order = db.Orders.FirstOrDefault(m => m.Status > -1 && m.SnNos.Contains(SnNos)) ?? new Orders();
                var apply = db.MachineApply.FirstOrDefault(m => m.Id == order.Sort) ?? new MachineApply();
                var user = db.Users.FirstOrDefault(m => m.Id == apply.UserId) ?? new Users();
                string[] SnNoList = function.CheckNull(apply.SwapSnExpand).TrimEnd('\n').Split('\n');
                string[] OrderSnNo = function.CheckNull(order.SnNos).Split(',');
                for (int i = 0; i < OrderSnNo.Length; i++)
                {
                    Dictionary<string, object> data = new Dictionary<string, object>();
                    data["ApplyNo"] = apply.ApplyNo;
                    data["OrderNo"] = order.OrderNo;
                    data["MakerCode"] = user.MakerCode;
                    data["RealName"] = user.RealName;
                    if(SnNoList.Length > i)
                    {
                        data["ComeSn"] = SnNoList[i];
                        data["ComeSnParam"] = SnNoList[i].Split(':')[0];
                    }
                    if(OrderSnNo.Length > i)
                    {
                        data["SendSn"] = OrderSnNo[i];
                    }
                    data["CreateDate"] = apply.CreateDate == null ? "" : apply.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
                    data["Status"] = order.Status == 2 ? "已发货" : "未发货";
                    dataList.Add(data);
                }
            }
            Dictionary<string, object> obj = new Dictionary<string, object>();
            obj.Add("code", 0);
            obj.Add("msg", "");
            obj.Add("count", dataList.Count);
            obj.Add("data", dataList);
            return Json(obj);
        }

        #endregion


        #region 查询创客直推奖

        public IActionResult Prize100(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public Dictionary<string, string> Prize100Do(string MakerCode)
        {
            Dictionary<string, string> dic = new Dictionary<string, string>();
            string result = "";
            UserForMakerCode forMakerCode = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == MakerCode);
            if (forMakerCode == null)
            {
                result += "创客编号不存在\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            int OrderCount = db.Orders.Count(m => m.UserId == forMakerCode.UserId && m.PayStatus == 1 && m.TotalPrice == 600);
            if (OrderCount == 0)
            {
                result += "该创客未下单\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            if (OrderCount > 1)
            {
                result += "该创客已不是首笔下单\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            Orders order = db.Orders.FirstOrDefault(m => m.UserId == forMakerCode.UserId && m.PayStatus == 1 && m.TotalPrice == 600) ?? new Orders();
            if (order.PayStatus < 1)
            {
                result += "未付款\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
            Users puser = db.Users.FirstOrDefault(m => m.Id == user.ParentUserId) ?? new Users();
            result += "订单号：" + order.OrderNo + "\n";
            result += "下单创客\n创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile + "\n";
            result += "上级创客\n创客编号：" + puser.MakerCode + "，姓名：" + puser.RealName + "，手机号：" + puser.Mobile + "\n";
            int machineCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.PosSnType == 0); //判断是否拥有3台购买机
            int ActiveCount = db.PosMachinesTwo.Count(m => m.UserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送）
            if (machineCount + ActiveCount >= 3)
            {
                string IsGet = "未发放";
                int ToUserId = 0;
                UserAccountRecord item = db.UserAccountRecord.FirstOrDefault(m => m.QueryCount == order.Id && m.ChangeType == 112);
                if (item == null)
                {
                    DateTime start = order.PayDate.Value.AddMinutes(-2);
                    DateTime end = order.PayDate.Value.AddMinutes(2);
                    item = db.UserAccountRecord.FirstOrDefault(m => m.UserId == puser.Id && m.ChangeType == 112 && m.ChangeAmount == 100 && m.CreateDate >= start && m.CreateDate <= end);
                }
                if (item != null)
                {
                    IsGet = "已发放(发放时间:" + item.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") + ")";
                    ToUserId = item.UserId;
                    dic.Add("code", "1");
                }
                else
                {
                    dic.Add("id", order.Id.ToString());
                    dic.Add("code", "0");
                }
                Users touser = db.Users.FirstOrDefault(m => m.Id == ToUserId) ?? new Users();
                result += "是否发放：" + IsGet + "\n";
                result += "应该发放对象\n创客编号：" + puser.MakerCode + "，姓名：" + puser.RealName + "，手机号：" + puser.Mobile + "\n";
                result += "实际发放对象\n创客编号：" + touser.MakerCode + "，姓名：" + touser.RealName + "，手机号：" + touser.Mobile + "\n";
            }
            else
            {
                result += "上级创客未满足条件\n购买机：" + machineCount + "台，激活机：" + ActiveCount + "台\n";
                dic.Add("code", "1");
            }
            dic.Add("result", result);
            return dic;
        }
        public string AddPrize100(int Id)
        {
            Orders order = db.Orders.FirstOrDefault(m => m.Id == Id);
            if (order != null)
            {
                //机具券逻辑
                OrderProduct pro = db.OrderProduct.FirstOrDefault(m => m.OrderId == Id);
                if (pro != null)
                {
                    //推荐下单奖励
                    if (pro.ProductId == 10 || pro.ProductId == 11)
                    {
                        int OrderId = order.Id;
                        bool checkPrize = db.UserAccountRecord.Any(m => m.QueryCount == OrderId && m.ChangeType == 112);
                        if (!checkPrize)
                        {
                            Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId);
                            if (user != null)
                            {
                                bool directPrize = false; //直推奖标记
                                int ParentUserId = user.ParentUserId;
                                // List<int> proids = new List<int>();
                                // proids.Add(10);
                                // proids.Add(11);
                                while (ParentUserId > 0)
                                {
                                    Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
                                    int machineCount = db.PosMachinesTwo.Count(m => m.UserId == ParentUserId && m.PosSnType == 0); //判断是否拥有3台购买机
                                    int ActiveCount = db.PosMachinesTwo.Count(m => m.UserId == ParentUserId && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送）
                                    int couponCount = db.PosCoupons.Count(m => m.UserId == ParentUserId && m.IsUse == 0); //判断是否拥有3张券
                                    if ((machineCount + ActiveCount + couponCount >= 3 || puser.LeaderLevel > 0) && !directPrize)
                                    {
                                        DirectPrize(db, order.Id, ParentUserId, pro.ProductCount);
                                        directPrize = true;
                                        db.SaveChanges();
                                        return "发放成功";
                                    }
                                    ParentUserId = puser.ParentUserId;
                                }
                            }
                        }
                        return "已发放，请勿重复发放";
                    }
                }
            }
            return "操作失败";
        }
        public void DirectPrize(WebCMSEntities db, int OrderId, int UserId, int Count = 1)
        {
            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
            if (account == null)
            {
                account = db.UserAccount.Add(new UserAccount()
                {
                    Id = UserId,
                    UserId = UserId,
                }).Entity;
                db.SaveChanges();
            }
            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
            account.BalanceAmount += 100 * Count;
            account.TotalAmount += 100 * Count;
            decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
            decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
            decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
            UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
            {
                CreateDate = DateTime.Now,
                UpdateDate = DateTime.Now,
                UserId = UserId, //创客
                ChangeType = 112, //变动类型
                ChangeAmount = 100 * Count, //变更金额
                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                AfterTotalAmount = AfterTotalAmount, //变更后总金额
                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                QueryCount = OrderId,
            }).Entity;
            db.SaveChanges();
        }
        #endregion

        #region 查询机具开机奖

        public IActionResult OpenPrize(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public Dictionary<string, string> OpenPrizeDo(string PosSn)
        {
            Dictionary<string, string> dic = new Dictionary<string, string>();
            string result = "";
            PosMachinesTwo pos = db.PosMachinesTwo .FirstOrDefault(m => m.PosSn == PosSn);
            if (pos == null)
            {
                result += "机具SN号不存在\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            if(pos.BindingState == 0)
            {
                result += "机具未绑定\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            if(pos.ActivationState == 0)
            {
                result += "机具未激活\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
            if (merchant == null)
            {
                result += "商户不存在\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            Users buyuser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
            result += "机具号：" + PosSn + "\n";
            result += "机具所属人：\n创客编号：" + buyuser.MakerCode + "，姓名：" + buyuser.RealName + "，手机号：" + buyuser.Mobile + "\n";
            result += "商户信息\n商户编号：" + merchant.KqMerNo + "，姓名：" + merchant.MerchantName + "，手机号：" + merchant.MerchantMobile + "\n";
            string OpenUser10 = "未领取";
            string OpenUser20 = "未领取";
            var OpenRewardDetail = db.OpenRewardDetail.Where(m => m.SnNo == pos.PosSn).ToList();
            OpenRewardDetail openreward = OpenRewardDetail.FirstOrDefault(m => m.CreditRewardAmount == 20) ?? new OpenRewardDetail();
            if (openreward.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == openreward.UserId) ?? new Users();
                OpenUser20 = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
            }
            openreward = OpenRewardDetail.FirstOrDefault(m => m.CreditRewardAmount == 10) ?? new OpenRewardDetail();
            if (openreward.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == openreward.UserId) ?? new Users();
                OpenUser10 = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
            }
            result += "开机奖20：" + OpenUser20 + "\n";
            result += "开机奖10：" + OpenUser10 + "\n";
            dic.Add("id", pos.Id.ToString());
            dic.Add("code", "0");
            dic.Add("result", result);
            return dic;
        }
        public string AddOpenPrize(int Id)
        {
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == Id && m.ActivationState == 1);
            if (pos == null)
            {
                return "机具未激活";
            }
            if (pos.BindingTime < DateTime.Now.AddDays(-30))
            {
                return "绑定已超过30天";
            }
            decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
            if (ActPrize == 0)
            {
                return "机具无押金";
            }
            PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
            if (merchant == null)
            {
                return "商户不存在";
            }
            bool check = db.OpenRewardDetail.Any(m => m.SnNo == pos.PosSn);
            if(check)
            {
                return "开机奖励已发放，请勿重复操作";
            }
            // 从机具所属人上级开始分开机奖励
            Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
            if (user != null)
            {
                if (!string.IsNullOrEmpty(user.ParentNav))
                {
                    decimal Prize = 20;
                    List<string> PrizeFlag = new List<string>();
                    string[] ParentNavs = user.ParentNav.Trim(',').Replace(",,", ",").Split(',');
                    for (int i = ParentNavs.Length - 1; i >= 0; i--)
                    {
                        int UserId = int.Parse(ParentNavs[i]);
                        Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1);
                        if (puser != null && Prize > 0)
                        {
                            int machineCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.PosSnType == 0); //判断是否拥有3台购买机
                            int ActiveCount = db.PosMachinesTwo.Count(m => m.BuyUserId == puser.Id && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送）
                            int couponCount = db.PosCoupons.Count(m => m.UserId == puser.Id && m.IsUse == 0); //判断是否拥有3张券
                            if (machineCount + ActiveCount + couponCount >= 3)
                            {
                                int pTopUserId = 0;
                                if (!string.IsNullOrEmpty(puser.ParentNav))
                                {
                                    pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                                }
                                Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                                OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
                                {
                                    CreateDate = DateTime.Now,
                                    UpdateDate = DateTime.Now,
                                    TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
                                    TradeDate = pos.ActivationTime, //达标日期
                                    UserId = puser.Id, //创客
                                    BrandId = pos.BrandId, //品牌
                                    ProductName = RelationClass.GetKqProductBrandInfo(pos.BrandId), //产品名称
                                    MerchantId = pos.BindMerchantId, //商户
                                    DirectUserId = merchant.UserId, //商户直属人
                                    SnNo = pos.PosSn, //SN号
                                    MerNo = merchant.KqMerNo, //渠道商户号
                                    SnType = pos.PosSnType, //机具类型
                                    StandardDate = pos.ActivationTime, //商户的激活日期
                                    SnStoreId = pos.StoreId, //SN仓库
                                    MerBuddyType = puser.MerchantType, //商户创客类型
                                    RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励
                                    RewardTips = "开机奖励", //奖励描述
                                    CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
                                    DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
                                    CreditRewardAmount = Prize, //贷记卡交易奖励金额
                                    RewardDesc = "开机奖励", //奖励描述
                                    TopUserId = pTopUserId, //顶级创客
                                    SeoTitle = machineUser.RealName,
                                }).Entity;
                                db.OpenReward.Add(new OpenReward()
                                {
                                    CreateDate = DateTime.Now,
                                    UpdateDate = DateTime.Now,
                                    TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
                                    TradeDate = DateTime.Now, //达标日期
                                    UserId = puser.Id, //创客
                                    BrandId = pos.BrandId, //品牌
                                    RewardType = 2, //奖励类型
                                    CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
                                    DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
                                    CreditRewardAmount = Prize, //贷记卡交易奖励金额
                                    RewardDesc = "开机奖励", //奖励描述
                                    TopUserId = pTopUserId, //顶级创客
                                });
                                string IdBrand = puser.Id + "_" + pos.BrandId;
                                UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                                if (userData == null)
                                {
                                    userData = db.UserMachineData.Add(new UserMachineData()
                                    {
                                        IdBrand = IdBrand,
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                userData.OpenProfit += Prize;
                                db.SaveChanges();
                                RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                                //账户入库
                                UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
                                if (account == null)
                                {
                                    account = db.UserAccount.Add(new UserAccount()
                                    {
                                        Id = puser.Id,
                                        UserId = puser.Id,
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                //收支明细入库
                                decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                                decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                                decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                                account.BalanceAmount += Prize;
                                account.TotalAmount += Prize;
                                decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                                decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                                decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                                UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                                {
                                    CreateDate = DateTime.Now,
                                    UpdateDate = DateTime.Now,
                                    UserId = puser.Id, //创客
                                    ChangeType = 50, //变动类型
                                    ProductType = pos.BrandId, //产品类型
                                    ChangeAmount = Prize, //变更金额
                                    BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                                    AfterTotalAmount = AfterTotalAmount, //变更后总金额
                                    BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                                    AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                                    BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                                    AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                                }).Entity;
                                db.SaveChanges();
                                RedisDbconn.Instance.Set("UserAccount:" + puser.Id, account);

                                string dateString = DateTime.Now.ToString("yyyyMMdd");
                                string monthString = DateTime.Now.ToString("yyyyMM");
                                // 开机奖励列表
                                List<string> dates = RedisDbconn.Instance.GetList<string>("OpenRewardDay:" + puser.Id + ":" + pos.BrandId);
                                if (!dates.Contains(dateString))
                                {
                                    RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString);
                                }
                                RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize);

                                List<string> months = RedisDbconn.Instance.GetList<string>("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId);
                                if (!months.Contains(monthString))
                                {
                                    RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString);
                                }
                                RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize);

                                // 开机奖励详情
                                RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail);

                                //收支明细
                                RedisDbconn.Instance.AddList("UserAccountRecord:" + puser.Id + ":1:" + monthString, userAccountRecord);
                                RedisDbconn.Instance.AddNumber("UserAccount:" + puser.Id + ":1:" + monthString, Prize);

                                Prize -= 10;
                                PrizeFlag.Add(Prize.ToString("f0"));
                            }
                        }
                    }
                    string result = "";
                    if(!PrizeFlag.Contains("20"))
                    {
                        result += "20元奖励未发，请检查上级是否满足条件\n";
                    }
                    if(!PrizeFlag.Contains("10"))
                    {
                        result += "10元奖励未发，请检查上级是否满足条件\n";
                    }
                    if(string.IsNullOrEmpty(result))
                    {
                        return "发放成功";
                    }
                    return result;
                }
            }
            db.Dispose();
            return "操作失败";
        }
        
        #endregion

        #region 查询机具流量费分佣

        public IActionResult FluxPrize(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public Dictionary<string, string> FluxPrizeDo(string PosSn)
        {
            Dictionary<string, string> dic = new Dictionary<string, string>();
            string result = "";
            PosMachinesTwo pos = db.PosMachinesTwo .FirstOrDefault(m => m.PosSn == PosSn);
            if (pos == null)
            {
                result += "机具SN号不存在\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            if(pos.BindingState == 0)
            {
                result += "机具未绑定\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            if(pos.ActivationState == 0)
            {
                result += "机具未激活\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
            if (merchant == null)
            {
                result += "商户不存在\n";
                dic.Add("code", "1");
                dic.Add("result", result);
                return dic;
            }
            Users buyuser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
            result += "机具号：" + PosSn + "\n";
            result += "机具所属人：\n创客编号：" + buyuser.MakerCode + "，姓名：" + buyuser.RealName + "，手机号：" + buyuser.Mobile + "\n";
            result += "商户信息\n商户编号：" + merchant.KqMerNo + "，姓名：" + merchant.MerchantName + "，手机号：" + merchant.MerchantMobile + "\n";
            string FluxGet6 = "未领取";
            string FluxUser6 = "";
            FluxProfitDetail flux = db.FluxProfitDetail.FirstOrDefault(m => m.SnNo == pos.PosSn) ?? new FluxProfitDetail();
            if (flux.Id > 0)
            {
                Users user = db.Users.FirstOrDefault(m => m.Id == flux.UserId) ?? new Users();
                FluxGet6 = "已领取（领取时间：" + flux.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") + "）";
                FluxUser6 = "创客编号：" + user.MakerCode + "，姓名：" + user.RealName + "，手机号：" + user.Mobile;
            }
            result += "流量费：" + FluxGet6 + "\n";
            result += "流量费发放对象：" + FluxUser6 + "\n";
            dic.Add("id", pos.Id.ToString());
            dic.Add("code", "0");
            dic.Add("result", result);
            return dic;
        }
        public string AddFluxPrize(int Id)
        {
            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == Id && m.ActivationState == 1);
            if (pos == null)
            {
                return "机具未激活";
            }
            if (pos.BindingTime < DateTime.Now.AddDays(-30))
            {
                return "绑定已超过30天";
            }
            decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
            if (ActPrize == 0)
            {
                return "机具无押金";
            }
            PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
            if (merchant == null)
            {
                return "商户不存在";
            }
            if(pos.BrandId == 6)
            {
                return "立刷不支持流量费分佣";
            }
            if(decimal.Parse(function.CheckNum(pos.SeoKeyword)) <= 0)
            {
                return "无押金机，不支持流量费分佣";
            }
            bool check = db.FluxProfitDetail.Any(m => m.MerNo == merchant.KqMerNo);
            if(check)
            {
                return "开机奖励已发放，请勿重复操作";
            }
            SpModels.TradeFluxRecord trade = spdb.TradeFluxRecord.FirstOrDefault(m => m.TradeSnNo == pos.PosSn);
            if(trade != null)
            {
                try
                {
                    string OrderNo = trade.TradeSerialNo; //单号
                    DateTime TradeDate = trade.CreateDate.Value;
                    string TradeMonth = TradeDate.ToString("yyyyMM");
                    decimal FeeAmount = trade.FeeAmount; //流量费
                    if (trade.ProductType == "1" || trade.ProductType == "4" || trade.ProductType == "6" || trade.ProductType == "8" || trade.ProductType == "9")
                    {
                        FeeAmount = FeeAmount / 100;
                    }
                    string TradeSnNo = trade.TradeSnNo; //机具SN
                    decimal FluxProfit = 0;
                    if (trade.ProductType == "1" && FeeAmount == 60)
                    {
                        FluxProfit = 24;
                    }
                    else if (trade.ProductType == "7" && FeeAmount == 46)
                    {
                        FluxProfit = 10;
                    }
                    else if (trade.ProductType != "1" && FeeAmount == 48)
                    {
                        FluxProfit = 12;
                    }
                    if (FluxProfit > 0)
                    {
                        Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
                        int GetUserId = user.Id;
                        int TopUserId = 0;
                        string ParentNav = user.ParentNav;
                        if (!string.IsNullOrEmpty(ParentNav))
                        {
                            string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                            if (ParentNavList.Length > 1)
                            {
                                TopUserId = int.Parse(ParentNavList[1]);
                            }
                            else if (ParentNavList.Length == 1)
                            {
                                TopUserId = int.Parse(ParentNavList[0]);
                            }
                        }
                        FluxProfitSummary fluxProfit = db.FluxProfitSummary.FirstOrDefault(m => m.UserId == GetUserId && m.BrandId == pos.BrandId && m.TradeMonth == TradeMonth);
                        if (fluxProfit == null)
                        {
                            fluxProfit = db.FluxProfitSummary.Add(new FluxProfitSummary()
                            {
                                CreateDate = DateTime.Now,
                                UpdateDate = DateTime.Now,
                                UserId = GetUserId, //创客
                                BrandId = pos.BrandId,
                                TopUserId = TopUserId, //顶级创客
                                TradeMonth = TradeMonth, //交易月
                                MerUserType = user.MerchantType, //商户创客类型
                                Remark = "流量卡分佣", //备注
                            }).Entity;
                            db.SaveChanges();
                        }
                        fluxProfit.FluxProfitAmt += FluxProfit; //流量分润总金额
                        db.FluxProfitDetail.Add(new FluxProfitDetail()
                        {
                            CreateDate = DateTime.Now,
                            UpdateDate = DateTime.Now,
                            RecordNo = OrderNo, //单号
                            TradeDate = TradeDate.ToString("yyyyMMdd"), //交易日期
                            TradeTime = TradeDate.ToString("HHmmss"), //交易时间
                            TradeMonth = TradeMonth, //交易月
                            UserId = GetUserId, //创客
                            MerchantId = pos.BindMerchantId, //商户
                            MerchantUserId = pos.UserId, //商户直属人
                            MerNo = merchant.KqMerNo, //渠道商户编号
                            SnNo = pos.PosSn, //渠道SN号
                            FluxOrderNo = OrderNo, //流量扣费单号
                            TradeOrderNo = OrderNo, //交易流水号
                            TradeAmt = trade.TradeAmount, //商户交易额
                            FluxFeeAmt = FeeAmount, //流量费
                            FluxProfitAmt = FluxProfit, //流量分润总金额
                            PosType = pos.PosSnType.ToString(), //POS类型
                            Remark = "流量卡分佣", //备注
                            BrandId = pos.BrandId, //品牌
                            TopUserId = TopUserId, //顶级创客
                            MerUserType = user.MerchantType, //商户创客类型
                        });
                        string IdBrand = user.Id + "_" + pos.BrandId;
                        UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                        if (userData == null)
                        {
                            userData = db.UserMachineData.Add(new UserMachineData()
                            {
                                IdBrand = IdBrand,
                            }).Entity;
                            db.SaveChanges();
                        }
                        userData.FluxProfit += FluxProfit;
                        db.SaveChanges();
                        RedisDbconn.Instance.Clear("UserMachineData:" + IdBrand);
                        UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                        if (account == null)
                        {
                            account = db.UserAccount.Add(new UserAccount()
                            {
                                Id = GetUserId,
                                UserId = GetUserId,
                            }).Entity;
                            db.SaveChanges();
                        }
                        decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
                        decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
                        decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
                        account.BalanceAmount += FluxProfit;
                        account.TotalAmount += FluxProfit;
                        decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                        decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                        decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                        UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
                        {
                            CreateDate = DateTime.Now,
                            UpdateDate = DateTime.Now,
                            UserId = GetUserId, //创客
                            ChangeType = 60, //变动类型
                            ProductType = pos.BrandId, //产品类型
                            ChangeAmount = FluxProfit, //变更金额
                            BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                            AfterTotalAmount = AfterTotalAmount, //变更后总金额
                            BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                            AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                            BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                            AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                        }).Entity;
                        db.SaveChanges();
                        spdb.Dispose();
                        db.Dispose();
                        return "发放成功";
                    }
                }
                catch (Exception ex)
                {
                    function.WriteLog(DateTime.Now.ToString() + "\n$" + trade.Id + "$\n" + ex.ToString(), "流量卡分佣异常");
                }
            }
            spdb.Dispose();
            db.Dispose();
            return "操作失败";
        }
        
        #endregion

        #region 设置立刷费率

        public IActionResult LisFee(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string LisFeeDo(string PosSns, decimal Fee, string Kind, string Fix)
        {
            if (string.IsNullOrEmpty(PosSns))
            {
                return "请输入机具号";
            }
            string result = SysUserName + "设置\n";
            string[] PosSnList = PosSns.Split('\n');
            int total = PosSnList.Length;
            int index = 0;
            foreach (string SubPosSn in PosSnList)
            {
                index += 1;
                string PosSn = SubPosSn.Replace("\r", "");
                result += PosSn + ":" + Fee + "\n";
                if (Kind == "M5")
                {
                    result += SetLiSFee(PosSn, Fee) + "\n";
                }
                else if (Kind == "N1")
                {
                    result += SetLiSDeposit(PosSn, (int)Fee);
                }
                RedisDbconn.Instance.Set("LisFeeProcess:" + SysId, index + " / " + total);
            }
            result += "\n\n";
            function.WriteLog(result, "设置立刷费率");
            return result;
        }
        public string LisFeeProcess()
        {
            return RedisDbconn.Instance.Get<string>("LisFeeProcess:" + SysId);
        }

        #region 立刷

        string LiSAgentId = "50814834";
        string LiSPrivateKey = "MIIJQwIBADANBgkqhkiG9w0BAQEFAASCCS0wggkpAgEAAoICAQDTdeLXqQmfVJM/ATVnq+TdhgpKKPp3hXcuY2s9qrN1Uws7I7jqnq/gfoBHBWBu/PnQp/z65okBoz4PEpWzJYZDF4csgh3E45He46ialNzUlOPWv6yLzgQPHuneq2pXOb7dbN4kZx+g3nEbBjH+/P9xp+lU3HCwjNxIFSr3EyBAQf2HgvNqh70u9T13fGVx3Jtd2xbIKYhvGNPH9ZCGiZNiCy+m+F+TKywgKK/xify1KQgR6otVUOVIGYvPYlXAgLJM2/V54166KX1UUFMsKRj4Kt2j4GqoHzDfRk9ibYJ/8iSDGX4+WH5+8mq/raqA77VcAD+bMrt3Bm59XmaWtjZwDY1zh5sP5jEaxu4lde2xZD80kQ6p1ZydpqnjmWm6NKXSz8j85gRkTQqNALKNANnJb6f1Yy30WirnrhMkqU2dqBzzXxtk3k/2zv9BENjYs1igrRYpwX3QRx87aTOrIk/PO6cxMaWl249LPigah0OqVyIg5yOvtnUCdU12OqaVELIw5GnZ7rTRn3tAsJ+u1om+3XktbN3GUEpw5RWAT3UAsAU7Vxt9xPCss+JXF+ogXYgo9QpEjanXOfLo5KPv2CkBuzy87d85OId71gXpYcbp0zbKz5eXKZanVP9pwn43jqiPkqtam8N1TLCCmZ4t2cd+gpW2CX/+W7bmc25HJtRPuwIDAQABAoICAE7B9GfwTGYsYN8xewuOySH8n255jrffXMFJRBLmtgo3kNJI/sFbsxPA6dQJ253a2MxvFNj57gNPInkIqfrcOgJZC/52w9GmFJlYX16bnRgMEEPWhdRYOcjL8bz+SRANsNnVh3M1eWE4GBZBm3NmFVnmeRAjPlFzVUP/pk35sKReL6g+DJ0by0lnC6qqCTp8ON2fEQAh/++o5o/uFRMWwG7ezbO5hBdTGA8uOEGU7CspChlqKtTu2UaeRSVLcbbN+BqKPgZUud5KP6Scei3TbLpZdM1pczAE1fYCwORe9yDiNdkiMJPV798mOL4FV6DIJtsKOKZ8Ibg2DAbjlwABA4rQsgBUAA4Nj+skqLE7gGnJViHzKw87zve+v3CV9NEldHV7g2a78yKye489vlmmxcLj+Ln5O/Y3OQnDwsO8mVua5Ddyp26N88oB1wW62VLUn68ePclDd3Bdub/ayiBqFOqA0cTlqI5Dvz0rqrK9dkq4Ij295EK3OfYHCjuoHN+mJP0K0+o+5ItPXu7KWRz/Bf+KPneAAgvTRaDMww+HpfbcM6sxfiZqVE0yGux39i6wjEOCcIbfO8O7wgCEk4GE/98Z6/+lp1NEaQLHcu24FlUeCgThTVaJsmcY9aHB+jFn11yBiJ6+N+RYONWto0xLDyt71qM5KXEEngYambCK8D0JAoIBAQD5tYwpTNfcessxPcYAXkdJWNAP3/8kwz97rFi9gZYsxhZJ/JCU8TUCYlpJDf91mCe0i7uayGb3FbtzoWEwHxKL4DdlL47ZaaGA2dIVNMkxksXDehEE6/bVRAcFH1fT9mZr7uB2uX1YjesFRKEEd3UXpfKSPwtm3QUQz7P7WxzL0CWpfC11vAK2biCG72inE3MelCw/z1Y7M7oo2fyflObMPKkqyuy5NGtZ5t9xpMvLaZrOzJkYbwPaIqxIvISg9rxilZhjMhIFHOW8xM0lVHMEkk2NrwwsMihxFmDaUohZf0GiyYzNEEVBmVEhAZSOV5d1JlWYQStyvDas195/IHjNAoIBAQDYyakyJbbEhgcLSrmXKtJY584y6SYFE1mOZKKkON2EfDpAlwFmJYV26dWiPb77mUsf1HUU/aIT6sfZsrh6axvs0rqqp5ltIr6AzXnJce590EMJnASWLTAdhYXK6e5Y1W8AhylP4LzZk/dy4LOaF09pMi3ugogFFJAWV8j/cv2niUsCXg/I6cQz/Co6cwVhBzOnAMIjdvZbJ2ONJ1Jy/4yS17DBFRyHxMbGVPckXEVodjZ73TAfUQIM83Z8YILxyym2d2f7lvuCyT+ZjmpEJQztdxPO8qT9MaROs4c/qVjJZndoTZ3z4i2eke9Bf3Qcd6Bfy6jPq/r73hl0w0kBo4qnAoIBAQCC8fgZJEnCPcZWAR3WzZm2VdNtr7n9TkH5GazDW7QjsJC5pa8v27k/kdHko2mGAg84N1pe1Z5hDc1p2oO7l1/DaAXEkwbm7eSaTB9FrZOf4mbAlj9chFzBA1ZnEkOdTIXzLaYZvDWF/Y30CkQhsn79srEcjeDtxRNF+JVaRzI3kuRdF1hDeB84CVIXUG5hxupEa9E0eQawLvT9PSqjiJLrIRhY72bpzBpLX61my9NuzOc4cMQLsxOjDTGpRuqJ+jlZvTbXNceLVNcIgW9OlxVlnU778IKCnp7khqatdkA4JmqF8gla86BNwRdxJoH/juFGtp6GJA6jsR0+0EjGA4I1AoIBAGl2ITNeGX2dXgvmPEcH8/CARFWMCozpjuWwm1acu1baQFRvoaSZmEXzF5SnySMIvf0sFBE0GgbqbnK/ePNE6/7XvSuMAR2Qi3CJhTe0jzrxd8tS9QBB12hlLmM6TlM08Z0mI7jSMcz/KJ/gJD9QG7enS6T+J0GhcT8NUaDDxhYcujram384CdToVXq9vd4n7L7PpaIvG0XY8ZsXiAqduzssZrZnmMuLtM+DQf+US8e3ymWTgveZJxA52GhFYy5RkWdMy28fUheb467GE3g3NgTHqwFAFXd/ENmgiKk1rxW7HVfGepLMczjy8ZvBbzDyGTjBEMyGc8DXmTauUfPUJX0CggEBAKEWyNHhEBcEfW6ppPYsaKTlIquA2Chr15KsZcSFOMIcsF/6D7TDZg2NPDYFmlALF/cdqDjRIAP/v5IMRiu3UtHyfDbRyEHx0prvucFMY0HyX9VOJnticwTb39awHi/uFJLs7txERw89eJFcLaxRRRRSpPq3PCalGFpC2i8HXsPnv3gyt+bfE92h6E2YTyP41NYmcuuXkyWM83s11YSC9ZgeilbJuvdajePHrtIAxy8cny+yTBcbnJnWw1yHtzWCA5FAw5OWSaeotbWaFEAHaOW1VG9e1I54pgmVTc5n+WixsgH1fpiz04ojlWRWRyP7hqS+GbAyGgg00KyErRrPcwc=";

        string LiSReqUrl = "https://openapi.jlpay.com/access/charge/"; //请求url

        public string LiSSign(string data)
        {
            var rsa = RSA.Create();
            var key = Convert.FromBase64String(LiSPrivateKey);
            var content = Encoding.UTF8.GetBytes(data);
            rsa.ImportPkcs8PrivateKey(key, out _);
            var result = rsa.SignData(content, HashAlgorithmName.SHA256, RSASignaturePadding.Pkcs1);
            return Convert.ToBase64String(result);
        }

        // 设置费率
        public string SetLiSFee(string sn, decimal serviceFee)
        {
            Dictionary<string, object> dic = new Dictionary<string, object>();
            dic.Add("agentId", LiSAgentId);
            dic.Add("deviceSn", sn);
            List<Dictionary<string, object>> feeList = new List<Dictionary<string, object>>();
            Dictionary<string, object> item = new Dictionary<string, object>();
            item.Add("feeCalcType", "M5");
            item.Add("fixed", "0");
            item.Add("rate", serviceFee);
            feeList.Add(item);
            dic.Add("feeList", feeList);
            dic.Add("signMethod", "02");
            string content = LiSAgentId + sn + "M50" + serviceFee + "02";
            string signstr = LiSSign(content);
            dic.Add("signData", signstr);
            string req = Newtonsoft.Json.JsonConvert.SerializeObject(dic);
            string result = function.PostWebRequest(LiSReqUrl + "FEE003", req, new Dictionary<string, string>(), "application/json");
            return result;
        }

        // 设置押金
        public string SetLiSDeposit(string sn, int serviceFee)
        {
            serviceFee = serviceFee * 100;
            Dictionary<string, object> dic = new Dictionary<string, object>();
            dic.Add("agentId", LiSAgentId);
            dic.Add("deviceSn", sn);
            List<Dictionary<string, object>> feeList = new List<Dictionary<string, object>>();
            Dictionary<string, object> item = new Dictionary<string, object>();
            item.Add("feeCalcType", "N1");
            item.Add("fixed", "1");
            item.Add("rate", serviceFee);
            feeList.Add(item);
            dic.Add("feeList", feeList);
            dic.Add("signMethod", "02");
            string content = LiSAgentId + sn + "N11" + serviceFee + "02";
            string signstr = LiSSign(content);
            dic.Add("signData", signstr);
            string req = Newtonsoft.Json.JsonConvert.SerializeObject(dic);
            string result = function.PostWebRequest(LiSReqUrl + "FEE003", req, new Dictionary<string, string>(), "application/json");
            return result;
        }

        #endregion


        #endregion

        #region 查询商户型创客设置信息

        public IActionResult SeeMerchantType(string right)
        {
            ViewBag.RightInfo = RightInfo;
            ViewBag.right = right;

            return View();
        }

        [HttpPost]
        public string SeeMerchantTypeDo(string PosSn)
        {
            if (string.IsNullOrEmpty(PosSn))
            {
                return "请输入机具SN或者创客编号";
            }
            SetMerchantTypeRecord pos = new SetMerchantTypeRecord();
            if (PosSn.StartsWith("K"))
            {
                UserForMakerCode userfor = db.UserForMakerCode.FirstOrDefault(m => m.MakerCode == PosSn) ?? new UserForMakerCode();
                bool check = db.SetMerchantTypeRecord.Any(m => m.ToUserId == userfor.UserId);
                if (check)
                {
                    pos = db.SetMerchantTypeRecord.Where(m => m.ToUserId == userfor.UserId).OrderByDescending(m => m.Id).FirstOrDefault() ?? new SetMerchantTypeRecord();
                }
            }
            else
            {
                bool check = db.SetMerchantTypeRecord.Any(m => m.PosSn == PosSn);
                if (check)
                {
                    pos = db.SetMerchantTypeRecord.Where(m => m.PosSn == PosSn).OrderByDescending(m => m.Id).FirstOrDefault() ?? new SetMerchantTypeRecord();
                }
            }
            if (pos.Id == 0)
            {
                return "查无信息";
            }
            Users setUser = db.Users.FirstOrDefault(m => m.Id == pos.FromUserId) ?? new Users();
            Users toUser = db.Users.FirstOrDefault(m => m.Id == pos.ToUserId) ?? new Users();
            string CreateDate = pos.CreateDate == null ? "" : pos.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string bindTime = pos.BindDate == null ? "" : pos.BindDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string activeTime = pos.ActDate == null ? "" : pos.ActDate.Value.ToString("yyyy-MM-dd HH:mm:ss");
            string bindResult = pos.BindStatus == 1 ? "已绑定" : "未绑定";
            string activeResult = pos.ActStatus == 1 ? "已激活" : "未激活";
            string RecycFlag = pos.IsRecyc == 1 ? "已循环" : "未循环";
            string result = "";
            result += "机具SN：" + pos.PosSn + "\n";
            result += "操作人：创客编号：" + setUser.MakerCode + "，姓名：" + setUser.RealName + "，手机号：" + setUser.Mobile + "\n";
            result += "操作对象：创客编号：" + toUser.MakerCode + "，姓名：" + toUser.RealName + "，手机号：" + toUser.Mobile + "\n";
            result += "商户编号：" + pos.MerNo + "\n";
            result += "操作时间：" + pos.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss") + "\n";
            result += "绑定状态：" + bindResult + "(绑定时间：" + bindTime + ")\n";
            result += "激活状态：" + activeResult + "(激活时间：" + activeTime + ")\n";
            result += "贷记卡交易额：" + pos.CreditAmount + "\n";
            result += "是否循环：" + RecycFlag + "\n";
            return result;
        }

        #endregion

    }
}