修改往来单位查询

Myshipping.Application/Entity/BookingTruck.cs

@@ -211,5 +211,10 @@ namespace Myshipping.Application.Entity
         /// </summary>
         [Description("派车流水号")]
         public string TruckFlowNo { get; set; }
+        /// <summary>
+        /// 任务流水号
+        /// </summary>
+        [Description("任务流水号")]
+        public string TaskNo { get; set; }
     }
 }

Myshipping.Application/Service/BookingTruck/BookingTruckService.cs

@@ -65,71 +65,84 @@ namespace Myshipping.Application
 
             try
             {
-                BookingTruck entity = info.Adapt<BookingTruck>();
+                var id = InnerSave(info);
 
-                if(entity == null)
-                    throw Oops.Oh($"派车信息不能为空");
+                result.succ = true;
+                result.msg = "保存成功";
+                result.ext = id;
+            }
+            catch (Exception ex)
+            {
+                result.succ = false;
+                result.msg = $"保存派车异常，原因：{ex.Message}";
+            }
 
-                List<BookingTruckCtn> entityCtnList = info.ContaList.Adapt<List<BookingTruckCtn>>();
+            return result;
+        }
 
-                if (entity.Id == 0)
-                {
-                    _bookingTruckRepository.Insert(entity);
 
-                    if (entityCtnList.Count > 0)
-                    {
-                        entityCtnList.ForEach(async ctn =>
-                        {
-                            ctn.TruckId = entity.Id;
+        /// <summary>
+        /// 保存内部方法
+        /// </summary>
+        /// <param name="info">派车信息</param>
+        /// <returns>返回派车Id</returns>
+        private async Task<long> InnerSave(BookingTruckDto info)
+        {
+            BookingTruck entity = info.Adapt<BookingTruck>();
 
-                            await _bookingTruckContaRepository.InsertAsync(ctn);
-                        });
-                    }
-                }
-                else
+            if (entity == null)
+                throw Oops.Oh($"派车信息不能为空");
+
+            List<BookingTruckCtn> entityCtnList = info.ContaList.Adapt<List<BookingTruckCtn>>();
+
+            if (entity.Id == 0)
+            {
+                _bookingTruckRepository.Insert(entity);
+
+                if (entityCtnList.Count > 0)
                 {
-                    await _bookingTruckRepository.AsUpdateable(entity).IgnoreColumns(it => new
-                    {
-                        it.TenantId,
-                        it.CreatedTime,
-                        it.CreatedUserId,
-                        it.CreatedUserName,
-                        it.IsDeleted,
-                        it.BookingId,
-                        it.TruckId,
-                        it.TruckName,
-                        it.TruckCode,
-                    }).ExecuteCommandAsync();
-
-                    if (entityCtnList.Count > 0)
+                    entityCtnList.ForEach(async ctn =>
                     {
-                        entityCtnList.ForEach(async ctn =>
-                        {
-                            ctn.TruckId = entity.Id;
+                        ctn.TruckId = entity.Id;
 
-                            await _bookingTruckContaRepository.AsUpdateable(ctn).IgnoreColumns(it => new
-                            {
-                                it.TenantId,
-                                it.CreatedTime,
-                                it.CreatedUserId,
-                                it.CreatedUserName,
-                                it.IsDeleted,
-                            }).ExecuteCommandAsync();
-                        });
-                    }
+                        await _bookingTruckContaRepository.InsertAsync(ctn);
+                    });
                 }
-
-                result.succ = true;
-                result.msg = "保存成功";
-                result.ext = entity.Id;
             }
-            catch (Exception ex)
+            else
             {
-                result.succ = false;
-                result.msg = $"保存派车异常，原因：{ex.Message}";
+                await _bookingTruckRepository.AsUpdateable(entity).IgnoreColumns(it => new
+                {
+                    it.TenantId,
+                    it.CreatedTime,
+                    it.CreatedUserId,
+                    it.CreatedUserName,
+                    it.IsDeleted,
+                    it.BookingId,
+                    it.TruckId,
+                    it.TruckName,
+                    it.TruckCode,
+                }).ExecuteCommandAsync();
+
+                if (entityCtnList.Count > 0)
+                {
+                    entityCtnList.ForEach(async ctn =>
+                    {
+                        ctn.TruckId = entity.Id;
+
+                        await _bookingTruckContaRepository.AsUpdateable(ctn).IgnoreColumns(it => new
+                        {
+                            it.TenantId,
+                            it.CreatedTime,
+                            it.CreatedUserId,
+                            it.CreatedUserName,
+                            it.IsDeleted,
+                        }).ExecuteCommandAsync();
+                    });
+                }
             }
 
-            return result;
+            return entity.Id;
         }
 
         /// <summary>
@@ -472,11 +485,19 @@ namespace Myshipping.Application
 
             try
             {
+                var model = InnerCreateTruckFromBookingOrder(bookingId);
 
+                result.succ = true;
+
+                if (model != null && model.ContaList != null && model.ContaList.Count > 0)
+                {
+                    result.ext = model.ContaList;
+                }
             }
             catch (Exception ex)
             {
-
+                result.succ = false;
+                result.msg = $"引入订舱详情生成派车信息异常，原因：{ex.Message}";
             }
 
             return result;
@@ -492,9 +513,21 @@ namespace Myshipping.Application
         {
             TaskManageOrderResultDto result = new TaskManageOrderResultDto();
 
+            /*
+             提交派车流程
+             1、先保存一遍派车信息。（需校验当前派车信息未提交，只有暂存的才能保存）
+             2、调取派车任务接口推送派车任务。
+             3、派车任务推送成功后更新状态、任务ID。
+             4、返回结果。
+             */
             try
             {
+                //先保存
+                var id = InnerSave(info);
+
+                //更新派车订单为已提交
 
+                //推送新增派车任务接口
             }
             catch (Exception ex)
             {
@@ -514,6 +547,13 @@ namespace Myshipping.Application
         {
             TaskManageOrderResultDto result = new TaskManageOrderResultDto();
 
+            /*
+             批量提交派车流程
+             1、需校验当前派车信息未提交
+             2、调取派车任务接口推送派车任务。
+             3、派车任务推送成功后更新状态、任务ID。
+             4、返回结果。
+             */
             try
             {
 
@@ -534,6 +574,14 @@ namespace Myshipping.Application
         [HttpGet("/BookingTruck/Cancel")]
         public async Task<TaskManageOrderResultDto> Cancel(long id)
         {
+            /*
+             撤销派车流程
+             1、确定当前派车已提交。
+             2、调取取消派车任务接口，申请撤销派车。
+             3、取消派车推送成功后更新状态。
+             4、返回结果。
+             */
+
             TaskManageOrderResultDto result = new TaskManageOrderResultDto();
 
             try
@@ -557,6 +605,13 @@ namespace Myshipping.Application
         {
             TaskManageOrderResultDto result = new TaskManageOrderResultDto();
 
+            /*
+             批量撤销派车流程
+             1、确定当前派车已提交。
+             2、调取取消派车任务接口，申请撤销派车。
+             3、取消派车推送成功后更新状态。
+             4、返回结果。
+             */
             try
             {
 

Myshipping.Application/Service/BookingTruck/Dtos/BookingTruckCtnDto.cs

@@ -96,5 +96,17 @@ namespace Myshipping.Application
         /// 备注
         /// </summary>
         public string REMARK { get; set; }
+        /// <summary>
+        /// 车牌号
+        /// </summary>
+        public string CarNumber { get; set; }
+        /// <summary>
+        /// 司机
+        /// </summary>
+        public string CarDriver { get; set; }
+        /// <summary>
+        /// 司机电话
+        /// </summary>
+        public string CarDriverTel { get; set; }
     }
 }

Myshipping.Application/Service/Para/Interface/IParaService.cs

@@ -1,4 +1,5 @@
-using System;
+using Myshipping.Core.Service;
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
@@ -116,5 +117,14 @@ namespace Myshipping.Application
         /// <param name="QuerySearch">约号参数台账查询请求</param>
         /// <returns>返回结果</returns>
         Task<dynamic> GetParaContractNoPageAsync(QueryParaContractNoDto QuerySearch);
+
+        /// <summary>
+        /// 检索车队参数
+        /// </summary>
+        /// <param name="queryItem">检索值</param>
+        /// <param name="queryType">检索类型 fleet-车队（默认）；customs_broker-报关行</param>
+        /// <param name="top">默认最大行数</param>
+        /// <returns>返回回执</returns>
+        //Task<List<DjyCustomerDto>> QuerytDjyCustomerInfo(string queryItem, string queryType = "fleet", int top = 10);
     }
 }

Myshipping.Core/Myshipping.Core.xml

@@ -9922,6 +9922,15 @@
             <param name="type">类型，参考字典参数：客户属性（djy_cust_prop）</param>
             <returns></returns>
         </member>
+        <member name="M:Myshipping.Core.Service.DjyCustomerService.QuerytDjyCustomerInfo(System.String,System.String[],System.Int32)">
+            <summary>
+            检索往来单位（包含车队）
+            </summary>
+            <param name="queryItem">检索值</param>
+            <param name="queryType">检索类型数组（可传多个） fleet-车队；customs_broker-报关行</param>
+            <param name="top">默认最大行数</param>
+            <returns>返回回执</returns>
+        </member>
         <member name="T:Myshipping.Core.Service.DjyCustomerContactDto">
             <summary>
             订舱客户联系人输出参数
@@ -10772,6 +10781,15 @@
             服务项目
             </summary>
         </member>
+        <member name="M:Myshipping.Core.Service.IDjyCustomerService.QuerytDjyCustomerInfo(System.String,System.String[],System.Int32)">
+            <summary>
+            检索车队参数
+            </summary>
+            <param name="queryItem">检索值</param>
+            <param name="queryType">检索类型数组（可传多个） fleet-车队；customs_broker-报关行</param>
+            <param name="top">默认最大行数</param>
+            <returns>返回回执</returns>
+        </member>
         <member name="T:Myshipping.Core.Service.DjyDingtalkGroupConfigService">
             <summary>
             钉钉客服通知群配置服务

Myshipping.Core/Service/DjyCustomer/DjyCustomerService.cs

@@ -11,6 +11,9 @@ using System.Collections.Generic;
 using Furion.FriendlyException;
 using Furion.Logging;
 using Microsoft.Extensions.Logging;
+using System;
+using System.Text.RegularExpressions;
+using NPOI.Util;
 
 namespace Myshipping.Core.Service
 {
@@ -203,5 +206,64 @@ namespace Myshipping.Core.Service
             return entities.XnPagedResult();
         }
 
+        /// <summary>
+        /// 检索往来单位（包含车队）
+        /// </summary>
+        /// <param name="queryItem">检索值</param>
+        /// <param name="queryType">检索类型数组（可传多个） fleet-车队；customs_broker-报关行</param>
+        /// <param name="top">默认最大行数</param>
+        /// <returns>返回回执</returns>
+        [HttpGet("/DjyCustomer/QuerytDjyCustomerInfo")]
+        public async Task<List<DjyCustomerOutput>> QuerytDjyCustomerInfo([FromQuery] string queryItem, [FromQuery] string[] queryType, [FromQuery] int top = 10)
+        {
+            List<DjyCustomerOutput> list = new List<DjyCustomerOutput>();
+
+            try
+            {
+                string sqlWhere = "1=1";
+
+                if (!string.IsNullOrWhiteSpace(queryItem))
+                {
+                    sqlWhere += $" and (CodeName like '%{queryItem.Trim()}%' or ShortName like '%{queryItem.Trim()}%' or FullName like '%{queryItem.Trim()}%')";
+                }
+
+                if (queryType.Length > 0)
+                {
+                    sqlWhere += $" and PropString REGEXP '" + string.Join("|", queryType) + "'";
+                }
+
+                var entityList = await _rep.AsQueryable().Where(sqlWhere).Take(top).OrderBy(a => a.FullName)
+                    .ToListAsync();
+
+                if (entityList.Count > 0)
+                {
+                    list = entityList.Adapt<List<DjyCustomerOutput>>();
+
+                    var custsArg = list.Select(a => a.Id).ToArray();
+                    var contactList = _repContact.AsQueryable()
+                        .Where(a => custsArg.Contains(a.CustomerId.Value)).ToList();
+
+                    list = list.GroupJoin(contactList, l => l.Id, r => r.CustomerId.Value, (l, r) =>
+                    {
+                        var curList = r.ToList();
+
+                        if (curList.Count > 0)
+                            l.Contacts = curList.Adapt<List<DjyCustomerContactOutput>>();
+
+                        return l;
+
+                    }).ToList();
+                }
+
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError("检索车队异常，请求：queryItem={0}；queryType={1}；top={2} 异常：{3}", queryItem, queryType, top, ex.Message);
+
+                throw Oops.Bah("检索车队异常，异常{msg}", ex.Message);
+            }
+
+            return list;
+        }
     }
 }

Myshipping.Core/Service/DjyCustomer/IDjyCustomerService.cs

@@ -15,5 +15,14 @@ namespace Myshipping.Core.Service
         Task<DjyCustomerOutput> Detail([FromQuery] GetDjyCustomerInput input);
         //Task<dynamic> List([FromQuery] QueryBookingCustomerInput input);
         Task<List<DjyCustomerContactOutput>> ListContact(long customerId);
+
+        /// <summary>
+        /// 检索车队参数
+        /// </summary>
+        /// <param name="queryItem">检索值</param>
+        /// <param name="queryType">检索类型数组（可传多个） fleet-车队；customs_broker-报关行</param>
+        /// <param name="top">默认最大行数</param>
+        /// <returns>返回回执</returns>
+        Task<List<DjyCustomerOutput>> QuerytDjyCustomerInfo(string queryItem, string[] queryType, int top = 10);
     }
 }