HttpManager.cs 7.1 KB
using Common;
using RestSharp;
using System;
using System.Collections.Generic;
using System.Drawing;

namespace DeviceLibrary
{
    public class HttpManager
    {
        private static log4net.ILog log = log4net.LogManager.GetLogger("HttpManager");



        public class BoxDestInfo
        {
            public int code { get; set; }

            public string msg { get; set; }
            public string data { get; set; }

            public override string ToString()
            {
                return string.Format("code:{0}, msg:{1}, data:{2}", code, msg, data);
            }
        }

        private static string Addr_FindFullShelfTarget = "/rest/api/dcs/device/shelfDestination";


        /// <summary>
        /// 查找满料架目的地
        /// </summary>
        /// <param name="rfid"></param>
        /// <param name="dest"></param>
        /// <returns></returns>
        public static bool FindFullShelfTarget(string rfid, out BoxDestInfo destInfo)
        {
            destInfo = null;
            try
            {
                if (rfid.Equals("") || rfid.Equals("00"))
                    return false;
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("rfid", rfid);
                string server = GetAddr(Addr_FindFullShelfTarget, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                destInfo = JsonHelper.DeserializeJsonToObject<BoxDestInfo>(resultStr);
                log.Debug(string.Format("FindFullShelfTarget server:[{0}] return:[{1}]", server, resultStr));
                if (destInfo == null)
                {
                    log.Error("查找目的地【" + server + "】【" + resultStr + "】");
                    return false;
                }
                else if (destInfo.code.Equals(0).Equals(true))
                {
                    if (destInfo.data.ToLower().Equals("none"))
                        return false;
                    else
                        return true;
                }
                return false;


            }
            catch (Exception ex)
            {
                log.Error("FindFullShelfTarget", ex);
                return false;
            }
        }
        private static string Addr_updateDeviceAlarmMsg = "/rest/api/qisda/device/updateDeviceAlarmMsg";
        /// <summary>
        /// 异常看板
        /// </summary>
        /// <param name="msgList"></param>
        /// <returns></returns>
        public static string updateDeviceAlarmMsg(List<AlarmMsg> msgList)
        {
            string msg = "";
            try
            {
                if (msgList.Count.Equals(0)) return "";
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                string msgListStr = JsonHelper.SerializeObject(msgList);
                paramMap.Add("deviceAlarmList", msgListStr);
                string server = GetAddr(Addr_updateDeviceAlarmMsg, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Post(server, "");
                msgList.ForEach(new Action<AlarmMsg>(k=>log.Debug("deviceAlarmList " + k.ToString())));
                log.Debug(string.Format("updateDeviceAlarmMsg server:[{0}] return:[{1}]", server,resultStr));
                RfidData data = JsonHelper.DeserializeJsonToObject<RfidData>(resultStr);

                if (data == null)
                {
                    return msg = " updateDeviceAlarmMsg 没有收到服务器反馈";
                }
                else if (data.code.Equals(0).Equals(false))
                {
                    return msg = "【" + server + "】【" + resultStr + "】" + data.msg;
                }
                return "";
            }
            catch (Exception ex)
            {
                log.Error(ex);
            }
            return msg;
        }
        private static string GetAddr(string addr, Dictionary<string, string> paramsMap)
        {
            string server = AppConfigHelper.GetValue(SettingString.httpServer);
            if (server.EndsWith("/"))
            {
                server = server.Substring(0, server.Length - 1);
            }
            string path = server + addr.Trim() + "?";
            foreach (string paramName in paramsMap.Keys)
            {
                string par = System.Web.HttpUtility.UrlEncode(paramsMap[paramName], System.Text.Encoding.UTF8);
                path += paramName + "=" + par + "&";
            }
            path = path.Substring(0, path.Length - 1);
            return path;
        }

        private static string Addr_agvRemoveRfid = "/rest/api/dcs/device/agvRemoveRfid";
        /// <summary>
        /// 根据RFID清理料架的缓存信息
        /// </summary>
        /// <param name="rfid"></param>
        /// <returns></returns>
        public static bool AgvRemoveRfid(string rfid)
        {
            try
            {
                Dictionary<string, string> paramMap = new Dictionary<string, string>();
                paramMap.Add("rfid", rfid.ToUpper());
                string server = GetAddr(Addr_agvRemoveRfid, paramMap);
                DateTime startTime = DateTime.Now;
                string resultStr = HttpHelper.Get(server);
                log.Info("清理料架的缓存信息【" + server + "】【" + resultStr + "】");

                RfidData rfidData = JsonHelper.DeserializeJsonToObject<RfidData>(resultStr);

                if (rfidData == null)
                {
                    return false;
                }
                else
                {

                    if (rfidData.code.Equals(0))
                    {
                        return true;
                    }
                }

            }
            catch (Exception ex)
            {
                log.Error(ex);
                return false;
            }
            return false;
        }
    }


    public class AlarmMsg
    {

        //>>>name :  异常位置名称
        public string name = "";
        //>>>msgKey :  异常信息唯一标识
        public string msgKey = "";
        //>>>msgValue :  异常信息
        public string msgValue = "";
        //0:异常;1:正常显示
        public int type = 0;

        /// <summary>
        /// 异常信息
        /// </summary>
        /// <param name="name">异常位置名称</param>
        /// <param name="key">异常信息唯一标识</param>
        /// <param name="value">异常信息</param>
        public AlarmMsg(string name, string key, string value, int type = 0)
        {
            this.name = name;
            this.msgKey = key;
            this.msgValue = value;
            this.type = type;
        }
        public override string ToString()
        {
            return string.Format("[name:{0},msgKey:{1},msgValue:{2},type:{3}]", name, msgKey, msgValue, type);
        }
    }
    public class RfidData
    {
        //{"code":0,"msg":"ok","data":"7"} 
        public int code { get; set; }

        public string msg { get; set; }

        public Dictionary<string, string> data { get; set; }
    }

}