ParticleData.cs 36 KB

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