提交武汉军粮分支

CZT

2023-09-06 71c4fa1e27f75ae4b765c95c67a3069c84dc72ba

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
package com.ld.igds.protocol.quantity.shuhan.command;
 
import com.alibaba.fastjson.JSON;
import com.ld.igds.io.request.QuantityRequest;
import com.ld.igds.protocol.quantity.shuhan.ShuHanUtils;
 
/**
 * @author vince.xu
 * @Title: CommandBuilder
 * @ProjectName igds-grain-platform
 * @Description:
 * @date 2021/6/30 003015:10
 */
public class CommandBuilder {
    public static String CHECK_URL = "http://#ipport/cgi-bin/laser_meter.lua?start=1&pan_step=3&tilt_seq=-3,-6,-8,-10,-12,-14,-16,-18,-20,-22,-24,-26,-28,-31,-34,-37,-41,-45,-50,-55,-60,-65,-70,-80,-90&delay_ms=1000&meter_ms=100&sweep=1";
    public static String QUERY_STATUS_URL = "http://#ipport/tmp/measure_state.json";
    public static String RESULT_URL = "http://#ipport/cgibin/masureStart?&length1=#length1&length2=#length2&length3=#length3&length4=#length4&height=#height&lineHeight=#lineHeight&density=#density&yip=#yip";
    //获取检测命令
    public static  String getCheckMsg(QuantityRequest request){
        Message message = new Message();
        message.setFunctionId("1");
        message.setOrderId("1");
        message.setSn(request.getYtIp());
        MessageContent content= new MessageContent();
        String url = new String(CHECK_URL);
        content.setUrl(url.replaceAll("#ipport",request.getYtIp()+":" + request.getYtPort()));
        message.setContent(content);
        return ShuHanUtils.MSG_START + JSON.toJSONString(message) + ShuHanUtils.MSG_END;
    }
 
    /**
     * 查询状态命令
     * @param request
     * @return
     */
    public static  String getQueryStatusMsg(QuantityRequest request){
        Message message = new Message();
        message.setFunctionId("2");
        message.setOrderId("1");
        message.setSn(request.getYtIp());
        MessageContent content= new MessageContent();
        String url = new String(QUERY_STATUS_URL);
        content.setUrl(url.replaceAll("#ipport",request.getYtIp()+":" + request.getYtPort()));
        message.setContent(content);
        return ShuHanUtils.MSG_START + JSON.toJSONString(message) + ShuHanUtils.MSG_END;
    }
 
 
    /**
     * 获取结果命令
     *     public static String RESULT_URL = "http://#ipport/cgibin/masureStart?&length1=#length1&length2=#length2&length3=#length3&length4=#length4&height=#height&lineHeight=#lineHeight&density=#density&yip=#yip";
     * @param request
     * @return
     */
    public static String getResultMsg(QuantityRequest request){
        Message message = new Message();
        message.setFunctionId("3");
        message.setOrderId("1");
        message.setSn(request.getYtIp());
        MessageContent content= new MessageContent();
        String url = new String(RESULT_URL);
        url = url.replaceAll("#ipport","127.0.0.1:" + 80);
        url = url.replaceAll("#length1",request.getLength1() + "");
        url = url.replaceAll("#length2",request.getLength2() + "");
        url = url.replaceAll("#length3",request.getLength3() + "");
        url =  url.replaceAll("#length4",request.getLength4() + "");
        url =  url.replaceAll("#height",request.getHeight() + "");
        url =  url.replaceAll("#lineHeight",request.getLineHeight() + "");
        url = url.replaceAll("#density",request.getDensity() + "");
        url = url.replaceAll("#yip",request.getYtIp() + "");
        content.setUrl(url);
        message.setContent(content);
        return ShuHanUtils.MSG_START + JSON.toJSONString(message) + ShuHanUtils.MSG_END;
    }
}