ludc
2024-12-04 e405b861b9521f5ea38c5402203a5b05988f9de2
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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
package com.vci.web.dao.impl;
 
import com.vci.constant.FrameWorkLangCodeConstant;
import com.vci.corba.common.PLException;
import com.vci.corba.framework.data.PvolumeInfo;
import com.vci.dto.VciFileVolumeDTO;
import com.vci.enumpck.UI.VciFileServiceOsTypeEnum;
import com.vci.enumpck.UI.VciFileTransProtocolEnum;
import com.vci.model.VciFileVolumeDO;
import com.vci.pagemodel.VciFileVolumeVO;
import com.vci.starter.web.annotation.bus.VciChangeDocument;
import com.vci.starter.web.enumpck.VciChangeDocumentTypeEnum;
import com.vci.starter.web.exception.VciBaseException;
import com.vci.starter.web.pagemodel.BaseResult;
import com.vci.starter.web.pagemodel.DataGrid;
import com.vci.starter.web.pagemodel.PageHelper;
import com.vci.starter.web.util.BeanUtilForVCI;
import com.vci.starter.web.util.VciBaseUtil;
import com.vci.starter.web.wrapper.VciQueryWrapperForDO;
import com.vci.web.dao.VciFileVolumeDaoI;
import com.vci.web.service.VciFileVolumeServiceI;
import com.vci.web.util.PlatformClientUtil;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
 
import javax.annotation.Resource;
import java.util.*;
 
import static com.vci.constant.FrameWorkDefaultValueConstant.FRAMEWORK_DATA_ENABLED;
import static com.vci.constant.FrameWorkLangCodeConstant.*;
 
/**
 * 文仓管理服务
 *
 * @author weidy
 * @date 2020-08-04
 */
@Service
@VciChangeDocument(btmType = "fileVolume")
public class VciFileVolumeServiceImpl implements VciFileVolumeServiceI {
 
    /**
    * 日志
    */
    private Logger logger = LoggerFactory.getLogger(getClass());
 
    /**
    * 数据操作层
    */
    @Resource
    private VciFileVolumeDaoI vciFileVolumeMapper;
 
    /**
     * 平台调用的
     */
    @Autowired
    private PlatformClientUtil platformClientUtil;
 
    /**
     * 查询所有的文仓管理
     * @param conditionMap 查询条件
     * @param pageHelper 分页和排序
     * @return 执行结果
     * @throws VciBaseException 查询条件和分页出错的时候会抛出异常
     */
    @Override
    public DataGrid<VciFileVolumeVO> gridVciFileVolume(Map<String, String> conditionMap, PageHelper pageHelper) throws VciBaseException {
        if (pageHelper == null) {
            pageHelper = new PageHelper(-1);
        }
        VciQueryWrapperForDO queryWrapper = new VciQueryWrapperForDO(conditionMap,VciFileVolumeDO.class,pageHelper);
        List<VciFileVolumeDO> doList = vciFileVolumeMapper.selectByWrapper(queryWrapper);
        DataGrid<VciFileVolumeVO> dataGrid=new DataGrid<>();
        if (!CollectionUtils.isEmpty(doList)) {
            dataGrid.setData(vciFileVolumeDO2VOs(doList));
            queryWrapper.clearPage();
            dataGrid.setTotal(vciFileVolumeMapper.countByWrapper(queryWrapper));
        }
        return dataGrid;
    }
 
    /**
     * 批量数据对象转换为显示对象
     * @param vciFileVolumeDOs 数据对象列表
     * @return 显示对象
     * @throws VciBaseException 参数为空或者不存在的时候会抛出异常
     */
    @Override
    public List<VciFileVolumeVO> vciFileVolumeDO2VOs(Collection<VciFileVolumeDO>  vciFileVolumeDOs) throws VciBaseException {
        List<VciFileVolumeVO> voList = new ArrayList<>();
        if(!CollectionUtils.isEmpty(vciFileVolumeDOs)){
            vciFileVolumeDOs.stream().forEach(s ->{
                    VciFileVolumeVO vo =  vciFileVolumeDO2VO(s);
                if(vo != null){
                    voList.add(vo);
                }
            });
        }
        return voList;
    }
 
    /**
     * 数据对象转换为显示对象
     * @param  vciFileVolumeDO 数据对象
     * @return 显示对象
     * @throws VciBaseException 拷贝属性出错的时候会抛出异常
     */
    @Override
    public VciFileVolumeVO vciFileVolumeDO2VO(VciFileVolumeDO vciFileVolumeDO) throws VciBaseException {
              VciFileVolumeVO vo = new VciFileVolumeVO();
        if(vciFileVolumeDO != null){
            BeanUtilForVCI.convert(vciFileVolumeDO,vo);
 
            //还需要处理枚举等其他的内容
            vo.setServiceOsTypeText(VciFileServiceOsTypeEnum.getTextByValue(vo.getServiceOsType()));
            vo.setTransProtocolText(VciFileTransProtocolEnum.getTextByValue(vo.getTransProtocol()));
        }
        return vo;
    }
 
    /**
     * 增加文仓管理
     * @param vciFileVolumeDTO 文仓管理数据传输对象
     * @return 执行结果
     * @throws VciBaseException 参数为空,唯一项,必输项不通过时会抛出异常
     */
    @Override
    @VciChangeDocument(changeType = VciChangeDocumentTypeEnum.ADD)
    public VciFileVolumeVO addSave(VciFileVolumeDTO vciFileVolumeDTO) throws VciBaseException {
        VciBaseUtil.alertNotNull(vciFileVolumeDTO,"需要添加的数据对象");
        //将DTO转换为DO
        VciFileVolumeDO vciFileVolumeDO = new VciFileVolumeDO();
        BeanUtilForVCI.convert(vciFileVolumeDTO,vciFileVolumeDO);
        vciFileVolumeDO.setCurrentVolume("0");
        int insert = vciFileVolumeMapper.insert(vciFileVolumeDO);
        if(insert>0){
            return vciFileVolumeDO2VO(vciFileVolumeDO);
        }else{
            throw new VciBaseException(FrameWorkLangCodeConstant.ADD_FAIL);
        }
    }
 
    /**
     * 修改文仓管理
     * @param vciFileVolumeDTO 文仓管理数据传输对象
     * @return 执行结果
     * @throws VciBaseException 参数为空,唯一项,必输项不通过时会抛出异常
     */
     @Override
     @VciChangeDocument(changeType = VciChangeDocumentTypeEnum.EDIT)
     public VciFileVolumeVO editSave(VciFileVolumeDTO vciFileVolumeDTO) throws VciBaseException {
         VciBaseUtil.alertNotNull(vciFileVolumeDTO,"数据对象",vciFileVolumeDTO.getOid(),"文仓管理主键");
         //将DTO转换为DO
         VciFileVolumeDO vciFileVolumeDO = selectByOid(vciFileVolumeDTO.getOid());
         BeanUtilForVCI.convert(vciFileVolumeDTO,vciFileVolumeDO);
         int update = vciFileVolumeMapper.updateByPrimaryKey(vciFileVolumeDO);
         if(update>0){
             return vciFileVolumeDO2VO(vciFileVolumeDO);
         }else{
             throw new VciBaseException(EDIT_FAIL);
         }
     }
 
 
    /**
     * 校验是否可以删除,如果存在下级,并且下级有数据引用则不能删除
     * @param vciFileVolumeDTO 数据传输对象
     * @param vciFileVolumeDO 数据库中的数据对象
     * @return success为true为可以删除,false表示有数据引用,obj为true表示有下级
     */
    private BaseResult checkIsCanDeleteForDO(VciFileVolumeDTO vciFileVolumeDTO, VciFileVolumeDO vciFileVolumeDO) {
        if(!checkIsLinked(vciFileVolumeDO.getOid())) {
            return BaseResult.success();
        }else{
            return BaseResult.fail(DATA_LINKED_NOT_DELETE,new String[]{""});
        }
    }
 
    /**
    * 校验是否被引用
    * @param oid 主键
    * @throws VciBaseException 被引用的时候会抛出异常
    */
    private boolean checkIsLinked(String oid) throws VciBaseException {
        //TODO 添加需要校验引用的地方
        return false;
    }
 
    /**
     * 删除文仓管理
     * @param vciFileVolumeDTO 文仓管理数据传输对象,oid和ts需要传输
     * @return 删除结果反馈::success:成功,fail:失败
     * @throws VciBaseException 参数为空,被引用时抛出异常
     */
    @Override
    @VciChangeDocument(changeType = VciChangeDocumentTypeEnum.DELETE)
    public BaseResult deleteVciFileVolume(VciFileVolumeDTO vciFileVolumeDTO) throws VciBaseException {
        VciBaseUtil.alertNotNull(vciFileVolumeDTO,"文仓管理数据对象",vciFileVolumeDTO.getOid(),"文仓管理的主键");
        VciFileVolumeDO vciFileVolumeDO = selectByOid(vciFileVolumeDTO.getOid());
        BaseResult baseResult = checkIsCanDeleteForDO(vciFileVolumeDTO,vciFileVolumeDO);
        if(baseResult.isSuccess()) {
 
        }else{
            return baseResult;
        }
        //执行删除操作
        return (vciFileVolumeMapper.deleteByPrimaryKey(vciFileVolumeDO.getOid()) > 0)? BaseResult.successMsg(DELETE_SUCCESS): BaseResult.fail(DELETE_FAIL);
    }
 
    /**
    * 主键获取文仓管理
    * @param oid 主键
    * @return 文仓管理显示对象
    * @throws VciBaseException 参数为空,数据不存在时会抛出异常
    */
    @Override
    public VciFileVolumeVO getObjectByOid(String oid) throws VciBaseException {
        return vciFileVolumeDO2VO(selectByOid(oid));
    }
 
    /**
     * 编号获取文仓管理
     *
     * @param id 编号
     * @return 文仓管理显示对象
     * @throws VciBaseException 参数为空,数据不存在时会抛出异常
     */
    @Override
    public VciFileVolumeVO getObjectById(String id) throws VciBaseException {
        return vciFileVolumeDO2VO(selectById(id));
    }
 
    /**
     * 编号查询数据对象
     * @param id 编号
     * @return  数据对象
     * @throws VciBaseException 参数为空,并且数据不存在的时候会抛出异常
     */
    private VciFileVolumeDO selectById(String id) throws VciBaseException {
        VciBaseUtil.alertNotNull(id,"主键");
        VciQueryWrapperForDO queryWrapperForDO = new VciQueryWrapperForDO(null,VciFileVolumeDO.class);
        queryWrapperForDO.eq("plname",id);
        List<VciFileVolumeDO> vciFileVolumeDOs = vciFileVolumeMapper.selectByWrapper(queryWrapperForDO);
        if(CollectionUtils.isEmpty(vciFileVolumeDOs)){
            throw new VciBaseException(DATA_ID_NOT_EXIST);
        }
        return vciFileVolumeDOs.get(0);
    }
 
    /**
    * 主键查询数据对象
    * @param oid 主键
    * @return  数据对象
    * @throws VciBaseException 参数为空,并且数据不存在的时候会抛出异常
    */
    private VciFileVolumeDO selectByOid(String oid) throws VciBaseException {
        VciBaseUtil.alertNotNull(oid,"主键");
        VciFileVolumeDO vciFileVolumeDO = vciFileVolumeMapper.selectByPrimaryKey(oid.trim());
        if(vciFileVolumeDO == null || StringUtils.isBlank(vciFileVolumeDO.getOid())){
            throw new VciBaseException(DATA_OID_NOT_EXIST);
        }
        return vciFileVolumeDO;
    }
 
    /**
     * 主键批量获取文仓管理
     * @param oidCollections 主键集合,但是受性能影响,建议一次查询不超过10000个
     * @return 文仓管理显示对象
     * @throws VciBaseException 查询出现异常时会抛出
     */
    @Override
    public Collection<VciFileVolumeVO> listVciFileVolumeByOids(Collection<String> oidCollections) throws VciBaseException {
        VciBaseUtil.alertCollectionNotNull("数据对象主键集合",oidCollections);
        List<VciFileVolumeDO> vciFileVolumeDOList = listVciFileVolumeDOByOidCollections(oidCollections);
        return vciFileVolumeDO2VOs(vciFileVolumeDOList);
    }
 
    /**
    * 使用主键集合查询数据对象
    * @param oidCollections 主键的集合
    * @return 数据对象列表
    */
    private List<VciFileVolumeDO> listVciFileVolumeDOByOidCollections(Collection<String> oidCollections){
        List<VciFileVolumeDO> vciFileVolumeDOList = new ArrayList<>();
        if(!CollectionUtils.isEmpty(oidCollections)){
            Collection<Collection<String>> oidCollectionsList = VciBaseUtil.switchCollectionForOracleIn(oidCollections);
            oidCollectionsList.stream().forEach(oids ->{
                List<VciFileVolumeDO> tempDOList =  vciFileVolumeMapper.selectByPrimaryKeyCollection(oids);
                if(!CollectionUtils.isEmpty(tempDOList)){
                    vciFileVolumeDOList.addAll(tempDOList);
                }
            });
        }
        return  vciFileVolumeDOList;
    }
 
    /**
     * 启用文仓管理
     * @param vciFileVolumeDTO 文仓管理数据传输对象,oid和ts需要传输
     * @return 启用结果反馈::success:成功,fail:失败
     * @throws VciBaseException 执行出现异常时会抛出
     */
    @Override
    @VciChangeDocument(changeType = VciChangeDocumentTypeEnum.LCSTATUS)
    public BaseResult enableVciFileVolume(VciFileVolumeDTO vciFileVolumeDTO) throws VciBaseException {
        return changeLcStatus(vciFileVolumeDTO,false);
    }
 
    /**
     * 停用{comments}
     * @param vciFileVolumeDTO 文仓管理数据传输对象,oid和ts需要传输
     * @return 停用结果反馈::success:成功,fail:失败
     * @throws VciBaseException 执行出现异常时会抛出
     */
    @Override
    @VciChangeDocument(changeType = VciChangeDocumentTypeEnum.LCSTATUS)
    public BaseResult disableVciFileVolume(VciFileVolumeDTO vciFileVolumeDTO) throws VciBaseException {
        return changeLcStatus(vciFileVolumeDTO,true);
    }
 
    /**
     * 修改生命周期的状态,如停用和启用
     * @param vciFileVolumeDTO 文仓管理数据传输对象,必须要有oid和ts
     * @param disable 是否为停用
     * @return 执行的结果
     */
    private BaseResult changeLcStatus(VciFileVolumeDTO vciFileVolumeDTO, boolean disable){
        VciBaseUtil.alertNotNull(vciFileVolumeDTO,"数据对象",vciFileVolumeDTO.getOid(),"主键");
        VciFileVolumeDO vciFileVolumeDO = selectByOid(vciFileVolumeDTO.getOid());
        //老的项目的状态值不一样
        return BaseResult.success();
    }
 
 
    /**
     * 参照文仓管理列表
     * @param conditionMap 查询条件
     * @param pageHelper 分页和排序
     * @return 文仓管理显示对象列表,生效的内容
     * @throws VciBaseException 查询条件和分页出错的时候会抛出异常
     */
    @Override
    public DataGrid<VciFileVolumeVO> refDataGridVciFileVolume(Map<String, String> conditionMap, PageHelper pageHelper) throws VciBaseException {
        if(conditionMap == null){
            conditionMap = new HashMap<>();
        }
        conditionMap.put("lcStatus", FRAMEWORK_DATA_ENABLED);
        return gridVciFileVolume(conditionMap,pageHelper);
    }
 
    /**
     * 查询全部
     *
     * @return 文仓
     * @throws VciBaseException 查询会抛出异常
     */
    @Override
    public List<VciFileVolumeDO> selectAll() throws VciBaseException {
        return vciFileVolumeMapper.selectAll();
    }
 
    /**
     * 更新卷的使用容量
     *
     * @param oid        主键
     * @param usedVolume 使用容量
     * @return 受影响的行数
     */
    @Override
    public synchronized int updateUsedVolume(String oid, long usedVolume) {
        VciBaseUtil.alertNotNull(oid,"主键");
        return vciFileVolumeMapper.updateUsedVolume(oid,String.valueOf(usedVolume));
    }
 
    /**
     * 获取上传的默认卷
     * @return 卷对象
     */
    @Override
    public VciFileVolumeDO getUploadVolume(){
        try {
            PvolumeInfo volumeInfo = platformClientUtil.getFrameworkService().getDefaultVolume();
            VciFileVolumeDO fileVolumeDO = new VciFileVolumeDO();
            fileVolumeDO.setOid(volumeInfo.id);
            fileVolumeDO.setId(volumeInfo.name);
            fileVolumeDO.setName(volumeInfo.service);
            fileVolumeDO.setServiceUrl(volumeInfo.host);
            fileVolumeDO.setVolumePath(volumeInfo.path);
            fileVolumeDO.setServiceOsType(volumeInfo.type+"");
            return fileVolumeDO;
        } catch (PLException e) {
            throw new RuntimeException(e);
        }
    }
 
 
}