blame | history | patch | commit | commitdiff | ignore whitespace
Administrator
7 days ago ed5a6de6023e73e7f5b5af86a94aa4f1e43a3fc4 
 src/main/java/cc/mrbird/febs/mall/controller/CommonController.java


@@ -1,23 +1,39 @@


package cc.mrbird.febs.mall.controller;




import cc.mrbird.febs.common.annotation.ControllerEndpoint;


import cc.mrbird.febs.common.entity.FebsResponse;


import cc.mrbird.febs.common.exception.FebsException;


import cc.mrbird.febs.common.utils.AppContants;


import cc.mrbird.febs.common.utils.RedisUtils;


import cc.mrbird.febs.common.utils.SubMailSend;


import cc.mrbird.febs.common.utils.ZzSmsSend;


import cc.mrbird.febs.common.utils.*;


import cc.mrbird.febs.mall.dto.AccountAndCodeDto;


import cc.mrbird.febs.mall.dto.Base64UploadDto;


import cc.mrbird.febs.mall.entity.DataDictionaryCustom;


import cc.mrbird.febs.mall.service.ICommonService;


import cn.hutool.core.io.file.FileNameUtil;


import cn.hutool.core.lang.UUID;


import cn.hutool.core.util.IdUtil;


import cn.hutool.core.util.StrUtil;


import com.thoughtworks.xstream.core.BaseException;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


import io.swagger.annotations.ApiParam;


import lombok.RequiredArgsConstructor;


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 net.coobird.thumbnailator.Thumbnails;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.util.FileCopyUtils;


import org.springframework.validation.annotation.Validated;


import org.springframework.web.bind.annotation.*;


import org.springframework.web.multipart.MultipartFile;


import sun.misc.BASE64Encoder;




import javax.imageio.ImageIO;


import java.awt.image.BufferedImage;


import java.io.File;


import java.io.FileOutputStream;


import java.io.IOException;


import java.io.InputStream;


import java.util.HashMap;


import java.util.List;


import java.util.Map;




/**


@@ -25,6 +41,7 @@


 * @date 2021-09-16


 **/


@Slf4j


@CrossOrigin("*")


@RestController


@RequestMapping(value = "/api/common")


@RequiredArgsConstructor


@@ -32,6 +49,7 @@


public class CommonController {




    private final RedisUtils redisUtils;


    private final ICommonService commonService;




    @ApiOperation(value = "获取验证码接口", notes = "获取验证码通用接口")


    @GetMapping(value = "/verifyCode")


@@ -46,7 +64,9 @@




        // 发送手机验证码


        if (AppContants.ACCOUNT_TYPE_MOBILE.equals(type)) {


            boolean result = ZzSmsSend.sendVerifyCode(account, code.toString(), 2);


//            boolean result = Sms106Send.sendVerifyCode(account, code.toString(), 2);


            boolean result = ZzSmsSend.sendALiYun(account, code.toString());


//            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);


@@ -68,4 +88,170 @@


        }


        return new FebsResponse().fail().message("验证码发送失败");


    }




    @ApiOperation(value = "获取阿里云验证码接口", notes = "获取阿里云验证码接口")


    @GetMapping(value = "/aliVerifyCode")


    public FebsResponse aliVerifyCode(@ApiParam(name = "account", value = "手机号", required = true) @RequestParam(value = "account") String account,


                                   @ApiParam(name = "type", value = "类型1-手机号", required = true) @RequestParam("type") String type) {


        log.info("#账号:{}, 类型:{}#", account, type);




        Integer code = (int) ((Math.random() * 9 + 1) * 100000);


        if (StrUtil.isNotBlank(redisUtils.getString(AppContants.VERIFY_CODE_PREFIX + account))) {


            throw new FebsException("验证码已发送");


        }




        // 发送手机验证码


        if (AppContants.ACCOUNT_TYPE_MOBILE.equals(type)) {


            boolean result = ZzSmsSend.sendALiYun(account, code.toString());


            if (result) {


                Map<String, Object> map = new HashMap<>();


                boolean flag = redisUtils.set(AppContants.VERIFY_CODE_PREFIX + account, code, 300);


                map.put("code", flag);


                return new FebsResponse().success().message("验证码发送成功");


            }


            // 发送邮件验证码


        } else if (AppContants.ACCOUNT_TYPE_EMAIL.equals(type)) {


            boolean flag = SubMailSend.sendMail(account, code.toString());


            if (flag) {


                redisUtils.set(AppContants.VERIFY_CODE_PREFIX + account, code, 120);


                return new FebsResponse().success().message("验证码发送成功");


            } else {


                return new FebsResponse().fail().message("验证码发送失败");


            }


        } else {


            log.info("未定义账号类型");


            throw new FebsException("未定义账号类型");


        }


        return new FebsResponse().fail().message("验证码发送失败");


    }




    /**


     * 通用上传请求


     */


    // 文件保存目录路径


    @Value("${static.resource.url}")


    private String resourceUrl;


    // 文件保存目录URL


    @Value("${static.resource.path}")


    private String resourcePath;




    @ControllerEndpoint(operation = "文件上传服务器", exceptionMessage = "上传失败")


    @PostMapping(value = "/fileUploadEsc")


    public Map<String,Object> fileUploadEsc(@RequestBody @Validated MultipartFile file) throws IOException {


        if (file == null) {


            throw new FebsException("上传文件不能为空");


        }


        return FileUtil.fileUploadEsc(file,resourceUrl,resourcePath);


    }




    /**


     *  图片上传


     * @return


     */


    @PostMapping(value = "/uploadFileBase64")


    @ControllerEndpoint(operation = "图片上传", exceptionMessage = "上传失败")


    public Map<String,Object> uploadFileBase64(@RequestBody @Validated MultipartFile file) throws IOException {


        if (file == null || file.isEmpty()) {


            return new FebsResponse().message("上传文件为空");


        }


        return FileUtil.fileUploadEsc(file,resourceUrl,resourcePath);




//        //文件加密


//        BASE64Encoder base64Encoder =new BASE64Encoder();


//        String base64EncoderImg = null;


//        try {


//            base64EncoderImg = base64Encoder.encode(file.getBytes());


//        } catch (IOException e) {


//            e.printStackTrace();


//        }


//


//        String imageFuffix = ".png";


//        String imageNames = System.currentTimeMillis() + IdUtil.simpleUUID() + imageFuffix;


//        String imageName = "uploadeFile/" + imageNames;


//        OssUtils.uploadFileWithBase64(base64EncoderImg, imageName);


//        String bucket_name ="https://excoin.oss-cn-hangzhou.aliyuncs.com";


//        String url = bucket_name + "/" + imageName;


//


//        Map<String,Object> map = new HashMap<String,Object>();


//        Map<String,Object> map2 = new HashMap<String,Object>();


//        map.put("code",0);//0表示成功，1失败


//        map.put("msg","上传成功");//提示消息


//        map.put("data",map2);


//        map2.put("src",url);//图片url


//        map2.put("title",imageNames);//图片名称，这个会显示在输入框里


//        return map;


    }




    @ApiOperation(value = "数据字典")


    @GetMapping(value = "/findDataDic/{type}")


    public FebsResponse findDataDic(@PathVariable("type") String type) {


        List<DataDictionaryCustom> dic = commonService.findDataDicByType(type);


        return new FebsResponse().success().data(dic);


    }




    @ApiOperation(value = "base64FileUpload上传")


    @PostMapping(value = "/base64FileUpload")


    public Map<String,Object> base64FileUpload(@RequestBody @Validated MultipartFile file) throws IOException {


        if (file == null || file.isEmpty()) {


            return new FebsResponse().message("上传文件为空").fail();


        }




        try {


            byte[] fileBytes = file.getBytes();


            String base64Str = java.util.Base64.getEncoder().encodeToString(fileBytes);


            String imageSuffix = "." + file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(".") + 1);


            String imageNames = System.currentTimeMillis() + IdUtil.simpleUUID() + imageSuffix;


            String imageName = "hc/" + imageNames;


            OssUtils.uploadFileWithBase64(base64Str, imageName);


            String bucket_name = "https://excoin.oss-cn-hangzhou.aliyuncs.com";


            String url = bucket_name + "/" + imageName;




            Map<String,Object> map = new HashMap<String,Object>();


            Map<String,Object> map2 = new HashMap<String,Object>();


            map2.put("src",url);//图片url


            map2.put("title",imageNames);//图片名称，这个会显示在输入框里


            map.put("code",0);//0表示成功，1失败


            map.put("msg","上传成功");//提示消息


            map.put("data",map2);


            return map;


        } catch (IOException e) {


            log.error("上传失败: {}", e.getMessage());


            return new FebsResponse().message("上传失败").fail();


        }


    }




    @ApiOperation(value = "base64上传")


    @PostMapping(value = "/base64Upload")


    public FebsResponse base64Upload(@RequestBody @Validated Base64UploadDto base64UploadDto) {


        String base64Str = base64UploadDto.getBase64Str();


        if (base64Str.startsWith("data:image")) {


            base64Str = base64Str.substring(base64Str.indexOf(",") + 1, base64Str.length() - 1);


        }




        String imageFuffix = ".jpg";


        String imageNames = System.currentTimeMillis() + IdUtil.simpleUUID() + imageFuffix;


        String imageName = "uploadeFile/" + imageNames;


        OssUtils.uploadFileWithBase64(base64Str, imageName);


        String bucket_name ="https://excoin.oss-cn-hangzhou.aliyuncs.com";


        String url = bucket_name + "/" + imageName;




        return new FebsResponse().message("上传成功").success().data(url);


    }




    @ApiOperation(value = "获取版本信息")


    @GetMapping(value = "/appVersion")


    public FebsResponse appVersion() {


        return new FebsResponse().message("获取成功").success().data(commonService.findAppVersion());


    }




    @ApiOperation(value = "验证验证码接口")


    @PostMapping(value = "/checkCode")


    public FebsResponse checkCode(@RequestBody AccountAndCodeDto accountAndCodeDto) {




        boolean flag = commonService.verifyCode(accountAndCodeDto.getAccount(), accountAndCodeDto.getCode());


        if (flag) {


            return new FebsResponse().success();


        }


        return new FebsResponse().fail().message("验证码错误");


    }


}