Compare commits

..

No commits in common. "cdfc62bab15008d7ea4b33cb724bd68d6e830e20" and "93c4486d9b774266e3bf1833a7efa61ce8ce842c" have entirely different histories.

11 changed files with 62 additions and 328 deletions

View File

@ -54,8 +54,6 @@ namespace OpenAuth.App
/// </summary>
public async Task<Response<bool>> Add(MiMinePoint model)
{
model.Id=Guid.NewGuid().ToString();
model.CreateTime = DateTime.Now;
var flag = await Repository.InsertAsync(model);
return new Response<bool>

View File

@ -53,8 +53,7 @@ namespace OpenAuth.App
/// 添加
/// </summary>
public async Task<Response<bool>> Add(MiParking model)
{
model.Id = Guid.NewGuid().ToString();
{
var flag = await Repository.InsertAsync(model);
return new Response<bool>

View File

@ -1,13 +1,9 @@
using AutoMapper.Execution;
using DocumentFormat.OpenXml.Office2010.Excel;
using Infrastructure;
using OpenAuth.App.BaseApp.Base;
using OpenAuth.App.Interface;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
using OpenAuth.App.ServiceApp.MiManager.Response;
using OpenAuth.App.ServiceApp.MiManager.Resquest;
using OpenAuth.Repository;
using OpenAuth.Repository.Domain;
using SqlSugar;
@ -29,28 +25,16 @@ namespace OpenAuth.App
/// <summary>
/// 分页
/// </summary>
public async Task<Response<PageInfo<List<dynamic>>>> LoadAllPage(MiPuchLoadreq req)
public async Task<Response<PageInfo<List<MiPunchRecord>>>> LoadAllPage(PageReq request)
{
RefAsync<int> totalCount = 0;
var result = new PageInfo<SysRole>();
var list = await base.Repository.AsQueryable()
.WhereIF(req.begintime!=null&&req.endtime!=null,r=>r.PunchTime>=req.begintime&&r.PunchTime<req.endtime)
.WhereIF(req.status!=null,r=>r.PunchStatus==req.status)
.LeftJoin<SysUser>((r,u)=>r.UserId==u.Id)
.LeftJoin<MiMinePoint>((r,u,p)=>r.MinePointId==p.Id)
.WhereIF(!string.IsNullOrEmpty(req.username),(r,u,p)=>u.Name.Contains(req.username))
.WhereIF(!string.IsNullOrEmpty(req.key),(r,u,p)=>p.Name.Contains(req.key))
.OrderByDescending((r, u, p) => r.PunchTime)
.Select<dynamic>((r, u, p) => new
{
Id = r.Id.SelectAll(),
Name=u.Name,
PointName=p.Name
})
.ToPageListAsync(req.page, req.limit, totalCount);
.ToPageListAsync(request.page, request.limit, totalCount);
return new Response<PageInfo<List<dynamic>>>
return new Response<PageInfo<List<MiPunchRecord>>>
{
Result = new PageInfo<List<dynamic>>
Result = new PageInfo<List<MiPunchRecord>>
{
Items = list,
Total = totalCount
@ -59,130 +43,57 @@ namespace OpenAuth.App
}
#endregion
/// <summary>
/// 详情
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public async Task<Response<MiPuchRecordRes>> Get(string id)
public async Task<MiPunchRecord> Get(object id)
{
var data= await Repository.AsQueryable()
.LeftJoin<SysUser>((r,u)=>r.UserId==u.Id)
.Select((r,u)=>new MiPuchRecordRes
{
Id = r.Id,
UserId = r.UserId,
UserName=u.Name,
Lat=r.Lat,
Lng=r.Lng,
MinePointId=r.MinePointId,
PunchStatus=r.PunchStatus,
PunchTime=r.PunchTime,
Remark=r.Remark,
Image=SqlFunc.Subqueryable<MiPunchImage>().Where(a=>a.PunchId==r.Id).ToList()
}).FirstAsync();
return new Response<MiPuchRecordRes>()
{
Result=data
};
return await Repository.GetByIdAsync(id);
}
/// <summary>
/// 添加
/// </summary>
public async Task<Response<bool>> Add(MiPuchRecordReq model)
public async Task<Response<bool>> Add(MiPunchRecord model)
{
if (string.IsNullOrEmpty(model.MinePointId))
{
throw new Exception("请输入监管盗采点");
}
var user = _auth.GetCurrentUser().User;
MiPunchRecord record = model.MapTo<MiPunchRecord>();
record.Id = Guid.NewGuid().ToString();
record.PunchTime = DateTime.Now;
record.UserId = user.Id;
var flag = await Repository.InsertAsync(model);
List<MiPunchImage> image = new List<MiPunchImage>();
foreach (var item in model.Image)
return new Response<bool>
{
var img = item.MapTo<MiPunchImage>();
img.Id = Guid.NewGuid().ToString();
img.MinePointId = model.MinePointId;
img.PunchId = record.Id;
img.CreateTime = DateTime.Now;
image.Add(img);
}
using (var uow = base.UnitWork.CreateContext())
{
var flag1 = await uow.MiPunchRecord.InsertAsync(record);
var flag2 = await uow.MiPunchImage.InsertRangeAsync(image);
var flag = uow.Commit() && flag1 && flag2;
return new Response<bool>
{
Result = flag,
Message = flag == true ? "success" : "error"
};
}
Result = flag,
Message = flag == true ? "success" : "error"
};
}
/// <summary>
/// 删除
/// </summary>
/// <param name="ids"></param>
public async Task<Response<bool>> Delete(List<string> ids )
public async Task<Response<bool>> Delete(List<MiPunchRecord> models)
{
using (var uow = base.UnitWork.CreateContext())
var flag = await Repository.DeleteAsync(models);
return new Response<bool>
{
var flag1 = await uow.MiPunchRecord.DeleteAsync(r=>ids.Contains(r.Id));
var flag2 = await uow.MiPunchImage.DeleteAsync(r=>ids.Contains(r.PunchId));
var flag = uow.Commit() && flag1 && flag2;
return new Response<bool>
{
Result = flag,
Message = flag == true ? "success" : "error"
};
}
Result = flag,
Message = flag == true ? "success" : "error"
};
}
/// <summary>
/// 更新
/// </summary>
/// <param name="obj"></param>
public async Task<Response<bool>> Update(MiPuchRecordReq model)
public async Task<Response<bool>> Update(MiPunchRecord model)
{
if (string.IsNullOrEmpty(model.MinePointId))
{
throw new Exception("请输入监管盗采点");
}
bool flag = await base.Repository.UpdateAsync(model);
MiPunchRecord record = model.MapTo<MiPunchRecord>();
List<MiPunchImage> image = new List<MiPunchImage>();
foreach (var item in model.Image)
return new Response<bool>
{
var img = item.MapTo<MiPunchImage>();
img.Id = Guid.NewGuid().ToString();
img.MinePointId = model.MinePointId;
img.PunchId = record.Id;
img.CreateTime = DateTime.Now;
image.Add(img);
}
using (var uow = base.UnitWork.CreateContext())
{
await uow.MiPunchImage.DeleteAsync(r=>r.PunchId==model.Id);
await uow.MiPunchRecord.UpdateAsync(record);
await uow.MiPunchImage.InsertRangeAsync(image);
var flag = uow.Commit();
return new Response<bool>
{
Result = flag,
Message = flag == true ? "success" : "error"
};
}
Result = flag,
Message = flag == true ? "success" : "error"
};
}
/// <summary>

View File

@ -1,67 +0,0 @@
using OpenAuth.Repository.Domain;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace OpenAuth.App.ServiceApp.MiManager.Response
{
public class MiPuchRecordRes
{
public string Id { get; set; }
/// <summary>
/// Desc:userid
/// Default:
/// Nullable:False
/// </summary>
public long UserId { get; set; }
public string UserName { get; set; }
/// <summary>
/// Desc:打卡时间
/// Default:DateTime.Now
/// Nullable:True
/// </summary>
public DateTime? PunchTime { get; set; }
/// <summary>
/// Desc:备注
/// Default:
/// Nullable:True
/// </summary>
public string Remark { get; set; }
/// <summary>
/// Desc:盗采点id
/// Default:
/// Nullable:True
/// </summary>
public string MinePointId { get; set; }
/// <summary>
/// Desc:打卡点状态:正常、异常、违法
/// Default:'正常'::character varying
/// Nullable:True
/// </summary>
public short? PunchStatus { get; set; }
/// <summary>
/// Desc:经度
/// Default:
/// Nullable:True
/// </summary>
public decimal? Lng { get; set; }
/// <summary>
/// Desc:纬度
/// Default:
/// Nullable:True
/// </summary>
public decimal? Lat { get; set; }
public List<MiPunchImage> Image { get; set; }
}
}

View File

@ -1,23 +0,0 @@
using OpenAuth.App.Request;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace OpenAuth.App.ServiceApp.MiManager.Resquest
{
public class MiPuchLoadreq: PageReq
{
/// <summary>
/// 巡查人员
/// </summary>
public string username { get; set; }
/// <summary>
/// 巡查时间
/// </summary>
public DateTime? begintime { get; set; }
public DateTime? endtime { get; set; }
public short? status { get; set; }
}
}

View File

@ -1,65 +0,0 @@
using OpenAuth.Repository.Domain;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace OpenAuth.App.ServiceApp.MiManager.Resquest
{
public class MiPuchRecordReq
{
public string Id { get; set; }
/// <summary>
/// Desc:userid
/// Default:
/// Nullable:False
/// </summary>
public long UserId { get; set; }
/// <summary>
/// Desc:打卡时间
/// Default:DateTime.Now
/// Nullable:True
/// </summary>
public DateTime? PunchTime { get; set; }
/// <summary>
/// Desc:备注
/// Default:
/// Nullable:True
/// </summary>
public string Remark { get; set; }
/// <summary>
/// Desc:盗采点id
/// Default:
/// Nullable:True
/// </summary>
public string MinePointId { get; set; }
/// <summary>
/// Desc:打卡点状态:正常、异常、违法
/// Default:'正常'::character varying
/// Nullable:True
/// </summary>
public string PunchStatus { get; set; }
/// <summary>
/// Desc:经度
/// Default:
/// Nullable:True
/// </summary>
public decimal? Lng { get; set; }
/// <summary>
/// Desc:纬度
/// Default:
/// Nullable:True
/// </summary>
public decimal? Lat { get; set; }
public List<MiPunchImage> Image { get; set; }
}
}

View File

@ -15,13 +15,12 @@ namespace OpenAuth.Repository.Domain
}
/// <summary>
/// Desc:主键
/// Default:
/// Nullable:False
/// </summary>
[SugarColumn(IsPrimaryKey = true)]
public string Id {get;set;}
/// <summary>
/// Desc:主键
/// Default:
/// Nullable:False
/// </summary>
public string Id {get;set;}
/// <summary>
/// Desc:监管点名称

View File

@ -15,13 +15,12 @@ namespace OpenAuth.Repository.Domain
}
/// <summary>
/// Desc:主键
/// Default:
/// Nullable:False
/// </summary>
[SugarColumn(IsPrimaryKey = true)]
public string Id {get;set;}
/// <summary>
/// Desc:主键
/// Default:
/// Nullable:False
/// </summary>
public string Id {get;set;}
/// <summary>
/// Desc:停车场编号

View File

@ -15,13 +15,12 @@ namespace OpenAuth.Repository.Domain
}
/// <summary>
/// Desc:图片ID
/// Default:
/// Nullable:False
/// </summary>
[SugarColumn(IsPrimaryKey = true)]
public string Id {get;set;}
/// <summary>
/// Desc:图片ID
/// Default:
/// Nullable:False
/// </summary>
public string Id {get;set;}
/// <summary>
/// Desc:打卡id

View File

@ -15,13 +15,12 @@ namespace OpenAuth.Repository.Domain
}
/// <summary>
/// Desc:打卡记录ID
/// Default:
/// Nullable:False
/// </summary>
[SugarColumn(IsPrimaryKey = true)]
public string Id {get;set;}
/// <summary>
/// Desc:打卡记录ID
/// Default:
/// Nullable:False
/// </summary>
public string Id {get;set;}
/// <summary>
/// Desc:userid
@ -56,7 +55,7 @@ namespace OpenAuth.Repository.Domain
/// Default:'正常'::character varying
/// Nullable:True
/// </summary>
public short? PunchStatus {get;set;}
public string PunchStatus {get;set;}
/// <summary>
/// Desc:经度

View File

@ -1,17 +1,13 @@
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using DocumentFormat.OpenXml.Office2010.Excel;
using Infrastructure;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using OpenAuth.App;
using OpenAuth.App.Request;
using OpenAuth.App.Response;
using OpenAuth.App.ServiceApp.MiManager.Response;
using OpenAuth.App.ServiceApp.MiManager.Resquest;
using OpenAuth.Repository.Domain;
using Org.BouncyCastle.Bcpg.OpenPgp;
namespace OpenAuth.WebApi.Controllers
{
@ -35,20 +31,9 @@ namespace OpenAuth.WebApi.Controllers
/// 分页
/// </summary>
[HttpGet]
public async Task<Response<PageInfo<List<dynamic>>>> LoadAllPage([FromQuery] MiPuchLoadreq request)
public async Task<Response<PageInfo<List<MiPunchRecord>>>> LoadAllPage([FromQuery] PageReq request)
{
var result = new Response<PageInfo<List<dynamic>>>();
try
{
result = await _app.LoadAllPage(request);
}
catch (Exception ex)
{
result.Code = 500;
result.Message = ex.InnerException?.Message ?? ex.Message;
}
return result;
return await _app.LoadAllPage(request);
}
#endregion
@ -58,12 +43,12 @@ namespace OpenAuth.WebApi.Controllers
/// 实体
/// </summary>
[HttpGet]
public async Task<Response<MiPuchRecordRes>> Get(string id)
public async Task<Response<MiPunchRecord>> Get(object id)
{
var result = new Response<MiPuchRecordRes>();
var result = new Response<MiPunchRecord>();
try
{
result =await _app.Get(id);
result.Result =await _app.Get(id);
}
catch (Exception ex)
{
@ -83,7 +68,7 @@ namespace OpenAuth.WebApi.Controllers
/// 添加
/// </summary>
[HttpPost]
public async Task<Response<bool>> Add(MiPuchRecordReq model)
public async Task<Response<bool>> Add(MiPunchRecord model)
{
var result = new Response<bool>();
try
@ -105,7 +90,7 @@ namespace OpenAuth.WebApi.Controllers
/// 修改
/// </summary>
[HttpPost]
public async Task<Response<bool>> Update(MiPuchRecordReq model)
public async Task<Response<bool>> Update(MiPunchRecord model)
{
var result = new Response<bool>();
try
@ -128,7 +113,7 @@ namespace OpenAuth.WebApi.Controllers
/// 删除
/// </summary>
[HttpPost]
public async Task<Response<bool>> Delete(List<string> models)
public async Task<Response<bool>> Delete([FromBody] List<MiPunchRecord> models)
{
var result = new Response<bool>();
try