ParticleData.cs 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980
  1. using OTSCommon.DBOperate.Model;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Data.SQLite;
  6. using System.Drawing;
  7. using System.Drawing.Imaging;
  8. using System.IO;
  9. using System.Linq;
  10. namespace OTSIncAReportApp.DataOperation.DataAccess
  11. {
  12. public class ParticleData
  13. {
  14. private SqlHelper dbHelper;
  15. public ParticleData(string path)
  16. {
  17. dbHelper = new SqlHelper("data source='" + path + "\\FIELD_FILES\\Inclusion.db'");
  18. }
  19. /// <summary>
  20. /// 获取SegmentList
  21. /// </summary>
  22. /// <param name="model">Feature</param>
  23. /// <returns></returns>
  24. public List<Particle> GetParticleList(Particle model)
  25. {
  26. //存放查询数据的数据表
  27. SQLiteParameter[] Parameter = new SQLiteParameter[1]
  28. {
  29. new SQLiteParameter("@FieldId", model.FieldId)
  30. };
  31. string sql = "select * from IncAData where Fieldid=@FieldId";
  32. DataTable DT = dbHelper.ExecuteDataTable(sql, Parameter);
  33. var result = new List<Particle>();
  34. foreach (DataRow dr in DT.Rows)
  35. {
  36. Particle item = new Particle() { };
  37. result.Add(item);
  38. }
  39. return result;
  40. }
  41. /// <summary>
  42. /// 获取ParticleListBy
  43. /// </summary>
  44. /// <param name="model">Feature</param>
  45. /// <returns></returns>
  46. public List<Particle> GetParticleListByCon(string con, string max, string min, int display)
  47. {
  48. string sqlp = "select a.* from IncAData a ";
  49. string where = " where 1=1 ";
  50. if (display == 1)
  51. {
  52. where = where + " and a.XrayId >-1 ";
  53. }
  54. if (con != "")
  55. {
  56. where = where + " and a." + con + ">" + min + " and a." + con + "<" + max;
  57. }
  58. sqlp = sqlp + where;
  59. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  60. List<Particle> listp = dbHelper.TableToList<Particle>(DT);
  61. return listp;
  62. }
  63. /// <summary>
  64. /// 获取ParticleList
  65. /// </summary>
  66. /// <param name="model">Feature</param>
  67. /// <returns></returns>
  68. public DataTable GetParticleListAndEm()
  69. {
  70. string sqlp = @"select *,
  71. (select group_concat(name||'-'||Percentage,';')
  72. from ElementChemistry where XRayId =INcAData.XRayId and fieldid=INcAData.fieldid ) as Element
  73. from INcAData where xrayid>-1";
  74. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  75. return DT;
  76. }
  77. /// <summary>
  78. /// 获取ParticleList
  79. /// </summary>
  80. /// <param name="model">Feature</param>
  81. /// <returns></returns>
  82. public DataTable GetMergedParticleInfo()
  83. {
  84. string sqlp = @"select *,
  85. (select group_concat(name||'-'||Percentage,';')
  86. from ElementChemistry where XRayId =MergedParticleInfo.XRayId and fieldid=MergedParticleInfo.fieldid ) as Element
  87. from MergedParticleInfo ";
  88. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  89. return DT;
  90. }
  91. /// <summary>
  92. /// 获取ParticleList
  93. /// </summary>
  94. /// <param name="model">Feature</param>
  95. /// <returns></returns>
  96. public DataTable GetParticleListByIncA(string con)
  97. {
  98. string sqlp = @"select TypeId,TypeName,TypeColor,count(1) as con,sum(Area) as Area,avg(" + con
  99. + ") as av,max(" + con
  100. + ") as max ";
  101. sqlp = sqlp + "from IncAData where typeid !=-1 and typeid !=4 group by TypeId";
  102. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  103. return DT;
  104. }
  105. /// <summary>
  106. /// 获取ParticleList
  107. /// </summary>
  108. /// <param name="model">Feature</param>
  109. /// <returns></returns>
  110. public DataTable GetParticleListForParticlSize(string con, string fieldAndPartic)
  111. {
  112. string sqlp = @"select TypeId,TypeName,TypeColor,count(1) as con,avg(" + con
  113. + ") as av,max(" + con
  114. + ") as max ,GroupName";
  115. sqlp = sqlp + " from IncAData where typeid !=-1 and typeid !=4";
  116. if (fieldAndPartic != "")
  117. {
  118. sqlp = sqlp + " and '" + fieldAndPartic + "' like ('%,'||fieldid||'-'||particleid||',%')";
  119. }
  120. sqlp = sqlp + " group by TypeId ";
  121. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  122. if (con == "area")
  123. {
  124. for (int i = 0; i < DT.Rows.Count; i++)
  125. {
  126. DT.Rows[i]["max"] = Math.Sqrt((double)DT.Rows[i]["max"] / Math.PI) * 2;
  127. }
  128. }
  129. return DT;
  130. }
  131. /// <summary>
  132. /// 获取ParticleList
  133. /// </summary>
  134. /// <param name="model">Feature</param>
  135. /// <returns></returns>
  136. public DataTable GetParticleListForParticlSizeID(string con, string fieldAndPartic)
  137. {
  138. string sqlp = @"select TypeId,TypeName,TypeColor,count(1) as con,avg(" + con
  139. + ") as av,max(" + con
  140. + ") as max ,GroupName ,GroupId";
  141. sqlp = sqlp + " from IncAData where typeid !=-1 and typeid !=4";
  142. if (fieldAndPartic != "")
  143. {
  144. sqlp = sqlp + " and '" + fieldAndPartic + "' like ('%,'||fieldid||'-'||particleid||',%')";
  145. }
  146. sqlp = sqlp + " group by TypeId ";
  147. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  148. if (con == "area")
  149. {
  150. for (int i = 0; i < DT.Rows.Count; i++)
  151. {
  152. DT.Rows[i]["max"] = Math.Sqrt((double)DT.Rows[i]["max"] / Math.PI) * 2;
  153. }
  154. }
  155. return DT;
  156. }
  157. /// <summary>
  158. /// 获取element含量
  159. /// </summary>
  160. /// <returns></returns>
  161. public DataTable GetElementForArea(string fieldAndPartic)
  162. {
  163. string sqlp = @"select e.name,sum(e.percentage*p.area) as earea from ElementChemistry e
  164. inner join INcAData p on e.xrayid=p.xrayid and e.fieldid = p.fieldid from IncAData where typeid !=-1 and typeid !=4";
  165. if (fieldAndPartic != "")
  166. {
  167. sqlp = sqlp + " and '" + fieldAndPartic + "' like ('%,'||p.fieldid||'-'||p.particleid||',%')";
  168. }
  169. sqlp = sqlp + " group by e.name order by sum(e.percentage*p.area) desc";
  170. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  171. return DT;
  172. }
  173. /// <summary>
  174. /// 获取element含量
  175. /// </summary>
  176. /// <returns></returns>
  177. public DataTable GetSmallElementForArea()
  178. {
  179. string sqlp = @"select e.name, sum(e.percentage*i.area) as earea from elementchemistry e inner join incadata i on e.xrayid = i.xrayid and e.fieldid = i.fieldid
  180. group by e.name order by sum(e.percentage*i.area) desc";
  181. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  182. return DT;
  183. }
  184. /// <summary>
  185. /// 获取所有Particle
  186. /// </summary>
  187. /// <returns></returns>
  188. public DataTable GetParticleAll(string fieldAndPartic)
  189. {
  190. string sqlp = @"select * from INcAData where typeid !=-1 and typeid !=4";
  191. if (fieldAndPartic != "")
  192. {
  193. sqlp = sqlp + " and '" + fieldAndPartic + "' like ('%,'||fieldid||'-'||particleid||',%')";
  194. }
  195. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  196. for (int i = 0; i < DT.Rows.Count; i++)
  197. {
  198. DT.Rows[i]["Area"] = Math.Sqrt((double)DT.Rows[i]["Area"] / Math.PI) * 2;
  199. }
  200. return DT;
  201. }
  202. public DataTable GetParticleAllforparticlelist(string fieldAndPartic)
  203. {
  204. string sqlp = @"select * from INcAData";
  205. if (fieldAndPartic != "")
  206. {
  207. sqlp = sqlp + " where '" + fieldAndPartic + "' like ('%,'||fieldid||'-'||particleid||',%')";
  208. }
  209. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  210. for (int i = 0; i < DT.Rows.Count; i++)
  211. {
  212. DT.Rows[i]["Area"] = Math.Sqrt((double)DT.Rows[i]["Area"] / Math.PI) * 2;
  213. }
  214. return DT;
  215. }
  216. /// <summary>
  217. /// 查找所有颗粒的颜色、面积、种类名称信息
  218. /// </summary>
  219. /// <returns></returns>
  220. public DataTable GetParticleTypeInformation()
  221. {
  222. string sqlp = @"select Area,TypeName,TypeColor from IncAData";
  223. DataTable dt = dbHelper.ExecuteDataTable(sqlp, null);
  224. return dt;
  225. }
  226. /// <summary>
  227. /// 查找IncaData表中所有种类
  228. /// </summary>
  229. /// <returns></returns>
  230. public DataTable GetParticleClassAll()
  231. {
  232. string sqlp = @"SELECT DISTINCT TypeName FROM IncaData";
  233. DataTable dt = dbHelper.ExecuteDataTable(sqlp, null);
  234. return dt;
  235. }
  236. /// <summary>
  237. /// 获取所有Particle
  238. /// </summary>
  239. /// <returns></returns>
  240. public DataTable GetParticleAllHaveXray(string fieldAndPartic)
  241. {
  242. string incaSql = @"select * from IncAData where typeid !=-1 and typeid !=4";
  243. if (fieldAndPartic != "")
  244. {
  245. incaSql = incaSql + " and '" + fieldAndPartic + "' like ('%,'||fieldid||'-'||particleid||',%')";
  246. }
  247. DataTable incaDT = dbHelper.ExecuteDataTable(incaSql, null);
  248. incaDT.Columns.Add("Element");
  249. DataTable dt_element = GetElementChemistry();
  250. DataTable elementchemistry = dt_element.Clone();
  251. for (int i = 0; i < dt_element.Rows.Count; i++)
  252. {
  253. if (dt_element.Rows[i]["Name"].ToString() != "Fe")
  254. {
  255. elementchemistry.Rows.Add(dt_element.Rows[i].ItemArray);
  256. }
  257. }
  258. for (int i = 0; i < incaDT.Rows.Count; i++)
  259. {
  260. string str = "XRayId = " + incaDT.Rows[i]["particleId"].ToString() + " and fieldid = " + incaDT.Rows[i]["fieldid"].ToString();
  261. DataRow[] drs = elementchemistry.Select(str);
  262. string ConcatenatedString = "";
  263. for (int j = 0; j < drs.Length; j++)
  264. {
  265. ConcatenatedString += drs[j]["name"] + "-" + ChangeDataToD(drs[j]["Percentage"].ToString()) + ';';
  266. }
  267. incaDT.Rows[i]["Element"] = ConcatenatedString;
  268. }
  269. return incaDT;
  270. }
  271. /// <summary>
  272. /// 获取所有Particle
  273. /// </summary>
  274. /// <returns></returns>
  275. public DataTable GetParticleHaveXray(string fieldAndPartic)
  276. {
  277. string sqlp = @"select *,
  278. (select group_concat(name||'-'||Percentage,';')
  279. from ElementChemistry where XRayId =INcAData.XRayId and fieldid=INcAData.fieldid ) as Element from INcAData where xrayid>-1 ";
  280. if (fieldAndPartic != "")
  281. {
  282. sqlp = sqlp + " and '" + fieldAndPartic + "' like ('%,'||fieldid||'-'||particleid||',%')";
  283. }
  284. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  285. for (int i = 0; i < DT.Rows.Count; i++)
  286. {
  287. DT.Rows[i]["Area"] = Math.Sqrt((double)DT.Rows[i]["Area"] / Math.PI) * 2;
  288. }
  289. return DT;
  290. }
  291. /// <summary>
  292. /// 获取所有Particle
  293. /// </summary>
  294. /// <returns></returns>
  295. public List<Particle> GetParticleAllList()
  296. {
  297. string sqlp = @"select * from INcAData";
  298. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  299. List<Particle> listp = dbHelper.TableToList<Particle>(DT);
  300. return listp;
  301. }
  302. /// <summary>
  303. /// 获取所有分类的面积
  304. /// </summary>
  305. /// <param name="fieldAndPartic">选择颗粒</param>
  306. /// <returns></returns>
  307. public DataTable GetAreaByAllIncA(string fieldAndPartic)
  308. {
  309. string sqlp = @"select TypeId,TypeName,sum(area) as ar,count(1) as con ,GroupName from INcAData where typeid !=-1 and typeid !=4";
  310. if (fieldAndPartic != "")
  311. {
  312. sqlp = sqlp + " and '" + fieldAndPartic + "' like ('%,'||fieldid||'-'||particleid||',%')";
  313. }
  314. sqlp = sqlp + " group by TypeId";
  315. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  316. return DT;
  317. }
  318. /// <summary>
  319. /// 获取所有大颗粒没有的小颗粒分类
  320. /// </summary>
  321. /// <param name="fieldAndPartic">选择颗粒</param>
  322. /// <returns></returns>
  323. public DataTable GetSmallParticleInfo()
  324. {
  325. string sqlp = @"select TypeId,TypeName,TypeColor,sum(area) as area,sum(ParticleQuant) as ParticleQuant from SmallParticleInfo where TypeId not in(select TypeId from INcAData) group by TypeId";
  326. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  327. return DT;
  328. }
  329. /// <summary>
  330. /// 获取不同分类的面积
  331. /// </summary>
  332. /// <param name="fieldAndPartic">选择颗粒</param>
  333. /// <returns></returns>
  334. public DataTable GetAreaByIncA(string TypeId, string fieldAndPartic)
  335. {
  336. string sqlp = @"select e.name,sum(e.percentage*p.area) as pc,p.TypeId from ElementChemistry e
  337. inner join INcAData p on e.xrayid=p.xrayid and e.fieldid = p.fieldid where p.TypeId=" + TypeId + " ";
  338. if (fieldAndPartic != "")
  339. {
  340. sqlp = sqlp + " and '" + fieldAndPartic + "' like ('%,'||p.fieldid||'-'||p.particleid||',%')";
  341. }
  342. sqlp = sqlp + " group by e.name";
  343. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  344. return DT;
  345. }
  346. public DataTable GetAreaByIncA_All()
  347. {
  348. string sqlp = @"select e.name,sum(e.percentage*p.area) as pc,p.TypeId from ElementChemistry e
  349. inner join INcAData p on e.xrayid=p.xrayid and e.fieldid = p.fieldid group by e.name ";
  350. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  351. return DT;
  352. }
  353. /// <summary>
  354. /// 获取全部的物质大类
  355. /// </summary>
  356. /// <returns></returns>
  357. public DataTable GetAllClass()
  358. {
  359. string sqlp = @"select GroupName from IncAData group by GroupName order by count(1) desc";
  360. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  361. return DT;
  362. }
  363. /// <summary>
  364. /// 获取所有元素
  365. /// </summary>
  366. /// <param name="model">Feature</param>
  367. /// <returns></returns>
  368. public DataTable GetAllElement()
  369. {
  370. string sqlp = @"select name from ElementChemistry group by name order by count(1) desc";
  371. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  372. return DT;
  373. }
  374. /// <summary>
  375. /// 获取常用夹杂物分类信息
  376. /// </summary>
  377. /// <returns></returns>
  378. public DataTable GetCommonlyUsedClassifyData()
  379. {
  380. string sqlp = @"select
  381. (select count(typeid) from incadata where typeid BETWEEN 10100 and 10199 and typeid BETWEEN 12200 and 12299 and typeid BETWEEN 11300 and 11299 ) as SPINEL ,
  382. (select count(typeid) from incadata where typeid BETWEEN 10000 and 10999 ) as OXIDE ,
  383. (select count(typeid) from incadata where typeid BETWEEN 11200 and 11299 and typeid BETWEEN 11400 and 11499 and typeid BETWEEN 11200 and 11599 ) as SULFIDE_OXIDE ,
  384. (select count(typeid) from incadata where typeid BETWEEN 12000 and 12999 ) as NITRIDE ,
  385. (select count(typeid) from incadata where typeid BETWEEN 11000 and 11999 ) as SULFIDE ";
  386. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  387. return DT;
  388. }
  389. public bool DeleteFromData(string fieldid, string particleid)
  390. {
  391. string sqlp = @"delete from IncAData where FieldId=" + fieldid + " and ParticleId="
  392. + particleid;
  393. if (dbHelper.ExecuteQuery_bool(sqlp))
  394. {
  395. return true;
  396. }
  397. else
  398. {
  399. return false;
  400. }
  401. }
  402. /// <summary>
  403. /// 获取颗粒信息
  404. /// </summary>
  405. /// <param name="model">Feature</param>
  406. /// <returns></returns>
  407. public Particle GetParticleByFidAndPid(string fieldid, string particleid)
  408. {
  409. string sqlp = @"select *,(select xraydata from xraydata where xrayindex=INcAData.xrayid and fieldid="
  410. + fieldid + ") as XRayData,(select group_concat(name || '_' || Percentage, ';')from ElementChemistry where XRayId = INcAData.XRayId and fieldid ="
  411. + fieldid + ") as Element from INcAData where fieldid="
  412. + fieldid + " and particleid= " + particleid;
  413. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  414. List<Particle> listp = dbHelper.TableToList<Particle>(DT);
  415. Particle particle = new Particle();
  416. if (listp.Count > 0)
  417. {
  418. particle = listp[0];
  419. List<Element> ElementList = new List<Element>();
  420. string element = DT.Rows[0]["Element"].ToString();
  421. for (int i = 0; i < element.Split(';').Count(); i++)
  422. {
  423. if (element.Split(';')[i] != "")
  424. {
  425. Element ele = new Element() { Name = element.Split(';')[i].Split('_')[0], Percentage = Convert.ToDouble(element.Split(';')[i].Split('_')[1]) };
  426. ElementList.Add(ele);
  427. }
  428. }
  429. particle.ElementList = ElementList;
  430. }
  431. return particle;
  432. }
  433. public Particle GetParticleXrayDataByFidAndPid(string fieldid, string xrayid)
  434. {
  435. string sqlp = @"select xraydata from xraydata where xrayindex=" + xrayid + " and fieldid="
  436. + fieldid;
  437. DataTable DT = dbHelper.ExecuteDataTable(sqlp, null);
  438. List<Particle> listp = dbHelper.TableToList<Particle>(DT);
  439. if (listp.Count > 0)
  440. {
  441. return listp[0];
  442. }
  443. else
  444. {
  445. return null;
  446. }
  447. }
  448. public enum PARTCLE_TYPE
  449. {
  450. SMALL = 0,//过小颗粒
  451. OVERSIZE = 1,//过大颗粒
  452. AVE_GRAY_NOT_INRANRE = 2,//亮度不在分析范围内的颗粒
  453. SEARCH_X_RAY = 3,
  454. LOW_COUNT = 4,//低计数率颗粒
  455. NO_INTEREST_ELEMENTS = 5,
  456. NO_ANALYSIS_X_RAY = 6,//不含分析元素
  457. NOT_IDENTIFIED_SIC = 7,//非夹杂物颗粒SiC
  458. NOT_IDENTIFIED_FEO = 8,//非夹杂物颗粒FeO
  459. NOT_IDENTIFIED = 9,//未识别颗粒
  460. IDENTIFIED = 10,//分析颗粒,当为可识别类型时,可以被进一步识别为用户类型(1000以上),系统预定义类型(10000以上),所以最终颗粒类型不会为8,但可能为7
  461. USER_DEFINED_MIN = 1000,
  462. SYS_DEFINED_MIN = 10000
  463. }
  464. #region 分页添加读取数据库函数
  465. /// <summary>
  466. /// 获取分页查询所需信息
  467. /// </summary>
  468. /// <param name=""></param>
  469. /// <param name=""></param>
  470. /// <returns></returns>
  471. public DataTable GetInfoForPartucleDevidePage(int currentPage, int pagesize, string OrderFunction, string condition)
  472. {
  473. int p = (currentPage - 1) * pagesize;
  474. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,FieldPosX as 'SEMPosX',FieldPosY as 'SEMPosY',ParticleId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,SubParticles, (select group_concat(name || '-' || Percentage, ';') from ElementChemistry where XRayId = MergedParticleInfo.XRayId and fieldid = MergedParticleInfo.fieldid) as Element from MergedParticleInfo where 1=1 " + condition + " union select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,FieldPosX,FieldPosY,ParticleId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as SubParticles,(select group_concat(name || '-' || Percentage, ';') from ElementChemistry where XRayId = INcAData.XRayId and fieldid = INcAData.fieldid ) as Element from INcAData where xrayid > -1 and instr(','||(select ifnull(group_concat(SubParticles, ','),'') from MergedParticleInfo)|| ',',',' || fieldid || ':' || particleid || ',')= 0 " + condition + " order by " + OrderFunction + " limit " + pagesize.ToString() + " offset " + p.ToString();
  475. DataTable DT = new DataTable();
  476. DT = dbHelper.ExecuteQuery(sqliteString);
  477. return DT;
  478. }
  479. public DataTable GetIncaSurfaceData( List<string> lst_str)
  480. {
  481. DataTable particlesAll = GetInfoForPartucleDevidePage2("");
  482. DataTable dt_element = GetElementChemistry();
  483. List<int> list_int = new List<int>();
  484. for (int a = 0; a < lst_str.Count; a++)
  485. {
  486. for (int i = 0; i < dt_element.Rows.Count; i++)
  487. {
  488. if (dt_element.Rows[i]["Name"].ToString() == lst_str[a].ToString())
  489. {
  490. list_int.Add(i);
  491. }
  492. }
  493. }
  494. for (int i = 0; i < list_int.Count; i++)
  495. {
  496. dt_element.Rows[list_int[i]].Delete();
  497. }
  498. dt_element.AcceptChanges();
  499. for (int i = 0; i < particlesAll.Rows.Count; i++)
  500. {
  501. string str = "XRayId = " + particlesAll.Rows[i]["particleId"].ToString() + " and fieldid = " + particlesAll.Rows[i]["fieldid"].ToString();
  502. DataRow[] drs = dt_element.Select(str);
  503. string ConcatenatedString = "";
  504. for (int j = 0; j < drs.Length; j++)
  505. {
  506. ConcatenatedString += drs[j]["name"] + "-" + ChangeDataToD(drs[j]["Percentage"].ToString()) + ';';
  507. }
  508. particlesAll.Rows[i]["Element"] = ConcatenatedString;
  509. }
  510. return particlesAll;
  511. }
  512. /// <summary>
  513. /// 拼接颗粒
  514. /// </summary>
  515. /// <param name="lst_str"></param>
  516. /// <returns></returns>
  517. public DataTable GetSplicingParticlesData()
  518. {
  519. DataTable particlesAll = GetSplicingParticles();
  520. return particlesAll;
  521. }
  522. /// <summary>
  523. /// 保留两位小数
  524. /// </summary>
  525. /// <param name="strData"></param>
  526. /// <returns></returns>
  527. private string ChangeDataToD(string strData)
  528. {
  529. Decimal dData = 0.00M;
  530. if (strData.Contains("E"))
  531. {
  532. dData = Convert.ToDecimal(Decimal.Parse(strData.ToString(), System.Globalization.NumberStyles.Float));
  533. }
  534. else
  535. {
  536. return Convert.ToDouble(strData).ToString("0.00");
  537. }
  538. return Convert.ToDouble(dData).ToString("0.00");
  539. }
  540. public DataTable GetInfoForPartucleDevidePage2(string condition)
  541. {
  542. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,FieldPosX " +
  543. "as 'SEMPosX',FieldPosY as 'SEMPosY',XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,SubParticles," +
  544. " (select group_concat(name || '-' || Percentage, ';') from ElementChemistry where XRayId = MergedParticleInfo.XRayId and fieldid = MergedParticleInfo.fieldid) " +
  545. "as Element from MergedParticleInfo where 1=1 " + condition + " union select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId," +
  546. "SegmentNum,SEMPosX,SEMPosY,XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as SubParticles,'' " +
  547. "as Element from INcAData where xrayid > -1 and instr(','||(select ifnull(group_concat(SubParticles, ','),'') from MergedParticleInfo)|| ',',',' || fieldid || ':' || particleid || ',')= 0 " +
  548. condition;
  549. DataTable DT = new DataTable();
  550. DT = dbHelper.ExecuteQuery(sqliteString);
  551. return DT;
  552. }
  553. public DataTable GetSplicingParticles()
  554. {
  555. string sqliteString1 = "select * from MergedParticleInfo";
  556. DataTable DT = new DataTable();
  557. DT = dbHelper.ExecuteQuery(sqliteString1);
  558. return DT;
  559. }
  560. public DataTable GetInfoForPartucleDevidePage_analyticalParticle(string condition)
  561. {
  562. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,SEMPosX,SEMPosY,XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as Element from INcAData where (xrayid > -1 and typeid !=9 and typeid !=-1 and typeid !=4)" +
  563. condition;
  564. DataTable DT = new DataTable();
  565. DT = dbHelper.ExecuteQuery(sqliteString);
  566. return DT;
  567. }
  568. public DataTable GetInfoForPartucleDevidePage_otherParticle(string condition)
  569. {
  570. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,SEMPosX,SEMPosY,XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as Element from INcAData where (typeid =9 or typeid =-1 or typeid =4) " +
  571. condition;
  572. DataTable DT = new DataTable();
  573. DT = dbHelper.ExecuteQuery(sqliteString);
  574. return DT;
  575. }
  576. public DataTable GetInfoForPartucleDevidePage_mergeParticles(string condition)
  577. {
  578. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,FieldPosX " +
  579. "as 'SEMPosX',FieldPosY as 'SEMPosY',XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,SubParticles,''as Element from MergedParticleInfo where 1=1 " + condition;
  580. DataTable DT1 = new DataTable();
  581. try
  582. {
  583. DT1 = dbHelper.ExecuteQuery(sqliteString);
  584. }
  585. catch
  586. {
  587. }
  588. return DT1;
  589. }
  590. public DataTable GetInfoForPartucleDevidePage_allParticles(string condition)
  591. {
  592. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,SEMPosX,SEMPosY,XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as Element from INcAData where 1=1 " +
  593. condition;
  594. DataTable DT = new DataTable();
  595. DT = dbHelper.ExecuteQuery(sqliteString);
  596. return DT;
  597. }
  598. public DataTable GetInfoForPartucleDevidePage_NotIdentifyParticle(string condition)
  599. {
  600. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,SEMPosX,SEMPosY,XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as Element from INcAData where typeid =9 " +
  601. condition;
  602. DataTable DT = new DataTable();
  603. DT = dbHelper.ExecuteQuery(sqliteString);
  604. return DT;
  605. }
  606. public DataTable GetInfoForPartucleDevidePage_InvalidParticle(string condition)
  607. {
  608. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,SEMPosX,SEMPosY,XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as Element from INcAData where typeid =-1 " +
  609. condition;
  610. DataTable DT = new DataTable();
  611. DT = dbHelper.ExecuteQuery(sqliteString);
  612. return DT;
  613. }
  614. public DataTable GetInfoForPartucleDevidePage_LowCountsParticle(string condition)
  615. {
  616. string sqliteString = "select fieldid,particleid,AveGray,RectLeft,RectTop,RectWidth,RectHeight,Area,PosX,PosY,TypeId,SegmentNum,SEMPosX,SEMPosY,XrayId,DMAX,DMIN,DPERP,PERIMETER,ORIENTATION,DINSCR,DMEAN,DELONG,DFERET,TypeName,TypeColor,'' as Element from INcAData where typeid =4 " +
  617. condition;
  618. DataTable DT = new DataTable();
  619. DT = dbHelper.ExecuteQuery(sqliteString);
  620. return DT;
  621. }
  622. public DataTable GetClassificationOfAllParticles(string condition)
  623. {
  624. string sqliteString1 = "select distinct TypeName from INcAData "+ condition;
  625. DataTable DT = new DataTable();
  626. DT = dbHelper.ExecuteQuery(sqliteString1);
  627. return DT;
  628. }
  629. public DataTable GetXRayData()
  630. {
  631. string sqliteString = @"select * from xraydata";
  632. DataTable DT = new DataTable();
  633. DT = dbHelper.ExecuteQuery(sqliteString);
  634. return DT;
  635. }
  636. public DataTable GetElementChemistry()
  637. {
  638. string sqliteString = "select * from ElementChemistry";
  639. DataTable DT = new DataTable();
  640. DT = dbHelper.ExecuteQuery(sqliteString);
  641. return DT;
  642. }
  643. /// <summary>
  644. /// 得到图形形状
  645. /// </summary>
  646. /// <returns></returns>
  647. public DataTable GetSegment()
  648. {
  649. string sqliteString = "select * from Segment";
  650. DataTable DT = new DataTable();
  651. DT = dbHelper.ExecuteQuery(sqliteString);
  652. return DT;
  653. }
  654. public Bitmap GetBitmapForBig(string sub, double xs, string path, int picHeight, int picWidth)
  655. {
  656. string vs = "," + sub.Replace(':', '-') + ",";
  657. DataTable dataTable = GetParticleAll(vs);
  658. if (dataTable.Rows.Count == 0)
  659. {
  660. return null;
  661. }
  662. //内接矩形
  663. double max_Y = Convert.ToInt64(dataTable.Rows[0]["FieldPosY"]) * xs - Convert.ToInt64(dataTable.Rows[0]["RectTop"]);
  664. double max_X = Convert.ToInt64(dataTable.Rows[0]["FieldPosX"]) * xs + Convert.ToInt64(dataTable.Rows[0]["RectLeft"]);
  665. double min_Y = max_Y;
  666. double min_X = max_X;
  667. //拼接field矩形
  668. double MAX_Y = Convert.ToInt64(dataTable.Rows[0]["FieldPosY"]) * xs;
  669. double MAX_X = Convert.ToInt64(dataTable.Rows[0]["FieldPosX"]) * xs;
  670. double MIN_Y = MAX_Y;
  671. double MIN_X = MAX_X;
  672. foreach (DataRow item in dataTable.Rows)
  673. {
  674. //颗粒外接矩形
  675. double lefttopX = Convert.ToInt64(item["FieldPosX"]) * xs + Convert.ToInt64(item["RectLeft"]);
  676. if (lefttopX < min_X)
  677. {
  678. min_X = lefttopX;
  679. }
  680. if (lefttopX + Convert.ToInt64(item["RectWidth"]) > max_X)
  681. {
  682. max_X = lefttopX + Convert.ToInt64(item["RectWidth"]);
  683. }
  684. double lrfttopY = Convert.ToInt64(item["FieldPosY"]) * xs - Convert.ToInt64(item["RectTop"]);
  685. if (max_Y < lrfttopY)
  686. {
  687. max_Y = lrfttopY;
  688. }
  689. if (min_Y > lrfttopY - Convert.ToInt64(item["RectHeight"]))
  690. {
  691. min_Y = lrfttopY - Convert.ToInt64(item["RectHeight"]);
  692. }
  693. //画布
  694. double lefttopXH = Convert.ToInt64(item["FieldPosX"]) * xs;
  695. if (lefttopXH > MAX_X)
  696. {
  697. MAX_X = lefttopXH;
  698. }
  699. if (lefttopXH < MIN_X)
  700. {
  701. MIN_X = lefttopXH;
  702. }
  703. double lrfttopYH = Convert.ToInt64(item["FieldPosY"]) * xs;
  704. if (MAX_Y < lrfttopYH)
  705. {
  706. MAX_Y = lrfttopYH;
  707. }
  708. if (MIN_Y > lrfttopYH)
  709. {
  710. MIN_Y = lrfttopYH;
  711. }
  712. }
  713. int WIDTH = Convert.ToInt32(MAX_X - MIN_X) + picWidth;
  714. int HEIGHT = Convert.ToInt32(MAX_Y - MIN_Y) + picHeight;
  715. //构造最终的图片白板
  716. Bitmap tableChartImage = new Bitmap(WIDTH, HEIGHT);
  717. Graphics graph = Graphics.FromImage(tableChartImage);
  718. //初始化这个大图
  719. graph.DrawImage(tableChartImage, 0, 0);
  720. int width = Convert.ToInt32(max_X - min_X);
  721. int height = Convert.ToInt32(max_Y - min_Y);
  722. int X = Convert.ToInt32(min_X - MIN_X);
  723. int Y = Convert.ToInt32(MAX_Y - max_Y);
  724. Rectangle rectangle = new Rectangle() { X = X, Y = Y, Width = width, Height = height };
  725. foreach (DataRow item in dataTable.Rows)
  726. {
  727. string filePath = path + "\\FIELD_FILES\\";
  728. string imagePath = filePath + "Field" + item["fieldid"].ToString() + ".bmp";
  729. //然后将取出的数据,转换成Bitmap对象
  730. Bitmap ls_bt = ReadImageFile(imagePath);
  731. int x = Convert.ToInt32(Convert.ToDouble(item["FieldPosX"]) * xs - MIN_X);
  732. int y = Convert.ToInt32(Convert.ToDouble(item["FieldPosY"]) * xs - MIN_Y);
  733. graph.DrawImage(ls_bt, x, y);
  734. }
  735. Bitmap bmap = tableChartImage.Clone(rectangle, PixelFormat.Format8bppIndexed);
  736. return bmap;
  737. }
  738. /// <summary>
  739. /// 通过FileStream 来打开文件,这样就可以实现不锁定Image文件,到时可以让多用户同时访问Image文件
  740. /// </summary>
  741. /// <param name="path"></param>
  742. /// <returns></returns>
  743. public Bitmap ReadImageFile(string path)
  744. {
  745. if (!File.Exists(path))
  746. {
  747. return null;//文件不存在
  748. }
  749. FileStream fs = File.OpenRead(path); //OpenRead
  750. int filelength = 0;
  751. filelength = (int)fs.Length; //获得文件长度
  752. Byte[] image = new Byte[filelength]; //建立一个字节数组
  753. fs.Read(image, 0, filelength); //按字节流读取
  754. System.Drawing.Image result = System.Drawing.Image.FromStream(fs);
  755. fs.Close();
  756. Bitmap bit = new Bitmap(result);
  757. return bit;
  758. }
  759. /// <summary>
  760. /// 传入单颗颗粒的particle类对象,返回从field中抠取出的bitmap对象,抠取单颗颗粒
  761. /// </summary>
  762. /// <param name="in_cotsparticleclr"></param>
  763. /// <returns></returns>
  764. public Bitmap GetBitmapByParticle(Bitmap ls_bt, Rectangle offset_rect)
  765. {
  766. //为了能把整个颗粒显示完整
  767. offset_rect.X = offset_rect.X - 20;
  768. offset_rect.Y = offset_rect.Y - 20;
  769. offset_rect.Width = offset_rect.Width + 40;
  770. offset_rect.Height = offset_rect.Height + 40;
  771. //防止计算偏差后,有坐标溢出现象
  772. if (offset_rect.X < 0)
  773. offset_rect.X = 0;
  774. if (offset_rect.Y < 0)
  775. offset_rect.Y = 0;
  776. if (offset_rect.X + offset_rect.Width > ls_bt.Width)
  777. {
  778. offset_rect.Width = ls_bt.Width - offset_rect.X;
  779. }
  780. if (offset_rect.Y + offset_rect.Height > ls_bt.Height)
  781. {
  782. offset_rect.Height = ls_bt.Height - offset_rect.Y;
  783. }
  784. Bitmap new_ret_bp;
  785. //防止为0后面计算出错
  786. if (offset_rect.Width > 0 && offset_rect.Height > 0)
  787. {
  788. //最后通过list_showsegment组建成新的图片,进行返回
  789. new_ret_bp = ls_bt.Clone(offset_rect, ls_bt.PixelFormat);
  790. }
  791. else
  792. {
  793. new_ret_bp = new Bitmap(offset_rect.Width, offset_rect.Height);
  794. }
  795. return new_ret_bp;
  796. }
  797. public void InsertUpdate(List<int> particleID, List<string> particleData)
  798. {
  799. List<KeyValuePair<string, SQLiteParameter[]>> cmdlist = new List<KeyValuePair<string, SQLiteParameter[]>>();
  800. var str = dbHelper.UpdateINCAEntryData(particleID, particleData);
  801. cmdlist.Add(str);
  802. try
  803. {
  804. dbHelper.ExecuteNonQueryBatch(ref cmdlist);
  805. }
  806. catch (Exception e)
  807. {
  808. //NLog.LogManager.GetCurrentClassLogger().Error(e.Message);
  809. }
  810. }
  811. public KeyValuePair<string, SQLiteParameter[]> GetUpdataAIncACmd(List<int> particleID, List<string> particleData)
  812. {
  813. var str = dbHelper.UpdateINCAEntryData(particleID, particleData);
  814. return str;
  815. }
  816. public void ExecuteNonQueryBatch(List<KeyValuePair<string, SQLiteParameter[]>> cmdlist)
  817. {
  818. try
  819. {
  820. dbHelper.ExecuteNonQueryBatch(ref cmdlist);
  821. }
  822. catch (Exception e)
  823. {
  824. //NLog.LogManager.GetCurrentClassLogger().Error(e.Message);
  825. }
  826. }
  827. #endregion
  828. }
  829. public class UserLibraryData
  830. {
  831. private SqlHelper dbHelper;
  832. public UserLibraryData(string libraryName,string resultpath)
  833. {
  834. NLog.Logger log = NLog.LogManager.GetCurrentClassLogger();
  835. if (!libraryName.Contains(".db"))
  836. {
  837. libraryName += ".db";
  838. }
  839. if(libraryName.ToLower()== "nostddb.db")
  840. {
  841. dbHelper = null;
  842. log.Error("Failed to load user-defined library" + "!");
  843. }
  844. string fullPath = resultpath + libraryName;
  845. string fullPath2 = System.IO.Directory.GetCurrentDirectory() + "\\Config\\SysData\\" + libraryName;
  846. if (System.IO.File.Exists(fullPath))
  847. {
  848. dbHelper = new SqlHelper("data source='" + fullPath + "'");
  849. log.Warn("Loading the user standard library:" + fullPath + "!");
  850. }
  851. else if(System.IO.File.Exists(fullPath2))
  852. {
  853. dbHelper = new SqlHelper("data source='" + fullPath2 + "'");
  854. log.Warn("Loading the user standard library:" + fullPath2 + "!");
  855. }
  856. else
  857. {
  858. dbHelper = null;
  859. log.Error("Failed to load user-defined library"+ "!");
  860. }
  861. }
  862. public DataTable GetSubAttributeFromDatabase()
  863. {
  864. string sqliteString = "select STDId,Hardness,Density,Electrical_conductivity from ClassifySTD";
  865. DataTable DT = new DataTable();
  866. DT = dbHelper.ExecuteQuery(sqliteString);
  867. return DT;
  868. }
  869. public SqlHelper GetSqlHelper() { return dbHelper; }
  870. }
  871. }