huishou/update-user.mjs

import { Client } from 'ssh2';
import fs from 'fs';

const conn = new Client();

conn.on('ready', () => {
  console.log('=== 修改宁赜的角色 ===');
  
  conn.exec('cat /www/huishou/server/data/users.json', (err, stream) => {
    if (err) { console.log('ERR:', err); conn.end(); return; }
    let users = '';
    stream.on('data', (d) => users += d.toString());
    stream.on('close', () => {
      const usersData = JSON.parse(users);
      const user = usersData.find(u => u.name === '宁赜');
      if (user) {
        user.role = 'collector';
        
        const newData = JSON.stringify(usersData, null, 2);
        
        conn.sftp((err, sftp) => {
          if (err) { console.log('SFTP ERR:', err); conn.end(); return; }
          
          const writeStream = sftp.createWriteStream('/www/huishou/server/data/users.json');
          writeStream.on('close', () => {
            console.log('用户数据更新完成');
            conn.end();
          });
          writeStream.write(newData);
          writeStream.end();
        });
      } else {
        console.log('未找到宁赜');
        conn.end();
      }
    });
  });
});

conn.on('error', (err) => {
  console.log('连接错误:', err.message);
});

conn.connect({ host: 'hs.yifenbao.cn', port: 22, username: 'root', password: 'Torch1112' });