修改数据库连接池属性信息

src/main/java/com/nmgs/controller/UserController.java

@@ -56,15 +56,27 @@ public class UserController {
                                              @RequestParam("IDNUMBER") String IDNUMBER,
                                              @RequestParam("REALNAME") String REALNAME,
                                              @RequestParam(value = "PHONE",required = false) String PHONE,
-                                             @RequestParam("NUMBERPIC") String NUMBERPIC){
+                                             @RequestParam(value = "NUMBERPIC", required = false) String NUMBERPIC) {
         LogUtil.WriteLog_Info("用户实名认证开始====" + PubTools.getCurrentDate() + "====" + USERID, "UserController");
         int i = userTableService.updateUser(USERID,IDNUMBER,PHONE,REALNAME,NUMBERPIC);
         LogUtil.WriteLog_Info("用户实名认证结束========" + PubTools.getCurrentDate(), "UserController");
         if(i<0){
-            return ResultData.fail("认证失败");
+            if (i == -99) {
+                return ResultData.fail("身份证附件没有上传");
+            } else if (i == -98) {
+                return ResultData.fail("附件无法识别");
+            } else if (i == -97) {
+                return ResultData.fail("姓名与附件上面信息不符");
+            } else if (i == -96) {
+                return ResultData.fail("身份证号与附件上面信息不符");
+            } else {
+                return ResultData.fail("认证失败");
+            }
         }else if(i>0){
             //WebsocketUtil.sendCheckMessageForAll("user");
-            redisConfigUtil.publish("USER", "user");
+            if (i == 1) {
+                redisConfigUtil.publish("USER", "user");
+            }
             //测试取消订阅
             // redisConfigUtil.publish(Consistant.USER + USERID, "unSubscribe_" + USERID);
             return ResultData.success(1,"已提交");

src/main/java/com/nmgs/controller/UserVehicleController.java

@@ -169,10 +169,20 @@ public class UserVehicleController {
         int ret = this.userVehicleService.updateUserVehicle(USERID,ACARNO,CHECKUSERNAME,CHECKUSERNUMBER,LICENSEPIC,PERMITPIC,VEHICLEPIC,CERTIFICATION,REFERRERCODE);
         if(ret >0){
             // WebsocketUtil.sendCheckMessageForAll("car");
-            redisConfigUtil.publish("CAR", "car");
+            if (ret == 1) {
+                redisConfigUtil.publish("CAR", "car");
+            }
             return ResultData.success("更新成功");
         }else{
-            return ResultData.fail("更新车牌信息出错");
+            if (ret == -99) {
+                return ResultData.fail("行驶证没有上传");
+            } else if (ret == -98) {
+                return ResultData.fail("行驶证无法识别");
+            } else if (ret == -97) {
+                return ResultData.fail("姓名与行驶证上面信息不符");
+            } else {
+                return ResultData.fail("更新车牌信息出错");
+            }
         }
     }
 }

src/main/java/com/nmgs/util/PubTools.java

@@ -4,9 +4,12 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import oracle.sql.CLOB;
 
+import java.io.File;
 import java.lang.reflect.Array;
 import java.math.BigDecimal;
 import java.math.BigInteger;
+import java.net.HttpURLConnection;
+import java.net.URL;
 import java.sql.Blob;
 import java.sql.Clob;
 import java.text.ParseException;
@@ -19,7 +22,7 @@ public class PubTools {
     static SimpleDateFormat dfYMD = new SimpleDateFormat("yyyyMMdd");
 
 
-
+    public static String HTTPS = PropertiesUtil.getValue("domainInteger") + File.separator;
     /**
      * 判断字符串是否为空
      * yyp 20190305
@@ -232,6 +235,57 @@ public class PubTools {
         }
         return reString;
     }
+
+    /**
+     * 远程网络请求，需要能访问外网的环境：根据路径判断附件是否存在
+     *
+     * @param imageUrl
+     * @return
+     */
+    public static boolean isImageExist(String imageUrl) {
+        try {
+            URL url = new URL(PubTools.HTTPS + imageUrl);
+            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+            conn.setRequestMethod("HEAD");  // 仅获取响应头‌:ml-citation{ref="3,8" data="citationList"}
+            conn.setConnectTimeout(5000);
+            int statusCode = conn.getResponseCode();
+            if (statusCode != 200) return false;  // 非200状态码直接返回失败‌:ml-citation{ref="3,8" data="citationList"}
+
+            return true;  // 验证是否为图片类型‌:ml-citation{ref="1,6" data="citationList"}
+        } catch (Exception e) {
+            return false;
+        }
+    }
+
+    /**
+     * 本地访问：根据路径判断附件是否存在
+     *
+     * @param imageUrl
+     * @return
+     */
+    public static boolean isImageExistLocal(String imageUrl) {
+        try {
+            URL url = new URL(imageUrl);
+            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+            conn.setRequestMethod("HEAD");  // 仅获取响应头‌:ml-citation{ref="3,8" data="citationList"}
+            conn.setConnectTimeout(5000);
+            int statusCode = conn.getResponseCode();
+            if (statusCode != 200) return false;  // 非200状态码直接返回失败‌:ml-citation{ref="3,8" data="citationList"}
+
+            return true;  // 验证是否为图片类型‌:ml-citation{ref="1,6" data="citationList"}
+        } catch (Exception e) {
+            return false;
+        }
+    }
+
+    public static int getEnabledOcr() {
+        int a = 0;
+        String ocrenabled = PropertiesUtil.getValue("OCRENABLED");
+        if ("1".equals(ocrenabled)) {
+            a = 1;
+        }
+        return a;
+    }
 }
 
 

src/main/java/com/nmgs/util/redisConfigUtil.java

@@ -5,12 +5,14 @@ import com.nmgs.config.RedisSessionConfig;
 import com.nmgs.entity.Consistant;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 import redis.clients.jedis.Jedis;
 
 import java.util.concurrent.TimeUnit;
 
 @Component
+@Async
 public class redisConfigUtil {
     public  static  RedisTemplate<String, Object> redisTemplate;
 
@@ -27,7 +29,11 @@ public class redisConfigUtil {
      * @param key
      */
     public static void publish(String key, String value) {
-        redisTemplate.convertAndSend(key, value);
+        try {
+            redisTemplate.convertAndSend(key, value);
+        } catch (Exception e) {
+            LogUtil.WriteLog_Error("redis出错====" + e.getMessage(), "redisConfigUtil");
+        }
     }
 
     /**

src/main/resources/static/application.properties

@@ -11,16 +11,18 @@ server.servlet.encoding.force=true
 spring.messages.encoding=UTF-8
 spring.profiles.active=dev
 # ?????
-spring.datasource.hikari.maximum-pool-size=10000
+spring.datasource.hikari.maximum-pool-size=100
 spring.datasource.hikari.auto-commit=true
-spring.datasource.hikari.idle-timeout=0
+spring.datasource.hikari.idle-timeout=300000
 spring.datasource.hikari.pool-name=DatebookHikariCP
-spring.datasource.hikari.max-lifetime=300000
+spring.datasource.hikari.max-lifetime=600000
 spring.datasource.hikari.connection-timeout=600000
-spring.datasource.hikari.minimum-idle=1
+spring.datasource.hikari.minimum-idle=5
 spring.datasource.hikari.allow-pool-suspension=true
 spring.datasource.hikari.register-mbeans=true
 spring.datasource.hikari.leak-detection-threshold=600000
+#??HikariCP??
+logging.level.com.zaxxer.hikari=DEBUG
 spring.devtools.restart.enabled=true
 spring.devtools.restart.additional-paths=src/main
 spring.session.store-type=none