TEAMModelOS/TEAMModelBI/Controllers/BICommon/BICouponController.cs

using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Options;
using System.Net.Http;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK;
using TEAMModelOS.Models;
using System.Text.Json;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Text;
using TEAMModelOS.SDK.Extension;
using System;
using System.Net.Http.Json;
using System.ComponentModel.DataAnnotations;
using System.Net;
using System.Net.Http.Headers;
using Newtonsoft.Json;
using System.Text.Encodings.Web;

namespace TEAMModelBI.Controllers.BICommon
{
    [Route("coupon")]
    [ApiController]
    public class BICouponController : ControllerBase
    {
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly IConfiguration _configuration;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly IHttpClientFactory _http;
        private readonly CoreAPIHttpService _coreAPIHttpService;
        private readonly IWebHostEnvironment _environment; //读取文件
        private readonly HttpClient _httpClient;

        public BICouponController(DingDing dingDing, IOptionsSnapshot<Option> option, IConfiguration configuration, AzureServiceBusFactory serviceBus, IHttpClientFactory http, CoreAPIHttpService coreAPIHttpService, IWebHostEnvironment hostingEnvironment, HttpClient httpClient)
        {
            _dingDing = dingDing;
            _option = option?.Value;
            _configuration = configuration;
            _serviceBus = serviceBus;
            _http = http;
            _coreAPIHttpService = coreAPIHttpService;
            _environment = hostingEnvironment;
            _httpClient = httpClient;
        }

        /// <summary>
        /// 建立優惠券
        /// </summary>
        /// <param name="GenerateCouponRequest"></param>
        /// <returns></returns>
        //[AuthToken(Roles = "admin,rdc,assist,sales")]
        [HttpPost("create-coupon")]
        public async Task<IActionResult> CreateCoupon(GenerateCouponRequest request)
        {
            try
            {
                //string url = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
                string url = "https://api2.teammodel.net";
                if (request.srvAdr == "China") url = "https://api2.teammodel.cn";
                
                string AccessToken = await getCoreAccessToken(request.srvAdr);
                var client = _http.CreateClient();
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken);
                HttpResponseMessage response = await client.PostAsJsonAsync($"{url}/Service/GenerateCoupon", request);
                if (response.StatusCode == HttpStatusCode.OK)
                {
                    string jsonStr = await response.Content.ReadAsStringAsync();
                    var options1 = new JsonSerializerOptions
                    {
                        Encoder = JavaScriptEncoder.UnsafeRelaxedJsonEscaping
                    };

                    await _dingDing.SendBotMsg(System.Text.Json.JsonSerializer.Serialize(request, options1), GroupNames.高飛);
                    return Ok(jsonStr.ToObject<JsonElement>());
                }
                else {
                    return BadRequest();
                }
            }
            catch (Exception ex) {
                return BadRequest();
            }
        }

        /// <summary>
        /// 歸戶
        /// </summary>
        /// <param name="GenerateCouponRequest"></param>
        /// <returns></returns>
        //[AuthToken(Roles = "admin,rdc,assist,sales")]
        [HttpPost("consolidation-coupon")]
        public async Task<IActionResult> ConsolidationCoupon(ConsolidationCouponRequest request)
        {
            try
            {
                string HaBookAuthString = (_option.Location.Contains("Global") && request.srvAdr.Equals("China")) ? "HaBookAuthCN" : "HaBookAuth";
                //string url = "https://api2.teammodel.net";
                //if (request.srvAdr == "China") url = "https://api2.teammodel.cn";
                string url = _configuration.GetValue<string>($"{HaBookAuthString}:CoreAPI");
                string AccessToken = await getCoreAccessToken(request.srvAdr);
                var client = _http.CreateClient();
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken);
                HttpResponseMessage response = await client.PostAsJsonAsync($"{url}/Service/CouponConsolidation", request);
                if (response.StatusCode == HttpStatusCode.OK)
                {
                    return Ok(new { state = 0, msg = "歸戶成功" });
                }
                else
                {
                    return BadRequest();
                }
            }
            catch (Exception ex)
            {
                return BadRequest();
            }
        }

        /// <summary>
        /// 通知
        /// </summary>
        /// <param name="GenerateCouponRequest"></param>
        /// <returns></returns>
        //[AuthToken(Roles = "admin,rdc,assist,sales")]
        [HttpPost("push-notify")]
        public async Task<IActionResult> PushNotify(PushNotifyRequest request)
        {
            try
            {
                string HaBookAuthString = (_option.Location.Contains("Global") && request.srvAdr.Equals("China")) ? "HaBookAuthCN" : "HaBookAuth";
                //string url = "https://api2.teammodel.net";
                //if (request.srvAdr == "China") url = "https://api2.teammodel.cn";
                string url = _configuration.GetValue<string>($"{HaBookAuthString}:CoreAPI");
                string AccessToken = await getCoreAccessToken(request.srvAdr);
                var client = _http.CreateClient();
                client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken);
                HttpResponseMessage response = await client.PostAsJsonAsync($"{url}/Service/PushNotify", request);
                if (response.StatusCode == HttpStatusCode.OK)
                {
                    return Ok(new { state = 0, msg = "發送成功" });
                }
                else
                {
                    return BadRequest();
                }
            }
            catch (Exception ex)
            {
                return BadRequest();
            }
        }

        private async Task<string> getCoreAccessToken(string srvAdr)
        {
            string AccessToken = "";
            try
            {
                string HaBookAuthString = (_option.Location.Contains("Global") && srvAdr.Equals("China")) ? "HaBookAuthCN" : "HaBookAuth"; //GL站點 => 可取得GL、CN兩站點設定資料  CN站點 => 只取自身站點資料
                string Url = _configuration.GetValue<string>($"{HaBookAuthString}:CoreAPI") + "/oauth2/token";
                string GrantType = "device";
                string ClientID = _configuration.GetValue<string>($"{HaBookAuthString}:CoreService:clientID");
                string Secret = _configuration.GetValue<string>($"{HaBookAuthString}:CoreService:clientSecret");
                var content = new { grant_type = GrantType, client_id = ClientID, client_secret = Secret };
                var response = await _http.CreateClient().PostAsJsonAsync($"{Url}", content);
                if (response.IsSuccessStatusCode)
                {
                    string responseBody = response.Content.ReadAsStringAsync().Result;
                    using (JsonDocument document = JsonDocument.Parse(responseBody.ToString()))
                    {
                        if (document.RootElement.TryGetProperty("access_token", out JsonElement AccessTokenObj))
                        {
                            AccessToken = AccessTokenObj.ToString();
                        }
                    }
                }
                return AccessToken;
            }
            catch (Exception ex)
            {
                return AccessToken;
            }
        }


    }

    public class info
    {
        public string l { get; set; }
        public string n { get; set; }
        public string u { get; set; }
    }
    public class CouponRule
    {
        public string q { get; set; }
        //可獲得的權益
        public string b { get; set; }
        //若已有權益 則給積分
        public int p { get; set; } = 0;
    }

    public record GenerateCouponRequest([Required] string srvAdr, [Required] string CouponType, List<string> targets, string couponName, int quantity, [Required] long expire, [Required] List<CouponRule> rule, string eventName, List<info> info, int maxTaker = -1);
    public record ConsolidationCouponRequest([Required] string srvAdr, [Required] string coupon, [Required] List<string> ids);
    public record PushNotifyRequest([Required] string srvAdr, [Required] string title, [Required] string body, [Required] List<string> tags, [Required] string sender, [Required] string hubName, string data = null);
}