From b30e1a48f2bc5f65a0efd2e69e090fed2d7a627c Mon Sep 17 00:00:00 2001 From: yanghui <2536613402@qq.com> Date: 星期四, 17 十一月 2022 15:56:43 +0800 Subject: [PATCH] #feat 订单退款和查询 --- springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java | 77 +++++++++++++++++++++++++++++++++++--- 1 files changed, 71 insertions(+), 6 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java index d41d5f6..f76bf1c 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java +++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java @@ -1,18 +1,25 @@ package com.panzhihua.applets.api; import java.io.File; +import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; -import java.util.Arrays; -import java.util.Base64; -import java.util.List; -import java.util.UUID; +import java.util.*; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; +import cn.hutool.core.util.StrUtil; +import com.jcraft.jsch.SftpException; +import com.panzhihua.applets.config.MinioUtil; +import com.panzhihua.applets.umf.UmfPayUtil; +import com.panzhihua.common.controller.BaseController; +import com.panzhihua.common.utlis.DateUtils; +import com.panzhihua.common.utlis.MimeTypeUtils; +import net.coobird.thumbnailator.Thumbnails; +import org.apache.commons.io.FilenameUtils; import org.apache.commons.lang3.RandomUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.data.redis.core.StringRedisTemplate; @@ -38,6 +45,8 @@ import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; +import static com.panzhihua.common.utlis.FileTypeUploadUtils.assertAllowed; + /** * @program: springcloud_k8s_panzhihuazhihuishequ * @description: 公共接口 @@ -48,7 +57,7 @@ @RestController @RequestMapping("/common/") @Api(tags = {"公共接口"}) -public class CommonApi { +public class CommonApi extends BaseController { /** * 允许的图片文件后缀 */ @@ -73,10 +82,16 @@ private int port; @Value("${ftp.url}") private String url; + @Value("${minio.url}") + private String minUrl; @Resource private WxMaConfiguration wxMaConfiguration; @Resource private CommunityService communityService; + @Resource + private MinioUtil minioUtil; + @Resource + private UmfPayUtil umfPayUtil; public static void main(String[] args) { // int nextInt = RandomUtils.nextInt(99999, 1000000); @@ -92,7 +107,7 @@ @PostMapping(value = "uploadimage", consumes = "multipart/*", headers = "content-type=multipart/form-date") public R uploadImage(@RequestParam MultipartFile file, HttpServletRequest request) throws IOException { // 微信图片内容校验 - WxMaSecCheckService wxMaSecCheckService = wxMaConfiguration.getMaService().getSecCheckService(); + WxMaSecCheckService wxMaSecCheckService = wxMaConfiguration.getMaService(this.getAppId()).getSecCheckService(); String property = System.getProperty("user.dir"); String fileExtension = ".jpg"; @@ -141,6 +156,44 @@ } + @ApiOperation(value = "新上传照片接口") + @PostMapping(value = "/uploadimages", consumes = "multipart/*", headers = "content-type=multipart/form-date") + public R uploadImages(@RequestParam MultipartFile file, HttpServletRequest request) { + try { + assertAllowed(file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION); + String extension = FilenameUtils.getExtension(file.getOriginalFilename()); + String name = UUID.randomUUID().toString().replaceAll("-", "") + "." + extension; + String imageUrl = minioUtil.upload(file, name); + return R.ok(imageUrl); + } catch (Exception e) { + log.error("上传照片失败【{}】", e.getMessage()); + return R.fail(); + } + } + + @ApiOperation(value = "新上传照片压缩接口") + @PostMapping(value = "/uploadimagescompress", consumes = "multipart/*", headers = "content-type=multipart/form-date") + public R uploadImagesComPress(@RequestParam MultipartFile file, HttpServletRequest request) { + try { + assertAllowed(file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION); + String extension = FilenameUtils.getExtension(file.getOriginalFilename()); + String uuid=UUID.randomUUID().toString().replaceAll("-", ""); + String name = uuid + "."+ extension; + String fileName = minioUtil.uploadRetFileName(file, name); + Thumbnails.of(file.getInputStream()).scale(0.5).outputQuality(0.71).outputFormat("jpg").toFile(uuid+"_compress"); + File file1=new File(uuid+"_compress.jpg"); + String imageUrl = minioUtil.uploadFile(file1, uuid+"_compress.jpg"); + //上传完压缩图后把原图清理,防止文件服务器资源爆满 + if (StrUtil.isNotBlank(fileName)){ + minioUtil.removeMinio(fileName); + } + return R.ok(imageUrl); + } catch (Exception e) { + log.error("上传照片失败【{}】", e.getMessage()); + return R.fail(); + } + } + @ApiOperation(value = "发送验证码") @PostMapping(value = "smscode") public R smscode(@RequestBody UserPhoneVO userPhoneVO) { @@ -165,4 +218,16 @@ String result = HttpUtils.sendGet(url, param); return R.ok(JSON.parseObject(result)); } + @ApiOperation("uu洗车下单接口") + @GetMapping("/uuPay") + public R uuPay(@RequestParam("orderid") String orderid,@RequestParam("openid")String openid,@RequestParam("amount")String amount){ + Map map=umfPayUtil.pay(orderid, DateUtils.getCurrentDateString(),openid,amount); + return R.ok(map); + } + @ApiOperation("无水洗车下单接口") + @GetMapping("/wsPay") + public R wsPay(@RequestParam("orderid") String orderid,@RequestParam("openid")String openid,@RequestParam("amount")String amount){ + Map map=umfPayUtil.pay2(orderid, DateUtils.getCurrentDateString(),openid,amount); + return R.ok(map); + } } -- Gitblit v1.7.1