CoupangModel.cs 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239
  1. using System.Security.Cryptography;
  2. using System.Text;
  3. using System.Text.Json;
  4. using goods.Models;
  5. using static Microsoft.Extensions.Logging.EventSource.LoggingEventSource;
  6. using Product = goods.Models.Coupang.Product;
  7. using Search = goods.Models.Coupang.Search;
  8. namespace goods.Models.Coupang
  9. {
  10. public class CoupangModel
  11. {
  12. private readonly CoupangPartners _coupangPartners;
  13. private string _ChannelID;
  14. public CoupangModel(CoupangPartners coupangPartners)
  15. {
  16. _coupangPartners = coupangPartners;
  17. _ChannelID = "goods20241230";
  18. }
  19. /// <summary>
  20. /// Generate HMAC signature for Coupang API.
  21. /// </summary>
  22. public static String GenerateHmac(String method, String url, String accessKey, String secretKey)
  23. {
  24. var dateTimeStamp = DateTime.Now.ToUniversalTime().ToString("yyMMddTHHmmssZ");
  25. var message = String.Format("{0}{1}{2}", dateTimeStamp, method, url.Replace("?", String.Empty));
  26. var keyBytes = ASCIIEncoding.Default.GetBytes(secretKey);
  27. var messageBytes = ASCIIEncoding.Default.GetBytes(message);
  28. var hashBytes = default(Byte[]);
  29. using (var hash = new HMACSHA256(keyBytes))
  30. {
  31. hashBytes = hash.ComputeHash(messageBytes);
  32. }
  33. var signature = BitConverter.ToString(hashBytes).Replace("-", String.Empty).ToLower();
  34. return String.Format("CEA algorithm=HmacSHA256, access-key={0}, signed-date={1}, signature={2}", accessKey, dateTimeStamp, signature);
  35. }
  36. // 골드박스
  37. public async Task<Product.Response> GetGoldBoxProduct()
  38. {
  39. Product.Response parseData = new();
  40. try
  41. {
  42. var urlPath = $"/v2/providers/affiliate_open_api/apis/openapi/v1/products/goldbox?subId={_ChannelID}"; // URI 경로만 전달
  43. // Step 1: URI 생성
  44. var baseUri = new Uri(_coupangPartners.APIUrl);
  45. var fullUri = baseUri + urlPath;
  46. // Step 2: HMAC 서명 생성
  47. var method = "GET";
  48. var signature = GenerateHmac(method, urlPath, _coupangPartners.APIKey, _coupangPartners.APISecret);
  49. // Step 3: HttpRequestMessage 생성
  50. using var request = new HttpRequestMessage(HttpMethod.Get, fullUri);
  51. request.Headers.Add("Authorization", signature);
  52. // Content-Type을 설정하려면 HttpContent를 추가
  53. request.Content = new StringContent(string.Empty); // 빈 본문
  54. // Step 4: HTTP 요청 보내기
  55. var response = await _coupangPartners.httpClient.SendAsync(request);
  56. if (response.IsSuccessStatusCode)
  57. {
  58. var jsonString = await response.Content.ReadAsStringAsync();
  59. parseData = JsonSerializer.Deserialize<Product.Response>(jsonString);
  60. if (parseData is null)
  61. {
  62. return new Product.Response();
  63. }
  64. }
  65. response.EnsureSuccessStatusCode();
  66. }
  67. catch (HttpRequestException e)
  68. {
  69. Console.WriteLine($"Request error: {e.Message}");
  70. }
  71. return parseData;
  72. }
  73. // 카테고리 별 상품
  74. public async Task<Product.Response> GetCategoryProduct(int categoryID)
  75. {
  76. Product.Response parseData = new();
  77. try
  78. {
  79. var urlPath = $"/v2/providers/affiliate_open_api/apis/openapi/v1/products/bestcategories/{categoryID}?limit=100&subId={_ChannelID}";
  80. // Step 1: URI 생성
  81. var baseUri = new Uri(_coupangPartners.APIUrl);
  82. var fullUri = baseUri + urlPath;
  83. // Step 2: HMAC 서명 생성
  84. var method = "GET";
  85. var signature = GenerateHmac(method, urlPath, _coupangPartners.APIKey, _coupangPartners.APISecret);
  86. // Step 3: HttpRequestMessage 생성
  87. using var request = new HttpRequestMessage(HttpMethod.Get, fullUri);
  88. request.Headers.Add("Authorization", signature);
  89. // Content-Type을 설정하려면 HttpContent를 추가
  90. request.Content = new StringContent(string.Empty); // 빈 본문
  91. // Step 4: HTTP 요청 보내기
  92. var response = await _coupangPartners.httpClient.SendAsync(request);
  93. if (response.IsSuccessStatusCode)
  94. {
  95. var jsonString = await response.Content.ReadAsStringAsync();
  96. parseData = JsonSerializer.Deserialize<Product.Response>(jsonString);
  97. if (parseData is null)
  98. {
  99. return new Product.Response();
  100. }
  101. }
  102. response.EnsureSuccessStatusCode();
  103. }
  104. catch (HttpRequestException e)
  105. {
  106. Console.WriteLine($"Request error: {e.Message}");
  107. }
  108. return parseData;
  109. }
  110. // 쿠팡PL 상품
  111. public async Task<Product.Response> GetPlProduct(int brandID)
  112. {
  113. Product.Response parseData = new();
  114. try
  115. {
  116. var urlPath = $"/v2/providers/affiliate_open_api/apis/openapi/v1/products/coupangPL/{brandID}?limit=100&subId={_ChannelID}";
  117. // Step 1: URI 생성
  118. var baseUri = new Uri(_coupangPartners.APIUrl);
  119. var fullUri = baseUri + urlPath;
  120. // Step 2: HMAC 서명 생성
  121. var method = "GET";
  122. var signature = GenerateHmac(method, urlPath, _coupangPartners.APIKey, _coupangPartners.APISecret);
  123. // Step 3: HttpRequestMessage 생성
  124. using var request = new HttpRequestMessage(HttpMethod.Get, fullUri);
  125. request.Headers.Add("Authorization", signature);
  126. // Content-Type을 설정하려면 HttpContent를 추가
  127. request.Content = new StringContent(string.Empty); // 빈 본문
  128. // Step 4: HTTP 요청 보내기
  129. var response = await _coupangPartners.httpClient.SendAsync(request);
  130. if (response.IsSuccessStatusCode)
  131. {
  132. var jsonString = await response.Content.ReadAsStringAsync();
  133. parseData = JsonSerializer.Deserialize<Product.Response>(jsonString);
  134. if (parseData is null)
  135. {
  136. return new Product.Response();
  137. }
  138. }
  139. response.EnsureSuccessStatusCode();
  140. }
  141. catch (HttpRequestException e)
  142. {
  143. Console.WriteLine($"Request error: {e.Message}");
  144. }
  145. return parseData;
  146. }
  147. // 검색 상품
  148. public async Task<Search.Response> GetSearchProduct(string keyword)
  149. {
  150. Search.Response parseData = new();
  151. try
  152. {
  153. var urlPath = $"/v2/providers/affiliate_open_api/apis/openapi/v1/products/search";
  154. var encodedKeyword = Uri.EscapeDataString(keyword);
  155. var queryParams = $"?keyword={encodedKeyword}&limit=10&srpLinkOnly=false&subId={_ChannelID}";
  156. var fullPathWithQuery = urlPath + queryParams;
  157. // Step 1: URI 생성
  158. var baseUri = new Uri(_coupangPartners.APIUrl);
  159. var fullUri = new Uri(baseUri, fullPathWithQuery);
  160. // Step 2: HMAC 서명 생성
  161. var method = "GET";
  162. var signature = GenerateHmac(method, fullPathWithQuery, _coupangPartners.APIKey, _coupangPartners.APISecret);
  163. // Step 3: HttpRequestMessage 생성
  164. using var request = new HttpRequestMessage(HttpMethod.Get, fullUri);
  165. request.Headers.Add("Authorization", signature);
  166. // Content-Type을 설정하려면 HttpContent를 추가
  167. request.Content = new StringContent(string.Empty); // 빈 본문
  168. // Step 4: HTTP 요청 보내기
  169. var response = await _coupangPartners.httpClient.SendAsync(request);
  170. if (response.IsSuccessStatusCode)
  171. {
  172. var jsonString = await response.Content.ReadAsStringAsync();
  173. parseData = JsonSerializer.Deserialize<Search.Response>(jsonString);
  174. if (parseData is null)
  175. {
  176. return new Search.Response();
  177. }
  178. }
  179. response.EnsureSuccessStatusCode();
  180. }
  181. catch (HttpRequestException e)
  182. {
  183. Console.WriteLine($"Request error: {e.Message}");
  184. }
  185. return parseData;
  186. }
  187. }
  188. }