1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package com.vci.server.bof.server.create;
 
import javax.xml.rpc.holders.LongHolder;
 
import com.vci.corba.common.data.VCIInvocationInfo;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.corba.omd.data.LinkObject;
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
import com.vci.server.base.utility.LogRecordUtil;
import com.vci.server.bof.server.ServiceFacadeExecuteHelper;
import com.vci.server.bof.service.BOFactoryServices;
import com.vci.server.bof.service.LOFactoryService;
 
public class BatchCUDBOLO extends ServiceFacadeExecuteHelper {
 
    private static ServiceFacadeExecuteHelper instance = null;
    
    public static ServiceFacadeExecuteHelper getInstance() {
        if(instance == null) {
            instance = new BatchCUDBOLO();
        }
        return instance;
    }
    
    @Override
    protected Object doAction() throws Throwable {
        BusinessObject[] deleteBOs = params.getDeleteBos();
        BusinessObject[] createBOs = params.getCreateBos();
        BusinessObject[] updateBOs = params.getUpdateBos();
        LinkObject[] deleteLOs = params.getDeleteLos();
        LinkObject[] createLOs = params.getCreateLos();
        LinkObject[] updateLOs = params.getUpdateLos();
        boolean rs = false;
//        VCIInvocationInfo info = HibernateSessionFactory.getVciSessionInfo();
//        String ip = "127.0.0.1";
//        if(info!=null){
//            ip = info.clientIPInfo == null||"".equals(info.clientIPInfo) ?"127.0.0.1":info.clientIPInfo;
//        }
        if(deleteLOs != null && deleteLOs.length > 0) {            
            LOFactoryService services = LOFactoryService.getInstance();
            rs =  services.batchDeleteLinkObject(deleteLOs);
            if (!rs) {
                return rs;
            }
        }
        if(deleteBOs != null && deleteBOs.length > 0) {
            BOFactoryServices services = BOFactoryServices.getInstance();
            rs = services.batchDeleteBusinessObject(deleteBOs, 1);
            if (!rs) {
                LogRecordUtil.batchWriteLog(deleteBOs, "删除", "操作失败");
                return rs;
            }
            LogRecordUtil.batchWriteLog(deleteBOs, "删除");
        }
        if((createBOs != null && createBOs.length > 0) || 
                (createLOs != null && createLOs.length > 0)) {            
            LongHolder ts = new LongHolder();
            BOFactoryServices services = BOFactoryServices.getInstance();
            rs = services.batchCreateBusinessObjectWithLink(createBOs, createLOs, ts);
            if (!rs) {
                LogRecordUtil.batchWriteLog(createBOs, "创建", "操作失败");
                return rs;
            }
            LogRecordUtil.batchWriteLog(createBOs, "创建");
        }
        if(updateBOs != null && updateBOs.length > 0) {            
            BOFactoryServices services = BOFactoryServices.getInstance();
            rs = services.batchUpdateBusinessObject(updateBOs);
            if (!rs) {
                LogRecordUtil.batchWriteLog(updateBOs, "更新", "操作失败");
                return rs;
            }
            LogRecordUtil.batchWriteLog(updateBOs, "更新");
        }
        if(updateLOs != null && updateLOs.length > 0) {            
            LOFactoryService services = LOFactoryService.getInstance();
            rs = services.batchUpdateLinkObject(updateLOs);
        }
        return rs;
    }
 
}