kxs-admin/AppStart/Helper/TimeOutPosChargeReturnService.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading;
using MySystem.Models;
using Library;

namespace MySystem
{
    /// <summary>
    /// 过期购买机具循环截止时间超过15天激活扣费退还
    /// </summary>
    public class TimeOutPosChargeReturnService
    {
        public readonly static TimeOutPosChargeReturnService Instance = new TimeOutPosChargeReturnService();
        private TimeOutPosChargeReturnService()
        { }

        public void Start()
        {
            Thread th = new Thread(doSomething);
            th.IsBackground = true;
            th.Start();
        }

        public void doSomething()
        {
            while (true)
            {
                if (DateTime.Now.Hour < 18)
                {
                    try
                    {
                        string check = function.ReadInstance("/TimeOutPosChargeReturn/check" + DateTime.Now.ToString("yyyy-MM-dd") + ".txt");
                        if (string.IsNullOrEmpty(check))
                        {
                            function.WritePage("/TimeOutPosChargeReturn/", "check" + DateTime.Now.ToString("yyyy-MM-dd") + ".txt", DateTime.Now.ToString("HH:mm:ss"));
                            WebCMSEntities db = new WebCMSEntities();
                            DataTable dt = CustomerSqlConn.dtable("SELECT a.Id Id FROM ToChargeBackRecord a LEFT JOIN PosMachinesTwo b ON a.Remark=b.PosSn WHERE a.`Status`=1 AND a.Sort=0 AND b.PosSnType=0  AND b.BindingState=1 AND b.ActivationState=1", MysqlConn.connstr);//循环过期超过15天激活机具退费创客
                            foreach (DataRow item in dt.Rows)
                            {
                                int Id = int.Parse(item["Id"].ToString());
                                var toChargeBackRecord = db.ToChargeBackRecord.FirstOrDefault(m => m.Id == Id && m.Status == 1) ?? new ToChargeBackRecord();
                                var userAccount = db.UserAccount.FirstOrDefault(m => m.Id == toChargeBackRecord.UserId) ?? new UserAccount();
                                var userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord
                                {
                                    CreateDate = DateTime.Now,
                                    UserId = toChargeBackRecord.UserId,
                                    BeforeBalanceAmount = userAccount.BalanceAmount,
                                    AfterBalanceAmount = userAccount.BalanceAmount + toChargeBackRecord.ChargeAmount,
                                    ChangeAmount = toChargeBackRecord.ChargeAmount,
                                    ChangeType = 126,//过期购买机具超过15天激活扣费退还
                                    Remark = "机具货款退还",

                                }).Entity;
                                toChargeBackRecord.Sort = 1;//过期购买机具循环截止时间超过15天激活扣费退还标识
                                userAccount.BalanceAmount += toChargeBackRecord.ChargeAmount;
                                db.SaveChanges();
                            }
                        }
                    }
                    catch (Exception ex)
                    {
                        function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "过期购买机具超过15天激活扣费退还");
                    }
                }
                Thread.Sleep(1000);
            }
        }
    }
}