mp-main-v2/Controllers/HomeController.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Library;
using LitJson;
using System.Data;
using MySystem.Models.Main;
using System.Text.RegularExpressions;
using Aop.Api.Domain;
using MySystem.Models;

namespace MySystem.Controllers
{
    public class HomeController : Controller
    {
        private readonly ILogger<HomeController> _logger;

        public HomeController(ILogger<HomeController> logger)
        {
            _logger = logger;
        }

        public IActionResult Index()
        {
            return View();
        }

        // public string test2(int id)
        // {
        //     WebCMSEntities db = new WebCMSEntities();
        //     MerchantAddInfo AddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.Id == id) ?? new MerchantAddInfo();
        //     AddInfo.MchtNo = "";
        //     string result = HaoDaHelper.Instance.AddNewMerchant(AddNewMerchantSetUtil.SetValue(AddInfo));
        //     db.Dispose();
        //     return result;
        // }

        public string test()
        {
            // List<int> MerchantIds = new List<int>();
            // MerchantIds.Add(5);
            // foreach(int MerchantId in MerchantIds)
            // {
            //     RedisDbconn.Instance.AddList("MerchantConfirmHdQueue", "{\"MerchantId\":\"" + MerchantId + "\"}");
            // }
            // TianYuVoiceHelper.Instance.doSomething(DateTime.Now.ToString("yyyyMMddHHmmssfff"),"2023100701","100");
            // MqLinksHelper.Instance.doSomething("LKB01230600250000585","100");

            WebCMSEntities db = new WebCMSEntities();
            DateTime start = DateTime.Parse("2024-03-10 00:00:00");
            List<ConsumerOrders> orders = db.ConsumerOrders.Where(m => m.Status > 0 && m.IsAct == 1 && m.CreateDate > start && m.CurDivi < m.MaxDivi && m.SettleAmount > 0).OrderBy(m => m.Id).ToList();
            foreach(ConsumerOrders order in orders)
            {
                bool check = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, 1, 10000).Any(m => m.Id == order.Id);
                bool check1 = db.ConsumerProfit.Any(m => m.OrderId == order.Id);
                if(!check && !check1)
                {
                    RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":List", order.Id.ToString());
                    ConsumerOrders edit = db.ConsumerOrders.FirstOrDefault(m => m.Id == order.Id);
                    if(edit != null)
                    {
                        edit.ReturnFlag = 1;
                        db.SaveChanges();
                    }
                }
                else
                {
                    if(!check)
                    {
                        RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
                        ConsumerOrders edit = db.ConsumerOrders.FirstOrDefault(m => m.Id == order.Id);
                        if(edit != null)
                        {
                            edit.ReturnFlag = 1;
                            db.SaveChanges();
                        }
                    }
                    else if(!check1)
                    {
                        ConsumerOrders edit = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, 1, 10000).FirstOrDefault(m => m.Id == order.Id);
                        long count = RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId,edit);
                        if(count > 0)
                        {
                            RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":List", order.Id.ToString());
                        }
                    }
                }
                if(order.ReturnFlag == 0 && check && check1)
                {
                    ConsumerOrders edit = db.ConsumerOrders.FirstOrDefault(m => m.Id == order.Id);
                    if(edit != null)
                    {
                        edit.ReturnFlag = 1;
                        db.SaveChanges();
                    }
                }
            }

            // Dictionary<string, decimal> ids = new Dictionary<string, decimal>();
            // ids.Add("2023123120272680842405573", 30.08M);
            // foreach(string orderno in ids.Keys)
            // {
            //     decimal cur = ids[orderno];
            //     ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.OrderNo == orderno) ?? new ConsumerOrders();
            //     order.CurDivi = cur;
            //     order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"UpdateDate\":\".*?\"", "\"UpdateDate\":\"" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + "\"");
            //     order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"ProfitDays\":.*?,", "\"ProfitDays\":90,");
            //     RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
            // }

            // string content = function.ReadInstance("/222.log");
            // string[] contents = content.Split('\n');
            // foreach(string sub in contents)
            // {
            //     // RedisDbconn.Instance.AddList("WeChatPayBackHd", sub);
            //     RedisDbconn.Instance.AddList("PartOrderQueue", sub);
            // }

            // DataTable dt = CustomerSqlConn.dtable("select tb.Id,tb.PayMode,p.Id pId from (select Id,PayMode from ConsumerOrders where CreateDate>='2024-01-18 00:00:00' and `Status`>0) tb left join ConsumerProfit p on tb.Id=p.OrderId", AppConfig.Base.SqlConnStr);
            // foreach(DataRow dr in dt.Rows)
            // {
            //     string Id = dr["Id"].ToString();
            //     string PayMode = dr["PayMode"].ToString();
            //     string pId = dr["pId"].ToString();
            //     if(string.IsNullOrEmpty(pId))
            //     {
            //         RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + PayMode + ":List", Id);
            //     }
            // }

            string str = "";
            // str += "<table>";
            // str += "<tr><td>订单号</td><td>下单时间</td><td>商家分红天数</td><td>当前分红金额</td><td>最大分红</td></tr>";
            // List<int> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:2:1940", 1, 10000).Select(m => m.Id).ToList();
            // DataTable dt = CustomerSqlConn.dtable("select OrderId,sum(GetMoney) money from ConsumerProfit where MerchantId=1940 and CreateDate>='2023-12-01 00:00:00' group by OrderId order by OrderId", AppConfig.Base.SqlConnStr);
            // foreach(DataRow dr in dt.Rows)
            // {
            //     decimal cur = decimal.Parse(dr["money"].ToString());
            //     int OrderId = int.Parse(dr["OrderId"].ToString());
            //     if(!orders.Contains(OrderId))
            //     {
            //         // string orderno = dr["OrderNo"].ToString();
            //         ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.Id == OrderId) ?? new ConsumerOrders();
            //         if(order.MaxDivi - cur >= 1)
            //         {
            //             order.CurDivi = cur;
            //             MerchantParamSet set = Newtonsoft.Json.JsonConvert.DeserializeObject<MerchantParamSet>(order.SeoDescription);
            //             order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"UpdateDate\":\".*?\"", "\"UpdateDate\":\"" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + "\"");
            //             // order.SeoDescription = Regex.Replace(function.CheckNull(order.SeoDescription), "\"ProfitDays\":.*?,", "\"ProfitDays\":365,");
            //             str += "<tr><td>" + order.OrderNo + "</td><td>" + order.UpdateDate.Value.ToString() + "</td><td>" + set.ProfitDays + "</td><td>" + cur + "</td><td>" + order.MaxDivi + "</td></tr>";
            //             // RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
            //             // var list = db.ConsumerProfit.Where(m => m.OrderId == order.Id).OrderBy(m => m.Id).ToList();
            //             // foreach(var sub in list)
            //             // {
            //             //     if(cur >= sub.GetMoney)
            //             //     {
            //             //         cur -= sub.GetMoney;
            //             //     }
            //             //     else
            //             //     {
            //             //         if(cur > 0)
            //             //         {
            //             //             var edit = db.ConsumerProfit.FirstOrDefault(m => m.OrderId == order.Id);
            //             //             if(edit != null)
            //             //             {
            //             //                 edit.GetMoney = cur;
            //             //                 db.SaveChanges();
            //             //             }
            //             //         }
            //             //         else
            //             //         {
            //             //             var edit = db.ConsumerProfit.FirstOrDefault(m => m.OrderId == order.Id);
            //             //             if(edit != null)
            //             //             {
            //             //                 db.ConsumerProfit.Remove(edit);
            //             //                 db.SaveChanges();
            //             //             }
            //             //         }
            //             //     }
            //             // }
            //         }
            //     }
            // }
            // str += "</table>";



            // List<int> ids = new List<int>();
            // ids.Add(4058);
            // List<ConsumerOrders> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:2:1271");
            // foreach(int oid in ids)
            // {
            //     function.WriteLog("oid:" + oid, "返现id");
            //     decimal curDivi = 0;
            //     ConsumerOrders order = orders.FirstOrDefault(m => m.Id == oid);
            //     if(order == null)
            //     {
            //         order = db.ConsumerOrders.FirstOrDefault(m => m.Id == oid);
            //         curDivi = order.MaxDivi;
            //         function.WriteLog("出局", "返现id");
            //     }
            //     else
            //     {
            //         function.WriteLog("未出局", "返现id");
            //         curDivi = order.CurDivi;
            //     }
            //     if(order != null)
            //     {
            //         List<ConsumerProfit> profits = db.ConsumerProfit.Where(m => m.OrderId == oid).ToList();
            //         foreach(ConsumerProfit profit in profits)
            //         {
            //             if(curDivi >= profit.GetMoney)
            //             {
            //                 curDivi -= profit.GetMoney;
            //             }
            //             else
            //             {
            //                 function.WriteLog(profit.Id.ToString(), "返现id");
            //             }
            //         }
            //     }
            //     function.WriteLog("\n\n", "返现id");
            // }

            db.Dispose();

            // RedisDbconn.Instance.AddRightList("testlist", "1");
            // RedisDbconn.Instance.AddRightList("testlist", "2");
            // RedisDbconn.Instance.AddRightList("testlist", "3");
            // RedisDbconn.Instance.AddRightList("testlist", "4");
            // RedisDbconn.Instance.AddRightList("testlist", "5");
            // RedisDbconn.Instance.AddRightList("testlist", "6");
            // RedisDbconn.Instance.AddRightList("testlist", "7");
            // RedisDbconn.Instance.AddRightList("testlist", "8");
            // RedisDbconn.Instance.AddRightList("testlist", "9");

            // str = RedisDbconn.Instance.RPopLPush<string>("testlist", "testlist"); 

            // decimal settleAmount = b / 100M;
            // decimal divideAmt = (1 - 0.0038M) * a;
            // divideAmt = decimal.Parse(divideAmt.ToString("f2"));
            // decimal hdfee = 0.0038M * a * (1 - g / 100 - 0.01M);
            // hdfee = decimal.Parse(hdfee.ToString("f2"));
            // decimal servicefee = 0.01M * a - hdfee;
            // servicefee = decimal.Parse(servicefee.ToString("f2"));
            // decimal amount = a*(1-0.0038M) - servicefee;
            // amount = decimal.Parse(amount.ToString("f2"));
            // decimal otherAmt = settleAmount - servicefee - amount;
            // if(otherAmt != 0)
            // {
            //     amount += otherAmt;
            // }

            // amount = amount * 100; //金额（分）
            // servicefee = servicefee * 100;
            // string seviceAmount = servicefee.ToString("f0"); //服务费
            // string amountAmount = amount.ToString("f0");

            // return amountAmount + ":" + seviceAmount;

            // List<int> ids = new List<int>();
            // ids.Add(191);
            // foreach(int id in ids)
            // {
            //     RedisDbconn.Instance.AddList("MerchantConfirmHdQueue", "{\"MerchantId\":\"" + id.ToString() + "\"}");
            // }

            // List<ConsumerOrders> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:2:1940", 1, 10000);
            // int index = orders.Count;
            // foreach(ConsumerOrders order in orders)
            // {
            //     index -= 1;
            //     // decimal persent = order.CurDivi / order.MaxDivi;
            //     // if(order.CurDivi > order.MaxDivi)
            //     // {
            //         // RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
            //         order.MaxDivi = order.PayMoney * 0.8M;
            //         RedisDbconn.Instance.SetList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, index, order);
            //     // }
            // }

            // DataTable dt = CustomerSqlConn.dtable("select DISTINCT MerchantId,PayMode from ConsumerOrders where IsAct=1 and `Status`>0 and MerchantId!=1940 order by MerchantId,PayMode", AppConfig.Base.SqlConnStr);
            // foreach(DataRow dr in dt.Rows)
            // {
            //     string PayMode = dr["PayMode"].ToString();
            //     string MerchantId = dr["MerchantId"].ToString();
            //     List<ConsumerOrders> orders = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId, 1, 10000);
            //     foreach(ConsumerOrders order in orders)
            //     {
            //         decimal check = order.MaxDivi - order.CurDivi;
            //         if(check < 0.01M)
            //         {
            //             function.WriteLog("MerchantId:" + order.MerchantId);
            //             RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
            //         }
            //     }
            // }

            return str;
        }

        public string bindapp(int mid)
        {
            // DataTable dt = CustomerSqlConn.dtable("select Id,MchtNo from MerchantAddInfo where HdStatus=3 and CreateDate>='2023-10-01 00:00:00' and MchtNo!='' and MchtNo is not null", AppConfig.Base.SqlConnStr);
            // DataTable dt = CustomerSqlConn.dtable("select Id,MchtNo from MerchantAddInfo where Id=" + mid, AppConfig.Base.SqlConnStr);
            // foreach(DataRow dr in dt.Rows)
            // {
            //     CheckWeChatSignService.Instance.StartDo(new QueryMerchantStatus()
            //     {
            //         MerchantId = dr["Id"].ToString(),
            //         MerchantNo = dr["MchtNo"].ToString(),
            //     });
            // }

            // Models.Main1.WebCMSEntities db1 = new Models.Main1.WebCMSEntities();
            // WebCMSEntities db = new WebCMSEntities();
            // MerchantAddInfo merchantadd = db.MerchantAddInfo.FirstOrDefault(m => m.Id == 1147);
            // MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == 1147);
            // string pwd = "417027";
            // merchant.LoginPwd = function.MD532(pwd);
            // Models.Main1.MerchantLoginInfo info = db1.MerchantLoginInfo.FirstOrDefault(m => m.LoginMobile == merchantadd.MobilePhone);
            // if (info == null)
            // {
            //     info = db1.MerchantLoginInfo.Add(new Models.Main1.MerchantLoginInfo()
            //     {
            //         LoginMobile = merchantadd.MobilePhone,
            //     }).Entity;
            //     db1.SaveChanges();
            // }
            // info.LoginPwd = function.MD532(pwd);
            // db1.SaveChanges();
            // Models.Main1.MerchantAccountLinkInfo infolink = db1.MerchantAccountLinkInfo.FirstOrDefault(m => m.LoginId == info.Id && m.MerchantId == merchantadd.Id && m.Kind == 2);
            // if (infolink == null)
            // {
            //     infolink = db1.MerchantAccountLinkInfo.Add(new Models.Main1.MerchantAccountLinkInfo()
            //     {
            //         LoginId = info.Id,
            //         MerchantId = merchantadd.Id,
            //         Kind = 2,
            //     }).Entity;
            //     db1.SaveChanges();
            // }
            // db1.Dispose();
            // db.Dispose();

            return "ok";
        }
    
        
        public string clearQueue(int OrderId, int MerchantId, int PayMode)
        {
            // List<ConsumerOrders> list = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:" + PayMode + ":" + MerchantId + "", 1, 100000);
            // foreach(ConsumerOrders sub in list)
            // {
            //     if(sub.Id == OrderId)
            //     {
            //         RedisDbconn.Instance.DelFromList("ConsumerOrdersHd:Divi:2:1272", sub);
            //     }
            // }
            return "ok";
        }
    
    
        //补返现
        public string back(string no)
        {
            WebCMSEntities db = new WebCMSEntities();
            ConsumerOrders order = db.ConsumerOrders.FirstOrDefault(m => m.OrderNo == no);
            if(order != null)
            {
                List<ConsumerOrders> list = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId + "", 1, 100000);
                ConsumerOrders check = list.FirstOrDefault(m => m.Id == order.Id);
                bool op = db.ConsumerProfit.Any(m => m.OrderId == order.Id);
                if(check == null)
                {
                    if(!op)
                    {
                        RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":List", order.Id.ToString());
                    }
                    else
                    {
                        RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + order.PayMode + ":" + order.MerchantId, order);
                    }
                }
                db.Dispose();
            }
            return "ok";
        }

        public string goonback(int mid, int pm, string date)
        {
            DateTime start = DateTime.Parse(date + " 00:00:00");
            DateTime end = start.AddDays(1);
            WebCMSEntities db = new WebCMSEntities();
            List<ConsumerOrders> queue = RedisDbconn.Instance.GetList<ConsumerOrders>("ConsumerOrdersHd:Divi:" + pm + ":" + mid + "", 1, 100000);
            List<ConsumerOrders> list = db.ConsumerOrders.Where(m => m.MerchantId == mid && m.PayMode == pm && m.Status > 0 && m.IsAct == 1 && m.CreateDate >= start && m.CreateDate < end).ToList();
            foreach(ConsumerOrders sub in list)
            {
                if(!queue.Any(m => m.Id == sub.Id) && sub.CurDivi < sub.MaxDivi)
                {
                    RedisDbconn.Instance.AddList("ConsumerOrdersHd:Divi:" + pm + ":" + mid, sub);
                }
            }
            db.Dispose();
            return "ok";
        }
    }
}