文件信息接口

pom.xml

@@ -138,6 +138,14 @@
             <version>4.4.10</version>
         </dependency>
 
+
+		<!-- hutool -->
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.8.12</version>
+        </dependency>
+        
         <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
         <dependency>
             <groupId>org.apache.httpcomponents</groupId>

src/main/java/com/chinaitop/depot/gjjsj/mapper/GjjMapper.java

@@ -47,6 +47,8 @@ public interface GjjMapper {
 	Map<String, Object> getCbgmGjjDate(String id);
 	
 	Map<String, Object> getZjGjjDate(String id);
+
+	Map<String, Object> getWjGjjData(String ywId);
 	
 
 

src/main/java/com/chinaitop/depot/gjjsj/mapper/GjjMapper.xml

@@ -780,4 +780,20 @@
 			left join basic_enum e5 on e5.enumid=a.ypdj
     	where a.id = #{id}
     </select>
+    
+    
+    <select id="getWjGjjData" parameterType="java.lang.String" resultType="java.util.Map">
+    		SELECT
+				org_id id,
+				CONCAT(kqbm,'PMT.jpg') wjmc,-- 1文件名称 K
+				kqbm kqdm, -- 2库区代码  K
+				tykqbm tykqbm,-- 3统一库区编码  Y
+				'1' AS wjlx,  -- 4文件类型 K
+				birds_eye tpdz,
+				updatetime zhgxsj-- 6最后更新时间
+			FROM
+				org_info
+		    where 
+			   org_class_id=5318 and org_id = #{id}
+    </select>
 </mapper>

src/main/java/com/chinaitop/mq/dto/jkEnum.java

@@ -42,6 +42,8 @@ public enum jkEnum {
 	
 	wsd("温湿度检测数据",2427,"ODS_UP_WSDJCXXJK"),
 	
+	hcjc("虫害检测",2428,"ODS_UP_CHJCXXJK"),
+	
 	tf("通风作业数据源",2430,"ODS_UP_TFZYXXJK"),
 	
 	xz("熏蒸",2431,"ODS_UP_XZZYXXJK"),

src/main/java/com/chinaitop/mq/sub/MyMessageListener.java

@@ -2,6 +2,7 @@ package com.chinaitop.mq.sub;
 
 import com.chinaitop.depot.common.util.SecureMngr;
 import com.chinaitop.depot.gjjsj.mapper.GjjMapper;
+import com.chinaitop.mq.utils.FileUtil;
 import com.chinaitop.mq.dto.BaseDTO;
 import com.chinaitop.mq.dto.RecevieDTO;
 import com.chinaitop.mq.dto.TestDTO;
@@ -99,11 +100,7 @@ public class MyMessageListener implements MessageListener {
 		
 		Map<String, Object> pjsjmap = new HashMap<>();
     	if(tableName != null && tableName != ""){
-    		if(tableName.equals(jkEnum.dw.getTableName())){//仓储单位信息
-    			
-    			pjsjmap = gjjMapper.getDwGjjDate(ywId);
-    			
-    		}else if(tableName.equals(jkEnum.kq.getTableName())){//库区信息
+    	    if(tableName.equals(jkEnum.kq.getTableName())){//库区信息
     			
     			pjsjmap = gjjMapper.getKqGjjDate(ywId);
     			
@@ -181,6 +178,22 @@ public class MyMessageListener implements MessageListener {
     			
     			pjsjmap = gjjMapper.getZjGjjDate(ywId);
     			
+    		}else if(tableName.equals(jkEnum.hcjc.getTableName())){//害虫检测
+    			
+    		}else if(tableName.equals(jkEnum.wj.getTableName())){//文件信息
+    			
+    			pjsjmap = gjjMapper.getWjGjjData(ywId);
+    			
+    			String url = (String) pjsjmap.get("tpdz");
+    			if(null != url && "" != url && url.length()>0){
+    				String wjl = FileUtil.getBase64Content(url);
+    				pjsjmap.put("wjl", wjl);
+    			}else{
+    				pjsjmap.put("wjl", "");
+    			}
+    			
+    			pjsjmap.remove("tpdz");
+    			
     		}
     		
     		if(!pjsjmap.isEmpty() && pjsjmap != null){

src/main/java/com/chinaitop/mq/utils/FileUtil.java

@@ -0,0 +1,81 @@
+package com.chinaitop.mq.utils;
+
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.util.Base64;
+
+import cn.hutool.http.HttpUtil;
+
+public class FileUtil {
+	/**
+	 * 根据文件路径将文件转为二进制数组
+	 * @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 byteArray
+	 * @return
+	 */
+	public static String toHexString(byte[] byteArray) {
+		if (byteArray == null || byteArray.length < 1)
+			throw new IllegalArgumentException(
+					"this byteArray must not be null or empty");
+
+		final StringBuilder hexString = new StringBuilder();
+		for (int i = 0; i < byteArray.length; i++) {
+			if ((byteArray[i] & 0xff) < 0x10)// 0~F前面不零
+				hexString.append("0");
+			hexString.append(Integer.toHexString(0xFF & byteArray[i]));
+		}
+		return hexString.toString().toLowerCase();
+	}
+	
+	
+	/**
+     * 网络文件转文件流
+     */
+    public static byte[] urlToStream(String url) {
+        return HttpUtil.downloadBytes(url);
+    }
+    
+	/**
+     * 获取Base64编码的字符串
+     *
+     * @param url 网络文件地址
+     * @methodName: getBase64Content
+     * @return: java.lang.String 网络文件地址
+     * @author: ybw
+     * @date: 2024/7/19
+     **/
+    public static String getBase64Content(String url) {
+        byte[] bytes = urlToStream(url);
+        // 将文件内容转换为Base64字符串
+        return Base64.getEncoder().encodeToString(bytes);
+    }
+}