返利

snowy-plugin/snowy-plugin-biz/src/main/java/vip/xiaonuo/biz/modular/rechargerecord/service/impl/BizRechargeRecordServiceImpl.java

@@ -12,17 +12,20 @@
  */
 package vip.xiaonuo.biz.modular.rechargerecord.service.impl;
 
-import cn.hutool.core.bean.BeanUtil;
+
 import cn.hutool.core.collection.CollStreamUtil;
 import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.io.FileUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.RandomUtil;
-import cn.hutool.core.util.StrUtil;
+import cn.hutool.http.HttpRequest;
+import cn.hutool.http.HttpResponse;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.google.common.collect.Maps;
 import com.wechat.pay.java.core.RSAAutoCertificateConfig;
 import com.wechat.pay.java.core.exception.HttpException;
 import com.wechat.pay.java.core.exception.MalformedMessageException;
@@ -42,24 +45,25 @@ import vip.xiaonuo.auth.core.util.StpLoginUserUtil;
 import vip.xiaonuo.biz.modular.rechargeplanconfig.entity.BizRechargePlanConfig;
 import vip.xiaonuo.biz.modular.rechargeplanconfig.mapper.BizRechargePlanConfigMapper;
 import vip.xiaonuo.biz.modular.rechargerecord.param.*;
-import vip.xiaonuo.biz.modular.recommendrecord.entity.BizRecommendRecord;
 import vip.xiaonuo.biz.modular.recommendrecord.service.BizRecommendRecordService;
 import vip.xiaonuo.biz.modular.user.entity.BizUser;
 import vip.xiaonuo.biz.modular.user.mapper.BizUserMapper;
 import vip.xiaonuo.common.enums.CommonDeleteFlagEnum;
-import vip.xiaonuo.common.enums.CommonSortOrderEnum;
 import vip.xiaonuo.common.exception.CommonException;
 import vip.xiaonuo.common.page.CommonPageRequest;
 import vip.xiaonuo.biz.modular.rechargerecord.entity.BizRechargeRecord;
 import vip.xiaonuo.biz.modular.rechargerecord.mapper.BizRechargeRecordMapper;
 import vip.xiaonuo.biz.modular.rechargerecord.service.BizRechargeRecordService;
-import vip.xiaonuo.common.pojo.CommonEntity;
 import vip.xiaonuo.common.util.CommonCryptogramUtil;
 import vip.xiaonuo.common.util.CommonWxUtil;
 import vip.xiaonuo.common.wx.WxPayConfig;
 
+import java.io.*;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.Base64;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -91,6 +95,7 @@ public class BizRechargeRecordServiceImpl extends ServiceImpl<BizRechargeRecordM
     private SaBaseLoginUserApi loginUserApi;
 
 
+
     @Override
     public Page<BizRechargeRecord> page(BizRechargeRecordPageParam bizRechargeRecordPageParam) {
         QueryWrapper<BizRechargeRecord> queryWrapper = new QueryWrapper<BizRechargeRecord>().checkSqlInjection();
@@ -366,4 +371,43 @@ public class BizRechargeRecordServiceImpl extends ServiceImpl<BizRechargeRecordM
         bizRechargeRecord.setIsPay("2");
         this.updateById(bizRechargeRecord);
     }
+
+    public static void main(String[] args) {
+        CommonWxUtil util = new CommonWxUtil();
+        try {
+            String accessToken = util.getAccessToken();
+            String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+accessToken;
+            Map<String,Object> map = Maps.newHashMap();
+            map.put("page","pages/register/index");
+            map.put("scene","a=1");
+            map.put("check_path","true");
+            map.put("env_version","release");
+            //HttpResponse execute = HttpUtil.createPost(url).body(JSONObject.toJSONString(map)).execute();
+            HttpResponse response = HttpRequest.post(url)
+                    .body(JSONObject.toJSONString(map))
+                    .execute();
+            if (response.isOk()) {
+                // 获取响应的字节流
+                byte[] bytes = response.bodyBytes();
+                if (bytes.length > 0) {
+                    // 转换为 Base64 字符串
+                    System.out.printf("base:"+Base64.getEncoder().encodeToString(bytes));
+                    saveImageToFile(bytes,"D://1.png");
+                } else {
+                    System.out.printf("返回的字节流为空");
+                }
+            } else {
+                // 如果返回状态码不是 200，解析错误信息
+                String errorResponse = response.body();
+                System.out.printf("获取小程序码失败，错误信息：" + errorResponse);
+            }
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public static void saveImageToFile(byte[] imageData, String filePath) throws IOException {
+        Files.write(Paths.get(filePath), imageData);
+        System.out.println("图片已保存至: " + filePath);
+    }
 }