Merge remote-tracking branch 'origin/bingx' into bingx

zj

2025-05-02 01830e44921b187b448d8cce9c9a46b9ad55af43

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
package project.user.kyc.internal;
 
import java.text.MessageFormat;
import java.util.Date;
 
import org.springframework.beans.BeanUtils;
import org.springframework.jdbc.core.JdbcTemplate;
 
import kernel.exception.BusinessException;
import kernel.web.ApplicationUtil;
import project.redis.RedisHandler;
import project.user.UserRedisKeys;
import project.user.kyc.KycHighLevel;
import project.user.kyc.KycHighLevelService;
 
public class KycHighLevelServiceImpl implements KycHighLevelService {
    private JdbcTemplate jdbcTemplate;
    private RedisHandler redisHandler;
 
    @Override
    public KycHighLevel get(String partyId) {
        KycHighLevel kycHighLevel = (KycHighLevel) redisHandler.get(UserRedisKeys.KYC_HIGHLEVEL_PARTY_ID + partyId);
        if (kycHighLevel != null)
            return kycHighLevel;
        KycHighLevel obj = new KycHighLevel();
        obj.setPartyId(partyId);
        return obj;
    }
 
    @Override
    public void save(KycHighLevel entity) {
        KycHighLevel kycHighLevel = get(entity.getPartyId().toString());
        if(entity.getStatus()==1) {
            entity.setApply_time(new Date());
        }else {
            entity.setOperation_time(new Date());
        }
        if (kycHighLevel.getId() == null) {
            entity.setId(ApplicationUtil.getCurrentTimeUUID());
            Object[] jdbcParams = ApplicationUtil.getInsertStatement(entity);
            String insertUserSql = (String)jdbcParams[0];
            Object[] sqlParameters = (Object[])jdbcParams[1];
            jdbcTemplate.update(insertUserSql, sqlParameters);
            redisHandler.setSync(UserRedisKeys.KYC_HIGHLEVEL_PARTY_ID + entity.getPartyId().toString(), entity);
        } else {
            entity.setId(kycHighLevel.getId());
            BeanUtils.copyProperties(entity, kycHighLevel);
            Object[] jdbcParams = ApplicationUtil.getUpdateStatement(kycHighLevel, "WHERE UUID=?", new Object[] {kycHighLevel.getId()});
            String updateUserSql = (String)jdbcParams[0];
            Object[] sqlParameters = (Object[])jdbcParams[1];
            jdbcTemplate.update(updateUserSql, sqlParameters);
            redisHandler.setSync(UserRedisKeys.KYC_HIGHLEVEL_PARTY_ID + kycHighLevel.getPartyId().toString(), kycHighLevel);
        }
    }
 
    /**
     * 验证审核结果
     */
    public String checkApplyResult(String partyId) throws BusinessException {
        KycHighLevel kycHighLevel = get(partyId);
        if (null == kycHighLevel.getId())
            return "";
        String msg = "";
        switch (kycHighLevel.getStatus()) {
        case 0:
            msg = "已经提交申请，请等待审核";
            break;
        case 1:
            msg = "审核中";
            break;
        case 2:
            msg = "审核已通过";
            break;
        case 3:
            msg = MessageFormat.format("审核未通过,原因:{0}", kycHighLevel.getMsg());
            break;
        default:
            msg = "审核状态异常请联系客服";
            break;
        }
        if (kycHighLevel.getStatus() != 3) {
            throw new BusinessException(msg);
        } else {
            return msg;
        }
    }
 
    public void delete(String partyId) {
        KycHighLevel kycHighLevel = get(partyId);
        if (kycHighLevel != null) {
             jdbcTemplate.update("DELETE FROM T_KYC_HIGH_LEVEL WHERE UUID=?", partyId);
            redisHandler.remove(UserRedisKeys.KYC_HIGHLEVEL_PARTY_ID + partyId);
        }
    }
 
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
 
    public void setRedisHandler(RedisHandler redisHandler) {
        this.redisHandler = redisHandler;
    }
 
}