diff --git a/com.actionsoft.apps.coe.pal/src/com/actionsoft/apps/coe/pal/pal/repository/upfile/dao/UpFileDao.java b/com.actionsoft.apps.coe.pal/src/com/actionsoft/apps/coe/pal/pal/repository/upfile/dao/UpFileDao.java index 89e1e906..2c7488ad 100755 --- a/com.actionsoft.apps.coe.pal/src/com/actionsoft/apps/coe/pal/pal/repository/upfile/dao/UpFileDao.java +++ b/com.actionsoft.apps.coe.pal/src/com/actionsoft/apps/coe/pal/pal/repository/upfile/dao/UpFileDao.java @@ -1,5 +1,6 @@ package com.actionsoft.apps.coe.pal.pal.repository.upfile.dao; +import com.actionsoft.apps.coe.pal.pal.repository.upfile.cache.PALUpfileCache; import com.actionsoft.apps.coe.pal.pal.repository.upfile.model.UpfileModel; import com.actionsoft.bpms.commons.database.RowMapper; import com.actionsoft.bpms.util.DBSql; @@ -45,6 +46,10 @@ public class UpFileDao { } String sql = DBSql.getInsertStatement(UpfileModel.DATABASE_ENTITY, paraMap); result = DBSql.update(sql.toString(), paraMap); + if (result > 0) { + // 更新缓存 + PALUpfileCache.putModel(model); + } return result; } @@ -77,7 +82,11 @@ public class UpFileDao { sql.setCharAt(index, ' '); sql.append("where " + UpfileModel.FIELD_UUID + "=?"); args.add(model.getUuid()); - return DBSql.update(sql.toString(), args.toArray()); + int result = DBSql.update(sql.toString(), args.toArray()); + if (result > 0) { + PALUpfileCache.putModel(model); + } + return result; } public boolean batchInsert(List list) { @@ -105,6 +114,8 @@ public class UpFileDao { prest.addBatch(); } prest.executeBatch(); + //更新缓存 + list.stream().forEach(PALUpfileCache::putModel); conn.commit(); return true; } catch (SQLException e) { @@ -177,6 +188,10 @@ public class UpFileDao { StringBuffer sql = new StringBuffer(); sql.append("delete from ").append(UpfileModel.DATABASE_ENTITY).append(" where id = '" + uuid + "'"); result = DBSql.update(sql.toString()); + if (result > 0) { + // 更新缓存 + PALUpfileCache.removeById(uuid); + } return result; } @@ -185,6 +200,10 @@ public class UpFileDao { StringBuffer sql = new StringBuffer(); sql.append("delete from ").append(UpfileModel.DATABASE_ENTITY).append(" where 1 = 1 ").append(sqlWhere); result = DBSql.update(sql.toString()); + if (result > 0) { + // 更新缓存 + PALUpfileCache.getCache().reload(); + } return result; }