修改项目配置与百分比

ebc-mock-service/src/main/java/com/ai/bss/mock/service/impl/MockProcessImpl.java

    private static final int PORT = 8042;
//    private static String kafkaServers = "47.105.160.21:9090";
    private static String kafkaServers = "10.19.90.34:9090";
   // private static String kafkaServers = "10.19.90.34:9090";
    private static String kafkaServers = "10.1.194.17:9092";
    @Value("${kafka.producer.servers}")
    private static String servers;

ebc-mock-service/src/main/java/com/ai/bss/mock/utils/KafkaProducerConfig.java

    @Value("${kafka.producer.servers:Empty}")
//    private static String servers = "47.105.160.21:9090";
    private static String servers = "10.19.90.34:9090";
    //private static String servers = "10.19.90.34:9090";
    private static String servers = "10.1.194.17:9092";
    @Value("${kafka.producer.retries:0}")
    private  int retries;
    @Value("${kafka.producer.batch.size:4096}")
        }
        return true;
    }
}
}

ebc-mock-service/src/main/resources/application.properties

#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#spring.datasource.username=cmp
#spring.datasource.password=cmp@123
spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
spring.datasource.url=jdbc:mysql://10.1.252.196:3306/energy?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=ebc
spring.datasource.password=ebc@123
spring.datasource.username=root
spring.datasource.password=asdsadadaUda4u!@
# JPA (JpaBaseConfiguration, HibernateJpaAutoConfiguration)
#spring.jpa.database=default
#============== kafka ===================
kafka.consumer.zookeeper.connect=47.105.160.21:2100
kafka.consumer.servers=47.105.160.21:9090
#kafka.consumer.zookeeper.connect=47.105.160.21:2100
#kafka.consumer.servers=47.105.160.21:9090
kafka.consumer.zookeeper.connect=10.1.194.17:2181
kafka.consumer.servers=10.1.194.17:9092
kafka.consumer.enable.auto.commit=true
kafka.consumer.session.timeout=6000
kafka.consumer.auto.commit.interval=100
kafka.consumer.group.id=productMessage
kafka.consumer.concurrency=10
kafka.producer.servers=47.105.160.21:9090
#kafka.producer.servers=47.105.160.21:9090
kafka.producer.servers=10.1.194.17:9092
kafka.producer.retries=0
kafka.producer.batch.size=4096
kafka.producer.linger=1
kafka.producer.buffer.memory=40960
kafka.producer.topic=67message
kafka.producer.topic=67message

ebc-mock-service/src/test/resources/application.properties

#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#spring.datasource.username=comon_frm
#spring.datasource.password=1qaz@WSX
spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?useUnicode=true&ampcharacterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
#spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?useUnicode=true&ampcharacterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
spring.datasource.url=jdbc:mysql://10.1.252.196:3306/energy?useUnicode=true&ampcharacterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=ebc
spring.datasource.password=ebc@123
spring.datasource.username=root
spring.datasource.password=asdsadadaUda4u!@
# JPA (JpaBaseConfiguration, HibernateJpaAutoConfiguration)
#spring.jpa.database=default
# LOGGING
logging.level.com.ai=info
logging.level.org.springframework.data=info
logging.level.org.springframework.data=info

location-rescue-service/src/main/java/com/ai/bss/location/rescue/config/MyCorsFilter.java

    public FilterRegistrationBean mySessionUserFilter(){
        FilterRegistrationBean registrationBean = new FilterRegistrationBean();
        registrationBean.setFilter(new SessionUserFilter());
        registrationBean.setUrlPatterns(Arrays.asList("/*"));
        registrationBean.setUrlPatterns(Arrays.asList("/sfsdafsadf"));
        Map<String, String> initParameters = new HashMap<String,String>();
        initParameters.put("impl-classname","com.ai.sso.external.DefaultPopedomImpl");
        initParameters.put("ALLOWPATH","gif;jpg;jpeg;png;login;checkLogin;genVerificationCode;logout;stomp;");
        registrationBean.setInitParameters(initParameters);
        return registrationBean;
    }
}

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

# DATASOURCE (DataSourceAutoConfiguration & DataSourceProperties)
#spring.datasource.url=jdbc:mysql://localhost:3306/cmp
spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
#spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#spring.datasource.username=ebc
#spring.datasource.password=ebc@123
spring.datasource.url=jdbc:mysql://10.1.252.196:3306/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=ebc
spring.datasource.password=ebc@123
spring.datasource.username=root
spring.datasource.password=asdsadadaUda4u!@
# JPA (JpaBaseConfiguration, HibernateJpaAutoConfiguration)
#spring.jpa.database=default
#kafka
#kafka.bootstrap-servers=47.105.160.21:9090
#http://10.19.90.34:8187/mock/startMackData?sId=26&f=5&topic0=DeviceLocationA&topic1=IndividualAlarmA
kafka.bootstrap-servers=10.19.90.34:9090
kafka.topic.deviceLocation=Topic_IoT_DeviceLocation_1
kafka.topic.alarm=Topic_IoT_IndividualAlarm_1
#kafka.bootstrap-servers=10.19.90.34:9090
kafka.bootstrap-servers=10.1.194.17:9092
kafka.topic.deviceLocation=Topic_IoT_DeviceLocation
kafka.topic.alarm=Topic_IoT_IndividualAlarm
#kafka.topic.deviceLocation=DeviceLocationA
#kafka.topic.alarm=IndividualAlarmA
kafka.producer.batch-size=16785
kafka.listener.poll-timeout=1500
#minio
minio.endpoint=http://10.19.90.34
minio.port=19000
minio.endpoint=http://10.1.194.18
minio.port=9000
minio.accessKey=minioadmin
minio.secretKey=minioadmin
minio.secure=false
# \u5f15\u5165gis\u548ciot\u7684\u914d\u7f6e\u6587\u4ef6
spring.profiles.active=iot,gis
uspa.login.url=http://10.19.90.34:20000/usermng/login
uspa.login.url=http://10.1.194.17:20000/usermng/login
uspa.login.vercode=Hiz#8uAqkjhoPmXu8%aaa
uspa.login.menuUrl=http://10.19.90.34:20000/usermng/process/com.wframe.usermanager.services.impl.QueryMenuByUser
uspa.login.menuUrl=http://10.1.194.17:20000/usermng/process/com.wframe.usermanager.services.impl.QueryMenuByUser

location-rescue-service/src/main/resources/ipu-cache.xml

	       <!-- <server ip="121.42.183.206" port="7104" /> -->
	       <!-- <server ip="121.42.183.206" port="7105" /> -->
	       <!-- <server ip="121.42.183.206" port="7106" /> -->
			<server ip="10.19.90.34" port="6379" />
<!--			<server ip="10.19.90.34" port="6379" />-->
			<server ip="10.1.194.17" port="6379" />
	    </servers>
		<!-- 客户端类型:Jedis,JedisCluster -->
	    <config name="clientType" value="Jedis"/>
	    <!-- 访问redis的密码，可以为空 -->
	    <config name="auth" value="Ipu@321!"/>
	    <config name="auth" value="ebc@redis"/>
	    <!-- redis池的可用连接实例的最大数目，缺省为8 -->
	    <config name="poolSize" value="10"/>
	    <!-- redis池最多有多少个状态为idle(空闲的)的jedis实例，缺省为8,空闲连接大于这个数会进行回收 -->
	    <!-- 出现异常最大重试次数 -->
	    <config name="maxAttempts"/>
	</cache>
	
	<cache name="SSN_CACHE" type="redis">
		<servers>
	        <!-- 如果不是cluster，则只使用第一个redis -->
	    <!-- 出现异常最大重试次数 -->
	    <config name="maxAttempts"/>
	</cache>
	
	<cache name="client_route" type="redis">
		<servers>
	        <!-- 如果不是cluster，则只使用第一个redis -->
	    <!-- 出现异常最大重试次数 -->
	    <config name="maxAttempts"/>
	</cache>
	
	<cache name="pushServer_route" type="redis">
		<servers>
	        <!-- 如果不是cluster，则只使用第一个redis -->
	    <!-- 出现异常最大重试次数 -->
	    <config name="maxAttempts"/>
	</cache>
</caches>
</caches>

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

TENANT_REGISTER_CLASS=com.ai.customermanager.services.impl.CustRegisterVercodeImpl
##\u8fdc\u7a0b\u7f13\u5b58\u8c03\u7528\u7c7b\uff0c\u8fd9\u4e2a\u7c7b\u5fc5\u987b\u6709\u4e09\u4e2a\u51fd\u6570 
##\u8fdc\u7a0b\u7f13\u5b58\u8c03\u7528\u7c7b\uff0c\u8fd9\u4e2a\u7c7b\u5fc5\u987b\u6709\u4e09\u4e2a\u51fd\u6570
##    public boolean set(String key,String value)
##    public String get(String key)
##    public boolean del(String key);
#redis.single=10.11.20.117:6379
#redis.password=luMZulgbotmo71aa
redis.single=10.19.90.34:6379
redis.password=Ipu@321!
redis.single=10.1.194.17:6379
redis.password=ebc@redis
redis.pool.maxTotal=1000
redis.pool.minIdle=5
SESSION_DEFAULT_VERCODE=Hiz#8uAqkjhoPmXu8%aaa
#\u662f\u5426\u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236 1 \u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236 
#\u662f\u5426\u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236 1 \u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236
is_check_interface=0
USER_LOGIN_AUTH_CLASS=com.wframe.usermanager.services.impl.UserLoginAuthImpl
#USER_LOGIN_AUTH_CLASS=com.wframe.msgmanager.services.impl.UserLoginByTokenImpl
#USER_LOGIN_AUTH_CLASS=com.wframe.msgmanager.services.impl.UserLoginByToken4XblImpl
SIGN_KEY_CODE=TENANT_CODE
SIGN_KEY_CODE=TENANT_CODE

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/model/AlarmIdenResultDto.java

    private String alarmType;
    private String alarmMemo;
    private String alarmEmployeeRoleId;
    private int[] box;
    private double[] box;
}

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/model/FaceIdenResultDto.java

    private int isMatch;
    private int[] box;
    private double[] box;
}

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/service/aiIden/ClothingCodeAiIden.java

					idenResultDto.setAlarmType("");
					idenResultDto.setAlarmMemo("已穿工作服");
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					idenResultDto.setBox(boxIntArr);
					successList.add(idenResultDto);
					idenResultDto.setAlarmType(MonitorManageConsts.AI_ALARM_TYPE_WEA);
					idenResultDto.setAlarmMemo("未穿工作服");
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					idenResultDto.setBox(boxIntArr);
					alarmIdenResultDtosList.add(idenResultDto);

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/service/aiIden/FaceAiIden.java

					BigDecimal score = resultObject.getBigDecimal("score");
					resultDto.setSimi(score.setScale(4, BigDecimal.ROUND_HALF_UP).floatValue());
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					resultDto.setBox(boxIntArr);
					aiIdenLogDto.setIdenResultType(MonitorManageConsts.AI_IDENTIFY_RESULT);
					BigDecimal score = resultObject.getBigDecimal("score");
					resultDto.setSimi(score.setScale(4, BigDecimal.ROUND_HALF_UP).floatValue());
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					resultDto.setBox(boxIntArr);
					aiIdenLogDto.setRelateEmployeeRoleId(faceId);

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/service/aiIden/SafetyHelmetAiIden.java

					idenResultDto.setAlarmType("");
					idenResultDto.setAlarmMemo("已戴安全帽");
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObj.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObj.getJSONArray("box"), imageParam);
					idenResultDto.setBox(boxIntArr);
					successList.add(idenResultDto);
					idenResultDto.setAlarmType(MonitorManageConsts.AI_ALARM_TYPE_WEA);
					idenResultDto.setAlarmMemo("未戴安全帽");
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObj.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObj.getJSONArray("box"), imageParam);
					idenResultDto.setBox(boxIntArr);
					alarmIdenResultDtosList.add(idenResultDto);

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/service/aiIden/SmokeAiIden.java

				idenResultDto.setAlarmMemo("违规吸烟");
				JSONObject resultObj = JSONObject.parseObject(jsonArray.get(i).toString());
				int[] boxIntArr = AiIdenUtils.getBoxArray(resultObj.getJSONArray("box"), imageParam);
				double[] boxIntArr = AiIdenUtils.getBoxArray(resultObj.getJSONArray("box"), imageParam);
				idenResultDto.setBox(boxIntArr);
				alarmIdenResultDtosList.add(idenResultDto);

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/service/aiIden/StrangerAiIden.java

@Slf4j
@Component
public class StrangerAiIden implements AiIdenInterfaces {
	
	@Autowired
	private EbcAiService ebcAiService;
	
    @Autowired
    private KafkaProcess kafkaProcess;
    
	@Override
	public List<AlarmIdenResultDto> executeAiIden(AiIdenLogDto aiIdenLogDto, String filePath,
			Map<String, Integer> imageParam, boolean isHuman) {
			log.info("陌生人识别：没有识别到人......");
			return null;
		}
		
		List<AlarmIdenResultDto> alarmIdenResultDtosList = new ArrayList<AlarmIdenResultDto>();
		
		try {
			log.info("开始AI陌生人识别处理......");
			String aiResponseData = ebcAiService.faceAiRecog(ImageBase64Converter.convertFileToBase64(filePath));
				idenResultDto = new AlarmIdenResultDto();
				JSONObject resultObject = JSONObject.parseObject(resultList.get(i).toString());
				String faceId = resultObject.getString("faceid");
				
				if (StringUtils.isBlank(faceId) || "null".equals(faceId) || "Unknow".equals(faceId)) {
					// 陌生人
					log.debug("陌生人");
					
					idenResultDto.setAlarmEmployeeRoleId(MonitorManageConsts.alarmEmployeeRoleId);
					idenResultDto.setAlarmType(MonitorManageConsts.AI_ALARM_TYPE_STA);
					idenResultDto.setAlarmMemo("陌生人");
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					idenResultDto.setBox(boxIntArr);
					alarmIdenResultDtosList.add(idenResultDto);
					
				}else {
					// 非陌生人
					log.debug("不是陌生人");
					
					idenResultDto.setAlarmEmployeeRoleId(faceId);
					idenResultDto.setAlarmType("");
					idenResultDto.setAlarmMemo("不是陌生人");
					int[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					double[] boxIntArr = AiIdenUtils.getBoxArray(resultObject.getJSONArray("box"), imageParam);
					idenResultDto.setBox(boxIntArr);
					successList.add(idenResultDto);
				}
			}
			
			if (CollectionUtils.isEmpty(alarmIdenResultDtosList)) {
				aiIdenLogDto.setIdenResult(JSON.toJSONString(successList));
				aiIdenLogDto.setIdenResultType(MonitorManageConsts.AI_IDENTIFY_RESULT);
		} catch (Exception e) {
			log.error("陌生人识别AI处理异常:"+e.getMessage());
		}
		
		return alarmIdenResultDtosList;
	}

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/service/impl/KafkaProcessImpl.java

import java.util.Map;
import org.apache.commons.lang.StringUtils;
import org.apache.logging.log4j.util.Strings;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@Slf4j
@Service
public class KafkaProcessImpl implements KafkaProcess {
	
	private static final Logger logger = LoggerFactory.getLogger(KafkaProcessImpl.class);
//    EBC设备tcp连接服务地址
	// private static final int PORT = 8042;
//    private static String kafkaServers = "47.105.160.21:9090";
	private static String kafkaServers = "10.19.90.34:9090";
	//private static String kafkaServers = "10.19.90.34:9090";
	private static String kafkaServers = "10.1.194.17:9092";
	@Value("${kafka.producer.servers}")
	private static String servers;
					: resourceToolInfoMap.get("resourceToolName").toString());
			aiIdenLogDto.setTopic(topicAiTask);
			
			// 代理实现接口
			String className = getClassByAiIdenModel(aiIdenModel);
			Class<?> myClass = Class.forName(className);
			//AiIdenInterfaces proxy = (AiIdenInterfaces) new ProxyFactory(myClass).getProxyInstance();
			
			ProxyFactory proxy = new ProxyFactory(myClass.newInstance());
			//ProxyFactory proxy = new ProxyFactory(SpringApplicationContext.getBean(myClass));
			AiIdenInterfaces aiIdenInterfaces =(AiIdenInterfaces) proxy.Instance();   //获得代理对象
			List<AlarmIdenResultDto> alarmResult = aiIdenInterfaces.executeAiIden(aiIdenLogDto, filePath, imageParam, isHuman);
			
			if (!CollectionUtils.isEmpty(alarmResult)) {
				alarmIdenResultDtosList.addAll(alarmResult);
			}
				if (isHuman){
					aiIdenLogDto = faceAiRecog(aiIdenLogDto, filePath,imageParam);
				}
			
			} else if (MonitorManageConsts.AI_MODEL_SAFETY_HELMET.equals(aiIdenModel)) {
				if (isHuman) {
					aiIdenLogDto = aiHelmetDetect(aiIdenLogDto, filePath,imageParam);
				}
			
			}else if (MonitorManageConsts.AI_MODEL_SMOKE.equals(aiIdenModel)) {
					if (isHuman){
						aiIdenLogDto = smokingDetect(aiIdenLogDto, filePath,imageParam);//吸烟识别
				}
			
			}else if (MonitorManageConsts.AI_MODEL_CLOTHING_CODE.equals(aiIdenModel)) {
					if (isHuman){
						aiIdenLogDto=workClothesDetect(aiIdenLogDto, filePath,imageParam);//工作服识别
					}
				}
			
			else if (MonitorManageConsts.AI_MODEL_INSTRUMENT.equals(aiIdenModel)) {
				aiIdenLogDto=instrumentDetect(aiIdenLogDto,filePath);//仪表识别
			
			} else if (MonitorManageConsts.AI_MODEL_STRANGER.equals(aiIdenModel)){
				if (isHuman) {
					aiIdenLogDto = strangerDetect(aiIdenLogDto, filePath, imageParam);//陌生人识别
				}
			
			} else {
			
			}*/
		}
			aiIdenLogDto.setIdenResultType(MonitorManageConsts.AI_IDENTIFY_RESULT_ALARM);
			aiIdenLogDto.setIdenResult(JSON.toJSONString(alarmIdenResultDtosList));
			aiIdenLogDto.setRelateEmployeeRoleId(MonitorManageConsts.alarmEmployeeRoleId);
			
			log.info("AI识别结果为报警，推送KAFKA消息："+JSONObject.toJSONString(aiIdenLogDto));
			processKafka(aiIdenLogDto.getTopic(), JSONObject.toJSONString(aiIdenLogDto));
			log.info("消息推送完成");
			/*// 安全帽识别
			String aiResponseData = ebcAiService.workClothesDetect(ImageBase64Converter.convertFileToBase64(aifilePath),
					true, true, 0.9f);
			
			JSONObject jsonObject = JSONObject.parseObject(aiResponseData);// JSONUtil.formatJsonStr(aiResponseData);
			if (jsonObject.getString("Status").equals("Ok")) {
				JSONArray jsonoArray = JSONArray.parseArray(jsonObject.getString("Result"));
			}*/
			log.info("开始AI人数识别处理...");
			String aiResponseData = ebcAiService.headDetect(ImageBase64Converter.convertFileToBase64(aifilePath), true,
					0.9f);
			//暂时用安全帽识别判断是否有人
			String aiResponseData = ebcAiService.helmetDetect(ImageBase64Converter.convertFileToBase64(aifilePath),
					Strings.EMPTY, Strings.EMPTY);
			/*String aiResponseData = ebcAiService.headDetect(ImageBase64Converter.convertFileToBase64(aifilePath), true,
					0.9f);*/
			JSONObject jsonObject = JSONObject.parseObject(aiResponseData);
			JSONArray jsonArray = jsonObject.getJSONArray("Result");
			if (!CollectionUtils.isEmpty(jsonArray)) {
		return result.toString();
	}
}

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/utils/AiIdenUtils.java

	 *
	 * @return boxIntArr
	 */
	public static int[] getBoxArray(JSONArray jsonArray, Map<String, Integer> getImageParam) {
	public static double[] getBoxArray(JSONArray jsonArray, Map<String, Integer> getImageParam) {
		if (CollectionUtils.isEmpty(jsonArray) || jsonArray.size() != 4 || CollectionUtils.isEmpty(getImageParam)) {
			return new int[4];
			return new double[4];
		}
		/*int[] boxIntArr=new int[jsonArray.size()];
		    boxIntArr[i] =boxValue.intValue();
		}*/
		int[] boxIntArr = new int[4];
		double[] boxLongArr = new double[4];
		try {
			BigDecimal boxValue = (BigDecimal) jsonArray.get(0);
			boxIntArr[0] = boxValue.divide(new BigDecimal(getImageParam.get("width")), 0, BigDecimal.ROUND_FLOOR)
					.intValue();
			boxLongArr[0] = boxValue.divide(new BigDecimal(getImageParam.get("height")), 4, BigDecimal.ROUND_HALF_UP).doubleValue();
			boxValue = (BigDecimal) jsonArray.get(1);
			boxIntArr[1] = boxValue.divide(new BigDecimal(getImageParam.get("height")), 0, BigDecimal.ROUND_FLOOR)
					.intValue();
			boxLongArr[1] = boxValue.divide(new BigDecimal(getImageParam.get("width")), 4, BigDecimal.ROUND_HALF_UP)
					.doubleValue();
			boxValue = (BigDecimal) jsonArray.get(2);
			boxIntArr[2] = boxValue.divide(new BigDecimal(getImageParam.get("width")), 0, BigDecimal.ROUND_CEILING)
					.intValue();
			boxLongArr[2] = boxValue.divide(new BigDecimal(getImageParam.get("height")), 4, BigDecimal.ROUND_HALF_UP)
					.doubleValue();
			boxValue = (BigDecimal) jsonArray.get(3);
			boxIntArr[3] = boxValue.divide(new BigDecimal(getImageParam.get("height")), 0, BigDecimal.ROUND_CEILING)
					.intValue();
			boxLongArr[3] = boxValue.divide(new BigDecimal(getImageParam.get("width")), 4, BigDecimal.ROUND_HALF_UP)
					.doubleValue();
		} catch (Exception e) {
			log.error("getBoxArray is error: errorMsg=" + e.getMessage() + ", jsonArray=" + jsonArray);
		}
		return boxIntArr;
		return boxLongArr;
	}
	/**
		return result.toString();
	}
}
}

monitor-manage-service/src/main/java/com/ai/bss/monitorManage/utils/KafkaProducerConfig.java

    @Value("${kafka.producer.servers:Empty}")
//    private static String servers = "47.105.160.21:9090";
    private static String servers = "10.19.90.34:9090";
    private static String servers = "10.1.194.17:9092";
    @Value("${kafka.producer.retries:0}")
    private  int retries;
    @Value("${kafka.producer.batch.size:4096}")
        }
        return true;
    }
}
}

monitor-manage-service/src/main/resources/application.properties

#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#spring.datasource.username=comon_frm
#spring.datasource.password=1qaz@WSX
spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
spring.datasource.url=jdbc:mysql://10.1.252.196:3306/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=ebc
spring.datasource.password=ebc@123
spring.datasource.username=root
spring.datasource.password=asdsadadaUda4u!@
# JPA (JpaBaseConfiguration, HibernateJpaAutoConfiguration)
#spring.jpa.database=default
#kafka
#kafka.bootstrap-servers=47.105.160.21:9090
kafka.bootstrap-servers=10.19.90.34:9090
kafka.bootstrap-servers=10.1.194.17:9092
#kafka.topic.deviceLocation=Topic_IoT_DeviceLocation_111
#kafka.topic.alarm=Topic_IoT_IndividualAlarm_111
#kafka.topic.deviceLocation=DeviceLocationA
kafka.listener.poll-timeout=1500
#minio
minio.endpoint=http://10.19.90.34
minio.port=19000
minio.endpoint=http://10.1.194.18
minio.port=9000
minio.accessKey=minioadmin
minio.secretKey=minioadmin
minio.secure=false
logging.level.org.springframework.data=debug
#\u76d1\u63a7\u6587\u4ef6\u5939
camera.filePath=/home/puaiuc/data/DAHUA
#camera.filePath=E:\\data\\DAHUA
camera.filePath=/root/ebc/data/DAHUA
#camera.filePath=D:\\data\\DAHUA
#AI\u05b4\u56fe\u7247
#kafka.topic.aitask=topicTaskTest
#AI\u5931\u8d25\u8bf7\u6c42\u5730\u5740
#ebc.ai.head-det-url=http://10.1.251.211:7001/todo/api/v1.4/control/online/IMAGE/HEAD/PREDICT
ebc.ai.head-det-url=http://10.1.251.211:7001/todo/api/v1.4/control/online/IMAGE/HUMAN/PREDICT
ebc.ai.head-det-url=http://10.1.251.211:7001/todo/api/v1.4/control/online/IMAGE/HEAD/PREDICT
#ebc.ai.head-det-url=http://10.1.251.211:7003/todo/api/v1.4/control/online/IMAGE/HUMAN/PREDICT
ebc.ai.helmet-det-url=http://10.1.251.211:7003/todo/api/v1.4/control/online/IMAGE/HELMET/PREDICT
ebc.ai.smokingdet-url=http://10.1.251.213:5125/smokingdet
ebc.ai.instrument-det-url=http://10.1.251.213:19100/predict
#AI\u4efb\u52a1\u8bf7\u6c42\u5730\u5740
ebc.protection.resource-url=http://10.19.90.34:8018/sp/resourceTool/getResourceToolAllInfo
ebc.protection.resource-url=http://10.1.252.196:8018/sp/resourceTool/getResourceToolAllInfo

monitor-manage-service/src/test/java/com/ai/bss/monitorManage/PictureProcessServiceTest.java

package com.ai.bss.monitorManage;
import com.ai.bss.components.common.util.ImageBase64Converter;
import com.ai.bss.components.ebcai.service.EbcAiService;
import com.ai.bss.monitorManage.service.interfaces.MonitorManageService;
import lombok.extern.slf4j.Slf4j;
import org.apache.logging.log4j.util.Strings;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
    @Autowired
    MonitorManageService pictureProcessService;
    @Autowired
    EbcAiService ebcAiService;
    @Test
    public void loadPictureFromDirectory() throws InterruptedException {
        pictureProcessService.loadPictureFromDirectory();
    }
    @Test
    public void setPictureProcessService11()  {
/*
        String aiResponseData = ebcAiService.workClothesDetect(ImageBase64Converter.convertFileToBase64("D:\\data\\DAHUA\\6L04C6FPAGFD039\\images\\12120210203112625221.jpg"),
                true, true, 0.9f);*/
        String aiResponseData = ebcAiService.faceAiRecog(ImageBase64Converter.convertFileToBase64("D:\\data\\DAHUA\\6L04C6FPAGFD039\\images\\12120210203112625221.jpg"));
        log.info("AI人脸识别结果： " + aiResponseData);
      /* String aiResponseData = ebcAiService.helmetDetect(ImageBase64Converter.convertFileToBase64("D:\\data\\DAHUA\\6L04C6FPAGFD039\\images\\12120210203112625221.jpg"),
                Strings.EMPTY, Strings.EMPTY);*/
      /*String aiResponseData = ebcAiService.headDetect(ImageBase64Converter.convertFileToBase64("D:\\data\\DAHUA\\6L04C6FPAGFD039\\images\\12120210203112625221.jpg"), true,
                0.9f);
*/
     /*   String aiResponseData = ebcAiService.instrumentDetect(ImageBase64Converter.convertFileToBase64("D:\\data\\DAHUA\\6L04C6FPAGFD039\\images\\12120210203112625221111222.jpg"),
                Strings.EMPTY, Strings.EMPTY, Strings.EMPTY);*/
        System.out.println(aiResponseData);
    }
}

monitor-manage-service/src/test/resources/application.properties

spring.application.name=WorkTaskSpec
server.port=8018
server.port=8028
server.servlet.context-path=/sp
server.servlet.context-path=/
# DATASOURCE (DataSourceAutoConfiguration & DataSourceProperties)
#spring.datasource.url=jdbc:mysql://localhost:3306/cmp
#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#spring.datasource.username=comon_frm
#spring.datasource.password=1qaz@WSX
spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
spring.datasource.url=jdbc:mysql://10.1.252.196:3306/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=ebc
spring.datasource.password=ebc@123
spring.datasource.username=root
spring.datasource.password=asdsadadaUda4u!@
# JPA (JpaBaseConfiguration, HibernateJpaAutoConfiguration)
#spring.jpa.database=default
#kafka
#kafka.bootstrap-servers=47.105.160.21:9090
kafka.bootstrap-servers=10.19.90.34:9090
kafka.topic.deviceLocation=Topic_IoT_DeviceLocation_111
kafka.topic.alarm=Topic_IoT_IndividualAlarm_111
kafka.bootstrap-servers=10.1.194.17:9092
#kafka.topic.deviceLocation=Topic_IoT_DeviceLocation_111
#kafka.topic.alarm=Topic_IoT_IndividualAlarm_111
#kafka.topic.deviceLocation=DeviceLocationA
#kafka.topic.alarm=IndividualAlarmA
kafka.producer.batch-size=16785
kafka.listener.poll-timeout=1500
#minio
minio.endpoint=http://10.19.90.34
minio.port=19000
minio.endpoint=http://10.1.194.18
minio.port=9000
minio.accessKey=minioadmin
minio.secretKey=minioadmin
minio.secure=false
minio.bucketHeaderImage=prod-dev
minio.faceAddServiceUrl=http://10.21.10.28:9018/api/face/add
minio.face-del-service-url=http://10.21.10.28:9018/api/face/del
minio.face-recog-service-url=http://10.21.10.28:9018/api/face/recog
#minio.faceAddServiceUrl=http://10.21.10.28:9018/api/face/add
#minio.face-del-service-url=http://10.21.10.28:9018/api/face/del
#minio.face-recog-service-url=http://10.21.10.28:9018/api/face/recog
minio.faceAddServiceUrl=http://10.1.251.211:7002/todo/api/v1.4/control/online/IMAGE/FACE/PREDICT
minio.face-del-service-url=http://10.1.251.211:7002/todo/api/v1.4/control/online/IMAGE/FACE/PREDICT
minio.face-recog-service-url=http://10.1.251.211:7002/todo/api/v1.4/control/online/IMAGE/FACE/PREDICT
minio.face-recog-mincosin-value=0.5
myminio.bucketWorkToolImage=tool-image
myminio.bucketWorkToolView=tool-view
myminio.bucketAiImage=ai-image
myminio.bucketAiVideo=ai-video
# CACHE
#spring.cache.type=ehcache
logging.level.com.ai=debug
logging.level.org.springframework.data=debug
#\u76d1\u63a7\u6587\u4ef6\u5939
camera.filePath=/root/ebc/data/DAHUA
#camera.filePath=D:\\data\\DAHUA
camera.filePath=D:\\resource\\upload\\file\\20200107
#AI\u05b4\u56fe\u7247
#kafka.topic.aitask=topicTaskTest
kafka.topic.aitask=topic_ai_task
#AI\u89c6\u9891
#kafka.topic.aivideo=topicVideoTest
kafka.topic.aivideo=topic_ai_video
#AI\u5931\u8d25\u8bf7\u6c42\u5730\u5740
#ebc.ai.head-det-url=http://10.1.251.211:7001/todo/api/v1.4/control/online/IMAGE/HEAD/PREDICT
ebc.ai.head-det-url=http://10.1.251.211:7001/todo/api/v1.4/control/online/IMAGE/HUMAN/PREDICT
ebc.ai.helmet-det-url=http://10.1.251.211:7003/todo/api/v1.4/control/online/IMAGE/HELMET/PREDICT
ebc.ai.smokingdet-url=http://10.1.251.213:5125/smokingdet
ebc.ai.instrument-det-url=http://10.1.251.213:19100/predict
ebc.ai.work-clothes-det-url=http://10.1.251.211:7003/todo/api/v1.4/control/online/IMAGE/HUMAN/PREDICT
#ebc.ai.face-recog-service-url=http://10.21.10.28:9018/api/face/recog
ebc.ai.face-recog-service-url=http://10.1.251.211:7002/todo/api/v1.4/control/online/IMAGE/FACE/PREDICT
#AI\u4efb\u52a1\u8bf7\u6c42\u5730\u5740
ebc.protection.resource-url=http://localhost:8018/sp/resourceTool/getResourceToolAllInfo

security-protection-service/src/main/java/com/ai/bss/security/protection/config/MyCorsFilter.java

        FilterRegistrationBean registrationBean = new FilterRegistrationBean();
        registrationBean.setFilter(new SessionUserFilter());
        //registrationBean.setUrlPatterns(Arrays.asList("/mySessionUserFilter"));
        registrationBean.setUrlPatterns(Arrays.asList("/login/*"));
        registrationBean.setUrlPatterns(Arrays.asList("/sdfsdafsafasf"));
        Map<String, String> initParameters = new HashMap<String,String>();
        initParameters.put("impl-classname","com.ai.sso.external.DefaultPopedomImpl");
        initParameters.put("ALLOWPATH","gif;jpg;jpeg;png;login;checkLogin;genVerificationCode;logout;");

security-protection-service/src/main/java/com/ai/bss/security/protection/service/impl/LoginServiceImpl.java

            String result = HttpServiceUtil.sendPost(menuUrl, paramsMap, charset,headerMap1 );
            //将返回结果转为map
            logger.error("返回结果json: " + result);
            resultMap = JSON.parseObject(result, Map.class);
            logger.error("返回结果resultMap: " + resultMap.toString());
            String result1 = (String)resultMap.get("RESULT");
            if(null!=result1&&!"".equals(result1)){
                //如果result有值返回正确，将返回结果转为List
                logger.error("返回结果result1: " + result1);
                List<Map<String,List<Map>>> list = JSON.parseObject(result1, List.class);
                logger.error("返回结果list: " + list.toString());
                resultMap.put("RESULT",list);
            }
        } catch (Exception e) {
            logger.error("调用uspa获取菜单接口失败: " + e.getMessage());
            return resultMap;
        }
        return resultMap;
    }
}
}

security-protection-service/src/main/resources/application-minio.properties

#minio
minio.endpoint=http://10.19.90.34
minio.port=19000
minio.endpoint=http://10.1.194.18
minio.port=9000
minio.accessKey=minioadmin
minio.secretKey=minioadmin
minio.secure=false
# \u76d1\u63a7\u89c6\u9891\u622a\u56fe
spminio.bucketAiImage=ai-image
# \u76d1\u63a7\u89c6\u9891\u622a\u56fe
spminio.bucketM3U8=m3u8-index
spminio.bucketM3U8=m3u8-index

security-protection-service/src/main/resources/application.properties

#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#spring.datasource.username=comon_frm
#spring.datasource.password=1qaz@WSX
spring.datasource.url=jdbc:mysql://10.19.90.34:3307/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
spring.datasource.url=jdbc:mysql://10.1.252.196:3306/energy?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&verifyServerCertificate=false&useSSL=false&requireSSL=false
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=ebc
spring.datasource.password=ebc@123
spring.datasource.username=root
spring.datasource.password=asdsadadaUda4u!@
# JPA (JpaBaseConfiguration, HibernateJpaAutoConfiguration)
#spring.jpa.database=default
#kafka
#kafka.bootstrap-servers=47.105.160.21:9090
kafka.bootstrap-servers=10.19.90.34:9090
kafka.bootstrap-servers=10.1.194.17:9092
kafka.topic.aitask=topic_ai_task
kafka.topic.aivideo=topic_ai_video
#kafka.topic.aitask=topicTaskTest
logging.level.com.ai=debug
logging.level.org.springframework.data=debug
uspa.login.url=http://10.19.90.34:20000/usermng/login
uspa.login.url=http://10.1.194.17:20000/usermng/login
uspa.login.vercode=Hiz#8uAqkjhoPmXu8%aaa
uspa.login.menuUrl=http://10.19.90.34:20000/usermng/process/com.wframe.usermanager.services.impl.QueryMenuByUser
uspa.login.menuUrl=http://10.1.194.17:20000/usermng/process/com.wframe.usermanager.services.impl.QueryMenuByUser
        
# \u5f15\u5165minio\u548ciot\u7684\u914d\u7f6e\u6587\u4ef6
spring.profiles.active=iot,minio

security-protection-service/src/main/resources/sso.properties

TENANT_REGISTER_CLASS=com.ai.customermanager.services.impl.CustRegisterVercodeImpl
##\u8fdc\u7a0b\u7f13\u5b58\u8c03\u7528\u7c7b\uff0c\u8fd9\u4e2a\u7c7b\u5fc5\u987b\u6709\u4e09\u4e2a\u51fd\u6570 
##\u8fdc\u7a0b\u7f13\u5b58\u8c03\u7528\u7c7b\uff0c\u8fd9\u4e2a\u7c7b\u5fc5\u987b\u6709\u4e09\u4e2a\u51fd\u6570
##    public boolean set(String key,String value)
##    public String get(String key)
##    public boolean del(String key);
#redis.single=10.11.20.117:6379
#redis.password=luMZulgbotmo71aa
redis.single=10.19.90.34:6379
redis.password=Ipu@321!
redis.single=10.1.194.17:6379
redis.password=ebc@redis
redis.pool.maxTotal=1000
redis.pool.minIdle=5
SESSION_DEFAULT_VERCODE=Hiz#8uAqkjhoPmXu8%aaa
#\u662f\u5426\u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236 1 \u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236 
#\u662f\u5426\u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236 1 \u8fdb\u884c\u63a5\u53e3\u6743\u9650\u63a7\u5236
is_check_interface=0
USER_LOGIN_AUTH_CLASS=com.wframe.usermanager.services.impl.UserLoginAuthImpl
#USER_LOGIN_AUTH_CLASS=com.wframe.msgmanager.services.impl.UserLoginByTokenImpl
#USER_LOGIN_AUTH_CLASS=com.wframe.msgmanager.services.impl.UserLoginByToken4XblImpl
SIGN_KEY_CODE=TENANT_CODE
SIGN_KEY_CODE=TENANT_CODE