From 217258891f8d90a0586a1d785b9ce72f7e226666 Mon Sep 17 00:00:00 2001 From: fwq <582742538@qq.com> Date: 星期一, 26 十二月 2022 17:38:34 +0800 Subject: [PATCH] 时间工具类 --- src/main/java/com/hx/mybatis/aes/springbean/InitMysqlData.java | 21 ++++++++++++++------- 1 files changed, 14 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/hx/mybatis/aes/springbean/InitMysqlData.java b/src/main/java/com/hx/mybatis/aes/springbean/InitMysqlData.java index d1648b3..4975d2b 100644 --- a/src/main/java/com/hx/mybatis/aes/springbean/InitMysqlData.java +++ b/src/main/java/com/hx/mybatis/aes/springbean/InitMysqlData.java @@ -3,14 +3,13 @@ import com.gitee.sunchenbin.mybatis.actable.annotation.Column; import com.gitee.sunchenbin.mybatis.actable.annotation.Table; import com.hx.common.annotations.MysqlHexAes; -import com.hx.common.dao.CommonMapper; +import com.hx.common.dao.mapper.CommonMapper; import com.hx.common.service.CommonService; import com.hx.exception.ServiceException; import com.hx.mybatisTool.SqlSentence; import com.hx.util.StringUtils; import com.hx.util.mysql.aes.MysqlHexAesTool; -import javax.annotation.PostConstruct; import java.lang.reflect.Field; import java.util.*; import java.util.concurrent.ExecutorService; @@ -21,7 +20,7 @@ /** * 椤圭洰鍚姩灏辨墽琛屽悗灏辨墽琛岃鏂规硶 */ - @PostConstruct + //@PostConstruct 2022-06-17灞忔帀锛屾殏鏃剁敤涓嶄笂 public static void initData(String packPath, CommonService commonService){ //椤圭洰鍚姩鐨勬椂鍊欏~鍏� @@ -76,10 +75,14 @@ for(String fieldName:fieldData.getEncrypFields()){ selectField.append(","+fieldName); } + pageNum = pageNum*pageSize; + sqlSentence.sqlSentence("SELECT "+selectField.toString()+" FROM "+fieldData.getTableName()+" LIMIT "+pageNum+","+pageSize,values); List<Map<String,Object>> list = commonService.selectListMap(CommonMapper.class,sqlSentence); + boolean isUpdate = false; for (Map<String,Object> map:list){ + isUpdate = false; StringBuilder setField = new StringBuilder(); for (Map.Entry<String, Object> entry : map.entrySet()) { String mapKey = entry.getKey(); @@ -97,12 +100,16 @@ setField.append(","); } setField.append(mapKey+" = #{m."+mapKey+"}"); + isUpdate = true; } - values = map; - sqlSentence.sqlSentence("UPDATE "+fieldData.getTableName()+" SET "+setField.toString()+" WHERE "+fieldData.getId()+" = #{m."+fieldData.getId()+"}",values); - if(commonService.updateSentence(sqlSentence)!=1){ - throw new ServiceException("鏇存柊瓒呰繃1鏉★紝鏇存柊澶辫触锛�"); + if(isUpdate){ + values = map; + sqlSentence.sqlSentence("UPDATE "+fieldData.getTableName()+" SET "+setField.toString()+" WHERE "+fieldData.getId()+" = #{m."+fieldData.getId()+"}",values); + + if(commonService.updateSentence(sqlSentence)!=1){ + throw new ServiceException("鏇存柊瓒呰繃1鏉★紝鏇存柊澶辫触锛�"); + } } } -- Gitblit v1.8.0