dev 契约锁

P15GEN2\59518

2024-05-29 d4210c7c4b04abde20037ea8aa0f54ef8a2649aa

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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
package foundation.icall.callout;
 
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.util.Set;
 
import foundation.dao.bizlogic.DocDescription;
import foundation.dao.bizlogic.IRequest;
import foundation.util.ContentBuilder;
import foundation.util.MapList;
import okhttp3.FormBody;
import okhttp3.MediaType;
import okhttp3.Request.Builder;
import okhttp3.RequestBody;
 
public class ICallRequest implements IRequest {
 
    private String url;
    private MapList<String, String> params;
    private MapList<String, String> headers;
    private MapList<String, String> formBody;
    private JSONResponse jsonBody;
    private DocDescription docDescription;
    
    public ICallRequest(String url) {
        this.url = url;
        params = new MapList<String, String>(false);
        headers = new MapList<String, String>(false);
        formBody = new MapList<String, String>(false);
    }
 
    public String paramsToURL() throws UnsupportedEncodingException {
        if (params.isEmpty()) {
            return "";
        }
        
        ContentBuilder builder = new ContentBuilder("&");
        Set<String> keySet = params.getKeySet();
        
        for (String key: keySet) {
            String name = URLEncoder.encode(key, "utf-8");
            
            String value = params.get(key);
            if (value == null) {
                continue;
            }
            
            value = URLEncoder.encode(value, "utf-8");
            builder.append(name, value);
        }
        
        return builder.toString();
    }
    
    public void applyHeaders(Builder builder) {
        Set<String> keySet = headers.getKeySet();
        
        for (String key: keySet) {
            String value = headers.get(key);
            
            if (value == null) {
                continue;
            }
            
            builder.addHeader(key, value);
        }
    }
 
    public void applyJSONBody(Builder builder) {
        MediaType contentType = MediaType.parse("application/json;charset=utf-8");
        RequestBody body = RequestBody.create(contentType, jsonBody.toString());
        builder.post(body);
    }
 
    public void applyFormBody(Builder builder) throws UnsupportedEncodingException {
        Charset charset = Charset.forName("UTF-8");
        FormBody.Builder formBuilder = new FormBody.Builder(charset);
        
        Set<String> keySet = formBody.getKeySet();
        
        for (String key: keySet) {
            String value = formBody.get(key);
            formBuilder.add(key, value);
        }
        
        FormBody result = formBuilder.build();
        builder.post(result);
    }
    
    public void addHeader(String name, String value) {
        headers.add(name, value);
    }
    
    public void addFormData(String name, String value) {
        formBody.add(name, value);
    }
    
    @Override
    public String getURL() {
        return url;
    }
 
    public void setURL(String url) {
        this.url = url;
    }
 
    @Override
    public DocDescription getDocDescription() {
        return docDescription;
    }
 
    @Override
    public void setDocDescription(DocDescription docDesciption) {
        this.docDescription = docDesciption;
    }
 
    public boolean existsHeaders() {
        return !headers.isEmpty();
    }
 
    public boolean existsJSONBody() {
        return jsonBody != null;
    }
 
    public boolean existsFormBody() {
        return formBody != null;
    }
 
    public void addOneParam(String key, String value) {
        params.add(key, value);
    }
    
    @Override
    public String getRequestHeader() {
        return headers.mapToString(",");
    }
    
    @Override
    public String getRequestBody() {
        return formBody.mapToString(",");
    }
 
    @Override
    public String getBody() {
        ContentBuilder json = new ContentBuilder(",");
        json.append("\"url\":\"" + url + "\"");
        
        json.append("\"params\":" + params.mapToString(","));
        json.append("\"headers\":" + headers.mapToString(","));
        json.append("\"formBody\":" + formBody.mapToString(","));
        
        return json.toString();
    }
}