GS-2373

alex

2025-11-17 3fce3e400fd44d3b6f345a31413e0ad2b7724107

 lib/db.js

@@ -1,5 +1,6 @@
const mysql = require("mysql2/promise")
const dayjs = require("dayjs")
const _ = require("lodash")

const log = require("../logger")
const searchLib = require("./search")
@@ -43,6 +44,9 @@
    getSingleKursTeilnehmer,
    getKursTeilnehmerCount,

    getKursLp,
    getKursUnterobjektLp,

    getKursOffline,
    setKursOffline,

@@ -83,7 +87,7 @@
}

async function getUsers(offset = 0, limit = 10, search = null) {
    log.info("++++++++++ get users", offset, limit, search)
    // log.info("++++++++++ get users", offset, limit, search)
    limit = Number(limit) || 10
    offset = Number(offset) || 0
    // TODO check args for SQL Injection
@@ -402,10 +406,129 @@
    return results
}

async function getKursLp(obj_id, raw = false) {
    const {ref_id} = await getRefIdFromObjId(obj_id)
    const tnUnter = await getKursUnterobjektLp(obj_id)

    if (raw) {
        return tnUnter
    } else { // LP aller Unterobjekte zusammenfassen
        const libLp = require("../lib/libLp")
        const data = libLp.alleAuswerten(tnUnter)
        return data
    }

    // const teilnehmer = await getKursTeilnehmer(ref_id)
    // const tnUnter = await getKursUnterobjektLp(obj_id)
    // console.table(teilnehmer)
    // console.table(tnUnter)
    //
    // /**
    //  * Die beiden Datensätze mergen
    //  * NEIN - es reicht der
    //  *
    //  */
    //
    // const idx = _.groupBy(tnUnter, "usr_id")
    // for (const tn of teilnehmer) {
    //     delete tn.parent_id
    //     delete tn.type
    //     delete tn.active
    //
    //     /** @type Array */
    //     const unter = idx[tn.usr_id]
    //     if (!unter) continue
    //
    //     /**
    //      * wenn unter.status_changed neuer, wird unter tn.status_changed vorgezogen
    //      * wenn unter.status neuer, überscheibt es tn.status
    //      * tn.passed muss zurückgesetzt werden wenn tn.status überschrieben wird
    //      */
    //     tn.status_overwrite = false
    //
    //     // max unter status_changed finden
    //     const unterStatusChanged = _.max(unter.map(u => u.status_changed))
    //
    //     // es muss nur überschrieben werden wenn das Unterdatum größer ist
    //     if (unterStatusChanged > tn.status_changed) {
    //         // unter Status auswerten
    //         // 0 = noch nicht bearbeitet
    //         // 1 = in Bearbeitung
    //         // 2 = bestanden
    //         // 3 = nicht bestanden
    //
    //         /** @type Array */
    //         const unterStatusse = unter.map(u => u.status)
    //         let newStatus = tn.status
    //         const allSame = function () {
    //             if (!unterStatusse.length) return false
    //             const first = unterStatusse[0]
    //             return unterStatusse.every(it => it === first)
    //         }()
    //         console.log({unterStatusse})
    //         // Fall 1: keine Unterstatussse vorhanden -> status vom Kurs
    //         if (!unterStatusse.length) {
    //             newStatus = tn.status
    //         }
    //         // Fall 2: eines nicht bestanden -> nicht bestanden // 0,1,2,3 -> 3
    //         if (unterStatusse.some(u => u === 3)) {
    //             newStatus = 3
    //         }
    //         // Fall 3: alle statusse gleich -> status // 0,0,0 1,1,1 2,2,2 3,3,3
    //         else if (allSame) {
    //             newStatus = unterStatusse[0]
    //         }
    //         // Fall 4: wenn eines in Bearbeitung -> in Bearbeitung // 0,1,0 2,1,2
    //         else if (unterStatusse.some(u => u === 1)) {
    //             newStatus = 1
    //         }
    //         // Fall 5: sonst in Bearbeitung
    //         else {
    //             // newStatus = Math.max.apply(this, unterStatusse)
    //             newStatus = 1
    //         }
    //         tn.status_changed = unterStatusChanged
    //         tn.status = newStatus
    //         tn.status_overwrite = true
    //     }
    // }
    // return teilnehmer
}

async function getKursUnterobjektLp(obj_id) {
    const pool = await poolP
    const q = `SELECT ud.usr_id,
                      ud.login,
                      ud.firstname,
                      ud.lastname,
                      ulc.obj_id,
                      ulc.item_id,
                      ulc.lpmode,
                      t.obj_id as item_obj_id,
                      od.type,
                      ulm.status,
                      ulm.status_changed,
                      ulm.percentage,
                      ulm.completed
               FROM ${database}.ut_lp_collections ulc
                        INNER JOIN ${database}.object_reference t ON t.ref_id = ulc.item_id
                        INNER JOIN ${database}.ut_lp_marks ulm ON ulm.obj_id = t.obj_id
                        INNER JOIN ${database}.usr_data ud ON ud.usr_id = ulm.usr_id
                        INNER JOIN ${database}.object_data od ON od.obj_id = t.obj_id
               WHERE ulc.obj_id = ${obj_id} # obj_id Kurs
                    AND ulc.active = 1
                    AND ulc.lpmode = 5  # nur mode 5
               ORDER BY ud.usr_id, ulc.item_id
    `
    const [results] = await pool.query(q)
    return results
}


async function getKursOffline(obj_id) {
    const pool = await poolP
    const q = `SELECT offline 
                FROM ${database}.object_data
    const q = `SELECT offline
               FROM ${database}.object_data
               WHERE obj_id = ${obj_id}
    `
    const [results] = await pool.query(q)