|
@ -936,13 +936,14 @@ func (impl *CustOrderServiceImplement) ReleasePlantTask(user *global.User) { |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
for { |
|
|
for { |
|
|
custOrder, ok, err := channel.Read() |
|
|
|
|
|
|
|
|
custOrderInterface, ok, err := channel.Read() |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return |
|
|
return |
|
|
} |
|
|
} |
|
|
if !ok { |
|
|
if !ok { |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
|
|
|
custOrder := custOrderInterface.(model.CustOrder) |
|
|
err = impl.ReleaseSingleOrder(user, custOrder) |
|
|
err = impl.ReleaseSingleOrder(user, custOrder) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Error("派工异常, 错误:" + err.Error()) |
|
|
log.Error("派工异常, 错误:" + err.Error()) |
|
|