MongoDbconn.cs 3.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using Library;
  5. // using MongoDB.Bson;
  6. // using MongoDB.Driver;
  7. // using MongoDB.Driver.Linq;
  8. namespace MySystem
  9. {
  10. public class MongoDbconn
  11. {
  12. public readonly static MongoDbconn Instance = new MongoDbconn();
  13. // IMongoDatabase mydb;
  14. private MongoDbconn()
  15. {
  16. // //连接数据库
  17. // MongoClient client = new MongoClient(ConfigurationManager.AppSettings["MongoConnStr"].ToString());
  18. // //获取database
  19. // mydb = client.GetDatabase("test");
  20. }
  21. // public List<Dictionary<string, object>> List(string tableEnName, int pageNum = 1, int pageSize = 20)
  22. // {
  23. // int skip = (pageNum - 1) * pageSize;
  24. // //获取collection
  25. // var collection = mydb.GetCollection<BsonDocument>(tableEnName);
  26. // var filter = Builders<BsonDocument>.Filter;
  27. // List<BsonDocument> docs = collection.Find(filter.Regex("Mobile", "/138/") & filter.Eq("AddOrReduce", "1") & (filter.Regex("SellNote", "购买.*?") | filter.Eq("IntegralSourceName", "客服") | filter.Eq("SellNote", "积分兑换码"))).Skip(skip).Limit(pageSize).ToList();
  28. // List<Dictionary<string, object>> list = new List<Dictionary<string, object>>();
  29. // foreach (var doc in docs)
  30. // {
  31. // Dictionary<string, object> item = doc.ToDictionary();
  32. // list.Add(item);
  33. // }
  34. // return list;
  35. // }
  36. // public List<TestUsers> List2(string tableEnName)
  37. // {
  38. // //获取collection
  39. // var collection = mydb.GetCollection<TestUsers>(tableEnName);
  40. // List<TestUsers> docs = collection.AsQueryable().OrderByDescending(m => m.TotalAmount).ToList();
  41. // return docs;
  42. // }
  43. }
  44. // public class IntegralRecord
  45. // {
  46. // public int _id { get; set; }
  47. // // public int Id { get; set; }
  48. // public int Sort { get; set; }
  49. // public int QueryCount { get; set; }
  50. // public Nullable<System.DateTime> CreateDate { get; set; }
  51. // public Nullable<System.DateTime> UpdateDate { get; set; }
  52. // public string SeoTitle { get; set; }
  53. // public string SeoKeyword { get; set; }
  54. // public string SeoDescription { get; set; }
  55. // public bool IsStat { get; set; }
  56. // public string PlatformCode { get; set; }
  57. // public string IntegralSourceName { get; set; }
  58. // public int IntegralSourceId { get; set; }
  59. // public Nullable<System.DateTime> IntegralDate { get; set; }
  60. // public decimal OrderMoney { get; set; }
  61. // public string SellId { get; set; }
  62. // public string Mobile { get; set; }
  63. // public string MerchantName { get; set; }
  64. // public bool AddOrReduce { get; set; }
  65. // public decimal Integral { get; set; }
  66. // public string SellNote { get; set; }
  67. // public string UserId { get; set; }
  68. // public int MerchantId { get; set; }
  69. // public string Operater { get; set; }
  70. // public List<OrderMoney> orderMoneys { get; set; }
  71. // }
  72. // public class TestUsers
  73. // {
  74. // public int _id { get; set; }
  75. // // public int Id { get; set; }
  76. // public string Name { get; set; }
  77. // public List<OrderMoney> orderMoneys { get; set; }
  78. // public decimal TotalAmount { get; set; }
  79. // }
  80. // public class OrderMoney
  81. // {
  82. // public Nullable<System.DateTime> Time { get; set; }
  83. // public decimal Money { get; set; }
  84. // }
  85. }