| | |
| | | using Tiger.Business.WMS.Sharetronic.Shelf; |
| | | using Tiger.Model.Entitys.MES.U9C; |
| | | using Tiger.Model.MES.Yada; |
| | | using static IronPython.Modules._ast; |
| | | |
| | | namespace Tiger.Business.WMS.Transaction |
| | | { |
| | |
| | | /// </summary> |
| | | public class In_BIZ_U9_RECEIPT : WmsTask, IIn_BIZ_U9_RECEIPT |
| | | { |
| | | |
| | | public IIn_BIZ_U9_RECEIPT Init(string id, string userCode, string apiHost, string orgCode) |
| | | { |
| | | base.Init(id, userCode, apiHost, orgCode); |
| | |
| | | } |
| | | |
| | | #region Propertys & Variables |
| | | |
| | | public string CurOrderNo { get; set; } |
| | | #endregion |
| | | |
| | | #region Functions |
| | |
| | | return SetOutPutMqttMsg(action, input.Locale); |
| | | } |
| | | |
| | | CurOrderNo = receipt.ORDER_NO; |
| | | |
| | | //执行上架数据处理 |
| | | foreach (var item in CurInvItem.Items) |
| | | { |
| | |
| | | }); |
| | | |
| | | //完成所有处理后使用事务保存数据 |
| | | action = DoIfFinish(action, input.Locale, () => { |
| | | action = DoIfFinish(action, input.Locale, () => |
| | | { |
| | | //设置当前物料的默认储位 |
| | | if (CurInvItem.ItemInfo.DEFAULT_LOCATION.IsNullOrEmpty()) |
| | | { |
| | | SetDefaultLocation(MainDB, CurInvItem.ItemInfo, nLocation); |
| | | } |
| | | }); |
| | | //if (!action.Data.Data.IsNullOrEmpty() && action.Data.Data is DefaultInStoreOutput) |
| | | //{ |
| | | // (action.Data.Data as DefaultInStoreOutput).OrderInfo = receipt; |
| | | //} |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | return SetOutPutMqttMsg(action, locale); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取需要上架的收货单列表(带分页) |
| | | /// </summary> |
| | | /// <returns></returns> |
| | | public async Task<ApiAction<PageAble<BIZ_U9_RECEIPT>>> GetOrderList(BaseInputWithPage input) |
| | | { |
| | | var action = new ApiAction<PageAble<BIZ_U9_RECEIPT>>(); |
| | | var query = Biz.DataSource["YadaU9C"].Client.Queryable<mes_ReturnedDocInfo>().Where(q => q.Status == 3) |
| | | .WhereIF(!input.OrderNo.IsNullOrEmpty(), q => q.DocNo.Contains(input.OrderNo)) |
| | | .OrderBy(q => q.DocNo).ToPage(input.pageIndex, input.pageSize); |
| | | |
| | | action.Data = await MainDB.Queryable<BIZ_U9_RECEIPT>().Where(q => query.data.Select(o => o.DocNo).Contains(q.ORDER_NO)).ToPageAsync(input.pageIndex, input.pageSize); |
| | | foreach (var order in action.Data.data) |
| | | { |
| | | order.ERP_STATUS_CODE = query.data.FirstOrDefault(q => q.DocNo == order.ORDER_NO)?.Status.ToString(); |
| | | order.ERP_STATUS_NAME = query.data.FirstOrDefault(q => q.DocNo == order.ORDER_NO)?.StatusName; |
| | | } |
| | | MainDB.Updateable(action.Data.data, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.ERP_STATUS_CODE, q.ERP_STATUS_NAME }).ExecuteCommand(); |
| | | return action; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 获取当前收货单信息 |
| | | /// </summary> |
| | | /// <returns></returns> |
| | | public async Task<ApiAction<BIZ_U9_RECEIPT>> GetCurOrder() |
| | | { |
| | | var action = new ApiAction<BIZ_U9_RECEIPT>(); |
| | | action.Data = MainDB.Queryable<BIZ_U9_RECEIPT>().Where(q => q.ORDER_NO == CurOrderNo).IncludesAllFirstLayer().First(); |
| | | return action; |
| | | } |
| | | |
| | | #endregion |
| | | |
| | | /// <summary> |