领导带班下井排班导入

APT.Data.Migrations/Migrations/20251206092548_hmr2025120602.cs

@@ -0,0 +1,46 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace APT.Data.Migrations.Migrations
+{
+    public partial class hmr2025120602 : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AlterColumn<string>(
+                name: "PHONE",
+                table: "T_FO_SCHEDULING",
+                type: "nvarchar(50)",
+                maxLength: 50,
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(500)",
+                oldMaxLength: 500,
+                oldNullable: true);
+
+            migrationBuilder.AddColumn<string>(
+                name: "REMARK",
+                table: "T_FO_SCHEDULING",
+                type: "nvarchar(500)",
+                maxLength: 500,
+                nullable: true);
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropColumn(
+                name: "REMARK",
+                table: "T_FO_SCHEDULING");
+
+            migrationBuilder.AlterColumn<string>(
+                name: "PHONE",
+                table: "T_FO_SCHEDULING",
+                type: "nvarchar(500)",
+                maxLength: 500,
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(50)",
+                oldMaxLength: 50,
+                oldNullable: true);
+        }
+    }
+}

APT.Data.Migrations/Migrations/MigrationContextModelSnapshot.cs

@@ -37712,6 +37712,10 @@ namespace APT.Data.Migrations.Migrations
                         .HasColumnType("uniqueidentifier");
 
                     b.Property<string>("PHONE")
+                        .HasMaxLength(50)
+                        .HasColumnType("nvarchar(50)");
+
+                    b.Property<string>("REMARK")
                         .HasMaxLength(500)
                         .HasColumnType("nvarchar(500)");
 

APT.MS.Data/Mapping/T4/T4Map.cs

@@ -2117,8 +2117,9 @@ builder.HasOne(t => t.Nav_ImgFile).WithMany().HasForeignKey(t => t.IMG_FILE_ID).
 builder.HasOne(t => t.Nav_Tech).WithMany().HasForeignKey(t => t.TECH_ID).OnDelete(DeleteBehavior.Restrict);
 builder.HasOne(t => t.Nav_Driver).WithMany().HasForeignKey(t => t.DRIVER_ID).OnDelete(DeleteBehavior.Restrict);
 builder.Property(t => t.WEEK).HasMaxLength(500);
-builder.Property(t => t.PHONE).HasMaxLength(500);
+builder.Property(t => t.PHONE).HasMaxLength(50);
 builder.HasOne(t => t.Nav_Class).WithMany().HasForeignKey(t => t.CLASS_ID).OnDelete(DeleteBehavior.Restrict);
+builder.Property(t => t.REMARK).HasMaxLength(500);
 		} 
      }
 	 #endregion

APT.MS.Domain/Entities/FO/T_FO_SCHEDULING.cs

@@ -36,6 +36,7 @@ namespace APT.MS.Domain.Entities.FO
         public string WEEK { get; set; }
 
         [Description("电话")]
+        [DataFieldLength(50)]
         public string PHONE { get; set; }
 
         [Description("班次")]
@@ -43,6 +44,10 @@ namespace APT.MS.Domain.Entities.FO
         public Guid? CLASS_ID { get; set; }
         [Description("导航：班次")]
         [FormFieldQuery]
-        public virtual T_FM_CLASS Nav_Class { get; set; }
+        public virtual T_FM_CLASS Nav_Class { get; set; }
+
+        [Description("备注")]
+        [DataFieldLength(500)]
+        public string REMARK { get; set; }
     }
 }

APT.MicroApi/APT.FO.WebApi/Controllers/SchedulingController.cs

@@ -0,0 +1,290 @@
+using APT.BaseData.Domain.ApiModel;
+using APT.BaseData.Domain.Entities.FM;
+using APT.BaseData.Domain.Enums;
+using APT.Infrastructure.Core;
+using APT.MS.Domain.Entities.FO;
+using APT.MS.Domain.Entities.SC;
+using APT.MS.Domain.Entities.SC.SC;
+using APT.MS.Domain.Enums;
+using APT.Utility;
+using Microsoft.AspNetCore.Mvc;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.IO;
+using System.Linq;
+
+namespace APT.FO.WebApi.Controllers
+{
+    /// <summary>
+    ///  工作票排班明细
+    /// </summary>
+    [Route("api/FO/FOScheduling")]
+    public partial class SchedulingController : AuthorizeApiController<T_FO_SCHEDULING>
+    {
+        /// <summary>
+        /// 获取导入数据  
+        /// 参考         [Route("api/PF/Import")]
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost, Route("GetImportData")]
+        public JsonActionResult<ImportDataModel> GetImportData()
+        {
+            return SafeExecute<ImportDataModel>(() =>
+            {
+                var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId;
+                var httpRequest = this.HttpContext.Request;
+                string orgIdStr = httpRequest.Form["OrgId"];// 获取 组织            
+                ImportDataModel result = new ImportDataModel();
+                var dic = Path.Combine(System.AppContext.BaseDirectory, "tempImportFiles");
+                if (!Directory.Exists(dic))
+                    Directory.CreateDirectory(dic);
+                foreach (var key in httpRequest.Form.Files)  // 文件键
+                {
+                    var postedFile = key;    // 获取文件键对应的文件对象
+                    string filePath = Path.Combine(dic, DateTime.Now.ToString("yyyy_MM_dd_hh_mm_ss") + "_" + postedFile.FileName);
+                    Byte[] fileData = new Byte[postedFile.Length];
+                    Stream sr = postedFile.OpenReadStream();//创建数据流对象 
+                    sr.Read(fileData, 0, (int)postedFile.Length);
+                    using (FileStream fs = new FileStream(filePath, FileMode.CreateNew))
+                    {
+                        fs.Write(fileData, 0, fileData.Length);
+                        fs.Flush();
+                        fs.Close();
+                    }
+
+                    //获取数据
+                    Dictionary<int, int> startRowIndexs = new Dictionary<int, int>();
+                    startRowIndexs.Add(0, 1);//根据Excel格式数据赋值
+                    var dataTables = FileUtils.ReadExcelByOledb(filePath, startRowIndexs);
+                    string Msg = string.Empty;
+
+                    bool isOK = InsertModel(dataTables.Tables[0], orgId, ref Msg);
+
+                    try
+                    {
+                        System.IO.File.Delete(filePath);
+                    }
+                    catch { }
+
+                    result.Data = Msg;
+                    result.MessageList = new List<string> { Msg };
+                }
+
+                return result;
+            });
+        }
+
+        /// <summary>
+        /// 数据插入
+        /// </summary>
+        /// <param name="dtSource"></param>
+        /// <param name="orgId"></param>
+        /// <param name="Msg"></param>
+        /// <param name="rowIndex"></param>
+        /// <returns></returns>
+        /// <exception cref="Exception"></exception>
+        public bool InsertModel(DataTable dtSource, Guid? orgId, ref string Msg, int rowIndex = 1)
+        {
+            if (dtSource == null || dtSource.Rows.Count < rowIndex)
+            {
+                Msg = "未获取到导入数据";
+                throw new Exception(Msg);
+            }
+            int rowAll = dtSource.Rows.Count;
+            if (!string.IsNullOrEmpty(Msg))
+            {
+                throw new Exception(Msg);
+            }
+            var newFilter = new BaseFilter(orgId);
+            newFilter.SelectField = new List<string> { "NAME" };
+            var fmClass = this.GetEntities<T_FM_CLASS>(t => !t.IS_DELETED, newFilter, "Nav_ClassDetail");
+            var users = GetEntities<T_FM_USER>(t => t.IS_DELETED == false && t.ENABLE_STATUS == 0, new BaseFilter(orgId));
+            if (dtSource.Rows.Count == 1)
+            {
+                throw new Exception("导入必须两条以上，一条请直接新增");
+            }
+            for (int i = 0; i < rowAll; i++)
+            {
+                if (string.IsNullOrEmpty(dtSource.Rows[i][0].ToString()))
+                {
+                    if (string.IsNullOrEmpty(Msg))
+                        Msg = "第"+(i+1)+"行第1列:日期不能为空";
+                    else
+                        Msg = Msg + "\n" + "第" + (i + 1) + "行第1列:日期不能为空";
+                }
+                if (string.IsNullOrEmpty(dtSource.Rows[i][1].ToString()))
+                {
+                    if (string.IsNullOrEmpty(Msg))
+                        Msg = "第" + (i + 1) + "行第2列:班次不能为空";
+                    else
+                        Msg = Msg + "\n" + "第" + (i + 1) + "行第2列:班次不能为空";
+                }
+                else 
+                {
+                    var firstClass = fmClass.FirstOrDefault(t => t.NAME == dtSource.Rows[i][1].ToString());
+                    if (firstClass == null)
+                    {
+                        if (string.IsNullOrEmpty(Msg))
+                            Msg = "第" + (i + 1) + "行第2列:班次未找到，请先到班次管理添加";
+                        else
+                            Msg = Msg + "\n" + "第" + (i + 1) + "行第2列:班次未找到，请先到班次管理添加";
+                    }
+                }
+                if (string.IsNullOrEmpty(dtSource.Rows[i][2].ToString()))
+                {
+                    if (string.IsNullOrEmpty(Msg))
+                        Msg = "第" + (i + 1) + "行第3列:带班领导不能为空";
+                    else
+                        Msg = Msg + "\n" + "第" + (i + 1) + "行第3列:带班领导不能为空";
+                }
+                else
+                {
+                    var firstUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][2].ToString());
+                    if (firstUser == null)
+                    {
+                        if (string.IsNullOrEmpty(Msg))
+                            Msg = "第" + (i + 1) + "行第3列:带班领导未找到，请先到用户列表添加";
+                        else
+                            Msg = Msg + "\n" + "第" + (i + 1) + "行第3列:带班领导未找到，请先到用户列表添加";
+                    }
+                }
+                if (string.IsNullOrEmpty(dtSource.Rows[i][5].ToString()))
+                {
+                    if (string.IsNullOrEmpty(Msg))
+                        Msg = "第" + (i + 1) + "行第6列:班次不能为空";
+                    else
+                        Msg = Msg + "\n" + "第" + (i + 1) + "行第6列:班次不能为空";
+                }
+                else
+                {
+                    var firstClass = fmClass.FirstOrDefault(t => t.NAME == dtSource.Rows[i][5].ToString());
+                    if (firstClass == null)
+                    {
+                        if (string.IsNullOrEmpty(Msg))
+                            Msg = "第" + (i + 1) + "行第6列:班次未找到，请先到班次管理添加";
+                        else
+                            Msg = Msg + "\n" + "第" + (i + 1) + "行第6列:班次未找到，请先到班次管理添加";
+                    }
+                }
+                if (string.IsNullOrEmpty(dtSource.Rows[i][6].ToString()))
+                {
+                    if (string.IsNullOrEmpty(Msg))
+                        Msg = "第" + (i + 1) + "行第7列:带班领导不能为空";
+                    else
+                        Msg = Msg + "\n" + "第" + (i + 1) + "行第7列:带班领导不能为空";
+                }
+                else
+                {
+                    var firstUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][6].ToString());
+                    if (firstUser == null)
+                    {
+                        if (string.IsNullOrEmpty(Msg))
+                            Msg = "第" + (i + 1) + "行第7列:带班领导未找到，请先到用户列表添加";
+                        else
+                            Msg = Msg + "\n" + "第" + (i + 1) + "行第7列:带班领导未找到，请先到用户列表添加";
+                    }
+                }
+                if (string.IsNullOrEmpty(dtSource.Rows[i][9].ToString()))
+                {
+                    if (string.IsNullOrEmpty(Msg))
+                        Msg = "第" + (i + 1) + "行第10列:班次不能为空";
+                    else
+                        Msg = Msg + "\n" + "第" + (i + 1) + "行第10列:班次不能为空";
+                }
+                else
+                {
+                    var firstClass = fmClass.FirstOrDefault(t => t.NAME == dtSource.Rows[i][9].ToString());
+                    if (firstClass == null)
+                    {
+                        if (string.IsNullOrEmpty(Msg))
+                            Msg = "第" + (i + 1) + "行第10列:班次未找到，请先到班次管理添加";
+                        else
+                            Msg = Msg + "\n" + "第" + (i + 1) + "行第10列:班次未找到，请先到班次管理添加";
+                    }
+                }
+                if (string.IsNullOrEmpty(dtSource.Rows[i][10].ToString()))
+                {
+                    if (string.IsNullOrEmpty(Msg))
+                        Msg = "第" + (i + 1) + "行第11列:带班领导不能为空";
+                    else
+                        Msg = Msg + "\n" + "第" + (i + 1) + "行第11列:带班领导不能为空";
+                }
+                else
+                {
+                    var firstUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][10].ToString());
+                    if (firstUser == null)
+                    {
+                        if (string.IsNullOrEmpty(Msg))
+                            Msg = "第" + (i + 1) + "行第11列:带班领导未找到，请先到用户列表添加";
+                        else
+                            Msg = Msg + "\n" + "第" + (i + 1) + "行第11列:带班领导未找到，请先到用户列表添加";
+                    }
+                }
+                i++;
+            }
+            if (!string.IsNullOrEmpty(Msg))
+            {
+                throw new Exception(Msg);
+            }
+            var classFirst = fmClass.FirstOrDefault(t => t.NAME == dtSource.Rows[0][1].ToString());
+            var classScond = fmClass.FirstOrDefault(t => t.NAME == dtSource.Rows[0][5].ToString());
+            var classThird = fmClass.FirstOrDefault(t => t.NAME == dtSource.Rows[0][9].ToString());
+            List<T_FO_SCHEDULING> sches = new List<T_FO_SCHEDULING>();
+            string[] Day = new string[] { "星期日", "星期一", "星期二", "星期三", "星期四", "星期五", "星期六" };
+            for (int i = 0; i < rowAll; i++)
+            {
+                var firstUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][2].ToString());
+                var techUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][3].ToString());
+                var driverUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][4].ToString());
+                var scondUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][6].ToString());
+                var techScondUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][7].ToString());
+                var driverScondUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][8].ToString());
+                var thirdUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][10].ToString());
+                var techThirdUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][11].ToString());
+                var driverThirdUser = users.FirstOrDefault(t => t.NAME == dtSource.Rows[i][12].ToString());
+                T_FO_SCHEDULING sche = new T_FO_SCHEDULING();
+                sche.ID = Guid.NewGuid();
+                sche.ORG_ID = orgId;
+                sche.DATE = Convert.ToDateTime(dtSource.Rows[i][0].ToString());
+                sche.USER_ID = firstUser.ID;
+                sche.TECH_ID = techUser?.ID;
+                sche.DRIVER_ID = driverUser?.ID;
+                sche.CLASS_ID = classFirst.ID;
+                sche.REMARK = dtSource.Rows[i][13].ToString();
+                sche.WEEK = Day[Convert.ToInt32(sche.DATE.DayOfWeek.ToString("d"))].ToString();
+                sches.Add(sche);
+                T_FO_SCHEDULING sche2 = new T_FO_SCHEDULING();
+                sche2.ID = Guid.NewGuid();
+                sche2.ORG_ID = orgId;
+                sche2.DATE = Convert.ToDateTime(dtSource.Rows[i][0].ToString());
+                sche2.USER_ID = scondUser.ID;
+                sche2.TECH_ID = techUser?.ID;
+                sche2.DRIVER_ID = driverScondUser?.ID;
+                sche2.CLASS_ID = classScond.ID;
+                sche2.REMARK = dtSource.Rows[i][13].ToString();
+                sche2.WEEK = Day[Convert.ToInt32(sche.DATE.DayOfWeek.ToString("d"))].ToString();
+                sches.Add(sche2);
+                T_FO_SCHEDULING sche3 = new T_FO_SCHEDULING();
+                sche3.ID = Guid.NewGuid();
+                sche3.ORG_ID = orgId;
+                sche3.DATE = Convert.ToDateTime(dtSource.Rows[i][0].ToString());
+                sche3.USER_ID = thirdUser.ID;
+                sche3.TECH_ID = techThirdUser?.ID;
+                sche3.DRIVER_ID = driverThirdUser?.ID;
+                sche3.CLASS_ID = classThird.ID;
+                sche3.REMARK = dtSource.Rows[i][13].ToString();
+                sche3.WEEK = Day[Convert.ToInt32(sche.DATE.DayOfWeek.ToString("d"))].ToString();
+                sches.Add(sche3);
+            }
+            UnifiedCommit(() =>
+            {
+                if (sches != null && sches.Any())
+                    BantchAddEntityNoCommit(sches);
+            });
+            //Msg = "导入成功！";
+            return true;
+        }
+
+    }
+}