聚水潭接口对接

src/WMS.Web.Domain/Services/ProductInventoryService.cs

@@ -27,13 +27,15 @@ namespace WMS.Web.Domain.Services
         private readonly ILingXingService _lingXingService;
         private readonly IBasicsRepositories _basicsRepositories;
         public readonly IBasicsRepositories _transactionRepositories;
+        public readonly IJuShuiTanService _juShuiTanService;
         public ProductInventoryService(IErpService erpService,
             ISingleDataService singleDataService,
             IErpBasicDataExtendService erpBasicDataExtendService,
             IProductInventoryRepositories repositories,
             ILingXingService lingXingService,
             IBasicsRepositories basicsRepositories,
-            IBasicsRepositories transactionRepositories)
+            IBasicsRepositories transactionRepositories,
+            IJuShuiTanService juShuiTanService)
         {
             _erpService = erpService;
             _singleDataService = singleDataService;
@@ -42,9 +44,13 @@ namespace WMS.Web.Domain.Services
             _lingXingService = lingXingService;
             _basicsRepositories = basicsRepositories;
             _transactionRepositories = transactionRepositories;
+            _juShuiTanService = juShuiTanService;
         }
 
-
+        /// <summary>
+        /// 金蝶
+        /// </summary>
+        /// <returns></returns>
         public async Task<Result> Erp()
         {
             //获取单点配置
@@ -93,12 +99,85 @@ namespace WMS.Web.Domain.Services
                 return Result.ReFailure(ResultCodes.DateWriteError);
             return Result.ReSuccess();
         }
-
-        public Task<Result> JuShuiTan()
+        /// <summary>
+        /// 聚水潭
+        /// </summary>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public async Task<Result> JuShuiTan()
         {
-            throw new NotImplementedException();
-        }
+            //获取单点配置
+            var r = await _basicsRepositories.GetUcStockByHeadOfficeAsync("", 1);
+            var listNames = r.Where(w =>
+             w.ManagementSystem == 2 && !string.IsNullOrEmpty(w.WarehouseCodeOfJushuitan))
+                .Select(s => s.WarehouseCodeOfJushuitan)
+                .ToList();
+            //获取领星仓库
+            var resStock = await _juShuiTanService.GetStock();
+            if (!resStock.IsSuccess) return resStock;
 
+            var ids = resStock.Data.Where(w => listNames.Contains(w.Name)).Select(s => s.Id).ToList();
+            //获取领星库存
+            var resInventory = await _juShuiTanService.GetInventory(ids);
+            if (!resInventory.IsSuccess) return resStock;
+
+            //物料
+            var materials_result = await _erpService.BillQueryForMaterial();
+            List<ErpMaterialDto> materials = new List<ErpMaterialDto>();
+            if (materials_result.IsSuccess)
+                materials = materials_result.Data.ToList();
+
+            List<ProductInventory> inventoryList = new List<ProductInventory>();
+            foreach (var item in resInventory.Data)
+            {
+                //如果物料不匹配 过滤
+                var m = materials.FirstOrDefault(f => f.Specifications.Equals(item.sku_id));
+                if (m == null) continue;
+                //找仓库
+                var l_stock = resStock.Data.FirstOrDefault(f => f.Id == item.wms_co_id);
+                if (l_stock == null) continue;
+                var stock = r.FirstOrDefault(f => f.WarehouseCodeOfLingxing.Equals(l_stock.Name));
+                if (stock == null) continue;
+
+                var entity = new ProductInventory()
+                {
+                    Type = ProductInventoryType.JushuiTan,
+                    MaterialNumber = m.MaterialNumber,
+                    Customer = "",
+                    OrgCode = stock.Code,
+                    StockCode = stock.ErpOrgCode,
+                    Qty = item.ky_qty,
+                    BeforeQty = item.qty ?? 0
+                };
+                inventoryList.Add(entity);
+            }
+            IDbContextTransaction _transaction = _transactionRepositories.GetTransaction();
+            Result res_Rollback = Result.ReSuccess();
+            bool isSuccess = true;
+            //修改库存
+            //先删除之前的再添加
+            if (res_Rollback.IsSuccess)
+            {
+                isSuccess = await _repositories.Delete(ProductInventoryType.LingXing, false);
+                if (isSuccess == false) res_Rollback = Result.ReFailure(ResultCodes.DateWriteError);
+            }
+            if (res_Rollback.IsSuccess)
+            {
+                isSuccess = await _repositories.AddRange(inventoryList, false);
+                if (isSuccess == false) res_Rollback = Result.ReFailure(ResultCodes.DateWriteError);
+            }
+            //提交事务
+            isSuccess = _transactionRepositories.CommitTransaction(res_Rollback.IsSuccess ? false : true, _transaction);
+            if (!res_Rollback.IsSuccess) return res_Rollback;
+            if (!isSuccess)
+                return Result.ReFailure(ResultCodes.DateWriteError);
+
+            return Result.ReSuccess();
+        }
+        /// <summary>
+        /// 领星
+        /// </summary>
+        /// <returns></returns>
         public async Task<Result> LingXing()
         {
             //获取单点配置