JsonMapper.cs 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529
  1. using Newtonsoft.Json;
  2. using Newtonsoft.Json.Linq;
  3. using PTMedicalInsurance.Common;
  4. using PTMedicalInsurance.Variables;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.IO;
  8. using System.Reflection;
  9. namespace PTMedicalInsurance.Helper
  10. {
  11. /// <summary>
  12. /// 将json转换为实体对象
  13. /// </summary>
  14. public class JsonMapper
  15. {
  16. const string ArrayPattern = "[]";
  17. private string jsonConfig;
  18. private string configFile;
  19. private JsonMappingSetting setting;
  20. public JsonMapper(string name)
  21. {
  22. configFile = Global.curEvt.path + "/config/" + name + ".json";
  23. reload();
  24. }
  25. public void reload()
  26. {
  27. // 加载字段映射配置
  28. if (File.Exists(configFile))
  29. {
  30. jsonConfig = File.ReadAllText(configFile);
  31. setting = JsonHelper.toObject<JsonMappingSetting>(JObject.Parse(jsonConfig));
  32. }
  33. else
  34. {
  35. setting = new JsonMappingSetting();
  36. }
  37. }
  38. /// <summary>
  39. /// 获取入参映射
  40. /// </summary>
  41. /// <returns></returns>
  42. public List<FieldMapping> GetInputMapping()
  43. {
  44. return setting.Input??new List<FieldMapping>();
  45. }
  46. /// <summary>
  47. /// 设置入参
  48. /// </summary>
  49. /// <param name="value"></param>
  50. public void SetInputMapping(List<FieldMapping> value)
  51. {
  52. setting.Input = value;
  53. }
  54. /// <summary>
  55. /// 获取出参映射
  56. /// </summary>
  57. /// <returns></returns>
  58. public List<FieldMapping> GetOutputMapping()
  59. {
  60. return setting.Output ?? new List<FieldMapping>();
  61. }
  62. /// <summary>
  63. /// 设置出参
  64. /// </summary>
  65. /// <param name="value"></param>
  66. public void SetOutputMapping(List<FieldMapping> value)
  67. {
  68. setting.Output = value;
  69. }
  70. /// <summary>
  71. /// 获取转换类
  72. /// </summary>
  73. /// <returns></returns>
  74. private ConvertMapping GetConverter()
  75. {
  76. return setting.Convert??new ConvertMapping();
  77. }
  78. /// <summary>
  79. /// 根据实体类获取Json
  80. /// </summary>
  81. /// <param name="typeName"></param>
  82. /// <returns></returns>
  83. private string GetConvertJson(string typeName)
  84. {
  85. if (!string.IsNullOrEmpty(typeName))
  86. {
  87. if (typeName.IndexOf(".")<1)
  88. {
  89. typeName = "PTMedicalInsurance.Entity.Local." + typeName;
  90. }
  91. Type type = Type.GetType(typeName);
  92. if (type != null)
  93. {
  94. Object obj = Activator.CreateInstance(type);
  95. return JsonHelper.toJsonString(obj, false);
  96. }
  97. }
  98. return string.Empty;
  99. }
  100. /// <summary>
  101. /// 将参数方向对调
  102. /// </summary>
  103. public void ChangeDirection(List<FieldMapping> mappings)
  104. {
  105. mappings.ForEach((map) =>
  106. {
  107. if (!string.IsNullOrEmpty(map.Source) && !string.IsNullOrEmpty(map.Target))
  108. {
  109. string orgin = map.Target;
  110. map.Target = map.Source;
  111. map.Source = orgin;
  112. }
  113. });
  114. }
  115. /// <summary>
  116. /// 入参实例JSON
  117. /// </summary>
  118. /// <returns></returns>
  119. public string GetInputJson()
  120. {
  121. return GetConvertJson(GetConverter()?.Input);
  122. }
  123. /// <summary>
  124. /// 出参实例JSON
  125. /// </summary>
  126. /// <returns></returns>
  127. public string GetOutputJson()
  128. {
  129. return GetConvertJson(GetConverter()?.Output);
  130. }
  131. /// <summary>
  132. /// Json字段映射
  133. /// </summary>
  134. /// <param name="jObject"></param>
  135. /// <returns></returns>
  136. private JObject MapJson(string key,JObject jSource)
  137. {
  138. JObject jObject = new JObject();
  139. if(string.IsNullOrEmpty(jsonConfig) || string.IsNullOrEmpty(key))
  140. {
  141. return jSource;
  142. }
  143. List<FieldMapping> fieldMappings = "input".Equals(key) ? GetInputMapping() : GetOutputMapping() ;
  144. if (fieldMappings != null)
  145. {
  146. // 对于每一个字段映射信息
  147. foreach (var fieldMapping in fieldMappings)
  148. {
  149. // 使用JToken.SelectToken来获取源路径对应的值
  150. dynamic value = new JValue("");
  151. string nameKey = fieldMapping.Source;
  152. string expression = fieldMapping.Expression;
  153. if (!string.IsNullOrEmpty(nameKey))
  154. {
  155. nameKey = nameKey.Split(",".ToCharArray())[0]; //多对一忽略后面的
  156. if (fieldMapping.Child != null)
  157. {
  158. //数组映射
  159. nameKey = nameKey.Replace(ArrayPattern, "");
  160. }
  161. else
  162. {
  163. if (nameKey.Contains(ArrayPattern))
  164. {
  165. //数组映射对象时,取第一个
  166. nameKey = nameKey.Replace(ArrayPattern, "[0]");
  167. }
  168. }
  169. value = jSource.SelectToken(nameKey);
  170. }
  171. else if (fieldMapping.Value != null)
  172. {
  173. // 支持固定值
  174. value = new JValue(fieldMapping.Value);
  175. }
  176. // 表达式(全局变量)
  177. if ((expression ?? "").Equals("GlobaVariables"))
  178. {
  179. value = GetExpressionValue(expression, fieldMapping.Source);
  180. expression = null;
  181. }
  182. // 表达式(扩展字段)
  183. if ((expression ?? "").Equals("SaveToExpand"))
  184. {
  185. SetExpression(expression, fieldMapping.Source, value);
  186. continue;
  187. }
  188. if ((expression ?? "").Equals("ConvertToString"))
  189. {
  190. value = GetExpressionValue(expression,value);
  191. expression = null;
  192. }
  193. // 普通转换
  194. if (value != null)
  195. {
  196. if (fieldMapping.Child != null)
  197. {
  198. //数组映射,此时的value为array
  199. var items = new JArray();
  200. foreach (var item in (JArray)value)
  201. {
  202. var child = MapChildItem((JObject)item, fieldMapping.Child);
  203. items.Add(child);
  204. }
  205. CreateJObjectFromString(jObject, fieldMapping.Target.Replace(ArrayPattern,""), items, 0);
  206. }
  207. else
  208. {
  209. ParseAndMap(value, jObject, nameKey, fieldMapping.Target, expression);
  210. }
  211. }
  212. }
  213. }
  214. return jObject;
  215. }
  216. private JObject MapChildItem(JObject itemObject, List<FieldMapping> childs)
  217. {
  218. JObject newItem = new JObject();
  219. foreach (FieldMapping subMapping in childs)
  220. {
  221. if (!string.IsNullOrEmpty(subMapping.Value))
  222. {
  223. newItem[subMapping.Target] = subMapping.Value;
  224. }
  225. else
  226. {
  227. newItem[subMapping.Target] = itemObject[subMapping.Source];
  228. }
  229. }
  230. return newItem;
  231. }
  232. /// <summary>
  233. /// 映射实体
  234. /// </summary>
  235. /// <typeparam name="TSource">源对象</typeparam>
  236. /// <typeparam name="TTarget">目标对象</typeparam>
  237. /// <param name="name">名称</param>
  238. /// <param name="sourceItem">源数据</param>
  239. /// <returns></returns>
  240. public TTarget Map<TSource, TTarget>(string key, TSource sourceItem)
  241. {
  242. var json = JsonConvert.SerializeObject(sourceItem);
  243. var jObject = JObject.Parse(json);
  244. // 映射
  245. JObject jRet = MapJson(key,jObject);
  246. // 然后将修改后的JObject再转化到目标类型的对象
  247. var targetItem = jRet.ToObject<TTarget>();
  248. return targetItem;
  249. }
  250. /// <summary>
  251. /// 解析对象后转换为JObject
  252. /// </summary>
  253. /// <typeparam name="TSource"></typeparam>
  254. /// <typeparam name="TTarget"></typeparam>
  255. /// <param name="sourceItem"></param>
  256. /// <returns></returns>
  257. //[Obsolete("建议使用Map方法")]
  258. private JObject MapObject<TSource, TTarget>(string key,TSource sourceItem)
  259. {
  260. TTarget target = Map<TSource, TTarget>(key,sourceItem);
  261. var json = JsonConvert.SerializeObject(target);
  262. return JObject.Parse(json);
  263. }
  264. /// <summary>
  265. /// 入参映射
  266. /// </summary>
  267. /// <typeparam name="TSource"></typeparam>
  268. /// <typeparam name="TTarget"></typeparam>
  269. /// <param name="sourceItem"></param>
  270. /// <returns></returns>
  271. public JObject MapRequest<TSource, TTarget>(TSource sourceItem)
  272. {
  273. TTarget target = Map<TSource, TTarget>("input",sourceItem);
  274. var json = JsonConvert.SerializeObject(target);
  275. return JObject.Parse(json);
  276. }
  277. /// <summary>
  278. /// 出参映射
  279. /// </summary>
  280. /// <typeparam name="TSource"></typeparam>
  281. /// <typeparam name="TTarget"></typeparam>
  282. /// <param name="sourceItem"></param>
  283. /// <returns></returns>
  284. public JObject MapResponse<TSource, TTarget>(TSource sourceItem)
  285. {
  286. TTarget target = Map<TSource, TTarget>("output", sourceItem);
  287. var json = JsonConvert.SerializeObject(target);
  288. return JObject.Parse(json);
  289. }
  290. /// <summary>
  291. /// 解析并映射字段
  292. /// </summary>
  293. /// <param name="sourceToken"></param>
  294. /// <param name="targetObject"></param>
  295. /// <param name="sourcePath"></param>
  296. /// <param name="targetPath"></param>
  297. private void ParseAndMap(JToken sourceToken, JObject targetObject, string sourcePath, string targetPath, string expression = "")
  298. {
  299. // 支持映射多个字段
  300. var targetFields = targetPath.Split(',');
  301. foreach (var targetField in targetFields) {
  302. //if (!sourceToken.HasValues && string.IsNullOrEmpty(sourceToken.Value<string>())) continue;
  303. ParseAndMapField(sourceToken, targetObject, sourcePath, targetField, expression);
  304. }
  305. }
  306. /// <summary>
  307. /// 解析并映射单个字段
  308. /// </summary>
  309. /// <param name="sourceToken"></param>
  310. /// <param name="targetObject"></param>
  311. /// <param name="sourcePath"></param>
  312. /// <param name="targetPath"></param>
  313. private void ParseAndMapField(JToken value, JObject targetObject, string sourcePath, string targetPath, string expression = "")
  314. {
  315. if (string.IsNullOrEmpty(targetPath)) return;
  316. if (sourcePath !=null && sourcePath.StartsWith(".")) { sourcePath = sourcePath.Substring(1); }
  317. if (targetPath.StartsWith(".")) { targetPath = targetPath.Substring(1); }
  318. var targetTokens = targetPath.Split('.');
  319. var remainingTargetPath = string.Join(".", targetTokens, 0, targetTokens.Length - 1);
  320. var isArray = remainingTargetPath.Contains(ArrayPattern);
  321. var remainingTargetTokens = remainingTargetPath.Split(ArrayPattern.ToCharArray());
  322. //var value = sourceToken.SelectToken(sourcePath);
  323. // 抵达路径顶点
  324. if (targetTokens.Length == 1)
  325. {
  326. targetObject.Add(targetTokens[0], value);
  327. return;
  328. }
  329. // 处理数组类型的映射
  330. if (isArray)
  331. {
  332. if (value is JValue) {
  333. // 将固定数据给数组中的第一个对象
  334. var newItem = (targetObject[targetTokens[0]] ?? new JObject()) as JObject;
  335. CreateJObjectFromString(newItem, targetPath, (JValue)value,1,expression);
  336. targetObject[targetTokens[0]] = newItem;
  337. }
  338. //if (value is JArray)
  339. //{
  340. // string[] childPath = sourcePath.Split(ArrayPattern.ToCharArray());
  341. // string[] destPath = targetPath.Split(ArrayPattern.ToCharArray());
  342. // string arrayKey = targetTokens[0].Split(ArrayPattern.ToCharArray())[0];
  343. // var newItem = (targetObject[arrayKey] ?? new JArray()) as JArray;
  344. // //CreateJObjectFromString(newItem, targetPath, null,0);
  345. // foreach (var item in ((JArray)value).Children<JObject>())
  346. // {
  347. // var childItem = new JObject();
  348. // ParseAndMapField(item.SelectToken(childPath[2].Substring(1)), childItem, childPath[2], destPath[2]); // 递归处理嵌套路径
  349. // newItem.Add(childItem);
  350. // }
  351. // targetObject[arrayKey] = newItem;
  352. //}
  353. }
  354. else if (targetTokens.Length > 1) {
  355. // 对象层级
  356. string nameKey = targetTokens[0];
  357. int index = 1; //不包含根节点
  358. if (nameKey.Contains("[]"))
  359. {
  360. nameKey = nameKey.Substring(0, nameKey.Length - 2);
  361. index = 0;
  362. }
  363. var newItem = (targetObject[nameKey] ?? new JObject()) as JObject;
  364. CreateJObjectFromString(newItem,targetPath,(JValue)value, index, expression);
  365. targetObject[nameKey] = newItem;
  366. }
  367. else // 普通嵌套映射
  368. {
  369. var newItem = new JObject();
  370. ParseAndMapField(value, newItem, sourcePath, remainingTargetPath); // 递归处理嵌套路径
  371. targetObject.Add(targetTokens[0], newItem);
  372. }
  373. targetObject.Remove(sourcePath);
  374. }
  375. /// <summary>
  376. /// 根据层级创建对象
  377. /// </summary>
  378. /// <param name="current"></param>
  379. /// <param name="input"></param>
  380. /// <param name="value"></param>
  381. /// <returns></returns>
  382. private JObject CreateJObjectFromString(JObject current, string input,JToken value,int index = 1,string expression = "")
  383. {
  384. var keys = input.Split('.');
  385. JObject root = current;
  386. for (int i = index; i < keys.Length - 1; i++)
  387. {
  388. if (keys[i].EndsWith("[]"))
  389. {
  390. string actualKey = keys[i].Substring(0, keys[i].Length - 2);
  391. if (current[actualKey] == null)
  392. {
  393. current[actualKey] = new JArray { new JObject() };
  394. }
  395. // 数组的某一条
  396. current = (JObject)((JArray)current[actualKey]).Last; ;
  397. }
  398. else
  399. {
  400. if (current[keys[i]] == null)
  401. {
  402. current[keys[i]] = new JObject();
  403. }
  404. current = (JObject)current[keys[i]];
  405. }
  406. }
  407. if (!string.IsNullOrEmpty(expression)) {
  408. value = GetExpressionValue(expression, value);
  409. }
  410. current[keys[keys.Length - 1]] = value;
  411. return root;
  412. }
  413. private void SetExpression(string method, string key,object value)
  414. {
  415. try
  416. {
  417. Type type = typeof(ExpressionEvaluator);
  418. MethodInfo mi = type.GetMethod(method);
  419. if (mi != null)
  420. {
  421. mi.Invoke(null, new object[] {key,value });
  422. }
  423. }
  424. catch (Exception e)
  425. { }
  426. }
  427. private string GetExpressionValue(string method,object value)
  428. {
  429. object objRtn = null;
  430. try
  431. {
  432. Type type = typeof(ExpressionEvaluator);
  433. MethodInfo mi = type.GetMethod(method);
  434. if (mi != null)
  435. {
  436. objRtn = mi.Invoke(null, new object[] { value });
  437. }
  438. }
  439. catch (Exception e)
  440. { }
  441. return objRtn?.ToString();
  442. }
  443. /// <summary>
  444. /// 保存配置
  445. /// </summary>
  446. public void Save()
  447. {
  448. jsonConfig = JsonHelper.toJsonString(this.setting);
  449. if(!string.IsNullOrEmpty(jsonConfig) && !string.IsNullOrEmpty(configFile))
  450. {
  451. File.WriteAllText(configFile,jsonConfig);
  452. }
  453. }
  454. }
  455. public class JsonMappingSetting
  456. {
  457. public List<FieldMapping> Input { set; get; }
  458. public List<FieldMapping> Output { set; get; }
  459. public ConvertMapping Convert { set; get; }
  460. }
  461. public class FieldMapping
  462. {
  463. public string Source { get; set; }
  464. public string Target { get; set; }
  465. public string Value { get; set; }
  466. public string Expression { set; get; }
  467. public List<FieldMapping> Child { get; set; }
  468. public FieldMapping()
  469. { }
  470. }
  471. public class ConvertMapping
  472. {
  473. public string Input { set; get; }
  474. public string Output { set; get; }
  475. }
  476. }