在线统计处理

src/server/app.js

@@ -128,7 +128,7 @@ if(!server.address()){
    log.info('Configuration profile: ' + configFile.split('.')[1]);
}
//JobInitializer.init();
JobInitializer.init();
pubSub.registerHandlers(config.subChannel,msg=> console.log(msg));
pubSub.subscribe(config.subChannel);

src/server/models/schedule/job.initializer.js

@@ -3,10 +3,6 @@
let Scheduler = require('./scheduler');
let TopicTerminatingJob = require('./jobs/topic.terminating.job');
let configFile = require('../../include/commons').CONFIG_FILE;
let config = require('../../resources/config/' + configFile);
const TOPIC_TERMINATING_CRON = config.topicConfig.TERMINATING_CRON;
class JobInitializer {
    constructor() {
@@ -14,7 +10,7 @@ class JobInitializer {
    // schedule jobs
    static init() {
        Scheduler.cronSchedule(TOPIC_TERMINATING_CRON, TopicTerminatingJob.exec);
        Scheduler.cronSchedule("0 0 3 * * *", TopicTerminatingJob.exec);
    }
}

src/server/models/schedule/jobs/topic.terminating.job.js

@@ -6,39 +6,17 @@
 */
"use strict";
let TopicRepo = require('../../../repository/mysql/topics.repo');
let ModelUtil = require("../../../util/model.util.js");
let WlyySDK = require("../../../util/wlyy.sdk");
let onlineCache = require('../../socket.io/onlineCache').onlineCache();
let log = require("../../../util/log.js");
let configFile = require('../../../include/commons').CONFIG_FILE;
let config = require('../../../resources/config/' + configFile);
const TOPIC_TTL = config.topicConfig.TTL;
class TopicTerminatingJob {
    constructor() {
    }
    static exec() {
        TopicRepo.findAllBySessionLastActiveTime(TOPIC_TTL, function (err, topics) {
            if (err) {
                return ModelUtil.logError("Find topics without activity over " + TOPIC_TTL + " hour(s) failed", err);
            }
            topics.forEach(function (topic) {
                let topicId = topic.topic_id;
                let topicName = topic.topic_name;
                WlyySDK.request('admin', '0a5c5258-8863-4b07-a3f9-88c768528ab4', '', 'admin_imei', '/doctor/consult/finish_consult?consult=' + topicId, 'GET', function (err, res) {
                    log.info("Got topic to terminate, " + topicId + ": " + topicName + ", last active time: " + topic.last_message_time);
                    if (err) return log.error("Terminating topic failed, try next time, error: ", err);
                    log.info("Terminating topic " + topicId + " succeed");
                });
            });
        });
        onlineCache.init();
    }
}

src/server/models/sessions/participants.js

@@ -263,9 +263,7 @@ class Participants extends RedisModel {
     */
    changUserRedisLoginStatus(userid,clientType,status,sessionId){
        let participants = new Participants();
        log.info("changUserRedisLoginStatus,userid:"+userid)
        log.info("changUserRedisLoginStatus,userid:"+userid)
        log.info("changUserRedisLoginStatus,userid:"+userid)
        log.info("changUserRedisLoginStatus,userid:"+userid);
        if(sessionId != "system"){
            if(status==1){

src/server/models/socket.io/onlineCache.js

@@ -23,10 +23,20 @@ class OnlineCache{
        if (onlineCache === null) {
            onlineCache = new OnlineCache();
        }
        return onlineCache;
    }
    /**
     * 清空数据，
     */
    init(){
        this._helperMap = new Map();
        this._teacherMap = new Map();
        this._childMap = new Map();
        this._olderWxMap = new Map();
        this._olderPadMap = new Map();
    }
    getListByType(type){
        if("helper" == type){
            return this.mapToJson(this._helperMap);