From def1eb8623e1444164ae4bce9179d011a89b8c5e Mon Sep 17 00:00:00 2001
From: 严智鑫 <test>
Date: 星期二, 03 十二月 2024 09:15:27 +0800
Subject: [PATCH] 现场对接批量更新
---
JiuMuMesParent/moduleService/DeviceInteractionModule/src/test/java/com/mes/DeviceInteractionModuleApplicationTest.java | 214 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 214 insertions(+), 0 deletions(-)
diff --git a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/test/java/com/mes/DeviceInteractionModuleApplicationTest.java b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/test/java/com/mes/DeviceInteractionModuleApplicationTest.java
index e57dd51..bbffdb6 100644
--- a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/test/java/com/mes/DeviceInteractionModuleApplicationTest.java
+++ b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/test/java/com/mes/DeviceInteractionModuleApplicationTest.java
@@ -1,15 +1,34 @@
package com.mes;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import com.mes.md.entity.*;
import com.mes.md.mapper.AccountMapper;
+import com.mes.md.mapper.KBBTJPDrawingBPMapper;
+import com.mes.md.mapper.MachineMapper;
+import com.mes.md.mapper.PrimitiveTaskMapper;
import com.mes.md.service.AccountService;
+import com.mes.md.service.PrimitiveTaskService;
+import com.mes.md.service.ProjectService;
+import com.mes.md.service.TaskingService;
import com.mes.tools.HexConversion;
+import com.mes.utils.HexUtil;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
+import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.Socket;
+import java.nio.charset.StandardCharsets;
+import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@@ -31,6 +50,117 @@
@Autowired
AccountService accountService;
+ @Autowired
+ KBBTJPDrawingBPMapper kBBTJPDrawingBPMapper;
+
+ @Autowired
+ PrimitiveTaskMapper primitiveTaskMapper;
+
+ @Autowired
+ PrimitiveTaskService primitiveTaskService;
+
+ @Autowired
+ TaskingService taskingService;
+
+
+ @Autowired
+ ProjectService projectService;
+
+ @Autowired
+ MachineMapper machineMapper;
+
+ @Test
+ public void testStr() {
+ String str=new String("4銆佸彂閫佷换鍔� 浠诲姟鏁版嵁锛歿}, ".getBytes(),StandardCharsets.UTF_8);
+ int a=1;
+ log.info(str,1);
+ }
+
+ @Test
+ public void testSaoMa3() {
+ try {
+// 鍒涘缓TCP瀹㈡埛绔苟杩炴帴鍒版湇鍔″櫒
+ String serverAddress = "192.168.1.8";
+ int serverPort = 2001;
+ Socket clientSocket = new Socket(serverAddress, serverPort);
+ // 鍒涘缓杈撳叆娴佸拰杈撳嚭娴�
+ InputStream inputStream = clientSocket.getInputStream();
+ OutputStream outputStream = clientSocket.getOutputStream();
+ // 鍙戦�佹暟鎹粰鏈嶅姟鍣�
+ String message = "start";
+ outputStream.write(message.getBytes());
+ // 璇诲彇鏈嶅姟鍣ㄥ搷搴旂殑鏁版嵁
+ byte[] buffer = new byte[1024];
+ int bytesRead = inputStream.read(buffer);
+ String receivedMessage = new String(buffer, 0, bytesRead);
+ System.out.println("鏀跺埌鏈嶅姟鍣ㄥ搷搴旓細" + receivedMessage);
+ // 鍏抽棴杩炴帴
+ clientSocket.close();
+ }catch (Exception e){
+ log.info("鎵爜寮傚父");
+ }
+ }
+
+ @Test
+ public void testSaoMa() {
+ try {
+// 鍒涘缓TCP瀹㈡埛绔苟杩炴帴鍒版湇鍔″櫒
+ String serverAddress = "192.168.1.8";
+ int serverPort = 2001;
+ Socket clientSocket = new Socket(serverAddress, serverPort);
+ // 鍒涘缓杈撳叆娴佸拰杈撳嚭娴�
+ InputStream inputStream = clientSocket.getInputStream();
+ OutputStream outputStream = clientSocket.getOutputStream();
+ // 鍙戦�佹暟鎹粰鏈嶅姟鍣�
+ String message = "start";
+ outputStream.write(message.getBytes());
+ // 璇诲彇鏈嶅姟鍣ㄥ搷搴旂殑鏁版嵁
+ byte[] buffer = new byte[1024];
+ int bytesRead = inputStream.read(buffer);
+ String receivedMessage = new String(buffer, 0, bytesRead);
+ System.out.println("鏀跺埌鏈嶅姟鍣ㄥ搷搴旓細" + receivedMessage);
+ // 鍙戦�佹暟鎹粰鏈嶅姟鍣�
+ String message2 = "stop";
+ outputStream.write(message2.getBytes());
+
+ // 鍏抽棴杩炴帴
+ clientSocket.close();
+ }catch (Exception e){
+ log.info("鎵爜寮傚父");
+ }
+ }
+ @Test
+ public void conncet(){
+ try {
+ int bufSizes = 0;
+ byte[] msgs = new byte[2048];
+ //鍒涘缓杩炴帴 172.17.125.200 192.168.10.101
+ Socket socket = new Socket("10.36.164.100", 1099);
+ try {
+ socket.setSoTimeout(3000);
+ //鍐欏叆闇�瑕佹暟鎹�
+ DataOutputStream outToServer = new DataOutputStream(socket.getOutputStream());
+ outToServer.write(HexUtil.stringToInt("000100000006010300000028"));
+ outToServer.flush();
+ //璇诲彇鏁版嵁
+ DataInputStream in = new DataInputStream(socket.getInputStream());
+ bufSizes = in.read(msgs);
+ String message = HexUtil.byteToHexString(bufSizes, msgs);
+ System.out.println(message);
+ } catch (Exception e) {
+ System.out.println("璇诲彇澶辫触");
+ try {
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//璁剧疆鏃ユ湡鏍煎紡
+ } catch (Exception e2) {
+ // TODO: handle exception
+
+ }
+ }
+ socket.close();
+ } catch (Exception e) {
+ System.out.println("寮傚父");
+ }
+ }
@Test
public void testFindPath() {
//String url = getClass().getResource("").getPath();
@@ -64,6 +194,90 @@
log.info("{}",Account);
}
+ //杩炴帴瀹㈡埛琛�
+ @Test
+ public void testInput() {
+ Machine machine=machineMapper.selectById(14);
+ taskingService.scanMachineAdd(machine, "46594135");
+ log.info("鍐呭{}",2);
+ }
+
+ //杩炴帴瀹㈡埛琛�
+ @Test
+ public void testSqlServerInput() {
+
+ boolean is=projectService.insertProjectStandard();
+
+
+ log.info("鍐呭{}",is);
+ }
+ //杩炴帴瀹㈡埛琛�
+ @Test
+ public void testMachineFinsh() {
+ Machine machine=machineMapper.selectById(14);
+ int a=taskingService.finishMachineTask(machine);
+ log.info("鍐呭{}",a);
+ }
+ //瀹氬埗鏌ユ壘浠诲姟
+ @Test
+ public void testSqlServer() {
+ Machine machine=machineMapper.selectById(26);
+ String scan_id="";
+ List<Tasking> taskingList=taskingService.findMachineTask(machine);
+ if(!taskingList.isEmpty()){
+ Tasking tasking=taskingList.get(0);
+ if (scan_id.equals(tasking.getScanId())){
+
+ }else{
+ List<Tasking> isExist=taskingService.findMachineTaskID(machine,scan_id);
+ if(isExist.isEmpty()){
+ //璇诲彇瀹㈡埛鏁版嵁搴�
+ projectService.insertProjectCustomization(scan_id);
+ }
+ }
+ }
+// insertProjectCustomization();
+ log.info("鍐呭{}",taskingList);
+ }
+
+ //瀹氬埗鏌ユ壘浠诲姟
+ @Test
+ public void testSqlServeraa() {
+ Machine machine=machineMapper.selectById(12);
+ String scan_id="46399819";
+ projectService.insertProjectCustomization(scan_id);
+ log.info("鍐呭{}",machine);
+ }
+ //淇敼瀹㈡埛琛�
+ @Test
+ public void testSqlServerUpdate() {
+ UpdateWrapper updateWrapper=new UpdateWrapper();
+ KBBTJPDrawingBP kBBTJPDrawingBPs=new KBBTJPDrawingBP();
+ kBBTJPDrawingBPMapper.update(kBBTJPDrawingBPs,updateWrapper);
+ List<KBBTJPDrawingBP> kBBTJPDrawingBP=kBBTJPDrawingBPMapper.selectJoinList(KBBTJPDrawingBP.class,new MPJLambdaWrapper<KBBTJPDrawingBP>()
+ .selectAll(KBBTJPDrawingBP.class)
+ .eq(KBBTJPDrawingBP::getScanId,"011045108661010000")
+ .orderByAsc(KBBTJPDrawingBP::getCreateDate)
+ .orderByAsc(KBBTJPDrawingBP::getTaskSequence));
+ kBBTJPDrawingBP.get(0).setIsWorking(1);
+ kBBTJPDrawingBPMapper.updateById(kBBTJPDrawingBP.get(0));
+ //kBBTJPDrawingBPMapper.update(kBBTJPDrawingBP,new QueryWrapper<>());
+// log.info("鍐呭{}",KBBTJPDrawingBP);
+ }
+
+ //淇敼瀹㈡埛琛�
+ @Test
+ public void testSqlServerUpdate2() {
+ UpdateWrapper<KBBTJPDrawingBP> updateWrapper=new UpdateWrapper<KBBTJPDrawingBP>();
+ updateWrapper.lambda().eq(KBBTJPDrawingBP::getScanId,"011045108661010000");
+
+ KBBTJPDrawingBP kBBTJPDrawingBPs=new KBBTJPDrawingBP();
+ kBBTJPDrawingBPs.setIsWorking(2);
+ kBBTJPDrawingBPMapper.update(kBBTJPDrawingBPs,updateWrapper);
+
+// log.info("鍐呭{}",KBBTJPDrawingBP);
+ }
+
}
--
Gitblit v1.8.0