From 6ac7c1f37073562049887969f530dbdf4c54bd67 Mon Sep 17 00:00:00 2001
From: zhangxin <xin.zhang@le-it.com.cn>
Date: Mon, 16 May 2022 15:34:41 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9channel=20=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E7=B1=BB=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 models/channel/ReleaseTask.go | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/models/channel/ReleaseTask.go b/models/channel/ReleaseTask.go
index e0d285a..c69b318 100644
--- a/models/channel/ReleaseTask.go
+++ b/models/channel/ReleaseTask.go
@@ -1,20 +1,19 @@
 package channel
 
 import (
-	plnModel "LAPP_ACURA_MOM_BACKEND/models/pln"
 	"errors"
 	"sync"
 )
 
 type ReleaseTaskChannel struct {
-	c      chan plnModel.CustOrder
+	c      chan interface{}
 	closed bool
 	mutex  sync.Mutex
 }
 
 func NewReleaseChannel() *ReleaseTaskChannel {
 	return &ReleaseTaskChannel{
-		c: make(chan plnModel.CustOrder, 100),
+		c: make(chan interface{}, 100),
 	}
 }
 
@@ -26,13 +25,13 @@ func (c *ReleaseTaskChannel) IsClosed() bool {
 }
 
 // SendData 发送数据
-func (c *ReleaseTaskChannel) SendData(custOrder plnModel.CustOrder) error {
+func (c *ReleaseTaskChannel) SendData(data interface{}) error {
 	c.mutex.Lock()
 	defer c.mutex.Unlock()
 	if c.closed {
 		return errors.New("管道已关闭")
 	}
-	c.c <- custOrder
+	c.c <- data
 	return nil
 }
 
@@ -46,7 +45,7 @@ func (c *ReleaseTaskChannel) Close() {
 	c.closed = true
 }
 
-func (c *ReleaseTaskChannel) Read() (data plnModel.CustOrder, ok bool, err error) {
+func (c *ReleaseTaskChannel) Read() (data interface{}, ok bool, err error) {
 	c.mutex.Lock()
 	if c.closed {
 		err = errors.New("管道已关闭")
@@ -65,6 +64,6 @@ func (c *ReleaseTaskChannel) ResetChannel() (err error) {
 		return
 	}
 	c.closed = false
-	c.c = make(chan plnModel.CustOrder, 50)
+	c.c = make(chan interface{}, 50)
 	return
 }
\ No newline at end of file