需求：有13個表，其中一個主表和12細表，主表用來記錄推送狀態，細表記錄12種病例的詳細信息，現在需要把這12張病例表數據進行數據推送；普通方法需要寫12個方法分別去推送數據然后修改狀態；現在可以通過模塊化思想去封裝通用接口；

通用數據處理方法

  /*** 通用的數據處理方法* @param dataList 數據列表* @param mbType MB類型名稱* @param gType G類型標識* @param dtoClass DTO類類型* @param result 結果列表*/private <T, D> void processMBData(List<T> dataList, String mbType, String gType, Class<D> dtoClass, List<TechBeianBingLiDetail> result) {if (CollUtil.isNotEmpty(dataList)) {dataList.forEach(item -> {try {D dto = BeanUtil.copyProperties(item, dtoClass);BeanUtil.setFieldValue(dto, "timestamp", DateUtil.format(DateUtil.date(), "yyyy/MM/dd HH:mm:ss"));BeanUtil.setFieldValue(dto, "flag", "i");BeanUtil.setFieldValue(dto, "mbid", gType);String jsonRequest = dto.toString();NcisReponseMsg ncisReponseMsg = proxyUtil.postCaseInfo(jsonRequest, mbType + "-" + BeanUtil.getFieldValue(dto, "ZJID"));PushStatusEnum pushStatus = "0".equals(ncisReponseMsg.getFlag())? PushStatusEnum.YI_TUI_SONG: PushStatusEnum.TUI_SONG_SHI_BAI;result.add(new TechBeianBingLiDetail().setBusinessId(String.valueOf(BeanUtil.getFieldValue(dto, "ZJID"))).setPushStatus(pushStatus.getStatus()));} catch (Exception e) {log.error("推送失敗{} data: {}, Error: {}",mbType, JSONUtil.toJsonStr(item), e.getMessage(), e);}});}}

因為我的數據要求json格式為：

[{"ZD":"timestamp","DA":"2020/11/02 21:11:30"}, 
{"ZD":"flag","DA":"i"},
{"ZD":"mbid","DA":"G01"},
{"ZD":"zjid","DA":"xxxx"},
{"ZD":"yyid","DA":"xxxx"},
......
{"ZD":"p1","DA":"123456"}]

因為我寫了一個通用類，重寫tostring方法，這12個病例繼承這個類，并重寫自己的同string方法，通過super.tostring調用父類方法就行；

ToStringIgnore是我自定義的json忽略注解；

ToStringAlias是我自定義的json別名注解；

package org.yunshu.medicaltechnology.proxys;import org.yunshu.medicaltechnology.annotation.ToStringAlias;
import org.yunshu.medicaltechnology.annotation.ToStringIgnore;import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.List;public class BaseDto {@Overridepublic String toString() {List<String> fields = new ArrayList<>();Class<?> clazz = this.getClass();while (clazz != null && clazz != Object.class) {Field[] declaredFields = clazz.getDeclaredFields();for (Field field : declaredFields) {field.setAccessible(true);// 1. 忽略被標記為 @ToStringIgnore 的字段if (field.isAnnotationPresent(ToStringIgnore.class)) {continue;}// 2. 獲取別名String fieldName = field.getName();if (field.isAnnotationPresent(ToStringAlias.class)) {fieldName = field.getAnnotation(ToStringAlias.class).value();}// 3. 讀取字段值并格式化try {Object value = field.get(this);fields.add(formatField(fieldName, value != null ? value.toString() : ""));} catch (IllegalAccessException e) {fields.add(formatField(fieldName, ""));}}clazz = clazz.getSuperclass(); // 處理繼承的字段}return "[" + String.join(", ", fields) + "]";}private String formatField(String fieldName, String fieldValue) {return "{\"ZD\":\"" + fieldName + "\",\"DA\":\"" + fieldValue + "\"}";}
}

最終實現：

   /*** 獲取并處理所有類型的數據* @return 推送成功的記錄數*/@Override@Scheduled(cron = "0 20 0 * * ?")public String insert() {ArrayList<TechBeianBingLiDetail> bo = new ArrayList<>();// 處理MB01數據processMBData(gMapper.getMB01(), "MB01", "G01", NcisCaseInfoG01Dto.class, bo);// 處理MB02數據processMBData(gMapper.getMB02(), "MB02", "G02", NcisCaseInfoG02Dto.class, bo);// 處理MB03數據processMBData(gMapper.getMB03(), "MB03", "G03", NcisCaseInfoG03Dto.class, bo);// 處理MB04數據processMBData(gMapper.getMB04(), "MB04", "G04", NcisCaseInfoG04Dto.class, bo);// 處理MB06數據processMBData(gMapper.getMB06(), "MB06", "G06", NcisCaseInfoG06Dto.class, bo);// 處理MB07數據processMBData(gMapper.getMB07(), "MB07", "G07", NcisCaseInfoG07Dto.class, bo);// 處理MB08數據processMBData(gMapper.getMB08(), "MB08", "G08", NcisCaseInfoG08Dto.class, bo);// 處理MB10數據processMBData(gMapper.getMB10(), "MB10", "G10", NcisCaseInfoG10Dto.class, bo);// 處理MB11數據processMBData(gMapper.getMB11(), "MB11", "G11", NcisCaseInfoG11Dto.class, bo);// 處理MB13數據processMBData(gMapper.getMB13(), "MB13", "G13", NcisCaseInfoG13Dto.class, bo);// 處理MB16數據processMBData(gMapper.getMb16(), "MB16", "G16", NcisCaseInfoG16Dto.class, bo);// 處理MB17數據processMBData(gMapper.getMb17(), "MB17", "G17", NcisCaseInfoG17Dto.class, bo);if(CollUtil.isNotEmpty(bo)){techBeianBingLiDetailMapper.batchUpdatePushStatus(bo);}return String.valueOf(bo.size());}