在NestJS中使用node-snap7库实现S7 PLC地址块读取和写入

首先需要在NestJS项目中安装node-snap7库，可以使用以下命令：

npm install node-snap7

然后在需要使用PLC读写的服务中引入该库：

import { Injectable } from '@nestjs/common';
import * as snap7 from 'node-snap7';

@Injectable()
export class PlcService {
  private client: snap7.S7Client;

  constructor() {
    this.client = new snap7.S7Client();
  }

  async connect(ipAddress: string, rack: number, slot: number): Promise<void> {
    return new Promise<void>((resolve, reject) => {
      this.client.connect(
        ipAddress,
        rack,
        slot,
        (err) => {
          if (err) {
            reject(err);
          } else {
            resolve();
          }
        },
      );
    });
  }

  async readBytes(dbNumber: number, start: number, length: number): Promise<Buffer> {
    return new Promise<Buffer>((resolve, reject) => {
      const buffer = Buffer.alloc(length);
      this.client.readArea(
        snap7.S7AreaDB,
        dbNumber,
        start,
        length,
        snap7.S7Word,
        (err, data) => {
          if (err) {
            reject(err);
          } else {
            resolve(data);
          }
        },
      );
    });
  }

  async writeBytes(dbNumber: number, start: number, buffer: Buffer): Promise<void> {
    return new Promise<void>((resolve, reject) => {
      this.client.writeArea(
        snap7.S7AreaDB,
        dbNumber,
        start,
        buffer.length,
        snap7.S7Word,
        buffer,
        (err) => {
          if (err) {
            reject(err);
          } else {
            resolve();
          }
        },
      );
    });
  }
}

在上述代码中，我们定义了一个PlcService服务，该服务中包含了连接PLC、读取PLC地址块和写入PLC地址块等方法。在connect方法中，我们使用node-snap7库中的S7Client类连接PLC。在readBytes方法中，我们使用readArea方法读取PLC地址块的数据。在writeBytes方法中，我们使用writeArea方法向PLC地址块写入数据。

在使用该服务时，需要先调用connect方法连接PLC，连接成功后即可使用readBytes和writeBytes方法读取和写入PLC地址块的数据。

import { Controller, Get, Post, Body } from '@nestjs/common';
import { PlcService } from './plc.service';

@Controller('plc')
export class PlcController {
  constructor(private readonly plcService: PlcService) {}

  @Post('connect')
  async connect(@Body() body: { ipAddress: string; rack: number; slot: number }): Promise<void> {
    await this.plcService.connect(body.ipAddress, body.rack, body.slot);
  }

  @Get('read')
  async read(): Promise<Buffer> {
    return this.plcService.readBytes(1, 0, 10);
  }

  @Post('write')
  async write(@Body() body: { data: string }): Promise<void> {
    const buffer = Buffer.from(body.data, 'hex');
    await this.plcService.writeBytes(1, 0, buffer);
  }
}

在上述代码中，我们定义了一个PlcController控制器，该控制器中包含了连接PLC、读取PLC地址块和写入PLC地址块等接口。在connect接口中，我们接收客户端传递过来的PLC的IP地址、机架号和插槽号，然后调用plcService中的connect方法连接PLC。在read接口中，我们调用readBytes方法读取PLC地址块的数据，并将数据返回给客户端。在write接口中，我们接收客户端传递过来的数据，然后将数据转换为Buffer类型，并调用writeBytes方法向PLC地址块写入数据。

需要注意的是，以上代码仅是示例代码，实际应用中需要根据具体的PLC型号和地址块设置调用相应的读写方法。