Mybatis拦截器记录数据更新历史记录到MongoDB

package com.sk.sams.common.mybatis.changemonitor.listener; import java.math.BigDecimal; import java.util.ArrayList; import java.util.Date; import java.util.List; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.time.DateFormatUtils; import org.springframework.data.mongodb.core.MongoOperations; import com.sk.sams.common.HistoryEntry; import com.sk.sams.common.mybatis.changemonitor.domain.ChangeData; import com.sk.sams.common.mybatis.changemonitor.domain.ChangeObject; import com.sk.sams.common.mybatis.changemonitor.domain.PropertyHistory; import com.sk.sams.share.SamsConstants; import com.sk.sams.util.IpUtil; import com.sk.sams.util.RandomCodeUtil; import com.sk.sams.util.Tools; import com.sk.sams.util.URLUtil; import com.sk.sams.util.UserUtil; public class DoChangeEventListener implements DoInsertEventListener, DoDeleteEventListener, DoUpdateEventListener { private MongoOperations mongoOperations; @Override public void onPostDelete(List<ChangeData> changeTable) { for (ChangeData changeData : changeTable) { Long entityId = changeData.getEntityId(); HistoryEntry historyEntry = new HistoryEntry(URLUtil.getURL(), entityId, RandomCodeUtil.getRandomCode(), changeData.getTableName(), SamsConstants.OPER_DEL, StringUtils.EMPTY, Tools.obj2Json(changeData.getCurrentEntityMap()), UserUtil.getUserID(), IpUtil.getIp(), DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss.SSS")); mongoOperations.insert(historyEntry); } } @Override public void onPostInsert(List<ChangeData> changeTable) { for (ChangeData changeData : changeTable) { Long entityId = changeData.getEntityId(); HistoryEntry historyEntry = new HistoryEntry(URLUtil.getURL(), entityId, RandomCodeUtil.getRandomCode(), changeData.getTableName(), SamsConstants.OPER_ADD, StringUtils.EMPTY, Tools.obj2Json(changeData.getCurrentEntityMap()), UserUtil.getUserID(), IpUtil.getIp(), DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss.SSS")); mongoOperations.insert(historyEntry); } } @Override public void onPostUpdate(List<ChangeData> changeTable) { for (ChangeData changeData : changeTable) { Long entityId = changeData.getEntityId(); List<ChangeObject> afterColumnList = changeData.getAfterColumnList(); List<ChangeObject> beforeColumnList = changeData.getBeforeColumnList(); List<PropertyHistory> list = new ArrayList<>(); for (ChangeObject beforeChangeObject : beforeColumnList) { PropertyHistory propertyHistory = new PropertyHistory(); String property = beforeChangeObject.getName(); String oldValue = getExactValue(beforeChangeObject.getValue()); propertyHistory.setProperty(property); propertyHistory.setOldVal(oldValue); String newValue = StringUtils.EMPTY; for (ChangeObject afterChangeObject : afterColumnList) { if (StringUtils.equals(property, afterChangeObject.getName())) { newValue = getExactValue(afterChangeObject.getValue()); break; } } if (oldValue != null && !oldValue.equals(newValue)) { propertyHistory.setNewVal(newValue); list.add(propertyHistory); } } if (CollectionUtils.isEmpty(list)) { return; } HistoryEntry historyEntry = new HistoryEntry(URLUtil.getURL(), entityId, RandomCodeUtil.getRandomCode(), changeData.getTableName(), SamsConstants.OPER_UPDATE, Tools.obj2Json(list), Tools.obj2Json(changeData.getCurrentEntityMap()), UserUtil.getUserID(), IpUtil.getIp(), DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss.SSS")); mongoOperations.insert(historyEntry); } } public void setMongoOperations(MongoOperations mongoOperations) { this.mongoOperations = mongoOperations; } private String getExactValue(Object value) { if (value == null) return StringUtils.EMPTY; if (value instanceof Boolean) { boolean flag = Boolean.valueOf(value.toString()).booleanValue(); return flag ? "1" : "0"; } if (value instanceof Number) { return BigDecimal.valueOf((Double.parseDouble(value.toString()))).stripTrailingZeros().toPlainString(); } return value.toString(); } }