offline-pdf-app/server/index.js

const express = require('../node_modules/express')

const bodyParser = require('../node_modules/body-parser')

const path = require('path')

const net = require('net');

const { getDevicesId, regeditKey, validate } = require(path.join(__dirname, '../dll/index'))

const cors = require('cors');

const fs = require('fs')

const app = express()

const http = require('http');

const server = http.createServer(app);

const {exec} = require('child_process');

const { getHtml, getXorKeyByFileName } = require(path.join(__dirname, './xorFileContent'))

app.use(cors())

app.use(express.static(path.join(__dirname, '../dist')));

app.use(express.static(path.join(__dirname, '../images')));

app.use(express.static(path.join(__dirname, '../files')));

app.use(bodyParser.urlencoded({ extended: false }));

app.use(bodyParser.json());

const { category: categorySql  } = require(path.join(__dirname, './dataJson/category'))

const { slides: slidesSql } = require(path.join(__dirname, './dataJson/slides'))

const { idObject } = require(path.join(__dirname, '../id'))

app.get('/html', function(req, res) {
  res.setHeader('Content-Type', 'text/html');
  res.sendFile(path.join(__dirname, '../dist/index.html'))
})

app.get('/file', function(req, res) {

  const { id } = req.query
  const target = idObject.find(item =>item.catId == Number(id))
  
  console.log(target);
  res.setHeader('Content-Type', 'text/html');
  // res.send(getHtml(target.fileName))
  res.send(getHtml(target.fileName))

})

app.get('/devicesId', function(req, res ) {
  const id = getDevicesId()
  res.send({
    code: 200,
    data: id,
    msg: 'DevicesId'
  })
})

app.post('/login', async function (req, res) {
  const devicesId = req.body.devicesId
  const code = req.body.code

  
  const r = await  regeditKey(devicesId, code)
  console.log('r:', r == 1);
  
  res.send({
    code: 200,
    data: r,
    msg: r == 1 ? '激活成功' : '激活失败'
  })
})

app.post('/validate', async function(req, res ) {
  const r = await validate()
  res.send({
    code: 200,
    data: r,
    msg: r == 1 ? '校验通过' : '校验失败'
  })
})

app.get('/data/common/script.js', function(req, res) {
  const regex = /id=([^&]+)/;
  const match = req.headers.referer.match(regex);
  const target = idObject.find(item =>item.catId == Number(match[1]))
  let filename = target.fileName
  const strs =  [...fs.readFileSync(path.join(__dirname, '../files', filename, '/data/common/script.js'))]
  res.set('Content-Type', 'application/javascript');
  res.send(Buffer.from(strs))
})


app.get('/data/player/player.js', function(req, res) {
  const regex = /id=([^&]+)/;
  const match = req.headers.referer.match(regex);
  const target = idObject.find(item =>item.catId == Number(match[1]))
  let filename = target.fileName
  const strs =  [...fs.readFileSync(path.join(__dirname,`../files/${filename}/data/player/player.js`))]
  res.set('Content-Type', 'application/javascript');
  res.send(Buffer.from(strs))
})

app.get('/data/player/pre.gif', function(req, res) {
  const regex = /id=([^&]+)/;
  const match = req.headers.referer.match(regex);
  const target = idObject.find(item =>item.catId == Number(match[1]))
  let filename = target.fileName
  const strs =  [...fs.readFileSync(path.join(__dirname,`../files/${filename}/data/player/pre.gif`))]
  res.set('Content-Type', 'image/gif');
  res.send(Buffer.from(strs))
})

// :filename(png|mp3|mp4|jpg)
app.get('/data/pres/*', async function(req, res, next) {

  const regex = /id=([^&]+)/;
  const match = req.headers.referer.match(regex);

  const target = idObject.find(item =>item.catId == Number(match[1]))

  let filename = target.fileName

  if (req.path.includes('.js')) {
    const strs = fs.readFileSync(path.join(__dirname,`../files/${filename}${req.path}`))
    res.set('Content-Type', 'application/javascript');
    res.send(Buffer.from(strs))
    // next()
    return
  }


  if (req.path.includes('.css')) {
    const strs = fs.readFileSync(path.join(__dirname,`../files/${filename}${req.path}`))
    res.set('Content-Type', 'text/css');
    res.send(Buffer.from(strs))
    return
  }

  if (req.path.includes('.woff')) {
    try {
      const strs = fs.readFileSync(path.join(__dirname,`../files/${filename}${req.path}`))
      res.set('Content-Type', 'font/woff');
      res.send(Buffer.from(strs))
      return
    } catch (error) {
      return
    }
  

  }

  if (req.path.includes('.gif')) {
    const strs = fs.readFileSync(path.join(__dirname,`../files/${filename}${req.path}`))
    res.set('Content-Type', 'image/gif');
    res.send(Buffer.from(strs))
    return
  }
  
  // 字符数组
  const strs = fs.readFileSync(path.join(__dirname,`../files/${filename}${req.path}`))
  for (let i = 0; i < 100; i++) {
    strs[i] ^= getXorKeyByFileName(filename); // 异或操作
  }

  try {
    if (req.path.includes('.png')) {
      res.set('Content-Type', 'image/png');
      res.send(Buffer.from(strs))
    } else if (req.path.includes('.mp3')) {
      res.set('Content-Type', 'audio/mpeg');
      res.send(Buffer.from(strs))
    } else if (req.path.includes('.mp4')) {
      res.set('Content-Type', 'video/mp4');
      res.send(Buffer.from(strs))
    } else if (req.path.includes('.jpg')) {
      res.set('Content-Type', 'image/jpg');
      res.send(Buffer.from(strs))
    } else if (req.path.includes('.js')) {
      res.set('Content-Type', 'image/jpg');
      res.send(Buffer.from(strs))
    }
  } catch (error) {
      next()
  }
 
})

let port = ''

const baseUrl = () => 'http://localhost:' + port + '/'

// 以下为页面所需要的业务代码
app.get('/home/:catId', async function(req, res) {

  const { catId } = req.params

  const categorys = categorySql.filter(item => catId === item.parent_id)
  
  const result = categorys.map( category => {
    return {
      classLevelId: category.class_level_id,
      classLevelName: category.class_level_name,
      categoryDTOS: [
        {
          catId: category.cat_id,
          catLevel: category.cat_level,
          catName: category.cat_name,
          classLevelId: category.class_level_id,
          classLevelImg: null,
          classLevelName: category.class_level_name,
          createTime: category.create_time,
          description: category.description,
          imgUrl: baseUrl() + category.img_url,
          longImgUrl:baseUrl() + category.long_img_url,
          parentId: category.parent_id,
          slidesAmount: category.slidesAmount,
          categoryTreeDTO: categorySql.filter(item => item.parent_id === category.cat_id &&  category.cat_level !== '100000').map(_ => {
            return {
              catId: _.cat_id,
              catLevel: _.cat_level,
              catName: _.cat_name,
              classLevelId: _.class_level_id,
              classLevelImg: null,
              classLevelName: _.class_level_name,
              createTime: _.create_time,
              description: _.description,
              imgUrl: baseUrl() + _.img_url,
              longImgUrl:  baseUrl() +  _.long_img_url,
              parentId: _.parent_id,
              slidesAmount: _.slidesAmount,
            }
          })
        }
      ]
    }
  })

  res.send( {
    status: 200,
    data: result,
    msg: '获取成功'
  })
})


app.get('/category/queryCourse/list/:catId/:page/:pageSize', async function(req, res) {

  const {catId, page, pageSize} = req.params

  console.log('catId, page, pageSize:', catId, page, pageSize);

  const category = categorySql.find( item => item.cat_id === catId )

  const slidesList = slidesSql.filter( item => item.cat_id === catId && item.is_delete !== '1')

  const total = slidesList.length

  const result = {
    catId: category.catId,
    catLevel: category.cat_level,
    catName: category.cat_name,
    classLevelId: category.class_level_id,
    classLevelName: category.class_level_name,
    description: category.description,
    imgUrl:  baseUrl() +  category.img_url,
    parentId: category.parent_id,
    parentName: category.parentName,
    slidesDOPage: {
      currentPage: Number(page),
      pageSize: Number(pageSize),
      total: Number(total),
      entityList: slidesList.slice((page - 1) * pageSize, page * pageSize > total ? total % pageSize  + (page - 1) * pageSize :  page * pageSize).map(_ => {
        return {
          "slidesId": _.slides_id,
          "slidesName": _.slides_name,
          "slidesSize": null,
          "description": null,
          "createTime": null,
          "updateTime": null,
          "slidesUrl": null,
          "catId": _.cat_id,
          "classLevelId": null,
          "classLevelName": null,
          "emptyPos": null,
          "isDelete": null,
          "typeName": null,
          "sort": null,
          "article": null,
          "fileId": null,
          "fileVersionId": null,
          "videoUrl": null,
          "imgUrl": null
        }

      })
    }
  }

  res.send({
    status: 200,
    data: result,
    msg: '获取成功'
  })

})


app.get('/slides/queryInfo/7', function (req, res) {

  const result = {
    slidesUrl: getHtml
  }

  res.send({
    status: 200,
    data: result,
    msg: '获取成功'
  })

})


if (process.argv[2] === 'test') {
  async function createPort  ()  {
    const _port = await findAvailablePort(3000);  // 从3000端口开始查找空闲端口
    port = _port
    server.close()
    server.listen(port, () => {
      console.log('Server is running on port in ' + port);
    })
  }
  createPort()
  // let port = 13004
  // server.close()
  // server.listen(port, () => {
  //   console.log('Server is running on port in server/index.js  ' + port);
  // })
}

// 创建函数来关闭指定端口的进程
function closePort(port) {
  // 使用 netstat 查找占用端口的进程
  exec(`netstat -ano | findstr :${port}`, (error, stdout, stderr) => {
      if (error) {
          console.error(`执行错误: ${error}`);
          return;
      }

      if (!stdout) {
          console.log(`端口 ${port} 没有被占用`);
          return;
      }

      // 输出的最后一列是 PID
      const lines = stdout.trim().split('\n');
      lines.forEach(line => {
          const parts = line.trim().split(/\s+/);
          const pid = parts[parts.length - 1];
          console.log(`端口 ${port} 被 PID 为 ${pid} 的进程占用`);

          // 使用 taskkill 命令终止进程
          exec(`taskkill /F /PID ${pid}`, (error, stdout, stderr) => {
              if (error) {
                  console.error(`无法终止进程 PID: ${pid} - ${error}`);
                  return;
              }
              server.listen(port, () => {
                console.log('Server is running on port ' + port);
              })
              console.log(`成功终止进程 PID: ${pid}`);
          });
      });
  });
}


// 查找可用端口的函数
function findAvailablePort(startPort) {
  return new Promise((resolve, reject) => {
      const server = net.createServer();

      server.listen(startPort, () => {
          // 端口可用
          server.close(() => resolve(startPort));
      });

      server.on('error', (err) => {
          if (err.code === 'EADDRINUSE') {
              // 如果端口被占用，递归查找下一个端口
              resolve(findAvailablePort(startPort + 1));
          } else {
              reject(err);
          }
      });
  });
}


module.exports = {
  getRunPort: () => port,
  nodeServer: server,
  createPort: async (cb) => {
    const _port = await findAvailablePort(3000);  // 从3000端口开始查找空闲端口
    port = _port
    server.close()
    server.listen(port, () => {
      cb(port)
      console.log('Server is running on port in ' + port);
    })
  }
}