liuqingkun
5 months ago
parent
1ab6d32808
commit
973f3f3373
7 changed files with 391 additions and 811 deletions
@ -1,254 +0,0 @@ |
||||
|
||||
package org.springblade.common.constant; |
||||
|
||||
import org.springblade.core.launch.constant.AppConstant; |
||||
|
||||
import static org.springblade.core.launch.constant.AppConstant.APPLICATION_NAME_PREFIX; |
||||
|
||||
/** |
||||
* 启动常量 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
public interface LauncherConstant { |
||||
|
||||
/** |
||||
* 郵件服務 |
||||
*/ |
||||
String APPLICATION_EMAIL_NAME = APPLICATION_NAME_PREFIX + "email"; |
||||
|
||||
|
||||
String APPLICATION_FLOW_NAME = APPLICATION_NAME_PREFIX + "workflow"; |
||||
|
||||
/** |
||||
* 资产 |
||||
*/ |
||||
String APPLICATION_CAPITAL_NAME = APPLICATION_NAME_PREFIX + "capital"; |
||||
|
||||
/** |
||||
* lims |
||||
*/ |
||||
String APPLICATION_LIMS_NAME = APPLICATION_NAME_PREFIX + "lims"; |
||||
|
||||
/** |
||||
* office |
||||
*/ |
||||
String APPLICATION_OFFICE_NAME = APPLICATION_NAME_PREFIX + "office"; |
||||
/** |
||||
* repair |
||||
*/ |
||||
String APPLICATION_REPAIR_NAME = APPLICATION_NAME_PREFIX + "repair"; |
||||
|
||||
/** |
||||
* monitor |
||||
*/ |
||||
String APPLICATION_MONITOR_NAME = APPLICATION_NAME_PREFIX + "monitor"; |
||||
|
||||
/** |
||||
* iot |
||||
*/ |
||||
String APPLICATION_IOT_NAME = APPLICATION_NAME_PREFIX + "iot"; |
||||
/** |
||||
* xxljob |
||||
*/ |
||||
String APPLICATION_XXLJOB_NAME = APPLICATION_NAME_PREFIX + "xxljob"; |
||||
|
||||
/** |
||||
* xxljob |
||||
*/ |
||||
String APPLICATION_XXLJOB_ADMIN_NAME = APPLICATION_NAME_PREFIX + "xxljob-admin"; |
||||
|
||||
/** |
||||
* nacos dev 地址 |
||||
*/ |
||||
// String NACOS_DEV_ADDR = "172.29.14.103:8848"; |
||||
String NACOS_DEV_ADDR = "127.0.0.1:8848"; |
||||
|
||||
//String NACOS_DEV_ADDR = "172.29.14.103:8848"; |
||||
|
||||
/** |
||||
* nacos prod 地址 |
||||
*/ |
||||
String NACOS_PROD_ADDR = "172.30.0.48:8848"; |
||||
|
||||
/** |
||||
* nacos test 地址 |
||||
*/ |
||||
String NACOS_TEST_ADDR = "192.168.1.88:8848"; |
||||
|
||||
/** |
||||
* sentinel dev 地址 |
||||
*/ |
||||
String SENTINEL_DEV_ADDR = "127.0.0.1:8848"; |
||||
|
||||
/** |
||||
* sentinel prod 地址 |
||||
*/ |
||||
String SENTINEL_PROD_ADDR = "172.30.0.58:8858"; |
||||
|
||||
/** |
||||
* sentinel test 地址 |
||||
*/ |
||||
String SENTINEL_TEST_ADDR = "172.30.0.58:8858"; |
||||
|
||||
/** |
||||
* seata dev 地址 |
||||
*/ |
||||
String SEATA_DEV_ADDR = "127.0.0.1:8091"; |
||||
|
||||
/** |
||||
* seata prod 地址 |
||||
*/ |
||||
String SEATA_PROD_ADDR = "172.30.0.68:8091"; |
||||
|
||||
/** |
||||
* seata test 地址 |
||||
*/ |
||||
String SEATA_TEST_ADDR = "172.30.0.68:8091"; |
||||
|
||||
/** |
||||
* zipkin dev 地址 |
||||
*/ |
||||
String ZIPKIN_DEV_ADDR = "http://127.0.0.1:9411"; |
||||
|
||||
/** |
||||
* zipkin prod 地址 |
||||
*/ |
||||
String ZIPKIN_PROD_ADDR = "http://172.30.0.71:9411"; |
||||
|
||||
/** |
||||
* zipkin test 地址 |
||||
*/ |
||||
String ZIPKIN_TEST_ADDR = "http://172.30.0.71:9411"; |
||||
|
||||
/** |
||||
* elk dev 地址 |
||||
*/ |
||||
String ELK_DEV_ADDR = "127.0.0.1:9000"; |
||||
|
||||
/** |
||||
* elk prod 地址 |
||||
*/ |
||||
String ELK_PROD_ADDR = "172.30.0.72:9000"; |
||||
|
||||
/** |
||||
* elk test 地址 |
||||
*/ |
||||
String ELK_TEST_ADDR = "172.30.0.72:9000"; |
||||
|
||||
/** |
||||
* seata file模式 |
||||
*/ |
||||
String FILE_MODE = "file"; |
||||
|
||||
/** |
||||
* seata nacos模式 |
||||
*/ |
||||
String NACOS_MODE = "nacos"; |
||||
|
||||
/** |
||||
* seata default模式 |
||||
*/ |
||||
String DEFAULT_MODE = "default"; |
||||
|
||||
/** |
||||
* seata group后缀 |
||||
*/ |
||||
String GROUP_NAME = "-group"; |
||||
|
||||
/** |
||||
* seata 服务组格式 |
||||
* |
||||
* @param appName 服务名 |
||||
* @return group |
||||
*/ |
||||
static String seataServiceGroup(String appName) { |
||||
return appName.concat(GROUP_NAME); |
||||
} |
||||
|
||||
/** |
||||
* 动态获取nacos地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String nacosAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return NACOS_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return NACOS_TEST_ADDR; |
||||
default: |
||||
return NACOS_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取sentinel地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String sentinelAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return SENTINEL_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return SENTINEL_TEST_ADDR; |
||||
default: |
||||
return SENTINEL_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取seata地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String seataAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return SEATA_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return SEATA_TEST_ADDR; |
||||
default: |
||||
return SEATA_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取zipkin地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String zipkinAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return ZIPKIN_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return ZIPKIN_TEST_ADDR; |
||||
default: |
||||
return ZIPKIN_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取elk地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String elkAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return ELK_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return ELK_TEST_ADDR; |
||||
default: |
||||
return ELK_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -1,254 +0,0 @@ |
||||
|
||||
package org.springblade.common.constant; |
||||
|
||||
import org.springblade.core.launch.constant.AppConstant; |
||||
|
||||
import static org.springblade.core.launch.constant.AppConstant.APPLICATION_NAME_PREFIX; |
||||
|
||||
/** |
||||
* 启动常量 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
public interface LauncherConstant { |
||||
|
||||
/** |
||||
* 郵件服務 |
||||
*/ |
||||
String APPLICATION_EMAIL_NAME = APPLICATION_NAME_PREFIX + "email"; |
||||
|
||||
|
||||
String APPLICATION_FLOW_NAME = APPLICATION_NAME_PREFIX + "workflow"; |
||||
|
||||
/** |
||||
* 资产 |
||||
*/ |
||||
String APPLICATION_CAPITAL_NAME = APPLICATION_NAME_PREFIX + "capital"; |
||||
|
||||
/** |
||||
* lims |
||||
*/ |
||||
String APPLICATION_LIMS_NAME = APPLICATION_NAME_PREFIX + "lims"; |
||||
|
||||
/** |
||||
* office |
||||
*/ |
||||
String APPLICATION_OFFICE_NAME = APPLICATION_NAME_PREFIX + "office"; |
||||
/** |
||||
* repair |
||||
*/ |
||||
String APPLICATION_REPAIR_NAME = APPLICATION_NAME_PREFIX + "repair"; |
||||
|
||||
/** |
||||
* monitor |
||||
*/ |
||||
String APPLICATION_MONITOR_NAME = APPLICATION_NAME_PREFIX + "monitor"; |
||||
|
||||
/** |
||||
* iot |
||||
*/ |
||||
String APPLICATION_IOT_NAME = APPLICATION_NAME_PREFIX + "iot"; |
||||
/** |
||||
* xxljob |
||||
*/ |
||||
String APPLICATION_XXLJOB_NAME = APPLICATION_NAME_PREFIX + "xxljob"; |
||||
|
||||
/** |
||||
* xxljob |
||||
*/ |
||||
String APPLICATION_XXLJOB_ADMIN_NAME = APPLICATION_NAME_PREFIX + "xxljob-admin"; |
||||
|
||||
/** |
||||
* nacos dev 地址 |
||||
*/ |
||||
String NACOS_DEV_ADDR = "172.29.14.103:8848"; |
||||
//String NACOS_DEV_ADDR = "127.0.0.1:8848"; |
||||
|
||||
//String NACOS_DEV_ADDR = "172.29.14.103:8848"; |
||||
|
||||
/** |
||||
* nacos prod 地址 |
||||
*/ |
||||
String NACOS_PROD_ADDR = "172.30.0.48:8848"; |
||||
|
||||
/** |
||||
* nacos test 地址 |
||||
*/ |
||||
String NACOS_TEST_ADDR = "192.168.1.88:8848"; |
||||
|
||||
/** |
||||
* sentinel dev 地址 |
||||
*/ |
||||
String SENTINEL_DEV_ADDR = "127.0.0.1:8848"; |
||||
|
||||
/** |
||||
* sentinel prod 地址 |
||||
*/ |
||||
String SENTINEL_PROD_ADDR = "172.30.0.58:8858"; |
||||
|
||||
/** |
||||
* sentinel test 地址 |
||||
*/ |
||||
String SENTINEL_TEST_ADDR = "172.30.0.58:8858"; |
||||
|
||||
/** |
||||
* seata dev 地址 |
||||
*/ |
||||
String SEATA_DEV_ADDR = "127.0.0.1:8091"; |
||||
|
||||
/** |
||||
* seata prod 地址 |
||||
*/ |
||||
String SEATA_PROD_ADDR = "172.30.0.68:8091"; |
||||
|
||||
/** |
||||
* seata test 地址 |
||||
*/ |
||||
String SEATA_TEST_ADDR = "172.30.0.68:8091"; |
||||
|
||||
/** |
||||
* zipkin dev 地址 |
||||
*/ |
||||
String ZIPKIN_DEV_ADDR = "http://127.0.0.1:9411"; |
||||
|
||||
/** |
||||
* zipkin prod 地址 |
||||
*/ |
||||
String ZIPKIN_PROD_ADDR = "http://172.30.0.71:9411"; |
||||
|
||||
/** |
||||
* zipkin test 地址 |
||||
*/ |
||||
String ZIPKIN_TEST_ADDR = "http://172.30.0.71:9411"; |
||||
|
||||
/** |
||||
* elk dev 地址 |
||||
*/ |
||||
String ELK_DEV_ADDR = "127.0.0.1:9000"; |
||||
|
||||
/** |
||||
* elk prod 地址 |
||||
*/ |
||||
String ELK_PROD_ADDR = "172.30.0.72:9000"; |
||||
|
||||
/** |
||||
* elk test 地址 |
||||
*/ |
||||
String ELK_TEST_ADDR = "172.30.0.72:9000"; |
||||
|
||||
/** |
||||
* seata file模式 |
||||
*/ |
||||
String FILE_MODE = "file"; |
||||
|
||||
/** |
||||
* seata nacos模式 |
||||
*/ |
||||
String NACOS_MODE = "nacos"; |
||||
|
||||
/** |
||||
* seata default模式 |
||||
*/ |
||||
String DEFAULT_MODE = "default"; |
||||
|
||||
/** |
||||
* seata group后缀 |
||||
*/ |
||||
String GROUP_NAME = "-group"; |
||||
|
||||
/** |
||||
* seata 服务组格式 |
||||
* |
||||
* @param appName 服务名 |
||||
* @return group |
||||
*/ |
||||
static String seataServiceGroup(String appName) { |
||||
return appName.concat(GROUP_NAME); |
||||
} |
||||
|
||||
/** |
||||
* 动态获取nacos地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String nacosAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return NACOS_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return NACOS_TEST_ADDR; |
||||
default: |
||||
return NACOS_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取sentinel地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String sentinelAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return SENTINEL_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return SENTINEL_TEST_ADDR; |
||||
default: |
||||
return SENTINEL_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取seata地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String seataAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return SEATA_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return SEATA_TEST_ADDR; |
||||
default: |
||||
return SEATA_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取zipkin地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String zipkinAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return ZIPKIN_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return ZIPKIN_TEST_ADDR; |
||||
default: |
||||
return ZIPKIN_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取elk地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String elkAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return ELK_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return ELK_TEST_ADDR; |
||||
default: |
||||
return ELK_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -1,254 +0,0 @@ |
||||
|
||||
package org.springblade.common.constant; |
||||
|
||||
import org.springblade.core.launch.constant.AppConstant; |
||||
|
||||
import static org.springblade.core.launch.constant.AppConstant.APPLICATION_NAME_PREFIX; |
||||
|
||||
/** |
||||
* 启动常量 |
||||
* |
||||
* @author Chill |
||||
*/ |
||||
public interface LauncherConstant { |
||||
|
||||
/** |
||||
* 郵件服務 |
||||
*/ |
||||
String APPLICATION_EMAIL_NAME = APPLICATION_NAME_PREFIX + "email"; |
||||
|
||||
|
||||
String APPLICATION_FLOW_NAME = APPLICATION_NAME_PREFIX + "workflow"; |
||||
|
||||
/** |
||||
* 资产 |
||||
*/ |
||||
String APPLICATION_CAPITAL_NAME = APPLICATION_NAME_PREFIX + "capital"; |
||||
|
||||
/** |
||||
* lims |
||||
*/ |
||||
String APPLICATION_LIMS_NAME = APPLICATION_NAME_PREFIX + "lims"; |
||||
|
||||
/** |
||||
* office |
||||
*/ |
||||
String APPLICATION_OFFICE_NAME = APPLICATION_NAME_PREFIX + "office"; |
||||
/** |
||||
* repair |
||||
*/ |
||||
String APPLICATION_REPAIR_NAME = APPLICATION_NAME_PREFIX + "repair"; |
||||
|
||||
/** |
||||
* monitor |
||||
*/ |
||||
String APPLICATION_MONITOR_NAME = APPLICATION_NAME_PREFIX + "monitor"; |
||||
|
||||
/** |
||||
* iot |
||||
*/ |
||||
String APPLICATION_IOT_NAME = APPLICATION_NAME_PREFIX + "iot"; |
||||
/** |
||||
* xxljob |
||||
*/ |
||||
String APPLICATION_XXLJOB_NAME = APPLICATION_NAME_PREFIX + "xxljob"; |
||||
|
||||
/** |
||||
* xxljob |
||||
*/ |
||||
String APPLICATION_XXLJOB_ADMIN_NAME = APPLICATION_NAME_PREFIX + "xxljob-admin"; |
||||
|
||||
/** |
||||
* nacos dev 地址 |
||||
*/ |
||||
//String NACOS_DEV_ADDR = "172.29.14.103:8848"; |
||||
String NACOS_DEV_ADDR = "127.0.0.1:8848"; |
||||
|
||||
//String NACOS_DEV_ADDR = "172.29.14.103:8848"; |
||||
|
||||
/** |
||||
* nacos prod 地址 |
||||
*/ |
||||
String NACOS_PROD_ADDR = "172.30.0.48:8848"; |
||||
|
||||
/** |
||||
* nacos test 地址 |
||||
*/ |
||||
String NACOS_TEST_ADDR = "192.168.1.88:8848"; |
||||
|
||||
/** |
||||
* sentinel dev 地址 |
||||
*/ |
||||
String SENTINEL_DEV_ADDR = "127.0.0.1:8848"; |
||||
|
||||
/** |
||||
* sentinel prod 地址 |
||||
*/ |
||||
String SENTINEL_PROD_ADDR = "172.30.0.58:8858"; |
||||
|
||||
/** |
||||
* sentinel test 地址 |
||||
*/ |
||||
String SENTINEL_TEST_ADDR = "172.30.0.58:8858"; |
||||
|
||||
/** |
||||
* seata dev 地址 |
||||
*/ |
||||
String SEATA_DEV_ADDR = "127.0.0.1:8091"; |
||||
|
||||
/** |
||||
* seata prod 地址 |
||||
*/ |
||||
String SEATA_PROD_ADDR = "172.30.0.68:8091"; |
||||
|
||||
/** |
||||
* seata test 地址 |
||||
*/ |
||||
String SEATA_TEST_ADDR = "172.30.0.68:8091"; |
||||
|
||||
/** |
||||
* zipkin dev 地址 |
||||
*/ |
||||
String ZIPKIN_DEV_ADDR = "http://127.0.0.1:9411"; |
||||
|
||||
/** |
||||
* zipkin prod 地址 |
||||
*/ |
||||
String ZIPKIN_PROD_ADDR = "http://172.30.0.71:9411"; |
||||
|
||||
/** |
||||
* zipkin test 地址 |
||||
*/ |
||||
String ZIPKIN_TEST_ADDR = "http://172.30.0.71:9411"; |
||||
|
||||
/** |
||||
* elk dev 地址 |
||||
*/ |
||||
String ELK_DEV_ADDR = "127.0.0.1:9000"; |
||||
|
||||
/** |
||||
* elk prod 地址 |
||||
*/ |
||||
String ELK_PROD_ADDR = "172.30.0.72:9000"; |
||||
|
||||
/** |
||||
* elk test 地址 |
||||
*/ |
||||
String ELK_TEST_ADDR = "172.30.0.72:9000"; |
||||
|
||||
/** |
||||
* seata file模式 |
||||
*/ |
||||
String FILE_MODE = "file"; |
||||
|
||||
/** |
||||
* seata nacos模式 |
||||
*/ |
||||
String NACOS_MODE = "nacos"; |
||||
|
||||
/** |
||||
* seata default模式 |
||||
*/ |
||||
String DEFAULT_MODE = "default"; |
||||
|
||||
/** |
||||
* seata group后缀 |
||||
*/ |
||||
String GROUP_NAME = "-group"; |
||||
|
||||
/** |
||||
* seata 服务组格式 |
||||
* |
||||
* @param appName 服务名 |
||||
* @return group |
||||
*/ |
||||
static String seataServiceGroup(String appName) { |
||||
return appName.concat(GROUP_NAME); |
||||
} |
||||
|
||||
/** |
||||
* 动态获取nacos地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String nacosAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return NACOS_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return NACOS_TEST_ADDR; |
||||
default: |
||||
return NACOS_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取sentinel地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String sentinelAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return SENTINEL_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return SENTINEL_TEST_ADDR; |
||||
default: |
||||
return SENTINEL_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取seata地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String seataAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return SEATA_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return SEATA_TEST_ADDR; |
||||
default: |
||||
return SEATA_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取zipkin地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String zipkinAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return ZIPKIN_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return ZIPKIN_TEST_ADDR; |
||||
default: |
||||
return ZIPKIN_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 动态获取elk地址 |
||||
* |
||||
* @param profile 环境变量 |
||||
* @return addr |
||||
*/ |
||||
static String elkAddr(String profile) { |
||||
switch (profile) { |
||||
case (AppConstant.PROD_CODE): |
||||
return ELK_PROD_ADDR; |
||||
case (AppConstant.TEST_CODE): |
||||
return ELK_TEST_ADDR; |
||||
default: |
||||
return ELK_DEV_ADDR; |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,72 @@ |
||||
|
||||
package org.springblade.lims.service; |
||||
|
||||
|
||||
import org.springblade.lims.excel.ExamineExcel; |
||||
|
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
/** |
||||
* 实验试剂 服务类 |
||||
* |
||||
* @author lqk |
||||
* @date 2026-01-13 9:20 |
||||
*/ |
||||
public interface IExamineReagentService { |
||||
|
||||
/** |
||||
* 获取分组后的实验数据 |
||||
* |
||||
* @param group 分组数量 |
||||
* @param excelData 实验数据 |
||||
* @return key：分组号， value：分组数据 |
||||
*/ |
||||
Map<String, List<ExamineExcel>> getGroupExcelData(int group, List<ExamineExcel> excelData); |
||||
|
||||
// 2010597883441655809 非洲猪瘟病毒阻断ELISA抗体检测试剂盒--青岛立见生物科技有限公司
|
||||
// 2010597883441655810 非洲猪瘟病毒(ASFV)阻断ELISA抗体检测试剂盒--北京鑫康生物技术开发有限公司
|
||||
// 2010597883441655811 非洲猪瘟病毒抗体阻断ELISA检测试剂盒--测易生物
|
||||
// 2010597883512958977 猪伪狂犬病病毒gE蛋白阻断ELISA抗体检测试剂盒--科前生物
|
||||
// 2010597883512958978 猪伪狂犬病病毒gB蛋自阻断ELIA抗体检测试剂盒--科前生物
|
||||
// 2010597883512958979 猪伪狂犬病毒gPI竞争ELISA抗体检测试剂盒--禾旭生物
|
||||
// 2010597883512958980 猪伪狂犬病毒gB竞争ELISA抗体检测试剂盒--禾旭生物
|
||||
// 2010597883512958981 猪瘟病毒ELISA抗体检测试剂盒--深圳市绿诗源生物技术有限公司
|
||||
// 2010597883512958982 猪瘟病毒阻断ELISA抗体检测试剂盒--科前生物 --有相同的
|
||||
// 2010597883512958983 猪瘟病毒间接ELISA抗体检测试剂盒--禾旭生物 --有相同的
|
||||
// 2010597883512958984 猪繁殖与呼吸综合征病毒ELISA抗体检测试剂盒（维伯鑫）--维伯鑫
|
||||
// 2010597883512958985 猪繁殖与呼吸综合征病毒ELISA抗体检测试剂盒（绿诗源）--深圳市绿诗源生物技术有限公司
|
||||
// 2010597883512958986 猪繁殖与呼吸综合征病毒间接ELISA抗体检测试剂盒--禾旭生物 --有相同的
|
||||
// 2010597883512958987 猪繁殖与呼吸综合征病毒ELISA抗体检测试剂盒（测易）--测易生物
|
||||
// 2010597883512958988 猪口蹄疫病毒O型VP1间接ELISA抗体检测试剂盒--洛阳莱普生信息科技有限公司
|
||||
|
||||
/** |
||||
* 数据库ID：2010597883512958989 |
||||
* 试剂名称：禽白血病病毒J亚群ELISA抗体检测试剂盒 |
||||
* 生产厂家：哈尔滨国生生物科技股份有限公司 |
||||
* |
||||
* @param group 填报实验结果的组数，每组9行，12列 |
||||
* @param groupExcelData |
||||
* @param map1 |
||||
* @param list |
||||
*/ |
||||
void reagent2010597883512958989(int group, Map<String, List<ExamineExcel>> groupExcelData, |
||||
Map<String, List<Map<String, Map<String, Object>>>> map1, |
||||
List<Map<String, Object>> list); |
||||
|
||||
/** |
||||
* 数据库ID：2010597883512958990 |
||||
* 试剂名称：禽白血病病毒AB亚群ELISA抗体检测试剂盒 |
||||
* 生产厂家：哈尔滨国生生物科技股份有限公司 |
||||
* |
||||
* @param group 填报实验结果的组数，每组9行，12列 |
||||
* @param groupExcelData |
||||
* @param map1 |
||||
* @param list |
||||
*/ |
||||
void reagent2010597883512958990(int group, Map<String, List<ExamineExcel>> groupExcelData, |
||||
Map<String, List<Map<String, Map<String, Object>>>> map1, |
||||
List<Map<String, Object>> list); |
||||
|
||||
|
||||
} |
||||
@ -0,0 +1,256 @@ |
||||
package org.springblade.lims.service.impl; |
||||
|
||||
import lombok.RequiredArgsConstructor; |
||||
import org.apache.commons.lang.StringUtils; |
||||
import org.springblade.core.log.exception.ServiceException; |
||||
import org.springblade.lims.excel.ExamineExcel; |
||||
import org.springblade.lims.service.IExamineReagentService; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.text.DecimalFormat; |
||||
import java.util.ArrayList; |
||||
import java.util.HashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
/** |
||||
* @author lqk |
||||
* @date 2026-01-13 9:20 |
||||
*/ |
||||
@Service |
||||
@RequiredArgsConstructor |
||||
public class ExamineReagentServiceImpl implements IExamineReagentService { |
||||
private final static DecimalFormat DECIMAL_FORMAT = new DecimalFormat("#0.000"); |
||||
|
||||
@Override |
||||
public Map<String, List<ExamineExcel>> getGroupExcelData(int group, List<ExamineExcel> excelData) { |
||||
Map<String, List<ExamineExcel>> groupExcelData = new HashMap<>(); |
||||
|
||||
for (int i = 0; i < group; i++) { |
||||
List<ExamineExcel> excels = new ArrayList<>(); |
||||
for (int j = i * 8 + i; j < (i + 1) * 8 + i; j++) { |
||||
ExamineExcel excel = excelData.get(j); |
||||
excels.add(excel); |
||||
} |
||||
groupExcelData.put((i + 1) + "", excels); |
||||
} |
||||
|
||||
return groupExcelData; |
||||
} |
||||
|
||||
/** |
||||
* 数据库ID：2010597883512958989 |
||||
* 试剂名称：禽白血病病毒J亚群ELISA抗体检测试剂盒 |
||||
* 生产厂家：哈尔滨国生生物科技股份有限公司 |
||||
* <p> |
||||
* 1. 成立条件: 阳性对照血清OD450nm值均在0.55~1.25之间， 阴性对照血清OD450nm值均＜0.10 |
||||
* 2. 计算方法： S/P值=（待检样品OD450nm值－阴性对照血清平均OD450nm值)/(阳性对照血清平均OD450nm值－阴性对照血清平均OD450nm值) |
||||
* 3. 结果判定: S/P 值≥0.3 时，判为阳性； S/P 值＜0.3 时，判为阴性； |
||||
* |
||||
* @param group 填报实验结果的组数，每组9行，12列 |
||||
* @param groupExcelData |
||||
* @param map1 |
||||
* @param list |
||||
*/ |
||||
@Override |
||||
public void reagent2010597883512958989(int group, Map<String, List<ExamineExcel>> groupExcelData, Map<String, List<Map<String, Map<String, Object>>>> map1, List<Map<String, Object>> list) { |
||||
for (int i = 0; i < group; i++) { |
||||
List<Map<String, Map<String, Object>>> mapList = new ArrayList<>(); |
||||
List<ExamineExcel> excels = groupExcelData.get(i + 1 + ""); |
||||
double negativeVal1 = Double.parseDouble(excels.get(0).getCode1()); |
||||
double negativeVal2 = Double.parseDouble(excels.get(1).getCode1()); |
||||
double positiveVal1 = Double.parseDouble(excels.get(2).getCode1()); |
||||
double positiveVal2 = Double.parseDouble(excels.get(3).getCode1()); |
||||
// 阴性对照平均值
|
||||
double negativeAvg = (negativeVal1 + negativeVal2) / 2; |
||||
// 阳性对照平均值
|
||||
double positiveAvg = (positiveVal1 + positiveVal2) / 2; |
||||
|
||||
// 成立条件校验
|
||||
if (negativeVal1 < 0.10 && negativeVal2 < 0.10 && positiveVal1 >= 0.55 && positiveVal1 <= 1.25 && positiveVal2 >= 0.55 && positiveVal2 <= 1.25) { |
||||
throw new ServiceException("第" + (i + 1) + "板阴阳性对照OD值条件不成立，请修改后重新上传！"); |
||||
} |
||||
|
||||
for (int rowNum = 0; rowNum < excels.size(); rowNum++) { |
||||
// 行标头：前端渲染需要A、B、C....
|
||||
String a = String.valueOf((char) (rowNum + 65)); |
||||
|
||||
//取到一行记录
|
||||
ExamineExcel examineExcel = excels.get(rowNum); |
||||
int fieldsLength = examineExcel.getClass().getDeclaredFields().length - 1; |
||||
|
||||
Map<String, Map<String, Object>> map2 = new HashMap<>(); |
||||
|
||||
String SP = "0.00"; |
||||
for (int colNum = 1; colNum <= fieldsLength; colNum++) { |
||||
String cellVal = getExamineCellData(examineExcel, colNum); |
||||
|
||||
Map<String, Object> mapResult = new HashMap<>(); |
||||
// colNum 是列，rowNum是行 ，我们定义index是一列列的定义
|
||||
int index = (colNum - 1) * 8 + rowNum + 1; |
||||
if (StringUtils.isNotBlank(cellVal)) { |
||||
if (rowNum > 5 || colNum > 1) { |
||||
if (positiveAvg != 0) { |
||||
SP = DECIMAL_FORMAT.format((Double.parseDouble(cellVal) - negativeAvg) / (positiveAvg - negativeAvg)); |
||||
} |
||||
mapResult.put("originResult", cellVal); |
||||
mapResult.put("value", SP); |
||||
mapResult.put("num", "1"); |
||||
if (Double.parseDouble(SP) < 0.3) { |
||||
mapResult.put("result", "阴性"); |
||||
} else { |
||||
mapResult.put("result", "阳性"); |
||||
} |
||||
} else { |
||||
mapResult.put("originResult", cellVal); |
||||
mapResult.put("num", ""); |
||||
} |
||||
} else { |
||||
mapResult.put("originResult", ""); |
||||
mapResult.put("num", ""); |
||||
} |
||||
mapResult.put("order", index + i * 96); |
||||
map2.put(a + colNum, mapResult); |
||||
list.add(mapResult); |
||||
} |
||||
mapList.add(map2); |
||||
} |
||||
|
||||
map1.put("g" + (i + 1), mapList); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 数据库ID：2010597883512958990 |
||||
* 试剂名称：禽白血病病毒AB亚群ELISA抗体检测试剂盒 |
||||
* 生产厂家：哈尔滨国生生物科技股份有限公司 |
||||
* <p> |
||||
* 1. 成立条件: 阳性对照血清OD450nm值均在0.6~1.3之间， 阴性对照血清OD450nm值均＜0.10 |
||||
* 2. 计算方法： S/P值=（待检样品OD450nm值－阴性对照血清平均OD450nm值)/(阳性对照血清平均OD450nm值－阴性对照血清平均OD450nm值) |
||||
* 3. 结果判定: S/P值≥0.2时，判为阳性； S/P值＜0.2时，判为阴性； |
||||
* |
||||
* @param group 填报实验结果的组数，每组9行，12列 |
||||
* @param groupExcelData |
||||
* @param map1 |
||||
* @param list |
||||
*/ |
||||
@Override |
||||
public void reagent2010597883512958990(int group, Map<String, List<ExamineExcel>> groupExcelData, Map<String, List<Map<String, Map<String, Object>>>> map1, List<Map<String, Object>> list) { |
||||
for (int i = 0; i < group; i++) { |
||||
List<Map<String, Map<String, Object>>> mapList = new ArrayList<>(); |
||||
List<ExamineExcel> excels = groupExcelData.get(i + 1 + ""); |
||||
double negativeVal1 = Double.parseDouble(excels.get(0).getCode1()); |
||||
double negativeVal2 = Double.parseDouble(excels.get(1).getCode1()); |
||||
double positiveVal1 = Double.parseDouble(excels.get(2).getCode1()); |
||||
double positiveVal2 = Double.parseDouble(excels.get(3).getCode1()); |
||||
// 阴性对照平均值
|
||||
double negativeAvg = (negativeVal1 + negativeVal2) / 2; |
||||
// 阳性对照平均值
|
||||
double positiveAvg = (positiveVal1 + positiveVal2) / 2; |
||||
|
||||
// 成立条件校验
|
||||
if (negativeVal1 < 0.10 && negativeVal2 < 0.10 && positiveVal1 >= 0.6 && positiveVal1 <= 1.3 && positiveVal2 >= 0.6 && positiveVal2 <= 1.3) { |
||||
throw new ServiceException("第" + (i + 1) + "板阴阳性对照OD值条件不成立，请修改后重新上传！"); |
||||
} |
||||
|
||||
for (int rowNum = 0; rowNum < excels.size(); rowNum++) { |
||||
// 行标头：前端渲染需要A、B、C....
|
||||
String a = String.valueOf((char) (rowNum + 65)); |
||||
|
||||
//取到一行记录
|
||||
ExamineExcel examineExcel = excels.get(rowNum); |
||||
int fieldsLength = examineExcel.getClass().getDeclaredFields().length - 1; |
||||
|
||||
Map<String, Map<String, Object>> map2 = new HashMap<>(); |
||||
|
||||
String SP = "0.00"; |
||||
for (int colNum = 1; colNum <= fieldsLength; colNum++) { |
||||
String cellVal = getExamineCellData(examineExcel, colNum); |
||||
|
||||
Map<String, Object> mapResult = new HashMap<>(); |
||||
// colNum 是列，rowNum是行 ，我们定义index是一列列的定义
|
||||
int index = (colNum - 1) * 8 + rowNum + 1; |
||||
if (StringUtils.isNotBlank(cellVal)) { |
||||
if (rowNum > 5 || colNum > 1) { |
||||
if (positiveAvg != 0) { |
||||
SP = DECIMAL_FORMAT.format((Double.parseDouble(cellVal) - negativeAvg) / (positiveAvg - negativeAvg)); |
||||
} |
||||
mapResult.put("originResult", cellVal); |
||||
mapResult.put("value", SP); |
||||
mapResult.put("num", "1"); |
||||
if (Double.parseDouble(SP) < 0.2) { |
||||
mapResult.put("result", "阴性"); |
||||
} else { |
||||
mapResult.put("result", "阳性"); |
||||
} |
||||
} else { |
||||
mapResult.put("originResult", cellVal); |
||||
mapResult.put("num", ""); |
||||
} |
||||
} else { |
||||
mapResult.put("originResult", ""); |
||||
mapResult.put("num", ""); |
||||
} |
||||
mapResult.put("order", index + i * 96); |
||||
map2.put(a + colNum, mapResult); |
||||
list.add(mapResult); |
||||
} |
||||
mapList.add(map2); |
||||
} |
||||
|
||||
map1.put("g" + (i + 1), mapList); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 获取实验填报数据单个单元格的数据 |
||||
* |
||||
* @param examineExcel 实验数据 |
||||
* @param colNum 列号 |
||||
* @return |
||||
*/ |
||||
private String getExamineCellData(ExamineExcel examineExcel, int colNum) { |
||||
String code; |
||||
switch (colNum) { |
||||
case 1: |
||||
code = examineExcel.getCode1(); |
||||
break; |
||||
case 2: |
||||
code = examineExcel.getCode2(); |
||||
break; |
||||
case 3: |
||||
code = examineExcel.getCode3(); |
||||
break; |
||||
case 4: |
||||
code = examineExcel.getCode4(); |
||||
break; |
||||
case 5: |
||||
code = examineExcel.getCode5(); |
||||
break; |
||||
case 6: |
||||
code = examineExcel.getCode6(); |
||||
break; |
||||
case 7: |
||||
code = examineExcel.getCode7(); |
||||
break; |
||||
case 8: |
||||
code = examineExcel.getCode8(); |
||||
break; |
||||
case 9: |
||||
code = examineExcel.getCode9(); |
||||
break; |
||||
case 10: |
||||
code = examineExcel.getCode10(); |
||||
break; |
||||
case 11: |
||||
code = examineExcel.getCode11(); |
||||
break; |
||||
case 12: |
||||
code = examineExcel.getCode12(); |
||||
break; |
||||
default: |
||||
code = "0"; |
||||
} |
||||
return code; |
||||
} |
||||
} |
||||
Loading…
Reference in new issue