weekly_check_in.js

'use strict';

/**
 * @ngdoc function
 * @name livewellApp.controller:WeeklyCheckInCtrl
 * @description
 * # WeeklyCheckInCtrl
 * Controller of the livewellApp
 */
angular.module('livewellApp').controller('WeeklyCheckInCtrl', function($scope, $location, $routeParams, Questions, Guid, UserDetails, Pound, Database) {
    $scope.pageTitle = 'Weekly Check In';

    var phq_questions = Questions.query('phq9');
    var amrs_questions = Questions.query('amrs');

    //combine questions into one group for the page
    $scope.questionGroups = [phq_questions, amrs_questions];

    //allows you to pass a question index url param into the question group directive
    $scope.questionIndex = parseInt($routeParams.questionIndex) - 1 || 0;

    $scope.skippable = false;

    //overrides questiongroup default submit action to send data to PR
    $scope.submit = function() {
        var _SAVE_LOCATION = 'livewell_survey_data';

        $scope.responseArray[$scope.currentIndex] = $('form').serializeArray()[0];

        var responses = _.flatten($scope.responseArray);

        var sessionID = Guid.create();

        var clinicalStatus = JSON.parse(localStorage['clinicalStatus']);
    
        _.each(responses, function(el) {
            var payload = {
                userId: UserDetails.find,
                survey: $scope.pageTitle,
                questionDataLabel: el.name,
                questionValue: el.value,
                sessionGUID: sessionID,
                savedAt: new Date(),
                clinicalStatus: clinicalStatus
            };

            (new PurpleRobot()).emitReading(_SAVE_LOCATION, payload).execute();
            console.log(payload);
        });

        var responsePayload = {
            sessionID: sessionID,
            responses: responses
        };
        
        console.log('WEEKLY_PAYLOAD');
        console.log(JSON.stringify(responsePayload, 2));

        Pound.add('weeklyCheckIn', responsePayload);

        var lWR = responses;
        var phq8Sum = parseInt(lWR[0].value) + parseInt(lWR[1].value) + parseInt(lWR[2].value) + parseInt(lWR[3].value) + parseInt(lWR[4].value) + parseInt(lWR[5].value) + parseInt(lWR[6].value) + parseInt(lWR[7].value);
        var amrsSum = parseInt(lWR[8].value) + parseInt(lWR[9].value) + parseInt(lWR[10].value) + parseInt(lWR[11].value) + parseInt(lWR[12].value);

        if (_.where(JSON.parse(localStorage.team, { role: 'Psychiatrist' })[0] != undefined)) {
            $scope.psychiatristEmail = _.where(JSON.parse(localStorage.team), {
                role: 'Psychiatrist'
            })[0].email;
        } else {
            $scope.psychiatristEmail = '';
        }

        if (_.where(JSON.parse(localStorage.team), { role: 'Coach' })[0] != undefined) {
            $scope.coachEmail = _.where(JSON.parse(localStorage.team), {
                role: 'Coach'
            })[0].email;
        } else {
            $scope.coachEmail = ''
        }
        
        // Make new PR reading for weekly clinical reachout...

        if (amrsSum >= 10) {
            (new PurpleRobot()).emitReading('livewell_clinicalreachout', {
                call: 'coach',
                message: 'Altman Mania Rating Scale >= 10',
                clinicalStatus: clinicalStatus
            }).execute();
        
            (new PurpleRobot()).emitReading('livewell_email', {
                coachEmail: $scope.coachEmail,
                message: 'Altman Mania Rating Scale >= 10',
                clinicalStatus: clinicalStatus
            }).execute();
        }
        if (amrsSum >= 16) {
            (new PurpleRobot()).emitReading('livewell_clinicalreachout', {
                call: 'psychiatrist',
                message: 'Altman Mania Rating Scale >= 16',
                clinicalStatus: clinicalStatus
            }).execute();

            (new PurpleRobot()).emitReading('livewell_email', {
                psychiatristEmail: $scope.psychiatristEmail,
                message: 'Altman Mania Rating Scale >= 16',
                clinicalStatus: clinicalStatus
            }).execute();
        }

        if (phq8Sum >= 15) {
            (new PurpleRobot()).emitReading('livewell_clinicalreachout', {
                call: 'coach',
                message: 'PHQ8 >= 15',
                clinicalStatus: clinicalStatus
            }).execute();

            (new PurpleRobot()).emitReading('livewell_email', {
                coachEmail: $scope.coachEmail,
                message: 'PHQ8 >= 15',
                clinicalStatus: clinicalStatus
            }).execute();
        }
        if (phq8Sum >= 20) {
            (new PurpleRobot()).emitReading('livewell_clinicalreachout', {
                call: 'psychiatrist',
                message: 'PHQ8 >= 20',
                clinicalStatus: clinicalStatus
            }).execute();

            (new PurpleRobot()).emitReading('livewell_email', {
                psychiatristEmail: $scope.psychiatristEmail,
                message: 'PHQ8 >= 20',
                clinicalStatus: clinicalStatus
            }).execute();
        }

        var dbObject = {
            created: Date.now(),
            sessionID: sessionID,
            phq_composite: phq8Sum,
            amrs_composite: amrsSum
        };
        
        for (var i = 0; i < responsePayload['responses'].length; i++) {
            var response = responsePayload['responses'][i];
            
            dbObject[response['name']] = parseInt(response['value']);
        }

        Database.insertWithCallback('weekly_check_in', dbObject, function() {
            Database.updateWeeklyReachout(function() {
                Database.filter('clinical_weekly_reachout', 'updated', IDBKeyRange.lowerBound(0), "prev", function(cursor) {
					if (_.where(JSON.parse(localStorage.team), { role: 'Psychiatrist' })[0] != undefined) 
					{
						$scope.phoneNumber = _.where(JSON.parse(localStorage.team), {
							role: 'Psychiatrist'
						})[0].phone;
					} else {
						$scope.phoneNumber = '312-503-1886';
					}

                    $scope.reachoutMessage = null;

                    if (cursor != null) {
                        $scope.reachoutMessage = cursor.value.message
                    }

                    $scope.$apply();

					if ($scope.reachoutMessage != null) {
						$("#continue").modal();

						$('#continue').on('hide.bs.modal', function (e) {
							console.log('HIDE');
							console.log($location);
						
							$location.path("/ews");
							$scope.$apply();
						});
					} else {
						$location.path("/ews");
						$scope.$apply();
					}
                });
            });
        });
    }
});