Просмотр исходного кода

更新批量回复为存储过程执行

hejq 8 лет назад
Родитель
Сommit
fbb77cc138

+ 7 - 4
src/main/java/com/uas/platform/b2b/dao/PurchaseOrderItemDao.java

@@ -1,17 +1,17 @@
 package com.uas.platform.b2b.dao;
 
-import java.util.Date;
-import java.util.List;
-
+import com.uas.platform.b2b.model.PurchaseOrderItem;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.jpa.repository.query.Procedure;
 import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 import org.springframework.transaction.annotation.Transactional;
 
-import com.uas.platform.b2b.model.PurchaseOrderItem;
+import java.util.Date;
+import java.util.List;
 
 @Repository
 @Transactional
@@ -77,4 +77,7 @@ public interface PurchaseOrderItemDao extends JpaSpecificationExecutor<PurchaseO
 	@Modifying(clearAutomatically = true)
 	@Query("update PurchaseOrderItem p set p.replyQty=(select sum(r.qty) from PurchaseOrderReply r where r.orderItem=p),p.replyDelivery= :delivery,p.replyRemark= :remark where p.id= :id")
 	public void updateByReply(@Param("delivery") Date delivery, @Param("remark") String remark, @Param("id") long id);
+
+    @Procedure(procedureName = "purc$reply_batch")
+    public void replyByBatch(String idString, String username, String userip, Long enuu, Long useruu);
 }

+ 1 - 0
src/main/java/com/uas/platform/b2b/service/PurchaseOrderService.java

@@ -384,4 +384,5 @@ public interface PurchaseOrderService {
 	 */
 	List<Object[]> getOrderCount(String category);
 
+	public void replyByBatch(String idString, String username, String userip, Long enuu, Long useruu);
 }

+ 5 - 0
src/main/java/com/uas/platform/b2b/service/impl/PurchaseOrderServiceImpl.java

@@ -1224,4 +1224,9 @@ public class PurchaseOrderServiceImpl implements PurchaseOrderService {
         return purchaseOrderDao.getUnreadCountEveryStatus(ids);
 	}
 
+    @Override
+    public void replyByBatch(String idString, String username, String userip, Long enuu, Long useruu) {
+        purchaseOrderItemDao.replyByBatch(idString, username, userip, enuu, useruu);
+    }
+
 }