<commit_before>'use strict';
import { _ } from 'meteor/underscore';
import { Meteor } from 'meteor/meteor';
import { dbLog } from '../db/dbLog';
import { dbInstantMessage } from '../db/dbInstantMessage';
import { dbResourceLock } from '../db/dbResourceLock';
import { threadId } from './thread';

Meteor.startup(function() {
  Meteor.setInterval(handleInstantMessage, 5000);
});

function handleInstantMessage() {
  try {
    dbResourceLock.insert({
      _id: 'instantMessage',
      threadId: threadId,
      task: 'handleInstantMessage',
      time: new Date()
    });
    const logList = dbLog
      .find(
        {
          resolve: false
        },
        {
          disableOplog: true
        }
      )
      .fetch();
    _.each(logList, (log) => {
      const instantMessage = {
        type: log.logType,
        createdAt: log.createdAt,
        onlyForUsers: [],
        source: '!'
      };
      switch (log.logType) {
        case '驗證通過': {
          instantMessage.onlyForUsers = log.username;
          instantMessage.message = log.username[0] + '的帳號驗證通過，領取起始資金$' + log.price + '。';
          break;
        }
        case '發薪紀錄': {
          instantMessage.message = '系統向所有已驗證通過的使用者發給了' + log.price + '的薪水！';
          break;
        }
        case '創立公司': {
          instantMessage.message = log.username[0] + '發起了「' + log.companyName + '」的新公司創立計劃，誠意邀請有意者投資！';
          break;
        }
        case '參與投資': {
          instantMessage.message = log.username[0] + '向「' + log.companyName + '公司創立計劃」投資了$' + log.amount + '！';
          break;
        }
        case '創立失敗': {
          instantMessage.message = log.username.join('、') + '等人投資的「' + log.companyName + '公司創立計劃」由於投資人數不足失敗了，投資金額將全數返回！';
          break;
        }
        case '創立成功': {
          instantMessage.message = log.username.join('、') + '等人投資的「' + log.companyName + '公司創立計劃」成功了，該公司正式上市，初始股價為$' + log.price + '！';
          break;
        }
        case '創立得股': {
          instantMessage.onlyForUsers = log.username;
          instantMessage.message = '對「' + log.companyName + '公司創立計劃」的投資為你帶來了' + log.amount + '數量的公司股票！';
          break;
        }
        case '購買下單': {
          instantMessage.message = log.username[0] + '想要用每股$' + log.price + '的單價購買' + log.amount + '數量的「' + log.companyName + '」公司股票！';
          break;
        }
        case '販賣下單': {
          instantMessage.message = log.username[0] + '想要用每股$' + log.price + '的單價販賣' + log.amount + '數量的「' + log.companyName + '」公司股票！';
          break;
        }
        case '取消下單': {
          instantMessage.message = log.username[0] + '取消了以每股$' + log.price + '的單價' + log.message + log.amount + '數量的「' + log.companyName + '」公司股票的訂單！';
          break;
        }
        case '訂單完成': {
          instantMessage.onlyForUsers = log.username;
          instantMessage.message = '您以每股$' + log.price + '的單價' + log.message + log.amount + '數量的「' + log.companyName + '」公司股票的訂單已經全數交易完畢！';
          break;
        }
        case '公司釋股': {
          instantMessage.message = '由於大量的高價買單需求，「' + log.companyName + '」公司釋出了' + log.amount + '數量的股票！';
          break;
        }
        case '交易紀錄': {
          instantMessage.message = log.username[0] + '以$' + log.price + '的單價向' + (log.username[1] || '「companyName」公司') + '購買了' + log.amount + '數量的「' + log.companyName + '」公司股票！';
          break;
        }
        case '辭職紀錄': {
          instantMessage.message = log.username[0] + '辭去了「' + log.companyName + '」公司的經理人職務！';
          break;
        }
        case '參選紀錄': {
          instantMessage.message = log.username[0] + '開始競選「' + log.companyName + '」公司的經理人職務！';
          break;
        }
        case '經理管理': {
          instantMessage.message = log.username[0] + '修改了「' + log.companyName + '」公司的資訊！';
          break;
        }
        //推薦產品不進即時訊息
        case '推薦產品': {
          instantMessage.message = log.username[0] + '向「' + log.companyName + '」公司的一項產品投了一張推薦票，使其獲得了$' + log.price + '的營利額！';<commit_msg>移除無用註解。<commit_after>'use strict';
import { _ } from 'meteor/underscore';
import { Meteor } from 'meteor/meteor';
import { dbLog } from '../db/dbLog';
import { dbInstantMessage } from '../db/dbInstantMessage';
import { dbResourceLock } from '../db/dbResourceLock';
import { threadId } from './thread';

Meteor.startup(function() {
  Meteor.setInterval(handleInstantMessage, 5000);
});

function handleInstantMessage() {
  try {
    dbResourceLock.insert({
      _id: 'instantMessage',
      threadId: threadId,
      task: 'handleInstantMessage',
      time: new Date()
    });
    const logList = dbLog
      .find(
        {
          resolve: false
        },
        {
          disableOplog: true
        }
      )
      .fetch();
    _.each(logList, (log) => {
      const instantMessage = {
        type: log.logType,
        createdAt: log.createdAt,
        onlyForUsers: [],
        source: '!'
      };
      switch (log.logType) {
        case '驗證通過': {
          instantMessage.onlyForUsers = log.username;
          instantMessage.message = log.username[0] + '的帳號驗證通過，領取起始資金$' + log.price + '。';
          break;
        }
        case '發薪紀錄': {
          instantMessage.message = '系統向所有已驗證通過的使用者發給了' + log.price + '的薪水！';
          break;
        }
        case '創立公司': {
          instantMessage.message = log.username[0] + '發起了「' + log.companyName + '」的新公司創立計劃，誠意邀請有意者投資！';
          break;
        }
        case '參與投資': {
          instantMessage.message = log.username[0] + '向「' + log.companyName + '公司創立計劃」投資了$' + log.amount + '！';
          break;
        }
        case '創立失敗': {
          instantMessage.message = log.username.join('、') + '等人投資的「' + log.companyName + '公司創立計劃」由於投資人數不足失敗了，投資金額將全數返回！';
          break;
        }
        case '創立成功': {
          instantMessage.message = log.username.join('、') + '等人投資的「' + log.companyName + '公司創立計劃」成功了，該公司正式上市，初始股價為$' + log.price + '！';
          break;
        }
        case '創立得股': {
          instantMessage.onlyForUsers = log.username;
          instantMessage.message = '對「' + log.companyName + '公司創立計劃」的投資為你帶來了' + log.amount + '數量的公司股票！';
          break;
        }
        case '購買下單': {
          instantMessage.message = log.username[0] + '想要用每股$' + log.price + '的單價購買' + log.amount + '數量的「' + log.companyName + '」公司股票！';
          break;
        }
        case '販賣下單': {
          instantMessage.message = log.username[0] + '想要用每股$' + log.price + '的單價販賣' + log.amount + '數量的「' + log.companyName + '」公司股票！';
          break;
        }
        case '取消下單': {
          instantMessage.message = log.username[0] + '取消了以每股$' + log.price + '的單價' + log.message + log.amount + '數量的「' + log.companyName + '」公司股票的訂單！';
          break;
        }
        case '訂單完成': {
          instantMessage.onlyForUsers = log.username;
          instantMessage.message = '您以每股$' + log.price + '的單價' + log.message + log.amount + '數量的「' + log.companyName + '」公司股票的訂單已經全數交易完畢！';
          break;
        }
        case '公司釋股': {
          instantMessage.message = '由於大量的高價買單需求，「' + log.companyName + '」公司釋出了' + log.amount + '數量的股票！';
          break;
        }
        case '交易紀錄': {
          instantMessage.message = log.username[0] + '以$' + log.price + '的單價向' + (log.username[1] || '「companyName」公司') + '購買了' + log.amount + '數量的「' + log.companyName + '」公司股票！';
          break;
        }
        case '辭職紀錄': {
          instantMessage.message = log.username[0] + '辭去了「' + log.companyName + '」公司的經理人職務！';
          break;
        }
        case '參選紀錄': {
          instantMessage.message = log.username[0] + '開始競選「' + log.companyName + '」公司的經理人職務！';
          break;
        }
        case '經理管理': {
          instantMessage.message = log.username[0] + '修改了「' + log.companyName + '」公司的資訊！';
          break;
        }
        case '推薦產品': {
          instantMessage.message = log.username[0] + '向「' + log.companyName + '」公司的一項產品投了一張推薦票，使其獲得了$' + log.price + '的營利額！';
{'fraction_non_alphanumeric': 0.1607256120766206, 'fraction_numerical': 0.004059368260814411, 'mean_word_length': 2.046367851622875, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '4789920', 'n_tokens_mistral': 3288, 'n_tokens_neox': 3476, 'n_words': 464}