Pico.Core 1.1.7

公共组件 Pico.Core

版本描述

v1.0.9

实现了字符串的扩展方法
断言较验参数
EF动态Where条件
EF统一分页查询方法
Camunda 外部任务标准监听，回调，获取指定实例的当前任务
统一的Id生成器
封装了解释Accesstoken实现获取用户身份信息
封装了部分的Grap Api的调用
封装了http+Json的请求方法
封装API的标准输出 Result
封装了二唯码生成器
统一了基本查询参数SearchParam，可供扩展
统一了AzureFunction入口方法调用

组件使用说明

Azure Function

//在 Startup.cs中增加启动配置
 PicoApplication.Setup();
//方法标准写法
[FunctionName("token")]
public static async Task<IActionResult> Run(
[HttpTrigger(AuthorizationLevel.Function, "get", Route = null)] HttpRequest req,
            ILogger log)
{
    return await req.ExecutingAsync(async () =>
     {
       return await GraphUtil.GetAccessTokenAsync();
     }, log);
}
//或者，兼容未走网关的服务
[FunctionName("token")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", Route = null)] HttpRequest req,
    ILogger log,ClaimsPrincipal claims)
{
    return await req.ExecutingAsync(async () =>
     {
         //业务逻辑
       return await GraphUtil.GetAccessTokenAsync();
     }, log,claims);
 }

.Net Core Api

获取身份信息

IdentityUtil.Email //获取当前用户
IdentityUtil.IsLogin() //判断用户是否登录
IdentityUtil.AccessToken //获取访问的Token

Camunda 流程引擎

//1.在启动类开启Bpm
PicoApplication.Setup(new PicoConfiguration(){
  EnableBpm = true,
});
//2.在配置文件中增加如下配置
"BPM_CONFIG_JSON": {"ApiUrl": "","SecretKey":""}
// 3.实现Camunda监听器
 internal class CamundaService : CamundaListener
    {
        public static ISet<string> Topics = new HashSet<string> {
            C.TERMINATE_REMOVE
        };
        public override Dictionary<string, CamundaVariable> ExecuteTask(ExternalTask task)
        {
            var variables = task.Variables;
            switch (task.TopicName)
            {
                case C.TERMINATE_REMOVE:
                    //定义业务逻辑
                    //回写流程变量
                    variables[xxx] = new CamundaVariable { Value = xxx };
                    break;
                default:
                    break;
            }
            return variables;
        }
    }
//4.在启动类中启动监听
new CamundaService().Start(CamundaService.Topics);

//启动流程
var res =CamundaUtil.StartByKey<T>(new StartProcess<T>(),key)
//任务回调
CamundaUtil.Callback(new CallbackProcess())
//获取指定用户当前实例的待办任务ID
var taskId CamundaUtil.GetTaskId(processId，email)

Redis 缓存工具

//1.在启动类开启Redis
PicoApplication.Setup(new PicoConfiguration(){
  EnableReadis = true,
});
//2.在配置文件中增加如下配置
//3.从缓存中取值
CacheUtil.GetAsync(key).Result
CacheUtil.GetAsync<T>(key).Result
//设置值
CacheUtil.SetAsync(key,val,cacheTime)
//删除
CacheUtil.RemoveAsync(key)
//键值判断
CacheUtil.ExistAsync(key)

Id生成器

IdUtil.LongId() //雪花算法生成唯一long型Id
IdUtil.StringId()//雪花算法生成唯一string型Id

QrCode生成器

QrCodeUtil.GetQRCode("https://helpdesk.poico.com") //为指定的Url生成二维码图像

RestUtil 请求工具

var body = new RestParm{
    Url="https://xx.com/service",
    Body=new object()
};
var res = await body.PostAsync(); //异步方法获取返回结果
var res = body.PostAsync().Result; //同步方法获取返回结果
GetAsync()//Http GET 请求
PutAsync()//Http PUT 请求
DeleteAsync()//Http DELETE 请求
PatchAsync()//Http PATCH 请求

GraphUtil 请求工具

//1.在启动类开启Graph
PicoApplication.Setup(new PicoConfiguration(){
  EnableGraph = true,
});
//2.在配置文件中增加如下配置
"GRAPH_CONFIG_JSON": {"TenantId": "","ClientId": "","SecretKey":""}
// 3.获取accessToken
var token = GraphUtil.GetAccessTokenAsync().Result;
//4.获取o365UserId
var userId =GraphUtil.GetUserId(email);

Result 标准输出

{
    "code": 200,
    "success": true,
    "msg": "操作成功",
    "time": 1511,
    "data":null,
    "status": "Success"
}

Page<T> 标准分页返回

var pageInfo = new Page<Project>(1,10);
var Q =from p in db.Projects select p;
var res = Q.ToPageList(pageInfo, new KeyValuePair<Expression<Func<Project, object>>, E.Sort>(e => e.ProjectId, E.Sort.ASC));
//前端页指定排序
var res = Q.ToPageList(pageInfo, new KeyValuePair<string, E.Sort> ("ProjectId",E.Sort.ASC), new KeyValuePair<string, E.Sort>("ProjectStatus", E.Sort.DESC));
                   

动态查询条件

var args = new SearchParam{Keyword="xx",StartTime="xx",EndTime="xx"};
var Q =from p in db.Projects select p;
Q = Q.Where(args.Keyword.IsNotEmpty(), e => e.ProjectName.Contains(args.Keyword) || e.SicName.Contains(args.Keyword))
      .Where(args.StartTime > TimeUtil.MinValue, e => e.ShowCloseDate >= args.StartTime.Date)
      .Where(args.EndTime > TimeUtil.MinValue, e => e.ShowCloseDate <= args.EndTime.Date);
return Q.ToList();

动态排序

//后端指定排序字段
 var orderByItems = new HashSet<KeyValuePair<Expression<Func<Projects, object>>, E.Sort>>
                {
                    new  KeyValuePair<Expression<Func<Projects, object>>, E.Sort> (e=>e.ProjectId,E.Sort.ASC),
                     new  KeyValuePair<Expression<Func<Projects, object>>, E.Sort>(e=>e.ProjectStatus, E.Sort.DESC)
                };
 var result = Q.OrderBy(orderByItems.ToArray()).ToList();
 //前端指定排序字段
  var orderByItems = new HashSet<KeyValuePair<string, E.Sort>>
                {
                    new KeyValuePair<string, E.Sort> ("ProjectId",E.Sort.ASC),
                     new KeyValuePair<string, E.Sort>("ProjectStatus", E.Sort.DESC)
                };
 var result = Q.OrderBy(orderByItems.ToArray()).ToList();

值判断

var str="xxx";
//非空判断
str.IsNotEmpty()
//空判断
str.IsEmpty()
//忽略大小写相等判断
"xx".EqualsIgnoreCase(str)

var obj= new ojbect();
//非空判断
obj.IsNotEmpty()
//空判断
obj.IsEmpty()

参数较验

//用断言代替if else
Tools.AssertEmpty(email,"Email Is Required") 
Tools.AssertFalse(agr>18,"年龄必须大于18") 
Tools.AssertTrue(o365UserId.IsNotEmpty(),"帐号已被注册") 
Tools.AssertNull(user,"User Not Fund")

Json序列化与反序列化

//返序列化
var json ="";
var obj = json.ToObject<T>();

//序列化
var obj = new object();
var json = obj.ToJson();

字符串与基本类型转换

var str="";
str.ToInt() //string to int
str.ToLong() //string to long
str.ToBool() //string to bool
str.ToDouble() //string to double
str.ToDateTime() //string to datetime
//datetime to string
var dt =TimeUtil.Now;
dt.ToFormatString(dt,"yyyy-MM-dd")

统一获取服务器时间

TimeUtil.Now
TimeUtil.UtcNow
TimeUtil.MinValue

邮件工具

var emailRequest = new EmailParam { To = "xx", Body = "test", Subject = "test", };
await emailRequest.TriggerAsync();
//Teams 审批流
var approveRequest= new ApproveParam {To = "xx",Title = "test",Details = "test", Requestor = "xx", CallbackUrl = "xx",Id = "test"};
approveRequest.TriggerAsync();