TDMSChannel.cs 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358
  1. using System;
  2. using System.ComponentModel;
  3. using System.Linq;
  4. using System.Reflection;
  5. using System.Runtime.InteropServices;
  6. using System.Text;
  7. using TDMS.Common;
  8. using TDMS.Externals;
  9. namespace TDMS.Default
  10. {
  11. internal class TDMSChannel : BaseTDMSLevel, ITDMSChannel
  12. {
  13. public TDMSChannel(IntPtr channelPtr)
  14. {
  15. _SelfPtr = channelPtr;
  16. PropertyOperator = new ChannelPropertyOperator(channelPtr);
  17. SetNameAndDescription();
  18. SetUnit();
  19. }
  20. private void SetUnit()
  21. {
  22. Unit = GetDefaultProperty(Constants.DDC_CHANNEL_UNIT_STRING);
  23. }
  24. #region Implementation of ITDMSChannel
  25. public bool SetData<T>(params T[] values)
  26. {
  27. if(values.Length <= 0)
  28. return true;
  29. var dataType = typeof(T).ToDataType();
  30. var success = Error.NoError;
  31. switch (dataType)
  32. {
  33. case TDMSDataType.UInt8:
  34. var byteArray = values.Cast<byte>().ToArray();
  35. success = DDC.SetDataValuesUInt8(_SelfPtr, byteArray, (uint)values.Length);
  36. break;
  37. case TDMSDataType.Int16:
  38. var shortArray = values.Cast<short>().ToArray();
  39. success = DDC.SetDataValuesInt16(_SelfPtr, shortArray, (uint)values.Length);
  40. break;
  41. case TDMSDataType.Int32:
  42. var intArray = values.Cast<int>().ToArray();
  43. success = DDC.SetDataValuesInt32(_SelfPtr, intArray, (uint)values.Length);
  44. break;
  45. case TDMSDataType.Float:
  46. var floatArray = values.Cast<float>().ToArray();
  47. success = DDC.SetDataValuesFloat(_SelfPtr, floatArray, (uint)values.Length);
  48. break;
  49. case TDMSDataType.Double:
  50. var doubleArray = values.Cast<double>().ToArray();
  51. success = DDC.SetDataValuesDouble(_SelfPtr, doubleArray, (uint)values.Length);
  52. break;
  53. case TDMSDataType.String:
  54. var stringArray = values.Cast<string>().ToArray();
  55. success = DDC.SetDataValuesString(_SelfPtr, stringArray, (uint)values.Length);
  56. break;
  57. case TDMSDataType.Timestamp:
  58. var datetimeArray = values.Cast<DateTime>().ToArray();
  59. var df = datetimeArray.Factoring();
  60. success = DDC.SetDataValuesTimestampComponents(_SelfPtr,
  61. df.Years,
  62. df.Months,
  63. df.Days,
  64. df.Hours,
  65. df.Minutes,
  66. df.Seconds,
  67. df.Milliseconds,
  68. (uint)values.Length);
  69. break;
  70. case TDMSDataType.UnDefine:
  71. default: throw new InvalidEnumArgumentException();
  72. }
  73. return success == Error.NoError;
  74. }
  75. /// <inheritdoc />
  76. public bool AppendData<T>(params T[] values)
  77. {
  78. if(values.Length <= 0)
  79. return true;
  80. var dataType = typeof(T).ToDataType();
  81. var success = Error.NoError;
  82. switch (dataType)
  83. {
  84. case TDMSDataType.UInt8:
  85. var byteArray = values.Cast<byte>().ToArray();
  86. success = DDC.AppendDataValuesUInt8(_SelfPtr, byteArray, (uint)values.Length);
  87. break;
  88. case TDMSDataType.Int16:
  89. var shortArray = values.Cast<short>().ToArray();
  90. success = DDC.AppendDataValuesInt16(_SelfPtr, shortArray, (uint)values.Length);
  91. break;
  92. case TDMSDataType.Int32:
  93. var intArray = values.Cast<int>().ToArray();
  94. success = DDC.AppendDataValuesInt32(_SelfPtr, intArray, (uint)values.Length);
  95. break;
  96. case TDMSDataType.Float:
  97. var floatArray = values.Cast<float>().ToArray();
  98. success = DDC.AppendDataValuesFloat(_SelfPtr, floatArray, (uint)values.Length);
  99. break;
  100. case TDMSDataType.Double:
  101. var doubleArray = values.Cast<double>().ToArray();
  102. success = DDC.AppendDataValuesDouble(_SelfPtr, doubleArray, (uint)values.Length);
  103. break;
  104. case TDMSDataType.String:
  105. var stringArray = values.Cast<string>().ToArray();
  106. success = DDC.AppendDataValuesString(_SelfPtr, stringArray, (uint)values.Length);
  107. break;
  108. case TDMSDataType.Timestamp:
  109. var datetimeArray = values.Cast<DateTime>().ToArray();
  110. var df = datetimeArray.Factoring();
  111. success = DDC.AppendDataValuesTimestampComponents(_SelfPtr,
  112. df.Years,
  113. df.Months,
  114. df.Days,
  115. df.Hours,
  116. df.Minutes,
  117. df.Seconds,
  118. df.Milliseconds,
  119. (uint)values.Length);
  120. break;
  121. case TDMSDataType.UnDefine:
  122. default: throw new InvalidEnumArgumentException();
  123. }
  124. return success == Error.NoError;
  125. }
  126. /// <inheritdoc />
  127. public bool UpdateData<T>(int index, params T[] values)
  128. {
  129. if(values.Length <= 0)
  130. return true;
  131. var dataType = typeof(T).ToDataType();
  132. var success = Error.NoError;
  133. switch (dataType)
  134. {
  135. case TDMSDataType.UInt8:
  136. var byteArray = values.Cast<byte>().ToArray();
  137. success = DDC.ReplaceDataValuesUInt8(_SelfPtr, (uint)index, byteArray, (uint)values.Length);
  138. break;
  139. case TDMSDataType.Int16:
  140. var shortArray = values.Cast<short>().ToArray();
  141. success = DDC.ReplaceDataValuesInt16(_SelfPtr, (uint)index, shortArray, (uint)values.Length);
  142. break;
  143. case TDMSDataType.Int32:
  144. var intArray = values.Cast<int>().ToArray();
  145. success = DDC.ReplaceDataValuesInt32(_SelfPtr, (uint)index, intArray, (uint)values.Length);
  146. break;
  147. case TDMSDataType.Float:
  148. var floatArray = values.Cast<float>().ToArray();
  149. success = DDC.ReplaceDataValuesFloat(_SelfPtr, (uint)index, floatArray, (uint)values.Length);
  150. break;
  151. case TDMSDataType.Double:
  152. var doubleArray = values.Cast<double>().ToArray();
  153. success = DDC.ReplaceDataValuesDouble(_SelfPtr, (uint)index, doubleArray, (uint)values.Length);
  154. break;
  155. case TDMSDataType.String:
  156. var stringArray = values.Cast<string>().ToArray();
  157. success = DDC.ReplaceDataValuesString(_SelfPtr, (uint)index, stringArray, (uint)values.Length);
  158. break;
  159. case TDMSDataType.Timestamp:
  160. var datetimeArray = values.Cast<DateTime>().ToArray();
  161. var df = datetimeArray.Factoring();
  162. success = DDC.ReplaceDataValuesTimestampComponents(_SelfPtr,
  163. (uint)index,
  164. df.Years,
  165. df.Months,
  166. df.Days,
  167. df.Hours,
  168. df.Minutes,
  169. df.Seconds,
  170. df.Milliseconds,
  171. (uint)values.Length);
  172. break;
  173. case TDMSDataType.UnDefine:
  174. default: throw new InvalidEnumArgumentException();
  175. }
  176. return success == Error.NoError;
  177. }
  178. /// <inheritdoc />
  179. public T[] GetDataValues<T>(uint startIndex, uint length)
  180. {
  181. var dataType = typeof(T).ToDataType();
  182. var success = Error.NoError;
  183. switch (dataType)
  184. {
  185. case TDMSDataType.UInt8:
  186. var byteArray = new byte[length];
  187. success = DDC.GetDataValuesUInt8(_SelfPtr, (uint)startIndex, (uint)length, byteArray);
  188. return byteArray.Cast<T>().ToArray();
  189. case TDMSDataType.Int16:
  190. var shortArray = new short[length];
  191. success = DDC.GetDataValuesInt16(_SelfPtr, (uint)startIndex, (uint)length, shortArray);
  192. return shortArray.Cast<T>().ToArray();
  193. case TDMSDataType.Int32:
  194. var intArray = new int[length];
  195. success = DDC.GetDataValuesInt32(_SelfPtr, (uint)startIndex, (uint)length, intArray);
  196. return intArray.Cast<T>().ToArray();
  197. case TDMSDataType.Float:
  198. var floatArray = new float[length];
  199. success = DDC.GetDataValuesFloat(_SelfPtr, (uint)startIndex, (uint)length, floatArray);
  200. return floatArray.Cast<T>().ToArray();
  201. case TDMSDataType.Double:
  202. var doubleArray = new double[length];
  203. success = DDC.GetDataValuesDouble(_SelfPtr, (uint)startIndex, (uint)length, doubleArray);
  204. return doubleArray.Cast<T>().ToArray();
  205. case TDMSDataType.String:
  206. var stringArray = new string[length];
  207. var stringPointers = new IntPtr[length];
  208. success = DDC.GetDataValuesString(_SelfPtr, (uint)startIndex, (uint)length, stringPointers);
  209. for (int i = 0; i < length; i++)
  210. {
  211. stringArray[i] = Marshal.PtrToStringAnsi(stringPointers[i]) ??string.Empty;
  212. }
  213. return stringArray.Cast<T>().ToArray();
  214. case TDMSDataType.Timestamp:
  215. var df = new DatetimeFactor((int)length);
  216. success = DDC.GetDataValuesTimestampComponents(_SelfPtr,
  217. (uint)startIndex,
  218. (uint)length,
  219. df.Years,
  220. df.Months,
  221. df.Days,
  222. df.Hours,
  223. df.Minutes,
  224. df.Seconds,
  225. df.Milliseconds,
  226. df.WeekDays);
  227. return df.ToDateTimeArray().Cast<T>().ToArray();
  228. case TDMSDataType.UnDefine:
  229. default: throw new InvalidEnumArgumentException();
  230. }
  231. }
  232. /// <inheritdoc />
  233. public string Unit { get; private set; }
  234. #endregion
  235. #region Implementation of ITDMSLevel
  236. /// <inheritdoc />
  237. public override bool Close()
  238. {
  239. if(!_IsClosed)
  240. {
  241. var success = DDC.CloseChannel(_SelfPtr);
  242. }
  243. return _IsClosed = true;
  244. }
  245. /// <inheritdoc />
  246. public override ulong ChildCount => DDC.CountDataValues(_SelfPtr, out var numValues) == 0 ? numValues : 0;
  247. /// <inheritdoc />
  248. public override bool Clear()
  249. {
  250. return false;
  251. }
  252. /// <inheritdoc />
  253. public override bool Contains(string levelName)
  254. {
  255. return false;
  256. }
  257. /// <inheritdoc />
  258. public override bool TryGetItem(string levelName, out ITDMSLevel level)
  259. {
  260. level = null;
  261. return false;
  262. }
  263. /// <inheritdoc />
  264. public override bool Remove(string levelName)
  265. {
  266. return false;
  267. }
  268. /// <inheritdoc />
  269. public override bool RemoveAt(int index)
  270. {
  271. return false;
  272. }
  273. #endregion
  274. }
  275. }