Pro.php 52 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278
  1. <?php
  2. namespace App\Models;
  3. # use Illuminate\Database\Eloquent\Model;
  4. use App\Helpers\TimeLine;
  5. use DateTime;
  6. use Exception;
  7. use Illuminate\Support\Facades\DB;
  8. class Pro extends Model
  9. {
  10. protected $table = 'pro';
  11. public function displayName($_flat = false) {
  12. $name = [];
  13. if(!empty($this->name_display)) return $this->name_display;
  14. $sep = ", ";
  15. if($_flat) {
  16. if(!empty($this->name_first)) $name[] = $this->name_first;
  17. if(!empty($this->name_last)) $name[] = $this->name_last;
  18. $sep = ' ';
  19. }
  20. else {
  21. if(!empty($this->name_last)) $name[] = $this->name_last;
  22. if(!empty($this->name_first)) $name[] = $this->name_first;
  23. }
  24. if(!count($name)) {
  25. $name = $this->name_display;
  26. }
  27. else {
  28. $name = implode($sep, $name);
  29. }
  30. return $name;
  31. }
  32. public function initials() {
  33. $characters = [];
  34. if(!empty($this->name_first)) $characters[] = $this->name_first[0];
  35. if(!empty($this->name_last)) $characters[] = $this->name_last[0];
  36. return strtolower(implode("", $characters));
  37. }
  38. public function debitBills()
  39. {
  40. return $this->hasMany(Bill::class, 'debit_pro_id');
  41. }
  42. public function cmBills()
  43. {
  44. return $this->hasMany(Bill::class, 'cm_pro_id');
  45. }
  46. public function hcpBills()
  47. {
  48. return $this->hasMany(Bill::class, 'hcp_pro_id');
  49. }
  50. public function teamsWhereMcp()
  51. {
  52. return $this->hasMany(ProTeam::class, 'mcp_pro_id', 'id');
  53. }
  54. public function teamsWhereAssistant()
  55. {
  56. return $this->hasMany(ProTeam::class, 'assistant_pro_id', 'id');
  57. }
  58. public function isDefaultNA()
  59. {
  60. return $this->is_considered_for_dna && !$this->is_hcp;
  61. }
  62. public function lastPayment() {
  63. return ProTransaction
  64. ::where('pro_id', $this->id)
  65. ->where('plus_or_minus', 'PLUS')
  66. ->orderBy('created_at', 'desc')
  67. ->first();
  68. }
  69. public function hasRates() {
  70. $numRates = ProRate::where('is_active', true)->where('pro_id', $this->id)->count();
  71. return $numRates > 0;
  72. }
  73. public function cmRates() {
  74. return ProRate::distinct('code')
  75. ->where('is_active', true)
  76. ->where('pro_id', $this->id)
  77. ->where('code', 'LIKE', 'CM%')
  78. ->get();
  79. }
  80. public function rmRates() {
  81. return ProRate::distinct('code')
  82. ->where('is_active', true)
  83. ->where('pro_id', $this->id)
  84. ->where('code', 'LIKE', 'RM%')
  85. ->get();
  86. }
  87. public function noteRates() {
  88. return ProRate::distinct('code')
  89. ->where('is_active', true)
  90. ->where('pro_id', $this->id)
  91. ->where('code', 'NOT LIKE', 'CM%')
  92. ->where('code', 'NOT LIKE', 'RM%')
  93. ->where('responsibility', '<>', 'GENERIC')
  94. ->where('responsibility', '<>', 'NA')
  95. ->get();
  96. }
  97. public function genericRates() {
  98. return ProRate::distinct('code')
  99. ->where('is_active', true)
  100. ->where('pro_id', $this->id)
  101. ->where('responsibility', 'GENERIC')
  102. ->get();
  103. }
  104. public function recentDebits() {
  105. return ProTransaction
  106. ::where('pro_id', $this->id)
  107. ->where('plus_or_minus', 'PLUS')
  108. ->orderBy('created_at', 'desc')
  109. ->skip(0)->take(4)->get();
  110. }
  111. public function shortcuts() {
  112. return $this->hasMany(ProTextShortcut::class, 'pro_id')->where('is_removed', false);
  113. }
  114. public function allShortcuts() {
  115. $myId = $this->id;
  116. $shortcuts = ProTextShortcut::where('is_removed', false)
  117. ->where(function ($query2) use ($myId) {
  118. $query2
  119. ->where('pro_id', $myId)
  120. ->orWhereNull('pro_id');
  121. })
  122. ->orderBy('shortcut')
  123. ->get();
  124. return $shortcuts;
  125. }
  126. public function noteTemplates() {
  127. return $this->hasMany(NoteTemplatePro::class, 'pro_id')
  128. ->where('is_removed', false)
  129. ->orderBy('position_index', 'asc');
  130. }
  131. public function visitTemplates() {
  132. if($this->pro_type == 'ADMIN'){
  133. return VisitTemplate::where('is_active' , true)->get();
  134. }
  135. $allAccessibleVisitTemplatesIDs = VisitTemplate::where('is_accessible_to_all', true)->where('is_active', true)->pluck('id')->toArray();
  136. $accesses = VisitTemplateAccess::where('pro_id', $this->id)->where('is_active', true)->pluck('visit_template_id')->toArray();
  137. $allAllowedVisitTemplatesIDs = array_unique(array_merge($allAccessibleVisitTemplatesIDs, $accesses));
  138. return VisitTemplate::whereIn('id', $allAllowedVisitTemplatesIDs)->get();
  139. }
  140. public function currentWork() {
  141. return ProClientWork::where('pro_id', $this->id)->where('is_active', true)->first();
  142. }
  143. public function isWorkingOnClient($_client) {
  144. $count = ProClientWork::where('pro_id', $this->id)->where('client_id', $_client->id)->where('is_active', true)->count();
  145. return $count > 0;
  146. }
  147. public function canvasCustomItems($_key) {
  148. return ClientCanvasDataCustomItem::where('key', $_key)
  149. ->where('pro_id', $this->id)
  150. ->where('is_removed', false)
  151. ->orderBy('label')
  152. ->get();
  153. }
  154. /**
  155. * @param $_start - YYYY-MM-DD
  156. * @param $_end - YYYY-MM-DD
  157. * @param string $_timezone - defaults to EASTERN
  158. * @param string $_availableBG - defaults to #00a
  159. * @param string $_unavailableBG - defaults to #a00
  160. * @return array
  161. * @throws Exception
  162. */
  163. public function getAvailabilityEvents($_start, $_end, $_timezone = 'EASTERN', $_availableBG = '#00a', $_unavailableBG = '#a00') {
  164. $_start .= ' 00:00:00';
  165. $_end .= ' 23:59:59';
  166. // get availability data
  167. $proGenAvail = ProGeneralAvailability
  168. ::where('is_cancelled', false)
  169. ->where('pro_id', $this->id)
  170. ->get();
  171. $proSpecAvail = ProSpecificAvailability
  172. ::where('is_cancelled', false)
  173. ->where('pro_id', $this->id)
  174. ->where(function ($query) use ($_start, $_end) {
  175. $query
  176. ->where(function ($query2) use ($_start, $_end) {
  177. $query2
  178. ->where('start_time', '>=', $_start)
  179. ->where('start_time', '<=', $_end);
  180. })
  181. ->orWhere(function ($query2) use ($_start, $_end) {
  182. $query2
  183. ->where('end_time', '>=', $_start)
  184. ->where('end_time', '<=', $_end);
  185. });
  186. })
  187. ->get();
  188. $proSpecUnavail = ProSpecificUnavailability
  189. ::where('is_cancelled', false)
  190. ->where('pro_id', $this->id)
  191. ->where(function ($query) use ($_start, $_end) {
  192. $query
  193. ->where(function ($query2) use ($_start, $_end) {
  194. $query2
  195. ->where('start_time', '>=', $_start)
  196. ->where('start_time', '<=', $_end);
  197. })
  198. ->orWhere(function ($query2) use ($_start, $_end) {
  199. $query2
  200. ->where('end_time', '>=', $_start)
  201. ->where('end_time', '<=', $_end);
  202. });
  203. })
  204. ->get();
  205. // default GA
  206. // if no gen avail, assume mon to fri, 9 to 7
  207. /*if (count($proGenAvail) === 0) {
  208. $dayNames = ['MONDAY', 'TUESDAY', 'WEDNESDAY', 'THURSDAY', 'FRIDAY'];
  209. foreach ($dayNames as $dayName) {
  210. $item = new \stdClass();
  211. $item->day_of_week = $dayName;
  212. $item->timezone = $_timezone;
  213. $item->start_time = '09:00:00';
  214. $item->end_time = '18:00:00';
  215. $proGenAvail->push($item);
  216. }
  217. }*/
  218. // create timeline
  219. $phpTZ = appTZtoPHPTZ($_timezone);
  220. $phpTZObject = new \DateTimeZone($phpTZ);
  221. $startDate = new \DateTime($_start, $phpTZObject);
  222. $endDate = new \DateTime($_end, $phpTZObject);
  223. $proTimeLine = new TimeLine($startDate, $endDate);
  224. // General availability
  225. $period = new \DatePeriod($startDate, \DateInterval::createFromDateString('1 day'), $endDate);
  226. $days = [];
  227. foreach ($period as $day) {
  228. $days[] = [
  229. "day" => strtoupper($day->format("l")), // SUNDAY, etc.
  230. "date" => $day->format("Y-m-d"), // 2020-10-04, etc.
  231. ];
  232. }
  233. foreach ($days as $day) {
  234. $proGenAvailForTheDay = $proGenAvail->filter(function ($record) use ($day) {
  235. return $record->day_of_week === $day["day"];
  236. });
  237. foreach ($proGenAvailForTheDay as $ga) {
  238. $gaStart = new \DateTime($day["date"], new \DateTimeZone(appTZtoPHPTZ($ga->timezone)));
  239. $parts = explode(":", $ga->start_time);
  240. $gaStart->setTime(intval($parts[0]), intval($parts[1]), intval($parts[2]));
  241. $gaStart->setTimezone($phpTZObject);
  242. $gaEnd = new \DateTime($day["date"], new \DateTimeZone(appTZtoPHPTZ($ga->timezone)));
  243. $parts = explode(":", $ga->end_time);
  244. $gaEnd->setTime(intval($parts[0]), intval($parts[1]), intval($parts[2]));
  245. $gaEnd->setTimezone($phpTZObject);
  246. $proTimeLine->addAvailability($gaStart, $gaEnd);
  247. }
  248. }
  249. // specific availability
  250. foreach ($proSpecAvail as $sa) {
  251. $saStart = new \DateTime($sa->start_time, new \DateTimeZone(appTZtoPHPTZ($sa->timezone)));
  252. $saStart->setTimezone($phpTZObject);
  253. $saEnd = new \DateTime($sa->end_time, new \DateTimeZone(appTZtoPHPTZ($sa->timezone)));
  254. $saEnd->setTimezone($phpTZObject);
  255. $proTimeLine->addAvailability($saStart, $saEnd);
  256. }
  257. // specific unavailability
  258. foreach ($proSpecUnavail as $sua) {
  259. $suaStart = new \DateTime($sua->start_time, new \DateTimeZone(appTZtoPHPTZ($sua->timezone)));
  260. $suaStart->setTimezone($phpTZObject);
  261. $suaEnd = new \DateTime($sua->end_time, new \DateTimeZone(appTZtoPHPTZ($sua->timezone)));
  262. $suaEnd->setTimezone($phpTZObject);
  263. $proTimeLine->removeAvailability($suaStart, $suaEnd);
  264. }
  265. $events = [];
  266. // availability
  267. foreach ($proTimeLine->getAvailable() as $item) {
  268. $eStart = new \DateTime('@' . $item->start);
  269. $eStart->setTimezone($phpTZObject);
  270. $eEnd = new \DateTime('@' . $item->end);
  271. $eEnd->setTimezone($phpTZObject);
  272. $events[] = [
  273. "type" => "availability",
  274. "start" => $eStart->format('Y-m-d H:i:s'),
  275. "end" => $eEnd->format('Y-m-d H:i:s'),
  276. "editable" => false,
  277. "backgroundColor" => $_availableBG
  278. ];
  279. }
  280. // unavailability
  281. foreach ($proTimeLine->getUnavailable() as $item) {
  282. $eStart = new \DateTime('@' . $item->start);
  283. $eStart->setTimezone($phpTZObject);
  284. $eEnd = new \DateTime('@' . $item->end);
  285. $eEnd->setTimezone($phpTZObject);
  286. $events[] = [
  287. "type" => "unavailability",
  288. "start" => $eStart->format('Y-m-d H:i:s'),
  289. "end" => $eEnd->format('Y-m-d H:i:s'),
  290. "editable" => false,
  291. "backgroundColor" => $_unavailableBG
  292. ];
  293. }
  294. return $events;
  295. }
  296. public function getMyClientIds($_search = false) {
  297. $clients = $this->getAccessibleClientsQuery($_search)->get();
  298. $clientIds = [];
  299. foreach($clients as $client){
  300. $clientIds[] = $client->id;
  301. }
  302. return $clientIds;
  303. }
  304. public function favoritesByCategory($_category) {
  305. return ProFavorite::where('pro_id', $this->id)
  306. ->where('is_removed', false)
  307. ->where('category', $_category)
  308. ->orderBy('category', 'asc')
  309. ->orderBy('position_index', 'asc')
  310. ->get();
  311. }
  312. public function favoritesByCategoryDecoded($_category) {
  313. $favorites = ProFavorite::where('pro_id', $this->id)
  314. ->where('is_removed', false)
  315. ->where('category', $_category)
  316. ->orderBy('category', 'asc')
  317. ->orderBy('position_index', 'asc')
  318. ->get();
  319. foreach ($favorites as $favorite) {
  320. if ($favorite->data) {
  321. $favorite->data = json_decode($favorite->data);
  322. }
  323. }
  324. return $favorites;
  325. }
  326. function get_patients_count_as_mcp() {
  327. $query = Client::whereNull('shadow_pro_id');
  328. return $query->where('mcp_pro_id', $this->id)
  329. ->where(function ($q) {
  330. $q->whereNull('client_engagement_status_category')
  331. ->orWhere('client_engagement_status_category', '<>', 'DUMMY');
  332. })->count();
  333. }
  334. function get_new_patients_awaiting_visit_count_as_mcp() {
  335. $query = Client::whereNull('shadow_pro_id');
  336. return $query->where('mcp_pro_id', $this->id)
  337. ->where('has_mcp_done_onboarding_visit', '!=', 'YES')
  338. ->count();
  339. }
  340. function get_notes_pending_signature_count_as_mcp() {
  341. return Note::where('hcp_pro_id', $this->id)
  342. ->where('is_cancelled', '<>', true)
  343. ->where('is_core_note', '<>', true)
  344. ->where('is_signed_by_hcp', '<>', true)
  345. ->count();
  346. }
  347. function get_notes_pending_summary_suggestion_as_mcp_query(){
  348. $segmentsWithProposedSummarySuggestion = Segment::whereHas('proposedSegmentSummarySuggestion', function($sugQuery){
  349. return $sugQuery->where('status', '=', 'PENDING');
  350. })->get();
  351. $noteIDs = [];
  352. foreach($segmentsWithProposedSummarySuggestion as $seg){
  353. $noteIDs[] = $seg->note_id;
  354. }
  355. return Note::where('hcp_pro_id', $this->id)
  356. ->where('is_cancelled', '<>', true)
  357. ->where('is_core_note', '<>', true)
  358. ->where('is_signed_by_hcp', true)
  359. ->whereIn('id', $noteIDs);
  360. }
  361. function get_notes_rejected_summary_suggestion_as_mcp_query(){
  362. $segmentsWithProposedSummarySuggestion = Segment::whereHas('proposedSegmentSummarySuggestion', function($sugQuery){
  363. return $sugQuery->where('status', '=', 'REJECTED');
  364. })->get();
  365. $noteIDs = [];
  366. foreach($segmentsWithProposedSummarySuggestion as $seg){
  367. $noteIDs[] = $seg->note_id;
  368. }
  369. return Note::where('hcp_pro_id', $this->id)
  370. ->where('is_cancelled', '<>', true)
  371. ->where('is_core_note', '<>', true)
  372. ->where('is_signed_by_hcp', true)
  373. ->whereIn('id', $noteIDs);
  374. }
  375. function get_notes_pending_summary_suggestion_count_as_mcp(){
  376. return $this->get_notes_pending_summary_suggestion_as_mcp_query()->count();
  377. }
  378. function get_notes_pending_summary_suggestion_as_mcp(){
  379. return $this->get_notes_pending_summary_suggestion_as_mcp_query()->get();
  380. }
  381. function get_notes_rejected_summary_suggestion_count_as_mcp(){
  382. return $this->get_notes_rejected_summary_suggestion_as_mcp_query()->count();
  383. }
  384. function get_notes_rejected_summary_suggestion_as_mcp(){
  385. return $this->get_notes_rejected_summary_suggestion_as_mcp_query()->get();
  386. }
  387. function get_notes_pending_summary_suggestion_as_admin_query(){
  388. $segmentsWithProposedSummarySuggestion = Segment::whereHas('proposedSegmentSummarySuggestion', function($sugQuery){
  389. return $sugQuery->where('status', '=', 'PENDING');
  390. })->get();
  391. $noteIDs = [];
  392. foreach($segmentsWithProposedSummarySuggestion as $seg){
  393. $noteIDs[] = $seg->note_id;
  394. }
  395. return Note::where('is_cancelled', '<>', true)
  396. ->where('is_core_note', '<>', true)
  397. ->where('is_signed_by_hcp', true)
  398. ->whereIn('id', $noteIDs);
  399. }
  400. function get_notes_rejected_summary_suggestion_as_admin_query(){
  401. $segmentsWithProposedSummarySuggestion = Segment::whereHas('proposedSegmentSummarySuggestion', function($sugQuery){
  402. return $sugQuery->where('status', '=', 'REJECTED');
  403. })->get();
  404. $noteIDs = [];
  405. foreach($segmentsWithProposedSummarySuggestion as $seg){
  406. $noteIDs[] = $seg->note_id;
  407. }
  408. return Note::where('is_cancelled', '<>', true)
  409. ->where('is_core_note', '<>', true)
  410. ->where('is_signed_by_hcp', true)
  411. ->whereIn('id', $noteIDs);
  412. }
  413. function get_notes_pending_summary_suggestion_count_as_admin(){
  414. return $this->get_notes_pending_summary_suggestion_as_admin_query()->count();
  415. }
  416. function get_notes_pending_summary_suggestion_as_admin(){
  417. return $this->get_notes_pending_summary_suggestion_as_admin_query()->get();
  418. }
  419. function get_notes_rejected_summary_suggestion_count_as_admin(){
  420. return $this->get_notes_rejected_summary_suggestion_as_admin_query()->count();
  421. }
  422. function get_notes_rejected_summary_suggestion_as_admin(){
  423. return $this->get_notes_rejected_summary_suggestion_as_admin_query()->get();
  424. }
  425. function get_notes_pending_billing_count_as_mcp() {
  426. return Note::where('hcp_pro_id', $this->id)
  427. ->where('is_cancelled', '<>', true)
  428. ->where('is_signed_by_hcp', true)
  429. ->where('is_billing_marked_done', '<>', true)
  430. ->count();
  431. }
  432. function get_measurements_awaiting_review_count_as_mcp() {
  433. $result = DB::select(DB::raw("
  434. SELECT SUM(rm_num_measurements_not_stamped_by_mcp) AS count
  435. FROM care_month
  436. WHERE mcp_pro_id = :pro_id
  437. AND rm_num_measurements_not_stamped_by_mcp IS NOT NULL
  438. AND rm_num_measurements_not_stamped_by_mcp > 0;
  439. "), ["pro_id" => $this->id]);
  440. if($result) return $result[0]->count;
  441. }
  442. function get_bills_pending_signature_count_as_mcp(){
  443. $pendingBillsToSign = Bill::where('bill_service_type', '<>', 'CARE_MONTH')->where(function ($query) {
  444. $query->where('hcp_pro_id', $this->id)->where('is_signed_by_hcp', false)->where('is_cancelled', false);
  445. })
  446. ->orWhere(function ($query) {
  447. $query->where('cm_pro_id', $this->id)->where('is_signed_by_cm', false)->where('is_cancelled', false);
  448. })->orWhere(function ($query) {
  449. $query->where('rme_pro_id', $this->id)->where('is_signed_by_rme', false)->where('is_cancelled', false);
  450. })->orWhere(function ($query) {
  451. $query->where('rmm_pro_id', $this->id)->where('is_signed_by_rmm', false)->where('is_cancelled', false);
  452. })->orWhere(function ($query) {
  453. $query->where('generic_pro_id', $this->id)->where('is_signed_by_generic_pro', false)->where('is_cancelled', false);
  454. })->count();
  455. return $pendingBillsToSign;
  456. }
  457. function get_incoming_reports_pending_signature_count_as_mcp() {
  458. return IncomingReport::where('hcp_pro_id', $this->id)
  459. ->where('has_hcp_pro_signed', '<>', true)
  460. ->where('is_entry_error', '<>', true)
  461. ->count();
  462. }
  463. function get_patients_without_appointment_query() {
  464. return Client::where('mcp_pro_id', $this->id)
  465. ->whereNull('today_mcp_appointment_date')
  466. ->where(function($q){
  467. $q->whereNull('next_mcp_appointment_id')
  468. ->orWhere('next_mcp_appointment_date', '<=', DB::raw('NOW()::DATE'));
  469. });
  470. }
  471. function get_patients_without_appointment_for_dna_query() {
  472. return Client::where('default_na_pro_id', $this->id)
  473. ->whereNull('today_mcp_appointment_date')
  474. ->where(function($q){
  475. $q->whereNull('next_mcp_appointment_id')
  476. ->orWhere('next_mcp_appointment_date', '<=', DB::raw('NOW()::DATE'));
  477. });
  478. }
  479. function get_patients_without_appointment_count_as_mcp() {
  480. return $this->get_patients_without_appointment_query()->count();
  481. }
  482. function get_patients_overdue_for_visit_query() {
  483. return Client::where('mcp_pro_id', $this->id)
  484. ->where(function($q){
  485. $q->whereNull('most_recent_completed_mcp_note_id')
  486. ->orWhere('most_recent_completed_mcp_note_date', '<', DB::raw("NOW()::DATE - INTERVAL '45 DAY'"));
  487. });
  488. }
  489. function get_patients_overdue_for_visit_for_dna_query() {
  490. return Client::where('default_na_pro_id', $this->id)
  491. ->where(function($q){
  492. $q->whereNull('most_recent_completed_mcp_note_id')
  493. ->orWhere('most_recent_completed_mcp_note_date', '<', DB::raw("NOW()::DATE - INTERVAL '45 DAY'"));
  494. });
  495. }
  496. function get_patients_overdue_count_as_mcp() {
  497. return $this->get_patients_overdue_for_visit_query()->count();
  498. }
  499. function get_patients_without_remote_measurement_in_48_hours_count_as_mcp() {
  500. return DB::select("SELECT COUNT(*) as count FROM client WHERE ((most_recent_cellular_measurement_at+ interval '48 hour')::timestamp < NOW() OR most_recent_cellular_measurement_id IS NULL) AND client.mcp_pro_id = :mcp_pro_id AND is_active IS TRUE", ['mcp_pro_id'=>$this->id])[0]->count;
  501. }
  502. function get_cancelled_appointments_pending_acknowledgement_count_as_mcp_query() {
  503. // SELECT * FROM appointment WHERE hcp_pro_id = :me.id AND status = 'REJECTED' AND wasAcknowledgedByAppointmentPro IS NOT TRUE;
  504. return Appointment::where('pro_id', $this->id)
  505. ->where('latest_confirmation_decision_enum', 'REJECTED')
  506. ->where('is_decision_acknowledgement_from_appointment_pro_pending', true);
  507. }
  508. function get_cancelled_appointments_pending_acknowledgement_count_as_mcp() {
  509. // SELECT * FROM appointment WHERE hcp_pro_id = :me.id AND status = 'REJECTED' AND wasAcknowledgedByAppointmentPro IS NOT TRUE;
  510. return $this->get_cancelled_appointments_pending_acknowledgement_count_as_mcp_query()->count();
  511. }
  512. function get_cancelled_bills_awaiting_review_count_as_mcp() {
  513. // SELECT * FROM bill WHERE bill_service_type = 'NOTE' AND is_cancelled IS TRUE AND isCancellationAcknowledged IS FALSE;
  514. return Bill::where('hcp_pro_id', $this->id)
  515. ->where('bill_service_type', 'NOTE')
  516. ->where('is_cancelled', true)
  517. ->where('is_cancellation_acknowledged', '<>', true)
  518. ->count();
  519. }
  520. function get_cancelled_supply_orders_awaiting_review_count_as_mcp() {
  521. // SELECT * FROM supply_order WHERE signed_by_pro_id = :me.id AND is_cancelled IS TRUE AND isCancellationAcknowledged IS NOT TRUE;
  522. return SupplyOrder::where('signed_by_pro_id', $this->id)
  523. ->where('is_cancelled', true)
  524. ->where('is_cancellation_acknowledged', '<>', true)
  525. ->count();
  526. }
  527. function get_erx_and_orders_awaiting_signature_count_as_mcp() {
  528. // SELECT * FROM erx WHERE hcp_pro_id = :me.id AND pro_declared_status <> 'CANCELLED' AND hasHcpProSigned IS NOT TRUE;
  529. return Erx::where('hcp_pro_id', $this->id)
  530. ->where('pro_declared_status', '<>', 'CANCELLED')
  531. ->where('has_hcp_pro_signed', '<>', true)
  532. ->count();
  533. }
  534. function get_supply_orders_awaiting_signature_count_as_mcp() {
  535. // SELECT supply_order.id FROM supply_order WHERE signed_by_pro_id IS NOT TRUE AND is_cancelled IS NOT TRUE AND created_by_pro_id = :me.id;
  536. return SupplyOrder::where('created_by_pro_id', $this->id)
  537. ->whereNull('signed_by_pro_id')
  538. ->where('is_cancelled', '<>', true)
  539. ->count();
  540. }
  541. function get_supply_orders_awaiting_shipment_count_as_mcp() {
  542. return SupplyOrder::where('created_by_pro_id', $this->id)
  543. ->where('is_signed_by_pro', true)
  544. ->where('is_cleared_for_shipment', true)
  545. ->whereNull('shipment_id')
  546. ->count();
  547. }
  548. function get_unsigned_incoming_reports_count_as_mcp() {
  549. return IncomingReport::where('hcp_pro_id', $this->id)
  550. ->whereRaw('(has_hcp_pro_signed IS NULL OR has_hcp_pro_signed = FALSE)')
  551. ->count();
  552. }
  553. function get_unsigned_rpm_bills_count_as_mcp() {
  554. $query = "
  555. SELECT count(distinct(care_month.id))
  556. FROM care_month join client on care_month.client_id = client.id join note mrnote on client.most_recent_completed_mcp_note_id = mrnote.id
  557. left join bill on care_month.mcp_rm_generic_bill_id = bill.id
  558. left join note mrmnote on mrmnote.id = (
  559. select max(n.id) from note n
  560. where
  561. n.client_id = client.id AND
  562. n.is_cancelled = FALSE AND
  563. (n.is_signed_by_hcp IS NOT NULL AND n.is_signed_by_hcp = TRUE) AND
  564. n.effective_dateest::date >= care_month.start_date::date AND
  565. n.effective_dateest::date < (care_month.start_date::date + INTERVAL '1 month')
  566. )
  567. WHERE
  568. care_month.mcp_pro_id = {$this->id}
  569. AND EXTRACT(MONTH from care_month.start_date) = EXTRACT(MONTH from now())
  570. AND EXTRACT(YEAR from care_month.start_date) = EXTRACT(YEAR from now())
  571. AND care_month.mcp_rm_generic_bill_id IS NOT NULL
  572. AND bill.is_signed_by_generic_pro = TRUE
  573. ";
  574. // dd($query);
  575. $count = DB::select($query);
  576. return $count[0]->count;
  577. }
  578. function get_unsigned_rpm_bills_count_as_rmm() {
  579. $query = "
  580. SELECT count(distinct(care_month.id))
  581. FROM care_month join client on care_month.client_id = client.id join note mrnote on client.most_recent_completed_mcp_note_id = mrnote.id
  582. left join bill on care_month.rmm_rm_generic_bill_id = bill.id
  583. left join note mrmnote on mrmnote.id = (
  584. select max(n.id) from note n
  585. where
  586. n.client_id = client.id AND
  587. n.is_cancelled = FALSE AND
  588. (n.is_signed_by_hcp IS NOT NULL AND n.is_signed_by_hcp = TRUE) AND
  589. n.effective_dateest::date >= care_month.start_date::date AND
  590. n.effective_dateest::date < (care_month.start_date::date + INTERVAL '1 month')
  591. )
  592. WHERE
  593. care_month.rmm_pro_id = {$this->id}
  594. AND EXTRACT(MONTH from care_month.start_date) = EXTRACT(MONTH from now())
  595. AND EXTRACT(YEAR from care_month.start_date) = EXTRACT(YEAR from now())
  596. AND care_month.rmm_rm_generic_bill_id IS NOT NULL
  597. AND bill.is_signed_by_generic_pro = TRUE
  598. ";
  599. // dd($query);
  600. $count = DB::select($query);
  601. return $count[0]->count;
  602. }
  603. function get_birthdays_today_as_mcp(){
  604. return;
  605. $queryClients = $this->performer()->pro->getAccessibleClientsQuery();
  606. $keyNumbers['patientsHavingBirthdayToday'] = $queryClients
  607. ->whereRaw('EXTRACT(DAY from dob) = ?', [date('d')])
  608. ->whereRaw('EXTRACT(MONTH from dob) = ?', [date('m')])
  609. ->count();
  610. $reimbursement = [];
  611. $reimbursement["currentBalance"] = $performer->pro->balance;
  612. $reimbursement["nextPaymentDate"] = '--';
  613. $lastPayment = ProTransaction::where('pro_id', $performerProID)->where('plus_or_minus', 'PLUS')->orderBy('created_at', 'DESC')->first();
  614. if ($lastPayment) {
  615. $reimbursement["lastPayment"] = $lastPayment->amount;
  616. $reimbursement["lastPaymentDate"] = $lastPayment->created_at;
  617. } else {
  618. $reimbursement["lastPayment"] = '--';
  619. $reimbursement["lastPaymentDate"] = '--';
  620. }
  621. }
  622. public function getAppointmentsPendingStatusChangeAck() {
  623. return Appointment::where('pro_id', $this->id)
  624. ->where('is_status_acknowledgement_from_appointment_pro_pending', true)
  625. //->where('raw_date', '>=', DB::raw('NOW()'))
  626. ->orderBy('raw_date', 'asc')
  627. ->get();
  628. }
  629. public function getAppointmentsPendingDecisionAck() {
  630. return Appointment::where('pro_id', $this->id)
  631. ->where('is_decision_acknowledgement_from_appointment_pro_pending', true)
  632. //->where('raw_date', '>=', DB::raw('NOW()'))
  633. ->orderBy('raw_date', 'asc')
  634. ->get();
  635. }
  636. public function getAppointmentsPendingTimeChangeAck() {
  637. return Appointment::where('pro_id', $this->id)
  638. ->where('is_time_change_acknowledgement_from_appointment_pro_pending', true)
  639. //->where('raw_date', '>=', DB::raw('NOW()'))
  640. ->orderBy('raw_date', 'asc')
  641. ->get();
  642. }
  643. public function getAccessibleClientsQuery($_search = false) {
  644. $proID = $this->id;
  645. $query = Client::whereNull('shadow_pro_id');
  646. if ($this->pro_type === 'ADMIN' && ($_search ? $this->can_see_any_client_via_search : $this->can_see_all_clients_in_list)) {
  647. $query = $query->where('id', '>', 0);
  648. } else {
  649. $query = $query->where(function ($q) use ($proID) {
  650. $q->where('mcp_pro_id', $proID)
  651. ->orWhere('cm_pro_id', $proID)
  652. ->orWhere('rmm_pro_id', $proID)
  653. ->orWhere('rme_pro_id', $proID)
  654. ->orWhere('physician_pro_id', $proID)
  655. ->orWhere('default_na_pro_id', $proID)
  656. ->orWhereRaw('id IN (SELECT client_id FROM client_pro_access WHERE is_active AND pro_id = ?)', [$proID])
  657. ->orWhereRaw('id IN (SELECT client_id FROM appointment WHERE status NOT IN (\'CANCELLED\') AND pro_id = ?)', [$proID])
  658. ->orWhereRaw('id IN (SELECT mcp_pro_id FROM client_program WHERE client_id = client.id AND is_active = TRUE)')
  659. ->orWhereRaw('id IN (SELECT manager_pro_id FROM client_program WHERE client_id = client.id AND is_active = TRUE)')
  660. ->orWhereRaw('id IN (SELECT client_id FROM note WHERE ally_pro_id = ? AND is_cancelled = FALSE)', [$proID]);;
  661. });
  662. }
  663. return $query;
  664. }
  665. public function canAccess($_patientUid) {
  666. $proID = $this->id;
  667. if ($this->pro_type === 'ADMIN') {
  668. return true;
  669. }
  670. $canAccess = Client::select('uid')
  671. ->where('uid', $_patientUid)
  672. ->where(function ($q) use ($proID) {
  673. $q->whereNull('mcp_pro_id')
  674. ->orWhere('mcp_pro_id', $proID)
  675. ->orWhere('cm_pro_id', $proID)
  676. ->orWhere('rmm_pro_id', $proID)
  677. ->orWhere('rme_pro_id', $proID)
  678. ->orWhere('physician_pro_id', $proID)
  679. ->orWhere('default_na_pro_id', $proID)
  680. ->orWhereRaw('id IN (SELECT client_id FROM client_pro_access WHERE is_active AND pro_id = ?)', [$proID])
  681. ->orWhereRaw('id IN (SELECT client_id FROM appointment WHERE status NOT IN (\'CANCELLED\') AND pro_id = ?)', [$proID])
  682. ->orWhereRaw('id IN (SELECT mcp_pro_id FROM client_program WHERE client_id = client.id AND is_active = TRUE)')
  683. ->orWhereRaw('id IN (SELECT manager_pro_id FROM client_program WHERE client_id = client.id AND is_active = TRUE)')
  684. ->orWhereRaw('id IN (SELECT client_id FROM note WHERE ally_pro_id = ? AND is_cancelled = FALSE)', [$proID]);
  685. })->count();
  686. return !!$canAccess;
  687. }
  688. public function canAddCPMEntryForMeasurement(Measurement $measurement, Pro $pro)
  689. {
  690. // check if client has any programs where this measurement type is allowed
  691. $allowed = false;
  692. $client = $measurement->client;
  693. $clientPrograms = $client->clientPrograms;
  694. if($pro->pro_type !== 'ADMIN') {
  695. $clientPrograms = $clientPrograms->filter(function($_clientProgram) use ($pro) {
  696. return $_clientProgram->manager_pro_id === $pro->id;
  697. });
  698. }
  699. if(count($clientPrograms)) {
  700. foreach ($clientPrograms as $clientProgram) {
  701. if(strpos(strtolower($clientProgram->measurement_labels), '|' . strtolower($measurement->label) . '|') !== FALSE) {
  702. $allowed = true;
  703. break;
  704. }
  705. }
  706. }
  707. return $allowed ? $clientPrograms : FALSE;
  708. }
  709. public function getUnstampedMeasurementsFromCurrentMonth($_countOnly, $skip, $limit)
  710. {
  711. date_default_timezone_set('US/Eastern');
  712. $start = strtotime(date('Y-m-01'));
  713. $end = date_add(date_create(date('Y-m-01')), date_interval_create_from_date_string("1 month"))->getTimestamp();
  714. $start *= 1000;
  715. $end *= 1000;
  716. $measurementsQuery = Measurement::where('measurement.is_active', true)
  717. ->join('client', 'client.id', '=', 'measurement.client_id')
  718. ->whereNotNull('measurement.client_bdt_measurement_id')
  719. ->whereNotNull('measurement.ts')
  720. ->where('measurement.is_cellular_zero', false)
  721. ->where('measurement.ts', '>=', $start)
  722. ->where('measurement.ts', '<', $end)
  723. ->whereIn('measurement.client_id', $this->getMyClientIds())
  724. ->where(function ($q) {
  725. $q
  726. ->where(function ($q2) {
  727. $q2
  728. ->where('client.mcp_pro_id', $this->id)
  729. ->where('measurement.has_been_stamped_by_mcp', false);
  730. })
  731. ->orWhere(function ($q2) {
  732. $q2
  733. ->where('client.default_na_pro_id', $this->id)
  734. ->where('measurement.has_been_stamped_by_non_hcp', false);
  735. })
  736. ->orWhere(function ($q2) {
  737. $q2
  738. ->where('client.rmm_pro_id', $this->id)
  739. ->where('measurement.has_been_stamped_by_rmm', false);
  740. })
  741. ->orWhere(function ($q2) {
  742. $q2
  743. ->where('client.rme_pro_id', $this->id)
  744. ->where('measurement.has_been_stamped_by_rme', false);
  745. });
  746. });
  747. if($_countOnly) {
  748. return $measurementsQuery->count();
  749. }
  750. $x = [];
  751. $measurements = $measurementsQuery
  752. ->orderBy('ts', 'desc')
  753. ->skip($skip)
  754. ->take($limit)
  755. ->get();
  756. // eager load stuff needed in JS
  757. foreach ($measurements as $measurement) {
  758. // if ($measurement->client_bdt_measurement_id) {
  759. // $measurement->bdtMeasurement = $measurement->clientBDTMeasurement->measurement;
  760. // }
  761. unset($measurement->clientBDTMeasurement); // we do not need this travelling to the frontend
  762. $client = [
  763. "uid" => $measurement->client->uid,
  764. "name" => $measurement->client->displayName(),
  765. ];
  766. $measurement->patient = $client;
  767. $measurement->careMonth = $measurement->client->currentCareMonth();
  768. $measurement->timestamp = friendlier_date_time($measurement->created_at);
  769. unset($measurement->client); // we do not need this travelling to the frontend
  770. if(@$measurement->detail_json) unset($measurement->detail_json);
  771. if(@$measurement->canvas_data) unset($measurement->canvas_data);
  772. if(@$measurement->latest_measurements) unset($measurement->latest_measurements);
  773. if(@$measurement->info_lines) unset($measurement->info_lines);
  774. if(@$measurement->canvas_data_backup) unset($measurement->canvas_data_backup);
  775. if(@$measurement->migrated_canvas_data_backup) unset($measurement->migrated_canvas_data_backup);
  776. // if($measurement->label == 'SBP' || $measurement->label = 'DBP'){
  777. // continue;
  778. // }
  779. $x[] = $measurement;
  780. }
  781. // dd($measurements);
  782. return $measurements;
  783. }
  784. public function getMeasurements($_onlyUnstamped = true)
  785. {
  786. $measurementsQuery = Measurement::where('is_removed', false);
  787. if ($this->pro_type != 'ADMIN') {
  788. $measurementsQuery
  789. ->whereIn('client_id', $this->getMyClientIds());
  790. }
  791. if ($_onlyUnstamped) {
  792. $measurementsQuery
  793. ->whereNotNull('client_bdt_measurement_id')
  794. ->whereNotNull('ts')
  795. ->where('is_cellular_zero', false)
  796. ->where(function ($q) {
  797. $q->whereNull('status')
  798. ->orWhere(function ($q2) {
  799. $q2->where('status', '<>', 'ACK')
  800. ->where('status', '<>', 'INVALID_ACK');
  801. });
  802. });
  803. }
  804. $x = [];
  805. $measurements = $measurementsQuery->orderBy('ts', 'desc')->paginate(50);
  806. // eager load stuff needed in JS
  807. foreach ($measurements as $measurement) {
  808. // if ($measurement->client_bdt_measurement_id) {
  809. // $measurement->bdtMeasurement = $measurement->clientBDTMeasurement->measurement;
  810. // }
  811. unset($measurement->clientBDTMeasurement); // we do not need this travelling to the frontend
  812. $client = [
  813. "uid" => $measurement->client->uid,
  814. "name" => $measurement->client->displayName(),
  815. ];
  816. $measurement->patient = $client;
  817. $measurement->careMonth = $measurement->client->currentCareMonth();
  818. $measurement->timestamp = friendly_date_time($measurement->created_at);
  819. unset($measurement->client); // we do not need this travelling to the frontend
  820. // if($measurement->label == 'SBP' || $measurement->label = 'DBP'){
  821. // continue;
  822. // }
  823. $x[] = $measurement;
  824. }
  825. return $measurements;
  826. }
  827. public function companyPros()
  828. {
  829. return $this->hasMany(CompanyPro::class, 'pro_id', 'id')
  830. ->where('is_active', true);
  831. }
  832. public function companyProPayers()
  833. {
  834. return $this->hasMany(CompanyProPayer::class, 'pro_id', 'id');
  835. }
  836. public function isAssociatedWithMCPayer() {
  837. $companyProPayers = $this->companyProPayers;
  838. $foundMC = false;
  839. if($companyProPayers) {
  840. foreach ($companyProPayers as $companyProPayer) {
  841. if($companyProPayer->payer && $companyProPayer->payer->is_medicare) {
  842. $foundMC = true;
  843. break;
  844. }
  845. }
  846. }
  847. return $foundMC;
  848. }
  849. public function isAssociatedWithNonMCPayer($_payerID) {
  850. $companyProPayers = $this->companyProPayers;
  851. $foundNonMC = false;
  852. if($companyProPayers) {
  853. foreach ($companyProPayers as $companyProPayer) {
  854. if($companyProPayer->payer && !$companyProPayer->payer->is_medicare && $companyProPayer->payer->id === $_payerID) {
  855. $foundNonMC = true;
  856. break;
  857. }
  858. }
  859. }
  860. return $foundNonMC;
  861. }
  862. public function companyLocations() {
  863. $companyProPayers = $this->companyProPayers;
  864. $companyIDs = [];
  865. foreach ($companyProPayers as $companyProPayer) {
  866. $companyIDs[] = $companyProPayer->company_id;
  867. }
  868. $locations = [];
  869. if(count($companyIDs)) {
  870. $locations = CompanyLocation::whereIn('id', $companyIDs)->get();
  871. }
  872. return $locations;
  873. }
  874. public function shadowClient() {
  875. return $this->hasOne(Client::class, 'id', 'shadow_client_id');
  876. }
  877. public function defaultCompanyPro() {
  878. return $this->hasOne(CompanyPro::class, 'id', 'default_company_pro_id');
  879. }
  880. public function currentNotePickupForProcessing() {
  881. return $this->hasOne(NotePickupForProcessing::class, 'id', 'current_note_pickup_for_processing_id');
  882. }
  883. public function get_patients_not_seen_in_45_days_count_as_mcp(){
  884. return 0;
  885. }
  886. //DNA_DASHBOARD
  887. //queries
  888. private function patientsQueryAsDna(){
  889. // WHERE na_pro_id = :me.id
  890. return Client::where('default_na_pro_id', $this->id);
  891. }
  892. private function patientsAwaitingMcpVisitQueryAsDna(){
  893. // WHERE has_mcp_done_onboarding_visit <> 'YES'
  894. return Client::where('default_na_pro_id', $this->id)->where('has_mcp_done_onboarding_visit', '<>', 'YES');
  895. }
  896. private function patientsWithoutAppointmentQueryAsDna(){
  897. // WHERE today_mcp_appointment_date IS NULL AND next_mcp_appointment_date IS NULL
  898. return Client::where('default_na_pro_id', $this->id)
  899. ->whereNull('today_mcp_appointment_date')
  900. ->whereNull('next_mcp_appointment_date');
  901. }
  902. private function encountersPendingMyReviewQueryAsDna(){
  903. // WHERE ally_pro_id = me.id AND is_cancelled IS NOT TRUE AND is_signed_by_hcp IS TRUE AND is_signed_by_ally IS NOT TRUE;
  904. return Note::where('ally_pro_id', $this->id)
  905. ->where('is_cancelled', '<>', true)
  906. ->where('is_signed_by_hcp', true)
  907. ->where('is_signed_by_ally','<>', true);
  908. }
  909. private function encountersInProgressQueryAsDna(){
  910. // SELECT * FROM note WHERE ally_pro_id = me.id AND is_cancelled IS NOT TRUE AND is_signed_by_hcp IS NOT TRUE ORDER BY effective_dateest DESC, created_at DESC;
  911. return Note::where('ally_pro_id', $this->id)
  912. ->where('is_cancelled', '<>', true)
  913. ->where('is_signed_by_hcp', '<>', true);
  914. }
  915. private function appointmentsPendingConfirmationQueryAsDna(){
  916. // WHERE client_id IN (SELECT id FROM client WHERE default_na_pro_id = :me.id) AND status = 'PENDING'
  917. $myId = $this->id;
  918. return Appointment::whereHas('client', function($clientQuery) use ($myId) {
  919. return $clientQuery->where('default_na_pro_id', $myId);
  920. })->where('status', 'PENDING');
  921. }
  922. private function cancelledAppointmentsPendingAckQueryAsDna(){
  923. // WHERE client_id IN (SELECT id FROM client WHERE default_na_pro_id = :me.id) AND status = 'CANCELLED' AND is_status_acknowledgement_from_default_na_pending IS TRUE;
  924. $myId = $this->id;
  925. return Appointment::whereHas('client', function($clientQuery) use ($myId) {
  926. return $clientQuery->where('default_na_pro_id', $myId);
  927. })->where('status', 'CANCELLED')
  928. ->where('is_status_acknowledgement_from_default_na_pending', true);
  929. }
  930. private function reportsPendingAckQueryAsDna(){
  931. // WHERE client_id IN (SELECT id FROM client WHERE default_na_pro_id = :me.id) AND has_na_pro_signed IS FALSE AND is_entry_error
  932. $myId = $this->id;
  933. return IncomingReport::whereHas('client',function($clientQuery) use ($myId) {
  934. return $clientQuery->where('default_na_pro_id', $myId);
  935. })->where('has_na_pro_signed', '<>', true)
  936. ->where('is_entry_error','<>', true);
  937. }
  938. private function supplyOrdersPendingMyAckQueryAsDna(){
  939. // WHERE client_id IN (SELECT id FROM client WHERE default_na_pro_id = :me.id) AND has_na_pro_signed IS FALSE AND is_signed_by_pro IS TRUE AND is_cancelled IS NOT TRUE;
  940. $myId = $this->id;
  941. return SupplyOrder::whereHas('client',function($clientQuery) use ($myId) {
  942. return $clientQuery->where('default_na_pro_id', $myId);
  943. })->where('has_na_pro_signed', '<>', true)
  944. ->where('is_signed_by_pro', true)
  945. ->where('is_cancelled', '<>', true);
  946. }
  947. private function supplyOrdersPendingHcpApprovalQueryAsDna(){
  948. // WHERE client_id IN (SELECT id FROM client WHERE default_na_pro_id = :me.id) AND has_na_pro_signed IS TRUE AND is_signed_by_pro IS NOT TRUE AND is_cancelled IS NOT TRUE;
  949. $myId = $this->id;
  950. return SupplyOrder::whereHas('client',function($clientQuery) use ($myId) {
  951. return $clientQuery->where('default_na_pro_id', $myId);
  952. })->where('has_na_pro_signed', true)
  953. ->where('is_signed_by_pro','<>', true)
  954. ->where('is_cancelled', '<>', true);
  955. }
  956. //counts
  957. public function patientsCountAsDna(){
  958. return $this->patientsQueryAsDna()->count();
  959. }
  960. public function patientsAwaitingMcpVisitCountAsDna(){
  961. return $this->patientsAwaitingMcpVisitQueryAsDna()->count();
  962. }
  963. public function patientsWithoutAppointmentCountAsDna(){
  964. return $this->patientsWithoutAppointmentQueryAsDna()->count();
  965. }
  966. public function encountersPendingMyReviewCountAsDna(){
  967. return $this->encountersPendingMyReviewQueryAsDna()->count();
  968. }
  969. public function encountersInProgressCountAsDna(){
  970. return $this->encountersInProgressQueryAsDna()->count();
  971. }
  972. public function appointmentsPendingConfirmationCountAsDna(){
  973. return $this->appointmentsPendingConfirmationQueryAsDna()->count();
  974. }
  975. public function cancelledAppointmentsPendingAckCountAsDna(){
  976. return $this->cancelledAppointmentsPendingAckQueryAsDna()->count();
  977. }
  978. public function reportsPendingAckCountAsDna(){
  979. return $this->reportsPendingAckQueryAsDna()->count();
  980. }
  981. public function supplyOrdersPendingMyAckCountAsDna(){
  982. return $this->supplyOrdersPendingMyAckQueryAsDna()->count();
  983. }
  984. public function supplyOrdersPendingHcpApprovalCountAsDna(){
  985. return $this->supplyOrdersPendingHcpApprovalQueryAsDna()->count();
  986. }
  987. //records
  988. private $DNA_RESULTS_PAGE_SIZE = 50;
  989. public function patientsRecordsAsDna(){
  990. return $this->patientsQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  991. }
  992. public function patientsAwaitingMcpVisitRecordsAsDna(){
  993. return $this->patientsAwaitingMcpVisitQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  994. }
  995. public function patientsWithoutAppointmentRecordsAsDna(){
  996. return $this->patientsWithoutAppointmentQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  997. }
  998. public function encountersPendingMyReviewRecordsAsDna(){
  999. return $this->encountersPendingMyReviewQueryAsDna()
  1000. ->orderBy('effective_dateest', 'desc')
  1001. ->orderBy('created_at', 'desc')
  1002. ->paginate($this->DNA_RESULTS_PAGE_SIZE);
  1003. }
  1004. public function encountersInProgressRecordsAsDna(){
  1005. return $this->encountersInProgressQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  1006. }
  1007. public function appointmentsPendingConfirmationRecordsAsDna(){
  1008. return $this->appointmentsPendingConfirmationQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  1009. }
  1010. public function cancelledAppointmentsPendingAckRecordsAsDna(){
  1011. return $this->cancelledAppointmentsPendingAckQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  1012. }
  1013. public function reportsPendingAckRecordsAsDna(){
  1014. return $this->reportsPendingAckQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  1015. }
  1016. public function supplyOrdersPendingMyAckRecordsAsDna(){
  1017. return $this->supplyOrdersPendingMyAckQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  1018. }
  1019. public function supplyOrdersPendingHcpApprovalRecordsAsDna(){
  1020. return $this->supplyOrdersPendingHcpApprovalQueryAsDna()->paginate($this->DNA_RESULTS_PAGE_SIZE);
  1021. }
  1022. public function measurementsPendingReviewAsDna(){
  1023. //Measurements Pending Review
  1024. // SELECT * FROM measurement WHERE client_id IN (SELECT id FROM client WHERE rmm_pro_id = :me.id)
  1025. // AND has_been_stamped_by_rmm IS FALSE AND is_cellular IS TRUE AND is_cellular_zero IS NOT TRUE AND is_active IS TRUE ORDER BY ts DESC;
  1026. $myId = $this->id;
  1027. return Measurement::whereHas('client',function($clientQuery) use ($myId) {
  1028. return $clientQuery->where('rmm_pro_id', $myId);
  1029. })
  1030. ->where('has_been_stamped_by_rmm', '<>', true)
  1031. ->where('is_cellular', true)
  1032. ->where('is_cellular_zero', '<>', true)
  1033. ->where('is_active', true)
  1034. ->orderBy('ts', 'DESC')
  1035. ->paginate(15);
  1036. }
  1037. public function getProcessingAmountAsDna(){
  1038. $expectedForCm = DB::select(DB::raw("SELECT coalesce(SUM(cm_expected_payment_amount),0) as expected_pay FROM bill WHERE cm_pro_id = :performerProID AND has_cm_been_paid = false AND is_signed_by_cm IS TRUE AND is_cancelled = false"), ['performerProID' => $this->id])[0]->expected_pay;
  1039. $expectedForRme = DB::select(DB::raw("SELECT coalesce(SUM(rme_expected_payment_amount),0) as expected_pay FROM bill WHERE rme_pro_id = :performerProID AND has_rme_been_paid = false AND is_signed_by_rme IS TRUE AND is_cancelled = false"), ['performerProID' => $this->id])[0]->expected_pay;
  1040. $expectedForRmm = DB::select(DB::raw("SELECT coalesce(SUM(rmm_expected_payment_amount),0) as expected_pay FROM bill WHERE rmm_pro_id = :performerProID AND has_rmm_been_paid = false AND is_signed_by_rmm IS TRUE AND is_cancelled = false"), ['performerProID' => $this->id])[0]->expected_pay;
  1041. $expectedForNa = DB::select(DB::raw("SELECT coalesce(SUM(generic_pro_expected_payment_amount),0) as expected_pay FROM bill WHERE generic_pro_id = :performerProID AND has_generic_pro_been_paid = false AND is_signed_by_generic_pro IS TRUE AND is_cancelled = false"), ['performerProID' => $this->id])[0]->expected_pay;
  1042. $totalExpectedAmount = $expectedForCm + $expectedForRme + $expectedForRmm + $expectedForNa;
  1043. return $totalExpectedAmount;
  1044. }
  1045. public function getNextPaymentDateAsDna(){
  1046. $nextPaymentDate = '--';
  1047. //if today is < 15th, next payment is 15th, else nextPayment is
  1048. $today = strtotime(date('Y-m-d'));
  1049. $todayDate = date('j', $today);
  1050. $todayMonth = date('m', $today);
  1051. $todayYear = date('Y', $today);
  1052. if ($todayDate < 15) {
  1053. $nextPaymentDate = new DateTime();
  1054. $nextPaymentDate->setDate($todayYear, $todayMonth, 15);
  1055. $nextPaymentDate = $nextPaymentDate->format('m/d/Y');
  1056. } else {
  1057. $nextPaymentDate = new \DateTime();
  1058. $lastDayOfMonth = date('t', $today);
  1059. $nextPaymentDate->setDate($todayYear, $todayMonth, $lastDayOfMonth);
  1060. $nextPaymentDate = $nextPaymentDate->format('m/d/Y');
  1061. }
  1062. return $nextPaymentDate;
  1063. }
  1064. public function clientSmsesAsDna(){
  1065. $myId = $this->id;
  1066. return ClientSMS::whereHas('client', function($clientQuery) use ($myId){
  1067. return $clientQuery->where('default_na_pro_id', $myId);
  1068. })
  1069. ->orderBy('created_at', 'DESC')
  1070. ->paginate(15);
  1071. }
  1072. public function clientMemosAsDna(){
  1073. $naClientMemos = DB::select(
  1074. DB::raw("
  1075. SELECT c.uid as client_uid, c.name_first, c.name_last,
  1076. cm.uid, cm.content, cm.created_at
  1077. FROM client c join client_memo cm on c.id = cm.client_id
  1078. WHERE
  1079. c.default_na_pro_id = {$this->id}
  1080. ORDER BY cm.created_at DESC
  1081. ")
  1082. );
  1083. return $naClientMemos;
  1084. }
  1085. public function getAppointmentsPendingStatusChangeAckAsDna() {
  1086. $myId = $this->id;
  1087. return Appointment::whereHas('client', function($clientQuery) use ($myId){
  1088. return $clientQuery->where('default_na_pro_id', $myId);
  1089. })
  1090. ->where('is_status_acknowledgement_from_appointment_pro_pending', true)
  1091. ->where('raw_date', '>=', DB::raw('NOW()'))
  1092. ->orderBy('raw_date', 'asc')
  1093. ->get();
  1094. }
  1095. public function getAppointmentsPendingDecisionAckAsDna() {
  1096. $myId = $this->id;
  1097. return Appointment::whereHas('client', function($clientQuery) use ($myId){
  1098. return $clientQuery->where('default_na_pro_id', $myId);
  1099. })
  1100. ->where('is_decision_acknowledgement_from_appointment_pro_pending', true)
  1101. ->where('raw_date', '>=', DB::raw('NOW()'))
  1102. ->orderBy('raw_date', 'asc')
  1103. ->get();
  1104. }
  1105. public function getAppointmentsPendingTimeChangeAckAsDna() {
  1106. $myId = $this->id;
  1107. return Appointment::whereHas('client', function($clientQuery) use ($myId){
  1108. return $clientQuery->where('default_na_pro_id', $myId);
  1109. })
  1110. ->where('is_time_change_acknowledgement_from_appointment_pro_pending', true)
  1111. ->where('raw_date', '>=', DB::raw('NOW()'))
  1112. ->orderBy('raw_date', 'asc')
  1113. ->get();
  1114. }
  1115. function myGenericBills() {
  1116. return Bill::where('bill_service_type', 'GENERIC')
  1117. ->where('generic_pro_id', $this->id)
  1118. ->orderBy('created_at', 'DESC')->get();
  1119. }
  1120. }