From 094a9290c836827bc1f45fd3549e7cd2ea1e1e45 Mon Sep 17 00:00:00 2001
From: qushaowei <qushaowei@163.com>
Date: 星期二, 07 十一月 2023 09:45:36 +0800
Subject: [PATCH] Merge branch 'master' of http://117.34.109.166:18448/r/mdc_430 into develop
---
lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 51 insertions(+), 0 deletions(-)
diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java
index 2fa8719..c155000 100644
--- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java
+++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java
@@ -3,6 +3,7 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.commons.lang3.StringUtils;
+import org.jeecg.common.system.vo.DictModel;
import org.jeecg.modules.mdc.dto.EquipmentMachingDto;
import org.jeecg.modules.mdc.dto.MdcEquipmentRunningSectionDto;
import org.jeecg.modules.mdc.entity.*;
@@ -12,6 +13,7 @@
import org.jeecg.modules.mdc.util.TimeFieldUtils;
import org.jeecg.modules.mdc.vo.MdcAlarmAnalyzeQueryVo;
import org.jeecg.modules.mdc.vo.MdcEquipmentRunningSectionVo;
+import org.jeecg.modules.system.service.ISysDictService;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -39,6 +41,12 @@
@Resource
private IEquipmentWorkLineService equipmentWorkLineService;
+
+ @Resource
+ private ISysDictService sysDictService;
+
+ @Resource
+ private IEquipmentRunningTraceService equipmentRunningTraceService;
@Override
public List<MdcEquipmentRunningSectionDto> logList(MdcEquipmentRunningSectionVo equipmentRunningSectionVo) {
@@ -483,10 +491,53 @@
//save errorList
super.saveBatch(errorList);
}
+ List<DictModel> dictList = sysDictService.queryDictItemsByCode("data_synchronization_flag");
+ if (dictList != null && !dictList.isEmpty() && "0".equals(dictList.get(0).getValue())) {
+ this.dataSynchronizationHandler(list, errorList);
+ }
}
}
/**
+ * 鏁版嵁鍚屾澶勭悊
+ * @param list
+ * @param errorList
+ */
+ private void dataSynchronizationHandler(List<MdcEquipmentRunningSection> list, List<MdcEquipmentRunningSection> errorList) {
+ // 鏁版嵁杞崲
+ List<EquipmentRunningTrace> equipList = new ArrayList<>();
+ if (list != null && !list.isEmpty()) {
+ list.forEach(item -> {
+ EquipmentRunningTrace equipmentRunningSection = new EquipmentRunningTrace();
+ equipmentRunningSection.setEquipment(item.getEquipmentId());
+ equipmentRunningSection.setAlarm(item.getAlarm());
+ equipmentRunningSection.setCreateTime(item.getCreateTime());
+ equipmentRunningSection.setDuration(item.getDuration());
+ equipmentRunningSection.setEndTime(item.getEndTime());
+ equipmentRunningSection.setStartTime(item.getStartTime());
+ equipmentRunningSection.setStatus(item.getStatus());
+ equipmentRunningSection.setSequencenumber(item.getSequenceNumber());
+ equipList.add(equipmentRunningSection);
+ });
+ }
+ if (errorList != null && !errorList.isEmpty()) {
+ errorList.forEach(item -> {
+ EquipmentRunningTrace equipmentRunningSection = new EquipmentRunningTrace();
+ equipmentRunningSection.setEquipment(item.getEquipmentId());
+ equipmentRunningSection.setAlarm(item.getAlarm());
+ equipmentRunningSection.setCreateTime(item.getCreateTime());
+ equipmentRunningSection.setDuration(item.getDuration());
+ equipmentRunningSection.setEndTime(item.getEndTime());
+ equipmentRunningSection.setStartTime(item.getStartTime());
+ equipmentRunningSection.setStatus(item.getStatus());
+ equipmentRunningSection.setSequencenumber(item.getSequenceNumber());
+ equipList.add(equipmentRunningSection);
+ });
+ }
+ equipmentRunningTraceService.saveBatch(equipList);
+ }
+
+ /**
* 鑾峰彇璁惧杩愯璁板綍鏈�鏃╃殑鏁版嵁
*/
@Override
--
Gitblit v1.9.3