From 1b230d7961b2d5068298f0cba13287cabd2fd649 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期三, 17 七月 2024 18:47:35 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/task/handler/ErrorStockHandler.java | 33 ++++++++++++++++++++-------------
1 files changed, 20 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/handler/ErrorStockHandler.java b/src/main/java/com/zy/asrs/task/handler/ErrorStockHandler.java
index 85cc3fa..8f49780 100644
--- a/src/main/java/com/zy/asrs/task/handler/ErrorStockHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/ErrorStockHandler.java
@@ -1,36 +1,43 @@
package com.zy.asrs.task.handler;
+import com.zy.asrs.service.LocMastService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
-
-import java.util.List;
-import java.util.Map;
/**
* Created by vincent on 2020/7/7
*/
@Service
+@Slf4j
public class ErrorStockHandler extends AbstractHandler<String> {
@Autowired
private JdbcTemplate jdbcTemplate;
+ @Autowired
+ private LocMastService locMastService;
- @Transactional
+ //@Transactional
public ReturnT<String> start() {
try {
- String sql = "SELECT distinct a.loc_no as locNo FROM asr_loc_mast a,asr_loc_detl b where a.loc_no=b.loc_no and (a.loc_type ='O' or a.loc_type ='D')";
- List<Map<String, Object>> result = jdbcTemplate.queryForList(sql);
- if (!result.isEmpty()) {
- for (Map<String, Object> map : result) {
- int delCount = jdbcTemplate.update("delete from asr_loc_detl where loc_no=?;", map.get("locNo"));
- System.out.println(delCount);
- }
- }
+ int update = jdbcTemplate.update("DELETE asr_loc_detl FROM asr_loc_detl JOIN asr_loc_mast ON asr_loc_detl.loc_no = asr_loc_mast.loc_no WHERE asr_loc_mast.loc_sts = 'O'");
+// log.info("(ErrorStockHandler)鍒犻櫎鏉℃暟涓猴紱" + update);
+ } catch (Exception e) {
+ e.printStackTrace();
+ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+ return FAIL.setMsg(e.getMessage());
+ }
+ return SUCCESS;
+ }
+
+ public ReturnT<String> startAgv() {
+ try {
+ int update = jdbcTemplate.update("DELETE agv_loc_detl FROM agv_loc_detl JOIN agv_loc_mast ON agv_loc_detl.loc_no = agv_loc_mast.loc_no WHERE agv_loc_mast.loc_sts = 'O'");
+// log.info("(ErrorStockHandler)鍒犻櫎鏉℃暟涓猴紱" + update);
} catch (Exception e) {
e.printStackTrace();
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
--
Gitblit v1.9.1