增加申请虚拟广电卡队列

AppStart/PublicFunction.cs

@@ -84,5 +84,37 @@ namespace MySystem
         }
 
         #endregion
+
+        #region 统计机具绑定数据
+
+        public static void StatUserMachineData(int UserId, int BrandId, int Count)
+        {
+            using (WebCMSEntities db = new WebCMSEntities())
+            {
+                string IdBrand = UserId + "_" + BrandId;
+                UserMachineData MachineData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
+                if (MachineData == null)
+                {
+                    MachineData = db.UserMachineData.Add(new UserMachineData()
+                    {
+                        IdBrand = IdBrand,
+                    }).Entity;
+                    db.SaveChanges();
+                }
+                if (Count < 0)
+                {
+                    MachineData.TotalMachineCount -= Math.Abs(Count);
+                    MachineData.UnBindCount -= Math.Abs(Count);
+                }
+                else
+                {
+                    MachineData.TotalMachineCount += Count;
+                    MachineData.UnBindCount += Count;
+                }
+                db.SaveChanges();
+            }
+        }
+
+        #endregion
     }
 }

AppStart/Timer/VirtualApplyHelper.cs

@@ -0,0 +1,221 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Linq;
+using System.Data;
+using MySystem;
+using MySystem.PxcModels;
+using Library;
+using LitJson;
+
+public class VirtualApplyHelper
+{
+    public readonly static VirtualApplyHelper Instance = new VirtualApplyHelper();
+    private VirtualApplyHelper()
+    {
+    }
+
+    public void Start()
+    {
+        Thread th = new Thread(StartDo);
+        th.IsBackground = true;
+        th.Start();
+    }
+
+    private void StartDo()
+    {
+        while (true)
+        {
+            try
+            {
+                string data = RedisDbconn.Instance.RPop<string>("VirtualApplyQueue");
+                if(!string.IsNullOrEmpty(data))
+                {
+                    TransferOneDo(data);
+                }
+                else
+                {
+                    Thread.Sleep(5000);
+                }
+            }
+            catch (Exception ex)
+            {
+                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "申请虚拟卡异常");
+            }
+        }
+    }
+
+    public void TransferOneDo(string value)
+    {
+        WebCMSEntities maindb = new WebCMSEntities();
+        JsonData data = JsonMapper.ToObject(value);
+        int OrderId = int.Parse(function.CheckInt(data["OrderId"].ToString()));
+        int StoreId = int.Parse(function.CheckInt(data["StoreId"].ToString())); //仓库
+        int ToUserId = int.Parse(function.CheckInt(data["ToUserId"].ToString())); //收货人
+        int SnCount = int.Parse(function.CheckInt(data["SnCount"].ToString()));
+        Dictionary<string, object> Obj = new Dictionary<string, object>();
+        StoreHouse store = maindb.StoreHouse.FirstOrDefault(m => m.Id == StoreId) ?? new StoreHouse();
+
+        string SnNos = ""; //划拨的机具号（多个）
+        Orders order = maindb.Orders.FirstOrDefault(m => m.Id == OrderId);
+        if (order != null)
+        {
+            if (order.Status == 2)
+            {
+                return;
+            }
+            int ApplyType = 0; // 申请类型，1-机具SN，2-200兑换码，3-300券
+            List<string> SourceSnNos = new List<string>();
+            if (order.Sort > 0)
+            {
+                MachineApply Apply = maindb.MachineApply.FirstOrDefault(m => m.Id == order.Sort);
+                if (Apply != null)
+                {
+                    Apply.Status = 1;
+                    Apply.QueryCount = order.Id;
+                    ApplyType = Apply.Sort;
+                    if (!string.IsNullOrEmpty(Apply.SwapSnExpand))
+                    {
+                        string[] SwapSnExpands = Apply.SwapSnExpand.Split('\n');
+                        foreach (string sub in SwapSnExpands)
+                        {
+                            if (!string.IsNullOrEmpty(sub))
+                            {
+                                SourceSnNos.Add(sub.Split(':')[0]);
+                            }
+                        }
+                    }
+                }
+            }
+            Dictionary<int, string> couponIds = new Dictionary<int, string>();
+            int SnIndex = 0;
+            List<PosMachinesTwo> PosList = maindb.PosMachinesTwo.Where(m => m.BrandId == 14 && m.StoreId == 8664 && m.BuyUserId == 0 && m.BindingState == 0 && m.ActivationState == 0).Take(SnCount).ToList();
+            foreach (PosMachinesTwo pos in PosList)
+            {
+                string ChangeNo = "SC" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
+                int SnIdNum = pos.Id;
+                DateTime RecycEndDate = DateTime.Now.AddDays(360);
+                int LeaderUserId = 0;
+                if (SourceSnNos.Count > SnIndex)
+                {
+                    string SourceSnNo = SourceSnNos[SnIndex];
+                    if (ApplyType <= 1)
+                    {
+                        MachineForSnNo forSnNo = maindb.MachineForSnNo.FirstOrDefault(m => m.SnNo == SourceSnNo) ?? new MachineForSnNo();
+                        PosMachinesTwo spos = maindb.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId) ?? new PosMachinesTwo();
+                        RecycEndDate = spos.RecycEndDate == null ? RecycEndDate = DateTime.Now.AddDays(360) : spos.RecycEndDate.Value;
+                        LeaderUserId = spos.LeaderUserId;
+                    }
+                    else if (ApplyType > 1)
+                    {
+                        PosCoupons coupon = maindb.PosCoupons.FirstOrDefault(m => m.ExchangeCode == SourceSnNo) ?? new PosCoupons();
+                        LeaderUserId = coupon.LeaderUserId;
+                        if (coupon.OpId > 0)
+                        {
+                            if (couponIds.ContainsKey(coupon.OpId))
+                            {
+                                string[] datas = couponIds[coupon.OpId].Split(',');
+                                int Num = int.Parse(datas[2]) + 1;
+                                couponIds[coupon.OpId] = datas[0] + "," + datas[1] + "," + Num;
+                            }
+                            else
+                            {
+                                couponIds.Add(coupon.OpId, coupon.Id + "," + coupon.QueryCount + ",1");
+                            }
+                        }
+                    }
+                }
+
+                if (StoreId == 0)
+                {
+                    StoreId = pos.StoreId;
+                }
+                SnNos += pos.PosSn + ",";
+                Users toUser = maindb.Users.FirstOrDefault(m => m.Id == ToUserId) ?? new Users();
+                StoreStockChange query = maindb.StoreStockChange.Add(new StoreStockChange()
+                {
+                    CreateDate = DateTime.Now,
+                    StoreId = StoreId, //仓库
+                    BrandId = pos.BrandId, //产品类型
+                    ProductName = RelationClass.GetKqProductBrandInfo(pos.BrandId), //产品名称
+                    ChangeNo = ChangeNo, //变更单号
+                    TransType = 11, //交易类型
+                    SnNo = pos.PosSn, //SN编号
+                    SnType = pos.PosSnType, //SN机具类型
+                    StockOpDirect = 1, //库存操作方向
+                    DeviceType = pos.DeviceType, //设备类型
+                    FromUserId = store.UserId, //出货人
+                    FromDate = DateTime.Now, //出库时间
+                    ToUserId = ToUserId, //收货人
+                    ToStoreId = StoreId, //退货收货仓库
+                    OpId = pos.OpId
+                }).Entity;
+                UserStoreChange userstore = maindb.UserStoreChange.Add(new UserStoreChange()
+                {
+                    CreateDate = DateTime.Now,
+                    UserId = store.UserId, //创客
+                    BrandId = pos.BrandId, //产品类型
+                    ChangeRecordNo = ChangeNo, //变更记录单号
+                    TransType = 0, //交易类型
+                    SnNo = pos.PosSn, //SN编号
+                    SnType = pos.PosSnType, //SN机具类型
+                    StockOpDirect = 0, //库存操作方向
+                    DeviceVendor = pos.DeviceName, //设备厂商
+                    DeviceType = pos.DeviceKind, //设备类型
+                    DeviceModel = pos.DeviceType, //设备型号
+                    ToUserId = ToUserId, //收货创客
+                    ToDate = DateTime.Now, //入库时间
+                    SourceStoreId = pos.SourceStoreId, //源仓库
+                    SnStatus = 1, //SN状态
+                    BindStatus = (int)pos.BindingState, //绑定状态
+                    BindMerchantId = pos.BindMerchantId, //绑定商户
+                    ActiveStatus = (int)pos.ActivationState, //激活状态
+                    ActRewardUserId = pos.BuyUserId, //激活奖励创客
+                    BrandType = pos.DeviceType, //品牌类型
+                }).Entity;
+                StoreChangeHistory history = maindb.StoreChangeHistory.Add(new StoreChangeHistory()
+                {
+                    CreateDate = DateTime.Now,
+                    UserId = store.UserId, //创客
+                    BrandId = pos.BrandId, //产品类型
+                    ChangeRecordNo = ChangeNo, //变更记录单号
+                    TransType = 2, //交易类型
+                    SnNo = pos.PosSn, //SN编号
+                    SnType = pos.PosSnType, //SN机具类型
+                    StockOpDirect = 1, //库存操作方向
+                    DeviceVendor = pos.DeviceName, //设备厂商
+                    DeviceModel = pos.DeviceKind, //设备型号
+                    DeviceType = pos.DeviceType, //设备类型
+                    ToUserId = ToUserId, //收货创客
+                    FromUserId = store.UserId, //出货创客
+                    FromDate = DateTime.Now, //出库时间
+                    SourceStoreId = pos.SourceStoreId, //源仓库
+                    StoreId = store.Id, //仓库
+                    OpId = pos.OpId
+                }).Entity;
+                maindb.SaveChanges();
+                PublicFunction.StatUserMachineData(ToUserId, pos.BrandId, 1);
+                store.LaveNum -= 1;
+                store.OutNum += 1;
+
+                pos.OrderId = OrderId;
+                pos.BuyUserId = ToUserId;
+                pos.UserId = ToUserId;
+                pos.TransferTime = DateTime.Now;
+                pos.RecycEndDate = RecycEndDate; // 循环结束时间
+                pos.PosSnType = order.QueryCount;
+                pos.LeaderUserId = LeaderUserId;
+                
+                maindb.SaveChanges();
+                SnIndex += 1;
+
+            }
+            order.Status = 2;
+            order.SendStatus = 1;
+            order.SendDate = DateTime.Now;
+            order.SnNos = SnNos.TrimEnd(',');
+            maindb.SaveChanges();
+        }
+        maindb.Dispose();
+    }
+}

Startup.cs

@@ -227,6 +227,7 @@ namespace MySystem
                 LeaderAmountMonthChangeQueue.Instance.Start(); //每月一号记录上月盟主储蓄金和可提现余额
                 ResetPosFirstFlagAndIsExecuteService.Instance.Start(); //每月1号计算商户首台机具标记
                 OperateAmountRecordService.Instance.Start(); //运营中心额度变更 
+                VirtualApplyHelper.Instance.Start(); //申请虚拟广电卡
 
                 ChangePosTimer.Instance.Start(); //售后换新执行机具数据转移
                 RecommendActStatService.Instance.Start(); //推荐王奖励数据统计