1

huangxiaoqiang

2025-10-23 82149871f30f4564d84272649352496a2ab0a38e

 ÏîÄ¿´úÂë/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/AspNetCoreSchedule.cs

@@ -30,10 +30,11 @@
        private readonly ISys_ConfigService _configService;
        private readonly ILocationInfoRepository _locationRepository;
        private readonly IDt_InboundOrderRepository _inboundOrderRepository;
        private readonly IDt_OutboundOrderRepository _outboundorderRepository;

        private Timer _timer;

        public MyBackgroundService(ILogger<MyBackgroundService> logger, ILocationInfoRepository locationRepository, IStockInfoRepository stockInfoRepository, IDt_AreaInfoRepository areaInfoRepository, IDt_TaskRepository taskRepository, IDt_StationManagerRepository stationManagerRepository, ISys_ConfigService configService,IDt_InboundOrderRepository inboundOrderRepository)
        public MyBackgroundService(ILogger<MyBackgroundService> logger, ILocationInfoRepository locationRepository, IStockInfoRepository stockInfoRepository, IDt_AreaInfoRepository areaInfoRepository, IDt_TaskRepository taskRepository, IDt_StationManagerRepository stationManagerRepository, ISys_ConfigService configService,IDt_InboundOrderRepository inboundOrderRepository, IDt_OutboundOrderRepository outboundorderRepository)
        {
            _logger = logger;
            _locationRepository = locationRepository;
@@ -43,6 +44,7 @@
            _stationManagerRepository = stationManagerRepository;
            _configService = configService;
            _inboundOrderRepository = inboundOrderRepository;
            _outboundorderRepository = outboundorderRepository;
        }

        public Task StartAsync(CancellationToken cancellationToken)
@@ -55,8 +57,8 @@
        {
            try
            {
                #region å…¥åº“单据同步
                List<WMS_采购入成品入库自动打印清单_ST> ERPPrintChecklist =SqlSugarHelper.DBERP.Queryable<WMS_采购入成品入库自动打印清单_ST>().Where(x => true).ToList();

                
                var printCheckList = _inboundOrderRepository.QueryData(x => true);
                List<Dt_InboundOrder> inboundOrderAdd = new List<Dt_InboundOrder>();
@@ -68,7 +70,7 @@
                    {
                        Dt_InboundOrder Print = new Dt_InboundOrder()
                        {
                            OrderNo = GetOrderPintCode(),
                            OrderNo = GetOrderPintCode("OrderNoIn"),
                            UpperOrderNo = item.单号,
                            DemandClassification = item.需求分类,
                            OrderType = item.单据类型,
@@ -92,7 +94,7 @@
                    {
                        if (x.OrderNo == null || x.OrderNo == "")
                        {
                            x.OrderNo = GetOrderPintCode();
                            x.OrderNo = GetOrderPintCode("OrderNoIn");
                            x.UpperOrderNo = item.单号;
                            x.DemandClassification = item.需求分类;
                            x.OrderType = item.单据类型;
@@ -120,6 +122,42 @@
                {
                    _inboundOrderRepository.UpdateData(inboundOrderUpdate);
                }
                #endregion

                var OutBoundOrder = _outboundorderRepository.QueryData(x => true);
                List<Dt_OutboundOrder> outboundOrderAdd = new List<Dt_OutboundOrder>();
                List<Dt_OutboundOrder> outboundOrderUpdate = new List<Dt_OutboundOrder>();

                #region ERP生产领料单同步
                List<WMS_用友工程发货单一览表_ST> ERPMaterialRequisition = SqlSugarHelper.DBERP.Queryable<WMS_用友工程发货单一览表_ST>().Where(x => true).ToList();
                foreach (var item in ERPMaterialRequisition)
                {
                    var x = OutBoundOrder.Where(x => x.MaterielCode == item.子件料号 && x.UpperOrderNo == item.单号).FirstOrDefault();
                    if(x == null)
                    {
                        Dt_OutboundOrder outOrder = new Dt_OutboundOrder()
                        {
                            OrderNo = GetOrderPintCode("OrderNoOut"),
                            UpperOrderNo = item.单号,
                            MaterielCode = item.子件料号,
                            MaterielName = item.子件品名,
                            DemandClassification = item.需求名称,
                            OrderQuantity = item.子件实际用量,
                            OverOutQuantity = item.子件发放数量,
                            NotOutQuantity = item.子件未发数量,
                            OrderStatus =(int)OrderStateEmun.未开始,
                            OrderType =(int)OrderTypeEmun.生产领料单,
                            CreateType =(int)OrderCreateTypeEmun.ERP推送,
                        };
                        outboundOrderAdd.Add(outOrder);
                    }
                }

                #endregion
                if (outboundOrderAdd.Count > 0)
                {
                    _outboundorderRepository.AddData(outboundOrderAdd);
                }
            }
            catch (Exception ex)
            {
@@ -127,10 +165,10 @@
            }
        }

        public string GetOrderPintCode()
        public string GetOrderPintCode(string printCode)
        {
            string PrintCode = "";
            var PrintSetting = SqlSugarHelper.DbWMS.Queryable<Dt_PrintSetting>().Where(x => x.PrintCode == "OrderNo").ToList().FirstOrDefault();
            var PrintSetting = SqlSugarHelper.DbWMS.Queryable<Dt_PrintSetting>().Where(x => x.PrintCode == printCode).ToList().FirstOrDefault();

            if (PrintSetting.Spare1 == DateTime.Now.ToString("yyyyMMdd"))
            {