kxs-stat/AppStart/Helper/SplitTableData/AddRecordService.cs

using System;
using System.Collections.Generic;
using Library;
using LitJson;
using System.Linq;
using System.Data;
using System.Threading;
using MySystem.PxcModels;

namespace MySystem
{
    public class AddRecordService
    {
        public readonly static AddRecordService Instance = new AddRecordService();
        private AddRecordService()
        { }

        //分表字段集合
        private Dictionary<string, string> FieldDic = new Dictionary<string, string>()
        {
            {"TradeRecord", "Id,Sort,QueryCount,Status,Version,CreateDate,UpdateDate,CreateMan,UpdateMan,SeoTitle,SeoKeyword,SeoDescription,MerUserId,TopUserId,Remark,BrandId,DirectFlag,CapFlag,QrPayFlag,BankCardType,TradeAmount,TradeSerialNo,ClearDate,TradeDate,SnNo,MerBuddyType,HelpMonthCount,MerHelpFlag,MerNo,MerchantId,UserId,RecordNo,ParentNav,PayType,VipFlag,ActStatus"},
            {"UserAccountRecord", "Id,Sort,QueryCount,Status,Version,CreateDate,UpdateDate,CreateMan,UpdateMan,SeoTitle,SeoKeyword,SeoDescription,TransRecordNo,Remark,AfterBalanceAmount,BeforeBalanceAmount,AfterFreezeAmount,BeforeFreezeAmount,AfterTotalAmount,BeforeTotalAmount,ChangeAmount,ProductType,ChangeType,UserId,Kind"},
            {"SpBindRecord", "Id,Sort,QueryCount,Status,CreateDate,UpdateDate,SeoTitle,SeoKeyword,SeoDescription,ChannelSerial,UpdateTime,CreateTime,Remark,MerNewSnNo,ProductType,MerStatus,MerOperateType,MerOperateDate,MerSnNo,MerName,AgentName,MerNo,Field5,Field4,Field3,Field2,Field1"},
            {"SpMerchants", "Id,Sort,QueryCount,Status,CreateDate,UpdateDate,SeoTitle,SeoKeyword,SeoDescription,AgentNo,SnNo,UpdateTime,CreateTime,Remark,City,Province,ProductType,MerStatus,MerAuditDate,MerRegDate,MerIdcardNo,MerMobile,MerRealName,AgentName,MerName,MerNo,Field5,Field4,Field3,Field2,Field1"},
            {"SpActivateRecord", "Id,Sort,QueryCount,Status,CreateDate,UpdateDate,SeoTitle,SeoKeyword,SeoDescription,ProductType,AgentNo,Remark,BizEnterName,BizEnterNo,MerIdcardNo,MerRealName,ActivateDate,ActivateStatus,AssessMonthCount,AssessMonth,MerRegDate,SnNo,MerMobile,MerName,MerNo,ChannelSerial,Field5,Field4,Field3,Field2,Field1"},
            {"SpTradeRecord", "Id,Sort,QueryCount,Status,CreateDate,UpdateDate,SeoTitle,SeoKeyword,SeoDescription,ChannelSerial,AgentNo,ProductType,Remark,SettleMethod,SettleFee,BankCardNo,ReceiptType,IsStoreCashier,DigAmt,DigAmtFlag,MerMobile,DeviceType,TradeSnNo,BankCardType,SerEntryMode,TradeType,TradeTime,TradeDate,ErrorMsg,ErrorCode,TradeStatus,DiscountRateFlag,BankAuthCode,TradeReferNo,TradeAmount,MerName,MerNo,TradeSerialNo,Field5,Field4,Field3,Field2,Field1"},
        };

        //交易记录队列
        public void StartTradeRecord()
        {
            Thread th = new Thread(StartTradeRecordDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartTradeRecordDo()
        {
            while (true)
            {
                WebCMSEntities db = new WebCMSEntities();
                int startId = int.Parse(function.ReadInstance("/Rds/TradeRecordId.txt"));
                List<TradeRecord> list = db.TradeRecord.Where(m => m.Id > startId && m.Status == 0).OrderBy(m => m.Id).Take(100).ToList();
                if(list.Count > 0)
                {
                    string ids = "";
                    foreach(TradeRecord sub in list)
                    {
                        AddData(Newtonsoft.Json.JsonConvert.SerializeObject(sub), sub.CreateDate.Value.ToString("yyyyMMdd"), "TradeRecord");
                        ids += sub.Id + ",";
                        startId = sub.Id;
                    }
                    CustomerSqlConn.op("update TradeRecord set RdsStat=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SqlConn);
                    function.WritePage("/Rds/", "TradeRecordId.txt", startId.ToString());
                }
                else
                {
                    Thread.Sleep(10000);
                }
                db.Dispose();
            }
        }

        //收支明细队列
        public void StartUserAccountRecord()
        {
            Thread th = new Thread(StartUserAccountRecordDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartUserAccountRecordDo()
        {
            while (true)
            {
                WebCMSEntities db = new WebCMSEntities();
                int startId = int.Parse(function.ReadInstance("/Rds/UserAccountRecordId.txt"));
                List<UserAccountRecord> list = db.UserAccountRecord.Where(m => m.Id > startId && m.Status == 0).OrderBy(m => m.Id).Take(100).ToList();
                if(list.Count > 0)
                {
                    string ids = "";
                    foreach(UserAccountRecord sub in list)
                    {
                        AddData(Newtonsoft.Json.JsonConvert.SerializeObject(sub), sub.CreateDate.Value.ToString("yyyyMMdd"), "UserAccountRecord");
                        ids += sub.Id + ",";
                        startId = sub.Id;
                    }
                    CustomerSqlConn.op("update UserAccountRecord set RdsStat=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SqlConn);
                    function.WritePage("/Rds/", "UserAccountRecordId.txt", startId.ToString());
                }
                else
                {
                    Thread.Sleep(10000);
                }
                db.Dispose();
            }
        }

        //SP绑定记录队列
        public void StartSpBindRecord()
        {
            Thread th = new Thread(StartSpBindRecordDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartSpBindRecordDo()
        {
            while (true)
            {
                SpModels.WebCMSEntities db = new SpModels.WebCMSEntities();
                int startId = int.Parse(function.ReadInstance("/Rds/SpBindRecordId.txt"));
                List<SpModels.BindRecord> list = db.BindRecord.Where(m => m.Id > startId && m.Status == 0).OrderBy(m => m.Id).Take(100).ToList();
                if(list.Count > 0)
                {
                    string ids = "";
                    foreach(SpModels.BindRecord sub in list)
                    {
                        AddData(Newtonsoft.Json.JsonConvert.SerializeObject(sub), sub.CreateDate.Value.ToString("yyyyMMdd"), "SpBindRecord");
                        ids += sub.Id + ",";
                        startId = sub.Id;
                    }
                    CustomerSqlConn.op("update BindRecord set RdsStat=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SpSqlConn);
                    function.WritePage("/Rds/", "BindRecordId.txt", startId.ToString());
                }
                else
                {
                    Thread.Sleep(10000);
                }
                db.Dispose();
            }
        }

        //SP商户信息队列
        public void StartSpMerchants()
        {
            Thread th = new Thread(StartSpMerchantsDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartSpMerchantsDo()
        {
            while (true)
            {
                SpModels.WebCMSEntities db = new SpModels.WebCMSEntities();
                int startId = int.Parse(function.ReadInstance("/Rds/SpMerchantsId.txt"));
                List<SpModels.Merchants> list = db.Merchants.Where(m => m.Id > startId && m.Status == 0).OrderBy(m => m.Id).Take(100).ToList();
                if(list.Count > 0)
                {
                    string ids = "";
                    foreach(SpModels.Merchants sub in list)
                    {
                        AddData(Newtonsoft.Json.JsonConvert.SerializeObject(sub), sub.CreateDate.Value.ToString("yyyyMMdd"), "SpMerchants");
                        ids += sub.Id + ",";
                        startId = sub.Id;
                    }
                    CustomerSqlConn.op("update Merchants set RdsStat=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SpSqlConn);
                    function.WritePage("/Rds/", "MerchantsId.txt", startId.ToString());
                }
                else
                {
                    Thread.Sleep(10000);
                }
                db.Dispose();
            }
        }

        //SP激活押金队列
        public void StartSpActivateRecord()
        {
            Thread th = new Thread(StartSpActivateRecordDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartSpActivateRecordDo()
        {
            while (true)
            {
                SpModels.WebCMSEntities db = new SpModels.WebCMSEntities();
                int startId = int.Parse(function.ReadInstance("/Rds/SpActivateRecordId.txt"));
                List<SpModels.ActivateRecord> list = db.ActivateRecord.Where(m => m.Id > startId && m.Status == 0).OrderBy(m => m.Id).Take(100).ToList();
                if(list.Count > 0)
                {
                    string ids = "";
                    foreach(SpModels.ActivateRecord sub in list)
                    {
                        AddData(Newtonsoft.Json.JsonConvert.SerializeObject(sub), sub.CreateDate.Value.ToString("yyyyMMdd"), "SpActivateRecord");
                        ids += sub.Id + ",";
                        startId = sub.Id;
                    }
                    CustomerSqlConn.op("update ActivateRecord set RdsStat=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SpSqlConn);
                    function.WritePage("/Rds/", "ActivateRecordId.txt", startId.ToString());
                }
                else
                {
                    Thread.Sleep(10000);
                }
                db.Dispose();
            }
        }

        //SP交易记录队列
        public void StartSpTradeRecord()
        {
            Thread th = new Thread(StartSpTradeRecordDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartSpTradeRecordDo()
        {
            while (true)
            {
                SpModels.WebCMSEntities db = new SpModels.WebCMSEntities();
                int startId = int.Parse(function.ReadInstance("/Rds/SpTradeRecordId.txt"));
                List<SpModels.TradeRecord> list = db.TradeRecord.Where(m => m.Id > startId && m.Status == 0).OrderBy(m => m.Id).Take(100).ToList();
                if(list.Count > 0)
                {
                    string ids = "";
                    foreach(SpModels.TradeRecord sub in list)
                    {
                        AddData(Newtonsoft.Json.JsonConvert.SerializeObject(sub), sub.CreateDate.Value.ToString("yyyyMMdd"), "SpTradeRecord");
                        ids += sub.Id + ",";
                        startId = sub.Id;
                    }
                    CustomerSqlConn.op("update TradeRecord set RdsStat=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SpSqlConn);
                    function.WritePage("/Rds/", "TradeRecordId.txt", startId.ToString());
                }
                else
                {
                    Thread.Sleep(10000);
                }
                db.Dispose();
            }
        }


        //添加表数据
        public void AddData(string content, string date, string table)
        {
            try
            {
                JsonData selfDr = JsonMapper.ToObject(content);
                string fields = FieldDic[table];
                string val = "";
                foreach(string field in fields.Split(','))
                {
                    Type t = selfDr[field].GetType();
                    if(t == typeof(int) || t == typeof(decimal))
                    {
                        val += selfDr[field].ToString() + ",";
                    }
                    else
                    {
                        val += "'" + selfDr[field].ToString() + "',";
                    }
                }
                string sql = "INSERT INTO " + table + date + " (" + fields + ") VALUES (" + val.TrimEnd(',') + ")";
                CustomerSqlConn.op(sql, AppConfig.Base.StatSqlConn);
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "添加记录RDS异常");
            }
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "添加记录RDS");
        }

    }
}