dotnet/molilian.core/Core/taoke/UnionCouponCore.cs

using dodohold.core;
using Microsoft.AspNetCore.Mvc;

namespace molilian.core
{
    public partial class UnionCouponCore
    {

        private static string _end_point;
        static UnionCouponCore()
        {
            _end_point = Environment.GetEnvironmentVariable("EndPoint");
        }

        public static async Task<ActionResult> UnionCouponAsync(string content, string dplink, string channel, string style, string ip, string oaid, string clickId)
        {
            switch (channel)
            {
                case "tb":
                    return await TaobaoCouponAsync(content, dplink, ip, oaid);
                case "jd":
                    return await JdCouponAsync(content, dplink, ip, oaid, clickId);
                default:
                    if (!string.IsNullOrEmpty(content.Trim()))
                    {
                        return await UnionCpsCore.TbtCouponAsync(content, channel, ip, oaid);
                    }
                    var result = await UnionCpsCore.CpsCouponAsync(channel, style, ip, oaid);
                    if (result.success)
                    {
                        return new APIResult(new
                        {
                            result.success,
                            result.message,
                            result.title,
                            result.sub_title,
                            result.deeplink_url,
                            result.shortLinkurl,
                            result.token,
                            result.channel,
                            exposeTracks = $"https://api.molilian.com/tracks/track?track_id=9&unique_id={result.channel}",
                            clickTracks = $"https://api.molilian.com/tracks/track?track_id=10&unique_id={result.channel}",
                        });
                    }
                    else
                    {
                        return new APIResult(new
                        {
                            result.success,
                            result.message,
                            result.reason,
                            result.channel,
                        });
                    }
            }
        }

        public static async Task<APIResult> TaobaoCouponAsync(string content, string dplink, string ip = "", string oaid = "")
        {
            AlimamaPlus alimama = null;
            content = content.UrlDecode();
            dplink = dplink.UrlDecode();
            UnionCouponDTO result = new()
            {
                channel = TkChannelEnum.tb,
                rawContent = content,
                rawContent2 = dplink,
                end_point = _end_point,
                ip = ip,
                oaid = oaid
            };

            content = AlimamaPlus.FakeItemUrl(content, dplink);
            result.content = content;

            if (string.IsNullOrEmpty(content))
            {
                result.success = false;
                result.message = "放弃转链";
                result.reason = "无效的参数";
                result.rawContent = content;
                _ = TkLogCore.CouponLogAsync(result);
                return new APIResult(new
                {
                    result.success,
                    result.reason,
                    result.message,
                    channel = result.channel.ToString(),
                });
            }

            try
            {
                string reason;
                UnionParseRequest request = new()
                {
                    Ip = ip,
                    Oaid = oaid,
                    RiskStrategy = string.Empty,
                    LaunchScene = 0,
                };
                if (AlimamaPlus.FilterRiskLink(ip, oaid, content, out reason) ||
                    AlimamaPlus.ShouldIgnoreRequest(request, out reason))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = reason;
                    _ = TkLogCore.CouponLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.message,
                        result.reason,
                        channel = result.channel.ToString(),
                    });
                }

                var account = await TkPoolCore.GetOneAsync(TkPoolCore.TkAction.coupon, false, string.Empty, 0);
                if (account == null)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "没有匹配账号";
                    _ = TkLogCore.CouponLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.message,
                        result.reason,
                        channel = result.channel.ToString(),
                    });
                }
                result.accountId = account.id;
                result.accountName = account.name;
                alimama = new AlimamaPlus(account);
                result = await alimama.UnionCoupon2Async(content, result);
            }
            catch (Exception ex)
            {
                if (ex.Message.Contains("was canceled"))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                }
                else
                {
                    _ = new LoggerLibrary("unionCoupon", "tb_error")
                        .Info(ip, oaid)
                        .Info(content)
                        .Info(ex.Message, ex.StackTrace)
                        .SaveAsync();

                    NotifyCore.Notify(new NifyMessage
                    {
                        message = $"【转链异常TB】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "转链接口异常";
                }
            }
            _ = TkLogCore.CouponLogAsync(result, alimama);
            if (!result.success)
            {
                return new APIResult(new
                {
                    result.success,
                    result.message,
                    result.reason,
                    channel = result?.channel.ToString(),
                });
            }
            int couponAmount = (int)result.couponAmount * 100;
            return new APIResult(new
            {
                result.success,
                result.message,
                channel = result?.channel.ToString(),
                result?.itemId,
                couponAmount,
                result?.deeplink_url,
                result?.pic,
                result?.couponEffectiveStartTime,
                result?.couponEffectiveEndTime,
            });
        }

        public static async Task<APIResult> JdCouponAsync(string content, string dplink, string ip, string oaid, string clickId)
        {
            content = content.UrlDecode();
            dplink = dplink.UrlDecode();
            UnionCouponDTO result = new()
            {
                channel = TkChannelEnum.jd,
                rawContent = content,
                rawContent2 = dplink,
                end_point = _end_point,
            };
            if (string.IsNullOrEmpty(content))
            {
                content = dplink.Replace("taobao://", "https://");
            }
            if (string.IsNullOrEmpty(content))
            {
                result.success = false;
                result.message = "放弃转链";
                result.reason = "无效的参数";
                result.rawContent = content;
                _ = TkLogCore.CouponLogAsync(result);
                return new APIResult(new
                {
                    result.success,
                    result.reason,
                    result.message,
                    channel = result.channel.ToString(),
                });
            }

            try
            {
                var config = TkConfigCore.Get();
                UnionParseRequest request = new();
                request.Ip = ip;
                request.Oaid = oaid;
                request.RiskStrategy = string.Empty;
                request.LaunchScene = 0;
                if (JdUnionPlus.ShouldIgnoreRequest(config, request, out string reason))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = reason;
                    _ = TkLogCore.CouponLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.reason,
                        result.message,
                        channel = result.channel.ToString(),
                    });
                }

                var api = DataokeCore.GetOne();
                if (api == null)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "没有匹配账号";
                    result.rawContent = content;
                    _ = TkLogCore.CouponLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.reason,
                        result.message,
                        channel = result.channel.ToString(),
                    });
                }

                var account = await JdPoolCore.GetOneAsync();
                if (account == null)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "没有匹配账号";
                    _ = TkLogCore.CouponLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.reason,
                        result.message,
                        channel = result.channel.ToString(),
                    });
                }
                result = await JdUnionPlus.JdCouponAsync(account, api, content, clickId, result);
                if (result.success && result.couponAmount == 0)
                {
                    result.success = false;
                    result.message = "没有优惠券";
                    result.reason = "";
                }
            }
            catch (Exception ex)
            {
                if (ex.Message.Contains("was canceled"))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                }
                else
                {
                    _ = new LoggerLibrary("unionCoupon", "jd_error")
                        .Info(ip, oaid)
                        .Info(content)
                        .Info(ex.Message, ex.StackTrace)
                        .SaveAsync();
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = $"【转链异常JD】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    result.success = false;
                    result.message = "内部错误";
                    result.reason = "转链接口异常";
                }
            }
            _ = TkLogCore.CouponLogAsync(result);
            if (!result.success)
            {
                return new APIResult(new
                {
                    result.success,
                    result.reason,
                    result.message,
                    channel = result?.channel.ToString(),
                });
            }
            int couponAmount = (int)(result.couponAmount * 100);
            return new APIResult(new
            {
                result.success,
                result.message,
                channel = result?.channel.ToString(),
                result?.itemId,
                couponAmount,
                result?.deeplink_url,
                result?.pic,
                result?.couponEffectiveStartTime,
                result?.couponEffectiveEndTime,
            });
        }

    }

}