Merge branch 'master' of http://60.209.125.238:13080/whm/BookingHeChuan

Myshipping.Application/Service/BookingOrderContact/BookingOrderContactService.cs

@@ -10,6 +10,7 @@ using Myshipping.Application.Entity;
 using Microsoft.Extensions.Logging;
 using System.Collections.Generic;
 using Furion.FriendlyException;
+using Myshipping.Core.Entity;
 
 namespace Myshipping.Application
 {
@@ -20,11 +21,18 @@ namespace Myshipping.Application
     public class BookingOrderContactService : IBookingOrderContactService, IDynamicApiController, ITransient
     {
         private readonly SqlSugarRepository<BookingOrderContact> _rep;
+        private readonly SqlSugarRepository<BookingOrder> _repOrder;
+        private readonly SqlSugarRepository<DjyCustomerContact> _repContact;
         private readonly ILogger<BookingOrderContact> _logger;
 
-        public BookingOrderContactService(SqlSugarRepository<BookingOrderContact> rep, ILogger<BookingOrderContact> logger)
+        public BookingOrderContactService(SqlSugarRepository<BookingOrderContact> rep,
+            SqlSugarRepository<BookingOrder> repOrder,
+            SqlSugarRepository<DjyCustomerContact> repContact,
+            ILogger<BookingOrderContact> logger)
         {
             _rep = rep;
+            _repOrder = repOrder;
+            _repContact = repContact;
             _logger = logger;
         }
 
@@ -41,7 +49,7 @@ namespace Myshipping.Application
                                      .WhereIF(!string.IsNullOrWhiteSpace(input.Name), u => u.Name.Contains(input.Name.Trim()))
                                      .WhereIF(!string.IsNullOrWhiteSpace(input.Tel), u => u.Tel.Contains(input.Tel.Trim()))
                                      .WhereIF(!string.IsNullOrWhiteSpace(input.Email), u => u.Email.Contains(input.Email.Trim()))
-                                     .WhereIF(input.BookingId!=0,u=>u.BookingId==input.BookingId)
+                                     .WhereIF(input.BookingId != 0, u => u.BookingId == input.BookingId)
                                      .ToPagedListAsync(input.PageNo, input.PageSize);
             return entities.XnPagedResult();
         }
@@ -111,16 +119,32 @@ namespace Myshipping.Application
         /// <param name="input"></param>
         /// <returns></returns>
         [HttpPost("/BookingOrderContact/savebatch"), SqlSugarUnitOfWork]
-        public async Task SaveBatch(List<UpdateBookingOrderContactInput> input,long bookingId)
+        public async Task SaveBatch(List<UpdateBookingOrderContactInput> input, long bookingId)
         {
             _rep.Delete(x => x.BookingId == bookingId);
-            if (input!=null&&input.Count>0) {
+            if (input != null && input.Count > 0)
+            {
                 foreach (var item in input)
                 {
                     await _rep.InsertAsync(item.Adapt<BookingOrderContact>());
                 }
             }
 
+            //自动增加到该客户的联系人
+            var bookObj = _repOrder.FirstOrDefault(x => x.Id == bookingId);
+            if (bookObj.CUSTOMERID.HasValue && bookObj.CUSTOMERID.Value > 0)
+            {
+                var dbContacts = _repContact.Where(x => x.CustomerId == bookObj.CUSTOMERID.Value).ToList();
+
+                //不存在的，增加
+                foreach (var item in input.Where(x => dbContacts.Count(cc => cc.Name == x.Name) == 0))
+                {
+                    var ct = item.Adapt<DjyCustomerContact>();
+                    ct.CustomerId = bookObj.CUSTOMERID.Value;
+                    await _repContact.InsertAsync(ct);
+                }
+
+            }
         }
 
         ///// <summary>