ZY.Framework.Core 1.3.2.17

基础组件

nuget引用组件 :ZY.Framework.Core

数据库

config

  "MySQLDbOption": {
    "ConnectionString": "server=localhost;port=3306;database=template;uid=root;password=yk1234;Old Guids=true;Allow User Variables=True;charset=utf8",
    "HisConnectionString": "server=localhost;port=3306;database=templatehis;uid=root;password=yk1234;Old Guids=true;Allow User Variables=True;charset=utf8;Pooling=true"
  }

Program

	 
LoggerFactory MyLoggerFactory = new LoggerFactory(new[] { new DebugLoggerProvider() });
var migrationsAssembly = typeof(EFDbContext).GetTypeInfo().Assembly.GetName().Name;
services.AddFramework<EFDbContext>(option =>
{
    //option.UseSqlServer(Configuration["SQLDbOption:ConnectionString"],
    option.UseMySql(
        configuration["MySQLDbOption:ConnectionString"],
        ServerVersion.AutoDetect(configuration["MySQLDbOption:ConnectionString"]),
        builder => builder.MigrationsAssembly(migrationsAssembly));
})
    .AddDbContext<HistoryDbContext>(opt =>
    {
        string connectionString = configuration["MySQLDbOption:HisConnectionString"];
        var serverVersion = ServerVersion.AutoDetect(connectionString);
        opt.UseLoggerFactory(MyLoggerFactory).UseMySql(
            connectionString,
            serverVersion,
            builder => builder.MigrationsAssembly(migrationsAssembly));
    });

Context

    public class EFDbContext : BaseDbContext
    {
        public EFDbContext(DbContextOptions<EFDbContext> options) : base(options){}
        public DbSet<Arrears> Arrears { get; set; }
        public DbSet<ArrearsApply> ArrearsApply { get; set; }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            base.OnModelCreating(modelBuilder);
        }
    }

    public class HistoryDbContext : BaseDbContext
    {
        public HistoryDbContext(DbContextOptions<HistoryDbContext> options) : base(options){}
        public DbSet<CarRecord> CarRecord { get; set; }
        public DbSet<TempPay> TempPay { get; set; }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
        }
    }

调用

    private readonly IRepository _service;
    private readonly IUnitOfWork _unitofwork;
    private readonly IRepositoryBase<HistoryDbContext> _history;
    private readonly IUnitOfWork<HistoryDbContext> _historyunitOfWork;

数据库扩展

调用

    // 获取查询首个字段
    var num = _repository.SqlQueryFirst<long>("select count(1) from carrecord",null);

    //获取查询字段集合
    var data = _repository.SqlQuery<string>("select id from carrecord",null);

    // 获取查询首个对象
    var num = _repository.SqlQueryFirst<carrecord>("select * from carrecord limit 1",null);

    //获取查询对象集合
    var data = _repository.SqlQuery<carrecord>("select * from carrecord",null);

    //无具体接收对象 查询集合
    var parkingsetting = _repository.SqlQueryDynamic($"select Item, Value,ParkingId from parkingse where RobotId is null", null);
    return parkingsetting?.Where(x => x.Item == item)?.FirstOrDefault()?.Value;


    //修改更新sql操作
    var num = _repository.ExecuteSql("update Parking set TempSurplus=@left where Id=@parkingId", new
    {
        parkingId,
        left
    });

** 接收对象为任意定义对象，对象一致赋值，不一致默认值

** 传入参数，可以是匿名对象，也可以是具体对象，字段与占位符一致就行

HTTP

调用

private readonly IHttpService _httpClient;

//普通请求
var resutl = await _httpClient.GetAsync<ApiResult<DeptInfo>>(_server.BasicsUrl, "api/PropertyManage/GetDeptInfo", new { DeptId = deptid });

//全局签名请求
_httpClient.SetSignature(new Signature { Key = _parkingRobotOption.Key, Tenant = _parkingRobotOption.ParkingId });
var result = await _httpClient.GetAsync<ApiResult>(_server.CloudUrl, "/api/CarRecord/status", new { id = recordId });


//单次签名请求
var sign = new Signature(new Signature { Key = _parkingRobotOption.Key, Tenant = _parkingRobotOption.ParkingId });
var result = await _httpClient.GetAsync<ApiResult>(_server.CloudUrl, "/api/CarRecord/status", new { id = recordId }, sign);

//超时处理
var soure = new CancellationTokenSource(TimeSpan.FromSeconds(3));
var resutl = await _httpClient.GetAsync<ApiResult<DeptInfo>>(_server.BasicsUrl, "api/PropertyManage/GetDeptInfo", new { DeptId = deptid }, soure.Token);

缓存

Program

    services.AddFrameworkUseCache(); //内存缓存
    services.AddFrameworkUseRedis<TCache>(); //redis 缓存

调用

    private readonly ICacheService _cache;

    //同步
    return _cache.TryGetValue<List<HolidayEntity>>("ISHOLIDAY", o =>
    {
        return _repository.GetList<HolidayEntity>(s => s.Time >= $"{DateTime.Now.Year}-1-1".ToDateTime() && s.Time <= $"{DateTime.Now.Year}-12-31".ToDateTime());
    });

    //异步
    return await _cache.TryGetValue<DeptInfo>(key, async (s) =>
    {
        return new DeptInfo();
    });

脚本运行

调用

//执行脚本
var cmd = Path.Combine("scripts", "memoryinfo.sh");
var result = ProcessHelper.Run<Memoryinfo>(Bash, cmd);

//执行命令
return ProcessHelper.Run("top", " -b n 1 -i -c").Output;

//异步执行脚本
var cmd = Path.Combine("scripts", $"startbusiness.sh");
ProcessHelper.RunAsync(Bash, $"{cmd} {port}");

对象去重

调用

    List<CarRecord> list = await _service.GetListAsync<CarRecord>(s => s.BatchId == record.BatchId);
    list = list.Distinct(new PropertyComparer<CarRecord>("Id")).ToList();

** 对集合中某个对象字段去重

对象转sql

调用

var test = new Test
{
    Id = 1,
    Age = 1
};

List<Test> list = new List<Test>() { test};

//集合转sql
var sql = list.ToAddSql(ESql.InsertOrUpdate); 

//对象转sql
var sql = test.ToAddSql(ESql.InsertOrUpdate);