lsm/OpenAuth.Net
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/OpenAuth.Net.git synced 2025-09-20 18:47:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: 流程模板调整为sqlsugar

Browse Source
This commit is contained in:
wintel
2025-04-06 21:24:18 +08:00
parent 68aa427b40
commit 3ff124a3b0
1 changed files with 12 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
OpenAuth.App/FlowScheme/FlowSchemeApp.cs
View File

@@ -1,23 +1,20 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Infrastructure; using Infrastructure;
using Microsoft.EntityFrameworkCore;
using OpenAuth.App.Interface; using OpenAuth.App.Interface;
using OpenAuth.App.Request; using OpenAuth.App.Request;
using OpenAuth.App.Response; using OpenAuth.App.Response;
using OpenAuth.Repository;
using OpenAuth.Repository.Domain; using OpenAuth.Repository.Domain;
using OpenAuth.Repository.Interface; using SqlSugar;
namespace OpenAuth.App namespace OpenAuth.App
{ {
public class FlowSchemeApp :BaseStringApp<FlowScheme,OpenAuthDBContext> public class FlowSchemeApp :SqlSugarBaseApp<FlowScheme>
{ {
public void Add(FlowScheme flowScheme) public void Add(FlowScheme flowScheme)
{ {
if (Repository.Any(u => u.SchemeName == flowScheme.SchemeName)) if (Repository.IsAny(u => u.SchemeName == flowScheme.SchemeName))
{ {
throw new Exception("流程名称已经存在"); throw new Exception("流程名称已经存在");
} }
@@ -25,33 +22,32 @@ namespace OpenAuth.App
var user = _auth.GetCurrentUser().User; var user = _auth.GetCurrentUser().User;
flowScheme.CreateUserId = user.Id; flowScheme.CreateUserId = user.Id;
flowScheme.CreateUserName = user.Name; flowScheme.CreateUserName = user.Name;
Repository.Add(flowScheme); Repository.Insert(flowScheme);
} }
public FlowScheme FindByCode(string code) public FlowScheme FindByCode(string code)
{ {
return Repository.FirstOrDefault(u => u.SchemeCode == code); return Repository.GetFirst(u => u.SchemeCode == code);
} }
public void Update(FlowScheme flowScheme) public void Update(FlowScheme flowScheme)
{ {
if (Repository.Any(u => u.SchemeName == flowScheme.SchemeName && u.Id != flowScheme.Id)) if (Repository.IsAny(u => u.SchemeName == flowScheme.SchemeName && u.Id != flowScheme.Id))
{ {
throw new Exception("流程名称已经存在"); throw new Exception("流程名称已经存在");
} }
UnitWork.Update<FlowScheme>(u => u.Id == flowScheme.Id, u => new FlowScheme Repository.Update(u => new FlowScheme
{ {
FrmUrlTemplate = flowScheme.FrmUrlTemplate,
SchemeContent = flowScheme.SchemeContent,
SchemeName = flowScheme.SchemeName, SchemeName = flowScheme.SchemeName,
ModifyDate = DateTime.Now, ModifyDate = DateTime.Now,
FrmId = flowScheme.FrmId, FrmId = flowScheme.FrmId,
FrmType = flowScheme.FrmType, FrmType = flowScheme.FrmType,
FrmUrlTemplate = flowScheme.FrmUrlTemplate,
Disabled = flowScheme.Disabled, Disabled = flowScheme.Disabled,
Description = flowScheme.Description, Description = flowScheme.Description,
OrgId = flowScheme.OrgId OrgId = flowScheme.OrgId
}); },u => u.Id == flowScheme.Id);
} }
/// <summary> /// <summary>
@@ -63,7 +59,7 @@ namespace OpenAuth.App
/// <returns></returns> /// <returns></returns>
public List<FlowScheme> LoadUrlFormFlowScheme() public List<FlowScheme> LoadUrlFormFlowScheme()
{ {
return Repository.Find(u => u.FrmType == Define.FORM_TYPE_URL).ToList(); return Repository.GetList(u => u.FrmType == Define.FORM_TYPE_URL);
} }
@@ -83,7 +79,7 @@ namespace OpenAuth.App
return result; return result;
} }
public FlowSchemeApp(IUnitWork<OpenAuthDBContext> unitWork, IRepository<FlowScheme,OpenAuthDBContext> repository,IAuth auth) : base(unitWork, repository, auth) public FlowSchemeApp(ISqlSugarClient client, IAuth auth) : base(client, auth)
{ {
} }
} }