2205 lines
115 KiB
C#
2205 lines
115 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Reflection;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using Aspose.Cells.Drawing;
|
||
using DbModels;
|
||
using JNPF.Common.Core.Manager;
|
||
using JNPF.DependencyInjection;
|
||
using JNPF.DynamicApiController;
|
||
using JNPF.Systems.Interfaces.System;
|
||
using JNPF.VisualDev;
|
||
using Mapster;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using SqlSugar;
|
||
using Tnb.BasicData.Entities;
|
||
using Tnb.BasicData;
|
||
using Tnb.EquipMgr.Entities;
|
||
using Tnb.ProductionMgr.Entities;
|
||
using Tnb.ProductionMgr.Entities.Dto.PrdManage;
|
||
using Tnb.ProductionMgr.Entities.Dto;
|
||
using Tnb.ProductionMgr.Interfaces;
|
||
using JNPF.Common.Enums;
|
||
using JNPF.Common.Extension;
|
||
using JNPF.Common.Security;
|
||
using JNPF.FriendlyException;
|
||
using Tnb.ProductionMgr.Entities.Enums;
|
||
using JNPF.VisualDev.Entitys.Dto.VisualDevModelData;
|
||
using JNPF.VisualDev.Interfaces;
|
||
using JNPF.VisualDev.Entitys;
|
||
using Aop.Api.Domain;
|
||
using Senparc.Weixin.MP.AdvancedAPIs.Card;
|
||
using Aspose.Cells.Drawing.Texts;
|
||
using JNPF.Systems.Entitys.Permission;
|
||
using WebSocketSharp.Frame;
|
||
using JNPF.Logging;
|
||
using System.Dynamic;
|
||
using Tnb.EquipMgr.Entities.Dto;
|
||
using JNPF.Common.Filter;
|
||
using JNPF.Systems.Entitys.System;
|
||
using Microsoft.ClearScript.Util.Web;
|
||
using Newtonsoft.Json;
|
||
using Tnb.BasicData.Entities.Dto;
|
||
using NPOI.SS.Formula.Functions;
|
||
using Tnb.PerMgr.Entities;
|
||
using Tnb.QcMgr.Interfaces;
|
||
using Tnb.QcMgr.Entities;
|
||
using Tnb.QcMgr.Entities.Enums;
|
||
|
||
// using Tnb.PerMgr.Entities;
|
||
|
||
namespace Tnb.ProductionMgr
|
||
{
|
||
[ApiDescriptionSettings(Tag = ModuleConst.Tag, Area = ModuleConst.Area, Order = 700)]
|
||
[Route("api/[area]/[controller]/[action]")]
|
||
[OverideVisualDev(ModuleId)]
|
||
|
||
public class PrdMoTaskService : IOverideVisualDevService, IPrdMoTaskService, IDynamicApiController, ITransient
|
||
{
|
||
private const string ModuleId = "25567924238373";
|
||
private const string MoModuleId = "25018860321301";
|
||
private readonly ISqlSugarRepository<PrdTask> _repository;
|
||
private readonly IUserManager _userManager;
|
||
private readonly IDictionaryDataService _dictionaryDataService;
|
||
private readonly IRunService _runService;
|
||
private readonly IVisualDevService _visualDevService;
|
||
private static Dictionary<string, object> _dicDefect = new Dictionary<string, object>();
|
||
private static Dictionary<string, object> _dicWorkLine = new Dictionary<string, object>();
|
||
private static Dictionary<string, object> _dicProcess = new Dictionary<string, object>();
|
||
private readonly ISqlSugarClient _db;
|
||
private readonly IBillRullService _billRuleService;
|
||
private readonly IQcCheckPlanService _qcCheckPlanService;
|
||
|
||
public OverideVisualDevFunc OverideFuncs { get; } = new OverideVisualDevFunc();
|
||
public PrdMoTaskService(
|
||
ISqlSugarRepository<PrdTask> repository,
|
||
IUserManager userManager,
|
||
IDictionaryDataService dictionaryDataService,
|
||
IRunService runService,
|
||
IBillRullService billRullService,
|
||
IVisualDevService visualDevService,
|
||
IQcCheckPlanService qcCheckPlanService
|
||
)
|
||
{
|
||
_repository = repository;
|
||
_userManager = userManager;
|
||
_dictionaryDataService = dictionaryDataService;
|
||
_runService = runService;
|
||
_visualDevService = visualDevService;
|
||
_db = _repository.AsSugarClient();
|
||
OverideFuncs.DeleteAsync = Delete;
|
||
OverideFuncs.GetListAsync = GetList;
|
||
_billRuleService = billRullService;
|
||
_qcCheckPlanService=qcCheckPlanService;
|
||
}
|
||
|
||
#region Get
|
||
|
||
/// <summary>
|
||
/// 根据产品ID获取模具列表
|
||
/// </summary>
|
||
/// <param name="itemId">产品ID</param>
|
||
/// <returns></returns>
|
||
/// <remarks>
|
||
/// <br/>return results:
|
||
/// <br/>[
|
||
/// <br/> {
|
||
/// <br/> mold_code:模具编号
|
||
/// <br/> mold_name:模具名称
|
||
/// <br/> item_name:产品名称
|
||
/// <br/> item_code:产品编号
|
||
/// <br/> cavity_qty:模穴数
|
||
/// <br/> }
|
||
/// <br/>]
|
||
/// </remarks>
|
||
[HttpGet("{materialId}")]
|
||
public async Task<dynamic> GetMoldListByItemId(string materialId)
|
||
{
|
||
var result = new List<Tnb.ProductionMgr.Entities.Dto.MoldListOutput>();
|
||
result = await _db.Queryable<ToolMoldsMaterial>()
|
||
.InnerJoin<ToolMolds>((a, b) => a.mold_id == b.id)
|
||
.InnerJoin<BasMaterial>((a, b, c) => a.material_id == c.id)
|
||
.Where((a, b, c) => a.material_id == materialId)
|
||
.Select((a, b, c) => new Tnb.ProductionMgr.Entities.Dto.MoldListOutput
|
||
{
|
||
mold_id = b.id,
|
||
mold_code = b.mold_code,
|
||
mold_name = b.mold_name,
|
||
mold_type_code = b.mold_type_code,
|
||
material_name = c.name,
|
||
material_code = c.code,
|
||
available_stations = SqlFunc.Subqueryable<EqpEquipment>().Where(it => it.mold_id == a.id).Count(),
|
||
}).ToListAsync();
|
||
return result;
|
||
}
|
||
/// <summary>
|
||
/// 根据模具Id获取设备列表
|
||
/// </summary>
|
||
/// <param name="moldId"></param>
|
||
/// <returns></returns>
|
||
[HttpGet("{moldId}")]
|
||
public async Task<dynamic> GetEquipmentListByMoldId(string moldId)
|
||
{
|
||
var items = await _db.Queryable<ToolMoldsEquipment>().InnerJoin<EqpEquipment>((a, b) => a.equipment_id == b.id)
|
||
.Where((a, b) => a.mold_id == moldId)
|
||
.Select((a, b) => new Entities.Dto.EquipmentListOutput
|
||
{
|
||
eqp_id = b.id,
|
||
eqp_code = b.code,
|
||
eqp_type_code = SqlFunc.Subqueryable<EqpEquipType>().Where(iit => iit.id == b.equip_type_id).Select(iit => iit.name),
|
||
eqp_machine_num = b.eqp_machine_num,
|
||
tonnage = b.tonnage,
|
||
task_list_qty = SqlFunc.Subqueryable<PrdTask>().Where(x => x.eqp_id == b.id).Count(),
|
||
estimated_end_date = SqlFunc.Subqueryable<PrdTask>().Where(x => x.eqp_id == b.id).OrderByDesc(o => o.plan_end_date).Select(x => x.plan_end_date)
|
||
}).Mapper(x =>
|
||
{
|
||
x.first_date = x.estimated_end_date.HasValue ? x.estimated_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss") : "";
|
||
}).ToListAsync();
|
||
return items;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 工单调整-生产任务重新排序
|
||
/// </summary>
|
||
/// <param name="eqpId">设备ID</param>
|
||
/// <returns>排序后生产任务列表</returns>
|
||
/// <remarks>
|
||
/// returns:
|
||
/// <br/>[
|
||
/// <br/> {
|
||
/// <br/> no:生产序号
|
||
/// <br/> mo_id：工单编号
|
||
/// <br/> group_flag：同组标识
|
||
/// <br/> plan_qty:计划生产数量
|
||
/// <br/> comple_qty:完成数量
|
||
/// <br/> item_name:产品名称
|
||
/// <br/> mold_code:模具编号
|
||
/// <br/> }
|
||
/// <br/>]
|
||
/// </remarks>
|
||
[HttpGet("{eqpId}")]
|
||
public async Task<dynamic> PrdTaskSort(string eqpId)
|
||
{
|
||
var taskStatusDic = await _dictionaryDataService.GetDicByTypeId(DictConst.PrdTaskStatusTypeId);
|
||
var list = await _repository.AsSugarClient().Queryable<PrdMoTask>()
|
||
.LeftJoin<PrdMo>((a, b) => a.mo_id == b.id)
|
||
.LeftJoin<BasMaterial>((a, b, c) => a.material_id == c.id)
|
||
.LeftJoin<ToolMolds>((a, b, c, d) => a.mold_id == d.id)
|
||
.Where((a, b, c, d) => a.eqp_id == eqpId)
|
||
.OrderBy((a, b, c, d) => a.estimated_start_date)
|
||
.Select((a, b, c, d) => new PrdTaskSortOutput
|
||
{
|
||
mo_status_code = a.mo_task_code,
|
||
status = a.mo_task_status,
|
||
group_flag = a.group_flag,
|
||
plan_qty = b.plan_qty,
|
||
comple_qty = a.complete_qty,
|
||
item_name = c.name,
|
||
mold_code = d.mold_code,
|
||
})
|
||
.ToListAsync();
|
||
var data = list.Select((x, idx) => new PrdTaskSortOutput
|
||
{
|
||
no = idx + 1,
|
||
mo_status_code = x.mo_status_code,
|
||
status = taskStatusDic.ContainsKey(x.status) ? taskStatusDic[x.status].ToString() : "",
|
||
group_flag = x.group_flag,
|
||
plan_qty = x.plan_qty,
|
||
comple_qty = x.comple_qty,
|
||
item_name = x.item_name,
|
||
mold_code = x.mold_code,
|
||
})
|
||
.ToList();
|
||
return data;
|
||
}
|
||
/// <summary>
|
||
/// 查看生产任务操作记录
|
||
/// </summary>
|
||
/// <param name="taskId">任务ID</param>
|
||
/// <returns></returns>
|
||
[HttpGet("{taskId}")]
|
||
public async Task<dynamic> GetMoOperRecord(string taskId)
|
||
{
|
||
var list = await _repository.AsSugarClient().Queryable<PrdTaskLog>().Where(it => it.mo_task_id == taskId).ToListAsync();
|
||
var data = list.Adapt<List<PrdTaskOperOutput>>();
|
||
var dic = await _dictionaryDataService.GetDicByTypeId(DictConst.PrdTaskStatusTypeId);
|
||
_repository.AsSugarClient().ThenMapper(data, x =>
|
||
{
|
||
x.statusName = dic.ContainsKey(x.status) ? dic[x.status].ToString() : x.status;
|
||
x.schedule_type = _repository.AsSugarClient().Queryable<PrdMoTask>().Single(y => y.id == x.mo_task_id).schedule_type;
|
||
});
|
||
return data;
|
||
}
|
||
/// <summary>
|
||
/// 获取自检报废批次记录
|
||
/// </summary>
|
||
/// <param name="moTaskId">任务单Id</param>
|
||
/// <returns></returns>
|
||
[HttpGet("{moTaskId}")]
|
||
public async Task<dynamic> GetScarpStatRecord(string moTaskId)
|
||
{
|
||
var output = new PrdMoTaskDefectOutput();
|
||
var db = _repository.AsSugarClient();
|
||
if (_dicDefect.Count < 1)
|
||
{
|
||
_dicDefect = await db.Queryable<BasDefectType>().ToDictionaryAsync(x => x.id, x => x.defect_type_name);
|
||
}
|
||
output.mo_task_code = (await db.Queryable<PrdMoTask>().FirstAsync(it => it.id == moTaskId))?.mo_task_code;
|
||
var defects = await db.Queryable<PrdMoTaskDefect>().Where(it => it.mo_task_id == moTaskId).ToListAsync();
|
||
var users = await db.Queryable<UserEntity>().ToListAsync();
|
||
if (defects?.Count > 0)
|
||
{
|
||
output.batchItems = defects.GroupBy(g => new { g.batch,g.create_id }).Select(t => new BatchItem
|
||
{
|
||
scrap_qty = t.Sum(d => d.defective_item_qty),
|
||
batch = t.Key.batch,
|
||
create_time = t.Key.batch.ParseToDateTime().ToString("yyyy-MM-dd HH:mm:ss"),
|
||
create_name = users.First(x=>x.Id==t.Key.create_id)?.RealName ?? "",
|
||
categoryItems = t.GroupBy(g => g.defective_cagetory_id).Select(c => new CategoryItem
|
||
{
|
||
name = _dicDefect[c.Key]?.ToString(),
|
||
qty = c.Sum(d => d.defective_item_qty),
|
||
defectItems = c.Select(d => new DefectItem
|
||
{
|
||
name = d.defective_item,
|
||
qty = d.defective_item_qty,
|
||
}).ToList(),
|
||
}).ToList(),
|
||
}).ToList();
|
||
|
||
}
|
||
return output;
|
||
}
|
||
/// <summary>
|
||
/// 根据工单Id获取任务单列表
|
||
/// </summary>
|
||
/// <param name="moId"></param>
|
||
/// <remarks>
|
||
/// output:
|
||
/// <br/>{
|
||
/// <br/> mo_task_code:生产任务单号
|
||
/// <br/> material_code:物料编码
|
||
/// <br/> mold_code:模具编码
|
||
/// <br/> mold_name:模具名称
|
||
/// <br/> eqp_code:设备编码
|
||
/// <br/> eqp_name:设备名称
|
||
/// <br/> eqp_type_code:设备型号
|
||
/// <br/> mo_task_qty:任务单数量
|
||
/// <br/> mo_task_status:任务状态
|
||
/// <br/> scheduled_qty:计划生产数量
|
||
/// <br/> complete_qty:完成数量
|
||
/// <br/> estimated_start_date:预计开工时间
|
||
/// <br/> estimated_end_date:预计完工时间
|
||
/// <br/>}
|
||
/// </remarks>
|
||
[HttpGet("{moId}")]
|
||
public async Task<dynamic> GetPrdTaskInfoByMoId(string moId, int schedType = 1)
|
||
{
|
||
List<PrdMoTaskOutput> result = new();
|
||
var dic = await _dictionaryDataService.GetDicByTypeId(DictConst.PrdTaskStatusTypeId);
|
||
if (schedType == 1)
|
||
{
|
||
result = await _db.Queryable<PrdMoTask>().LeftJoin<PrdMo>((a, b) => a.mo_id == b.id)
|
||
.LeftJoin<BasMaterial>((a, b, c) => a.material_id == c.id)
|
||
.LeftJoin<ToolMolds>((a, b, c, d) => a.mold_id == d.id)
|
||
.LeftJoin<EqpEquipment>((a, b, c, d, e) => a.eqp_id == e.id)
|
||
.Where((a, b, c, d, e) => a.mo_id == moId)
|
||
.OrderByDescending((a,b,c,d,e)=>a.create_time)
|
||
.Select((a, b, c, d, e) => new PrdMoTaskOutput
|
||
{
|
||
mo_task_code = a.mo_task_code,
|
||
mo_task_status = a.mo_task_status,
|
||
mold_code = d.mold_code,
|
||
mold_name = d.mold_name,
|
||
material_code = c.code,
|
||
material_name = c.name,
|
||
eqp_code = e.code,
|
||
eqp_name = e.name,
|
||
eqp_type_code = SqlFunc.Subqueryable<EqpEquipType>().Where(it => it.id == e.equip_type_id).Select(it => it.code),
|
||
mo_task_qty = SqlFunc.Subqueryable<PrdMoTask>().Where(a => a.mo_id == moId).Count(),
|
||
estimated_start_date = a.estimated_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
estimated_end_date = a.estimated_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
plan_qty = a.scheduled_qty,
|
||
complete_qty = SqlFunc.IsNull(a.reported_work_qty,0)+SqlFunc.IsNull(a.scrap_qty,0),
|
||
process_code = SqlFunc.Subqueryable<BasProcess>().Where(it => it.id == a.process_id).Select(it => it.process_code),
|
||
process_name = SqlFunc.Subqueryable<BasProcess>().Where(it => it.id == a.process_id).Select(it => it.process_name),
|
||
create_time = a.create_time==null ? "" : a.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
})
|
||
.Mapper(it =>
|
||
{
|
||
it.mo_task_status = dic.ContainsKey(it.mo_task_status) ? dic[it.mo_task_status].ToString() : "";
|
||
})
|
||
.ToListAsync();
|
||
}
|
||
else
|
||
{
|
||
result = await _db.Queryable<PrdMoTask>().LeftJoin<PrdMo>((a, b) => a.mo_id == b.id)
|
||
.LeftJoin<BasMaterial>((a, b, c) => a.material_id == c.id)
|
||
.LeftJoin<OrganizeEntity>((a, b, c, d) => a.workline_id == d.Id)
|
||
.LeftJoin<BasProcess>((a,b,c,d,e)=>a.process_id==e.id)
|
||
.Where((a, b, c, d) => (b.id == moId || b.parent_id == moId) && SqlFunc.IsNullOrEmpty(a.parent_id))
|
||
.OrderByDescending((a,b,c,d,e)=>a.create_time)
|
||
.Select((a, b, c, d,e) => new PrdMoTaskOutput
|
||
{
|
||
mo_task_code = a.mo_task_code,
|
||
mo_task_status = a.mo_task_status,
|
||
workline_code = d.EnCode,
|
||
workline_name = d.FullName,
|
||
material_code = c.code,
|
||
material_name = c.name,
|
||
process_code = e.process_code,
|
||
process_name = e.process_name,
|
||
mo_task_qty = SqlFunc.Subqueryable<PrdMoTask>().Where(a => a.mo_id == moId).Count(),
|
||
estimated_start_date = a.estimated_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
estimated_end_date = a.estimated_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
plan_qty = a.scheduled_qty,
|
||
complete_qty = SqlFunc.IsNull(a.reported_work_qty,0)+SqlFunc.IsNull(a.scrap_qty,0),
|
||
create_time = a.create_time==null ? "" : a.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
})
|
||
.Mapper(it =>
|
||
{
|
||
it.mo_task_status = dic.ContainsKey(it.mo_task_status) ? dic[it.mo_task_status].ToString()! : "";
|
||
})
|
||
.ToListAsync();
|
||
}
|
||
|
||
return result;
|
||
|
||
}
|
||
/// <summary>
|
||
///组装、包装 获取待下发任务列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
public async Task<dynamic> GetPackScheldToBeIssueList([FromQuery] PackScheldToBeIssueListInput input)
|
||
{
|
||
var dic = await _dictionaryDataService.GetDicByTypeId(DictConst.PrdTaskStatusTypeId);
|
||
var result = await _db.Queryable<PrdMoTask>()
|
||
.LeftJoin<OrganizeEntity>((a, b) => a.workline_id == b.Id)
|
||
.LeftJoin<PrdMo>((a, b, c) => a.mo_id == c.id)
|
||
.LeftJoin<BasMbom>((a, b, c, d) => a.bom_id == d.id)
|
||
.WhereIF(!string.IsNullOrEmpty(input.mo_task_code), (a, b, c, d) => a.mo_task_code.Contains(input.mo_task_code))
|
||
.Where((a, b, c, d) => a.schedule_type == 2 && string.IsNullOrEmpty(a.parent_id))
|
||
.OrderByDescending(a=>a.create_time)
|
||
.Select((a, b, c, d) => new PackSechelToBeIssueListOutput
|
||
{
|
||
mo_task_id = a.id,
|
||
mo_task_code = a.mo_task_code,
|
||
material_id = a.material_id,
|
||
material_code = SqlFunc.Subqueryable<BasMaterial>().Where(it => it.id == a.material_id).Select(it => it.code),
|
||
material_name = SqlFunc.Subqueryable<BasMaterial>().Where(it => it.id == a.material_id).Select(it => it.name),
|
||
workline_id = a.workline_id,
|
||
workline_code = b.EnCode,
|
||
workline_name = b.FullName,
|
||
mo_task_status = a.mo_task_status,
|
||
// scheduled_qty = SqlFunc.Subqueryable<PrdMoTask>().Where(it => it.mo_id == a.mo_id).Sum(it => it.scheduled_qty),
|
||
scheduled_qty = a.scheduled_qty,
|
||
plan_qty = SqlFunc.Subqueryable<PrdMo>().Where(it => it.id == a.mo_id).Select(it => it.plan_qty),
|
||
complete_qty = a.last_process_complete_qty,
|
||
estimated_start_date = a.estimated_start_date==null ? null : a.estimated_start_date.Value.ToString("yyyy-MM-dd HH:mm"),
|
||
estimated_end_date = a.estimated_end_date==null ? null : a.estimated_end_date.Value.ToString("yyyy-MM-dd HH:mm"),
|
||
bom_id = d.id,
|
||
bom_version = d.version
|
||
})
|
||
.Mapper(it => it.mo_task_status = dic.ContainsKey(it.mo_task_status) ? dic[it.mo_task_status].ToString()! : "")
|
||
.ToListAsync();
|
||
return result;
|
||
}
|
||
/// <summary>
|
||
/// 根据生产任务ID获取子任务列表
|
||
/// </summary>
|
||
/// <param name="mo_task_id"></param>
|
||
/// <returns></returns>
|
||
[HttpGet("{mo_task_id}")]
|
||
public async Task<dynamic> GetSubMoTaskListByTaskId(string mo_task_id)
|
||
{
|
||
var dic = await _dictionaryDataService.GetDicByTypeId(DictConst.PrdTaskStatusTypeId);
|
||
var result = await _db.Queryable<PrdMoTask>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<OrganizeEntity>((a, b, c) => a.workline_id == c.Id)
|
||
.LeftJoin<PrdMo>((a, b, c, d) => a.mo_id == d.id)
|
||
.LeftJoin<BasProcess>((a,b,c,d,e)=>a.process_id==e.id)
|
||
.Where((a, b, c, d) => a.parent_id == mo_task_id)
|
||
.Select((a, b, c, d,e) => new PackSechelToBeIssueListOutput
|
||
{
|
||
mo_task_id = a.id,
|
||
mo_task_code = a.mo_task_code,
|
||
material_code = b.code,
|
||
material_name = b.name,
|
||
workline_code = c.EnCode,
|
||
workline_name = c.FullName,
|
||
mo_task_status = a.mo_task_status,
|
||
scheduled_qty = a.scheduled_qty,
|
||
plan_qty = d.plan_qty,
|
||
process_task_qty = a.process_task_qty,
|
||
complete_qty = SqlFunc.IsNull(a.reported_work_qty,0)+SqlFunc.IsNull(a.scrap_qty,0),
|
||
estimated_start_date = a.estimated_start_date==null ? null : a.estimated_start_date.Value.ToString("yyyy-MM-dd HH:mm"),
|
||
estimated_end_date = a.estimated_end_date==null ? null : a.estimated_end_date.Value.ToString("yyyy-MM-dd HH:mm"),
|
||
process_name = e.process_name,
|
||
bom_version = SqlFunc.Subqueryable<BasMbom>().Where(it => it.material_id == a.material_id).Select(it => it.version)
|
||
})
|
||
.Mapper(it => it.mo_task_status = dic.ContainsKey(it.mo_task_status) ? dic[it.mo_task_status].ToString()! : "")
|
||
.OrderBy(a => a.mo_task_code, OrderByType.Asc)
|
||
.ToListAsync();
|
||
return result;
|
||
}
|
||
// /// <summary>
|
||
// /// 获取组装、包装 待排产工单树形列表
|
||
// /// </summary>
|
||
// /// <returns></returns>
|
||
// [HttpGet]
|
||
// public async Task<dynamic> GetUnSchedulingList([FromQuery] VisualDevModelListQueryInput input)
|
||
// {
|
||
// List<PrdMoTreeOutput> trees = new();
|
||
// VisualDevEntity? templateEntity = await _visualDevService.GetInfoById(MoModuleId, true);
|
||
// var data = await _runService.GetListResult(templateEntity, input);
|
||
//
|
||
//
|
||
// if (data?.list?.Count > 0)
|
||
// {
|
||
// var parentIdField = nameof(PrdMo.parent_id);
|
||
// var nodes = data.list.Where(it => it.ContainsKey(parentIdField) && it[parentIdField].IsNullOrEmpty()).ToList();
|
||
// foreach (var row in nodes)
|
||
// {
|
||
// var pkName = "material_id_id";
|
||
// var dic = row.ToDictionary(x => x.Key, x => x.Value);
|
||
//
|
||
// PrdMoTreeOutput node = DictionaryToObject<PrdMoTreeOutput>(row);
|
||
// node.parentId = "0";
|
||
// node.mo_id = node.id;
|
||
// if (dic.ContainsKey(pkName))
|
||
// {
|
||
// var materialId = dic[pkName]?.ToString();
|
||
// var material = await _db.Queryable<BasMaterial>().FirstAsync(it => it.id == materialId);
|
||
// node.material_id_id = materialId;
|
||
// node.material_code = material?.code;
|
||
// node.material_name = material?.name;
|
||
// node.material_standard = material?.material_standard;
|
||
// }
|
||
// //
|
||
// var scheldQtyCol = nameof(PrdMo.scheduled_qty);
|
||
//
|
||
// node.scheduled_qty = _db.Queryable<PrdMoTask>().Where(it => it.mo_id == dic["id"].ToString()).Sum(it => it.scheduled_qty)?.ToString();
|
||
// var queryObj = new { parent_id = node.id };
|
||
// input.superQueryJson = "";
|
||
// input.queryJson = queryObj.ToJsonString();
|
||
// var subData = await _runService.GetListResult(templateEntity, input);
|
||
// if (subData?.list?.Count > 0)
|
||
// {
|
||
// var childNodes = new List<PrdMoTreeOutput>();
|
||
// foreach (var item in subData.list)
|
||
// {
|
||
// dic = item.ToDictionary(x => x.Key, x => x.Value);
|
||
// PrdMoTreeOutput subNode = DictionaryToObject<PrdMoTreeOutput>(item);
|
||
// subNode.parentId = node.id;
|
||
// subNode.mo_id = subNode.id;
|
||
// if (dic.ContainsKey(pkName))
|
||
// {
|
||
// var materialId = dic[pkName]?.ToString();
|
||
// var material = await _db.Queryable<BasMaterial>().FirstAsync(it => it.id == materialId);
|
||
// subNode.material_id_id = materialId;
|
||
// subNode.material_code = material?.code;
|
||
// subNode.material_name = material?.name;
|
||
// subNode.material_standard = material?.material_standard;
|
||
// }
|
||
// node.scheduled_qty = _db.Queryable<PrdMoTask>().Where(it => it.mo_id == dic["id"].ToString()).Sum(it => it.scheduled_qty)?.ToString();
|
||
// childNodes.Add(subNode);
|
||
// }
|
||
// trees.AddRange(childNodes);
|
||
// }
|
||
// trees.Add(node);
|
||
// }
|
||
// }
|
||
// var treeList = trees.ToTree();
|
||
// var list = treeList.Skip(input.currentPage - 1).Take(input.pageSize).ToList();
|
||
// SqlSugarPagedList<PrdMoTreeOutput> pagedList = new()
|
||
// {
|
||
// list = treeList,
|
||
// pagination = new Pagination
|
||
// {
|
||
// CurrentPage = input.currentPage,
|
||
// PageSize = input.pageSize,
|
||
// Total = treeList.Count
|
||
// }
|
||
// };
|
||
// return PageResult<PrdMoTreeOutput>.SqlSugarPageResult(pagedList);
|
||
// }
|
||
|
||
|
||
/// <summary>
|
||
/// 获取组装、包装 待排产工单树形列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpGet]
|
||
public async Task<dynamic> GetUnSchedulingList([FromQuery] VisualDevModelListQueryInput input)
|
||
{
|
||
Dictionary<string, object> queryJson = !string.IsNullOrEmpty(input.queryJson) ? JsonConvert.DeserializeObject<Dictionary<string, object>>(input.queryJson) : new Dictionary<string, object>();
|
||
List<string> moStatusList = new List<string>();
|
||
if (queryJson!=null && queryJson.ContainsKey("mo_stauts"))
|
||
{
|
||
moStatusList = JsonConvert.DeserializeObject<List<string>>(JsonConvert.SerializeObject(queryJson["mo_status"]));
|
||
}
|
||
List<string> moTypeList = new List<string>();
|
||
if (queryJson!=null && queryJson.ContainsKey("mo_type"))
|
||
{
|
||
moTypeList = JsonConvert.DeserializeObject<List<string>>(JsonConvert.SerializeObject(queryJson["mo_type"]));
|
||
}
|
||
string moCode = queryJson!=null && queryJson.ContainsKey("mo_code") ? queryJson["mo_code"].ToString() : "";
|
||
string combineMoCode = queryJson!=null && queryJson.ContainsKey("combine_mo_code") ? queryJson["combine_mo_code"].ToString() : "";
|
||
var db = _repository.AsSugarClient();
|
||
var result = await db.Queryable<PrdMo>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<DictionaryDataEntity>((a, b, c) => a.mo_type == c.Id)
|
||
.LeftJoin<DictionaryDataEntity>((a, b, c, d) => a.mo_status == d.Id)
|
||
.LeftJoin<UserEntity>((a, b, c, d, e) => a.create_id == e.Id)
|
||
.WhereIF(moStatusList != null && moStatusList.Count > 0,
|
||
(a, b, c, d, e) => moStatusList.Contains(a.mo_status))
|
||
.WhereIF(moTypeList != null && moTypeList.Count > 0, (a, b, c, d, e) => moTypeList.Contains(a.mo_type))
|
||
.WhereIF(!string.IsNullOrEmpty(moCode),(a,b,c,d,e)=>a.mo_code.Contains(moCode))
|
||
.WhereIF(!string.IsNullOrEmpty(combineMoCode),(a,b,c,d,e)=>a.combine_mo_code.Contains(combineMoCode))
|
||
.Where((a,b,c,d,e)=>SqlFunc.IsNullOrEmpty(a.parent_id))
|
||
.OrderByDescending((a,b,c,d,e)=>a.create_time)
|
||
.Select((a, b, c, d, e) => new PrdMoListTreeOutput
|
||
{
|
||
org_id = a.org_id,
|
||
mo_id = a.id,
|
||
mo_code = a.mo_code,
|
||
material_code = b.code,
|
||
material_name = b.name,
|
||
material_standard = b.material_standard,
|
||
mo_type = c.FullName,
|
||
mo_status = d.FullName,
|
||
plan_qty = a.plan_qty.Value.ToString(),
|
||
input_qty = a.input_qty.Value.ToString(),
|
||
complete_qty = a.complete_qty.Value.ToString(),
|
||
scrap_qty = a.scrap_qty.Value.ToString(),
|
||
plan_start_date = a.plan_start_date.Value.ToString("yyyy-MM-dd"),
|
||
plan_end_date = a.plan_end_date.Value.ToString("yyyy-MM-dd"),
|
||
is_create_dispatch = a.is_create_dispatch==0 ? "否" : "是",
|
||
production_linecode = a.production_linecode,
|
||
is_merge = a.is_merge==0 ? "否" : "是",
|
||
combine_mo_code = a.combine_mo_code,
|
||
time_stamp = a.time_stamp,
|
||
create_id = e.RealName,
|
||
create_time = a.create_time.Value.ToString("yyyy-MM-dd : HH:mm:ss"),
|
||
material_id = b.code,
|
||
material_id_id = a.material_id,
|
||
scheduled_qty = a.scheduled_qty.Value.ToString(),
|
||
parent_id = "0",
|
||
id = a.id,
|
||
hasChildren = SqlFunc.Subqueryable<PrdMo>().Where(x=>x.parent_id==a.id).Any(),
|
||
num = SqlFunc.Subqueryable<PrdMo>().Where(x=>x.parent_id==a.id).Count(),
|
||
isLeaf = SqlFunc.Subqueryable<PrdMo>().Where(x=>x.parent_id==a.id).Any(),
|
||
children = SqlFunc.Subqueryable<PrdMo>()
|
||
.LeftJoin<BasMaterial>((h,i) => h.material_id == i.id)
|
||
.LeftJoin<DictionaryDataEntity>((h,i,j) => h.mo_type == j.Id)
|
||
.LeftJoin<DictionaryDataEntity>((h,i,j,k) => h.mo_status == k.Id)
|
||
.LeftJoin<UserEntity>((h,i,j,k,l) => h.create_id == l.Id)
|
||
.Where((h,i,j,k,l)=>a.id==h.parent_id).ToList((h,i,j,k,l)=>new PrdMoListTreeOutput()
|
||
{
|
||
org_id = h.org_id,
|
||
mo_id = h.id,
|
||
mo_code = h.mo_code,
|
||
material_code = i.code,
|
||
material_name = i.name,
|
||
material_standard = i.material_standard,
|
||
mo_type = j.FullName,
|
||
mo_status = k.FullName,
|
||
plan_qty = h.plan_qty.Value.ToString(),
|
||
input_qty = h.input_qty.Value.ToString(),
|
||
complete_qty = h.complete_qty.Value.ToString(),
|
||
scrap_qty = h.scrap_qty.Value.ToString(),
|
||
plan_start_date = h.plan_start_date.Value.ToString("yyyy-MM-dd"),
|
||
plan_end_date = h.plan_end_date.Value.ToString("yyyy-MM-dd"),
|
||
is_create_dispatch = h.is_create_dispatch==0 ? "否" : "是",
|
||
production_linecode = h.production_linecode,
|
||
is_merge = h.is_merge==0 ? "否" : "是",
|
||
combine_mo_code = h.combine_mo_code,
|
||
time_stamp = h.time_stamp,
|
||
create_id = l.RealName,
|
||
create_time = h.create_time.Value.ToString("yyyy-MM-dd : HH:mm:ss"),
|
||
material_id = i.code,
|
||
material_id_id = h.material_id,
|
||
scheduled_qty = h.scheduled_qty.Value.ToString(),
|
||
parent_id = a.id,
|
||
id = h.id,
|
||
hasChildren = false,
|
||
num = 0,
|
||
isLeaf = true,
|
||
})
|
||
}).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
|
||
|
||
return PageResult<PrdMoListTreeOutput>.SqlSugarPageResult(result);
|
||
}
|
||
|
||
#endregion
|
||
|
||
|
||
#region Post
|
||
|
||
/// <summary>
|
||
/// 生产工单-生产排产
|
||
/// </summary>
|
||
/// <param name="input">
|
||
///<br/>{
|
||
///<br/> Id:生产任务主键Id
|
||
///<br/> MoType:工单类型 1、注塑/挤出 2、组装/包装
|
||
///<br/> MoId:工单Id
|
||
///<br/> ItemId:产品编号
|
||
///<br/> ItemName:产品名称
|
||
///<br/> MoldId:模具Id
|
||
///<br/> MoldName:模具名称
|
||
///<br/> EqpId:设备Id
|
||
///<br/> EqpName:设备名称
|
||
///<br/> LineId:产线编号
|
||
///<br/> LineName:产线名称
|
||
///<br/>}
|
||
/// </param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> ProductionScheduling(ProductionSchedulingCrInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
var row = -1;
|
||
if (input.schedule_type.HasValue)
|
||
{
|
||
if (input.schedule_type.Value == 1) //注塑、基础排产
|
||
{
|
||
var mo = await db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id);
|
||
var moTask = input.Adapt<PrdMoTask>();
|
||
moTask.id = SnowflakeIdHelper.NextId();
|
||
moTask.create_id = _userManager.UserId;
|
||
moTask.create_time = DateTime.Now;
|
||
moTask.mo_task_status = DictConst.ToBeScheduledEncode;
|
||
moTask.scheduled_qty = input.scheduled_qty;
|
||
moTask.unit_id = mo.unit_id;
|
||
|
||
var moCode = mo?.mo_code;
|
||
var taskCode = await _billRuleService.GetBillNumber(Tnb.BasicData.CodeTemplateConst.PRDMOTASK_CODE);
|
||
moTask.mo_task_code = taskCode;
|
||
// var taskCode = await db.Queryable<PrdMoTask>().Where(it => !string.IsNullOrEmpty(it.mo_task_code) && it.mo_task_code.Contains(moCode)).OrderByDescending(it => it.mo_task_code).Select(it => it.mo_task_code).FirstAsync();
|
||
// if (taskCode.IsNullOrEmpty())
|
||
// {
|
||
// moTask.mo_task_code = $"{moCode}-01";
|
||
// }
|
||
// else
|
||
// {
|
||
// var pos = taskCode.IndexOf("-", StringComparison.Ordinal);
|
||
// if (pos > -1)
|
||
// {
|
||
// var num = taskCode.AsSpan().Slice(pos + 1).ToString().ParseToInt();
|
||
// var code = taskCode.AsSpan().Slice(0, pos).ToString();
|
||
// var n = (num + 1).ToString().PadLeft(2, '0');
|
||
// moTask.mo_task_code = $"{code}-{n}";
|
||
// }
|
||
// }
|
||
try
|
||
{
|
||
await db.Ado.BeginTranAsync();
|
||
row = await db.Insertable(moTask).ExecuteCommandAsync();
|
||
#region 质检模块
|
||
//质检
|
||
TriggerPlanEntity entity = new TriggerPlanEntity();
|
||
entity.materialid = moTask.material_id;
|
||
entity.processid = moTask.process_id;
|
||
entity.workid = moTask.workstation_id;
|
||
entity.triggerevent = EnumTriggerEvent.首件检新的生产任务;
|
||
await _qcCheckPlanService.CreateTask(entity);
|
||
#endregion
|
||
//根据工单号获取当前工单包含的已排产数
|
||
var schedQty = db.Queryable<PrdMoTask>().Where(it => it.mo_id == input.mo_id)?.Sum(d => d.scheduled_qty);
|
||
|
||
if (mo != null)
|
||
{//判断如果当前 工单的已排产数大于工单计划数量则更新工单状态为 已排产
|
||
// if (schedQty.HasValue && schedQty.Value >= mo.plan_qty)
|
||
// {
|
||
// mo.mo_status = DictConst.AlreadyId;
|
||
// }
|
||
// else
|
||
// {
|
||
// if (schedQty.HasValue)
|
||
// mo.scheduled_qty = schedQty.Value;
|
||
// }
|
||
// row = await db.Updateable(mo).ExecuteCommandAsync();
|
||
|
||
if (mo.scheduled_qty == null)
|
||
{
|
||
await _db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.mo_status == DictConst.AlreadyId)
|
||
.SetColumns(x => x.scheduled_qty == input.scheduled_qty)
|
||
.Where(x=>x.id==mo.id)
|
||
.ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await _db.Updateable<PrdMo>().SetColumns(x => x.scheduled_qty == x.scheduled_qty + input.scheduled_qty)
|
||
.Where(x=>x.id==mo.id)
|
||
.ExecuteCommandAsync();
|
||
}
|
||
}
|
||
var material = await db.Queryable<BasMaterial>().FirstAsync(it => it.id == moTask.material_id);
|
||
|
||
var taskLog = new PrdTaskLog();
|
||
taskLog.id = SnowflakeIdHelper.NextId();
|
||
taskLog.mo_code = (await db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id))?.mo_code!;
|
||
taskLog.eqp_code = (await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == input.eqp_id))?.code!;
|
||
taskLog.mold_code = (await db.Queryable<ToolMolds>().FirstAsync(it => it.id == input.mold_id))?.mold_code!;
|
||
taskLog.item_code = material?.code!;
|
||
taskLog.item_standard = material?.material_standard!;
|
||
taskLog.status = DictConst.ToBeScheduledEncode;
|
||
taskLog.operator_name = _userManager.RealName;
|
||
taskLog.create_id = _userManager.UserId;
|
||
taskLog.create_time = DateTime.Now;
|
||
taskLog.mo_task_id = moTask.id;
|
||
taskLog.mo_task_code = moTask.mo_task_code;
|
||
|
||
await db.Insertable(taskLog).ExecuteCommandAsync();
|
||
//将生产任务插入到自检报废记录表
|
||
//var sacipRecord = new PrdMoTaskDefectRecord();
|
||
//sacipRecord.id = SnowflakeIdHelper.NextId();
|
||
//sacipRecord.material_code = material?.code!;
|
||
//sacipRecord.material_name = material?.name!;
|
||
//sacipRecord.eqp_code = (await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == moTask.eqp_id))?.code!;
|
||
//sacipRecord.mold_name = (await db.Queryable<ToolMolds>().FirstAsync(it => it.id == moTask.mold_id))?.mold_name!;
|
||
//sacipRecord.estimated_start_date = moTask.plan_start_date;
|
||
//sacipRecord.estimated_end_date = moTask.plan_end_date;
|
||
//sacipRecord.plan_qty = moTask.plan_qty;
|
||
//sacipRecord.scrap_qty = moTask.scrap_qty;
|
||
//sacipRecord.status = moTask.mo_task_status;
|
||
//sacipRecord.create_id = _userManager.UserId;
|
||
//sacipRecord.create_time = DateTime.Now;
|
||
//sacipRecord.mo_task_id = moTask.id;
|
||
//sacipRecord.mo_task_code = moTask.mo_task_code;
|
||
//await db.Insertable(sacipRecord).ExecuteCommandAsync();
|
||
|
||
await db.Ado.CommitTranAsync();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
await db.Ado.RollbackTranAsync();
|
||
}
|
||
}
|
||
else if (input.schedule_type.Value == 2) //组装、包装排产
|
||
{
|
||
|
||
}
|
||
}
|
||
return row > 0;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 组装包装排产
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
/// <exception cref="ArgumentNullException"></exception>
|
||
[HttpPost]
|
||
public async Task<dynamic> PackSchedling(PackSchedlingCrInput input)
|
||
{
|
||
var row = -1;
|
||
try
|
||
{
|
||
await _db.Ado.BeginTranAsync();
|
||
var moTask = input.Adapt<PrdMoTask>();
|
||
moTask.id = SnowflakeIdHelper.NextId();
|
||
moTask.create_id = _userManager.UserId;
|
||
moTask.bom_id = input.bom_id;
|
||
moTask.workroute_id = (await _db.Queryable<BasMbom>().FirstAsync(it => it.id == input.bom_id))?.route_id;
|
||
moTask.workline_id = input.workline_id;
|
||
moTask.create_time = DateTime.Now;
|
||
moTask.schedule_type = 2;
|
||
moTask.mo_task_status = DictConst.ToBeScheduledEncode;
|
||
moTask.estimated_start_date = input.estimated_start_date;
|
||
moTask.estimated_end_date = input.estimated_end_date;
|
||
moTask.scheduled_qty = input.scheduled_qty;
|
||
var mo = await _db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id);
|
||
// moTask.unit_id = mo.unit_id;
|
||
var moCode = mo?.mo_code;
|
||
// var taskCode = await _db.Queryable<PrdMoTask>().Where(it => string.IsNullOrEmpty(it.parent_id) && !string.IsNullOrEmpty(it.mo_task_code) && it.mo_task_code.Contains(moCode))
|
||
// .OrderByDescending(it => it.mo_task_code)
|
||
// .Select(it => it.mo_task_code)
|
||
// .FirstAsync();
|
||
var taskCode = await _billRuleService.GetBillNumber(Tnb.BasicData.CodeTemplateConst.PRDMOTASK_CODE);
|
||
moTask.mo_task_code = taskCode;
|
||
// if (taskCode is null || taskCode.IsNullOrEmpty())
|
||
// {
|
||
// moTask.mo_task_code = $"{moCode}-01";
|
||
// }
|
||
// else
|
||
// {
|
||
// var pos = taskCode?.IndexOf("-", StringComparison.Ordinal);
|
||
// if (pos.HasValue && pos.Value > -1)
|
||
// {
|
||
// var num = taskCode.AsSpan().Slice(pos.Value + 1).ToString().ParseToInt();
|
||
// var code = taskCode.AsSpan().Slice(0, pos.Value).ToString();
|
||
// var n = (num + 1).ToString().PadLeft(2, '0');
|
||
// moTask.mo_task_code = $"{code}-{n}";
|
||
// }
|
||
// }
|
||
row = await _db.Insertable(moTask).ExecuteCommandAsync();
|
||
#region 质检模块
|
||
//质检
|
||
TriggerPlanEntity entity = new TriggerPlanEntity();
|
||
entity.materialid = moTask.material_id;
|
||
entity.processid = moTask.process_id;
|
||
entity.workid = moTask.workstation_id;
|
||
entity.triggerevent = EnumTriggerEvent.首件检新的生产任务;
|
||
await _qcCheckPlanService.CreateTask(entity);
|
||
|
||
#endregion
|
||
|
||
var material_h = await _db.Queryable<BasMaterial>().FirstAsync(it => it.id == moTask.material_id);
|
||
//添加生产任务操作记录日志
|
||
var taskLog = new PrdTaskLog();
|
||
taskLog.id = SnowflakeIdHelper.NextId();
|
||
taskLog.mo_code = (await _db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id))?.mo_code!;
|
||
taskLog.item_code = material_h?.code!;
|
||
taskLog.item_standard = material_h?.material_standard!;
|
||
taskLog.status = DictConst.ToBeScheduledEncode;
|
||
taskLog.operator_name = _userManager.RealName;
|
||
taskLog.create_id = _userManager.UserId;
|
||
taskLog.create_time = DateTime.Now;
|
||
taskLog.mo_task_id = moTask.id;
|
||
taskLog.mo_task_code = moTask.mo_task_code!;
|
||
row = await _db.Insertable(taskLog).ExecuteCommandAsync();
|
||
//将生产任务插入到自检报废记录表
|
||
//var sacipRecord = new PrdMoTaskDefectRecord();
|
||
//sacipRecord.id = SnowflakeIdHelper.NextId();
|
||
//sacipRecord.material_code = material?.code!;
|
||
//sacipRecord.material_name = material?.name!;
|
||
//sacipRecord.eqp_code = (await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == moTask.eqp_id))?.code!;
|
||
//sacipRecord.mold_name = (await db.Queryable<ToolMolds>().FirstAsync(it => it.id == moTask.mold_id))?.mold_name!;
|
||
//sacipRecord.estimated_start_date = moTask.plan_start_date;
|
||
//sacipRecord.estimated_end_date = moTask.plan_end_date;
|
||
//sacipRecord.plan_qty = moTask.plan_qty;
|
||
//sacipRecord.scrap_qty = moTask.scrap_qty;
|
||
//sacipRecord.status = moTask.mo_task_status;
|
||
//sacipRecord.create_id = _userManager.UserId;
|
||
//sacipRecord.create_time = DateTime.Now;
|
||
//sacipRecord.mo_task_id = moTask.id;
|
||
//sacipRecord.mo_task_code = moTask.mo_task_code;
|
||
//await db.Insertable(sacipRecord).ExecuteCommandAsync();
|
||
|
||
//根据工单号获取当前工单包含的已排产数
|
||
var schedQty = _db.Queryable<PrdMoTask>().Where(it => it.mo_id == input.mo_id)?.Sum(d => d.scheduled_qty);
|
||
// if (mo != null)
|
||
// {//判断如果当前 工单的已排产数大于工单计划数量则更新工单状态为 已排产
|
||
// if (schedQty.HasValue && schedQty.Value >= mo.plan_qty)
|
||
// {
|
||
// mo.mo_status = DictConst.AlreadyId;
|
||
// await _db.Updateable(mo).ExecuteCommandAsync();
|
||
// }
|
||
// else
|
||
// {
|
||
// if (schedQty.HasValue)
|
||
// {
|
||
// mo.scheduled_qty += schedQty.Value;
|
||
// await _db.Updateable(mo).ExecuteCommandAsync();
|
||
// }
|
||
// }
|
||
// }
|
||
|
||
if (mo != null)
|
||
{
|
||
if (mo.scheduled_qty == null)
|
||
{
|
||
await _db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.mo_status == DictConst.AlreadyId)
|
||
.SetColumns(x => x.scheduled_qty == input.scheduled_qty)
|
||
.Where(x=>x.id==mo.id)
|
||
.ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await _db.Updateable<PrdMo>().SetColumns(x => x.scheduled_qty == x.scheduled_qty + input.scheduled_qty)
|
||
.Where(x=>x.id==mo.id)
|
||
.ExecuteCommandAsync();
|
||
}
|
||
}
|
||
|
||
var subTaskList = await _db.Queryable<BasMbom>()
|
||
.LeftJoin<BasMbomProcess>((a, b) => a.id == b.mbom_id)
|
||
.LeftJoin<BasRouteH>((a, b, c) => a.route_id == c.id)
|
||
// .LeftJoin<BasRouteD>((a, b, c, d) => b.process_id == d.process_id && c.id == d.route_id)
|
||
.LeftJoin<BasRouteD>((a, b, c, d) => b.route_detail_id == d.id)
|
||
.LeftJoin<BasMbomOutput>((a, b, c, d, e) => a.id == e.mbom_id && e.mbom_process_id == b.id)
|
||
.Where((a, b, c, d, e) => a.id == input.bom_id)
|
||
.OrderBy((a,b,c,d,e)=>b.ordinal)
|
||
.Select((a, b, c, d, e) => new SubBomListOutput
|
||
{
|
||
version = a.version,
|
||
unit_id = a.unit_id,
|
||
route_id = c.id,
|
||
process_id = b.process_id,
|
||
material_id = SqlFunc.Subqueryable<BasMaterial>().Where(it => it.id == e.material_id).Select(it => it.id),
|
||
num = e.num,
|
||
ordinal = d.ordinal,
|
||
mbom_process_id = b.id,
|
||
})
|
||
.Mapper(it => it.output_qty = it.num.ParseToInt())
|
||
.ToListAsync();
|
||
if (subTaskList?.Count > 0)
|
||
{
|
||
List<PrdMoTask> subMoTasks = new();
|
||
List<PrdTaskLog> subMoTaskLogs = new();
|
||
foreach (var item in subTaskList)
|
||
{
|
||
PrdMoTask subMoTask = new();
|
||
subMoTask.mo_id = input.mo_id;
|
||
subMoTask.material_id = item.material_id;
|
||
subMoTask.schedule_type = 2;
|
||
subMoTask.parent_id = moTask.id;
|
||
subMoTask.bom_id = input.bom_id;
|
||
subMoTask.process_id = item.process_id;
|
||
subMoTask.mbom_process_id = item.mbom_process_id;
|
||
subMoTask.mo_task_status = DictConst.ToBeScheduledEncode;
|
||
subMoTask.workroute_id = item.route_id;
|
||
subMoTask.workline_id = input.workline_id;
|
||
subMoTask.material_id = item.material_id;
|
||
subMoTask.scheduled_qty = input.scheduled_qty;
|
||
subMoTask.process_task_qty = item.output_qty * moTask.scheduled_qty;
|
||
subMoTask.estimated_start_date = input.estimated_start_date;
|
||
subMoTask.estimated_end_date = input.estimated_end_date;
|
||
subMoTask.create_id = _userManager.UserId;
|
||
subMoTask.create_time = DateTime.Now;
|
||
subMoTasks.Add(subMoTask);
|
||
|
||
var subTaskLog = new PrdTaskLog();
|
||
var subMaterial = await _db.Queryable<BasMaterial>().SingleAsync(x => x.id == item.material_id);
|
||
subTaskLog.id = SnowflakeIdHelper.NextId();
|
||
subTaskLog.mo_code = (await _db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id))?.mo_code!;
|
||
subTaskLog.item_code = subMaterial?.code!;
|
||
subTaskLog.item_standard = subMaterial?.material_standard!;
|
||
subTaskLog.status = DictConst.ToBeScheduledEncode;
|
||
subTaskLog.operator_name = _userManager.RealName;
|
||
subTaskLog.create_id = _userManager.UserId;
|
||
subTaskLog.create_time = DateTime.Now;
|
||
subTaskLog.mo_task_id = subMoTask.id;
|
||
subTaskLog.mo_task_code = subMoTask.mo_task_code!;
|
||
subMoTaskLogs.Add(subTaskLog);
|
||
}
|
||
//根据生产任务编号生成子任务编号
|
||
if (moTask.mo_task_code!.IsNotEmptyOrNull())
|
||
{
|
||
for (int i = 1; i <= subMoTasks.Count; i++)
|
||
{
|
||
string n = i.ToString();
|
||
subMoTasks[i - 1].mo_task_code = $"{moTask.mo_task_code}-{n.PadLeft(2, '0')}";
|
||
}
|
||
}
|
||
row = await _db.Insertable(subMoTasks).ExecuteCommandAsync();
|
||
await _db.Insertable(subMoTaskLogs).ExecuteCommandAsync();
|
||
}
|
||
await _db.Ado.CommitTranAsync();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
JNPF.Logging.Log.Error("组装包装排产时报错", ex);
|
||
await _db.Ado.RollbackTranAsync();
|
||
}
|
||
return row > 0;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 生产任务下发，开始 、结束、完成
|
||
/// </summary>
|
||
/// <param name="input">输入参数</param>
|
||
/// <returns></returns>
|
||
/// <exception cref="ArgumentNullException"></exception>
|
||
/// <exception cref="NotImplementedException"></exception>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdTaskRelease(PrdTaskReleaseUpInput input)
|
||
{
|
||
var row = -1;
|
||
if (input is null)
|
||
{
|
||
throw new ArgumentNullException(nameof(input));
|
||
}
|
||
if (input.TaskIds is null)
|
||
{
|
||
throw new ArgumentNullException(nameof(input.TaskIds));
|
||
}
|
||
if (input.Behavior.IsNullOrWhiteSpace())
|
||
{
|
||
throw new ArgumentException($"{nameof(input.Behavior)} not be null or empty");
|
||
}
|
||
//var taskList = await _db.Queryable<PrdMoTask>().Where(it => input.TaskIds.Contains(it.id) && it.mo_task_status == DictConst.ToBeScheduledEncode).ToListAsync();
|
||
//if (taskList?.Count > 0)
|
||
{
|
||
string SetTaskStatus(PrdTaskBehavior behavior) => behavior switch
|
||
{
|
||
PrdTaskBehavior.Release => DictConst.ToBeStartedEnCode,
|
||
PrdTaskBehavior.Start => DictConst.InProgressEnCode,
|
||
PrdTaskBehavior.Closed => DictConst.ClosedEnCode,
|
||
PrdTaskBehavior.Compled => DictConst.ComplatedEnCode,
|
||
PrdTaskBehavior.Pause => DictConst.MoStatusPauseCode,
|
||
_ => throw new NotImplementedException(),
|
||
};
|
||
PrdTaskBehavior behavior = input.Behavior.ToEnum<PrdTaskBehavior>();
|
||
var status = SetTaskStatus(behavior);
|
||
var db = _repository.AsSugarClient();
|
||
var list = await db.Queryable<PrdMoTask>().Where(it => input.TaskIds.Contains(it.id)).Select(it => it).ToListAsync();
|
||
if (behavior == PrdTaskBehavior.Compled)
|
||
{
|
||
// if (list?.Count > 0)
|
||
// {
|
||
// // var schedQtySum = list.Sum(x => x.scheduled_qty);
|
||
// // var planQtySum = list.Sum(x => x.plan_qty);
|
||
// // if (schedQtySum < planQtySum)
|
||
// // {
|
||
// // throw new AppFriendlyException("任务数量必须大于等于生产计划数量,才可完成", 500);
|
||
// // }
|
||
//
|
||
// int reportedWorkQty = list.Sum(x => x.last_process_complete_qty) ?? 0;
|
||
// int scrapQty = list.Sum(x => x.scrap_qty) ?? 0;
|
||
// int scheduledQty = list.Sum(x => x.scheduled_qty) ?? 0;
|
||
// if (scheduledQty >= reportedWorkQty+scrapQty)
|
||
// {
|
||
// throw new AppFriendlyException("已完成数量大于等于任务单数量,才可完成", 500);
|
||
// }
|
||
// }
|
||
}
|
||
|
||
var taskReportLogs = new List<PrdMoTask>();
|
||
var prdTaskList = await db.Queryable<PrdMoTask>().Where(it => input.TaskIds.Contains(it.id)).ToListAsync();
|
||
if (prdTaskList?.Count > 0)
|
||
{
|
||
#region 质检模块
|
||
//质检
|
||
if (prdTaskList.Where(p => p.mo_task_status == "Pause").Count() > 0 && status == "InProgress")
|
||
{
|
||
foreach (var task in prdTaskList.Where(p => p.mo_task_status == "Pause").ToList())
|
||
{
|
||
TriggerPlanEntity entity = new TriggerPlanEntity();
|
||
entity.materialid = task.material_id;
|
||
entity.processid = task.process_id;
|
||
entity.workid = task.workstation_id;
|
||
entity.triggerevent = EnumTriggerEvent.首件检生产任务暂停;
|
||
await _qcCheckPlanService.CreateTask(entity);
|
||
}
|
||
}
|
||
#endregion
|
||
prdTaskList.ForEach(x => x.mo_task_status = status);
|
||
row = await db.Updateable(prdTaskList).ExecuteCommandAsync();
|
||
foreach (var item in prdTaskList)
|
||
{
|
||
if (string.IsNullOrEmpty(item.parent_id)) continue;
|
||
//子任务所有状态相同才修改父任务状态
|
||
int count1 = await db.Queryable<PrdMoTask>().CountAsync(y => y.parent_id == item.parent_id);
|
||
int count2 = await db.Queryable<PrdMoTask>().CountAsync(y => y.parent_id == item.parent_id && y.mo_task_status==status);
|
||
if (count1 == count2)
|
||
{
|
||
await db.Updateable<PrdMoTask>().SetColumns(x => x.mo_task_status == status)
|
||
.Where(x => x.id == item.parent_id).ExecuteCommandAsync();
|
||
}
|
||
}
|
||
if (row > 0)
|
||
{
|
||
taskReportLogs.AddRange(prdTaskList);
|
||
}
|
||
}
|
||
if (row > 0)
|
||
{
|
||
//更新子任务
|
||
var subMoTaskList = await db.Queryable<PrdMoTask>().Where(it => input.TaskIds.Contains(it.parent_id)).ToListAsync();
|
||
if (subMoTaskList?.Count > 0)
|
||
{
|
||
var subTaskIds = subMoTaskList.Select(it => it.id).ToList();
|
||
row = await db.Updateable<PrdMoTask>()
|
||
.SetColumns(it => new PrdMoTask { mo_task_status = status })
|
||
.Where(it => subTaskIds.Contains(it.id))
|
||
.ExecuteCommandAsync();
|
||
if (row > 0)
|
||
{
|
||
taskReportLogs.AddRange(subMoTaskList);
|
||
}
|
||
}
|
||
}
|
||
//插入操作记录日志
|
||
var prdMOTasks = await _db.Queryable<PrdMoTask>().Where(it => input.TaskIds.Contains(it.id) && string.IsNullOrEmpty(it.parent_id)).ToListAsync();
|
||
if (prdMOTasks?.Count > 0)
|
||
{
|
||
List<PrdTaskLog> taskLogEntities = new();
|
||
foreach (var taskId in input.TaskIds)
|
||
{
|
||
var taskLog = await db.Queryable<PrdTaskLog>().FirstAsync(it => it.mo_task_id == taskId);
|
||
if (taskLog is null)
|
||
{
|
||
var taskItem = list?.Find(x => x.id == taskId);
|
||
taskLog = new PrdTaskLog();
|
||
taskLog.id = SnowflakeIdHelper.NextId();
|
||
if (taskItem != null)
|
||
{
|
||
if (taskItem.mo_id!.IsNotEmptyOrNull())
|
||
{
|
||
taskLog.mo_code = (await db.Queryable<PrdMo>().FirstAsync(it => it.id == taskItem.mo_id))?.mo_code!;
|
||
}
|
||
if (taskItem.eqp_id!.IsNotEmptyOrNull())
|
||
{
|
||
taskLog.eqp_code = (await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == taskItem.eqp_id))?.code!;
|
||
}
|
||
if (taskItem.mold_id!.IsNotEmptyOrNull())
|
||
{
|
||
taskLog.mold_code = (await db.Queryable<ToolMolds>().FirstAsync(it => it.id == taskItem.mold_id))?.mold_code!;
|
||
}
|
||
if (taskItem.material_id!.IsNotEmptyOrNull())
|
||
{
|
||
var material = await db.Queryable<BasMaterial>().FirstAsync(it => it.id == taskItem.material_id);
|
||
taskLog.item_code = material?.code!;
|
||
taskLog.item_standard = material?.material_standard!;
|
||
}
|
||
taskLog.operator_name = _userManager.RealName;
|
||
taskLog.status = status;
|
||
taskLog.create_id = _userManager.UserId;
|
||
taskLog.create_time = DateTime.Now;
|
||
taskLog.mo_task_id = taskItem.id;
|
||
}
|
||
taskLogEntities.Add(taskLog);
|
||
}
|
||
else
|
||
{
|
||
var records = await db.Queryable<PrdTaskLog>().Where(it => it.mo_task_id == taskLog.mo_task_id).ToListAsync();
|
||
if (records != null && !records.Select(x => x.status).Contains(status))
|
||
{
|
||
taskLog.id = SnowflakeIdHelper.NextId();
|
||
taskLog.status = status;
|
||
taskLogEntities.Add(taskLog);
|
||
}
|
||
}
|
||
}
|
||
if (taskLogEntities?.Count > 0)
|
||
{
|
||
row = await db.Insertable(taskLogEntities).ExecuteCommandAsync();
|
||
}
|
||
|
||
List<PrdReportRecord> prdReportLogs = new();
|
||
List<PrdMoTaskDefectRecord> prdTaskDefectLogs = new();
|
||
if (taskReportLogs?.Count > 0)
|
||
{
|
||
foreach (var taskInfo in taskReportLogs)
|
||
{
|
||
//组装生产提报对象
|
||
var material = (await db.Queryable<BasMaterial>().FirstAsync(it => it.id == taskInfo.material_id));
|
||
var mo = await db.Queryable<PrdMo>().FirstAsync(it => it.id == taskInfo.mo_id);
|
||
var record = taskInfo.Adapt<PrdReportRecord>();
|
||
record.id = SnowflakeIdHelper.NextId();
|
||
record.masterial_code = material?.code;
|
||
record.masterial_name = material?.name;
|
||
record.plan_start_date = taskInfo.estimated_start_date;
|
||
record.plan_end_date = taskInfo.estimated_end_date;
|
||
record.plan_qty = taskInfo.plan_qty;
|
||
record.eqp_code = (await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == taskInfo.eqp_id))?.code;
|
||
record.mo_task_type = mo?.mo_type;
|
||
record.status = taskInfo.mo_task_status;
|
||
record.mo_task_id = taskInfo.id;
|
||
//record.completed_qty = (await db.Queryable<PrdReport>().Where(it => it.mo_task_code == taskInfo.mo_task_code).SumAsync(it => it.reported_work_qty)).Value;
|
||
prdReportLogs.Add(record);
|
||
|
||
//组装自检报废对象
|
||
var sacipRecord = new PrdMoTaskDefectRecord();
|
||
sacipRecord.id = SnowflakeIdHelper.NextId();
|
||
sacipRecord.material_code = material?.code!;
|
||
sacipRecord.material_name = material?.name!;
|
||
sacipRecord.eqp_code = (await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == taskInfo.eqp_id))?.code!;
|
||
sacipRecord.mold_name = (await db.Queryable<ToolMolds>().FirstAsync(it => it.id == taskInfo.mold_id))?.mold_name!;
|
||
sacipRecord.estimated_start_date = taskInfo.estimated_start_date;
|
||
sacipRecord.estimated_end_date = taskInfo.estimated_end_date;
|
||
sacipRecord.plan_qty = taskInfo.plan_qty;
|
||
sacipRecord.scrap_qty = taskInfo.scrap_qty.HasValue ? taskInfo.scrap_qty.Value : 0;
|
||
sacipRecord.status = taskInfo.mo_task_status;
|
||
sacipRecord.create_id = _userManager.UserId;
|
||
sacipRecord.create_time = DateTime.Now;
|
||
sacipRecord.mo_task_id = taskInfo.id;
|
||
sacipRecord.mo_task_code = taskInfo.mo_task_code;
|
||
sacipRecord.mo_task_type = mo?.mo_type;
|
||
sacipRecord.status = taskInfo.mo_task_status;
|
||
prdTaskDefectLogs.Add(sacipRecord);
|
||
}
|
||
}
|
||
var reportTaskIds = prdReportLogs.Select(it => it.mo_task_id).ToList();
|
||
if (reportTaskIds?.Count > 0)
|
||
{
|
||
var items = await db.Queryable<PrdReportRecord>().Where(it => reportTaskIds.Contains(it.mo_task_id)).ToListAsync();
|
||
if (items == null || items.Count < 1)
|
||
{
|
||
row = await db.Insertable(prdReportLogs).ExecuteCommandAsync();
|
||
}
|
||
}
|
||
var defectTaskIds = prdTaskDefectLogs.Select(it => it.mo_task_id).ToList();
|
||
if (defectTaskIds?.Count > 0)
|
||
{
|
||
var items = await db.Queryable<PrdMoTaskDefectRecord>().Where(it => defectTaskIds.Contains(it.mo_task_id)).ToListAsync();
|
||
if (items == null || items.Count < 1)
|
||
{
|
||
row = await db.Insertable(prdTaskDefectLogs).ExecuteCommandAsync();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
//else
|
||
// throw new AppFriendlyException("只有待下发状态的任务才可下发", 500);
|
||
return (row > 0);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 生产任务单修改
|
||
/// </summary>
|
||
/// <param name="input">生产任务单修改输入参数</param>
|
||
/// <returns></returns>
|
||
/// <exception cref="AppFriendlyException"></exception>
|
||
[HttpPost]
|
||
public async Task<dynamic> IcmoModify(IcmoUpInput input)
|
||
{
|
||
var row = -1;
|
||
var db = _repository.AsSugarClient();
|
||
if (input.icmo_id.IsNullOrWhiteSpace())
|
||
throw new ArgumentNullException(nameof(input.icmo_id));
|
||
var icmoItem = await db.Queryable<PrdMoTask>().FirstAsync(it => it.id == input.icmo_id);
|
||
switch (input.category)
|
||
{
|
||
case 1: //设备
|
||
|
||
if (icmoItem != null)
|
||
{
|
||
var eqpItem = await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == icmoItem.eqp_id);
|
||
icmoItem.eqp_id = eqpItem.id;
|
||
icmoItem.eqp_type_code = db.Queryable<EqpEquipType>().First(it => it.id == eqpItem.equip_type_id)?.code!;
|
||
//if (input.scheduled_qty > icmoItem.plan_qty)
|
||
//{
|
||
// throw new AppFriendlyException("任务单数量不能大于计划数量", 500);
|
||
//}
|
||
//row = await db.Updateable<PrdMo>().SetColumns(it => new PrdMo { input_qty = input.scheduled_qty }).Where(it => it.id == input.mo_id).ExecuteCommandAsync();
|
||
}
|
||
|
||
break;
|
||
case 2: //模具
|
||
if (icmoItem != null)
|
||
{
|
||
var moldItem = await db.Queryable<ToolMolds>().FirstAsync(it => it.id == icmoItem.mold_id);
|
||
icmoItem.mold_id = moldItem.id;
|
||
icmoItem.mold_code = moldItem.mold_code;
|
||
icmoItem.mold_name = moldItem.mold_name;
|
||
icmoItem.mold_cavity_qty = moldItem.cavity_qty;
|
||
}
|
||
break;
|
||
}
|
||
row = await db.Updateable(icmoItem).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
||
return (row > 0);
|
||
}
|
||
|
||
// /// <summary>
|
||
// /// 生产提报
|
||
// /// </summary>
|
||
// /// <param name="input"></param>
|
||
// /// <remarks>
|
||
// /// input:
|
||
// /// <br/>{
|
||
// /// <br/> icmo_id:生产任务ID
|
||
// /// <br/> icmo_code:任务单号
|
||
// /// <br/> prd_qty：生产数量
|
||
// /// <br/> reported_work_qty：已报工数量
|
||
// /// <br/> reported_qty：提报数量
|
||
// /// <br/> icmo_qty：生产任务量
|
||
// /// <br/>}
|
||
// /// </remarks>
|
||
// [HttpPost]
|
||
// public async Task<dynamic> PrdReport(PrdReportCrInput input)
|
||
// {
|
||
// var row = -1;
|
||
// var db = _repository.AsSugarClient();
|
||
// var report = await db.Queryable<PrdReport>().FirstAsync(it => it.mo_task_id == input.mo_task_id);
|
||
//
|
||
// //if (report is not null)
|
||
// //{
|
||
// // report.mo_task_code = input.mo_task_code;
|
||
// // report.mo_task_id = input.mo_task_id;
|
||
// // report.reported_work_qty += input.reported_qty;
|
||
// // report.prd_qty += input.reported_qty;
|
||
// //}
|
||
// //else
|
||
// {
|
||
// report = input.Adapt<PrdReport>();
|
||
// report.id = SnowflakeIdHelper.NextId();
|
||
// report.reported_qty = input.reported_qty;
|
||
// report.create_id = _userManager.UserId;
|
||
// report.create_time = DateTime.Now;
|
||
//
|
||
// }
|
||
// row = await db.Insertable(report).ExecuteCommandAsync();
|
||
// var master = await db.Queryable<PrdReportRecord>().FirstAsync(it => it.mo_task_id == input.mo_task_id);
|
||
// if (master != null)
|
||
// {
|
||
// master.reported_work_qty += input.reported_qty;
|
||
// master.completed_qty += input.reported_qty;
|
||
// await db.Updateable(master).ExecuteCommandAsync();
|
||
// }
|
||
// return row > 0;
|
||
// }
|
||
|
||
/// <summary>
|
||
/// 生产提报
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <remarks>
|
||
/// input:
|
||
/// <br/>{
|
||
/// <br/> icmo_id:生产任务ID
|
||
/// <br/> icmo_code:任务单号
|
||
/// <br/> prd_qty：生产数量
|
||
/// <br/> reported_work_qty：已报工数量
|
||
/// <br/> reported_qty：提报数量
|
||
/// <br/> icmo_qty：生产任务量
|
||
/// <br/>}
|
||
/// </remarks>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdReport(PrdReportCrInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
DbResult<bool> result = await _repository.AsSugarClient().Ado.UseTranAsync(async () =>
|
||
{
|
||
var row = -1;
|
||
var report = await db.Queryable<PrdReport>().FirstAsync(it => it.mo_task_id == input.mo_task_id);
|
||
var prdMoTask = await db.Queryable<PrdMoTask>().SingleAsync(x => x.id == input.mo_task_id);
|
||
var prdMo = await db.Queryable<PrdMo>().SingleAsync(x => x.id == prdMoTask.mo_id);
|
||
var mbomProcess = await db.Queryable<BasMbomProcess>().SingleAsync(x => x.id == prdMoTask.mbom_process_id);
|
||
|
||
if (prdMoTask.mo_task_status == DictConst.MoStatusPauseCode)
|
||
{
|
||
throw Oops.Bah("暂停的任务单无法提报");
|
||
}
|
||
|
||
if ((prdMoTask.reported_work_qty ?? 0) + input.reported_qty > prdMoTask.scheduled_qty)
|
||
{
|
||
var config1 = await db.Queryable<BasFactoryConfig>().FirstAsync(x => x.enabled == 1 && x.key == FactoryConfigConst.IS_SURPASS);
|
||
if (config1?.value == "1")
|
||
{
|
||
var config2 = await db.Queryable<BasFactoryConfig>().FirstAsync(x => x.enabled == 1 && x.key == FactoryConfigConst.IS_SURPASS_PERCENTAGE);
|
||
if (!string.IsNullOrEmpty(config2?.value))
|
||
{
|
||
if ((prdMoTask.reported_work_qty ?? 0) + input.reported_qty > prdMoTask.scheduled_qty*(100+Convert.ToDecimal(config2?.value ?? "1"))/100)
|
||
{
|
||
throw Oops.Bah($"提报数量不能大于{100+Convert.ToDecimal(config2?.value ?? "0")}%排产数量");
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
throw Oops.Bah("提报数量不能大于排产数量");
|
||
}
|
||
}
|
||
|
||
|
||
// bool flag = (prdMoTask.reported_work_qty ?? 0) + (prdMoTask.scrap_qty ?? 0) + input.reported_qty == prdMoTask.scheduled_qty;
|
||
// if ((prdMoTask.reported_work_qty ?? 0) + (prdMoTask.scrap_qty ?? 0) + input.reported_qty > prdMoTask.scheduled_qty)
|
||
// {
|
||
// throw Oops.Bah("已完成数量不能大于任务单数量");
|
||
// }
|
||
|
||
report = input.Adapt<PrdReport>();
|
||
report.id = SnowflakeIdHelper.NextId();
|
||
report.reported_qty = input.reported_qty;
|
||
report.create_id = _userManager.UserId;
|
||
report.create_time = DateTime.Now;
|
||
// report.batch = input.mo_task_code + DateTimeOffset.Now.ToUnixTimeSeconds().ToString();
|
||
report.barcode = input.mo_task_code + DateTimeOffset.Now.ToUnixTimeSeconds().ToString();
|
||
report.equip_id = prdMoTask.eqp_id;
|
||
report.mbom_process_id = prdMoTask.mbom_process_id;
|
||
report.station = input.station;
|
||
report.status = 0;
|
||
report.material_id = prdMoTask.material_id;
|
||
report.unit_id = prdMoTask.unit_id;
|
||
report.process_id = mbomProcess?.process_id ?? "";
|
||
|
||
row = await db.Insertable(report).ExecuteCommandAsync();
|
||
|
||
#region 质检模块
|
||
//质检模块
|
||
TriggerPlanEntity entity = new TriggerPlanEntity();
|
||
entity.materialid = prdMoTask.material_id;
|
||
entity.processid = prdMoTask.process_id;
|
||
entity.workid = prdMoTask.workstation_id;
|
||
var reported = prdMoTask.reported_work_qty == null ? 0 : prdMoTask.reported_work_qty;
|
||
var scrap = prdMoTask.scrap_qty == null ? 0 : prdMoTask.scrap_qty;
|
||
entity.oldpronum = reported+ scrap;
|
||
entity.newpronum = input.reported_qty;
|
||
entity.triggerevent = EnumTriggerEvent.生产检定量;
|
||
await _qcCheckPlanService.CreateTask(entity);
|
||
#endregion
|
||
if (prdMoTask.reported_work_qty == null)
|
||
{
|
||
await db.Updateable<PrdMoTask>()
|
||
// .SetColumns(x => x.complete_qty == x.complete_qty + input.reported_qty)
|
||
.SetColumns(x => x.reported_work_qty == input.reported_qty)
|
||
// .SetColumnsIF(flag,x=>x.mo_task_status==DictConst.ComplatedEnCode)
|
||
.Where(x => x.id == input.mo_task_id).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Updateable<PrdMoTask>()
|
||
// .SetColumns(x => x.complete_qty == x.complete_qty + input.reported_qty)
|
||
.SetColumns(x => x.reported_work_qty == x.reported_work_qty + input.reported_qty)
|
||
// .SetColumnsIF(flag,x=>x.mo_task_status==DictConst.ComplatedEnCode)
|
||
.Where(x => x.id == input.mo_task_id).ExecuteCommandAsync();
|
||
}
|
||
|
||
if (prdMoTask.schedule_type==1)
|
||
{
|
||
if (prdMo.reported_work_qty == null)
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.reported_work_qty == input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.reported_work_qty == x.reported_work_qty + input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
|
||
if (prdMo.complete_qty == null)
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.complete_qty == input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.complete_qty == x.complete_qty + input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
}
|
||
|
||
if (prdMoTask.schedule_type == 2 && !string.IsNullOrEmpty(prdMoTask.mbom_process_id))
|
||
{
|
||
if (mbomProcess.is_last==1 && prdMoTask != null && !string.IsNullOrEmpty(prdMoTask.parent_id))
|
||
{
|
||
var parentMoTask = await db.Queryable<PrdMoTask>().SingleAsync(x => x.id == prdMoTask.parent_id);
|
||
if (parentMoTask?.last_process_complete_qty == null)
|
||
{
|
||
await db.Updateable<PrdMoTask>()
|
||
.SetColumns(x => x.last_process_complete_qty == input.reported_qty)
|
||
// .SetColumnsIF(flag,x=>x.mo_task_status==DictConst.ComplatedEnCode)
|
||
.Where(x => x.id == prdMoTask.parent_id).ExecuteCommandAsync();
|
||
}else if (parentMoTask?.last_process_complete_qty != null)
|
||
{
|
||
await db.Updateable<PrdMoTask>()
|
||
.SetColumns(x => x.last_process_complete_qty == x.last_process_complete_qty + input.reported_qty)
|
||
// .SetColumnsIF(flag,x=>x.mo_task_status==DictConst.ComplatedEnCode)
|
||
.Where(x => x.id == prdMoTask.parent_id).ExecuteCommandAsync();
|
||
}
|
||
|
||
if (prdMo.reported_work_qty == null)
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.reported_work_qty == input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.reported_work_qty == x.reported_work_qty + input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
|
||
if (prdMo.complete_qty == null)
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.complete_qty == input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.complete_qty == x.complete_qty + input.reported_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
}
|
||
}
|
||
|
||
var master = await db.Queryable<PrdReportRecord>().FirstAsync(it => it.mo_task_id == input.mo_task_id);
|
||
if (master != null)
|
||
{
|
||
master.reported_work_qty += input.reported_qty;
|
||
master.completed_qty += input.reported_qty;
|
||
await db.Updateable(master).ExecuteCommandAsync();
|
||
}
|
||
|
||
|
||
//扣除生产投料 按最先投入的依次扣除
|
||
// List<PrdFeedingD> prdFeedingDs = await db.Queryable<PrdFeedingH>()
|
||
// .LeftJoin<PrdFeedingD>((a,b)=>a.id==b.feeding_id)
|
||
// .Where((a,b) => a.workline_id == prdMoTask.workline_id && (b.status=="0" || b.status=="1"))
|
||
// .OrderBy((a,b) => b.create_time)
|
||
// .Select((a,b)=>b)
|
||
// .ToListAsync();
|
||
//
|
||
// if (prdFeedingDs != null && prdFeedingDs.Count>0)
|
||
// {
|
||
//
|
||
// BasMbom basMbom = await db.Queryable<BasMbom>().SingleAsync(x => x.id == prdMoTask.bom_id);
|
||
// List<BasMbomInput> basMbomInputs = await db.Queryable<BasMbomInput>().Where(x =>
|
||
// x.mbom_id == prdMoTask.bom_id && x.mbom_process_id == prdMoTask.mbom_process_id).ToListAsync();
|
||
//
|
||
// foreach (var item in basMbomInputs)
|
||
// {
|
||
// var details = prdFeedingDs.Where(x => x.material_id == item.material_id).OrderBy(x=>x.create_time).ToList();
|
||
// if (details?.Count>0)
|
||
// {
|
||
// decimal deductNum = input.reported_qty * item.num / basMbom.num;
|
||
// decimal? notUseNum = details.Sum(x => x.num - x.use_num);
|
||
// if (notUseNum > deductNum)
|
||
// {
|
||
//
|
||
// foreach (var detail in details)
|
||
// {
|
||
//
|
||
// if (deductNum - (detail.num - detail.use_num) < 0)
|
||
// {
|
||
// await db.Updateable<PrdFeedingD>().SetColumns(x => x.use_num == x.use_num+deductNum)
|
||
// .SetColumns(x=>x.status=="1")
|
||
// .Where(x => x.id == detail.id).ExecuteCommandAsync();
|
||
//
|
||
// }
|
||
// else
|
||
// {
|
||
// await db.Updateable<PrdFeedingD>().SetColumns(x => x.use_num == x.num)
|
||
// .SetColumns(x=>x.status=="2")
|
||
// .Where(x => x.id == detail.id).ExecuteCommandAsync();
|
||
//
|
||
// }
|
||
//
|
||
// deductNum = deductNum - (detail.num - detail.use_num);
|
||
//
|
||
// if (deductNum <= 0)
|
||
// break;
|
||
// }
|
||
//
|
||
// if (deductNum > 0)
|
||
// {
|
||
// throw new Exception("投入物料不足");
|
||
// }
|
||
// }
|
||
// else if(notUseNum == deductNum)
|
||
// {
|
||
// foreach (var detail in details)
|
||
// {
|
||
// await db.Updateable<PrdFeedingD>().SetColumns(x => x.use_num == x.num)
|
||
// .SetColumns(x=>x.status=="2")
|
||
// .Where(x => x.id == detail.id).ExecuteCommandAsync();
|
||
//
|
||
// }
|
||
// }
|
||
// else
|
||
// {
|
||
// throw new Exception("投入物料不足");
|
||
// }
|
||
//
|
||
// }
|
||
// else
|
||
// {
|
||
// throw new Exception("无投入物料");
|
||
// }
|
||
// }
|
||
// }
|
||
|
||
});
|
||
|
||
if (!result.IsSuccess) throw Oops.Bah(result.ErrorMessage);
|
||
return result.IsSuccess;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 自检报废提交
|
||
/// </summary>
|
||
/// <param name="input">自检报废输入参数</param>
|
||
/// <returns>true/false</returns>
|
||
/// <remarks>
|
||
/// input:
|
||
///<br/>{
|
||
///<br/> "icmo_code": 任务单号,
|
||
///<br/> "scrap_qty": 报废数量,
|
||
///<br/> "remark": 备注,
|
||
///<br/> "categoryItems": [
|
||
///<br/> {
|
||
///<br/> "defective_category":次品分类,
|
||
///<br/> "category_qty": 分类数量,
|
||
///<br/> "items": [
|
||
///<br/> {
|
||
///<br/> "defective_item": 次品项,
|
||
///<br/> "defective_item_qty": 次品项数量
|
||
///<br/> }
|
||
///<br/> ]
|
||
///<br/> }
|
||
///<br/> ]
|
||
///<br/>}
|
||
/// </remarks>
|
||
[HttpPost]
|
||
public async Task<dynamic> SelfTestScrapped(SelfTestScrappedInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
if (await db.Queryable<PrdMoTask>().AnyAsync(x => x.id == input.mo_task_id && x.mo_task_status == DictConst.MoStatusPauseCode))
|
||
{
|
||
throw Oops.Bah("暂停的任务单无法报废");
|
||
}
|
||
|
||
var result = await db.Ado.UseTranAsync(async () =>
|
||
{
|
||
List<PrdMoTaskDefect> destDefects = new();
|
||
var batch = DateTime.Now.ToString("yyyyMMddHHmmss");
|
||
var prdMoTask = await db.Queryable<PrdMoTask>().SingleAsync(x => x.id == input.mo_task_id);
|
||
|
||
foreach (var categoryItem in input.categoryItems)
|
||
{
|
||
foreach (var dItem in categoryItem.items)
|
||
{
|
||
var defect = new PrdMoTaskDefect();
|
||
defect.id = SnowflakeIdHelper.NextId();
|
||
defect.mo_task_id = input.mo_task_id;
|
||
defect.batch = batch;
|
||
defect.defective_cagetory_id = categoryItem.category_id;
|
||
defect.defective_item = dItem.defective_item;
|
||
defect.defective_item_qty = dItem.defective_item_qty;
|
||
defect.create_id = _userManager.UserId;
|
||
defect.scrap_qty = input.scrap_qty;
|
||
destDefects.Add(defect);
|
||
}
|
||
}
|
||
await db.Insertable(destDefects).ExecuteCommandAsync();
|
||
|
||
var scrapQty = db.Queryable<PrdMoTaskDefect>().Where(it => it.mo_task_id == input.mo_task_id)?.Sum(d => d.defective_item_qty);
|
||
if (scrapQty.HasValue && scrapQty.Value > 0)//更新生产任务表报废数量
|
||
{
|
||
#region 质检模块
|
||
//质检模块
|
||
|
||
TriggerPlanEntity entity = new TriggerPlanEntity();
|
||
entity.materialid = prdMoTask.material_id;
|
||
entity.processid = prdMoTask.process_id;
|
||
entity.workid = prdMoTask.workstation_id;
|
||
var reported = prdMoTask.reported_work_qty == null ? 0 : prdMoTask.reported_work_qty;
|
||
var scrap = prdMoTask.scrap_qty == null ? 0 : prdMoTask.scrap_qty;
|
||
entity.oldpronum = reported + scrap;
|
||
entity.newpronum = input.scrap_qty;
|
||
entity.triggerevent = EnumTriggerEvent.生产检定量;
|
||
await _qcCheckPlanService.CreateTask(entity);
|
||
#endregion
|
||
await db.Updateable<PrdMoTask>().SetColumns(it => new PrdMoTask { scrap_qty = scrapQty.Value }).Where(it => it.id == input.mo_task_id).ExecuteCommandAsync();
|
||
}
|
||
var defectRecord = await db.Queryable<PrdMoTaskDefectRecord>().FirstAsync(it => it.mo_task_id == input.mo_task_id);
|
||
if (defectRecord != null)
|
||
{
|
||
defectRecord.scrap_qty += input.scrap_qty;
|
||
await db.Updateable(defectRecord).ExecuteCommandAsync();
|
||
}
|
||
var reportMaster = await db.Queryable<PrdReportRecord>().FirstAsync(it => it.mo_task_id == input.mo_task_id);
|
||
var prdMo = await db.Queryable<PrdMo>().SingleAsync(x => x.id == prdMoTask.mo_id);
|
||
|
||
if (prdMo.reported_work_qty == null)
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.scrap_qty == input.scrap_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.scrap_qty == x.scrap_qty + input.scrap_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
|
||
if (prdMo.complete_qty == null)
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.complete_qty == input.scrap_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
else
|
||
{
|
||
await db.Updateable<PrdMo>()
|
||
.SetColumns(x => x.complete_qty == x.complete_qty + input.scrap_qty)
|
||
.Where(x => x.id == prdMo.id).ExecuteCommandAsync();
|
||
}
|
||
|
||
if (reportMaster != null)
|
||
{
|
||
reportMaster.completed_qty += input.scrap_qty;
|
||
await db.Updateable(reportMaster).ExecuteCommandAsync();
|
||
}
|
||
|
||
});
|
||
return result.IsSuccess;
|
||
}
|
||
/// <summary>
|
||
/// 修改组装、包装，生产任务信息
|
||
/// </summary>
|
||
/// <param name="updateToObj"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> UpdatePackMoTask(PackPrdTaskUpInput input)
|
||
{
|
||
if (input == null) throw new ArgumentNullException("input");
|
||
var row = await _db.Updateable<PrdMoTask>().SetColumns(it => new PrdMoTask
|
||
{
|
||
workline_id = input.workline_id,
|
||
bom_id = input.bom_id,
|
||
estimated_start_date = input.estimated_start_date,
|
||
estimated_end_date = input.estimated_end_date,
|
||
scheduled_qty = input.scheduled_qty,
|
||
})
|
||
.Where(it => it.id == input.mo_task_id).ExecuteCommandAsync();
|
||
return row > 0;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 生成子工单
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task GenSubMo(GenSubMoCrInput input)
|
||
{
|
||
if (input is null) throw new ArgumentNullException("input");
|
||
if (input.ids is null || input.ids.Count == 0) throw new ArgumentException($"{nameof(input.ids)} not be null or count zero");
|
||
var curMo = await _db.Queryable<PrdMo>().FirstAsync(it => it.id == input.mo_id);
|
||
if (curMo == null) throw new ArgumentNullException("创建子工单时的父工单不能为null");
|
||
|
||
|
||
var outMaterials = await _db.Queryable<BasMbom>().InnerJoin<BasMbomProcess>((a, b) => a.id == b.mbom_id)
|
||
.InnerJoin<BasMbomOutput>((a, b, c) => a.id == c.mbom_id && b.id == c.mbom_process_id)
|
||
.Where((a, b, c) => a.id == input.bom_id && input.ids.Contains(b.process_id))
|
||
.Select((a, b, c) => new
|
||
{
|
||
material_id = c.material_id,
|
||
num = c.num,
|
||
})
|
||
.ToListAsync();
|
||
|
||
if (outMaterials?.Count > 0)
|
||
{
|
||
var ids = outMaterials.Select(x => x.material_id).ToList();
|
||
await _db.Deleteable<PrdMo>().Where(it => it.parent_id == input.mo_id).ExecuteCommandAsync();
|
||
if (ids?.Count > 0)
|
||
{
|
||
var dicOutMaterialNum = outMaterials.DistinctBy(x => x.material_id).ToDictionary(x => x.material_id, x => x.num.ParseToInt());
|
||
List<PrdMo> subMoList = new();
|
||
var outputMaterials = await _db.Queryable<BasMaterial>().Where(it => ids.Contains(it.id)).ToListAsync();
|
||
foreach (var om in outputMaterials)
|
||
{
|
||
PrdMo subMo = new();
|
||
subMo.material_id = om.id;
|
||
subMo.material_code = om.code;
|
||
subMo.plan_qty = dicOutMaterialNum.ContainsKey(om.id) ? dicOutMaterialNum[om.id] * curMo.plan_qty : 0;
|
||
subMo.mo_type = curMo.mo_type;
|
||
subMo.parent_id = curMo.id;
|
||
subMo.plan_start_date = curMo.plan_start_date;
|
||
subMo.plan_end_date = curMo.plan_end_date;
|
||
subMo.create_id = _userManager.UserId;
|
||
subMo.create_time = DateTime.Now;
|
||
subMo.mo_status = DictConst.WaitProductId;
|
||
subMoList.Add(subMo);
|
||
}
|
||
//生成子工单编码
|
||
for (int i = 0; i < subMoList.Count; i++)
|
||
{
|
||
var num = (i + 1).ToString().PadLeft(2, '0');
|
||
subMoList[i].mo_code = $"{curMo.mo_code}-{num}";
|
||
}
|
||
var row = await _db.Insertable(subMoList).ExecuteCommandAsync();
|
||
if (row < 1) throw Oops.Oh(ErrorCode.COM1000);
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
|
||
#endregion
|
||
|
||
private static Dictionary<string, string[]> dicProperties = new Dictionary<string, string[]>(StringComparer.OrdinalIgnoreCase);
|
||
private static T DictionaryToObject<T>(IDictionary<String, Object> dictionary) where T : class, new()
|
||
{
|
||
var name = typeof(T).Name;
|
||
T instance = new();
|
||
if (!dicProperties.TryGetValue(name, out string[] properies))
|
||
{
|
||
properies = instance.GetType().GetProperties(BindingFlags.Instance | BindingFlags.Public).Select(p => p.Name).ToArray();
|
||
dicProperties[name] = properies;
|
||
}
|
||
foreach (var pn in properies)
|
||
{
|
||
if (dictionary.ContainsKey(pn))
|
||
{
|
||
instance.PropertySetValue(pn, dictionary[pn]);
|
||
}
|
||
}
|
||
return instance;
|
||
}
|
||
// private async Task<dynamic> GetList(VisualDevModelListQueryInput input)
|
||
// {
|
||
// var db = _repository.AsSugarClient();
|
||
// VisualDevEntity? templateEntity = await _visualDevService.GetInfoById(ModuleId, true);
|
||
// var data = await _runService.GetListResult(templateEntity, input);
|
||
// if (data?.list?.Count > 0)
|
||
// {
|
||
// foreach (var row in data.list)
|
||
// {
|
||
// var dic = row.ToDictionary(x => x.Key, x => x.Value);
|
||
// var pkName = "material_id_id";
|
||
// if (dic.ContainsKey(pkName))
|
||
// {
|
||
// var materialId = dic[pkName]?.ToString();
|
||
// var material = await db.Queryable<BasMaterial>().FirstAsync(it => it.id == materialId);
|
||
// if (material != null)
|
||
// {
|
||
// row["material_id"] = $"{material.code}/{material.name}";
|
||
// }
|
||
// }
|
||
// //模具
|
||
// if (dic.ContainsKey("mold_id"))
|
||
// {
|
||
// var moldId = dic["mold_id"]?.ToString();
|
||
// var mold = await db.Queryable<ToolMolds>().FirstAsync(it => it.id == moldId);
|
||
// if (mold != null)
|
||
// {
|
||
// row["mold_id"] = $"{mold.mold_code}/{mold.mold_name}";
|
||
// }
|
||
// }
|
||
// //设备
|
||
// if (dic.ContainsKey("eqp_id"))
|
||
// {
|
||
// var eqpId = dic["eqp_id"]?.ToString();
|
||
// var eqp = await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == eqpId);
|
||
// if (eqp != null)
|
||
// {
|
||
// row["eqp_id"] = $"{eqp.code}/{eqp.name}";
|
||
// }
|
||
// }
|
||
// }
|
||
// }
|
||
// return data!;
|
||
// }
|
||
|
||
private async Task<dynamic> GetList(VisualDevModelListQueryInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
Dictionary<string, string> queryJson = !string.IsNullOrEmpty(input.queryJson) ? JsonConvert.DeserializeObject<Dictionary<string, string>>(input.queryJson) : new Dictionary<string, string>();
|
||
string moTaskCode = queryJson.ContainsKey("mo_task_code") ? queryJson["mo_task_code"].ToString() : "";
|
||
string eqpId = queryJson.ContainsKey("eqp_id") ? queryJson["eqp_id"].ToString() : "";
|
||
List<string> worklineIds = new List<string>();
|
||
List<string> equipIds = new List<string>();
|
||
if (!string.IsNullOrEmpty(eqpId))
|
||
{
|
||
worklineIds = await db.Queryable<OrganizeEntity>().Where(x => x.ParentId == eqpId && x.Category==DictConst.RegionCategoryWorklineCode && x.DeleteMark==null).Select(x=>x.Id).ToListAsync();
|
||
equipIds = await db.Queryable<EqpEquipment>().Where(x => x.equip_type_id == eqpId).Select(x => x.id).ToListAsync();
|
||
}
|
||
|
||
var result = await db.Queryable<PrdMoTask>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<DictionaryTypeEntity>((a, b, c) => c.EnCode == DictConst.TaskStatus)
|
||
.LeftJoin<DictionaryDataEntity>((a, b, c, d) =>
|
||
c.Id == d.DictionaryTypeId && a.mo_task_status == d.EnCode)
|
||
.LeftJoin<ToolMolds>((a, b, c, d, e) => a.mold_id == e.id)
|
||
.LeftJoin<PrdMo>((a, b, c, d, e, f) => a.mo_id == f.id)
|
||
.LeftJoin<OrganizeEntity>((a, b, c, d, e, f, g) => a.workline_id == g.Id)
|
||
.LeftJoin<EqpEquipment>((a, b, c, d, e, f, g, h) => a.eqp_id == h.id)
|
||
.WhereIF(!string.IsNullOrEmpty(moTaskCode), (a, b, c, d) => a.mo_task_code.Contains(moTaskCode))
|
||
.WhereIF(!string.IsNullOrEmpty(eqpId) && equipIds.Count <= 0 && worklineIds.Count <= 0,
|
||
(a, b, c, d) => a.workline_id == eqpId || a.eqp_id == eqpId)
|
||
.WhereIF(worklineIds.Count > 0, (a, b, c, d) => worklineIds.Contains(a.workline_id))
|
||
.WhereIF(equipIds.Count > 0, (a, b, c, d) => equipIds.Contains(a.eqp_id))
|
||
.Where((a)=>a.mo_task_status==DictConst.ToBeStartedEnCode || a.mo_task_code==DictConst.ToBeScheduledEncode || a.mo_task_code==DictConst.MoStatusPauseCode)
|
||
.Select((a, b, c, d,e,f,g,h) => new WorkOrderAdjustmentListOutput
|
||
{
|
||
id = a.id,
|
||
mo_task_code = a.mo_task_code,
|
||
material_id = b.code+"/"+b.name,
|
||
material_id_id = a.material_id,
|
||
mold_id = e.mold_code+"/"+e.mold_name,
|
||
mold_id_id = a.mold_id,
|
||
mo_task_status = d.FullName,
|
||
plan_qty = f.plan_qty,
|
||
complete_qty = SqlFunc.IsNull(a.reported_work_qty,0) + SqlFunc.IsNull(a.scrap_qty,0),
|
||
scheduled_qty = a.scheduled_qty,
|
||
workline_id = a.workline_id==null ? "" :g.EnCode+"/"+g.FullName,
|
||
workline_id_id = a.workline_id,
|
||
estimated_start_date = a.estimated_start_date==null ? "" : a.estimated_start_date.Value.ToString("yyyy-MM-dd"),
|
||
estimated_end_date = a.estimated_end_date==null ? "" : a.estimated_end_date.Value.ToString("yyyy-MM-dd"),
|
||
eqp_id = a.eqp_id==null ? "" : h.code+"/"+h.name,
|
||
eqp_id_id = a.eqp_id,
|
||
create_time = a.create_time==null ? "" :a.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss")
|
||
}).OrderByDescending(a => a.create_time).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
return PageResult<WorkOrderAdjustmentListOutput>.SqlSugarPageResult(result);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 删除
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <returns></returns>
|
||
private async Task Delete(string id)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
var result = await db.Ado.UseTranAsync(async () =>
|
||
{
|
||
var row = -1;
|
||
var prdTask = await db.Queryable<PrdMoTask>().FirstAsync(it => it.id == id);
|
||
row = await db.Deleteable<PrdTask>().Where(it => it.id == id).ExecuteCommandAsync();
|
||
if (row > 0)
|
||
{
|
||
var prdMo = await db.Queryable<PrdMo>().FirstAsync(it => it.id == prdTask.mo_id);
|
||
if (prdMo is not null)
|
||
{
|
||
prdMo.scheduled_qty += prdTask.scheduled_qty;
|
||
prdMo.mo_status = DictConst.ScheduledId;
|
||
row = await db.Updateable(prdMo).ExecuteCommandAsync();
|
||
}
|
||
}
|
||
return row > 0;
|
||
});
|
||
if (!result.IsSuccess) throw Oops.Oh(ErrorCode.COM1002);
|
||
}
|
||
public async Task<List<PrdMoTask>> GetListByEqpId(string eqpId)
|
||
{
|
||
return await _db.Queryable<PrdMoTask>().Where(it => it.eqp_id == eqpId && it.mo_task_status == DictConst.InProgressEnCode).ToListAsync();
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 计算预计结束日期
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
/// <exception cref="AppFriendlyException"></exception>
|
||
[HttpPost]
|
||
public async Task<dynamic> GetEstimatedEndTime(CountEstimatedEndTimeInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
if (input.type == 1)
|
||
{
|
||
PerProcessStandardsH processStandardsH = await db.Queryable<PerProcessStandardsH>()
|
||
.Where(x => x.equip_id == input.equip_id && x.molds_id == input.molds_id &&
|
||
x.output_material_id == input.material_id && x.enabled == 1)
|
||
.OrderByDescending(x => x.create_time).FirstAsync();
|
||
|
||
ToolMolds toolMolds = await db.Queryable<ToolMolds>().SingleAsync(x => x.id == input.molds_id);
|
||
if(toolMolds==null) throw Oops.Bah("没找到模具");
|
||
if(toolMolds?.mold_cavity<=0) throw Oops.Bah("模穴数错误");
|
||
if (processStandardsH == null) throw Oops.Bah("工艺标准成型周期错误");
|
||
if (processStandardsH?.moulding_cycle <= 0) throw Oops.Bah("工艺标准成型周期错误");
|
||
|
||
decimal? addTime = (input.scheduled_qty * processStandardsH?.moulding_cycle - 1) / toolMolds.mold_cavity + 1;
|
||
return input.estimated_start_date.AddSeconds((double)addTime.Value).ToString("yyyy-MM-dd HH:mm:ss");
|
||
}
|
||
else
|
||
{
|
||
var list = await db.Queryable<BasMbomProcess>()
|
||
.LeftJoin<BasStandardTime>((a,b)=>a.process_id==b.process_id)
|
||
.Where((a,b)=>a.mbom_id==input.mbom_id).Select((a,b)=>b).ToListAsync();
|
||
|
||
decimal max = list.Select(x => Convert.ToDecimal(x.standard_time)).Max(x => x);
|
||
decimal? addTime = input.scheduled_qty * max;
|
||
return input.estimated_start_date.AddSeconds((double)addTime.Value).ToString("yyyy-MM-dd HH:mm:ss");
|
||
}
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取这个产线生产中的任务单
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> GetMoTaskByWorklineId(Dictionary<string,string> dic)
|
||
{
|
||
string id = dic["id"];
|
||
return await _repository.AsSugarClient().Queryable<PrdMoTask>()
|
||
.Where(x => x.workline_id == id && x.mo_task_status == DictConst.InProgressEnCode).FirstAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更换机台
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> ChangeEquip(ChangeEquipInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
DbResult<bool> result = await db.Ado.UseTranAsync(async () =>
|
||
{
|
||
var moTask = await db.Queryable<PrdMoTask>().SingleAsync(x => x.id == input.mo_task_id);
|
||
if (moTask.eqp_id == input.equip_id)
|
||
{
|
||
throw new Exception("与原机台相同");
|
||
}
|
||
|
||
await db.Updateable<PrdMoTask>().SetColumns(x => x.eqp_id == input.equip_id)
|
||
.Where(x => x.id == input.mo_task_id).ExecuteCommandAsync();
|
||
|
||
var mo = await db.Queryable<PrdMo>().SingleAsync(x => x.id == moTask.mo_id);
|
||
var material = await db.Queryable<BasMaterial>().SingleAsync(x => x.id == moTask.material_id);
|
||
var process = await db.Queryable<BasMaterial>().SingleAsync(x => x.id == moTask.process_id);
|
||
var taskLog = new PrdTaskLog();
|
||
taskLog.id = SnowflakeIdHelper.NextId();
|
||
taskLog.mo_code = mo?.mo_code!;
|
||
taskLog.eqp_code = (await db.Queryable<EqpEquipment>().FirstAsync(it => it.id == input.equip_id))?.code!;
|
||
taskLog.mold_code = "";
|
||
taskLog.item_code = material?.code!;
|
||
taskLog.item_standard = material?.material_standard!;
|
||
taskLog.status = "更换机台";
|
||
taskLog.operator_name = _userManager.RealName;
|
||
taskLog.create_id = _userManager.UserId;
|
||
taskLog.create_time = DateTime.Now;
|
||
taskLog.mo_task_id = moTask.id;
|
||
taskLog.mo_task_code = moTask.mo_task_code;
|
||
taskLog.station_code = "";
|
||
taskLog.process_code = process?.code;
|
||
|
||
await db.Insertable<PrdTaskLog>(taskLog).ExecuteCommandAsync();
|
||
});
|
||
|
||
if (!result.IsSuccess) throw Oops.Bah(result.ErrorMessage);
|
||
return result.IsSuccess ? "更换成功" : result.ErrorMessage;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更换模具
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> ChangeMold(ChangeMoldInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
DbResult<bool> result = await db.Ado.UseTranAsync(async () =>
|
||
{
|
||
var moTask = await db.Queryable<PrdMoTask>().SingleAsync(x => x.id == input.mo_task_id);
|
||
if (moTask.mold_id == input.mold_id)
|
||
{
|
||
throw new Exception("与原模具相同");
|
||
}
|
||
|
||
await db.Updateable<PrdMoTask>().SetColumns(x => x.mold_id == input.mold_id)
|
||
.Where(x => x.id == input.mo_task_id).ExecuteCommandAsync();
|
||
|
||
var mo = await db.Queryable<PrdMo>().SingleAsync(x => x.id == moTask.mo_id);
|
||
var mold = await db.Queryable<ToolMolds>().SingleAsync(x => x.id == input.mold_id);
|
||
var material = await db.Queryable<BasMaterial>().SingleAsync(x => x.id == moTask.material_id);
|
||
var process = await db.Queryable<BasMaterial>().SingleAsync(x => x.id == moTask.process_id);
|
||
var taskLog = new PrdTaskLog();
|
||
taskLog.id = SnowflakeIdHelper.NextId();
|
||
taskLog.mo_code = mo?.mo_code!;
|
||
taskLog.eqp_code = "";
|
||
taskLog.mold_code = mold?.mold_code;
|
||
taskLog.item_code = material?.code!;
|
||
taskLog.item_standard = material?.material_standard!;
|
||
taskLog.status = "更换模具";
|
||
taskLog.operator_name = _userManager.RealName;
|
||
taskLog.create_id = _userManager.UserId;
|
||
taskLog.create_time = DateTime.Now;
|
||
taskLog.mo_task_id = moTask.id;
|
||
taskLog.mo_task_code = moTask.mo_task_code;
|
||
taskLog.station_code = "";
|
||
taskLog.process_code = process?.code;
|
||
|
||
await db.Insertable<PrdTaskLog>(taskLog).ExecuteCommandAsync();
|
||
});
|
||
|
||
if (!result.IsSuccess) throw Oops.Bah(result.ErrorMessage);
|
||
return result.IsSuccess ? "更换成功" : result.ErrorMessage;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 更换产线
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> ChangeWorkline(ChangeWorklineInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
DbResult<bool> result = await db.Ado.UseTranAsync(async () =>
|
||
{
|
||
var moTask = await db.Queryable<PrdMoTask>().SingleAsync(x => x.id == input.mo_task_id);
|
||
if (moTask.workline_id == input.workline_id)
|
||
{
|
||
throw new Exception("与原产线相同");
|
||
}
|
||
|
||
|
||
await db.Updateable<PrdMoTask>().SetColumns(x => x.workline_id == input.workline_id)
|
||
.Where(x => x.id == input.mo_task_id).ExecuteCommandAsync();
|
||
|
||
var mo = await db.Queryable<PrdMo>().SingleAsync(x => x.id == moTask.mo_id);
|
||
var material = await db.Queryable<BasMaterial>().SingleAsync(x => x.id == moTask.material_id);
|
||
var process = await db.Queryable<BasMaterial>().SingleAsync(x => x.id == moTask.process_id);
|
||
var taskLog = new PrdTaskLog();
|
||
taskLog.id = SnowflakeIdHelper.NextId();
|
||
taskLog.mo_code = mo?.mo_code!;
|
||
taskLog.eqp_code = "";
|
||
taskLog.mold_code = "";
|
||
taskLog.item_code = material?.code!;
|
||
taskLog.item_standard = material?.material_standard!;
|
||
taskLog.status = "更换产线";
|
||
taskLog.operator_name = _userManager.RealName;
|
||
taskLog.create_id = _userManager.UserId;
|
||
taskLog.create_time = DateTime.Now;
|
||
taskLog.mo_task_id = moTask.id;
|
||
taskLog.mo_task_code = moTask.mo_task_code;
|
||
taskLog.station_code = "";
|
||
taskLog.process_code = process?.code;
|
||
|
||
await db.Insertable<PrdTaskLog>(taskLog).ExecuteCommandAsync();
|
||
});
|
||
|
||
if (!result.IsSuccess) throw Oops.Bah(result.ErrorMessage);
|
||
return result.IsSuccess ? "更换成功" : result.ErrorMessage;
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据id获取任务单相关信息
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> GetPrdMoTaskInfoById(Dictionary<string,string> dic)
|
||
{
|
||
string id = dic.ContainsKey("id") ? dic["id"] : "";
|
||
if (string.IsNullOrEmpty(id)) return null;
|
||
var db = _repository.AsSugarClient();
|
||
return await db.Queryable<PrdMoTask>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<ToolMolds>((a, b, c) => a.mold_id == c.id)
|
||
.LeftJoin<EqpEquipment>((a, b, c, d) => a.eqp_id == d.id)
|
||
.LeftJoin<DictionaryDataEntity>((a,b,c,d,e)=>e.EnCode==a.mo_task_status && e.DictionaryTypeId==DictConst.PrdTaskStatusTypeId)
|
||
.LeftJoin<BasProcess>((a,b,c,d,e,f)=>a.process_id==f.id)
|
||
.Where((a, b, c, d) => a.id == id)
|
||
.Select((a, b, c, d,e,f) => new
|
||
{
|
||
id = a.id,
|
||
mo_task_code = a.mo_task_code,
|
||
mo_task_status = e.FullName,
|
||
material_id = a.material_id,
|
||
material_code = b.code,
|
||
material_name = b.name,
|
||
mold_id = a.mold_id,
|
||
mold_code = c.mold_code,
|
||
mold_name = c.mold_name,
|
||
schedule_type = a.schedule_type,
|
||
equip_code = d.code,
|
||
equip_name = d.name,
|
||
scheduled_qty = a.scheduled_qty,
|
||
reported_work_qty = a.reported_work_qty,
|
||
scrap_qty = a.scrap_qty,
|
||
process_id_id = a.process_id,
|
||
process_id = f.process_name,
|
||
}).FirstAsync();
|
||
|
||
}
|
||
|
||
}
|
||
}
|