beacon的事务处理，transaction

zhgc

范例一：smttools/st001

1.                         $db->BeginTrans();   //开始事务处理
   
2.                         $sqls=array();
   
3.                         $sqls[] ="UPDATE SMT.R_TR_SN  SET ext_qty='{$extqty}',location_flag=1,work_flag=0,kitting_flag='a'  WHERE TR_SN='{$trsn}'";
   
4.                         $sqls[]="insert into SMT.R_program_log (prg_name,fun_name,action_type,oldsn,out_emp,data1,data2) values('SMTTOOLS','EmptyToFull','空盘下料状态修改','{$trsn}','".$user->empno."','{$extqty}','".this.txt_extqty.Text. "')";
   
5.                         $sqls[]="INSERT INTO smt.r_kitting_scan_detail (tr_sn, cust_kp_no, qty, from_location,to_location, move_type, move_reason, move_emp, move_time) VALUES ('{$trsn}', '{$kp}', '{$extqty}', '{$wo}',".
   
6.                        "'KITTING', 'e', '996', '".$user->empno."', now())";
   
7.                         $sqls[]="UPDATE smt.r_wo_request SET RETURN_QTY = RETURN_QTY + {$extqty} WHERE WO = '{$wo}' AND CUST_KP_NO =  '{$kp}' ";
   
8.                         if($smttools->isdebug){
   
9.                                 $smttools->saveLog($sqls);
   
10.                         }         
    
11. 
    
12.                         $rst=true;
    
13.                         foreach($sqls as $sql){
    
14.                                 $rst = $db->execute($sql);
    
15.                                 if($rst){
    
16.                                
    
17.                                 }else{
    
18.                                         $res=$db->ErrorMsg();
    
19.                                         break;
    
20.                                 }
    
21.                         }
    
22.                         if($rst==true){
    
23.                                 $rst=false; //可能提交的时候出错！
    
24.                                 $db -> CommitTrans();
    
25.                                 $rst=true;               
    
26.                         }else{
    
27.                                 $db -> RollbackTrans();
    
28.                         }
    
29.                         return $rst;

复制代码

syant

1. 
   
2.         //处理数据库连接
   
3.         $this->app->prepare_mes();
   
4. 
   
5.         //开始处理修改数据
   
6.         $sqls=array();
   
7.         $sqls[] ="update smt.c_stencil_base set work_flag=1,check_time=now() where  stencil_sn='{$trsn}'";
   
8.         $sqls[] ="insert into smt.c_stencil_list select * from  smt.c_stencil_base where   stencil_sn='{$trsn}'";
   
9. 
   
10.         //开始事务处理
    
11.         $this->app->mes->BeginTrans();   
    
12.         $rst=true;
    
13.         foreach($sqls as $sql){
    
14.                 $rst = $this->app->mes->execute($sql);
    
15.                 if($rst){
    
16.                        
    
17.                 }else{
    
18.                         $res=$this->app->mes->ErrorMsg();
    
19.                         $this->app->AjaxFail("{$res},{$sql}", 100);
    
20.                         break;
    
21.                 }
    
22.         }
    
23. 
    
24.         //开始提交
    
25.         if($rst==true){
    
26.                 $this->app->mes -> CommitTrans();
    
27.         }else{
    
28.                 $this->app->mes -> RollbackTrans();
    
29.                 return;
    
30.         }
    
31. 
    
32.         //要取消AjaxOK，改为AjaxPass函数，因为AjaxPass和AjaxFail保持一样的参数顺序
    
33.         $this->app->AjaxOK($trsninfo,"钢网{$trsn}收入工具室！");   

复制代码