D-Net

package eu.dnetlib.goldoa.domain;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.databind.type.TypeFactory;

import eu.dnetlib.goldoa.service.dao.UserDAO;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.aspectj.lang.ProceedingJoinPoint;

import org.aspectj.lang.annotation.Around;

import org.aspectj.lang.annotation.Aspect;

import org.aspectj.lang.reflect.MethodSignature;

import org.hibernate.stat.Statistics;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import java.text.DecimalFormat;

import java.text.NumberFormat;

import java.util.List;

/**

 * Created by panagiotis on 8/3/2017.

 */

@Aspect

@Component

public class HIbernateDomainConverter {

    private Log log = LogFactory.getLog(HIbernateDomainConverter.class);

    private final static NumberFormat NF = new DecimalFormat("0.0###");

    @Autowired

    UserDAO ud;

    @Around("execution (java.util.List<Object> eu.dnetlib.goldoa.service.SearchManager.*(..)) ")

    public Object objectListConverter(ProceedingJoinPoint pjp) throws  Throwable{

        List obj = (List) pjp.proceed();

        ObjectMapper mapper = new ObjectMapper();

        if(obj.isEmpty())

            return obj;

        Class returnType = obj.get(0).getClass();

        String json = mapper.writeValueAsString(obj);

        return mapper.readValue(json,TypeFactory.defaultInstance().constructCollectionType(List.class,returnType));

    }

    @Around("execution (java.util.List<eu.dnetlib.goldoa.domain.*> eu.dnetlib.goldoa.service.*Manager.*(..)) ")

    public Object listConverter(ProceedingJoinPoint pjp) throws  Throwable{

        List obj = (List) pjp.proceed();

        ObjectMapper mapper = new ObjectMapper();

        if(obj.isEmpty())

            return obj;

        Class returnType = obj.get(0).getClass();

        String json = mapper.writeValueAsString(obj);

        log.debug(json);

        log.debug(returnType);

        Statistics statistics = (Statistics) ud.getSession().getSessionFactory().getStatistics();

        statistics.setStatisticsEnabled(true);

        long hit0 = statistics.getQueryCacheHitCount();

        long miss0 = statistics.getSecondLevelCacheMissCount();

        Object result = pjp.proceed();

        return mapper.readValue(json,TypeFactory.defaultInstance().constructCollectionType(List.class,returnType));

    }

    @Around("execution (eu.dnetlib.goldoa.domain.* eu.dnetlib.goldoa.service.*Manager.*(..)) ")

    public Object objectConverter(ProceedingJoinPoint pjp) throws Throwable {

        Object obj = pjp.proceed();

        Class returnType = ((MethodSignature) pjp.getSignature()).getMethod().getReturnType();

        ObjectMapper mapper = new ObjectMapper();

        String json = mapper.writeValueAsString(returnType.cast(obj));

        return mapper.readValue(json, returnType);

    }

}