li_chx
/
Java_multithreaded_synthesis_experiments
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

首次git提交，用于lichx个人的多端同步

This commit is contained in:
lichx 2023-12-19 16:25:28 +08:00
commit d3a94abd6d
59 changed files with 4246 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
.gitignore vendored Normal file
View File

@ -0,0 +1,29 @@
### IntelliJ IDEA ###
out/
!**/src/main/**/out/
!**/src/test/**/out/
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
bin/
!**/src/main/**/bin/
!**/src/test/**/bin/
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

8
.idea/.gitignore vendored Normal file
View File

@ -0,0 +1,8 @@
# 默认忽略的文件
/shelf/
/workspace.xml
# 基于编辑器的 HTTP 客户端请求
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml

12
.idea/dataSources.xml Normal file
View File

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="DataSourceManagerImpl" format="xml" multifile-model="true">
<data-source source="LOCAL" name="@127.0.0.1" uuid="11d26e98-f022-4cdd-82a4-a9a4a1456d73">
<driver-ref>mysql.8</driver-ref>
<synchronize>true</synchronize>
<jdbc-driver>com.mysql.cj.jdbc.Driver</jdbc-driver>
<jdbc-url>jdbc:mysql://127.0.0.1:3306</jdbc-url>
<working-dir>$ProjectFileDir$</working-dir>
</data-source>
</component>
</project>

9
.idea/libraries/mysql_connector_java_8_0_27.xml Normal file
View File

@ -0,0 +1,9 @@
<component name="libraryTable">
<library name="mysql-connector-java-8.0.27">
<CLASSES>
<root url="jar://$PROJECT_DIR$/libs/mysql-connector-java-8.0.27.jar!/" />
</CLASSES>
<JAVADOC />
<SOURCES />
</library>
</component>

5
.idea/misc.xml Normal file
View File

@ -0,0 +1,5 @@
<project version="4">
<component name="ProjectRootManager" version="2" languageLevel="JDK_20" default="true" project-jdk-name="20" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/out" />
</component>
</project>

8
.idea/modules.xml Normal file
View File

@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectModuleManager">
<modules>
<module fileurl="file://$PROJECT_DIR$/Object-oriented vs. multithreaded synthesis experiments.iml" filepath="$PROJECT_DIR$/Object-oriented vs. multithreaded synthesis experiments.iml" />
</modules>
</component>
</project>

124
.idea/uiDesigner.xml Normal file
View File

@ -0,0 +1,124 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Palette2">
<group name="Swing">
<item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
</item>
<item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
</item>
<item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.svg" removable="false" auto-create-binding="false" can-attach-label="true">
<default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
</item>
<item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
<initial-values>
<property name="text" value="Button" />
</initial-values>
</item>
<item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="RadioButton" />
</initial-values>
</item>
<item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="CheckBox" />
</initial-values>
</item>
<item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
<initial-values>
<property name="text" value="Label" />
</initial-values>
</item>
<item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
</item>
<item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
</item>
<item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
<preferred-size width="-1" height="20" />
</default-constraints>
</item>
<item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
</item>
<item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
</item>
</group>
</component>
</project>

6
.idea/vcs.xml Normal file
View File

@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$" vcs="Git" />
</component>
</project>

BIN
MatchLogs.txt Normal file
View File

Binary file not shown.

BIN
MatchedTransports.txt Normal file
View File

Binary file not shown.

22
Object-oriented vs. multithreaded synthesis experiments.iml Normal file
View File

@ -0,0 +1,22 @@
<?xml version="1.0" encoding="UTF-8"?>
<module type="JAVA_MODULE" version="4">
<component name="NewModuleRootManager" inherit-compiler-output="true">
<exclude-output />
<content url="file://$MODULE_DIR$">
<sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="library" name="mysql-connector-java-8.0.27" level="project" />
<orderEntry type="module-library">
<library>
<CLASSES>
<root url="file://$MODULE_DIR$/../../../Java-lib/javafx-sdk-20.0.1/lib" />
</CLASSES>
<JAVADOC />
<SOURCES />
<jarDirectory url="file://$MODULE_DIR$/../../../Java-lib/javafx-sdk-20.0.1/lib" recursive="false" />
</library>
</orderEntry>
</component>
</module>

BIN
libs/mysql-connector-java-8.0.27.jar Normal file
View File

Binary file not shown.

119
src/com/qst/dms/db/DBUtil.java Normal file
View File

@ -0,0 +1,119 @@
package com.qst.dms.db;
import java.sql.*;
import com.qst.dms.util.Config;
public class DBUtil {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
/**
* 得到数据库连接
*/
public Connection getConnection() throws ClassNotFoundException,
SQLException, InstantiationException, IllegalAccessException {
// 通过Config获取MySQL数据库配置信息
String driver = Config.getValue("driver");
String url = Config.getValue("url");
String user = Config.getValue("user");
String pwd = Config.getValue("password");
try {
// 指定驱动程序
Class.forName(driver);
// 建立数据库连结
conn = DriverManager.getConnection(url, user, pwd);
return conn;
} catch (Exception e) {
// 如果连接过程出现异常，抛出异常信息
throw new SQLException("驱动错误或连接失败！");
}
}
/**
* 释放资源
*/
public void closeAll() {
// 如果rs不空，关闭rs
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
// 如果pstmt不空，关闭pstmt
if (pstmt != null) {
try {
pstmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
// 如果conn不空，关闭conn
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 执行SQL语句，可以进行查询
*/
public ResultSet executeQuery(String preparedSql, Object[] param) {
// 处理SQL,执行SQL
try {
// 得到PreparedStatement对象
pstmt = conn.prepareStatement(preparedSql);
if (param != null) {
for (int i = 0; i < param.length; i++) {
// 为预编译sql设置参数
pstmt.setObject(i + 1, param[i]);
}
}
// 执行SQL语句
rs = pstmt.executeQuery();
} catch (SQLException e) {
// 处理SQLException异常
e.printStackTrace();
}
return rs;
}
/**
* 执行SQL语句，可以进行增、删、改的操作，不能执行查询
*/
public int executeUpdate(String preparedSql, Object[] param) throws SQLIntegrityConstraintViolationException
{
int num = 0;
// 处理SQL,执行SQL
try {
// 得到PreparedStatement对象
pstmt = conn.prepareStatement(preparedSql);
if (param != null) {
for (int i = 0; i < param.length; i++) {
// 为预编译sql设置参数
pstmt.setObject(i + 1, param[i]);
}
}
// 执行SQL语句
num = pstmt.executeUpdate();
}
catch(SQLIntegrityConstraintViolationException e)
{
throw e;
}
//你都catch完了 我catch啥 那SQLIntegrityConstraintViolationException应该打印吗？
//我觉得直接catch然后throw给外部吧
catch (SQLException e) {
// 处理SQLException异常
e.printStackTrace();
}
return num;
}
}

5
src/com/qst/dms/db/config/mysql.properties Normal file
View File

@ -0,0 +1,5 @@
driver = com.mysql.cj.jdbc.Driver
url = jdbc:mysql://localhost:3306/q_dms?useUnicode=true&characterEncoding=UTF-8
user = root
password = 123456
serverIP=127.0.0.1

66
src/com/qst/dms/dos/DBDemo.java Normal file
View File

@ -0,0 +1,66 @@
package com.qst.dms.dos;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
import com.qst.dms.entity.DataBase;
import com.qst.dms.entity.LogRec;
import com.qst.dms.entity.MatchedLogRec;
import com.qst.dms.entity.MatchedTransport;
import com.qst.dms.entity.Transport;
import com.qst.dms.service.LogRecService;
import com.qst.dms.service.TransportService;
public class DBDemo {
public static void main(String[] args) {
// 创建一个日志业务类
LogRecService logService = new LogRecService();
ArrayList<MatchedLogRec> matchLogs = new ArrayList<>();
matchLogs.add(new MatchedLogRec(
new LogRec(1001, new Date(), "青島",DataBase.GATHER, "zhangsan", "192.168.1.1", 1),
new LogRec(1002, new Date(), "青島", DataBase.GATHER, "zhangsan", "192.168.1.1", 0)));
matchLogs.add(new MatchedLogRec(
new LogRec(1003, new Date(), "北京",DataBase.GATHER, "lisi", "192.168.1.6", 1),
new LogRec(1004, new Date(), "北京", DataBase.GATHER, "lisi", "192.168.1.6", 0)));
matchLogs.add(new MatchedLogRec(
new LogRec(1005, new Date(), "济南",DataBase.GATHER, "wangwu", "192.168.1.89", 1),
new LogRec(1006, new Date(), "济南", DataBase.GATHER, "wangwu", "192.168.1.89", 0)));
//保存匹配的日志信息到数据库中
logService.saveMatchLogToDB(matchLogs);
//从数据库中读取匹配的日志信息
ArrayList<MatchedLogRec> logList = null;
try
{
logList = logService.readMatchedLogFromDB();
} catch (SQLException e)
{
e.printStackTrace();
}
logService.showMatchLog(logList);
// 创建一个物流业务类
TransportService tranService = new TransportService();
ArrayList<MatchedTransport> matchTrans = new ArrayList<>();
matchTrans.add(new MatchedTransport(
new Transport(2001, new Date(), "青島",DataBase.GATHER,"zhangsan","zhaokel",1),
new Transport(2002, new Date(), "北京",DataBase.GATHER,"lisi","zhaokel",2),
new Transport(2003, new Date(), "北京",DataBase.GATHER,"wangwu","zhaokel",3)));
matchTrans.add(new MatchedTransport(
new Transport(2004, new Date(), "青島",DataBase.GATHER,"maliu","w",1),
new Transport(2005, new Date(), "北京",DataBase.GATHER,"sunqi","w",2),
new Transport(2006, new Date(), "北京",DataBase.GATHER,"fengba","w",3)));
//保存匹配的物流信息到数据库中
tranService.saveMatchTransportToDB(matchTrans);
//从数据库中中读取匹配的物流信息
ArrayList<MatchedTransport> transportList = null;
try
{
transportList = tranService.readMatchedTransportFromDB();
} catch (SQLException e)
{
e.printStackTrace();
}
tranService.showMatchTransport(transportList);
}
}

34
src/com/qst/dms/dos/EntityDataDemo.java Normal file
View File

@ -0,0 +1,34 @@
package com.qst.dms.dos;
import com.qst.dms.entity.LogRec;
import com.qst.dms.entity.Transport;
import com.qst.dms.service.LogRecService;
import com.qst.dms.service.TransportService;
public class EntityDataDemo {
public static void main(String[] args) {
// 创建一个日志业务类
LogRecService logService = new LogRecService();
// 创建一个日志对象数组，用于存放采集的三个日志信息
LogRec[] logs = new LogRec[3];
for (int i = 0; i < logs.length; i++) {
System.out.println("第"+(i+1)+"个日志数据采集：");
logs[i] = logService.inputLog();
}
// 输出采集的日志信息
logService.showLog(logs);
// 创建一个物流业务类
TransportService tranService = new TransportService();
// 创建一个物流对象数组，用于存放采集的两个物流信息
Transport[] transports = new Transport[2];
for (int i = 0; i < transports.length; i++) {
System.out.println("第"+(i+1)+"个物流数据采集：");
transports[i] = tranService.inputTransport();
}
//输出采集的物流信息
tranService.showTransport(transports);
}
}

56
src/com/qst/dms/dos/FileDemo.java Normal file
View File

@ -0,0 +1,56 @@
package com.qst.dms.dos;
import java.util.ArrayList;
import java.util.Date;
import com.qst.dms.entity.DataBase;
import com.qst.dms.entity.LogRec;
import com.qst.dms.entity.MatchedLogRec;
import com.qst.dms.entity.MatchedTransport;
import com.qst.dms.entity.Transport;
import com.qst.dms.service.LogRecService;
import com.qst.dms.service.TransportService;
public class FileDemo {
public static void main(String[] args) {
// 创建一个日志业务类
LogRecService logService = new LogRecService();
ArrayList<MatchedLogRec> matchLogs = new ArrayList<>();
matchLogs.add(new MatchedLogRec(
new LogRec(1001, new Date(), "青島",DataBase.GATHER, "zhangsan", "192.168.1.1", 1),
new LogRec(1002, new Date(), "青島", DataBase.GATHER, "zhangsan", "192.168.1.1", 0)));
matchLogs.add(new MatchedLogRec(
new LogRec(1003, new Date(), "北京",DataBase.GATHER, "lisi", "192.168.1.6", 1),
new LogRec(1004, new Date(), "北京", DataBase.GATHER, "lisi", "192.168.1.6", 0)));
matchLogs.add(new MatchedLogRec(
new LogRec(1005, new Date(), "济南",DataBase.GATHER, "wangwu", "192.168.1.89", 1),
new LogRec(1006, new Date(), "济南", DataBase.GATHER, "wangwu", "192.168.1.89", 0)));
//保存匹配的日志信息到文件中
//logService.saveMatchLog(matchLogs);
logService.saveAndAppendMatchLog(matchLogs); //追加测试
//保存匹配的日志信息到数据库中
//logService.saveMatchLogToDB(matchLogs);
//从文件中读取匹配的日志信息
ArrayList<MatchedLogRec> list1 = logService.readMatchLog();
logService.showMatchLog(list1);
// 创建一个物流业务类
TransportService tranService = new TransportService();
ArrayList<MatchedTransport> matchTrans = new ArrayList<>();
matchTrans.add(new MatchedTransport(
new Transport(2001, new Date(), "青島",DataBase.GATHER,"zhangsan","zhaokel",1),
new Transport(2002, new Date(), "北京",DataBase.GATHER,"lisi","zhaokel",2),
new Transport(2003, new Date(), "北京",DataBase.GATHER,"wangwu","zhaokel",3)));
matchTrans.add(new MatchedTransport(
new Transport(2004, new Date(), "青島",DataBase.GATHER,"maliu","zhaokel",1),
new Transport(2005, new Date(), "北京",DataBase.GATHER,"sunqi","zhaokel",2),
new Transport(2006, new Date(), "北京",DataBase.GATHER,"fengba","zhaokel",3)));
//保存匹配的物流信息到文件中
tranService.saveMatchedTransport(matchTrans);
//保存匹配的物流信息到数据库中
//tranService.saveMatchTransportToDB(matchTrans);
//从文件中读取匹配的物流信息
ArrayList<MatchedTransport> list2 = tranService.readMatchedTransport();
tranService.showMatchTransport(list2);
}
}

20
src/com/qst/dms/dos/LogRecDemo.java Normal file
View File

@ -0,0 +1,20 @@
package com.qst.dms.dos;
import com.qst.dms.entity.LogRec;
import com.qst.dms.service.LogRecService;
public class LogRecDemo {
public static void main(String[] args) {
// 创建一个日志业务类
LogRecService logService = new LogRecService();
// 创建一个日志对象数组，用于存放采集的三个日志信息
LogRec[] logs = new LogRec[3];
for (int i = 0; i < logs.length; i++) {
System.out.println("第" + (i + 1) + "个日志数据采集：");
logs[i] = logService.inputLog();
}
// 显示日志信息
logService.showLog(logs);
}
}

210
src/com/qst/dms/dos/MenuDriver.java Normal file
View File

@ -0,0 +1,210 @@
package com.qst.dms.dos;
import java.util.ArrayList;
import java.util.InputMismatchException;
import java.util.Scanner;
import com.qst.dms.entity.LogRec;
import com.qst.dms.entity.MatchedLogRec;
import com.qst.dms.entity.MatchedTransport;
import com.qst.dms.entity.Transport;
import com.qst.dms.gather.LogRecAnalyse;
import com.qst.dms.gather.TransportAnalyse;
import com.qst.dms.service.LogRecService;
import com.qst.dms.service.TransportService;
public class MenuDriver
{
public static void main(String[] args)
{
// 建立一个从键盘接收数据的扫描器
Scanner scanner = new Scanner(System.in);
// 创建一个泛型ArrayList集合存储日志数据
ArrayList<LogRec> logRecList = new ArrayList<>();
// 创建一个泛型ArrayList集合存储物流数据
ArrayList<Transport> transportList = new ArrayList<>();
// 创建一个日志业务类
LogRecService logService = new LogRecService();
// 创建一个物流业务类
TransportService tranService = new TransportService();
// 日志数据匹配集合
ArrayList<MatchedLogRec> matchedLogs = null;
// 物流数据匹配集合
ArrayList<MatchedTransport> matchedTrans = null;
try
{
while (true)
{
// 输出菜单界面，需补充
//...
System.out.println("********************************************");
System.out.println("欢迎进入日志物流信息管理系统！");
System.out.println("* 1、数据采集 2、数据匹配 *");
System.out.println("* 3、数据记录 4、数据显示 *");
System.out.println("* 5、数据发送 0、退出应用 *");
System.out.println("********************************************");
// 提示用户输入要操作的菜单项
System.out.println("请输入菜单项（0~5）：");
// 接收键盘输入的选项
int choice;
for (; ; )
try
{
choice = scanner.nextInt();
break;
} catch (InputMismatchException e)
{
System.out.println("输入数据不合法，请重新输入");
scanner.nextLine();
}
switch (choice)
{
case 1:
{
System.out.println("请输入采集数据类型：1.日志 2.物流");
// 接收键盘输入的选项
int type = scanner.nextInt();
if (type == 1)
{
System.out.println("正在采集日志数据，请输入正确信息，确保数据的正常采集！");
// 采集日志数据，需补充LogService类中的inputLog方法
LogRec log = logService.inputLog();
// 将采集的日志数据添加到logRecList集合中
logRecList.add(log);
} else if (type == 2)
{
System.out.println("正在采集物流数据，请输入正确信息，确保数据的正常采集！");
// 采集物流数据，需补充tranService类中的inputTransport方法
Transport tran = tranService.inputTransport();
// 将采集的物流数据添加到transportList集合中
transportList.add(tran);
}
}
break;
case 2:
{
System.out.println("请输入匹配数据类型：1.日志 2.物流");
// 接收键盘输入的选项
int type = scanner.nextInt();
if (type == 1)
{
System.out.println("正在日志数据过滤匹配...");
// 创建日志数据分析对象，用于日志数据筛选与匹配
LogRecAnalyse logAn = new LogRecAnalyse(logRecList);
// 需实现doFilter抽象方法，对日志数据进行过滤，根据日志登录状态
//分别放在登录和登出两个集合中
logAn.doFilter();
// 日志数据分析
matchedLogs = logAn.matchData();
System.out.println("日志数据过滤匹配完成！");
} else if (type == 2)
{
System.out.println("正在物流数据过滤匹配...");
// 创建物流数据分析对象
TransportAnalyse transAn = new TransportAnalyse(
transportList);
// 物流数据过滤
transAn.doFilter();
// 物流数据分析
matchedTrans = transAn.matchData();
System.out.println("物流数据过滤匹配完成！");
}
}
break;
case 3:
System.out.println("请输入记录数据类型：1.日志 2.物流");
int type = 0;
while (true)
{
if (scanner.hasNextInt())
{
type = scanner.nextInt();
if (type >= 1 && type <= 2)
break;
else
System.out.println("请输入合法的数字");
} else
{
System.out.println("请输入合法的数字");
scanner.nextLine();
}
}
try
{
if (type == 1)
{
//logService.saveMatchLog(matchedLogs); 2023.11.17 改为追加方式
logService.saveAndAppendMatchLog(matchedLogs);
logService.saveMatchLogToDB(matchedLogs);//添加至DB
logRecList.clear();
matchedLogs.clear();
//添加数据库追加
} else if (type == 2)
{
//tranService.saveMatchedTransport(matchedTrans); 2023.11.17 改为追加方式
tranService.saveAndAppendTransport(matchedTrans);
tranService.saveMatchTransportToDB(matchedTrans);//添加至DB
transportList.clear();
matchedTrans.clear();
}
}
catch(NullPointerException ex)
{
System.out.println("没有信息需要记录");
}
break;
case 4:
{
System.out.println("显示匹配的数据：");
// ArrayList<MatchedLogRec> last_log = logService.readMatchLog();
// ArrayList<MatchedTransport> last_transport = tranService.readMatchedTransport(); 2023.11.25改为读取数据库数据
ArrayList<MatchedLogRec>last_log = logService.readMatchedLogFromDB();
ArrayList<MatchedTransport>last_transport = tranService.readMatchedTransportFromDB();
if (last_log.isEmpty() && (matchedLogs == null || matchedLogs.isEmpty()))
{
System.out.println("匹配的日志记录是0条！");
} else
{
//输出匹配的日志信息
System.out.println("日志:");
if (!last_log.isEmpty())
logService.showMatchLog(last_log);
if (matchedLogs != null && (!matchedLogs.isEmpty()))
logService.showMatchLog(matchedLogs);
}
if (last_transport.isEmpty() && (matchedTrans == null || matchedTrans.isEmpty()))
{
System.out.println("匹配的物流记录是0条！");
} else
{
// 输出匹配的物流信息
System.out.println("物流:");
if (!last_transport.isEmpty())
tranService.showMatchTransport(last_transport);
if (matchedTrans != null && (!matchedTrans.isEmpty()))
tranService.showMatchTransport(matchedTrans);
}
}
break;
case 5:
System.out.println("数据发送 中...");
break;
case 0:
// 应用程序退出
System.exit(0);
default:
System.out.println("请输入正确的菜单项（0~5）！");
}
}
} catch (Exception e)
{
System.out.println("输入的数据不合法！");
}
}
}

22
src/com/qst/dms/dos/TransportDemo.java Normal file
View File

@ -0,0 +1,22 @@
package com.qst.dms.dos;
import com.qst.dms.entity.Transport;
import com.qst.dms.service.TransportService;
public class TransportDemo {
public static void main(String[] args) {
// 创建一个物流业务类
TransportService tranService = new TransportService();
// 创建一个物流对象数组，用于存放采集的四个物流信息
Transport[] transports = new Transport[4];
for (int i = 0; i < transports.length; i++) {
System.out.println("第" + (i + 1) + "个物流数据采集：");
transports[i] = tranService.inputTransport();
}
// 显示物流信息
tranService.showTransport(transports);
}
}

30
src/com/qst/dms/entity/AppendObjectOutputStream.java Normal file
View File

@ -0,0 +1,30 @@
package com.qst.dms.entity;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
public class AppendObjectOutputStream extends ObjectOutputStream
{
public static File file = null;
public AppendObjectOutputStream() throws IOException
{
super(new FileOutputStream(file,true));
//AppendObjectOutputStream.file = file; 这不可行 因为 上面的构造函数调用了writeStreamHeadler 然后file=null 所以需要在外部提前赋值
}
public void writeStreamHeader() throws IOException
{
if(file!=null)
{
if (file.length() == 0)
super.writeStreamHeader();
else
{
//super.
this.reset();
}
} else
super.writeStreamHeader();
}
}

79
src/com/qst/dms/entity/DataBase.java Normal file
View File

@ -0,0 +1,79 @@
package com.qst.dms.entity;
import java.io.Serializable;
import java.util.Date;
//数据基础类
public class DataBase implements Serializable{
// ID标识
private int id;
// 时间
private Date time;
// 地点
private String address;
// 状态
private int type;
// 状态常量
public static final int GATHER=1;//"采集"
public static final int MATHCH=2;//"匹配";
public static final int RECORD=3;//"记录";
public static final int SEND=4;//"发送";
public static final int RECIVE=5;//"接收";
public static final int WRITE=6;//"归档";
public static final int SAVE=7;//"保存";
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public Date getTime() {
return time;
}
public void setTime(Date time) {
this.time = time;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
public int getType() {
return type;
}
public void setType(int type) {
this.type = type;
}
public DataBase() {
}
public DataBase(int id, Date time, String address, int type) {
this.id = id;
this.time = time;
this.address = address;
this.type = type;
}
public String toString() {
return id + "," + time + "," + address + "," + type;
}
}

85
src/com/qst/dms/entity/LogRec.java Normal file
View File

@ -0,0 +1,85 @@
package com.qst.dms.entity;
import java.io.Serializable;
import java.sql.Timestamp;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.Date;
//用户登录日志记录
public class LogRec extends DataBase implements Serializable{
/**
* 登录用户名
*/
private String user;
/**
* 登录用户主机IP地址
*/
private String ip;
/**
* 登录状态：登录、登出
*/
private int logType;
/**
* 登录常量LOG_IN、登出常量常量LOG_OUT
*/
public static final int LOG_IN=1;
public static final int LOG_OUT=0;
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getIp() {
return ip;
}
public void setIp(String ip) {
this.ip = ip;
}
public int getLogType() {
return logType;
}
public static LogRec get_LogRec(Object[] info)
{
int id = (int)info[0],type = (int)info[3],logtype = (int)info[6];
Date time = Date.from( ((LocalDateTime)info[1]).atZone( ZoneId.systemDefault()).toInstant());
String address = (String)info[2],username = (String)info[4],ip = (String)info[5];
return new LogRec(id,time,address,type,username,ip,logtype);
}
public Object[] get_DB_param()
{
return new Object[]{
this.getId(),
new Timestamp(this.getTime().getTime()),
this.getAddress(),this.getType(),this.getUser(),
this.getIp(),this.getLogType()
};
}
public void setLogType(int logType) {
this.logType = logType;
}
public LogRec() {
}
public LogRec(int id, Date time, String address, int type,String user,String ip,int logType) {
super(id,time,address,type);
this.user=user;
this.ip=ip;
this.logType=logType;
}
public String toString() {
return this.getId() + "," +this.getTime() + "," +this.getAddress() + "," + this.getType() + ","+user+","+ip+","+logType;
}
}

72
src/com/qst/dms/entity/MatchedLogRec.java Normal file
View File

@ -0,0 +1,72 @@
package com.qst.dms.entity;
import java.io.Serializable;
import java.sql.Timestamp;
import java.util.Date;
//匹配日志记录，"登录登出对" 类型
public class MatchedLogRec implements Serializable {
private LogRec login;
private LogRec logout;
// user用户登录名
public String getUser() {
return login.getUser();
}
//登录地点
public String getAddress(){return login.getAddress();}
// 登入时刻
public Date getLogInTime() {
return login.getTime();
}
// 登出时刻
public Date getLogoutTime() {
return logout.getTime();
}
// 登入记录
public LogRec getLogin() {
return login;
}
// 登出记录
public LogRec getLogout() {
return logout;
}
public Object[] get_DB_param()
{
return new Object[]{
login.getId(),logout.getId()
};
}
public MatchedLogRec() {
}
public MatchedLogRec(LogRec login, LogRec logout) {
if (login.getLogType() != LogRec.LOG_IN) {
throw new RuntimeException("不是登录记录!");
}
if (logout.getLogType() != LogRec.LOG_OUT) {
throw new RuntimeException("不是登出记录");
}
if (!login.getUser().equals(logout.getUser())) {
throw new RuntimeException("登录登出必须是同一个用户!");
}
if (!login.getIp().equals(logout.getIp())) {
throw new RuntimeException("登录登出必须是同一个IP地址!");
}
this.login = login;
this.logout = logout;
}
public String toString() {
return login.toString() + " | " + logout.toString();
}
}

62
src/com/qst/dms/entity/MatchedTransport.java Normal file
View File

@ -0,0 +1,62 @@
/**
* @公司 青软实训QST
* @作者 zhaokl
*/
package com.qst.dms.entity;
import java.io.Serializable;
public class MatchedTransport implements Serializable{
private Transport send;
private Transport trans;
private Transport receive;
public Transport getSend() {
return send;
}
public void setSend(Transport send) {
this.send = send;
}
public Transport getTrans() {
return trans;
}
public void setTrans(Transport trans) {
this.trans = trans;
}
public Transport getReceive() {
return receive;
}
public void setReceive(Transport receive) {
this.receive = receive;
}
public MatchedTransport() {
}
public MatchedTransport(Transport send, Transport trans, Transport receive) {
if (send.getTransportType() != Transport.SENDING) {
throw new RuntimeException("不是发货记录!");
}
if (trans.getTransportType() != Transport.TRANSPORTING) {
throw new RuntimeException("不是送货记录!");
}
if (receive.getTransportType() != Transport.RECEIVED) {
throw new RuntimeException("不是签收记录!");
}
this.send = send;
this.trans = trans;
this.receive = receive;
}
public String toString() {
// TODO Auto-generated method stub
return send.toString() + "|" + trans.toString() + "|" + receive;
}
}

92
src/com/qst/dms/entity/Transport.java Normal file
View File

@ -0,0 +1,92 @@
/**
* @公司 青软实训QST
* @作者 zhaokl
*/
package com.qst.dms.entity;
import java.io.Serializable;
import java.sql.Timestamp;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.Date;
//货运物流信息
public class Transport extends DataBase implements Serializable{
/**
* 经手人
*/
private String handler;
/**
* 收货人
*/
private String reciver;
/**
* 物流状态
*/
private int transportType;
/**
* 物流状态常量:发货中, 送货中, 已签收
*/
public static final int SENDING = 1;// 发货中
public static final int TRANSPORTING = 2;// 送货中
public static final int RECEIVED = 3;// 已签收
public String getHandler() {
return handler;
}
public void setHandler(String handler) {
this.handler = handler;
}
public String getReciver() {
return reciver;
}
public void setReciver(String reciver) {
this.reciver = reciver;
}
public int getTransportType() {
return transportType;
}
public void setTransportType(int transportType) {
this.transportType = transportType;
}
public Transport() {
}
public Transport(int id, Date time, String address, int type,
String handler, String reciver, int transportType) {
super(id, time, address, type);
this.handler = handler;
this.reciver = reciver;
this.transportType = transportType;
}
static public Transport get_Transport(Object[] info)
{
int id = (Integer) info[0],type = (Integer) info[3],transportType = (Integer) info[6];
Date time = Date.from( ((LocalDateTime)info[1]).atZone( ZoneId.systemDefault()).toInstant());
String address = (String) info[2],handler = (String) info[4],reciver = (String)info[5];
return new Transport(id,time,address,type,handler,reciver,transportType);
}
public Object[] get_DB_param()
{
return new Object[]{
this.getId(),new Timestamp(this.getTime().getTime()),
this.getAddress(),this.getType(),this.getHandler(),this.getReciver(),
this.getTransportType()
};
}
public String toString() {
return this.getId() + "," + this.getTime() + "," + this.getAddress()
+ "," + this.getType() + "," + handler + "," + transportType;
}
}

99
src/com/qst/dms/entity/User.java Normal file
View File

@ -0,0 +1,99 @@
package com.qst.dms.entity;
//用户实体
public class User {
// 用户id
private int id;
// 用户名
private String username;
// 密码
private String password;
// 性别
private int sex;
// 爱好
private String hobby;
// 地址
private String address;
// 学历
private String degree;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getSex() {
return sex;
}
public void setSex(int sex) {
this.sex = sex;
}
public String getHobby() {
return hobby;
}
public void setHobby(String hobby) {
this.hobby = hobby;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
public String getDegree() {
return degree;
}
public void setDegree(String degree) {
this.degree = degree;
}
public User() {
}
public User(String username, String password, int sex, String hobby,
String address, String degree) {
this.username = username;
this.password = password;
this.sex = sex;
this.hobby = hobby;
this.address = address;
this.degree = degree;
}
public User(int id, String username, String password, int sex,
String hobby, String address, String degree) {
this.id = id;
this.username = username;
this.password = password;
this.sex = sex;
this.hobby = hobby;
this.address = address;
this.degree = degree;
}
}

10
src/com/qst/dms/exception/DataAnalyseException.java Normal file
View File

@ -0,0 +1,10 @@
package com.qst.dms.exception;
public class DataAnalyseException extends Exception {
public DataAnalyseException() {
}
public DataAnalyseException(String msg) {
super(msg);
}
}

31
src/com/qst/dms/gather/DataFilter.java Normal file
View File

@ -0,0 +1,31 @@
package com.qst.dms.gather;
import java.util.ArrayList;
import com.qst.dms.entity.DataBase;
//数据过滤抽象类
public abstract class DataFilter {
// 数据集合,使用泛型集合
private ArrayList<? extends DataBase> datas;
public ArrayList<? extends DataBase> getDatas() {
return datas;
}
public void setDatas(ArrayList<? extends DataBase> datas) {
this.datas = datas;
}
// 构造方法
public DataFilter() {
}
public DataFilter(ArrayList<? extends DataBase> datas) {
this.datas = datas;
}
// 数据过滤抽象方法
public abstract void doFilter();
}

9
src/com/qst/dms/gather/IDataAnalyse.java Normal file
View File

@ -0,0 +1,9 @@
package com.qst.dms.gather;
import java.util.ArrayList;
//数据分析接口
public interface IDataAnalyse {
// 进行数据匹配,返回泛型ArrayList集合
ArrayList<?> matchData();
}

74
src/com/qst/dms/gather/LogRecAnalyse.java Normal file
View File

@ -0,0 +1,74 @@
package com.qst.dms.gather;
import java.util.ArrayList;
import com.qst.dms.entity.DataBase;
import com.qst.dms.entity.LogRec;
import com.qst.dms.entity.MatchedLogRec;
import com.qst.dms.exception.DataAnalyseException;
//日志分析类，继承DataFilter抽象类，实现数据分析接口
public class LogRecAnalyse extends DataFilter implements IDataAnalyse {
// “登录”集合
private ArrayList<LogRec> logIns = new ArrayList<>();
// “登出”集合
private ArrayList<LogRec> logOuts = new ArrayList<>();
// 构造方法
public LogRecAnalyse() {
}
public LogRecAnalyse(ArrayList<LogRec> logRecs) {
super(logRecs);
}
// 实现DataFilter抽象类中的过滤抽象方法
public void doFilter() {
// 获取数据集合
ArrayList<LogRec> logs = (ArrayList<LogRec>) this.getDatas();
// 遍历，对日志数据进行过滤，根据日志登录状态分别放在不同的数组中
// 添加到“登录”日志集合中
// 添加到“登出”日志集合中
for (LogRec log:logs)
{
//1是登录，0是登出
if(log.getLogType()==1)
logIns.add(log);
else
logOuts.add(log);
}
}
// 实现IDataAnalyse接口中数据分析方法
public ArrayList<MatchedLogRec> matchData() {
// 创建日志匹配集合
ArrayList<MatchedLogRec> matchLogs = new ArrayList<>();
// 数据匹配分析
try
{
for(LogRec logIn:logIns)
for(LogRec logOut:logOuts)
try
{
matchLogs.add(new MatchedLogRec(logIn,logOut));
}
catch(RuntimeException e)
{
continue;
}
if(matchLogs.isEmpty())
throw new DataAnalyseException("没有匹配的数据");
}
catch (DataAnalyseException e)
{
e.printStackTrace();
}
//try
// 没找到匹配的数据,抛出DataAnalyseException异常
//catch (DataAnalyseException e) {
//e.printStackTrace();
return matchLogs;
}
}

75
src/com/qst/dms/gather/TransportAnalyse.java Normal file
View File

@ -0,0 +1,75 @@
package com.qst.dms.gather;
import java.util.ArrayList;
import com.qst.dms.entity.DataBase;
import com.qst.dms.entity.MatchedTransport;
import com.qst.dms.entity.Transport;
import com.qst.dms.exception.DataAnalyseException;
//物流分析类，继承DataFilter抽象类，实现数据分析接口
public class TransportAnalyse extends DataFilter implements IDataAnalyse {
// 发货集合
private ArrayList<Transport> transSends = new ArrayList<>();
// 送货集合
private ArrayList<Transport> transIngs = new ArrayList<>();
// 已签收集合
private ArrayList<Transport> transRecs = new ArrayList<>();
// 构造方法
public TransportAnalyse() {
}
public TransportAnalyse(ArrayList<Transport> trans) {
super(trans);
}
// 实现DataFilter抽象类中的过滤抽象方法
public void doFilter() {
// 获取数据集合
ArrayList<Transport> trans = (ArrayList<Transport>) this.getDatas();
// 遍历，对物流数据进行过滤，根据物流状态分别放在不同的集合中
for (Transport tran : trans) {
if (tran.getTransportType() == Transport.SENDING) {
transSends.add(tran);
} else if (tran.getTransportType() == Transport.TRANSPORTING) {
transIngs.add(tran);
} else if (tran.getTransportType() == Transport.RECEIVED) {
transRecs.add(tran);
}
}
}
// 实现IDataAnalyse接口中数据分析方法
public ArrayList<MatchedTransport> matchData() {
// 创建物流匹配集合
ArrayList<MatchedTransport> matchTrans = new ArrayList<>();
// 数据匹配分析
for (Transport send : transSends) {
for (Transport tran : transIngs) {
for (Transport rec : transRecs) {
if ((send.getReciver().equals(tran.getReciver()))
&& (send.getReciver().equals(rec.getReciver()))) {
// 修改物流状态类型为“匹配”
send.setType(DataBase.MATHCH);
tran.setType(DataBase.MATHCH);
rec.setType(DataBase.MATHCH);
// 添加到匹配集合中
matchTrans.add(new MatchedTransport(send, tran, rec));
}
}
}
}
try {
if (matchTrans.size() == 0) {
// 没找到匹配的数据,抛出DataAnalyseException异常
throw new DataAnalyseException("没有匹配的物流数据！");
}
} catch (DataAnalyseException e) {
e.printStackTrace();
}
return matchTrans;
}
}

35
src/com/qst/dms/security/String_SHA_256.java Normal file
View File

@ -0,0 +1,35 @@
package com.qst.dms.security;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
public class String_SHA_256
{
public static String String_to_SHA256(String password)
{
StringBuilder hexString = new StringBuilder();
if (password == null)
{
return null;
}
try {
// 创建MessageDigest实例并指定算法为SHA-256
MessageDigest digest = MessageDigest.getInstance("SHA-256");
// 计算散列值
byte[] hashBytes = digest.digest(password.getBytes());
// 将散列值转换为十六进制字符串表示
for (byte b : hashBytes) {
String hex = Integer.toHexString(0xff & b);
if (hex.length() == 1) {
hexString.append('0');
}
hexString.append(hex);
}
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
}
finally
{
return hexString.toString();
}
}
}

260
src/com/qst/dms/service/LogRecService.java Normal file
View File

@ -0,0 +1,260 @@
package com.qst.dms.service;
import java.io.EOFException;
import java.io.*;
import java.io.FileNotFoundException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Date;
import java.util.InputMismatchException;
import java.util.Scanner;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.util.Enumeration;
import com.qst.dms.db.DBUtil;
import com.qst.dms.entity.*;
import com.sun.net.httpserver.Request;
//日志业务类
public class LogRecService {
// 日志数据采集
public LogRec inputLog() {
LogRec log = null;
// 建立一个从键盘接收数据的扫描器
Scanner scanner = new Scanner(System.in);
try {
// 提示用户输入ID标识
System.out.println("请输入ID标识：");
// 接收键盘输入的整数
int id =0;
for(;;)
try
{
id = scanner.nextInt();
break;
}
catch(InputMismatchException e)
{
System.out.println("输入数据不合法，请重新输入");
scanner.nextLine();
}
// 获取当前系统时间
Date nowDate = new Date();
// 提示用户输入地址
System.out.println("请输入地址：");
// 接收键盘输入的字符串信息
String address = scanner.next();
// 数据状态是“采集”
int type = DataBase.GATHER;
// 提示用户输入登录用户名
System.out.println("请输入登录用户名：");
// 接收键盘输入的字符串信息
String user = scanner.next();
// 提示用户输入主机IP
// System.out.println("请输入主机IP：");
// // 接收键盘输入的字符串信息
// String ip = scanner.next();
String ip = "";
try {
Enumeration<NetworkInterface> interfaces = NetworkInterface.getNetworkInterfaces();
while (interfaces.hasMoreElements()) {
NetworkInterface iface = interfaces.nextElement();
// 过滤回环接口和虚拟接口
if (iface.isLoopback() || iface.isVirtual() || !iface.isUp()) {
continue;
}
Enumeration<InetAddress> addresses = iface.getInetAddresses();
while (addresses.hasMoreElements()) {
ip = addresses.nextElement().getHostAddress();
}
}
} catch (SocketException e) {
e.printStackTrace();
}
// 提示用户输入登录状态、登出状态
System.out.println("请输入登录状态:1是登录，0是登出");
int logType = 0;
for(;;)
try
{
logType = scanner.nextInt();
if(logType!=0&&logType!=1)
throw new InputMismatchException();
break;
}
catch(InputMismatchException e)
{
System.out.println("输入数据不合法，请重新输入");
scanner.nextLine();
}
// 创建日志对象
log = new LogRec(id, nowDate, address, type, user, ip, logType);
} catch (Exception e) {
System.out.println("采集的日志信息不合法");
}
// 返回日志对象
return log;
}
public ArrayList<MatchedLogRec> readMatchLog()
{
ArrayList<MatchedLogRec> matchedLogs = new ArrayList<>();
try(ObjectInputStream OIStream = new ObjectInputStream(new FileInputStream("MatchLogs.txt")))
{
MatchedLogRec matchLog;
while((matchLog = (MatchedLogRec) OIStream.readObject())!=null)
matchedLogs.add(matchLog);
}
catch(FileNotFoundException ex)
{
;
}
catch(EOFException ex)
{
;
}
catch(Exception Ex)
{
Ex.printStackTrace();
}
return matchedLogs;
}
public ArrayList<MatchedLogRec> readMatchedLogFromDB() throws SQLException
{
ArrayList<MatchedLogRec>matchedLogRecs = new ArrayList<>();
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "select i.id,i.time,i.address,i.type,i.username,i.ip,i.logtype,"+
"o.id,o.time,o.address,o.type,o.username,o.ip,o.logtype "+
"from matched_logrec m,gather_logrec i,gather_logrec o "+
"where m.loginid=i.id AND m.logoutid=o.id;";
ResultSet resultSet = db.executeQuery(sql,null);
while(resultSet.next())
{
Object[] temp = new Object[7];
for(int i=1;i<=7;i++)
temp[i-1] = resultSet.getObject(i);
LogRec login = LogRec.get_LogRec(temp);
for(int i=8;i<=14;i++)
temp[i-8] = resultSet.getObject(i);
LogRec logout = LogRec.get_LogRec(temp);
matchedLogRecs.add(new MatchedLogRec(login,logout));
}
db.closeAll();
}
catch (SQLException e)
{
throw e;
}
catch (Exception e)
{
e.printStackTrace();
}
return matchedLogRecs;
}
public void saveMatchLog(ArrayList<MatchedLogRec>matchLogs)
{
try{
ObjectOutputStream obStream = new ObjectOutputStream(new FileOutputStream("MatchLogs.txt"));
for(MatchedLogRec log:matchLogs)
{
if(log==null)
continue;
obStream.writeObject(log);
obStream.flush();
}
//null 代表结尾
obStream.writeObject(null);
obStream.close();
}catch(Exception Ex)
{
Ex.printStackTrace();
}
}
public void saveAndAppendMatchLog(ArrayList<MatchedLogRec>matchLogs)
{
if(matchLogs==null)
return;
try
{
File file = new File("MatchLogs.txt");
AppendObjectOutputStream.file = file;
AppendObjectOutputStream AOOStream = new AppendObjectOutputStream();
for(MatchedLogRec log:matchLogs)
{
if(log==null)
continue;
AOOStream.writeObject(log);
AOOStream.flush();
}
//null 代表结尾
//AOOStream.writeObject(null);
AOOStream.close();
}
catch (Exception Ex)
{
Ex.printStackTrace();
}
}
public void saveMatchLogToDB(ArrayList<MatchedLogRec>matchLogs)
{
DBUtil db = new DBUtil();
try
{
db.getConnection();
for(MatchedLogRec logRec:matchLogs)
{
LogRec login = logRec.getLogin();
LogRec logout = logRec.getLogout();
//信息
String sql = "INSERT INTO gather_logrec(id,time,address,type,username,ip,logtype) VALUES(?,?,?,?,?,?,?)";
db.executeUpdate(sql, login.get_DB_param());
db.executeUpdate(sql, logout.get_DB_param());
//匹配对
sql = "INSERT INTO matched_logrec(loginid,logoutid) VALUES(?,?)";
db.executeUpdate(sql, logRec.get_DB_param());
}
db.closeAll();
} catch(Exception e)
{
e.printStackTrace();
}
}
// 日志信息输出
public void showLog(LogRec... logRecs) {
for (LogRec e : logRecs) {
if (e != null) {
System.out.println(e.toString());
}
}
}
// 匹配日志信息输出，可变参数
public void showMatchLog(MatchedLogRec... matchLogs) {
for (MatchedLogRec e : matchLogs) {
if (e != null) {
System.out.println(e.toString());
}
}
}
// 匹配日志信息输出,参数是集合
public void showMatchLog(ArrayList<MatchedLogRec> matchLogs) {
for (MatchedLogRec e : matchLogs) {
if (e != null) {
System.out.println(e.toString());
}
}
}
}

233
src/com/qst/dms/service/TransportService.java Normal file
View File

@ -0,0 +1,233 @@
package com.qst.dms.service;
import java.io.*;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.SQLIntegrityConstraintViolationException;
import java.util.ArrayList;
import java.util.Date;
import java.util.Scanner;
import com.qst.dms.db.DBUtil;
import com.qst.dms.entity.*;
public class TransportService {
// 物流数据采集
public Transport inputTransport() {
Transport trans = null;
// 建立一个从键盘接收数据的扫描器
Scanner scanner = new Scanner(System.in);
try {
// 提示用户输入ID标识
System.out.println("请输入ID标识：");
// 接收键盘输入的整数
int id = scanner.nextInt();
// 获取当前系统时间
Date nowDate = new Date();
// 提示用户输入地址
System.out.println("请输入地址：");
// 接收键盘输入的字符串信息
String address = scanner.next();
// 数据状态是“采集”
int type = DataBase.GATHER;
// 提示用户输入登录用户名
System.out.println("请输入货物经手人：");
// 接收键盘输入的字符串信息
String handler = scanner.next();
// 提示用户输入主机IP
System.out.println("请输入 收货人:");
// 接收键盘输入的字符串信息
String reciver = scanner.next();
// 提示用于输入物流状态
System.out.println("请输入物流状态：1发货中，2送货中，3已签收");
// 接收物流状态
int transportType = scanner.nextInt();
// 创建物流信息对象
trans = new Transport(id, nowDate, address, type, handler, reciver,
transportType);
} catch (Exception e) {
System.out.println("采集的日志信息不合法");
}
// 返回物流对象
return trans;
}
// 物流信息输出
public void showTransport(Transport... transports) {
for (Transport e : transports) {
if (e != null) {
System.out.println(e.toString());
}
}
}
// 匹配的物流信息输出，可变参数
public void showMatchTransport(MatchedTransport... matchTrans) {
for (MatchedTransport e : matchTrans) {
if (e != null) {
System.out.println(e.toString());
}
}
}
// 匹配的物流信息输出，参数是集合
public void showMatchTransport(ArrayList<MatchedTransport> matchTrans) {
for (MatchedTransport e : matchTrans) {
if (e != null) {
System.out.println(e.toString());
}
}
}
public ArrayList<MatchedTransport>readMatchedTransportFromDB() throws SQLException
{
ArrayList<MatchedTransport>matchedTransports = new ArrayList<>();
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "select s.id,s.time,s.address,s.type,s.handler,s.reciver,s.transporttype,"+
"t.id,t.time,t.address,t.type,t.handler,t.reciver,t.transporttype,"+
"r.id,r.time,r.address,r.type,r.handler,r.reciver,r.transporttype "+
"from matched_transport m,gather_transport s,gather_transport t,gather_transport r " +
"where m.sendid=s.id AND m.transid=t.id AND m.receiveid=r.id;";
ResultSet resultSet = db.executeQuery(sql,null);
while(resultSet.next())
{
Object[] temp = new Object[7];
for(int i=1;i<=7;i++)
temp[i-1] = resultSet.getObject(i);
Transport send = Transport.get_Transport(temp);
for(int i=8;i<=14;i++)
temp[i-8] = resultSet.getObject(i);
Transport trans = Transport.get_Transport(temp);
for(int i=15;i<=21;i++)
temp[i-15] = resultSet.getObject(i);
Transport receive = Transport.get_Transport(temp);
MatchedTransport matchedTransport = new MatchedTransport(send,trans,receive);
matchedTransports.add(matchedTransport);
}
db.closeAll();
}
catch(SQLException e)
{
throw e;
}
catch(Exception e)
{
e.printStackTrace();
}
return matchedTransports;
}
// 匹配物流信息保存，参数是集合
public void saveMatchedTransport(ArrayList<MatchedTransport> matchTrans) {
// 创建一个ObjectOutputStream对象输出流，并连接文件输出流
// 以可追加的方式创建文件输出流，数据保存到MatchedTransports.txt文件中
try (ObjectOutputStream obs = new ObjectOutputStream(
new FileOutputStream("MatchedTransports.txt", true))) {
// 循环保存对象数据
for (MatchedTransport e : matchTrans) {
if (e != null) {
// 把对象写入到文件中
obs.writeObject(e);
obs.flush();
}
}
// 文件末尾保存一个null对象，代表文件结束
obs.writeObject(null);
obs.flush();
} catch (Exception ex) {
ex.printStackTrace();
}
}
public void saveMatchTransportToDB(ArrayList<MatchedTransport> matchTrans)
{
DBUtil db = new DBUtil();
try
{
db.getConnection();
for(MatchedTransport matchedTransport:matchTrans)
{
Transport send =matchedTransport.getSend(),
trans =matchedTransport.getTrans(),
receive = matchedTransport.getReceive();
String sql = "insert into gather_transport(id,time,address,type,handler,reciver,transporttype) VALUES(?,?,?,?,?,?,?);";
db.executeUpdate(sql, send.get_DB_param());
db.executeUpdate(sql, trans.get_DB_param());
db.executeUpdate(sql,receive.get_DB_param());
sql = "insert into matched_transport(sendid,transid,receiveid) VALUES(?,?,?);";
db.executeUpdate(sql,new Object[]{send.getId(),trans.getId(),receive.getId()});
}
db.closeAll();
}
catch(SQLIntegrityConstraintViolationException e)
{;}
catch(Exception e)
{
e.printStackTrace();
}
}
public void saveAndAppendTransport(ArrayList<MatchedTransport>matchTrans)
{
if (matchTrans == null)
return;
try
{
File file = new File("MatchedTransports.txt");
AppendObjectOutputStream.file = file;
AppendObjectOutputStream AOOStream = new AppendObjectOutputStream();
for(MatchedTransport tran:matchTrans)
{
if(tran==null)
continue;
AOOStream.writeObject(tran);
AOOStream.flush();
}
//null 代表结尾
//AOOStream.writeObject(null);
AOOStream.close();
}
catch (Exception Ex)
{
Ex.printStackTrace();
}
}
// 读匹配物流信息保存，参数是集合
public ArrayList<MatchedTransport> readMatchedTransport() {
ArrayList<MatchedTransport> matchTrans = new ArrayList<>();
// 创建一个ObjectInputStream对象输入流，并连接文件输入流，读MatchedTransports.txt文件中
try (ObjectInputStream ois = new ObjectInputStream(new FileInputStream(
"MatchedTransports.txt"))) {
MatchedTransport matchTran;
// 循环读文件中的对象
while ((matchTran = (MatchedTransport) ois.readObject()) != null) {
// 将对象添加到泛型集合中
matchTrans.add(matchTran);
}
}
catch(FileNotFoundException ex)
{
;
}
catch(EOFException ex)
{
;
}
catch (Exception ex) {
ex.printStackTrace();
}
return matchTrans;
}
}

85
src/com/qst/dms/service/UserService.java Normal file
View File

@ -0,0 +1,85 @@
package com.qst.dms.service;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
//import com.mysql.jdbc.Statement;
import com.qst.dms.db.DBUtil;
import com.qst.dms.entity.User;
public class UserService {
private static Statement statement; //revised by yyc 20191012
// 根据用户名查询用户
public User findUserByName(String userName) throws SQLException
{
DBUtil db = new DBUtil();
User user = null;
try {
// 获取数据库链接
db.getConnection();
// 使用PreparedStatement发送sql语句
String sql = "SELECT * FROM userdetails WHERE username=?";
// 设置参数
Object[] param = new Object[] { userName };
// 执行查询
ResultSet rs = db.executeQuery(sql, param);
if (rs.next()) {
// 将结果集中的数据封装到对象中
user = new User(rs.getInt(1), rs.getString(2), rs.getString(3),
rs.getInt(4), rs.getString(5), rs.getString(6),
rs.getString(7));
}
}catch (SQLException e)
{
throw e;
}
catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭数据库的连接
db.closeAll();
}
// 返回用户对象
return user;
}
// 保存用户信息
public boolean saveUser(User user) {
// 定义一个布尔返回值，初始值为false
boolean r = false;
DBUtil db = new DBUtil();
try {
// 获取数据库连接
db.getConnection();
//start revised by yyc 20191012
// String sqltest = "SELECT * FROM userdetails WHERE username=user";
// ResultSet rs = statement.executeQuery(sqltest);
//start revised by yyc 20191126
String sqltest = "SELECT * FROM userdetails WHERE username='"+user.getUsername()+"'";
ResultSet rs = db.executeQuery(sqltest,null);
if(rs.next())
return r;
//end
// 使用PreparedStatement发送sql语句
String sql = "INSERT INTO userdetails(username,password,sex,hobby,address,degree) VALUES (?,?,?,?,?,?)";
// 设置参数
Object[] param = new Object[] { user.getUsername(),
user.getPassword(), user.getSex(), user.getHobby(),
user.getAddress(), user.getDegree() };
// 判断数据是否保存成功
if (db.executeUpdate(sql, param) > 0) {
// 保存成功，设置返回值为true
r = true;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭数据库的连接
db.closeAll();
}
// 返回
return r;
}
}

820
src/com/qst/dms/ui/InfoInputFXML.java Normal file
View File

@ -0,0 +1,820 @@
package com.qst.dms.ui;
import com.qst.dms.db.DBUtil;
import com.qst.dms.entity.*;
import com.qst.dms.gather.LogRecAnalyse;
import com.qst.dms.gather.TransportAnalyse;
import com.qst.dms.service.LogRecService;
import com.qst.dms.service.TransportService;
import javafx.animation.FadeTransition;
import javafx.application.Platform;
import javafx.event.ActionEvent;
import javafx.fxml.FXML;
import javafx.scene.control.*;
import javafx.scene.control.Alert.AlertType;
import javafx.scene.image.Image;
import javafx.scene.image.ImageView;
import javafx.scene.input.KeyEvent;
import javafx.scene.paint.Color;
import javafx.scene.input.MouseEvent;
import javafx.util.Duration;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.sql.ResultSet;
import java.util.*;
public class InfoInputFXML {
// 创建一个泛型ArrayList集合存储日志数据
ArrayList<LogRec> logRecList = new ArrayList<>();
// 创建一个泛型ArrayList集合存储物流数据
ArrayList<Transport> transportList = new ArrayList<>();
// 创建一个日志业务类
LogRecService logService = new LogRecService();
// 创建一个物流业务类
TransportService tranService = new TransportService();
// 日志数据匹配集合
ArrayList<MatchedLogRec> matchedLogs = null;
// 物流数据匹配集合
ArrayList<MatchedTransport> matchedTrans = null;
@FXML
private TextField logID;
@FXML
private TextField logIP;
@FXML
private RadioButton logLogin;
@FXML
private RadioButton logLogout;
@FXML
private TextField logPosition;
@FXML
private TextField logUser;
@FXML
private TextField transportAddress;
@FXML
private TextField transportHandler;
@FXML
private TextField transportID;
@FXML
private TextField transportReceiver;
@FXML
private ChoiceBox<String> transportMode;
@FXML
private Label logLabelSuccess;
@FXML
private Label transportLabelSuccess;
@FXML
private Label logIDError;
@FXML
private Label logUserEmpty;
@FXML
private Label logAddressEmpty;
@FXML
private Label logIPEmpty;
@FXML
private Label logStateEmpty;
@FXML
private Label transportIDError;
@FXML
private Label transportAddressEmpty;
@FXML
private Label transportReceiverEmpty;
@FXML
private Label transportHandlerEmpty;
@FXML
private Label transportStateEmpty;
@FXML
private Button collectDataButton;
@FXML
private Button matchLogButton;
@FXML
private Button matchTransportButton;
@FXML
private Button sandDataButton;
@FXML
private Button saveDataButton;
@FXML
private Button showDataButton;
@FXML
private TabPane collectDataPane;
@FXML
private Label logInfoLabel;
@FXML
private Label transportInfoLabel;
private Button[] topButtons;
private String[] photos;
private TextField[] textFields;
private Label[] errorLabels;
private boolean[] textFieldChanged;
private int logMode;//0未选择 1登录 2登出
private int transportModeVal;//0未选择 1发货中 2 运货中 3 已送达
String defaultIP;
public static String loginUser;
private MainFrame mainFrame;
private int logUpVal;
private int transportUpVal;
private boolean logIDValid=true,transportIDValid=true;
private boolean sqlError;
FadeTransition transportSuccess;
FadeTransition logSuccess;
private Thread errorThread;
private Thread checkerThread;
private volatile boolean stopRequested = false;
private Image OKImage;
private Image errorImage;
private ImageView logImageView;
private ImageView transportImageView;
void SQLErrorAlert()
{
Alert alert = new Alert(Alert.AlertType.ERROR);
alert.setTitle("错误");
alert.setHeaderText("连接到sql数据库失败");
alert.setContentText("当前无法添加信息");
alert.showAndWait();
}
@FXML
void ConfirmLog(ActionEvent event) {
if(sqlError)
SQLErrorAlert();
boolean canDo=true;
if(logMode==0)
{logStateEmpty.setTextFill(Color.color(1,0,0,1));canDo=false;}
int id=0;
try
{
String Sid = logID.getText();
if(Sid.isEmpty())
throw new Exception("ID不能为空");
if(!logIDValid)
throw new Exception("ID已被占用");
id = Integer.parseInt(Sid);
}
catch(NumberFormatException e)
{
logIDError.setText("请输入纯数字");
logIDError.setTextFill(Color.color(1,0,0,1));
canDo=false;
}
catch(Exception e)
{
logIDError.setText(e.getMessage());
logIDError.setTextFill(Color.color(1,0,0,1));
canDo=false;
}
String address = logPosition.getText();
if(address.isEmpty())
{logAddressEmpty.setTextFill(Color.color(1,0,0,1));canDo=false;}
String user = logUser.getText();
if(user==null||user.isEmpty())
{logUserEmpty.setTextFill(Color.color(1,0,0,1));canDo=false;}
String ip = logIP.getText();
if(ip.isEmpty())
{logIPEmpty.setTextFill(Color.color(1,0,0,1));canDo=false;}
Date nowDate = new Date();
int logType = logMode==2?0:1;
if(!canDo)
return;
int type=0;
LogRec log = new LogRec(id, nowDate, address, type, user, ip, logType);
logRecList.add(log);
loginUser = user;
logUpVal++;
logMode=0;
logLogin.setSelected(false);
logLogout.setSelected(false);
Thread thread = new Thread(()->{Platform.runLater(()->{
setLogTextFields();});});
thread.start();
logSuccessAnimation();
}
@FXML
void ConfirmTransport(ActionEvent event) {
if(sqlError)
SQLErrorAlert();
boolean canDo = true;
int id = 0;
try
{
String Sid = transportID.getText();
if(Sid.isEmpty())
throw new Exception("ID不能为空");
if(!transportIDValid)
throw new Exception("ID已被占用");
id = Integer.parseInt(Sid);
}
catch(NumberFormatException e)
{
transportIDError.setText("请输入纯数字");
transportIDError.setTextFill(Color.color(1,0,0,1));
canDo=false;
}
catch(Exception e)
{
transportIDError.setText(e.getMessage());
transportIDError.setTextFill(Color.color(1,0,0,1));
canDo=false;
}
String transportModeString = transportMode.getValue();
if(transportModeString==null)
{
transportModeVal = 0;
transportStateEmpty.setTextFill(Color.color(1,0,0,1));
canDo=false;
}
else
switch(transportModeString)
{
case "发货中" ->transportModeVal=1;
case "运送中" ->transportModeVal=2;
case "已送达" ->transportModeVal=3;
}
String address = transportAddress.getText();
if(address.isEmpty())
{transportAddressEmpty.setTextFill(Color.color(1,0,0,1));canDo=false;}
String handler = transportHandler.getText();
if(handler.isEmpty())
{transportHandlerEmpty.setTextFill(Color.color(1,0,0,1));canDo=false;}
String receiver = transportReceiver.getText();
if(receiver.isEmpty())
{transportReceiverEmpty.setTextFill(Color.color(1,0,0,1));canDo=false;}
if(!canDo)
return;
Date nowDate = new Date();
Transport transport = new Transport(id,nowDate,address,2,handler,receiver,transportModeVal);
transportList.add(transport);
transportUpVal++;
transportModeVal=0;
transportMode.setValue(null);
Thread thread = new Thread(()->{Platform.runLater(()->{
setTransportTextFields();});});
thread.start();
transportSuccessAnimation();
}
void logIDTest()
{
logIDValid=true;
int logIDValue;
try
{
String s = logID.getText();
if(s.isEmpty())
throw new Exception();
logIDValue = Integer.parseInt(s);
}
catch (Exception e)
{logIDValid=false;return;}
Thread thread = new Thread(()->
{
Platform.runLater(()->{
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "SELECT id FROM gather_logrec WHERE id = "+ logIDValue;
ResultSet resultSet = db.executeQuery(sql,null);
if(resultSet.next())
logIDValid = false;
db.closeAll();
} catch(Exception e)
{
if(errorThread==null||errorThread.getState()==Thread.State.TERMINATED)
{
db.closeAll();
errorThread = new Thread(() -> {
setSqlError();
});
errorThread.start();
}
}
});
});
thread.start();
}
void updateSQLCheckerTime()
{
Thread thread = new Thread(()->{
stopRequested=true;
while(checkerThread.isAlive())
{
checkerThread.interrupt();
try
{
Thread.sleep(50);
} catch (InterruptedException e)
{
e.printStackTrace();
}
}
stopRequested=false;
checkerThread = new Thread(()->{
SQLChecker();
});
checkerThread.start();
});
thread.start();
}
void SQLChecker()
{
while (!stopRequested)
{
try
{
Thread.sleep(UpdateTimeSetFXML.updateTime*1000);
} catch (InterruptedException e)
{
break;
}
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "SELECT * FROM gather_transport";
db.closeAll();
} catch(Exception e)
{
db.closeAll();
if(errorThread==null||errorThread.getState()==Thread.State.TERMINATED)
{
errorThread = new Thread(() -> {
setSqlError();
});
errorThread.start();
}
//e.printStackTrace();
}
}
}
void transportIDTest()
{
transportIDValid=true;
int transportIDValue;
try
{
String s = transportID.getText();
if(s.isEmpty())
throw new Exception();
transportIDValue = Integer.parseInt(s);
}
catch (Exception e)
{transportIDValid=false;return;}
Thread thread = new Thread(()->
{
Platform.runLater(()->{
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "SELECT id FROM gather_transport WHERE id = "+ transportIDValue;
ResultSet resultSet = db.executeQuery(sql,null);
if(resultSet.next())
transportIDValid=false;
db.closeAll();
} catch(Exception e)
{
db.closeAll();
if(errorThread==null||errorThread.getState()==Thread.State.TERMINATED)
{
errorThread = new Thread(() -> {
setSqlError();
});
errorThread.start();
}
//e.printStackTrace();
}
});
});
thread.start();
}
void setSqlError()
{
sqlError = true;
while (true)
{
for (int i = 3; i >= 0; i--)
{
int finalI = i;
Platform.runLater(()-> {
logInfoLabel.setTextFill(Color.color(1, 0, 0, 1));
transportInfoLabel.setTextFill(Color.color(1, 0, 0, 1));
logImageView.setImage(errorImage);
transportImageView.setImage(errorImage);
logInfoLabel.setText("数据库连接异常，将在" + finalI + "秒后重试");
transportInfoLabel.setText("数据库连接异常，将在" + finalI + "秒后重试");
});
if (i != 0)
try
{
Thread.sleep(1000);
} catch (InterruptedException e)
{
e.printStackTrace();
}
}
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "SELECT id FROM gather_transport WHERE id = (SELECT MAX(id) FROM gather_transport)";
ResultSet resultSet = db.executeQuery(sql,null);
db.closeAll();
} catch(Exception e)
{
db.closeAll();
continue;
}
break;
}
setReady();
}
private void setReady()
{
Platform.runLater(()->{
logImageView.setImage(OKImage);
transportImageView.setImage(OKImage);
logInfoLabel.setText("就绪");
transportInfoLabel.setText("就绪");
logInfoLabel.setTextFill(Color.color(0,0,0,1));
transportInfoLabel.setTextFill(Color.color(0,0,0,1));
});
sqlError=false;
}
@FXML
void LoginSet(ActionEvent event) {
logLogout.setSelected(false);
logMode = 1;
logStateEmpty.setTextFill(Color.color(1,0,0,0));
}
@FXML
void LogoutSet(ActionEvent event) {
logLogin.setSelected(false);
logMode = 2;
logStateEmpty.setTextFill(Color.color(1,0,0,0));
}
@FXML
void RedoALLLog(ActionEvent event) {
logUser.clear();
logPosition.clear();
logIP.clear();
logID.clear();
}
@FXML
void RedoAllTransport(ActionEvent event) {
transportID.clear();
transportAddress.clear();
transportHandler.clear();
transportReceiver.clear();
}
@FXML
public void matchedAcquisitionLogData(ActionEvent event) {
if(logRecList.isEmpty())
{
matchedLogs = new ArrayList<>();
return;
}
LogRecAnalyse logAn = new LogRecAnalyse(logRecList);
logAn.doFilter();
matchedLogs = logAn.matchData();
}
@FXML
public void matchedAcquisitionTransportData(ActionEvent event){
if(transportList.isEmpty())
{
matchedTrans = new ArrayList<>();
return;
}
TransportAnalyse transAn = new TransportAnalyse(transportList);
transAn.doFilter();
matchedTrans = transAn.matchData();
}
@FXML
public void sandData(ActionEvent event) {
//开发中……
}
@FXML
public void saveData(ActionEvent event) {
boolean doLog=false,doTransport=false;
if((matchedLogs==null||matchedLogs.isEmpty())&&!logRecList.isEmpty())
{
doLog=true;
Alert alert = new Alert(AlertType.CONFIRMATION);
alert.setTitle("Warning Dialog");
alert.setHeaderText("配对的日志数据为空");
alert.setContentText("你是否忘记匹配日志数据，要匹配日志数据吗？");
Optional<ButtonType> result = alert.showAndWait();
if (result.get() == ButtonType.OK){
matchedAcquisitionLogData(null);
if(matchedLogs.isEmpty())
doLog=false;
}
else doLog=false;
}
if(doLog)
{
logService.saveAndAppendMatchLog(matchedLogs);
logService.saveMatchLogToDB(matchedLogs);//添加至DB
logRecList.clear();
matchedLogs.clear();
logUpVal=0;
}
if((matchedTrans==null|| matchedTrans.isEmpty())&&!transportList.isEmpty())
{
doTransport=true;
Alert alert = new Alert(AlertType.CONFIRMATION);
alert.setTitle("Warning Dialog");
alert.setHeaderText("配对的物流数据为空");
alert.setContentText("你是否忘记匹配物流数据，要匹配物流数据吗？");
Optional<ButtonType> result = alert.showAndWait();
if (result.get() == ButtonType.OK){
matchedAcquisitionTransportData(null);
if(matchedTrans.isEmpty())
doTransport=false;
}
else doTransport=false;
}
if(doTransport)
{
tranService.saveAndAppendTransport(matchedTrans);
tranService.saveMatchTransportToDB(matchedTrans);//添加至DB
transportList.clear();
matchedTrans.clear();
transportUpVal=0;
}
}
@FXML
void toInfoInputFrame(ActionEvent event) {
;
}
@FXML
void toTableFrame(ActionEvent event)
{
fadeOut(()->{mainFrame.toTableFrame();});
}
public void getDelegation(MainFrame _mainFrame)
{
mainFrame = _mainFrame;
}
void setLogTextFields()
{
sqlError = false;
DBUtil db = new DBUtil();
int min_id=0;
try
{
db.getConnection();
String sql = "SELECT id FROM gather_logrec WHERE id = (SELECT MAX(id) FROM gather_logrec)";
ResultSet resultSet = db.executeQuery(sql,null);
if(resultSet.next())
{
Integer id=(Integer) resultSet.getObject(1);
min_id = id.intValue()+ logUpVal +1;
}
db.closeAll();
} catch(Exception e)
{
db.closeAll();
if(errorThread==null||errorThread.getState()==Thread.State.TERMINATED)
{
errorThread = new Thread(() -> {
setSqlError();
});
errorThread.start();
}
}
for(TextField textField:textFields)
textField.setStyle("-fx-text-fill: #666");
logUser.setText(loginUser);
logID.setText(""+min_id);
logIP.setText(defaultIP);
Arrays.fill(textFieldChanged,false);
}
void setTransportTextFields()
{
sqlError = false;
DBUtil db = new DBUtil();
int min_id=0;
try
{
db.getConnection();
String sql = "SELECT id FROM gather_transport WHERE id = (SELECT MAX(id) FROM gather_transport)";
ResultSet resultSet = db.executeQuery(sql,null);
if(resultSet.next())
{
Integer id=(Integer) resultSet.getObject(1);
min_id = id.intValue()+ transportUpVal +1;
}
db.closeAll();
} catch(Exception e)
{
db.closeAll();
if(errorThread==null||errorThread.getState()==Thread.State.TERMINATED)
{
errorThread = new Thread(() -> {
setSqlError();
});
errorThread.start();
}
}
for(TextField textField:textFields)
textField.setStyle("-fx-text-fill: #666");
transportID.setText(""+min_id);
Arrays.fill(textFieldChanged,false);
}
@FXML
void beChanged(KeyEvent event) {
TextField textField = (TextField)event.getSource();
for(int i = 0;i<textFields.length;i++)
if(textFields[i]==textField)
{
if(textFields[i]==logID)
logIDTest();
if(textFields[i]==transportID)
transportIDTest();
textFieldChanged[i]=true;
errorLabels[i].setTextFill(Color.color(1,0,0,0));
break;
}
}
@FXML
public void beClicked(MouseEvent event)
{
TextField textField = (TextField)event.getSource();
textField.setStyle("-fx-text-fill: black; ");
textField.selectAll();
}
public void initialize()
{
sqlError = true;
checkerThread = new Thread(()->{
SQLChecker();
});
checkerThread.start();
logUpVal = 0;
transportUpVal = 0;
textFieldChanged = new boolean[8];
Arrays.fill(textFieldChanged,false);
textFields = new TextField[]{logID,logUser,logPosition,logIP,transportID,transportAddress,transportHandler,transportReceiver};
errorLabels = new Label[]{logIDError, logUserEmpty, logAddressEmpty, logIPEmpty,transportIDError,transportAddressEmpty,transportHandlerEmpty,transportReceiverEmpty,logStateEmpty,transportStateEmpty};
topButtons = new Button[]{collectDataButton, matchLogButton, matchTransportButton, saveDataButton, sandDataButton, showDataButton};
photos = new String[]{"dataCollection.png","logPair.png","transportPair.png","save.png","upload.png","table.png"};
logMode = 0;
transportMode.getItems().addAll("发货中","运送中","已送达");
setPhotos();
for(Label label:errorLabels)
label.setTextFill(Color.color(1,0,0,0));
logLabelSuccess.setTextFill(Color.color(0,1,0,0));
transportLabelSuccess.setTextFill(Color.color(0,1,0,0));
try {
Enumeration<NetworkInterface> interfaces = NetworkInterface.getNetworkInterfaces();
while (interfaces.hasMoreElements()) {
NetworkInterface iface = interfaces.nextElement();
// 过滤回环接口和虚拟接口
if (iface.isLoopback() || iface.isVirtual() || !iface.isUp()) {
continue;
}
Enumeration<InetAddress> addresses = iface.getInetAddresses();
while (addresses.hasMoreElements()) {
defaultIP = addresses.nextElement().getHostAddress();
}
}
} catch (SocketException e) {
e.printStackTrace();
}
OKImage = new Image("resources/ok.png");
errorImage = new Image("resources/error.png");
logImageView = new ImageView();
transportImageView = new ImageView();
for(ImageView imageView : new ImageView[]{logImageView,transportImageView})
{
imageView.setFitHeight(19);
imageView.setFitWidth(19);
}
logImageView.setImage(OKImage);
transportImageView.setImage(OKImage);
logInfoLabel.setGraphic(logImageView);
transportInfoLabel.setGraphic(transportImageView);
transportMode.setOnAction((event)->{transportStateEmpty.setTextFill(Color.color(1,0,0,0));});
Thread thread = new Thread(()->{Platform.runLater(()->{
setLogTextFields();setTransportTextFields();});});
thread.start();
}
void setPhotos()
{
for(int i=0;i<topButtons.length;i++)
{
Image image = new Image("resources/"+photos[i]);
ImageView imageView = new ImageView(image);
imageView.setFitWidth(18);
imageView.setFitHeight(18);
topButtons[i].setGraphic(imageView);
}
}
void fadeOut(Runnable action)
{
// 创建FadeTransition对象
FadeTransition fadeOut = new FadeTransition(Duration.seconds(0.5),collectDataPane );
fadeOut.setFromValue(1); // 初始不透明度为1（完全可见）
fadeOut.setToValue(0);
fadeOut.setOnFinished((event)->{
if (action != null)
action.run();});
fadeOut.play();
}
void fadeIn(Runnable action)
{
// 创建FadeTransition对象
FadeTransition fadeIn = new FadeTransition(Duration.seconds(0.5),collectDataPane );
fadeIn.setFromValue(0); // 初始不透明度为0（完全透明）
fadeIn.setToValue(1);
fadeIn.setOnFinished((event)->{
if (action != null)
action.run();});
fadeIn.play();
}
void logSuccessAnimation()
{
logLabelSuccess.setTextFill(Color.color(0.26953125,0.66796875,0.26953125,1));
if(logSuccess!=null)
logSuccess.stop();
logSuccess = new FadeTransition(Duration.seconds(1),logLabelSuccess);
logSuccess.setFromValue(1); // 初始不透明度为1（完全可见）
logSuccess.setToValue(0);
logSuccess.setDelay(Duration.seconds(3));
logSuccess.play();
}
void transportSuccessAnimation()
{
transportLabelSuccess.setTextFill(Color.color(0.26953125,0.66796875,0.26953125,1));
if(transportSuccess!=null)
transportSuccess.stop();
transportSuccess = new FadeTransition(Duration.seconds(1),transportLabelSuccess);
transportSuccess.setFromValue(1); // 初始不透明度为1（完全可见）
transportSuccess.setToValue(0);
transportSuccess.setDelay(Duration.seconds(3));
transportSuccess.play();
}
public void updateFlushTime(ActionEvent event)
{
mainFrame.updateFlushTime();
}
}

94
src/com/qst/dms/ui/LoginFXML.java Normal file
View File

@ -0,0 +1,94 @@
package com.qst.dms.ui;
import com.qst.dms.entity.User;
import com.qst.dms.security.String_SHA_256;
import com.qst.dms.service.UserService;
import javafx.event.ActionEvent;
import javafx.fxml.FXML;
import javafx.scene.control.*;
import java.sql.SQLException;
public class LoginFXML
{
@FXML
private TextField Username;
@FXML
private PasswordField Password;
@FXML
private Button Login_Button;
@FXML
private Button Reset_Button;
@FXML
private Button Register_Button;
@FXML
void Login(ActionEvent event)
{
UserService userService =new UserService();
try
{
User user = userService.findUserByName(Username.getText());
if(user==null||!(String_SHA_256.String_to_SHA256(Password.getText()).equals(user.getPassword())))
Login_failed();
else
{
InfoInputFXML.loginUser = Username.getText();
LoginFrame.close_scene();
}
}
catch(SQLException e)
{
SQLErrorAlert(0);
}
catch (Exception e)
{
e.printStackTrace();
}
}
void SQLErrorAlert(int type)
{
Alert alert = new Alert(Alert.AlertType.ERROR);
alert.setTitle("错误");
alert.setHeaderText("连接到sql数据库失败");
if(type==0)
alert.setContentText("当前无法校验用户名和密码");
if(type==1)
alert.setContentText("当前无法添加用户");
alert.showAndWait();
}
@FXML
void Reset(ActionEvent event)
{
Username.clear();
Password.clear();
}
@FXML
void Register(ActionEvent event)
{
UserService userService =new UserService();
try
{
User user = userService.findUserByName("");
RegistFrame.main(null);
}
catch (SQLException e)
{
SQLErrorAlert(1);
}
catch(Exception e)
{
e.printStackTrace();
}
}
void Login_failed()
{
Alert alert = new Alert(Alert.AlertType.ERROR);
alert.setTitle("错误");
alert.setHeaderText("用户名或密码错误");
alert.setContentText("请检查输入的用户名和密码");
alert.showAndWait();
}
}

38
src/com/qst/dms/ui/LoginFrame.java Normal file
View File

@ -0,0 +1,38 @@
package com.qst.dms.ui;
import com.qst.dms.entity.User;
import com.qst.dms.service.UserService;
import javafx.application.Application;
import javafx.fxml.FXMLLoader;
import javafx.scene.Scene;
import javafx.scene.layout.AnchorPane;
import javafx.scene.layout.Pane;
import javafx.stage.Stage;
public class LoginFrame extends Application
{
private static Scene scene;
public static void main(String[] args)
{
Application.launch(args);
}
@Override
public void start(Stage stage) throws Exception
{
Pane pane = FXMLLoader.load(getClass().getClassLoader().getResource("resources/LoginFrame.fxml"));
scene = new Scene(pane);
stage.setScene(scene);
stage.setResizable(false);
stage.show();
}
public static void close_scene()
{
Stage primaryStage=(Stage)scene.getWindow();//将submit(登录按钮)与MainApplication类中的primaryStage(新窗口)绑定 并执行close()
primaryStage.close();//打开新的窗口 所以要关闭当前的窗口
MainFrame mainFrame = new MainFrame();
mainFrame.startapp();
}
}

87
src/com/qst/dms/ui/MainFrame.java Normal file
View File

@ -0,0 +1,87 @@
package com.qst.dms.ui;
import com.qst.dms.entity.*;
import com.qst.dms.service.LogRecService;
import com.qst.dms.service.TransportService;
import com.qst.dms.service.UserService;
import javafx.application.Application;
import javafx.event.ActionEvent;
import javafx.fxml.FXMLLoader;
import javafx.scene.Scene;
import javafx.scene.layout.AnchorPane;
import javafx.scene.layout.Pane;
import javafx.stage.Stage;
import java.util.ArrayList;
public class MainFrame extends Application
{
public static void main(String[] args){
Application.launch(args);
}
public void startapp()
{
try
{
this.start(new Stage());
}
catch(Exception e)
{
e.printStackTrace();
}
}
private Stage stage;
private Scene infoInputScene,tableScene,updateTimeSetScene;
InfoInputFXML infoInputFXMLController;
TableFXML tableFXMLController;
UpdateTimeSetFXML updateTimeSetFXMLController;
@Override
public void start(Stage _stage) throws Exception
{
stage = _stage;
FXMLLoader infoInputFrameFXMLLoader = new FXMLLoader();
FXMLLoader tableFrameFXMLLoader = new FXMLLoader();
FXMLLoader updateTimeSetFXMLLoader = new FXMLLoader();
infoInputFrameFXMLLoader.setLocation(getClass().getClassLoader().getResource("resources/InfoInputFrame.fxml"));
tableFrameFXMLLoader.setLocation(getClass().getClassLoader().getResource("resources/TableFrame.fxml"));
updateTimeSetFXMLLoader.setLocation(getClass().getClassLoader().getResource("resources/timeSetDialog.fxml"));
//set Scene
infoInputScene = new Scene(infoInputFrameFXMLLoader.load());
tableScene = new Scene(tableFrameFXMLLoader.load());
updateTimeSetScene = new Scene(updateTimeSetFXMLLoader.load());
//set Controller
infoInputFXMLController = infoInputFrameFXMLLoader.getController();
tableFXMLController = tableFrameFXMLLoader.getController();
updateTimeSetFXMLController = updateTimeSetFXMLLoader.getController();
//set Delegation
infoInputFXMLController.getDelegation(this);
tableFXMLController.getDelegation(this,infoInputFXMLController);
updateTimeSetFXMLController.getDelegation(infoInputFXMLController,tableFXMLController);
//set Stage
stage.setScene(infoInputScene);
stage.setResizable(false);
stage.show();
}
public void toInfoInputFrame() {
stage.setScene(infoInputScene);
infoInputFXMLController.fadeIn(null);
}
public void toTableFrame() {
tableFXMLController.setTable();
stage.setScene(tableScene);
tableFXMLController.fadeIn(null);
}
public void updateFlushTime() {
Stage subWindow = new Stage();
subWindow.setScene(updateTimeSetScene);
subWindow.setOnCloseRequest((event)->{
event.consume();
updateTimeSetFXMLController.closeRequest();
subWindow.close();
});
subWindow.show();
}
}

216
src/com/qst/dms/ui/RegistFrame.java Normal file
View File

@ -0,0 +1,216 @@
package com.qst.dms.ui;
import java.awt.FlowLayout;
import java.awt.GridLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.ButtonGroup;
import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JCheckBox;
import javax.swing.JComboBox;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JPasswordField;
import javax.swing.JRadioButton;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import com.qst.dms.entity.User;
import com.qst.dms.security.String_SHA_256;
import com.qst.dms.service.UserService;
//注册窗口
public class RegistFrame extends JFrame {
// 主面板
private JPanel p;
// 标签
private JLabel lblName, lblPwd, lblRePwd, lblSex, lblHobby, lblAdress,
lblDegree;
// 用户名，文本框
private JTextField txtName;
// 密码和确认密码，密码框
private JPasswordField txtPwd, txtRePwd;
// 性别，单选按钮
private JRadioButton rbMale, rbFemale;
// 爱好，多选框
private JCheckBox ckbRead, ckbNet, ckbSwim, ckbTour;
// 地址，文本域
private JTextArea txtAdress;
// 学历，组合框
private JComboBox<String> cmbDegree;
// 确认和取消，按钮
private JButton btnOk, btnCancle;
// 注册的用户
private static User user;
// 用户业务类
private UserService userService;
// 构造方法
public RegistFrame() {
super("用户注册");
// 实例化用户业务类对象
userService = new UserService();
// 设置窗体的icon
ImageIcon icon = new ImageIcon("images\\dms.png");
this.setIconImage(icon.getImage());
// 设置面板布局，网格布局
p = new JPanel(new GridLayout(8, 1));
// 实例化组件
lblName = new JLabel("用 户 名：");
lblPwd = new JLabel("密 码：");
lblRePwd = new JLabel("确认密码：");
lblSex = new JLabel("性 别：");
lblHobby = new JLabel("爱 好：");
lblAdress = new JLabel("地 址：");
lblDegree = new JLabel("学 历：");
txtName = new JTextField(16);
txtPwd = new JPasswordField(16);
txtRePwd = new JPasswordField(16);
rbMale = new JRadioButton("男");
rbFemale = new JRadioButton("女");
// 性别的单选逻辑
ButtonGroup bg = new ButtonGroup();
bg.add(rbMale);
bg.add(rbFemale);
ckbRead = new JCheckBox("阅读");
ckbNet = new JCheckBox("上网");
ckbSwim = new JCheckBox("游泳");
ckbTour = new JCheckBox("旅游");
txtAdress = new JTextArea(3, 20);
// 组合框显示的学历数组
String str[] = { "小学", "初中", "高中", "本科", "硕士", "博士" };
cmbDegree = new JComboBox<String>(str);
// 设置组合框可编辑
cmbDegree.setEditable(true);
btnOk = new JButton("确定");
// 注册监听器，监听确定按钮
btnOk.addActionListener(new RegisterListener());
btnCancle = new JButton("重置");
// 注册监听器，监听重置按钮
btnCancle.addActionListener(new ResetListener());
// 将组件分组放入面板，然后将小面板放入主面板
JPanel p1 = new JPanel(new FlowLayout(FlowLayout.LEFT));
p1.add(lblName);
p1.add(txtName);
p.add(p1);
JPanel p2 = new JPanel(new FlowLayout(FlowLayout.LEFT));
p2.add(lblPwd);
p2.add(txtPwd);
p.add(p2);
JPanel p3 = new JPanel(new FlowLayout(FlowLayout.LEFT));
p3.add(lblRePwd);
p3.add(txtRePwd);
p.add(p3);
JPanel p4 = new JPanel(new FlowLayout(FlowLayout.LEFT));
p4.add(lblSex);
p4.add(rbMale);
p4.add(rbFemale);
p.add(p4);
JPanel p5 = new JPanel(new FlowLayout(FlowLayout.LEFT));
p5.add(lblHobby);
p5.add(ckbRead);
p5.add(ckbNet);
p5.add(ckbSwim);
p5.add(ckbTour);
p.add(p5);
JPanel p6 = new JPanel(new FlowLayout(FlowLayout.LEFT));
p6.add(lblAdress);
p6.add(txtAdress);
p.add(p6);
JPanel p7 = new JPanel(new FlowLayout(FlowLayout.LEFT));
p7.add(lblDegree);
p7.add(cmbDegree);
p.add(p7);
JPanel p8 = new JPanel(new FlowLayout(FlowLayout.CENTER));
p8.add(btnOk);
p8.add(btnCancle);
p.add(p8);
// 主面板放入窗体中
this.add(p);
// 设置窗体大小和位置
this.setSize(310, 350);
this.setLocation(300, 300);
// 设置窗体不可改变大小
this.setResizable(false);
// 设置窗体初始可见
this.setVisible(true);
}
// 监听类，负责处理确认按钮的业务逻辑
private class RegisterListener implements ActionListener {
// 重写actionPerFormed()方法，事件处理方法
public void actionPerformed(ActionEvent e) {
// 获取用户输入的数据
String userName = txtName.getText().trim();
String password = new String(txtPwd.getPassword());
String rePassword = new String(txtRePwd.getPassword());
// 将性别“男”“女”对应转化为“1”“0”
int sex = Integer.parseInt(rbFemale.isSelected() ? "0" : "1");
String hobby = (ckbRead.isSelected() ? "阅读" : "")
+ (ckbNet.isSelected() ? "上网" : "")
+ (ckbSwim.isSelected() ? "游泳" : "")
+ (ckbTour.isSelected() ? "旅游" : "");
String address = txtAdress.getText().trim();
String degree = cmbDegree.getSelectedItem().toString().trim();
// 判断两次输入密码是否一致
if (password.equals(rePassword)) {
// 将数据封装到对象中
password = String_SHA_256.String_to_SHA256(password);
user = new User(userName, password, sex, hobby, address, degree);
// 保存数据
if (userService.saveUser(user)) {
// 输出提示信息
//System.out.println("注册成功！");
JOptionPane.showMessageDialog(null,"注册成功！","成功提示",JOptionPane.PLAIN_MESSAGE);
} else {
// 输出提示信息
//System.out.println("注册失败！");
JOptionPane.showMessageDialog(null,"注册失败！","错误提示",JOptionPane.ERROR_MESSAGE);
}
} else {
// 输出提示信息
//System.out.println("两次输入的密码不一致！");
JOptionPane.showMessageDialog(null,"两次输入的密码不一致！","错误提示",JOptionPane.ERROR_MESSAGE);
}
}
}
// 监听类，负责处理重置按钮
public class ResetListener implements ActionListener {
// 重写actionPerFormed()方法，重置组件内容事件处理方法
public void actionPerformed(ActionEvent e) {
// 清空姓名、密码、确认密码内容
txtName.setText("");
txtPwd.setText("");
txtRePwd.setText("");
// 重置单选按钮为未选择
rbMale.setSelected(false);
rbFemale.setSelected(false);
// 重置所有的复选按钮为未选择
ckbRead.setSelected(false);
ckbNet.setSelected(false);
ckbSwim.setSelected(false);
ckbTour.setSelected(false);
// 清空地址栏
txtAdress.setText("");
// 重置组合框为未选择状态
cmbDegree.setSelectedIndex(0);
}
}
public static void main(String[] args) {
new RegistFrame();
}
}

356
src/com/qst/dms/ui/TableFXML.java Normal file
View File

@ -0,0 +1,356 @@
package com.qst.dms.ui;
import com.qst.dms.db.DBUtil;
import com.qst.dms.entity.MatchedLogRec;
import com.qst.dms.entity.MatchedTransport;
import com.qst.dms.entity.Transport;
import com.qst.dms.service.LogRecService;
import com.qst.dms.service.TransportService;
import javafx.animation.FadeTransition;
import javafx.application.Platform;
import javafx.event.ActionEvent;
import javafx.fxml.FXML;
import javafx.scene.control.*;
import javafx.scene.control.cell.PropertyValueFactory;
import javafx.scene.image.Image;
import javafx.scene.image.ImageView;
import javafx.scene.paint.Color;
import javafx.util.Duration;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
public class TableFXML {
private MainFrame mainFrame;
private InfoInputFXML infoInputFrame;
// 创建一个日志业务类
LogRecService logService = new LogRecService();
// 创建一个物流业务类
TransportService tranService = new TransportService();
// 日志数据匹配集合
ArrayList<MatchedLogRec> matchedLogs = null;
// 物流数据匹配集合
ArrayList<MatchedTransport> matchedTrans = null;
@FXML
private TableView<logLine> logTable;
@FXML
private TableColumn<logLine, String> logUsername;
@FXML
private TableColumn<logLine, String> loginTime;
@FXML
private TableColumn<logLine, String> logoutTime;
@FXML
private TableColumn<logLine, String> logAddress;
@FXML
private TableColumn<transportLine, String> transAddress;
@FXML
private TableColumn<transportLine, String> transHandler;
@FXML
private TableColumn<transportLine, String> transID;
@FXML
private TableColumn<transportLine, String> transReceiver;
@FXML
private TableColumn<transportLine, String> transState;
@FXML
private TableColumn<transportLine, String>transTime;
@FXML
private TableColumn<transportLine, String> transType;
@FXML
private TableView<transportLine> transportTable;
@FXML
private Button collectDataButton;
@FXML
private Button matchLogButton;
@FXML
private Button matchTransportButton;
@FXML
private Button sandDataButton;
@FXML
private Button saveDataButton;
@FXML
private Button showDataButton;
@FXML
private TabPane tablePane;
@FXML
private Label logSQLLabel;
@FXML
private Label transportSQLLabel;
private Image OKImage;
private Image errorImage;
private ImageView logImageView;
private ImageView transportImageView;
private Thread errorThread;
private volatile boolean stopRequested = false;
private Thread flusherThread;
public void getDelegation(MainFrame _mainFrame,InfoInputFXML _infoInputFrame)
{
mainFrame = _mainFrame;
infoInputFrame =_infoInputFrame;
}
public void setTable()
{
try
{
matchedLogs = logService.readMatchedLogFromDB();
matchedTrans = tranService.readMatchedTransportFromDB();
}
catch(SQLException e)
{
if(errorThread==null||errorThread.getState()==Thread.State.TERMINATED)
{
errorThread = new Thread(this::SQLError);
errorThread.start();
}
return;
}
logTable.getItems().clear();
transportTable.getItems().clear();
for(MatchedLogRec matchedLogRec:matchedLogs)
logTable.getItems().add(new logLine(matchedLogRec.getUser(),matchedLogRec.getLogInTime().toString(),matchedLogRec.getLogoutTime().toString(),matchedLogRec.getAddress()));
for(MatchedTransport matchedTransport :matchedTrans)
{
Transport[] transports = new Transport[]{ matchedTransport.getSend(), matchedTransport.getTrans(),matchedTransport.getReceive()};
for(Transport transport:transports)
transportTable.getItems().add(new transportLine(transport.getId()+"",transport.getAddress(),transport.getHandler(),transport.getReciver(),"已禁用",transport.getTime().toString(),transport.getType()));
}
}
void SQLError()
{
while(true)
{
for (int i = 3; i >= 0; i--)
{
int finalI = i;
Platform.runLater(() -> {
logSQLLabel.setTextFill(Color.color(1,0,0,1));
transportSQLLabel.setTextFill(Color.color(1,0,0,1));
logImageView.setImage(errorImage);
transportImageView.setImage(errorImage);
logSQLLabel.setText("数据库连接异常，将在" + finalI + "秒后重试");
transportSQLLabel.setText("数据库连接异常，将在" + finalI + "秒后重试");
});
if (i != 0)
try
{
Thread.sleep(1000);
} catch (InterruptedException e)
{
e.printStackTrace();
}
}
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "SELECT * FROM gather_transport";
ResultSet resultSet = db.executeQuery(sql,null);
db.closeAll();
} catch(Exception e)
{
db.closeAll();
continue;
}
break;
}
Platform.runLater(()->{
logImageView.setImage(OKImage);
transportImageView.setImage(OKImage);
logSQLLabel.setText("就绪");
transportSQLLabel.setText("就绪");
logSQLLabel.setTextFill(Color.color(0,0,0,1));
transportSQLLabel.setTextFill(Color.color(0,0,0,1));
});
}
@FXML
void matchedAcquisitionLogData(ActionEvent event) {
infoInputFrame.matchedAcquisitionLogData(null);
}
@FXML
void matchedAcquisitionTransportData(ActionEvent event) {
infoInputFrame.matchedAcquisitionTransportData(null);
}
@FXML
void sandData(ActionEvent event) {
infoInputFrame.sandData(null);
}
@FXML
void saveData(ActionEvent event) {
infoInputFrame.saveData(null);
}
@FXML
void toInfoInputFrame(ActionEvent event) {
fadeOut(()->{mainFrame.toInfoInputFrame();});
}
@FXML
void toTableFrame(ActionEvent event) {
;
}
private Button[] topButtons;
private String[] photos;
public void initialize()
{
topButtons = new Button[]{collectDataButton, matchLogButton, matchTransportButton, saveDataButton, sandDataButton, showDataButton};
photos = new String[]{"dataCollection.png","logPair.png","transportPair.png","save.png","upload.png","table.png"};
setPhotos();
logUsername.setCellValueFactory(new PropertyValueFactory<logLine,String>("logUsername"));
loginTime.setCellValueFactory(new PropertyValueFactory<logLine,String>("loginTime"));
logoutTime.setCellValueFactory(new PropertyValueFactory<logLine,String>("logoutTime"));
logAddress.setCellValueFactory(new PropertyValueFactory<logLine,String>("logAddress"));
transID.setCellValueFactory(new PropertyValueFactory<>("transID"));
transAddress.setCellValueFactory(new PropertyValueFactory<>("transAddress"));
transHandler.setCellValueFactory(new PropertyValueFactory<>("transHandler"));
transReceiver.setCellValueFactory(new PropertyValueFactory<>("transReceiver"));
transState.setCellValueFactory(new PropertyValueFactory<>("transState"));
transTime.setCellValueFactory(new PropertyValueFactory<>("transTime"));
transType.setCellValueFactory(new PropertyValueFactory<>("transType"));
OKImage = new Image("resources/ok.png");
errorImage = new Image("resources/error.png");
logImageView = new ImageView();
transportImageView = new ImageView();
for(ImageView imageView : new ImageView[]{logImageView,transportImageView})
{
imageView.setFitHeight(19);
imageView.setFitWidth(19);
}
logImageView.setImage(OKImage);
transportImageView.setImage(OKImage);
logSQLLabel.setGraphic(logImageView);
transportSQLLabel.setGraphic(transportImageView);
flusherThread = new Thread(()->{flusher();});
flusherThread.start();
}
void updateFlusherTime()
{
Thread thread = new Thread(()->{
stopRequested=true;
while(flusherThread.isAlive())
{
flusherThread.interrupt();
try
{
Thread.sleep(50);
} catch (InterruptedException e)
{
e.printStackTrace();
}
}
stopRequested=false;
flusherThread = new Thread(()->{
flusher();
});
flusherThread.start();
});
thread.start();
}
public void flusher()
{
while (!stopRequested)
{
try
{
Thread.sleep(UpdateTimeSetFXML.updateTime*1000);
} catch (InterruptedException e)
{
break;
}
DBUtil db = new DBUtil();
try
{
db.getConnection();
String sql = "SELECT * FROM gather_transport";
db.closeAll();
} catch(Exception e)
{
db.closeAll();
if(errorThread==null||errorThread.getState()==Thread.State.TERMINATED)
{
errorThread = new Thread(this::SQLError);
errorThread.start();
}
//e.printStackTrace();
}
setTable();
}
}
void setPhotos()
{
for(int i=0;i<topButtons.length;i++)
{
Image image = new Image("resources/"+photos[i]);
ImageView imageView = new ImageView(image);
imageView.setFitWidth(18);
imageView.setFitHeight(18);
topButtons[i].setGraphic(imageView);
}
}
void fadeOut(Runnable action)
{
// 创建FadeTransition对象
FadeTransition fadeOut = new FadeTransition(Duration.seconds(0.5),tablePane );
fadeOut.setFromValue(1); // 初始不透明度为1（完全可见）
fadeOut.setToValue(0); // 目标不透明度为0（完全透明）
fadeOut.setOnFinished((event)->{
if (action != null)
action.run();});
fadeOut.play();
}
void fadeIn(Runnable action)
{
// 创建FadeTransition对象
FadeTransition fadeIn = new FadeTransition(Duration.seconds(0.5),tablePane );
fadeIn.setFromValue(0); // 初始不透明度为1（完全可见）
fadeIn.setToValue(1); // 目标不透明度为0（完全透明）
fadeIn.setOnFinished((event)->{
if (action != null)
action.run();});
fadeIn.play();
}
public void updateFlushTime(ActionEvent event)
{
mainFrame.updateFlushTime();
}
}

70
src/com/qst/dms/ui/UpdateTimeSetFXML.java Normal file
View File

@ -0,0 +1,70 @@
package com.qst.dms.ui;
import javafx.fxml.FXML;
import javafx.fxml.FXMLLoader;
import javafx.scene.control.Slider;
import javafx.scene.control.TextField;
import javafx.scene.input.KeyEvent;
import javafx.scene.input.MouseEvent;
public class UpdateTimeSetFXML
{
public static int updateTime;
public int tempUpdateTime;
private InfoInputFXML infoInputFXML;
private TableFXML tableFXML;
private UpdateTimeSetFXML updateTimeSetFrame;
@FXML
private TextField timeField;
@FXML
private Slider timeSlider;
@FXML
void mouseDragging(MouseEvent event) {
tempUpdateTime = (int)timeSlider.getValue();
timeField.setText(""+tempUpdateTime);
}
public void initialize()
{
updateTime = 1;
timeSlider.setMin(1);
timeSlider.setMax(60);
timeSlider.setValue(1);
timeField.setText("1");
}
public void getDelegation(InfoInputFXML _infoInputFXMLController, TableFXML _tableFXMLController)
{
infoInputFXML=_infoInputFXMLController;
tableFXML=_tableFXMLController;
}
public void beChanged(KeyEvent keyEvent)
{
String value = timeField.getText();
int caretPosition = timeField.getCaretPosition();
if (!value.matches("\\d*")) {
timeField.setText(value.replaceAll("[^\\d]", ""));
timeField.positionCaret(Math.max(0,caretPosition-1));
}
else {
if(value.isEmpty())
return;
tempUpdateTime = Math.max(1,Integer.parseInt(value));
timeSlider.setValue(tempUpdateTime);
}
}
public void closeRequest()
{
updateTime=tempUpdateTime;
infoInputFXML.updateSQLCheckerTime();
tableFXML.updateFlusherTime();
}
}

37
src/com/qst/dms/ui/logLine.java Normal file
View File

@ -0,0 +1,37 @@
package com.qst.dms.ui;
public class logLine
{
public logLine(String logUsername, String loginTime, String logoutTime, String logAddress)
{
this.logUsername = logUsername;
this.loginTime = loginTime;
this.logoutTime = logoutTime;
this.logAddress = logAddress;
}
public String getLogUsername()
{
return logUsername;
}
public String getLoginTime()
{
return loginTime;
}
public String getLogoutTime()
{
return logoutTime;
}
public String getLogAddress()
{
return logAddress;
}
public String logUsername;
public String loginTime;
public String logoutTime;
public String logAddress;
}

62
src/com/qst/dms/ui/transportLine.java Normal file
View File

@ -0,0 +1,62 @@
package com.qst.dms.ui;
import com.qst.dms.entity.Transport;
public class transportLine
{
public transportLine(String transID,String transAddress, String transHandler, String transReceiver, String transState, String transTime, int transType)
{
this.transID = transID;
this.transAddress = transAddress;
this.transHandler = transHandler;
this.transReceiver = transReceiver;
this.transState = transState;
this.transTime = transTime;
switch (transType)
{
case Transport.SENDING -> this.transType = "发货中";
case Transport.TRANSPORTING -> this.transType = "送货中";
case Transport.RECEIVED -> this.transType = "已签收";
}
}
public String getTransID() { return transID; }
public String getTransAddress()
{
return transAddress;
}
public String getTransHandler()
{
return transHandler;
}
public String getTransReceiver()
{
return transReceiver;
}
public String getTransState()
{
return transState;
}
public String getTransTime()
{
return transTime;
}
public String getTransType()
{
return transType;
}
String transID;
String transAddress;
String transHandler;
String transReceiver;
String transState;
String transTime;
String transType;
}

22
src/com/qst/dms/util/Config.java Normal file
View File

@ -0,0 +1,22 @@
package com.qst.dms.util;
import java.io.FileInputStream;
import java.util.Properties;
//配置类
public class Config {
private static Properties p = null;
static {
try {
p = new Properties();
//加载配置类
p.load(new FileInputStream("src/com/qst/dms/db/config/mysql.properties"));
} catch (Exception e) {
e.printStackTrace();
}
}
//获取配置类的参数
public static String getValue(String key) {
return p.get(key).toString();
}
}

208
src/resources/InfoInputFrame.fxml Normal file
View File

@ -0,0 +1,208 @@
<?xml version="1.0" encoding="UTF-8"?>
<?import javafx.scene.control.Button?>
<?import javafx.scene.control.ChoiceBox?>
<?import javafx.scene.control.Label?>
<?import javafx.scene.control.Menu?>
<?import javafx.scene.control.MenuBar?>
<?import javafx.scene.control.MenuItem?>
<?import javafx.scene.control.RadioButton?>
<?import javafx.scene.control.SeparatorMenuItem?>
<?import javafx.scene.control.Tab?>
<?import javafx.scene.control.TabPane?>
<?import javafx.scene.control.TextField?>
<?import javafx.scene.control.ToolBar?>
<?import javafx.scene.layout.AnchorPane?>
<?import javafx.scene.layout.VBox?>
<?import javafx.scene.shape.Line?>
<?import javafx.scene.text.Font?>
<?import javafx.scene.text.Text?>
<VBox maxHeight="-Infinity" maxWidth="-Infinity" minHeight="-Infinity" minWidth="-Infinity" prefHeight="400.0" prefWidth="600.0" xmlns="http://javafx.com/javafx/21" xmlns:fx="http://javafx.com/fxml/1" fx:controller="com.qst.dms.ui.InfoInputFXML">
<children>
<MenuBar>
<menus>
<Menu mnemonicParsing="false" text="操作">
<items>
<MenuItem mnemonicParsing="false" onAction="#toInfoInputFrame" text="采集数据" />
<MenuItem mnemonicParsing="false" onAction="#matchedAcquisitionLogData" text="匹配日志数据" />
<MenuItem mnemonicParsing="false" onAction="#matchedAcquisitionTransportData" text="匹配物流数据" />
<MenuItem mnemonicParsing="false" onAction="#saveData" text="保存数据" />
<MenuItem mnemonicParsing="false" onAction="#sandData" text="发送数据" />
<MenuItem mnemonicParsing="false" onAction="#toTableFrame" text="显示数据" />
<SeparatorMenuItem mnemonicParsing="false" />
<MenuItem mnemonicParsing="false" onAction="#updateFlushTime" text="设置更新时间" />
</items>
</Menu>
<Menu mnemonicParsing="false" text="帮助">
<items>
<MenuItem mnemonicParsing="false" text="查看帮助" />
<MenuItem mnemonicParsing="false" text="关于" />
</items>
</Menu>
</menus>
</MenuBar>
<AnchorPane prefHeight="375.0" prefWidth="600.0">
<children>
<ToolBar prefHeight="40.0" prefWidth="600.0">
<items>
<Button fx:id="collectDataButton" mnemonicParsing="false" onAction="#toInfoInputFrame" text="采集数据" />
<Button fx:id="matchLogButton" mnemonicParsing="false" onAction="#matchedAcquisitionLogData" text="匹配日志数据" />
<Button fx:id="matchTransportButton" mnemonicParsing="false" onAction="#matchedAcquisitionTransportData" text="匹配物流数据" />
<Button fx:id="saveDataButton" mnemonicParsing="false" onAction="#saveData" text="保存数据" />
<Button fx:id="sandDataButton" mnemonicParsing="false" onAction="#sandData" text="发送数据" />
<Button fx:id="showDataButton" mnemonicParsing="false" onAction="#toTableFrame" text="显示数据" />
</items>
</ToolBar>
<TabPane fx:id="collectDataPane" layoutY="40.0" prefHeight="335.0" prefWidth="600.0" tabClosingPolicy="UNAVAILABLE">
<tabs>
<Tab text="日志">
<content>
<AnchorPane minHeight="0.0" minWidth="0.0" prefHeight="180.0" prefWidth="200.0">
<children>
<Text layoutX="121.66" layoutY="101.0" strokeType="OUTSIDE" strokeWidth="0.0" text="用户名：" textAlignment="CENTER" AnchorPane.topAnchor="84.75">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66" layoutY="136.0" strokeType="OUTSIDE" strokeWidth="0.0" text="登录地点：" textAlignment="CENTER" AnchorPane.topAnchor="119.75">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66" layoutY="171.0" strokeType="OUTSIDE" strokeWidth="0.0" text="登录IP：" textAlignment="CENTER" AnchorPane.topAnchor="154.75">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66" layoutY="66.0" strokeType="OUTSIDE" strokeWidth="0.0" text="日志ID：" textAlignment="CENTER" AnchorPane.topAnchor="49.75">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66" layoutY="206.0" strokeType="OUTSIDE" strokeWidth="0.0" text="登录状态：" textAlignment="CENTER" AnchorPane.topAnchor="189.75">
<font>
<Font size="16.0" />
</font>
</Text>
<TextField fx:id="logID" layoutX="239.0" layoutY="49.0" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefHeight="10.0" prefWidth="220.0" AnchorPane.leftAnchor="207.0" AnchorPane.topAnchor="49.75" />
<TextField fx:id="logUser" layoutX="239.0" layoutY="85.0" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefHeight="10.0" prefWidth="220.0" AnchorPane.leftAnchor="207.0" AnchorPane.topAnchor="84.75" />
<TextField fx:id="logPosition" layoutX="239.0" layoutY="119.0" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefHeight="10.0" prefWidth="220.0" AnchorPane.leftAnchor="207.0" AnchorPane.topAnchor="119.75" />
<TextField fx:id="logIP" layoutX="239.0" layoutY="155.0" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefHeight="10.0" prefWidth="220.0" AnchorPane.leftAnchor="207.0" AnchorPane.topAnchor="154.75" />
<RadioButton fx:id="logLogin" layoutX="240.0" layoutY="192.0" mnemonicParsing="false" onAction="#LoginSet" text="登入" AnchorPane.topAnchor="192.0" />
<RadioButton fx:id="logLogout" layoutX="332.0" layoutY="192.0" mnemonicParsing="false" onAction="#LogoutSet" text="登出" AnchorPane.topAnchor="192.0" />
<Button layoutX="209.0" layoutY="241.0" mnemonicParsing="false" onAction="#ConfirmLog" prefHeight="23.0" prefWidth="64.0" text="确认" AnchorPane.leftAnchor="208.0" AnchorPane.rightAnchor="328.0" />
<Button layoutX="358.0" layoutY="241.0" mnemonicParsing="false" onAction="#RedoALLLog" prefHeight="23.0" prefWidth="64.0" text="重置" AnchorPane.rightAnchor="208.0" />
<Label fx:id="logStateEmpty" layoutX="457.0" layoutY="192.0" prefHeight="19.0" prefWidth="105.0" text="请选择登录状态" textFill="RED">
<font>
<Font size="14.0" />
</font></Label>
<Label fx:id="logLabelSuccess" layoutX="271.0" layoutY="210.0" prefHeight="19.0" prefWidth="57.0" text="录入成功" textAlignment="CENTER" textFill="#28e228">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="logIPEmpty" layoutX="457.0" layoutY="156.0" prefHeight="19.0" prefWidth="105.0" text="登录IP不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="logAddressEmpty" layoutX="457.0" layoutY="122.0" prefHeight="19.0" prefWidth="105.0" text="地点不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="logUserEmpty" layoutX="457.0" layoutY="86.0" prefHeight="19.0" prefWidth="105.0" text="用户名不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="logIDError" layoutX="457.0" layoutY="52.0" prefHeight="19.0" prefWidth="105.0" text="ID不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Line endX="500.0" layoutX="100.0" layoutY="286.0" startX="-100.0" stroke="#888787" AnchorPane.bottomAnchor="19.5" AnchorPane.leftAnchor="0.0" />
<Label fx:id="logInfoLabel" layoutX="17.333333333333332" layoutY="284.0" prefHeight="20.0" prefWidth="600.0" text="就绪" AnchorPane.bottomAnchor="0.0" AnchorPane.leftAnchor="0.0" />
</children>
</AnchorPane>
</content>
</Tab>
<Tab text="物流">
<content>
<AnchorPane minHeight="0.0" minWidth="0.0" prefHeight="180.0" prefWidth="600.0">
<children>
<Text layoutX="121.66666666666667" layoutY="66.25" strokeType="OUTSIDE" strokeWidth="0.0" text="物流ID：" AnchorPane.leftAnchor="121.66666666666667" AnchorPane.topAnchor="50.0">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66666666666667" layoutY="100.91666666666667" strokeType="OUTSIDE" strokeWidth="0.0" text="目的地：" AnchorPane.leftAnchor="121.66666666666667" AnchorPane.topAnchor="84.66666666666667">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66666666666667" layoutY="136.25" strokeType="OUTSIDE" strokeWidth="0.0" text="经手人：" AnchorPane.leftAnchor="121.66666666666667" AnchorPane.topAnchor="120.0">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66666666666667" layoutY="170.91666666666666" strokeType="OUTSIDE" strokeWidth="0.0" text="收货人：" AnchorPane.leftAnchor="121.66666666666667" AnchorPane.topAnchor="154.66666666666666">
<font>
<Font size="16.0" />
</font>
</Text>
<Text layoutX="121.66666666666667" layoutY="206.25" strokeType="OUTSIDE" strokeWidth="0.0" text="物流状态：" AnchorPane.leftAnchor="121.66666666666667" AnchorPane.topAnchor="190.0">
<font>
<Font size="16.0" />
</font>
</Text>
<TextField fx:id="transportID" layoutX="207.33333333333334" layoutY="51.0" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefWidth="220.0" AnchorPane.leftAnchor="207.33333333333334" AnchorPane.rightAnchor="172.66666666666669" AnchorPane.topAnchor="51.0" />
<TextField fx:id="transportAddress" layoutX="207.0" layoutY="84.66666666666667" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefWidth="220.0" AnchorPane.leftAnchor="207.0" AnchorPane.topAnchor="84.66666666666667" />
<TextField fx:id="transportHandler" layoutX="207.0" layoutY="120.0" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefWidth="220.0" AnchorPane.leftAnchor="207.0" AnchorPane.topAnchor="120.0" />
<TextField fx:id="transportReceiver" layoutX="207.0" layoutY="154.66666666666666" onKeyTyped="#beChanged" onMouseClicked="#beClicked" prefWidth="220.0" AnchorPane.leftAnchor="207.0" AnchorPane.topAnchor="154.66666666666666" />
<ChoiceBox fx:id="transportMode" layoutX="208.0" layoutY="189.0" prefHeight="23.0" prefWidth="181.0" />
<Button layoutX="212.0" layoutY="241.0" mnemonicParsing="false" onAction="#ConfirmTransport" prefHeight="23.0" prefWidth="64.0" text="确认" AnchorPane.leftAnchor="208.0" />
<Button layoutX="349.0" layoutY="241.0" mnemonicParsing="false" onAction="#RedoAllTransport" prefHeight="23.0" prefWidth="64.0" text="重置" AnchorPane.rightAnchor="208.0" />
<Label fx:id="transportIDError" layoutX="448.0" layoutY="52.0" text="ID不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="transportAddressEmpty" layoutX="448.0" layoutY="86.0" text="目的地不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="transportHandlerEmpty" layoutX="448.0" layoutY="122.0" text="经手人不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
+ </Label>
<Label fx:id="transportReceiverEmpty" layoutX="448.0" layoutY="156.0" text="收货人不能为空" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="transportStateEmpty" layoutX="448.0" layoutY="191.0" text="请选择物流状态" textFill="RED">
<font>
<Font size="14.0" />
</font>
</Label>
<Label fx:id="transportLabelSuccess" layoutX="271.0" layoutY="216.0" prefHeight="19.0" prefWidth="57.0" text="录入成功" textAlignment="CENTER" textFill="#28e228">
<font>
<Font size="14.0" />
</font>
</Label>
<Line endX="500.0" layoutX="33.0" layoutY="281.0" startX="-100.0" stroke="#888787" AnchorPane.bottomAnchor="19.5" AnchorPane.leftAnchor="0.0" />
<Label fx:id="transportInfoLabel" layoutX="23.0" layoutY="284.0" prefHeight="19.5" prefWidth="600.0" text="就绪" AnchorPane.bottomAnchor="0.0" AnchorPane.leftAnchor="0.0" />
</children>
</AnchorPane>
</content>
</Tab>
</tabs>
</TabPane>
</children>
</AnchorPane>
</children>
</VBox>

19
src/resources/LoginFrame.fxml Normal file
View File

@ -0,0 +1,19 @@
<?xml version="1.0" encoding="UTF-8"?>
<?import javafx.scene.control.Button?>
<?import javafx.scene.control.Label?>
<?import javafx.scene.control.PasswordField?>
<?import javafx.scene.control.TextField?>
<?import javafx.scene.layout.AnchorPane?>
<AnchorPane prefHeight="155.0" prefWidth="289.0" xmlns="http://javafx.com/javafx/21" xmlns:fx="http://javafx.com/fxml/1" fx:controller="com.qst.dms.ui.LoginFXML">
<children>
<Label layoutX="44.0" layoutY="35.0" prefHeight="23.0" prefWidth="54.0" text="用户名：" textAlignment="CENTER" />
<Label layoutX="44.0" layoutY="61.0" prefHeight="23.0" prefWidth="54.0" text="密 码：" textAlignment="CENTER" />
<Button id="Login_Button" layoutX="44.0" layoutY="110.0" mnemonicParsing="false" onAction="#Login" text="登录" />
<Button id="Reset_Button" layoutX="124.0" layoutY="110.0" mnemonicParsing="false" onAction="#Reset" text="重置" />
<Button id="Register_Button" layoutX="204.0" layoutY="110.0" mnemonicParsing="false" onAction="#Register" text="注册" />
<TextField fx:id="Username" layoutX="98.0" layoutY="35.0" prefHeight="23.0" prefWidth="138.0" />
<PasswordField fx:id="Password" layoutX="98.0" layoutY="66.0" prefHeight="23.0" prefWidth="138.0" />
</children>
</AnchorPane>

97
src/resources/TableFrame.fxml Normal file
View File

@ -0,0 +1,97 @@
<?xml version="1.0" encoding="UTF-8"?>
<?import javafx.scene.control.Button?>
<?import javafx.scene.control.Label?>
<?import javafx.scene.control.Menu?>
<?import javafx.scene.control.MenuBar?>
<?import javafx.scene.control.MenuItem?>
<?import javafx.scene.control.SeparatorMenuItem?>
<?import javafx.scene.control.Tab?>
<?import javafx.scene.control.TabPane?>
<?import javafx.scene.control.TableColumn?>
<?import javafx.scene.control.TableView?>
<?import javafx.scene.control.ToolBar?>
<?import javafx.scene.layout.AnchorPane?>
<?import javafx.scene.layout.VBox?>
<VBox maxHeight="-Infinity" maxWidth="-Infinity" minHeight="-Infinity" minWidth="-Infinity" prefHeight="400.0" prefWidth="600.0" xmlns="http://javafx.com/javafx/21" xmlns:fx="http://javafx.com/fxml/1" fx:controller="com.qst.dms.ui.TableFXML">
<children>
<MenuBar>
<menus>
<Menu mnemonicParsing="false" text="操作">
<items>
<MenuItem mnemonicParsing="false" onAction="#toInfoInputFrame" text="采集数据" />
<MenuItem mnemonicParsing="false" onAction="#matchedAcquisitionLogData" text="匹配日志数据" />
<MenuItem mnemonicParsing="false" onAction="#matchedAcquisitionTransportData" text="匹配物流数据" />
<MenuItem mnemonicParsing="false" onAction="#saveData" text="保存数据" />
<MenuItem mnemonicParsing="false" onAction="#sandData" text="发送数据" />
<MenuItem mnemonicParsing="false" onAction="#toTableFrame" text="显示数据" />
<SeparatorMenuItem mnemonicParsing="false" />
<MenuItem mnemonicParsing="false" onAction="#updateFlushTime" text="设置更新时间" />
</items>
</Menu>
<Menu mnemonicParsing="false" text="帮助">
<items>
<MenuItem mnemonicParsing="false" text="查看帮助" />
<MenuItem mnemonicParsing="false" text="关于" />
</items>
</Menu>
</menus>
</MenuBar>
<AnchorPane prefHeight="375.0" prefWidth="600.0">
<children>
<ToolBar prefHeight="40.0" prefWidth="600.0">
<items>
<Button fx:id="collectDataButton" mnemonicParsing="false" onAction="#toInfoInputFrame" text="采集数据" />
<Button fx:id="matchLogButton" mnemonicParsing="false" onAction="#matchedAcquisitionLogData" text="匹配日志数据" />
<Button fx:id="matchTransportButton" mnemonicParsing="false" onAction="#matchedAcquisitionTransportData" text="匹配物流数据" />
<Button fx:id="saveDataButton" mnemonicParsing="false" onAction="#saveData" text="保存数据" />
<Button fx:id="sandDataButton" mnemonicParsing="false" onAction="#sandData" text="发送数据" />
<Button fx:id="showDataButton" mnemonicParsing="false" onAction="#toTableFrame" text="显示数据" />
</items>
</ToolBar>
<TabPane fx:id="tablePane" layoutY="40.0" prefHeight="335.0" prefWidth="600.0" tabClosingPolicy="UNAVAILABLE">
<tabs>
<Tab text="日志">
<content>
<AnchorPane minHeight="0.0" minWidth="0.0" prefHeight="284.0" prefWidth="600.0">
<children>
<TableView fx:id="logTable" prefHeight="287.0" prefWidth="600.0" AnchorPane.bottomAnchor="19.5" AnchorPane.topAnchor="0.0">
<columns>
<TableColumn fx:id="logUsername" prefWidth="150.0" text="用户名" />
<TableColumn fx:id="loginTime" minWidth="0.0" prefWidth="190.0" text="登录时间" />
<TableColumn fx:id="logoutTime" prefWidth="190.0" text="登出时间" />
<TableColumn fx:id="logAddress" prefWidth="69.0" text="登录地点" />
</columns>
</TableView>
<Label fx:id="logSQLLabel" layoutX="29.0" layoutY="284.0" prefHeight="19.5" prefWidth="600.0" text="就绪" AnchorPane.bottomAnchor="0.0" AnchorPane.leftAnchor="0.0" />
</children>
</AnchorPane>
</content>
</Tab>
<Tab text="物流">
<content>
<AnchorPane minHeight="0.0" minWidth="0.0" prefHeight="289.0" prefWidth="600.0">
<children>
<TableView fx:id="transportTable" prefHeight="309.0" prefWidth="600.0" AnchorPane.bottomAnchor="19.5" AnchorPane.topAnchor="0.0">
<columns>
<TableColumn fx:id="transID" prefWidth="68.66662347316742" text="物流ID" />
<TableColumn fx:id="transTime" prefWidth="176.0" text="采集时间" />
<TableColumn fx:id="transAddress" prefWidth="90.0" text="目的地" />
<TableColumn fx:id="transState" prefWidth="50.0" text="状态" />
<TableColumn fx:id="transHandler" prefWidth="75.0" text="经手人" />
<TableColumn fx:id="transReceiver" prefWidth="75.0" text="收货人" />
<TableColumn fx:id="transType" prefWidth="60.66668701171875" text="物流类型" />
</columns>
</TableView>
<Label fx:id="transportSQLLabel" layoutX="57.0" layoutY="284.0" prefHeight="19.5" prefWidth="600.0" text="就绪" AnchorPane.bottomAnchor="0.0" AnchorPane.leftAnchor="0.0" />
</children>
</AnchorPane>
</content>
</Tab>
</tabs>
</TabPane>
</children>
</AnchorPane>
</children>
</VBox>

BIN
src/resources/dataCollection.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 10 KiB

BIN
src/resources/error.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 6.9 KiB

BIN
src/resources/info.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 7.7 KiB

BIN
src/resources/logPair.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 12 KiB

BIN
src/resources/ok.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 19 KiB

BIN
src/resources/save.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 6.6 KiB

BIN
src/resources/table.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 5.1 KiB

34
src/resources/timeSetDialog.fxml Normal file
View File

@ -0,0 +1,34 @@
<?xml version="1.0" encoding="UTF-8"?>
<?import javafx.scene.control.Label?>
<?import javafx.scene.control.Slider?>
<?import javafx.scene.control.TextField?>
<?import javafx.scene.image.Image?>
<?import javafx.scene.image.ImageView?>
<?import javafx.scene.layout.AnchorPane?>
<?import javafx.scene.shape.Line?>
<?import javafx.scene.text.Font?>
<AnchorPane prefHeight="147.0" prefWidth="349.0" xmlns="http://javafx.com/javafx/21" xmlns:fx="http://javafx.com/fxml/1" fx:controller="com.qst.dms.ui.UpdateTimeSetFXML">
<children>
<Label layoutX="29.0" layoutY="27.0" text="设置更新时间">
<font>
<Font size="16.0" />
</font>
</Label>
<ImageView fitHeight="49.0" fitWidth="49.0" layoutX="265.0" layoutY="14.0" pickOnBounds="true" preserveRatio="true">
<image>
<Image url="@info.png" />
</image>
</ImageView>
<Line endX="249.00003051757812" endY="-2.288818359375E-5" layoutX="101.0" layoutY="74.0" startX="-100.0" />
<Label layoutX="39.0" layoutY="96.0" text="更新时间 (s)">
<font>
<Font size="14.0" />
</font>
</Label>
<Slider fx:id="timeSlider" layoutX="143.0" layoutY="99.0" onMouseClicked="#mouseDragging" onMouseDragged="#mouseDragging" AnchorPane.leftAnchor="143.0" />
<TextField fx:id="timeField" layoutX="288.0" layoutY="94.0" onKeyTyped="#beChanged" prefHeight="23.0" prefWidth="49.0" />
<Line endX="249.33331298828125" endY="-4.000022888183594" layoutX="-36.0" layoutY="117.0" startX="249.33331298828125" startY="-18.000022888183594" stroke="#000000ac" />
</children>
</AnchorPane>

BIN
src/resources/transportPair.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 8.2 KiB

BIN
src/resources/upload.png Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 7.6 KiB