黔云通代驾
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
3 天以前 e5bdd46a51ebfda768262ff51c17879241ea2b14 
 user/guns-admin/src/main/java/com/supersavedriving/user/modular/api/AppUserController.java


@@ -3,6 +3,7 @@


import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.heredata.hos.model.bucket.Bucket;


import com.sun.xml.internal.bind.v2.TODO;


import com.supersavedriving.user.core.common.annotion.ServiceLog;


import com.supersavedriving.user.core.util.ToolUtil;


@@ -14,7 +15,10 @@


import com.supersavedriving.user.modular.system.util.MallBook.model.InterfaceResponse;


import com.supersavedriving.user.modular.system.util.MallBook.util.RSASignature;


import com.supersavedriving.user.modular.system.util.huawei.OBSUtil;


import com.supersavedriving.user.modular.system.util.huawei.SMSUtil;


import com.supersavedriving.user.modular.system.util.qianyuntong.NCOSSUtil;


import com.supersavedriving.user.modular.system.util.qianyuntong.QianYunTongConfig;


import com.supersavedriving.user.modular.system.util.qianyuntong.SMSUtil;


import com.supersavedriving.user.modular.system.util.qianyuntong.model.SendSmsRequest;


import com.supersavedriving.user.modular.system.util.weChat.WeChatUtil;


import com.supersavedriving.user.modular.system.warpper.*;


import io.swagger.annotations.ApiImplicitParam;


@@ -25,6 +29,7 @@


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


import org.springframework.web.multipart.MultipartFile;




import javax.annotation.Resource;


import javax.servlet.http.HttpServletRequest;


import javax.servlet.http.HttpServletResponse;


import java.io.InputStream;


@@ -73,6 +78,9 @@


    private TCheckCarActivityService  checkCarActivityService;


    @Autowired


    private ITBranchOfficeAreaService branchOfficeAreaService;


    


    @Resource


    private QianYunTongConfig qianYunTongConfig;








@@ -279,8 +287,29 @@


            String name = file.getOriginalFilename();


            name = UUIDUtil.getRandomCode() + name.substring(name.lastIndexOf("."));


//            String s = OBSUtil.putObjectToBucket(inputStream, name);


            String s = OssUploadUtil.ossUpload(file);


            return ResponseWarpper.success(s);


//            String s = OssUploadUtil.ossUpload(file);


            String bucketName = qianYunTongConfig.getBucketName();


            Bucket grjyTest = NCOSSUtil.getBucketInfo(bucketName);


            if (null == grjyTest) {


                //创建桶


                Boolean bucket = NCOSSUtil.createBucket(bucketName);


                if (!bucket) {


                    throw new RuntimeException("创建存储桶失败");


                }


                //设置桶策略


                String policyText = "{\"Version\":\"2025-06-23\",\"Statement\":[{\"Sid\":\"Stmt20250623\",\"Action\":[\"GetObject\"],\"Effect\":\"Allow\",\"Resource\":\"" + bucketName + "/*\",\"Principal\":\"*\"}]}";


                Boolean bucketPolicy = NCOSSUtil.setBucketPolicy(bucketName, policyText);


                if (!bucketPolicy) {


                    throw new RuntimeException("设置桶策略失败");


                }


            }


            //上传对象


            String key = "imgs/daijia/user/" + name;


            String object = NCOSSUtil.putObject(bucketName, key, inputStream);


            if (null == object) {


                throw new RuntimeException("上传图片失败");


            }


            return ResponseWarpper.success("https://traffic.qytzt.cn/v1/AUTH_" + qianYunTongConfig.getAccount() + "/" + bucketName + "/" + key);


        }catch (Exception e){


            e.printStackTrace();


            return new ResponseWarpper(500, e.getMessage());


@@ -448,7 +477,7 @@


    }




    @ResponseBody


    @PostMapping("/api/appUser/queryUsedCouponNum")


    @PostMapping("/api/appUser/queryCheckUsedCouponNum")


    @ApiOperation(value = "获取已使用车检优惠券数量", tags = {"用户端-个人中心(车检)"}, notes = "")


    @ApiImplicitParams({


            @ApiImplicitParam(name = "Authorization", value = "用户token（Bearer +token）", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....")


@@ -624,9 +653,16 @@


            return ResponseWarpper.success(ResultUtil.paranErr("phone"));


        }


        try {


            String numberRandom = UUIDUtil.getNumberRandom(5);


//            SMSUtil.send(phone, "1d0f0cbe5b214b0d8efa891730eb532a", "[\"" + numberRandom + "\"]");


            String sData = aLiSendSms.sendSms(phone,"SMS_154775435", "{\"code\":\"" + numberRandom + "\"}");


            String numberRandom = UUIDUtil.getNumberRandom(4);


            SendSmsRequest request = new SendSmsRequest();


            request.setDestAddress(phone);


            request.setTemplateId("TPL202410290001");


            Map<String, String> templateParams = new HashMap<>();


            templateParams.put("code", numberRandom);


            request.setTemplateParams(templateParams);


            request.setCode("code");


            request.setSpId("T8d5hdfg");


            SMSUtil.sendSms(request);


            redisUtil.setStrValue(receiver + phone, numberRandom, 300);//5分钟有效期


            return ResponseWarpper.success(ResultUtil.success());


        }catch (Exception e){