同步用户查表插入脚本示例

1. //员工信息同步                             
   
2.                              (function(){                             
   
3.                                      var rtn = "";                             
   
4.                                      var sql = "select id,DEFAULTDEPARTMENT,loginno from obpm2.t_user";                             
   
5.                                      var datas = queryByDSName("OA_DS",sql);                             
   
6.                                      var count = 0;        //同步成功数量                                                      
   
7.                                      var formName = "A员工信息";                             
   
8.                               var process = getDocumentProcess();                             
   
9.                                    var formProcess = getFormProcess();        //申明表单业务处理类                             
   
10.                                      var form = formProcess.doViewByFormName(formName,getApplication());                             
    
11.                                      var webuser = getWebUser();         
    
12.                               var doc1 = process.doNew(form,webuser,createParamsTable());//创建记录                                                        
    
13.                                      if(datas != null && datas.size()>0){                             
    
14.                                              for(var iter1=datas.iterator();iter1.hasNext();){                             
    
15.                                                      var user = iter1.next();                             
    
16.                                                      var id = user.get("id");                                             
    
17.                                                      var defaultDept = user.get("DEFAULTDEPARTMENT");                             
    
18.                                        var loginno = user.get("loginno");                 
    
19.                                                      var depname = "";            
    
20.           //println("1111111111");                                                                  
    
21.                                                      var sql3 = "select name,domain_id domainid from obpm2.t_department where id='"+defaultDept+"'";           
    
22.           //println("sql3---------->"+sql3)                                                                  
    
23.                                                      //var cdoc = findBySQL(sql3);         
    
24.                                                                   //println("111111222");         
    
25.                                         // if(cdoc!=null){                             
    
26.                                           //    depname = cdoc.getItemValueAsString("name");                             
    
27.                                                      //}            
    
28.         try{                                                                         
    
29.                                                                                  
    
30.                                                              //查询员工信息登记资料表中是否已有当前用户数据                             
    
31.                                                              var sql1 = "select id,domainid from tlk_A员工信息 where item_姓名 = '"+id+"'";         
    
32.         //println("sql1------->"+sql1);                                                                                
    
33.                                                              var datas1 = queryBySQL(sql1);            
    
34.            //已有数据时不再插入                        println("22222222");                                                           
    
35.                                                              if(datas1 != null && datas1.size() > 0){                                     
    
36.                                                                var sql2 = "update tlk_A员工信息 set item_部门 = '"+defaultDept+"' where item_姓名 = '"+id+"'";                 
    
37.                                                                                     
    
38.                                                                updateByDSName("OA_DS",sql2);                             
    
39.                                                              }else{            
    
40.                                                                                     
    
41.                                                              var uuid = new Packages.cn.myapps.util.sequence.Sequence();      
    
42.                                           doc1.setId(uuid.getSequence());  
    
43.                                                                                    
    
44.                                                              doc1.findItem("姓名").setValue(id);           
    
45.                                                                                    
    
46.                                                          doc1.findItem("工号").setValue(loginno);           
    
47.                                                                                    
    
48.                                                              doc1.findItem("部门").setValue(defaultDept);                                             
    
49.                                                              process.doCreate(doc1);      
    
50.                                                 
    
51.               
    
52.                                                              count++;                             
    
53.                                                              }         
    
54.                                                                                         
    
55.                                                                       
    
56.                                              }catch(ex){                             
    
57.                                                                                   
    
58.                                                                                       
    
59.                                                              rtn="";                           
    
60.                                                      }                                   
    
61.                                                                       
    
62.                                      }   }                          
    
63.                                      return rtn;                             
    
64.                              })();

复制代码