using SysBaseLibs;
using SysDataLibs;
using SysDataLibs.TableClass;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Services;

namespace GSMarketSys.WS
{
    /// <summary>
    /// registerIPServer 的摘要说明
    /// </summary>
    [WebService(Namespace = "http://tempuri.org/")]
    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
    [System.ComponentModel.ToolboxItem(false)]
    // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消注释以下行。 
    // [System.Web.Script.Services.ScriptService]
    public class registerIPServer : System.Web.Services.WebService
    {

        public registerIPServer()
        {

            //如果使用设计的组件，请取消注释以下行 
            //InitializeComponent(); 
        }

        // 查询指定市场的监控信息序号
        private string GetMarketWatchID(string lcMarketId, SysBaseLibs.DBConnSql loConn)
        {
            string strRet = string.Empty;
            string lcSql = "select * from " + Tn.MarketWatch + " where " + MarketWatch_info.cMarketId + "='" + lcMarketId + "'";

            SysBaseLibs.rsQuery loQuery = loConn.OpenQuery(lcSql);
            if (loQuery != null && loQuery.IsOpened && loQuery.RecCount > 0)
            {
                strRet = loQuery.GetString(MarketWatch_info.cMarketWatchID);
            }
            return strRet;
        }

        private Sys_Users_info GetUserInfo(string userid, SysBaseLibs.DBConnSql loConn)
        {
            Sys_Users_info loUserInfo = null;

            string lcSql = "select * from " + Tn.Sys_Users + " where "
                + Sys_Users_info.cIsLock + "='N' and  " + Sys_Users_info.cUserCode + "='" + userid + "' and "
                + Sys_Users_info.cIsAudit + "='Y' ";

            SysBaseLibs.rsQuery loQuery = loConn.OpenQuery(lcSql);
            if (loQuery != null && loQuery.IsOpened && loQuery.RecCount == 1)
            {
                loUserInfo = new Sys_Users_info(loQuery.CurrentRow);
            }

            return loUserInfo;
        }

        [WebMethod]
        public bool registerIP(string userid, string passwd, string url, string watchType)
        {
            bool bRet = false;

            userid = Utils.AreaToSQL(userid);
            url = Utils.AreaToSQL(url);
            watchType = Utils.AreaToSQL(watchType);

            string lcIP = HttpContext.Current.Request.ServerVariables.GetValues("REMOTE_ADDR")[0];
            SysBaseLibs.DBConnSql DbConn = new SysBaseLibs.DBConnSql();

            try
            {
                if (DbConn.Open())
                {
                    //Sys_Users_info loUsers = new Sys_Users_info(userid, DbConn);
                    Sys_Users_info loUsers = GetUserInfo(userid, DbConn);
                    if (loUsers != null && loUsers.IsMarketSys && loUsers.Password == passwd)
                    {
                        UserSession loSession = new UserSession(loUsers, DbConn);
                        MarketWatch_info loMarketInfo = new MarketWatch_info();
                        loMarketInfo.MarketId = loSession.MarketInfo.MarketID;
                        loMarketInfo.UserId = loSession.UserInfo.UserID;
                        loMarketInfo.WatchDate = DateTime.Now.ToShortDateString();
                        loMarketInfo.UpdateTime = DateTime.Now.ToString();
                        loMarketInfo.WatchType = watchType;
                        loMarketInfo.WatchUrl = "http://" + lcIP + "" + url;

                        string lcMarketWatchSql = string.Empty;

                        // 查询指定市场的监控信息序号
                        string strMarketWatchID = GetMarketWatchID(loSession.MarketInfo.MarketID, DbConn);
                        if (strMarketWatchID != "")
                        {
                            loMarketInfo.MarketWatchID = strMarketWatchID;
                            lcMarketWatchSql = loMarketInfo.UpdateSql();
                        }
                        else
                        {
                            lcMarketWatchSql = loMarketInfo.InsertSql();
                        }

                        if (DbConn.ExcuteSqlTran(lcMarketWatchSql))
                        {
                            bRet = true;
                            //SysBaseLibs.ThreadLog.LogInfo("用户 " + userid + " 注册了视频信息," + loSession.MarketInfo.Names + "(" + loSession.MarketInfo.MarketID + ") , 地址为" + lcIP);
                        }
                    }
                }
            }
            catch (Exception err)
            {
                SysBaseLibs.ThreadLog.LogException(err);
                return false;
            }
            finally
            {
                if (DbConn != null && DbConn.IsOpened)
                    DbConn.Close();
            }

            return bRet;
        }
    }
}