格式化代码

啊鑫

18 小时以前 ed05efdc17aab076146b134ebe105b6382f221d7

 MES.Service/service/BasicData/SalesDeliveryNoticeManager.cs

@@ -1,227 +1,219 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Globalization;
using MES.Service.DB;
using MES.Service.Modes;
using MES.Service.Dto.webApi;
using MES.Service.service.BasicData;
using System.Globalization;
using MES.Service.Modes;
using SqlSugar;

namespace MES.Service.service
namespace MES.Service.service;

public class SalesDeliveryNoticeManager : Repository<SalesDeliveryNotice>
{
    public class SalesDeliveryNoticeManager : Repository<SalesDeliveryNotice>
    //当前类已经继承了 Repository 增、删、查、改的方法

    private readonly SalesDeliveryNoticeDetailManager
        _SalesDeliveryDetailManager = new();

    //ErpSalesRerurn
    public bool Save(ErpSalesDelivery SalesDelivery)
    {
        var erpSalesDeliveryDto = SalesDelivery.OrderDto;
        var mesSalesDelivery =
            ConvertErpToSalesDelivery(SalesDelivery.OrderDto);
        var mesSalesDeliveryDatas =
            ConvertErpToSalesDeliveryDetail(SalesDelivery.Items);

        //当前类已经继承了 Repository 增、删、查、改的方法

        private readonly SalesDeliveryNoticeDetailManager _SalesDeliveryDetailManager = new();
        //ErpSalesRerurn
        public bool Save(ErpSalesDelivery SalesDelivery)
        return UseTransaction(db =>
        {
            var erpSalesDeliveryDto = SalesDelivery.OrderDto;
            var mesSalesDelivery = ConvertErpToSalesDelivery(SalesDelivery.OrderDto);
            var mesSalesDeliveryDatas = ConvertErpToSalesDeliveryDetail(SalesDelivery.Items);

            return UseTransaction(db =>
            switch (erpSalesDeliveryDto.Type)
            {
                switch (erpSalesDeliveryDto.Type)
                {
                    case "3":
                        return DeleteData(db, mesSalesDelivery, mesSalesDeliveryDatas) ? 1 : 0;
                    case "2":
                    case "4":
                        return SaveOrUpdateData(db, mesSalesDelivery, mesSalesDeliveryDatas, erpSalesDeliveryDto.Type) ? 1: 0;
                    default:
                        throw new NotImplementedException( $"type没有{erpSalesDeliveryDto.Type}这个类型");
                }
            }) > 0;
        }
    
        private bool DeleteData(SqlSugarScope db, SalesDeliveryNotice mesSalesDelivery,List<SalesDeliveryNoticeDetail> mesSalesDeliveryDatas)
        {
            var decimals = mesSalesDeliveryDatas.Select(s => s.Id).ToArray();
            var update = base.DeleteById(mesSalesDelivery.Id);
            var insertOrUpdate = db.Deleteable<SalesDeliveryNoticeDetail>().In(decimals).ExecuteCommand() > 0;

            if (update && insertOrUpdate)
            {
                return true;
                case "3":
                    return DeleteData(db, mesSalesDelivery,
                        mesSalesDeliveryDatas)
                        ? 1
                        : 0;
                case "2":
                case "4":
                    return SaveOrUpdateData(db, mesSalesDelivery,
                        mesSalesDeliveryDatas, erpSalesDeliveryDto.Type)
                        ? 1
                        : 0;
                default:
                    throw new NotImplementedException(
                        $"type没有{erpSalesDeliveryDto.Type}这个类型");
            }
            throw new NotImplementedException("更新失败");
        }) > 0;
    }

    private bool DeleteData(SqlSugarScope db,
        SalesDeliveryNotice mesSalesDelivery,
        List<SalesDeliveryNoticeDetail> mesSalesDeliveryDatas)
    {
        var decimals = mesSalesDeliveryDatas.Select(s => s.Id).ToArray();
        var update = base.DeleteById(mesSalesDelivery.Id);
        var insertOrUpdate = db.Deleteable<SalesDeliveryNoticeDetail>()
            .In(decimals).ExecuteCommand() > 0;

        if (update && insertOrUpdate) return true;
        throw new NotImplementedException("更新失败");
    }

    // 插入或更新数据的方法
    private bool SaveOrUpdateData(SqlSugarScope db,
        SalesDeliveryNotice mesSalesDelivery,
        List<SalesDeliveryNoticeDetail> mesSalesDeliveryDatas, string type)
    {
        if (mesSalesDelivery.Id != null) base.DeleteById(mesSalesDelivery.Id);
        if (mesSalesDeliveryDatas.Count > 0)
            db.Deleteable<SalesDeliveryNoticeDetail>()
                .Where(s => s.ErpHeadId == mesSalesDelivery.ErpId)
                .ExecuteCommand();
        var orUpdate = base.Insert(mesSalesDelivery);
        var baOrUpdate =
            _SalesDeliveryDetailManager.InsertRange(mesSalesDeliveryDatas);
        if (orUpdate && baOrUpdate) return true;


        throw new NotImplementedException("插入或更新失败");
    }

    // 批量保存记录的方法
    public bool SaveList(List<ErpSalesDelivery> salesOrder)
    {
        var result = salesOrder.Select(Save).ToList();
        return result.All(b => b);
    }

    private SalesDeliveryNotice ConvertErpToSalesDelivery(
        ErpSalesDeliveryDto erpDto)
    {
        DateTime parsedDate;

        // 时间格式转换函数，ERP时间格式为 "yyyy-MM-dd HH:mm:ss"
        DateTime? ParseDateTime(string dateStr)
        {
            if (DateTime.TryParseExact(dateStr, "yyyy-MM-dd HH:mm:ss",
                    CultureInfo.InvariantCulture, DateTimeStyles.None,
                    out parsedDate)) return parsedDate;

            return null; // 如果转换失败，返回null
        }

        // 插入或更新数据的方法
        private bool SaveOrUpdateData(SqlSugarScope db, SalesDeliveryNotice mesSalesDelivery,List<SalesDeliveryNoticeDetail> mesSalesDeliveryDatas, string type)
        var salesOrder = new SalesDeliveryNotice
        {
            if (mesSalesDelivery.Id != null)
            {
                base.DeleteById(mesSalesDelivery.Id);
            }
            if (mesSalesDeliveryDatas.Count > 0)
            {
                db.Deleteable<SalesDeliveryNoticeDetail>().Where(s => s.ErpHeadId == mesSalesDelivery.ErpId).ExecuteCommand();
            }
            var orUpdate = base.Insert(mesSalesDelivery);
            var baOrUpdate = _SalesDeliveryDetailManager.InsertRange(mesSalesDeliveryDatas);
            if (orUpdate && baOrUpdate)
            {
                return true;
            }
            BillNo = erpDto.FBillNo,
            ErpId = erpDto.ErpID,
            FDate = ParseDateTime(erpDto.FDate) ?? null,
            BillType = erpDto.FBillTypeID, // 单据类型
            Currency = erpDto.FSettleCurrld, // 结算币别
            SalesDept = erpDto.FSaleDeptId, //销售部门
            Customer = erpDto.FCustomerID, // 客户
            DeliveryMethod = erpDto.FHeadDeliveryWay, // 交货方式
            DeliveryLocation = erpDto.FHeadLocId, // 交货地点
            Carrier = erpDto.FCarrierID, // 承运商
            TransportNo = erpDto.FCarriageNO, // 运输单号
            BillNoType = erpDto.FCarriageNO, // 单据状态
            DeliveryDept = erpDto.FDeliveryDeptID, // 发货部门
            InventoryGroup = erpDto.FStockerGroupId, // 库存组
            WarehouseManager = erpDto.FStockerId, // 仓管员
            SalesGroup = erpDto.FSaleGroupId, // 销售组
            SalesPerson = erpDto.FSalesManId, //销售员
            Receiver = erpDto.FReceiveCusId, // 收货方
            ReceiverContact = erpDto.FReceiveCusContact, // 收货方联系人
            ReceiverAddress = erpDto.FReceiveAddress, // 收货方地址
            ReceiverName = erpDto.FLinkMan, // 收货方姓名
            LinkPhone = erpDto.FLinkPhone, //联系电话
            SettleParty = erpDto.FSettleID, // 结算方
            PayerParty = erpDto.FPayerID, //付款方
            CreatedBy = erpDto.FCreatorId, // 创建人
            CreatedDate = ParseDateTime(erpDto.FCreateDate) ?? null, // 创建时间
            ModifiedBy = erpDto.FModifierId, // 修改人
            ModifiedDate = ParseDateTime(erpDto.FModifyDate) ?? null, // 修改时间
            ClosedBy = erpDto.FCloserId, // 关闭人
            CloseReason = erpDto.FCloseReason, // 关闭原因
            // CloseDate = ParseDateTime(erpDto.FCloseDate) ?? null, // 关闭日期
            ApprovedBy = erpDto.FApproverId, // 审核人
            ApprovedDate = ParseDateTime(erpDto.FApproveDate) ?? null, // 审核日期
            CancelStatus = erpDto.FCancelStatus, // 作废状态
            CancelledBy = erpDto.FCancellerId, // 作废人
            CancelDate = ParseDateTime(erpDto.FCancelDate) ?? null, // 作废日期
            CloseStatus = erpDto.FBillCloseStatus, // 关闭状态
            BillStatus = erpDto.FDocumentStatus //单据状态
        };

        var single = base.GetSingle(it => it.ErpId == erpDto.ErpID);
        if (single != null) salesOrder.Id = single.Id;

            throw new NotImplementedException("插入或更新失败");
        return salesOrder;
    }

    private List<SalesDeliveryNoticeDetail> ConvertErpToSalesDeliveryDetail(
        List<ErpSalesDeliveryDetailDto> erpDtoList)

    {
        var salesOrderSubList = new List<SalesDeliveryNoticeDetail>();
        DateTime parsedDate;

        // 时间格式转换函数，ERP时间格式为 "yyyy-MM-dd HH:mm:ss"
        DateTime? ParseDateTime(string dateStr)
        {
            if (DateTime.TryParseExact(dateStr, "yyyy-MM-dd HH:mm:ss",
                    CultureInfo.InvariantCulture, DateTimeStyles.None,
                    out parsedDate)) return parsedDate;
            return null; // 如果转换失败，返回null
        }

        // 批量保存记录的方法
        public bool SaveList(List<ErpSalesDelivery> salesOrder)

        foreach (var erpDto in erpDtoList)
        {
            var result = salesOrder.Select(Save).ToList();
            return result.All(b => b);
        }
 
        private SalesDeliveryNotice ConvertErpToSalesDelivery(ErpSalesDeliveryDto erpDto)
        {
            DateTime parsedDate;

            // 时间格式转换函数，ERP时间格式为 "yyyy-MM-dd HH:mm:ss"
            DateTime? ParseDateTime(string dateStr)
            var salesOrderSub = new SalesDeliveryNoticeDetail
            {
                if (DateTime.TryParseExact(dateStr, "yyyy-MM-dd HH:mm:ss",CultureInfo.InvariantCulture,DateTimeStyles.None, out parsedDate))
                {
                    return parsedDate;
                }

                return null; // 如果转换失败，返回null
            }

            var salesOrder = new SalesDeliveryNotice
            {
                BillNo = erpDto.FBillNo,
                ErpId = erpDto.ErpID,
                FDate = ParseDateTime(erpDto.FDate) ?? null,
                BillType = erpDto.FBillTypeID, // 单据类型
                Currency = erpDto.FSettleCurrld, // 结算币别
                SalesDept = erpDto.FSaleDeptId, //销售部门
                Customer = erpDto.FCustomerID, // 客户
                DeliveryMethod = erpDto.FHeadDeliveryWay, // 交货方式
                DeliveryLocation = erpDto.FHeadLocId, // 交货地点
                Carrier = erpDto.FCarrierID, // 承运商
                TransportNo = erpDto.FCarriageNO, // 运输单号
                BillNoType = erpDto.FCarriageNO, // 单据状态
                DeliveryDept = erpDto.FDeliveryDeptID, // 发货部门
                InventoryGroup = erpDto.FStockerGroupId, // 库存组
                WarehouseManager = erpDto.FStockerId, // 仓管员
                SalesGroup = erpDto.FSaleGroupId, // 销售组
                SalesPerson = erpDto.FSalesManId,//销售员
                Receiver = erpDto.FReceiveCusId, // 收货方
                ReceiverContact = erpDto.FReceiveCusContact, // 收货方联系人
                ReceiverAddress = erpDto.FReceiveAddress, // 收货方地址
                ReceiverName = erpDto.FLinkMan, // 收货方姓名
                LinkPhone    = erpDto.FLinkPhone,//联系电话
                SettleParty = erpDto.FSettleID, // 结算方
                PayerParty = erpDto.FPayerID,//付款方
                CreatedBy = erpDto.FCreatorId, // 创建人
                CreatedDate = ParseDateTime(erpDto.FCreateDate) ?? null, // 创建时间
                ModifiedBy = erpDto.FModifierId, // 修改人
                ModifiedDate = ParseDateTime(erpDto.FModifyDate) ?? null, // 修改时间
                ClosedBy = erpDto.FCloserId, // 关闭人
                CloseReason = erpDto.FCloseReason, // 关闭原因
               // CloseDate = ParseDateTime(erpDto.FCloseDate) ?? null, // 关闭日期
                ApprovedBy = erpDto.FApproverId, // 审核人
                ApprovedDate = ParseDateTime(erpDto.FApproveDate) ?? null, // 审核日期
                CancelStatus = erpDto.FCancelStatus, // 作废状态
                CancelledBy = erpDto.FCancellerId, // 作废人
                CancelDate = ParseDateTime(erpDto.FCancelDate) ?? null, // 作废日期
                CloseStatus = erpDto.FBillCloseStatus, // 关闭状态
                BillStatus = erpDto.FDocumentStatus //单据状态

                ErpLineId = erpDto.ErpID, //ERP行ID
                ErpHeadId = erpDto.EHID, //ERP头ID
                MaterialId = erpDto.FMaterialId, //物料编号
                SalesUnitId = erpDto.FUnitID, //销售单位
                SalesQuantity = Convert.ToDecimal(erpDto.FQty), //销售数量
                IsFree = Convert.ToDecimal(erpDto.FIsFree), //是否赠品
                DeliveryDate = ParseDateTime(erpDto.FDeliverydate), //要货日期
                Warehouse = erpDto.FStockId, //出货仓库
                PlanTrackingNumber = erpDto.FMtoNo, //计划跟踪号
                LotNumber = erpDto.FLot, //批号
                SrcBillNo = erpDto.FSrcBillNo, //源单编号
                PriceQty = erpDto.FPriceUnitQty, //计价数量
                OwnerId = erpDto.FOwnerIdHead, //货主
                InventoryUnit = erpDto.FStockUnitID, //库存单位
                InventoryQuantity = Convert.ToDecimal(erpDto.FStockQty), //库存数量
                PlanDeliveryDate =
                    ParseDateTime(erpDto.FPlanDeliveryDate), //计划发货日期
                OutLmtUnit = erpDto.FOutLmtUnit, //超发控制单位
                OutMaxQty = erpDto.FOutMaxQty, //出库上限
                OutMinQty = erpDto.FOutMinQty, //出库下限
                DeliveryLoc = erpDto.FDeliveryLoc, //交货地点
                DeliverylAddress = erpDto.FDeliveryLAddress, //交货地址
                SourceBillNo = erpDto.FSrcBillNo, //原单单号
                OrderBillNo = erpDto.FOrderNo, //订单单号
                TerminationStatus = erpDto.FTerminationStatus, //终止状态
                TerminationDate = ParseDateTime(erpDto.FTerminateDate), //业务终止日期
                SumOutQty = erpDto.FSumOutQty, //累计出库数量
                RemainOutQty = erpDto.FRemainOutQty, //未出库数量
                SalesOrder = erpDto.FXSHTH, //销售订单号
                CustOrder = erpDto.F_ZJXF_TEXT_QTR_LEE, //客户订单号
                SalesContractNo = erpDto.FXSHTBH, //销售合同编号
                F_KHWLBM = erpDto.F_KHWLBM,
                F_KHWLMC = erpDto.F_KHWLMC
            };

            var single = base.GetSingle(it => it.ErpId == erpDto.ErpID);
            if (single != null)
            {
                salesOrder.Id = single.Id;
            }
            if (erpDto.FRemainOutQty == 0)
                salesOrderSub.IsFinish = 1;
            else
                salesOrderSub.IsFinish = 0;

            return salesOrder;
            var single = _SalesDeliveryDetailManager.GetSingle(it =>
                it.ErpLineId == salesOrderSub.ErpLineId);
            if (single != null) salesOrderSub.Id = single.Id;

            salesOrderSubList.Add(salesOrderSub);
        }

        private List<SalesDeliveryNoticeDetail> ConvertErpToSalesDeliveryDetail(List<ErpSalesDeliveryDetailDto> erpDtoList)

        {
            var salesOrderSubList = new List<SalesDeliveryNoticeDetail>();
            DateTime parsedDate;
            // 时间格式转换函数，ERP时间格式为 "yyyy-MM-dd HH:mm:ss"
            DateTime? ParseDateTime(string dateStr)
            {
                if (DateTime.TryParseExact(dateStr, "yyyy-MM-dd HH:mm:ss",CultureInfo.InvariantCulture,DateTimeStyles.None,out parsedDate))
                {
                    return parsedDate;
                }
                return null; // 如果转换失败，返回null
            }



            foreach (var erpDto in erpDtoList)
            {
                var salesOrderSub = new SalesDeliveryNoticeDetail
                {
                    ErpLineId = erpDto.ErpID,//ERP行ID
                    ErpHeadId = erpDto.EHID,//ERP头ID
                    MaterialId = erpDto.FMaterialId,//物料编号
                    SalesUnitId = erpDto.FUnitID,//销售单位
                    SalesQuantity = Convert.ToDecimal(erpDto.FQty),//销售数量
                    IsFree = Convert.ToDecimal(erpDto.FIsFree),//是否赠品
                    DeliveryDate = ParseDateTime(erpDto.FDeliverydate),//要货日期
                    Warehouse = erpDto.FStockId,//出货仓库
                    PlanTrackingNumber = erpDto.FMtoNo,//计划跟踪号
                    LotNumber = erpDto.FLot,//批号
                    SrcBillNo = erpDto.FSrcBillNo,//源单编号
                    PriceQty = erpDto.FPriceUnitQty,//计价数量
                    OwnerId = erpDto.FOwnerIdHead,//货主
                    InventoryUnit = erpDto.FStockUnitID,//库存单位
                    InventoryQuantity = Convert.ToDecimal(erpDto.FStockQty),//库存数量
                    PlanDeliveryDate = ParseDateTime(erpDto.FPlanDeliveryDate),//计划发货日期
                    OutLmtUnit = erpDto.FOutLmtUnit,//超发控制单位
                    OutMaxQty = erpDto.FOutMaxQty,//出库上限
                    OutMinQty = erpDto.FOutMinQty,//出库下限
                    DeliveryLoc = erpDto.FDeliveryLoc,//交货地点
                    DeliverylAddress = erpDto.FDeliveryLAddress,//交货地址
                    SourceBillNo = erpDto.FSrcBillNo,//原单单号
                    OrderBillNo = erpDto.FOrderNo,//订单单号
                    TerminationStatus = erpDto.FTerminationStatus,//终止状态
                    TerminationDate = ParseDateTime(erpDto.FTerminateDate),//业务终止日期
                    SumOutQty = erpDto.FSumOutQty,//累计出库数量
                    RemainOutQty = erpDto.FRemainOutQty,//未出库数量
                    SalesOrder   = erpDto.FXSHTH,//销售订单号
                    CustOrder    = erpDto.F_ZJXF_TEXT_QTR_LEE,//客户订单号
                    SalesContractNo = erpDto.FXSHTBH,//销售合同编号
                    F_KHWLBM=erpDto.F_KHWLBM,
                    F_KHWLMC=erpDto.F_KHWLMC,

                };

                if (erpDto.FRemainOutQty==0)
                {
                    salesOrderSub.IsFinish = 1;
                }
                else
                {
                    salesOrderSub.IsFinish = 0;
                }

                var single = _SalesDeliveryDetailManager.GetSingle(it =>it.ErpLineId == salesOrderSub.ErpLineId);
                if (single != null)
                {
                    salesOrderSub.Id = single.Id;
                }

                salesOrderSubList.Add(salesOrderSub);
            }

            return salesOrderSubList;
        }

        return salesOrderSubList;
    }
}