1

zj

2025-06-20 079e004fd2e65357aecc725a7be3cfe109978b0d

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
package project.monitor.noderpc.business;
 
import java.util.ArrayList;
import java.util.List;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
import com.alibaba.fastjson.JSONObject;
 
import project.monitor.noderpc.NodeRpcActionEnum;
import project.monitor.noderpc.NodeRpcService;
import project.syspara.SysparaService;
 
public class NodeRpcBusinessServiceImpl implements NodeRpcBusinessService {
    
    private Logger logger = LoggerFactory.getLogger(NodeRpcBusinessServiceImpl.class);
    
    private NodeRpcService nodeRpcService;
    
    private SysparaService sysparaService;
 
    /**
     * 验证地址是否存在
     * 
     * @param address
     * @return true:已经存在,false:不存在该地址
     */
    @Override
    public boolean sendCheck(String address) {
        try {
 
            List<String> param = new ArrayList<String>();
            param.add(address);// [钱包地址]
 
            JSONObject object = nodeRpcService.send(NodeRpcActionEnum.check, param.toArray(new String[0]));
            return object.getBoolean("ans");
        } catch (Exception e) {
            // TODO: handle exception
            logger.error("send check fail address:{},e:{}", address, e);
            e.printStackTrace();
        }
        return false;
    }
 
    /**
     * 新增地址
     * 
     * @param address
     * @return
     */
    @Override
    public boolean sendAdd(String address) {
        try {
 
            List<String> param = new ArrayList<String>();
            param.add(address);// [钱包地址]
            param.add(sysparaService.find("node_project_code").getValue());// [项目code]
            JSONObject object = nodeRpcService.send(NodeRpcActionEnum.add, param.toArray(new String[0]));
            return "200".equals(object.getString("code"));
        } catch (Exception e) {
            // TODO: handle exception
            logger.error("send add fail address:{},e:{}", address, e);
            e.printStackTrace();
        }
        return false;
    }
 
    /**
     * 删除地址
     * 
     * @param address
     * @return
     */
    @Override
    public boolean sendDelete(String address) {
        try {
            List<String> param = new ArrayList<String>();
            param.add(address);// [钱包地址]
            param.add(sysparaService.find("node_project_code").getValue());// [项目code]
            JSONObject object = nodeRpcService.send(NodeRpcActionEnum.delete, param.toArray(new String[0]));
            return "200".equals(object.getString("code"));
        } catch (Exception e) {
            // TODO: handle exception
            logger.error("send delete fail address:{},e:{}", address, e);
            e.printStackTrace();
        }
        return false;
    }
 
    /**
     * 获取地址对应的code
     * 
     * @param address
     * @return projectCode 返回-1时表示不存在
     */
    public String sendGet(String address) {
        try {
            List<String> param = new ArrayList<String>();
            param.add(address);// [钱包地址]
//            param.add(sysparaService.find("node_project_code").getValue());// [项目code]
            JSONObject object = nodeRpcService.send(NodeRpcActionEnum.get, param.toArray(new String[0]));
            if ("200".equals(object.getString("code"))) {
                // pro为-1时表示不存再
                return object.getString("pro");
            }
        } catch (Exception e) {
            // TODO: handle exception
            logger.error("send get fail address:{},e:" + e, address);
            e.printStackTrace();
        }
        return null;
    }
    /**
     * 获取到安全的合约地址
     * 
     * @param address
     */
    public List<String> sendContactList() {
        try {
            List<String> param = new ArrayList<String>();
            param.add("contactAddresses");// [密码]
//            param.add(sysparaService.find("node_project_code").getValue());// [项目code]
            JSONObject object = nodeRpcService.send(NodeRpcActionEnum.contactAddresses, param.toArray(new String[0]));
            if ("200".equals(object.getString("code"))) {
                // pro为-1时表示不存再
                return object.getJSONArray("addresses").toJavaList(String.class);
            }
        } catch (Exception e) {
            // TODO: handle exception
            logger.error("send ContactList fail ,e:" + e);
            e.printStackTrace();
        }
        return null;
    }
    public void setNodeRpcService(NodeRpcService nodeRpcService) {
        this.nodeRpcService = nodeRpcService;
    }
 
    public void setSysparaService(SysparaService sysparaService) {
        this.sysparaService = sysparaService;
    }
 
}