package com.mes;
|
|
import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
|
import com.github.xingshuangs.iot.protocol.s7.service.S7PLC;
|
import com.mes.common.JsonConversion;
|
import com.mes.common.ReadFile;
|
import com.mes.connect.IndustrialInterface.Api;
|
import com.mes.connect.IndustrialInterface.IndustrialClient;
|
import com.mes.connect.Thread.MachineThread;
|
import com.mes.connect.entity.LogicConfig;
|
import com.mes.connect.entity.PlcParameters;
|
import com.mes.connect.s7.S7Client;
|
import com.mes.connect.s7.S7ClientOld;
|
import lombok.extern.slf4j.Slf4j;
|
import org.junit.Test;
|
import org.junit.runner.RunWith;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.test.context.SpringBootTest;
|
import org.springframework.test.context.ActiveProfiles;
|
import org.springframework.test.context.junit4.SpringRunner;
|
|
import javax.annotation.Resource;
|
import java.io.IOException;
|
import java.sql.Types;
|
import java.util.*;
|
|
/**
|
* @Author : yanzhixin
|
* @Date: 2024/3/27 16:37
|
* @Description:
|
*/
|
@Slf4j
|
@RunWith(SpringRunner.class)
|
@SpringBootTest(classes = plcConnectModuleApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
public class plcConnectModuleApplicationTest {
|
|
@Autowired
|
Api api;
|
|
@Test
|
public void testb() {
|
//byte[] resultValues=new byte[]{99, 23, 67, 76, 45, 49, 48, 45, 56, 48, 47, 55, 48, 67, 76, 45, 51, 45, 55, 51};
|
String s="白玻";
|
log.info(s);
|
}
|
@Test
|
public void testReadJson() {
|
try {
|
LogicConfig logicConfig=JsonConversion.jsonToObjectByJackson(ReadFile.readJson("shelfLogic.json").toString(), LogicConfig.class);
|
PlcParameters plcParameters=JsonConversion.jsonToObjectByJackson(ReadFile.readJson("shelf.json").toString(), PlcParameters.class);
|
log.info("{},{}",logicConfig,plcParameters);
|
}catch (Exception e) {
|
|
}
|
}
|
@Test
|
public void testReadS7Old() throws IOException {
|
S7PLC s7PLC = new S7PLC(EPlcType.S1500, "10.153.19.191", 102, 0, 0);
|
s7PLC.connect();
|
int value= s7PLC.readUInt16("DB8.6");
|
log.info("{},{}",value,s7PLC.checkConnected());
|
s7PLC.close();
|
}
|
@Test
|
public void testReadS7OldClient() throws IOException {
|
IndustrialClient client = new S7ClientOld("S1500","10.153.19.191", 102, 0, 1);
|
client.connect();
|
int value=client.readRegister("S7.DB8.DBW6");
|
log.info("{}",value);
|
client.disconnect();
|
}
|
@Test
|
public void testReadS7() throws IOException {
|
IndustrialClient client=new S7Client("10.153.19.42", 102, 0, 1);;
|
client.connect();
|
// 连接到 PLC
|
System.out.println("成功连接到 PLC");
|
|
// // 读取单个位
|
// boolean bitValue = client.readBit("S7.DB1.0");
|
// System.out.println("DB1.DBX0.0 的值: " + bitValue);
|
//
|
// // 写入单个位
|
// client.writeBit("DB1.DBX0.1", true);
|
// System.out.println("已将 DB1.DBX0.1 设置为 true");
|
|
// 读取单个寄存器 (Word)
|
int registerValue = client.readRegister("DB1.DBW2");
|
System.out.println("DB1.DBW2 的值: " + registerValue);
|
//
|
// // 写入单个寄存器
|
// client.writeRegister("DB1.DBW4", 12345);
|
// System.out.println("已将 DB1.DBW4 设置为 12345");
|
//
|
// // 读取多个寄存器
|
// int[] registers = client.readRegisters("DB1.DBW6", 3);
|
// System.out.println("DB1.DBW6-DB1.DBW11 的值: " +
|
// registers[0] + ", " +
|
// registers[1] + ", " +
|
// registers[2]);
|
//
|
// // 写入多个寄存器
|
// int[] values = {6789, 101112, 131415};
|
// client.writeRegisters("DB1.DBW12", values);
|
// System.out.println("已写入多个寄存器值");
|
//
|
// // 读取浮点数
|
// float floatValue = client.readFloat("DB1.DBD18");
|
// System.out.println("DB1.DBD18 的浮点值: " + floatValue);
|
//
|
// // 写入浮点数
|
// client.writeFloat("DB1.DBD22", 3.14159f);
|
// System.out.println("已将 DB1.DBD22 设置为 3.14159");
|
//
|
// // 读取字符串
|
// String stringValue = client.readString("DB1.DBW26", 10);
|
// System.out.println("DB1.DBW26 开始的字符串: " + stringValue);
|
//
|
// // 写入字符串
|
// client.writeString("DB1.DBW36", "Hello PLC");
|
// System.out.println("已写入字符串 'Hello PLC'");
|
}
|
@Test
|
public void testApi() {
|
//Http接口测试
|
// Map<String, Object> data=new HashMap<>();
|
// data.put("method","POST");
|
// String resultHttp[]= api.httpApi("http://localhost:8082/account/testApi",data);
|
// log.info("{}",resultHttp);
|
|
// 查询带单个参数的视图
|
// Map<String, Object> params = new HashMap<>();
|
// params.put("width", 699); // 参数名与SQL中的列名一致
|
// String resultView[]= api.viewApi("procedurename",null);
|
// log.info("{}",resultView);
|
|
// 示例 调用testProcedure存储过程
|
// Map<String, Object> params = new HashMap<>();
|
// params.put("dataParmars", "测试数据"); // 输入参数，对应存储过程中的IN参数
|
// Map<String, Object> outParams = new HashMap<>();
|
// outParams.put("messagedate", Types.VARCHAR); // 输出参数，对应存储过程中的OUT参数
|
// String[] resultProcedure = api.procedureAPI("testProcedure", params, outParams);
|
// // 打印执行结果
|
// log.info("{}存储过程执行结果:{}",params,resultProcedure);
|
}
|
@Test
|
public void testMainThread() {
|
Thread thread = new Thread(() -> {
|
while (true) {
|
log.info(new Date().toString());
|
}
|
|
});
|
thread.start();
|
}
|
@Test
|
public void testMain() {
|
|
}
|
|
}
|
