wms:agv:init

ZR.Service/mes/wms/WmAGVService.cs

@@ -0,0 +1,124 @@
+using System;
+using SqlSugar;
+using Infrastructure.Attribute;
+using Infrastructure.Extensions;
+using ZR.Model;
+
+using ZR.Repository;
+using ZR.Service.Business.IBusinessService;
+using System.Linq;
+using ZR.Model.MES.wms;
+using ZR.Model.MES.wms.Dto;
+using ZR.Service.mes.wms.IService;
+using ZR.Model.MES.pro;
+using Mapster;
+
+namespace ZR.Service.Business
+{
+    /// <summary>
+    /// 盘点记录Service业务层处理
+    /// </summary>
+    [AppService(ServiceType = typeof(IWmAGVService), ServiceLifetime = LifeTime.Transient)]
+    public class WmAGVService : BaseService<AgvTask>, IWmAGVService
+    {
+       
+
+        /// <summary>
+        /// 1.获取工单列表
+        /// </summary>
+        /// <param name="parm"></param>
+        /// <returns></returns>
+        public List<AGVWorkorderDto> GetList(QueryAGVparam param)
+        {
+            List<AGVWorkorderDto>  aGVWorkorderDtos = new List<AGVWorkorderDto>();
+            var predicate = Expressionable.Create<ProWorkorder_v2>()
+                .AndIF(param.year > 0, it => it.Year == param.year)
+                .AndIF(param.week > 0, it => it.Week == param.week)
+                .AndIF(param.day > 0, it => it.Date == param.day);
+
+            var response = Context.Queryable<ProWorkorder_v2>()
+                .Where(it=>it.Remark3=="是")
+                .Where(predicate.ToExpression()).ToList();
+            foreach (var item in response)
+            {
+                aGVWorkorderDtos.Add(item.Adapt<AGVWorkorderDto>());
+            }
+            return aGVWorkorderDtos;
+        }
+
+
+        /// <summary>
+        /// 2.获取当前工单下的所有AGV小车任务
+        /// </summary>
+        /// <param name="workorder_id"></param>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public List<AgvTask> QueryAGVTask(string workorder_id)
+        {
+           return Context.Queryable<AgvTask>().Where(it => it.FkWorkorderId == workorder_id).OrderByDescending(it=>it.Sort).ToList();
+        }
+
+
+
+        /// <summary>
+        /// 3.新增AGV小车任务
+        /// </summary>
+        /// <param name="task"></param>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public int AddAGVTask(AgvTask task)
+        {
+            int result = 0;
+            //TODO  1 判断agv小车task是否可以新增
+            if(string.IsNullOrEmpty(task.FkWorkorderId))
+            {
+                return -1;
+            }
+            ProWorkorder_v2 workorder = Context.Queryable<ProWorkorder_v2>()
+                .Where(it => it.Id == task.FkWorkorderId)
+                .First();
+              
+            int require_num= workorder.PreviousNumber;
+            int all_require_num=Context.Queryable<AgvTask>().Where(it => it.FkWorkorderId == workorder.Id).Sum(it => it.Number)??0;
+
+            if(require_num>all_require_num)
+            {
+                task.Id = SnowFlakeSingle.Instance.NextId().ToString();
+                result= Context.Insertable(task).ExecuteCommand();
+            }
+
+
+            return result;
+        }
+
+
+        /// <summary>
+        /// 4.删除AGV小车任务
+        /// </summary>
+        /// <param name="taskId"></param>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public int DeleteTask(string taskId)
+        {
+          return  Context.Deleteable<AgvTask>().Where(it=>it.Id==taskId).ExecuteCommand();
+
+        }
+
+        /// <summary>
+        /// 6 获取agv 起点和终点
+        /// </summary>
+        /// <param name="location"></param>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public List<AgvLocation> GetAGV_position_list(AgvLocation location)
+        {
+            var predicate = Expressionable.Create<AgvLocation>()
+                .AndIF(string.IsNullOrEmpty(location.Area), it => it.Area == location.Area)
+                .AndIF(location.Type > -1, it => it.Type == location.Type)
+                .AndIF(string.IsNullOrEmpty(location.Coordinate), it => it.Coordinate == location.Coordinate);
+
+
+          return   Context.Queryable<AgvLocation>().Where(predicate.ToExpression()).ToList();
+        }
+    }
+}