635 lines
31 KiB
C#
635 lines
31 KiB
C#
using JNPF.Common.Core.Manager;
|
||
using JNPF.Common.Extension;
|
||
using JNPF.Common.Filter;
|
||
using JNPF.Common.Security;
|
||
using JNPF.DependencyInjection;
|
||
using JNPF.DynamicApiController;
|
||
using JNPF.FriendlyException;
|
||
using JNPF.Systems.Entitys.Permission;
|
||
using JNPF.Systems.Entitys.System;
|
||
using JNPF.Systems.Interfaces.System;
|
||
using JNPF.VisualDev;
|
||
using JNPF.VisualDev.Entitys.Dto.VisualDevModelData;
|
||
using JNPF.VisualDev.Interfaces;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using SqlSugar;
|
||
using Tnb.BasicData;
|
||
using Tnb.BasicData.Entities;
|
||
using Tnb.EquipMgr.Entities;
|
||
using Tnb.ProductionMgr.Entities;
|
||
using Tnb.ProductionMgr.Entities.Dto;
|
||
using Tnb.ProductionMgr.Entities.Dto.PrdManage;
|
||
using Tnb.ProductionMgr.Entities.Enums;
|
||
using Tnb.ProductionMgr.Interfaces;
|
||
|
||
namespace Tnb.ProductionMgr
|
||
{
|
||
/// <summary>
|
||
/// 生产计划管理
|
||
/// </summary>
|
||
[ApiDescriptionSettings(Tag = ModuleConst.Tag, Area = ModuleConst.Area, Order = 700)]
|
||
[Route("api/[area]/[controller]/[action]")]
|
||
[OverideVisualDev(ModuleId)]
|
||
public class PrdMoService : IOverideVisualDevService, IPrdMoService, IDynamicApiController, ITransient
|
||
{
|
||
// private const string ModuleId = "25018860321301";
|
||
private const string ModuleId = "26900026924053";
|
||
private readonly ISqlSugarRepository<PrdMo> _repository;
|
||
private readonly IDataBaseManager _dataBaseManager;
|
||
private readonly IUserManager _userManager;
|
||
private readonly IDictionaryDataService _dictionaryDataService;
|
||
private readonly IRunService _runService;
|
||
private readonly IVisualDevService _visualDevService;
|
||
private readonly ISqlSugarClient _db;
|
||
|
||
public OverideVisualDevFunc OverideFuncs { get; } = new OverideVisualDevFunc();
|
||
|
||
public PrdMoService(
|
||
ISqlSugarRepository<PrdMo> repository,
|
||
IDataBaseManager dataBaseManager,
|
||
IUserManager userManager,
|
||
IDictionaryDataService dictionaryDataService,
|
||
IRunService runService,
|
||
IVisualDevService visualDevService
|
||
)
|
||
{
|
||
_repository = repository;
|
||
_dataBaseManager = dataBaseManager;
|
||
_userManager = userManager;
|
||
_dictionaryDataService = dictionaryDataService;
|
||
_runService = runService;
|
||
_visualDevService = visualDevService;
|
||
_db = _repository.AsSugarClient();
|
||
OverideFuncs.GetListAsync = GetList;
|
||
}
|
||
|
||
// 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.Add("material_name", material.name);
|
||
// row.Add($"material_attribute", material.attribute);
|
||
// if (dic.ContainsKey("material_id"))
|
||
// {
|
||
// row["material_id"] = material.code + "/" + material.name;
|
||
// }
|
||
// }
|
||
//
|
||
// if (dic.ContainsKey("unit_id"))
|
||
// {
|
||
// string unitId = dic["unit_id"]?.ToString() ?? "";
|
||
// var unit = await db.Queryable<DictionaryDataEntity>().SingleAsync(x => x.Id == unitId);
|
||
// row["unit_id"] = unit?.FullName ?? "";
|
||
// }
|
||
// }
|
||
// }
|
||
// }
|
||
// return data!;
|
||
// }
|
||
|
||
private async Task<dynamic> GetList(VisualDevModelListQueryInput input)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
Dictionary<string, string> queryJson = !string.IsNullOrEmpty(input.queryJson) ? Newtonsoft.Json.JsonConvert.DeserializeObject<Dictionary<string, string>>(input.queryJson) : new Dictionary<string, string>();
|
||
string moCode = queryJson.ContainsKey("mo_code") ? queryJson["mo_code"].ToString() : "";
|
||
string moStatus = queryJson.ContainsKey("mo_status") ? queryJson["mo_status"].ToString() : "";
|
||
string combineMoCode = queryJson.ContainsKey("combine_mo_code") ? queryJson["combine_mo_code"].ToString() : "";
|
||
var result = await db.Queryable<PrdMo>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<DictionaryTypeEntity>((a, b, c) => c.EnCode == DictConst.MeasurementUnit)
|
||
.LeftJoin<DictionaryDataEntity>((a, b, c, d) => c.Id == d.DictionaryTypeId && a.unit_id == d.Id)
|
||
.LeftJoin<DictionaryDataEntity>((a, b, c, d, e) => a.mo_status == e.Id)
|
||
.LeftJoin<DictionaryDataEntity>((a, b, c, d, e,f) => a.mo_type==f.Id)
|
||
.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))
|
||
.WhereIF(!string.IsNullOrEmpty(moStatus), (a, b, c, d, e) => a.mo_status == moStatus)
|
||
.Where(a=>SqlFunc.IsNullOrEmpty(a.parent_id))
|
||
.OrderByDescending(a=>a.create_time)
|
||
.Select((a, b, c, d, e,f) => new PrdMoListOuput
|
||
{
|
||
id = a.id,
|
||
mo_type = f.FullName,
|
||
mo_source = a.mo_source=="1" ? "ERP同步" : "新建/导入",
|
||
mo_code = a.mo_code,
|
||
plan_start_date = a.plan_start_date==null ? "" : a.plan_start_date.Value.ToString("yyyy-MM-dd"),
|
||
plan_end_date = a.plan_end_date==null ? "" : a.plan_end_date.Value.ToString("yyyy-MM-dd"),
|
||
material_id = b.code+"/"+b.name,
|
||
material_id_id = b.id,
|
||
plan_qty = a.plan_qty,
|
||
unit_id = d.FullName,
|
||
mo_status = e.FullName,
|
||
remark = a.remark,
|
||
children = SqlFunc.Subqueryable<PrdMo>()
|
||
.LeftJoin<BasMaterial>((aa, bb) => aa.material_id == bb.id)
|
||
.LeftJoin<DictionaryTypeEntity>((aa, bb, cc) => cc.EnCode == DictConst.MeasurementUnit)
|
||
.LeftJoin<DictionaryDataEntity>((aa, bb, cc, dd) => cc.Id == dd.DictionaryTypeId && aa.unit_id == dd.Id)
|
||
.LeftJoin<DictionaryDataEntity>((aa, bb, cc, dd, ee) => aa.mo_status == ee.Id)
|
||
.LeftJoin<DictionaryDataEntity>((aa, bb, cc, dd, ee,ff) => aa.mo_type==ff.Id)
|
||
.Where(aa=>aa.parent_id==a.id)
|
||
.ToList((aa,bb,cc,dd,ee,ff)=>new PrdMoListOuput
|
||
{
|
||
id = aa.id,
|
||
mo_type = ff.FullName,
|
||
mo_source = aa.mo_source=="1" ? "ERP同步" : "新建/导入",
|
||
mo_code = aa.mo_code,
|
||
plan_start_date = aa.plan_start_date==null ? "" : aa.plan_start_date.Value.ToString("yyyy-MM-dd"),
|
||
plan_end_date = aa.plan_end_date==null ? "" : aa.plan_end_date.Value.ToString("yyyy-MM-dd"),
|
||
material_id = bb.code+"/"+bb.name,
|
||
material_id_id = bb.id,
|
||
plan_qty = aa.plan_qty,
|
||
unit_id = dd.FullName,
|
||
mo_status = ee.FullName,
|
||
remark = aa.remark,
|
||
})
|
||
}).ToPagedListAsync(input.currentPage, int.MaxValue);
|
||
return PageResult<PrdMoListOuput>.SqlSugarPageResult(result);
|
||
}
|
||
|
||
|
||
#region Get
|
||
|
||
|
||
/// <summary>
|
||
/// 获取自建报废记录
|
||
/// </summary>
|
||
/// <param name="icmoCode"></param>
|
||
/// <returns></returns>
|
||
[HttpGet("{icmoCode}")]
|
||
public async Task<dynamic> GetReportRecord(string icmoCode)
|
||
{
|
||
var db = _repository.AsSugarClient();
|
||
var output = new PrdMoTaskDefectOutput();
|
||
//output.mo_task_code = icmoCode;
|
||
//var scrap = (await db.Queryable<PrdScrapped>().FirstAsync(it => it.icmo_code == icmoCode));
|
||
//output.items = new List<CategoryItem>();
|
||
//var categorys = await db.Queryable<PrdScrappedDefectiveCagetory>().Where(it => it.icmo_code == icmoCode).ToListAsync();
|
||
//foreach (var category in categorys)
|
||
//{
|
||
// var categoryItem = category.Adapt<SelfTestScrappedOutputItem>();
|
||
// categoryItem.items = new List<PrdScrappedDefectiveItem>();
|
||
// var items = await db.Queryable<PrdScrappedDefectiveItem>().Where(it => it.defective_cagetory_id == category.id).ToListAsync();
|
||
// categoryItem.items.AddRange(items);
|
||
// output.categoryItems.Add(categoryItem);
|
||
//}
|
||
return output;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region Post
|
||
|
||
/// <summary>
|
||
/// 生产工单创建-生产工单下发
|
||
/// </summary>
|
||
/// <param name="input">生产工单下发输入参数</param>
|
||
/// <returns></returns>
|
||
[HttpPut]
|
||
public async Task<dynamic> WorkOrderIssue(MoCrInput input)
|
||
{
|
||
if (input is null)
|
||
{
|
||
throw new ArgumentNullException(nameof(input));
|
||
}
|
||
if (input.Behavior.IsNullOrWhiteSpace())
|
||
{
|
||
throw new ArgumentException($"{nameof(input.Behavior)},not be null or empty");
|
||
}
|
||
|
||
var db = _repository.AsSugarClient();
|
||
//获取同组工单的Id，一起下发
|
||
var combineMoCodes = await db.Queryable<PrdMo>().Where(it => input.WorkOrderIds.Contains(it.id)).Select(it => it.combine_mo_code).ToListAsync();
|
||
if (combineMoCodes?.Count > 0)
|
||
{
|
||
var moIds = await db.Queryable<PrdMo>().Where(it => combineMoCodes.Contains(it.combine_mo_code) && !input.WorkOrderIds.Contains(it.id)).Select(it => it.id).ToListAsync();
|
||
input.WorkOrderIds = input.WorkOrderIds.Concat(moIds).ToList();
|
||
}
|
||
|
||
string getMoStatus(MoBehavior behavior)
|
||
{
|
||
string status = "";
|
||
switch (behavior)
|
||
{
|
||
case MoBehavior.Release:
|
||
status = DictConst.IssueId;
|
||
break;
|
||
case MoBehavior.Closed:
|
||
status = DictConst.MoCloseId;
|
||
break;
|
||
}
|
||
return status!;
|
||
}
|
||
var behavior = input.Behavior.ToEnum<MoBehavior>();
|
||
var status = getMoStatus(behavior);
|
||
var row = await db.Updateable<PrdMo>()
|
||
.SetColumns(it => new PrdMo { mo_status = status })
|
||
.Where(it => input.WorkOrderIds.Contains(it.id))
|
||
.ExecuteCommandAsync();
|
||
return (row > 0);
|
||
}
|
||
// /// <summary>
|
||
// /// 关联同组工单
|
||
// /// </summary>
|
||
// /// <param name="input">关联同组工单输入参数</param>
|
||
// /// <returns></returns>
|
||
// [HttpPost]
|
||
// public async Task<dynamic> RelevancySameGroupMo(MoCrInput input)
|
||
// {
|
||
// (bool executeRes, string errMsg) multi = (true, "");
|
||
// var list = await _repository.AsSugarClient().Queryable<PrdMo>()
|
||
// .InnerJoin<ToolMolds>((a, b) => a.material_id == b.material_id)
|
||
// .Where((a, b) => input.WorkOrderIds.Contains(a.id))
|
||
// .Select((a, b) => new
|
||
// {
|
||
// planDate = a.plan_start_date,
|
||
// mold_code = b.mold_code,
|
||
// }).ToListAsync();
|
||
// var planDateAll = true;
|
||
// var moldIdAll = true;
|
||
// if (list?.Count > 0)
|
||
// {
|
||
// var planDate = list.FirstOrDefault()?.planDate;
|
||
// var moldCode = list.FirstOrDefault()?.mold_code;
|
||
//
|
||
// planDateAll = list.Skip(1).All(x => x.planDate == planDate);
|
||
// moldIdAll = list.Skip(1).All(x => x.mold_code == moldCode);
|
||
// if (planDateAll && moldIdAll)
|
||
// {
|
||
// var groupId = SnowflakeIdHelper.NextId();
|
||
// multi.executeRes = await _repository.AsSugarClient().Updateable<PrdMo>()
|
||
// .SetColumns(c => new PrdMo { combine_mo_code = groupId })
|
||
// .Where(it => input.WorkOrderIds.Contains(it.id))
|
||
// .ExecuteCommandHasChangeAsync();
|
||
// }
|
||
// else
|
||
// {
|
||
// multi.executeRes = false;
|
||
// if (!planDateAll)
|
||
// {
|
||
// throw new AppFriendlyException("计划开始日期不一致", null);
|
||
// }
|
||
// if (!moldIdAll)
|
||
// {
|
||
// throw new AppFriendlyException("未关联到同一模具下", null);
|
||
// }
|
||
// }
|
||
// }
|
||
// return multi;
|
||
// }
|
||
|
||
/// <summary>
|
||
/// 关联同组工单
|
||
/// </summary>
|
||
/// <param name="input">关联同组工单输入参数</param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> RelevancySameGroupMo(MoCrInput input)
|
||
{
|
||
(bool executeRes, string errMsg) multi = (true, "");
|
||
var list = await _repository.AsSugarClient().Queryable<PrdMo>()
|
||
.LeftJoin<ToolMoldsMaterial>((a, b) => a.material_id == b.material_id)
|
||
.LeftJoin<ToolMolds>((a,b,c)=>b.mold_id==c.id)
|
||
.Where((a, b,c) => input.WorkOrderIds.Contains(a.id))
|
||
.Select((a, b,c) => new
|
||
{
|
||
planDate = a.plan_start_date,
|
||
mold_code = c.mold_code,
|
||
}).ToListAsync();
|
||
var planDateAll = true;
|
||
var moldIdAll = true;
|
||
if (list?.Count > 0)
|
||
{
|
||
var planDate = list.FirstOrDefault()?.planDate;
|
||
var moldCode = list.FirstOrDefault()?.mold_code;
|
||
|
||
planDateAll = list.All(x => x.planDate == planDate);
|
||
moldIdAll = moldCode != null && list.All(x => x.mold_code == moldCode);
|
||
if (planDateAll && moldIdAll)
|
||
{
|
||
var groupId = SnowflakeIdHelper.NextId();
|
||
multi.executeRes = await _repository.AsSugarClient().Updateable<PrdMo>()
|
||
.SetColumns(c => new PrdMo { combine_mo_code = groupId })
|
||
.Where(it => input.WorkOrderIds.Contains(it.id))
|
||
.ExecuteCommandHasChangeAsync();
|
||
}
|
||
else
|
||
{
|
||
multi.executeRes = false;
|
||
if (!planDateAll)
|
||
{
|
||
throw Oops.Bah("计划开始日期不一致");
|
||
}
|
||
if (!moldIdAll)
|
||
{
|
||
throw Oops.Bah("未关联到同一模具下");
|
||
}
|
||
}
|
||
}
|
||
return multi;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 取消关联
|
||
/// </summary>
|
||
/// <param name="input">取消关联输入参数</param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> CanelRelevancy(MoCrInput input)
|
||
{
|
||
return await _repository.AsSugarClient().Updateable<PrdMo>()
|
||
.SetColumns(c => new PrdMo { combine_mo_code = "" })
|
||
.Where(it => input.WorkOrderIds.Contains(it.id))
|
||
.ExecuteCommandHasChangeAsync();
|
||
}
|
||
|
||
|
||
|
||
#endregion
|
||
|
||
#region 工单追溯相关
|
||
|
||
/// <summary>
|
||
/// 工单追溯一级列表
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdMoFromOneList(PrdMoFromQueryInput input)
|
||
{
|
||
List<string> ids = new List<string>();
|
||
List<string> ids1 = new List<string>();
|
||
List<string> ids2 = new List<string>();
|
||
if (!string.IsNullOrEmpty(input.mo_task_code))
|
||
{
|
||
ids1 = await _db.Queryable<PrdMoTask>().Where(x => x.mo_task_code.Contains(x.mo_task_code)).Select(x => x.mo_id).ToListAsync();
|
||
ids = ids1;
|
||
}
|
||
if (!string.IsNullOrEmpty(input.batch))
|
||
{
|
||
ids2 = await _db.Queryable<PrdReport>()
|
||
.LeftJoin<PrdMoTask>((a,b)=>a.mo_task_id==b.id)
|
||
.Where((a,b) => a.batch.Contains(input.batch)).Select((a,b) => b.mo_id).ToListAsync();
|
||
ids = ids2;
|
||
}
|
||
|
||
if (!string.IsNullOrEmpty(input.mo_task_code) && !string.IsNullOrEmpty(input.batch))
|
||
{
|
||
ids = ids1.Intersect(ids2).ToList();
|
||
}
|
||
|
||
var result = await _db.Queryable<PrdMo>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.WhereIF(!string.IsNullOrEmpty(input.mo_code),(a,b)=>a.mo_code.Contains(input.mo_code))
|
||
.WhereIF(ids!=null && ids.Count>0,(a,b)=>ids.Contains(a.id))
|
||
.Select((a, b) =>
|
||
new PrdMoFromOneListOutput
|
||
{
|
||
id = a.id,
|
||
mo_code = a.mo_code,
|
||
material_id = a.material_id,
|
||
material_code = b.code,
|
||
material_name = b.name,
|
||
material_standard = b.material_standard,
|
||
act_start_date = a.act_start_date==null ? "" : a.act_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
act_end_date = a.act_end_date==null ? "" : a.act_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss")
|
||
}).ToPagedListAsync(input.currentPage, input.pageSize);
|
||
return PageResult<PrdMoFromOneListOutput>.SqlSugarPageResult(result);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 工单追溯二级列表
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdMoFromTwoList(Dictionary<string,string> dic)
|
||
{
|
||
string mo_id = dic.ContainsKey("mo_id") ? dic["mo_id"] : "";
|
||
string mo_task_code = dic.ContainsKey("mo_task_code") ? dic["mo_task_code"] : "";
|
||
string batch = dic.ContainsKey("batch") ? dic["batch"] : "";
|
||
List<string> ids = new List<string>();
|
||
if (!string.IsNullOrEmpty(batch))
|
||
{
|
||
ids = await _db.Queryable<PrdReport>().Where(x => x.batch.Contains(batch)).Select(x=>x.mo_task_id).ToListAsync();
|
||
}
|
||
|
||
PrdMo prdMo = await _repository.GetSingleAsync(x => x.id == mo_id);
|
||
if (prdMo.mo_type is DictConst.PrdMoTypeZS or DictConst.PrdMoTypeJC)
|
||
{
|
||
return await _db.Queryable<PrdMoTask>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<OrganizeRelationEntity>((a,b,c)=>a.eqp_id==c.ObjectId && c.ObjectType=="Eqp")
|
||
.LeftJoin<OrganizeEntity>((a,b,c,d)=>c.OrganizeId==d.Id)
|
||
.LeftJoin<OrganizeEntity>((a,b,c,d,e)=>d.OrganizeIdTree.Contains(e.Id) && e.Category==DictConst.RegionCategoryWorkshopCode)
|
||
.LeftJoin<EqpEquipment>((a,b,c,d,e,f)=>a.eqp_id==f.id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_id),(a,b,c,d)=>a.mo_id==mo_id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_task_code),(a,b,c,d)=>a.mo_task_code==mo_task_code)
|
||
.WhereIF(ids!=null && ids.Count>0,(a,b,c,d)=>ids.Contains(a.id))
|
||
.Select((a, b, c, d,e,f) =>
|
||
new PrdMoFromTwoListOutput
|
||
{
|
||
id = a.id,
|
||
mo_task_code = a.mo_task_code,
|
||
material_id = a.material_id,
|
||
material_code = b.code,
|
||
material_name = b.name,
|
||
material_standard = b.material_standard,
|
||
act_start_date = a.act_start_date == null ? "" : a.act_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
act_end_date = a.act_end_date == null ? "" : a.act_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
workshop_name = e.FullName,
|
||
station_name = d.FullName,
|
||
equip_code = f.code
|
||
}).ToListAsync();
|
||
}
|
||
else
|
||
{
|
||
return await _db.Queryable<PrdMoTask>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<OrganizeEntity>((a, b, c) => a.workline_id == c.Id)
|
||
.LeftJoin<BasMbom>((a, b, c, d) => a.bom_id == d.id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_id),(a,b,c,d)=>a.mo_id==mo_id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_task_code),(a,b,c,d)=>a.mo_task_code.Contains(mo_task_code))
|
||
.WhereIF(ids!=null && ids.Count>0,(a,b,c,d)=>ids.Contains(a.id))
|
||
.Select((a, b, c, d) =>
|
||
new PrdMoFromTwoListOutput
|
||
{
|
||
id = a.id,
|
||
mo_task_code = a.mo_task_code,
|
||
material_id = a.material_id,
|
||
material_code = b.code,
|
||
material_name = b.name,
|
||
material_standard = b.material_standard,
|
||
act_start_date = a.act_start_date == null ? "" : a.act_start_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
act_end_date = a.act_end_date == null ? "" : a.act_end_date.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
workline_name = c.FullName,
|
||
mbom_version = d.version
|
||
}).ToListAsync();
|
||
}
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 工单追溯三级级列表
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdMoFromThreeList(Dictionary<string,string> dic)
|
||
{
|
||
string mo_task_id = dic.ContainsKey("mo_task_id") ? dic["mo_task_id"] : "";
|
||
string mo_task_code = dic.ContainsKey("mo_task_code") ? dic["mo_task_code"] : "";
|
||
string batch = dic.ContainsKey("batch") ? dic["batch"] : "";
|
||
List<string> ids = new List<string>();
|
||
if (!string.IsNullOrEmpty(batch))
|
||
{
|
||
ids = await _db.Queryable<PrdReport>().Where(x => x.batch.Contains(batch)).Select(x=>x.mo_task_id).ToListAsync();
|
||
}
|
||
|
||
PrdMoTask prdMoTask = await _db.Queryable<PrdMoTask>().SingleAsync(x => x.id == mo_task_id);
|
||
List<BasProcessStation> processStations = await _db.Queryable<BasProcessStation>().Where(x=>x.process_id==prdMoTask.process_id).ToListAsync();
|
||
List<string> orgIds = processStations.Select(x => x.id).ToList();
|
||
List<OrganizeEntity> orgs = await _db.Queryable<OrganizeEntity>().Where(x=>x.Category==DictConst.RegionCategoryStationCode && x.DeleteMark==null).ToListAsync();
|
||
return await _db.Queryable<PrdMoTask>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<BasProcess>((a,b,c)=>a.process_id==c.id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_task_id),(a,b,c)=>a.id==mo_task_id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_task_code),(a,b,c)=>a.mo_task_code.Contains(mo_task_code))
|
||
.WhereIF(ids!=null && ids.Count>0,(a,b,c)=>ids.Contains(a.id))
|
||
.Select((a, b, c) =>
|
||
new PrdMoFromThreeListOutput
|
||
{
|
||
id = a.id,
|
||
mo_task_code = a.mo_task_code,
|
||
material_id = a.material_id,
|
||
material_code = b.code,
|
||
workline_id = a.workline_id,
|
||
material_name = b.name,
|
||
process_id = a.process_id,
|
||
process_name = c.process_name,
|
||
}).Mapper(x =>
|
||
{
|
||
List<string> orgId1 = orgs.Where(y => y.OrganizeIdTree.Contains(x.workline_id)).Select(y=>y.Id).ToList();
|
||
string station_id = orgIds.Intersect(orgId1)?.FirstOrDefault();
|
||
if (!string.IsNullOrEmpty(station_id))
|
||
{
|
||
x.station_name = orgs.FirstOrDefault(y => y.Id == station_id)?.FullName;
|
||
}
|
||
}).ToListAsync();
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 工单追溯人列表
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdMoFromManList(Dictionary<string,string> dic)
|
||
{
|
||
string mo_task_id = dic.ContainsKey("mo_task_id") ? dic["mo_task_id"] : "";
|
||
string batch = dic.ContainsKey("batch") ? dic["batch"] : "";
|
||
List<string> ids = new List<string>();
|
||
if (!string.IsNullOrEmpty(batch))
|
||
{
|
||
ids = await _db.Queryable<PrdReport>().Where(x => x.batch.Contains(batch)).Select(x=>x.mo_task_id).ToListAsync();
|
||
}
|
||
|
||
return await _db.Queryable<PrdReport>()
|
||
.LeftJoin<UserEntity>((a, b) => a.create_id == b.Id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_task_id), (a, b) => a.mo_task_id == mo_task_id)
|
||
.WhereIF(ids!=null && ids.Count>0,(a,b)=>ids.Contains(a.mo_task_id))
|
||
.GroupBy((a,b)=>new {a.create_id,employee_name = b.RealName})
|
||
.Select((a, b) => new PrdMoFromManListOutput()
|
||
{
|
||
// id = a.id,
|
||
employee_name = b.RealName,
|
||
start_time = SqlFunc.AggregateMin(a.create_time),
|
||
end_time = SqlFunc.AggregateMax(a.create_time)
|
||
}).Mapper(x =>
|
||
{
|
||
x.work_time = (x.start_time == null ? "" : x.start_time.Value.ToString("yyyy-MM-dd HH:mm:ss")) + "~" + (x.end_time == null ? "" : x.end_time.Value.ToString("yyyy-MM-dd HH:mm:ss"));
|
||
})
|
||
.ToListAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 工单追溯机列表
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdMoFromEquipList(Dictionary<string,string> dic)
|
||
{
|
||
string mo_task_id = dic.ContainsKey("mo_task_id") ? dic["mo_task_id"] : "";
|
||
string batch = dic.ContainsKey("batch") ? dic["batch"] : "";
|
||
List<string> ids = new List<string>();
|
||
if (!string.IsNullOrEmpty(batch))
|
||
{
|
||
ids = await _db.Queryable<PrdReport>().Where(x => x.batch.Contains(batch)).Select(x=>x.mo_task_id).ToListAsync();
|
||
}
|
||
|
||
return await _db.Queryable<PrdMoTask>()
|
||
.LeftJoin<EqpEquipment>((a, b) => a.eqp_id == b.id)
|
||
.LeftJoin<ToolMolds>((a,b,c)=>a.mold_id==c.id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_task_id), (a, b) => a.id == mo_task_id)
|
||
.WhereIF(ids!=null && ids.Count>0,(a,b)=>ids.Contains(a.id))
|
||
.Select((a, b,c) => new PrdMoFromEquipListOutput()
|
||
{
|
||
equip_code = b.code,
|
||
mold_code = b.code,
|
||
}).ToListAsync();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 工单追溯料列表
|
||
/// </summary>
|
||
/// <param name="input"></param>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<dynamic> PrdMoFromMaterialList(Dictionary<string,string> dic)
|
||
{
|
||
string mo_task_id = dic.ContainsKey("mo_task_id") ? dic["mo_task_id"] : "";
|
||
string batch = dic.ContainsKey("batch") ? dic["batch"] : "";
|
||
List<string> ids = new List<string>();
|
||
if (!string.IsNullOrEmpty(batch))
|
||
{
|
||
ids = await _db.Queryable<PrdReport>().Where(x => x.batch.Contains(batch)).Select(x=>x.mo_task_id).ToListAsync();
|
||
}
|
||
|
||
return await _db.Queryable<PrdFeedingD>()
|
||
.LeftJoin<BasMaterial>((a, b) => a.material_id == b.id)
|
||
.LeftJoin<PrdMaterialReceiptD>((a,b,c)=>a.material_receipt_detail_id==c.id)
|
||
.LeftJoin<BasSupplier>((a,b,c,d)=>c.supplier_id==d.id)
|
||
.LeftJoin<PrdFeedingH>((a,b,c,d,e)=>a.feeding_id==e.id)
|
||
.WhereIF(!string.IsNullOrEmpty(mo_task_id), (a, b,c,d,e) => e.mo_task_id == mo_task_id)
|
||
.WhereIF(ids!=null && ids.Count>0,(a,b,c,d,e)=>ids.Contains(a.id))
|
||
.Select((a,b,c,d,e)=>new PrdMoFromMaterialListOutput()
|
||
{
|
||
material_code = b.code,
|
||
material_name = b.name,
|
||
batch = a.batch,
|
||
supplier_name = d.supplier_name,
|
||
check_conclusion = c.check_conclusion,
|
||
instock_time = c.instock_time.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
feeding_time = e.create_time==null ? "" : e.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss"),
|
||
}).ToListAsync();
|
||
}
|
||
|
||
#endregion
|
||
}
|
||
}
|
||
|