feat: 完成模板从gitee上获取

This commit is contained in:
chenchun
2024-11-07 17:35:22 +08:00
parent ed5c20c612
commit d5ca8ddf1e
15 changed files with 192 additions and 61 deletions

View File

@@ -0,0 +1,85 @@
using System.Net;
using Microsoft.Extensions.Configuration;
using Newtonsoft.Json.Linq;
using Volo.Abp.DependencyInjection;
namespace Yi.Abp.Tool.Domain;
public class GiteeManager : ITransientDependency
{
private readonly string _accessToken;
private readonly IHttpClientFactory _httpClientFactory;
private const string GiteeHost = "https://gitee.com/api/v5";
private const string Owner = "ccnetcore";
private const string Repo = "yi-template";
public GiteeManager(IConfiguration configuration, IHttpClientFactory httpClientFactory)
{
_httpClientFactory = httpClientFactory;
_accessToken = configuration.GetValue<string>("GiteeAccession");
}
/// <summary>
/// 是否存在当前分支
/// </summary>
/// <returns></returns>
public async Task<bool> IsExsitBranchAsync(string branch)
{
using var client = _httpClientFactory.CreateClient();
var response =
await client.GetAsync(
$"{GiteeHost}/repos/{Owner}/{Repo}/branches/{branch}?access_token={_accessToken}");
if (response.StatusCode == HttpStatusCode.NotFound)
{
return false;
}
return true;
}
/// <summary>
/// 获取所有分支
/// </summary>
/// <returns></returns>
public async Task<List<string>> GetAllBranchAsync()
{
using var client = _httpClientFactory.CreateClient();
var response =
await client.GetAsync(
$"{GiteeHost}/repos/{Owner}/{Repo}/branches?access_token={_accessToken}&sort=name&direction=asc&page=1&per_page=100");
response.EnsureSuccessStatusCode();
var result= await response.Content.ReadAsStringAsync();
JArray jsonArray= JArray.Parse(result);
// 创建一个列表来存储名字
List<string> names = new List<string>();
// 遍历每个对象,获取 name 字段
foreach (JObject obj in jsonArray)
{
// 获取 name 字段的值
string name = obj["name"]?.ToString();
if (name != null)
{
names.Add(name);
}
}
return names;
}
/// <summary>
/// 下载仓库分支代码
/// </summary>
/// <param name="branch"></param>
/// <returns></returns>
public async Task<Stream> DownLoadFileAsync(string branch)
{
using var client = _httpClientFactory.CreateClient();
var response =
await client.GetAsync(
$"{GiteeHost}/repos/{Owner}/{Repo}/zipball?access_token={_accessToken}&ref={branch}");
response.EnsureSuccessStatusCode();
return await response.Content.ReadAsStreamAsync();
}
}

View File

@@ -13,13 +13,19 @@ namespace Yi.Abp.Tool.Domain
{
public class TemplateGenManager : ITransientDependency
{
public readonly ToolOptions _toolOptions;
public TemplateGenManager(IOptionsMonitor<ToolOptions> toolOptions) { _toolOptions = toolOptions.CurrentValue; }
private readonly ToolOptions _toolOptions;
private readonly GiteeManager _giteeManager;
public TemplateGenManager(IOptionsMonitor<ToolOptions> toolOptions, GiteeManager giteeManager)
{
_giteeManager = giteeManager;
_toolOptions = toolOptions.CurrentValue;
}
public async Task<string> CreateTemplateAsync(TemplateGenCreateDto input)
{
if (string.IsNullOrEmpty(input.TemplateFilePath))
//这里判断gitee上是否有这个分支
if (await _giteeManager.IsExsitBranchAsync(input.GiteeRef))
{
throw new UserFriendlyException($"模板路径无法找到,请检查,[{input.TemplateFilePath}]路径");
throw new UserFriendlyException($"Gitee分支未找到{input.GiteeRef},请检查,[{input.GiteeRef}]分支是否存在");
}
if (string.IsNullOrEmpty(_toolOptions.TempDirPath))
{
@@ -33,8 +39,15 @@ namespace Yi.Abp.Tool.Domain
Directory.CreateDirectory(tempFileDirPath);
}
//文件解压覆盖
ZipFile.ExtractToDirectory(input.TemplateFilePath, tempFileDirPath, true);
//下载的模板存放文件路径
var downloadFilePath = Path.Combine(_toolOptions.TempDirPath,"download" ,$"{id}.zip");
var gitSteam= await _giteeManager.DownLoadFileAsync(input.GiteeRef);
using (FileStream fileStream = new FileStream(downloadFilePath, FileMode.Create, FileAccess.Write))
{
await gitSteam.CopyToAsync(fileStream);
}
//文件解压覆盖,将刚刚下载的模板,解压即可
ZipFile.ExtractToDirectory(downloadFilePath, tempFileDirPath, true);
await ReplaceContentAsync(tempFileDirPath, input.ReplaceStrData);
var tempFilePath = Path.Combine(_toolOptions.TempDirPath, $"{id}.zip");
@@ -45,13 +58,22 @@ namespace Yi.Abp.Tool.Domain
return tempFilePath;
}
/// <summary>
/// 获取全部模板列表
/// </summary>
/// <returns></returns>
public async Task<List<string>> GetAllTemplatesAsync()
{
return await _giteeManager.GetAllBranchAsync();
}
/// <summary>
/// 替换内容,key为要替换的内容value为替换成的内容
/// </summary>
/// <returns></returns>
private async Task ReplaceContentAsync(string rootDirectory, Dictionary<string, string> dic)
{
foreach (var dicEntry in dic)
{
await ReplaceInDirectory(rootDirectory, dicEntry.Key, dicEntry.Value);
@@ -110,5 +132,6 @@ namespace Yi.Abp.Tool.Domain
return directoryPath;
}
}
}
}