基于Java和Lua的分布式微服务网约车项目设计源码

package com.hcy.rabbitbasicutils.beans; import org.apache.commons.lang3.StringUtils; import org.dozer.*; import org.dozer.builder.BuilderUtil; import org.dozer.builder.DestBeanBuilderCreator; import org.dozer.cache.Cache; import org.dozer.cache.CacheKeyFactory; import org.dozer.cache.CacheManager; import org.dozer.cache.DozerCacheType; import org.dozer.classmap.*; import org.dozer.converters.DateFormatContainer; import org.dozer.converters.PrimitiveOrWrapperConverter; import org.dozer.event.DozerEvent; import org.dozer.event.DozerEventManager; import org.dozer.event.DozerEventType; import org.dozer.event.EventManager; import org.dozer.factory.BeanCreationDirective; import org.dozer.factory.DestBeanCreator; import org.dozer.fieldmap.*; import org.dozer.stats.StatisticType; import org.dozer.stats.StatisticsManager; import org.dozer.util.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.lang.reflect.Array; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Modifier; import java.util.*; import java.util.Map.Entry; import static org.dozer.util.DozerConstants.BASE_CLASS; import static org.dozer.util.DozerConstants.ITERATE; public class MappingProcessor implements Mapper { private final Logger log = LoggerFactory.getLogger(MappingProcessor.class); private final ClassMappings classMappings; private final Configuration globalConfiguration; private final List<CustomConverter> customConverterObjects; private final Map<String, CustomConverter> customConverterObjectsWithId; private final StatisticsManager statsMgr; private final EventManager eventMgr; private final CustomFieldMapper customFieldMapper; private final MappedFieldsTracker mappedFields = new MappedFieldsTracker(); private final Cache converterByDestTypeCache; private final Cache superTypeCache; private final PrimitiveOrWrapperConverter primitiveConverter = new PrimitiveOrWrapperConverter(); private final LogMsgFactory logMsgFactory = new LogMsgFactory(); protected MappingProcessor(ClassMappings classMappings, Configuration globalConfiguration, CacheManager cacheMgr, StatisticsManager statsMgr, List<CustomConverter> customConverterObjects, DozerEventManager eventManager, CustomFieldMapper customFieldMapper, Map<String, CustomConverter> customConverterObjectsWithId) { this.classMappings = classMappings; this.globalConfiguration = globalConfiguration; this.statsMgr = statsMgr; this.customConverterObjects = customConverterObjects; this.eventMgr = eventManager; this.customFieldMapper = customFieldMapper; this.converterByDestTypeCache = cacheMgr.getCache(DozerCacheType.CONVERTER_BY_DEST_TYPE.name()); this.superTypeCache = cacheMgr.getCache(DozerCacheType.SUPER_TYPE_CHECK.name()); this.customConverterObjectsWithId = customConverterObjectsWithId; } /* Mapper Interface Implementation */ public <T> T map(final Object srcObj, final Class<T> destClass) { return map(srcObj, destClass, null); } public <T> T map(final Object srcObj, final Class<T> destClass, final String mapId) { MappingValidator.validateMappingRequest(srcObj, destClass); return mapGeneral(srcObj, destClass, null, mapId); } public void map(final Object srcObj, final Object destObj) { map(srcObj, destObj, null); } public void map(final Object srcObj, final Object destObj, final String mapId) { MappingValidator.validateMappingRequest(srcObj, destObj); mapGeneral(srcObj, null, destObj, mapId); } /* End of Mapper Interface Implementation */ /** * Single point of entry for atomic mapping operations * * @param srcObj source object * @param destClass destination class * @param destObj destination object * @param mapId mapping identifier * @param <T> destination object type * @return new or updated destination object */ private <T> T mapGeneral(Object srcObj, final Class<T> destClass, final T destObj, final String mapId) { srcObj = MappingUtils.deProxy(srcObj); Class<T> destType; T result; if (destClass == null) { destType = (Class<T>) destObj.getClass(); result = destObj; } else { destType = destClass; result = null; } ClassMap classMap = null; try { classMap = getClassMap(srcObj.getClass(), destType, mapId); eventMgr.fireEvent(new DozerEvent(DozerEventType.MAPPING_STARTED, classMap, null, srcObj, result, null)); // TODO Check if any proxy issues are here // Check to see if custom converter has been specified for this mapping // combination. If so, just use it. Class<?> converterClass = MappingUtils.findCustomConverter(converterByDestTypeCache, classMap.getCustomConverters(), srcObj .getClass(), destType); if (destObj == null) { // If this is a nested MapperAware conversion this mapping can be already processed // but we can do this optimization only in case of no destObject, instead we must copy to the dest object Object alreadyMappedValue = mappedFields.getMappedValue(srcObj, destType); if (alreadyMappedValue != null) { return (T) alreadyMappedValue; } } if (converterClass != null) { return (T) mapUsingCustomConverter(converterClass, srcObj.getClass(), srcObj, destType, result, null, true); } BeanCreationDirective creationDirective = new BeanCreationDirective(srcObj, classMap.getSrcClassToMap(), classMap.getDestClassToMap(), destType, classMap.getDestClassBeanFactory(), classMap.getDestClassBeanFactoryId(), classMap.getDestClassCreateMethod()); result = createByCreationDirectiveAndMap(creationDirective, classMap, srcObj, result, false, null); } catch (Throwable e) { MappingUtils.throwMappingException(e); } eventMgr.fireEvent(new DozerEvent(DozerEventType.MAPPING_FINISHED, classMap, null, srcObj, result, null)); return result; } /** * Create builder or target object if needed and call * {@link MappingProcessor#mapToDestObject(ClassMap, Object, Object, boolean, String)} function with * arguments {@code classMap}, {@code srcObj}, {@code result}, {@code bypassSuperMappings}, {@code mapId} * @param creationDirective directive for concrete mapping (based mostly on {@code classMap}) * @param classMap class map information for concrete class * @param srcObj source object * @param result target entity for mapping * @param bypassSuperMappings //TODO * @param mapId mapping identifier * @return result or created target entity for mapping */ private <T> T createByCreationDirectiveAndMap(BeanCreationDirective creationDirective, ClassMap classMap, Object srcObj, T result, boolean bypassSuperMappings, String mapId) { if (result == null) { BeanBuilder beanBuilder = DestBeanBuilderCreator.create(creationDirective); if (beanBuilder == null) { result = (T) DestBeanCreator.create(creationDirective); mapToDestObject(classMap, srcObj, result, bypassSuperMappings, mapId); } else { mapToDestObject(classMap, srcObj, beanBuilder, bypassSuperMappings, mapId); result = (T) beanBuilder.build(); } } else { mapToDestObject(classMap, srcObj, result, bypassSuperMappings, mapId); } return result; } /** * This function used to map into created instance of destination class * @param classMap object with mapping configuration * @param srcObj source object * @param de