czt
2025-10-31 8172572f01c0baa527085243e010afa4bec5efcc
src/main/java/com/fzzy/api/view/pr/Api1109PR.java
@@ -5,7 +5,6 @@
import com.bstek.dorado.annotation.Expose;
import com.bstek.dorado.data.provider.Page;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiPushManager;
import com.fzzy.api.service.ApiRemoteService;
@@ -24,13 +23,10 @@
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Component;
import sun.misc.BASE64Encoder;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import java.io.*;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -87,12 +83,12 @@
               predicates.add(predicate2);
            }
            if (null != param.getStart()) {
               Predicate predicate3 = cb.greaterThan(root.<Date>get("qdrq"), ContextUtil.getCurZero(param.getStart()));
               Predicate predicate3 = cb.greaterThan(root.<Date>get("zhgxsj"), ContextUtil.getCurZero(param.getStart()));
               predicates.add(predicate3);
            }
            if (null != param.getEnd()) {
               Predicate predicate4 = cb.lessThan(root.<Date>get("qdrq"), ContextUtil.getNextZero(param.getEnd()));
               Predicate predicate4 = cb.lessThan(root.<Date>get("zhgxsj"), ContextUtil.getNextZero(param.getEnd()));
               predicates.add(predicate4);
            }
            return cb.and(predicates.toArray(new Predicate[0]));
@@ -172,9 +168,6 @@
      ApiRemoteService apiRemoteService = apiPushManager.getApiRemoteService(apiConf.getPushProtocol());
      if (null == apiRemoteService) return "系统没有当前推送协议配置,执行失败";
      if (PushProtocol.SB_SH_2023.getCode().equals(apiConf.getPushProtocol())){
         return pushDataList(items,apiRemoteService,apiConf);
      }
      return pushDataSingle(items,apiRemoteService,apiConf);
   }
@@ -236,141 +229,4 @@
      return responseDto.toString();
   }
   /**
    * imgFile 图片本地存储路径
    */
   public static String getImgFileToBase64(String imgFile) {
      //将图片文件转化为字节数组字符串,并对其进行Base64编码处理
      InputStream inputStream = null;
      byte[] buffer = null;
      //读取图片字节数组
      try {
         inputStream = new FileInputStream(imgFile);
         int count = 0;
         while (count == 0) {
            count = inputStream.available();
         }
         buffer = new byte[count];
         inputStream.read(buffer);
      } catch (IOException e) {
         log.error(e.getMessage(),e);
      } finally {
         if (inputStream != null) {
            try {
               // 关闭inputStream流
               inputStream.close();
            } catch (IOException e) {
               e.printStackTrace();
            }
         }
      }
      // 对字节数组Base64编码
      //return Base64Utils.encodeToString(buffer);
       return new BASE64Encoder().encode(buffer);
   }
   /**
    * 获取图片的二进制流
    * @param imgPath
    * @return
    */
   @SuppressWarnings("resource")
   public String imgToIo(String imgPath){
      //图片转化为二进制
      byte[] imageBytes = null;
      try {
         FileInputStream fileInputStream = new FileInputStream(new File(imgPath));
         imageBytes = new byte[fileInputStream.available()];
         fileInputStream.read(imageBytes);
      } catch (IOException e) {
         System.out.println(e);
         return null;
      }
      return UnicodeByteToStr(imageBytes);
   }
   private static String UnicodeByteToStr(byte[] b){
      StringBuilder sb = new StringBuilder();
      for(int i=0;i<b.length;i++) {
         sb.append(String.format("%02x", b[i]));
      }
      return sb.toString();
   }
   /**
    * 根据文件路径将文件转为二进制数组
    * @param filePath:文件路径
    * @return
    */
   public static byte[] file2byte(String filePath) {
      byte[] buffer = null;
      try {
         File file = new File(filePath);
         FileInputStream fis = new FileInputStream(file);
         ByteArrayOutputStream bos = new ByteArrayOutputStream();
         byte[] b = new byte[1024];
         int n;
         while ((n = fis.read(b)) != -1) {
            bos.write(b, 0, n);
         }
         fis.close();
         bos.close();
         buffer = bos.toByteArray();
      } catch (FileNotFoundException e) {
         e.printStackTrace();
      } catch (IOException e) {
         e.printStackTrace();
      }
      return buffer;
   }
   /**
    * 将二进制数组转为字符串
    * @param b
    * @return
    */
   public static String toHexString(byte[] b) {
      StringBuilder sb = new StringBuilder();
      String stmp="";
      for (int n=0;n<b.length;n++) {
         stmp=(Integer.toHexString(b[n] & 0XFF));
         if (stmp.length()==1) sb.append("0"+stmp);
         else sb.append(stmp);
      }
      return sb.toString().toUpperCase();
   }
   public static void main(String[] args) {
      String hex = toHexString(file2byte("E://91511424746940066Y001.jpg"));
      System.out.println(hex);
      saveToImgFile(hex,"E://dd.jpg");
   }
   public static  void saveToImgFile(String src,String output){
      if(src==null||src.length()==0){
         return;
      }
      try{
         FileOutputStream out = new FileOutputStream(new File(output));
         byte[] bytes = src.getBytes();
         for(int i=0;i<bytes.length;i+=2){
            out.write(charToInt(bytes[i])*16+charToInt(bytes[i+1]));
         }
         out.close();
      }catch(Exception e){
         e.printStackTrace();
      }
   }
   private static int charToInt(byte ch){
      int val = 0;
      if(ch>=0x30&&ch<=0x39){
         val=ch-0x30;
      }else if(ch>=0x41&&ch<=0x46){
         val=ch-0x41+10;
      }
      return val;
   }
}