WaferHistoryDBViewModel.cs 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615
  1. using Prism.Mvvm;
  2. using System;
  3. using Prism.Commands;
  4. using System.Collections.Generic;
  5. using System.Linq;
  6. using System.Text;
  7. using System.Threading.Tasks;
  8. using Venus_MainPages.Views;
  9. using MECF.Framework.Common.CommonData;
  10. using System.Collections.ObjectModel;
  11. using Xceed.Wpf.Toolkit.Primitives;
  12. using Venus_MainPages.Unity;
  13. using System.Windows;
  14. using MECF.Framework.Common.DataCenter;
  15. using System.Data;
  16. using System.ComponentModel;
  17. using OpenSEMI.Ctrlib.Controls;
  18. using Venus_Core;
  19. using RecipeStep = MECF.Framework.Common.CommonData.RecipeStep;
  20. namespace Venus_MainPages.ViewModels
  21. {
  22. public class WaferHistoryDBViewModel:BindableBase
  23. {
  24. private ObservableCollection<WaferHistoryMovement> _movements = new ObservableCollection<WaferHistoryMovement>();
  25. public ObservableCollection<WaferHistoryMovement> Movements
  26. {
  27. get { return _movements; }
  28. set { SetProperty(ref _movements, value); }
  29. }
  30. private WaferHistoryItem _selectedItem;
  31. public WaferHistoryItem SelectedItem
  32. {
  33. get { return _selectedItem; }
  34. set { SetProperty(ref _selectedItem, value); }
  35. }
  36. private DateTime _searchBeginTime;
  37. public DateTime SearchBeginTime
  38. {
  39. get { return _searchBeginTime; }
  40. set { SetProperty(ref _searchBeginTime, value); }
  41. }
  42. private ObservableCollection<WaferHistoryLot> _lots = new ObservableCollection<WaferHistoryLot>();
  43. public ObservableCollection<WaferHistoryLot> Lots
  44. {
  45. get { return _lots; }
  46. set { SetProperty(ref _lots, value); }
  47. }
  48. public ObservableCollection<WaferHistoryRecipe> _recipes = new ObservableCollection<WaferHistoryRecipe>();
  49. public ObservableCollection<WaferHistoryRecipe> Recipes
  50. {
  51. get { return _recipes; }
  52. set { SetProperty(ref _recipes, value); }
  53. }
  54. private WaferHistoryRecipe _recipe;
  55. public WaferHistoryRecipe Recipe
  56. {
  57. get { return _recipe; }
  58. set { SetProperty(ref _recipe, value); }
  59. }
  60. private ObservableCollection<LazyTreeItem<WaferHistoryItem>> _historyData;
  61. public ObservableCollection<LazyTreeItem<WaferHistoryItem>> HistoryData
  62. {
  63. get { return _historyData; }
  64. set { SetProperty(ref _historyData, value); }
  65. }
  66. private ObservableCollection<WaferHistoryWafer> _wafers = new ObservableCollection<WaferHistoryWafer>();
  67. public ObservableCollection<WaferHistoryWafer> Wafers
  68. {
  69. get { return _wafers; }
  70. set { SetProperty(ref _wafers, value); }
  71. }
  72. private DateTime _searchEndTime;
  73. public DateTime SearchEndTime
  74. {
  75. get { return _searchEndTime; }
  76. set { SetProperty(ref _searchEndTime, value); }
  77. }
  78. private string keyWord;
  79. public string KeyWord
  80. {
  81. get { return keyWord; }
  82. set { SetProperty(ref keyWord, value); }
  83. }
  84. private WaferHistoryDBView view;
  85. public DateTime StartDateTime { get; set; }
  86. public DateTime EndDateTime { get; set; }
  87. private DelegateCommand<object> _QueryCommand;
  88. public DelegateCommand<object> QueryCommand =>
  89. _QueryCommand ?? (_QueryCommand = new DelegateCommand<object>(QueryLots));
  90. private DelegateCommand<WaferHistoryItem> _SelectionChangedCommand;
  91. public DelegateCommand<WaferHistoryItem> SelectionChangedCommand =>
  92. _SelectionChangedCommand ?? (_SelectionChangedCommand = new DelegateCommand<WaferHistoryItem>(SelectionChanged));
  93. private DelegateCommand<object> _LoadCommandPD;
  94. public DelegateCommand<object> LoadCommandPD =>
  95. _LoadCommandPD ?? (_LoadCommandPD = new DelegateCommand<object>(OnLoadPd));
  96. public WaferHistoryDBViewModel()
  97. {
  98. HistoryData = new ObservableCollection<LazyTreeItem<WaferHistoryItem>>();
  99. }
  100. void QueryLots(object e)
  101. {
  102. this.SearchBeginTime = this.view.wfTimeFrom.Value;
  103. this.SearchEndTime = this.view.wfTimeTo.Value;
  104. if (SearchBeginTime > SearchEndTime)
  105. {
  106. MessageBox.Show("Time range invalid, start time should be early than end time");
  107. return;
  108. }
  109. Lots = new ObservableCollection<WaferHistoryLot>(QueryLot(SearchBeginTime, SearchEndTime, KeyWord));//.OrderByDescending(lot => lot.StartTime).ToArray();
  110. HistoryData.Clear();
  111. var lotsItem = new WaferHistoryItem() { Name = "Lots", };
  112. var root = new LazyTreeItem<WaferHistoryItem>(lotsItem, x => LoadSubItem(x));
  113. root.SubItems = new ObservableCollection<LazyTreeItem<WaferHistoryItem>>(Lots.Select(x => new LazyTreeItem<WaferHistoryItem>(new WaferHistoryItem() { ID = x.ID, Name = x.Name, StartTime = x.StartTime, EndTime = x.EndTime, Type = WaferHistoryItemType.Lot }, LoadSubItem)));
  114. root.IsExpanded = true;
  115. HistoryData.Add(root);
  116. SelectedItem = lotsItem;
  117. }
  118. private Dictionary<string, object> _mapGasNameValue = new Dictionary<string, object>();
  119. private Dictionary<string, string> _mapGasNameKey = new Dictionary<string, string>()
  120. {
  121. {"PMA.MfcGas1.GasName", "PMA.IoMfc.MfcGas1"},
  122. {"PMA.MfcGas2.GasName", "PMA.IoMfc.MfcGas2"},
  123. {"PMA.MfcGas3.GasName", "PMA.IoMfc.MfcGas3"},
  124. {"PMA.MfcGas4.GasName", "PMA.IoMfc.MfcGas4"},
  125. {"PMA.MfcGas5.GasName", "PMA.IoMfc.MfcGas5"},
  126. {"PMB.MfcGas1.GasName", "PMB.IoMfc.MfcGas1"},
  127. {"PMB.MfcGas2.GasName", "PMB.IoMfc.MfcGas2"},
  128. {"PMB.MfcGas3.GasName", "PMB.IoMfc.MfcGas3"},
  129. {"PMB.MfcGas4.GasName", "PMB.IoMfc.MfcGas4"},
  130. {"PMB.MfcGas5.GasName", "PMB.IoMfc.MfcGas5"},
  131. };
  132. //protected override void OnActivate()
  133. //{
  134. // base.OnActivate();
  135. // _mapGasNameValue = QueryDataClient.Instance.Service.PollConfig(_mapGasNameKey.Keys);
  136. //}
  137. private void SelectionChanged(WaferHistoryItem item)
  138. {
  139. switch (item.Type)
  140. {
  141. case WaferHistoryItemType.Lot:
  142. QueryLotWafer(item);
  143. break;
  144. case WaferHistoryItemType.Wafer:
  145. QueryWaferRecipe(item);
  146. QueryWaferMovement(item);
  147. break;
  148. case WaferHistoryItemType.Recipe:
  149. QueryRecipe(item);
  150. break;
  151. default:
  152. break;
  153. }
  154. SelectedItem = item;
  155. }
  156. public WaferHistoryRecipe QueryRecipe(WaferHistoryItem whItem)
  157. {
  158. WaferHistoryRecipe result = new WaferHistoryRecipe();
  159. string sql = $"SELECT * FROM \"process_data\" where \"guid\" = '{whItem.ID}'and \"process_begin_time\" >= '{whItem.StartTime:yyyy/MM/dd HH:mm:ss.fff}' and \"process_begin_time\" <= '{whItem.EndTime:yyyy/MM/dd HH:mm:ss.fff}';";
  160. //Application.Current.Dispatcher.BeginInvoke(new Action(() =>
  161. //{
  162. DataTable dbData = QueryDataClient.Instance.Service.QueryData(sql);
  163. if (dbData != null && dbData.Rows.Count > 0)
  164. {
  165. for (int i = 0; i < dbData.Rows.Count; i++)
  166. {
  167. WaferHistoryRecipe item = new WaferHistoryRecipe();
  168. item.ID = dbData.Rows[i]["guid"].ToString();
  169. var itemName = dbData.Rows[i]["recipe_name"].ToString();
  170. if (!dbData.Rows[i]["process_begin_time"].Equals(DBNull.Value))
  171. item.StartTime = (DateTime)dbData.Rows[i]["process_begin_time"];
  172. if (!dbData.Rows[i]["process_end_time"].Equals(DBNull.Value))
  173. item.EndTime = (DateTime)dbData.Rows[i]["process_end_time"];
  174. if (dbData.Rows[i].Table.Columns.Contains("recipe_setting_time") && !dbData.Rows[i]["recipe_setting_time"].Equals(DBNull.Value))
  175. item.SettingTime = dbData.Rows[i]["recipe_setting_time"].ToString();
  176. item.ActualTime = item.Duration;
  177. item.Recipe = itemName;
  178. item.Chamber = dbData.Rows[i]["process_in"].ToString();
  179. item.Name = itemName;
  180. item.Type = WaferHistoryItemType.Recipe;
  181. result = item;
  182. }
  183. }
  184. sql = $"SELECT * FROM \"recipe_step_data\" where \"process_data_guid\" = '{whItem.ID}' and \"step_begin_time\" >= '{whItem.StartTime:yyyy/MM/dd HH:mm:ss.fff}' and \"step_begin_time\" <= '{whItem.EndTime:yyyy/MM/dd HH:mm:ss.fff}' order by step_number ASC;";
  185. dbData = QueryDataClient.Instance.Service.QueryData(sql);
  186. List<RecipeStep> steps = new List<RecipeStep>();
  187. if (dbData != null && dbData.Rows.Count > 0)
  188. {
  189. for (int i = 0; i < dbData.Rows.Count; i++)
  190. {
  191. RecipeStep item = new RecipeStep();
  192. item.No = int.Parse(dbData.Rows[i]["step_number"].ToString());
  193. item.Name = dbData.Rows[i]["step_name"].ToString();
  194. if (!dbData.Rows[i]["step_begin_time"].Equals(DBNull.Value))
  195. item.StartTime = (DateTime)dbData.Rows[i]["step_begin_time"];
  196. if (!dbData.Rows[i]["step_end_time"].Equals(DBNull.Value))
  197. item.EndTime = (DateTime)dbData.Rows[i]["step_end_time"];
  198. item.ActualTime = item.EndTime.CompareTo(item.StartTime) <= 0 ? "" : item.EndTime.Subtract(item.StartTime).TotalSeconds.ToString();
  199. item.SettingTime = dbData.Rows[i]["step_time"].ToString();
  200. steps.Add(item);
  201. }
  202. }
  203. sql = $"SELECT * FROM \"step_fdc_data\" where \"process_data_guid\" = '{whItem.ID}' and \"create_time\" >= '{whItem.StartTime:yyyy/MM/dd HH:mm:ss.fff}' and \"create_time\" <= '{whItem.EndTime:yyyy/MM/dd HH:mm:ss.fff}'order by step_number ASC;";
  204. dbData = QueryDataClient.Instance.Service.QueryData(sql);
  205. List<RecipeStepFdcData> fdcs = new List<RecipeStepFdcData>();
  206. if (dbData != null && dbData.Rows.Count > 0)
  207. {
  208. for (int i = 0; i < dbData.Rows.Count; i++)
  209. {
  210. RecipeStepFdcData item = new RecipeStepFdcData();
  211. item.StepNumber = int.Parse(dbData.Rows[i]["step_number"].ToString());
  212. item.Name = dbData.Rows[i]["parameter_name"].ToString();
  213. foreach (var name in _mapGasNameKey)
  214. {
  215. if (item.Name.Contains(name.Value) && _mapGasNameValue.ContainsKey(name.Key))
  216. item.Name = item.Name.Replace(name.Value, (string)_mapGasNameValue[name.Key]);
  217. }
  218. if (!dbData.Rows[i]["sample_count"].Equals(DBNull.Value))
  219. item.SampleCount = (int)dbData.Rows[i]["sample_count"];
  220. if (!dbData.Rows[i]["setpoint"].Equals(DBNull.Value))
  221. item.SetPoint = (float)dbData.Rows[i]["setpoint"];
  222. if (!dbData.Rows[i]["min_value"].Equals(DBNull.Value))
  223. item.MinValue = (float)dbData.Rows[i]["min_value"];
  224. if (!dbData.Rows[i]["max_value"].Equals(DBNull.Value))
  225. item.MaxValue = (float)dbData.Rows[i]["max_value"];
  226. if (!dbData.Rows[i]["std_value"].Equals(DBNull.Value))
  227. item.StdValue = (float)dbData.Rows[i]["std_value"];
  228. if (!dbData.Rows[i]["mean_value"].Equals(DBNull.Value))
  229. item.MeanValue = (float)dbData.Rows[i]["mean_value"];
  230. fdcs.Add(item);
  231. }
  232. }
  233. result.Steps = steps;
  234. result.Fdcs = fdcs;
  235. Recipe = result;
  236. return result;
  237. }
  238. public List<WaferHistoryMovement> QueryWaferMovement(WaferHistoryItem whItem)
  239. {
  240. List<WaferHistoryMovement> result = new List<WaferHistoryMovement>();
  241. string sql = $"SELECT * FROM \"wafer_move_history\" where \"wafer_data_guid\" = '{whItem.ID}'and \"arrive_time\" >= '{whItem.StartTime:yyyy/MM/dd HH:mm:ss.fff}' and \"arrive_time\" <= '{whItem.EndTime:yyyy/MM/dd HH:mm:ss.fff}' order by \"arrive_time\" ASC limit 1000;";
  242. Movements.Clear();
  243. //Application.Current.Dispatcher.BeginInvoke(new Action(() =>
  244. //{
  245. DataTable dbData = QueryDataClient.Instance.Service.QueryData(sql);
  246. if (dbData != null && dbData.Rows.Count > 0)
  247. {
  248. for (int i = 0; i < dbData.Rows.Count - 1; i++)
  249. {
  250. WaferHistoryMovement item = new WaferHistoryMovement();
  251. item.Source = $"station : {dbData.Rows[i]["station"]} slot : {dbData.Rows[i]["slot"]}";
  252. item.Destination = $"station : {dbData.Rows[i + 1]["station"]} slot : {dbData.Rows[i + 1]["slot"]}";
  253. item.InTime = dbData.Rows[i]["arrive_time"].ToString();
  254. result.Add(item);
  255. Movements.Add(item);
  256. }
  257. }
  258. //}));
  259. return result;
  260. }
  261. public List<WaferHistoryWafer> QueryLotWafer(WaferHistoryItem whItem)
  262. {
  263. List<WaferHistoryWafer> result = new List<WaferHistoryWafer>();
  264. //string sql = $"select data.*,process_data.process_status from (SELECT * FROM wafer_data,lot_wafer_data where lot_wafer_data.lot_data_guid = '{lotGuid}' and lot_wafer_data.wafer_data_guid = wafer_data.guid order by wafer_data.create_time ASC; as data )" +
  265. // $" LEFT JOIN process_data ON process_data.wafer_data_guid=data.wafer_id";
  266. string sql = $"SELECT wafer_data.*,lot_wafer_data.*,process_data.process_status as status FROM wafer_data LEFT JOIN lot_wafer_data ON lot_wafer_data.wafer_data_guid = wafer_data.guid " +
  267. $"LEFT JOIN process_data ON process_data.wafer_data_guid = wafer_data.guid where lot_wafer_data.lot_data_guid = '{whItem.ID}' order by wafer_data.create_time ASC";
  268. Wafers.Clear();
  269. //Application.Current.Dispatcher.BeginInvoke(new Action(() =>
  270. //{
  271. DataTable dbData = QueryDataClient.Instance.Service.QueryData(sql);
  272. Dictionary<string, int> itemPtr = new Dictionary<string, int>();
  273. List<string> itemNameList = new List<string>();
  274. if (dbData != null && dbData.Rows.Count > 0)
  275. {
  276. for (int i = 0; i < dbData.Rows.Count; i++)
  277. {
  278. WaferHistoryWafer item = new WaferHistoryWafer();
  279. item.ID = dbData.Rows[i]["guid"].ToString();
  280. if (!itemPtr.ContainsKey(item.ID))
  281. {
  282. itemPtr.Add(item.ID, 0);
  283. }
  284. var itemLoadPort = dbData.Rows[i]["create_station"].ToString();
  285. var itemSlot = dbData.Rows[i]["create_slot"].ToString();
  286. //item.CarrierID = dbData.Rows[i]["rfid"].ToString();
  287. item.LotID = dbData.Rows[i]["lot_id"].ToString();
  288. item.SlotID = dbData.Rows[i]["create_slot"].ToString();
  289. var itemWaferID = dbData.Rows[i]["wafer_id"].ToString();
  290. item.Sequence = dbData.Rows[i]["sequence_name"].ToString();
  291. item.Status = dbData.Rows[i]["status"].ToString();
  292. sql = $"SELECT * FROM \"wafer_move_history\" where \"wafer_data_guid\" = '{item.ID}' and \"arrive_time\" >= '{whItem.StartTime:yyyy/MM/dd HH:mm:ss.fff}' and \"arrive_time\" <= '{whItem.EndTime:yyyy/MM/dd HH:mm:ss.fff}' order by \"arrive_time\" ASC limit 1000;";
  293. DataTable dbDataMovement = QueryDataClient.Instance.Service.QueryData(sql);
  294. if (dbDataMovement != null && dbDataMovement.Rows.Count >= 2 && dbDataMovement.Rows.Count > itemPtr[item.ID])
  295. {
  296. item.StartTime = (DateTime)dbDataMovement.Rows[itemPtr[item.ID]]["arrive_time"];
  297. for (int j = itemPtr[item.ID]; j < dbDataMovement.Rows.Count; j++)
  298. {
  299. if (dbDataMovement.Rows[j]["station"].ToString().StartsWith("LP"))
  300. {
  301. item.EndTime = (DateTime)dbDataMovement.Rows[j]["arrive_time"];
  302. itemPtr[item.ID] = j + 1;
  303. break;
  304. }
  305. }
  306. }
  307. else
  308. {
  309. if (!dbData.Rows[i]["create_time"].Equals(DBNull.Value))
  310. {
  311. item.StartTime = ((DateTime)dbData.Rows[i]["create_time"]);
  312. }
  313. if (!dbData.Rows[i]["delete_time"].Equals(DBNull.Value))
  314. item.EndTime = ((DateTime)dbData.Rows[i]["delete_time"]);
  315. }
  316. item.Name = $"{itemLoadPort} - {itemSlot} - {itemWaferID}";
  317. item.Type = WaferHistoryItemType.Wafer;
  318. if (!itemNameList.Contains(item.Name))
  319. {
  320. Wafers.Add(item);
  321. result.Add(item);
  322. itemNameList.Add(item.Name);
  323. }
  324. }
  325. }
  326. //}));
  327. return result;
  328. }
  329. public List<WaferHistoryRecipe> QueryWaferRecipe(WaferHistoryItem whItem)
  330. {
  331. List<WaferHistoryRecipe> result = new List<WaferHistoryRecipe>();
  332. string sql = $"SELECT * FROM \"process_data\" where \"wafer_data_guid\" = '{whItem.ID}'and \"process_begin_time\" >= '{whItem.StartTime:yyyy/MM/dd HH:mm:ss.fff}' and \"process_begin_time\" <= '{whItem.EndTime:yyyy/MM/dd HH:mm:ss.fff}' order by \"process_begin_time\" ASC;";
  333. Recipes.Clear();
  334. //Application.Current.Dispatcher.BeginInvoke(new Action(() =>
  335. //{
  336. DataTable dbData = QueryDataClient.Instance.Service.QueryData(sql);
  337. if (dbData != null && dbData.Rows.Count > 0)
  338. {
  339. for (int i = 0; i < dbData.Rows.Count; i++)
  340. {
  341. WaferHistoryRecipe item = new WaferHistoryRecipe();
  342. item.ID = dbData.Rows[i]["guid"].ToString();
  343. var itemName = dbData.Rows[i]["recipe_name"].ToString();
  344. if (!dbData.Rows[i]["process_begin_time"].Equals(DBNull.Value))
  345. item.StartTime = (DateTime)dbData.Rows[i]["process_begin_time"];
  346. if (dbData.Rows[i].Table.Columns.Contains("process_end_time") && !dbData.Rows[i]["process_end_time"].Equals(DBNull.Value))
  347. item.EndTime = (DateTime)dbData.Rows[i]["process_end_time"];
  348. if (dbData.Rows[i].Table.Columns.Contains("recipe_setting_time") && !dbData.Rows[i]["recipe_setting_time"].Equals(DBNull.Value))
  349. item.SettingTime = dbData.Rows[i]["recipe_setting_time"].ToString();
  350. item.ActualTime = item.Duration;
  351. item.Recipe = itemName;
  352. item.Chamber = dbData.Rows[i]["process_in"].ToString();
  353. item.Name = itemName;
  354. item.Type = WaferHistoryItemType.Recipe;
  355. Recipes.Add(item);
  356. result.Add(item);
  357. }
  358. }
  359. //}));
  360. return result;
  361. }
  362. public List<WaferHistoryLot> QueryLot(DateTime from, DateTime to, string key)
  363. {
  364. List<WaferHistoryLot> result = new List<WaferHistoryLot>();
  365. string sql = $"SELECT * FROM \"lot_data\" where \"start_time\" >= '{from:yyyy/MM/dd HH:mm:ss.fff}' and \"start_time\" <= '{to:yyyy/MM/dd HH:mm:ss.fff}' ";
  366. if (!string.IsNullOrWhiteSpace(key))
  367. sql += $" and lower(\"name\") like '%{key.ToLower()}%'";
  368. sql += "order by \"start_time\" ASC;";
  369. //Application.Current.Dispatcher.BeginInvoke(new Action(() =>
  370. //{
  371. DataTable dbData = QueryDataClient.Instance.Service.QueryData(sql);
  372. if (dbData != null && dbData.Rows.Count > 0)
  373. {
  374. for (int i = 0; i < dbData.Rows.Count; i++)
  375. {
  376. WaferHistoryLot item = new WaferHistoryLot();
  377. string name = dbData.Rows[i]["name"].ToString();
  378. string time = "";
  379. item.WaferCount = (int)dbData.Rows[i]["total_wafer_count"];
  380. item.ID = dbData.Rows[i]["guid"].ToString();
  381. if (!dbData.Rows[i]["start_time"].Equals(DBNull.Value))
  382. {
  383. item.StartTime = ((DateTime)dbData.Rows[i]["start_time"]);
  384. time = item.StartTime.ToString("yyyy-MM-dd HH:mm:ss");
  385. }
  386. if (!dbData.Rows[i]["end_time"].Equals(DBNull.Value))
  387. {
  388. item.EndTime = ((DateTime)dbData.Rows[i]["end_time"]);
  389. }
  390. item.InputPort = dbData.Rows[i]["input_port"].ToString();
  391. item.Name = $"{name}-{time}";
  392. item.LotID = $"{name}";
  393. result.Add(item);
  394. }
  395. }
  396. return result;
  397. }
  398. private void OnLoadPd(Object eventView)
  399. {
  400. this.view = (WaferHistoryDBView)eventView;
  401. this.view.wfTimeFrom.Value = DateTime.Today;
  402. this.view.wfTimeTo.Value = new DateTime(DateTime.Today.Year, DateTime.Today.Month, DateTime.Today.Day, 23, 59, 59, 999);
  403. }
  404. protected List<LazyTreeItem<WaferHistoryItem>> LoadSubItem(WaferHistoryItem item)
  405. {
  406. switch (item.Type)
  407. {
  408. case WaferHistoryItemType.Lot:
  409. var wafers = QueryLotWafer(item);
  410. return wafers.Select(x => new LazyTreeItem<WaferHistoryItem>(x, y => LoadSubItem(y))).OrderBy(s => s.Data.StartTime).ToList();
  411. case WaferHistoryItemType.Wafer:
  412. var recipes = QueryWaferRecipe(item);
  413. return recipes.Select(x => new LazyTreeItem<WaferHistoryItem>(x, y => LoadSubItem(y))).OrderBy(s => s.Data.StartTime).ToList();
  414. default:
  415. break;
  416. }
  417. return new List<LazyTreeItem<WaferHistoryItem>> { };
  418. }
  419. }
  420. public class LazyTreeItem<T> : INotifyPropertyChanged where T : ITreeItem<T>, new()
  421. {
  422. private LazyTreeItem<T> dummyChild;
  423. private T data;
  424. private Func<T, List<LazyTreeItem<T>>> loader;
  425. private LazyTreeItem()
  426. {
  427. data = new T();
  428. data.ID = Guid.NewGuid().ToString();
  429. }
  430. public LazyTreeItem(T data, Func<T, List<LazyTreeItem<T>>> loader)
  431. {
  432. this.data = data;
  433. this.loader = loader;
  434. dummyChild = new LazyTreeItem<T>();
  435. SubItems = new ObservableCollection<LazyTreeItem<T>>();
  436. SubItems.Add(dummyChild);
  437. }
  438. public T Data
  439. {
  440. get
  441. {
  442. return data;
  443. }
  444. }
  445. public ObservableCollection<LazyTreeItem<T>> SubItems
  446. {
  447. get; set;
  448. }
  449. private bool isExpanded;
  450. public event PropertyChangedEventHandler PropertyChanged;
  451. private void OnPropertyChanged(string name)
  452. {
  453. if (PropertyChanged != null)
  454. {
  455. PropertyChanged.Invoke(this, new PropertyChangedEventArgs(name));
  456. }
  457. }
  458. public bool HasDummyChild
  459. {
  460. get { return SubItems.Count == 1 && SubItems.First().data.ID == dummyChild.data.ID; }
  461. }
  462. public bool IsExpanded
  463. {
  464. get { return isExpanded; }
  465. set
  466. {
  467. if (value != isExpanded)
  468. {
  469. isExpanded = value;
  470. OnPropertyChanged("IsExpanded");
  471. }
  472. if (HasDummyChild)
  473. {
  474. SubItems.Remove(dummyChild);
  475. var items = loader(data);
  476. foreach (var item in items)
  477. {
  478. SubItems.Add(item);
  479. }
  480. //items.ForEachDo(x => SubItems.Add(x));
  481. }
  482. }
  483. }
  484. }
  485. }