Commit 94e37468 authored by Noel Alonso's avatar Noel Alonso
Browse files

Separa base común de controladores tipo data y geo 

De este modo las funcionalidades comunes estarán en RController
y las específicas según su tipo en data y geo
parent dd3b680d

src/main/java/es/redmic/viewlib/common/controller/RController.java

+33 −65
Original line number Diff line number Diff line
@@ -7,35 +7,38 @@ import java.util.HashSet; 
import java.util.Map;

import java.util.Set;



import javax.validation.Valid;



import org.springframework.validation.BindingResult;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestBody;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

import org.springframework.kafka.core.KafkaTemplate;

import org.springframework.kafka.support.SendResult;

import org.springframework.util.concurrent.ListenableFuture;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.ResponseBody;



import es.redmic.brokerlib.avro.common.CommonDTO;

import es.redmic.exception.databinding.DTONotValidException;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.listener.SendListener;

import es.redmic.models.es.common.dto.ElasticSearchDTO;

import es.redmic.models.es.common.dto.SuperDTO;

import es.redmic.models.es.common.model.BaseES;

import es.redmic.models.es.common.query.dto.MgetDTO;

import es.redmic.models.es.common.query.dto.SimpleQueryDTO;

import es.redmic.viewlib.common.dto.MetaDTO;

import es.redmic.viewlib.common.service.IBaseService;



public abstract class RController<TModel extends BaseES<?>, TDTO extends CommonDTO, TQueryDTO extends SimpleQueryDTO> {



	private static Logger logger = LogManager.getLogger();



	@Autowired

	protected KafkaTemplate<String, Event> kafkaTemplate;



	protected Class<TDTO> typeOfTDTO;



	protected Class<TQueryDTO> typeOfTQueryDTO;



	private Set<String> fieldsExcludedOnQuery = new HashSet<String>();

	protected Set<String> fieldsExcludedOnQuery = new HashSet<String>();



	private Map<String, Object> fixedQuery = new HashMap<String, Object>();

	protected Map<String, Object> fixedQuery = new HashMap<String, Object>();



	IBaseService<TModel, TDTO, TQueryDTO> service;
@@ -44,59 +47,6 @@ public abstract class RController<TModel extends BaseES<?>, TDTO extends CommonD 
		defineTypeOfArguments();

	}



	@RequestMapping(value = "", method = RequestMethod.GET)

	@ResponseBody

	public SuperDTO _search(@RequestParam(required = false, value = "fields") String[] fields,

			@RequestParam(required = false, value = "text") String text,

			@RequestParam(required = false, value = "from") Integer from,

			@RequestParam(required = false, value = "size") Integer size) {



		return new ElasticSearchDTO(service.find(fields, text, from, size, fixedQuery, fieldsExcludedOnQuery));

	}



	@RequestMapping(value = "/_search", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _advancedSearch(@Valid @RequestBody TQueryDTO queryDTO, BindingResult bindingResult) {



		if (bindingResult != null && bindingResult.hasErrors())

			throw new DTONotValidException(bindingResult);



		return new ElasticSearchDTO(service.find(queryDTO, fixedQuery, fieldsExcludedOnQuery));

	}



	@RequestMapping(value = "/{id}", method = RequestMethod.GET)

	@ResponseBody

	public SuperDTO _get(@PathVariable("id") String id) {



		MetaDTO<?> response = service.findById(id);

		return new ElasticSearchDTO(response, response.get_source() == null ? 0 : 1);

	}



	@RequestMapping(value = "/_mget", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _mget(@Valid @RequestBody MgetDTO dto, BindingResult errorDto) {



		if (errorDto.hasErrors())

			throw new DTONotValidException(errorDto);



		return new ElasticSearchDTO(service.mget(dto));

	}



	@RequestMapping(value = "/_suggest", method = RequestMethod.GET)

	@ResponseBody

	public SuperDTO _suggest(@RequestParam(required = false, value = "fields") String[] fields,

			@RequestParam("text") String text, @RequestParam(required = false, value = "size") Integer size) {



		return new ElasticSearchDTO(service.suggest(fields, text, size, fixedQuery, fieldsExcludedOnQuery));

	}



	@RequestMapping(value = "/_suggest", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _advancedSuggest(@Valid @RequestBody TQueryDTO queryDTO, BindingResult bindingResult) {



		return new ElasticSearchDTO(service.suggest(queryDTO, fixedQuery, fieldsExcludedOnQuery));

	}



	@RequestMapping(value = { "${controller.mapping.FILTER_SCHEMA}" }, method = RequestMethod.GET)

	@ResponseBody

	public ElasticSearchDTO getFilterSchema() {
@@ -133,4 +83,22 @@ public abstract class RController<TModel extends BaseES<?>, TDTO extends CommonD 
	protected void setFixedQuery(String term, Object value) {

		fixedQuery.put(term, value);

	}



	protected void publishFailedEvent(Event event, String topic) {



		logger.info("sending FailedEvent='{}' to topic='{}'", event, topic);



		ListenableFuture<SendResult<String, Event>> future = kafkaTemplate.send(topic, event.getAggregateId(), event);



		future.addCallback(new SendListener());

	}



	protected void publishConfirmedEvent(Event event, String topic) {



		logger.info("sending ConfirmEvent='{}' to topic='{}'", event, topic);



		ListenableFuture<SendResult<String, Event>> future = kafkaTemplate.send(topic, event.getAggregateId(), event);



		future.addCallback(new SendListener());

	}

}

src/main/java/es/redmic/viewlib/common/controller/RWController.java

deleted100644 → 0
+0 −46
Original line number Diff line number Diff line 
package es.redmic.viewlib.common.controller;



import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

import org.springframework.kafka.core.KafkaTemplate;

import org.springframework.kafka.support.SendResult;

import org.springframework.util.concurrent.ListenableFuture;



import es.redmic.brokerlib.avro.common.CommonDTO;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.brokerlib.listener.SendListener;

import es.redmic.models.es.common.model.BaseES;

import es.redmic.models.es.common.query.dto.SimpleQueryDTO;

import es.redmic.viewlib.common.service.IBaseService;



public abstract class RWController<TModel extends BaseES<?>, TDTO extends CommonDTO, TQueryDTO extends SimpleQueryDTO>

		extends RController<TModel, TDTO, TQueryDTO> {



	private static Logger logger = LogManager.getLogger();



	@Autowired

	protected KafkaTemplate<String, Event> kafkaTemplate;



	public RWController(IBaseService<TModel, TDTO, TQueryDTO> service) {

		super(service);

	}



	protected void publishFailedEvent(Event event, String topic) {



		logger.info("sending FailedEvent='{}' to topic='{}'", event, topic);



		ListenableFuture<SendResult<String, Event>> future = kafkaTemplate.send(topic, event.getAggregateId(), event);



		future.addCallback(new SendListener());

	}



	protected void publishConfirmedEvent(Event event, String topic) {



		logger.info("sending ConfirmEvent='{}' to topic='{}'", event, topic);



		ListenableFuture<SendResult<String, Event>> future = kafkaTemplate.send(topic, event.getAggregateId(), event);



		future.addCallback(new SendListener());

	}

}

src/main/java/es/redmic/viewlib/data/controller/DataController.java

0 → 100644
+86 −0
Original line number Diff line number Diff line 
package es.redmic.viewlib.data.controller;



import javax.validation.Valid;



import org.springframework.validation.BindingResult;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.ResponseBody;



import es.redmic.brokerlib.avro.common.CommonDTO;

import es.redmic.exception.databinding.DTONotValidException;

import es.redmic.models.es.common.dto.ElasticSearchDTO;

import es.redmic.models.es.common.dto.SuperDTO;

import es.redmic.models.es.common.model.BaseES;

import es.redmic.models.es.common.query.dto.MgetDTO;

import es.redmic.models.es.common.query.dto.SimpleQueryDTO;

import es.redmic.viewlib.common.controller.RController;

import es.redmic.viewlib.common.dto.MetaDTO;

import es.redmic.viewlib.data.service.IDataService;



public abstract class DataController<TModel extends BaseES<?>, TDTO extends CommonDTO, TQueryDTO extends SimpleQueryDTO>

		extends RController<TModel, TDTO, TQueryDTO> {



	IDataService<TModel, TDTO, TQueryDTO> service;



	public DataController(IDataService<TModel, TDTO, TQueryDTO> service) {

		super(service);

		this.service = service;

	}



	@RequestMapping(value = "", method = RequestMethod.GET)

	@ResponseBody

	public SuperDTO _search(@RequestParam(required = false, value = "fields") String[] fields,

			@RequestParam(required = false, value = "text") String text,

			@RequestParam(required = false, value = "from") Integer from,

			@RequestParam(required = false, value = "size") Integer size) {



		return new ElasticSearchDTO(service.find(fields, text, from, size, fixedQuery, fieldsExcludedOnQuery));

	}



	@RequestMapping(value = "/_search", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _advancedSearch(@Valid @RequestBody TQueryDTO queryDTO, BindingResult bindingResult) {



		if (bindingResult != null && bindingResult.hasErrors())

			throw new DTONotValidException(bindingResult);



		return new ElasticSearchDTO(service.find(queryDTO, fixedQuery, fieldsExcludedOnQuery));

	}



	@RequestMapping(value = "/{id}", method = RequestMethod.GET)

	@ResponseBody

	public SuperDTO _get(@PathVariable("id") String id) {



		MetaDTO<?> response = service.findById(id);

		return new ElasticSearchDTO(response, response.get_source() == null ? 0 : 1);

	}



	@RequestMapping(value = "/_mget", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _mget(@Valid @RequestBody MgetDTO dto, BindingResult errorDto) {



		if (errorDto.hasErrors())

			throw new DTONotValidException(errorDto);



		return new ElasticSearchDTO(service.mget(dto));

	}



	@RequestMapping(value = "/_suggest", method = RequestMethod.GET)

	@ResponseBody

	public SuperDTO _suggest(@RequestParam(required = false, value = "fields") String[] fields,

			@RequestParam("text") String text, @RequestParam(required = false, value = "size") Integer size) {



		return new ElasticSearchDTO(service.suggest(fields, text, size, fixedQuery, fieldsExcludedOnQuery));

	}



	@RequestMapping(value = "/_suggest", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _advancedSuggest(@Valid @RequestBody TQueryDTO queryDTO, BindingResult bindingResult) {



		return new ElasticSearchDTO(service.suggest(queryDTO, fixedQuery, fieldsExcludedOnQuery));

	}

}

src/main/java/es/redmic/viewlib/geodata/controller/GeoDataController.java

0 → 100644
+70 −0
Original line number Diff line number Diff line 
package es.redmic.viewlib.geodata.controller;



import javax.validation.Valid;



import org.springframework.validation.BindingResult;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.ResponseBody;



import es.redmic.brokerlib.avro.common.CommonDTO;

import es.redmic.exception.databinding.DTONotValidException;

import es.redmic.models.es.common.dto.ElasticSearchDTO;

import es.redmic.models.es.common.dto.SuperDTO;

import es.redmic.models.es.common.model.BaseES;

import es.redmic.models.es.common.query.dto.MgetDTO;

import es.redmic.models.es.common.query.dto.SimpleQueryDTO;

import es.redmic.viewlib.common.controller.RController;

import es.redmic.viewlib.common.dto.MetaDTO;

import es.redmic.viewlib.geodata.service.IGeoDataService;



public class GeoDataController<TModel extends BaseES<?>, TDTO extends CommonDTO, TQueryDTO extends SimpleQueryDTO>

		extends RController<TModel, TDTO, TQueryDTO> {



	IGeoDataService<TModel, TDTO, TQueryDTO> service;



	public GeoDataController(IGeoDataService<TModel, TDTO, TQueryDTO> service) {

		super(service);

		this.service = service;

	}



	@RequestMapping(value = "/{id}", method = RequestMethod.GET)

	@ResponseBody

	public SuperDTO _get(@PathVariable("activityId") String activityId, @PathVariable("id") String id) {



		MetaDTO<?> response = service.findById(id, activityId);

		return new ElasticSearchDTO(response, response.get_source() == null ? 0 : 1);

	}



	@RequestMapping(value = "/_mget", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _mget(@PathVariable("activityId") String activityId, @Valid @RequestBody MgetDTO dto,

			BindingResult errorDto) {



		if (errorDto.hasErrors())

			throw new DTONotValidException(errorDto);



		return new ElasticSearchDTO(service.mget(dto, activityId));

	}



	@RequestMapping(value = "/_suggest", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _advancedSuggest(@PathVariable("activityId") String activityId,

			@Valid @RequestBody TQueryDTO queryDTO, BindingResult bindingResult) {



		return new ElasticSearchDTO(service.suggest(queryDTO, activityId));

	}



	@RequestMapping(value = "/_search", method = RequestMethod.POST)

	@ResponseBody

	public SuperDTO _advancedSearch(@PathVariable("activityId") String activityId,

			@Valid @RequestBody TQueryDTO queryDTO, BindingResult bindingResult) {



		if (bindingResult != null && bindingResult.hasErrors())

			throw new DTONotValidException(bindingResult);



		return new ElasticSearchDTO(service.find(queryDTO, activityId));

	}

}