kxs-main/AppStart/Helper/SycnSpServer/SycnSpTradeService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using MySystem.SpModels;
using Library;
using LitJson;

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

        public void Start()
        {
            WebCMSEntities spdb = new WebCMSEntities();
            PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
            DateTime start = DateTime.Now.AddDays(-2);
            List<TradeRecord> trades = spdb.TradeRecord.Where(m => m.CreateDate >= start && m.Status == 1).OrderByDescending(m => m.Id).ToList();
            foreach (TradeRecord trade in trades)
            {
                PxcModels.MachineForSnNo posFor = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == trade.TradeSnNo) ?? new PxcModels.MachineForSnNo();
                PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId) ?? new PxcModels.PosMachinesTwo();
                PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users();
                int TopUserId = 0;
                if (!string.IsNullOrEmpty(user.ParentNav))
                {
                    TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                }
                bool check = db.TradeRecord.Any(m => m.RecordNo == trade.TradeSerialNo);
                if (!check)
                {
                    db.TradeRecord.Add(new PxcModels.TradeRecord()
                    {
                        CreateDate = trade.CreateDate,
                        UpdateDate = trade.UpdateDate,
                        RecordNo = trade.TradeSerialNo, //单号
                        UserId = pos.UserId, //创客
                        MerchantId = pos.BindMerchantId, //商户
                        MerNo = trade.MerNo, //渠道商户编号
                        MerHelpFlag = 0, //是否属于扶持周期内商户
                        HelpMonthCount = 0, //扶持第几个月
                        MerBuddyType = user.MerchantType, //商户创客类型
                        SnNo = trade.TradeSnNo, //渠道SN号
                        // TradeDate = DateTime.Parse(trade.TradeTime), //交易日期
                        TradeSerialNo = trade.ChannelSerial, //交易流水号
                        TradeAmount = trade.TradeAmount / 100, //交易金额
                        BankCardType = int.Parse(trade.BankCardType), //银行卡类型
                        QrPayFlag = trade.TradeType == "02" ? 1 : 0, //云闪付标识
                        BrandId = int.Parse(trade.ProductType), //品牌
                        Remark = trade.Remark, //备注
                        TopUserId = TopUserId, //顶级创客
                        MerUserId = pos.UserId, //商户直属创客
                    });
                }
                TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
                if (edit != null)
                {
                    edit.Status = 2;
                }
            }
            spdb.SaveChanges();
            spdb.Dispose();
            db.SaveChanges();
            db.Dispose();
        }
    }
}