机构编辑库区图片转二进制流

src/main/java/com/chinaitop/depot/system/controller/OrgInfoController.java

@@ -16,6 +16,7 @@ import com.chinaitop.depot.system.service.RoleButtonService;
 import com.chinaitop.depot.system.service.RoleFuncService;
 import com.chinaitop.depot.system.service.RoleInfoService;
 import com.chinaitop.depot.utils.DataSynchronization;
+import com.chinaitop.depot.utils.FileUtil;
 import com.fasterxml.jackson.core.JsonParseException;
 import com.fasterxml.jackson.databind.JsonMappingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -29,6 +30,7 @@ import io.swagger.annotations.ApiOperation;
 
 import org.apache.commons.lang.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RestController;
@@ -70,6 +72,9 @@ public class OrgInfoController {
 	@Resource
 	private RoleButtonService roleButtonService;
 	
+	@Value("${web.upload-path}")
+	private String uploadPath;
+	
 	/**
 	 * 查找组织信息
 	 * @param pageNum 页码
@@ -145,6 +150,12 @@ public class OrgInfoController {
 		ObjectMapper mapper = new ObjectMapper();
 		OrgInfo orgInfo = (OrgInfo)mapper.readValue(orgInfoJson, OrgInfo.class);
         if (orgInfo.getOrgId() == null) {
+        	if(!ObjectUtils.toString(orgInfo.getBirdsEye()).isEmpty()) {
+        		String path = uploadPath+orgInfo.getBirdsEye();
+        		byte[] file2byte = FileUtil.file2byte(path);
+        		String hexString = FileUtil.toHexString(file2byte);
+        		orgInfo.setWjl(hexString);
+        	}
 			orgInfoService.add(orgInfo);
 			//默认给新建的机构创建一个系统管理员角色
 			RoleInfo roleInfo = new RoleInfo();
@@ -161,6 +172,12 @@ public class OrgInfoController {
 			List<ButtonInfo> buttonList = buttonInfoService.queryByExample(exampleButton);
 			roleButtonService.saveForList(roleInfo.getRoleId(), buttonList);
 		} else {
+			if(!ObjectUtils.toString(orgInfo.getBirdsEye()).isEmpty()) {
+        		String path = uploadPath+orgInfo.getBirdsEye();
+        		byte[] file2byte = FileUtil.file2byte(path);
+        		String hexString = FileUtil.toHexString(file2byte);
+        		orgInfo.setWjl(hexString);
+        	}
 			orgInfoService.update(orgInfo);
 		}
         if(5318 == orgInfo.getOrgClassId()) {//粮食企业的级别是在上级行政单位的级别上加2位顺序码
@@ -260,6 +277,28 @@ public class OrgInfoController {
 		}
 	}
 	
+	@RequestMapping("/updateWjl")
+	public Map<String, Object> updateWjl() {
+		Map<String, Object> modelMap = new HashMap<>();
+		OrgInfoExample example = new OrgInfoExample();
+		List<OrgInfo> list = orgInfoService.queryByExample(example);
+		for(OrgInfo orgInfo:list) {
+			if(!ObjectUtils.toString(orgInfo.getBirdsEye()).isEmpty()) {
+				try {
+					String path = uploadPath+orgInfo.getBirdsEye();
+					byte[] file2byte = FileUtil.file2byte(path);
+					String hexString = FileUtil.toHexString(file2byte);
+					orgInfo.setWjl(hexString);
+					orgInfoService.update(orgInfo);
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+        	}
+		}
+		modelMap.put("status", "success");
+		return modelMap;
+	}
+	
 	 //角色
    /* @RequestMapping("/getTreeAreaList")
     public Map<String, Object> getTreeAreaList(HttpServletRequest request) {

src/main/java/com/chinaitop/depot/system/mapper/OrgInfoMapper.xml

@@ -59,6 +59,9 @@
     <result column="level_code" property="levelCode" jdbcType="VARCHAR" />
     <result column="updatetime" property="updateTime" jdbcType="VARCHAR" />
   </resultMap>
+  <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.chinaitop.depot.system.model.OrgInfo">
+    <result column="wjl" jdbcType="LONGVARCHAR" property="wjl" />
+  </resultMap>
   <sql id="Example_Where_Clause" >
     <where >
       <foreach collection="oredCriteria" item="criteria" separator="or" >
@@ -175,7 +178,7 @@
       regist_number, bank_name, account_name, 
       account_number,total_assets,corporate_capacity,
       office_phone,registered_address,mail_box,official_website,
-      house_number,tank_number,depot_property,level_code)
+      house_number,tank_number,depot_property,level_code,wjl)
     values (#{orgId,jdbcType=INTEGER}, #{orgName,jdbcType=VARCHAR}, #{shortName,jdbcType=VARCHAR}, 
       #{orgCode,jdbcType=VARCHAR}, #{orgClassId,jdbcType=INTEGER}, #{companyNature,jdbcType=INTEGER}, 
       #{busiType,jdbcType=INTEGER}, #{address,jdbcType=VARCHAR}, #{contact,jdbcType=VARCHAR}, 
@@ -194,7 +197,7 @@
       #{accountNumber,jdbcType=VARCHAR}, #{totalAssets,jdbcType=INTEGER}, #{corporateCapacity,jdbcType=VARCHAR}, 
       #{officePhone,jdbcType=VARCHAR}, #{registeredAddress,jdbcType=VARCHAR}, #{mailBox,jdbcType=VARCHAR}, 
       #{officialWebsite,jdbcType=VARCHAR}, #{houseNumber,jdbcType=INTEGER}, #{tankNumber,jdbcType=INTEGER}, 
-      #{depotProperty,jdbcType=VARCHAR}, #{levelCode,jdbcType=VARCHAR})
+      #{depotProperty,jdbcType=VARCHAR}, #{levelCode,jdbcType=VARCHAR}, #{wjl,jdbcType=LONGVARCHAR})
   </insert>
   <insert id="insertSelective" parameterType="com.chinaitop.depot.system.model.OrgInfo" useGeneratedKeys="true" keyProperty="orgId">
     insert into org_info
@@ -334,6 +337,9 @@
       <if test="accountNumber != null" >
         account_number,
       </if>
+      <if test="wjl != null">
+        wjl,
+      </if>
     </trim>
     <trim prefix="values (" suffix=")" suffixOverrides="," >
       <if test="orgId != null" >
@@ -471,6 +477,9 @@
       <if test="accountNumber != null" >
         #{accountNumber,jdbcType=VARCHAR},
       </if>
+      <if test="wjl != null">
+        #{wjl,jdbcType=LONGVARCHAR},
+      </if>
     </trim>
   </insert>
   <select id="countByExample" parameterType="com.chinaitop.depot.system.model.OrgInfoExample" resultType="java.lang.Integer" >
@@ -620,6 +629,9 @@
       <if test="record.levelCode != null" >
         level_code = #{record.levelCode,jdbcType=VARCHAR},
       </if>
+      <if test="record.wjl != null">
+        wjl = #{record.wjl,jdbcType=LONGVARCHAR},
+      </if>
     </set>
     <if test="_parameter != null" >
       <include refid="Update_By_Example_Where_Clause" />
@@ -671,7 +683,8 @@
       regist_number = #{record.registNumber,jdbcType=VARCHAR},
       bank_name = #{record.bankName,jdbcType=VARCHAR},
       account_name = #{record.accountName,jdbcType=VARCHAR},
-      account_number = #{record.accountNumber,jdbcType=VARCHAR}
+      account_number = #{record.accountNumber,jdbcType=VARCHAR},
+      wjl = #{record.wjl,jdbcType=LONGVARCHAR}
     <if test="_parameter != null" >
       <include refid="Update_By_Example_Where_Clause" />
     </if>
@@ -841,6 +854,9 @@
       <if test="levelCode != null" >
         level_code = #{levelCode,jdbcType=VARCHAR},
       </if>
+      <if test="wjl != null">
+        wjl = #{wjl,jdbcType=LONGVARCHAR},
+      </if>
     </set>
     where org_id = #{orgId,jdbcType=INTEGER}
   </update>
@@ -899,7 +915,8 @@
       house_number = #{houseNumber,jdbcType=INTEGER},
       tank_number = #{tankNumber,jdbcType=INTEGER},
       depot_property = #{depotProperty,jdbcType=VARCHAR},
-      level_code = #{levelCode,jdbcType=VARCHAR}
+      level_code = #{levelCode,jdbcType=VARCHAR},
+      wjl = #{wjl,jdbcType=LONGVARCHAR}
     where org_id = #{orgId,jdbcType=INTEGER}
   </update>
   <update id="updateOrgLevel" parameterType="map" statementType="CALLABLE" >

src/main/java/com/chinaitop/depot/system/model/OrgInfo.java

@@ -123,6 +123,8 @@ public class OrgInfo implements Serializable {
     
     private Date updateTime;
 
+    private String wjl;
+
     public Integer getOrgId() {
         return orgId;
     }
@@ -578,5 +580,12 @@ public class OrgInfo implements Serializable {
 	public void setUpdateTime(Date updateTime) {
 		this.updateTime = updateTime;
 	}
+
+	public String getWjl() {
+        return wjl;
+    }
 	
+	public void setWjl(String wjl) {
+        this.wjl = wjl == null ? null : wjl.trim();
+    }
 }

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

@@ -0,0 +1,55 @@
+package com.chinaitop.depot.utils;
+
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+
+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();
+	}
+}