|
@@ -0,0 +1,148 @@
|
|
|
|
+package com.taais.biz.service.impl;
|
|
|
|
+
|
|
|
|
+import java.util.Arrays;
|
|
|
|
+import java.util.List;
|
|
|
|
+
|
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
|
+import com.mybatisflex.core.paginate.Page;
|
|
|
|
+import com.mybatisflex.core.query.QueryWrapper;
|
|
|
|
+import com.taais.common.core.utils.MapstructUtils;
|
|
|
|
+import com.taais.common.core.utils.StringUtils;
|
|
|
|
+import com.taais.common.orm.core.page.PageQuery;
|
|
|
|
+import com.taais.common.core.core.page.PageResult;
|
|
|
|
+import com.taais.common.orm.core.service.impl.BaseServiceImpl;
|
|
|
|
+import jakarta.annotation.Resource;
|
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
|
+import com.taais.biz.mapper.TrackSequenceMapper;
|
|
|
|
+import com.taais.biz.domain.TrackSequence;
|
|
|
|
+import com.taais.biz.domain.bo.TrackSequenceBo;
|
|
|
|
+import com.taais.biz.domain.vo.TrackSequenceVo;
|
|
|
|
+import com.taais.biz.service.ITrackSequenceService;
|
|
|
|
+import static com.taais.biz.domain.table.TrackSequenceTableDef.TRACK_SEQUENCE;
|
|
|
|
+
|
|
|
|
+/**
|
|
|
|
+ * 注视轨迹序列Service业务层处理
|
|
|
|
+ *
|
|
|
|
+ * @author wangkang
|
|
|
|
+ * 2024-09-22
|
|
|
|
+ */
|
|
|
|
+@Service
|
|
|
|
+public class TrackSequenceServiceImpl extends BaseServiceImpl<TrackSequenceMapper, TrackSequence> implements ITrackSequenceService {
|
|
|
|
+ @Resource
|
|
|
|
+ private TrackSequenceMapper trackSequenceMapper;
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public QueryWrapper query() {
|
|
|
|
+ return super.query().from(TRACK_SEQUENCE);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private QueryWrapper buildQueryWrapper(TrackSequenceBo trackSequenceBo) {
|
|
|
|
+ QueryWrapper queryWrapper = super.buildBaseQueryWrapper();
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.NAME.like
|
|
|
|
+ (trackSequenceBo.getName()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.STATUS.eq
|
|
|
|
+ (trackSequenceBo.getStatus()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.START_TIME.eq
|
|
|
|
+ (trackSequenceBo.getStartTime()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.END_TIME.eq
|
|
|
|
+ (trackSequenceBo.getEndTime()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.COST_SECOND.eq
|
|
|
|
+ (trackSequenceBo.getCostSecond()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.LOG.eq
|
|
|
|
+ (trackSequenceBo.getLog()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.REMARKS.eq
|
|
|
|
+ (trackSequenceBo.getRemarks()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.URL.eq
|
|
|
|
+ (trackSequenceBo.getUrl()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.INPUT_OSS_ID.eq
|
|
|
|
+ (trackSequenceBo.getInputOssId()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.INPUT_PATH.eq
|
|
|
|
+ (trackSequenceBo.getInputPath()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.OUTPUT_PATH.eq
|
|
|
|
+ (trackSequenceBo.getOutputPath()));
|
|
|
|
+ queryWrapper.and(TRACK_SEQUENCE.ZIP_FILE_PATH.eq
|
|
|
|
+ (trackSequenceBo.getZipFilePath()));
|
|
|
|
+
|
|
|
|
+ return queryWrapper;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 查询注视轨迹序列
|
|
|
|
+ *
|
|
|
|
+ * @param id 注视轨迹序列主键
|
|
|
|
+ * @return 注视轨迹序列
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ public TrackSequenceVo selectById(Long id) {
|
|
|
|
+ return this.getOneAs(query().where(TRACK_SEQUENCE.ID.eq(id)), TrackSequenceVo.class);
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 查询注视轨迹序列列表
|
|
|
|
+ *
|
|
|
|
+ * @param trackSequenceBo 注视轨迹序列Bo
|
|
|
|
+ * @return 注视轨迹序列集合
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ public List<TrackSequenceVo> selectList(TrackSequenceBo trackSequenceBo) {
|
|
|
|
+ QueryWrapper queryWrapper = buildQueryWrapper(trackSequenceBo);
|
|
|
|
+ return this.listAs(queryWrapper, TrackSequenceVo.class);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 分页查询注视轨迹序列列表
|
|
|
|
+ *
|
|
|
|
+ * @param trackSequenceBo 注视轨迹序列Bo
|
|
|
|
+ * @return 分页注视轨迹序列集合
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ public PageResult<TrackSequenceVo> selectPage(TrackSequenceBo trackSequenceBo) {
|
|
|
|
+ QueryWrapper queryWrapper = buildQueryWrapper(trackSequenceBo);
|
|
|
|
+ Page<TrackSequenceVo> page = this.pageAs(PageQuery.build(), queryWrapper, TrackSequenceVo.class);
|
|
|
|
+ return PageResult.build(page);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 新增注视轨迹序列
|
|
|
|
+ *
|
|
|
|
+ * @param trackSequenceBo 注视轨迹序列Bo
|
|
|
|
+ * @return 结果:true 操作成功,false 操作失败
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ public boolean insert(TrackSequenceBo trackSequenceBo) {
|
|
|
|
+ TrackSequence trackSequence =MapstructUtils.convert(trackSequenceBo, TrackSequence. class);
|
|
|
|
+
|
|
|
|
+ return this.save(trackSequence);//使用全局配置的雪花算法主键生成器生成ID值
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 修改注视轨迹序列
|
|
|
|
+ *
|
|
|
|
+ * @param trackSequenceBo 注视轨迹序列Bo
|
|
|
|
+ * @return 结果:true 更新成功,false 更新失败
|
|
|
|
+ */
|
|
|
|
+ @Override
|
|
|
|
+ public boolean update(TrackSequenceBo trackSequenceBo) {
|
|
|
|
+ TrackSequence trackSequence =MapstructUtils.convert(trackSequenceBo, TrackSequence. class);
|
|
|
|
+ if (ObjectUtil.isNotNull(trackSequence) && ObjectUtil.isNotNull(trackSequence.getId())){
|
|
|
|
+ boolean updated = this.updateById(trackSequence);
|
|
|
|
+ return updated;
|
|
|
|
+ }
|
|
|
|
+ return false;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 批量删除注视轨迹序列
|
|
|
|
+ *
|
|
|
|
+ * @param ids 需要删除的注视轨迹序列主键集合
|
|
|
|
+ * @return 结果:true 删除成功,false 删除失败
|
|
|
|
+ */
|
|
|
|
+ @Transactional
|
|
|
|
+ @Override
|
|
|
|
+ public boolean deleteByIds(Long[] ids) {
|
|
|
|
+ return this.removeByIds(Arrays.asList(ids));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+}
|