From 39f62fa03a2463652e971edfabab56313db6af10 Mon Sep 17 00:00:00 2001
From: Lius <Lius2225@163.com>
Date: 星期六, 28 六月 2025 10:20:34 +0800
Subject: [PATCH] 涉密->工控
---
lxzn-module-msi/src/main/java/org/jeecg/modules/msi/webapi/service/impl/MsiWebapiJsonServiceImpl.java | 159 +++++++++++++++++++++++++++++++++++++++++------------
1 files changed, 123 insertions(+), 36 deletions(-)
diff --git a/lxzn-module-msi/src/main/java/org/jeecg/modules/msi/webapi/service/impl/MsiWebapiJsonServiceImpl.java b/lxzn-module-msi/src/main/java/org/jeecg/modules/msi/webapi/service/impl/MsiWebapiJsonServiceImpl.java
index 5c649d2..d0f9f2c 100644
--- a/lxzn-module-msi/src/main/java/org/jeecg/modules/msi/webapi/service/impl/MsiWebapiJsonServiceImpl.java
+++ b/lxzn-module-msi/src/main/java/org/jeecg/modules/msi/webapi/service/impl/MsiWebapiJsonServiceImpl.java
@@ -3,8 +3,10 @@
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import liquibase.util.JdbcUtils;
+import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.jeecg.common.util.DateUtils;
+import org.jeecg.common.util.RedisUtil;
import org.jeecg.modules.msi.webapi.entity.MsiWebapiJsonEntity;
import org.jeecg.modules.msi.webapi.mapper.MsiWebapiJsonMapper;
import org.jeecg.modules.msi.webapi.service.IMsiWebapiJsonService;
@@ -15,48 +17,93 @@
import org.springframework.jdbc.datasource.DataSourceUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
+import org.jetbrains.annotations.NotNull;
+import javax.annotation.Resource;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
@Service
+@Slf4j
public class MsiWebapiJsonServiceImpl extends ServiceImpl<MsiWebapiJsonMapper, MsiWebapiJsonEntity> implements IMsiWebapiJsonService {
@Autowired
private JdbcTemplate jdbcTemplate;
+ @Resource
+ private RedisUtil redisUtil;
+
+ private final static String ZDHKEY = "ZDHKEY_";
+
/**
* 瑙ｆ瀽鍗曟潯鏁版嵁淇濆瓨鍒板崟琛�
+ *
* @param data
* @return
*/
@Override
public boolean saveTableAutomationOne(List<MachineEquipentInfo> data) {
- if (data ==null || data.isEmpty()) {
+ if (data == null || data.isEmpty()) {
return false;
}
List<String> listStatus = new ArrayList<>();
List<String> listParameter = new ArrayList<>();
+
for (MachineEquipentInfo machineInfo : data) {
- System.out.println(machineInfo);
+// log.info("鎺ユ敹鑷姩鍖栨暟鎹細" + machineInfo);
+
+ // 鑾峰彇褰撳墠璁板綍鐨剅unningStatus鍊�
+ String currentRunningStatus = null;
+ for (DetailedListVo item : machineInfo.getItemList()) {
+ if ("runningStatus".equals(item.getItemName())) {
+ currentRunningStatus = item.getItemValue();
+ break;
+ }
+ }
+
+ // 鑾峰彇鍓嶄竴鏉＄姸鎬�
+ if (redisUtil.hasKey(ZDHKEY + machineInfo.getMachineNo())) {
+ String prevRunningStatus = (String) redisUtil.get(ZDHKEY + machineInfo.getMachineNo());
+
+ // 濡傛灉褰撳墠鐘舵�佷笌鍓嶄竴鏉＄浉鍚岋紝鍒欏彧鍐欏叆鍗曡〃鏁版嵁
+ if (currentRunningStatus != null && currentRunningStatus.equals(prevRunningStatus)) {
+ String parameter = listSqlParameter(machineInfo);
+ if (parameter != null && !parameter.equals("")) {
+ listParameter.add(parameter);
+ }
+ continue;
+ }
+
+ // 鏇存柊鍓嶄竴鏉¤褰曠殑鐘舵�佸��
+ redisUtil.set(ZDHKEY + machineInfo.getMachineNo(), currentRunningStatus);
+ } else {
+ if (currentRunningStatus != null) {
+ redisUtil.set(ZDHKEY + machineInfo.getMachineNo(), currentRunningStatus);
+ }
+ }
+
+ // 鐢熸垚SQL
String stutus = listSqls(machineInfo);
if (stutus != null && !stutus.equals("")) {
listStatus.add(stutus);
}
+
String parameter = listSqlParameter(machineInfo);
if (parameter != null && !parameter.equals("")) {
listParameter.add(parameter);
}
+
}
// 鎵ц鐘舵�佹暟鎹甋QL
try {
executeBatchSql(listStatus);
- executeBatchSql(listParameter);
+ if (!listParameter.isEmpty()) {
+ executeBatchSql(listParameter);
+ }
return true;
} catch (Exception e) {
log.error("鎵цSQL鎵归噺鎻掑叆澶辫触", e);
@@ -67,6 +114,7 @@
/**
* 鎵归噺鎵цSQL璇彞
+ *
* @param sqlList SQL璇彞鍒楄〃
* @throws SQLException
*/
@@ -102,22 +150,23 @@
/**
- * 鎻掑叆鍒癊quipmentLog
+ * 鎻掑叆鍒拌澶囧崟琛�
+ *
* @param machineInfo
* @return
*/
public String listSqlParameter(MachineEquipentInfo machineInfo) {
String listSqls = null;
List<DetailedListVo> itemList = machineInfo.getItemList();
- Map<String ,DetailedListVo> itemMap = new HashMap<String ,DetailedListVo>();
- for (DetailedListVo item: itemList) {
- itemMap.put(item.getItemName(),item);
+ Map<String, DetailedListVo> itemMap = new HashMap<String, DetailedListVo>();
+ for (DetailedListVo item : itemList) {
+ itemMap.put(item.getItemName(), item);
}
String sql = "insert into ";
sql = sql + "ZDH_" + machineInfo.getMachineNo() + " ";
sql = sql + "(EquipmentID,EquipmentName,CollectTime,runningStatus,spindleSpeed,feedRatio,runDuration,spindleDuration,progName,progStatus,toolNo) values ( ";
//EquipmentID
- if (machineInfo.getMachineNo() == null || machineInfo.getMachineNo().equals("")) {
+ if (machineInfo.getMachineNo() == null || machineInfo.getMachineNo().equals("")) {
return null;
} else {
sql = sql + "'" + machineInfo.getMachineNo() + "', ";
@@ -125,10 +174,12 @@
//EquipmentName
sql = sql + null + ", ";
//CollectTime
- if (machineInfo.getEndTime() != null) {
- sql = sql + "'" + DateUtils.formattedDate(machineInfo.getEndTime(),DateUtils.STR_DD_MM_YYYY,DateUtils.STR_DATE_TIME_SMALL) + "', ";
+ // 鍋囪 endTime 鏄� "MM/dd/yyyy HH:mm:ss" 鏍煎紡鐨勫瓧绗︿覆
+ if (machineInfo.getEndTime() != null && !machineInfo.getEndTime().isEmpty()) {
+ sql = getTime(machineInfo, sql);
} else {
- sql = sql + "'" + DateUtils.format(DateUtils.getDate(),DateUtils.STR_DATE_TIME) + "', ";
+ // 濡傛灉 endTime 涓� null 鎴栫┖锛屼娇鐢ㄥ綋鍓嶆椂闂�
+ sql = sql + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "', ";
}
//runningStatus
if (itemMap.containsKey("runningStatus")) {
@@ -145,7 +196,7 @@
//feedRatio
if (itemMap.containsKey("feedRatio")) {
sql = sql + "'" + itemMap.get("feedRatio").getItemValue() + "', ";
- }else {
+ } else {
sql = sql + "NULL, ";
}
//runDuration
@@ -180,7 +231,7 @@
}
sql = sql + "); \n";
- if (StringUtils.isBlank(listSqls) ) {
+ if (StringUtils.isBlank(listSqls)) {
listSqls = sql;
} else {
listSqls += sql;
@@ -190,7 +241,8 @@
/**
- * 鎻掑叆鍒癊quipmentLog
+ * 鎻掑叆鍒癊quipmentLog
+ *
* @param machineInfo
* @return
*/
@@ -205,37 +257,72 @@
}
sql = sql + null + ", ";
if (machineInfo.getEndTime() != null) {
-
- sql = sql + "'" + DateUtils.formattedDate(machineInfo.getEndTime(),DateUtils.STR_DD_MM_YYYY,DateUtils.STR_DATE_TIME_SMALL) + "', ";
+ sql = getTime(machineInfo, sql);
} else {
return null;
}
- Map<String ,DetailedListVo> itemMap = new HashMap<String ,DetailedListVo>();
- for (DetailedListVo item: itemList) {
- itemMap.put(item.getItemName(),item);
+ Map<String, DetailedListVo> itemMap = new HashMap<String, DetailedListVo>();
+ for (DetailedListVo item : itemList) {
+ itemMap.put(item.getItemName(), item);
}
if (itemMap.containsKey("runningStatus")) {
int oporation = 0;
switch (itemMap.get("runningStatus").getItemValue()) {
- case "0" : oporation =0;break;
- case "1" : oporation =2;break;
- case "2" : oporation =3;break;
- case "3" : oporation =2;break;
- case "4" : oporation =2;break;
- case "10" : oporation =2;break;
- case "13" : oporation =2;break;
- case "14" : oporation =2;break;
- case "10001" : oporation =2;break;
- default: break;
+ case "0":
+ oporation = 0;
+ break;
+ case "1":
+ oporation = 2;
+ break;
+ case "2":
+ oporation = 3;
+ break;
+ case "3":
+ oporation = 2;
+ break;
+ case "4":
+ oporation = 2;
+ break;
+ case "10":
+ oporation = 2;
+ break;
+ case "13":
+ oporation = 2;
+ break;
+ case "14":
+ oporation = 2;
+ break;
+ case "10001":
+ oporation = 2;
+ break;
+ default:
+ break;
}
- sql = sql + " " + oporation + ", ";
+ sql = sql + " " + oporation + ", ";
} else {
return null;
}
- sql = sql + null + " ); \n";
- if (StringUtils.isBlank(listSqls) ) {
+ sql = sql + null + " ); \n";
+ if (StringUtils.isBlank(listSqls)) {
listSqls = sql;
}
return listSqls;
}
+
+ @NotNull
+ private String getTime(MachineEquipentInfo machineInfo, String sql) {
+ try {
+ // 1. 灏嗗瓧绗︿覆瑙ｆ瀽涓� Date 瀵硅薄
+ SimpleDateFormat inputFormat = new SimpleDateFormat("MM/dd/yyyy HH:mm:ss");
+ Date endDate = inputFormat.parse(machineInfo.getEndTime());
+
+ // 2. 灏� Date 鏍煎紡鍖栦负鐩爣 SQL 鏍煎紡锛堝 "yyyy-MM-dd HH:mm:ss"锛�
+ SimpleDateFormat outputFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ sql = sql + "'" + outputFormat.format(endDate) + "', ";
+ } catch (ParseException e) {
+ // 澶勭悊瑙ｆ瀽澶辫触鐨勬儏鍐碉紙濡傛棩蹇楄褰曟垨鎶涘嚭寮傚父锛�
+ throw new RuntimeException("Invalid end time format: " + machineInfo.getEndTime(), e);
+ }
+ return sql;
+ }
}
--
Gitblit v1.9.3