append port AsyncSend function

internal/appchain/port.go

@@ -71,11 +71,22 @@ func (a *appChain) Send(msg *pb.Message) (*pb.Message, error) {
 }
 
 func (a *appChain) AsyncSend(msg *pb.Message) error {
-	// TODO 调用该执行。
-	// a.ExecuteIBTP()
-	// a.Rollback()
-
-	panic("implement me")
+	if msg.Type == pb.Message_IBTP_RECEIPT_SEND {
+		ibpx := &pb.IBTPX{}
+		err := ibpx.Unmarshal(msg.Payload.Data)
+		if err != nil {
+			return err
+		}
+		ibtp := ibpx.GetIbtp()
+		ibtp, err = a.ExecuteIBTP(ibtp)
+		if err != nil {
+			return err
+		}
+		if ibtp == nil {
+			return errors.New("ibtp wrong")
+		}
+	}
+	return errors.New("ibtp type wrong")
 }
 
 // ListenIBTPX 监听IBTPX数据。