田源
2024-03-07 4b4083fd73dc27ece42f4835483565eef0e4f608
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
package com.vci.client.portal.custom;
 
import java.util.*;
 
import com.vci.client.common.oq.OQTool;
import com.vci.client.oq.QTClient;
import com.vci.common.qt.object.Condition;
import com.vci.common.qt.object.Connector;
import com.vci.common.qt.object.QueryTemplate;
import com.vci.corba.common.VCIError;
import com.vci.corba.omd.data.BusinessObject;
import com.vci.omd.constants.FileObjectType;
 
 
public class CommonFileUI implements ICommonFileUI{
 
    /**
     * * 获取文档关联的所有文件
     * @param documentId,文档OID
     * @return
     * @throws PLMError
     * @throws VciException
     */
    @Override
    public BusinessObject[] getAllFile(String documentId) throws VCIError {
        Map<String, String> conditions = new HashMap<String, String>();
        conditions.put(FileObjectType.SELECT_DOCUMENT_ID, documentId);
        
        QueryTemplate qt2 = new QueryTemplate();
        qt2.setId("btmQuery");
        qt2.setBtmType(FileObjectType.FILE_DATA_TABLE);
        qt2.setType("btm");
        List<String> clauseList = new ArrayList<String>();
        clauseList.add("*");
        qt2.setClauseList(clauseList);
        Condition cond = OQTool.getCondition(conditions);
        qt2.setCondition(cond);
        
        BusinessObject[] bos = QTClient.getService().findBTMObjects(qt2.getId(),  OQTool.qtTOXMl(qt2).asXML());
        
        return bos;
    }
 
    @Override
    public BusinessObject[] getMultiObjectFiles(String[] objIds)
            throws VCIError {
        List<BusinessObject> boList = new ArrayList<BusinessObject>();
        List<String> idList = new ArrayList<String>();
        for (int i = 0; i < objIds.length; i++) {
            idList.add(objIds[i]);
            if (i + 1 % 200 == 0) {
                BusinessObject[] cbos = getObjectFiles(idList.toArray(new String[0]));
                addArrayDataToList(boList, cbos);
                idList.clear();
            }
        }
        
        if (idList.size() > 0) {
            BusinessObject[] cbos = getObjectFiles(idList.toArray(new String[0]));
            addArrayDataToList(boList, cbos);
            idList.clear();
        }
        
        return boList.toArray(new BusinessObject[0]);
    }
    
    private void addArrayDataToList(List<BusinessObject> boList, BusinessObject[] cbos) {
        for (int i = 0; i < cbos.length; i++) {
            boList.add(cbos[i]);
        }
    }
    
    /**
     * 一次查询出对象数组的所有文件(一次传递的数量最多200个对象)
     * @param objIds
     * @return
     * @throws VCIError
     */
    private BusinessObject[] getObjectFiles(String[] objIds) throws VCIError {
        QueryTemplate qt2 = new QueryTemplate();
        qt2.setId("btmQuery");
        qt2.setBtmType(FileObjectType.FILE_DATA_TABLE);
        qt2.setType("btm");
        List<String> clauseList = new ArrayList<String>();
        clauseList.add("*");
        qt2.setClauseList(clauseList);
        
        Map<String, String> map = new HashMap<String, String>();
        Condition condition_ = OQTool.getCondition(map);
        for(String documentId : objIds){
            map.put(FileObjectType.SELECT_DOCUMENT_ID, documentId);
            Condition condition = OQTool.getCondition(map);
            condition_ = OQTool.mergeCondition(condition, condition_, Connector.OR);
            map.clear();
        }
        qt2.setCondition(condition_);
        
        BusinessObject[] bos = QTClient.getService().findBTMObjects(qt2.getId(),  OQTool.qtTOXMl(qt2).asXML());
        
        return bos;
    }
}