ParticleData.cs 37 KB

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