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