添加华电配置

src/main/java/com/dskj/znzn/transData/web/dataTransfer/entity/DataTransfer.java

@@ -26,7 +26,7 @@ import java.util.Date;
 @Setter
 @TableName("data_transfer")
 @ApiModel(value = "DataTransfer对象", description = "数据操作 ")
-public class DataTransfer implements Serializable {
+public class    DataTransfer implements Serializable {
 
     private static final long serialVersionUID = 1L;
 

src/main/resources/application-huadian.yml

@@ -1,11 +1,10 @@
 server:
   port: 9002
-
 spring:
   datasource:
-    url: jdbc:mysql://127.0.0.1:4000/energy_data?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&useSSL=false
+    url: jdbc:mysql://127.0.0.1:3306/energy_data_prod?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&useSSL=false
     username: root
-    password: 123456
+    password: admin123456
     driver-class-name: com.mysql.cj.jdbc.Driver
     druid:
       initial-size: 30
@@ -26,7 +25,6 @@ spring:
       time-between-eviction-runs-millis: 60000
       validation-query: SELECT 'x'
 
-
 knife4j:
   enable: true
   setting:
@@ -41,4 +39,4 @@ logging:
   level:
     com.dskj.znzn.transData.web.transConf.mapper: debug
     com.dskj.znzn.transData.web.waveData.mapper: debug
-  config: classpath:logback-prod.xml
+  config: classpath:logback-prod.xml

src/main/resources/application.yml

@@ -2,7 +2,7 @@ server:
   port: 9001
 spring:
   profiles:
-    active: prod
+    active: huadian
 
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver

src/main/resources/logback-dev.xml

@@ -5,7 +5,7 @@
     <property name="CHARSET" value="utf-8"/>
     <property name="MAX_FILE_SIZE" value="200MB"/>
     <property name="MAX_HISTORY" value="30"/>
-    <property name="BASE_LOG_PATH" value="/data/logs"/>
+    <property name="BASE_LOG_PATH" value="${user.home}/logs/"/>
     <property name="SERVICE_NAME" value="WindDataTrans"/>
 
     <appender name="console" class="ch.qos.logback.core.ConsoleAppender">

src/main/resources/logback-prod.xml

@@ -5,7 +5,7 @@
     <property name="CHARSET" value="utf-8"/>
     <property name="MAX_FILE_SIZE" value="200MB"/>
     <property name="MAX_HISTORY" value="30"/>
-    <property name="BASE_LOG_PATH" value="/home/trans/project/logs"/>
+    <property name="BASE_LOG_PATH" value="${user.home}/logs/"/>
     <property name="SERVICE_NAME" value="WindDataTrans"/>
 
     <appender name="console" class="ch.qos.logback.core.ConsoleAppender">

src/test/java/NavicateJieMi.java

@@ -0,0 +1,213 @@
+	
+import javax.crypto.Cipher;
+import javax.crypto.spec.IvParameterSpec;
+import javax.crypto.spec.SecretKeySpec;
+import javax.xml.bind.DatatypeConverter;
+import java.nio.charset.StandardCharsets;
+import java.security.MessageDigest;
+import java.util.Arrays;
+
+public class NavicateJieMi {
+	public static void main(String []args) {
+        //navicat11解密
+        Navicat11Cipher de = new Navicat11Cipher();
+        System.out.println(de.decryptString("6976000ED1E3C2"));
+        //navicat12+解密
+        Navicat12Cipher de12 = new Navicat12Cipher();
+        System.out.println(de12.decryptString("6976000ED1E3C2"));
+    }
+    static class Navicat11Cipher {
+        public static final String DefaultUserKey = "3DC5CA39";
+        private static byte[] _IV;
+
+        private static SecretKeySpec _Key;
+        private static Cipher _Encryptor;
+        private static Cipher _Decryptor;
+
+        private static void initKey(String UserKey) {
+            try {
+                MessageDigest sha1 = MessageDigest.getInstance("SHA1");
+                byte[] userkey_data = UserKey.getBytes(StandardCharsets.UTF_8);
+                sha1.update(userkey_data, 0, userkey_data.length);
+                _Key = new SecretKeySpec(sha1.digest(), "Blowfish");
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+
+        private static void initChiperEncrypt() {
+            try {
+                // Must use NoPadding
+                _Encryptor = Cipher.getInstance("Blowfish/ECB/NoPadding");
+                _Encryptor.init(Cipher.ENCRYPT_MODE, _Key);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+
+        private static void initChiperDecrypt() {
+            try {
+                // Must use NoPadding
+                _Decryptor = Cipher.getInstance("Blowfish/ECB/NoPadding");
+                _Decryptor.init(Cipher.DECRYPT_MODE, _Key);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+
+        private static void initIV() {
+            try {
+                byte[] initVec = DatatypeConverter.parseHexBinary("FFFFFFFFFFFFFFFF");
+                _IV = _Encryptor.doFinal(initVec);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+
+        private void xorBytes(byte[] a, byte[] b) {
+            for (int i = 0; i < a.length; i++) {
+                int aVal = a[i] & 0xff; // convert byte to integer
+                int bVal = b[i] & 0xff;
+                a[i] = (byte) (aVal ^ bVal); // xor aVal and bVal and typecast to byte
+            }
+        }
+
+        private void xorBytes(byte[] a, byte[] b, int l) {
+            for (int i = 0; i < l; i++) {
+                int aVal = a[i] & 0xff; // convert byte to integer
+                int bVal = b[i] & 0xff;
+                a[i] = (byte) (aVal ^ bVal); // xor aVal and bVal and typecast to byte
+            }
+        }
+
+        static {
+            initKey(DefaultUserKey);
+            initChiperEncrypt();
+            initChiperDecrypt();
+            initIV();
+        }
+
+        private byte[] Encrypt(byte[] inData) {
+            try {
+                byte[] CV = Arrays.copyOf(_IV, _IV.length);
+                byte[] ret = new byte[inData.length];
+
+                int blocks_len = inData.length / 8;
+                int left_len = inData.length % 8;
+
+                for (int i = 0; i < blocks_len; i++) {
+                    byte[] temp = Arrays.copyOfRange(inData, i * 8, (i * 8) + 8);
+
+                    xorBytes(temp, CV);
+                    temp = _Encryptor.doFinal(temp);
+                    xorBytes(CV, temp);
+
+                    System.arraycopy(temp, 0, ret, i * 8, 8);
+                }
+
+                if (left_len != 0) {
+                    CV = _Encryptor.doFinal(CV);
+                    byte[] temp = Arrays.copyOfRange(inData, blocks_len * 8, (blocks_len * 8) + left_len);
+                    xorBytes(temp, CV, left_len);
+                    System.arraycopy(temp, 0, ret, blocks_len * 8, temp.length);
+                }
+
+                return ret;
+            } catch (Exception e) {
+                e.printStackTrace();
+                return null;
+            }
+        }
+
+        public String encryptString(String inputString) {
+            try {
+                byte[] inData = inputString.getBytes(StandardCharsets.UTF_8);
+                byte[] outData = Encrypt(inData);
+                return DatatypeConverter.printHexBinary(outData);
+            } catch (Exception e) {
+                e.printStackTrace();
+                return "";
+            }
+        }
+
+        private byte[] Decrypt(byte[] inData) {
+            try {
+                byte[] CV = Arrays.copyOf(_IV, _IV.length);
+                byte[] ret = new byte[inData.length];
+
+                int blocks_len = inData.length / 8;
+                int left_len = inData.length % 8;
+
+                for (int i = 0; i < blocks_len; i++) {
+                    byte[] temp = Arrays.copyOfRange(inData, i * 8, (i * 8) + 8);
+
+                    temp = _Decryptor.doFinal(temp);
+                    xorBytes(temp, CV);
+                    System.arraycopy(temp, 0, ret, i * 8, 8);
+                    for (int j = 0; j < CV.length; j++) {
+                        CV[j] = (byte) (CV[j] ^ inData[i * 8 + j]);
+                    }
+                }
+
+                if (left_len != 0) {
+                    CV = _Encryptor.doFinal(CV);
+                    byte[] temp = Arrays.copyOfRange(inData, blocks_len * 8, (blocks_len * 8) + left_len);
+
+                    xorBytes(temp, CV, left_len);
+                    for (int j = 0; j < temp.length; j++) {
+                        ret[blocks_len * 8 + j] = temp[j];
+                    }
+                }
+
+                return ret;
+            } catch (Exception e) {
+                e.printStackTrace();
+                return null;
+            }
+        }
+
+        public String decryptString(String hexString) {
+            try {
+                byte[] inData = DatatypeConverter.parseHexBinary(hexString);
+                byte[] outData = Decrypt(inData);
+                return new String(outData, StandardCharsets.UTF_8);
+            } catch (Exception e) {
+                e.printStackTrace();
+                return "";
+            }
+        }
+    }
+    static class Navicat12Cipher {
+        private static SecretKeySpec _AesKey;
+        private static IvParameterSpec _AesIV;
+
+        static {
+            _AesKey = new SecretKeySpec("libcckeylibcckey".getBytes(StandardCharsets.UTF_8), "AES");
+            _AesIV = new IvParameterSpec("libcciv libcciv ".getBytes(StandardCharsets.UTF_8));
+        }
+
+        public String encryptString(String plaintext) {
+            try {
+                Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
+                cipher.init(Cipher.ENCRYPT_MODE, _AesKey, _AesIV);
+                byte[] ret = cipher.doFinal(plaintext.getBytes(StandardCharsets.UTF_8));
+                return DatatypeConverter.printHexBinary(ret);
+            } catch (Exception e) {
+                e.printStackTrace();
+                return "";
+            }
+        }
+
+        public String decryptString(String ciphertext) {
+            try {
+                Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
+                cipher.init(Cipher.DECRYPT_MODE, _AesKey, _AesIV);
+                byte[] ret = cipher.doFinal(DatatypeConverter.parseHexBinary(ciphertext));
+                return new String(ret, StandardCharsets.UTF_8);
+            } catch (Exception e) {
+                e.printStackTrace();
+                return "";
+            }
+        }
+    }
+}