ElementChemistryDB.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325
  1. using OTSCLRINTERFACE;
  2. using OTSDataType;
  3. using OTSModelSharp.DTLBase;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Data;
  7. using System.Linq;
  8. using System.Text;
  9. using System.Threading.Tasks;
  10. namespace OTSModelSharp.DTLBase
  11. {
  12. public class CElementChemistryDB : CSQLiteDB
  13. {
  14. List<CPosXrayClr> m_listPosXrayInfo = new List<CPosXrayClr>();
  15. public CElementChemistryDB(IDBStoreBase _conStr, IDBTableBase _table):base(_conStr,_table)
  16. {
  17. }
  18. public System.Data.DataTable GetQueryById( long a_nXrayId, long a_nFieldId, long a_nElementId, long a_nElementSize)
  19. {
  20. var datastorePtr = GetDatastore();
  21. var tableInfoPtr = GetTableInfo();
  22. var sXrayIdColumnName = tableInfoPtr.GetColumnName((int)CElementChemistryTable.ColumnID.N_XRAY_INDEX - (int)CElementChemistryTable.ColumnID.MIN);
  23. var sFieldIdColumnName = tableInfoPtr.GetColumnName((int)CElementChemistryTable.ColumnID.N_FIELD_ID - (int)CElementChemistryTable.ColumnID.MIN);
  24. var sElementIdColumnName = tableInfoPtr.GetColumnName((int)CElementChemistryTable.ColumnID.N_ELEMENT_ID - (int)CElementChemistryTable.ColumnID.MIN);
  25. var sElementNumColumnName = tableInfoPtr.GetColumnName((int)CElementChemistryTable.ColumnID.N_ELEMENT_TOTAL - (int)CElementChemistryTable.ColumnID.MIN);
  26. String sSQLCommand= String.Format("SELECT * FROM \'{0}\' WHERE {1} = {2} AND {3} ={4} AND {5} ={6} AND {7} = {8};", (String)tableInfoPtr.GetTableName(), sFieldIdColumnName,
  27. a_nFieldId, sXrayIdColumnName, a_nXrayId,sElementIdColumnName, a_nElementId,sElementNumColumnName, a_nElementSize);
  28. var q=datastorePtr.QueryByCmdForDataTable(sSQLCommand);
  29. return q;
  30. }
  31. public List< CPosXrayClr> GetXrayInfoList( bool a_bForce/* = FALSE*/)
  32. {
  33. if (a_bForce)
  34. {
  35. m_listPosXrayInfo.Clear();
  36. }
  37. if (m_listPosXrayInfo.Count == 0)
  38. {
  39. ReadXrayPointInfoList();
  40. }
  41. return m_listPosXrayInfo;
  42. }
  43. public bool ReadXrayPointInfoList()
  44. {
  45. var tableInfoPtr = GetTableInfo();
  46. var query = GetTableQueryForDataTable("");
  47. m_listPosXrayInfo = ReadXrayPointInfoList(query);
  48. return true;
  49. }
  50. public bool SaveElementChemistriesList(List<CPosXrayClr> a_xrayPointList)
  51. {
  52. var tableInfoPtr = GetTableInfo();
  53. var datastorePtr = GetDatastore();
  54. String sInsertFormat = tableInfoPtr.GetInsertCommandFormatString();
  55. String sSQLCommand = "";
  56. foreach (var xrayPointInfo in a_xrayPointList)
  57. {
  58. List<CElementChemistryClr> listElemnentChemistries = xrayPointInfo.GetElementQuantifyData();
  59. int nSize = (int)listElemnentChemistries.Count;
  60. int nElementIndex = 0;
  61. foreach (var pElementChemistry in listElemnentChemistries)
  62. {
  63. sSQLCommand= String.Format(sInsertFormat,
  64. xrayPointInfo.GetIndex(),
  65. xrayPointInfo.GetScanFieldId(),
  66. nElementIndex,
  67. nSize,
  68. pElementChemistry.GetName(),
  69. pElementChemistry.GetPercentage());
  70. //var helper = new SQLiteHelper(datastorePtr);
  71. if (datastorePtr.RunCommand(sSQLCommand) != true)
  72. {
  73. return false;
  74. }
  75. nElementIndex++;
  76. }
  77. }
  78. return true;
  79. }
  80. public bool SaveElementChemistriesList( CPosXrayClr a_pxrayPoint)
  81. {
  82. var tableInfoPtr = GetTableInfo();
  83. var datastorePtr = GetDatastore();
  84. String sInsertFormat = tableInfoPtr.GetInsertCommandFormatString();
  85. String sSQLCommand = "";
  86. List<CElementChemistryClr >listElemnentChemistries = a_pxrayPoint.GetElementQuantifyData();
  87. int nSize = (int)listElemnentChemistries.Count;
  88. int nElementIndex = 0;
  89. foreach (var pElementChemistry in listElemnentChemistries)
  90. {
  91. sSQLCommand=String.Format(sInsertFormat,
  92. a_pxrayPoint.GetIndex(),
  93. a_pxrayPoint.GetScanFieldId(),
  94. nElementIndex,
  95. nSize,
  96. pElementChemistry.GetName(),
  97. pElementChemistry.GetPercentage(),
  98. pElementChemistry.GetMolarPercentage());
  99. if (datastorePtr.RunCommand(sSQLCommand) != true)
  100. {
  101. return false;
  102. }
  103. nElementIndex++;
  104. }
  105. return true;
  106. }
  107. public List<string> GetSavingElementChemistriesCmds(CPosXrayClr a_pxrayPoint)
  108. {
  109. List<string> cmds = new List<string>();
  110. var tableInfoPtr = GetTableInfo();
  111. var datastorePtr = GetDatastore();
  112. String sInsertFormat = tableInfoPtr.GetInsertCommandFormatString();
  113. String sSQLCommand = "";
  114. List<CElementChemistryClr> listElemnentChemistries = a_pxrayPoint.GetElementQuantifyData();
  115. int nSize = (int)listElemnentChemistries.Count;
  116. int nElementIndex = 0;
  117. foreach (var pElementChemistry in listElemnentChemistries)
  118. {
  119. sSQLCommand = String.Format(sInsertFormat,
  120. a_pxrayPoint.GetIndex(),
  121. a_pxrayPoint.GetScanFieldId(),
  122. nElementIndex,
  123. nSize,
  124. pElementChemistry.GetName(),
  125. pElementChemistry.GetPercentage(),
  126. pElementChemistry.GetMolarPercentage());
  127. cmds.Add(sSQLCommand);
  128. nElementIndex++;
  129. }
  130. return cmds;
  131. }
  132. public bool DeleteElementChemistryById(long a_nFieldId, long a_nXrayId)
  133. {
  134. if (m_listPosXrayInfo.Count != 0)
  135. {
  136. for (int itr = 0; itr < m_listPosXrayInfo.Count; itr++)
  137. {
  138. if (m_listPosXrayInfo[itr].ToString() == a_nFieldId.ToString())
  139. {
  140. CPosXrayClr posXrayInfo = new CPosXrayClr();
  141. posXrayInfo = m_listPosXrayInfo[itr];
  142. break;
  143. }
  144. }
  145. }
  146. DataTable query;
  147. var tableInfoPtr = GetTableInfo();
  148. var datastorePtr = GetDatastore();
  149. String sTableName = tableInfoPtr.GetTableName();
  150. if (IsTableExists(sTableName))
  151. {
  152. var sXrayIdColumnName = tableInfoPtr.GetColumnName((int)CElementChemistryTable.ColumnID.N_XRAY_INDEX - (int)CElementChemistryTable.ColumnID.MIN);
  153. var sFieldIdColumnName = tableInfoPtr.GetColumnName((int)CElementChemistryTable.ColumnID.N_FIELD_ID - (int)CElementChemistryTable.ColumnID.MIN);
  154. String sSQLCommand =
  155. String.Format("DELETE FROM \'{0}\' WHERE {1} = {2} AND {3} ={4};",
  156. sTableName,
  157. sXrayIdColumnName,
  158. a_nXrayId,
  159. sFieldIdColumnName,
  160. a_nFieldId);
  161. //var helper = new SQLiteHelper(datastorePtr);
  162. datastorePtr.RunCommand(sSQLCommand);
  163. }
  164. return true;
  165. }
  166. public bool IsTableExists(String a_sTableName)
  167. {
  168. return IsDBExist();
  169. }
  170. public List<CPosXrayClr> ReadXrayPointInfoList(DataTable a_query)
  171. {
  172. List<CPosXrayClr> xrayList = new List<CPosXrayClr>();
  173. Dictionary<string, CPosXrayClr> mapXrayInfo = new Dictionary<string, CPosXrayClr>();
  174. foreach (DataRow row in a_query.Rows)
  175. {
  176. int nCol = (int)CElementChemistryTable.ColumnID.N_FIELD_ID- (int)CElementChemistryTable.ColumnID.MIN;
  177. int curFldId = Convert.ToInt32(row[nCol]);
  178. nCol = (int)CElementChemistryTable.ColumnID.N_XRAY_INDEX - (int)CElementChemistryTable.ColumnID.MIN;
  179. int xrayId = Convert.ToInt32(row[nCol]);
  180. string fldvec = "";
  181. fldvec+=curFldId.ToString();
  182. fldvec += "_";
  183. fldvec += xrayId.ToString();
  184. nCol = (int)CElementChemistryTable.ColumnID.S_NAME - (int)CElementChemistryTable.ColumnID.MIN;
  185. string cheName = Convert.ToString(row[nCol]);
  186. nCol = (int)CElementChemistryTable.ColumnID.F_PERCENTAGE - (int)CElementChemistryTable.ColumnID.MIN;
  187. double percentage = Convert.ToDouble(row[nCol]);
  188. CElementChemistryClr che = new CElementChemistryClr(cheName,percentage);
  189. if (!mapXrayInfo.ContainsKey(fldvec))
  190. {
  191. CPosXrayClr xray = new CPosXrayClr();
  192. xray.AddQuantifyElement(che);
  193. mapXrayInfo.Add(fldvec, xray);
  194. }
  195. else
  196. {
  197. CPosXrayClr xray = mapXrayInfo[fldvec];
  198. xray.AddQuantifyElement(che);
  199. }
  200. }
  201. foreach (var keyvalue in mapXrayInfo)
  202. {
  203. xrayList.Add(keyvalue.Value);
  204. }
  205. return xrayList;
  206. }
  207. public bool GetAllMapedXrayInfo(ref Dictionary<string, CPosXrayClr> mapXrayInfo)
  208. {
  209. DataTable a_query = GetTableQueryForDataTable();
  210. //Dictionary<string, CPosXrayClr> mapXrayInfo = new Dictionary<string, CPosXrayClr>();
  211. foreach (DataRow row in a_query.Rows)
  212. {
  213. int nCol = (int)CElementChemistryTable.ColumnID.N_FIELD_ID - (int)CElementChemistryTable.ColumnID.MIN;
  214. int curFldId = Convert.ToInt32(row[nCol]);
  215. nCol = (int)CElementChemistryTable.ColumnID.N_XRAY_INDEX - (int)CElementChemistryTable.ColumnID.MIN;
  216. int xrayId = Convert.ToInt32(row[nCol]);
  217. string fldvec = "";
  218. fldvec += curFldId.ToString();
  219. fldvec += "_";
  220. fldvec += xrayId.ToString();
  221. nCol = (int)CElementChemistryTable.ColumnID.S_NAME - (int)CElementChemistryTable.ColumnID.MIN;
  222. string cheName = Convert.ToString(row[nCol]);
  223. nCol = (int)CElementChemistryTable.ColumnID.F_PERCENTAGE - (int)CElementChemistryTable.ColumnID.MIN;
  224. double percentage = Convert.ToDouble(row[nCol]);
  225. CElementChemistryClr che = new CElementChemistryClr(cheName, percentage);
  226. if (!mapXrayInfo.ContainsKey(fldvec))
  227. {
  228. CPosXrayClr xray = new CPosXrayClr();
  229. xray.AddQuantifyElement(che);
  230. mapXrayInfo.Add(fldvec, xray);
  231. }
  232. else
  233. {
  234. CPosXrayClr xray = mapXrayInfo[fldvec];
  235. xray.AddQuantifyElement(che);
  236. }
  237. }
  238. return true;
  239. }
  240. }
  241. }