first-add1

吴健

3 天以前 fe3cf2ddd9596ee7f20faa8809b3e8b751b37584

first-add1

 billion-main/src/main/java/com/billion/main/tcp/TcpClient.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,134 @@
//package com.billion.main.tcp;
//
//import cn.hutool.core.collection.CollUtil;
//import cn.hutool.core.util.ObjUtil;
//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
//import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
//import com.billion.main.da.domain.DaStationCollection;
//import com.billion.main.da.service.impl.DaStationCollectionServiceImpl;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.scheduling.annotation.Async;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.PostConstruct;
//import javax.annotation.Resource;
//import java.io.IOException;
//import java.io.InputStream;
//import java.io.OutputStream;
//import java.net.InetAddress;
//import java.net.ServerSocket;
//import java.net.Socket;
//import java.net.UnknownHostException;
//import java.util.Arrays;
//import java.util.List;
//import java.nio.charset.StandardCharsets;
//
///**
// * ç®€ä»‹è¯´æ˜Ž:TCP连接
// *
// * @author: Eric
// * @date: 2025-03-29 13:29:01
// * @version: 1.0
// */
//@Slf4j
//@Component
//public class TcpClient {
//
//    private Socket socket;
//    private InputStream input;
//    private OutputStream output;
//
//    @Value("${tcp.server.ip}")
//    private String serverIp;
//
//    @Value("${tcp.server.port}")
//    private int serverPort;
//
//    @Resource
//    private DaStationCollectionServiceImpl daStationCollectionService;
//
//    @PostConstruct
//    public void init() throws UnknownHostException {
//
//        try {
//            log.info("开始建立连接");
//            // å»ºç«‹ TCP è¿žæŽ¥
//            socket = new Socket(serverIp, serverPort);
//            int localPort = socket.getLocalPort();
//            InetAddress localAddress = socket.getLocalAddress();
//            log.info("localPort",localPort);
//            log.info("localAddress",localAddress);
//            int port = socket.getPort();
//            log.info("port:",port);
//            input = socket.getInputStream();
//            output = socket.getOutputStream();
//            log.info("input:",input);
//            log.info("output:",output);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//    }
//
//    // å‘送数据到下位机
//    public void sendData(byte[] data) throws IOException {
//        output.write(data);
//        output.flush();
//    }
//
//    // æŽ¥æ”¶ä¸‹ä½æœºæ•°æ®ï¼ˆæŒç»­ç›‘听）
//    @Async
//    public void receiveData() {
//        log.info("接收数据循环");
//        byte[] buffer = new byte[1024];
//        if (ObjUtil.isNotNull(socket)){
//            while (!socket.isClosed()) {
//                try {
//                    log.info("开始接收数据");
//                    int len = input.read(buffer);
//                    if (len > 0) {
//                        byte[] received = Arrays.copyOf(buffer, len);
//                        String str = new String(received, "UTF-8");
//                        System.out.println(str);
//                        log.info("接收到数据：",str);
////                    processData(received); // å¤„理数据
//                        List<DaStationCollection> collect = daStationCollectionService.list(new LambdaQueryWrapper<DaStationCollection>()
//                                .eq(DaStationCollection::getStatus, "0"));
//                        if (CollUtil.isNotEmpty(collect)) {
//                            DaStationCollection daStationCollection = collect.get(0);
//                            String sfcCode = daStationCollection.getSfcCode();
//                            TcpClient tcpClient = new TcpClient();
//                            byte[] bytes = sfcCode.getBytes(StandardCharsets.UTF_8);
//                            tcpClient.sendData(bytes);
//                            log.info("发送数据：",sfcCode);
//                            log.info("发送数据-byte：",bytes);
//                            //清除
//                            daStationCollectionService.update(new LambdaUpdateWrapper<DaStationCollection>()
//                                    .eq(DaStationCollection::getSfcCode,sfcCode)
//                                    .set(DaStationCollection::getStatus,"1"));
//                        }
//                    }
//                } catch (IOException e) {
//                    e.printStackTrace();
//                    closeConnection();
//                }
//            }
//        }
//
//    }
//
////    private void processData(byte[] data) {
////        // è§£æžæ•°æ®ï¼ˆå¦‚ Modbus TCP åè®®ï¼‰
////        System.out.println("Received: " + HexUtils.bytesToHex(data));
////    }
//
//    public void closeConnection() {
//        try {
//            input.close();
//            output.close();
//            socket.close();
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//    }
//}

 billion-ui/src/assets/logo/logo.png