244 lines
10 KiB
C#
244 lines
10 KiB
C#
using DOAN.Model;
|
|
using DOAN.Model.MES.base_;
|
|
using DOAN.Model.MES.base_.Dto;
|
|
using DOAN.Model.MES.product;
|
|
using DOAN.Model.Mobile.ReportFlow.Dto;
|
|
using DOAN.Model.Public;
|
|
using DOAN.Model.System;
|
|
using DOAN.Repository;
|
|
using DOAN.Service.Mobile.IService;
|
|
using DOAN.Service.Public.IPublicService;
|
|
using Infrastructure.Attribute;
|
|
using Mapster;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using SqlSugar.DistributedSystem.Snowflake;
|
|
using System.Diagnostics;
|
|
|
|
namespace DOAN.Service.Mobile;
|
|
|
|
/// <summary>
|
|
/// 广告管理Service业务层处理
|
|
/// </summary>
|
|
[AppService(ServiceType = typeof(IReportFlowService), ServiceLifetime = LifeTime.Transient)]
|
|
public class ReportFlowService : BaseService<ProReportwork01>, IReportFlowService
|
|
{
|
|
public ProWorkorder GetWorkOrderDetail(string workorder)
|
|
{
|
|
return Context.Queryable<ProWorkorder>().Where(x => x.Workorder == workorder).First();
|
|
}
|
|
public List<ProWorkorder> GetWorkOrdersByDate(DateTime startDate, DateTime endDate)
|
|
{
|
|
return Context.Queryable<ProWorkorder>()
|
|
.Where(it => it.WorkorderDate >= startDate && it.WorkorderDate <= endDate).ToList();
|
|
}
|
|
|
|
public ProReportwork01 GetProcessReportWorkDetail(string workorder, int process)
|
|
{
|
|
return Context.Queryable<ProReportwork01>().Where(x => x.Workorder == workorder && x.ProcessId == process).First();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 首工序报工
|
|
/// </summary>
|
|
/// <param name="workorder"></param>
|
|
/// <param name="processId"></param>
|
|
/// <param name="finish_num"></param>
|
|
/// <param name="stove_code"></param>
|
|
/// <param name="feed_order"></param>
|
|
/// <param name="Worker"></param>
|
|
/// <returns></returns>
|
|
public bool FeedProcessReportwork(string workorder, int processId, int finish_num, string stove_code, string feed_order, string Worker)
|
|
{
|
|
int result = 0;
|
|
bool Exist = Context.Queryable<ProReportwork01>().Where(it => it.Workorder == workorder && it.ProcessId == processId).Any();
|
|
|
|
string NickName = Context.Queryable<SysUser>().Where(it => it.UserName == Worker).Select(it => it.NickName).First();
|
|
Worker = string.IsNullOrEmpty(NickName) ? Worker + "|异常人员|" : NickName;
|
|
if (Exist)
|
|
{
|
|
result = Context.Updateable<ProReportwork01>().Where(it => it.Workorder == workorder && it.ProcessId == processId)
|
|
.SetColumns(it => it.FinishNum == finish_num)
|
|
.SetColumns(it => it.Worker == Worker)
|
|
.SetColumns(it => it.JobDateTime == DateTime.Now)
|
|
.SetColumns(it => it.RouteId == 32)
|
|
.SetColumns(it => it.UpdatedBy == Worker)
|
|
.SetColumns(it => it.UpdatedTime == DateTime.Now)
|
|
.ExecuteCommand();
|
|
Context.Updateable<ProWorkorder>().Where(it => it.Workorder == workorder)
|
|
.SetColumns(it => it.StoveCode == stove_code)
|
|
.SetColumns(it => it.FeedOrder == feed_order)
|
|
.ExecuteCommand();
|
|
}
|
|
else
|
|
{
|
|
ProReportwork01 proReportwork01 = new ProReportwork01();
|
|
proReportwork01.Id = XueHua;
|
|
proReportwork01.Workorder = workorder;
|
|
proReportwork01.ProcessId = processId;
|
|
proReportwork01.FinishNum = finish_num;
|
|
proReportwork01.RouteId = 32;
|
|
proReportwork01.Worker = Worker;
|
|
proReportwork01.JobDateTime = DateTime.Now;
|
|
proReportwork01.CreatedBy = Worker;
|
|
proReportwork01.CreatedTime = DateTime.Now;
|
|
result = Context.Insertable(proReportwork01).ExecuteCommand();
|
|
Context.Updateable<ProWorkorder>().Where(it => it.Workorder == workorder)
|
|
.SetColumns(it => it.StoveCode == stove_code)
|
|
.SetColumns(it => it.FeedOrder == feed_order)
|
|
.ExecuteCommand();
|
|
|
|
}
|
|
return result > 0;
|
|
}
|
|
|
|
public bool ProcessReportWork(string workorder, int process, int finish_num, int bad_num, string Worker)
|
|
{
|
|
int result = 0;
|
|
bool Exist = Context.Queryable<ProReportwork01>().Where(it => it.Workorder == workorder && it.ProcessId == process).Any();
|
|
string NickName = Context.Queryable<SysUser>().Where(it => it.UserName == Worker).Select(it => it.NickName).First();
|
|
Worker = string.IsNullOrEmpty(NickName) ? Worker + "|异常人员|" : NickName;
|
|
if (Exist)
|
|
{
|
|
result = Context.Updateable<ProReportwork01>().Where(it => it.Workorder == workorder && it.ProcessId == process)
|
|
.SetColumns(it => it.FinishNum == finish_num)
|
|
.SetColumns(it => it.BadNum == bad_num)
|
|
.SetColumns(it => it.Worker == Worker)
|
|
.SetColumns(it => it.RouteId == 32)
|
|
.SetColumns(it => it.JobDateTime == DateTime.Now)
|
|
.SetColumns(it => it.UpdatedBy == Worker)
|
|
.SetColumns(it => it.UpdatedTime == DateTime.Now)
|
|
.ExecuteCommand();
|
|
|
|
}
|
|
else
|
|
{
|
|
ProReportwork01 proReportwork01 = new ProReportwork01();
|
|
proReportwork01.Id = XueHua;
|
|
proReportwork01.Workorder = workorder;
|
|
proReportwork01.ProcessId = process;
|
|
proReportwork01.FinishNum = finish_num;
|
|
proReportwork01.BadNum = bad_num;
|
|
proReportwork01.Worker = Worker;
|
|
proReportwork01.RouteId = 32;
|
|
proReportwork01.JobDateTime = DateTime.Now;
|
|
proReportwork01.CreatedBy = Worker;
|
|
proReportwork01.CreatedTime = DateTime.Now;
|
|
result = Context.Insertable(proReportwork01).ExecuteCommand();
|
|
|
|
}
|
|
return result > 0;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 出货工序报工
|
|
/// </summary>
|
|
/// <param name="workorder"></param>
|
|
/// <param name="processId"></param>
|
|
/// <param name="finish_num"></param>
|
|
/// <param name="bad_num"></param>
|
|
/// <param name="feed_order"></param>
|
|
/// <param name="Worker"></param>
|
|
/// <returns></returns>
|
|
public bool ShipmentProcessReportwork(string workorder, int processId, int finish_num, int bad_num, string customer_order, string Worker)
|
|
{
|
|
int result = 0;
|
|
bool Exist = Context.Queryable<ProReportwork01>().Where(it => it.Workorder == workorder && it.ProcessId == processId).Any();
|
|
string NickName = Context.Queryable<SysUser>().Where(it => it.UserName == Worker).Select(it => it.NickName).First();
|
|
Worker = string.IsNullOrEmpty(NickName) ? Worker + "|异常人员|" : NickName;
|
|
if (Exist)
|
|
{
|
|
result = Context.Updateable<ProReportwork01>()
|
|
.Where(it => it.Workorder == workorder && it.ProcessId == processId)
|
|
.SetColumns(it => it.FinishNum == finish_num)
|
|
.SetColumns(it => it.RouteId == 32)
|
|
.SetColumns(it => it.BadNum == bad_num)
|
|
.SetColumns(it => it.Worker == Worker)
|
|
.SetColumns(it => it.JobDateTime == DateTime.Now)
|
|
.SetColumns(it => it.UpdatedBy == Worker)
|
|
.SetColumns(it => it.UpdatedTime == DateTime.Now)
|
|
.ExecuteCommand();
|
|
Context.Updateable<ProWorkorder>().Where(it => it.Workorder == workorder)
|
|
.SetColumns(it => it.CustomerOrder == customer_order)
|
|
.ExecuteCommand();
|
|
|
|
}
|
|
else
|
|
{
|
|
ProReportwork01 proReportwork01 = new ProReportwork01();
|
|
proReportwork01.Id = XueHua;
|
|
proReportwork01.Workorder = workorder;
|
|
proReportwork01.ProcessId = processId;
|
|
proReportwork01.FinishNum = finish_num;
|
|
proReportwork01.BadNum = bad_num;
|
|
proReportwork01.Worker = Worker;
|
|
proReportwork01.RouteId = 32;
|
|
proReportwork01.JobDateTime = DateTime.Now;
|
|
proReportwork01.CreatedBy = Worker;
|
|
proReportwork01.CreatedTime = DateTime.Now;
|
|
result = Context.Insertable(proReportwork01).ExecuteCommand();
|
|
Context.Updateable<ProWorkorder>().Where(it => it.Workorder == workorder)
|
|
.SetColumns(it => it.CustomerOrder == customer_order)
|
|
.ExecuteCommand();
|
|
|
|
}
|
|
return result > 0;
|
|
}
|
|
|
|
public List<ProReportWorkDetialDto> GetWorkOrderReportWorkList(string workorder)
|
|
{
|
|
return Context.Queryable<ProReportwork01>()
|
|
.LeftJoin<BaseWorkProcesses>((rw, wp) => rw.ProcessId == wp.Id)
|
|
.Where((rw, wp) => rw.Workorder == workorder)
|
|
.OrderBy(rw => rw.ProcessId)
|
|
.Select((rw, wp) => new ProReportWorkDetialDto()
|
|
{
|
|
ProcessName = wp.Name,
|
|
}, true)
|
|
.ToList();
|
|
}
|
|
|
|
public PagedInfo<ProReportWorkDetialDto> GetReportInfoByName(ProReportWorkDto2 query)
|
|
{
|
|
|
|
string NickName = Context.Queryable<SysUser>().Where(it => it.UserName == query.name).Select(it => it.NickName).First();
|
|
query.name = string.IsNullOrEmpty(NickName) ? query.name + "|异常人员|" : NickName;
|
|
|
|
return Context.Queryable<ProReportwork01>()
|
|
.LeftJoin<BaseWorkProcesses>((rw, wp) => rw.ProcessId == wp.Id)
|
|
.Where((rw, wp) => rw.Worker == query.name && rw.JobDateTime >= DateTime.Today && rw.JobDateTime < DateTime.Today.AddDays(1))
|
|
.OrderBy(rw => rw.ProcessId)
|
|
.Select((rw, wp) => new ProReportWorkDetialDto()
|
|
{
|
|
ProcessName = wp.Name,
|
|
}, true)
|
|
.ToPage_NO_Convert(query);
|
|
|
|
}
|
|
|
|
public List<BaseWorkProcessesDto> GetProcessByRoute(int route_id)
|
|
{
|
|
|
|
return Context.Queryable<BaseRelWorkRouteProcesses>()
|
|
.LeftJoin<BaseWorkProcesses>((rel, pro) => rel.FkWorkProcesses == pro.Id)
|
|
.Where((rel, pro) => rel.FkWorkRoute == route_id)
|
|
.Select((rel, pro) => pro)
|
|
.ToList()
|
|
.Adapt<List<BaseWorkProcesses>, List<BaseWorkProcessesDto>>();
|
|
|
|
}
|
|
|
|
public PagedInfo<ProReportWorkDetialDto> GetReportByProcessId(ProReportWorkDto3 query)
|
|
{
|
|
return Context.Queryable<ProReportwork01>()
|
|
.LeftJoin<BaseWorkProcesses>((rw, wp) => rw.ProcessId == wp.Id)
|
|
.Where((rw, wp) => rw.ProcessId == query.processId && rw.JobDateTime >= DateTime.Today && rw.JobDateTime < DateTime.Today.AddDays(1))
|
|
.OrderBy(rw => rw.ProcessId)
|
|
.Select((rw, wp) => new ProReportWorkDetialDto()
|
|
{
|
|
ProcessName = wp.Name,
|
|
}, true)
|
|
.ToPage_NO_Convert(query);
|
|
}
|
|
}
|
|
|