Windows UWP应用使用当地Sqlite和远程Sql（一）

[DataContract]    public partial class BaseModel<T> : INotifyPropertyChanged where T : class    {        public event PropertyChangedEventHandler PropertyChanged;        public void OnPro(string pName)        {            if (this.PropertyChanged != null)                this.PropertyChanged(this, new PropertyChangedEventArgs(pName));        }        public static T FromJson(string json)        {            using (var ms = new MemoryStream(Encoding.UTF8.GetBytes(json)))            {                var t = JSON.ReadObject(ms);                return t as T;            }        }        public override string ToString()        {            return ToJson();        }        public string ToJson()        {            var t = this;            string json = "";            using (var ms = new MemoryStream())            {                JSON.WriteObject(ms, t);                var array = ms.ToArray();                json = Encoding.UTF8.GetString(array, 0, array.Length);            }            return json;        }        public static DataContractJsonSerializer JSON = new DataContractJsonSerializer(typeof(T));        [NoRemeberProperty]        public bool IsSelected        {            get            {                return _IsSelected;            }            set            {                _IsSelected = value;                OnPro("IsSelected");            }        }        [AutoIncrement, PrimaryKey]        public int ClientId        {            get            {                return _ClientId;            }            set            {                _ClientId = value;            }        }        private bool _IsSelected;        private int _ClientId;    }

 public class NoRemeberProperty : Attribute    {    }

[DataContract]    public class UserAccount : BaseModel<UserAccount>    {        private string _Name;        private string _Email;        private string _Password;        [DataMember]        public string Name        {            get            {                return _Name;            }            set            {                _Name = value; OnPro("Name");            }        }        [DataMember]        public string Email        {            get            {                return _Email;            }            set            {                _Email = value; OnPro("Email");            }        }        [DataMember]        public string Password        {            get            {                return _Password;            }            set            {                _Password = value; OnPro("Password");            }        }    }

public async static void InitDataBase()        {            bool isNeedCreate = false;            StorageFile sf = null;            try            {                sf = await StorageFile.GetFileFromPathAsync(DBPath);            }            catch (FileNotFoundException ex) //文件不存在            {                isNeedCreate = true;            }            if (isNeedCreate)            {                try                {                    Setting.Values.Clear();                    var db = new SQLiteAsyncConnection(DBPath);                    await db.CreateTableAsync<RoundTask>();                    await db.CreateTableAsync<AssetChanges>();                    await db.CreateTableAsync<UserAccount>();                    await db.CreateTableAsync<MoneyInfo>();                }                catch (Exception er) //试图加载格式不正确的程序                {                    sf.DeleteAsync();                    OnException("初始化数据库失败", er);                    Sss.WriteException("sss.initdatebase", er);                }            }        }

public static string DBPath        {            get            {                //return "connectionDrive.sqlite";                return System.IO.Path.Combine(Windows.Storage.ApplicationData.Current.LocalFolder.Path, "connectionDrive.sqlite");            }        }

[DataContract]    public enum StatusCode    {        /// <summary>        /// 账户不存在        /// </summary>        [EnumMember]        UserAccount_NotExists,        /// <summary>        /// 密码错误        /// </summary>        [EnumMember]        Password_Error,        /// <summary>        /// 用户账户已存在        /// </summary>        [EnumMember]        UserAccount_Exists,        /// <summary>        /// 网络错误致使数据传输出错或失败        /// </summary>        [EnumMember]        Network_Error,        /// <summary>        /// 未初始化请求        /// </summary>        [EnumMember]        None,        /// <summary>        /// 已成功提交并执行请求        /// </summary>        [EnumMember]        Completed,        /// <summary>        /// 操作失败        /// </summary>        [EnumMember]        Error,        /// <summary>        /// 已停止支持该版本，请更新你的程序        /// </summary>        [EnumMember]        Application_Stop,    }

public static SQLiteAsyncConnection db = new SQLiteAsyncConnection(Sss.DBPath);        public static async Task<StatusCode> AddObject(object obj)        {            try            {                await db.InsertAsync(obj);                OnAddedObject(obj);                return StatusCode.Completed;            }            catch (Exception e)            {                Sss.WriteException("local.addobject", e);                return StatusCode.Error;            }        }        public static async Task<StatusCode> UpdateObject(object obj)        {            try            {                await db.UpdateAsync(obj);                OnUpdatedObject(obj);                return StatusCode.Completed;            }            catch (Exception e)            {                Sss.WriteException("local.updateobject", e);                return StatusCode.Error;            }        }

public static async Task<List<string>> GetEmails()        {            try            {                var sql = "select * from UserAccount";                var rs = await db.QueryAsync<UserAccount>(sql);                return rs.Select(c => c.Email).ToList();            }            catch (Exception e)            {                return null;            }        }        public static async Task<bool> CanLogin(string email, string pwd)        {            try            {                var sql = "select * from UserAccount where email = '" + email + "' and password = '" + pwd + "'";                var rs = await db.QueryAsync<UserAccount>(sql);                return rs.Count == 1;            }            catch (Exception e)            {                return false;            }        }

[DataContract]    public enum UserWork    {        [EnumMember]        Login,}public enum WorkStatus    {        PostBegin,        PostEnd,        PostPause    }

 [DataContract]    public class HR    {        private Dictionary<string, object> Values = new Dictionary<string, object>();        [DataMember]        public string Source        {            get            {                var s = "";                foreach (var t in Values)                {                    s += t.Key + "=" + t.Value + "&";                }                if (s.EndsWith("&"))                {                    s = s.Substring(0, s.Length - 1);                }                return s;            }            set            {                Values.Clear();                foreach (var t in value.Split('&'))                {                    var s = t.Split('=');                    Values.Add(s[0], s[1]);                }            }        }        public StatusCode Status        {            get            {                if (this.Values.ContainsKey("Status"))                    return (StatusCode)Enum.Parse(typeof(StatusCode), this["Status"].ToString());                else                    return StatusCode.None;            }            set { this["Status"] = value.ToString(); }        }        public object this[string key]        {            get            {                if (this.Values.ContainsKey(key))                    return this.Values[key];                else                    return string.Empty;            }            set            {                if (!this.Values.ContainsKey(key))                    this.Values.Add(key, String.Empty);                this.Values[key] = value;            }        }        public T Get<T>(string key) where T : class        {            return this.Values[key] as T;        }    }

private static string _workUri = "http://localhost:9009/work.ashx";        private static string _version = "1";        public static event EventHandler<WorkStatus> WorkStatusChanged;        public static string Version        {            get { return WB._version; }            set { WB._version = value; }        }        public static string WorkUri        {            get            {                if (Sss.WorkUir != null)                    _workUri = Sss.WorkUir;                return _workUri;            }            set            {                _workUri = value;                Sss.WorkUir = _workUri;            }        }        private static void OnWorkStatusChanged(UserWork work, WorkStatus status)        {            if (WorkStatusChanged != null)            {                WorkStatusChanged(work, status);            }        }        private async static Task<String> Post(string uri, HttpFormUrlEncodedContent args)        {            HttpClient hc = new HttpClient();            var r = await hc.PostAsync(new Uri(WorkUri), args) as HttpResponseMessage;            return await r.Content.ReadAsStringAsync();        }        public async static Task<HR> Post(UserWork type, params object[] args)        {            HR hr = null;            try            {                OnWorkStatusChanged(type, WorkStatus.PostBegin);                var pd = GetData(type, args);                hr = new HR() { Source = await Post(WorkUri, GetData(type, args)) };                return hr;            }            catch (Exception er)            {                return new HR() { Status = StatusCode.Network_Error };            }            finally            {                //if (hr["msg"].ToString().Length > 0)                //    await Sss.Show("", hr["msg"].ToString(), Sss.OkCmd);                OnWorkStatusChanged(type, WorkStatus.PostEnd);            }        }        public static HttpFormUrlEncodedContent GetData(UserWork type, params object[] args)        {            var lst = new List<KeyValuePair<string, string>>();            lst.Add(new KeyValuePair<string, string>("type", type.ToString()));            lst.Add(new KeyValuePair<string, string>("version", Version.ToString()));            if (type == UserWork.Login)            {                lst.Add(new KeyValuePair<string, string>("UserAccount", args.Where(c => c is UserAccount).First().ToString()));            }            return new HttpFormUrlEncodedContent(lst);         }public static string GetStatusText(UserWork type)        {            string status = "";            switch (type)            {                case UserWork.Login:                    status += "正在登录";                    break;             }     return status + "..." ;}

        public bool 是否有网 { get; set; }        private async void button_Click(object sender, RoutedEventArgs e)        {            if (是否有网)            {                var hr = await WB.Post(UserWork.Login, new UserAccount() { Email = txtEmail.Text, Password = pwd.Password });                 if (hr.Status == StatusCode.Completed)                {                    //登录成功;                }            }            else            {                if (Local.CanLogin(txtEmail.Text, pwd.Password))                {                    //登录成功;                }            }        }

public void ProcessRequest(HttpContext context)        {            var h = new HR();            h.Status = StatusCode.None;            try            {var type = (UserWork)Enum.Parse(typeof(UserWork), context.Request["type"]);switch (type)            {                case UserWork.Login:                   Login(context, h);                    break;}              }            catch (Exception e)            {                h.Status = StatusCode.Error;                h["msg"] = e.Message + (e.InnerException == null ? "" : e.InnerException.Message);            }            finally            {                context.Response.Write(h.Source);                context.Response.End();            }        }private static StatusCode Login(HttpContext context, HR h)        {            var ut = Sss.FromJson<UserAccount>(context.Request["UserAccount"]);            if (udao.IsExists(ut.Email))            {                if (udao.Login(ut))                {                    h.Status = StatusCode.Completed;                    h["UserAccount"] = ut.ToString();                }                else                {                   h.Status = StatusCode.Password_Error;                }            }            else            {                h.Status = StatusCode.UserAccount_NotExists;            }        }