audit_krs_con_digger.php 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608
  1. <?php
  2. $_SERVER['SERVER_NAME'] = 'biuro.biall-net.pl';
  3. //when used in /Library/Server/Web/Data/Sites/bzyk-biale-plamy-php-temp/SE/dev on biuro.biall-net.pl
  4. if( file_exists ( "../../se-lib/bootstrap.php"))
  5. require("../../se-lib/bootstrap.php");
  6. //when used in in native SE
  7. else require("../../../../SE-production-git/SE/se-lib/bootstrap.php");
  8. Lib::loadClass("Vendor_Geophp");
  9. $db = DB::getDB();
  10. // DB::getPDO()->query("truncate table Rozdzielcza_test_bzyk_Cables_to_PE");
  11. //unset($ID_Way);
  12. /*foreach($cables_from_joins_to_PE_arr as $id_j=>$Path_Point_val) {
  13. $sql_Path_Point_val="insert into Rozdzielcza_test_bzyk_Cables_to_PE (the_geom,ID_Way,ID_Point,len,PE_ID_Join)
  14. values (ST_GeomFromText('".$Path_Point_val['LINESTRING']."'),'".$Path_Point_val['ID_Way']."',
  15. '".$Path_Point_val['ID_Point']."' ,'".$Path_Point_val['len']."','".$Path_Point_val['PE_ID_Join']."' ) ";
  16. echo "#216Query path ins:: ".$sql_Path_Point_val." ";
  17. //if(strlen($edge_joins_filled_paths[$ID_Way]['asText'])>2)
  18. if(strlen($Path_Point_val['LINESTRING'])>1)
  19. DB::getPDO()->query($sql_Path_Point_val);
  20. else echo " ERROR blad danych!!! dla ID_Point:".$Path_Point_val['ID_Point'];
  21. //else echo "#296 path nie wygenerowalo sie !! dla ".$ID_Way." i pkt ".$pkt_A." , ".$pkt_B." \n";
  22. }
  23. */
  24. $tables['Y']['BI_audit_ENERGA_PRACOWNICY']['rel']['pesel']='pesel';
  25. $tables['Y']['BI_audit_ENERGA_PRACOWNICY']['rel']['nip']='nip';
  26. $tables['Y']['BI_audit_ENERGA_PRACOWNICY']['rel']['regon']='regon';
  27. $tables['Y']['BI_audit_ENERGA_PRACOWNICY']['rel']['ID_BI_audit_ENERGA_PRACOWNICY']='ID';
  28. //$tables['X']['BI_audit_KW_requested']['rel_search']['pesel']='Seller_Person';
  29. //$tables['X']['BI_audit_KW_requested']['rel']['pesel']['search']='like';
  30. $tables['Z']['BI_audit_ENERGA_PRACOWNICY_adresy']['rel']['ID_BI_audit_ENERGA_PRACOWNICY']='ID_BI_audit_ENERGA_PRACOWNICY';
  31. $tables['Z']['BI_audit_ENERGA_PRACOWNICY_adresy']['rel_and']['TERYT']['TERYT_SYM']='TERYT_SYM';
  32. $tables['Z']['BI_audit_ENERGA_PRACOWNICY_adresy']['rel_and']['TERYT']['TERYT_SYM_UL']='TERYT_SYM_UL';
  33. $tables['Z']['BI_audit_ENERGA_PRACOWNICY_adresy']['rel_and']['TERYT']['budynek']='nrBudynku';
  34. $tables['Z']['BI_audit_ENERGA_PRACOWNICY_adresy']['rel_and']['TERYT']['nrLokalu']='nrLokalu';
  35. $tables['X']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel']['BI_audit_ENERGA_RUM_KONTRAHENCI']='ID';
  36. $tables['X']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel']['nip']='NIP';
  37. $tables['X']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel']['regon']='REGON';
  38. $tables['X']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel_like']['pesel']='PESEL';
  39. $tables['Z']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel']['BI_audit_ENERGA_RUM_KONTRAHENCI']='ID';
  40. $tables['Z']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel_and']['TERYT']['TERYT_SYM']='TERYT_SYM';
  41. $tables['Z']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel_and']['TERYT']['TERYT_SYM_UL']='TERYT_SYM_UL';
  42. $tables['Z']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel_and']['TERYT']['nrLokalu']='Numer_mieszkania_lokalu';
  43. $tables['Z']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel_and']['TERYT']['budynek']='Numer_budynku';
  44. //$tables['X']['BI_audit_ENERGA_RUM_KONTRAHENCI']['rel']['teryt']=1;
  45. //$tables['X']['BI_audit_ENERGA_RUM_UMOWY']['rel_like']['nip']='Strony_umowy';
  46. $tables['Z']['BI_audit_CEIDG']['rel']['nip']='nip';
  47. $tables['Z']['BI_audit_CEIDG']['rel']['regon']='regon';
  48. //$tables['Z']['BI_audit_CEIDG']['rel_and']['adres']['miejscowosc']='miejscowosc';
  49. //$tables['Z']['BI_audit_CEIDG']['rel_and']['adres']['ulica']='ulica';
  50. //$tables['Z']['BI_audit_CEIDG']['rel_and']['adres']['kodPocztowy']='kodPocztowy';
  51. //$tables['Z']['BI_audit_CEIDG']['rel_and']['adres']['budynek']='budynek';
  52. $tables['Z']['BI_audit_CEIDG']['rel_and']['TERYT']['TERYT_SYM']='TERYT_SYM';
  53. $tables['Z']['BI_audit_CEIDG']['rel_and']['TERYT']['TERYT_SYM_UL']='TERYT_SYM_UL';
  54. $tables['Z']['BI_audit_CEIDG']['rel_and']['TERYT']['nrLokalu']='lokal';
  55. $tables['Z']['BI_audit_CEIDG']['rel_and']['TERYT']['budynek']='budynek';
  56. $tables['Z']['BI_audit_CEIDG']['ref'][19]='BI_audit_CEIDG_pelnomocnicy';
  57. $tables['Z']['BI_audit_CEIDG']['ref'][18]='BI_audit_CEIDG_powiazania';
  58. $tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel']['nip']='nip';
  59. //$tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel_and']['adres']['miejscowosc']='miejscowosc';
  60. //$tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel_and']['adres']['ulica']='ulica';
  61. //$tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel_and']['adres']['kodPocztowy']='kodPocztowy';
  62. $tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel_and']['TERYT']['TERYT_SYM']='TERYT_SYM';
  63. $tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel_and']['TERYT']['TERYT_SYM_UL']='TERYT_SYM_UL';
  64. $tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel_and']['TERYT']['nrLokalu']='lokal';
  65. $tables['Z']['BI_audit_CEIDG_pelnomocnicy']['rel_and']['TERYT']['budynek']='budynek';
  66. $tables['Z']['BI_audit_CEIDG_pelnomocnicy']['backref'][19]='BI_audit_CEIDG';
  67. $tables['Z']['BI_audit_CEIDG_powiazania']['rel']['nip']='nip';
  68. $tables['Z']['BI_audit_CEIDG_powiazania']['rel']['regon']='regon';
  69. $tables['Z']['BI_audit_CEIDG_powiazania']['backref'][18]='BI_audit_CEIDG';
  70. $tables['Z']['BI_audit_KRS']['rel']['nip']='nip';
  71. $tables['Z']['BI_audit_KRS']['rel']['regon']='regon';
  72. $tables['Z']['BI_audit_KRS']['rel']['krs']='krs';
  73. //$tables['Z']['BI_audit_KRS']['rel_and']['adres']['miejscowosc']='A_miejscowosc';
  74. //$tables['Z']['BI_audit_KRS']['rel_and']['adres']['ulica']='A_ulica';
  75. //$tables['Z']['BI_audit_KRS']['rel_and']['adres']['kodPocztowy']='A_kod';
  76. //$tables['Z']['BI_audit_KRS']['rel_and']['adres']['budynek']='A_nrDomu';
  77. $tables['Z']['BI_audit_KRS']['rel_and']['TERYT']['TERYT_SYM']='TERYT_SYM';
  78. $tables['Z']['BI_audit_KRS']['rel_and']['TERYT']['TERYT_SYM_UL']='TERYT_SYM_UL';
  79. $tables['Z']['BI_audit_KRS']['rel_and']['TERYT']['nrLokalu']='A_nrLokalu';
  80. $tables['Z']['BI_audit_KRS']['rel_and']['TERYT']['budynek']='A_nrDomu';
  81. $tables['Z']['BI_audit_KRS']['ref'][12]='BI_audit_KRS_person';
  82. $tables['Z']['BI_audit_KRS']['ref'][11]='BI_audit_KRS_company';
  83. $tables['Z']['BI_audit_KRS_company']['rel']['regon']='regon';
  84. $tables['Z']['BI_audit_KRS_company']['rel']['krs']='krs';
  85. $tables['Z']['BI_audit_KRS_company']['backref'][11]='BI_audit_KRS';
  86. $tables['Z']['BI_audit_KRS_person']['rel']['pesel']='pesel';
  87. $tables['Z']['BI_audit_KRS_person']['backref'][12]='BI_audit_KRS';
  88. function start_dig($tables) {
  89. global $db;
  90. foreach($tables['Y'] as $Y=>$t) {
  91. $sql='select * from '.$Y.' where ID=12 or ID=19 or 1=1 limit 100' ;
  92. $res=$db->query($sql);
  93. while($h=$db->fetch($res)) {
  94. $hist_loop[$Y][]=$h;
  95. $hist_time[][$Y]=$h;
  96. dig_next($hist_loop,$t,$h,1,$hist_time,$Y,add_path('//',$Y));
  97. unset($hist_time);
  98. }
  99. }
  100. }
  101. function add_path($path,$last_tbl) {
  102. $path.="/".$last_tbl;
  103. return $path;
  104. }
  105. function sql($hist_loop,$prev_tbl,$prev_dig,$loop,$hist_time,$last_tbl,$path,$table_class) {
  106. global $tables;
  107. foreach($tables[$table_class] as $Z=>$z) {
  108. //rels in tbls
  109. foreach($z['rel'] as $z_rel_from=>$z_rel_to) {
  110. // echo "110 test z_rel_fr ".$z_rel_from." to z_rel_to ".$z_rel_to ;
  111. if( isset($prev_tbl['rel'][$z_rel_from])) {
  112. if( strlen($prev_dig->$prev_tbl['rel'][$z_rel_from]) > 0 ) {
  113. $sql[$Z]['rel'][$z_rel_to] = $prev_dig->$prev_tbl['rel'][$z_rel_from];
  114. $path_rel[$Z][]="(".$z_rel_to.")";
  115. }
  116. }
  117. }
  118. //search addr
  119. if(isset($z['rel_and']) and isset($prev_tbl['rel_and'])) {
  120. foreach($z['rel_and'] as $z_rel_and=>$z_rel_and_name) {
  121. $rel_and_ok=1;
  122. foreach($z_rel_and_name as $z_rel_and_name_cur=>$z_rel_and_name_col_to) {
  123. if(isset($prev_dig->$prev_tbl['rel_and'][$z_rel_and][$z_rel_and_name_cur]) and ( strlen($prev_dig->$prev_tbl['rel_and'][$z_rel_and][$z_rel_and_name_cur])) > 0 ) {//and ( strlen($prev_dig->$z_rel_and_name_cur) > 2)
  124. if($rel_and_ok<>0) $rel_and_ok=2;
  125. echo "\n<br>121 rel_and from:".$last_tbl." name: ".$z_rel_and_name_cur." OK for tbl ".$Z." z_rel_and_name_col_to: ".$z_rel_and_name_col_to." value:".$prev_dig->$prev_tbl['rel_and'][$z_rel_and][$z_rel_and_name_cur]." rel_and_ok=".$rel_and_ok;
  126. } else {
  127. echo "<br>\n #127 UNSET rel_and from:".$last_tbl." name ".$z_rel_and_name_cur." / ".$z_rel_and_name_col_to." ";
  128. $rel_and_ok=0;
  129. }
  130. }
  131. if($rel_and_ok==2) {
  132. $path_rel_and = array();
  133. // echo "\n<br>#133 Z=".$Z." ok rel_and_ok=".$rel_and_ok;
  134. foreach($z_rel_and_name as $z_rel_and_name_cur=>$z_rel_and_name_col_to) {
  135. // echo "\n<br> 135... ok. Z=".$Z."/ z_rel_and_name=".$z_rel_and_name_cur."/ z_rel_and_name_col_to=".$z_rel_and_name_col_to."/ prev_dig-z_rel_and_name_cur=".$prev_dig->$z_rel_and_name_cur;
  136. $sql_rel_and[$Z][$z_rel_and][$z_rel_and_name_col_to]=$prev_dig->$prev_tbl['rel_and'][$z_rel_and][$z_rel_and_name_cur];
  137. $path_rel_and[]="(".$z_rel_and_name_col_to.")";
  138. }
  139. } else {
  140. // echo "<br>#137 error rel_and_ok=".$rel_and_ok;
  141. }
  142. }
  143. }
  144. }
  145. if( isset($sql_rel_and)) {
  146. foreach($sql_rel_and as $T=>$z_rel_and_arr) {
  147. foreach($z_rel_and_arr as $z_rel_and_name=>$z_rel_and_name_col) {
  148. //echo "<br>156 z_rel_and_name=".$z_rel_and_name." ";
  149. $sql_rel_and_sql[$T][$z_rel_and_name]="select * from ".$T." where ( ";
  150. $and=0;
  151. foreach($z_rel_and_name_col as $z_rel_and_name_cur=>$z_rel_and_name_col_to) {
  152. if( $and==1) $sql_rel_and_sql[$T][$z_rel_and_name].=" and `".$z_rel_and_name_cur."` = '".$z_rel_and_name_col_to."' and `".$z_rel_and_name_cur."` not like '%--%' and `".$z_rel_and_name_cur."` not like '' " ;
  153. else $sql_rel_and_sql[$T][$z_rel_and_name].=" `".$z_rel_and_name_cur."` like '".$z_rel_and_name_col_to."' and `".$z_rel_and_name_cur."` not like '%--%' and `".$z_rel_and_name_cur."` not like '' " ;
  154. // if($z_rel_and_name_cur=='miejscowosc') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `miejscowosc` not like '' " ;
  155. // if($z_rel_and_name_cur=='A_ulica') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `A_ulica` not like '' " ;
  156. // if($z_rel_and_name_cur=='ulica') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `ulica` not like '' " ;
  157. // if($z_rel_and_name_cur=='kodPocztowy') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `kodPocztowy` not like '' " ;
  158. // if($z_rel_and_name_cur=='budynek') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `budynek` like '".$z_rel_and_name_col_to."' " ;
  159. // if($z_rel_and_name_cur=='A_nrDomu') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `A_nrDomu` like '".$z_rel_and_name_col_to."' " ;
  160. // if($z_rel_and_name_cur=='kodPocztowy') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `kodPocztowy` like '".$z_rel_and_name_col_to."' " ;
  161. $and=1;
  162. }
  163. $sql_rel_and_sql[$T][$z_rel_and_name].=" ) " ;
  164. if( isset($hist_loop[$T])) {
  165. foreach($hist_loop[$T] as $hist_rec) {
  166. $sql_rel_and_sql[$T][$z_rel_and_name].=" and ID!='".$hist_rec->ID."' ";
  167. }
  168. }
  169. $sql_rel_and_sql[$T][$z_rel_and_name].=" ; " ;
  170. dig_arr_cur($hist_loop,$T,$sql_rel_and_sql[$T][$z_rel_and_name],$hist_time,$loop,$last_tbl,$path);
  171. }
  172. }
  173. }
  174. if(isset($sql)) {
  175. foreach($sql as $T => $rel) {
  176. $sql_t[$T]=" select * from ".$T." where ( ";
  177. foreach($rel['rel'] as $col=>$val) {
  178. if( isset($sql_t_str[$T])) $sql_t_str[$T].=" or `".$col."` = '".$val."' " ;
  179. else $sql_t_str[$T]=" `".$col."` = '".$val."' " ;
  180. }
  181. $sql_t[$T].=$sql_t_str[$T]." ) ";
  182. //not loop
  183. if( isset($hist_loop[$T])) {
  184. echo "<br> hist loop cnt: ". count($hist_loop[$T]);
  185. foreach($hist_loop[$T] as $hist_rec) {
  186. $sql_t[$T].=" and ID!='".$hist_rec->ID."' ";
  187. }
  188. }
  189. }
  190. if( isset($sql_t)) {
  191. foreach($sql_t as $T => $sql_ext) {
  192. // $path.=$path_rel[$T][ key($sql_ext) ];
  193. dig_arr_cur($hist_loop,$T,$sql_ext,$hist_time,$loop,$last_tbl,$path);
  194. }
  195. }
  196. }
  197. }
  198. function dig_next($hist_loop,$prev_tbl,$prev_dig,$loop,$hist_time,$last_tbl='n/s',$path) {
  199. global $db,$tables;
  200. $loop++;
  201. echo "\n<hr>###LOOP ".$loop." path:".$path;
  202. if($loop<12) {
  203. //detect next ref tbls
  204. $sql = array();
  205. $sql_RELAND = array();
  206. sql($hist_loop,$prev_tbl,$prev_dig,$loop,$hist_time,$last_tbl,$path,'Z');
  207. /*foreach($tables['Z'] as $Z=>$z) {
  208. //rels in tbls
  209. foreach($z['rel'] as $z_rel_from=>$z_rel_to) {
  210. // echo "110 test z_rel_fr ".$z_rel_from." to z_rel_to ".$z_rel_to ;
  211. if( isset($prev_tbl['rel'][$z_rel_from])) {
  212. if( strlen($prev_dig->$prev_tbl['rel'][$z_rel_from]) > 0 ) {
  213. $sql[$Z]['rel'][$z_rel_to] = $prev_dig->$prev_tbl['rel'][$z_rel_from];
  214. $path_rel[$Z][]="(".$z_rel_to.")";
  215. }
  216. }
  217. }
  218. //search addr
  219. if(isset($z['rel_and'])) {
  220. foreach($z['rel_and'] as $z_rel_and=>$z_rel_and_name) {
  221. $rel_and_ok=1;
  222. foreach($z_rel_and_name as $z_rel_and_name_cur=>$z_rel_and_name_col_to) {
  223. if(isset($prev_dig->$z_rel_and_name_col_to) and ( strlen($prev_dig->$z_rel_and_name_col_to)) > 0 ) {//and ( strlen($prev_dig->$z_rel_and_name_cur) > 2)
  224. if($rel_and_ok<>0) $rel_and_ok=2;
  225. // echo "\n<br>121 rel_and from:".$last_tbl." OK for tbl ".$Z." z_rel_and_name_col_to: ".$z_rel_and_name_col_to." value:".$prev_dig->$z_rel_and_name_cur." rel_and_ok=".$rel_and_ok;
  226. } else {
  227. // echo "<br> #127 UNSET ".$prev_dig->$z_rel_and_name_cur." / ".$z_rel_and_name_col_to." ";
  228. $rel_and_ok=0;
  229. }
  230. }
  231. if($rel_and_ok==2) {
  232. $path_rel_and = array();
  233. // echo "\n<br>#133 Z=".$Z." ok rel_and_ok=".$rel_and_ok;
  234. foreach($z_rel_and_name as $z_rel_and_name_cur=>$z_rel_and_name_col_to) {
  235. // echo "\n<br> 135... ok. Z=".$Z."/ z_rel_and_name=".$z_rel_and_name_cur."/ z_rel_and_name_col_to=".$z_rel_and_name_col_to."/ prev_dig-z_rel_and_name_cur=".$prev_dig->$z_rel_and_name_cur;
  236. $sql_rel_and[$Z][$z_rel_and][$z_rel_and_name_col_to]=$prev_dig->$z_rel_and_name_col_to;
  237. $path_rel_and[]="(".$z_rel_and_name_col_to.")";
  238. }
  239. } else {
  240. // echo "<br>#137 error rel_and_ok=".$rel_and_ok;
  241. }
  242. }
  243. }
  244. }
  245. // echo "<br>135:sql_rel_and <pre>";
  246. // print_r($sql_rel_and);
  247. // echo " .EOF</pre>";
  248. if( isset($sql_rel_and)) {
  249. foreach($sql_rel_and as $T=>$z_rel_and_arr) {
  250. foreach($z_rel_and_arr as $z_rel_and_name=>$z_rel_and_name_col) {
  251. //echo "<br>156 z_rel_and_name=".$z_rel_and_name." ";
  252. $sql_rel_and_sql[$T][$z_rel_and_name]="select * from ".$T." where ( ";
  253. $and=0;
  254. foreach($z_rel_and_name_col as $z_rel_and_name_cur=>$z_rel_and_name_col_to) {
  255. if( $and==1) $sql_rel_and_sql[$T][$z_rel_and_name].=" and `".$z_rel_and_name_cur."` = '".$z_rel_and_name_col_to."' and `".$z_rel_and_name_cur."` not like '%--%' and `".$z_rel_and_name_cur."` not like '' " ;
  256. else $sql_rel_and_sql[$T][$z_rel_and_name].=" `".$z_rel_and_name_cur."` like '".$z_rel_and_name_col_to."' and `".$z_rel_and_name_cur."` not like '%--%' and `".$z_rel_and_name_cur."` not like '' " ;
  257. // if($z_rel_and_name_cur=='miejscowosc') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `miejscowosc` not like '' " ;
  258. // if($z_rel_and_name_cur=='A_ulica') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `A_ulica` not like '' " ;
  259. // if($z_rel_and_name_cur=='ulica') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `ulica` not like '' " ;
  260. // if($z_rel_and_name_cur=='kodPocztowy') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `kodPocztowy` not like '' " ;
  261. // if($z_rel_and_name_cur=='budynek') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `budynek` like '".$z_rel_and_name_col_to."' " ;
  262. // if($z_rel_and_name_cur=='A_nrDomu') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `A_nrDomu` like '".$z_rel_and_name_col_to."' " ;
  263. // if($z_rel_and_name_cur=='kodPocztowy') $sql_rel_and_sql[$T][$z_rel_and_name].=" and `kodPocztowy` like '".$z_rel_and_name_col_to."' " ;
  264. $and=1;
  265. }
  266. $sql_rel_and_sql[$T][$z_rel_and_name].=" ) " ;
  267. if( isset($hist_loop[$T])) {
  268. foreach($hist_loop[$T] as $hist_rec) {
  269. $sql_rel_and_sql[$T][$z_rel_and_name].=" and ID!='".$hist_rec->ID."' ";
  270. }
  271. }
  272. $sql_rel_and_sql[$T][$z_rel_and_name].=" ; " ;
  273. dig_arr_cur($hist_loop,$T,$sql_rel_and_sql[$T][$z_rel_and_name],$hist_time,$loop,$last_tbl,$path);
  274. }
  275. }
  276. }
  277. */
  278. //echo "<br>164:sql_rel_and_sql <pre>";
  279. // print_r($sql_rel_and_sql);
  280. // echo " .EOF</pre>";
  281. //X test
  282. //echo " <br> 129 prev <pre>";
  283. // print_r($prev_dig);
  284. // echo "<br> prevtbl";
  285. // print_r($prev_tbl);
  286. // echo "</pre>";
  287. foreach($tables['X'] as $X=>$x) {
  288. //rels in tbls
  289. if( isset($x['rel']) ) {
  290. foreach($x['rel'] as $x_rel_from=>$x_rel_to) {
  291. //echo "\n<br> #133test tbl ".$X." z_rel_fr ".$x_rel_from." to z_rel_to ".$x_rel_to." prev tbl " ;
  292. if( isset($prev_tbl['rel'][$x_rel_from]) ) { //isset($prev_dig->$prev_tbl['rel'][$x_rel_to])
  293. // echo "<br>141 rel from ".$x_rel_from." exists .. testing field ".$prev_tbl['rel'][$x_rel_from]." <br>";//strlen(".$prev_dig->$prev_tbl['rel'][$x_rel_to].")
  294. if( isset($prev_dig->$prev_tbl['rel'][$x_rel_from]) and strlen($prev_dig->$prev_tbl['rel'][$x_rel_from]) > 1 ) { //
  295. $sql_X[$X]['rel'][$x_rel_to]= $prev_dig->$prev_tbl['rel'][$x_rel_from];
  296. }
  297. }
  298. }
  299. }
  300. //rel_like
  301. if( isset($x['rel_like'])) {
  302. foreach($x['rel_like'] as $x_rel_from=>$x_rel_to) {
  303. //echo "\n<br> #133test tbl ".$X." z_rel_fr ".$x_rel_from." to z_rel_to ".$x_rel_to." prev tbl " ;
  304. if( isset($prev_tbl['rel'][$x_rel_from]) ) { //isset($prev_dig->$prev_tbl['rel'][$x_rel_to])
  305. // echo "<br>141 rel from ".$x_rel_from." exists .. testing field ".$prev_tbl['rel'][$x_rel_from]." <br>";//strlen(".$prev_dig->$prev_tbl['rel'][$x_rel_to].")
  306. if( isset($prev_dig->$prev_tbl['rel'][$x_rel_from]) and strlen($prev_dig->$prev_tbl['rel'][$x_rel_from]) > 1 ) { //
  307. $sql_X1[$X]['rel_like'][$x_rel_to]= $prev_dig->$prev_tbl['rel'][$x_rel_from];
  308. }
  309. }
  310. }
  311. }
  312. }
  313. flush();
  314. // echo "\n<br>sql_X<pre>";
  315. // print_r($sql_X);
  316. // echo "</pre>";
  317. if( isset($sql_X)) {
  318. foreach($sql_X as $T => $rel) {
  319. $sql_x[$T]=" select * from ".$T." where ( ";
  320. foreach($rel['rel'] as $col=>$val) {
  321. if( isset($sql_x_str[$T])) $sql_x_str[$T].=" or `".$col."` = '".$val."' " ;
  322. else $sql_x_str[$T]=" `".$col."` = '".$val."' " ;
  323. }
  324. $sql_x[$T].=$sql_x_str[$T]." ) ";
  325. //not loop
  326. if( isset($hist_loop[$T])) {
  327. foreach($hist_loop[$T] as $hist_rec) {
  328. $sql_t[$T].=" and ID!='".$hist_rec->ID."' ";
  329. }
  330. }
  331. }
  332. }
  333. // echo "<br> sql_x" ;
  334. //print_r($sql_x);
  335. if( isset($sql_X1)) {
  336. foreach($sql_X1 as $T => $rel) {
  337. $sql_x1[$T]=" select * from ".$T." where ( ";
  338. foreach($rel['rel_like'] as $col=>$val) {
  339. if( isset($sql_x1_str[$T])) $sql_x1_str[$T].=" or `".$col."` like '%".$val."'%" ;
  340. else $sql_x1_str[$T]=" `".$col."` like '%".$val."%' " ;
  341. }
  342. $sql_x1[$T].=$sql_x1_str[$T]." ) ";
  343. //not loop
  344. if( isset($hist_loop[$T])) {
  345. foreach($hist_loop[$T] as $hist_rec) {
  346. $sql_t[$T].=" and ID!='".$hist_rec->ID."' ";
  347. }
  348. }
  349. }
  350. }
  351. if( isset($sql_x)) {
  352. foreach($sql_x as $X => $sql_ext) {
  353. echo "\n<br>174 Querying :".$sql_ext ;
  354. $res=$db->query($sql_ext) or die('175 blad');
  355. while($h=$db->fetch($res)) {
  356. echo "\n<hr> #177 POWIAZANIE ZNALEZIONE DLA X <pre>";
  357. print_r($h);
  358. echo "<br> Historia sledzen:";
  359. print_r($hist_time);
  360. echo "#177 eof </pre>";
  361. }
  362. }
  363. }
  364. if( isset($sql_x1)) {
  365. foreach($sql_x1 as $X => $sql_ext) {
  366. echo "\n<br>306 Querying :".$sql_ext ;
  367. $res=$db->query($sql_ext) or die('307 blad');
  368. while($h=$db->fetch($res)) {
  369. echo "\n<hr> #309 POWIAZANIE ZNALEZIONE DLA X2 <pre>";
  370. print_r($h);
  371. echo "<br> Historia sledzen:";
  372. print_r($hist_time);
  373. echo "<br>relacje:";
  374. echo "#177 eof </pre>";
  375. }
  376. }
  377. }
  378. //X test eof
  379. /*
  380. foreach($sql as $T => $rel) {
  381. $sql_t[$T]=" select * from ".$T." where ( ";
  382. foreach($rel['rel'] as $col=>$val) {
  383. if( isset($sql_t_str[$T])) $sql_t_str[$T].=" or `".$col."` = '".$val."' " ;
  384. else $sql_t_str[$T]=" `".$col."` = '".$val."' " ;
  385. }
  386. $sql_t[$T].=$sql_t_str[$T]." ) ";
  387. //not loop
  388. if( isset($hist_loop[$T])) {
  389. echo "<br> hist loop cnt: ". count($hist_loop[$T]);
  390. foreach($hist_loop[$T] as $hist_rec) {
  391. $sql_t[$T].=" and ID!='".$hist_rec->ID."' ";
  392. }
  393. }
  394. }
  395. // echo "<br> 202 hist loop cnt: <pre> ". count($hist_loop);
  396. // print_r($hist_loop);
  397. // echo "</pre>";
  398. // echo "<pre>sql_t";
  399. // print_r($sql);
  400. // echo "<br>sql_t ";
  401. // print_r($sql_t);
  402. // echo "</pre>";
  403. if( isset($sql_t)) {
  404. foreach($sql_t as $T => $sql_ext) {
  405. // $path.=$path_rel[$T][ key($sql_ext) ];
  406. dig_arr_cur($hist_loop,$T,$sql_ext,$hist_time,$loop,$last_tbl,$path);
  407. }
  408. }
  409. //todo look in Y and die()
  410. */
  411. } else {
  412. echo "\n<hr> #377 Przekroczony limit zagnieżdzeń dla wątku: path=".$path."; <pre>\n";
  413. //print_r($hist_time);
  414. echo "</pre>";
  415. }
  416. echo "<br>#243 glebokosc:".$loop;
  417. }
  418. function dig_arr_cur($hist_loop,$T,$sql_ext,$hist_time,$loop,$last_tbl,$path) {
  419. global $db,$tables;
  420. echo "\n<br>216: from:".$last_tbl." Querying :T ".$T." ext: ".$sql_ext ;//$sql_ext
  421. // echo "\n<br> las fou"
  422. flush();
  423. $res=$db->query($sql_ext) or die('211 blad '.$sql_ext);
  424. while($h=$db->fetch($res)) {
  425. echo "\n<br> #149 found ".$h->ID;
  426. // echo "<pre>"; print_r($h); echo "</pre>";
  427. // $hist_loop[$T][]=$h;
  428. // $hist_time[][$T]=$sql_ext." ##408 ".$path;
  429. // $hist_time[][$T]=$h;
  430. $hist_loop_root_cur['hist_loop']=$hist_loop;
  431. $hist_loop_root_cur['hist_time']=$hist_time;
  432. $hist_loop_root_cur['hist_loop'][$T][]=$h;
  433. $hist_loop_root_cur['hist_time'][]=$sql_ext." ##408 ".$path;
  434. $hist_loop_root_cur['hist_time'][]=$h;
  435. // print_r($hist_loop);
  436. $path_root=add_path($path,$T);
  437. dig_next($hist_loop_root_cur['hist_loop'], $tables['Z'][$T],$h,$loop,$hist_loop_root_cur['hist_time'],$last_tbl,$path_root);
  438. //rel dzieci $tables['Z']['BI_audit_CEIDG']['ref'][19]='BI_audit_CEIDG_pelnomocnicy';
  439. if(isset($tables['Z'][$T]['ref'])) {
  440. // echo "<br>#296 try to ref tables for T ".$T."<pre>";
  441. // print_r($tables['Z'][$T]['ref']);
  442. // echo "</pre>";
  443. foreach($tables['Z'][$T]['ref'] as $ref_id => $ref_table) {
  444. $sql_ref=" select REMOTE_PRIMARY_KEY from `CRM__#REF_TABLE__".$ref_id."` where `PRIMARY_KEY`=".$h->ID." ";
  445. $res_rel=$db->query($sql_ref) or die('211 blad '.$sql_ref);
  446. echo "<br>#297 ".$sql_ref;
  447. while($h_rel=$db->fetch($res_rel)){
  448. $sql_rel_rec="select * from `".$ref_table."` where ID=".$h_rel->REMOTE_PRIMARY_KEY." ";
  449. $res_rel_rec=$db->query($sql_rel_rec) or die('211 blad '.$sql_rel_rec);
  450. echo "<br>#159 ref tbl ".$sql_rel_rec;
  451. while($h_rel_rec=$db->fetch($res_rel_rec)){
  452. // echo "#315 fnd:".$h_rel_rec->ID;
  453. $hist_loop_cur=$hist_loop_root_cur;
  454. // $hist_loop_cur['hist_time']=$hist_time;
  455. //$hist_loop[$ref_table][]=$h_rel_rec;
  456. $hist_loop_cur['hist_loop'][$ref_table][]=$h_rel_rec;
  457. // $hist_time[][$ref_table]=$sql_rel_rec;
  458. // $hist_time[][$ref_table]=$h_rel_rec;
  459. $hist_loop_cur['hist_time'][]=$sql_rel_rec." #435".$path;
  460. $hist_loop_cur['hist_time'][]=$h_rel_rec;
  461. dig_next($hist_loop_cur['hist_loop'],$tables['Z'][$ref_table],$h_rel_rec,$loop,$hist_loop_cur['hist_time'],$ref_table,add_path($path_root,$ref_table));
  462. }
  463. }
  464. }
  465. } else echo "#322 not ref to ".$T;
  466. if(isset($tables['Z'][$T]['backref'])) {
  467. //echo "<br>#296 try to backref tables T ".$T."<pre>";
  468. // print_r($tables['Z'][$T]['backref']);
  469. //echo "</pre>";
  470. foreach($tables['Z'][$T]['backref'] as $ref_id => $ref_table) {
  471. $sql_ref=" select PRIMARY_KEY from `CRM__#REF_TABLE__".$ref_id."` where `REMOTE_PRIMARY_KEY`=".$h->ID." ";
  472. $res_rel=$db->query($sql_ref) or die('318 blad '.$sql_ref);
  473. echo "<br>#319 backref ".$sql_ref;
  474. while($h_rel=$db->fetch($res_rel)){
  475. $sql_rel_rec="select * from `".$ref_table."` where ID=".$h_rel->PRIMARY_KEY." ";
  476. $res_rel_rec=$db->query($sql_rel_rec) or die('211 blad '.$sql_rel_rec);
  477. echo "<br>#324 ref tbl ".$sql_rel_rec;
  478. while($h_rel_rec=$db->fetch($res_rel_rec)){
  479. // echo "#315 fnd:".$h_rel_rec->ID;
  480. $hist_loop_cur=$hist_loop_root_cur;
  481. // $hist_loop_cur['hist_time']=$hist_time;
  482. // $hist_loop[$ref_table][]=$h_rel_rec;
  483. $hist_loop_cur['hist_loop'][$ref_table][]=$h_rel_rec;
  484. //$hist_time[][$ref_table]=$sql_rel_rec;
  485. //$hist_time[][$ref_table]=$h_rel_rec;
  486. $hist_loop_cur['hist_time'][$ref_table][]=$sql_rel_rec." #464".$path;
  487. $hist_loop_cur['hist_time'][$ref_table][]=$h_rel_rec;
  488. dig_next($hist_loop_cur['hist_loop'],$tables['Z'][$ref_table],$h_rel_rec,$loop,$hist_loop_cur['hist_time'],$ref_table,add_path($path_root,$ref_table));
  489. }
  490. }
  491. }
  492. } else echo "#322 not backref to ".$T;
  493. }
  494. }
  495. start_dig($tables);
  496. echo "<hr>end of raport ";