Skip to content

L
Laisi_AutoMES2
Commit b5cdac1d by xin.yang
Options

some update

parent 81afe7d9
Showing with 178 additions and 2234 deletions
Server/Apis/Siger.ApiQMS/Controllers/ManualCollectionController.cs
......@@ -19,10 +19,6 @@ using Siger.Middlelayer.Repository.Repositories.Interface;
using Siger.Middlelayer.Repository.Response;
using Siger.Middlelayer.Utility.Helpers;
using Siger.Middlelayer.Utility.ImportEntities;
using Siger.Middlelayer.Dapper.CheckTrace.Repostriories;
using System.Threading.Tasks;
using Siger.Middlelayer.Dapper.CheckTrace.Data;
using Siger.Middlelayer.Dapper.CheckTrace.Constant;
using Siger.ApiQMS.Utility;
using Siger.Middlelayer.Common.Helpers;
......@@ -72,231 +68,6 @@ namespace Siger.ApiQMS.Controllers
}
/// <summary>
/// 产品追溯查询
/// </summary>
/// <param name="sectionid">产线ID</param>
/// <param name="productid">产品ID</param>
/// <param name="materialid">物料ID</param>
/// <param name="route">工序ID</param>
/// <param name="checktype">检验类型</param>
/// <param name="sn">二维码</param>
/// <param name="result">结果OK 或者 NG 或者 传 2=让步放行</param>
/// <param name="itemid">检验项目ID</param>
/// <param name="itemname">检验项目名称 检验项目表的item_en</param>
/// <param name="starttime">开始时间</param>
/// <param name="endtime">结束时间</param>
/// <param name="userid">检验人ID</param>
/// <param name="usercheck">是否有检验人ID 0=>查询所有数据 大于0=>只查询有检验人的数据</param>
/// <param name="page"></param>
/// <param name="pagesize"></param>
/// <param name="toexcel">是否导出excel 0=>不导出，查询数据 1=>导出数据到excel</param>
/// <param name="inspectiontype">1->送检 2->人工检验</param>
/// <returns></returns>
[HttpGet]
public IActionResult GetPageList(int sectionid, int productid, int materialid, int route, int checktype, string sn, string result, int itemid, string itemname,
string starttime, string endtime, string userid, string usercheck, int page, int pagesize, string toexcel, int inspectiontype = 0)
{
if (result.ToInt() == (int)SendTestType.DeviationRelease)
{
return GetPageListByDeviationRelease(sectionid, productid, materialid, route, checktype, sn, result, itemid, itemname,
starttime, endtime, page, pagesize, toexcel);
}
else
{
return GetPageListResult(sectionid, productid, materialid, route, checktype, sn, result, itemid, itemname,
starttime, endtime, userid.ToInt(), usercheck.ToInt(), page, pagesize, toexcel, inspectiontype);
}
}
private IActionResult GetPageListResult(int sectionid, int productid, int materialid, int route, int checktype, string sn, string result, int itemid, string itemname,
string starttime, string endtime, int userid, int usercheck, int page, int pagesize, string toexcel, int inspectiontype = 0)
{
var list = new List<ResponseDataCollection>();
long total = 0;
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var tables = _traceRepostory.GetSubTableList(TabelNameConstant.SnTraceDetailTable);
var traceIds = new List<long>();
if (itemid > 0)
{
traceIds = _traceRepostory.GetTraceIdList(new List<long>(), 0, new List<int> { itemid },
itemname ?? "", starttime, endtime, ProjectId).ToList();
}
var sectionIds = new List<int>();
if (sectionid > 0)
{
sectionIds = _levelSectionRepository.GetLevelSectionIds(sectionid, ProjectId).ToList();
}
Task<bool>[] tasks = new Task<bool>[2];
var traces = new List<SnTrace>();
tasks[0] = Task<bool>.Factory.StartNew(() =>
{
traces = _traceRepostory.GetSnTracePageList(sectionIds, productid, materialid, route, checktype, sn, result,
traceIds, starttime, endtime, page, pagesize, ProjectId, toexcel, userid, usercheck, false, inspectiontype).ToList();
return true;
});
tasks[1] = Task<bool>.Factory.StartNew(() =>
{
total = _traceRepostory.CountTrace(sectionIds, productid, materialid, route, checktype, sn, result,
traceIds, starttime, endtime, ProjectId, userid, usercheck, false, inspectiontype);
return true;
});
Task.WaitAll(tasks);
if (traces.Any())
{
var checkIds = traces.Select(t => t.ID).Distinct().ToList();
var inspections = _traceInspectionRepository.GetList(t => checkIds.Contains(t.trace_id) && t.status == (int)RowState.Valid &&
t.projectid == ProjectId).ToList();
var sections = _levelSectionRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid).ToList();
var userIds = traces.Select(t => t.UserID).Distinct().ToList();
var users = _projectUserRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid &&
userIds.Contains(t.mid)).ToList();
var productIds = traces.Select(t => t.ProductID).Distinct().ToList();
var products = _productRepository.GetList(t => productIds.Contains(t.id) && t.projectid == ProjectId &&
t.status == (int)RowState.Valid).ToList();
var routeIds = traces.Select(t => t.RouteID).Distinct().ToList();
var routes = _productRouteRepository.GetList(t => routeIds.Contains(t.id) && t.projectId == ProjectId &&
t.status == (int)RowState.Valid).ToList();
var materialIds = traces.Select(t => t.MaterialID).Distinct().ToList();
var materials = _materialsRepository.GetList(t => materialIds.Contains(t.id) && t.projectId == ProjectId &&
t.status == (int)RowState.Valid).ToList();
foreach (var trace in traces)
{
var inspection = inspections.FirstOrDefault(t => t.trace_id == trace.ID);
var product = products.FirstOrDefault(t => t.id == trace.ProductID);
var user = users.FirstOrDefault(t => t.mid == trace.UserID);
var routeModel = routes.FirstOrDefault(t => t.id == trace.RouteID);
var material = materials.FirstOrDefault(t => t.id == trace.MaterialID);
var data = new ResponseDataCollection
{
id = trace.ID,
productid = trace.ProductID,
productcode = product?.code ?? "",
productname = product?.name ?? "",
sectionid = trace.SectionID,
sectionname = ChannelSectionHelper.GetChannelSection(trace.SectionID, sections),
workorder = trace.WorkOrder,
sn = trace.SN,
result = inspection?.result ?? (trace.Result.ToUpper() == "OK" ? ((int)SendTestType.Qalified).ToString() : ((int)SendTestType.Unqualified).ToString()),
check_mid = trace.UserID,
check_user = user?.name ?? "",
check_time = trace.CreateTime.ToString(ParameterConstant.DateTimeFormat),
routeid = trace.RouteID,
routename = routeModel?.name ?? "",
materialid = trace.MaterialID,
materialname = material?.name ?? "",
materialpn = material?.pn ?? "",
checktype = inspection == null ? trace.CheckType : inspection.check_type
};
list.Add(data);
}
}
if (toexcel.ToInt() == 1)
{
return ExportExcel(list);
}
return new PagedLongTotalObjectResult(list, total, page, pagesize);
}
private IActionResult GetPageListByDeviationRelease(int sectionid, int productid, int materialid, int route, int checktype, string sn, string result, int itemid, string itemname,
string starttime, string endtime, int page, int pagesize, string toexcel)
{
var list = new List<ResponseDataCollection>();
long total = 0;
var inspections = _traceInspectionRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid &&
t.result.ToInt() == result.ToInt() && t.check_status == (int)SendCheckStatus.Completed);
var sectionIds = new List<int>();
if (sectionid > 0)
{
sectionIds = _levelSectionRepository.GetLevelSectionIds(sectionid, ProjectId).ToList();
if (sectionIds.Any())
{
inspections = inspections.Where(t => sectionIds.Contains(t.sectionid));
}
}
if (productid > 0)
{
inspections = inspections.Where(t => t.productid == productid);
}
if (materialid > 0)
{
inspections = inspections.Where(t => t.materialid == materialid);
}
if (route > 0)
{
inspections = inspections.Where(t => t.routeid == route);
}
if (!string.IsNullOrEmpty(starttime) && !string.IsNullOrEmpty(endtime))
{
inspections = inspections.Where(t => t.check_time <= endtime.ToDateTime() && t.check_time >= starttime.ToDateTime());
}
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var tables = _traceRepostory.GetSubTableList(TabelNameConstant.SnTraceDetailTable);
var itemTraceIds = new List<long>();
if (itemid > 0)
{
itemTraceIds = _traceRepostory.GetTraceIdList(new List<long>(), 0, new List<int> { itemid },
itemname ?? "", starttime, endtime, ProjectId).ToList();
}
if (itemTraceIds.Any())
{
inspections = inspections.Where(t => itemTraceIds.Contains(t.trace_id));
}
total = inspections.Count();
var dataList = toexcel.ToInt() == 1 ? inspections.OrderByDescending(t => t.check_time).ToList() :
inspections.OrderByDescending(t => t.check_time).Skip((page - 1) * pagesize).Take(pagesize).ToList();
var traceIds = dataList.Where(t => t.trace_id > 0).Select(t => t.trace_id).ToList();
if (dataList.Any())
{
var sections = _levelSectionRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid).ToList();
var users = _projectUserRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid).ToList();
var routeIds = dataList.Select(t => t.routeid).Distinct().ToList();
var routes = _productRouteRepository.GetList(t => routeIds.Contains(t.id) && t.projectId == ProjectId &&
t.status == (int)RowState.Valid).ToList();
foreach (var trace in dataList)
{
var inspection = inspections.FirstOrDefault(t => t.trace_id == trace.trace_id);
var product = _productRepository.Get(t => t.id == trace.productid && t.projectid == ProjectId &&
t.status == (int)RowState.Valid);
var user = users.FirstOrDefault(t => t.mid == trace.check_mid);
var routeModel = routes.FirstOrDefault(t => t.id == trace.routeid);
var data = new ResponseDataCollection
{
id = trace.trace_id,
productid = trace.productid,
productcode = product?.code ?? "",
productname = product?.name ?? "",
sectionid = trace.sectionid,
sectionname = ChannelSectionHelper.GetChannelSection(trace.sectionid, sections),
workorder = "",
sn = trace.sn,
result = inspection.result ?? "",
check_mid = trace.check_mid,
check_user = user?.name ?? "",
check_time = (trace.check_time.HasValue && trace.check_time != DateTime.MinValue) ?
trace.check_time.Value.ToString(ParameterConstant.DateTimeFormat) : "",
routeid = trace.routeid,
routename = routeModel?.name ?? "",
};
list.Add(data);
}
}
if (toexcel.ToInt() == 1)
{
return ExportExcel(list);
}
return new PagedLongTotalObjectResult(list, total, page, pagesize);
}
/// <summary>
/// 人工检验数据查询
/// </summary>
/// <returns></returns>
......@@ -310,7 +81,7 @@ namespace Siger.ApiQMS.Controllers
sectionIds = _levelSectionRepository.GetLevelSectionIds(sectionid, ProjectId).ToList();
}
var dataList = new List<ResponseDataCollection>();
var res = _traceDetailRepository.GetPagedList(sectionIds, productid, materialid, route, checktype, sn, result, new List<long>(),
var res = _traceDetailRepository.GetPagedList(sectionIds, productid, materialid, route, checktype, sn, result, new List<string>(),
starttime, endtime, userid.ToInt(), itemid, ProjectId, page, pagesize, toexcel);
var sections = _levelSectionRepository.GetList(t => t.projectid == ProjectId &&
t.status == (int)RowState.Valid).ToList();
......@@ -428,7 +199,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detail.result,
Value = detail.value,
......@@ -468,7 +239,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detailResult,
Value = detail.value,
......@@ -481,14 +252,8 @@ namespace Siger.ApiQMS.Controllers
}
}
}
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var resDetails = new List<SnTraceDetailList>();
//插入大数据库 检验详情表
var res = _traceRepostory.InsertTraceDetailReturnTraceIdNumberIndex(trace, insertDetailList, ProjectId, out resDetails);
if (res <= 0)
{
throw new BadRequestException(CommonEnum.Fail);
}
var trace_id = Guid.NewGuid().ToString();
#region 插入检验扩展表
......@@ -503,7 +268,7 @@ namespace Siger.ApiQMS.Controllers
//插入中间层库的trace表
var inspection = new siger_check_sn_trace_inspection
{
trace_id = res,
trace_id = trace_id,
testroom = "",
productid = req.productid,
materialid = req.materialid.ToInt(),
......@@ -672,22 +437,15 @@ namespace Siger.ApiQMS.Controllers
/// </summary>
/// <returns></returns>
[HttpGet]
public IActionResult GetDetails(int productid, int sectionid, long id)
public IActionResult GetDetails(int productid, int sectionid, string id)
{
var res = new List<ResponseDataCollectionDetail>();
if (id > 0)
if (!string.IsNullOrEmpty(id))
{
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var trace = _traceRepostory.GetSnTrace(id, ProjectId);
if (trace == null)
{
throw new BadRequestException(CommonEnum.RecordNotFound);
}
var standards = _inspectStandard.GetList(t => t.productid == trace.ProductID &&
t.sectionid == trace.SectionID && t.projectid == ProjectId &&
var dataDetails = _traceDetailRepository.GetList(q => q.TraceID == id && q.projectid == ProjectId && q.status == (int)RowState.Valid).ToList();
var standards = _inspectStandard.GetList(t => t.productid == productid &&
t.sectionid == sectionid && t.projectid == ProjectId &&
t.status == (int)RowState.Valid).ToList();
var dataDetails = _traceRepostory.GetSingleTraceDetailList(trace.ID, ProjectId);
foreach (var standard in standards)
{
......@@ -743,17 +501,11 @@ namespace Siger.ApiQMS.Controllers
/// <param name="id"></param>
/// <returns></returns>
[HttpGet]
public IActionResult GetDetailList(long id)
public IActionResult GetDetailList(string id)
{
var res = new List<ResponseDataCollectionDetail>();
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var trace = _traceRepostory.GetSnTrace(id, ProjectId);
if (trace == null)
{
throw new BadRequestException(CommonEnum.RecordNotFound);
}
var dataDetails = _traceDetailRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid &&
t.TraceID == trace.ID).ToList();
t.TraceID == id).ToList();
var configKeys = dataDetails.Select(t => t.ItemName).ToList();
var configs = _defaultInfoConfigRepository.GetList(t => configKeys.Contains(t.key)).ToList();
......@@ -790,16 +542,10 @@ namespace Siger.ApiQMS.Controllers
/// <param name="id"></param>
/// <returns></returns>
[HttpGet]
public IActionResult GetTraceDetailList(long id)
public IActionResult GetTraceDetailList(string id)
{
var res = new List<ResponseDataCollectionDetail>();
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var trace = _traceRepostory.GetSnTrace(id, ProjectId);
if (trace == null)
{
throw new BadRequestException(CommonEnum.RecordNotFound);
}
var dataDetails = _traceRepostory.GetSingleTraceDetailList(id, ProjectId);
var dataDetails = _traceDetailRepository.GetList(q => q.projectid == ProjectId && q.status == (int)RowState.Valid && q.TraceID == id).ToList();
var configKeys = dataDetails.Select(t => t.ItemName).ToList();
var configs = _defaultInfoConfigRepository.GetList(t => configKeys.Contains(t.key)).ToList();
......@@ -847,31 +593,28 @@ namespace Siger.ApiQMS.Controllers
}
[HttpGet]
public IActionResult Delete(long id)
public IActionResult Delete(string id)
{
if (id == 0)
if (string.IsNullOrEmpty(id))
{
throw new BadRequestException(CommonEnum.RecordNotFound);
}
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var result = _traceRepostory.DeleteData(id);
if (result)
var inspections = _traceInspectionRepository.GetList(t =>
t.trace_id == id && t.projectid == ProjectId && t.status == (int)RowState.Valid).ToList();
var details = _traceDetailRepository.GetList(t =>
t.TraceID == id && t.projectid == ProjectId && t.status == (int)RowState.Valid).ToList();
foreach (var inspection in inspections)
{
inspection.status = (int)RowState.Invalid;
_traceInspectionRepository.Update(inspection);
}
foreach (var detail in details)
{
detail.status = (int)RowState.Invalid;
_traceDetailRepository.Update(detail);
}
if(_unitOfWork.Commit() > 0)
{
var inspections = _traceInspectionRepository.GetList(t =>
t.trace_id == id && t.projectid == ProjectId && t.status == (int)RowState.Valid).ToList();
var details = _traceDetailRepository.GetList(t =>
t.TraceID == id && t.projectid == ProjectId && t.status == (int)RowState.Valid).ToList();
foreach (var inspection in inspections)
{
inspection.status = (int)RowState.Invalid;
_traceInspectionRepository.Update(inspection);
}
foreach (var detail in details)
{
detail.status = (int)RowState.Invalid;
_traceDetailRepository.Update(detail);
}
_unitOfWork.Commit();
return new ObjectResult(CommonEnum.Succefull);
}
else
......@@ -883,9 +626,9 @@ namespace Siger.ApiQMS.Controllers
[HttpPost]
public IActionResult Update([FromBody]RequestUpdateDataCollection req)
{
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var snTrace = _traceRepostory.GetSnTrace(req.id, ProjectId);
if (snTrace == null)
var inspection = _traceInspectionRepository.Get(t => t.status == (int)RowState.Valid && t.projectid == ProjectId &&
t.trace_id == req.id);
if (inspection == null)
{
throw new BadRequestException(CommonEnum.RecordNotFound);
}
......@@ -957,7 +700,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detail.result,
Value = detail.value,
......@@ -997,7 +740,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detailResult,
Value = detail.value,
......@@ -1010,16 +753,6 @@ namespace Siger.ApiQMS.Controllers
}
}
}
if (!_traceRepostory.DeleteDetail(req.id))
{
throw new BadRequestException(CommonEnum.Fail);
}
var resDetails = new List<SnTraceDetailList>();
var res = _traceRepostory.InsertTraceOnlyDetailsReturnNumerIndex(snTrace, insertDetailList, ProjectId, traceResult, out resDetails);
if (!res)
{
throw new BadRequestException(CommonEnum.Fail);
}
#region 插入检验扩展表
if (req.result.ToUpper() == "OK")
......@@ -1030,34 +763,7 @@ namespace Siger.ApiQMS.Controllers
{
req.result = ((int)SendTestType.Unqualified).ToString();
}
var inspection = _traceInspectionRepository.Get(t => t.status == (int)RowState.Valid && t.projectid == ProjectId &&
t.trace_id == req.id);
if(inspection == null)
{
inspection = new siger_check_sn_trace_inspection
{
trace_id = snTrace.ID,
testroom = "",
productid = snTrace.ProductID,
materialid = snTrace.MaterialID,
sectionid = snTrace.SectionID,
sn = snTrace.SN ?? "",
routeid = snTrace.RouteID,
check_type = snTrace.CheckType,
check_status = (int)SendCheckStatus.Completed,
result = req.result,
send_mid = snTrace.UserID,
send_time = snTrace.CreateTime,
check_mid = snTrace.UserID,
check_time = snTrace.CreateTime,
inspection_type = (int)InspectionType.ManualCollection,
projectid = ProjectId,
workorder = snTrace.WorkOrder,
number = req.number.ToInt(),
quantity = req.quantity.ToInt()
};
_traceInspectionRepository.Insert(inspection);
}
else
{
inspection.result = req.result;
......@@ -1075,7 +781,7 @@ namespace Siger.ApiQMS.Controllers
{
var model = new siger_check_sn_trace_detail
{
TraceID = snTrace.ID,
TraceID = req.id,
ItemID = detail.ItemID,
Result = detail.Result,
Value = detail.Value,
......@@ -1085,7 +791,7 @@ namespace Siger.ApiQMS.Controllers
LowerLimit = detail.LowerLimit,
UpperLimit = detail.UpperLimit,
projectid = ProjectId,
CreateTime = snTrace.CreateTime,
CreateTime = inspection.checking_time.HasValue ? inspection.checking_time.Value : DateTime.Now,
};
_traceDetailRepository.Insert(model);
}
......@@ -1141,7 +847,7 @@ namespace Siger.ApiQMS.Controllers
}
[HttpGet]
public IActionResult GetUpdateDetails(long id)
public IActionResult GetUpdateDetails(string id)
{
var res = new ResponseDataCollectionDetailList();
var trace = _traceInspectionRepository.Get(t => t.projectid == ProjectId && t.status == (int)RowState.Valid && t.trace_id == id
......
Server/Apis/Siger.ApiQMS/Controllers/SendTestCollectionController.cs
......@@ -20,8 +20,6 @@ using Siger.Middlelayer.Repository.Repositories.Interface;
using Siger.Middlelayer.Repository.Response;
using Siger.Middlelayer.Utility.Helpers;
using Siger.Middlelayer.Utility.ImportEntities;
using Siger.Middlelayer.Dapper.CheckTrace.Repostriories;
using Siger.Middlelayer.Dapper.CheckTrace.Data;
using Siger.ApiQMS.Utility;
using UploadFileModel = Siger.Middlelayer.QmsRepository.Response.UploadFileModel;
using Siger.Middlelayer.Repository.Entities;
......@@ -377,7 +375,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detail.result,
Value = detail.value,
......@@ -417,7 +415,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detailResult,
Value = detail.value,
......@@ -430,13 +428,7 @@ namespace Siger.ApiQMS.Controllers
}
}
}
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var resDetails = new List<SnTraceDetailList>();
var traceId = _traceRepostory.InsertTraceDetailReturnTraceIdNumberIndex(trace, insertDetailList, ProjectId, out resDetails);
if (traceId <= 0)
{
throw new BadRequestException(CommonEnum.Fail);
}
var traceId = Guid.NewGuid().ToString();
var nowTime = DateTime.Now;
var machineIds = _machineAttributionRepository.GetList(t => t.projectid == ProjectId && t.station == sendTest.sectionid &&
t.status == (int)RowState.Valid && t.attribution == (int)MachineAttributionEnum.equipment).Select(t => t.machine).ToList();
......@@ -853,11 +845,6 @@ namespace Siger.ApiQMS.Controllers
}
if (_unitOfWork.Commit() > 0)
{
if(data.trace_id > 0)
{
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
_traceRepostory.DeleteData(data.trace_id);
}
return new ObjectResult(CommonEnum.Succefull);
}
else
......@@ -921,24 +908,6 @@ namespace Siger.ApiQMS.Controllers
var delTraceDetails = _traceDetailRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid &&
t.TraceID == sendTest.trace_id).ToList();
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
var snTrace = _traceRepostory.GetSnTrace(sendTest.trace_id, ProjectId);
var trace = new SnTrace
{
MaterialID = sendTest.materialid,
ProductID = sendTest.productid,
SectionID = sendTest.sectionid,
MachineID = machine?.id ?? 0,
WorkOrder = "",
SN = sendTest.sn ?? "",
Result = (result == (int)SendTestType.Qalified || result == (int)SendTestType.DeviationRelease) ? "OK" : "NG",
UserID = snTrace == null ? sendTest.check_mid : snTrace.UserID,
RouteID = sendTest.routeid,
CreateTime = snTrace == null ? ((sendTest.check_time.HasValue && sendTest.check_time != DateTime.MinValue) ?
sendTest.check_time.Value : DateTime.Now) : snTrace.CreateTime,
CheckType = sendTest.check_type
};
var insertDetailList = new List<SnTraceDetailList>();
foreach (var index in indexs)
{
......@@ -958,7 +927,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detail.result,
Value = detail.value,
......@@ -998,7 +967,7 @@ namespace Siger.ApiQMS.Controllers
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
TraceID = "",
ItemID = detail.itemid,
Result = detailResult,
Value = detail.value,
......@@ -1012,30 +981,7 @@ namespace Siger.ApiQMS.Controllers
}
}
// 删除旧数据
if (sendTest.trace_id > 0)
{
_traceRepostory.DeleteDetail(sendTest.trace_id);
}
long traceId = 0;
var resDetails = new List<SnTraceDetailList>();
if(snTrace == null)//如果没有这条数据，则插入trace,trace_detail,如果有直插入trace_detail
{
traceId = _traceRepostory.InsertTraceDetailReturnTraceIdNumberIndex(trace, insertDetailList, ProjectId, out resDetails);
}
else
{
if (_traceRepostory.InsertTraceOnlyDetailsReturnNumerIndex(snTrace, insertDetailList, ProjectId, trace.Result, out resDetails))
{
traceId = snTrace.ID;
}
}
if (traceId <= 0)
{
throw new BadRequestException(CommonEnum.Fail);
}
var traceId = Guid.NewGuid().ToString();
sendTest.result = req.result ?? "";
sendTest.trace_id = traceId;
sendTest.number = req.number.ToInt();
......@@ -1076,7 +1022,7 @@ namespace Siger.ApiQMS.Controllers
LowerLimit = detail.LowerLimit,
UpperLimit = detail.UpperLimit,
projectid = ProjectId,
CreateTime = trace.CreateTime
CreateTime = sendTest.checking_time.HasValue ? sendTest.checking_time.Value : DateTime.Now
};
_traceDetailRepository.Insert(model);
}
......@@ -1086,11 +1032,6 @@ namespace Siger.ApiQMS.Controllers
throw new BadRequestException(CommonEnum.Fail);
}
if (snTrace == null)//如果时新插入的数据，添加SN
{
AddSnList(sendTest, trace);
}
return new ObjectResult(CommonEnum.Succefull);
}
......
Server/Apis/Siger.ApiQMS/Controllers/SensorDataCollectionController.cs deleted 100644 → 0
using Microsoft.AspNetCore.Mvc;
using Siger.Middlelayer.Common;
using Siger.Middlelayer.Repository;
using System.Linq;
using Siger.Middlelayer.QmsRepository.Repositories.Interface;
using Siger.Middlelayer.QmsRepository.Request;
using Siger.Middlelayer.Common.Extensions;
using Siger.ApiCommon.Filters;
using Siger.Middlelayer.QmsRepository.Response;
using Siger.Middlelayer.QmsRepository.Entities;
using System;
using Siger.Middlelayer.Repository.Repositories.Interface;
using System.Collections.Generic;
using Siger.Middlelayer.Repository.Response;
using Siger.Middlelayer.Dapper.CheckTrace.Repostriories;
using Siger.Middlelayer.Common.ModuleEnum;
using Siger.Middlelayer.Dapper.CheckTrace.Data;
namespace Siger.ApiQMS.Controllers
{
public class SensorDataCollectionController : BaseController
{
private readonly IUnitOfWork _unitOfWork;
private readonly IInspectStandardRepository _inspectStandard;
private readonly IPortSettingRepository _portSettingRepository;
private readonly ISigerProjectLevelRepository _levelRepository;
private readonly ISigerProjectLevelSectionRepository _levelSectionRepository;
private readonly ISigerProjectProductRepository _productRepository;
private readonly ICheckSnListRepository _snListRepository;
private readonly ISigerTrMaterialsRepository _materialsRepository;
public SensorDataCollectionController(IUnitOfWork unitOfWork, IInspectStandardRepository inspectStandard,
IPortSettingRepository portSettingRepository, ISigerProjectLevelRepository levelRepository,
ISigerProjectLevelSectionRepository levelSectionRepository, ISigerProjectProductRepository productRepository,
ICheckSnListRepository snListRepository, ISigerTrMaterialsRepository materialsRepository)
{
_unitOfWork = unitOfWork;
_inspectStandard = inspectStandard;
_portSettingRepository = portSettingRepository;
_levelRepository = levelRepository;
_levelSectionRepository = levelSectionRepository;
_productRepository = productRepository;
_snListRepository = snListRepository;
_materialsRepository = materialsRepository;
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetPageList(int page, int pagesize, int projectid)
{
var data = _portSettingRepository.GetDataList(projectid);
//return new PagedObjectResult(data.Data, data.Total, page, pagesize);
return new ObjectResult(data);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetItemList(int projectid)
{
var items = _inspectStandard.GetList(t => t.projectid == projectid && t.status == (int)RowState.Valid)
.Select(q => new ResponseIdNameItem { id = q.id, name = q.item, en_name = q.item_en }).ToList();
return new ObjectResult(items);
}
[HttpPost]
[NoTokenValidateFilter]
public IActionResult Add([FromBody]RequestAddPortSetting req)
{
var entity = _portSettingRepository.Get(t => t.projectid == req.projectid && t.status == (int)RowState.Valid &&
t.itemid == req.itemid);
if(entity != null)
{
throw new BadRequestException(RequestEnum.InspectItemRepeat);
}
var model = new siger_qms_port_setting
{
port = req.port,
paritycheck = req.paritycheck,
baudrate = req.baudrate,
databit = req.databit,
stopbit = req.stopbit,
itemid = req.itemid,
projectid = req.projectid,
status = (int)RowState.Valid,
createtime = DateTime.Now
};
_portSettingRepository.Insert(model);
if (_unitOfWork.Commit() > 0)
{
return new ObjectResult(CommonEnum.Succefull);
}
else
{
throw new BadRequestException(CommonEnum.Fail);
}
}
[HttpPost]
[NoTokenValidateFilter]
public IActionResult Update([FromBody]RequestUpdatePortSetting req)
{
var data = _portSettingRepository.Get(t => t.id == req.id && t.projectid == req.projectid && t.status == (int)RowState.Valid);
if(data == null)
{
throw new BadRequestException(CommonEnum.RecordNotFound);
}
data.port = req.port;
data.paritycheck = req.paritycheck;
data.baudrate = req.baudrate;
data.databit = req.databit;
data.stopbit = req.stopbit;
data.itemid = req.itemid;
_portSettingRepository.Update(data);
if (_unitOfWork.Commit() > 0)
{
return new ObjectResult(CommonEnum.Succefull);
}
else
{
throw new BadRequestException(CommonEnum.Fail);
}
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult Delete(int id, int projectid)
{
var data = _portSettingRepository.Get(t => t.id == id && t.projectid == projectid && t.status == (int)RowState.Valid);
if (data == null)
{
throw new BadRequestException(CommonEnum.RecordNotFound);
}
data.status = (int)RowState.Invalid;
_portSettingRepository.Update(data);
if (_unitOfWork.Commit() > 0)
{
return new ObjectResult(CommonEnum.Succefull);
}
else
{
throw new BadRequestException(CommonEnum.Fail);
}
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetSectionSelect(int reverselevel, int parentid, int projectid)
{
var levels = _levelRepository.GetList(t => t.status == (int)RowState.Valid && t.projectid == projectid).OrderByDescending(t => t.id).ToList();
if (levels.Count < reverselevel)
{
throw new BadRequestException(RequestEnum.LevelNotFound);
}
var res = _levelSectionRepository.GetSectionIdNamesByLevel(levels[reverselevel - 1].id, parentid, projectid).ToList();
return new ObjectResult(res);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetProducts(int projectid)
{
var res = _productRepository.GetList(t => t.projectid == projectid && t.status == (int)RowState.Valid)
.Select(t =>new
{
t.id,
t.name,
t.code
}).ToList();
return new ObjectResult(res);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetMaterials(int productid, int projectid)
{
var res = _snListRepository.GetSonMaterialsByProductId(projectid, productid).ToList();
return new ObjectResult(res);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetSectionRoutes(int productid, int sectionid, int projectid)
{
var res = new List<ResponseIdName>();
var product = _productRepository.Get(t => t.id == productid && t.status == (int)RowState.Valid && t.projectid == projectid);
if (product != null)
{
res = _inspectStandard.GetSectionRouteList(product.code, sectionid, projectid).ToList();
}
return new ObjectResult(res);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetDetailList(int productid, int sectionid, int projectid)
{
var res = new List<ResponseSensorDataCollectionDetail>();
var standards = _inspectStandard.GetList(t =>
t.productid == productid && t.sectionid == sectionid && t.projectid == projectid
&& t.status == (int)RowState.Valid).ToList();
var senSorPorts = _portSettingRepository.GetList(t => t.projectid == projectid && t.status == (int)RowState.Valid).ToList();
foreach (var standard in standards)
{
var port = senSorPorts.FirstOrDefault(t => t.itemid == standard.id);
var model = new ResponseSensorDataCollectionDetail
{
id = standard.id,
itemid = standard.id,
max_value = standard.max_value,
min_value = standard.min_value,
result = "",
value = null,
item = standard.item,
standard = standard.standard,
checktype = standard.value_type,
portName = port?.port,
parity = port?.paritycheck ?? 0,
bautRate = port?.baudrate ?? 0,
dataBits = port?.databit ?? 0,
stopBits = port?.stopbit ?? 0
};
res.Add(model);
}
return new ObjectResult(res);
}
[HttpPost]
[NoTokenValidateFilter]
public IActionResult AddTrace([FromBody]RequestAddSensorDataCollection req)
{
if (req.details == null || !req.details.Any() || string.IsNullOrEmpty(req.result))
{
throw new BadRequestException(RequestEnum.CheckItemNotFound);
}
var product = _productRepository.Get(t => t.projectid == req.projectid && t.status == (int)RowState.Valid &&
t.id == req.productid);
if (product == null)
{
throw new BadRequestException(RequestEnum.ProductNotFound);
}
var maxLevel = _levelRepository.GetList(t => t.status == (int)RowState.Valid && t.projectid == req.projectid).Max(q => q.id);
var section = _levelSectionRepository.Get(t => t.status == (int)RowState.Valid && t.projectid == req.projectid && t.id == req.sectionid);
if (section == null || section.levelid != maxLevel)
{
throw new ServerException(1052);
}
var machine = _inspectStandard.GetMachineBySectionId(section.id, req.projectid);
if (machine == null)
{
throw new BadRequestException(RequestEnum.SectionMachineNull);
}
if (string.IsNullOrEmpty(req.result))
{
throw new BadRequestException(RequestEnum.SelectCheckResult);
}
var items = _inspectStandard.GetList(t => req.details.Select(q => q.itemid).Contains(t.id)).ToList();
foreach (var detail in req.details)
{
var item = items.FirstOrDefault(t => t.id == detail.itemid);
if (item == null)
{
throw new BadRequestException(RequestEnum.ParameterMiss);
}
if (string.IsNullOrEmpty(detail.result) && detail.checktype == (int)ValueTypeStatus.O)
{
throw new BadRequestException(RequestEnum.ParameterMiss);
}
if (detail.value == null && detail.checktype == (int)ValueTypeStatus.V)
{
throw new BadRequestException(RequestEnum.ParameterMiss);
}
}
var trace = new SnTrace
{
MaterialID = req.materialid.ToInt(),
ProductID = req.productid,
SectionID = req.sectionid,
MachineID = machine.id,
WorkOrder = req.workorder ?? "",
SN = req.sn ?? "",
Result = req.result,
UserID = UserId,
RouteID = req.routeid.ToInt(),
CreateTime = DateTime.Now,
CheckType = req.checktype
};
var insertDetailList = new List<SnTraceDetailList>();
foreach (var detail in req.details)
{
var item = items.FirstOrDefault(t => t.id == detail.itemid);
var result = "";
if (item.value_type == (int)ValueTypeStatus.V)
{
result = (detail.value.Value <= item.max_value && detail.value.Value >= item.min_value) ? "OK" : "NG";
}
else
{
result = detail.result;
}
insertDetailList.Add(new SnTraceDetailList
{
TraceID = 0,
ItemID = detail.itemid,
Result = result,
Value = detail.value,
ItemName = item.item
});
}
var _traceRepostory = new TraceDetailRepository(req.companyid, req.projectid);
var res = _traceRepostory.InsertTraceDetail(trace, insertDetailList, req.projectid);
if (res)
{
var snEntity = _snListRepository.Get(t => t.projectid == req.projectid && t.status == (int)RowState.Valid &&
t.SN == trace.SN);
if (snEntity == null)
{
var stateCode = "000";
var eventNoObj = _snListRepository.GetEventNoByResult(trace.SN, req.projectid);
if (eventNoObj != null)
{
//出站信息获取
var outObj = _snListRepository.GetOutStationByEventNo(eventNoObj.EventNo, trace.SectionID, req.projectid);
if (outObj != null)
{
stateCode = outObj.ResultStatus;
}
}
var material = _materialsRepository.Get(t => t.projectId == req.projectid && t.status == (int)RowState.Valid &&
t.id == req.materialid.ToInt());
var snListObj = new siger_check_sn_list
{
SN = trace.SN,
BatchNumber = "",
ProductID = trace.ProductID,
ProductCode = product.code,
LineID = section.parentid,
WorkOrder = trace.WorkOrder,
MaterialID = material?.id ?? 0,
PartNumber = material?.pn ?? "",
StateCode = stateCode,
CreateTime = DateTime.Now,
projectid = req.projectid
};
_snListRepository.Insert(snListObj);
_unitOfWork.Commit();
}
return new ObjectResult(CommonEnum.Succefull);
}
throw new BadRequestException(CommonEnum.Fail);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetProductsBySectionId(string sectionid)
{
var productIds = _inspectStandard.GetList(t => t.sectionid == sectionid.ToInt() && t.projectid == ProjectId &&
t.status == (int)RowState.Valid).Select(t => t.productid).ToList();
var products = _productRepository.GetList(t => productIds.Contains(t.id) && t.projectid == ProjectId &&
t.status == (int)RowState.Valid).Select(t => new
{
t.id,
t.name,
t.code
}).ToList();
return new ObjectResult(products);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetItems(int sectionid, int productid, int projectid)
{
var items = _inspectStandard.GetList(t => t.projectid == projectid && t.status == (int)RowState.Valid &&
t.sectionid == sectionid && t.productid == productid)
.Select(q => new ResponseIdNameItem { id = q.id, name = q.item, en_name = q.item_en }).ToList();
return new ObjectResult(items);
}
[HttpGet]
[NoTokenValidateFilter]
public IActionResult GetItemSectionSelect(int reverselevel, int parentid, int projectid)
{
var levels = _levelRepository.GetList(t => t.status == (int)RowState.Valid && t.projectid == projectid).OrderByDescending(t => t.id).ToList();
if (levels.Count < reverselevel)
{
throw new BadRequestException(RequestEnum.LevelNotFound);
}
var res = _levelSectionRepository.GetSectionIdNamesByLevel(levels[reverselevel - 1].id, parentid, projectid).ToList();
if(reverselevel == 2)
{
var itemSectionIds = _inspectStandard.GetList(t => t.projectid == projectid && t.status == (int)RowState.Valid)
.Select(t => t.sectionid).ToList();
var channelIds = _levelSectionRepository.GetList(t => itemSectionIds.Contains(t.id)).Select(t => t.parentid).ToList();
res = res.Where(t => channelIds.Contains(t.id)).ToList();
}
if(reverselevel == 1)
{
var itemSectionIds = _inspectStandard.GetList(t => t.projectid == projectid && t.status == (int)RowState.Valid &&
res.Select(q => q.id).Contains(t.sectionid)).Select(t => t.sectionid).ToList();
res = res.Where(t => itemSectionIds.Contains(t.id)).ToList();
}
return new ObjectResult(res);
}
}
}
\ No newline at end of file
Server/Apis/Siger.ApiQMS/Controllers/StatisticalController.cs
......@@ -12,7 +12,6 @@ using Siger.Middlelayer.QmsRepository.Request;
using Siger.Middlelayer.QmsRepository.Response;
using Siger.Middlelayer.Repository.Repositories.Interface;
using Siger.Middlelayer.Repository.Entities;
using Siger.Middlelayer.Dapper.CheckTrace.Repostriories;
using Siger.Middlelayer.Repository.Response;
using Siger.Middlelayer.QmsRepository.Entities;
using Siger.Middlelayer.Utility.Helpers;
......@@ -80,7 +79,6 @@ namespace Siger.ApiQMS.Controllers
}
var maxLevel = _levelRepository.GetList(t => t.projectid == ProjectId && t.status == (int)RowState.Valid)
.OrderByDescending(t => t.id).FirstOrDefault();
var _traceRepostory = new TraceDetailRepository(CompanyId, ProjectId);
if (req.x_id.ToInt() == 0)
{
var sectionIds = new List<int>();
......@@ -94,10 +92,9 @@ namespace Siger.ApiQMS.Controllers
sections = levelSections.Where(t => t.parentid == req.sectionid.ToInt()).ToList();
sectionIds = ChannelSectionHelper.GetSonLevelSectionList(req.sectionid.ToInt(), levelSections).Select(m => m.id).ToList();
}
var datas = _traceRepostory.GetSnTracePageList(sectionIds, req.productid.ToInt()
, req.materialid.ToInt(), 0, req.checktype.ToInt(),
"", "", new List<long>(), req.starttime, req.endtime, 1, 10, ProjectId, "1", 0).ToList();
var datas = _traceDetailRepository.GetSnTraceList(sectionIds, req.productid.ToInt()
, req.materialid.ToInt(), req.checktype.ToInt(), req.starttime, req.endtime, ProjectId).ToList();
foreach (var sec in sections)
{
var lastSections = ChannelSectionHelper.GetSonLevelSections(sec, levelSections)
......@@ -120,8 +117,8 @@ namespace Siger.ApiQMS.Controllers
var lastSections = section == null ? levelSections.Where(t=>t.levelid == maxLevel.id).ToList() :
ChannelSectionHelper.GetSonLevelSections(section, levelSections).Where(t => t.levelid == maxLevel.id).ToList();
var lastSectionIds = lastSections.Select(t => t.id).ToList();
var data = _traceRepostory.GetSnTracePageList(lastSectionIds, product?.id ?? 0, req.materialid.ToInt(), 0, req.checktype.ToInt(),
"", "", new List<long>(), req.starttime, req.endtime, 1, 10, ProjectId, "1", 0).Where(t => t.RouteID > 0).ToList();
var data = _traceDetailRepository.GetSnTraceList(lastSectionIds, product?.id ?? 0, req.materialid.ToInt(), req.checktype.ToInt(),
req.starttime, req.endtime, ProjectId).Where(t => t.RouteID > 0).ToList();
var routeIds = data.Select(t => t.RouteID).ToList();
var routes = _routeRepository.GetList(t => t.projectId == ProjectId && t.status == (int)RowState.Valid &&
routeIds.Contains(t.id)).ToList();
......@@ -284,7 +281,7 @@ namespace Siger.ApiQMS.Controllers
}
var etime = req.endtime.ToDateTime();
var stime = req.starttime.ToDateTime();
var traceIds = new List<long>();
var traceIds = new List<string>();
if (req.itemid.ToInt() > 0)
{
var item = _inspectStandardRepository.Get(t => t.id == req.itemid.ToInt() && t.projectid == ProjectId &&
......
Server/Apis/Siger.ApiQMS/Result/AbnomalRuleData.cs
......@@ -11,7 +11,7 @@ namespace Siger.ApiQMS.Result
public double LCL { get; set; }
public long traceID { get; set; }
public string traceID { get; set; }
public List<long> traceDetailID { get; set; } = new List<long>();
......@@ -27,7 +27,7 @@ namespace Siger.ApiQMS.Result
public double UCL { get; set; }
public double LCL { get; set; }
public long traceID { get; set; }
public string traceID { get; set; }
public string value { get; set; }
public int rule1 { get; set; }
public int rule2 { get; set; }
......
Server/Apis/Siger.ApiQMS/Tasks/QmsCreateTraceTableSchedule.cs deleted 100644 → 0
using FluentScheduler;
using Siger.Middlelayer.Common;
using Siger.Middlelayer.Common.Extensions;
using Siger.Middlelayer.Common.Helpers;
using Siger.Middlelayer.Dapper.CheckTrace.Constant;
using Siger.Middlelayer.Dapper.CheckTrace.Data;
using Siger.Middlelayer.Dapper.CheckTrace.Repostriories;
using Siger.Middlelayer.Log;
using Siger.Middlelayer.QmsRepository;
using Siger.Middlelayer.Redis;
using Siger.Middlelayer.Repository;
using System;
using System.Linq;
namespace Siger.ApiQMS.Tasks
{
public class QmsCreateTraceTablJob : IJob
{
private static ApiQmsDbContext _context;
private static ApiConfigDbContext _configContext;
static QmsCreateTraceTablJob()
{
_context = new ApiQmsDbContext();
_configContext = new ApiConfigDbContext();
}
public void Execute()
{
if (DateTime.Now.Day != 1)
{
return;
}
_context = new ApiQmsDbContext();
_configContext = new ApiConfigDbContext();
try
{
var dbConfigs = RedisCache.Instance.GetDbNameConfigs();
foreach (var item in dbConfigs)
{
try
{
if(item.Cid > 0 && item.Pid > 0)
{
CreateTraceTable(item.Pid, item.Cid);
}
}
catch (Exception e)
{
Logger.WriteLineError(e.Message);
}
}
_context.Dispose();
_configContext.Dispose();
}
catch (Exception ex)
{
_context.Dispose();
_configContext.Dispose();
Logger.WriteLineError(ex.Message);
}
}
private void CreateTraceTable(int pid, int cid)
{
var projectInfo = _configContext.siger_project.FirstOrDefault(q => q.id == pid);
if(projectInfo == null)
{
return;
}
var _traceRepostory = new TraceDetailTableRepository(cid, pid);
var traceIsExsit = _traceRepostory.TableIsExsit(TabelNameConstant.SnTraceTable, $"{cid}_{pid}");
if (!traceIsExsit)
{
_traceRepostory.CreateTable(TabelNameConstant.SnTraceTable, TabelNameConstant.SnTraceTable, 1);
}
var subTableIsExsit = _traceRepostory.TableIsExsit(TabelNameConstant.SubTableTable, $"{cid}_{pid}");
if (!subTableIsExsit)
{
_traceRepostory.CreateTable(TabelNameConstant.SubTableTable, TabelNameConstant.SubTableTable, 1);
}
var now = DateTime.Now.ToString(ParameterConstant.MouthFirstDay).ToDateTime();
var startTime = "2020-03-01 00:00:00".ToDateTime();
var projectStartTime = UnixTimeHelper.ConvertIntDate(projectInfo.createtime).ToDateTime().ToString(ParameterConstant.MouthFirstDay).ToDateTime();
startTime = startTime > projectStartTime ? startTime : projectStartTime;
for(var time = startTime; time <= now; time = time.AddMonths(1))
{
var detailTableName = $"{TabelNameConstant.SnTraceDetailTable}_{time.Year}{time.Month.ToString("00")}";
var detailIsExsit = _traceRepostory.TableIsExsit(detailTableName, $"{cid}_{pid}");
if (detailIsExsit)
{
var detailTable = _traceRepostory.GetSubTableInfo(detailTableName, TabelNameConstant.SnTraceDetailTable);
if (detailTable == null)
{
var minid = _traceRepostory.GetTableMinID(detailTableName);
var maxid = _traceRepostory.GetTableMaxID(detailTableName);
_traceRepostory.InsertSubTable(new SubTable
{
name = detailTableName,
tablename = TabelNameConstant.SnTraceDetailTable,
startid = minid,
endid = maxid,
validtime = time.AddMonths(-1),
createtime = DateTime.Now,
status = (int)RowState.Valid
});
}
continue;
}
var startid = 1L;
if (time > startTime)
{
var lastDetailTableName = $"{TabelNameConstant.SnTraceDetailTable}_{time.AddMonths(-1).Year}{time.AddMonths(-1).Month.ToString("00")}";
var lastDetailTable = _traceRepostory.GetSubTableInfo(lastDetailTableName, TabelNameConstant.SnTraceDetailTable);
if (lastDetailTable == null)
{
var minid = _traceRepostory.GetTableMinID(lastDetailTableName);
var maxid = _traceRepostory.GetTableMaxID(lastDetailTableName);
_traceRepostory.InsertSubTable(new SubTable
{
name = lastDetailTableName,
tablename = TabelNameConstant.SnTraceDetailTable,
startid = minid,
endid = maxid,
validtime = time.AddMonths(-1),
createtime = DateTime.Now,
status = (int)RowState.Valid
});
}
else
{
var maxId = _traceRepostory.GetTableMaxID(lastDetailTableName);
startid = maxId + 1;
_traceRepostory.UpdateSubTableEndId(lastDetailTable.id, maxId);
}
}
_traceRepostory.CreateTable(TabelNameConstant.SnTraceDetailTable, detailTableName, startid);
_traceRepostory.InsertSubTable(new SubTable
{
name = detailTableName,
tablename = TabelNameConstant.SnTraceDetailTable,
startid = startid,
endid = 0,
validtime = time,
createtime = DateTime.Now,
status = (int)RowState.Valid
});
}
}
}
}
Server/Apis/Siger.ApiQMS/Tasks/QmsDataMigrationJob.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Linq;
using FluentScheduler;
using Siger.Middlelayer.Common;
using Siger.Middlelayer.Common.Extensions;
using Siger.Middlelayer.Common.ModuleEnum;
using Siger.Middlelayer.Dapper.CheckTrace.Repostriories;
using Siger.Middlelayer.Log;
using Siger.Middlelayer.QmsRepository;
using Siger.Middlelayer.QmsRepository.Entities;
using Siger.Middlelayer.Redis;
namespace Siger.ApiQMS.Tasks
{
public class QmsDataMigrationJob : IJob
{
private static ApiQmsDbContext _context;
static QmsDataMigrationJob()
{
_context = new ApiQmsDbContext();
}
public void Execute()
{
_context = new ApiQmsDbContext();
try
{
var state = _context.siger_system_config.FirstOrDefault(t => t.status == (int)RowState.Valid &&
t.key == SystemConfigKey.QmsDataMigrationStatus);
if ((state != null && state.value.ToInt() != (int)RowState.Valid) || state == null)
{
_context.Dispose();
return;
}
var dbConfigs = RedisCache.Instance.GetDbNameConfigs();
foreach (var item in dbConfigs)
{
try
{
SyncBigDataToMiddleDataBase(item.Pid, item.Cid);
SyncMiddleDataToBigDataBase();
}
catch(Exception e)
{
Logger.WriteLineError(e.Message);
}
}
_context.Dispose();
}
catch (Exception ex)
{
_context.Dispose();
Logger.WriteLineError(ex.Message);
}
}
/// <summary>
/// 迁移大数据的数据到中间层(老数据迁移
/// </summary>
public void SyncBigDataToMiddleDataBase(int projectid, int companyid)
{
var _traceRepository = new TraceDataRepository(companyid, projectid);
var datas = _traceRepository.GetSnTraceList(projectid);
var traces = _context.siger_check_sn_trace_inspection.Where(t => t.projectid == projectid && t.status == (int)RowState.Valid &&
datas.Select(q => q.ID).Contains(t.trace_id)).ToList();
datas = datas.Where(t => !traces.Select(q => q.trace_id).Contains(t.ID)).ToList();
var insertModels = new List<siger_check_sn_trace_inspection>();
var insertDetailModels = new List<siger_check_sn_trace_detail>();
foreach(var data in datas)
{
var model = new siger_check_sn_trace_inspection
{
trace_id = data.ID,
testroom = "",
productid = data.ProductID,
materialid = data.MaterialID,
sectionid = data.SectionID,
sn = data.SN,
routeid = data.RouteID,
check_type = data.CheckType,
check_status = (int)SendCheckStatus.Completed,
result = data.Result.ToUpper() == "OK" ? ((int)SendTestType.Qalified).ToString() : ((int)SendTestType.Unqualified).ToString(),
send_mid = data.UserID,
send_time = data.CreateTime,
check_mid = data.UserID,
check_time = data.CreateTime,
inspection_type = (int)InspectionType.ManualCollection,
projectid = projectid,
reason = "",
workorder = data.WorkOrder,
recieve_mid = data.UserID,
recieve_time = data.CreateTime,
checking_mid = data.UserID,
checking_time = data.CreateTime
};
var dataDetails = _context.siger_check_sn_trace_detail.Where(t => t.projectid == projectid && t.status == (int)RowState.Valid &&
data.ID == t.TraceID).ToList();
if (dataDetails.Any())
{
continue;
}
var details = _traceRepository.GetSingleTraceDetailList(data.ID, projectid);
var numberIndexs = _context.siger_check_partindex.Where(t => t.projectid == projectid && t.status == (int)RowState.Valid &&
details.Select(q => q.ID).Contains(t.trace_detailid)).ToList();
var number = 0;
foreach (var detail in details)
{
var numberIndex = numberIndexs.FirstOrDefault(t => t.trace_detailid == detail.ID);
var detailModel = new siger_check_sn_trace_detail
{
TraceID = detail.TraceID,
ItemID = detail.ItemID,
Result = detail.Result,
Value = detail.Value,
ItemName = detail.ItemName,
SN = string.IsNullOrEmpty(detail.SN) ? model.sn : detail.SN,
NumberIndex = numberIndex?.partindex ?? 1,
projectid = projectid,
CreateTime = data.CreateTime
};
insertDetailModels.Add(detailModel);
if(detailModel.NumberIndex > number)
{
number = detailModel.NumberIndex;
}
}
model.number = number;
insertModels.Add(model);
}
foreach(var trace in traces)
{
var dataDetails = _context.siger_check_sn_trace_detail.Where(t => t.projectid == projectid && t.status == (int)RowState.Valid &&
trace.trace_id == t.TraceID).ToList();
if (dataDetails.Any())
{
continue;
}
var details = _traceRepository.GetSingleTraceDetailList(trace.trace_id, projectid);
var numberIndexs = _context.siger_check_partindex.Where(t => t.projectid == projectid && t.status == (int)RowState.Valid &&
details.Select(q => q.ID).Contains(t.trace_detailid)).ToList();
foreach (var detail in details)
{
var numberIndex = numberIndexs.FirstOrDefault(t => t.trace_detailid == detail.ID);
var detailModel = new siger_check_sn_trace_detail
{
TraceID = detail.TraceID,
ItemID = detail.ItemID,
Result = detail.Result,
Value = detail.Value,
ItemName = detail.ItemName,
SN = string.IsNullOrEmpty(detail.SN) ? trace.sn : detail.SN,
NumberIndex = numberIndex?.partindex ?? 1,
projectid = projectid,
CreateTime = (trace.check_time.HasValue && trace.check_time != DateTime.MinValue) ? trace.check_time.Value : DateTime.Now
};
insertDetailModels.Add(detailModel);
}
}
_context.siger_check_sn_trace_inspection.AddRange(insertModels);
_context.siger_check_sn_trace_detail.AddRange(insertDetailModels);
_context.SaveChanges();
}
public void SyncMiddleDataToBigDataBase()
{
return;
}
}
}
Server/Apis/Siger.ApiQMS/Utility/AbnormalCheckHelper.cs
......@@ -4,7 +4,6 @@ using Siger.ApiQMS.Result;
using Siger.Middlelayer.Common;
using Siger.Middlelayer.Common.Helpers;
using Siger.Middlelayer.Common.ModuleEnum;
using Siger.Middlelayer.Dapper.CheckTrace.Repostriories;
using Siger.Middlelayer.Log;
using Siger.Middlelayer.QmsRepository.Entities;
using Siger.Middlelayer.QmsRepository.Repositories.Interface;
......@@ -56,7 +55,7 @@ namespace Siger.ApiQMS.Utility
/// <param name="machineid"></param>
/// <param name="triggerAndon"></param>
/// <param name="typeCode"></param>
public void AbnomalRuleCheck(int num, long traceid, int sectionid, int machineid, bool triggerAndon, int typeCode)
public void AbnomalRuleCheck(int num, string traceid, int sectionid, int machineid, bool triggerAndon, int typeCode)
{
if (num <= 0)
{
......@@ -170,7 +169,7 @@ namespace Siger.ApiQMS.Utility
}
}
private void UpdateTraceWorkOrder(long traceid, string workOrder)
private void UpdateTraceWorkOrder(string traceid, string workOrder)
{
if (string.IsNullOrEmpty(workOrder))
{
......@@ -188,9 +187,6 @@ namespace Siger.ApiQMS.Utility
{
return;
}
var _itemTraceRepository = new TraceDataRepository(_companyId, _projectId);
_itemTraceRepository.UpdateSnTraceWorkOrder(traceid, workOrder, _projectId);
}
/// <summary>
......
Server/Apis/Siger.ApiQMS/Utility/SpcAnalysisUtility.cs
......@@ -13,7 +13,7 @@ namespace Siger.ApiQMS.Utility
{
public class SpcAnalysisUtility :IDisposable
{
public ResponseQMSDynamicDiag CheckDataRule(int itemID, double UCL, double LCL, long traceID, List<double> valueList,
public ResponseQMSDynamicDiag CheckDataRule(int itemID, double UCL, double LCL, string traceID, List<double> valueList,
List<int> rules)
{
var request = new RequestQMSDynamicDiag
......
Server/Infrastructure/Repositories/Siger.Middlelayer.QmsRepository/Entities/siger_check_sn_trace_detail.cs
......@@ -18,7 +18,7 @@ namespace Siger.Middlelayer.QmsRepository.Entities
public int MachineID { get; set; }
public long TraceID { get; set; }
public string TraceID { get; set; }
public string SN { get; set; }
......
Server/Infrastructure/Repositories/Siger.Middlelayer.QmsRepository/Entities/siger_check_sn_trace_inspection.cs
......@@ -8,7 +8,7 @@ namespace Siger.Middlelayer.QmsRepository.Entities
/// </summary>
public class siger_check_sn_trace_inspection : QmsEntityBase
{
public long trace_id { get; set; }
public string trace_id { get; set; }
/// <summary>
/// 检测室字典key
......
Server/Infrastructure/Repositories/Siger.Middlelayer.QmsRepository/Repositories/CheckSnTraceDetailRepository.cs
......@@ -23,7 +23,7 @@ namespace Siger.Middlelayer.QmsRepository.Repositories
}
public IPagedCollectionResult<ResponseDataCollection> GetPagedList(List<int> sectionid, int productid, int materialid,
int route, int checktype, string sn, string result, List<long> traceIds, string starttime, string endtime, int userid, int itemid,
int route, int checktype, string sn, string result, List<string> traceIds, string starttime, string endtime, int userid, int itemid,
int projectId, int page, int pagesize, string toexcel)
{
var minDate = "0001-01-01 00:00:00".ToDateTime();
......@@ -146,7 +146,7 @@ namespace Siger.Middlelayer.QmsRepository.Repositories
}
}
public List<double> GetHistoryDts(int limt, long traceId, int typeCode, int projectId, int itemId, DateTime minDate)
public List<double> GetHistoryDts(int limt, string traceId, int typeCode, int projectId, int itemId, DateTime minDate)
{
var query = from d in _context.siger_check_sn_trace_detail
join t in _context.siger_check_sn_trace_inspection on d.TraceID equals t.trace_id
......@@ -158,5 +158,56 @@ namespace Siger.Middlelayer.QmsRepository.Repositories
return query.OrderByDescending(t => t.CreateTime).OrderByDescending(t => t.NumberIndex)
.OrderByDescending(t => t.ID).Take(limt).Select(t => t.Value.Value).ToList();
}
public IEnumerable<SnTrace> GetSnTraceList(List<int> sectionIds, int productid, int materialid, int checktype, string starttime, string endtime, int projectid)
{
var query = from q in _context.siger_check_sn_trace_inspection
//join t in _context.siger_check_sn_trace_inspection on q.TraceID equals t.trace_id
where q.projectid == productid && q.status == (int)RowState.Valid //&& t.status == (int)RowState.Valid && q.projectid == productid
&& q.check_status == (int)SendCheckStatus.Completed
select new SnTrace
{
ID = q.trace_id,
ProductID = q.productid,
MaterialID = q.materialid,
SectionID = q.sectionid,
WorkOrder = q.workorder,
SN = q.sn,
Result = q.result,
UserID = q.checking_mid,
CreateTime = q.check_time > DateTime.MinValue ? q.check_time.Value : DateTime.MinValue,
RouteID = q.routeid,
CheckType = q.check_type,
};
Expression<Func<SnTrace, bool>> materialExpression = q => true;
if (materialid > 0)
{
materialExpression = q => q.MaterialID == materialid;
}
Expression<Func<SnTrace, bool>> sectionExpression = q => true;
if (sectionIds.Any())
{
sectionExpression = q => sectionIds.Contains(q.SectionID);
}
Expression<Func<SnTrace, bool>> productExpression = q => true;
if (productid > 0)
{
productExpression = q => q.ProductID == productid;
}
Expression<Func<SnTrace, bool>> checkTypeExpression = q => true;
if (checktype > 0)
{
checkTypeExpression = q => q.CheckType == checktype;
}
Expression<Func<SnTrace, bool>> timeExpression = q => true;
if (!string.IsNullOrEmpty(starttime) && !string.IsNullOrEmpty(endtime))
{
timeExpression = q => q.CreateTime <= endtime.ToDateTime() && q.CreateTime >= starttime.ToDateTime();
}
var expression = materialExpression.And(sectionExpression).And(productExpression).And(checkTypeExpression).And(timeExpression);
return query.Where(expression);
}
}
}
Server/Infrastructure/Repositories/Siger.Middlelayer.QmsRepository/Repositories/Interface/ICheckSnTraceDetailRepository.cs
......@@ -9,9 +9,11 @@ namespace Siger.Middlelayer.QmsRepository.Repositories.Interface
public interface ICheckSnTraceDetailRepository : IQmsRepositoryBase<siger_check_sn_trace_detail>
{
IPagedCollectionResult<ResponseDataCollection> GetPagedList(List<int> sectionid, int productid, int materialid,
int route, int checktype, string sn, string result, List<long> traceIds, string starttime, string endtime, int userid, int itemid,
int route, int checktype, string sn, string result, List<string> traceIds, string starttime, string endtime, int userid, int itemid,
int projectId, int page, int pagesize, string toexcel);
List<double> GetHistoryDts(int limt, long traceId, int typeCode, int projectId, int itemId, DateTime minDate);
List<double> GetHistoryDts(int limt, string traceId, int typeCode, int projectId, int itemId, DateTime minDate);
IEnumerable<SnTrace> GetSnTraceList(List<int> sectionIds, int productid, int materialid, int checktype, string starttime, string endtime, int projectid);
}
}
Server/Infrastructure/Repositories/Siger.Middlelayer.QmsRepository/Request/RequestDataCollection.cs
......@@ -38,7 +38,7 @@ namespace Siger.Middlelayer.QmsRepository.Request
public class RequestUpdateDataCollection : RequestAddDataCollection
{
public long id { get; set; }
public string id { get; set; }
}
public class DataCollectionDetail
......
Server/Infrastructure/Repositories/Siger.Middlelayer.QmsRepository/Response/ResponseDataCollection.cs
......@@ -5,7 +5,7 @@ namespace Siger.Middlelayer.QmsRepository.Response
{
public class ResponseDataCollection
{
public long id { get; set; }
public string id { get; set; }
public int productid { get; set; }
......@@ -138,4 +138,61 @@ namespace Siger.Middlelayer.QmsRepository.Response
public int stopBits { get; set; }
}
public class SnTrace
{
public string ID { get; set; }
public int ProductID { get; set; }
public int MaterialID { get; set; }
public int SectionID { get; set; }
public int MachineID { get; set; }
public string WorkOrder { get; set; }
public string SN { get; set; }
public string Result { get; set; }
public int UserID { get; set; }
public int RouteID { get; set; }
public DateTime CreateTime { get; set; }
public int CheckType { get; set; }
public string ItemName { get; set; } = string.Empty;
}
public class SnTraceDetail
{
public long ID { get; set; }
public string TraceID { get; set; }
public int ItemID { get; set; }
public string ItemName { get; set; } = string.Empty;
public string Result { get; set; }
public double? Value { get; set; }
public string SN { get; set; }
}
public class SnTraceDetailList : SnTraceDetail
{
public int NumberIndex { get; set; }
public double? LowerLimit { get; set; }
public double? UpperLimit { get; set; }
}
}
Server/Infrastructure/Repositories/Siger.Middlelayer.QmsRepository/Response/ResponseSendTestCollection.cs
......@@ -6,7 +6,7 @@ namespace Siger.Middlelayer.QmsRepository.Response
public class ResponseSendTestCollection
{
public int id { get; set; }
public long traceid { get; set; }
public string traceid { get; set; }
public int productid { get; set; }
public string productcode { get; set; }
public string productname { get; set; }
......
Server/Infrastructure/Siger.Middlelayer.Dapper/CheckTrace/Constant/TabelNameConstant.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Text;
namespace Siger.Middlelayer.Dapper.CheckTrace.Constant
{
public class TabelNameConstant
{
public const string SnTraceTable = "siger_check_sn_trace";
public const string SnTraceDetailTable = "siger_check_sn_trace_detail";
public const string SubTableTable = "siger_project_subtable";
public const string TraceInspection = "siger_check_sn_trace_inspection";
}
}
Server/Infrastructure/Siger.Middlelayer.Dapper/CheckTrace/Data/SnTrace.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Text;
namespace Siger.Middlelayer.Dapper.CheckTrace.Data
{
public class SnTrace
{
public long ID { get; set; }
public int ProductID { get; set; }
public int MaterialID { get; set; }
public int SectionID { get; set; }
public int MachineID { get; set; }
public string WorkOrder { get; set; }
public string SN { get; set; }
public string Result { get; set; }
public int UserID { get; set; }
public int RouteID { get; set; }
public DateTime CreateTime { get; set; }
public int CheckType { get; set; }
public string ItemName { get; set; } = string.Empty;
}
public class SnTraceDetail
{
public long ID { get; set; }
public long TraceID { get; set; }
public int ItemID { get; set; }
public string ItemName { get; set; } = string.Empty;
public string Result { get; set; }
public double? Value { get; set; }
public string SN { get; set; }
}
public class SnTraceDetailList : SnTraceDetail
{
public int NumberIndex { get; set; }
public double? LowerLimit { get; set; }
public double? UpperLimit { get; set; }
}
}
Server/Infrastructure/Siger.Middlelayer.Dapper/CheckTrace/Data/SubTable.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Text;
namespace Siger.Middlelayer.Dapper.CheckTrace.Data
{
public class SubTable
{
public int id { get; set; }
public string name { get; set; }
public string tablename { get; set; }
public long startid { get; set; }
public long endid { get; set; }
public DateTime validtime { get; set; }
public DateTime createtime { get; set; }
public int status { get; set; }
}
}
Server/Infrastructure/Siger.Middlelayer.Dapper/CheckTrace/Repostriories/TraceDataRepository.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Text;
using Dapper;
using Siger.Middlelayer.Dapper.CheckTrace.Data;
using Siger.Middlelayer.Dapper.CheckTrace.Constant;
using System.Linq;
using System.Threading.Tasks;
using Siger.Middlelayer.Common.Extensions;
using Siger.Middlelayer.Common.Log;
using Siger.Middlelayer.Common;
using Siger.Middlelayer.Common.ModuleEnum;
namespace Siger.Middlelayer.Dapper.CheckTrace.Repostriories
{
public class TraceDataRepository : TraceDbContext
{
public TraceDataRepository(int companyId, int projectId) : base(companyId, projectId)
{
}
public List<SubTable> GetSubTableList(string name)
{
using (var conn = GetDbConnection())
{
var sql = $"select * from {TabelNameConstant.SubTableTable} where tablename='{name}' and status=1";
var dataList = conn.Query<SubTable>(sql);
return dataList.ToList();
}
}
public IEnumerable<SnTrace> GetSnTraceList(int projectid)
{
var sql = $@"select ID,ProductID,MaterialID,SectionID,WorkOrder,SN,Result,UserID,CreateTime,RouteID,CheckType
from {TabelNameConstant.SnTraceTable}
where Status={(int)RowState.Valid} and ProjectID={projectid} and UserID>0
order by CreateTime";
var dataList = GetDataList<SnTrace>(sql);
return dataList;
}
public IEnumerable<SnTraceDetail> GetSingleTraceDetailList(long traceId, int projectid)
{
var snTraces = new List<SnTraceDetail>();
var subTables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
if (subTables.Count > 0)
{
Parallel.ForEach(subTables, new ParallelOptions { MaxDegreeOfParallelism = subTables.Count },
t => { snTraces.AddRange(GetSingleTraceDetails(t, traceId, projectid)); });
}
Task.WaitAll();
return snTraces.ToList();
}
private IEnumerable<SnTraceDetail> GetSingleTraceDetails(SubTable table, long traceId, int projectid)
{
var conditon = string.Empty;
if (traceId > 0)
{
conditon += $" and TraceID={traceId}";
}
var sql = $@"select ID,ItemID,TraceID,Result,Value,ItemName,SN
from {table.name}
where Status=1 and ProjectID={projectid} {conditon}";
var dataList = GetDataList<SnTraceDetail>(sql);
return dataList;
}
public SnTrace GetSnTrace(long id, int projectid)
{
using (var conn = GetDbConnection())
{
var sql = $"select * from {TabelNameConstant.SnTraceTable} where ID={id} and Status=1 and ProjectID={projectid}";
var data = conn.QuerySingleOrDefault<SnTrace>(sql);
return data;
}
}
public void UpdateSnTraceWorkOrder(long id, string workorder, int projectid)
{
using (var conn = GetDbConnection())
{
var sql = $"update {TabelNameConstant.SnTraceTable} set WorkOrder='{workorder}' where ID={id} and Status=1 and ProjectID={projectid}";
var data = conn.Execute(sql);
}
}
public override void Dispose()
{
throw new NotImplementedException();
}
}
}
Server/Infrastructure/Siger.Middlelayer.Dapper/CheckTrace/Repostriories/TraceDetailRepository.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Text;
using Dapper;
using Siger.Middlelayer.Dapper.CheckTrace.Data;
using Siger.Middlelayer.Dapper.CheckTrace.Constant;
using System.Linq;
using System.Threading.Tasks;
using Siger.Middlelayer.Common.Extensions;
using Siger.Middlelayer.Common.Log;
using Siger.Middlelayer.Common;
using Siger.Middlelayer.Common.ModuleEnum;
namespace Siger.Middlelayer.Dapper.CheckTrace.Repostriories
{
public class TraceDetailRepository : TraceDbContext
{
public TraceDetailRepository(int companyId, int projectId) : base(companyId, projectId)
{
}
public List<SubTable> GetSubTableList(string name)
{
using (var conn = GetDbConnection())
{
var sql = $"select * from {TabelNameConstant.SubTableTable} where tablename='{name}' and status=1";
var dataList = conn.Query<SubTable>(sql);
return dataList.ToList();
}
}
/// <summary>
/// 查询分页 和 导出获取数据
/// </summary>
/// <param name="sectionId"></param>
/// <param name="productId"></param>
/// <param name="materialId"></param>
/// <param name="routeId"></param>
/// <param name="checkType"></param>
/// <param name="sn"></param>
/// <param name="result"></param>
/// <param name="ids">siger_check_sn_trace.ID</param>
/// <param name="starttime"></param>
/// <param name="endtime"></param>
/// <param name="page"></param>
/// <param name="pagesize"></param>
/// <param name="projectid"></param>
/// <param name="toexcel"></param>
/// <param name="userId"></param>
/// <param name="userCheck">0->查询所有数据 1->查询有检验人的数据</param>
/// <param name="okContainsDeviation">查询OK的时候是否包含偏差放行 true->包含 false->不包含</param>
/// <param name="inspectionType">1->送检数据 2->人工检验数据</param>
/// <returns></returns>
public IEnumerable<SnTrace> GetSnTracePageList(List<int> sectionId, int productId, int materialId, int routeId, int checkType, string sn, string result, List<long> ids,
string starttime, string endtime, int page, int pagesize, int projectid, string toexcel, int userId, int userCheck = 0, bool okContainsDeviation = true, int inspectionType = 0)
{
var conditon = GetCondition(sectionId, productId, materialId, routeId, checkType, sn, result, ids,
starttime, endtime, userId, userCheck);
var pageLimit = "";
if(toexcel.ToInt() == 0)
{
pageLimit = $" limit { (page - 1) * pagesize},{ pagesize}";
}
if (!string.IsNullOrEmpty(result) && (result.ToUpper() == "OK" || result == ((int)SendTestType.DeviationRelease).ToString()) &&
okContainsDeviation == false)
{
var dbName = GetDbName();
var midDbName = GetMidDataBaseName();
var sql = $@"select t.ID,t.ProductID,t.MaterialID,t.SectionID,t.WorkOrder,t.SN,t.Result,t.UserID,t.CreateTime,t.RouteID,t.CheckType
from {dbName}.{TabelNameConstant.SnTraceTable} t left join {midDbName}.{TabelNameConstant.TraceInspection} s on t.ID=s.trace_id
where t.Status=1 and t.ProjectID={projectid} and (s.result='{((int)SendTestType.Qalified).ToString()}' or s.result is null) and
(s.status=1 or s.status is null) and (s.projectid={projectid} or s.projectid is null) {conditon}
order by t.CreateTime DESC {pageLimit}";
var dataList = GetDataList<SnTrace>(sql);
return dataList;
}
else if (inspectionType == (int)InspectionType.ManualCollection)
{
var dbName = GetDbName();
var midDbName = GetMidDataBaseName();
var sql = $@"select t.ID,t.ProductID,t.MaterialID,t.SectionID,t.WorkOrder,t.SN,t.Result,t.UserID,t.CreateTime,t.RouteID,t.CheckType
from {dbName}.{TabelNameConstant.SnTraceTable} t left join {midDbName}.{TabelNameConstant.TraceInspection} s on t.ID=s.trace_id
where t.Status=1 and t.ProjectID={projectid} and (s.inspection_type={(int)InspectionType.ManualCollection} or s.trace_id is NULL) and
(s.status=1 or s.status is null) and (s.projectid={projectid} or s.projectid is null) {conditon}
order by t.CreateTime DESC {pageLimit}";
var dataList = GetDataList<SnTrace>(sql);
return dataList;
}
else
{
var sql = $@"select t.ID,t.ProductID,t.MaterialID,t.SectionID,t.WorkOrder,t.SN,t.Result,t.UserID,t.CreateTime,t.RouteID,t.CheckType
from {TabelNameConstant.SnTraceTable} t
where t.Status=1 and t.ProjectID={projectid} {conditon}
order by t.CreateTime DESC {pageLimit}";
var dataList = GetDataList<SnTrace>(sql);
return dataList;
}
}
public long CountTrace(List<int> sectionId, int productId, int materialId, int routeId, int checkType, string sn, string result, List<long> ids,
string starttime, string endtime, int projectid, int userId, int userCheck = 0, bool okContainsDeviation = true, int inspectionType = 0)
{
using (var conn = GetDbConnection())
{
var conditon = GetCondition(sectionId, productId, materialId, routeId, checkType, sn, result, ids,
starttime, endtime, userId, userCheck);
if(!string.IsNullOrEmpty(result) && (result.ToUpper() == "OK" || result == ((int)SendTestType.DeviationRelease).ToString()) &&
okContainsDeviation == false)
{
var dbName = GetDbName();
var midDbName = GetMidDataBaseName();
var res = conn.ExecuteScalar<long>($@"select count(1) from {dbName}.{TabelNameConstant.SnTraceTable} t left join {midDbName}.{TabelNameConstant.TraceInspection} s on t.ID=s.trace_id
where t.Status=1 and t.ProjectID={projectid} and (s.result='{((int)SendTestType.Qalified).ToString()}' or s.result is null) and
(s.status=1 or s.status is null) and (s.projectid={projectid} or s.projectid is null) {conditon}");
return res;
}
else if(inspectionType == (int)InspectionType.ManualCollection)
{
var dbName = GetDbName();
var midDbName = GetMidDataBaseName();
var sql = $@"select count(1) from {dbName}.{TabelNameConstant.SnTraceTable} t left join {midDbName}.{TabelNameConstant.TraceInspection} s on t.ID=s.trace_id
where t.Status=1 and t.ProjectID={projectid} and (s.inspection_type={(int)InspectionType.ManualCollection} || s.trace_id is NULL) and
(s.status=1 or s.status is null) and (s.projectid={projectid} or s.projectid is null) {conditon}";
var res = conn.ExecuteScalar<long>(sql);
return res;
}
else
{
var res = conn.ExecuteScalar<long>($@"select count(1) from {TabelNameConstant.SnTraceTable} t
where t.Status=1 and t.ProjectID={projectid} {conditon}");
return res;
}
}
}
private string GetCondition(List<int> sectionId, int productId, int materialId, int routeId, int checkType, string sn, string result, List<long> ids,
string starttime, string endtime, int userId, int userCheck)
{
var conditon = string.Empty;
if (sectionId.Any())
{
conditon += $" and t.SectionID in ({string.Join(",", sectionId)})";
}
if (userCheck > 0)
{
conditon += $" and t.UserID>0";
}
if (productId > 0)
{
conditon += $" and t.ProductID={productId}";
}
if (materialId > 0)
{
conditon += $" and t.MaterialID={materialId}";
}
if (routeId > 0)
{
conditon += $" and t.RouteID={routeId}";
}
if (checkType > 0)
{
conditon += $" and t.CheckType={checkType}";
}
if (!string.IsNullOrEmpty(sn))
{
conditon += $" and t.SN={sn}";
}
if (!string.IsNullOrEmpty(result))
{
conditon += $" and t.Result='{result}'";
}
if (ids.Any())
{
conditon += $" and t.ID in ({string.Join(",", ids)})";
}
if (!string.IsNullOrEmpty(starttime) && !string.IsNullOrEmpty(endtime))
{
conditon += $" and t.CreateTime<='{endtime}' and t.CreateTime >= '{starttime}'";
}
if(userId > 0)
{
conditon += $" and t.UserID={userId}";
}
return conditon;
}
public SnTrace GetSnTrace(long id, int projectid)
{
using (var conn = GetDbConnection())
{
var sql = $"select * from {TabelNameConstant.SnTraceTable} where ID={id} and Status=1 and ProjectID={projectid}";
var data = conn.QuerySingleOrDefault<SnTrace>(sql);
return data;
}
}
/// <summary>
/// 通过TraceID获取详情数据
/// </summary>
/// <returns></returns>
public IEnumerable<SnTraceDetail> GetSingleTraceDetailList(long traceId, int projectid)
{
var snTraces = new List<SnTraceDetail>();
var subTables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
if (subTables.Count > 0)
{
Parallel.ForEach(subTables, new ParallelOptions { MaxDegreeOfParallelism = subTables.Count },
t => { snTraces.AddRange(GetSingleTraceDetails(t, traceId, projectid)); });
}
Task.WaitAll();
return snTraces.ToList();
}
private IEnumerable<SnTraceDetail> GetSingleTraceDetails(SubTable table, long traceId, int projectid)
{
var conditon = string.Empty;
if (traceId > 0)
{
conditon += $" and TraceID={traceId}";
}
var sql = $@"select ID,ItemID,TraceID,Result,Value,ItemName
from {table.name}
where Status=1 and ProjectID={projectid} {conditon}
order by CreateTime";
var dataList = GetDataList<SnTraceDetail>(sql);
return dataList;
}
public bool InsertTraceDetail(SnTrace trace, List<SnTraceDetailList> details, int projectid)
{
var tables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
if (!tables.Any())
{
return false;
}
using (var conn = GetDbConnection())
{
var now = DateTime.Now;
var tran = BeginTransaction(conn);
try
{
var time = DateTime.Now.ToString(ParameterConstant.DateTimeFormat);
var sql = $"insert into {TabelNameConstant.SnTraceTable} (SN,ProductID,MaterialID,SectionID,MachineID,WorkOrder,RouteID," +
$"UserID,Result,CreateTime,ProjectID,Status,CheckType) values('{trace.SN}',{trace.ProductID},{trace.MaterialID},{trace.SectionID},{trace.MachineID}," +
$"'{trace.WorkOrder}',{trace.RouteID},{trace.UserID},'{trace.Result}','{time}',{projectid},1,{trace.CheckType});";
sql += "SELECT @@identity;";//@ID=SCOPE_IDENTITY();
var traceId = conn.Query<long>(sql, tran).FirstOrDefault();
foreach (var detail in details)
{
var table = tables.FirstOrDefault(t => t.validtime.Year == now.Year && t.validtime.Month == now.Month);
if (table != null)
{
if (detail.Value.HasValue)
{
var dSQL = $"insert into {table.name}" +
$"(TraceID,MachineID,SN,ItemID,ItemName,Value,Result,CreateTime,ProjectID,Status) values" +
$"({traceId},{trace.MachineID},'{trace.SN}',{detail.ItemID},'{detail.ItemName}',{detail.Value.Value}," +
$"'{detail.Result}','{time}',{projectid},1)";
conn.Execute(dSQL, tran);
}
else
{
var dSQL = $"insert into {table.name}" +
$"(TraceID,MachineID,SN,ItemID,ItemName,Result,CreateTime,ProjectID,Status) values" +
$"({traceId},{trace.MachineID},'{trace.SN}',{detail.ItemID},'{detail.ItemName}'," +
$"'{detail.Result}','{time}',{projectid},1)";
conn.Execute(dSQL, tran);
}
}
}
Commit(tran, conn);
return true;
}
catch(Exception ex)
{
Logger.WriteLineError(ex.ToString());
Rollback(tran, conn);
return false;
}
}
}
/// <summary>
/// 删除所有数据
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public bool DeleteData(long id)
{
var tables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
using (var conn = GetDbConnection())
{
var tran = BeginTransaction(conn);
try
{
var sql = $"update {TabelNameConstant.SnTraceTable} set Status={(int)RowState.Invalid} where ID={id}";
conn.Execute(sql);
foreach(var table in tables)
{
var sql2 = $"update {table.name} set Status={(int)RowState.Invalid} where TraceID={id}";
conn.Execute(sql2);
}
Commit(tran, conn);
return true;
}
catch
{
Rollback(tran, conn);
return false;
}
}
}
/// <summary>
/// 只删除详情表数据
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public bool DeleteDetail(long id)
{
var tables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
using (var conn = GetDbConnection())
{
var tran = BeginTransaction(conn);
try
{
foreach (var table in tables)
{
var sql = $"update {table.name} set Status={(int)RowState.Invalid} where TraceID={id}";
conn.Execute(sql);
}
Commit(tran, conn);
return true;
}
catch
{
Rollback(tran, conn);
return false;
}
}
}
/// <summary>
/// 插入检验数据，并返回有插入ID和顺序序号的检验详情数据
/// </summary>
/// <returns></returns>
public long InsertTraceDetailReturnTraceIdNumberIndex(SnTrace trace, List<SnTraceDetailList> details, int projectid,
out List<SnTraceDetailList> resDetails)
{
resDetails = new List<SnTraceDetailList>();
var tables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
if (!tables.Any())
{
return 0;
}
using (var conn = GetDbConnection())
{
var now = DateTime.Now;
var tran = BeginTransaction(conn);
try
{
var time = trace.CreateTime.ToString(ParameterConstant.DateTimeFormat);
var sql = $"insert into {TabelNameConstant.SnTraceTable} (SN,ProductID,MaterialID,SectionID,MachineID,WorkOrder,RouteID," +
$"UserID,Result,CreateTime,ProjectID,Status,CheckType) values('{trace.SN}',{trace.ProductID},{trace.MaterialID},{trace.SectionID},{trace.MachineID}," +
$"'{trace.WorkOrder}',{trace.RouteID},{trace.UserID},'{trace.Result}','{time}',{projectid},1,{trace.CheckType});";
sql += "SELECT @@identity;";//@ID=SCOPE_IDENTITY();
var traceId = conn.Query<long>(sql, tran).FirstOrDefault();
foreach (var detail in details)
{
var table = tables.FirstOrDefault(t => t.validtime.Year == now.Year && t.validtime.Month == now.Month);
if (table != null)
{
if (detail.Value.HasValue)
{
var dSQL = $"insert into {table.name}" +
$"(TraceID,MachineID,SN,ItemID,ItemName,Value,Result,CreateTime,ProjectID,Status) values" +
$"({traceId},{trace.MachineID},'{trace.SN}',{detail.ItemID},'{detail.ItemName}',{detail.Value.Value}," +
$"'{detail.Result}','{time}',{projectid},1);";
dSQL += "SELECT @@identity;";
detail.ID = conn.Query<long>(dSQL, tran).FirstOrDefault();
resDetails.Add(detail);
}
else
{
var dSQL = $"insert into {table.name}" +
$"(TraceID,MachineID,SN,ItemID,ItemName,Result,CreateTime,ProjectID,Status) values" +
$"({traceId},{trace.MachineID},'{trace.SN}',{detail.ItemID},'{detail.ItemName}'," +
$"'{detail.Result}','{time}',{projectid},1);";
dSQL += "SELECT @@identity;";
detail.ID = conn.Query<long>(dSQL, tran).FirstOrDefault();
resDetails.Add(detail);
}
}
}
Commit(tran, conn);
return traceId;
}
catch (Exception ex)
{
Logger.WriteLineError("Insert Trace Detail Data Error:" + ex.ToString());
Rollback(tran, conn);
return 0;
}
}
}
/// <summary>
/// 插入检验数据，并返回有插入ID和顺序序号的检验详情数据
/// </summary>
/// <returns></returns>
public bool InsertTraceOnlyDetailsReturnNumerIndex(SnTrace trace, List<SnTraceDetailList> details, int projectid,
string result, out List<SnTraceDetailList> resDetails)
{
resDetails = new List<SnTraceDetailList>();
var tables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
if (!tables.Any())
{
return false;
}
using (var conn = GetDbConnection())
{
var now = DateTime.Now;
var tran = BeginTransaction(conn);
try
{
if (trace.Result != result)
{
var uSQL = $"update {TabelNameConstant.SnTraceTable} set Result='{result}' where ID={trace.ID} and Status=1 and ProjectID={projectid}";
conn.Execute(uSQL, tran);
}
var time = trace.CreateTime.ToString(ParameterConstant.DateTimeFormat);
foreach (var detail in details)
{
var table = tables.FirstOrDefault(t => t.validtime.Year == now.Year && t.validtime.Month == now.Month);
if (table != null)
{
if (detail.Value.HasValue)
{
var dSQL = $"insert into {table.name}" +
$"(TraceID,MachineID,SN,ItemID,ItemName,Value,Result,CreateTime,ProjectID,Status) values" +
$"({trace.ID},{trace.MachineID},'{trace.SN}',{detail.ItemID},'{detail.ItemName}',{detail.Value.Value}," +
$"'{detail.Result}','{time}',{projectid},1);";
dSQL += "SELECT @@identity;";
detail.ID = conn.Query<long>(dSQL, tran).FirstOrDefault();
resDetails.Add(detail);
}
else
{
var dSQL = $"insert into {table.name}" +
$"(TraceID,MachineID,SN,ItemID,ItemName,Result,CreateTime,ProjectID,Status) values" +
$"({trace.ID},{trace.MachineID},'{trace.SN}',{detail.ItemID},'{detail.ItemName}'," +
$"'{detail.Result}','{time}',{projectid},1);";
dSQL += "SELECT @@identity;";
detail.ID = conn.Query<long>(dSQL, tran).FirstOrDefault();
resDetails.Add(detail);
}
}
}
Commit(tran, conn);
return true;
}
catch (Exception ex)
{
Logger.WriteLineError("Insert Trace Detail Data Error:" + ex.ToString());
Rollback(tran, conn);
return false;
}
}
}
/// <summary>
/// 通过多个项目ID 获取TraceID
/// </summary>
/// <returns></returns>
public IEnumerable<long> GetTraceIdList(List<long> ids, long traceId, List<int> itemIds,
string itemName, string starttime, string endtime, int projectid)
{
var snTraceIds = new List<long>();
var subTables = GetSubTableList(TabelNameConstant.SnTraceDetailTable);
if (subTables.Any())
{
Parallel.ForEach(subTables, new ParallelOptions { MaxDegreeOfParallelism = subTables.Count },
t => { snTraceIds.AddRange(GetSnTraceIds(t, ids, traceId, itemIds, itemName, starttime, endtime, projectid)); });
Task.WaitAll();
}
return snTraceIds.ToList();
}
private IEnumerable<long> GetSnTraceIds(SubTable table, List<long> ids, long traceId, List<int> itemIds, string itemName
, string starttime, string endtime, int projectid)
{
var conditon = string.Empty;
var stime = starttime.ToDateTime();
var etime = endtime.ToDateTime();
if (ids.Any())
{
var detailIds = new List<int>();
if (DateTime.Now.Year == table.validtime.Year && DateTime.Now.Month == table.validtime.Month)
{
ids.Where(t => t >= table.startid);
}
else
{
ids.Where(t => t <= table.endid && t >= table.startid).ToList();
}
if (detailIds.Any())
{
conditon = $" and ID in ({string.Join(",", detailIds)}) ";
}
else
{
return new List<long>();
}
}
if (traceId > 0)
{
conditon += $" and TraceID={traceId}";
}
if (!string.IsNullOrEmpty(itemName))
{
conditon += $" and ItemName='{itemName}'";
}
if (itemIds.Any())
{
conditon += $" and ItemID in ({string.Join(",", itemIds)})";
}
var sql = $@"select TraceID
from {table.name}
where Status=1 and ProjectID={projectid} and CreateTime<='{endtime}' and
CreateTime>='{starttime}' {conditon}
group by TraceID ";
var dataList = GetDataList<long>(sql);
return dataList;
}
public override void Dispose()
{
throw new NotImplementedException();
}
}
}
Server/Infrastructure/Siger.Middlelayer.Dapper/CheckTrace/Repostriories/TraceDetailTableRepository.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Text;
using Dapper;
using Siger.Middlelayer.Dapper.CheckTrace.Data;
using Siger.Middlelayer.Dapper.CheckTrace.Constant;
using System.Linq;
using System.Threading.Tasks;
using Siger.Middlelayer.Common.Extensions;
using Siger.Middlelayer.Common.Log;
using Siger.Middlelayer.Common;
using Siger.Middlelayer.Common.ModuleEnum;
namespace Siger.Middlelayer.Dapper.CheckTrace.Repostriories
{
public class TraceDetailTableRepository : TraceDetailRepository
{
public TraceDetailTableRepository(int companyId, int projectId) : base(companyId, projectId)
{
}
/// <summary>
/// 查询表是否存在
/// </summary>
/// <returns></returns>
public bool TableIsExsit(string tablename, string schemaname)
{
using (var conn = GetDbConnection())
{
var sql = $"select TABLE_NAME from information_schema.TABLES where TABLE_NAME = '{tablename}' and TABLE_SCHEMA='{schemaname}';";
var data = conn.Query<string>(sql);
return !string.IsNullOrEmpty(data.FirstOrDefault());
}
}
public void CreateTable(string tablename, string true_tablename, long startid)
{
using (var conn = GetDbConnection())
{
var sql = string.Empty;
switch (tablename)
{
case TabelNameConstant.SnTraceTable:
{
sql = "CREATE TABLE `" + true_tablename + @"` (
`ID` bigint(20) NOT NULL AUTO_INCREMENT,
`SN` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '二维码',
`ProductID` int(11) NOT NULL COMMENT '产品ID',
`MaterialID` int(11) NOT NULL DEFAULT 0 COMMENT '物料ID',
`SectionID` int(20) NOT NULL COMMENT '工位ID',
`MachineID` int(11) NOT NULL COMMENT '设备ID',
`WorkOrder` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT '' COMMENT '工单号',
`RouteID` int(11) NOT NULL DEFAULT 0 COMMENT '产品工序ID',
`UserID` int(20) NOT NULL DEFAULT 0 COMMENT '用户MID',
`Result` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT '' COMMENT '结果',
`CheckType` int(2) NOT NULL DEFAULT 0 COMMENT '检验类型',
`CreateTime` datetime(0) NOT NULL,
`ProjectID` int(20) NOT NULL DEFAULT 0,
`Status` int(2) NOT NULL DEFAULT 1,
PRIMARY KEY(`ID`) USING BTREE,
INDEX `sn`(`SN`) USING BTREE,
INDEX `UserID`(`UserID`) USING BTREE,
INDEX `CreateTime`(`CreateTime`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = DYNAMIC; ";
break;
}
case TabelNameConstant.SnTraceDetailTable:
{
sql = @"CREATE TABLE `" + true_tablename + @"` (
`ID` bigint(20) NOT NULL AUTO_INCREMENT,
`MachineID` int(11) NOT NULL DEFAULT 0,
`TraceID` bigint(20) NOT NULL DEFAULT 0 COMMENT 'siger_tr_sn_trace.id(trace表ID)',
`SN` varchar(100) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '二维码',
`ItemID` int(11) NOT NULL DEFAULT 0 COMMENT 'siger_qms_inspection_standard.id(项目ID)',
`ItemName` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '项目名称',
`Value` double NULL DEFAULT NULL COMMENT '检测值',
`Result` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT '' COMMENT '结果',
`CreateTime` datetime(0) NOT NULL,
`ProjectID` int(20) NOT NULL DEFAULT 0,
`Status` int(20) NOT NULL DEFAULT 1,
PRIMARY KEY (`ID`) USING BTREE,
INDEX `index_createtime`(`CreateTime`) USING BTREE,
INDEX `index_itemname`(`ItemName`) USING BTREE,
INDEX `index_itemid`(`ItemID`) USING BTREE,
INDEX `index_traceid`(`TraceID`, `ProjectID`, `Status`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = " + startid + " CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = DYNAMIC;";
break;
}
case TabelNameConstant.SubTableTable:
{
sql = "CREATE TABLE `" + true_tablename + @"` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT '' COMMENT '分表表名',
`tablename` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT '' COMMENT '原始表名',
`startid` bigint(20) NOT NULL DEFAULT 0 COMMENT '分表最小ID',
`endid` bigint(20) NOT NULL DEFAULT 0 COMMENT '分表最大ID,新建表默认0',
`validtime` datetime(0) NOT NULL COMMENT '有效月份',
`createtime` datetime(0) NOT NULL COMMENT '创建时间',
`status` int(2) NOT NULL DEFAULT 1,
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = DYNAMIC;";
break;
}
}
var data = conn.Execute(sql);
}
}
public long GetTableMaxID(string tablename)
{
using (var conn = GetDbConnection())
{
var sql = $"select max(ID) from {tablename}";
var data = conn.Query<string>(sql);
bool num = long.TryParse(data.First(), out long result);
return num ? result : 0L;
}
}
public long GetTableMinID(string tablename)
{
using (var conn = GetDbConnection())
{
var sql = $"select min(ID) from {tablename}";
var data = conn.Query<string>(sql);
bool num = long.TryParse(data.First(), out long result);
return num ? result : 1L;
}
}
public SubTable GetSubTableInfo(string name, string tablename)
{
using (var conn = GetDbConnection())
{
var sql = $"select * from {TabelNameConstant.SubTableTable} where name='{name}' and tablename='{tablename}' and status=1";
var dataList = conn.Query<SubTable>(sql);
return dataList.FirstOrDefault();
}
}
public bool InsertSubTable(SubTable entity)
{
using (var conn = GetDbConnection())
{
var sql = $"INSERT INTO `siger_project_subtable` (name,tablename,startid,endid,validtime,createtime,status) VALUES ('{entity.name}', '{entity.tablename}', {entity.startid}, {entity.endid}, '{entity.validtime.ToString(ParameterConstant.DateTimeFormat)}', '{entity.createtime.ToString(ParameterConstant.DateTimeFormat)}', {entity.status});";
var data = conn.Execute(sql);
return data > 0;
}
}
public bool UpdateSubTableEndId(int id, long endid)
{
using (var conn = GetDbConnection())
{
var sql = $"update siger_project_subtable set endid={endid} where id={id}";
var data = conn.Execute(sql);
return data > 0;
}
}
public override void Dispose()
{
throw new NotImplementedException();
}
}
}
Server/Infrastructure/Siger.Middlelayer.Dapper/CheckTrace/TraceDbContext.cs deleted 100644 → 0
using System;
using System.Collections.Generic;
using System.Data;
using System.Threading.Tasks;
using Dapper;
using MySql.Data.MySqlClient;
using Siger.Middlelayer.Common.Configuration;
using Siger.Middlelayer.Redis;
namespace Siger.Middlelayer.Dapper.CheckTrace
{
public abstract class TraceDbContext
{
private static string _dbConnection;
private static string _dbMidConnection;
private readonly int _companyId;
private readonly int _projectId;
protected TraceDbContext(int companyId, int projectId)
{
var useOneDb = ConfigManager.GetValue("DbSetting", "UseOneDb", true);
if (useOneDb)
{
_dbConnection = ConfigManager.GetValue("DbSetting", "DbConnectionKM", string.Empty);
}
else
{
_dbConnection = ConfigManager.GetValue("DbClusterSetting", "ClusterConnectionKM", string.Empty);
}
if (string.IsNullOrEmpty(_dbConnection))
{
throw new Exception("DbSetting about [DbConnectionKM] not found.");
}
_dbMidConnection = ConfigManager.GetValue("DbSetting", "DbConnection", string.Empty);
if (string.IsNullOrEmpty(_dbMidConnection))
{
throw new Exception("DbSetting about [DbConnection] not found.");
}
_companyId = companyId;
_projectId = projectId;
}
public string GetDbName()
{
return $"{_companyId}_{_projectId}";
}
public IDbConnection GetMidDbConnection()
{
try
{
var connecctionStr = $"{_dbMidConnection}";
var connect = new MySqlConnection(connecctionStr);
connect.Open();
return connect;
}
catch (Exception e)
{
throw new Exception($"connect mysql db {_dbMidConnection} failed, error:" + e);
}
}
public IDbConnection GetDbConnection()
{
try
{
var dbConfig = RedisCache.Instance.GetDbName(_companyId, _projectId);
var connecctionStr = $"{_dbConnection};database={dbConfig.MysqlDbName}";
var connect = new MySqlConnection(connecctionStr);
connect.Open();
return connect;
}
catch (Exception e)
{
throw new Exception($"connect mysql db {_companyId}_{_projectId} failed, error:" + e);
}
}
protected async Task<IEnumerable<T>> GetDataListAsync<T>(string sql)
{
return await Task.Run(() =>
{
using (var conn = GetDbConnection())
{
var dataList = conn.QueryAsync<T>(sql);
return dataList;
}
});
}
protected IEnumerable<T> GetDataList<T>(string sql)
{
using (var conn = GetDbConnection())
{
var dataList = conn.Query<T>(sql);
return dataList;
}
}
protected long Count(string table)
{
using (var conn = GetDbConnection())
{
var result = conn.ExecuteScalar<long>($"select count(1) from {table}");
return result;
}
}
protected string GetMidDataBaseName()
{
using (var conn = GetMidDbConnection())
{
return conn.Database;
}
}
/// <summary>
/// 开启事务
/// </summary>
/// <param name="conn"></param>
/// <returns></returns>
public IDbTransaction BeginTransaction(IDbConnection conn)
{
IDbTransaction tran = conn.BeginTransaction();
return tran;
}
/// <summary>
/// 提交事务
/// </summary>
/// <param name="tran"></param>
/// <param name="conn"></param>
public void Commit(IDbTransaction tran, IDbConnection conn)
{
tran.Commit();
}
/// <summary>
/// 回滚事务
/// </summary>
/// <param name="tran"></param>
/// <param name="conn"></param>
public void Rollback(IDbTransaction tran, IDbConnection conn)
{
tran.Rollback();
}
public abstract void Dispose();
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment