CC/iWareCC_ASRS/ThreadService/00_269¹¤Î»/DataProcess_269.cs
@@ -75,5 +75,6 @@ } } } } CC/iWareCC_ASRS/ThreadService/04_BZ21£¨°áÔËÕû¶â»úÆ÷ÈË£©/DataProcess_BZ21.cs
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,59 @@ using iWareCommon.Utils; using iWareSql.WmsDBModel; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace iWareCC.ThreadService._04_BZ21_æ¬è¿æ´åæºå¨äºº_ { public class DataProcess_BZ21 { public static void PushPackageCode() { while (true) { Thread.Sleep(2000); using (WmsDBModel edm = new WmsDBModel()) { var value = edm.mes_PushPackageCode.Where(x => x.PushStatus == 0 || x.PushStatus == 1).FirstOrDefault(); if (value != null) { PushPackageCodeInput input = new PushPackageCodeInput(); input.PackageCode = value.PackageCode; var res = HttpHelper.GetHttpResponse<PushPackageCodeInput, Respone>(" ", input, 10000); } } } } public class PushPackageCodeInput { public string PackageCode { get; set; } } public class Respone { /// <summary> /// è¿åç /// </summary> public string code { get; set; } /// <summary> /// è¿åæ¶æ¯ /// </summary> public string message { get; set; } /// <summary> /// 请æ±ç¼å· /// </summary> public string reqCode { get; set; } /// <summary> /// èªå®ä¹è¿åï¼è¿åä»»å¡åå·ï¼ /// </summary> public string data { get; set; } } } } CC/iWareCC_ASRS/iWareCC.csproj
@@ -161,6 +161,7 @@ <Compile Include="ThreadService\02_BZ39å·¥ä½ï¼è¡¥æ¿åå·¥ä½ï¼\Outbound\3ãDataProcess_RobotBuffer_FinishTaskForOutbound.cs" /> <Compile Include="ThreadService\02_BZ39å·¥ä½ï¼è¡¥æ¿åå·¥ä½ï¼\Inbound\2ãDataProcess_RobotBuffer_FinishTask.cs" /> <Compile Include="ThreadService\02_BZ39å·¥ä½ï¼è¡¥æ¿åå·¥ä½ï¼\Inbound\1ãDataProcess_BZ39.cs" /> <Compile Include="ThreadService\04_BZ21ï¼æ¬è¿æ´åæºå¨äººï¼\DataProcess_BZ21.cs" /> <Compile Include="WCF\CCWcfService.cs" /> <Compile Include="WCF\ICCWcfService.cs" /> <Compile Include="WmsTask\AutoUpdateEngineInfoTask.cs" /> @@ -354,7 +355,6 @@ </ItemGroup> <ItemGroup> <Folder Include="ThreadService\03_BZ12%28æºå¨äººç å å·¥ä½%29\" /> <Folder Include="ThreadService\04_BZ21ï¼æ¬è¿æ´åæºå¨äººï¼\" /> </ItemGroup> <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" /> </Project> CC/iWareCommon/Utils/HTTP/HttpHelper.cs
@@ -75,34 +75,30 @@ /// <param name="url">请æ±å°å</param> /// <param name="postData">请æ±åæ°</param> /// <param name="timeout">å»¶è¿æ¶é´</param> /// <param name="method">POST GET PUT DELETE</param> /// <returns>请æ±çresponse</returns> public static string GetHttpResponse(string url, object postData, int timeout,string method) public static T2 GetHttpResponse<T, T2>(string url, T postData, int timeout) { HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); request.Method = method; request.Method = "POST"; request.ContentType = "application/json;charset=UTF-8"; request.UserAgent = null; request.Timeout = timeout; if (!"GET".Equals(method)) { //request.Headers.Add("Authorization", "eyJhbGciOiJIUzM4NCIsInR5cCI6IkpXVCJ9.eyJpYXQiOiIxNTUzNTMwNjAwIiwiZXhwIjoiMTYxNjYwMjYwMCIsImlzcyI6IlNBR1dXSVAiLCJzdWIiOiJ3Y3NpbnRlZ3JhdGVkIiwidXNlcm5hbWUiOiJ3Y3NpbnRlZ3JhdGVkIiwidXNlcmdyb3VwIjpbeyJsb2dpbm5hbWUiOiJ3Y3NpbnRlZ3JhdGVkIiwiZ3JvdXBJZCI6Ijg3YjE1MTQ1LWUwODMtNDM2Ny04ZjdiLTNiNTI3NWJhYzExZSIsImdyb3VwbmFtZSI6IlJDU2ludGVncmF0ZWQiLCJyb2xlSWQiOiI4NjNhMGIxZS0zODAzLTQyNmMtOTRlNC04OTRmNTE1ZWQyYzgiLCJyb2xlbmFtZSI6IlJDU-mbhuaIkCJ9LHsibG9naW5uYW1lIjoid2NzaW50ZWdyYXRlZCIsImdyb3VwSWQiOiI5ZGU3ZjA5Zi05YzhiLTQwNDEtODc0NS1hYjgxNGQ0OTFiODEiLCJncm91cG5hbWUiOiJXQ1NpbnRlZ3JhdGVkIiwicm9sZUlkIjoiNWJhZDE1YTUtOTQ1NC00YTc3LTk0OGYtNzUxMjI2NDdiOTA4Iiwicm9sZW5hbWUiOiJXQ1Ppm4bmiJAifV19.AN9iUPMFZ5w7UW7D5kERV903gPCtyk6o2STZILX7QzkVjKLLSWgpUnQYBBfiSSQk"); var myRequestStream = request.GetRequestStream(); var json = postData == null ? "" : JsonConvert.SerializeObject(postData); var jsonBytes = UTF8Encoding.UTF8.GetBytes(json); myRequestStream.Write(jsonBytes, 0, jsonBytes.Length); } HttpWebResponse response = (HttpWebResponse)request.GetResponse(); Stream myResponseStream = response.GetResponseStream(); StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8")); string retString = myStreamReader.ReadToEnd(); myStreamReader.Close(); myResponseStream.Close(); return retString; T2 result = JsonConvert.DeserializeObject<T2>(retString); return result; } /// <summary> /// Httpä¸ä¼ æä»¶ /// </summary> CC/iWareSql/WmsDBModel/WmsDBModel.cs
@@ -11,7 +11,7 @@ : base("name=WmsDBModel") { } public virtual DbSet<mes_PushPackageCode> mes_PushPackageCode { get; set; } public virtual DbSet<ApprovalFlow> ApprovalFlow { get; set; } public virtual DbSet<DingTalkUser> DingTalkUser { get; set; } public virtual DbSet<GoViewPro> GoViewPro { get; set; } CC/iWareSql/WmsDBModel/mes_PushPackageCode.cs
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,46 @@ namespace iWareSql.WmsDBModel { using System; using System.Collections.Generic; using System.ComponentModel.DataAnnotations; using System.ComponentModel.DataAnnotations.Schema; using System.Data.Entity.Spatial; public partial class mes_PushPackageCode { [DatabaseGenerated(DatabaseGeneratedOption.None)] public long Id { get; set; } [Required] [StringLength(50)] public string PackageCode { get; set; } public int PushStatus { get; set; } public int PushNum { get; set; } [StringLength(50)] public string ApiMessage { get; set; } public DateTime? CreateTime { get; set; } public DateTime? UpdateTime { get; set; } public long? CreateUserId { get; set; } [StringLength(64)] public string CreateUserName { get; set; } public long? UpdateUserId { get; set; } [StringLength(64)] public string UpdateUserName { get; set; } public long? CreateOrgId { get; set; } [StringLength(64)] public string CreateOrgName { get; set; } public bool IsDelete { get; set; } } } CC/iWareSql/iWareSql.csproj
@@ -162,6 +162,7 @@ <Compile Include="WmsDBModel\GoViewPro.cs" /> <Compile Include="WmsDBModel\GoViewProData.cs" /> <Compile Include="WmsDBModel\mes_batchOrderUPI_new.cs" /> <Compile Include="WmsDBModel\mes_PushPackageCode.cs" /> <Compile Include="WmsDBModel\SysCodeGen.cs" /> <Compile Include="WmsDBModel\SysCodeGenConfig.cs" /> <Compile Include="WmsDBModel\SysConfig.cs" /> LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Entity/WmsOrder/Mes_BatchOrderUPI.cs
@@ -135,5 +135,82 @@ [SugarColumn(ColumnName = "Info3", ColumnDescription = "纸箱é«", Length = 50)] public float? Info3 { get; set; } /// <summary> /// éå®åååå· /// </summary> [SugarColumn(ColumnName = "Info4", ColumnDescription = "éå®åååå·", Length = 60)] public string? Info4 { get; set; } /// <summary> /// ç产åå· /// </summary> [SugarColumn(ColumnName = "Info5", ColumnDescription = "ç产åå·", Length = 60)] public string? Info5 { get; set; } /// <summary> /// 第å å /// </summary> [SugarColumn(ColumnName = "Info6", ColumnDescription = "第å å ", Length = 60)] public string? Info6 { get; set; } /// <summary> /// ç»éåºåç§° /// </summary> [SugarColumn(ColumnName = "Info7", ColumnDescription = "ç»éåºåç§°", Length = 60)] public string? Info7 { get; set; } /// <summary> /// 产ååç§° /// </summary> [SugarColumn(ColumnName = "Info8", ColumnDescription = "产ååç§°", Length = 60)] public string? Info8 { get; set; } /// <summary> /// 客æ·åç§° /// </summary> [SugarColumn(ColumnName = "Info10", ColumnDescription = "客æ·åç§°", Length = 60)] public string? Info10 { get; set; } /// <summary> /// å è£ ç¼ç /// </summary> [SugarColumn(ColumnName = "Info9", ColumnDescription = "å è£ ç¼ç ", Length = 60)] public string? Info9 { get; set; } /// <summary> /// èªæoråè´§ /// </summary> [SugarColumn(ColumnName = "Info11", ColumnDescription = "èªæoråè´§", Length = 60)] public string? Info11 { get; set; } /// <summary> /// å è£ é¨ä»¶æ»æ°é /// </summary> [SugarColumn(ColumnName = "Info12", ColumnDescription = "å è£ é¨ä»¶æ»æ°é", Length = 60)] public string? Info12 { get; set; } /// <summary> /// å è£ é¢ç§¯ /// </summary> [SugarColumn(ColumnName = "Info13", ColumnDescription = "å è£ é¢ç§¯", Length = 60)] public string? Info13 { get; set; } /// <summary> /// é¨ä»¶åç§° /// </summary> [SugarColumn(ColumnName = "Info14", ColumnDescription = "é¨ä»¶åç§°", Length = 60)] public string? Info14 { get; set; } /// <summary> /// é¨ä»¶æ°é /// </summary> [SugarColumn(ColumnName = "Info15", ColumnDescription = "é¨ä»¶æ°é")] public int? Info15 { get; set; } /// <summary> /// é¨ä»¶å°ºå¯¸ /// </summary> [SugarColumn(ColumnName = "Info16", ColumnDescription = "é¨ä»¶å°ºå¯¸", Length = 60)] public string? Info16 { get; set; } } } LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Enum/WmsOrder/PushStatusEnum.cs
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,33 @@ using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace Admin.NET.Core.Enum; public enum PushStatusEnum { /// <summary> /// æªæ¨é /// </summary> [Description("æªæ¨é")] NotPush = 0, /// <summary> /// æ¨éä¸ /// </summary> [Description("æ¨éä¸")] Pushing = 1, /// <summary> /// æ¨éæå /// </summary> [Description("æ¨éæå")] PushSuccess = 2, /// <summary> /// æ¨é失败 /// </summary> [Description("æ¨é失败")] PushFail = 3, } LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Service/WmsOrder/MesPushPackageCode/Dto/MesPushPackageCodeInput.cs
@@ -170,3 +170,7 @@ { } public class PushPackageCodeInput { public string PackageCode { get; set; } } LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Service/WmsOrder/MesPushPackageCode/Dto/MesPushPackageCodeOutput.cs
@@ -76,5 +76,12 @@ public bool IsDelete { get; set; } } public class Respone { public int iState; public string message; public object result; } LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Service/WmsOrder/MesPushPackageCode/MesPushPackageCodeService.cs
@@ -4,6 +4,11 @@ using System.Data; using System.Web; using System.Text; using Furion.DatabaseAccessor; using Admin.NET.Core.Enum; using Furion.RemoteRequest.Extensions; using StackExchange.Profiling.Internal; namespace Admin.NET.Application; /// <summary> /// æ¨émeså è£ å·æå¡ @@ -111,7 +116,36 @@ } [HttpPost] [ApiDescriptionSettings(Name = "PushPackageCode")] [UnitOfWork] [AllowAnonymous] public async Task PushPackageCode(PushPackageCodeInput input) { var value = await _rep.AsQueryable().Where(x => x.PackageCode == input.PackageCode).FirstAsync(); if (value == null) throw Oops.Oh("å è£ å·ä¸åå¨"); if (value.PushStatus != (int)PushStatusEnum.NotPush || value.PushStatus != (int)PushStatusEnum.Pushing) throw Oops.Oh("é夿¨é"); string url = "http://localhost:8088/api/getwmstask/getwmstask"; var respon = await url.SetHttpMethod(HttpMethod.Post).SetBody(input).PostAsStringAsync(); var data = respon.FromJson<Respone>(); if (data.iState == 1) { value.PushStatus = (int)PushStatusEnum.PushSuccess; value.ApiMessage = data.message; value.PushNum++; } else { value.PushStatus = (int)PushStatusEnum.Pushing; value.ApiMessage = data.message; value.PushNum++; if (value.PushNum == 3) { value.PushStatus = (int)PushStatusEnum.PushFail; } } await _rep.UpdateAsync(value); } #region å¯¼å ¥ LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Service/WmsOrder/Mes_BatchOrderUPI_New/Dto/Mes_BatchOrderUPI_NewInput.cs
@@ -391,3 +391,186 @@ { } public class GetBatchOrderUPIInput { [Required] [SugarColumn(ColumnName = "PlanNo", ColumnDescription = "æ¹æ¬¡å·", Length = 50)] public string PlanNo { get; set; } [Required] [SugarColumn(ColumnName = "OrderId", ColumnDescription = "订åå·", Length = 50)] public string OrderId { get; set; } [Required] [SugarColumn(ColumnName = "UPI", ColumnDescription = "é¨ä»¶æ¡ç ", Length = 50)] public string UPI { get; set; } [Required] [SugarColumn(ColumnName = "DetailName", ColumnDescription = "é¨ä»¶åç§°", Length = 50)] public string DetailName { get; set; } [SugarColumn(ColumnName = "Length", ColumnDescription = "é¿")] public float Length { get; set; } [SugarColumn(ColumnName = "Width", ColumnDescription = "宽")] public float Width { get; set; } [SugarColumn(ColumnName = "Thk", ColumnDescription = "å")] public float Thk { get; set; } [SugarColumn(ColumnName = "Matgrid", ColumnDescription = "é¨ä»¶çº¹ç", Length = 50)] public string? Matgrid { get; set; } [SugarColumn(ColumnName = "IsEB", ColumnDescription = "æ¯å¦å°è¾¹")] public int? IsEB { get; set; } /// <summary> /// æå设å¤ç¼å· ãEditBy shaocx,2022-05-28ã /// 0ï¼ä¸æå /// 1ï¼åé¢é» /// 2ï¼è±ªè¿å é¢é» /// 5ï¼åå ´å é¢é» /// </summary> [SugarColumn(ColumnName = "DRNum", ColumnDescription = "æå设å¤ç¼å·")] public int? DRNum { get; set; } [SugarColumn(ColumnName = "IsPA", ColumnDescription = "æ¯å¦ä¼åå è£ ")] public int? IsPA { get; set; } /// <summary> /// é¯åå¾å· /// </summary> [SugarColumn(ColumnName = "MaterialIndeX", ColumnDescription = "é¯åå¾å·")] public int? MaterialIndeX { get; set; } #region å è£ çº¿æå ³ [Required] [SugarColumn(ColumnName = "PackageCode", ColumnDescription = "å è£ å·", Length = 50)] public string PackageCode { get; set; } [Required] [SugarColumn(ColumnName = "MachineXCenter", ColumnDescription = "å è£ Xåæ ", Length = 50)] public float? MachineXCenter { get; set; } [Required] [SugarColumn(ColumnName = "MachineYCenter", ColumnDescription = "å è£ Yåæ ", Length = 50)] public float? MachineYCenter { get; set; } [Required] [SugarColumn(ColumnName = "MachineZCenter", ColumnDescription = "å è£ Zåæ ", Length = 50)] public float? MachineZCenter { get; set; } [Required] [SugarColumn(ColumnName = "Sequence", ColumnDescription = "屿°", Length = 50)] public int? Sequence { get; set; } [Required] [SugarColumn(ColumnName = "Shelf", ColumnDescription = "次åº", Length = 50)] public int? Shelf { get; set; } #endregion /// <summary> /// æ¯å¦è½¬å /// 0ï¼ä¸è½¬å /// 1ï¼è½¬å /// ç®ååªæåé¢é»æè½è½¬å /// </summary> [Required] [SugarColumn(ColumnName = "Rotation", ColumnDescription = "转åè§åº¦", Length = 50)] public float? Rotation { get; set; } [SugarColumn(ColumnName = "Info1", ColumnDescription = "纸箱é¿", Length = 50)] public float? Info1 { get; set; } [SugarColumn(ColumnName = "Info2", ColumnDescription = "纸箱宽", Length = 50)] public float? Info2 { get; set; } [SugarColumn(ColumnName = "Info3", ColumnDescription = "纸箱é«", Length = 50)] public float? Info3 { get; set; } /// <summary> /// éå®åååå· /// </summary> [SugarColumn(ColumnName = "Info4", ColumnDescription = "éå®åååå·", Length = 60)] public string? Info4 { get; set; } /// <summary> /// ç产åå· /// </summary> [SugarColumn(ColumnName = "Info5", ColumnDescription = "ç产åå·", Length = 60)] public string? Info5 { get; set; } /// <summary> /// 第å å /// </summary> [SugarColumn(ColumnName = "Info6", ColumnDescription = "第å å ", Length = 60)] public string? Info6 { get; set; } /// <summary> /// ç»éåºåç§° /// </summary> [SugarColumn(ColumnName = "Info7", ColumnDescription = "ç»éåºåç§°", Length = 60)] public string? Info7 { get; set; } /// <summary> /// 产ååç§° /// </summary> [SugarColumn(ColumnName = "Info8", ColumnDescription = "产ååç§°", Length = 60)] public string? Info8 { get; set; } /// <summary> /// 客æ·åç§° /// </summary> [SugarColumn(ColumnName = "Info10", ColumnDescription = "客æ·åç§°", Length = 60)] public string? Info10 { get; set; } /// <summary> /// å è£ ç¼ç /// </summary> [SugarColumn(ColumnName = "Info9", ColumnDescription = "å è£ ç¼ç ", Length = 60)] public string? Info9 { get; set; } /// <summary> /// èªæoråè´§ /// </summary> [SugarColumn(ColumnName = "Info11", ColumnDescription = "èªæoråè´§", Length = 60)] public string? Info11 { get; set; } /// <summary> /// å è£ é¨ä»¶æ»æ°é /// </summary> [SugarColumn(ColumnName = "Info12", ColumnDescription = "å è£ é¨ä»¶æ»æ°é", Length = 60)] public string? Info12 { get; set; } /// <summary> /// å è£ é¢ç§¯ /// </summary> [SugarColumn(ColumnName = "Info13", ColumnDescription = "å è£ é¢ç§¯", Length = 60)] public string? Info13 { get; set; } /// <summary> /// é¨ä»¶åç§° /// </summary> [SugarColumn(ColumnName = "Info14", ColumnDescription = "é¨ä»¶åç§°", Length = 60)] public string? Info14 { get; set; } /// <summary> /// é¨ä»¶æ°é /// </summary> [SugarColumn(ColumnName = "Info15", ColumnDescription = "é¨ä»¶æ°é")] public int? Info15 { get; set; } /// <summary> /// é¨ä»¶å°ºå¯¸ /// </summary> [SugarColumn(ColumnName = "Info16", ColumnDescription = "é¨ä»¶å°ºå¯¸", Length = 60)] public string? Info16 { get; set; } } LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Service/WmsOrder/Mes_BatchOrderUPI_New/Mes_BatchOrderUPI_NewService.cs
@@ -4,6 +4,9 @@ using System.Data; using System.Web; using System.Text; using Furion.DatabaseAccessor; using Mapster; namespace Admin.NET.Application; /// <summary> /// æ¹æ¬¡æ°æ®æå¡ @@ -110,7 +113,23 @@ return await _rep.GetFirstAsync(u => u.Id == input.Id); } [HttpPost] [ApiDescriptionSettings(Name = "GetBatchOrderUPIList")] [UnitOfWork] [AllowAnonymous] public async Task GetBatchOrderUPIList(List<GetBatchOrderUPIInput> input) { List<Mes_BatchOrderUPI_New> list = new List<Mes_BatchOrderUPI_New>(); foreach (var item in input) { Mes_BatchOrderUPI_New task = new Mes_BatchOrderUPI_New(); task = item.Adapt<Mes_BatchOrderUPI_New>(); task.AreaCode = AreaCodeEnum.æ åºå; task.UpiStatus = UpiStatusEnum.åå§; list.Add(task); } await _rep.InsertRangeAsync(list); }