1
zyy
2 days ago a8e2dbcd82859a3f972192c60b95cba4defe1738
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
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
package com.yami.trading.api.controller;
 
import cn.hutool.core.util.StrUtil;
import com.qiniu.util.StringUtils;
import com.yami.trading.api.model.AddPaymentMethodModel;
import com.yami.trading.api.model.IdModel;
import com.yami.trading.api.model.PaymentMethodModel;
import com.yami.trading.api.service.UserCacheService;
import com.yami.trading.api.util.ServletUtil;
import com.yami.trading.bean.constans.UserConstants;
import com.yami.trading.bean.model.C2cPaymentMethod;
import com.yami.trading.bean.model.C2cPaymentMethodConfig;
import com.yami.trading.bean.model.C2cTranslate;
import com.yami.trading.bean.model.User;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.constants.PayTemplateParamEnum;
import com.yami.trading.common.constants.RedisKeys;
import com.yami.trading.common.domain.Result;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.util.IPHelper;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.c2c.C2cAdvertService;
import com.yami.trading.service.c2c.C2cPaymentMethodConfigService;
import com.yami.trading.service.c2c.C2cPaymentMethodService;
import com.yami.trading.service.c2c.C2cTranslateService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.system.LogService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;
 
import javax.validation.Valid;
import java.text.MessageFormat;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
 
@RestController
@CrossOrigin
@RequestMapping("api/paymentMethod")
@Api(tags = "收款方式")
public class ApiPaymentMethodController {
    @Autowired
    C2cPaymentMethodConfigService c2cPaymentMethodConfigService;
    @Autowired
    C2cPaymentMethodService c2cPaymentMethodService;
    @Autowired
    UserCacheService userCacheService;
    @Autowired
    LogService logService;
    @Autowired
    SysparaService sysparaService;
    @Autowired
    RedisTemplate redisTemplate;
    @Autowired
    C2cTranslateService c2cTranslateService;
    @Autowired
    C2cAdvertService c2cAdvertService;
 
    @ApiOperation(value = "获取收款方式列表")
    @RequestMapping("list")
    public Result<Map<String, String>> getPaymentMethod(@Valid PaymentMethodModel paymentMethodModel) {
        String language = paymentMethodModel.getLanguage();
        Map<String, C2cPaymentMethodConfig> methodConfigMap = this.c2cPaymentMethodConfigService.getBankCardPMethodConfigMap();
        // 多语言
        Map<String, String> retPayMap = new HashMap<>();
        for (String id : methodConfigMap.keySet()) {
            C2cPaymentMethodConfig configEntity = methodConfigMap.get(id);
 
            String payParamLangKeyPrefix = "pay.param.";
            String payMethodNameLangKey = payParamLangKeyPrefix + PayTemplateParamEnum.METHOD_NAME.getCode() + "." + configEntity.getUuid();
 
            C2cTranslate trans = c2cTranslateService.get(id, payMethodNameLangKey, language);
            if (null != trans) {
                retPayMap.put(id, trans.getTranslate());
            }
        }
 
        return Result.succeed(retPayMap);
    }
 
    @ApiOperation(value = "新增收款方式")
    @RequestMapping("add")
    public Result<?> add(@Valid AddPaymentMethodModel model) {
        String language = ServletUtil.getRequest().getParameter("language");
        if (StringUtils.isNullOrEmpty(model.getMethod_config_id())) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("支付方式模板不正确");
            } else {
                throw new YamiShopBindException("Payment method template is incorrect");
            }
        }
        if (StringUtils.isNullOrEmpty(model.getReal_name())) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("真实姓名必填");
            } else {
                throw new YamiShopBindException("Real name required");
            }
        }
        if (StringUtils.isNullOrEmpty(model.getParam_value1())) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("参数1必填");
            } else {
                throw new YamiShopBindException("Parameter value 1 is required");
            }
        }
        if (model.getReal_name().length() > 20) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("真实姓名长度大于20");
            } else {
                throw new YamiShopBindException("Real name length greater than 20");
            }
        }
        if (model.getRemark().length() > 100) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("备注长度大于100");
            } else {
                throw new YamiShopBindException("Note length greater than 100");
            }
        }
        C2cPaymentMethodConfig methodConfig = c2cPaymentMethodConfigService.getById(model.getMethod_config_id());
        if (null == methodConfig) {
            
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("支付方式模板不存在");
            } else {
                throw new YamiShopBindException("Payment method template does not exist");
            }
        }
        if (!StrUtil.isEmpty(model.getParam_value1())) {
            if (model.getParam_value1().length() > 25) {
                if (language.equals("zh-CN")) {
                    throw new YamiShopBindException(methodConfig.getParamName1() + "长度大于25");
                } else {
                    throw new YamiShopBindException(model.getParam_value1() + " length greater than 25");
                }
            }
        }
        if (!StrUtil.isEmpty(model.getParam_value2())) {
            if (model.getParam_value2().length() > 25) {
                if (language.equals("zh-CN")) {
                    throw new YamiShopBindException(methodConfig.getParamName2() + "长度大于25");
                } else {
                    throw new YamiShopBindException(model.getParam_value2() + " length greater than 25");
                }
            }
        }
        String partyId = SecurityUtils.getUser().getUserId();
        if (null == partyId) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("请重新登录");
            } else {
                throw new YamiShopBindException("please login again");
            }
        }
        // C2C用户和承兑商添加支付方式最大数量
        Map<String, C2cPaymentMethod> methodMap = c2cPaymentMethodService.getByPartyId(partyId);
        Object obj = this.sysparaService.find("c2c_payment_method_count_max");
        if (null != obj) {
            if (methodMap.size() >= Integer.valueOf(this.sysparaService.find("c2c_payment_method_count_max").getSvalue()).intValue()) {
                if (language.equals("zh-CN")) {
                    throw new YamiShopBindException("支付方式数量已达上限");
                } else {
                    throw new YamiShopBindException("The number of payment methods has reached the upper limit");
                }
            }
        }
        C2cPaymentMethod method = new C2cPaymentMethod();
        method.setPartyId(partyId);
        method.setMethodConfigId(model.getMethod_config_id());
        method.setMethodType(methodConfig.getMethodType());
        method.setType(1);
        method.setMethodName(methodConfig.getMethodName());
        method.setMethodImg(methodConfig.getMethodImg());
        method.setRealName(model.getReal_name());
        method.setParamName1(methodConfig.getParamName1());
        method.setParamValue1(model.getParam_value1());
        method.setParamName2(methodConfig.getParamName2());
        method.setParamValue2(model.getParam_value2());
        method.setParamName3(methodConfig.getParamName3());
        method.setParamValue3(model.getParam_value3());
        method.setParamName4(methodConfig.getParamName4());
        method.setParamValue4(model.getParam_value4());
        method.setParamName5(methodConfig.getParamName5());
        method.setParamValue5(model.getParam_value5());
        method.setParamName6(methodConfig.getParamName6());
        method.setParamValue6(model.getParam_value6());
        method.setParamName7(methodConfig.getParamName7());
        method.setParamValue7(model.getParam_value7());
        method.setParamName8(methodConfig.getParamName8());
        method.setParamValue8(model.getParam_value8());
        method.setParamName9(methodConfig.getParamName9());
        method.setParamValue9(model.getParam_value9());
        method.setParamName10(methodConfig.getParamName10());
        method.setParamValue10(model.getParam_value10());
        method.setParamName11(methodConfig.getParamName11());
        method.setParamValue11(model.getParam_value11());
        method.setParamName12(methodConfig.getParamName12());
        method.setParamValue12(model.getParam_value12());
        method.setParamName13(methodConfig.getParamName13());
        method.setParamValue13(model.getParam_value13());
        method.setParamName14(methodConfig.getParamName14());
        method.setParamValue14(model.getParam_value14());
        method.setParamName15(methodConfig.getParamName15());
        method.setParamValue15(model.getParam_value15());
        method.setQrcode(model.getQrcode());
        method.setRemark(model.getRemark());
        String id = c2cPaymentMethodService.saveData(method);
        C2cPaymentMethod methodSaved = c2cPaymentMethodService.getC2cPaymentMethod(id);
        if (null != methodSaved) {
            redisTemplate.opsForValue().set(RedisKeys.C2C_PAYMENT_METHOD_ID + methodSaved.getUuid(), methodSaved);
            Map<String, C2cPaymentMethod> map = (Map<String, C2cPaymentMethod>) redisTemplate.opsForValue().get(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + methodSaved.getPartyId());
            if (null == map) {
                map = new HashMap<>();
            }
            map.put(methodSaved.getUuid(), methodSaved);
            redisTemplate.opsForValue().set(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + methodSaved.getPartyId(), map);
            Map<String, String> map1 = (Map<String, String>) redisTemplate.opsForValue().get(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE);
            if (null == map1) {
                map1 = new ConcurrentHashMap<String, String>();
            }
            map1.put(methodSaved.getUuid(), String.valueOf(methodSaved.getMethodType()));
            redisTemplate.opsForValue().set(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE + methodSaved.getUuid(), map1);
        }
        String log = MessageFormat.format("ip:" + IPHelper.getIpAddr()
                        + ",用户新增支付方式,id:{0},用户PARTY_ID:{1},支付方式模板id:{2},支付方式类型:{3},支付方式名称:{4},支付方式图片:{5},真实姓名:{6},"
                        + "参数名1:{7},参数值1:{8},参数名2:{9},参数值2:{10},参数名3:{11},参数值3:{12},参数名4:{13},参数值4:{14},参数名5:{15},参数值5:{16},"
                        + "参数名6:{17},参数值6:{18},参数名7:{19},参数值7:{20},参数名8:{21},参数值8:{22},参数名9:{23},参数值9:{24},参数名10:{25},参数值10:{26},"
                        + "参数名11:{27},参数值11:{28},参数名12:{29},参数值12:{30},参数名13:{31},参数值13:{32},参数名14:{33},参数值14:{34},参数名15:{35},参数值15:{36},"
                        + "支付二维码:{37},备注:{38},创建时间:{39},更新时间:{40}",
                method.getUuid(), method.getPartyId(), method.getMethodConfigId(), method.getMethodType(), method.getMethodName(), method.getMethodImg(), method.getRealName(),
                method.getParamName1(), method.getParamValue1(), method.getParamName2(), method.getParamValue2(), method.getParamName3(), method.getParamValue3(), method.getParamName4(), method.getParamValue4(), method.getParamName5(), method.getParamValue5(),
                method.getParamName6(), method.getParamValue6(), method.getParamName7(), method.getParamValue7(), method.getParamName8(), method.getParamValue8(), method.getParamName9(), method.getParamValue9(), method.getParamName10(), method.getParamValue10(),
                method.getParamName11(), method.getParamValue11(), method.getParamName12(), method.getParamValue12(), method.getParamName13(), method.getParamValue13(), method.getParamName14(), method.getParamValue14(), method.getParamName15(), method.getParamValue15(),
                method.getQrcode(), method.getRemark(), method.getCreateTime(), method.getUpdateTime());
        User user = userCacheService.currentUser();
        logService.saveLog(user, log, UserConstants.LOG_CATEGORY_C2C);
        return Result.succeed(null);
    }
 
    @ApiOperation(value = "更新收款方式")
    @RequestMapping("update")
    public Result<?> update(@Valid AddPaymentMethodModel model) {
        String language = ServletUtil.getRequest().getParameter("language");
        if (StringUtils.isNullOrEmpty(model.getReal_name())) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("真实姓名必填");
            } else {
                throw new YamiShopBindException("Real name required");
            }
        }
        if (StringUtils.isNullOrEmpty(model.getParam_value1())) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("参数1必填");
            } else {
                throw new YamiShopBindException("Parameter value 1 is required");
            }
        }
        if (model.getReal_name().length() > 20) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("真实姓名长度大于20");
            } else {
                throw new YamiShopBindException("Real name length greater than 20");
            }
        }
        if (model.getRemark().length() > 100) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("备注长度大于100");
            } else {
                throw new YamiShopBindException("Note length greater than 100");
            }
        }
        C2cPaymentMethod method = this.c2cPaymentMethodService.getById(model.getId());
        if (null == method) {
            
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("支付方式不存在");
            } else {
                throw new YamiShopBindException("Payment method does not exist");
            }
        }
        String partyId = SecurityUtils.getUser().getUserId();
        if (!method.getPartyId().equals(partyId)) {
            if (language.equals("zh-CN")) {
                throw new YamiShopBindException("支付方式不匹配该用户");
            } else {
                throw new YamiShopBindException("The payment method does not match this user");
            }
        }
        String log = MessageFormat.format("ip:" + IPHelper.getIpAddr()
                        + ",用户修改支付方式,id:{0},原用户PARTY_ID:{1},原支付方式模板:{2},原支付方式类型:{3},原支付方式名称:{4},原支付方式图片:{5},原真实姓名:{6},"
                        + "原参数名1:{7},原参数值1:{8},原参数名2:{9},原参数值2:{10},原参数名3:{11},原参数值3:{12},原参数名4:{13},原参数值4:{14},原参数名5:{15},原参数值5:{16},"
                        + "原参数名6:{17},原参数值6:{18},原参数名7:{19},原参数值7:{20},原参数名8:{21},原参数值8:{22},原参数名9:{23},原参数值9:{24},原参数名10:{25},原参数值10:{26},"
                        + "原参数名11:{27},原参数值11:{28},原参数名12:{29},原参数值12:{30},原参数名13:{31},原参数值13:{32},原参数名14:{33},原参数值14:{34},原参数名15:{35},原参数值15:{36},"
                        + "原支付二维码:{37},原备注:{38},原创建时间:{39},原更新时间:{40}",
                method.getUuid(), method.getPartyId(), method.getMethodConfigId(), method.getMethodType(), method.getMethodName(), method.getMethodImg(), method.getRealName(),
                method.getParamName1(), method.getParamValue1(), method.getParamName2(), method.getParamValue2(), method.getParamName3(), method.getParamValue3(), method.getParamName4(), method.getParamValue4(), method.getParamName5(), method.getParamValue5(),
                method.getParamName6(), method.getParamValue6(), method.getParamName7(), method.getParamValue7(), method.getParamName8(), method.getParamValue8(), method.getParamName9(), method.getParamValue9(), method.getParamName10(), method.getParamValue10(),
                method.getParamName11(), method.getParamValue11(), method.getParamName12(), method.getParamValue12(), method.getParamName13(), method.getParamValue13(), method.getParamName14(), method.getParamValue14(), method.getParamName15(), method.getParamValue15(),
                method.getQrcode(), method.getRemark(), method.getCreateTime(), method.getUpdateTime());
        method.setRealName(model.getReal_name());
        method.setParamValue1(model.getParam_value1());
        method.setParamValue2(model.getParam_value2());
        method.setParamValue3(model.getParam_value3());
        method.setParamValue4(model.getParam_value4());
        method.setParamValue5(model.getParam_value5());
        method.setParamValue6(model.getParam_value6());
        method.setParamValue7(model.getParam_value7());
        method.setParamValue8(model.getParam_value8());
        method.setParamValue9(model.getParam_value9());
        method.setParamValue10(model.getParam_value10());
        method.setParamValue11(model.getParam_value11());
        method.setParamValue12(model.getParam_value12());
        method.setParamValue13(model.getParam_value13());
        method.setParamValue14(model.getParam_value14());
        method.setParamValue15(model.getParam_value15());
        method.setQrcode(model.getQrcode());
        method.setRemark(model.getRemark());
        boolean state = this.c2cPaymentMethodService.updateById(method);
        if (state) {
            redisTemplate.opsForValue().set(RedisKeys.C2C_PAYMENT_METHOD_ID + method.getUuid(), method);
            Map<String, C2cPaymentMethod> map = (Map<String, C2cPaymentMethod>) redisTemplate.opsForValue().get(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + method.getPartyId().toString());
            if (null == map) {
                map = new ConcurrentHashMap<String, C2cPaymentMethod>();
            } else {
                map.remove(method.getUuid());
            }
            map.put(method.getUuid(), method);
            redisTemplate.opsForValue().set(RedisKeys.C2C_PAYMENT_METHOD_PARTY_ID + method.getPartyId().toString(), map);
            Map<String, String> map1 = (Map<String, String>) redisTemplate.opsForValue().get(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE);
            if (null == map1) {
                map1 = new ConcurrentHashMap<String, String>();
            } else {
                map1.remove(method.getUuid());
            }
            map1.put(method.getUuid(), String.valueOf(method.getMethodType()));
            redisTemplate.opsForValue().set(RedisKeys.C2C_PAYMENT_METHOD_ID_TYPE, map1);
        }
        log += MessageFormat.format(",id:{0},新用户PARTY_ID:{1},新支付方式模板:{2},新支付方式类型:{3},新支付方式名称:{4},新支付方式图片:{5},新真实姓名:{6},"
                        + "新参数名1:{7},新参数值1:{8},新参数名2:{9},新参数值2:{10},新参数名3:{11},新参数值3:{12},新参数名4:{13},新参数值4:{14},新参数名5:{15},新参数值5:{16},"
                        + "新参数名6:{17},新参数值6:{18},新参数名7:{19},新参数值7:{20},新参数名8:{21},新参数值8:{22},新参数名9:{23},新参数值9:{24},新参数名10:{25},新参数值10:{26},"
                        + "新参数名11:{27},新参数值11:{28},新参数名12:{29},新参数值12:{30},新参数名13:{31},新参数值13:{32},新参数名14:{33},新参数值14:{34},新参数名15:{35},新参数值15:{36},"
                        + "新支付二维码:{37},新备注:{38},新创建时间:{39},新更新时间:{40}",
                method.getUuid(), method.getPartyId(), method.getMethodConfigId(), method.getMethodType(), method.getMethodName(), method.getMethodImg(), method.getRealName(),
                method.getParamName1(), method.getParamValue1(), method.getParamName2(), method.getParamValue2(), method.getParamName3(), method.getParamValue3(), method.getParamName4(), method.getParamValue4(), method.getParamName5(), method.getParamValue5(),
                method.getParamName6(), method.getParamValue6(), method.getParamName7(), method.getParamValue7(), method.getParamName8(), method.getParamValue8(), method.getParamName9(), method.getParamValue9(), method.getParamName10(), method.getParamValue10(),
                method.getParamName11(), method.getParamValue11(), method.getParamName12(), method.getParamValue12(), method.getParamName13(), method.getParamValue13(), method.getParamName14(), method.getParamValue14(), method.getParamName15(), method.getParamValue15(),
                method.getQrcode(), method.getRemark(), method.getCreateTime(), method.getUpdateTime());
        User user = userCacheService.currentUser();
        logService.saveLog(user, log, UserConstants.LOG_CATEGORY_C2C);
        return Result.succeed(null);
    }
 
    /**
     * 获取 支付方式 列表
     */
    @RequestMapping("myList")
    @ApiOperation("获取我的 支付方式 列表")
    public Result list(@RequestParam String language) {
        List<C2cPaymentMethod> list = new ArrayList<>();
        Map<String, C2cPaymentMethod> map = this.c2cPaymentMethodService.getByBankCardPartyId(SecurityUtils.getUser().getUserId());
        if (null != map && 0 != map.size()) {
            for (C2cPaymentMethod method : map.values()) {
                if (null != method) {
                    if (com.yami.trading.common.util.StringUtils.isNotEmpty(method.getMethodImg())) {
                        String path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + method.getMethodImg();
                        method.setMethodImg(path);
                    }
                    list.add(this.c2cTranslateService.translatePm(method, language));
                }
            }
        }
 
        return Result.succeed(list);
    }
 
    @ApiOperation(value = "删除我的收款方式")
    @RequestMapping("deletepPymentMethod")
    public Result<List<C2cPaymentMethod>> deletepPymentMethod(@Valid IdModel model) {
        c2cPaymentMethodService.removeById(model.getId());
        return Result.succeed(null);
    }
 
}