储物柜soket通信协议和中间件实现技术细节

 [HttpGet]
        /// <summary>
        /// 储物柜取物开箱接口(取件)
        /// </summary>
        /// <param name="StationNo">设备唯一编号  设备不存在或者设备编号有误！</param>
        /// <param name="CellNo">箱格编号</param>
        /// <returns></returns>
        public ApiActionResult BufferBox_Collect(string StationNo, string CellNo)
        {
            var result = new ApiActionResult()
            {
                Success = false,
                Result = null,
                Message = "操作失败。"
            };
            string msg = string.Empty;
            using (var db = new BufferBoxDBEntities())
            {
                var stationEntity = db.station_signin_session.Where(st => st.SessionDict == StationNo).FirstOrDefault();
                if (stationEntity == null)
                {
                    result.Message = "设备不存在或者设备编号有误！";
                    result.Result = "";
                    return result;
                }
                #region API_Request_session
                var requestEntity = new API_Request_session
                {
                    API_Request_IP = Request.GetClientIpAddress(),
                    RequestID = Guid.NewGuid(),
                    RequestData = CellNo + "|Collect",
                    RequestDataTime = DateTime.Now,
                    ResultData = JsonConvert.SerializeObject(new CommandResultDTO { CellNo = CellNo, Action = "取件", ResultMessage = "中间件已转发，设备还未回复。" }),
                    ExecuteFlag = false,
                    StationNo = StationNo
                };
                db.API_Request_session.AddObject(requestEntity);
                #endregion
                db.SaveChanges();
                //Com.DataCool.DotNetExpand.LogHelper.Info(JsonConvert.SerializeObject(requestEntity));
                msg = "api_request:" + JsonConvert.SerializeObject(requestEntity);
                result.Success = true;
                result.Message = "设备已经受理请求。";
                result.Result = requestEntity.RequestID.ToString();
            }
            if (!string.IsNullOrEmpty(msg))
            {
                Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                try
                {
                    clientSocket.Connect(new IPEndPoint(IPAddress.Parse(conf.AppSettings.Settings["Middleware_IP"].Value), Convert.ToInt32(conf.AppSettings.Settings["Middleware_PORT"].Value)));
                    clientSocket.Send(Encoding.UTF8.GetBytes(msg));
                }
                catch { }
            }            
            return result;
        }