| | |
| | | 代ç 管ç/PCS/WCS_Server/WIDESEA_System/WIDESEA_System.csproj |
| | | 代ç 管ç/PCS/WCS_Server/WIDESEA_System/WIDESEA_System.csproj |
| | | *.csproj |
| | | /代ç 管ç/PCS/WCS_Server/WIDESEA_WCS/JobsPart/Common/åå¨è¿ç¨/StoredProcedure.cs |
| | |
| | | axios.defaults.baseURL = 'http://127.0.0.1:8099/'; |
| | | } |
| | | else if (process.env.NODE_ENV == 'debug') { |
| | | axios.defaults.baseURL = 'http://127.0.0.1:8099/'; |
| | | axios.defaults.baseURL = 'http://192.168.12.101:8099/'; |
| | | } |
| | | |
| | | else if (process.env.NODE_ENV == 'production') { |
| | | axios.defaults.baseURL = 'http://127.0.0.1:8099/'; |
| | | axios.defaults.baseURL = 'http://192.168.12.101:8099/'; |
| | | } |
| | | if (!axios.defaults.baseURL.endsWith('/')) { |
| | | axios.defaults.baseURL+="/"; |
| | |
| | | ?? Context.User.FindFirstValue(ClaimTypes.NameIdentifier)).GetInt(); |
| | | } |
| | | } |
| | | |
| | | /// <summary> |
| | | /// è´¦å· |
| | | /// </summary> |
| | | public string UserName |
| | | { |
| | | get { return UserInfo.UserName; } |
| | | } |
| | | |
| | | /// <summary> |
| | | /// å§å |
| | | /// </summary> |
| | | public string UserTrueName |
| | | { |
| | | get { return UserInfo.UserTrueName; } |
| | |
| | | /// <summary> |
| | | ///çç¼çå· |
| | | /// </summary> |
| | | [Display(Name = "çç¼çå·")] |
| | | [MaxLength(255)] |
| | | [Column(TypeName = "varchar(255)")] |
| | | [Editable(true)] |
| | | public string HearthNumber { get; set; } |
| | | //[Display(Name = "çç¼çå·")] |
| | | //[MaxLength(255)] |
| | | //[Column(TypeName = "varchar(255)")] |
| | | //[Editable(true)] |
| | | //public string HearthNumber { get; set; } |
| | | |
| | | /// <summary> |
| | | ///çä»£å· |
| | |
| | | /// <summary> |
| | | ///ID |
| | | /// </summary> |
| | | //[Key] |
| | | //[Display(Name = "ID")] |
| | | //[Column(TypeName = "int")] |
| | | //[Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)] |
| | | //public int ID { get; set; } |
| | | [Key] |
| | | [Display(Name = "ID")] |
| | | [Column(TypeName = "int")] |
| | | [Editable(true)] |
| | | [Column(TypeName = "uniqueidentifier")] |
| | | [Required(AllowEmptyStrings = false)] |
| | | public int ID { get; set; } |
| | | |
| | | public Guid ID { get; set; } |
| | | /// <summary> |
| | | ///è´§ä½ç¼å· |
| | | /// </summary> |
| | |
| | | /// <summary> |
| | | ///AGVç¼å· |
| | | /// </summary> |
| | | [Display(Name = "AGVç¼å·")] |
| | | //[Display(Name = "AGVç¼å·")] |
| | | //[MaxLength(50)] |
| | | //[Column(TypeName = "nvarchar(50)")] |
| | | //[Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)] |
| | | //public string agv_code { get; set; } |
| | | /// <summary> |
| | | ///æçç¶æ |
| | | /// </summary> |
| | | [Display(Name = "æçç¶æ")] |
| | | [MaxLength(50)] |
| | | [Column(TypeName = "nvarchar(50)")] |
| | | [Editable(true)] |
| | | [Required(AllowEmptyStrings = false)] |
| | | public string agv_code { get; set; } |
| | | //[Required(AllowEmptyStrings = false)] |
| | | public string agv_TrayStatus { get; set; } |
| | | |
| | | |
| | | /// <summary> |
| | | ///ä»»å¡ç¶æ |
| | |
| | | public string agv_taskstate { get; set; } |
| | | |
| | | /// <summary> |
| | | ///AGVå·¥ä½ç±»å |
| | | ///å·¥åç±»å/AGVå·¥ä½ç±»å |
| | | /// </summary> |
| | | [Display(Name = "AGVå·¥ä½ç±»å")] |
| | | [Column(TypeName = "int")] |
| | |
| | | public string agv_remark { get; set; } |
| | | |
| | | /// <summary> |
| | | ///ä»»å¡ç级 |
| | | ///ä»»å¡ç级0ãæç¼1ãæ£å¸¸2ãå æ¥ |
| | | /// </summary> |
| | | [Display(Name = "ä»»å¡ç级")] |
| | | [Column(TypeName = "int")] |
| | |
| | | public string agv_userid { get; set; } |
| | | |
| | | /// <summary> |
| | | ///æçç |
| | | ///æçç±»å/æçç |
| | | /// </summary> |
| | | [Display(Name = "æçç ")] |
| | | [MaxLength(30)] |
| | | [Column(TypeName = "nvarchar(30)")] |
| | | [Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)]//ä¸è½ä¸ºç©º |
| | | public string agv_barcode { get; set; } |
| | | public string agv_Traytype { get; set; } |
| | | |
| | | /// <summary> |
| | | ///ç©æç |
| | |
| | | public string agv_userid { get; set; } |
| | | |
| | | /// <summary> |
| | | ///æçç |
| | | ///æçç±»å/æçç |
| | | /// </summary> |
| | | [Display(Name = "æçç ")] |
| | | [MaxLength(30)] |
| | | [Column(TypeName = "nvarchar(30)")] |
| | | [Editable(true)] |
| | | [Required(AllowEmptyStrings = false)] |
| | | public string agv_barcode { get; set; } |
| | | //[Required(AllowEmptyStrings = false)] |
| | | public string agv_Traytype { get; set; } |
| | | |
| | | /// <summary> |
| | | ///AGVç¼å· |
| | | /// </summary> |
| | | [Display(Name = "AGVç¼å·")] |
| | | //[Display(Name = "AGVç¼å·")] |
| | | //[MaxLength(50)] |
| | | //[Column(TypeName = "nvarchar(50)")] |
| | | //[Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)] |
| | | //public string agv_code { get; set; } |
| | | /// <summary> |
| | | ///æçç¶æ |
| | | /// </summary> |
| | | [Display(Name = "æçç¶æ")] |
| | | [MaxLength(50)] |
| | | [Column(TypeName = "nvarchar(50)")] |
| | | [Editable(true)] |
| | | [Required(AllowEmptyStrings = false)] |
| | | public string agv_code { get; set; } |
| | | //[Required(AllowEmptyStrings = false)] |
| | | public string agv_TrayStatus { get; set; } |
| | | |
| | | /// <summary> |
| | | ///AGVå·¥ä½ç±»å |
| | |
| | | using System.Linq; |
| | | using System.Text; |
| | | using System.Threading.Tasks; |
| | | using System.Xml.Linq; |
| | | using WIDESEA_Comm.LogInfo; |
| | | using WIDESEA_Core.BaseProvider; |
| | | using WIDESEA_Core.FreeDB; |
| | | using WIDESEA_Entity.DomainModels; |
| | |
| | | if (Gantry_client == null) throw new Exception("æ¡æ¶è°åº¦æå¡æªå¼å¯ï¼"); |
| | | if (!Gantry_client.IsConnected) throw new Exception("䏿¡æ¶è¿æ¥è¶
æ¶ï¼"); |
| | | var Gantryplc = FreeDB.Select<dt_plcinfohead>().Where(x => x.plcinfo_name == Gantry_client.PLCName).First(); |
| | | var Pipeline_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "龿¡æº"); |
| | | if (Pipeline_client == null) throw new Exception("龿¡æºè°åº¦æå¡æªå¼å¯ï¼"); |
| | | if (!Pipeline_client.IsConnected) throw new Exception("ä¸é¾æ¡æºè¿æ¥è¶
æ¶ï¼"); |
| | | List<string> numbers = new List<string>() { "1åå
é²å", "2åå
é²å", "3åå
é²å", "䏿åºé²å" }; |
| | | var details = FreeDB.Select<dt_plcinfodetail>().Where(x => x.plcdetail_iotype == Gantryplc.plcinfo_iotyep && x.plcdetail_number == numbers[requestin.AreaNr - 1]).ToList(); |
| | | if (MethodName == "AGVRequestin")//请æ±è¿å
¥åºå |
| | |
| | | Gantry_client.WriteByOrder("W_AGV_Request_In", true, numbers[requestin.AreaNr - 1]);//ç³è¯·è¿å
¥åºå |
| | | var Release = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Release_In").First(), Gantry_client);//å
许è¿å
¥åºå |
| | | var Gantry_Out_of_Area = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Gantry_Out_of_Area").First(), Gantry_client);//æ¡æ¶ä¸å¨è¯¥åºå |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success("AGV请æ±è¿å
¥åºå", $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nåºåå·ï¼{requestin.AreaNr}\nç³è¯·è¿å
¥åºåï¼true" + |
| | | $"\n\nè¯»åæ¡æ¶ä¿¡æ¯ï¼\nå
许è¿å
¥åºåï¼{Release}\næ¡æ¶ä¸å¨è¯¥åºåï¼{Gantry_Out_of_Area}", "AGV"); |
| | | #endregion |
| | | if (!Release) throw new Exception("æ¡æ¶æªå
许è¿å
¥ï¼"); |
| | | if (!Gantry_Out_of_Area) throw new Exception("æ¡æ¶å¨åºåå
ï¼"); |
| | | } |
| | |
| | | Gantry_client.WriteByOrder("W_AreaNr", (Int16)requestin.AreaNr, numbers[requestin.AreaNr - 1]);//åºåå· |
| | | if (requestin.Type == 1) |
| | | { |
| | | Pipeline_client.WriteByOrder("W_AGV_Entering", (Int16)1, numbers[requestin.AreaNr - 1]);//å
æ
å±è½ |
| | | Gantry_client.WriteByOrder("W_AGV_Leaving", false, numbers[requestin.AreaNr - 1]);//æ£å¨ç¦»å¼ |
| | | Gantry_client.WriteByOrder("W_AGV_Entering", true, numbers[requestin.AreaNr - 1]);//æ£å¨è¿å
¥ |
| | | var Area_Occupied_by_AGV = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Area_Occupied_by_AGV").First(), Gantry_client);//æ¡æ¶åé¦AGVå ä½ä¿¡å· |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success("AGVæ£å¨è¿å
¥åºå", $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nåºåå·ï¼{requestin.AreaNr}\næ£å¨ç¦»å¼ï¼false\næ£å¨è¿å
¥ï¼true\nå
æ
å±è½ï¼1" + |
| | | $"\n\nè¯»åæ¡æ¶ä¿¡æ¯ï¼\nåé¦AGVå ä½ä¿¡å·ï¼{Area_Occupied_by_AGV}", "AGV"); |
| | | #endregion |
| | | if (!Area_Occupied_by_AGV) throw new Exception("æ¡æ¶æªåé¦AGVå ä½ä¿¡å·"); |
| | | } |
| | | else if (requestin.Type == 2) |
| | | { |
| | | Pipeline_client.WriteByOrder("W_AGV_Entering", (Int16)2, numbers[requestin.AreaNr - 1]);//å
æ
å¯ç¨ |
| | | Gantry_client.WriteByOrder("W_AGV_Entering", false, numbers[requestin.AreaNr - 1]);//æ£å¨è¿å
¥ |
| | | Gantry_client.WriteByOrder("W_AGV_Leaving", true, numbers[requestin.AreaNr - 1]);//æ£å¨ç¦»å¼ |
| | | var Area_Occupied_by_AGV = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Area_Occupied_by_AGV").First(), Gantry_client);//æ¡æ¶åé¦AGVå ä½ä¿¡å· |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success("AGVæ£å¨ç¦»å¼åºå", $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nåºåå·ï¼{requestin.AreaNr}\næ£å¨è¿å
¥ï¼false\næ£å¨ç¦»å¼ï¼true\nå
æ
å±è½ï¼2" + |
| | | $"\n\nè¯»åæ¡æ¶ä¿¡æ¯ï¼\nåé¦AGV离å¼ä¿¡å·ï¼{!Area_Occupied_by_AGV}", "AGV"); |
| | | #endregion |
| | | if (Area_Occupied_by_AGV) throw new Exception("æ¡æ¶æªåé¦AGV离å¼ä¿¡å·"); |
| | | } |
| | | } |
| | |
| | | { |
| | | Gantry_client.WriteByOrder("W_AreaNr", (Int16)requestin.AreaNr, numbers[requestin.AreaNr - 1]);//åºåå· |
| | | Gantry_client.WriteByOrder("W_AGV_OUT_OF_Area", requestin.OUTOFArea == 1 ? true : false, numbers[requestin.AreaNr - 1]);//AGVä¸å¨è¯¥åºå |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success("AGVä¸å¨åºåå
", $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nåºåå·ï¼{requestin.AreaNr}\nAGVä¸å¨è¯¥åºåï¼{(requestin.OUTOFArea == 1 ? true : false)}", "AGV"); |
| | | #endregion |
| | | } |
| | | else if (MethodName == "GantryOutofArea")//æ¡æ¶ä¸å¨åºåå
|
| | | { |
| | | var Gantry_Out_of_Area = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Gantry_Out_of_Area").First(), Gantry_client);//æ¡æ¶ä¸å¨è¯¥åºå |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success("æ¡æ¶ä¸å¨åºåå
", $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\nåºåå·ï¼{requestin.AreaNr}\næ¡æ¶ä¸å¨è¯¥åºåï¼{Gantry_Out_of_Area}", "AGV"); |
| | | #endregion |
| | | if (!Gantry_Out_of_Area) throw new Exception("æ¡æ¶å¨åºåå
ï¼"); |
| | | } |
| | | respone.success = 1; |
| | |
| | | using StackExchange.Redis; |
| | | using FreeSql.Internal.Model; |
| | | using StackExchange.Redis; |
| | | using System; |
| | | using System.Collections.Generic; |
| | | using System.Linq; |
| | | using System.Text; |
| | | using System.Threading.Tasks; |
| | | using WIDESEA_Comm; |
| | | using WIDESEA_Comm.LogInfo; |
| | | using WIDESEA_Core.EFDbContext; |
| | | using WIDESEA_Core.FreeDB; |
| | | using WIDESEA_WCS.IRepositories; |
| | | using WIDESEA_WCS.Repositories; |
| | | using WIDESEA_WCS.WCSClient; |
| | |
| | | { |
| | | public class Gantry |
| | | { |
| | | static VOLContext Context = new VOLContext(); |
| | | Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); |
| | | Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); |
| | | Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); |
| | | Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); |
| | | Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); |
| | | Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context); |
| | | Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context); |
| | | Idt_patternRepository patternRepository = new dt_patternRepository(Context); |
| | | //FreeDB freeDB = new FreeDB(); |
| | | //static VOLContext Context = new VOLContext(); |
| | | //Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); |
| | | //Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); |
| | | //Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); |
| | | //Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); |
| | | ////Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); |
| | | //Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context); |
| | | //Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context); |
| | | //Idt_patternRepository patternRepository = new dt_patternRepository(Context); |
| | | #region æ¥è¯¢è½¦è½®æ°æ® |
| | | public void QueryWheeldata(PLCClient client) |
| | | { |
| | | try |
| | | { |
| | | VOLContext Context = new VOLContext(); |
| | | Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); |
| | | Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); |
| | | Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); |
| | | Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); |
| | | var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName); |
| | | List<string> names = new List<string>() { "1åå
è¾é䏿æ¥è¯¢è½¦è½®", "2åå
è¾é䏿æ¥è¯¢è½¦è½®", "3åå
è¾é䏿æ¥è¯¢è½¦è½®", "è¾é䏿æ¥è¯¢è½¦è½®" }; |
| | | foreach (string name in names) |
| | |
| | | //1-æ¾å°æ°æ®ï¼2-æªæ¾å°å·¥ä»¶ç±»åæ°æ® |
| | | client.WriteByOrder("W_i_status", (byte)2, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼2\nR_oi_onï¼0\n\næªæ¥è¯¢å°æºå 工车轮信æ¯", "PCS"); |
| | | #endregion |
| | | } |
| | | else |
| | | { |
| | |
| | | client.WriteByOrder("W_i_parameter_g", (float)geometry.g, name); |
| | | client.WriteByOrder("W_i_parameter_h", (float)geometry.h, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼1" + $"\naï¼{(float)geometry.a}\nbï¼{(float)geometry.b}\ncï¼{(float)geometry.c}\n" + |
| | | $"dï¼{(float)geometry.d}\neï¼{(float)geometry.e}\nfï¼{(float)geometry.f}\ngï¼{(float)geometry.g}\nhï¼{(float)geometry.h}\nR_oi_onï¼0", "PCS"); |
| | | #endregion |
| | | } |
| | | } |
| | | else |
| | |
| | | { |
| | | client.WriteByOrder("W_i_status", (byte)2, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼2\nR_oi_onï¼0\n\næªæ¥è¯¢å°æ£æµçº¿è½¦è½®ä¿¡æ¯", "PCS"); |
| | | #endregion |
| | | } |
| | | else |
| | | { |
| | |
| | | client.WriteByOrder("W_i_parameter_g", (float)geometry.g, name); |
| | | client.WriteByOrder("W_i_parameter_h", (float)geometry.h, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼1" + $"\naï¼{(float)geometry.a}\nbï¼{(float)geometry.b}\ncï¼{(float)geometry.c}\n" + |
| | | $"dï¼{(float)geometry.d}\neï¼{(float)geometry.e}\nfï¼{(float)geometry.f}\ngï¼{(float)geometry.g}\nhï¼{(float)geometry.h}\nR_oi_onï¼0", "PCS"); |
| | | #endregion |
| | | } |
| | | } |
| | | |
| | |
| | | { |
| | | try |
| | | { |
| | | VOLContext Context = new VOLContext(); |
| | | Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); |
| | | Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); |
| | | Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); |
| | | Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); |
| | | Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context); |
| | | Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context); |
| | | Idt_patternRepository patternRepository = new dt_patternRepository(Context); |
| | | var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName); |
| | | List<string> names = new List<string>() { "1åå
è¾é䏿æ¥è¯¢è®¢å", "2åå
è¾é䏿æ¥è¯¢è®¢å", "3åå
è¾é䏿æ¥è¯¢è®¢å", "è¾é䏿æ¥è¯¢è®¢å" }; |
| | | foreach (string name in names) |
| | | { |
| | | var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == name).ToList(); |
| | | var on = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_oi_on").First(), client); |
| | | //var on = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_oi_on" && x.plcdetail_number == name).First(), client); |
| | | if ((byte)on == 1) |
| | | { |
| | | //var wp_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_id").First(), client).ToString(); |
| | | var wp_id = client.ReadByOrder<string>("R_o_wp_id", name); |
| | | if (string.IsNullOrEmpty(wp_id)) |
| | | { |
| | | #region æ¥å¿è®°å½ |
| | | client.WriteByOrder("W_i_status", (byte)2, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼2\nR_oi_onï¼0\n\n车轮SNå·ä¸ºç©º", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | var wp_type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_type").First(), client); |
| | | var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == wp_id); |
| | | #region æµè¯ä½¿ç¨ |
| | | if (mes_Detail == null) |
| | | { |
| | | mes_Detail = mes_DetailRepository.FindFirst(x => x.jobID == (name == "3åå
è¾é䏿æ¥è¯¢è®¢å" ? "01180127004-2" : "01180127004-1")); |
| | | mes_Detail.SN = wp_id; |
| | | mes_DetailRepository.Update(mes_Detail, true); |
| | | } |
| | | #endregion |
| | | if (mes_Detail == null) |
| | | { |
| | | client.WriteByOrder("W_i_status", (byte)2, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼2\nR_oi_onï¼0\n\næªæ¥è¯¢å°å·¥å详æ
", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID); |
| | |
| | | { |
| | | client.WriteByOrder("W_i_status", (byte)2, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼2\nR_oi_onï¼0\n\næªæ¥è¯¢å°å·¥å头表", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | |
| | |
| | | { |
| | | client.WriteByOrder("W_i_status", (byte)4, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼4\nR_oi_onï¼0\n\næå¨å
¥åºæ¨¡å¼æªéæ©åºåº", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | var wp_type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_o_wp_type").First(), client); |
| | | //var geometry = dataRepository.FindFirst(x => x.TypeId == (Int32)wp_type); |
| | | var geometry = dataRepository.FindFirst(x => x.Description == mes_Head.drawingNo); |
| | | var geometry = dataRepository.Find(x => x.Description == mes_Head.drawingNo && x.TypeId == (Int32)wp_type).FirstOrDefault(); |
| | | if (geometry == null) |
| | | { |
| | | //1-好,å
许å å·¥ï¼2-ä¸å¨å表ä¸ï¼3-ä¸å 工车轮类åï¼4-æå¨å
¥åºæ¨¡å¼äººå·¥æªéæ©åºåº |
| | | client.WriteByOrder("W_i_status", (byte)2, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼2\nR_oi_onï¼0\n\næªæ¥è¯¢å°æºå 工车轮信æ¯", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | else |
| | |
| | | //å±è½å·¥èº(å±è½è§è§æ£æµ/å±è½æ¶æ²¹) |
| | | //if (name != "è¾é䏿æ¥è¯¢è½¦è½®") |
| | | //{ |
| | | client.WriteByOrder("W_i_skip_op_SJ1", mes_Head.skip_op_1, name);//å±è½è§è§æ£æµè®¾å¤1 |
| | | client.WriteByOrder("W_i_skip_op_SJ2", mes_Head.skip_op_2, name);//å±è½è§è§æ£æµè®¾å¤2 |
| | | client.WriteByOrder("W_i_skip_op_SJ1", name == "3åå
è¾é䏿æ¥è¯¢è®¢å" ? true : mes_Head.skip_op_1, name);//å±è½è§è§æ£æµè®¾å¤1 |
| | | client.WriteByOrder("W_i_skip_op_SJ2", name == "3åå
è¾é䏿æ¥è¯¢è®¢å" ? true : mes_Head.skip_op_2, name);//å±è½è§è§æ£æµè®¾å¤2 |
| | | client.WriteByOrder("W_i_skip_op_LT", mes_Head.skip_op_3, name);//å±è½é¾æ¡æº |
| | | //} |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼1" + |
| | | $"\nW_i_job_idï¼{mes_Detail.jobID}\nW_i_drawing_idï¼{mes_Head.drawingNo}\nW_i_heat_idï¼{mes_Detail.heatID}\nW_i_batch_idï¼{mes_Detail.heatBatchID}" + |
| | | $"\nW_i_skip_op_SJ1ï¼{(name == "3åå
è¾é䏿æ¥è¯¢è®¢å" ? true : mes_Head.skip_op_1)}\nW_i_skip_op_SJ2ï¼{(name == "3åå
è¾é䏿æ¥è¯¢è®¢å" ? true : mes_Head.skip_op_2)}" + |
| | | $"\nW_i_skip_op_LTï¼{mes_Head.skip_op_3}\nR_oi_onï¼0", "PCS"); |
| | | #endregion |
| | | } |
| | | } |
| | | else |
| | | { |
| | | var geometry = dataRepository.FindFirst(x => x.Description == mes_Head.drawingNo); |
| | | var geometry = detectionlineRepository.Find(x => x.Description == mes_Head.drawingNo && x.TypeId == (Int32)wp_type).FirstOrDefault(); |
| | | if (geometry == null) |
| | | { |
| | | //1-好,å
许å å·¥ï¼2-ä¸å¨å表ä¸ï¼3-ä¸å 工车轮类åï¼4-æå¨å
¥åºæ¨¡å¼äººå·¥æªéæ©åºåº |
| | | client.WriteByOrder("W_i_status", (byte)2, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼2\nR_oi_onï¼0\n\næªæ¥è¯¢å°æ£æµçº¿è½¦è½®ä¿¡æ¯", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | else |
| | |
| | | //client.WriteByOrder("W_i_sourceheat", "", name); |
| | | client.WriteByOrder("W_i_batch_id", mes_Detail.heatBatchID, name); |
| | | client.WriteByOrder("R_oi_on", (byte)0, name); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{wp_id}\nè½®åIDï¼{wp_type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_i_statusï¼1" + $"\nW_i_job_idï¼{mes_Detail.jobID}" + |
| | | $"\nW_i_drawing_idï¼{mes_Head.drawingNo}\nW_i_heat_idï¼{mes_Detail.heatID}\nW_i_batch_idï¼{mes_Detail.heatBatchID}\nR_oi_onï¼0", "PCS"); |
| | | #endregion |
| | | } |
| | | } |
| | | |
| | |
| | | { |
| | | try |
| | | { |
| | | VOLContext Context = new VOLContext(); |
| | | Idt_plcinfoheadRepository repository = new dt_plcinfoheadRepository(Context); |
| | | Idt_plcinfodetailRepository plcRepository = new dt_plcinfodetailRepository(Context); |
| | | Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(Context); |
| | | Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); |
| | | Idt_geometry_data_detectionlineRepository detectionlineRepository = new dt_geometry_data_detectionlineRepository(Context); |
| | | Idt_mes_detailRepository mes_DetailRepository = new dt_mes_detailRepository(Context); |
| | | Idt_mes_headRepository mes_HeadRepository = new dt_mes_headRepository(Context); |
| | | Idt_patternRepository patternRepository = new dt_patternRepository(Context); |
| | | var plc = repository.FindFirst(x => x.plcinfo_name == client.PLCName); |
| | | var Pipeline_client = PLCClient.Clients.FirstOrDefault(t => t.PLCName == "龿¡æº"); |
| | | if (Pipeline_client == null) throw new Exception("龿¡æºè°åº¦æå¡æªå¼å¯ï¼"); |
| | | if (!Pipeline_client.IsConnected) throw new Exception("ä¸é¾æ¡æºè¿æ¥è¶
æ¶ï¼"); |
| | | var Pipelineplc = repository.FindFirst(x => x.plcinfo_name == Pipeline_client.PLCName); |
| | | List<string> names = new List<string>() { "1åå
䏿åº", "2åå
䏿åº", "3åå
䏿åº" }; |
| | | |
| | | foreach (string name in names) |
| | | { |
| | | var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == name).ToList(); |
| | | |
| | | var Wheel_Type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_Type").First(), client);//车轮类å |
| | | var Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//车轮SNå· |
| | | if (string.IsNullOrEmpty(Wheel_id)) continue; |
| | | //var Wheel_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_id").First(), client).ToString(); |
| | | |
| | | var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == Wheel_id); |
| | | if (mes_Detail == null) |
| | | { |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{Wheel_id}\n\næªæ¥è¯¢å°å·¥å详æ
", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID); |
| | | if (mes_Head == null) |
| | | { |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{Wheel_id}\n\næªæ¥è¯¢å°å·¥å头表", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | |
| | | |
| | | var finished = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_load_finished").First(), client);//æ¾æå®æ |
| | | var updatefinished = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_Storage_update").First(), client);//è´§ä½ç¶ææ´æ° |
| | | if (!finished && updatefinished) |
| | | { |
| | | client.WriteByOrder("W_Storage_update", false, name);//è´§ä½ç¶ææ´æ° |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name + "è´§ä½ç¶ææ´æ°å¤ä½", $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{Wheel_id}\nè½®åIDï¼{Wheel_Type}\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_Storage_updateï¼false", "PCS"); |
| | | #endregion |
| | | } |
| | | if (finished && !updatefinished) |
| | | { |
| | | var AreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_AreaNr").First(), client); |
| | | var areaCode = PipelineJob.area_code(name); //æ ¹æ®ä¸æå£åå
åè·ååºå代ç |
| | | var station = stationinfoRepository.FindFirst(x => x.area == areaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == AreaNr.ToString()); //æ¤å¤æé®é¢ ä¸ç¥éæ¯ç»å°¾ä¸º1çåªä¸ªä¸æå£ |
| | | station.quantity++; //todo æ¤å¤æ°éä¸ä¼å¢å 使¯æ´æ°å®ä½å½±åæ¥é ææ¥æµè¯ |
| | | if (station.quantity > 5) |
| | | throw new Exception($"䏿ä½ä¿¡æ¯æ´æ°å¤±è´¥ï¼ä¸æä½è½¦è½®æ°é大äº5ï¼{station.stationCode}"); |
| | | //station.bindSN = station.bindSN == string.Empty ? Wheel_id : station.bindSN + "," + Wheel_id; |
| | | station.bindSN = string.IsNullOrEmpty(station.bindSN) ? Wheel_id : station.bindSN + "," + Wheel_id; |
| | | if (station.quantity == 1) |
| | | { |
| | | station.stationType = mes_Head.drawingNo; |
| | | station.Number = mes_Head.jobID; |
| | | station.heatNumber = mes_Detail.heatID; |
| | | station.tray_status = "StrogeTray"; |
| | | } |
| | | var count = stationinfoRepository.Update(station, true); |
| | | if (count < 1) |
| | | throw new Exception($"䏿ä½ä¿¡æ¯æ´æ°å¤±è´¥ï¼ä¸æä½ç¼å·ï¼{station.stationCode}"); |
| | | client.WriteByOrder("W_Storage_update", true, name);//è´§ä½ç¶ææ´æ° |
| | | client.WriteByOrder("W_Enabl_Load", false, name);//æ¯å¦å
许 |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name + "æ¾æå®æ", $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{Wheel_id}\nè½®åIDï¼{Wheel_Type}\n䏿ä½å·ï¼{AreaNr}" + |
| | | $"\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_Storage_updateï¼true" + $"\nW_Enabl_Loadï¼false", "PCS"); |
| | | #endregion |
| | | } |
| | | |
| | | var Request = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Request_Load").First(), client); |
| | | if (!Request) continue; |
| | |
| | | var NGStation = "X01001003"; |
| | | if (name == "2åå
䏿åº") NGStation = "X02001003"; |
| | | if (name == "3åå
䏿åº") NGStation = "X03001002"; |
| | | foreach (var station in Stations) |
| | | |
| | | foreach (var station in Stations) //ä»»ä½ä¸ä¸ªä¸æä½ä¸ºç©ºæç¦ç¨æ¶,é½ä¼åæ¢æ¡æ¶ |
| | | { |
| | | if (!station.enable || station.location_state == LocationStateEnum.Empty.ToString()) |
| | | client.WriteByOrder("W_Enabl_Load", false, name);//ä¿¡å·ä¸ºfalseæ¡æ¶åæ¢è¿å
¥ |
| | | } |
| | | var Wheel_Type = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_Type").First(), client);//车轮类å |
| | | var Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name);//车轮SNå· |
| | | //var Wheel_id = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_Wheel_id").First(), client).ToString(); |
| | | |
| | | var mes_Detail = mes_DetailRepository.FindFirst(x => x.SN == Wheel_id); |
| | | var mes_Head = mes_HeadRepository.FindFirst(x => x.jobID == mes_Detail.jobID); |
| | | //var currentAreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_Are00aNr").First(), client); |
| | | //var currentAreaCode = PipelineJob.area_code(name); //æ ¹æ®ä¸æå£åå
åè·ååºå代ç |
| | | //var currentStation = stationinfoRepository.FindFirst(x => x.area == currentAreaCode && x.stationCode.Substring(x.stationCode.Length - 1, 1) == currentAreaNr.ToString()); |
| | | //if (!currentStation.enable || currentStation.location_state == LocationStateEnum.Empty.ToString()) |
| | | // client.WriteByOrder("W_Enabl_Load", false, name);//ä¿¡å·ä¸ºfalseæ¡æ¶åæ¢è¿å
¥ |
| | | |
| | | var wheel = PipelineJob.QueryMateriel(mes_Head.drawingNo); |
| | | if (wheel == null) |
| | | { |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error(name, $"æªæ¥è¯¢å°è½¦è½®ä¿¡æ¯ï¼", "PCS"); |
| | | #endregion |
| | | continue; |
| | | } |
| | | |
| | | var PartStatus = DBExtension.Read(details.Where(x => x.plcdetail_name == "R_PartStatus").First(), client);//1:ok;2:nok |
| | | if ((Int16)PartStatus == 1) |
| | |
| | | Stationinfo = Stations.Where(x => x.enable && x.stationCode != NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity == 0).FirstOrDefault(); |
| | | if (Stationinfo != null) |
| | | { |
| | | #region æçç±»åä¸ä¸è´éæ´æ¢æç |
| | | if (Stationinfo.tray_type != (wheel.e < 1100 ? "SmallTray" : "LargeTray")) |
| | | { |
| | | Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); |
| | | Stationinfo.tray_type = Stationinfo.tray_type == "SmallTray" ? "SmallTray/LargeTray" : "LargeTray/SmallTray"; |
| | | Stationinfo.remark = "æçç±»åä¸ä¸è´éæ´æ¢æç"; |
| | | stationinfoRepository.Update(Stationinfo, true); |
| | | continue; |
| | | } |
| | | #endregion |
| | | |
| | | var Pipelinedetails = plcRepository.Find(x => x.plcdetail_iotype == Pipelineplc.plcinfo_iotyep && x.plcdetail_number == Stationinfo.stationCode).ToList(); |
| | | var PalletSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_PalletSignal").First(), Pipeline_client);//读åæçä¿¡å·:1:æ,2æ |
| | | //var MaterialSignal = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_MaterialSignal").First(), Pipeline_client);//读åè´§ç©ä¿¡å·:1:æ,2æ |
| | | //var Wheel_id = client.ReadByOrder<string>("R_Wheel_id", name); |
| | | if (PalletSignal == 1) |
| | | { |
| | | var SNS = Stationinfo.bindSN.Split(","); |
| | | List<string> list = new List<string>(); |
| | | foreach (var SN in SNS) |
| | | if (Stationinfo.bindSN != null) |
| | | { |
| | | if (!string.IsNullOrEmpty(SN)) |
| | | list.Add(SN); |
| | | var SNS = Stationinfo.bindSN.Split(","); |
| | | foreach (var SN in SNS) |
| | | { |
| | | if (!string.IsNullOrEmpty(SN)) |
| | | list.Add(SN); |
| | | } |
| | | } |
| | | |
| | | //ç¼åæ¶ä¸è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ |
| | | if (list.Count != Stationinfo.quantity) |
| | | { |
| | | Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); |
| | | Stationinfo.remark = "车轮æ°éä¸SNå·æ°éä¸ä¸è´"; |
| | | stationinfoRepository.Update(Stationinfo, true); |
| | | continue; |
| | | //åå
¥æ¡æ¶æ¥è¦ä¿¡å· |
| | | throw new Exception("䏿ä½è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ï¼ä¸æä½ç¼å·ï¼" + Stationinfo.stationCode); |
| | | //throw new Exception("䏿ä½è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ï¼ä¸æä½ç¼å·ï¼" + Stationinfo.stationCode); |
| | | } |
| | | var area = Convert.ToInt16(Stationinfo.stationCode.Substring(Stationinfo.stationCode.Length - 1, 1)); |
| | | client.WriteByOrder("W_AreaNr", (Int16)area, name);//åºåè´§ä½å· |
| | | client.WriteByOrder("W_IndexNr", (Int16)(Stationinfo.quantity + 1), name);//æçä¸ç第å 个车轮 |
| | | client.WriteByOrder("W_Storage_Type", (Int16)1, name);//æçç±»å1-横æ¾;2-ç«æ¾(ææ¶åªææ¨ªæ¾æç) |
| | | client.WriteByOrder("W_Enabl_Load", true, name);//æ¯å¦å
许 |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name + "æ¾æç³è¯·", $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{Wheel_id}\nè½®åIDï¼{Wheel_Type}\nè½¦è½®ç¶æï¼OK" + |
| | | $"\n读åæçå
çµä¿¡å·ï¼{PalletSignal}" + |
| | | $"\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\n䏿ä½å·ï¼{area}\n第å 个车轮ï¼{(Stationinfo.quantity + 1)}\næçç±»åï¼1\nW_Enabl_Loadï¼true", "PCS"); |
| | | #endregion |
| | | return; |
| | | } |
| | | } |
| | |
| | | && x.tray_type == (wheel.e < 1100 ? "SmallTray" : "LargeTray") |
| | | && x.Number == mes_Detail.jobID |
| | | && x.heatNumber == mes_Detail.heatID).FirstOrDefault(); |
| | | if (Stationinfo == null) |
| | | Stationinfo = Stations.Where(x => x.enable && x.stationCode == NGStation && x.location_state == LocationStateEnum.Stroge.ToString() && x.quantity == 0).FirstOrDefault(); |
| | | if (Stationinfo != null) |
| | | { |
| | | #region æçç±»åä¸ä¸è´éæ´æ¢æç |
| | | if (Stationinfo.tray_type != (wheel.e < 1100 ? "SmallTray" : "LargeTray")) |
| | | { |
| | | Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); |
| | | Stationinfo.tray_type = Stationinfo.tray_type == "SmallTray" ? "SmallTray/LargeTray" : "LargeTray/SmallTray"; |
| | | Stationinfo.remark = "æçç±»åä¸ä¸è´éæ´æ¢æç"; |
| | | stationinfoRepository.Update(Stationinfo, true); |
| | | } |
| | | #endregion |
| | | var Pipelinedetails = plcRepository.Find(x => x.plcdetail_iotype == Pipelineplc.plcinfo_iotyep && x.plcdetail_number == Stationinfo.stationCode).ToList(); |
| | | var PalletSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_PalletSignal").First(), client);//读åæçä¿¡å·:1:æ,2æ |
| | | var PalletSignal = (Int16)DBExtension.Read(Pipelinedetails.Where(x => x.plcdetail_name == "R_PalletSignal").First(), Pipeline_client);//读åæçä¿¡å·:1:æ,2æ |
| | | if (PalletSignal == 1) |
| | | { |
| | | var SNS = Stationinfo.bindSN.Split(","); |
| | | List<string> list = new List<string>(); |
| | | foreach (var SN in SNS) |
| | | if (Stationinfo.bindSN != null) |
| | | { |
| | | if (!string.IsNullOrEmpty(SN)) |
| | | list.Add(SN); |
| | | foreach (var SN in SNS) |
| | | { |
| | | if (!string.IsNullOrEmpty(SN)) |
| | | list.Add(SN); |
| | | } |
| | | } |
| | | |
| | | //ç¼åæ¶ä¸è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ |
| | | if (list.Count != Stationinfo.quantity) |
| | | { |
| | | Stationinfo.location_state = LocationStateEnum.Abnormal.ToString(); |
| | | Stationinfo.remark = "车轮æ°éä¸SNå·æ°éä¸ä¸è´"; |
| | | stationinfoRepository.Update(Stationinfo, true); |
| | | continue; |
| | | //åå
¥æ¡æ¶æ¥è¦ä¿¡å· |
| | | throw new Exception("䏿ä½è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ï¼ä¸æä½ç¼å·ï¼" + Stationinfo.stationCode); |
| | | //throw new Exception("䏿ä½è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ï¼ä¸æä½ç¼å·ï¼" + Stationinfo.stationCode); |
| | | } |
| | | var area = Convert.ToInt16(Stationinfo.stationCode.Substring(Stationinfo.stationCode.Length - 1, 1)); |
| | | client.WriteByOrder("W_AreaNr", (Int16)area, name);//åºåè´§ä½å· |
| | | client.WriteByOrder("W_IndexNr", (Int16)(Stationinfo.quantity + 1), name);//æçä¸ç第å 个车轮 |
| | | client.WriteByOrder("W_Storage_Type", (Int16)1, name);//æçç±»å1-横æ¾;2-ç«æ¾(ææ¶åªææ¨ªæ¾æç) |
| | | client.WriteByOrder("W_Enabl_Load", true, name);//æ¯å¦å
许 |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success(name + "æ¾æç³è¯·", $"è¯»åæ¡æ¶ä¿¡æ¯ï¼\n车轮SNï¼{Wheel_id}\nè½®åIDï¼{Wheel_Type}\nè½¦è½®ç¶æï¼NG" + |
| | | $"\n读åæçå
çµä¿¡å·ï¼{PalletSignal}" + |
| | | $"\n\nåå
¥æ¡æ¶ä¿¡æ¯ï¼\n䏿ä½å·ï¼{area}\n第å 个车轮ï¼{(Stationinfo.quantity + 1)}\næçç±»åï¼1\nW_Enabl_Loadï¼true", "PCS"); |
| | | #endregion |
| | | return; |
| | | } |
| | | } |
| | |
| | | // StationCodes = new List<string>() { "X03001001", "X03001002" }; |
| | | |
| | | #endregion |
| | | var finished = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_load_finished").First(), client);//æ¾æå®æ |
| | | var updatefinished = (bool)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_Storage_update").First(), client);//è´§ä½ç¶ææ´æ° |
| | | if (!finished && updatefinished) |
| | | client.WriteByOrder("W_Storage_update", false, name);//è´§ä½ç¶ææ´æ° |
| | | if (finished && !updatefinished) |
| | | { |
| | | var AreaNr = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "W_AreaNr").First(), client); |
| | | var station = stationinfoRepository.FindFirst(x => x.stationCode.Substring(x.stationCode.Length - 1, 1) == AreaNr.ToString()); |
| | | station.quantity = station.quantity++; |
| | | station.bindSN = station.bindSN == string.Empty ? Wheel_id : station.bindSN + "," + Wheel_id; |
| | | if (station.quantity == 0) |
| | | { |
| | | station.stationType = mes_Head.drawingNo; |
| | | station.Number = mes_Head.jobID; |
| | | station.heatNumber = mes_Detail.heatID; |
| | | } |
| | | var count = stationinfoRepository.Update(station); |
| | | if (count < 1) |
| | | throw new Exception($"䏿ä½ä¿¡æ¯æ´æ°å¤±è´¥ï¼ä¸æä½ç¼å·ï¼{station.stationCode}"); |
| | | client.WriteByOrder("W_Storage_update", true, name);//è´§ä½ç¶ææ´æ° |
| | | client.WriteByOrder("W_Enabl_Load", false, name);//æ¯å¦å
许 |
| | | } |
| | | |
| | | #region |
| | | //for (int i = 0; i < StationCodes.Count - 1; i++) |
| | | //{ |
| | |
| | | //throw new NotImplementedException(); |
| | | //Creation.HCJCreation(); |
| | | //Creation.PLCinfodetail(); |
| | | |
| | | //StationTask.CreateTask(); |
| | | //OutboundTask.CreateOutboundTask(); |
| | | |
| | | //ReplaceTray.a(); |
| | | StationTask.CreateTask(); |
| | | OutboundTask.CreateOutboundTask(); |
| | | ReplaceTray.ReplaceTrayTask(); |
| | | RestockHCJ.HCJGetBarcode(); |
| | | } |
| | | } |
| | | } |
| | |
| | | return; |
| | | } |
| | | Gantry gantry = new Gantry(); |
| | | gantry.QueryWheeldata(client); |
| | | gantry.QueryOrder(client); |
| | | gantry.QueryWheeldata(client); |
| | | gantry.Layofflevel(client); |
| | | } |
| | | } |
| | |
| | | //ç¼åæ¶æªå¯ç¨ç¦æ¢æ¡æ¶è¿å
¥ |
| | | foreach (var station in Stations) |
| | | { |
| | | if (!station.enable) |
| | | if (!station.enable || station.location_state != LocationStateEnum.Stroge.ToString()) |
| | | Gantry_client.WriteByOrder("W_RequestUnload", false, number);//ä¿¡å·ä¸ºfalseæ¡æ¶åæ¢è¿å
¥ |
| | | } |
| | | |
| | |
| | | if (list.Count != Station.quantity) |
| | | { |
| | | Station.location_state = LocationStateEnum.Abnormal.ToString(); |
| | | Station.remark = "车轮æ°éä¸SNå·æ°éä¸ä¸è´"; |
| | | stationinfoRepository.Update(Station, true); |
| | | Gantry_client.WriteByOrder("W_RequestUnload", false, number);//ä¿¡å·ä¸ºfalseæ¡æ¶åæ¢è¿å
¥ |
| | | throw new Exception("䏿ä½è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ï¼ä¸æä½ç¼å·ï¼" + Station.stationCode); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Error("䏿åº", $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_RequestUnloadï¼false\n\n{Station.stationCode}车轮æ°éä¸SNå·æ°éä¸ä¸è´", "PCS"); |
| | | #endregion |
| | | return; |
| | | //throw new Exception("䏿ä½è½¦è½®æ°éä¸SNå·æ°éä¸ä¸è´ï¼ä¸æä½ç¼å·ï¼" + Station.stationCode); |
| | | } |
| | | var details = plcRepository.Find(x => x.plcdetail_iotype == plc.plcinfo_iotyep && x.plcdetail_number == Station.stationCode).ToList(); |
| | | var PalletSignal = (Int16)DBExtension.Read(details.Where(x => x.plcdetail_name == "R_PalletSignal").First(), client);//读åæçä¿¡å·:1:æ,2æ |
| | |
| | | Gantry_client.WriteByOrder("W_Wheel_Type", (Int16)Convert.ToInt16(QueryMateriel(Station.stationType).TypeId), number);//车轮类å |
| | | Gantry_client.WriteByOrder("W_Wheel_id", SNS[SNS.Length - 1], number);//车轮SNå· |
| | | Gantry_client.WriteByOrder("W_RequestUnload", true, number); |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success("䏿åºç³è¯·", $"读åæçå
çµä¿¡å·ï¼{PalletSignal}\n读å第ä¸ä¸ªè½¦è½®å
çµä¿¡å·ï¼{MaterialSignal}\n\n" + |
| | | $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nåºåè´§ä½å·ï¼{area}\næçä¸ç第å 个车轮ï¼{SNS.Length}\næçç±»åï¼{1}\n车轮类åï¼{QueryMateriel(Station.stationType).TypeId}" + |
| | | $"\n车轮SNå·ï¼{SNS[SNS.Length - 1]}\nW_RequestUnloadï¼true", "PCS"); |
| | | #endregion |
| | | } |
| | | else |
| | | { |
| | |
| | | if (!Date_Vaild)//ä¿¡æ¯æè¯¯ï¼è®°å½æ¥å¿ |
| | | { |
| | | Station.location_state = LocationStateEnum.Abnormal.ToString(); |
| | | Station.remark = $"æªæ¥è¯¢å°SNå·ï¼{SNS[SNS.Length - 1]}ç订å"; |
| | | stationinfoRepository.Update(Station, true); |
| | | Gantry_client.WriteByOrder("W_RequestUnload", false, number);//ä¿¡å·ä¸ºfalseæ¡æ¶åæ¢è¿å
¥ |
| | | throw new Exception($"æªæ¥è¯¢å°SNå·ï¼{SNS[SNS.Length - 1]}ç订åï¼ä¸æä½ç¼å·ï¼{Station.stationCode}"); |
| | | //throw new Exception($"æªæ¥è¯¢å°SNå·ï¼{SNS[SNS.Length - 1]}ç订åï¼ä¸æä½ç¼å·ï¼{Station.stationCode}"); |
| | | WriteDBLog.Error("䏿åºä¿¡æ¯æ¥è¯¢", $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nW_RequestUnloadï¼false\n\n{Station.stationCode}æªæ¥è¯¢å°SNå·ï¼{SNS[SNS.Length - 1]}ç订å", "PCS"); |
| | | return; |
| | | } |
| | | } |
| | | var finished = (bool)DBExtension.Read(Gantrydetails.Where(x => x.plcdetail_name == "R_Unlod_finished").First(), Gantry_client);//夹å宿 |
| | |
| | | } |
| | | var count = stationinfoRepository.Update(Station, true); |
| | | if (count < 1) |
| | | throw new Exception($"䏿ä½ä¿¡æ¯æ´æ°å¤±è´¥ï¼ä¸æä½ç¼å·ï¼{Station.stationCode}"); |
| | | { |
| | | WriteDBLog.Error("åæå®æ", $"䏿ä½ä¿¡æ¯æ´æ°å¤±è´¥ï¼ä¸æä½ç¼å·ï¼{Station.stationCode}", "PCS"); |
| | | //throw new Exception($"䏿ä½ä¿¡æ¯æ´æ°å¤±è´¥ï¼ä¸æä½ç¼å·ï¼{Station.stationCode}"); |
| | | return; |
| | | } |
| | | Gantry_client.WriteByOrder("W_Storage_update", true, number);//è´§ä½ç¶ææ´æ° |
| | | Gantry_client.WriteByOrder("W_RequestUnload", false, number);//ä¿¡å·ä¸ºfalseæ¡æ¶åæ¢è¿å
¥ |
| | | #region æ¥å¿è®°å½ |
| | | WriteDBLog.Success("åæå®æ", $"åå
¥æ¡æ¶ä¿¡æ¯ï¼\nè´§ä½ç¶ææ´æ°ï¼{true}\nW_RequestUnloadï¼{false}", "PCS"); |
| | | #endregion |
| | | //finished = (bool)DBExtension.Read(Gantrydetails.Where(x => x.plcdetail_name == "R_Unlod_finished").First(), Gantry_client); |
| | | //while (finished) |
| | | //{ |
| | |
| | | // Gantry_client.WriteByOrder("W_Storage_update", false, number);//è´§ä½ç¶ææ´æ° |
| | | |
| | | } |
| | | else |
| | | Gantry_client.WriteByOrder("W_RequestUnload", false, number);//ä¿¡å·ä¸ºfalseæ¡æ¶åæ¢è¿å
¥ |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | return Newsn; |
| | | } |
| | | public static dt_geometry_data QueryMateriel(string type) |
| | | { |
| | | { |
| | | VOLContext Context = new VOLContext(); |
| | | Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); |
| | | var materielinfo = dataRepository.FindFirst(x => x.Description == type); |
| | | var materielinfo = dataRepository.Find(x => x.Description == type).OrderBy(x => x.TypeId).FirstOrDefault(); |
| | | return materielinfo; |
| | | } |
| | | public static string QueryMateriel(int typeId) |
| | | public static string QueryMateriel(int typeId) |
| | | { |
| | | VOLContext Context = new VOLContext(); |
| | | Idt_geometry_dataRepository dataRepository = new dt_geometry_dataRepository(Context); |
| | |
| | | var mes_heads = freeDB.Select<dt_mes_head>().Where(x => x.processCode == "28").OrderBy(x => x.expectedStartTime).ToList(); |
| | | foreach (var mes_head in mes_heads) |
| | | { |
| | | //var inventorys = freeDB.Select<dt_inventory>().Where(x => x.FigureNumber == mes_head.drawingNo).OrderBy.ToList(); |
| | | var station = stationinfoRepository.Find(x => x.stationType == mes_head.drawingNo && x.line != x.line).OrderBy(x => x.line).ThenByDescending(x => x.column).FirstOrDefault(); |
| | | bool ok = false; |
| | | List<string> list = new List<string>(); |
| | | if (station != null && station.location_state == LocationStateEnum.Stroge.ToString() && station.enable) |
| | | #region æ ¹æ®åºåå
¥åºæ¶é´æææ¥è¯¢ |
| | | var inventory = freeDB.Select<dt_inventory>().Where(x => x.FigureNumber == mes_head.drawingNo).OrderByDescending(x => x.OnlineTime).First(); |
| | | if (inventory != null) |
| | | { |
| | | var SNS = station.bindSN.Split(","); |
| | | foreach (var SN in SNS) |
| | | var Station = stationinfoRepository.Find(x => x.stationCode == inventory.stationCode).FirstOrDefault(); |
| | | if (Station != null) |
| | | { |
| | | if (!string.IsNullOrEmpty(SN)) |
| | | list.Add(SN); |
| | | var stationinfo = stationinfoRepository.Find(x => x.line == Station.line && x.area == Station.area && x.enable).OrderByDescending(x => x.column).FirstOrDefault(); |
| | | if (stationinfo != null) |
| | | { |
| | | if (stationinfo.bindSN == null) |
| | | throw new Exception(stationinfo.stationCode + "车轮SNå·ä¿¡æ¯å¼å¸¸!"); |
| | | List<string> lists = new List<string>(); |
| | | var SNS = stationinfo.bindSN.Split(","); |
| | | foreach (var SN in SNS) |
| | | { |
| | | if (!string.IsNullOrEmpty(SN)) |
| | | lists.Add(SN); |
| | | } |
| | | foreach (var item in lists) |
| | | { |
| | | if (freeDB.Select<dt_mes_detail>().Where(x => x.jobID == mes_head.jobID && x.SN == item).Any()) |
| | | { |
| | | dt_agvtask agvtask = new dt_agvtask() |
| | | { |
| | | agv_fromaddress = stationinfo.stationCode, |
| | | agv_id = Guid.NewGuid(), |
| | | agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), |
| | | agv_grade = 1, |
| | | agv_createtime = DateTime.Now, |
| | | agv_taskstate = "Queue", |
| | | agv_materielid = stationinfo.stationType, |
| | | agv_qty = stationinfo.quantity, |
| | | agv_tasktype = "TaskType_Outbound", |
| | | agv_toaddress = "", |
| | | agv_userid = "ç³»ç»", |
| | | bindSN = stationinfo.bindSN, |
| | | agv_worktype = Convert.ToInt32(mes_head.processCode), |
| | | agv_materbarcode = mes_head.materialCode, |
| | | agv_Traytype = stationinfo.tray_type, |
| | | agv_TrayStatus = stationinfo.tray_status |
| | | }; |
| | | dt_stationinfo TargetLocation = GetEmptyLocation(stationinfoRepository); |
| | | if (TargetLocation != null) |
| | | { |
| | | agvtask.agv_taskstate = "Create"; |
| | | agvtask.agv_toaddress = TargetLocation.stationCode; |
| | | TargetLocation.location_state = LocationStateEnum.Busy.ToString(); |
| | | freeDB.Update(TargetLocation); |
| | | } |
| | | freeDB.Add(agvtask); |
| | | return; |
| | | } |
| | | } |
| | | } |
| | | stationinfo = stationinfoRepository.Find(x => x.stationType == mes_head.drawingNo && x.line != Station.line).OrderBy(x => x.line).ThenByDescending(x => x.column).FirstOrDefault(); |
| | | if (stationinfo != null && stationinfo.enable) |
| | | { |
| | | if (stationinfo.bindSN == null) |
| | | throw new Exception(stationinfo.stationCode + "车轮SNå·ä¿¡æ¯å¼å¸¸!"); |
| | | List<string> lists = new List<string>(); |
| | | var SNS = stationinfo.bindSN.Split(","); |
| | | foreach (var SN in SNS) |
| | | { |
| | | if (!string.IsNullOrEmpty(SN)) |
| | | lists.Add(SN); |
| | | } |
| | | foreach (var item in lists) |
| | | { |
| | | if (freeDB.Select<dt_mes_detail>().Where(x => x.jobID == mes_head.jobID && x.SN == item).Any()) |
| | | { |
| | | dt_agvtask agvtask = new dt_agvtask() |
| | | { |
| | | agv_fromaddress = stationinfo.stationCode, |
| | | agv_id = Guid.NewGuid(), |
| | | agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), |
| | | agv_grade = 1, |
| | | agv_createtime = DateTime.Now, |
| | | agv_taskstate = "Queue", |
| | | agv_materielid = stationinfo.stationType, |
| | | agv_qty = stationinfo.quantity, |
| | | agv_tasktype = "TaskType_Outbound", |
| | | agv_toaddress = "", |
| | | agv_userid = "ç³»ç»", |
| | | bindSN = stationinfo.bindSN, |
| | | agv_worktype = Convert.ToInt32(mes_head.processCode), |
| | | agv_materbarcode = mes_head.materialCode, |
| | | agv_Traytype = stationinfo.tray_type, |
| | | agv_TrayStatus = stationinfo.tray_status |
| | | }; |
| | | dt_stationinfo TargetLocation = GetEmptyLocation(stationinfoRepository); |
| | | if (TargetLocation != null) |
| | | { |
| | | agvtask.agv_taskstate = "Create"; |
| | | agvtask.agv_toaddress = TargetLocation.stationCode; |
| | | TargetLocation.location_state = LocationStateEnum.Busy.ToString(); |
| | | freeDB.Update(TargetLocation); |
| | | } |
| | | freeDB.Add(agvtask); |
| | | return; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | foreach (var SN in list) |
| | | { |
| | | if (ok = freeDB.Select<dt_mes_detail>().Where(x => x.jobID == mes_head.jobID && x.SN == SN).Any()) continue; |
| | | } |
| | | if (ok) |
| | | { |
| | | dt_agvtask agvtask = new dt_agvtask() |
| | | { |
| | | agv_fromaddress = station.stationCode, |
| | | agv_id = Guid.NewGuid(), |
| | | agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), |
| | | agv_grade = 1, |
| | | agv_createtime = DateTime.Now, |
| | | agv_taskstate = "Queue", |
| | | agv_materielid = station.stationType, |
| | | agv_qty = station.quantity, |
| | | agv_tasktype = "TaskType_Outbound", |
| | | agv_toaddress = "", |
| | | agv_userid = "ç³»ç»", |
| | | bindSN = station.bindSN, |
| | | agv_worktype = Convert.ToInt32(mes_head.processCode), |
| | | agv_materbarcode = mes_head.materialCode, |
| | | agv_barcode = station.tray_type |
| | | }; |
| | | dt_stationinfo TargetLocation = GetEmptyLocation(stationinfoRepository); |
| | | if (TargetLocation != null) |
| | | { |
| | | agvtask.agv_taskstate = "Create"; |
| | | agvtask.agv_toaddress = TargetLocation.stationCode; |
| | | TargetLocation.location_state = LocationStateEnum.Busy.ToString(); |
| | | freeDB.Update(TargetLocation); |
| | | } |
| | | freeDB.Add(agvtask); |
| | | } |
| | | #endregion |
| | | |
| | | #region MyRegion |
| | | //var station = stationinfoRepository.Find(x => x.stationType == mes_head.drawingNo && x.line != x.line).OrderBy(x => x.line).ThenByDescending(x => x.column).FirstOrDefault(); |
| | | //bool ok = false; |
| | | //List<string> list = new List<string>(); |
| | | //if (station != null && station.location_state == LocationStateEnum.Stroge.ToString() && station.enable) |
| | | //{ |
| | | // var SNS = station.bindSN.Split(","); |
| | | // foreach (var SN in SNS) |
| | | // { |
| | | // if (!string.IsNullOrEmpty(SN)) |
| | | // list.Add(SN); |
| | | // } |
| | | //} |
| | | //foreach (var SN in list) |
| | | //{ |
| | | // if (ok = freeDB.Select<dt_mes_detail>().Where(x => x.jobID == mes_head.jobID && x.SN == SN).Any()) continue; |
| | | //} |
| | | //if (ok) |
| | | //{ |
| | | // dt_agvtask agvtask = new dt_agvtask() |
| | | // { |
| | | // agv_fromaddress = station.stationCode, |
| | | // agv_id = Guid.NewGuid(), |
| | | // agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), |
| | | // agv_grade = 1, |
| | | // agv_createtime = DateTime.Now, |
| | | // agv_taskstate = "Queue", |
| | | // agv_materielid = station.stationType, |
| | | // agv_qty = station.quantity, |
| | | // agv_tasktype = "TaskType_Outbound", |
| | | // agv_toaddress = "", |
| | | // agv_userid = "ç³»ç»", |
| | | // bindSN = station.bindSN, |
| | | // agv_worktype = Convert.ToInt32(mes_head.processCode), |
| | | // agv_materbarcode = mes_head.materialCode, |
| | | // agv_barcode = station.tray_type |
| | | // }; |
| | | // dt_stationinfo TargetLocation = GetEmptyLocation(stationinfoRepository); |
| | | // if (TargetLocation != null) |
| | | // { |
| | | // agvtask.agv_taskstate = "Create"; |
| | | // agvtask.agv_toaddress = TargetLocation.stationCode; |
| | | // TargetLocation.location_state = LocationStateEnum.Busy.ToString(); |
| | | // freeDB.Update(TargetLocation); |
| | | // } |
| | | // freeDB.Add(agvtask); |
| | | //} |
| | | #endregion |
| | | |
| | | } |
| | | } |
| | | catch (Exception) |
¶Ô±ÈÐÂÎļþ |
| | |
| | | using System; |
| | | using System.Collections.Generic; |
| | | using System.Linq; |
| | | using System.Security.Cryptography.Xml; |
| | | using System.Text; |
| | | using System.Threading.Tasks; |
| | | using WIDESEA_Comm; |
| | | using WIDESEA_Comm.TaskNo; |
| | | using WIDESEA_Core.FreeDB; |
| | | using WIDESEA_Entity.DomainModels; |
| | | using WIDESEA_WCS.JobsPart.Common.åå¨è¿ç¨; |
| | | using static FreeSql.Internal.GlobalFilter; |
| | | using static System.Collections.Specialized.BitVector32; |
| | | |
| | | namespace WIDESEA_WCS.JobsPart.Common |
| | | { |
| | | public class ReplaceTray |
| | | { |
| | | static FreeDB freeDB = new FreeDB(); |
| | | |
| | | public static void a() |
| | | { |
| | | var mes_Detail = freeDB.Select<dt_mes_detail>().Where(x => x.SN == "1202956016").First(); |
| | | var mes_Head = freeDB.Select<dt_mes_head>().Where(x => x.jobID == mes_Detail.jobID).First(); |
| | | |
| | | dt_inventory inventory = new dt_inventory() |
| | | { |
| | | SN = mes_Detail.SN, |
| | | Name = mes_Head.productName, |
| | | FigureNumber = mes_Head.drawingNo, |
| | | area = "2", |
| | | HeatNumber = mes_Detail.heatID, |
| | | BilletNumber = mes_Detail.billetID, |
| | | OnlineTime = DateTime.Now, |
| | | Operator = "AGV", |
| | | stationCode = "B01001001", |
| | | jobID = mes_Detail.jobID, |
| | | ID = Guid.NewGuid(), |
| | | remark="" |
| | | }; |
| | | StoredProcedure.EXEC( inventory,""); |
| | | } |
| | | /// <summary> |
| | | /// åå»ºæ´æ¢æçä»»å¡ |
| | | /// </summary> |
| | | public static void ReplaceTrayTask() |
| | | { |
| | | try |
| | | { |
| | | var stations = freeDB.Select<dt_stationinfo>().Where(x => x.stationCode.Contains("X") && x.location_state == LocationStateEnum.Abnormal.ToString() && (x.tray_type == "SmallTray/LargeTray" || x.tray_type == "LargeTray/SmallTray")).ToList(); |
| | | foreach (var station in stations) |
| | | { |
| | | var types = station.tray_type.Split('/'); |
| | | var area = types[0] == "SmallTray" ? "11" : "10"; |
| | | //æ¾1åºåºç空æä½ |
| | | |
| | | var EmptyStation = freeDB.Select<dt_stationinfo>().Where(x => x.area == area && x.stationCode.Contains("A") && x.location_state == "Empty" && x.enable) |
| | | .OrderBy(x => x.column).OrderByDescending(x => x.line).First(); |
| | | if (EmptyStation == null) |
| | | EmptyStation = freeDB.Select<dt_stationinfo>().Where(x => x.area == area && x.stationCode.Contains("C") && x.location_state == "Empty" && x.enable) |
| | | .OrderBy(x => x.line).OrderBy(x => x.column).First(); |
| | | if (EmptyStation != null) |
| | | { |
| | | dt_agvtask agvtask = new dt_agvtask() |
| | | { |
| | | agv_fromaddress = station.stationCode, |
| | | agv_id = Guid.NewGuid(), |
| | | agv_tasknum = IdenxManager.GetTaskNo("KH-", "WMS"), |
| | | agv_grade = 2, |
| | | agv_createtime = DateTime.Now, |
| | | agv_taskstate = "Create", |
| | | //agv_materielid = station.stationType, |
| | | agv_qty = 1, |
| | | agv_tasktype = "TaskType_EmptyPallet", |
| | | agv_toaddress = EmptyStation.stationCode, |
| | | agv_userid = "ç³»ç»", |
| | | agv_TrayStatus = station.tray_status, |
| | | //bindSN = station.bindSN, |
| | | //agv_worktype = Convert.ToInt32(mesinfo.processCode), |
| | | //agv_materbarcode = mesinfo.materialCode, |
| | | agv_Traytype = types[0] |
| | | }; |
| | | freeDB.Add(agvtask); |
| | | CreatePartQueue(agvtask, types[1]); |
| | | } |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | |
| | | throw; |
| | | } |
| | | } |
| | | /// <summary> |
| | | /// åå»ºå®æ´ç补空æä»»å¡ |
| | | /// </summary> |
| | | /// <param name="agvtask"></param> |
| | | public static void CreatePartQueue(dt_agvtask agvtask, string type = "") |
| | | { |
| | | if (agvtask.agv_fromaddress.Contains("X")) |
| | | { |
| | | dt_agvtask taskPart = new dt_agvtask() |
| | | { |
| | | agv_fromaddress = "", |
| | | agv_id = Guid.NewGuid(), |
| | | agv_tasknum = agvtask.agv_tasknum + "_1", |
| | | agv_grade = 2, |
| | | agv_createtime = DateTime.Now, |
| | | agv_taskstate = "Queue", |
| | | agv_qty = 1, |
| | | agv_tasktype = "TaskType_EmptyPallet", |
| | | agv_toaddress = agvtask.agv_fromaddress, |
| | | agv_userid = "ç³»ç»", |
| | | agv_TrayStatus = agvtask.agv_TrayStatus, |
| | | agv_Traytype = type |
| | | }; |
| | | freeDB.Add(taskPart); |
| | | } |
| | | } |
| | | } |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | using System; |
| | | using System.Collections.Generic; |
| | | using System.Linq; |
| | | using System.Text; |
| | | using System.Threading.Tasks; |
| | | using WIDESEA_Comm; |
| | | using WIDESEA_Core.FreeDB; |
| | | using WIDESEA_Entity.DomainModels; |
| | | |
| | | namespace WIDESEA_WCS.JobsPart.Common |
| | | { |
| | | public class RestockHCJ |
| | | { |
| | | static FreeDB freeDB = new FreeDB(); |
| | | public static Dictionary<string, List<string>> areaForList; |
| | | public RestockHCJ() |
| | | { |
| | | if (areaForList == null || areaForList.Count == 0) |
| | | { |
| | | areaForList = new Dictionary<string, List<string>>(); |
| | | var stationList = freeDB.Select<dt_stationinfo>().Where(x => true).ToList(); |
| | | areaForList.Add("䏿åº", stationList.Where(x => x.stationCode.Contains("X")).Select(x => x.stationCode).ToList()); |
| | | } |
| | | } |
| | | /// <summary> |
| | | /// æ´æ°è¡¥ç©ºæä»»å¡ |
| | | /// </summary> |
| | | public static void HCJGetBarcode() |
| | | { |
| | | var tasks = freeDB.Select<dt_agvtask>().Where(x => x.agv_taskstate == "Queue").ToList(); |
| | | foreach (var task in tasks) |
| | | { |
| | | if (task.agv_tasktype == "TaskType_EmptyPallet")//空æä»»å¡ |
| | | { |
| | | if (task.agv_fromaddress == "") |
| | | { |
| | | var area = task.agv_Traytype == "SmallTray" ? "11" : "10"; |
| | | //æ¾1åºåºç空æä½ |
| | | var EmptyStation = freeDB.Select<dt_stationinfo>().Where(x => x.area == area && x.stationCode.Contains("A") && x.location_state == LocationStateEnum.Stroge.ToString() && x.enable) |
| | | .OrderByDescending(x => x.column).OrderBy(x => x.line).First(); |
| | | if (EmptyStation == null) |
| | | EmptyStation = freeDB.Select<dt_stationinfo>().Where(x => x.area == area && x.stationCode.Contains("C") && x.location_state == LocationStateEnum.Stroge.ToString() && x.enable) |
| | | .OrderBy(x => x.line).OrderByDescending(x => x.column).First(); |
| | | if (EmptyStation != null) |
| | | { |
| | | task.agv_fromaddress = EmptyStation.stationCode; |
| | | task.agv_taskstate = "Create"; |
| | | freeDB.Update(task); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | Idt_stationinfoRepository stationinfoRepository = new dt_stationinfoRepository(context); |
| | | Idt_WorkinfoRepository workinfoRepository = new dt_WorkinfoRepository(context); |
| | | |
| | | List<dt_stationinfo> stationinfos = stationinfoRepository.Find(x => x.stationCode.Contains('X')); |
| | | List<dt_stationinfo> stationinfos = freeDB.Select<dt_stationinfo>().Where(x => x.stationCode.Contains("X") && x.quantity > 0 && !string.IsNullOrEmpty(x.stationType)).ToList(); |
| | | |
| | | foreach (var item in stationinfos) |
| | | { |
| | |
| | | bindSN = item.bindSN, |
| | | agv_worktype = Convert.ToInt32(mesinfo.processCode), |
| | | agv_materbarcode = mesinfo.materialCode, |
| | | agv_barcode=item.tray_type |
| | | agv_Traytype = item.tray_type, |
| | | agv_TrayStatus = item.tray_status |
| | | }; |
| | | |
| | | freeDB.Add(agvtask); |
| | |
| | | bindSN = item.bindSN, |
| | | agv_worktype = Convert.ToInt32(mesinfo.processCode), |
| | | agv_materbarcode = mesinfo.materialCode, |
| | | agv_barcode=item.tray_type |
| | | agv_Traytype = item.tray_type, |
| | | agv_TrayStatus = item.tray_status |
| | | }; |
| | | |
| | | freeDB.Add(agvtask); |
| | |
| | | { |
| | | if (cooRes.Status) |
| | | { |
| | | WriteDBLog.Success($"å¼å¯æå¡", new { æ°æ® = "æå¡å¯å¨æåï¼" }, "PCS", UserContext.Current.UserTrueName); |
| | | WriteDBLog.Success($"å¼å¯æå¡", new { æ°æ® = "æå¡å¯å¨æåï¼" }, "PCS", UserContext.Current.UserName); |
| | | return webResponse.OK("æå¡å¯å¨æåï¼"); |
| | | } |
| | | else |
| | | { |
| | | //è¿åPLCå¼å¸¸ |
| | | WriteDBLog.Error($"å¼å¯æå¡", new { æ°æ® = cooRes }, "PCS", UserContext.Current.UserTrueName); |
| | | WriteDBLog.Error($"å¼å¯æå¡", new { æ°æ® = cooRes }, "PCS", UserContext.Current.UserName); |
| | | return cooRes; |
| | | } |
| | | } |
| | |
| | | { |
| | | //è°åº¦å¯å¨å¤±è´¥ï¼å
³éå
¨é¨ |
| | | //WriteLog.Write_Log("æå¡", "æå¡", "å¯å¨æå¡\n[è°åº¦å¼å¸¸]" + startRes.Message); |
| | | WriteDBLog.Error($"å¼å¯æå¡", new { æ°æ® = startRes.Message }, "PCS", UserContext.Current.UserTrueName); |
| | | WriteDBLog.Error($"å¼å¯æå¡", new { æ°æ® = startRes.Message }, "PCS", UserContext.Current.UserName); |
| | | return startRes; |
| | | } |
| | | } |
| | |
| | | else if (typeof(DataType) == typeof(string))//å符串 |
| | | { |
| | | var str = GetContent(siemensPLCClient.ReadString(item.dbAddress, (ushort)item.dataLen), item).ToString(); |
| | | str = str.Replace("\0", "")?.Replace("\\", "")?.Replace("\u0014", "")?.Replace("?\u0006", ""); |
| | | str = str.Replace("\0", "")?.Replace("\\", "")?.Replace("\u0014", "")?.Replace("?\u0006", "")?.Replace("\n","")?.Trim(); |
| | | return (DataType)(str as object); |
| | | } |
| | | else |
| | |
| | | }, |
| | | //================è·¨åè¯·æ± (CORS)é
ç½®(2019-12-20æ°å¢)ï¼ |
| | | //================.netcore3.1å¿
é¡»é
ç½®æ¤å±æ§,å¤ä¸ªurlç¨è±å·éå¼,url为vueç«ç¹çå°åï¼å¯ä»¥å°åå¸åçå°åä¹åæ¶é
ç½®ä¸ |
| | | "CorsUrls": "http://localhost:8081,http://localhost:8080,http://localhost:7080,http://localhost:9980,http://127.0.0.1:9980,http://localhost:9990,http://www.volcore.xyz", |
| | | "CorsUrls": "http://localhost:8081,http://localhost:8080,http://localhost:7080,http://localhost:9980,http://127.0.0.1:9980,http://192.168.12.101:8099,http://localhost:9990,http://www.volcore.xyz", |
| | | "ExpMinutes": "120", //JWTæææ(åé=é»è®¤120), |
| | | "CreateMember": { //对表æå
¥æ°æ®æ¶ï¼éè¦è®°å½å建人/å建æ¶é´/åå»ºæ¥æ,é
ç½®UserIdField/UserNameField/DateFieldåå«ä¸ºå¯¹åºæ°æ®åºçå建人CreateID,å建人Creator,å建æ¶é´CreateDateåæ®µ(æ°å»ºæ°æ®æ¶,ç±æ¡æ¶é»è®¤å®æç»è¿å ä¸ªåæ®µèµå¼,åæ®µåºå大å°å)æå¯æå¨è°ç¨T.SetCreateDefaultVal()å®æè®¾ç½®å建人/å建æ¶é´/åå»ºæ¥æ |
| | | //å¦æè¡¨ç䏻鮿¯GUIDï¼ç颿¥è¯¢æ¶é»è®¤ä¼ç¨å°DateField对åºçå®ä½(æ°æ®åº)åæ®µè¿è¡æåº |
| | |
| | | axios.defaults.baseURL = 'http://127.0.0.1:8098/'; |
| | | } |
| | | else if (process.env.NODE_ENV == 'debug') { |
| | | axios.defaults.baseURL = 'http://127.0.0.1:8098/'; |
| | | axios.defaults.baseURL = 'http://192.168.12.101:8098/'; |
| | | } |
| | | |
| | | else if (process.env.NODE_ENV == 'production') { |
| | | axios.defaults.baseURL = 'http://127.0.0.1:8098/'; |
| | | axios.defaults.baseURL = 'http://192.168.12.101:8098/'; |
| | | } |
| | | if (!axios.defaults.baseURL.endsWith('/')) { |
| | | axios.defaults.baseURL+="/"; |
| | |
| | | {field:'stationCode',title:'ç¼åæ¶ç¼å·',type:'string',width:110,align:'left',sort:true}, |
| | | {field:'stationType',title:'å¾å·',type:'string',bind:{ key:'materielinfos',data:[]},width:110,align:'left'}, |
| | | {field:'area',title:'åºå',type:'string',bind:{ key:'area_name',data:[]},width:110,require:true,align:'left'}, |
| | | {field:'enable',title:'æ¯å¦å¯ç¨',type:'bool',bind:{ key:'status',data:[]},width:110,require:true,align:'left'}, |
| | | {field:'location_state',title:'è´§ä½ç¶æ',type:'string',bind:{ key:'location_states',data:[]},width:220,align:'left'}, |
| | | {field:'enable',title:'æ¯å¦å¯ç¨',type:'bool',bind:{ key:'status',data:[]},width:80,require:true,align:'left'}, |
| | | {field:'location_state',title:'è´§ä½ç¶æ',type:'string',bind:{ key:'location_states',data:[]},width:80,align:'left'}, |
| | | // {field:'lastUpdateTime',title:'æåç¶ææ¹åæ¶é´',type:'datetime',width:150,align:'left',sort:true}, |
| | | {field:'quantity',title:'车轮æ°é',type:'int',width:80,align:'left'}, |
| | | {field:'bindSN',title:'车轮SNå·',type:'string',width:220,align:'left'}, |
| | | {field:'tray_status',title:'æçç¶æ',type:'string',bind:{ key:'tray_status',data:[]},width:110,align:'left'}, |
| | | {field:'tray_type',title:'æçç±»å',type:'string',bind:{ key:'tray_types',data:[]},width:110,align:'left'}, |
| | | {field:'tray_status',title:'æçç¶æ',type:'string',bind:{ key:'tray_status',data:[]},width:80,align:'left'}, |
| | | {field:'tray_type',title:'æçç±»å',type:'string',bind:{ key:'tray_types',data:[]},width:120,align:'left'}, |
| | | // {field:'line',title:'è¡',type:'int',width:80,align:'left'}, |
| | | // {field:'column',title:'å',type:'int',width:80,align:'left'}, |
| | | {field:'heatNumber',title:'çå·',type:'int',width:80,align:'left'}, |
| | | // {field:'zj',title:'主é®',type:'int',width:80,hidden:true,require:true,align:'left'}, |
| | | {field:'Number',title:'å·¥åç¼å·',type:'string',width:220,align:'left'}, |
| | | {field:'remark',title:'夿³¨',type:'string',width:120,align:'left'}]); |
| | | {field:'remark',title:'夿³¨',type:'string',width:220,align:'left'}]); |
| | | const detail = ref({ |
| | | cnName: "#detailCnName", |
| | | table: "#detailTable", |
| | |
| | | /// <summary> |
| | | ///AGVç¼å· |
| | | /// </summary> |
| | | [Display(Name = "AGVç¼å·")] |
| | | //[Display(Name = "AGVç¼å·")] |
| | | //[MaxLength(50)] |
| | | //[Column(TypeName = "nvarchar(50)")] |
| | | //[Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)] |
| | | //public string agv_code { get; set; } |
| | | /// <summary> |
| | | ///æçç¶æ |
| | | /// </summary> |
| | | [Display(Name = "æçç¶æ")] |
| | | [MaxLength(50)] |
| | | [Column(TypeName = "nvarchar(50)")] |
| | | [Editable(true)] |
| | | [Required(AllowEmptyStrings = false)] |
| | | public string agv_code { get; set; } |
| | | //[Required(AllowEmptyStrings = false)] |
| | | public string agv_TrayStatus { get; set; } |
| | | |
| | | /// <summary> |
| | | ///ä»»å¡ç¶æ |
| | |
| | | public string agv_userid { get; set; } |
| | | |
| | | /// <summary> |
| | | ///æçç |
| | | ///æçç±»å/æçç |
| | | /// </summary> |
| | | [Display(Name = "æçç ")] |
| | | [MaxLength(30)] |
| | | [Column(TypeName = "nvarchar(30)")] |
| | | [Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)]//ä¸è½ä¸ºç©º |
| | | public string agv_barcode { get; set; } |
| | | public string agv_Traytype { get; set; } |
| | | |
| | | /// <summary> |
| | | ///ç©æç |
| | |
| | | public string agv_userid { get; set; } |
| | | |
| | | /// <summary> |
| | | ///æçç |
| | | ///æçç±»å/æçç |
| | | /// </summary> |
| | | [Display(Name = "æçç ")] |
| | | [MaxLength(30)] |
| | | [Column(TypeName = "nvarchar(30)")] |
| | | [Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)] |
| | | public string agv_barcode { get; set; } |
| | | public string agv_Traytype { get; set; } |
| | | |
| | | /// <summary> |
| | | ///AGVç¼å· |
| | | /// </summary> |
| | | [Display(Name = "AGVç¼å·")] |
| | | //[Display(Name = "AGVç¼å·")] |
| | | //[MaxLength(50)] |
| | | //[Column(TypeName = "nvarchar(50)")] |
| | | //[Editable(true)] |
| | | ////[Required(AllowEmptyStrings = false)] |
| | | //public string agv_code { get; set; } |
| | | /// <summary> |
| | | ///æçç¶æ |
| | | /// </summary> |
| | | [Display(Name = "æçç¶æ")] |
| | | [MaxLength(50)] |
| | | [Column(TypeName = "nvarchar(50)")] |
| | | [Editable(true)] |
| | | //[Required(AllowEmptyStrings = false)] |
| | | public string agv_code { get; set; } |
| | | public string agv_TrayStatus { get; set; } |
| | | |
| | | /// <summary> |
| | | ///å·¥åç±»å |
| | |
| | | requestTask.Material = agv_task.agv_materielid; |
| | | requestTask.Grade = agv_task.agv_grade; |
| | | requestTask.Quantity = agv_task.agv_qty; |
| | | requestTask.TrayType = agv_task.agv_barcode.Contains("Small") ? 1 : 2;// |
| | | requestTask.TrayType = agv_task.agv_Traytype.Contains("Small") ? 1 : 2;// |
| | | requestTask.TaskType = agv_task.agv_tasktype.Contains("TaskType_EmptyPallet") ? 2 : 1;// |
| | | requestTask.A = Materiel.a; |
| | | requestTask.B = Materiel.b; |
| | |
| | | agv_completedate = DateTime.Now, |
| | | agv_grade = task.agv_grade, |
| | | agv_userid = task.agv_userid, |
| | | agv_barcode = task.agv_barcode, |
| | | agv_code = task.agv_code, |
| | | agv_Traytype = task.agv_Traytype, |
| | | agv_TrayStatus = task.agv_TrayStatus, |
| | | agv_worktype = task.agv_worktype, |
| | | agv_remark = task.agv_remark, |
| | | bindSN = task.bindSN, |
| | |
| | | agvtask.agv_fromaddress = fromaddress; |
| | | agvtask.agv_toaddress = toaddress; |
| | | agvtask.agv_tasknum = IdenxManager.GetTaskNo("KH-"); |
| | | agvtask.agv_code = "AGV"; |
| | | agvtask.agv_TrayStatus = station1.tray_status; |
| | | agvtask.agv_Traytype = station1.tray_type; |
| | | agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString(); |
| | | agvtask.agv_tasktype = tasktype; |
| | | agvtask.agv_worktype = worktype;//å·¥ä½ç±»å |
| | |
| | | }, |
| | | //================è·¨åè¯·æ± (CORS)é
ç½®(2019-12-20æ°å¢)ï¼ |
| | | //================.netcore3.1å¿
é¡»é
ç½®æ¤å±æ§,å¤ä¸ªurlç¨è±å·éå¼,url为vueç«ç¹çå°åï¼å¯ä»¥å°åå¸åçå°åä¹åæ¶é
ç½®ä¸ |
| | | "CorsUrls": "http://localhost:8081,http://localhost:8080,http://localhost:7080,http://localhost:9980,http://127.0.0.1:9980,http://localhost:9990,http://www.volcore.xyz", |
| | | "CorsUrls": "http://localhost:8081,http://localhost:8080,http://localhost:7080,http://localhost:9980,http://192.168.12.101:8081,http://127.0.0.1:9980,http://localhost:9990,http://www.volcore.xyz", |
| | | "ExpMinutes": "120", //JWTæææ(åé=é»è®¤120), |
| | | "CreateMember": { //对表æå
¥æ°æ®æ¶ï¼éè¦è®°å½å建人/å建æ¶é´/åå»ºæ¥æ,é
ç½®UserIdField/UserNameField/DateFieldåå«ä¸ºå¯¹åºæ°æ®åºçå建人CreateID,å建人Creator,å建æ¶é´CreateDateåæ®µ(æ°å»ºæ°æ®æ¶,ç±æ¡æ¶é»è®¤å®æç»è¿å ä¸ªåæ®µèµå¼,åæ®µåºå大å°å)æå¯æå¨è°ç¨T.SetCreateDefaultVal()å®æè®¾ç½®å建人/å建æ¶é´/åå»ºæ¥æ |
| | | //å¦æè¡¨ç䏻鮿¯GUIDï¼ç颿¥è¯¢æ¶é»è®¤ä¼ç¨å°DateField对åºçå®ä½(æ°æ®åº)åæ®µè¿è¡æåº |
¶Ô±ÈÐÂÎļþ |
| | |
| | | -- åå¨è¿ç¨ |
| | | CREATE PROCEDURE DeleteOldRecords |
| | | @MonthsAgo INT |
| | | AS |
| | | BEGIN |
| | | DECLARE @CutOffDate DATE = DATEADD(MONTH, -@MonthsAgo, GETDATE()); |
| | | |
| | | DELETE FROM dt_log_pcs |
| | | WHERE [createtime ] < @CutOffDate; |
| | | END |
| | | GO |
¶Ô±ÈÐÂÎļþ |
| | |
| | | -- å é¤6个æä¹åçPCSç³»ç»æ¥å¿æ°æ® |
| | | DECLARE @MonthsAgo INT = 6; |
| | | DECLARE @CurrentDate DATE = GETDATE(); |
| | | DECLARE @CutOffDate DATE = DATEADD(MONTH, -@MonthsAgo, @CurrentDate); |
| | | |
| | | -- å é¤æä½ |
| | | DELETE FROM dt_log_pcs |
| | | WHERE [createtime ] < @CutOffDate; |
¶Ô±ÈÐÂÎļþ |
| | |
| | | -- å建å é¤çåå¨è¿ç¨ |
| | | |
| | | CREATE PROCEDURE DeleteInterfacerecord --åå¨è¿ç¨åç§° |
| | | @MonthsAgo INT --åå¨è¿ç¨åæ° |
| | | AS |
| | | BEGIN |
| | | DECLARE @CutOffDate DATE = DATEADD(MONTH, -@MonthsAgo, GETDATE()); --声æåæ° |
| | | |
| | | DELETE FROM dt_Interfacerecord --æ°æ®åºè¡¨å |
| | | WHERE interface_createtime < @CutOffDate; --夿æ¡ä»¶çåå |
| | | END |
| | | GO |
| | | -- å建添å çåå¨è¿ç¨ |
| | | CREATE PROCEDURE Add_inventory |
| | | @SN NVARCHAR(255), |
| | | @Name NVARCHAR(255), |
| | | @FigureNumber NVARCHAR(255), |
| | | @area NVARCHAR(15), |
| | | @HeatNumber NVARCHAR(50), |
| | | @BilletNumber INT, |
| | | @OnlineTime datetime, |
| | | @Operator NVARCHAR(50), |
| | | @stationCode NVARCHAR(30), |
| | | @jobID NVARCHAR(255), |
| | | @ID uniqueidentifier, |
| | | @remark NVARCHAR(max) |
| | | AS |
| | | BEGIN |
| | | INSERT INTO dt_inventory (SN, Name,FigureNumber,area,HeatNumber,BilletNumber,OnlineTime,Operator,remark,stationCode,jobID,ID) |
| | | VALUES (@SN, @Name,@FigureNumber,@area,@HeatNumber,@BilletNumber,@OnlineTime,@Operator,@remark,@stationCode,@jobID,@ID) |
| | | |
| | | -- è¿åæ°æå
¥çç¨æ·ID |
| | | --SELECT SCOPE_IDENTITY() AS NewUserID; |
| | | END |
| | | GO |
| | | |
| | | -- å é¤å为 YourProcedureName çåå¨è¿ç¨ |
| | | --IF EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[Add_inventory]') AND type in (N'P', N'PC')) |
| | | --DROP PROCEDURE [dbo].Add_inventory; |
| | | |
| | | -- æ¥è¯¢ææåå¨è¿ç¨ |
| | | --SELECT * FROM information_schema.Routines WHERE ROUTINE_TYPE = 'PROCEDURE'; |
| | | |
| | | --æ§è¡ä¸éè¦åæ°çåå¨è¿ç¨ |
| | | --EXEC DeleteInterfacerecord |
| | | |
| | | --æ§è¡å¸¦åæ°çåå¨è¿ç¨ |
| | | --EXEC DeleteInterfacerecord @MonthsAgo = 6 |
| | | |
| | | --使ç¨sp_executesqlåå¨è¿ç¨ï¼è¿ç§æ¹æ³å¯ä»¥æä¾é¢å¤ç忰声æåç±»åæ£æ¥ï¼ |
| | | --DECLARE @Param1 NVARCHAR(100) = 'Value1', @Param2 INT = 123 |
| | | --EXEC sp_executesql |
| | | -- N'EXEC YourProcedureName @Param1, @Param2', |
| | | -- N'@Param1 NVARCHAR(100), @Param2 INT', |
| | | -- @Param1, @Param2 |
| | | |
| | | --ç´æ¥å¨åºç¨ç¨åºä»£ç ä¸è°ç¨åå¨è¿ç¨ï¼ä¾å¦å¨C#ä¸ä½¿ç¨ADO.NETï¼ |
| | | --using (SqlConnection conn = new SqlConnection(connectionString)) |
| | | --{ |
| | | -- SqlCommand cmd = new SqlCommand("YourProcedureName", conn); |
| | | -- cmd.CommandType = CommandType.StoredProcedure; |
| | | -- cmd.Parameters.AddWithValue("@Param1", "Value1"); |
| | | -- cmd.Parameters.AddWithValue("@Param2", 123); |
| | | -- conn.Open(); |
| | | -- cmd.ExecuteNonQuery(); |
| | | --} |