using Attribute;
using Dto;
using Vo;
using Model;
using Model.Base;
using Repository;
using Service;
using Microsoft.AspNetCore.Mvc;
using Common;
using Infrastructure;
using Vo.Client;
namespace Services
{
///
/// api接口分组Service业务层处理
///
[AppService(ServiceType = typeof(IApiGroupService), ServiceLifetime = LifeTime.Transient)]
public class ApiGroupService : BaseService, IApiGroupService
{
///
/// api接口分组-列表
///
/// 请求参数
/// api接口分组列表
public PagedInfo List([FromQuery] ApiGroupListDto parm)
{
//开始拼装查询条件
var predicate = Expressionable.Create();
predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.groupName), m => m.groupName.Contains(parm.groupName));
var response = Queryable()
.Where(predicate.ToExpression())
.OrderByDescending(m => m.id)
.ToPage(new PagerInfo());
return response;
}
///
/// api分组-列表
///
/// 请求参数
/// api分组列表
public List ApiList([FromBody] Dto.Client.ApiInfoDto param)
{
List groups = RedisServer.Cache.LRange("appapiinfo:" + param.groupKind + ":" + param.projectId, 0, -1).ToList();
if (groups.Count <= 0)
{
groups = GetList(m => m.groupKind == param.groupKind && m.version == param.projectId);
RedisServer.Cache.LPush("appapiinfo:" + param.groupKind + ":" + param.projectId, groups.ToArray());
}
return groups;
}
///
/// api分组-列表
///
/// 请求参数
/// api分组列表
public List groups([FromBody] Dto.Client.ApiGroupDto param)
{
if (param.key != "ym#2024")
{
throw new CustomException(ResultCode.FAIL, "无权限");
}
List list = RedisServer.Cache.LRange("appapigroup:" + param.groupKind + ":" + param.projectId, 0, -1).ToList();
if (list.Count > 0)
{
return list;
}
var groups = GetList(m => m.groupKind == param.groupKind && m.version == param.projectId).Select(m => new ApiListVo() { groupName = m.groupName, groupVersion = m.groupVersion }).ToArray();
RedisServer.Cache.LPush("appapigroup:" + param.groupKind + ":" + param.projectId, groups);
return groups.ToList();
}
///
/// api接口分组-下拉框数据
///
/// api接口分组下拉框数据
public PagedInfo SelectList()
{
//开始拼装查询条件
var predicate = Expressionable.Create();
var response = Queryable()
.Where(predicate.ToExpression())
.OrderByDescending(m => m.id)
.ToPage(new PagerInfo());
return response;
}
///
/// api接口分组-列表
///
/// 请求参数
/// api接口分组列表
public List apiList([FromQuery] Dto.Client.ApiGroupListDto param)
{
if(param.key != "omega")
{
throw new CustomException("口令不正确");
}
//开始拼装查询条件
var predicate = Expressionable.Create();
predicate = predicate.And(m => m.version == param.projectId && m.groupKind == param.groupKind);
var response = Queryable()
.Where(predicate.ToExpression())
.Includes(m => m.apiInfo)
.ToList();
return response;
}
///
/// 通知-同步接口分组数据
///
/// 请求参数
/// 通知-同步接口分组数据
public int notice([FromBody] Dto.Client.NoticeGroupDto param)
{
string id = param.id;
string groupName = param.groupName;
string groupRemark = param.groupRemark;
int groupKind = param.groupKind;
int groupProject = param.groupProject;
int groupId = 0;
ApiGroup group = GetFirst(m => m.groupName == groupName && m.groupKind == groupKind && m.version == groupProject);
if (group == null)
{
groupId = InsertReturnIdentity(new ApiGroup()
{
createDate = DateTime.Now,
groupName = groupName,
groupRemark = groupRemark,
groupKind = groupKind,
groupVersion = "1",
version = groupProject,
});
}
else
{
groupId = group.id;
group.updateDate = DateTime.Now;
group.groupRemark = groupRemark;
int groupVersion = int.Parse(group.groupVersion) + 1;
group.groupVersion = groupVersion.ToString();
Update(group, true);
}
return groupId;
}
}
}