1

zj

2024-10-21 a54e43c6d57c82660d46b24b0720175314960d78

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
package project.user.internal;
 
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
 
import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.jdbc.core.JdbcTemplate;
 
import kernel.web.ApplicationUtil;
import project.user.UserWalletAddress;
import project.user.UserWalletAddressService;
 
public class UserWalletAddressServiceImpl implements UserWalletAddressService {
    /**
     * 查询所有未生成地址的记录
     */
    public List<UserWalletAddress> queryByState(String state){
        return ApplicationUtil.executeSelect(UserWalletAddress.class,"WHERE STATE=?",new Object[] {state});
    }
    
    /**
     * 批量用户钱包地址信息
     */
    public void updateBatch(List<UserWalletAddress> addressList) {
        String sql = "UPDATE T_USER_WALLET_ADDRESS SET ERC_ADDRESS=?,STATE=? WHERE PARTY_ID=?";
        ApplicationUtil.getBean(JdbcTemplate.class).batchUpdate(sql, new BatchPreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps, int i) throws SQLException {
                ps.setString(1, addressList.get(i).getErcAddress());
                ps.setString(2, "1");
                ps.setString(3, addressList.get(i).getPartyId());
            }
            @Override
            public int getBatchSize() {
                return addressList.size();
            }
        });
    }
}