ClassFlowCNNGeneral.cpp 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974
  1. #include "ClassFlowCNNGeneral.h"
  2. #include <math.h>
  3. #include <iomanip>
  4. #include <sys/types.h>
  5. #include <sstream> // std::stringstream
  6. #include "CTfLiteClass.h"
  7. #include "ClassLogFile.h"
  8. #include "esp_log.h"
  9. #include "../../include/defines.h"
  10. static const char* TAG = "CNN";
  11. //#ifdef CONFIG_HEAP_TRACING_STANDALONE
  12. #ifdef HEAP_TRACING_CLASS_FLOW_CNN_GENERAL_DO_ALING_AND_CUT
  13. #include <esp_heap_trace.h>
  14. #define NUM_RECORDS 300
  15. static heap_trace_record_t trace_record[NUM_RECORDS]; // This buffer must be in internal RAM
  16. #endif
  17. ClassFlowCNNGeneral::ClassFlowCNNGeneral(ClassFlowAlignment *_flowalign, t_CNNType _cnntype) : ClassFlowImage(NULL, TAG)
  18. {
  19. string cnnmodelfile = "";
  20. modelxsize = 1;
  21. modelysize = 1;
  22. CNNGoodThreshold = 0.0;
  23. ListFlowControll = NULL;
  24. previousElement = NULL;
  25. SaveAllFiles = false;
  26. disabled = false;
  27. isLogImageSelect = false;
  28. CNNType = AutoDetect;
  29. CNNType = _cnntype;
  30. flowpostalignment = _flowalign;
  31. imagesRetention = 5;
  32. }
  33. string ClassFlowCNNGeneral::getReadout(int _analog = 0, bool _extendedResolution, int prev, float _before_narrow_Analog, float analogDigitalTransitionStart)
  34. {
  35. string result = "";
  36. if (GENERAL[_analog]->ROI.size() == 0)
  37. return result;
  38. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "getReadout _analog=" + std::to_string(_analog) + ", _extendedResolution=" + std::to_string(_extendedResolution) + ", prev=" + std::to_string(prev));
  39. if (CNNType == Analogue || CNNType == Analogue100)
  40. {
  41. float number = GENERAL[_analog]->ROI[GENERAL[_analog]->ROI.size() - 1]->result_float;
  42. int result_after_decimal_point = ((int) floor(number * 10) + 10) % 10;
  43. prev = PointerEvalAnalogNew(GENERAL[_analog]->ROI[GENERAL[_analog]->ROI.size() - 1]->result_float, prev);
  44. // LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "getReadout(analog) number=" + std::to_string(number) + ", result_after_decimal_point=" + std::to_string(result_after_decimal_point) + ", prev=" + std::to_string(prev));
  45. result = std::to_string(prev);
  46. if (_extendedResolution)
  47. result = result + std::to_string(result_after_decimal_point);
  48. for (int i = GENERAL[_analog]->ROI.size() - 2; i >= 0; --i)
  49. {
  50. prev = PointerEvalAnalogNew(GENERAL[_analog]->ROI[i]->result_float, prev);
  51. result = std::to_string(prev) + result;
  52. }
  53. return result;
  54. }
  55. if (CNNType == Digital)
  56. {
  57. for (int i = 0; i < GENERAL[_analog]->ROI.size(); ++i)
  58. {
  59. if (GENERAL[_analog]->ROI[i]->result_klasse >= 10)
  60. result = result + "N";
  61. else
  62. result = result + std::to_string(GENERAL[_analog]->ROI[i]->result_klasse);
  63. }
  64. return result;
  65. }
  66. if ((CNNType == DoubleHyprid10) || (CNNType == Digital100))
  67. {
  68. float number = GENERAL[_analog]->ROI[GENERAL[_analog]->ROI.size() - 1]->result_float;
  69. if (number >= 0) // NaN?
  70. {
  71. if (_extendedResolution) // is only set if it is the first digit (no analogue before!)
  72. {
  73. int result_after_decimal_point = ((int) floor(number * 10)) % 10;
  74. int result_before_decimal_point = ((int) floor(number)) % 10;
  75. result = std::to_string(result_before_decimal_point) + std::to_string(result_after_decimal_point);
  76. prev = result_before_decimal_point;
  77. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "getReadout(dig100-ext) result_before_decimal_point=" + std::to_string(result_before_decimal_point) + ", result_after_decimal_point=" + std::to_string(result_after_decimal_point) + ", prev=" + std::to_string(prev));
  78. }
  79. else
  80. {
  81. if (_before_narrow_Analog >= 0)
  82. prev = PointerEvalHybridNew(GENERAL[_analog]->ROI[GENERAL[_analog]->ROI.size() - 1]->result_float, _before_narrow_Analog, prev, true, analogDigitalTransitionStart);
  83. else
  84. prev = PointerEvalHybridNew(GENERAL[_analog]->ROI[GENERAL[_analog]->ROI.size() - 1]->result_float, prev, prev);
  85. result = std::to_string(prev);
  86. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "getReadout(dig100) prev=" + std::to_string(prev));
  87. }
  88. }
  89. else
  90. {
  91. result = "N";
  92. if (_extendedResolution && (CNNType != Digital))
  93. result = "NN";
  94. }
  95. for (int i = GENERAL[_analog]->ROI.size() - 2; i >= 0; --i)
  96. {
  97. if (GENERAL[_analog]->ROI[i]->result_float >= 0)
  98. {
  99. prev = PointerEvalHybridNew(GENERAL[_analog]->ROI[i]->result_float, GENERAL[_analog]->ROI[i+1]->result_float, prev);
  100. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "getReadout#PointerEvalHybridNew()= " + std::to_string(prev));
  101. result = std::to_string(prev) + result;
  102. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "getReadout#result= " + result);
  103. }
  104. else
  105. {
  106. prev = -1;
  107. result = "N" + result;
  108. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "getReadout(result_float<0 /'N') result_float=" + std::to_string(GENERAL[_analog]->ROI[i]->result_float));
  109. }
  110. }
  111. return result;
  112. }
  113. return result;
  114. }
  115. int ClassFlowCNNGeneral::PointerEvalHybridNew(float number, float number_of_predecessors, int eval_predecessors, bool Analog_Predecessors, float digitalAnalogTransitionStart)
  116. {
  117. int result;
  118. int result_after_decimal_point = ((int) floor(number * 10)) % 10;
  119. int result_before_decimal_point = ((int) floor(number) + 10) % 10;
  120. if (eval_predecessors < 0)
  121. {
  122. // on first digit is no spezial logic for transition needed
  123. // we use the recognition as given. The result is the int value of the recognition
  124. result = (int) ((int) trunc(number) + 10) % 10;
  125. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalHybridNew - No predecessor - Result = " + std::to_string(result) +
  126. " number: " + std::to_string(number) + " number_of_predecessors = " + std::to_string(number_of_predecessors)+ " eval_predecessors = " + std::to_string(eval_predecessors) + " Digital_Uncertainty = " + std::to_string(Digital_Uncertainty));
  127. return result;
  128. }
  129. if (Analog_Predecessors)
  130. {
  131. result = PointerEvalAnalogToDigitNew(number, number_of_predecessors, eval_predecessors, digitalAnalogTransitionStart);
  132. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalHybridNew - Analog predecessor, evaluation over PointerEvalAnalogNew = " + std::to_string(result) +
  133. " number: " + std::to_string(number) + " number_of_predecessors = " + std::to_string(number_of_predecessors)+ " eval_predecessors = " + std::to_string(eval_predecessors) + " Digital_Uncertainty = " + std::to_string(Digital_Uncertainty));
  134. return result;
  135. }
  136. if ((number_of_predecessors >= Digital_Transition_Area_Predecessor ) && (number_of_predecessors <= (10.0 - Digital_Transition_Area_Predecessor)))
  137. {
  138. // no digit change, because predecessor is far enough away (0+/-DigitalTransitionRangePredecessor) --> number is rounded
  139. if ((result_after_decimal_point <= DigitalBand) || (result_after_decimal_point >= (10-DigitalBand))) // Band around the digit --> Round off, as digit reaches inaccuracy in the frame
  140. result = ((int) round(number) + 10) % 10;
  141. else
  142. result = ((int) trunc(number) + 10) % 10;
  143. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalHybridNew - NO analogue predecessor, no change of digits, as pre-decimal point far enough away = " + std::to_string(result) +
  144. " number: " + std::to_string(number) + " number_of_predecessors = " + std::to_string(number_of_predecessors)+ " eval_predecessors = " + std::to_string(eval_predecessors) + " Digital_Uncertainty = " + std::to_string(Digital_Uncertainty));
  145. return result;
  146. }
  147. if (eval_predecessors <= 1) // Zero crossing at the predecessor has taken place (! evaluation via Prev_value and not number!) --> round up here (2.8 --> 3, but also 3.1 --> 3)
  148. {
  149. // We simply assume that the current digit after the zero crossing of the predecessor
  150. // has passed through at least half (x.5)
  151. if (result_after_decimal_point > 5)
  152. // The current digit does not yet have a zero crossing, but the predecessor does..
  153. result = (result_before_decimal_point + 1) % 10;
  154. else
  155. // Act. digit and predecessor have zero crossing
  156. result = result_before_decimal_point % 10;
  157. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalHybridNew - NO analogue predecessor, zero crossing has taken placen = " + std::to_string(result) +
  158. " number: " + std::to_string(number) + " number_of_predecessors = " + std::to_string(number_of_predecessors)+ " eval_predecessors = " + std::to_string(eval_predecessors) + " Digital_Uncertainty = " + std::to_string(Digital_Uncertainty));
  159. return result;
  160. }
  161. // remains only >= 9.x --> no zero crossing yet --> 2.8 --> 2,
  162. // and from 9.7(DigitalTransitionRangeLead) 3.1 --> 2
  163. // everything >=x.4 can be considered as current number in transition. With 9.x predecessor the current
  164. // number can still be x.6 - x.7.
  165. // Preceding (else - branch) does not already happen from 9.
  166. if (Digital_Transition_Area_Forward>=number_of_predecessors || result_after_decimal_point >= 4)
  167. // The current digit, like the previous digit, does not yet have a zero crossing.
  168. result = result_before_decimal_point % 10;
  169. else
  170. // current digit precedes the smaller digit (9.x). So already >=x.0 while the previous digit has not yet
  171. // has no zero crossing. Therefore, it is reduced by 1.
  172. result = (result_before_decimal_point - 1 + 10) % 10;
  173. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalHybridNew - O analogue predecessor, >= 9.5 --> no zero crossing yet = " + std::to_string(result) +
  174. " number: " + std::to_string(number) + " number_of_predecessors = " + std::to_string(number_of_predecessors)+ " eval_predecessors = " + std::to_string(eval_predecessors) + " Digital_Uncertainty = " + std::to_string(Digital_Uncertainty) + " result_after_decimal_point = " + std::to_string(result_after_decimal_point));
  175. return result;
  176. }
  177. int ClassFlowCNNGeneral::PointerEvalAnalogToDigitNew(float number, float numeral_preceder, int eval_predecessors, float analogDigitalTransitionStart)
  178. {
  179. int result;
  180. int result_after_decimal_point = ((int) floor(number * 10)) % 10;
  181. int result_before_decimal_point = ((int) floor(number) + 10) % 10;
  182. bool roundedUp = false;
  183. // Within the digital inequalities
  184. if ((result_after_decimal_point >= (10-Digital_Uncertainty * 10)) // Band around the digit --> Round off, as digit reaches inaccuracy in the frame
  185. || (eval_predecessors <= 4 && result_after_decimal_point>=6)) { // or digit runs after (analogue =0..4, digit >=6)
  186. result = (int) (round(number) + 10) % 10;
  187. roundedUp = true;
  188. // before/ after decimal point, because we adjust the number based on the uncertainty.
  189. result_after_decimal_point = ((int) floor(result * 10)) % 10;
  190. result_before_decimal_point = ((int) floor(result) + 10) % 10;
  191. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalAnalogToDigitNew - Digital Uncertainty - Result = " + std::to_string(result) +
  192. " number: " + std::to_string(number) + " numeral_preceder: " + std::to_string(numeral_preceder) +
  193. " erg before comma: " + std::to_string(result_before_decimal_point) +
  194. " erg after comma: " + std::to_string(result_after_decimal_point));
  195. } else {
  196. result = (int) ((int) trunc(number) + 10) % 10;
  197. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalAnalogToDigitNew - NO digital Uncertainty - Result = " + std::to_string(result) +
  198. " number: " + std::to_string(number) + " numeral_preceder = " + std::to_string(numeral_preceder));
  199. }
  200. // No zero crossing has taken place.
  201. // Only eval_predecessors used because numeral_preceder could be wrong here.
  202. // numeral_preceder<=0.1 & eval_predecessors=9 corresponds to analogue was reset because of previous analogue that are not yet at 0.
  203. if ((eval_predecessors>=6 && (numeral_preceder>analogDigitalTransitionStart || numeral_preceder<=0.2) && roundedUp))
  204. {
  205. result = ((result_before_decimal_point+10) - 1) % 10;
  206. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalAnalogToDigitNew - Nulldurchgang noch nicht stattgefunden = " + std::to_string(result) +
  207. " number: " + std::to_string(number) +
  208. " numeral_preceder = " + std::to_string(numeral_preceder) +
  209. " eerg after comma = " + std::to_string(result_after_decimal_point));
  210. }
  211. return result;
  212. }
  213. int ClassFlowCNNGeneral::PointerEvalAnalogNew(float number, int numeral_preceder)
  214. {
  215. float number_min, number_max;
  216. int result;
  217. if (numeral_preceder == -1)
  218. {
  219. result = (int) floor(number);
  220. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalAnalogNew - No predecessor - Result = " + std::to_string(result) +
  221. " number: " + std::to_string(number) + " numeral_preceder = " + std::to_string(numeral_preceder) + " Analog_error = " + std::to_string(Analog_error));
  222. return result;
  223. }
  224. number_min = number - Analog_error / 10.0;
  225. number_max = number + Analog_error / 10.0;
  226. if ((int) floor(number_max) - (int) floor(number_min) != 0)
  227. {
  228. if (numeral_preceder <= Analog_error)
  229. {
  230. result = ((int) floor(number_max) + 10) % 10;
  231. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalAnalogNew - number ambiguous, correction upwards - result = " + std::to_string(result) +
  232. " number: " + std::to_string(number) + " numeral_preceder = " + std::to_string(numeral_preceder) + " Analog_error = " + std::to_string(Analog_error));
  233. return result;
  234. }
  235. if (numeral_preceder >= 10 - Analog_error)
  236. {
  237. result = ((int) floor(number_min) + 10) % 10;
  238. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalAnalogNew - number ambiguous, downward correction - result = " + std::to_string(result) +
  239. " number: " + std::to_string(number) + " numeral_preceder = " + std::to_string(numeral_preceder) + " Analog_error = " + std::to_string(Analog_error));
  240. return result;
  241. }
  242. }
  243. result = ((int) floor(number) + 10) % 10;
  244. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "PointerEvalAnalogNew - number unambiguous, no correction necessary - result = " + std::to_string(result) +
  245. " number: " + std::to_string(number) + " numeral_preceder = " + std::to_string(numeral_preceder) + " Analog_error = " + std::to_string(Analog_error));
  246. return result;
  247. }
  248. bool ClassFlowCNNGeneral::ReadParameter(FILE* pfile, string& aktparamgraph)
  249. {
  250. std::vector<string> splitted;
  251. aktparamgraph = trim(aktparamgraph);
  252. if (aktparamgraph.size() == 0)
  253. if (!this->GetNextParagraph(pfile, aktparamgraph))
  254. return false;
  255. if ((toUpper(aktparamgraph) != "[ANALOG]") && (toUpper(aktparamgraph) != ";[ANALOG]")
  256. && (toUpper(aktparamgraph) != "[DIGIT]") && (toUpper(aktparamgraph) != ";[DIGIT]")
  257. && (toUpper(aktparamgraph) != "[DIGITS]") && (toUpper(aktparamgraph) != ";[DIGITS]")
  258. ) // Paragraph passt nicht
  259. return false;
  260. if (aktparamgraph[0] == ';')
  261. {
  262. disabled = true;
  263. while (getNextLine(pfile, &aktparamgraph) && !isNewParagraph(aktparamgraph));
  264. ESP_LOGD(TAG, "[Analog/Digit] is disabled!");
  265. return true;
  266. }
  267. while (this->getNextLine(pfile, &aktparamgraph) && !this->isNewParagraph(aktparamgraph))
  268. {
  269. splitted = ZerlegeZeile(aktparamgraph);
  270. if ((toUpper(splitted[0]) == "ROIIMAGESLOCATION") && (splitted.size() > 1))
  271. {
  272. this->imagesLocation = "/sdcard" + splitted[1];
  273. this->isLogImage = true;
  274. }
  275. if ((toUpper(splitted[0]) == "LOGIMAGESELECT") && (splitted.size() > 1))
  276. {
  277. LogImageSelect = splitted[1];
  278. isLogImageSelect = true;
  279. }
  280. if ((toUpper(splitted[0]) == "ROIIMAGESRETENTION") && (splitted.size() > 1))
  281. {
  282. this->imagesRetention = std::stoi(splitted[1]);
  283. }
  284. if ((toUpper(splitted[0]) == "MODEL") && (splitted.size() > 1))
  285. {
  286. this->cnnmodelfile = splitted[1];
  287. }
  288. if ((toUpper(splitted[0]) == "CNNGOODTHRESHOLD") && (splitted.size() > 1))
  289. {
  290. CNNGoodThreshold = std::stof(splitted[1]);
  291. }
  292. if (splitted.size() >= 5)
  293. {
  294. general* _analog = GetGENERAL(splitted[0], true);
  295. roi* neuroi = _analog->ROI[_analog->ROI.size()-1];
  296. neuroi->posx = std::stoi(splitted[1]);
  297. neuroi->posy = std::stoi(splitted[2]);
  298. neuroi->deltax = std::stoi(splitted[3]);
  299. neuroi->deltay = std::stoi(splitted[4]);
  300. neuroi->CCW = false;
  301. if (splitted.size() >= 6)
  302. {
  303. neuroi->CCW = toUpper(splitted[5]) == "TRUE";
  304. }
  305. neuroi->result_float = -1;
  306. neuroi->image = NULL;
  307. neuroi->image_org = NULL;
  308. }
  309. if ((toUpper(splitted[0]) == "SAVEALLFILES") && (splitted.size() > 1))
  310. {
  311. if (toUpper(splitted[1]) == "TRUE")
  312. SaveAllFiles = true;
  313. }
  314. }
  315. if (!getNetworkParameter()) {
  316. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "An error occured on setting up the Network -> Disabling it!");
  317. disabled = true; // An error occured, disable this CNN!
  318. return false;
  319. }
  320. for (int _ana = 0; _ana < GENERAL.size(); ++_ana)
  321. for (int i = 0; i < GENERAL[_ana]->ROI.size(); ++i)
  322. {
  323. GENERAL[_ana]->ROI[i]->image = new CImageBasis("ROI " + GENERAL[_ana]->ROI[i]->name,
  324. modelxsize, modelysize, modelchannel);
  325. GENERAL[_ana]->ROI[i]->image_org = new CImageBasis("ROI " + GENERAL[_ana]->ROI[i]->name + " original",
  326. GENERAL[_ana]->ROI[i]->deltax, GENERAL[_ana]->ROI[i]->deltay, 3);
  327. }
  328. return true;
  329. }
  330. general* ClassFlowCNNGeneral::FindGENERAL(string _name_number)
  331. {
  332. for (int i = 0; i < GENERAL.size(); ++i)
  333. if (GENERAL[i]->name == _name_number)
  334. return GENERAL[i];
  335. return NULL;
  336. }
  337. general* ClassFlowCNNGeneral::GetGENERAL(string _name, bool _create = true)
  338. {
  339. string _analog, _roi;
  340. int _pospunkt = _name.find_first_of(".");
  341. if (_pospunkt > -1)
  342. {
  343. _analog = _name.substr(0, _pospunkt);
  344. _roi = _name.substr(_pospunkt+1, _name.length() - _pospunkt - 1);
  345. }
  346. else
  347. {
  348. _analog = "default";
  349. _roi = _name;
  350. }
  351. general *_ret = NULL;
  352. for (int i = 0; i < GENERAL.size(); ++i)
  353. if (GENERAL[i]->name == _analog)
  354. _ret = GENERAL[i];
  355. if (!_create) // not found and should not be created
  356. return _ret;
  357. if (_ret == NULL)
  358. {
  359. _ret = new general;
  360. _ret->name = _analog;
  361. GENERAL.push_back(_ret);
  362. }
  363. roi* neuroi = new roi;
  364. neuroi->name = _roi;
  365. _ret->ROI.push_back(neuroi);
  366. ESP_LOGD(TAG, "GetGENERAL - GENERAL %s - roi %s - CCW: %d", _analog.c_str(), _roi.c_str(), neuroi->CCW);
  367. return _ret;
  368. }
  369. string ClassFlowCNNGeneral::getHTMLSingleStep(string host)
  370. {
  371. string result, zw;
  372. std::vector<HTMLInfo*> htmlinfo;
  373. result = "<p>Found ROIs: </p> <p><img src=\"" + host + "/img_tmp/alg_roi.jpg\"></p>\n";
  374. result = result + "Analog Pointers: <p> ";
  375. htmlinfo = GetHTMLInfo();
  376. for (int i = 0; i < htmlinfo.size(); ++i)
  377. {
  378. std::stringstream stream;
  379. stream << std::fixed << std::setprecision(1) << htmlinfo[i]->val;
  380. zw = stream.str();
  381. result = result + "<img src=\"" + host + "/img_tmp/" + htmlinfo[i]->filename + "\"> " + zw;
  382. delete htmlinfo[i];
  383. }
  384. htmlinfo.clear();
  385. return result;
  386. }
  387. bool ClassFlowCNNGeneral::doFlow(string time)
  388. {
  389. #ifdef HEAP_TRACING_CLASS_FLOW_CNN_GENERAL_DO_ALING_AND_CUT
  390. //register a buffer to record the memory trace
  391. ESP_ERROR_CHECK( heap_trace_init_standalone(trace_record, NUM_RECORDS) );
  392. // start tracing
  393. ESP_ERROR_CHECK( heap_trace_start(HEAP_TRACE_LEAKS) );
  394. #endif
  395. if (disabled)
  396. return true;
  397. if (!doAlignAndCut(time)){
  398. return false;
  399. };
  400. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "doFlow after alignment");
  401. doNeuralNetwork(time);
  402. RemoveOldLogs();
  403. #ifdef HEAP_TRACING_CLASS_FLOW_CNN_GENERAL_DO_ALING_AND_CUT
  404. ESP_ERROR_CHECK( heap_trace_stop() );
  405. heap_trace_dump();
  406. #endif
  407. return true;
  408. }
  409. bool ClassFlowCNNGeneral::doAlignAndCut(string time)
  410. {
  411. if (disabled)
  412. return true;
  413. CAlignAndCutImage *caic = flowpostalignment->GetAlignAndCutImage();
  414. for (int _ana = 0; _ana < GENERAL.size(); ++_ana)
  415. for (int i = 0; i < GENERAL[_ana]->ROI.size(); ++i)
  416. {
  417. ESP_LOGD(TAG, "General %d - Align&Cut", i);
  418. caic->CutAndSave(GENERAL[_ana]->ROI[i]->posx, GENERAL[_ana]->ROI[i]->posy, GENERAL[_ana]->ROI[i]->deltax, GENERAL[_ana]->ROI[i]->deltay, GENERAL[_ana]->ROI[i]->image_org);
  419. if (SaveAllFiles)
  420. {
  421. if (GENERAL[_ana]->name == "default")
  422. GENERAL[_ana]->ROI[i]->image_org->SaveToFile(FormatFileName("/sdcard/img_tmp/" + GENERAL[_ana]->ROI[i]->name + ".jpg"));
  423. else
  424. GENERAL[_ana]->ROI[i]->image_org->SaveToFile(FormatFileName("/sdcard/img_tmp/" + GENERAL[_ana]->name + "_" + GENERAL[_ana]->ROI[i]->name + ".jpg"));
  425. }
  426. GENERAL[_ana]->ROI[i]->image_org->Resize(modelxsize, modelysize, GENERAL[_ana]->ROI[i]->image);
  427. if (SaveAllFiles)
  428. {
  429. if (GENERAL[_ana]->name == "default")
  430. GENERAL[_ana]->ROI[i]->image->SaveToFile(FormatFileName("/sdcard/img_tmp/" + GENERAL[_ana]->ROI[i]->name + ".jpg"));
  431. else
  432. GENERAL[_ana]->ROI[i]->image->SaveToFile(FormatFileName("/sdcard/img_tmp/" + GENERAL[_ana]->name + "_" + GENERAL[_ana]->ROI[i]->name + ".jpg"));
  433. }
  434. }
  435. return true;
  436. }
  437. void ClassFlowCNNGeneral::DrawROI(CImageBasis *_zw)
  438. {
  439. if (_zw->ImageOkay())
  440. {
  441. if (CNNType == Analogue || CNNType == Analogue100)
  442. {
  443. int r = 0;
  444. int g = 255;
  445. int b = 0;
  446. for (int _ana = 0; _ana < GENERAL.size(); ++_ana)
  447. for (int i = 0; i < GENERAL[_ana]->ROI.size(); ++i)
  448. {
  449. _zw->drawRect(GENERAL[_ana]->ROI[i]->posx, GENERAL[_ana]->ROI[i]->posy, GENERAL[_ana]->ROI[i]->deltax, GENERAL[_ana]->ROI[i]->deltay, r, g, b, 1);
  450. _zw->drawEllipse( (int) (GENERAL[_ana]->ROI[i]->posx + GENERAL[_ana]->ROI[i]->deltax/2), (int) (GENERAL[_ana]->ROI[i]->posy + GENERAL[_ana]->ROI[i]->deltay/2), (int) (GENERAL[_ana]->ROI[i]->deltax/2), (int) (GENERAL[_ana]->ROI[i]->deltay/2), r, g, b, 2);
  451. _zw->drawLine((int) (GENERAL[_ana]->ROI[i]->posx + GENERAL[_ana]->ROI[i]->deltax/2), (int) GENERAL[_ana]->ROI[i]->posy, (int) (GENERAL[_ana]->ROI[i]->posx + GENERAL[_ana]->ROI[i]->deltax/2), (int) (GENERAL[_ana]->ROI[i]->posy + GENERAL[_ana]->ROI[i]->deltay), r, g, b, 2);
  452. _zw->drawLine((int) GENERAL[_ana]->ROI[i]->posx, (int) (GENERAL[_ana]->ROI[i]->posy + GENERAL[_ana]->ROI[i]->deltay/2), (int) GENERAL[_ana]->ROI[i]->posx + GENERAL[_ana]->ROI[i]->deltax, (int) (GENERAL[_ana]->ROI[i]->posy + GENERAL[_ana]->ROI[i]->deltay/2), r, g, b, 2);
  453. }
  454. }
  455. else
  456. {
  457. for (int _dig = 0; _dig < GENERAL.size(); ++_dig)
  458. for (int i = 0; i < GENERAL[_dig]->ROI.size(); ++i)
  459. _zw->drawRect(GENERAL[_dig]->ROI[i]->posx, GENERAL[_dig]->ROI[i]->posy, GENERAL[_dig]->ROI[i]->deltax, GENERAL[_dig]->ROI[i]->deltay, 0, 0, (255 - _dig*100), 2);
  460. }
  461. }
  462. }
  463. bool ClassFlowCNNGeneral::getNetworkParameter()
  464. {
  465. if (disabled)
  466. return true;
  467. CTfLiteClass *tflite = new CTfLiteClass;
  468. string zwcnn = "/sdcard" + cnnmodelfile;
  469. zwcnn = FormatFileName(zwcnn);
  470. ESP_LOGD(TAG, "%s", zwcnn.c_str());
  471. if (!tflite->LoadModel(zwcnn)) {
  472. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Can't load tflite model " + cnnmodelfile + " -> Init aborted!");
  473. LogFile.WriteHeapInfo("getNetworkParameter-LoadModel");
  474. delete tflite;
  475. return false;
  476. }
  477. if (!tflite->MakeAllocate()) {
  478. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Can't allocate tflite model -> Init aborted!");
  479. LogFile.WriteHeapInfo("getNetworkParameter-MakeAllocate");
  480. delete tflite;
  481. return false;
  482. }
  483. if (CNNType == AutoDetect)
  484. {
  485. tflite->GetInputDimension(false);
  486. modelxsize = tflite->ReadInputDimenstion(0);
  487. modelysize = tflite->ReadInputDimenstion(1);
  488. modelchannel = tflite->ReadInputDimenstion(2);
  489. int _anzoutputdimensions = tflite->GetAnzOutPut();
  490. switch (_anzoutputdimensions)
  491. {
  492. case 2:
  493. CNNType = Analogue;
  494. ESP_LOGD(TAG, "TFlite-Type set to Analogue");
  495. break;
  496. case 10:
  497. CNNType = DoubleHyprid10;
  498. ESP_LOGD(TAG, "TFlite-Type set to DoubleHyprid10");
  499. break;
  500. case 11:
  501. CNNType = Digital;
  502. ESP_LOGD(TAG, "TFlite-Type set to Digital");
  503. break;
  504. /* case 20:
  505. CNNType = DigitalHyprid10;
  506. ESP_LOGD(TAG, "TFlite-Type set to DigitalHyprid10");
  507. break;
  508. */
  509. // case 22:
  510. // CNNType = DigitalHyprid;
  511. // ESP_LOGD(TAG, "TFlite-Type set to DigitalHyprid");
  512. // break;
  513. case 100:
  514. if (modelxsize==32 && modelysize == 32) {
  515. CNNType = Analogue100;
  516. ESP_LOGD(TAG, "TFlite-Type set to Analogue100");
  517. } else {
  518. CNNType = Digital100;
  519. ESP_LOGD(TAG, "TFlite-Type set to Digital");
  520. }
  521. break;
  522. default:
  523. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "tflite does not fit the firmware (outout_dimension=" + std::to_string(_anzoutputdimensions) + ")");
  524. }
  525. }
  526. delete tflite;
  527. return true;
  528. }
  529. bool ClassFlowCNNGeneral::doNeuralNetwork(string time)
  530. {
  531. if (disabled)
  532. return true;
  533. string logPath = CreateLogFolder(time);
  534. CTfLiteClass *tflite = new CTfLiteClass;
  535. string zwcnn = "/sdcard" + cnnmodelfile;
  536. zwcnn = FormatFileName(zwcnn);
  537. ESP_LOGD(TAG, "%s", zwcnn.c_str());
  538. if (!tflite->LoadModel(zwcnn)) {
  539. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Can't load tflite model " + cnnmodelfile + " -> Exec aborted this round!");
  540. LogFile.WriteHeapInfo("doNeuralNetwork-LoadModel");
  541. delete tflite;
  542. return false;
  543. }
  544. if (!tflite->MakeAllocate()) {
  545. LogFile.WriteToFile(ESP_LOG_ERROR, TAG, "Can't allocate tfilte model -> Exec aborted this round!");
  546. LogFile.WriteHeapInfo("doNeuralNetwork-MakeAllocate");
  547. delete tflite;
  548. return false;
  549. }
  550. for (int n = 0; n < GENERAL.size(); ++n) // For each NUMBER
  551. {
  552. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "Processing Number '" + GENERAL[n]->name + "'");
  553. for (int roi = 0; roi < GENERAL[n]->ROI.size(); ++roi) // For each ROI
  554. {
  555. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "ROI #" + std::to_string(roi) + " - TfLite");
  556. //ESP_LOGD(TAG, "General %d - TfLite", i);
  557. switch (CNNType) {
  558. case Analogue:
  559. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "CNN Type: Analogue");
  560. {
  561. float f1, f2;
  562. f1 = 0; f2 = 0;
  563. tflite->LoadInputImageBasis(GENERAL[n]->ROI[roi]->image);
  564. tflite->Invoke();
  565. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "After Invoke");
  566. f1 = tflite->GetOutputValue(0);
  567. f2 = tflite->GetOutputValue(1);
  568. float result = fmod(atan2(f1, f2) / (M_PI * 2) + 2, 1);
  569. if(GENERAL[n]->ROI[roi]->CCW)
  570. GENERAL[n]->ROI[roi]->result_float = 10 - (result * 10);
  571. else
  572. GENERAL[n]->ROI[roi]->result_float = result * 10;
  573. ESP_LOGD(TAG, "General result (Analog)%i - CCW: %d - %f", roi, GENERAL[n]->ROI[roi]->CCW, GENERAL[n]->ROI[roi]->result_float);
  574. if (isLogImage)
  575. LogImage(logPath, GENERAL[n]->ROI[roi]->name, &GENERAL[n]->ROI[roi]->result_float, NULL, time, GENERAL[n]->ROI[roi]->image_org);
  576. } break;
  577. case Digital:
  578. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "CNN Type: Digital");
  579. {
  580. GENERAL[n]->ROI[roi]->result_klasse = 0;
  581. GENERAL[n]->ROI[roi]->result_klasse = tflite->GetClassFromImageBasis(GENERAL[n]->ROI[roi]->image);
  582. ESP_LOGD(TAG, "General result (Digit)%i: %d", roi, GENERAL[n]->ROI[roi]->result_klasse);
  583. if (isLogImage)
  584. {
  585. string _imagename = GENERAL[n]->name + "_" + GENERAL[n]->ROI[roi]->name;
  586. if (isLogImageSelect)
  587. {
  588. if (LogImageSelect.find(GENERAL[n]->ROI[roi]->name) != std::string::npos)
  589. LogImage(logPath, _imagename, NULL, &GENERAL[n]->ROI[roi]->result_klasse, time, GENERAL[n]->ROI[roi]->image_org);
  590. }
  591. else
  592. {
  593. LogImage(logPath, _imagename, NULL, &GENERAL[n]->ROI[roi]->result_klasse, time, GENERAL[n]->ROI[roi]->image_org);
  594. }
  595. }
  596. } break;
  597. case DoubleHyprid10:
  598. {
  599. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "CNN Type: DoubleHyprid10");
  600. int _num, _numplus, _numminus;
  601. float _val, _valplus, _valminus;
  602. float _fit;
  603. float _result_save_file;
  604. tflite->LoadInputImageBasis(GENERAL[n]->ROI[roi]->image);
  605. tflite->Invoke();
  606. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "After Invoke");
  607. _num = tflite->GetOutClassification(0, 9);
  608. _numplus = (_num + 1) % 10;
  609. _numminus = (_num - 1 + 10) % 10;
  610. _val = tflite->GetOutputValue(_num);
  611. _valplus = tflite->GetOutputValue(_numplus);
  612. _valminus = tflite->GetOutputValue(_numminus);
  613. float result = _num;
  614. if (_valplus > _valminus)
  615. {
  616. result = result + _valplus / (_valplus + _val);
  617. _fit = _val + _valplus;
  618. }
  619. else
  620. {
  621. result = result - _valminus / (_val + _valminus);
  622. _fit = _val + _valminus;
  623. }
  624. if (result >= 10)
  625. result = result - 10;
  626. if (result < 0)
  627. result = result + 10;
  628. string zw = "_num (p, m): " + to_string(_num) + " " + to_string(_numplus) + " " + to_string(_numminus);
  629. zw = zw + " _val (p, m): " + to_string(_val) + " " + to_string(_valplus) + " " + to_string(_valminus);
  630. zw = zw + " result: " + to_string(result) + " _fit: " + to_string(_fit);
  631. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, zw);
  632. _result_save_file = result;
  633. if (_fit < CNNGoodThreshold)
  634. {
  635. GENERAL[n]->ROI[roi]->isReject = true;
  636. result = -1;
  637. _result_save_file+= 100; // In case fit is not sufficient, the result should still be saved with "-10x.y".
  638. string zw = "Value Rejected due to Threshold (Fit: " + to_string(_fit) + ", Threshold: " + to_string(CNNGoodThreshold) + ")";
  639. LogFile.WriteToFile(ESP_LOG_WARN, TAG, zw);
  640. }
  641. else
  642. {
  643. GENERAL[n]->ROI[roi]->isReject = false;
  644. }
  645. GENERAL[n]->ROI[roi]->result_float = result;
  646. ESP_LOGD(TAG, "Result General(Analog)%i: %f", roi, GENERAL[n]->ROI[roi]->result_float);
  647. if (isLogImage)
  648. {
  649. string _imagename = GENERAL[n]->name + "_" + GENERAL[n]->ROI[roi]->name;
  650. if (isLogImageSelect)
  651. {
  652. if (LogImageSelect.find(GENERAL[n]->ROI[roi]->name) != std::string::npos)
  653. LogImage(logPath, _imagename, &_result_save_file, NULL, time, GENERAL[n]->ROI[roi]->image_org);
  654. }
  655. else
  656. {
  657. LogImage(logPath, _imagename, &_result_save_file, NULL, time, GENERAL[n]->ROI[roi]->image_org);
  658. }
  659. }
  660. }
  661. break;
  662. case Digital100:
  663. case Analogue100:
  664. {
  665. LogFile.WriteToFile(ESP_LOG_DEBUG, TAG, "CNN Type: Digital100 or Analogue100");
  666. int _num;
  667. float _result_save_file;
  668. tflite->LoadInputImageBasis(GENERAL[n]->ROI[roi]->image);
  669. tflite->Invoke();
  670. _num = tflite->GetOutClassification();
  671. if(GENERAL[n]->ROI[roi]->CCW)
  672. GENERAL[n]->ROI[roi]->result_float = 10 - ((float)_num / 10.0);
  673. else
  674. GENERAL[n]->ROI[roi]->result_float = (float)_num / 10.0;
  675. _result_save_file = GENERAL[n]->ROI[roi]->result_float;
  676. GENERAL[n]->ROI[roi]->isReject = false;
  677. ESP_LOGD(TAG, "Result General(Analog)%i - CCW: %d - %f", roi, GENERAL[n]->ROI[roi]->CCW, GENERAL[n]->ROI[roi]->result_float);
  678. if (isLogImage)
  679. {
  680. string _imagename = GENERAL[n]->name + "_" + GENERAL[n]->ROI[roi]->name;
  681. if (isLogImageSelect)
  682. {
  683. if (LogImageSelect.find(GENERAL[n]->ROI[roi]->name) != std::string::npos)
  684. LogImage(logPath, _imagename, &_result_save_file, NULL, time, GENERAL[n]->ROI[roi]->image_org);
  685. }
  686. else
  687. {
  688. LogImage(logPath, _imagename, &_result_save_file, NULL, time, GENERAL[n]->ROI[roi]->image_org);
  689. }
  690. }
  691. } break;
  692. default:
  693. break;
  694. }
  695. }
  696. }
  697. delete tflite;
  698. return true;
  699. }
  700. bool ClassFlowCNNGeneral::isExtendedResolution(int _number)
  701. {
  702. if (!(CNNType == Digital))
  703. return true;
  704. return false;
  705. }
  706. std::vector<HTMLInfo*> ClassFlowCNNGeneral::GetHTMLInfo()
  707. {
  708. std::vector<HTMLInfo*> result;
  709. for (int _ana = 0; _ana < GENERAL.size(); ++_ana)
  710. for (int i = 0; i < GENERAL[_ana]->ROI.size(); ++i)
  711. {
  712. ESP_LOGD(TAG, "Image: %d", (int) GENERAL[_ana]->ROI[i]->image);
  713. if (GENERAL[_ana]->ROI[i]->image)
  714. {
  715. if (GENERAL[_ana]->name == "default")
  716. GENERAL[_ana]->ROI[i]->image->SaveToFile(FormatFileName("/sdcard/img_tmp/" + GENERAL[_ana]->ROI[i]->name + ".jpg"));
  717. else
  718. GENERAL[_ana]->ROI[i]->image->SaveToFile(FormatFileName("/sdcard/img_tmp/" + GENERAL[_ana]->name + "_" + GENERAL[_ana]->ROI[i]->name + ".jpg"));
  719. }
  720. HTMLInfo *zw = new HTMLInfo;
  721. if (GENERAL[_ana]->name == "default")
  722. {
  723. zw->filename = GENERAL[_ana]->ROI[i]->name + ".jpg";
  724. zw->filename_org = GENERAL[_ana]->ROI[i]->name + ".jpg";
  725. }
  726. else
  727. {
  728. zw->filename = GENERAL[_ana]->name + "_" + GENERAL[_ana]->ROI[i]->name + ".jpg";
  729. zw->filename_org = GENERAL[_ana]->name + "_" + GENERAL[_ana]->ROI[i]->name + ".jpg";
  730. }
  731. if (CNNType == Digital)
  732. zw->val = GENERAL[_ana]->ROI[i]->result_klasse;
  733. else
  734. zw->val = GENERAL[_ana]->ROI[i]->result_float;
  735. zw->image = GENERAL[_ana]->ROI[i]->image;
  736. zw->image_org = GENERAL[_ana]->ROI[i]->image_org;
  737. result.push_back(zw);
  738. }
  739. return result;
  740. }
  741. int ClassFlowCNNGeneral::getNumberGENERAL()
  742. {
  743. return GENERAL.size();
  744. }
  745. string ClassFlowCNNGeneral::getNameGENERAL(int _analog)
  746. {
  747. if (_analog < GENERAL.size())
  748. return GENERAL[_analog]->name;
  749. return "GENERAL DOES NOT EXIST";
  750. }
  751. general* ClassFlowCNNGeneral::GetGENERAL(int _analog)
  752. {
  753. if (_analog < GENERAL.size())
  754. return GENERAL[_analog];
  755. return NULL;
  756. }
  757. void ClassFlowCNNGeneral::UpdateNameNumbers(std::vector<std::string> *_name_numbers)
  758. {
  759. for (int _dig = 0; _dig < GENERAL.size(); _dig++)
  760. {
  761. std::string _name = GENERAL[_dig]->name;
  762. bool found = false;
  763. for (int i = 0; i < (*_name_numbers).size(); ++i)
  764. {
  765. if ((*_name_numbers)[i] == _name)
  766. found = true;
  767. }
  768. if (!found)
  769. (*_name_numbers).push_back(_name);
  770. }
  771. }
  772. string ClassFlowCNNGeneral::getReadoutRawString(int _analog)
  773. {
  774. string rt = "";
  775. if (_analog >= GENERAL.size() || GENERAL[_analog]==NULL || GENERAL[_analog]->ROI.size() == 0)
  776. return rt;
  777. for (int i = 0; i < GENERAL[_analog]->ROI.size(); ++i)
  778. {
  779. if (CNNType == Analogue || CNNType == Analogue100)
  780. {
  781. rt = rt + "," + RundeOutput(GENERAL[_analog]->ROI[i]->result_float, 1);
  782. }
  783. if (CNNType == Digital)
  784. {
  785. if (GENERAL[_analog]->ROI[i]->result_klasse == 10)
  786. rt = rt + ",N";
  787. else
  788. rt = rt + "," + RundeOutput(GENERAL[_analog]->ROI[i]->result_klasse, 0);
  789. }
  790. if ((CNNType == DoubleHyprid10) || (CNNType == Digital100))
  791. {
  792. rt = rt + "," + RundeOutput(GENERAL[_analog]->ROI[i]->result_float, 1);
  793. }
  794. }
  795. return rt;
  796. }