PrizeDo.cs 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613
  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 requestParamField = sub; //奖励内容
  308. var prizePercent = sub.prizePercent; //奖励比例
  309. var prizeAmount = sub.prizeAmount; //奖励固定值
  310. var prizeContent = sub.prizeContent; //奖励内容
  311. var conditionMode = sub.conditionMode; //条件模式
  312. var recursionFlag = sub.recursionFlag; //是否递归
  313. var conditions = conditionService.GetList(m => m.listId == sub.id);
  314. int allCount = conditions.Count; //所有奖励条件数
  315. int passCount = 0; //通过条件数
  316. foreach(var condition in conditions)
  317. {
  318. var returnFieldId = condition.returnFieldId; //条件返回字段
  319. var fieldQueryKind = condition.fieldQueryKind; //匹配条件
  320. var fieldQueryModel = condition.fieldQueryModel; //匹配方式
  321. var fieldQueryValue = condition.fieldQueryValue; //匹配值
  322. var fieldQueryValueType = condition.fieldQueryValueType; //匹配值类型
  323. var returnField = returnFieldService.GetFirst(m => m.id == returnFieldId);
  324. var queryTable = queryTableService.GetFirst(m => m.id == returnField.queryTableId);
  325. var checkObj = condiDic[queryTable.tableEnName + "-" + returnField.fieldEnName];
  326. var checkVal = fieldQueryValue;
  327. if(fieldQueryKind == "1") //模糊匹配
  328. {
  329. if(fieldQueryValueType == "text")
  330. {
  331. if(checkObj.ToString().Contains(GetExpressionVal(checkVal))) passCount += 1;
  332. }
  333. }
  334. else if(fieldQueryKind == "2") //精确匹配
  335. {
  336. if(fieldQueryValueType == "int")
  337. {
  338. if((int)checkObj == int.Parse(Function.CheckInt(checkVal))) passCount += 1;
  339. }
  340. else if(fieldQueryValueType == "number")
  341. {
  342. if((decimal)checkObj == decimal.Parse(Function.CheckNum(checkVal))) passCount += 1;
  343. }
  344. else
  345. {
  346. if(checkObj.ToString() == GetExpressionVal(checkVal)) passCount += 1;
  347. }
  348. }
  349. else if(fieldQueryKind == "3") //范围匹配
  350. {
  351. string[] val = checkVal.Split(':');
  352. if(fieldQueryModel == "request_param")
  353. {
  354. Dictionary<string, string> req = getRequestParams(content);
  355. if(fieldQueryValueType == "number")
  356. {
  357. 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;
  358. else if(!string.IsNullOrEmpty(req[val[0]]) && string.IsNullOrEmpty(req[val[1]]) && (decimal)checkObj >= decimal.Parse(Function.CheckNum(req[val[0]]))) passCount += 1;
  359. else if(string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (decimal)checkObj <= decimal.Parse(Function.CheckNum(req[val[1]]))) passCount += 1;
  360. }
  361. else if(fieldQueryValueType == "int")
  362. {
  363. 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;
  364. else if(!string.IsNullOrEmpty(req[val[0]]) && string.IsNullOrEmpty(req[val[1]]) && (int)checkObj >= int.Parse(Function.CheckInt(req[val[0]]))) passCount += 1;
  365. else if(string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (int)checkObj <= int.Parse(Function.CheckInt(req[val[1]]))) passCount += 1;
  366. }
  367. else if(fieldQueryValueType.StartsWith("date"))
  368. {
  369. 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;
  370. else if(!string.IsNullOrEmpty(req[val[0]]) && string.IsNullOrEmpty(req[val[1]]) && (DateTime)checkObj >= DateTime.Parse(req[val[0]])) passCount += 1;
  371. else if(string.IsNullOrEmpty(req[val[0]]) && !string.IsNullOrEmpty(req[val[1]]) && (DateTime)checkObj <= DateTime.Parse(req[val[1]])) passCount += 1;
  372. }
  373. }
  374. else if(fieldQueryModel == "fixed_value")
  375. {
  376. if(fieldQueryValueType == "number")
  377. {
  378. 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;
  379. else if(!string.IsNullOrEmpty(val[0]) && string.IsNullOrEmpty(val[1]) && (decimal)checkObj >= decimal.Parse(Function.CheckNum(val[0]))) passCount += 1;
  380. else if(string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (decimal)checkObj <= decimal.Parse(Function.CheckNum(val[1]))) passCount += 1;
  381. }
  382. else if(fieldQueryValueType == "int")
  383. {
  384. 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;
  385. else if(!string.IsNullOrEmpty(val[0]) && string.IsNullOrEmpty(val[1]) && (int)checkObj >= int.Parse(Function.CheckInt(val[0]))) passCount += 1;
  386. else if(string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (int)checkObj <= int.Parse(Function.CheckInt(val[1]))) passCount += 1;
  387. }
  388. else if(fieldQueryValueType.StartsWith("date"))
  389. {
  390. 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;
  391. else if(!string.IsNullOrEmpty(val[0]) && string.IsNullOrEmpty(val[1]) && (DateTime)checkObj >= DateTime.Parse(GetExpressionVal(val[0]))) passCount += 1;
  392. else if(string.IsNullOrEmpty(val[0]) && !string.IsNullOrEmpty(val[1]) && (DateTime)checkObj <= DateTime.Parse(GetExpressionVal(val[1]))) passCount += 1;
  393. }
  394. }
  395. }
  396. else if(fieldQueryKind == "4") //取反匹配
  397. {
  398. if(fieldQueryValueType == "int")
  399. {
  400. if((int)checkObj != int.Parse(Function.CheckInt(checkVal))) passCount += 1;
  401. }
  402. else if(fieldQueryValueType == "number")
  403. {
  404. if((decimal)checkObj != decimal.Parse(Function.CheckNum(checkVal))) passCount += 1;
  405. }
  406. else if(fieldQueryValueType == "text")
  407. {
  408. if(checkObj.ToString() != GetExpressionVal(checkVal)) passCount += 1;
  409. }
  410. }
  411. }
  412. bool op = false;
  413. if(conditionMode == "all" && passCount == allCount) op = true;
  414. else if(conditionMode == "one" && passCount == 1) op = true;
  415. if(op) //满足条件
  416. {
  417. if(prizePercent > 0)
  418. {
  419. }
  420. if(prizeAmount > 0)
  421. {
  422. var req = getRequestParams(content);
  423. var requestParamField = req[sub.requestParamField];
  424. var sendFlag = recordService.Any(m => m.prizeObjId == prizeObjectId && m.listId == sub.id && m.requestParamField == requestParamField);
  425. if(!sendFlag)
  426. {
  427. recordService.Add(new PriRecord()
  428. {
  429. createDate = DateTime.Now,
  430. projectId = projectId,
  431. listId = sub.id,
  432. prizeAmount = sub.prizeAmount,
  433. prizeObjId = prizeObjectId,
  434. requestParamField = requestParamField,
  435. batchNo = batchNo,
  436. });
  437. // prizeToDatabase(projectId, content); //入库
  438. }
  439. }
  440. }
  441. }
  442. }
  443. //奖励入库
  444. public static void prizeToDatabase(int projectId, string content)
  445. {
  446. var prizeInTableService = App.GetService<IPriPrizeInTableService>();
  447. var prizeInFieldService = App.GetService<IPriPrizeInFieldService>();
  448. var prizeInQueryFieldService = App.GetService<IPriPrizeInQueryFieldService>();
  449. var db = initDb(projectId);
  450. //入库表
  451. var prizeInTables = prizeInTableService.GetList(m => m.projectId == projectId);
  452. foreach(var prizeInTable in prizeInTables)
  453. {
  454. Dictionary<string, object> doFields = new Dictionary<string, object>();
  455. //入库字段
  456. var prizeInFields = prizeInFieldService.GetList(m => m.inTableId == prizeInTable.id);
  457. foreach(var prizeInField in prizeInFields)
  458. {
  459. string fieldEnName = prizeInField.fieldEnName;
  460. string fieldQueryModel = prizeInField.fieldQueryModel;
  461. string fieldQueryValue = prizeInField.fieldQueryValue;
  462. string fieldQueryValueType = prizeInField.fieldQueryValueType;
  463. if(fieldQueryModel == "request_param")
  464. {
  465. Dictionary<string, string> req = getRequestParams(content);
  466. fieldQueryValue = req[fieldQueryValue];
  467. }
  468. else if(fieldQueryModel == "fixed_value")
  469. {
  470. fieldQueryValue = GetExpressionVal(fieldQueryValue);
  471. }
  472. if(fieldQueryValueType == "text") doFields.Add(fieldEnName, fieldQueryValue);
  473. if(fieldQueryValueType == "int") doFields.Add(fieldEnName, int.Parse(fieldQueryValue));
  474. if(fieldQueryValueType == "number") doFields.Add(fieldEnName, decimal.Parse(fieldQueryValue));
  475. if(fieldQueryValueType == "datetime") doFields.Add(fieldEnName, DateTime.Parse(fieldQueryValue));
  476. if(fieldQueryValueType == "bool") doFields.Add(fieldEnName, bool.Parse(fieldQueryValue));
  477. }
  478. //查询匹配条件
  479. string condi = "";
  480. var queryFields = prizeInQueryFieldService.GetList(m => m.inTableId == prizeInTable.id);
  481. foreach(var queryField in queryFields)
  482. {
  483. string fieldEnName = queryField.fieldEnName;
  484. string fieldQueryKind = queryField.fieldQueryKind;
  485. string fieldQueryModel = queryField.fieldQueryModel;
  486. string fieldQueryValue = queryField.fieldQueryValue;
  487. string fieldQueryValueType = queryField.fieldQueryValueType;
  488. if(fieldQueryKind == "1") //模糊匹配
  489. {
  490. condi += " and " + fieldEnName + " like ";
  491. if(fieldQueryModel == "request_param")
  492. {
  493. Dictionary<string, string> req = getRequestParams(content);
  494. condi += "'%" + req[fieldQueryValue] + "%'";
  495. }
  496. else if(fieldQueryModel == "fixed_value")
  497. {
  498. condi += "'%" + fieldQueryValue + "%'";
  499. }
  500. }
  501. else if(fieldQueryKind == "2") //精确匹配
  502. {
  503. condi += " and " + fieldEnName + "=";
  504. string val = "";
  505. if(fieldQueryModel == "request_param")
  506. {
  507. Dictionary<string, string> req = getRequestParams(content);
  508. val = req[fieldQueryValue];
  509. }
  510. else if(fieldQueryModel == "fixed_value")
  511. {
  512. val = fieldQueryValue;
  513. }
  514. if(fieldQueryValueType == "text")
  515. {
  516. val = "'" + val + "'";
  517. }
  518. condi += val;
  519. }
  520. else if(fieldQueryKind == "3") //范围匹配
  521. {
  522. string[] val = fieldQueryValue.Split(':');
  523. if(fieldQueryModel == "request_param")
  524. {
  525. Dictionary<string, string> req = getRequestParams(content);
  526. if(fieldQueryValueType == "number")
  527. {
  528. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
  529. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
  530. }
  531. else
  532. {
  533. if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
  534. if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
  535. }
  536. }
  537. else if(fieldQueryModel == "fixed_value")
  538. {
  539. if(fieldQueryValueType == "number")
  540. {
  541. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
  542. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
  543. }
  544. else
  545. {
  546. if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + val[0] + "'";
  547. if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + val[1] + "'";
  548. }
  549. }
  550. }
  551. else if(fieldQueryKind == "4") //取反匹配
  552. {
  553. condi += " and " + fieldEnName + "!=";
  554. string val = "";
  555. if(fieldQueryModel == "request_param")
  556. {
  557. Dictionary<string, string> req = getRequestParams(content);
  558. val = req[fieldQueryValue];
  559. }
  560. else if(fieldQueryModel == "fixed_value")
  561. {
  562. val = fieldQueryValue;
  563. }
  564. if(fieldQueryValueType == "text")
  565. {
  566. val = "'" + val + "'";
  567. }
  568. condi += val;
  569. }
  570. }
  571. if(prizeInTable.excuteKind == "add") db.Insertable(doFields).ExecuteCommand();
  572. if(prizeInTable.excuteKind == "update") db.Updateable(doFields).Where("1=1" + condi).ExecuteCommand();
  573. }
  574. }
  575. //固定值表达式
  576. public static string GetExpressionVal(string str)
  577. {
  578. if(str == "#{now}#") str = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  579. if(str == "#{today}#") str = DateTime.Now.ToString("yyyy-MM-dd");
  580. if(str == "#{this_month}#") str = DateTime.Now.ToString("yyyy-MM");
  581. 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");
  582. 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");
  583. if(str.StartsWith("#{today") && str.EndsWith("DAY}#")) str = DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd");
  584. if(str.StartsWith("#{today") && str.EndsWith("MONTH}#")) str = DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd");
  585. if(str.StartsWith("#{this_month") && str.EndsWith("DAY}#")) str = DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM");
  586. if(str.StartsWith("#{this_month") && str.EndsWith("MONTH}#")) str = DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM");
  587. return str;
  588. }
  589. }
  590. }