PHP+Mysql分布式事务与解决方案深入理解

public function testAction(){
    $goods_id=1;
    $goods_name = "Devmax";
    $num = 1;
    $rs_order = $this->test->createorder($goods_id,$goods_name,$num);
    $rs_goods = $this->test->deduction($goods_id,$num);
    if($rs_order['status'] =="success" && $rs_goods['status']=="success"){
      $this->test->commitdb($rs_order['XA']);
      $this->test->commitdb1($rs_goods['XA']);
    }else{
      $this->test->rollbackdb($rs_order['XA']);
      $this->test->rollbackdb1($rs_goods['XA']);
    }

    print_r($rs_order);
    echo "<br />";
    print_r($rs_goods);
    die("dddd");
  }
  public function createorder($goods_id,$goods_name,$num){
    $XA = uniqid("");
    $this->_db->query("XA START '$XA'");
    $_rs = true;
    try {
      $data = array();
      $data['order_id'] = "V".date("YmdHis");
      $data['goods_name'] = $goods_name;
      $data['goods_num'] = $num;
      $this->_db->insert("temp_orders",$data);
      $rs = $this->_db->lastInsertId();
      if($rs){
        $_rs = true;
      }else{
        $_rs = false;
      }
    } catch (Exception $e) {
      $_rs = false;
    }
    $this->_db->query("XA END '$XA'");
     if($_rs){
         $this->_db->query("XA PREPARE '$XA'");
         return array("status"=>"success","XA"=>$XA);
     }else{
         return array("status"=>"nosuccess","XA"=>$XA);
     }
  }
   public function deduction($id){
    $XA = uniqid("");
    $this->db1->query("XA START '$XA'");
    $last_rs = true;
    try {
        $sql = "select * from temp_goods where id = '$id' and goods_num>0";
        $rs = $this->db1->fetchRow($sql);
        if(!empty($rs)){
          $sql = "update temp_goods set goods_num = goods_num-1 where id = '$id'";
          $rd = $this->db1->query($sql);
          if($rd){
            $last_rs = true;
          }else{
            $last_rs = false;
          }
        }else{
            $last_rs = false;;
        }
    } catch (Exception $e) {
       $last_rs = false;;
    }
     $this->db1->query("XA END '$XA'");
     if($last_rs){
         $this->db1->query("XA PREPARE '$XA'");
         return array("status"=>"success","XA"=>$XA);
     }else{
         return array("status"=>"nosuccess","XA"=>$XA);
     }

  }
  //提交事务！
  public function commitdb($xa){
    return $this->_db->query("XA COMMIT '$xa'");
  }

  //回滚事务
  public function rollbackdb($xa){
    return $this->_db->query("XA ROLLBACK '$xa'");
  }

  //提交事务！
  public function commitdb1($xa){
    return $this->db1->query("XA COMMIT '$xa'");
  }
   //回滚事务
  public function rollbackdb1($xa){
    return $this->db1->query("XA ROLLBACK '$xa'");
  }