library/DBC_decisiontree.php

   1 <?php
   2 /**
   3  * DBC DUTCH SYSTEM
   4  * Decision Tree - beslisboom
   5  *
   6  * functions used at the moment of closing dbc to choose a productgroep in the end
   7  * Cristian Navalici lemonsoftware [ @ ] gmail [ . ] com
   8  *
   9  * FUNCTIONS' LIST
  10  *
  11  * int dt_main(int $node) - main function; it's the decision point in our algorithm
  12  * string dt_whatparam(string $kmcode) - what param is needed for km* function
  13  * string dt_nodefunction(int $node) - what function is associated with a node
  14  * int dt_comparison(string $function, int $rval) - compare the values to make a decision
  15  * int dt_kma001()
  16  * int dt_kma002()
  17  */
  18
  19 /**
  20  * global variables used in script
  21  */
  22
  23 $beslis_table = ''; // we use different tables for 2007/08
  24 $rfsum = 0; // remember for sum - this we add all values from the algorithm
  25 $dbcid = 0; // dbc id
  26 $enddate = ''; // closing date for dbc (if used from a CLI script)
  27
  28 /**
  29  * if you run from a cron script (outside the webserver), use it this way
  30  *      include_once('library/DBC_cfunctions.php');
  31  *      include_once('library/DBC_decisiontree.php');
  32  *      global $rfsum;
  33  *      dt_main(1, 365, '2008-04-02');
  34  *      $z = dt_whatproductgroep($rfsum, '2008-04-02');
  35  *          1 - starting node, 365 - dbcid, '2008-04-02' - closing date
  36  */
  37
  38
  39 //-----------------------------------------------------------------------------
  40 /**
  41  * MAIN FUNCTION
  42  *
  43  * calls different functions, in a deadly precise algorithm
  44  *
  45  * @param int $node - in what node we are (default:1)
  46  * @param int $dbcid - in case we are calling from a script
  47  * @param string $end - closing date for dbc (used in dt_allevents)
  48  * @return int $rfsum - remember for sum
  49  */
  50 function dt_main($node = 1, $dbcid = 0, $end = '') {
  51     // if it's the first time, run the pre_init function
  52     if ( $node == 1 ) dt_preinit($dbcid, $end);
  53
  54     $function = dt_nodefunction($node);
  55
  56     switch ($function) {
  57         case 'KMA_001': $r = dt_kma001(); break;
  58         case 'KMA_002': $r = dt_kma002(); break;
  59         case 'KMA_003': $r = dt_kma003(); break;
  60         case 'KMA_004': $r = dt_kma004(); break;
  61         case 'KMA_005': $r = dt_kma005(); break;
  62         case 'KMT_001': $r = dt_kmt001($node); break;
  63         case 'KMT_002': $r = dt_kmt002(); break;
  64         case 'KMT_003': $r = dt_kmt003($node); break;
  65         case 'KMT_004': $r = dt_kmt004(); break;
  66         case 'KMN_001': $r = dt_kmn001($node); break;
  67         case 'KMP_001': $r = dt_kmp001(); break;
  68         case 'KMC_001': $r = dt_kmc001(); break;
  69     }
  70
  71     global $rfsum;
  72
  73     $direction = dt_comparison($node, $r);
  74     //echo "F:$function R: $r D: $direction SUM: $rfsum <br /> --------------- <br> "; //debug
  75     //echo "F:$function R: $r D: $direction SUM: $rfsum \n"; // debug for CLI
  76
  77     if ( $direction ) dt_main($direction);
  78     else {
  79         global $enddate, $dbcid;
  80         if ( !$dbcid ) $enddate = $_SESSION['eind']; // called from webinterface
  81
  82         if ( !$dbcid ) {
  83             // for a script, we must called this ourselves using global $rfsum and closing date
  84             $a = dt_whatproductgroep($rfsum, $enddate);
  85             // called from within openemr
  86             $_SESSION['pgroep'] = $a['id'];
  87             echo $a['name'];
  88         }
  89     }
  90
  91
  92 }
  93
  94 //-----------------------------------------------------------------------------
  95 /**
  96  * DECIDES WHAT TABLE WILL BE USED
  97  *
  98  * because the beslisboom has 2 tables (2007/2008), we must decide which one we'll use
  99  *
 100  * @param int $dbcid - in case we called this from a script (and we don't have $_SESSION)
 101  * @param string $end - closing date for dbc
 102  * @return void
 103  */
 104 function dt_preinit($dbc, $end) {
 105     // it sets some globals
 106     global $beslis_table, $dbcid, $enddate;
 107     $dbcid = $dbc;
 108     $enddate = $end;
 109
 110     $dbc = content_diagnose($dbcid);
 111     $odate = $dbc['ax_odate'];
 112
 113     if ( $odate <= '2007-12-31' ) {
 114         $beslis_table = 'cl_beslisboom_2007';
 115     } elseif ( $odate >= '2008-01-01') {
 116         $beslis_table = 'cl_beslisboom';
 117     } else {
 118         // leave room for more versions :)
 119     }
 120
 121 }
 122
 123
 124 //-----------------------------------------------------------------------------
 125 /**
 126  * COMPARISON
 127  *
 128  * function for comparison
 129  *
 130  * @param int $node - node to look for (and retrieve the one value)
 131  * @param int $value to compare
 132  * @return int - next node
 133  */
 134 function dt_comparison($node, $rval) {
 135     global $beslis_table;
 136     $q = sprintf("SELECT * FROM %s WHERE cbe_nodeorigin = %d ", $beslis_table, $node);
 137
 138     $r = mysql_query($q) or die(mysql_error());
 139
 140     if ( !mysql_num_rows($r) ) {
 141         return 0;
 142     } else {
 143         $row = mysql_fetch_array($r);
 144
 145         // compare the values function of the operator
 146         switch ( $row['cbe_operator'] ) {
 147             case '<=':  $rez = ( $rval <= $row['cbe_value1'] ); break;
 148             case '<':   $rez = ( $rval < $row['cbe_value1'] ); break;
 149             case '=':   $rez = ( $rval == $row['cbe_value1'] ); break;
 150             case '>=':  $rez = ( $rval >= $row['cbe_value1'] ); break;
 151         }
 152
 153         // update the remember for sum variable
 154         global $rfsum;
 155         $rfsum += ( $rez ) ? $row['cbe_rfsumT'] : $row['cbe_rfsumF'];
 156
 157         // next hop (node)
 158         $ret = $rez ? $row['cbe_nodegoal_T'] : $row['cbe_nodegoal_F'];
 159
 160         return $ret;
 161     }
 162 }
 163
 164 //-----------------------------------------------------------------------------
 165 /**
 166  * WHAT FUNCTION IS USED FOR A SPECIFIED NODE
 167  *
 168  * function of node, we call a function
 169  *
 170  * @param int node
 171  * @return string function name (in fact, a code from the tables)
 172  */
 173 function dt_nodefunction($node) {
 174     global $beslis_table;
 175     $q = sprintf("SELECT cbe_checkKM AS km FROM %s WHERE cbe_nodeorigin = %d ", $beslis_table, $node);
 176     $r = mysql_query($q) or die(mysql_error());
 177
 178     if ( !mysql_num_rows($r) ) {
 179         return 0;
 180     } else {
 181         $row = mysql_fetch_array($r);
 182         return $row['km'];
 183     }
 184 }
 185
 186 //-----------------------------------------------------------------------------
 187 /**
 188  * WHAT PARAMETER IS NEEDED FOR KM* FUNCTION
 189  *
 190  * some KM* functions work with some parameter; this function retrieves from db
 191  *
 192  * @param int $node - KM node
 193  * @param int $par - first or second param (1/2)
 194  * @return string $param (empty string for no param)
 195  */
 196 function dt_whatparam($node, $par = 1) {
 197     global $beslis_table;
 198
 199     if ( $par == 1 ) {
 200         $q = sprintf("SELECT cbe_KMpar1 AS param FROM %s WHERE cbe_nodeorigin = %d ", $beslis_table, $node);
 201     } else if ( $par == 2) {
 202         $q = sprintf("SELECT cbe_KMpar2 AS param FROM %s WHERE cbe_nodeorigin = %d ", $beslis_table, $node);
 203     }
 204     $r = mysql_query($q) or die(mysql_error());
 205
 206     if ( !mysql_num_rows($r) ) {
 207         return '';
 208     } else {
 209         $row = mysql_fetch_array($r);
 210         return $row['param'];
 211     }
 212 }
 213
 214 //-----------------------------------------------------------------------------
 215 /**
 216  * KMA001
 217  *
 218  * Number of days in clinic
 219  * Days in clinic can be recognised by CL_ACTIVITEIT_SOORT=VERBLIJFSDAG.
 220  * Exception: act_8.1.6*
 221  *
 222  * NOTE we don't use it now so it's always 0
 223  *
 224  * @param none
 225  * @return int
 226  */
 227 function dt_kma001() {
 228     return 0;
 229 }
 230
 231 //-----------------------------------------------------------------------------
 232 /**
 233  * KMA002
 234  *
 235  * ver 1: Sum of all direct time of activities + total time dagbesteding
 236  * If CL_ACTIVITEIT_SOORT = TIJDSCHRIJVEN then sum up all DIRECT_PATIENT-GEBONDEN_TIJD. Add time (if CL_ACTIVITEIT_SOORT  * = DAGBESTEDING) *60 (because dagbesteding/daycare is registered in hours; not minutes)
 237  *
 238  * ver 2: Sum of all direct time of activities + 15 times the hours spent in dagbesteding
 239  * If CL_ACTIVITEIT_SOORT = TIJDSCHRIJVEN then sum up all DIRECT_PATIENT-GEBONDEN_TIJD. Add time (if CL_ACTIVITEIT_SOORT  * = DAGBESTEDING) *15 (because dagbesteding/daycare is registered in hours; not minutes)
 240  *
 241  * @param none
 242  * @return int $totaltime
 243  */
 244 function dt_kma002() {
 245     $r = dt_allevents();
 246     $totaltime = 0;
 247
 248     //choose here what $ver we'll use function of a date
 249     //$dbc = content_diagnose($_SESSION['show_axid']);
 250     //$odate = $dbc['ax_odate'];
 251     //$ver    = ( $odate <= '2007-12-31') ? 1 : 2;
 252     $ver = 2 ; //we'll just use 2 because we don't have dagbestending
 253
 254     while ( $row = mysql_fetch_array($r) ) {
 255         $qe = sprintf("SELECT cl_activiteit_soort AS cas FROM cl_activiteit ca
 256         JOIN cl_event_activiteit cea ON cea.activity_sysid = ca.cl_activiteit_sysid
 257         WHERE cea.event_id = %d", $row['pc_eid']);
 258         $re = mysql_query($qe) or die(mysql_error());
 259         $rowe = mysql_fetch_array($re);
 260
 261         $cas = trim($rowe['cas']);
 262
 263         // those three times for an event (direct, indirect, travel)
 264         $times = dt_times($row['pc_eid']);
 265
 266         // SUM UP TIMES
 267         if ( $cas == 'Verblijfsdag' ) {
 268             /*if ( $ver == 1) {
 269                 // because dagbesteding/daycare is registered in hours; not minutes
 270                 //$totaltime += ( $times['dirtime'] * 60 );
 271             } else if ( $ver == 2 ){
 272                 // 15 times the hours spent in dagbesteding
 273                 //$totaltime += ( $times['dirtime'] * 15 );
 274             }*/
 275         } else if ( $cas == 'Tijdschrijven' ) {
 276             $totaltime += $times['dirtime'];
 277         }
 278     } // while
 279
 280     return $totaltime;
 281 }
 282
 283 //-----------------------------------------------------------------------------
 284 /**
 285  * KMA003
 286  *
 287  * total minutes total time (Sum of all direct, indirect and travel time of activities + total time dagbesteding)
 288  *
 289  * @param none
 290  * @return int
 291  */
 292 function dt_kma003() {
 293     $r = dt_allevents();
 294     $totaltime = 0;
 295
 296     //choose here what $ver we'll use function of a date
 297     //$dbc = content_diagnose($_SESSION['show_axid']);
 298     //$odate = $dbc['ax_odate'];
 299     //$ver    = ( $odate <= '2007-12-31') ? 1 : 2;
 300     $ver = 2; // it doesn't matter now.
 301
 302     while ( $row = mysql_fetch_array($r) ) {
 303         $qe = sprintf("SELECT cl_activiteit_soort AS cas FROM cl_activiteit ca
 304         JOIN cl_event_activiteit cea ON cea.activity_sysid = ca.cl_activiteit_sysid
 305         WHERE cea.event_id = %d", $row['pc_eid']);
 306         $re = mysql_query($qe) or die(mysql_error());
 307         $rowe = mysql_fetch_array($re);
 308
 309         // those three times for an event (direct, indirect, travel)
 310         $times = dt_times($row['pc_eid']);
 311         $totalt = $times['dirtime'] + $times['tratime'] + $times['indtime'];
 312 //echo "{$rowe['cas']} TIME KMA003: $totalt <br>"; //debug
 313         // SUM UP TIMES
 314         if ( $rowe['cas'] == 'Verblijfsdag' ) {
 315             /*if ( $ver == 1) {
 316                 // because dagbesteding/daycare is registered in hours; not minutes
 317                 $totaltime += ( $times['dirtime'] * 60 );
 318             } else if ( $ver == 2 ) {
 319                 // 15 times the hours spent in dagbesteding
 320                 $totaltime += ( $times['dirtime'] * 15 );
 321             }*/
 322         } else if ( $rowe['cas'] == 'Tijdschrijven' ) {
 323             $totaltime += $totalt;
 324         }
 325 //echo "TOTALTIME KMA003: $totaltime EV: {$row['pc_eid']}<br>"; //debug
 326     } // while
 327
 328     return $totaltime;
 329 }
 330
 331 //-----------------------------------------------------------------------------
 332 /**
 333  * KMA004
 334  *
 335  * number of separate kinds of jobs (e.g. Psychologist, psychiatrist, nurse, etc.)
 336  * Count how many distinct CL_BEROEPEN_CODE values are in this DBC
 337  *
 338  * NOTE: openemr doesn't use it in 2008
 339  *
 340  * @param none
 341  * @return int - distinct values for cl_beroep_code
 342  */
 343 function dt_kma004() {
 344     $r = dt_allevents();
 345     $beroep = array();
 346
 347     while ( $row = mysql_fetch_array($r) ) {
 348         $qe = sprintf("SELECT cl_beroep_code FROM cl_beroep cb JOIN cl_user_beroep cub ON cb.cl_beroep_sysid = cub.cl_beroep_sysid WHERE cub.cl_beroep_userid = %d ", $row['pc_aid']);
 349         $re = mysql_query($qe) or die(mysql_error());
 350         $rowe = mysql_fetch_array($re);
 351
 352         $beroep[] = $rowe['cl_beroep_code'];
 353     } // while
 354
 355     // find and return distict values from the jobs array
 356     return count(array_unique($beroep));
 357
 358 }
 359
 360 //-----------------------------------------------------------------------------
 361 /**
 362  * KMA005
 363  *
 364  * number of days in clinic without stay overnight
 365  * Total number of CL_ACTIVITEIT_SOORT=VERBLIJFSDAG,
 366  * but only for act_8.1.6, 8.2.6, 8.3.6, 8.4.6, 8.5.6, 8.6.6
 367  *
 368  * NOTE we don't use it at this moment
 369  *
 370  * @param none
 371  * @return int
 372  */
 373 function dt_kma005() {
 374     return 0;
 375 }
 376
 377 //-----------------------------------------------------------------------------
 378 /**
 379  * KMT001
 380  *
 381  * total minutes time on activity (parameter1)
 382  * old ver - Add up total time (direct, indirect, travel, dagbesteding) for activities that are hierarchically under   CL_ACTIVITEIT=parameter1
 383  * new ver - Add up total time (direct, indirect, travel, 15*dagbesteding) for activities that are hierarchically under  CL_ACTIVITEIT=parameter1, but ONLY activities with CL_ACTIVITEIT_SOORT = tijdschrijven or CL_ACTIVITEIT_SOORT =   dagbesteding
 384  *
 385  * @param int $node - node to look parameter for
 386  * @return int
 387 */
 388 function dt_kmt001($node) {
 389     global $dbcid;
 390
 391     $par = dt_whatparam($node, 1);
 392     $r = dt_allevents();
 393     $totaltime = 0;
 394 //echo "PAR KMT001: $par <br>"; //debug
 395     // choose here what $ver we'll use function of a date
 396     $dbc = content_diagnose($dbcid);
 397     $odate = $dbc['ax_odate'];
 398     $ver    = ( $odate <= '2007-12-31') ? 1 : 2;
 399
 400     while ( $row = mysql_fetch_array($r) ) {
 401         $qe = sprintf("SELECT cl_activiteit_soort AS cas, cl_activiteit_groepcode AS cag
 402         FROM cl_activiteit ca JOIN cl_event_activiteit cea ON cea.activity_sysid = ca.cl_activiteit_sysid
 403         WHERE cea.event_id = %d", $row['pc_eid']);
 404         $re = mysql_query($qe) or die(mysql_error());
 405         $rowe = mysql_fetch_array($re);
 406
 407         $cas = trim($rowe['cas']);
 408         $cag = trim($rowe['cag']);
 409
 410         // under the parameter
 411         if ( strpos($cag, $par) === 0 ) {
 412             // those three times for an event (direct, indirect, travel)
 413             $times = dt_times($row['pc_eid']);
 414             $totalt = $times['dirtime'] + $times['tratime'] + $times['indtime'];
 415
 416             if ( $ver == 1 ) {
 417                 $totaltime += $totalt;
 418             } else if ( $ver == 2 ) {
 419                 if ( $cas == 'Tijdschrijven' || $cas == 'Dagbesteding' ) $totaltime += $totalt;
 420             }
 421         } // if
 422
 423     } // while
 424 //echo "TOTALTIME KMT001: $totaltime <br>";
 425     return $totaltime;
 426 }
 427
 428 //-----------------------------------------------------------------------------
 429 /**
 430  * KMT002
 431  *
 432  * NOTE: openemr doesn't use it in 2008
 433  *
 434  * @param none
 435  * @return int
 436  */
 437 function dt_kmt002() {
 438     // TO BE IMPLEMENTED
 439 }
 440
 441 //-----------------------------------------------------------------------------
 442 /**
 443  * KMT003
 444  *
 445  * total minutes direct time on activity (parameter1)
 446  *
 447  * ver 1 - If CL_ACTIVITEIT_SOORT = TIJDSCHRIJVEN then sum up all DIRECT_PATIENT-GEBONDEN_TIJD. Add time (if  CL_ACTIVITEIT_SOORT = DAGBESTEDING) *60 (because dagbesteding/daycare is registered in hours; not minutes) BUT ONLY for activities that are hierarchically under parameter1 of CL_ACTIVITEIT
 448  *
 449  * ver 2 - If CL_ACTIVITEIT_SOORT = TIJDSCHRIJVEN then sum up all DIRECT_PATIENT-GEBONDEN_TIJD.
 450  * Add time (if CL_ACTIVITEIT_SOORT = DAGBESTEDING) * 15 (because dagbesteding/daycare is registered in hours; not minutes) BUT ONLY for activities that are hierarchically under parameter1 of CL_ACTIVITEIT;
 451  *
 452  * @param int $node- node to look parameter for
 453  * @return int
 454  */
 455 function dt_kmt003($node) {
 456     global $dbcid;
 457
 458     $par = dt_whatparam($node, 1);
 459     $r = dt_allevents();
 460     $totaltime = 0;
 461
 462     //choose here what $ver we'll use function of a date
 463     $dbc = content_diagnose($dbcid);
 464     $odate = $dbc['ax_odate'];
 465     $ver    = ( $odate <= '2007-12-31') ? 1 : 2;
 466
 467     while ( $row = mysql_fetch_array($r) ) {
 468         $qe = sprintf("SELECT cl_activiteit_soort AS cas, cl_activiteit_groepcode AS cag
 469         FROM cl_activiteit ca JOIN cl_event_activiteit cea ON cea.activity_sysid = ca.cl_activiteit_sysid
 470         WHERE cea.event_id = %d", $row['pc_eid']);
 471         $re = mysql_query($qe) or die(mysql_error());
 472         $rowe = mysql_fetch_array($re);
 473
 474         $cas = trim($rowe['cas']);
 475         $cag = trim($rowe['cag']);
 476
 477         // under the parameter
 478         if ( strpos($cag, $par) === 0 ) {
 479             // those three times for an event (direct, indirect, travel)
 480             $times = dt_times($row['pc_eid']);
 481
 482             if ( $ver == 1 ) {
 483                 if ( $cas == 'Tijdschrijven' ) $totaltime += $times['dirtime'];
 484                 if ( $cas == 'Dagbesteding' )  $totaltime += ($times['dirtime'] * 15); // not used yet!
 485             } else if ( $ver == 2 ) {
 486                 //if ( $cas == 'Tijdschrijven' || $cas == 'Dagbesteding' ) $totaltime += $times['dirtime'];
 487                 if ( $cas == 'Tijdschrijven' ) $totaltime += $times['dirtime'];
 488                 if ( $cas == 'Dagbesteding' )  $totaltime += ($times['dirtime'] * 60); // not used yet!
 489             }
 490
 491         } // if
 492     } // while
 493
 494     return $totaltime;
 495 }
 496
 497 //-----------------------------------------------------------------------------
 498 /**
 499  * KMT004
 500  *
 501  * NOTE: openemr doesn't use it in 2008
 502  *
 503  * @param none
 504  * @return void
 505  */
 506 function dt_kmt004() {
 507     // TO BE IMPLEMENTED
 508 }
 509
 510 //-----------------------------------------------------------------------------
 511 /**
 512  * KMN001
 513  *
 514  * The registered primary (main) diagnosis falls under category parameter1 (CL_DIAGNOSE)
 515  *
 516  * Example: if the asked value of CL_DIAGNOSE_CODE is AS1_6 then all CL_DIAGNOSE_CODE
 517  * values As1_6* are valid (all values in the same hierarchy)
 518  *
 519  * @param int $node- node to look parameter for
 520  * @return bool
 521  */
 522 function dt_kmn001($node) {
 523     global $dbcid;
 524
 525     $par = dt_whatparam($node, 1);
 526     $maindia = df_get_main_diagnose($dbcid);
 527
 528     return (strpos($maindia, $par) === 0);
 529 }
 530
 531 //-----------------------------------------------------------------------------
 532 /**
 533  * KMP001
 534  *
 535  * NOTE: not used by us
 536  * @param none
 537  * @return int
 538  */
 539 function dt_kmp001() {
 540     return 0;
 541 }
 542
 543 //-----------------------------------------------------------------------------
 544 /**
 545  * KMC001
 546  *
 547  * NOTE: openemr doesn't use it in 2008
 548  *
 549  * @param none
 550  * @return void
 551  */
 552 function dt_kmc001() {
 553     // TO BE IMPLEMENTED
 554 }
 555
 556
 557 //-----------------------------------------------------------------------------
 558 /**
 559  * ALL EVENTS FOR A DBC
 560  *
 561  * between opening date and closing date
 562  *
 563  * @param none
 564  * @return mysqlresult
 565  */
 566 function dt_allevents() {
 567     global $dbcid, $enddate;
 568
 569     $dia    = content_diagnose($dbcid);
 570     $odate  = mysql_real_escape_string($dia['ax_odate']);
 571     $cdate  = ( isset($_SESSION['eind']) && $_SESSION['eind'] ) ? mysql_real_escape_string($_SESSION['eind']) : $enddate;
 572     if ( !$cdate ) $cdate = date('Y-m-d'); //as a precaution
 573     $pid    = ( $dbcid ) ? what_patient($dbcid) : $_SESSION['pid'];
 574
 575     // find all events from DBC opening 'till closing date
 576     $q = sprintf("SELECT pc_eid, pc_aid FROM openemr_postcalendar_events
 577                 WHERE pc_pid = %d AND pc_eventDate >= '%s' AND pc_eventDate <= '%s' AND pc_apptstatus = '@' ",
 578                 $pid, $odate, $cdate);
 579     $r = mysql_query($q) or die(mysql_error());
 580
 581     return $r;
 582 }
 583
 584
 585 //-----------------------------------------------------------------------------
 586 /**
 587  * TIMES FOR AN EVENT
 588  *
 589  * returns direct, indirect and travel time (all in minutes)
 590  *
 591  * @param int $eid - event id
 592  * @return array
 593  */
 594 function dt_times($eid = 0) {
 595     if ( !$eid ) return 0;
 596
 597     // for JOIN - if the second table has inconsistency of data (missing record for an events)
 598     // a 'bug' occur and the direct time become 0
 599     //$qt = sprintf("SELECT ope.pc_duration, cta.indirect_time, cta.travel_time FROM openemr_postcalendar_events ope JOIN cl_time_activiteit cta ON ope.pc_eid = cta.event_id WHERE pc_eid = %d ", $eid);
 600     $qt = sprintf("SELECT pc_duration FROM openemr_postcalendar_events WHERE pc_eid = %d ", $eid);
 601     $rt = mysql_query($qt) or die(mysql_error());
 602     $rowt = mysql_fetch_array($rt);
 603
 604     // direct time
 605     $rez['dirtime'] = $rowt['pc_duration'] / 60;
 606
 607
 608     $qi = sprintf("SELECT indirect_time, travel_time FROM cl_time_activiteit WHERE event_id = %d ", $eid);
 609     $ri = mysql_query($qi) or die(mysql_error());
 610
 611     if ( mysql_num_rows($ri) ) {
 612         $rowi = mysql_fetch_array($ri);
 613         // indirect time
 614         $rez['indtime'] = $rowi['indirect_time'];
 615         // travel time
 616         $rez['tratime'] = $rowi['travel_time'];
 617     }
 618
 619     return $rez;
 620 }
 621
 622 //-----------------------------------------------------------------------------
 623 /**
 624  * WHAT PRODUCTGROEP
 625  *
 626  * after we have a result, we look up the right productgroep
 627  *
 628  * @param int $rfsum
 629  * @param string $endate - ending date for the DBC
 630  * @return array - two values id|name
 631  */
 632 function dt_whatproductgroep($rfsum, $endate) {
 633     global $dbcid;
 634
 635     // to avoid the bug: first time, it doesn't display properly
 636     if ( !$endate ) {
 637         $dc = content_diagnose($dbcid);
 638         $endate = $dc['ax_cdate'];
 639     }
 640
 641     $q = sprintf("SELECT cl_productgroep_sysid as cps, cl_productgroep_beschrijving as cpb
 642     FROM cl_productgroep WHERE cl_productgroep_code = %d
 643     AND cl_productgroep_begindatum <= '%s' AND cl_productgroep_einddatum >= '%s' ", $rfsum, $endate, $endate);
 644     $r = mysql_query($q) or die(mysql_error());
 645
 646     $row = mysql_fetch_array($r);
 647     $res = array();
 648     $res['id'] = $row['cps'];     $res['name'] = $row['cpb'];
 649
 650     return $res;
 651 }
 652
 653 //-----------------------------------------------------------------------------
 654 /**
 655  * SET PRESTATIECODE
 656  *
 657  * last step in the decision tree
 658  *
 659  * @param int $zsysid - zorg sysid
 660  * @param int $pgroep - productgroep sysid
 661  * @param int $dbcid - dbcid
 662  * @return
 663  */
 664 function dt_prestatiecode($zsysid, $pgroep, $dbcid) {
 665     $resstr = '';
 666
 667     // ZORGTYPE ----------------
 668     $qz = sprintf("SELECT cl_zorgtype_prestatiecodedeel AS czp FROM cl_zorg WHERE cl_zorgtype_sysid = %d ", $zsysid);
 669     $rz = mysql_query($qz) or die(mysql_error());
 670     $rowz = mysql_fetch_array($rz);
 671
 672     $czp = (int)$rowz['czp']; $czp = str_pad($czp, 3, '0', STR_PAD_LEFT);
 673     $resstr .= substr($rowz['czp'], 0, 3); // only 3 characters allowed
 674
 675     // DIAGNOSE ----------------
 676     $qd = sprintf("SELECT cl_productgroep_diagnose_blinderen AS cdb, cl_productgroep_code as cpc
 677     FROM cl_productgroep WHERE cl_productgroep_sysid = %d ", $pgroep);
 678     $rd = mysql_query($qd) or die(mysql_error());
 679     $rod = mysql_fetch_array($rd);
 680
 681     // posible values 1 - 0
 682     if ( $rod['cdb'] == 1 ) {
 683         $resstr .= '000';
 684     } else {
 685         // find CL_DIAGNOSE_PRESTATIECODEDEEL for the main diagnose
 686         $maind = df_get_main_diagnose($dbcid);
 687         $qpre = sprintf("SELECT cl_diagnose_prestatiecodedeel FROM cl_diagnose WHERE cl_diagnose_code = '%s' ",
 688                         $maind);
 689         $rpre = mysql_query($qpre) or die(mysql_error());
 690         $rowpre = mysql_fetch_array($rpre);
 691
 692         $resstr .= ( $rowpre['cl_diagnose_prestatiecodedeel'] ) ? $rowpre['cl_diagnose_prestatiecodedeel'] : '000' ;
 693     }
 694
 695     // PRODUCTGROEP CODE ----------------
 696     $resstr .= str_pad($rod['cpc'], 6, '0', STR_PAD_LEFT);
 697
 698     // save it to the table
 699     $qu = sprintf("UPDATE cl_axes SET ax_pcode='%s' WHERE ax_id = %d ", $resstr, $dbcid);
 700     mysql_query($qu) or die(mysql_error());
 701
 702 }
 703 //-----------------------------------------------------------------------------
 704
 705 ?>