dotnet/molilian.api/Controllers/public/TaskController.cs

using molilian.core;
using dodohold.core;
using Microsoft.AspNetCore.Mvc;
using Org.BouncyCastle.Ocsp;
using System.Text.Json;
using System.Runtime.InteropServices;
using System.Net;

namespace molilian.api.Controllers
{
    [ApiController]
    [Route("[controller]/[action]")]
    public class TaskController : ControllerBase
    {

        protected IHttpContextAccessor _accessor;
        public TaskController(IHttpContextAccessor accessor)
        {
            _accessor = accessor;
        }

        [HttpGet]
        public ActionResult BatchInsertLogDB()
        {
            TkLogCore.BatchInsertLogDB();
            return new APIResult(new { success = true, message = "ok" });
        }

        [HttpGet]
        public async Task<ActionResult> GetHistoryOrders(int id, int sleep = 2000)
        {
            var list = TkPoolCore.List();
            if (list == null) return new APIResult(new { success = false, message = "没有有效账号", });
            if (id == 0) return new APIResult(new { success = false, message = "没有有效账号", });

            string message = string.Empty;
            int total = 0;
            foreach (var account in list)
            {

                if (id != account.id) continue;

                try
                {
                    var alimama = new AlimamaPlus(account);
                    total += alimama.GetHistoryOrders(sleep);
                }
                catch (Exception ex)
                {
                    message = $"【订单接口异常】\t{account.name}\n{ex.Message}\n{ex.StackTrace}";
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = message,
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    continue;
                }
            }
            return new APIResult(new { success = true, message = "ok", total });
        }
        [HttpGet]
        public async Task<ActionResult> GetIncyOrders(int sleep = 2000)
        {
            var list = TkPoolCore.List();
            if (list == null) return new APIResult(new { success = false, message = "没有有效账号", });
            string message = string.Empty;
            int total = 0;
            foreach (var account in list)
            {
#if DEBUG
                if (account.id != 13) continue;
#endif

                try
                {
                    var alimama = new AlimamaPlus(account);
                    total += alimama.GetIncyOrders(sleep);
                }
                catch (Exception ex)
                {
                    message = $"【订单接口异常】\t{account.name}\n{ex.Message}\n{ex.StackTrace}";
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = message,
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    continue;
                }
            }
            return new APIResult(new { success = true, message = "ok", total });
        }




        [HttpGet]
        public async Task<ActionResult> GetViolationuWarning()
        {
            var list = TkPoolCore.List();
            if (list == null) return new APIResult(new { success = false, message = "没有有效账号", });
            string message = string.Empty;
            foreach (var account in list)
            {
                try
                {
                    var alimama = new AlimamaPlus(account);
                    alimama.GetViolationuWarning();
                }
                catch (Exception ex)
                {
                    message = $"【报表接口异常】FastReport\n{ex.Message}\n{ex.StackTrace}";
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = message,
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    continue;
                }
            }
            return new APIResult(new { success = true, message = "ok" });
        }

        [HttpGet]

        public async Task<ActionResult> DailyLogs(int intervalDay = 1)
        {
            try
            {
                AlimamaPlus.DailyLogs(intervalDay);
            }
            catch (Exception ex)
            {
                string message = $"【报表接口异常】DailyLogs\n{ex.Message}\n{ex.StackTrace}";
                NotifyCore.Notify(new NifyMessage
                {
                    message = message,
                    priority = NifyMessagePriority.high,
                    tags = ["red_circle"]
                });
            }
            return new APIResult(new { success = true, message = "ok" });
        }


        [HttpGet]
        public async Task<ActionResult> GetDrawBalance()
        {
            var list = TkPoolCore.List();
            if (list == null) return new APIResult(new { success = false, message = "没有有效账号", });
            string message = string.Empty;
            foreach (var account in list)
            {
                try
                {
                    var alimama = new AlimamaPlus(account);
                    alimama.GetDrawBalance();
                }
                catch (Exception ex)
                {
                    message = $"【报表接口异常】GetDrawBalance\n{ex.Message}\n{ex.StackTrace}";
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = message,
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    continue;
                }
            }
            return new APIResult(new { success = true, message = "ok" });
        }

        [HttpGet]
        public ActionResult FastReport()
        {
            var list = TkPoolCore.List();
            if (list == null) return new APIResult(new { success = false, message = "没有有效账号", });
            string message = string.Empty;
            foreach (var account in list)
            {
                try
                {
                    var alimama = new AlimamaPlus(account);
                    alimama.SaveReportOverview();
                }
                catch (Exception ex)
                {
                    message = $"【报表接口异常】FastReport\n{ex.Message}\n{ex.StackTrace}";
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = message,
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    continue;
                }
            }
            return new APIResult(new { success = true, message = "ok" });
        }

        [HttpGet]
        public async Task<ActionResult> SaveReport()
        {

            var list = TkPoolCore.List();
            if (list == null) return new APIResult(new { success = false, message = "没有有效账号", });
            string message = string.Empty;
            foreach (var account in list)
            {
                try
                {
                    var alimama = new AlimamaPlus(account);
                    alimama.SaveReportHourtrend(DateTime.Now.AddDays(-1));
                    alimama.SaveReportHourtrend(DateTime.Now);

                    if (DateTime.Now.Hour >= 12 && DateTime.Now.Hour < 16)
                    {
                        DateTime date = DateTime.Now.AddDays(-1);
                        alimama.FixReport(date);
                    }
                }
                catch (Exception ex)
                {
                    message = $"【报表接口异常】SaveReport\n{ex.Message}\n{ex.StackTrace}";
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = message,
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    continue;
                }
            }
            return new APIResult(new { success = true, message = "ok" });
        }

        [HttpGet]
        public async Task<ActionResult> FixReport(string dt)
        {
            if (!DateTime.TryParse(dt, out DateTime date))
            {
                return new APIResult(new { success = false, message = "日期错误", });
            }

            var list = TkPoolCore.List();
            if (list == null) return new APIResult(new { success = false, message = "没有有效账号", });
            string message = string.Empty;
            foreach (var account in list)
            {
                try
                {
                    var alimama = new AlimamaPlus(account);

                    while (date.Date < DateTime.Now.Date)
                    {
                        alimama.SaveReportHourtrend(date);
                        alimama.FixReport(date);
                        date = date.AddDays(1);
                    }
                }
                catch (Exception ex)
                {
                    message = $"【报表接口异常】SaveReport\n{ex.Message}\n{ex.StackTrace}";
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = message,
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    continue;
                }
            }
            return new APIResult(new { success = true, message = "ok" });
        }

        [HttpGet]
        public ActionResult RenewCookie(string name)
        {
            var account = new DBContext.Table("tk_pool").Get<TkPoolDTO>("name=@name", new { name });

            if (account == null) return new APIResult(new { success = false, message = "没有有效账号", });
            var alimama = new AlimamaPlus(account);

            (bool success, string message) = alimama.RenewCookie();
            return new APIResult(new { success, message });
        }
    }
}