update
This commit is contained in:
@@ -336,6 +336,8 @@ func (c *CartGrain) HandleMessage(message *Message, isReplay bool) (*FrameWithPa
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if len(items) > 0 {
|
||||||
|
|
||||||
c.Deliveries = append(c.Deliveries, &CartDelivery{
|
c.Deliveries = append(c.Deliveries, &CartDelivery{
|
||||||
Id: c.lastDeliveryId,
|
Id: c.lastDeliveryId,
|
||||||
Provider: msg.Provider,
|
Provider: msg.Provider,
|
||||||
@@ -345,11 +347,10 @@ func (c *CartGrain) HandleMessage(message *Message, isReplay bool) (*FrameWithPa
|
|||||||
c.Processing = true
|
c.Processing = true
|
||||||
go func() {
|
go func() {
|
||||||
time.Sleep(5 * time.Second)
|
time.Sleep(5 * time.Second)
|
||||||
c.mu.Lock()
|
|
||||||
c.Processing = false
|
c.Processing = false
|
||||||
c.mu.Unlock()
|
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
}
|
||||||
case RemoveDeliveryType:
|
case RemoveDeliveryType:
|
||||||
msg, ok := message.Content.(*messages.RemoveDelivery)
|
msg, ok := message.Content.(*messages.RemoveDelivery)
|
||||||
if !ok {
|
if !ok {
|
||||||
|
|||||||
Reference in New Issue
Block a user