PrizeDo.cs 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612
  1. using Common;
  2. using Infrastructure;
  3. using LitJson;
  4. using Microsoft.Extensions.Localization;
  5. using Model;
  6. using NuGet.Packaging;
  7. using Services;
  8. namespace Util
  9. {
  10. public class PrizeDo
  11. {
  12. public static string batchNo = "";
  13. //发奖入口
  14. public static void sendPrize(string content)
  15. {
  16. batchNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + Function.get_Random(3);
  17. int projectId = 1;
  18. string priObjString = prizeObject(projectId, content);
  19. if(!string.IsNullOrEmpty(priObjString))
  20. {
  21. string[] priObjData = priObjString.Split('|');
  22. string priObj = priObjData[0];
  23. string priListIds = priObjData[1];
  24. prizeSend(projectId, priListIds, priObj, content);
  25. }
  26. }
  27. //接收入参
  28. public static Dictionary<string, string> getRequestParams(string content)
  29. {
  30. Dictionary<string, string> dic = new Dictionary<string, string>();
  31. JsonData jsonData = JsonMapper.ToObject(content);
  32. var paramService = App.GetService<IPriProjectParamService>();
  33. var paramList = paramService.GetList(m => m.projectId == 1);
  34. foreach(var param in paramList)
  35. {
  36. dic.Add(param.fieldEnName, jsonData[param.fieldEnName].ToString());
  37. }
  38. return dic;
  39. }
  40. //数据库链接
  41. public static SqlSugarClient initDb(int projectId)
  42. {
  43. var databaseSetService = App.GetService<IPriDatabaseSetService>();
  44. var connectionString = databaseSetService.GetFirst(m => m.projectId == 1);
  45. string server = connectionString.ipAddress;
  46. int port = connectionString.port;
  47. string user = connectionString.userId;
  48. string password = connectionString.password;
  49. string database = connectionString.databaseName;
  50. var db = new SqlSugarClient(new ConnectionConfig()
  51. {
  52. ConnectionString = "server=" + server + ";port=" + port + ";user=" + user + ";password=" + password + ";database=" + database + ";charset=utf8;",
  53. DbType = DbType.MySql,
  54. IsAutoCloseConnection = true,
  55. });
  56. return db;
  57. }
  58. //查询条件匹配数据
  59. public static Dictionary<string, object> condition(int projectId, string content)
  60. {
  61. Dictionary<string, object> dic = new Dictionary<string, object>();
  62. var queryTableService = App.GetService<IPriQueryTableService>();
  63. var queryFieldService = App.GetService<IPriQueryFieldService>();
  64. var returnFieldService = App.GetService<IPriReturnFieldService>();
  65. //查询表
  66. var queryTables = queryTableService.GetList(m => m.projectId == projectId);
  67. foreach(var queryTable in queryTables)
  68. {
  69. //查询返回字段
  70. string fields = "";
  71. var returnFields = returnFieldService.GetList(m => m.queryTableId == queryTable.id);
  72. foreach(var returnField in returnFields)
  73. {
  74. fields += returnField.fieldEnName + ",";
  75. }
  76. fields = fields.TrimEnd(',');
  77. //查询匹配条件
  78. string condi = "";
  79. var queryFields = queryFieldService.GetList(m => m.queryTableId == queryTable.id);
  80. foreach(var queryField in queryFields)
  81. {
  82. string fieldEnName = queryField.fieldEnName;
  83. string fieldQueryKind = queryField.fieldQueryKind;
  84. string fieldQueryModel = queryField.fieldQueryModel;
  85. string fieldQueryValue = queryField.fieldQueryValue;
  86. string fieldQueryValueType = queryField.fieldQueryValueType;
  87. if(fieldQueryKind == "1") //模糊匹配
  88. {
  89. condi += " and " + fieldEnName + " like ";
  90. if(fieldQueryModel == "request_param")
  91. {
  92. Dictionary<string, string> req = getRequestParams(content);
  93. condi += "'%" + req[fieldQueryValue] + "%'";
  94. }
  95. else if(fieldQueryModel == "fixed_value")
  96. {
  97. condi += "'%" + GetExpressionVal(fieldQueryValue) + "%'";
  98. }
  99. }
  100. else if(fieldQueryKind == "2") //精确匹配
  101. {
  102. condi += " and " + fieldEnName + "=";
  103. string val = "";
  104. if(fieldQueryModel == "request_param")
  105. {
  106. Dictionary<string, string> req = getRequestParams(content);
  107. val = req[fieldQueryValue];
  108. }
  109. else if(fieldQueryModel == "fixed_value")
  110. {
  111. val = GetExpressionVal(fieldQueryValue);
  112. }
  113. if(fieldQueryValueType == "text")
  114. {
  115. val = "'" + val + "'";
  116. }
  117. condi += val;
  118. }
  119. else if(fieldQueryKind == "3") //范围匹配
  120. {
  121. string[] val = fieldQueryValue.Split(':');
  122. if(fieldQueryModel == "request_param")
  123. {
  124. Dictionary<string, string> req = getRequestParams(content);
  125. if(fieldQueryValueType == "number")
  126. {
  127. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
  128. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
  129. }
  130. else
  131. {
  132. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
  133. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
  134. }
  135. }
  136. else if(fieldQueryModel == "fixed_value")
  137. {
  138. if(fieldQueryValueType == "number")
  139. {
  140. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
  141. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
  142. }
  143. else
  144. {
  145. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetExpressionVal(val[0]) + "'";
  146. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetExpressionVal(val[1]) + "'";
  147. }
  148. }
  149. }
  150. else if(fieldQueryKind == "4") //取反匹配
  151. {
  152. condi += " and " + fieldEnName + "!=";
  153. string val = "";
  154. if(fieldQueryModel == "request_param")
  155. {
  156. Dictionary<string, string> req = getRequestParams(content);
  157. val = req[fieldQueryValue];
  158. }
  159. else if(fieldQueryModel == "fixed_value")
  160. {
  161. val = GetExpressionVal(fieldQueryValue);
  162. }
  163. if(fieldQueryValueType == "text")
  164. {
  165. val = "'" + val + "'";
  166. }
  167. condi += val;
  168. }
  169. }
  170. var db = initDb(projectId);
  171. var item = db.SqlQueryable<Dictionary<string, object>>("select " + fields + " " + queryTable.tableEnName + "-" + fields + " from " + queryTable.tableEnName + " where 1=1" + condi).First();
  172. dic.AddRange(item);
  173. }
  174. return dic;
  175. }
  176. //奖励发放对象
  177. public static string prizeObject(int projectId, string content)
  178. {
  179. Dictionary<string, object> dic = new Dictionary<string, object>();
  180. var prizeObjectTableService = App.GetService<IPriPrizeObjectTableService>();
  181. var prizeObjectFieldService = App.GetService<IPriPrizeObjectFieldService>();
  182. //查询表
  183. var prizeObjectTable = prizeObjectTableService.GetFirst(m => m.projectId == projectId) ?? new PriPrizeObjectTable();
  184. //查询返回字段
  185. string field = prizeObjectTable.selectField;
  186. //查询匹配条件
  187. string condi = "";
  188. var queryFields = prizeObjectFieldService.GetList(m => m.objectTableId == prizeObjectTable.id);
  189. foreach(var queryField in queryFields)
  190. {
  191. string fieldEnName = queryField.fieldEnName;
  192. string fieldQueryKind = queryField.fieldQueryKind;
  193. string fieldQueryModel = queryField.fieldQueryModel;
  194. string fieldQueryValue = queryField.fieldQueryValue;
  195. string fieldQueryValueType = queryField.fieldQueryValueType;
  196. if(fieldQueryKind == "1") //模糊匹配
  197. {
  198. condi += " and " + fieldEnName + " like ";
  199. if(fieldQueryModel == "request_param")
  200. {
  201. Dictionary<string, string> req = getRequestParams(content);
  202. condi += "'%" + req[fieldQueryValue] + "%'";
  203. }
  204. else if(fieldQueryModel == "fixed_value")
  205. {
  206. condi += "'%" + GetExpressionVal(fieldQueryValue) + "%'";
  207. }
  208. }
  209. else if(fieldQueryKind == "2") //精确匹配
  210. {
  211. condi += " and " + fieldEnName + "=";
  212. string val = "";
  213. if(fieldQueryModel == "request_param")
  214. {
  215. Dictionary<string, string> req = getRequestParams(content);
  216. val = req[fieldQueryValue];
  217. }
  218. else if(fieldQueryModel == "fixed_value")
  219. {
  220. val = GetExpressionVal(fieldQueryValue);
  221. }
  222. if(fieldQueryValueType == "text")
  223. {
  224. val = "'" + val + "'";
  225. }
  226. condi += val;
  227. }
  228. else if(fieldQueryKind == "3") //范围匹配
  229. {
  230. string[] val = fieldQueryValue.Split(':');
  231. if(fieldQueryModel == "request_param")
  232. {
  233. Dictionary<string, string> req = getRequestParams(content);
  234. if(fieldQueryValueType == "number")
  235. {
  236. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
  237. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
  238. }
  239. else
  240. {
  241. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
  242. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
  243. }
  244. }
  245. else if(fieldQueryModel == "fixed_value")
  246. {
  247. if(fieldQueryValueType == "number")
  248. {
  249. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
  250. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
  251. }
  252. else
  253. {
  254. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetExpressionVal(val[0]) + "'";
  255. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetExpressionVal(val[1]) + "'";
  256. }
  257. }
  258. }
  259. else if(fieldQueryKind == "4") //取反匹配
  260. {
  261. condi += " and " + fieldEnName + "!=";
  262. string val = "";
  263. if(fieldQueryModel == "request_param")
  264. {
  265. Dictionary<string, string> req = getRequestParams(content);
  266. val = req[fieldQueryValue];
  267. }
  268. else if(fieldQueryModel == "fixed_value")
  269. {
  270. val = GetExpressionVal(fieldQueryValue);
  271. }
  272. if(fieldQueryValueType == "text")
  273. {
  274. val = "'" + val + "'";
  275. }
  276. condi += val;
  277. }
  278. }
  279. var db = initDb(projectId);
  280. var item = db.SqlQueryable<Dictionary<string, object>>("select " + field + " from " + prizeObjectTable.tableEnName + " where 1=1" + condi).First();
  281. if(item != null)
  282. {
  283. return item[field].ToString() + "|" + prizeObjectTable.prizeListIds;
  284. }
  285. return "";
  286. }
  287. //奖励列表
  288. public static List<PriList> prizeList(int projectId, string prizeIds)
  289. {
  290. List<int> ids = Tools.SpitIntArrary(prizeIds, ',').ToList();
  291. var priListService = App.GetService<IPriListService>();
  292. var priList = priListService.GetList(m => m.projectId == projectId && ids.Contains(m.id)).ToList();
  293. return priList;
  294. }
  295. //奖励发放
  296. public static void prizeSend(int projectId, string prizeIds, string prizeObjectId, string content)
  297. {
  298. var recordService = App.GetService<IPriRecordService>();
  299. var conditionService = App.GetService<IPriConditionService>();
  300. var returnFieldService = App.GetService<IPriReturnFieldService>();
  301. var queryTableService = App.GetService<IPriQueryTableService>();
  302. //查询匹配条件
  303. var condiDic = condition(projectId, content);
  304. var priList = prizeList(projectId, prizeIds);
  305. foreach(var sub in priList)
  306. {
  307. var prizePercent = sub.prizePercent; //奖励比例
  308. var prizeAmount = sub.prizeAmount; //奖励固定值
  309. var prizeContent = sub.prizeContent; //奖励内容
  310. var conditionMode = sub.conditionMode; //条件模式
  311. var recursionFlag = sub.recursionFlag; //是否递归
  312. var conditions = conditionService.GetList(m => m.listId == sub.id);
  313. int allCount = conditions.Count; //所有奖励条件数
  314. int passCount = 0; //通过条件数
  315. foreach(var condition in conditions)
  316. {
  317. var returnFieldId = condition.returnFieldId; //条件返回字段
  318. var fieldQueryKind = condition.fieldQueryKind; //匹配条件
  319. var fieldQueryModel = condition.fieldQueryModel; //匹配方式
  320. var fieldQueryValue = condition.fieldQueryValue; //匹配值
  321. var fieldQueryValueType = condition.fieldQueryValueType; //匹配值类型
  322. var returnField = returnFieldService.GetFirst(m => m.id == returnFieldId);
  323. var queryTable = queryTableService.GetFirst(m => m.id == returnField.queryTableId);
  324. var checkObj = condiDic[queryTable.tableEnName + "-" + returnField.fieldEnName];
  325. var checkVal = fieldQueryValue;
  326. if(fieldQueryKind == "1") //模糊匹配
  327. {
  328. if(fieldQueryValueType == "text")
  329. {
  330. if(checkObj.ToString().Contains(GetExpressionVal(checkVal))) passCount += 1;
  331. }
  332. }
  333. else if(fieldQueryKind == "2") //精确匹配
  334. {
  335. if(fieldQueryValueType == "int")
  336. {
  337. if((int)checkObj == int.Parse(Function.CheckInt(checkVal))) passCount += 1;
  338. }
  339. else if(fieldQueryValueType == "number")
  340. {
  341. if((decimal)checkObj == decimal.Parse(Function.CheckNum(checkVal))) passCount += 1;
  342. }
  343. else
  344. {
  345. if(checkObj.ToString() == GetExpressionVal(checkVal)) passCount += 1;
  346. }
  347. }
  348. else if(fieldQueryKind == "3") //范围匹配
  349. {
  350. string[] val = checkVal.Split(':');
  351. if(fieldQueryModel == "request_param")
  352. {
  353. Dictionary<string, string> req = getRequestParams(content);
  354. if(fieldQueryValueType == "number")
  355. {
  356. if(!string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (decimal)checkObj >= decimal.Parse(Function.CheckNum(req[val[0]])) && (decimal)checkObj <= decimal.Parse(Function.CheckNum(req[val[1]]))) passCount += 1;
  357. else if(!string.IsNullOrEmpty(req[val[0]]) && string.IsNullOrEmpty(req[val[1]]) && (decimal)checkObj >= decimal.Parse(Function.CheckNum(req[val[0]]))) passCount += 1;
  358. else if(string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (decimal)checkObj <= decimal.Parse(Function.CheckNum(req[val[1]]))) passCount += 1;
  359. }
  360. else if(fieldQueryValueType == "int")
  361. {
  362. if(!string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (int)checkObj >= int.Parse(Function.CheckInt(req[val[0]])) && (int)checkObj <= int.Parse(Function.CheckInt(req[val[1]]))) passCount += 1;
  363. else if(!string.IsNullOrEmpty(req[val[0]]) && string.IsNullOrEmpty(req[val[1]]) && (int)checkObj >= int.Parse(Function.CheckInt(req[val[0]]))) passCount += 1;
  364. else if(string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (int)checkObj <= int.Parse(Function.CheckInt(req[val[1]]))) passCount += 1;
  365. }
  366. else if(fieldQueryValueType.StartsWith("date"))
  367. {
  368. if(!string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (DateTime)checkObj >= DateTime.Parse(req[val[0]]) && (DateTime)checkObj <= DateTime.Parse(req[val[1]])) passCount += 1;
  369. else if(!string.IsNullOrEmpty(req[val[0]]) && string.IsNullOrEmpty(req[val[1]]) && (DateTime)checkObj >= DateTime.Parse(req[val[0]])) passCount += 1;
  370. else if(string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (DateTime)checkObj <= DateTime.Parse(req[val[1]])) passCount += 1;
  371. }
  372. }
  373. else if(fieldQueryModel == "fixed_value")
  374. {
  375. if(fieldQueryValueType == "number")
  376. {
  377. if(!string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (decimal)checkObj >= decimal.Parse(Function.CheckNum(val[0])) && (decimal)checkObj <= decimal.Parse(Function.CheckNum(val[1]))) passCount += 1;
  378. else if(!string.IsNullOrEmpty(val[0]) && string.IsNullOrEmpty(val[1]) && (decimal)checkObj >= decimal.Parse(Function.CheckNum(val[0]))) passCount += 1;
  379. else if(string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (decimal)checkObj <= decimal.Parse(Function.CheckNum(val[1]))) passCount += 1;
  380. }
  381. else if(fieldQueryValueType == "int")
  382. {
  383. if(!string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (int)checkObj >= int.Parse(Function.CheckInt(val[0])) && (int)checkObj <= int.Parse(Function.CheckInt(val[1]))) passCount += 1;
  384. else if(!string.IsNullOrEmpty(val[0]) && string.IsNullOrEmpty(val[1]) && (int)checkObj >= int.Parse(Function.CheckInt(val[0]))) passCount += 1;
  385. else if(string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (int)checkObj <= int.Parse(Function.CheckInt(val[1]))) passCount += 1;
  386. }
  387. else if(fieldQueryValueType.StartsWith("date"))
  388. {
  389. if(!string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (DateTime)checkObj >= DateTime.Parse(GetExpressionVal(val[0])) && (DateTime)checkObj <= DateTime.Parse(GetExpressionVal(val[1]))) passCount += 1;
  390. else if(!string.IsNullOrEmpty(val[0]) && string.IsNullOrEmpty(val[1]) && (DateTime)checkObj >= DateTime.Parse(GetExpressionVal(val[0]))) passCount += 1;
  391. else if(string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (DateTime)checkObj <= DateTime.Parse(GetExpressionVal(val[1]))) passCount += 1;
  392. }
  393. }
  394. }
  395. else if(fieldQueryKind == "4") //取反匹配
  396. {
  397. if(fieldQueryValueType == "int")
  398. {
  399. if((int)checkObj != int.Parse(Function.CheckInt(checkVal))) passCount += 1;
  400. }
  401. else if(fieldQueryValueType == "number")
  402. {
  403. if((decimal)checkObj != decimal.Parse(Function.CheckNum(checkVal))) passCount += 1;
  404. }
  405. else if(fieldQueryValueType == "text")
  406. {
  407. if(checkObj.ToString() != GetExpressionVal(checkVal)) passCount += 1;
  408. }
  409. }
  410. }
  411. bool op = false;
  412. if(conditionMode == "all" && passCount == allCount) op = true;
  413. else if(conditionMode == "one" && passCount == 1) op = true;
  414. if(op) //满足条件
  415. {
  416. if(prizePercent > 0)
  417. {
  418. }
  419. if(prizeAmount > 0)
  420. {
  421. var req = getRequestParams(content);
  422. var requestParamField = req[sub.requestParamField];
  423. var sendFlag = recordService.Any(m => m.prizeObjId == prizeObjectId && m.listId == sub.id && m.requestParamField == requestParamField);
  424. if(!sendFlag)
  425. {
  426. recordService.Add(new PriRecord()
  427. {
  428. createDate = DateTime.Now,
  429. projectId = projectId,
  430. listId = sub.id,
  431. prizeAmount = sub.prizeAmount,
  432. prizeObjId = prizeObjectId,
  433. requestParamField = requestParamField,
  434. batchNo = batchNo,
  435. });
  436. // prizeToDatabase(projectId, content); //入库
  437. }
  438. }
  439. }
  440. }
  441. }
  442. //奖励入库
  443. public static void prizeToDatabase(int projectId, string content)
  444. {
  445. var prizeInTableService = App.GetService<IPriPrizeInTableService>();
  446. var prizeInFieldService = App.GetService<IPriPrizeInFieldService>();
  447. var prizeInQueryFieldService = App.GetService<IPriPrizeInQueryFieldService>();
  448. var db = initDb(projectId);
  449. //入库表
  450. var prizeInTables = prizeInTableService.GetList(m => m.projectId == projectId);
  451. foreach(var prizeInTable in prizeInTables)
  452. {
  453. Dictionary<string, object> doFields = new Dictionary<string, object>();
  454. //入库字段
  455. var prizeInFields = prizeInFieldService.GetList(m => m.inTableId == prizeInTable.id);
  456. foreach(var prizeInField in prizeInFields)
  457. {
  458. string fieldEnName = prizeInField.fieldEnName;
  459. string fieldQueryModel = prizeInField.fieldQueryModel;
  460. string fieldQueryValue = prizeInField.fieldQueryValue;
  461. string fieldQueryValueType = prizeInField.fieldQueryValueType;
  462. if(fieldQueryModel == "request_param")
  463. {
  464. Dictionary<string, string> req = getRequestParams(content);
  465. fieldQueryValue = req[fieldQueryValue];
  466. }
  467. else if(fieldQueryModel == "fixed_value")
  468. {
  469. fieldQueryValue = GetExpressionVal(fieldQueryValue);
  470. }
  471. if(fieldQueryValueType == "text") doFields.Add(fieldEnName, fieldQueryValue);
  472. if(fieldQueryValueType == "int") doFields.Add(fieldEnName, int.Parse(fieldQueryValue));
  473. if(fieldQueryValueType == "number") doFields.Add(fieldEnName, decimal.Parse(fieldQueryValue));
  474. if(fieldQueryValueType == "datetime") doFields.Add(fieldEnName, DateTime.Parse(fieldQueryValue));
  475. if(fieldQueryValueType == "bool") doFields.Add(fieldEnName, bool.Parse(fieldQueryValue));
  476. }
  477. //查询匹配条件
  478. string condi = "";
  479. var queryFields = prizeInQueryFieldService.GetList(m => m.inTableId == prizeInTable.id);
  480. foreach(var queryField in queryFields)
  481. {
  482. string fieldEnName = queryField.fieldEnName;
  483. string fieldQueryKind = queryField.fieldQueryKind;
  484. string fieldQueryModel = queryField.fieldQueryModel;
  485. string fieldQueryValue = queryField.fieldQueryValue;
  486. string fieldQueryValueType = queryField.fieldQueryValueType;
  487. if(fieldQueryKind == "1") //模糊匹配
  488. {
  489. condi += " and " + fieldEnName + " like ";
  490. if(fieldQueryModel == "request_param")
  491. {
  492. Dictionary<string, string> req = getRequestParams(content);
  493. condi += "'%" + req[fieldQueryValue] + "%'";
  494. }
  495. else if(fieldQueryModel == "fixed_value")
  496. {
  497. condi += "'%" + fieldQueryValue + "%'";
  498. }
  499. }
  500. else if(fieldQueryKind == "2") //精确匹配
  501. {
  502. condi += " and " + fieldEnName + "=";
  503. string val = "";
  504. if(fieldQueryModel == "request_param")
  505. {
  506. Dictionary<string, string> req = getRequestParams(content);
  507. val = req[fieldQueryValue];
  508. }
  509. else if(fieldQueryModel == "fixed_value")
  510. {
  511. val = fieldQueryValue;
  512. }
  513. if(fieldQueryValueType == "text")
  514. {
  515. val = "'" + val + "'";
  516. }
  517. condi += val;
  518. }
  519. else if(fieldQueryKind == "3") //范围匹配
  520. {
  521. string[] val = fieldQueryValue.Split(':');
  522. if(fieldQueryModel == "request_param")
  523. {
  524. Dictionary<string, string> req = getRequestParams(content);
  525. if(fieldQueryValueType == "number")
  526. {
  527. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
  528. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
  529. }
  530. else
  531. {
  532. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
  533. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
  534. }
  535. }
  536. else if(fieldQueryModel == "fixed_value")
  537. {
  538. if(fieldQueryValueType == "number")
  539. {
  540. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
  541. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
  542. }
  543. else
  544. {
  545. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + val[0] + "'";
  546. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + val[1] + "'";
  547. }
  548. }
  549. }
  550. else if(fieldQueryKind == "4") //取反匹配
  551. {
  552. condi += " and " + fieldEnName + "!=";
  553. string val = "";
  554. if(fieldQueryModel == "request_param")
  555. {
  556. Dictionary<string, string> req = getRequestParams(content);
  557. val = req[fieldQueryValue];
  558. }
  559. else if(fieldQueryModel == "fixed_value")
  560. {
  561. val = fieldQueryValue;
  562. }
  563. if(fieldQueryValueType == "text")
  564. {
  565. val = "'" + val + "'";
  566. }
  567. condi += val;
  568. }
  569. }
  570. if(prizeInTable.excuteKind == "add") db.Insertable(doFields).ExecuteCommand();
  571. if(prizeInTable.excuteKind == "update") db.Updateable(doFields).Where("1=1" + condi).ExecuteCommand();
  572. }
  573. }
  574. //固定值表达式
  575. public static string GetExpressionVal(string str)
  576. {
  577. if(str == "#{now}#") str = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  578. if(str == "#{today}#") str = DateTime.Now.ToString("yyyy-MM-dd");
  579. if(str == "#{this_month}#") str = DateTime.Now.ToString("yyyy-MM");
  580. if(str.StartsWith("#{now") && str.EndsWith("DAY}#")) str = DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd HH:mm:ss");
  581. if(str.StartsWith("#{now") && str.EndsWith("MONTH}#")) str = DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd HH:mm:ss");
  582. if(str.StartsWith("#{today") && str.EndsWith("DAY}#")) str = DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd");
  583. if(str.StartsWith("#{today") && str.EndsWith("MONTH}#")) str = DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd");
  584. if(str.StartsWith("#{this_month") && str.EndsWith("DAY}#")) str = DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM");
  585. if(str.StartsWith("#{this_month") && str.EndsWith("MONTH}#")) str = DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM");
  586. return str;
  587. }
  588. }
  589. }