From 829f629756e5402bcd3e9f6ef1f9c6dbffbabb11 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Wed, 17 Apr 2024 14:46:29 +0800 Subject: [PATCH] 55测试环境 --- src/main/java/com/xcong/excoin/common/system/controller/CommonController.java | 91 ++++++++++++++++++++++++++++++++++++--------- 1 files changed, 73 insertions(+), 18 deletions(-) diff --git a/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java b/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java index 94ab806..04f19af 100644 --- a/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java +++ b/src/main/java/com/xcong/excoin/common/system/controller/CommonController.java @@ -1,22 +1,36 @@ package com.xcong.excoin.common.system.controller; +import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.StrUtil; import com.xcong.excoin.common.contants.AppContants; import com.xcong.excoin.common.response.Result; +import com.xcong.excoin.common.system.bean.SysExceptionDetailEntity; +import com.xcong.excoin.common.system.dto.Base64UploadDto; import com.xcong.excoin.common.system.service.CommonService; +import com.xcong.excoin.configurations.properties.AliOssProperties; +import com.xcong.excoin.modules.blackchain.service.TrxUsdtUpdateService; +import com.xcong.excoin.modules.platform.dao.SysExceptionDetailDao; +import com.xcong.excoin.utils.MessageSourceUtils; +import com.xcong.excoin.utils.OssUtils; import com.xcong.excoin.utils.RedisUtils; import com.xcong.excoin.utils.SmsUtils; +import com.xcong.excoin.utils.mail.Sms106Send; +import com.xcong.excoin.utils.mail.SmsSend; import com.xcong.excoin.utils.mail.SubMailSend; +import com.xcong.excoin.utils.mail.ZzSmsSend; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import lombok.extern.slf4j.Slf4j; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; +import org.apache.ibatis.annotations.Param; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; +import java.math.BigDecimal; +import java.math.BigInteger; import java.util.HashMap; import java.util.Map; @@ -40,6 +54,9 @@ @Resource private CommonService commonservice; + @Resource + private AliOssProperties aliOssProperties; + @ApiOperation(value = "获取验证码接口", notes = "获取验证码通用接口") @GetMapping(value = "/verifyCode") public Result verifyCode(@ApiParam(name = "account", value = "手机号或邮箱", required = true) @RequestParam(value = "account") String account, @@ -48,28 +65,32 @@ Integer code = (int) ((Math.random() * 9 + 1) * 100000); if (StrUtil.isNotBlank(redisUtils.getString(AppContants.VERIFY_CODE_PREFIX + account))) { - return Result.fail("验证码已发送,请勿重复发"); + return Result.fail(MessageSourceUtils.getString("common_verify_code_exist")); } // 发送手机验证码 if (AppContants.ACCOUNT_TYPE_MOBILE.equals(type)) { - Map<String, Object> result = SmsUtils.sendVerifyCode(account, code); - if (SUCCESS.equals(result.get("resultstatus"))) { + boolean result = ZzSmsSend.sendVerifyCode(account, code.toString(), 2); + if (result) { Map<String, Object> map = new HashMap<>(); boolean flag = redisUtils.set(AppContants.VERIFY_CODE_PREFIX + account, code, 120); map.put("code", flag); - return Result.ok("success", map); + return Result.ok(MessageSourceUtils.getString("member_service_0010"), map); } // 发送邮件验证码 } else if (AppContants.ACCOUNT_TYPE_EMAIL.equals(type)) { - SubMailSend.sendMail(account, code.toString()); - redisUtils.set(AppContants.VERIFY_CODE_PREFIX + account, code, 120); - return Result.ok("success"); + boolean flag = SubMailSend.sendMail(account, code.toString()); + if (flag) { + redisUtils.set(AppContants.VERIFY_CODE_PREFIX + account, code, 120); + return Result.ok(MessageSourceUtils.getString("member_service_0010")); + } else { + return Result.fail(MessageSourceUtils.getString("result_fail_msg")); + } } else { log.info("未定义账号类型"); - return Result.fail("fail"); + return Result.fail(MessageSourceUtils.getString("result_fail_msg")); } - return Result.fail("fail"); + return Result.fail(MessageSourceUtils.getString("result_fail_msg")); } @ApiOperation(value = "验证验证码是否正确", notes = "验证验证码是否正确") @@ -78,14 +99,48 @@ @ApiParam(name = "code", value = "验证码", required = true) @RequestParam("code") String code) { boolean flag = commonservice.verifyCode(account, code); if (flag) { - return Result.ok("success"); + return Result.ok(MessageSourceUtils.getString("result_success_msg")); } - return Result.fail("验证码错误"); + return Result.fail(MessageSourceUtils.getString("common_verify_code")); } @ApiOperation(value = "文件上次接口", notes = "文件上传") - @GetMapping(value = "/uploadFile") - public Result uploadFile() { - return null; + @PostMapping(value = "/uploadFileBase64") + public Result uploadFileBase64(@RequestBody @Validated Base64UploadDto uploadDto) { + String imageName = "uploadeFile/image/" + System.currentTimeMillis() + IdUtil.simpleUUID() + AppContants.UPLOAD_IMAGE_SUFFIX; + boolean flag = OssUtils.uploadFileWithBase64(uploadDto.base64Str, imageName); + if (flag) { + String url = aliOssProperties.getBucketName() + "/" + imageName; + return Result.ok(MessageSourceUtils.getString("result_success_msg"), url); + } + return Result.fail(MessageSourceUtils.getString("uploadFile_controller_0001")); + } + + @Autowired + private TrxUsdtUpdateService trxUsdtUpdateService; + + @ApiOperation(value = "trc20测试") + @Transactional(rollbackFor = Exception.class) + @GetMapping(value = "/getTrc20Test") + public Result getTrc20Test() { + long start = System.currentTimeMillis(); + System.out.println(start); + long getnowblock = trxUsdtUpdateService.getnowblock(); + System.out.println(System.currentTimeMillis()); + Object trc20BlockNum = redisUtils.get("USDT_TRC20_BLOCK_NUM"); + TrxUsdtUpdateService.getblockbynum(BigInteger.valueOf(Long.parseLong(trc20BlockNum.toString()))); + long end = System.currentTimeMillis(); + System.out.println(end); + BigDecimal.ONE.divide(BigDecimal.ZERO); + return Result.ok(end - start); + } + + @Autowired + private SysExceptionDetailDao sysExceptionDetailDao; + + @GetMapping(value = "/getExceptionMsg") + public Result getExceptionMsg(@RequestParam(value = "id") Long id) { + SysExceptionDetailEntity sysExceptionDetailEntity = sysExceptionDetailDao.selectById(id); + return Result.ok(sysExceptionDetailEntity); } } -- Gitblit v1.9.1