using System; using System.Collections.Generic; using System.IO; using System.Security.Claims; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using Microsoft.Extensions.Options; using Model.InterFaceModel; using Newtonsoft.Json; using SqlSugar.Extensions; using Utility.Tools; using WMS.Entity.LogEntity; using WMS.IBLL.IBllAsnServer; using WMS.IBLL.IBllCheckServer; using WMS.IBLL.IBllSoServer; using WMS.IBLL.ILogServer; using WMS.IBLL.ISysServer; using WmsApi.Tools; namespace WmsApi.Controllers { /// <summary> /// 下游系统交互 /// </summary> [Route("api/[controller]/[action]")] [ApiController] public class DownApiController : ControllerBase { private readonly ApiUrlConfig _config; //接å£äº¤äº’路径 private readonly IExportNoticeServer _exNoticeSvc;//出库å•Svc private readonly IPalletBindServer _asnPalletBindSvc;//托盘绑定Svc private readonly IStockCheckServer _crCheckSvc;//托盘绑定Svc private readonly ITaskServer _taskSvc;//任务Svc private readonly IFunSettingServer _funSvc;//任务Svc public DownApiController(IOptions<ApiUrlConfig> setting, IExportNoticeServer exNoticeSvc, IPalletBindServer asnPalletBindSvc, IStockCheckServer crCheckSvc, ITaskServer taskSvc, IFunSettingServer funSvc) { _config = setting.Value; _exNoticeSvc = exNoticeSvc; _asnPalletBindSvc = asnPalletBindSvc; _crCheckSvc = crCheckSvc; _taskSvc = taskSvc; _funSvc = funSvc; } #region WMSæŽ¥å£ è°ƒç”¨ä¸‹æ¸¸ç³»ç»ŸæŽ¥å£ /// <summary> /// 指令下å‘(出库) /// </summary> /// <param name="soNo"></param> /// <returns></returns> [Authorize] [HttpGet] public IActionResult IssueOutHouse(string soNo) { try { //获å–当å‰ç™»å½•的用户ID var claimsIdentity = this.User.Identity as ClaimsIdentity; if (claimsIdentity == null) { return Ok(new { code = 1, msg = "未获å–åˆ°å½“å‰æ“作人信æ¯" }); } var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value; if (string.IsNullOrWhiteSpace(userId)) { return Ok(new { code = 1, msg = "未获å–åˆ°å½“å‰æ“作人信æ¯" }); } var list = _exNoticeSvc.IssueTwoOutHouse(soNo, int.Parse(userId), _config.WcsHost + _config.IssueComApiUrl, out string str); return Ok(new { code = 0, msg = str, data = list }); } catch (Exception e) { return Ok(new { code = 1, msg = e.Message }); } } /// <summary> /// 釿–°ä¸‹å‘出库任务 /// </summary> /// <param name="taskNo"></param> /// <returns></returns> [HttpPost] public IActionResult AgainSendSoTask(LogTask task) { try { //获å–当å‰ç™»å½•的用户ID var claimsIdentity = this.User.Identity as ClaimsIdentity; if (claimsIdentity == null) { return Ok(new { code = 1, msg = "未获å–åˆ°å½“å‰æ“作人信æ¯" }); } var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value; if (string.IsNullOrWhiteSpace(userId)) { return Ok(new { code = 1, msg = "未获å–åˆ°å½“å‰æ“作人信æ¯" }); } var list = _exNoticeSvc.AgainSendSoTask(task.TaskNo, int.Parse(userId), _config.WcsHost + _config.IssueComApiUrl); return Ok(new { code = 0, msg = "釿–°ä¸‹å‘已完æˆ", data = list }); } catch (Exception e) { return Ok(new { code = 1, msg = e.Message }); } } /// <summary> /// 指令下å‘(盘点出库) /// </summary> /// <param name="crNo"></param> /// <returns></returns> [Authorize] [HttpGet] public IActionResult CheckOutHouse(string crNo) { try { //获å–当å‰ç™»å½•的用户ID var claimsIdentity = this.User.Identity as ClaimsIdentity; if (claimsIdentity == null) { return Ok(new { code = 1, msg = "未获å–åˆ°å½“å‰æ“作人信æ¯" }); } var userId = claimsIdentity.FindFirst(ClaimTypes.Name)?.Value; if (string.IsNullOrWhiteSpace(userId)) { return Ok(new { code = 1, msg = "未获å–åˆ°å½“å‰æ“作人信æ¯" }); } var list = _crCheckSvc.CheckOutHouse(crNo, int.Parse(userId), _config.WcsHost + _config.IssueComApiUrl, out string str); return Ok(new { code = 0, msg = str, data = list }); } catch (Exception e) { return Ok(new { code = 1, msg = e.Message }); } } #endregion #region WMSæŽ¥å£ è¢«ä¸‹æ¸¸ç³»ç»ŸæŽ¥å£è°ƒç”¨ /// <summary> /// ç”³è¯·å‚¨ä½ /// </summary> /// <param name="model">入库å•ä¿¡æ¯</param> /// <returns></returns> [HttpPost] public IActionResult RequestLocation(RequestLocate model) { try { var logStr = $@".\log\WCS\WCS申请储ä½" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; //model.ManuFactureDate = DateTime.Now; var jsonData = JsonConvert.SerializeObject(model); LogFile.SaveLogToFile($"WCS申请储ä½ï¼š( {jsonData} ),", logStr); var list = _asnPalletBindSvc.RequestLocation(model); return Ok(new { Success = 0, Message = "", TaskList = list }); } catch (Exception e) { var logStr = $@".\log\WCS\WCS申请储ä½" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; LogFile.SaveLogToFile($"WCS申请储ä½å¤±è´¥ï¼š( {e.Message} ),", logStr); return Ok(new { Success = -1, Message = e.Message }); } } /// <summary> /// 接å—wcsè¿”å›žçš„ä¿¡å· //指令å馈(是å¦å®Œæˆï¼‰ /// </summary> /// <returns></returns> [HttpPost] public IActionResult ReceiveWcsSignal(ReceiveWcsSignal model) { try { //记录log var logStr = $@".\log\WCS\接收WCS返回信å·" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; var jsonData = JsonConvert.SerializeObject(model); LogFile.SaveLogToFile($"接收WCS返回信å·ï¼š( {jsonData} ),", logStr); if (string.IsNullOrEmpty(model.TaskNo) || string.IsNullOrEmpty(model.TaskStatus) || string.IsNullOrEmpty(model.TaskType)) { return Ok(new WcsReturnModel { StatusCode = -1, Msg = "æŽ¥å£æ•°æ®ä¸æ£ç¡®" }); } //接收时间 var time1 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); var orderType = _taskSvc.GetTaskOrderType(model.TaskNo);// 判æ–啿®ç±»åž‹å…¥å‡ºç§» switch (orderType) { case "0"://入库完æˆä»»åŠ¡ if (model.TaskType == "0")//0:入库 1:出库 2:移库 { _asnPalletBindSvc.ArrivalSuccess(model.TaskNo, 0, ""); return Ok(new WcsReturnModel { StatusCode = 0, Msg = "入库完æˆ" }); } break; case "1"://出库完æˆä»»åŠ¡ if (model.TaskType == "1")//0:入库 1:出库 2:移库 { _exNoticeSvc.ExportSuccess(model.TaskNo, 0, ""); return Ok(new WcsReturnModel { StatusCode = 0, Msg = "出库完æˆ" }); } else if (model.TaskType == "2") { //改原ã€ç›®æ ‡å‚¨ä½çжæ€ï¼Œåº“å˜æ˜Žç»†è¡¨ä½ç½®ä¿¡æ¯ï¼Œä»»åŠ¡æ”¹ä¸ºå·²å®Œæˆ _exNoticeSvc.RelocationSuccess(model.TaskNo, 0, ""); return Ok(new WcsReturnModel { StatusCode = 0, Msg = "移库完æˆ" }); } break; case "2"://盘库完æˆä»»åŠ¡ if (model.TaskType == "1")//0:入库 1:出库 2:移库 { _crCheckSvc.CheckSuccess(model.TaskNo, 0, ""); return Ok(new WcsReturnModel { StatusCode = 0, Msg = "盘点出库完æˆ" }); } else if (model.TaskType == "0")// ç›˜ç‚¹å‡ºåº“æ‰˜ç›˜å›žåº“å®Œæˆ { _asnPalletBindSvc.ArrivalSuccess(model.TaskNo, 0, ""); return Ok(new WcsReturnModel { StatusCode = 0, Msg = "入库完æˆ" }); } else if (model.TaskType == "2")//0:入库 1:出库 2:移库 { _exNoticeSvc.RelocationSuccess(model.TaskNo, 0, ""); return Ok(new WcsReturnModel { StatusCode = 0, Msg = "盘点移库完æˆ" }); } break; case "3"://移库完æˆä»»åŠ¡ã€ä¼˜åŒ–å‚¨ä½ if (model.TaskType == "3") //0:入库 1:出库 3:移库 { //填写移库完æˆä»£ç } break; default: return Ok(new WcsReturnModel { StatusCode = -1, Msg = "ä¼ é€’çš„ä»»åŠ¡çŠ¶æ€ä¸ºå¤±è´¥çжæ€" }); } return Ok(new WcsReturnModel { StatusCode = -1, Msg = "ä¼ é€’çš„ä»»åŠ¡çŠ¶æ€ä¸ºå¤±è´¥çжæ€" }); } catch (Exception ex) { return Ok(new WcsReturnModel { StatusCode = -1, Msg = ex.Message }); } } /// <summary> /// WCS申请空托出库 /// </summary> /// <param name="model"></param> /// <returns></returns> [HttpPost] public IActionResult PalletLocation(WcsPalletModel model) { try { //记录log var logStr = $@".\log\WCS\WCS申请空托盘" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; var jsonData = JsonConvert.SerializeObject(model); LogFile.SaveLogToFile($"WCS申请空托盘物料å·ï¼š( {jsonData} ),", logStr); //获å–ç©ºæ‰˜ç›˜æ‰€åœ¨åº“ä½ var list = _asnPalletBindSvc.PalletLocation(model.SkuNo,model.EndLocat); return Ok(new { Success = "0", Message = list == null ? "任务已申请ï¼" : "", TaskList = list }); } catch (Exception e) { //记录log var logStr = $@".\log\WCS\WCS申请空托盘" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; //var jsonData = JsonConvert.SerializeObject(JsonConvert.DeserializeObject(skuNo.ToString())); LogFile.SaveLogToFile($"当å‰ç©ºæ‰˜ç›˜ç”³è¯·å¤±è´¥ï¼,{e.Message}", logStr); return Ok(new { Success = -1, Message = e.Message }); } } /// <summary> /// WCSæ»¡æ”¾é‡æ–°åˆ†é…å‚¨ä½ /// </summary> /// <param name="model"></param> /// <returns></returns> [HttpPost] public IActionResult ReLocation(RequestLocate model) { try { var logStr = $@".\log\WCS\WCS满放" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; //model.ManuFactureDate = DateTime.Now; var jsonData = JsonConvert.SerializeObject(model); LogFile.SaveLogToFile($"WCS满放:( {jsonData} ),", logStr); var list = _asnPalletBindSvc.ReLocation(model); return Ok(new { Success = 0, Message = "", TaskList = list }); } catch (Exception e) { var logStr = $@".\log\WCS\WCS满放" + DateTime.Now.ToString("yyyyMMdd") + ".txt"; LogFile.SaveLogToFile($"WCS满放:( {e.Message} ),", logStr); return Ok(new { Success = -1, Message = e.Message }); } } //托盘箱ç ä¿¡æ¯ è‡ªåŠ¨ç åž› (wcsæä¾›) //申请空托(自动ç 空托时用) //è½¦é—´å«æ–™ /// <summary> /// æ¯æ—¥æ¸…空日志 /// </summary> /// <returns></returns> /// <exception cref="Exception"></exception> [HttpPost] public IActionResult DeleteNlogFile() { try { string[] files = null; try { files = Directory.GetFiles(_config.Get130log); } catch { try { files = Directory.GetFiles(_config.Get131log); } catch (Exception ex) { throw new Exception(ex.Message); } } finally { foreach (string file in files) { FileInfo fi = new FileInfo(file); if (fi.LastWriteTime < DateTime.Now.AddMonths(-1)) { fi.Delete(); } } } return Ok(new { msg = "æˆåŠŸæ¸…é™¤" }); } catch (Exception ex) { throw new Exception(ex.Message); } } [HttpPost] public IActionResult UptTaskYouxian() { var list = _funSvc.GetFunSettingList("", "On", "Fun020"); return Ok(new { msg = list[0].FunSetName }); } #endregion #region PDA //空托指令下å‘(出库) #endregion } }