From b849c6d6056a6783914546fed92399472e34f9dd Mon Sep 17 00:00:00 2001
From: admin <15939171744@163.com>
Date: 星期五, 26 七月 2024 08:32:42 +0800
Subject: [PATCH] -拧紧返修功能
---
jcdm-main/src/main/java/com/jcdm/main/da/passingStationCollection/service/impl/DaPassingStationCollectionServiceImpl.java | 49 ++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 48 insertions(+), 1 deletions(-)
diff --git a/jcdm-main/src/main/java/com/jcdm/main/da/passingStationCollection/service/impl/DaPassingStationCollectionServiceImpl.java b/jcdm-main/src/main/java/com/jcdm/main/da/passingStationCollection/service/impl/DaPassingStationCollectionServiceImpl.java
index a45c08e..f2c2bd7 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/da/passingStationCollection/service/impl/DaPassingStationCollectionServiceImpl.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/da/passingStationCollection/service/impl/DaPassingStationCollectionServiceImpl.java
@@ -1,17 +1,23 @@
package com.jcdm.main.da.passingStationCollection.service.impl;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.jcdm.common.utils.DateUtils;
//import com.jcdm.main.bs.orderScheduling.domain.BsOrderScheduling;
//import com.jcdm.main.bs.orderScheduling.mapper.BsOrderSchedulingMapper;
//import com.jcdm.main.bs.orderScheduling.service.IBsOrderSchedulingService;
+import com.jcdm.main.da.paramCollection.mapper.DaParamCollectionMapper;
import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection;
import com.jcdm.main.da.passingStationCollection.mapper.DaPassingStationCollectionMapper;
import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService;
import com.jcdm.main.rm.repairRecord.domain.RmRepairRecord;
import com.jcdm.main.rm.repairRecord.mapper.RmRepairRecordMapper;
+import org.apache.ibatis.session.ExecutorType;
+import org.apache.ibatis.session.SqlSession;
+import org.apache.ibatis.session.SqlSessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
@@ -24,13 +30,19 @@
* @date 2023-12-12
*/
@Service
-public class DaPassingStationCollectionServiceImpl implements IDaPassingStationCollectionService
+public class DaPassingStationCollectionServiceImpl extends ServiceImpl<DaPassingStationCollectionMapper,DaPassingStationCollection> implements IDaPassingStationCollectionService
{
@Autowired
private DaPassingStationCollectionMapper daPassingStationCollectionMapper;
@Autowired
+ private IDaPassingStationCollectionService daPassingStationCollectionService;
+
+ @Autowired
private RmRepairRecordMapper rmRepairRecordMapper;
+
+ @Resource
+ private SqlSessionFactory sqlSessionFactory;
// @Autowired
// private BsOrderSchedulingMapper bsOrderSchedulingMapper;
@@ -108,6 +120,11 @@
return daPassingStationCollectionMapper.updateDaPassingStationCollection(daPassingStationCollection);
}
+ @Override
+ public int updateDaPassingStationCollectionBySfcCodeAndLocationCode(DaPassingStationCollection daPassingStationCollection) {
+ return daPassingStationCollectionMapper.updateDaPassingStationCollectionBySfcCodeAndLocationCode(daPassingStationCollection);
+ }
+
/**
* 鎵归噺鍒犻櫎浜у搧杩囩珯閲囬泦
*
@@ -144,4 +161,34 @@
rmRepairRecordMapper.insertRmRepairRecord(rmRepairRecord);
}
}
+
+ @Override
+ public int jrmAddPassingStationCollection(DaPassingStationCollection daPassingStationCollection) {
+ for (String model : daPassingStationCollection.getSfcCode().split(",")) {
+ daPassingStationCollection.setSfcCode(model);
+ daPassingStationCollectionService.save(daPassingStationCollection);
+ }
+ return 1;
+ }
+
+ @Override
+ public void saveBeachDaPassingStationCollection(List<DaPassingStationCollection> list) {
+ // ExecutorType.SIMPLE: 杩欎釜鎵ц鍣ㄧ被鍨嬩笉鍋氱壒娈婄殑浜嬫儏銆傚畠涓烘瘡涓鍙ョ殑鎵ц鍒涘缓涓�涓柊鐨勯澶勭悊璇彞銆�
+ // ExecutorType.REUSE: 杩欎釜鎵ц鍣ㄧ被鍨嬩細澶嶇敤棰勫鐞嗚鍙ャ��
+ // ExecutorType.BATCH: 杩欎釜鎵ц鍣ㄤ細鎵归噺鎵ц鎵�鏈夋洿鏂拌鍙�,濡傛灉 SELECT 鍦ㄥ畠浠腑闂存墽琛岃繕浼氭爣瀹氬畠浠槸 蹇呴』鐨�,鏉ヤ繚璇佷竴涓畝鍗曞苟鏄撲簬鐞嗚В鐨勮涓恒��
+
+ // 鍏抽棴session鐨勮嚜鍔ㄦ彁浜�
+ SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
+ try {
+ DaPassingStationCollectionMapper userMapper = sqlSession.getMapper(DaPassingStationCollectionMapper.class);
+ list.stream().forEach(item -> userMapper.insertDaPassingStationCollection(item));
+ // 鎻愪氦鏁版嵁
+ sqlSession.commit();
+ sqlSession.rollback();
+ } catch (Exception e) {
+ sqlSession.rollback();
+ } finally {
+ sqlSession.close();
+ }
+ }
}
--
Gitblit v1.9.3