1.application.properties文件部分参数转换成SystemParam数据

王通
1 parent 2f29f5bf
Showing 26 changed files with 739 additions and 679 deletions
src/main/java/com/bsth/Application.java
src/main/java/com/bsth/StartCommand.java
src/main/java/com/bsth/common/SystemParamKeys.java
src/main/java/com/bsth/controller/realcontrol/AdminUtilsController.java
src/main/java/com/bsth/controller/realcontrol/ScheduleRealInfoController.java
src/main/java/com/bsth/data/BasicData.java
src/main/java/com/bsth/data/SystemParamCache.java
src/main/java/com/bsth/data/directive/GatewayHttpUtils.java
src/main/java/com/bsth/data/gpsdata_v2/load/GatewayHttpLoader.java
src/main/java/com/bsth/data/gpsdata_v2/load/SocketClientLoader.java
src/main/java/com/bsth/data/gpsdata_v2/rfid/RfidHttpLoader.java
src/main/java/com/bsth/data/schedule/DayOfSchedule.java
src/main/java/com/bsth/data/schedule/thread/CalcOilThread.java
src/main/java/com/bsth/entity/SystemParam.java
src/main/java/com/bsth/filter/SQLInjectFilter.java
src/main/java/com/bsth/security/SsoConfig.java
src/main/java/com/bsth/service/SystemParamService.java
src/main/java/com/bsth/service/forms/impl/RevenueLoader.java
src/main/java/com/bsth/service/impl/SystemParamServiceImpl.java
src/main/java/com/bsth/service/realcontrol/impl/ScheduleRealInfoServiceImpl.java
 package com.bsth;
+import com.bsth.data.SystemParamCache;
+import com.bsth.service.SystemParamService;
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.SerializationFeature;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
@@ -22,6 +25,9 @@ public class Application extends SpringBootServletInitializer {
 	public static ScheduledExecutorService mainServices = Executors.newScheduledThreadPool(21);
+	@Autowired
+	private SystemParamCache systemParamCache;
+
 	@Override
 	protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
 		return application.sources(Application.class);
-package com.bsth;
-
-
-import com.bsth.security.SecurityMetadataSourceService;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.stereotype.Component;
-
-
-/**
- * 随应用启动运行
- * @author PanZhao
- *
- */
-@Component
-public class StartCommand implements CommandLineRunner{
-
-	Logger logger = LoggerFactory.getLogger(this.getClass());
-	
-	@Autowired
-	SecurityMetadataSourceService invocationSecurityMetadataSourceService;
-	
-	@Override
-	public void run(String... arg0){
-		
-		try {
-			//启动时加载所有资源
-			invocationSecurityMetadataSourceService.loadResourceDefine();
-			
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
-	}
-}
+package com.bsth;
+
+
+import com.bsth.security.SecurityMetadataSourceService;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+
+/**
+ * 随应用启动运行
+ * @author PanZhao
+ *
+ */
+@Component
+public class StartCommand implements CommandLineRunner{
+
+	Logger logger = LoggerFactory.getLogger(this.getClass());
+	
+	@Autowired
+	SecurityMetadataSourceService invocationSecurityMetadataSourceService;
+
+    @Override
+	public void run(String... arg0){
+		
+		try {
+			//启动时加载所有资源
+			invocationSecurityMetadataSourceService.loadResourceDefine();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+}
@@ -6,4 +6,38 @@ package com.bsth.common;
 public class SystemParamKeys {
     public static final String SPECIAL_ROLES = "special.roles";
+
+    public static final String URL_HTTP_GPS_REAL_CACHE = "url.http.gps.real.cache";
+
+    public static final String URL_HTTP_GPS_REAL = "url.http.gps.real";
+
+    public static final String URL_HTTP_DIRECTIVE = "url.http.directive";
+
+    public static final String URL_HTTP_RFID = "url.http.rfid";
+
+    public static final String URL_HTTP_REPORT = "url.http.report.%s";
+
+    public static final String URL_HTTP_TICKETING = "url.http.ticketing";
+
+    public static final String URL_HTTP_DSM_ACK = "url.http.dsm.ack";
+
+    public static final String URL_HTTP_CP_ACK = "url.http.cp.ack";
+
+    public static final String MAIL_ADMIN = "mail.admin";
+
+    public static final String MAIL_WAYBILL = "mail.waybill";
+
+    public static final String ENABLED_FIRST_LAST_GENERATION = "enabled.first.last.generation";
+
+    public static final String ENABLED_FILTER_SQL_INJECTION = "enabled.filter.sql.injection";
+
+    public static final String ENABLED_SSO = "enabled.sso";
+
+    public static final String SSO_SYSTEM_CODE = "sso.system.code";
+
+    public static final String URL_HTTP_SSO_LOGIN = "url.http.sso.login";
+
+    public static final String URL_HTTP_SSO_LOGOUT = "url.http.sso.logout";
+
+    public static final String URL_HTTP_SSO_AUTH = "url.http.sso.auth";
 }
@@ -4,10 +4,15 @@ import ch.qos.logback.classic.Level;
 import ch.qos.logback.classic.LoggerContext;
 import com.bsth.common.ResponseCode;
 import com.bsth.data.BasicData;
+import com.bsth.data.SystemParamCache;
 import com.bsth.data.directive.DayOfDirectives;
 import com.bsth.data.directive.DirectivesPstThread;
+import com.bsth.data.directive.GatewayHttpUtils;
 import com.bsth.data.gpsdata_v2.cache.GeoCacheData;
 import com.bsth.data.gpsdata_v2.handlers.overspeed.OverspeedProcess;
+import com.bsth.data.gpsdata_v2.load.GatewayHttpLoader;
+import com.bsth.data.gpsdata_v2.load.SocketClientLoader;
+import com.bsth.data.gpsdata_v2.rfid.RfidHttpLoader;
 import com.bsth.data.gpsdata_v2.thread.GpsDataLoaderThread;
 import com.bsth.data.msg_queue.DirectivePushQueue;
 import com.bsth.data.msg_queue.WebSocketPushQueue;
@@ -15,7 +20,9 @@ import com.bsth.data.pilot80.PilotReport;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import com.bsth.filter.SQLInjectFilter;
+import com.bsth.security.SsoConfig;
 import com.bsth.service.SectionService;
+import com.bsth.service.SystemParamService;
 import com.bsth.service.schedule.utils.SpringUtils;
 import com.bsth.util.MailUtils;
 import com.bsth.websocket.handler.SendUtils;
@@ -73,6 +80,24 @@ public class AdminUtilsController {
     @Autowired
     private SectionService sectionService;
+    @Autowired
+    private SystemParamService systemParamService;
+
+    @Autowired
+    private SocketClientLoader socketClientLoader;
+
+    @Autowired
+    private GatewayHttpLoader gatewayHttpLoader;
+
+    @Autowired
+    private GatewayHttpUtils gatewayHttpUtils;
+
+    @Autowired
+    private RfidHttpLoader rfidHttpLoader;
+
+    @Autowired
+    private SsoConfig ssoConfig;
+
     /**
      * 出现重复班次的车辆
      *
@@ -274,13 +299,11 @@ public class AdminUtilsController {
         return "error";
     }
-
-
-    @RequestMapping("/changeEmail")
-    public String changeEmail(@RequestParam String email) {
+    @RequestMapping("/refreshBasicAll")
+    public String refreshBasicAll() {
         Map<String, Object> result = new HashMap<>();
         try {
-            mailUtils.setEmailSendToAddress(email);
+            basicDataLoader.loadAllData();
             return "success";
         } catch (Exception e) {
             e.printStackTrace();
@@ -289,11 +312,12 @@ public class AdminUtilsController {
         return "error";
     }
-    @RequestMapping("/viewEmail")
-    public String viewEmail() {
+    @RequestMapping("/setInjectStr")
+    public String setInjectStr(@RequestParam String injectStr) {
         Map<String, Object> result = new HashMap<>();
         try {
-            return mailUtils.getEmailSendToAddress();
+            SQLInjectFilter.setInjStr(injectStr);
+            return "success";
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -301,11 +325,11 @@ public class AdminUtilsController {
         return "error";
     }
-    @RequestMapping("/refreshBasicAll")
-    public String refreshBasicAll() {
-        Map<String, Object> result = new HashMap<>();
+    @RequestMapping("/reloadSystemParam")
+    public String reloadSystemParam() {
         try {
-            basicDataLoader.loadAllData();
+            systemParamService.refresh();
+
             return "success";
         } catch (Exception e) {
             e.printStackTrace();
@@ -314,11 +338,16 @@ public class AdminUtilsController {
         return "error";
     }
-    @RequestMapping("/setInjectStr")
-    public String setInjectStr(@RequestParam String injectStr) {
-        Map<String, Object> result = new HashMap<>();
+    @RequestMapping("/applySystemParam")
+    public String applySystemParam() {
         try {
-            SQLInjectFilter.setInjStr(injectStr);
+            socketClientLoader.afterPropertiesSet();
+            gatewayHttpLoader.afterPropertiesSet();
+            gatewayHttpUtils.afterPropertiesSet();
+            rfidHttpLoader.afterPropertiesSet();
+            ssoConfig.setSystemCode(SystemParamCache.getSsoSystemCode());
+            ssoConfig.setSsoAuthUrl(SystemParamCache.getUrlHttpSsoAuth());
+
             return "success";
         } catch (Exception e) {
             e.printStackTrace();
@@ -327,24 +356,18 @@ public class AdminUtilsController {
         return "error";
     }
-    @RequestMapping("/setSqlInjectEnabled")
-    public String setInjectStr(@RequestParam boolean sqlInjectEnabled) {
-        Map<String, Object> result = new HashMap<>();
+    @RequestMapping("/reloadAndApplySystemParam")
+    public String reloadAndApplySystemParam() {
         try {
-            sqlInjectFilter.setSqlInjectEnabled(sqlInjectEnabled);
-            return "success";
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+            systemParamService.refresh();
-        return "error";
-    }
+            socketClientLoader.afterPropertiesSet();
+            gatewayHttpLoader.afterPropertiesSet();
+            gatewayHttpUtils.afterPropertiesSet();
+            rfidHttpLoader.afterPropertiesSet();
+            ssoConfig.setSystemCode(SystemParamCache.getSsoSystemCode());
+            ssoConfig.setSsoAuthUrl(SystemParamCache.getUrlHttpSsoAuth());
-    @RequestMapping("/reloadSystemParam")
-    public String reloadSystemParam() {
-        Map<String, Object> result = new HashMap<>();
-        try {
-            basicDataLoader.loadSystemParam();
             return "success";
         } catch (Exception e) {
             e.printStackTrace();
@@ -6,6 +6,7 @@ import com.bsth.controller.BaseController;
 import com.bsth.controller.realcontrol.dto.ChangePersonCar;
 import com.bsth.controller.realcontrol.dto.DfsjChange;
 import com.bsth.data.BasicData;
+import com.bsth.data.SystemParamCache;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.data.schedule.edit_logs.service.dto.SchEditInfoDto;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
@@ -28,7 +29,6 @@ import org.joda.time.format.DateTimeFormatter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 import java.io.*;
@@ -50,13 +50,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	@Autowired
 	DayOfSchedule dayOfSchedule;
-	@Value("${dsm.ack.url}")
-	private String dsmUrl;
-
-	@Value("${cp.ack.url}")
-	private String cpUrl;
-
-	@RequestMapping(value = "check_fgs_ascription", method = RequestMethod.POST)
+    @RequestMapping(value = "check_fgs_ascription", method = RequestMethod.POST)
 	public Map<String, Object> checkPCFgsAscription(@RequestParam Long schId, String jGh, String sGh, String nbbm){
 		return scheduleRealInfoService.checkPCFgsAscription(schId, jGh, sGh, nbbm);
 	}
@@ -777,7 +771,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 		InputStream in = null;
 		SysUser user = SecurityUtils.getCurrentUser();
 		DateTimeFormatter fmt = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss");
-		StringBuilder url = new StringBuilder(dsmUrl), uri = new StringBuilder();
+		StringBuilder url = new StringBuilder(SystemParamCache.getUrlHttpDsmAck()), uri = new StringBuilder();
 		HttpURLConnection con = null;
 		try {
 			uri.append("ddyName=").append(URLEncoder.encode(user == null ? "admin" : user.getUserName(), "UTF-8"));
@@ -826,7 +820,7 @@ public class ScheduleRealInfoController extends BaseController&lt;ScheduleRealInfo,
 	public Map<String, Object> ackCp(@RequestParam Map<String, Object> param){
 		Map<String, Object> res = new HashMap<>();
 		BufferedReader br = null;
-		StringBuilder url = new StringBuilder(cpUrl);
+		StringBuilder url = new StringBuilder(SystemParamCache.getUrlHttpCpAck());
 		try {
 			url.append(param.get("id"));
 			CloseableHttpClient httpClient = HttpClientUtils.defaultHttpClient(url.toString());
@@ -105,9 +105,6 @@ public class BasicData {
     // 线路编码_日期 等级
     public static Map<String, String> lineDate2Level;
-
-    private static Map<String, SystemParam> key2param = new HashMap<>();
-
     static Logger logger = LoggerFactory.getLogger(BasicData.class);
     public static String getStationNameByCode(String code, String prefix){
@@ -200,7 +197,6 @@ public class BasicData {
                 logger.info("load geo cache..，");
                 geoCacheData.loadData();
                 station2ParkBuffer.saveAll();
-                loadSystemParam();
                 logger.info("加载基础数据成功！，");
             } catch (Exception e) {
                 logger.error("加载基础数据时出现异常，", e);
@@ -456,25 +452,5 @@ public class BasicData {
         	lineDate2Level = result;
         }
-
-        /**
-         * 加载系统配置参数
-         */
-        public void loadSystemParam() {
-            Map<String, SystemParam> key2param = new HashMap<>();
-            Iterator<SystemParam> systemParamIterator = systemParamRepository.findAll().iterator();
-            while (systemParamIterator.hasNext()) {
-                SystemParam systemParam = systemParamIterator.next();
-                key2param.put(systemParam.getKey(), systemParam);
-            }
-
-            if (key2param.size() > 0) {
-                BasicData.key2param = key2param;
-            }
-        }
-    }
-
-    public static Map<String, SystemParam> getSystemParam() {
-        return key2param;
     }
 }
+package com.bsth.data;
+
+import com.bsth.common.SystemParamKeys;
+import com.bsth.service.SystemParamService;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Hill
+ */
+@Component
+public class SystemParamCache implements InitializingBean {
+
+    @Autowired
+    private SystemParamService systemParamService;
+
+    private static SystemParamService systemParamService1;
+
+    public static String getSpecialRoles() {
+        return systemParamService1.getValue(SystemParamKeys.SPECIAL_ROLES);
+    }
+
+    public static String getUrlHttpGpsRealCache() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_GPS_REAL_CACHE);
+    }
+
+    public static String getUrlHttpGpsReal() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_GPS_REAL);
+    }
+
+    public static String getUrlHttpDirective() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_DIRECTIVE);
+    }
+
+    public static String getUrlHttpRfid() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_RFID);
+    }
+
+    public static String getUrlHttpReport(String param) {
+        return systemParamService1.getValue(String.format(SystemParamKeys.URL_HTTP_REPORT, param));
+    }
+
+    public static String getUrlHttpTicketing() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_TICKETING);
+    }
+
+    public static String getUrlHttpDsmAck() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_DSM_ACK);
+    }
+
+    public static String getUrlHttpCpAck() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_CP_ACK);
+    }
+
+    public static String getMailAdmin() {
+        return systemParamService1.getValue(SystemParamKeys.MAIL_ADMIN);
+    }
+
+    public static String getMailWaybill() {
+        return systemParamService1.getValue(SystemParamKeys.MAIL_WAYBILL);
+    }
+
+    public static boolean getEnabledFirstLastGeneration() {
+        return Boolean.parseBoolean(systemParamService1.getValue(SystemParamKeys.ENABLED_FIRST_LAST_GENERATION));
+    }
+
+    public static boolean getEnabledFilterSqlInjection() {
+        return Boolean.parseBoolean(systemParamService1.getValue(SystemParamKeys.ENABLED_FILTER_SQL_INJECTION));
+    }
+
+    public static boolean getEnabledSso() {
+        return Boolean.parseBoolean(systemParamService1.getValue(SystemParamKeys.ENABLED_SSO));
+    }
+
+    public static String getSsoSystemCode() {
+        return systemParamService1.getValue(SystemParamKeys.SSO_SYSTEM_CODE);
+    }
+
+    public static String getUrlHttpSsoLogin() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_SSO_LOGIN);
+    }
+
+    public static String getUrlHttpSsoLogout() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_SSO_LOGOUT);
+    }
+
+    public static final String URL_HTTP_SSO_AUTH = "url.http.sso.auth";
+    public static String getUrlHttpSsoAuth() {
+        return systemParamService1.getValue(SystemParamKeys.URL_HTTP_SSO_AUTH);
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        systemParamService1 = systemParamService;
+        systemParamService1.refresh();
+    }
+}
-package com.bsth.data.directive;
-
-import com.alibaba.fastjson.JSONObject;
-import com.bsth.util.ConfigUtil;
-import org.apache.http.client.config.RequestConfig;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.entity.StringEntity;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.util.EntityUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * @author PanZhao
- * @ClassName: GatewayHttpUtils
- * @Description: TODO(和网关HTTP通讯工具类)
- * @date 2016年8月14日 下午9:50:46
- */
-public class GatewayHttpUtils {
-    static Logger logger = LoggerFactory.getLogger(GatewayHttpUtils.class);
-
-    static String url;
-    static CloseableHttpClient httpClient = null;
-    static HttpPost post;
-    static RequestConfig requestConfig;
-    static CloseableHttpResponse response;
-
-    static {
-        url = ConfigUtil.get("http.send.directive");
-        httpClient = HttpClients.createDefault();
-        post = new HttpPost(url);
-        requestConfig = RequestConfig.custom()
-                .setConnectTimeout(3000).setConnectionRequestTimeout(2000)
-                .setSocketTimeout(3000).build();
-        post.setConfig(requestConfig);
-    }
-
-    public static int postJson(String jsonStr) {
-        logger.info("send : " + jsonStr);
-
-        int code = -1;
-        try {
-            post.setEntity(new StringEntity(jsonStr, "utf-8"));
-
-            response = httpClient.execute(post);
-
-            int statusCode = response.getStatusLine().getStatusCode();
-            if(statusCode != 200){
-                logger.error("http client status code: " + statusCode);
-            }
-
-            JSONObject json = JSONObject.parseObject(EntityUtils.toString(response.getEntity()));
-            if (null != json && json.getInteger("errCode") == 0)
-                code = 0;
-            else
-                logger.error("和网关http通讯失败，rs: " + json);
-
-            if (null != response)
-                response.close();
-        } catch (Exception e) {
-            logger.error("", e);
-        }
-        return code;
-    }
-}
+package com.bsth.data.directive;
+
+import com.alibaba.fastjson.JSONObject;
+import com.bsth.data.SystemParamCache;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author PanZhao
+ * @ClassName: GatewayHttpUtils
+ * @Description: TODO(和网关HTTP通讯工具类)
+ * @date 2016年8月14日 下午9:50:46
+ */
+@Component
+public class GatewayHttpUtils implements InitializingBean {
+    static Logger logger = LoggerFactory.getLogger(GatewayHttpUtils.class);
+
+    static String url;
+    static CloseableHttpClient httpClient = null;
+    static HttpPost post;
+    static RequestConfig requestConfig;
+    static CloseableHttpResponse response;
+
+    public static int postJson(String jsonStr) {
+        logger.info("send : " + jsonStr);
+
+        int code = -1;
+        try {
+            post.setEntity(new StringEntity(jsonStr, "utf-8"));
+
+            response = httpClient.execute(post);
+
+            int statusCode = response.getStatusLine().getStatusCode();
+            if(statusCode != 200){
+                logger.error("http client status code: " + statusCode);
+            }
+
+            JSONObject json = JSONObject.parseObject(EntityUtils.toString(response.getEntity()));
+            if (null != json && json.getInteger("errCode") == 0)
+                code = 0;
+            else
+                logger.error("和网关http通讯失败，rs: " + json);
+
+            if (null != response)
+                response.close();
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+        return code;
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        url = SystemParamCache.getUrlHttpDirective();
+        httpClient = HttpClients.createDefault();
+        post = new HttpPost(url);
+        requestConfig = RequestConfig.custom()
+                .setConnectTimeout(3000).setConnectionRequestTimeout(2000)
+                .setSocketTimeout(3000).build();
+        post.setConfig(requestConfig);
+    }
+}
-package com.bsth.data.gpsdata_v2.load;
-
-import com.alibaba.fastjson.JSON;
-import com.bsth.data.BasicData;
-import com.bsth.data.gpsdata_v2.GpsRealData;
-import com.bsth.data.gpsdata_v2.entity.GpsEntity;
-import com.bsth.data.gpsdata_v2.utils.GpsDataUtils;
-import com.bsth.util.ConfigUtil;
-import org.apache.commons.lang3.StringUtils;
-import org.apache.http.HttpEntity;
-import org.apache.http.client.config.RequestConfig;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.BeansException;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ApplicationContextAware;
-import org.springframework.stereotype.Component;
-
-import java.io.BufferedReader;
-import java.io.InputStreamReader;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 从网关http 接口加载数据
- * Created by panzhao on 2017/11/15.
- */
-@Component
-public class GatewayHttpLoader implements ApplicationContextAware{
-
-    static Logger logger = LoggerFactory.getLogger(GatewayHttpLoader.class);
-
-    static String url;
-    static List<GpsEntity> list;
-    static CloseableHttpClient httpClient = null;
-    static HttpGet get;
-    static RequestConfig requestConfig;
-    static CloseableHttpResponse response;
-    static HttpEntity entity;
-    static BufferedReader br;
-
-    static GpsRealData gpsRealData;
-
-    static{
-        url = ConfigUtil.get("http.gps.real.url");
-        list = new ArrayList<>();
-        httpClient = HttpClients.createDefault();
-        get = new HttpGet(url);
-        requestConfig = RequestConfig.custom()
-                .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
-                .setSocketTimeout(2500).build();
-        get.setConfig(requestConfig);
-    }
-
-    public static List<GpsEntity> load(){
-        try{
-            if(list.size() > 0)
-                list.clear();
-
-            response = httpClient.execute(get);
-            entity = response.getEntity();
-
-            logger.info("entity:" + entity + "get:" + get);
-            if(null == entity)
-                return list;
-
-            br = new BufferedReader(new InputStreamReader(entity.getContent()));
-
-            StringBuilder sb = new StringBuilder();
-            String str;
-            while ((str = br.readLine()) != null)
-                sb.append(str);
-
-            logger.debug("gps:" + sb.toString());
-            list = JSON.parseArray(JSON.parseObject(sb.toString()).getString("data"), GpsEntity.class);
-            //过滤掉无效的点位
-            list = GpsDataUtils.clearInvalid(list);
-
-            List<GpsEntity> ups = new ArrayList<>();
-            String nbbm;
-            for (GpsEntity gps : list) {
-                if (StringUtils.isBlank(gps.getDeviceId()))
-                    continue;
-
-                if (gps_equals(gpsRealData.get(gps.getDeviceId()), gps))
-                    continue;
-
-                nbbm = BasicData.deviceId2NbbmMap.get(gps.getDeviceId());
-                gps.setNbbm(nbbm);
-                ups.add(gps);
-            }
-            list = ups;
-
-            if (null != response)
-                response.close();
-        }catch (Exception e){
-            logger.error("", e);
-        }
-        return list;
-    }
-
-
-    private static boolean gps_equals(GpsEntity old, GpsEntity gps){
-        if(old != null &&
-                old.getTimestamp().equals(gps.getTimestamp()) &&
-                old.getLat().equals(gps.getLat()) &&
-                old.getLon().equals(gps.getLon()))
-            return true;
-        return false;
-    }
-
-    @Override
-    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
-        gpsRealData = applicationContext.getBean(GpsRealData.class);
-    }
-}
+package com.bsth.data.gpsdata_v2.load;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.data.BasicData;
+import com.bsth.data.SystemParamCache;
+import com.bsth.data.gpsdata_v2.GpsRealData;
+import com.bsth.data.gpsdata_v2.entity.GpsEntity;
+import com.bsth.data.gpsdata_v2.utils.GpsDataUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 从网关http 接口加载数据
+ * Created by panzhao on 2017/11/15.
+ */
+@Component
+public class GatewayHttpLoader implements ApplicationContextAware, InitializingBean {
+
+    static Logger logger = LoggerFactory.getLogger(GatewayHttpLoader.class);
+
+    static String url;
+    static List<GpsEntity> list;
+    static CloseableHttpClient httpClient = null;
+    static HttpGet get;
+    static RequestConfig requestConfig;
+    static CloseableHttpResponse response;
+    static HttpEntity entity;
+    static BufferedReader br;
+
+    static GpsRealData gpsRealData;
+
+    public static List<GpsEntity> load(){
+        try{
+            if(list.size() > 0)
+                list.clear();
+
+            response = httpClient.execute(get);
+            entity = response.getEntity();
+
+            logger.info("entity:" + entity + "get:" + get);
+            if(null == entity)
+                return list;
+
+            br = new BufferedReader(new InputStreamReader(entity.getContent()));
+
+            StringBuilder sb = new StringBuilder();
+            String str;
+            while ((str = br.readLine()) != null)
+                sb.append(str);
+
+            logger.debug("gps:" + sb.toString());
+            list = JSON.parseArray(JSON.parseObject(sb.toString()).getString("data"), GpsEntity.class);
+            //过滤掉无效的点位
+            list = GpsDataUtils.clearInvalid(list);
+
+            List<GpsEntity> ups = new ArrayList<>();
+            String nbbm;
+            for (GpsEntity gps : list) {
+                if (StringUtils.isBlank(gps.getDeviceId()))
+                    continue;
+
+                if (gps_equals(gpsRealData.get(gps.getDeviceId()), gps))
+                    continue;
+
+                nbbm = BasicData.deviceId2NbbmMap.get(gps.getDeviceId());
+                gps.setNbbm(nbbm);
+                ups.add(gps);
+            }
+            list = ups;
+
+            if (null != response)
+                response.close();
+        }catch (Exception e){
+            logger.error("", e);
+        }
+        return list;
+    }
+
+
+    private static boolean gps_equals(GpsEntity old, GpsEntity gps){
+        if(old != null &&
+                old.getTimestamp().equals(gps.getTimestamp()) &&
+                old.getLat().equals(gps.getLat()) &&
+                old.getLon().equals(gps.getLon()))
+            return true;
+        return false;
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        gpsRealData = applicationContext.getBean(GpsRealData.class);
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        url = SystemParamCache.getUrlHttpGpsReal();
+        list = new ArrayList<>();
+        httpClient = HttpClients.createDefault();
+        get = new HttpGet(url);
+        requestConfig = RequestConfig.custom()
+                .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
+                .setSocketTimeout(2500).build();
+        get.setConfig(requestConfig);
+    }
+}
-package com.bsth.data.gpsdata_v2.load;
-
-import com.alibaba.fastjson.JSON;
-import com.bsth.data.BasicData;
-import com.bsth.data.gpsdata_v2.entity.GpsEntity;
-import com.bsth.data.gpsdata_v2.utils.GpsDataUtils;
-import com.bsth.util.ConfigUtil;
-import org.apache.http.HttpEntity;
-import org.apache.http.client.config.RequestConfig;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
-
-import java.io.BufferedReader;
-import java.io.InputStreamReader;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 从专用的socket client 加载数据
- * Created by panzhao on 2017/11/15.
- */
-@Component
-public class SocketClientLoader {
-
-    static Logger logger = LoggerFactory.getLogger(SocketClientLoader.class);
-
-    static String url;
-    static List<GpsEntity> list;
-    static CloseableHttpClient httpClient = null;
-    static HttpGet get;
-    static RequestConfig requestConfig;
-    static CloseableHttpResponse response;
-    static HttpEntity entity;
-    static BufferedReader br;
-
-    static {
-        url = ConfigUtil.get("http.gps.real.cache.url");
-        list = new ArrayList<>();
-        httpClient = HttpClients.createDefault();
-        get = new HttpGet(url);
-        requestConfig = RequestConfig.custom()
-                .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
-                .setSocketTimeout(2500).build();
-        get.setConfig(requestConfig);
-    }
-
-    public static List<GpsEntity> load(){
-        try {
-            if(list.size() > 0)
-                list.clear();
-            logger.info("load start...");
-            response = httpClient.execute(get);
-            entity = response.getEntity();
-            if(null == entity)
-                return list;
-
-            br = new BufferedReader(new InputStreamReader(entity.getContent()));
-            StringBuilder sb = new StringBuilder();
-            String str;
-            while ((str = br.readLine()) != null)
-                sb.append(str);
-
-            list = JSON.parseArray(sb.toString(), GpsEntity.class);
-
-            logger.info("load end ! size: " + list.size());
-            //过滤掉无效的点位
-            list = GpsDataUtils.clearInvalid(list);
-
-            for (GpsEntity gps : list) {
-                gps.setNbbm(BasicData.deviceId2NbbmMap.get(gps.getDeviceId()));
-            }
-
-            if (null != response)
-                response.close();
-        } catch (Exception e) {
-            logger.error("", e);
-        }
-
-        return list;
-    }
-}
+package com.bsth.data.gpsdata_v2.load;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.data.BasicData;
+import com.bsth.data.SystemParamCache;
+import com.bsth.data.gpsdata_v2.entity.GpsEntity;
+import com.bsth.data.gpsdata_v2.utils.GpsDataUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.stereotype.Component;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 从专用的socket client 加载数据
+ * Created by panzhao on 2017/11/15.
+ */
+@Component
+public class SocketClientLoader implements InitializingBean {
+
+    static Logger logger = LoggerFactory.getLogger(SocketClientLoader.class);
+
+    static String url;
+    static List<GpsEntity> list;
+    static CloseableHttpClient httpClient = null;
+    static HttpGet get;
+    static RequestConfig requestConfig;
+    static CloseableHttpResponse response;
+    static HttpEntity entity;
+    static BufferedReader br;
+
+    public static List<GpsEntity> load(){
+        try {
+            if(list.size() > 0)
+                list.clear();
+            logger.info("load start...");
+            response = httpClient.execute(get);
+            entity = response.getEntity();
+            if(null == entity)
+                return list;
+
+            br = new BufferedReader(new InputStreamReader(entity.getContent()));
+            StringBuilder sb = new StringBuilder();
+            String str;
+            while ((str = br.readLine()) != null)
+                sb.append(str);
+
+            list = JSON.parseArray(sb.toString(), GpsEntity.class);
+
+            logger.info("load end ! size: " + list.size());
+            //过滤掉无效的点位
+            list = GpsDataUtils.clearInvalid(list);
+
+            for (GpsEntity gps : list) {
+                gps.setNbbm(BasicData.deviceId2NbbmMap.get(gps.getDeviceId()));
+            }
+
+            if (null != response)
+                response.close();
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+
+        return list;
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        url = SystemParamCache.getUrlHttpGpsRealCache();
+        list = new ArrayList<>();
+        httpClient = HttpClients.createDefault();
+        get = new HttpGet(url);
+        requestConfig = RequestConfig.custom()
+                .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
+                .setSocketTimeout(2500).build();
+        get.setConfig(requestConfig);
+    }
+}
 package com.bsth.data.gpsdata_v2.rfid;
+import com.bsth.data.SystemParamCache;
 import com.bsth.data.gpsdata_v2.rfid.entity.RfidInfo;
-import com.bsth.util.ConfigUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.commons.io.IOUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.stereotype.Component;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
@@ -20,11 +22,12 @@ import java.util.List;
  * @author hill
  * @date
  */
-public class RfidHttpLoader {
+@Component
+public class RfidHttpLoader implements InitializingBean {
     private final static Logger log = LoggerFactory.getLogger(RfidHttpLoader.class);
-    private static String RFID_URL = ConfigUtil.get("http.rfid.url");
+    private static String RFID_URL;
     public static List<RfidInfo> load() {
         List<RfidInfo> result = new ArrayList<>();
@@ -75,4 +78,9 @@ public class RfidHttpLoader {
         return result;
     }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        RFID_URL = SystemParamCache.getUrlHttpRfid();
+    }
 }
@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONArray;
 import com.bsth.common.Constants;
 import com.bsth.common.ResponseCode;
 import com.bsth.data.LineConfigData;
+import com.bsth.data.SystemParamCache;
 import com.bsth.data.gpsdata_v2.GpsRealData;
 import com.bsth.data.gpsdata_v2.utils.GpsDataRecovery;
 import com.bsth.data.schedule.f_a_l.FirstAndLastHandler;
@@ -27,7 +28,6 @@ import org.joda.time.format.DateTimeFormatter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.jdbc.core.BatchPreparedStatementSetter;
 import org.springframework.jdbc.core.JdbcTemplate;
@@ -54,9 +54,6 @@ import java.util.concurrent.ConcurrentMap;
 @Component
 public class DayOfSchedule {
-    @Value("${ms.fl.generate}")
-    private boolean generate;
-
     Logger logger = LoggerFactory.getLogger(this.getClass());
     //按线路分组的 “原始计划” 排班数据
@@ -187,6 +184,7 @@ public class DayOfSchedule {
      */
     public int reloadSch(String lineCode, String schDate, boolean forcePlan) {
         try {
+            boolean generate = SystemParamCache.getEnabledFirstLastGeneration();
             List<ScheduleRealInfo> list;
             if (forcePlan)
-package com.bsth.data.schedule.thread;
-
-import com.bsth.data.directive.DayOfDirectives;
-import com.bsth.data.gpsdata_v2.handlers.overspeed.OverspeedProcess;
-import com.bsth.data.gpsdata_v2.thread.GpsDataLoaderThread;
-import com.bsth.service.calc.CalcWaybillService;
-import com.bsth.service.forms.BudgetService;
-import com.bsth.service.oil.DlbService;
-import com.bsth.data.safe_driv.SafeDrivCenter;
-import com.bsth.service.oil.YlbService;
-import com.bsth.service.report.SheetService;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-/**
- * 计算油、公里加注量 线程
- * Created by panzhao on 2017/3/7.
- */
-@Component
-public class CalcOilThread extends Thread{
-
-    @Autowired
-    YlbService ylbService;
-    @Autowired
-    DlbService dlbService;
-    
-    @Autowired
-    SheetService sheetService;
-    Logger logger = LoggerFactory.getLogger(this.getClass());
-
-    @Autowired
-    DayOfDirectives dayOfDirectives;
-    
-    @Autowired
-    CalcWaybillService calcWaybillService;
-    
-    @Autowired
-    BudgetService budgetService;
-
-    @Override
-    public void run() {
-        logger.info("开始计算油量平衡表....");
-        try{
-            ylbService.obtainDsq();
-//          logger.info("开始计算班次准点率....");
-//			sheetService.saveSheetList("");
-//          logger.info("计算班次准点率结束！");
-        } catch(Exception e){
-            logger.error("计算油量平衡表失败",e);
-        }
-        try{
-            logger.info("开始计算电量平衡表....");
-            dlbService.obtainDsq();
-        } catch(Exception e){
-            logger.error("计算电量平衡表失败",e);
-        }
-        
-        try{
-            logger.info("计算路单里程开始");
-            calcWaybillService.autoGenerate("", "");
-        }catch(Exception e){
-            logger.error("计算路单里程失败",e);
-        }
-        
-        logger.info("开始保存统计日报....");
-        try{
-        	calcWaybillService.calcDaily("", "");
-        }catch(Exception e){
-            logger.error("统计日报失败",e);
-        }
-        
-        logger.info("开始获取营收人次....");
-        try{
-        	budgetService.updateRevenueRange("", "");
-        }catch(Exception e){
-            logger.error("获取营收人次失败",e);
-        }
-        
-        //清除指令数据
-        dayOfDirectives.clearAll();
-        //清除安全驾驶数据
-        SafeDrivCenter.clear();
-        //清除超速缓存数据
-        OverspeedProcess.clear();
-
-        GpsDataLoaderThread.setFlag(0);
-
-    }
-}
+package com.bsth.data.schedule.thread;
+
+import com.bsth.data.directive.DayOfDirectives;
+import com.bsth.data.gpsdata_v2.handlers.overspeed.OverspeedProcess;
+import com.bsth.data.gpsdata_v2.thread.GpsDataLoaderThread;
+import com.bsth.service.calc.CalcWaybillService;
+import com.bsth.service.forms.BudgetService;
+import com.bsth.service.oil.DlbService;
+import com.bsth.data.safe_driv.SafeDrivCenter;
+import com.bsth.service.oil.YlbService;
+import com.bsth.service.report.SheetService;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 计算油、公里加注量 线程
+ * Created by panzhao on 2017/3/7.
+ */
+@Component
+public class CalcOilThread extends Thread{
+
+    @Autowired
+    YlbService ylbService;
+    @Autowired
+    DlbService dlbService;
+    
+    @Autowired
+    SheetService sheetService;
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    DayOfDirectives dayOfDirectives;
+    
+    @Autowired
+    CalcWaybillService calcWaybillService;
+    
+    @Autowired
+    BudgetService budgetService;
+
+    @Override
+    public void run() {
+        logger.info("开始计算油量平衡表....");
+        try{
+            ylbService.obtainDsq();
+//          logger.info("开始计算班次准点率....");
+//			sheetService.saveSheetList("");
+//          logger.info("计算班次准点率结束！");
+        } catch(Exception e){
+            logger.error("计算油量平衡表失败",e);
+        }
+        try{
+            logger.info("开始计算电量平衡表....");
+            dlbService.obtainDsq();
+        } catch(Exception e){
+            logger.error("计算电量平衡表失败",e);
+        }
+        
+        try{
+            logger.info("计算路单里程开始");
+            calcWaybillService.autoGenerate("", "");
+        }catch(Exception e){
+            logger.error("计算路单里程失败",e);
+        }
+        
+        logger.info("开始保存统计日报....");
+        try{
+        	calcWaybillService.calcDaily("", "");
+        }catch(Exception e){
+            logger.error("统计日报失败",e);
+        }
+        
+        logger.info("开始获取营收人次....");
+        try{
+        	budgetService.updateRevenueRange("", "");
+        }catch(Exception e){
+            logger.error("获取营收人次失败",e);
+        }
+        
+        //清除指令数据
+        dayOfDirectives.clearAll();
+        //清除安全驾驶数据
+        SafeDrivCenter.clear();
+        //清除超速缓存数据
+        OverspeedProcess.clear();
+    }
+}
 package com.bsth.entity;
-import com.bsth.common.Constants;
-import com.bsth.data.BasicData;
-import com.bsth.entity.sys.Role;
-import com.bsth.security.util.SecurityUtils;
-
 import javax.persistence.*;
-import java.util.Set;
 /**
  * @author Hill
 package com.bsth.filter;
-import org.springframework.beans.factory.annotation.Value;
+import com.bsth.data.SystemParamCache;
 import org.springframework.stereotype.Component;
 import javax.servlet.FilterChain;
@@ -17,13 +17,10 @@ public class SQLInjectFilter extends BaseFilter{
 	private final static String specialUri = "adminUtils";
-	@Value("${enabled.sqlinject}")
-	private boolean sqlInjectEnabled;
-
 	@Override
 	public void doFilter(HttpServletRequest request, HttpServletResponse response, FilterChain chain)
 			throws IOException, ServletException {
-		if (!sqlInjectEnabled) {
+		if (!SystemParamCache.getEnabledFilterSqlInjection()) {
 			chain.doFilter(request, response);
 			return;
 		}
@@ -69,12 +66,4 @@ public class SQLInjectFilter extends BaseFilter{
 	public static void setInjStr(String injStr) {
 		SQLInjectFilter.injStr = injStr;
 	}
-
-	public boolean isSqlInjectEnabled() {
-		return sqlInjectEnabled;
-	}
-
-	public void setSqlInjectEnabled(boolean sqlInjectEnabled) {
-		this.sqlInjectEnabled = sqlInjectEnabled;
-	}
 }
@@ -55,7 +55,6 @@ public class SsoConfig {
         return systemCode;
     }
-    @Value("${sso.systemcode}")
     public void setSystemCode(String systemCode) {
         this.systemCode = systemCode;
     }
@@ -85,7 +84,6 @@ public class SsoConfig {
         return ssoAuthUrl;
     }
-    @Value("${sso.http.url.auth}")
     public void setSsoAuthUrl(String ssoAuthUrl) {
         this.ssoAuthUrl = ssoAuthUrl;
     }
@@ -6,4 +6,8 @@ import com.bsth.entity.SystemParam;
  * @author Hill
  */
 public interface SystemParamService extends BaseService<SystemParam, Integer> {
+
+    void refresh();
+
+    String getValue(String key);
 }
-package com.bsth.service.forms.impl;
-
-import com.alibaba.fastjson.JSON;
-import com.bsth.util.ConfigUtil;
-import org.apache.http.HttpEntity;
-import org.apache.http.client.config.RequestConfig;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
-
-import java.io.BufferedReader;
-import java.io.InputStreamReader;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-
-@Component
-public class RevenueLoader {
-
-    static Logger logger = LoggerFactory.getLogger(RevenueLoader.class);
-
-    static String url;
-    static List<Map<String, Object>> list;
-    static CloseableHttpClient httpClient = null;
-    static HttpGet get;
-    static RequestConfig requestConfig;
-    static CloseableHttpResponse response;
-    static HttpEntity entity;
-    static BufferedReader br;
-
-    /**
-     * 从票务系统获取营收
-     * @param date
-     * @param gsBm
-     * @return
-     */
-    public static List<Map<String, Object>> load(String date, String gsBm){
-        try {
-        	url = ConfigUtil.get("http.ticketing.interface") + "?txnType=getLineRevenue&busiDate="+date+"&companyCode="+gsBm;
-            list = new ArrayList<>();
-            httpClient = HttpClients.createDefault();
-            get = new HttpGet(url);
-            requestConfig = RequestConfig.custom()
-                    .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
-                    .setSocketTimeout(2500).build();
-            get.setConfig(requestConfig);
-            if(list.size() > 0)
-                list.clear();
-            logger.info("load start...");
-            response = httpClient.execute(get);
-            entity = response.getEntity();
-            if(null == entity)
-                return list;
-
-            br = new BufferedReader(new InputStreamReader(entity.getContent()));
-            StringBuilder sb = new StringBuilder();
-            String str;
-            while ((str = br.readLine()) != null)
-                sb.append(str);
-
-            Map<String, Object> parseObj = JSON.parseObject(sb.toString(), Map.class);
-            if(parseObj.get("status") != null && "SUCCESS".equals(parseObj.get("status").toString())){
-	            for(Map<String, Object> m : (List<Map<String, Object>>) parseObj.get("respData")){
-	            	list.add(m);
-	            }
-            }
-
-            logger.info("load end ! size: " + list.size());
-
-            if (null != response)
-                response.close();
-        } catch (Exception e) {
-            logger.error("", e);
-        }
-
-        return list;
-    }
-}
+package com.bsth.service.forms.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.data.SystemParamCache;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@Component
+public class RevenueLoader {
+
+    static Logger logger = LoggerFactory.getLogger(RevenueLoader.class);
+
+    static String url;
+    static List<Map<String, Object>> list;
+    static CloseableHttpClient httpClient = null;
+    static HttpGet get;
+    static RequestConfig requestConfig;
+    static CloseableHttpResponse response;
+    static HttpEntity entity;
+    static BufferedReader br;
+
+    /**
+     * 从票务系统获取营收
+     * @param date
+     * @param gsBm
+     * @return
+     */
+    public static List<Map<String, Object>> load(String date, String gsBm){
+        try {
+            url = String.format(SystemParamCache.getUrlHttpTicketing(), date, gsBm);
+            list = new ArrayList<>();
+            httpClient = HttpClients.createDefault();
+            get = new HttpGet(url);
+            requestConfig = RequestConfig.custom()
+                    .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
+                    .setSocketTimeout(2500).build();
+            get.setConfig(requestConfig);
+            if(list.size() > 0)
+                list.clear();
+            logger.info("load start...");
+            response = httpClient.execute(get);
+            entity = response.getEntity();
+            if(null == entity)
+                return list;
+
+            br = new BufferedReader(new InputStreamReader(entity.getContent()));
+            StringBuilder sb = new StringBuilder();
+            String str;
+            while ((str = br.readLine()) != null)
+                sb.append(str);
+
+            Map<String, Object> parseObj = JSON.parseObject(sb.toString(), Map.class);
+            if(parseObj.get("status") != null && "SUCCESS".equals(parseObj.get("status").toString())){
+	            for(Map<String, Object> m : (List<Map<String, Object>>) parseObj.get("respData")){
+	            	list.add(m);
+	            }
+            }
+
+            logger.info("load end ! size: " + list.size());
+
+            if (null != response)
+                response.close();
+        } catch (Exception e) {
+            logger.error("", e);
+        }
+
+        return list;
+    }
+}
 package com.bsth.service.impl;
 import com.bsth.entity.SystemParam;
+import com.bsth.repository.SystemParamRepository;
 import com.bsth.service.SystemParamService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
 /**
  * @author Hill
  */
+@Service
+@EnableScheduling
 public class SystemParamServiceImpl extends BaseServiceImpl<SystemParam, Integer> implements SystemParamService {
+
+    @Autowired
+    private SystemParamRepository systemParamRepository;
+
+    private Map<String, String> pairs = new HashMap<>();
+
+    @Scheduled(cron = "0 0/30 * * * ?")
+    public void refresh() {
+        for (SystemParam sp : systemParamRepository.findAll()) {
+            pairs.put(sp.getKey(), sp.getValue());
+        }
+    }
+
+    public String getValue(String key) {
+        return pairs.get(key);
+    }
 }
@@ -6,7 +6,6 @@ import java.math.BigDecimal;
 import java.net.HttpURLConnection;
 import java.net.MalformedURLException;
 import java.net.URL;
-import java.net.URLEncoder;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.text.DecimalFormat;
@@ -29,6 +28,7 @@ import java.util.Set;
 import java.util.concurrent.*;
 import java.util.regex.Pattern;
+import com.bsth.data.SystemParamCache;
 import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringEscapeUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -121,7 +121,6 @@ import com.bsth.util.Arith;
 import com.bsth.util.ComparableChild;
 import com.bsth.util.ComparableLp;
 import com.bsth.util.ComparableReal;
-import com.bsth.util.ConfigUtil;
 import com.bsth.util.DateUtils;
 import com.bsth.util.ReportRelatedUtils;
 import com.bsth.util.ReportUtils;
@@ -135,8 +134,6 @@ import com.github.stuxuhai.jpinyin.PinyinHelper;
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
-import javax.ws.rs.HEAD;
-
 @Service
 public class ScheduleRealInfoServiceImpl extends BaseServiceImpl<ScheduleRealInfo, Long>
         implements ScheduleRealInfoService, InitializingBean, DisposableBean {
@@ -225,6 +222,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
     @Autowired
     RepairReportRepository repairReportRepository;
+
     Logger logger = LoggerFactory.getLogger(this.getClass());
     SimpleDateFormat sdfMonth = new SimpleDateFormat("yyyy-MM-dd"),
@@ -6679,7 +6677,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
 		// 分公司保存格式 分公司编码_公司编码
 		String val = BasicData.nbbm2FgsCompanyCodeMap.get(incode);
 		String[] arr = val.split("_");
-		StringBuilder url = new StringBuilder(ConfigUtil.get("http.report.url." + arr[1]));
+		StringBuilder url = new StringBuilder(SystemParamCache.getUrlHttpReport(arr[1]));
 		url.append("?nbbm=").append(incode).append("&bxy=").append(reportUser).append("&bxbm=").append(repairTypes).append("&fgs=").append(arr[0]);
 		int count = repairReportRepository.repairReportBySch(id, isActive ? 1 : 0);
@@ -6719,7 +6717,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
     	// 分公司保存格式 分公司编码_公司编码
 		String val = BasicData.nbbm2FgsCompanyCodeMap.get(rr.getIncode());
 		String[] arr = val.split("_");
-		StringBuilder url = new StringBuilder(ConfigUtil.get("http.report.url." + arr[1]));
+		StringBuilder url = new StringBuilder(SystemParamCache.getUrlHttpReport(arr[1]));
 		url.append("?nbbm=").append(rr.getIncode()).append("&bxy=").append(rr.getReportUser()).append("&bxbm=").append(rr.getRepairType()).append("&fgs=").append(arr[0]);
 		Map<String, Object> res = request(url.toString());
 package com.bsth.util;
+import com.bsth.data.SystemParamCache;
 import com.bsth.email.SimpleMailSender;
 import com.bsth.email.entity.EmailBean;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import java.util.List;
@@ -13,21 +13,10 @@ import java.util.List;
 @Component
 public class MailUtils {
-    @Value("${admin.mail}")
-    private String emailSendToAddress;
-
     private Tools tools = new Tools("mailbox.properties");
     private SimpleMailSender sms = new SimpleMailSender(tools.getValue("username"),tools.getValue("password"));
-    public String getEmailSendToAddress() {
-        return emailSendToAddress;
-    }
-
-    public void setEmailSendToAddress(String emailSendToAddress) {
-        this.emailSendToAddress = emailSendToAddress;
-    }
-
     /**
      * recipients
      * 收件人集合
@@ -52,9 +41,9 @@ public class MailUtils {
      * mail
      * 邮件
      */
-    public int sendMail(String recipient,EmailBean mail){
+    public int sendMail(String recipient, EmailBean mail){
         try {
-            sms.send(recipient, mail.getSubject(),mail.getContent());
+            sms.send(recipient, mail.getSubject(), mail.getContent());
         } catch (Exception e) {
             e.printStackTrace();
             return -1;
@@ -63,6 +52,6 @@ public class MailUtils {
     }
     public int sendMail(EmailBean mail){
-        return sendMail(emailSendToAddress, mail);
+        return sendMail(SystemParamCache.getMailAdmin(), mail);
     }
 }
@@ -38,25 +38,6 @@ spring.datasource.hikari.connection-test-query= SELECT 1
 spring.datasource.hikari.validation-timeout= 3000
 spring.datasource.hikari.register-mbeans=true
-## gps client data
-http.gps.real.cache.url= http://10.10.150.24:12580/realGps/all
-## gateway real data
-http.gps.real.url= http://114.80.178.12:18080/transport_server/rtgps/
-## gateway send directive
-http.send.directive = http://192.168.168.201:9090/transport_server/message/
-## rfid data
-http.rfid.url= http://114.80.178.12:29000/rfid
-## http ticketing interface
-http.ticketing.interface= http://112.64.187.3:1080/gjService/request
-## first last generate
-ms.fl.generate=true
-## dsm ack interface
-dsm.ack.url= http://211.95.61.66:9008/modules/dsmCheckTheRecord/addDsm?
-## cp ack interface
-cp.ack.url= http://114.80.178.12:8778/prod-api/serverApi/instructionsIssue/confirm/
-## admin mail
-admin.mail= 3090342880@qq.com
-
 sso.enabled= true
 sso.systemcode = SYSUS023
 sso.http.url.login= http://10.10.200.142:9112/login?redirect=%2Findex
@@ -31,36 +31,6 @@ spring.datasource.hikari.connection-test-query= SELECT 1
 spring.datasource.hikari.validation-timeout= 3000
 spring.datasource.hikari.register-mbeans=true
-## gps client data
-http.gps.real.cache.url= http://10.10.150.24:12580/realGps/all
-## gateway real data
-http.gps.real.url= http://10.10.150.103:8080/transport_server/rtgps/
-## gateway send directive
-http.send.directive= http://10.10.150.103:8080/transport_server/message/
-## rfid data
-http.rfid.url= http://10.10.150.103:9000/rfid
-## wxsb
-#http.report.url.05= http://192.168.168.154:8088/ygjwsystem_j2ee/clbx/clbx_dd.do
-#http.report.url.22= http://192.168.168.154:8088/jgjwsystem_j2ee/clbx/clbx_dd.do
-#http.report.url.26= http://192.168.168.154:8088/nhjwsystem_j2ee/clbx/clbx_dd.do
-#http.report.url.55= http://192.168.168.154:8088/snjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.05= http://116.228.197.222:8081/ygjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.22= http://116.247.73.122:9098/jgjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.26= http://116.236.141.34:8088/nhjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.55= http://180.168.216.248:8088/snjwsystem_j2ee/clbx/clbx_dd.do
-## http ticketing interface
-http.ticketing.interface= http://112.64.187.3:1080/gjService/request
-## first last generate
-ms.fl.generate=true
-## dsm ack interface
-dsm.ack.url= http://211.95.61.66:9008/modules/dsmCheckTheRecord/addDsm?
-## cp ack interface
-cp.ack.url= http://114.80.178.12:8778/prod-api/serverApi/instructionsIssue/confirm/
-## admin mail
-admin.mail= 3090342880@qq.com
-## enabled
-enabled.sqlinject= false
-
 sso.enabled= true
 sso.systemcode = SYSUS023
 sso.http.url.login= http://10.10.200.142:9112/login?redirect=%2Findex
@@ -31,36 +31,6 @@ spring.datasource.hikari.connection-test-query= SELECT 1
 spring.datasource.hikari.validation-timeout= 3000
 spring.datasource.hikari.register-mbeans=true
-## gps client data
-http.gps.real.cache.url= http://10.10.150.24:12580/realGps/all
-## gateway real data
-http.gps.real.url= http://10.10.150.103:8080/transport_server/rtgps/
-## gateway send directive
-#http.send.directive= http://10.10.150.103:8080/transport_server/message/
-## rfid data
-http.rfid.url= http://114.80.178.12:29000/rfid
-## wxsb
-#http.report.url.05= http://192.168.168.154:8088/ygjwsystem_j2ee/clbx/clbx_dd.do
-#http.report.url.22= http://192.168.168.154:8088/jgjwsystem_j2ee/clbx/clbx_dd.do
-#http.report.url.26= http://192.168.168.154:8088/nhjwsystem_j2ee/clbx/clbx_dd.do
-#http.report.url.55= http://192.168.168.154:8088/snjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.05= http://116.228.197.222:8081/ygjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.22= http://116.247.73.122:9098/jgjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.26= http://116.236.141.34:8088/nhjwsystem_j2ee/clbx/clbx_dd.do
-http.report.url.55= http://180.168.216.248:8088/snjwsystem_j2ee/clbx/clbx_dd.do
-## http ticketing interface
-http.ticketing.interface= http://112.64.187.3:1080/gjService/request
-## first last generate
-ms.fl.generate=false
-## dsm ack interface
-dsm.ack.url= http://211.95.61.66:9008/modules/dsmCheckTheRecord/addDsm?
-## cp ack interface
-cp.ack.url= http://114.80.178.12:8778/prod-api/serverApi/instructionsIssue/confirm/
-## admin mail
-admin.mail= 3090342880@qq.com
-## enabled
-enabled.sqlinject= false
-
 sso.enabled= true
 sso.systemcode = SYSUS023
 sso.http.url.login= http://10.10.200.142:9112/login?redirect=%2Findex
@@ -6,4 +6,4 @@
 ms.mysql.driver= com.mysql.jdbc.Driver
 ms.mysql.url= jdbc:mysql://10.10.150.103/ms?useUnicode=true&characterEncoding=utf-8
 ms.mysql.username= root
-ms.mysql.password= Aa123456
 \ No newline at end of file
+ms.mysql.password= fsodlgjiuigAQF2$9fs9
 \ No newline at end of file
@@ -6,4 +6,4 @@
 ms.mysql.driver= com.mysql.jdbc.Driver
 ms.mysql.url= jdbc:mysql://10.10.150.103/ms?useUnicode=true&characterEncoding=utf-8
 ms.mysql.username= root
-ms.mysql.password= Aa123456
 \ No newline at end of file
+ms.mysql.password= fsodlgjiuigAQF2$9fs9
 \ No newline at end of file