ks-app-employment-service/stores/useRecommedIndexedDBStore.js

import {
    defineStore
} from 'pinia';
import {
    ref
} from 'vue'
import IndexedDBHelper from '@/common/IndexedDBHelper.js'
import useDictStore from '@/stores/useDictStore';
import jobAnalyzer from '@/utils/jobAnalyzer';
import {
    msg
} from '@/common/globalFunction.js'
import baseDB from './BaseDBStore';


class JobRecommendation {
    constructor() {
        this.conditions = {}; // 存储最新的条件及其出现次数
        this.askHistory = new Map(); // 记录每个条件的最后询问时间
        this.cooldown = 5 * 60 * 1000; // 冷却时间（单位：毫秒）
    }

    updateConditions(newConditions) {
        this.conditions = newConditions;
    }

    getCurrentTime() {
        return Date.now();
    }

    /**
     * 获取下一个符合条件的推荐问题
     * @returns {string|null} 返回推荐的问题，或 null（无可询问的）
     */
    getNextQuestion() {
        const now = this.getCurrentTime();

        // 按照出现次数降序排序
        const sortedConditions = Object.entries(this.conditions)
            .sort((a, b) => b[1] - a[1]); // 按出现次数降序排序


        for (const [condition, count] of sortedConditions) {
            const lastAskedTime = this.askHistory.get(condition);

            if (!lastAskedTime || now - lastAskedTime >= this.cooldown) {
                this.askHistory.set(condition, now);

                return condition;
            }
        }

        return null; // 没有可询问的
    }
}

// **🔹 创建推荐系统**
export const jobRecommender = new JobRecommendation();

export const useRecommedIndexedDBStore = defineStore("indexedDB", () => {
    const tableName = ref('record')
    const total = ref(200) // 记录多少条数据

    // 插入数据
    async function addRecord(payload) {
        const totalRecords = await baseDB.db.getRecordCount(tableName.value);
        if (totalRecords >= total.value) {
            console.log(`⚠数据超过 ${total.value} 条，删除最早的一条...`);
            await baseDB.db.deleteOldestRecord(tableName.value);
        }
        if (!baseDB.isDBReady) await baseDB.initDB();
        return await baseDB.db.add(tableName.value, payload);
    }

    // 获取所有数据
    async function getRecord() {
        if (!baseDB.isDBReady) await baseDB.initDB();
        return await baseDB.db.getAll(tableName.value);
    }

    // 格式化浏览数据岗位数据
    function JobParameter(job) {
        const experIenceLabel = useDictStore().dictLabel('experience', job.experience)
        const jobLocationAreaCodeLabel = useDictStore().dictLabel('area', job.jobLocationAreaCode)
        return {
            jobCategory: job.jobCategory,
            jobTitle: job.jobTitle,
            minSalary: job.minSalary,
            maxSalary: job.maxSalary,
            experience: job.experience,
            experIenceLabel,
            jobLocationAreaCode: job.jobLocationAreaCode,
            jobLocationAreaCodeLabel,
            createTime: Date.now()
        }
    }

    function analyzer(jobsData) {
        const result = jobAnalyzer.analyze(jobsData)
        const sort = jobAnalyzer.printUnifiedResults(result)
        return {
            result,
            sort
        }
    }

    return {
        addRecord,
        getRecord,
        JobParameter,
        analyzer
    };
});