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

using molilian.core;
using dodohold.core;
using Microsoft.AspNetCore.Mvc;
using System.Text.Json;
using TencentCloud.Ecm.V20190719.Models;
using YunhuiKit;

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

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

        [HttpGet]
        public async Task<ActionResult> Track([FromQuery] int track_id, [FromQuery] string unique_id)
        {
            if (track_id <= 0)
            {
                return new APIResult(new { success = false, message = "miss" });
            }

            var link = await TracksCore.GetLinkByIdAsync(track_id);
            if (link == null)
            {
                return new APIResult(new { success = false, message = "not found" });
            }

            var dto = new TrackRequestLogDTO
            {
                track_id = track_id,
                event_type = link.event_type,
                platform = link.platform,
                typename = link.typename,
                scene = link.scene,
                unique_id = unique_id,
                ip = _accessor.HttpContext.GetUserIp(),
                user_agent = Request.Headers.UserAgent.ToString(),
                referer = Request.Headers.Referer.ToString()
            };
            _ = TracksCore.LogTrackRequestAsync(dto);
            _ = TracksCore.TrackAsync(link);
            return new APIResult(new { success = true, message = "ok" });
        }

        [HttpPost]
        public async Task<ActionResult> Create([FromQuery] string eventType, [FromQuery] string platform = "", [FromQuery] string typename = "", [FromQuery] string scene = "", [FromQuery] string uniqueId = "", [FromQuery] string description = "")
        {
            if (string.IsNullOrWhiteSpace(typename)) typename = platform;
            if (string.IsNullOrWhiteSpace(platform)) platform = typename;
            var link = await TracksCore.CreateLinkAsync(eventType, platform, typename, scene, uniqueId, description);
            if (link == null)
            {
                return new APIResult(new { success = false, message = "invalid params or eventType" });
            }
            //var request = _accessor.HttpContext!.Request;
            //string url = $"{request.Scheme}://{request.Host}{link.path}";
            return new APIResult(new { success = true, message = "ok", url = link.path });
        }

        [HttpGet]
        public async Task<ActionResult> Daily([FromQuery] int daysAgo = 0, [FromQuery] string reportDate = "", [FromQuery] bool includeToday = false, [FromQuery] bool includeYesterday = true)
        {
            var dates = new List<DateTime>();
            DateTime today = DateTime.Now.Date;

            if (!string.IsNullOrWhiteSpace(reportDate) && DateTime.TryParse(reportDate, out var parsed))
            {
                dates.Add(parsed.Date);
                if (includeToday && parsed.Date != today) dates.Add(today);
            }
            else
            {
                if (daysAgo > 0)
                {
                    var date = today.AddDays(-daysAgo);
                    dates.Add(date);
                    if (includeToday && date != today) dates.Add(today);
                }
                else
                {
                    dates.Add(today);
                    if (includeYesterday) dates.Add(today.AddDays(-1));
                }
            }

            int rows = 0;
            var reportDates = new List<string>();
            foreach (var date in dates.Distinct())
            {
                rows += await TracksCore.FlushDailyAsync(date);
                reportDates.Add(date.ToString("yyyy-MM-dd"));
            }
            return new APIResult(new { success = true, message = "ok", rows, reportDates });

        }
    }
}