Blame view

src/main/java/com/huaheng/api/Weighing/controller/UDPClient.java 2 KB
xumiao authored
1
2
package com.huaheng.api.Weighing.controller;
周鸿 authored
3
import com.huaheng.api.Weighing.server.UDPServer;
xumiao authored
4
5
6
7
8
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.shipment.kuaidiHeader.domain.KuaidiHeader;
import com.huaheng.pc.shipment.kuaidiHeader.service.KuaidiHeaderService;
import com.huaheng.pc.shipment.shipmentHeader.domain.ShipmentHeader;
周鸿 authored
9
10
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
xumiao authored
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
import org.springframework.integration.ip.udp.UnicastSendingMessageHandler;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.io.IOException;

/**
 * @ClassName UDPClient
 * @Description TODO
 * @Author Administrator
 * @Date 2020/12/215:08
 */
@RestController
@RequestMapping("/api/UDPClient")
public class UDPClient {
周鸿 authored
28
29
30
    private static final Logger
            logger = LoggerFactory.getLogger(UDPClient.class);
xumiao authored
31
32
33
34
35
36
37
    @Resource
    private KuaidiHeaderService kuaidiHeaderService;

    @PostMapping("/haha")
    @ResponseBody
    public void ICSComputationUnit() throws IOException {
        String message ="776006167051546,0.71";
周鸿 authored
38
        UnicastSendingMessageHandler unicastSendingMessageHandler = new UnicastSendingMessageHandler("172.16.2.10", 8900);
周鸿 authored
39
//        UnicastSendingMessageHandler  unicastSendingMessageHandler = new UnicastSendingMessageHandler("172.16.29.88", 8800);
周鸿 authored
40
        logger.info("发送UDP: {}"+ message);
xumiao authored
41
        unicastSendingMessageHandler.handleMessage(MessageBuilder.withPayload(message).build());
周鸿 authored
42
        logger.info("发送成功");
xumiao authored
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
    }


    @PostMapping("/test")
    @ResponseBody
    public AjaxResult test(@RequestBody ShipmentHeader shipmentHeader) throws IOException {
        KuaidiHeader kuaidiHeader = new KuaidiHeader();
        kuaidiHeader.setOrderBill("AA2021");
        kuaidiHeader.setFromCode("AA2021");

        kuaidiHeader.setCreated(shipmentHeader.getCreated());
        kuaidiHeaderService.saveU8Kuaidi(kuaidiHeader);
        return AjaxResult.success("成功");
    }
}