配置kafka

location-rescue-service/src/main/java/com/ai/bss/location/rescue/controller/LocationManagementController.java

@@ -1,12 +1,19 @@
package com.ai.bss.location.rescue.controller;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
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 com.ai.bss.location.rescue.service.impl.LocationManagementServiceImpl;
import com.ai.bss.location.rescue.util.MirrorSendDateUtil;
import com.ai.bss.worker.model.EmployeeTerminalRelaDto;
/**
 * 人员定位管理
@@ -17,6 +24,9 @@ import com.ai.bss.location.rescue.util.MirrorSendDateUtil;
@RequestMapping("/locationManagement")
public class LocationManagementController {
	@Autowired
	LocationManagementServiceImpl locationManagementServiceImpl;
	/**
	 * 推送镜屏数据测试
	 * @param msg
@@ -25,13 +35,25 @@ public class LocationManagementController {
	@ResponseBody
	@RequestMapping(value = "/mirrorSendDataTest", method = RequestMethod.POST)
	public String mirrorSendDataTest(@RequestBody String msg) {
		
		MirrorSendDateUtil.sendData(MirrorSendDateUtil.topic_personnel, msg);
		
		return msg;
	}
	
	
	
	
	/**
	 * 获取已绑定终端的人员列表
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/queryEmployeeBindDeviceList")
	public Map<String, Object> queryEmployeeBindDeviceList() {
		Map<String, Object> result = new HashMap<String, Object>();
		List<EmployeeTerminalRelaDto> resultList = locationManagementServiceImpl.queryEmployeeBindDeviceList();
		result.put("dataList", resultList);
		return result;
	}
}

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/impl/LocationManagementServiceImpl.java

@@ -1,16 +1,34 @@
package com.ai.bss.location.rescue.service.impl;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ai.abc.api.model.CommonRequest;
import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.location.rescue.service.interfaces.LocationManagementService;
import com.ai.bss.worker.model.EmployeeTerminalRelaDto;
import com.ai.bss.worker.service.api.EmployeeTerminalRelaQuery;
@Service
public class LocationManagementServiceImpl implements LocationManagementService {
	Logger logger = LoggerFactory.getLogger(LocationManagementServiceImpl.class);
	@Autowired
	EmployeeTerminalRelaQuery employeeTerminalRelaQuery;
	
	
	@Override
	public List<EmployeeTerminalRelaDto> queryEmployeeBindDeviceList() {
		  String entityId = "0000"; //TODO 组织id
		  //根据组织编码查询该组织下绑定了终端的人员信息, 组织编码为空查询所有人员
		  CommonRequest<String> param = CommonRequest.<String>builder().data(entityId).build();
		  
		  CommonResponse<List<EmployeeTerminalRelaDto>> commonResponse = employeeTerminalRelaQuery.queryIndividualDevRelaByOrgCode(param);
		
		return commonResponse.getData();
	}
	
}	

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/interfaces/LocationManagementService.java

@@ -1,5 +1,9 @@
package com.ai.bss.location.rescue.service.interfaces;
import java.util.List;
import com.ai.bss.worker.model.EmployeeTerminalRelaDto;
/**
 * 人员定位管理
 * @author konghl@asiainfo.com
@@ -7,4 +11,10 @@ package com.ai.bss.location.rescue.service.interfaces;
 */
public interface LocationManagementService {
	/**
	 * 获取已绑定终端的人员列表
	 * @return
	 */
	List<EmployeeTerminalRelaDto> queryEmployeeBindDeviceList();
}

location-rescue-service/src/main/resources/application.properties

@@ -17,6 +17,24 @@ spring.jpa.properties.hibernate.format_sql=true
spring.jpa.properties.hibernate.generate_statistics=false
spring.main.allow-bean-definition-overriding=true
#kafka
spring.kafka.bootstrap-servers=47.105.160.21:9090
spring.kafka.producer.retries=0
spring.kafka.producer.batch-size=16384
spring.kafka.producer.buffer-memory=33554432
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.group-id=spring-boot-demo
spring.kafka.consumer.enable-auto-commit=false
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.properties.session.timeout.ms=60000
spring.kafka.listener.log-container-config=false
spring.kafka.listener.concurrency=5
spring.kafka.listener.ack-mode=manual-immediate
# CACHE
#spring.cache.type=ehcache
#spring.cache.ehcache.config=ehcache.xml