JiuMuMES.git - Gitblit

			@@ -1,15 +1,32 @@
			package com.mes;

			import com.mes.md.mapper.AccountMapper;
			import com.mes.md.service.AccountService;
			import cn.hutool.core.bean.BeanUtil;
			import cn.smallbun.screw.core.util.CollectionUtils;
			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.*;
			import com.mes.md.service.*;
			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.util.Map;
			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.*;
			import java.util.stream.Collectors;

			/**
			* @Author : yanzhixin
			@@ -27,12 +44,211 @@
			@Autowired
			AccountService accountService;

			@Autowired
			KBBTJPDrawingBPMapper kBBTJPDrawingBPMapper;

			@Autowired
			PrimitiveTaskMapper primitiveTaskMapper;

			@Autowired
			PrimitiveTaskService primitiveTaskService;

			@Autowired
			TaskingService taskingService;


			@Autowired
			ProjectService projectService;

			@Autowired
			MachineMapper machineMapper;

			@Autowired
			TaskingMapper taskingMapper;

			@Autowired
			KBBTLensSortingMapper kBBTLensSortingMapper;

			@Autowired
			KBBTProgramsOperationLogBPMapper kBBTProgramsOperationLogBPMapper;

			@Autowired
			KBBTProgramsOperationLogBPService kBBTProgramsOperationLogBPService;

			@Autowired
			TaskingLogMapper taskingLogMapper;

			@Autowired
			TaskingLogService taskingLogService;
			/**
			* 测试提交报工以及玻璃数据
			*/
			@Test
			public void reportTaskingLog() {
			taskingLogService.reportTaskingLog();
			}
			/**
			* 测试扫码后库位
			*/
			@Test
			public void testInset() {

			// 从数据库中查询出的对象集合
			List<Tasking> listTasking = taskingMapper.selectList(new QueryWrapper<Tasking>());
			List<KBBTProgramsOperationLogBP> abc =kBBTProgramsOperationLogBPMapper.selectList(new QueryWrapper<KBBTProgramsOperationLogBP>());
			// 判端是否为空
			if (CollectionUtils.isNotEmpty(listTasking)) {
			// 进行拆解封装
			List<KBBTProgramsOperationLogBP> stationDictVOS = listTasking.stream().map(item -> {
			KBBTProgramsOperationLogBP newData = new KBBTProgramsOperationLogBP();
			newData.setGlassId(item.getGlassId());
			newData.setState(item.getState());
			newData.setWorkState(item.getWorkState());
			newData.setGlassState(item.getGlassState());
			newData.setState(item.getState());
			newData.setScanId(item.getScanId());
			newData.setProgramId(item.getProgramId());
			newData.setBatchNumber(item.getBatchNumber()==null?"":item.getBatchNumber());
			newData.setTaskType(item.getTaskType());
			newData.setLength(item.getLength());
			newData.setWidth(item.getWidth());
			newData.setThickness(item.getThickness());
			newData.setDrawingMarking(item.getDrawingMarking());
			//newData.setIsMarking(item.getIsMarking());//是否打标：0不打标 1打标
			newData.setIsSilkScreen(item.getIsSilkScreen());
			newData.setIsWorking(1);
			newData.setSilkScreenX(item.getSilkScreenX());
			newData.setSilkScreenY(item.getSilkScreenY());
			newData.setR_1_1(item.getR_1_1());
			newData.setR_1_2(item.getR_1_2());
			newData.setR_2_1(item.getR_2_1());
			newData.setR_2_2(item.getR_2_2());
			newData.setR_3_1(item.getR_3_1());
			newData.setR_3_2(item.getR_3_2());
			newData.setR_4_1(item.getR_4_1());
			newData.setR_4_2(item.getR_4_2());
			newData.setCreateDate(new Date());
			kBBTProgramsOperationLogBPMapper.insert(newData);
			return newData;
			}).collect(Collectors.toList());
			log.info("保存数据是否成功：{},{}",stationDictVOS);
			}

			}

			/**
			* 测试扫码后库位
			*/
			@Test
			public void testStr() {
			//创建Calendar实例
			Calendar cal = Calendar.getInstance();
			//设置当前时间
			cal.setTime(new Date());
			cal.add(Calendar.DATE, -3);
			int deleteCount=taskingMapper.deleteJoin(new MPJLambdaWrapper<Tasking>()
			.selectAll(Tasking.class)
			.le(Tasking::getOperationRecordTime,cal.getTime()));

			log.info("{},删除数据:{}",cal.getTime(),deleteCount);
			}

			@Test
			public void testSaoMa3() {
			int deleteCount=taskingMapper.deleteJoin(new MPJLambdaWrapper<Tasking>()
			.selectAll(Tasking.class)
			.innerJoin(LineConfiguration.class,LineConfiguration::getId,Tasking::getLineConfigurationId)
			.innerJoin(Machine.class,Machine::getId,LineConfiguration::getMachineId)
			.eq(LineConfiguration::getMachineId,24L)
			.eq(Tasking::getGlassState,"正常")
			.eq(Tasking::getState,"线上")
			.ne(Tasking::getWorkState,"完工"));
			log.info("{}",deleteCount);
			}

			@Test
			public void testSaoMa() {
			try {
			// 创建TCP客户端并连接到服务器
			String serverAddress = "10.36.164.19";
			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();
			//log.info("完整路径：{}", Arrays.asList(url));

			log.info("完整路径");
			}
			@Test
			public void testByte() {
			//String url = getClass().getResource("").getPath();
			//log.info("完整路径：{}", Arrays.asList(url));
			byte[] msgs = new byte[2048];
			msgs[0]=(byte)0;
			msgs[1]=Byte.parseByte("1") ;
			int g=HexConversion.bytesToInt(msgs,0);

			String message = HexConversion.byteToHexString(4, msgs);
			byte font=msgs[1];
			String[] fontBit=String.format("%8s", Integer.toBinaryString((int)font)).replace(" ", "0").split("");
			byte[] bit=new byte[1];
			bit[0]=Byte.parseByte(fontBit[7]) ;
			log.info("结果:{},{}",fontBit,bit);
			//log.info("结果:{},{},{},{},{}",msgs,message,g,(msgs[0] & 0xFF),((msgs[1] & 0xFF)<<8));
			}
			@Test
			public void testFindAccount() {
			@@ -43,4 +259,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);
			}



			}