山东
This commit is contained in:
ICEC
@ -142,6 +142,67 @@ public class DB_Ajax_DashBoard_48102 {
|
||||
|
||||
|
||||
|
||||
public static String SD_DoGetCurrent() {
|
||||
StringBuilder jsonpath = new StringBuilder();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tChangeMould,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.Id,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.Line,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.CustomerName,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.NormalDensity,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.Length,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.NormalCapacity,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.SoCode,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.NormalWeight,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.Quantity,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.FactCapacity,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.MouldingStyleCode,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.CurrentFinishedQuantity\n" +
|
||||
"\t\n" +
|
||||
"\t,\n" +
|
||||
"CASE\n" +
|
||||
"\t\t\n" +
|
||||
"\t\tWHEN ( CurrentYield IS NULL ) THEN\n" +
|
||||
"\t\t0 ELSE CurrentYield \n" +
|
||||
"\tEND AS CurrentYield,\n" +
|
||||
"CASE\n" +
|
||||
"\t\t\n" +
|
||||
"\t\tWHEN ( CapacityStandardObtainedRate IS NULL ) THEN\n" +
|
||||
"\t\t0 ELSE CapacityStandardObtainedRate \n" +
|
||||
"\tEND AS CapacityStandardObtainedRate,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.SectionalErea,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.MouldYield,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.FinishedQuantity,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.TotalCapacity,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.ChangeMouldTime,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.OperatePersonCode,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.OperatePersonName,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.Speed,\n" +
|
||||
"\tV_SD_MouldingDisplayBoard.CurrentFinishLength \n" +
|
||||
"FROM\n" +
|
||||
"\tV_SD_MouldingDisplayBoard \n" +
|
||||
"ORDER BY\n" +
|
||||
"\tCAST ( REPLACE( V_SD_MouldingDisplayBoard.Line, '#', '' ) AS INT ) FOR JSON PATH";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
jsonpath.append(rs.getString(1));
|
||||
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return jsonpath.toString();
|
||||
}
|
||||
|
||||
public static List<HashMap<String,String>> DoGetLastDay() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
|
||||
139
ruoyi/src/main/java/com/ruoyi/db/sd_mssql/DB_8053_Test.java
Normal file
139
ruoyi/src/main/java/com/ruoyi/db/sd_mssql/DB_8053_Test.java
Normal file
@ -0,0 +1,139 @@
|
||||
package com.ruoyi.db.sd_mssql;
|
||||
|
||||
import java.sql.*;
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
public class DB_8053_Test {
|
||||
|
||||
private static String IP = "192.168.80.53";
|
||||
private static String DBName = "ERPDATA";
|
||||
private static String USER = "sa";
|
||||
private static String PWD = "#080507h";
|
||||
|
||||
/** 创建数据库对象 */
|
||||
private static Connection getSQLConnection() {
|
||||
Connection con = null;
|
||||
try {
|
||||
Class.forName("net.sourceforge.jtds.jdbc.Driver");
|
||||
// 加上 useunicode=true;characterEncoding=UTF-8 防止中文乱码
|
||||
con = DriverManager.getConnection(
|
||||
"jdbc:jtds:sqlserver://" + IP + ":1433/" + DBName + ";useunicode=true;characterEncoding=UTF-8",
|
||||
USER, PWD);
|
||||
} catch (ClassNotFoundException | SQLException e) {
|
||||
e.printStackTrace();
|
||||
System.out.println("==连接数据库失败===");
|
||||
}
|
||||
// System.out.println("==连接数据库成功===");
|
||||
return con;
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetChangeMouldTimeList() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tLine,\n" +
|
||||
"\tLEFT ( MouldingStyleCode, charindex( '-', MouldingStyleCode ) - 1 ) as Mould,MouldingStyleCode,\n" +
|
||||
"\tStartTime,\n" +
|
||||
"\tEndTime ,\n" +
|
||||
"\tDATEDIFF( minute,starttime, endtime) as ChangeMouldTime\n" +
|
||||
"FROM\n" +
|
||||
"\t[dbo].[MouldingDisplayBoard] \n" +
|
||||
"WHERE\n" +
|
||||
"\tChangeMould = 1 and \tDATEDIFF( minute,starttime, endtime) > 20\n" +
|
||||
"\torder by starttime desc \n";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("Line",rs.getString("Line"));
|
||||
map.put("Mould",rs.getString("Mould"));
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("StartTime",rs.getString("StartTime"));
|
||||
map.put("EndTime",rs.getString("EndTime"));
|
||||
map.put("ChangeMouldTime",rs.getString("ChangeMouldTime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGet_avg_changemouldtime_date_range(String fstarttime, String fendtime) {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT AVG\r\n" +
|
||||
" (\r\n" +
|
||||
" DATEDIFF( MINUTE, StartTime, EndTime )) AS avgchangemouldtime \r\n" +
|
||||
"FROM\r\n" +
|
||||
" dbo.MouldingDisplayBoard \r\n" +
|
||||
"WHERE\r\n" +
|
||||
"\tChangeMould = 1 and \tDATEDIFF( minute,starttime, endtime) > 20\n" +
|
||||
" AND Deleted = 0 \r\n" +
|
||||
" AND StartTime > '" + fstarttime + "' \r\n" +
|
||||
" AND endtime < '" + fendtime + "'";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("avgchangemouldtime",rs.getString("avgchangemouldtime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static String JsonTest() {
|
||||
StringBuilder jsonpath = new StringBuilder();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT * from [chen_12个月_A版本BOM销售额] FOR JSON PATH";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
jsonpath.append(rs.getString(1));
|
||||
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return jsonpath.toString();
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,374 @@
|
||||
package com.ruoyi.db.sd_mssql;
|
||||
|
||||
import java.sql.*;
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
public class DB_Ajax_DashBoard_8053 {
|
||||
|
||||
private static String IP = "192.168.80.53";
|
||||
private static String DBName = "ERPDATA";
|
||||
private static String USER = "sa";
|
||||
private static String PWD = "#080507h";
|
||||
|
||||
/** 创建数据库对象 */
|
||||
private static Connection getSQLConnection() {
|
||||
Connection con = null;
|
||||
try {
|
||||
Class.forName("net.sourceforge.jtds.jdbc.Driver");
|
||||
// 加上 useunicode=true;characterEncoding=UTF-8 防止中文乱码
|
||||
con = DriverManager.getConnection(
|
||||
"jdbc:jtds:sqlserver://" + IP + ":1433/" + DBName + ";useunicode=true;characterEncoding=UTF-8",
|
||||
USER, PWD);
|
||||
} catch (ClassNotFoundException | SQLException e) {
|
||||
e.printStackTrace();
|
||||
System.out.println("==连接数据库失败===");
|
||||
}
|
||||
// System.out.println("==连接数据库成功===");
|
||||
return con;
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetCurrentTimeGroup() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT * FROM [dbo].[V_chen_Dashboard_当前] order by " +
|
||||
"CAST (" +
|
||||
"REPLACE( line, '#', '' ) AS INT)";
|
||||
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("line",rs.getString("line"));
|
||||
map.put("Moulds",rs.getString("Moulds"));
|
||||
map.put("Person",rs.getString("Person"));
|
||||
map.put("NormalCapacity",rs.getString("NormalCapacity"));
|
||||
map.put("currentspeed",rs.getString("currentspeed"));
|
||||
map.put("FinishedQuantity",rs.getString("FinishedQuantity"));
|
||||
map.put("GroupTime",rs.getString("GroupTime"));
|
||||
map.put("GroupChangeMouldTime",rs.getString("GroupChangeMouldTime"));
|
||||
map.put("CurrentYield",rs.getString("CurrentYield"));
|
||||
map.put("CapacityStandardObtainedRate",rs.getString("CapacityStandardObtainedRate"));
|
||||
map.put("AvgDensity",rs.getString("AvgDensity"));
|
||||
map.put("MouldAndChangeMouldTime",rs.getString("MouldAndChangeMouldTime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
public static String DoGetCurrent() {
|
||||
StringBuilder jsonpath = new StringBuilder();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\t( SELECT MAX ( MouldingDisplayBoardOperation.OperateTime ) FROM MouldingDisplayBoardOperation WHERE MouldingDisplayBoardOperation.DisplayBoardId = V_MouldingDisplayBoard.Id ) AS LastUpdateDate,\n" +
|
||||
"ChangeMould,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.Id,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.Line,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.CustomerName,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.NormalDensity,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.Length,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.NormalCapacity,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.SoCode,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.NormalWeight,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.Quantity,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.FactCapacity,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.MouldingStyleCode,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.CurrentFinishedQuantity\n" +
|
||||
"\t\n" +
|
||||
"\t,\n" +
|
||||
"CASE\n" +
|
||||
"\t\t\n" +
|
||||
"\t\tWHEN ( CurrentYield IS NULL ) THEN\n" +
|
||||
"\t\t0 ELSE CurrentYield \n" +
|
||||
"\tEND AS CurrentYield,\n" +
|
||||
"CASE\n" +
|
||||
"\t\t\n" +
|
||||
"\t\tWHEN ( CapacityStandardObtainedRate IS NULL ) THEN\n" +
|
||||
"\t\t0 ELSE CapacityStandardObtainedRate \n" +
|
||||
"\tEND AS CapacityStandardObtainedRate,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.SectionalErea,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.MouldYield,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.FinishedQuantity,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.TotalCapacity,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.ChangeMouldTime,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.OperatePersonCode,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.OperatePersonName,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.Speed,\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard.CurrentFinishLength \n" +
|
||||
"FROM\n" +
|
||||
"\tdbo.V_MouldingDisplayBoard \n" +
|
||||
"ORDER BY\n" +
|
||||
"\tCAST (\n" +
|
||||
"\tREPLACE( dbo.V_MouldingDisplayBoard.Line, '#', '' ) AS INT) FOR JSON PATH";
|
||||
Statement stmt = conn.createStatement();//
|
||||
System.out.println(sql);
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
jsonpath.append(rs.getString(1));
|
||||
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return jsonpath.toString();
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetLastDay() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT * FROM V_chen_Dashboard_当天 ORDER BY " +
|
||||
"CAST (" +
|
||||
"REPLACE( line, '#', '' ) AS INT)";
|
||||
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
|
||||
|
||||
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("line",rs.getString("line"));
|
||||
map.put("Moulds",rs.getString("Moulds"));
|
||||
map.put("sumbox",rs.getString("sumbox"));
|
||||
map.put("sum_box_meter",rs.getString("sum_box_meter"));
|
||||
map.put("sum_device_meter",rs.getString("sum_device_meter"));
|
||||
map.put("avg_density",rs.getString("avg_density"));
|
||||
map.put("avg_currentcapacity",rs.getString("avg_currentcapacity"));
|
||||
map.put("avg_normalcapacity",rs.getString("avg_normalcapacity"));
|
||||
map.put("lastchangemouldtime",rs.getString("lastchangemouldtime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
public static List<HashMap<String,String>> DoGet30Day() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT * FROM V_chen_Dashboard_当月 ORDER BY "+
|
||||
" CAST (" +
|
||||
"REPLACE( line, '#', '' ) AS INT)";
|
||||
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
|
||||
|
||||
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("line",rs.getString("line"));
|
||||
map.put("Moulds",rs.getString("Moulds"));
|
||||
map.put("sumbox",rs.getString("sumbox"));
|
||||
map.put("sum_box_meter",rs.getString("sum_box_meter"));
|
||||
map.put("sum_device_meter",rs.getString("sum_device_meter"));
|
||||
map.put("avg_density",rs.getString("avg_density"));
|
||||
map.put("avg_currentcapacity",rs.getString("avg_currentcapacity"));
|
||||
map.put("avg_normalcapacity",rs.getString("avg_normalcapacity"));
|
||||
map.put("lastchangemouldtime",rs.getString("lastchangemouldtime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetDateRange(String fstarttime, String fendtime) {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "DECLARE @FStartTime DATETIME\r\n" +
|
||||
"DECLARE @FEndTime DATETIME\r\n" +
|
||||
"\r\n" +
|
||||
"set @FStartTime='" + fstarttime + "'\r\n" +
|
||||
"set @FEndTime='" + fendtime + "'\r\n" +
|
||||
"\r\n" +
|
||||
"\r\n" +
|
||||
"\r\n" +
|
||||
"\r\n" +
|
||||
"SELECT\r\n" +
|
||||
" db1.line,\r\n" +
|
||||
" AVG ( avg_density ) AS avg_density,\r\n" +
|
||||
" SUM ( sumbox ) AS sumbox,\r\n" +
|
||||
" MAX ( db2.sum1 ) AS sum_box_meter,\r\n" +
|
||||
" MAX ( db2.sum0 ) AS sum_device_meter,\r\n" +
|
||||
" dbo.chen_cal_line_time_mould ( MIN ( db1.StartTime ), MAX ( db1.EndTime ), db1.Line ) AS Moulds,\r\n" +
|
||||
" SUM ( currentcap * ( boxmeter / db2.sum1 )) AS avg_currentcapacity,\r\n" +
|
||||
" SUM ( db1.NormalCapacity* ( boxmeter / db2.sum1 )) AS avg_normalcapacity,\r\n" +
|
||||
" SUM ( boxmeter / db2.sum1 ) AS 校验字段 ,\r\n" +
|
||||
" avg(db4.ChangeMouldTime) as lastchangemouldtime\r\n" +
|
||||
"FROM \r\n" +
|
||||
" (SELECT\r\n" +
|
||||
" dbo.chen_cal_line_difftime( db3.StartTime, db3.EndTime, db3.line, db3.EndTime) as difftime,\r\n" +
|
||||
" db3.Quantity as Quantity,\r\n" +
|
||||
" db3.StartTime as StartTime,\r\n" +
|
||||
" db3.EndTime as EndTime,\r\n" +
|
||||
" db3.line as line,\r\n" +
|
||||
" db3.Length as Length ,\r\n" +
|
||||
" db3.NumberOfEveryKit as NumberOfEveryKit,\r\n" +
|
||||
" db3.MouldingStyleCode as MouldingStyleCode,\r\n" +
|
||||
" db3.SoCode as SoCode,\r\n" +
|
||||
" dbo.chen_cal_line_time_mould ( db3.StartTime, db3.EndTime, Line ) AS Moulds,\r\n" +
|
||||
" dbo.chen_cal_line_time_density ( db3.StartTime, db3.EndTime, Line ) AS avg_density,\r\n" +
|
||||
" \r\n" +
|
||||
" dbo.chen_cal_line_meter ( db3.StartTime, db3.EndTime, Line, @FEndTime ) / dbo.chen_cal_line_difftime( db3.StartTime, db3.EndTime, db3.line, db3.EndTime) * 60 * 60 * 12 AS currentcap,\r\n" +
|
||||
" NormalCapacity,\r\n" +
|
||||
" db3.sumbox AS sumbox,\r\n" +
|
||||
" dbo.chen_cal_line_meter ( db3.StartTime, db3.EndTime, Line, @FEndTime ) AS meter,\r\n" +
|
||||
" (db3.Length * db3.NumberOfEveryKit * db3.sumbox) AS boxmeter\r\n" +
|
||||
" \r\n" +
|
||||
"FROM\r\n" +
|
||||
" (\r\n" +
|
||||
" SELECT\r\n" +
|
||||
" db2.id,\r\n" +
|
||||
" db2.line,\r\n" +
|
||||
" SUM ( db1.Quantity ) AS sumbox,\r\n" +
|
||||
" MIN ( db1.OperateTime ) AS minop,\r\n" +
|
||||
" MAX ( db1.OperateTime ) AS maxop,\r\n" +
|
||||
" MAX (db2.Quantity) as Quantity, \r\n" +
|
||||
" MAX (db2.Length) as Length,\r\n" +
|
||||
" MAX (db2.NumberOfEveryKit) as NumberOfEveryKit,\r\n" +
|
||||
" MAX (db2.MouldingStyleCode) as MouldingStyleCode,\r\n" +
|
||||
" MAX (db2.SoCode) as SoCode, MAX (db2.NormalCapacity) as NormalCapacity,\r\n" +
|
||||
" ( CASE WHEN MIN ( db2.StartTime ) < @FStartTime THEN @FStartTime ELSE MIN ( db2.StartTime ) END ) AS StartTime,\r\n" +
|
||||
" ( CASE WHEN MIN ( db2.EndTime ) IS NULL THEN (dbo.chen_cal_line_op_lasttime(MIN ( db2.EndTime ),db2.line,@FEndTime)) ELSE ( CASE WHEN MIN ( db2.EndTime ) > @FEndTime THEN @FEndTime ELSE MIN ( db2.EndTime ) END ) END ) AS EndTime FROM\r\n" +
|
||||
" [dbo].[MouldingDisplayBoardOperation] AS db1\r\n" +
|
||||
" INNER JOIN MouldingDisplayBoard AS db2 ON db2.id = db1.DisplayBoardId \r\n" +
|
||||
" WHERE\r\n" +
|
||||
" db1.OperateTime >= @FStartTime \r\n" +
|
||||
" AND db1.OperateTime <= @FEndTime \r\n" +
|
||||
" GROUP BY\r\n" +
|
||||
" db2.id,\r\n" +
|
||||
" db2.line \r\n" +
|
||||
" ) AS db3) AS db1\r\n" +
|
||||
" INNER JOIN ( SELECT line, SUM ( meter ) AS sum0, SUM ( boxmeter ) AS sum1 FROM (SELECT\r\n" +
|
||||
" dbo.chen_cal_line_difftime( db3.StartTime, db3.EndTime, db3.line, db3.EndTime) as difftime,\r\n" +
|
||||
" db3.Quantity as Quantity,\r\n" +
|
||||
" db3.StartTime as StartTime,\r\n" +
|
||||
" db3.EndTime as EndTime,\r\n" +
|
||||
" db3.line as line,\r\n" +
|
||||
" db3.Length as Length ,\r\n" +
|
||||
" db3.NumberOfEveryKit as NumberOfEveryKit,\r\n" +
|
||||
" db3.MouldingStyleCode as MouldingStyleCode,\r\n" +
|
||||
" db3.SoCode as SoCode,\r\n" +
|
||||
" dbo.chen_cal_line_time_mould ( db3.StartTime, db3.EndTime, Line ) AS Moulds,\r\n" +
|
||||
" dbo.chen_cal_line_time_density ( db3.StartTime, db3.EndTime, Line ) AS avg_density,\r\n" +
|
||||
" \r\n" +
|
||||
" dbo.chen_cal_line_meter ( db3.StartTime, db3.EndTime, Line, @FEndTime ) / dbo.chen_cal_line_difftime( db3.StartTime, db3.EndTime, db3.line, db3.EndTime) * 60 * 60 * 12 AS currentcap,\r\n" +
|
||||
" NormalCapacity,\r\n" +
|
||||
" db3.sumbox AS sumbox,\r\n" +
|
||||
" dbo.chen_cal_line_meter ( db3.StartTime, db3.EndTime, Line, @FEndTime ) AS meter,\r\n" +
|
||||
" (db3.Length * db3.NumberOfEveryKit * db3.sumbox) AS boxmeter\r\n" +
|
||||
" \r\n" +
|
||||
"FROM\r\n" +
|
||||
" (\r\n" +
|
||||
" SELECT\r\n" +
|
||||
" db2.id,\r\n" +
|
||||
" db2.line,\r\n" +
|
||||
" SUM ( db1.Quantity ) AS sumbox,\r\n" +
|
||||
" MIN ( db1.OperateTime ) AS minop,\r\n" +
|
||||
" MAX ( db1.OperateTime ) AS maxop,\r\n" +
|
||||
" MAX (db2.Quantity) as Quantity, \r\n" +
|
||||
" MAX (db2.Length) as Length,\r\n" +
|
||||
" MAX (db2.NumberOfEveryKit) as NumberOfEveryKit,\r\n" +
|
||||
" MAX (db2.MouldingStyleCode) as MouldingStyleCode,\r\n" +
|
||||
" MAX (db2.SoCode) as SoCode, MAX (db2.NormalCapacity) as NormalCapacity,\r\n" +
|
||||
" ( CASE WHEN MIN ( db2.StartTime ) < @FStartTime THEN @FStartTime ELSE MIN ( db2.StartTime ) END ) AS StartTime,\r\n" +
|
||||
" ( CASE WHEN MIN ( db2.EndTime ) IS NULL THEN (dbo.chen_cal_line_op_lasttime(MIN ( db2.EndTime ),db2.line,@FEndTime)) ELSE ( CASE WHEN MIN ( db2.EndTime ) > @FEndTime THEN @FEndTime ELSE MIN ( db2.EndTime ) END ) END ) AS EndTime FROM\r\n" +
|
||||
" [dbo].[MouldingDisplayBoardOperation] AS db1\r\n" +
|
||||
" INNER JOIN MouldingDisplayBoard AS db2 ON db2.id = db1.DisplayBoardId \r\n" +
|
||||
" WHERE\r\n" +
|
||||
" db1.OperateTime >= @FStartTime \r\n" +
|
||||
" AND db1.OperateTime <= @FEndTime \r\n" +
|
||||
" GROUP BY\r\n" +
|
||||
" db2.id,\r\n" +
|
||||
" db2.line \r\n" +
|
||||
" ) AS db3) AS db3 GROUP BY line ) AS db2 ON db2.line = db1.line\r\n" +
|
||||
" LEFT JOIN (SELECT Line,id,DATEDIFF(MINUTE,StartTime,EndTime) as ChangeMouldTime FROM MouldingDisplayBoard WHERE id IN (SELECT MAX (id) AS id FROM MouldingDisplayBoard WHERE ChangeMould=1 GROUP BY Line)) as db4 on db4.line = db1.line\r\n" +
|
||||
"\r\n" +
|
||||
"GROUP BY" +
|
||||
" db1.line " +
|
||||
"ORDER BY " +
|
||||
"CAST (" +
|
||||
" REPLACE( db1.line, '#', '' ) AS INT)";
|
||||
Statement stmt = conn.createStatement();//
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
|
||||
|
||||
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("line",rs.getString("line"));
|
||||
map.put("Moulds",rs.getString("Moulds"));
|
||||
map.put("sumbox",rs.getString("sumbox"));
|
||||
map.put("sum_box_meter",rs.getString("sum_box_meter"));
|
||||
map.put("sum_device_meter",rs.getString("sum_device_meter"));
|
||||
map.put("avg_density",rs.getString("avg_density"));
|
||||
map.put("avg_currentcapacity",rs.getString("avg_currentcapacity"));
|
||||
map.put("avg_normalcapacity",rs.getString("avg_normalcapacity"));
|
||||
map.put("lastchangemouldtime",rs.getString("lastchangemouldtime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,201 @@
|
||||
package com.ruoyi.db.sd_mssql;
|
||||
|
||||
import java.sql.*;
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
public class DB_Ajax_DashBoard_ChangeMouldTime_8053 {
|
||||
|
||||
private static String IP = "192.168.80.53";
|
||||
private static String DBName = "ERPDATA";
|
||||
private static String USER = "sa";
|
||||
private static String PWD = "#080507h";
|
||||
|
||||
/** 创建数据库对象 */
|
||||
private static Connection getSQLConnection() {
|
||||
Connection con = null;
|
||||
try {
|
||||
Class.forName("net.sourceforge.jtds.jdbc.Driver");
|
||||
// 加上 useunicode=true;characterEncoding=UTF-8 防止中文乱码
|
||||
con = DriverManager.getConnection(
|
||||
"jdbc:jtds:sqlserver://" + IP + ":1433/" + DBName + ";useunicode=true;characterEncoding=UTF-8",
|
||||
USER, PWD);
|
||||
} catch (ClassNotFoundException | SQLException e) {
|
||||
e.printStackTrace();
|
||||
System.out.println("==连接数据库失败===");
|
||||
}
|
||||
// System.out.println("==连接数据库成功===");
|
||||
return con;
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetChangeMouldTimeList() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tLine,\n" +
|
||||
"\tLEFT ( MouldingStyleCode, charindex( '-', MouldingStyleCode ) - 1 ) as Mould,MouldingStyleCode,\n" +
|
||||
"\tStartTime,\n" +
|
||||
"\tEndTime ,\n" +
|
||||
"\tDATEDIFF( minute,starttime, endtime) as ChangeMouldTime\n" +
|
||||
"FROM\n" +
|
||||
"\t[dbo].[MouldingDisplayBoard] \n" +
|
||||
"WHERE\n" +
|
||||
"\tChangeMould = 1 and \tDATEDIFF( minute,starttime, endtime) > 20\n" +
|
||||
"\torder by starttime desc \n";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("Line",rs.getString("Line"));
|
||||
map.put("Mould",rs.getString("Mould"));
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("StartTime",rs.getString("StartTime"));
|
||||
map.put("EndTime",rs.getString("EndTime"));
|
||||
map.put("ChangeMouldTime",rs.getString("ChangeMouldTime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetChangeMouldTimeListDateRange(String fstarttime, String fendtime) {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tLine,\n" +
|
||||
"\tLEFT ( MouldingStyleCode, charindex( '-', MouldingStyleCode ) - 1 ) AS Mould,\n" +
|
||||
"\tMouldingStyleCode,\n" +
|
||||
"\tStartTime,\n" +
|
||||
"\tEndTime,\n" +
|
||||
"\tDATEDIFF( MINUTE, starttime, endtime ) AS ChangeMouldTime \n" +
|
||||
"FROM\n" +
|
||||
"\t[dbo].[MouldingDisplayBoard] \n" +
|
||||
"WHERE\n" +
|
||||
"\tChangeMould = 1 \n" +
|
||||
"\tAND DATEDIFF( MINUTE, starttime, endtime ) > 20 \n" +
|
||||
"\tAND endtime >= '"+fstarttime+"' \n" +
|
||||
"\tAND endtime <= '"+fendtime+"' \n" +
|
||||
"ORDER BY\n" +
|
||||
"\tstarttime DESC";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("Line",rs.getString("Line"));
|
||||
map.put("Mould",rs.getString("Mould"));
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("StartTime",rs.getString("StartTime"));
|
||||
map.put("EndTime",rs.getString("EndTime"));
|
||||
map.put("ChangeMouldTime",rs.getString("ChangeMouldTime"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGet_avg_changemouldtime_date_range(String fstarttime, String fendtime) {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT AVG\n" +
|
||||
"\t(\n" +
|
||||
"\tDATEDIFF( MINUTE, StartTime, EndTime )) AS avgchangemouldtime , count\n" +
|
||||
"\t(\n" +
|
||||
"\tDATEDIFF( MINUTE, StartTime, EndTime )) AS num \n" +
|
||||
"FROM\n" +
|
||||
"\tdbo.MouldingDisplayBoard \n" +
|
||||
"WHERE\n" +
|
||||
"\tChangeMould = 1 \n" +
|
||||
"\tAND DATEDIFF( MINUTE, starttime, endtime ) > 20 \n" +
|
||||
"\tAND Deleted = 0 " +
|
||||
" AND StartTime > '" + fstarttime + "' \r\n" +
|
||||
" AND endtime < '" + fendtime + "'";
|
||||
Statement stmt = conn.createStatement();//
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("avgchangemouldtime",rs.getString("avgchangemouldtime"));
|
||||
map.put("num",rs.getString("num"));
|
||||
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetGroupDensityListMap() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\r\n" +
|
||||
" line AS line,\r\n" +
|
||||
" AVG ( Density ) AS density \r\n" +
|
||||
"FROM\r\n" +
|
||||
" [dbo].[MouldingRealTimeDensity] \r\n" +
|
||||
"WHERE\r\n" +
|
||||
" CreatedOn > dbo.GetWorkShiftStartDate ( GETDATE( ) ) \r\n" +
|
||||
"GROUP BY\r\n" +
|
||||
" line \r\n" +
|
||||
"ORDER BY\r\n" +
|
||||
" convert(int,REPLACE( line, '#', '' ) )";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("density",rs.getString("density"));
|
||||
map.put("time",rs.getString("line"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,284 @@
|
||||
package com.ruoyi.db.sd_mssql;
|
||||
|
||||
import java.sql.*;
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
public class DB_Ajax_DashBoard_Density_8053 {
|
||||
|
||||
private static String IP = "192.168.80.53";
|
||||
private static String DBName = "ERPDATA";
|
||||
private static String USER = "sa";
|
||||
private static String PWD = "#080507h";
|
||||
|
||||
/** 创建数据库对象 */
|
||||
private static Connection getSQLConnection() {
|
||||
Connection con = null;
|
||||
try {
|
||||
Class.forName("net.sourceforge.jtds.jdbc.Driver");
|
||||
// 加上 useunicode=true;characterEncoding=UTF-8 防止中文乱码
|
||||
con = DriverManager.getConnection(
|
||||
"jdbc:jtds:sqlserver://" + IP + ":1433/" + DBName + ";useunicode=true;characterEncoding=UTF-8",
|
||||
USER, PWD);
|
||||
} catch (ClassNotFoundException | SQLException e) {
|
||||
e.printStackTrace();
|
||||
System.out.println("==连接数据库失败===");
|
||||
}
|
||||
// System.out.println("==连接数据库成功===");
|
||||
return con;
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
|
||||
}
|
||||
|
||||
public static List<String> DoGet72hdensity() {
|
||||
List<String> list = new ArrayList<String>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\r\n" +
|
||||
" ProductDate+TIME as time,\r\n" +
|
||||
" AVG ( Density ) as density\r\n" +
|
||||
"FROM\r\n" +
|
||||
" [dbo].[MouldingRealTimeDensity] \r\n" +
|
||||
"WHERE\r\n" +
|
||||
" CreatedOn > GETDATE( ) - 3\r\n" +
|
||||
"GROUP BY\r\n" +
|
||||
" ProductDate,\r\n" +
|
||||
"TIME ORDER BY MAX(CreatedOn)";
|
||||
Statement stmt = conn.createStatement();//
|
||||
// System.out.println(sql);
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
list.add("{time:\"" + rs.getString("time") + "\",density:\"" + rs.getString("density")
|
||||
+ "\"}");
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return list;
|
||||
}
|
||||
public static List<String> DoGetgroupdensity() {
|
||||
List<String> list = new ArrayList<String>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\r\n" +
|
||||
" line AS line,\r\n" +
|
||||
" AVG ( Density ) AS density \r\n" +
|
||||
"FROM\r\n" +
|
||||
" [dbo].[MouldingRealTimeDensity] \r\n" +
|
||||
"WHERE\r\n" +
|
||||
" CreatedOn > dbo.GetWorkShiftStartDate ( GETDATE( ) ) \r\n" +
|
||||
"GROUP BY\r\n" +
|
||||
" line \r\n" +
|
||||
"ORDER BY\r\n" +
|
||||
" convert(int,REPLACE( line, '#', '' ) )";
|
||||
Statement stmt = conn.createStatement();//
|
||||
// System.out.println(sql);
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
list.add("{line:\"" + rs.getString("line") + "\",density:\"" + rs.getString("density")
|
||||
+ "\"}");
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return list;
|
||||
}
|
||||
public static List<String> DoGet30ddensity() {
|
||||
List<String> list = new ArrayList<String>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\r\n" +
|
||||
" ProductDate as time,\r\n" +
|
||||
" AVG ( Density ) as density\r\n" +
|
||||
"FROM\r\n" +
|
||||
" [dbo].[MouldingRealTimeDensity] \r\n" +
|
||||
"WHERE\r\n" +
|
||||
" CreatedOn > GETDATE( ) - 30\r\n" +
|
||||
"GROUP BY\r\n" +
|
||||
" ProductDate ORDER BY MAX(CreatedOn)";
|
||||
Statement stmt = conn.createStatement();//
|
||||
// System.out.println(sql);
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
list.add("{time:\"" + rs.getString("time") + "\",density:\"" + rs.getString("density")
|
||||
+ "\"}");
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return list;
|
||||
}
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGet30dDensityListMap() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\r\n" +
|
||||
" ProductDate as time,\r\n" +
|
||||
" AVG ( Density ) as density\r\n" +
|
||||
"FROM\r\n" +
|
||||
" [dbo].[MouldingRealTimeDensity] \r\n" +
|
||||
"WHERE\r\n" +
|
||||
" CreatedOn > GETDATE( ) - 30\r\n" +
|
||||
"GROUP BY\r\n" +
|
||||
" ProductDate ORDER BY MAX(CreatedOn)";
|
||||
Statement stmt = conn.createStatement();//
|
||||
// System.out.println(sql);
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("density",rs.getString("density"));
|
||||
map.put("time",rs.getString("time"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGet72hDensityListMap() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\r\n" +
|
||||
" ProductDate+TIME as time,\r\n" +
|
||||
" AVG ( Density ) as density\r\n" +
|
||||
"FROM\r\n" +
|
||||
" [dbo].[MouldingRealTimeDensity] \r\n" +
|
||||
"WHERE\r\n" +
|
||||
" CreatedOn > GETDATE( ) - 3\r\n" +
|
||||
"GROUP BY\r\n" +
|
||||
" ProductDate,\r\n" +
|
||||
"TIME ORDER BY MAX(CreatedOn)";
|
||||
Statement stmt = conn.createStatement();//
|
||||
// System.out.println(sql);
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("density",rs.getString("density"));
|
||||
map.put("time",rs.getString("time"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetGroupDensityListMap() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\r\n" +
|
||||
" line AS line,\r\n" +
|
||||
" AVG ( Density ) AS density \r\n" +
|
||||
"FROM\r\n" +
|
||||
" [dbo].[MouldingRealTimeDensity] \r\n" +
|
||||
"WHERE\r\n" +
|
||||
" CreatedOn > dbo.GetWorkShiftStartDate ( GETDATE( ) ) \r\n" +
|
||||
"GROUP BY\r\n" +
|
||||
" line \r\n" +
|
||||
"ORDER BY\r\n" +
|
||||
" convert(int,REPLACE( line, '#', '' ) )";
|
||||
Statement stmt = conn.createStatement();//
|
||||
// System.out.println(sql);
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("density",rs.getString("density"));
|
||||
map.put("time",rs.getString("line"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
public static List<HashMap<String,String>> getDensityDataRange(String fDateStart, String fDateEnd) {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tProductDate AS TIME,\n" +
|
||||
"\tAVG ( Density ) AS density \n" +
|
||||
"FROM\n" +
|
||||
"\t[dbo].[MouldingRealTimeDensity] \n" +
|
||||
"WHERE\n" +
|
||||
"\tCreatedOn >= '"+fDateStart+"' and CreatedOn <= '"+fDateEnd+"'" +
|
||||
"GROUP BY\n" +
|
||||
"\tProductDate \n" +
|
||||
"ORDER BY\n" +
|
||||
"\tMAX ( CreatedOn );";
|
||||
Statement stmt = conn.createStatement();//
|
||||
// System.out.println(sql);
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("density",rs.getString("density"));
|
||||
map.put("time",rs.getString("time"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,556 @@
|
||||
package com.ruoyi.db.sd_mssql;
|
||||
|
||||
import java.sql.*;
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
public class DB_Ajax_DashBoard_Technologist_8053 {
|
||||
|
||||
private static String IP = "192.168.80.53";
|
||||
private static String DBName = "ERPDATA";
|
||||
private static String USER = "sa";
|
||||
private static String PWD = "#080507h";
|
||||
|
||||
/** 创建数据库对象 */
|
||||
private static Connection getSQLConnection() {
|
||||
Connection con = null;
|
||||
try {
|
||||
Class.forName("net.sourceforge.jtds.jdbc.Driver");
|
||||
// 加上 useunicode=true;characterEncoding=UTF-8 防止中文乱码
|
||||
con = DriverManager.getConnection(
|
||||
"jdbc:jtds:sqlserver://" + IP + ":1433/" + DBName + ";useunicode=true;characterEncoding=UTF-8",
|
||||
USER, PWD);
|
||||
} catch (ClassNotFoundException | SQLException e) {
|
||||
e.printStackTrace();
|
||||
System.out.println("==连接数据库失败===");
|
||||
}
|
||||
// System.out.println("==连接数据库成功===");
|
||||
return con;
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetSampleConfirmation() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\t内外销,\n" +
|
||||
"\tSUM ( CASE WHEN 客户是否下单 = '是' THEN 1 ELSE 0 END ) AS 下单数,\n" +
|
||||
"\tCOUNT (内外销) AS 打样数 \n" +
|
||||
"FROM\n" +
|
||||
"\t[dbo].[chen_打样分析汇总] \n" +
|
||||
"GROUP BY\n" +
|
||||
"\t内外销;";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("NWX",rs.getString("内外销"));
|
||||
map.put("ConfirmationNum",rs.getString("下单数"));
|
||||
map.put("SampleNum",rs.getString("打样数"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
public static List<HashMap<String,String>> DoGetBestOEM() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT TOP\n" +
|
||||
"\t20 MouldingStyleCode,\n" +
|
||||
"\t[折算人民币价税合计] AS CNY \n" +
|
||||
"FROM\n" +
|
||||
"\t[chen_12个月_A版本BOM销售额] \n" +
|
||||
"WHERE\n" +
|
||||
"\ttagname = 'OEM' \n" +
|
||||
"ORDER BY\n" +
|
||||
"\t折算人民币价税合计 DESC";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("CNY",rs.getString("CNY"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
public static List<HashMap<String,String>> DoGetBestODM() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT TOP\n" +
|
||||
"\t20 MouldingStyleCode,\n" +
|
||||
"\t[折算人民币价税合计] AS CNY \n" +
|
||||
"FROM\n" +
|
||||
"\t[chen_12个月_A版本BOM销售额] \n" +
|
||||
"WHERE\n" +
|
||||
"\ttagname = 'ODM' \n" +
|
||||
"ORDER BY\n" +
|
||||
"\t折算人民币价税合计 DESC";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("CNY",rs.getString("CNY"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 已完成订单交期
|
||||
* 根据工艺员共计数量
|
||||
*/
|
||||
public static List<HashMap<String,String>> DoFinishedSampleAvgDay() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tTechnologist,\n" +
|
||||
"\tCOUNT(id) as num,\n" +
|
||||
"\tAVG (\n" +
|
||||
"\tCAST ( [分解天数] AS FLOAT )) AS avg_f,\n" +
|
||||
"\tAVG ( CAST ( [交期天数] AS FLOAT ) ) AS avg_j \n" +
|
||||
"FROM\n" +
|
||||
"\t[dbo].[chen_打样分析汇总] \n" +
|
||||
"WHERE\n" +
|
||||
"\tStatus = 3 \n" +
|
||||
"GROUP BY\n" +
|
||||
"\tTechnologist";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("Technologist",rs.getString("Technologist"));
|
||||
map.put("avg_f",rs.getString("avg_f"));
|
||||
map.put("num",rs.getString("num"));
|
||||
map.put("avg_j",rs.getString("avg_j"));
|
||||
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 未完成打样交期
|
||||
* 根据工艺员共计数量
|
||||
*/
|
||||
public static List<HashMap<String,String>> DoUnFinishedSampleAvgDay() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tTechnologist,\n" +
|
||||
"\tCOUNT ( id ) AS num,\n" +
|
||||
"\tSUM ( CASE WHEN use_date >= 15 THEN 1 ELSE 0 END ) as day15num,\n" +
|
||||
"\tAVG(use_date) as avg_use_date\n" +
|
||||
"\tFROM\n" +
|
||||
"\t\t( SELECT Technologist, id, DATEDIFF( DAY, [经理审核时间], GETDATE()) AS use_date FROM [dbo].[chen_打样分析汇总] WHERE ( Status = 2 OR Status = 1 ) AND [经理审核时间] IS NOT NULL ) AS db0 \n" +
|
||||
"GROUP BY\n" +
|
||||
"\tTechnologist";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("Technologist",rs.getString("Technologist"));
|
||||
map.put("day15num",rs.getString("day15num"));
|
||||
map.put("num",rs.getString("num"));
|
||||
map.put("avg_use_date",rs.getString("avg_use_date"));
|
||||
|
||||
|
||||
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 新增订单
|
||||
*
|
||||
*/
|
||||
public static List<HashMap<String,String>> DayFinishedSampleOrder() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"dbo.[chen_打样分析汇总].Technologist,\n" +
|
||||
"dbo.[chen_打样分析汇总].SalesMan,\n" +
|
||||
"dbo.[chen_打样分析汇总].MouldingStyleCode,\n" +
|
||||
"dbo.[chen_打样分析汇总].[折算人民币价税合计] as CNY\n" +
|
||||
"\n" +
|
||||
"FROM\n" +
|
||||
"dbo.[chen_打样分析汇总]\n" +
|
||||
"WHERE\n" +
|
||||
"dbo.[chen_打样分析汇总].CreatedOn >= dbo.GetWorkShiftStartDate ( GETDATE( ) - 1 ) AND\n" +
|
||||
"dbo.[chen_打样分析汇总].CreatedOn <= dbo.GetWorkShiftStartDate ( GETDATE( ) )\n";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("Technologist",rs.getString("Technologist"));
|
||||
map.put("SalesMan",rs.getString("SalesMan"));
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("CNY",rs.getString("CNY"));
|
||||
|
||||
|
||||
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 新开模
|
||||
*
|
||||
*/
|
||||
public static List<HashMap<String,String>> DayNewMould() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"dbo.MouldManufacture.MouldCode,\n" +
|
||||
"CASE dbo.MouldManufacture.ManufactureType\n" +
|
||||
"\tWHEN 1 THEN N'新开模'\n" +
|
||||
"\tELSE N'修模'\n" +
|
||||
"END as new_or_fix\n" +
|
||||
",\n" +
|
||||
"BD_User.UserName\n" +
|
||||
"FROM\n" +
|
||||
"dbo.MouldManufacture\n" +
|
||||
"INNER JOIN BD_User on dbo.MouldManufacture.CreatedBy = BD_User.UserId\n" +
|
||||
"WHERE\n" +
|
||||
"dbo.MouldManufacture.CreatedOn >= dbo.GetWorkShiftStartDate ( GETDATE( ) - 1 ) AND\n" +
|
||||
"dbo.MouldManufacture.CreatedOn <= dbo.GetWorkShiftStartDate ( GETDATE( ) ) AND\n" +
|
||||
"dbo.MouldManufacture.Status <> -1\n";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("UserName",rs.getString("UserName"));
|
||||
map.put("new_or_fix",rs.getString("new_or_fix"));
|
||||
map.put("MouldCode",rs.getString("MouldCode"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 打样完成
|
||||
*
|
||||
*/
|
||||
public static List<HashMap<String,String>> DayFinishedSample() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"\tdbo.[chen_打样分析汇总].MouldingStyleCode,\n" +
|
||||
"\tdbo.[chen_打样分析汇总].Technologist,\n" +
|
||||
"\tdbo.[chen_打样分析汇总].FinishedDensity,\n" +
|
||||
"\tdbo.[chen_打样分析汇总].FinishedSpeed,\n" +
|
||||
"\tdbo.[chen_打样分析汇总].FinishedBy,\n" +
|
||||
"\tdbo.[chen_打样分析汇总].[交期天数] as UseDay\n" +
|
||||
"FROM\n" +
|
||||
"\tdbo.[chen_打样分析汇总] \n" +
|
||||
"WHERE\n" +
|
||||
"\tdbo.[chen_打样分析汇总].FinishedOn >= dbo.GetWorkShiftStartDate ( GETDATE( ) - 1 ) \n" +
|
||||
"\tAND dbo.[chen_打样分析汇总].FinishedOn <= dbo.GetWorkShiftStartDate ( GETDATE( ) )";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("Technologist",rs.getString("Technologist"));
|
||||
map.put("FinishedDensity",rs.getString("FinishedDensity"));
|
||||
map.put("FinishedSpeed",rs.getString("FinishedSpeed"));
|
||||
map.put("FinishedBy",rs.getString("FinishedBy"));
|
||||
map.put("UseDay",rs.getString("UseDay"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
/**
|
||||
* BOM完成
|
||||
*
|
||||
*/
|
||||
public static List<HashMap<String,String>> DayFinishedBOM() {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT\n" +
|
||||
"dbo.MouldingTechnicalForm.MouldingStyleCode,\n" +
|
||||
"dbo.MouldingTechnicalForm.Maker\n" +
|
||||
"\n" +
|
||||
"FROM\n" +
|
||||
"dbo.MouldingTechnicalForm\n" +
|
||||
"WHERE\n" +
|
||||
"dbo.MouldingTechnicalForm.ModifiedOn >= dbo.GetWorkShiftStartDate ( GETDATE( ) - 1 ) AND\n" +
|
||||
"dbo.MouldingTechnicalForm.ModifiedOn <= dbo.GetWorkShiftStartDate ( GETDATE( ) )";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("Maker",rs.getString("Maker"));
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
public static String All() {
|
||||
StringBuilder jsonpath = new StringBuilder();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT * from [chen_打样分析汇总] order by CreatedOn desc FOR JSON PATH";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
jsonpath.append(rs.getString(1));
|
||||
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return jsonpath.toString();
|
||||
}
|
||||
|
||||
|
||||
public static String AllDataDataRange(String fDateStart,String fDateEnd) {
|
||||
StringBuilder jsonpath = new StringBuilder();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT * from [chen_打样分析汇总] where CreatedOn >= '"+fDateStart+"' and CreatedOn <= '"+fDateEnd+"' order by CreatedOn desc FOR JSON PATH";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
jsonpath.append(rs.getString(1));
|
||||
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return jsonpath.toString();
|
||||
}
|
||||
|
||||
|
||||
|
||||
//除了 画框 婚纱框 相框 镜框
|
||||
|
||||
public static List<HashMap<String,String>> getBestByProductionLine(String ProductionLine) {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT DISTINCT TOP\n" +
|
||||
"\t20 chen_12个月_A版本BOM销售额.MouldingStyleCode,\n" +
|
||||
"\tchen_12个月_A版本BOM销售额.[折算人民币价税合计] AS CNY,\n" +
|
||||
"\tchen_打样分析汇总.[客户数量] as CustomerNum,\n" +
|
||||
"\tMouldingSampleMakingMasterSchedule.ProductionLine ,\n" +
|
||||
"\t( SELECT TOP 1 SHCountry FROM MouldingDataStatistics WHERE MouldingCode = reverse( SUBSTRING ( reverse( chen_12个月_A版本BOM销售额.MouldingStyleCode ), charindex( '-', reverse( chen_12个月_A版本BOM销售额.MouldingStyleCode ) ) + 1, 500 ) ) and SHCountry is not null GROUP BY SHCountry ORDER BY SUM ( SHMouldingSaleLength ) DESC ) AS Area \n" +
|
||||
"FROM\n" +
|
||||
"\t[chen_12个月_A版本BOM销售额]\n" +
|
||||
"\tLEFT JOIN MouldingSampleMakingMasterSchedule ON MouldingSampleMakingMasterSchedule.MouldingStyleCode = chen_12个月_A版本BOM销售额.MouldingStyleCode\n" +
|
||||
"\tINNER JOIN [chen_打样分析汇总] ON chen_打样分析汇总.MouldingStyleCode = chen_12个月_A版本BOM销售额.MouldingStyleCode \n" +
|
||||
"WHERE\n" +
|
||||
"\tMouldingSampleMakingMasterSchedule.ProductionLine = '"+ProductionLine+"' \n" +
|
||||
"ORDER BY\n" +
|
||||
"\tchen_12个月_A版本BOM销售额.折算人民币价税合计 DESC";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("CNY",rs.getString("CNY"));
|
||||
map.put("Area",rs.getString("Area"));
|
||||
map.put("CustomerNum",rs.getString("CustomerNum"));
|
||||
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
//除了 画框 婚纱框 相框 镜框
|
||||
|
||||
public static List<HashMap<String,String>> getBestByProductionLine_Jiancai( ) {
|
||||
List<HashMap<String,String>> hashMapList = new ArrayList<>();
|
||||
try {
|
||||
Connection conn = getSQLConnection();
|
||||
String sql = "SELECT DISTINCT TOP\n" +
|
||||
"\t20 chen_12个月_A版本BOM销售额.MouldingStyleCode,\n" +
|
||||
"\tchen_12个月_A版本BOM销售额.[折算人民币价税合计] AS CNY,\tchen_打样分析汇总.[客户数量] as CustomerNum,\n" +
|
||||
"\tMouldingSampleMakingMasterSchedule.ProductionLine ,\n" +
|
||||
"\n" +
|
||||
"\t(SELECT TOP\n" +
|
||||
"\t1 SHCountry \n" +
|
||||
"FROM\n" +
|
||||
"\tMouldingDataStatistics \n" +
|
||||
"WHERE MouldingCode = reverse(substring(reverse(chen_12个月_A版本BOM销售额.MouldingStyleCode),charindex('-',reverse(chen_12个月_A版本BOM销售额.MouldingStyleCode)) +1,500)) and SHCountry is not null\n" +
|
||||
"GROUP BY SHCountry\n" +
|
||||
"ORDER BY sum(SHMouldingSaleLength) desc ) as Area\n" +
|
||||
"FROM\n" +
|
||||
"\t[chen_12个月_A版本BOM销售额]\n" +
|
||||
"\tLEFT JOIN MouldingSampleMakingMasterSchedule ON MouldingSampleMakingMasterSchedule.MouldingStyleCode = chen_12个月_A版本BOM销售额.MouldingStyleCode \n" +
|
||||
"\tINNER JOIN [chen_打样分析汇总] on chen_打样分析汇总.MouldingStyleCode = chen_12个月_A版本BOM销售额.MouldingStyleCode\n" +
|
||||
"\n" +
|
||||
"WHERE\n" +
|
||||
"\tSUBSTRING(chen_12个月_A版本BOM销售额.MouldingStyleCode,1,1) = 'J'\n" +
|
||||
"\n" +
|
||||
"ORDER BY\n" +
|
||||
"\tchen_12个月_A版本BOM销售额.折算人民币价税合计 DESC";
|
||||
Statement stmt = conn.createStatement();//
|
||||
|
||||
ResultSet rs = stmt.executeQuery(sql);
|
||||
while (rs.next()) {
|
||||
// 截面积(mm2)
|
||||
HashMap<String,String> map = new HashMap<>();
|
||||
map.put("MouldingStyleCode",rs.getString("MouldingStyleCode"));
|
||||
map.put("CNY",rs.getString("CNY"));
|
||||
map.put("Area",rs.getString("Area"));
|
||||
map.put("CustomerNum",rs.getString("CustomerNum"));
|
||||
|
||||
hashMapList.add(map);
|
||||
|
||||
}
|
||||
rs.close();
|
||||
stmt.close();
|
||||
conn.close();
|
||||
} catch (SQLException e) {
|
||||
e.printStackTrace();
|
||||
|
||||
}
|
||||
return hashMapList;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
@ -0,0 +1,24 @@
|
||||
Application Version: ${ruoyi.version}
|
||||
Spring Boot Version: ${spring-boot.version}
|
||||
////////////////////////////////////////////////////////////////////
|
||||
// _ooOoo_ //
|
||||
// o8888888o //
|
||||
// 88" . "88 //
|
||||
// (| ^_^ |) //
|
||||
// O\ = /O //
|
||||
// ____/`---'\____ //
|
||||
// .' \\| |// `. //
|
||||
// / \\||| : |||// \ //
|
||||
// / _||||| -:- |||||- \ //
|
||||
// | | \\\ - /// | | //
|
||||
// | \_| ''\---/'' | | //
|
||||
// \ .-\__ `-` ___/-. / //
|
||||
// ___`. .' /--.--\ `. . ___ //
|
||||
// ."" '< `.___\_<|>_/___.' >'"". //
|
||||
// | | : `- \`.;`\ _ /`;.`/ - ` : | | //
|
||||
// \ \ `-. \_ __\ /__ _/ .-` / / //
|
||||
// ========`-.____`-.___\_____/___.-`____.-'======== //
|
||||
// `=---=' //
|
||||
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ //
|
||||
// 佛祖保佑 永不宕机 永无BUG //
|
||||
////////////////////////////////////////////////////////////////////
|
||||
@ -0,0 +1,43 @@
|
||||
package com.ruoyi.project.sd_changemouldtime.controller;
|
||||
|
||||
import com.ruoyi.db.sd_mssql.DB_Ajax_DashBoard_ChangeMouldTime_8053;
|
||||
import com.ruoyi.framework.web.controller.BaseController;
|
||||
import com.ruoyi.framework.web.domain.AjaxResult;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.PathVariable;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
/**
|
||||
* 服务器监控
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
@RestController
|
||||
@RequestMapping("/sd_changemouldtime")
|
||||
public class SDChangeMouldTimeController extends BaseController
|
||||
{
|
||||
// @PreAuthorize("@ss.hasPermi('monitor:server:list')")
|
||||
@GetMapping("/list")
|
||||
public AjaxResult DoGetChangeMouldTimeList() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_ChangeMouldTime_8053.DoGetChangeMouldTimeList());
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/DoGetChangeMouldTimeListDateRange/{fDateStart}/{fDateEnd}")
|
||||
public AjaxResult DoGetChangeMouldTimeListDateRange(@PathVariable String fDateStart, @PathVariable String fDateEnd) throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_ChangeMouldTime_8053.DoGetChangeMouldTimeListDateRange(fDateStart,fDateEnd));
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/rangetimeavg/{fDateStart}/{fDateEnd}")
|
||||
public AjaxResult getRangeTimeAvg(@PathVariable String fDateStart, @PathVariable String fDateEnd) throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_ChangeMouldTime_8053.DoGet_avg_changemouldtime_date_range(fDateStart,fDateEnd));
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,24 @@
|
||||
Application Version: ${ruoyi.version}
|
||||
Spring Boot Version: ${spring-boot.version}
|
||||
////////////////////////////////////////////////////////////////////
|
||||
// _ooOoo_ //
|
||||
// o8888888o //
|
||||
// 88" . "88 //
|
||||
// (| ^_^ |) //
|
||||
// O\ = /O //
|
||||
// ____/`---'\____ //
|
||||
// .' \\| |// `. //
|
||||
// / \\||| : |||// \ //
|
||||
// / _||||| -:- |||||- \ //
|
||||
// | | \\\ - /// | | //
|
||||
// | \_| ''\---/'' | | //
|
||||
// \ .-\__ `-` ___/-. / //
|
||||
// ___`. .' /--.--\ `. . ___ //
|
||||
// ."" '< `.___\_<|>_/___.' >'"". //
|
||||
// | | : `- \`.;`\ _ /`;.`/ - ` : | | //
|
||||
// \ \ `-. \_ __\ /__ _/ .-` / / //
|
||||
// ========`-.____`-.___\_____/___.-`____.-'======== //
|
||||
// `=---=' //
|
||||
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ //
|
||||
// 佛祖保佑 永不宕机 永无BUG //
|
||||
////////////////////////////////////////////////////////////////////
|
||||
@ -0,0 +1,54 @@
|
||||
package com.ruoyi.project.sd_dashboard.controller;
|
||||
|
||||
import com.ruoyi.db.mssql.DB_Ajax_DashBoard_48102;
|
||||
import com.ruoyi.db.sd_mssql.DB_Ajax_DashBoard_8053;
|
||||
import com.ruoyi.framework.web.controller.BaseController;
|
||||
import com.ruoyi.framework.web.domain.AjaxResult;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.PathVariable;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
/**
|
||||
* 服务器监控
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
@RestController
|
||||
@RequestMapping("/sd_dashboard")
|
||||
public class SDDashBoardController extends BaseController
|
||||
{
|
||||
// @PreAuthorize("@ss.hasPermi('monitor:server:list')")
|
||||
@GetMapping("/30day")
|
||||
public AjaxResult get30Day() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_8053.DoGet30Day());
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/lastday")
|
||||
public AjaxResult getLastDay() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_8053.DoGetLastDay());
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/group")
|
||||
public AjaxResult getGroup() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_8053.DoGetCurrentTimeGroup());
|
||||
}
|
||||
|
||||
@GetMapping("/current")
|
||||
public AjaxResult DoGetCurrent() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_48102.SD_DoGetCurrent());
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/daterange/{fDateStart}/{fDateEnd}")
|
||||
public AjaxResult getDateRange(@PathVariable String fDateStart, @PathVariable String fDateEnd) throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_8053.DoGetDateRange(fDateStart,fDateEnd));
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,49 @@
|
||||
package com.ruoyi.project.sd_density;
|
||||
|
||||
import com.ruoyi.db.mssql.DB_Ajax_DashBoard_Density_48102;
|
||||
import com.ruoyi.db.sd_mssql.DB_Ajax_DashBoard_Density_8053;
|
||||
import com.ruoyi.framework.web.controller.BaseController;
|
||||
import com.ruoyi.framework.web.domain.AjaxResult;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.PathVariable;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
/**
|
||||
* 服务器监控
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
@RestController
|
||||
@RequestMapping("/sd_density")
|
||||
public class SDDensityController extends BaseController
|
||||
{
|
||||
// @PreAuthorize("@ss.hasPermi('monitor:server:list')")
|
||||
@GetMapping("/30day")
|
||||
public AjaxResult get30Day() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_Density_8053.DoGet30dDensityListMap());
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/72h")
|
||||
public AjaxResult get72h() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_Density_8053.DoGet72hDensityListMap());
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/group")
|
||||
public AjaxResult getGroup() throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_Density_8053.DoGetGroupDensityListMap());
|
||||
}
|
||||
|
||||
|
||||
@GetMapping("/getDensityDataRange/{fDateStart}/{fDateEnd}")
|
||||
public AjaxResult getDateRange(@PathVariable String fDateStart, @PathVariable String fDateEnd) throws Exception
|
||||
{
|
||||
return AjaxResult.success(DB_Ajax_DashBoard_Density_8053.getDensityDataRange(fDateStart,fDateEnd));
|
||||
}
|
||||
|
||||
}
|
||||
@ -82,7 +82,7 @@ token:
|
||||
# 令牌密钥
|
||||
secret: abcdefghijklmnopqrstuvwxyz
|
||||
# 令牌有效期（默认30分钟）
|
||||
expireTime: 30
|
||||
expireTime: 99999
|
||||
|
||||
# MyBatis配置
|
||||
mybatis:
|
||||
|
||||
Reference in New Issue
Block a user