项目提交

zj

2025-01-06 0e7b38c2b3af72ea2a7f8a2fcbaad4d78e2c1977

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.gear.swx.utils;
 
import com.gear.swx.vo.SyncCurrentValueFromLdVo;
 
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.math.BigDecimal;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;
 
public class HttpGetCsvUtils {
 
 
    public static List<SyncCurrentValueFromLdVo> getCurrentValueFromLdVo(String code, String ip){
        try {
            String urlStr = "http://"+ip+"/exchange_curr.action?username=673468708&password=8a1576001bea15a3e5906ba3af004392&id="+code+"&column=mc,zf,price,zdf";
            // 创建 URL 对象
            URL url = new URL(urlStr);
 
            // 创建 HTTP 连接
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
            connection.setRequestMethod("GET");
 
            // 获取输入流
            BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
 
            String firstLine = reader.readLine();
            System.out.println(firstLine);
            String[] clomns = firstLine.split(",");
            Integer codePostion = 0;
            Integer namePosition = 1;
            Integer pricePosition = 2;
            Integer zdfPosition = 3;
            for(int i = 0; i < clomns.length; i++){
                if(clomns[i].equals("代码")){
                    codePostion = i;
                    continue;
                }else if(clomns[i].equals("价格")){
                    pricePosition = i;
                    continue;
                }else if(clomns[i].equals("名称")){
                    namePosition = i;
                    continue;
                }else if(clomns[i].equals("涨跌幅")){
                    zdfPosition = i;
                }
            }
            List<SyncCurrentValueFromLdVo> result = new ArrayList<>();
            // 读取 CSV 数据
            String line;
            while ((line = reader.readLine()) != null) {
                System.out.println(line);
                System.out.println(line); // 打印每一行数据
                String[] dataArray = line.split(",");
                SyncCurrentValueFromLdVo vo = new SyncCurrentValueFromLdVo();
                vo.setCode(dataArray[codePostion]);
                vo.setPrice(new BigDecimal(dataArray[pricePosition]));
                vo.setZdf(new BigDecimal(dataArray[zdfPosition]));
                vo.setName(dataArray[namePosition]);
                //更新对应产品的缓存100条数据
 
                result.add(vo);
            }
            // 关闭连接
            reader.close();
            connection.disconnect();
            return result;
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
        return null;
    }
}