|
|
@@ -1,28 +1,27 @@
|
|
|
-package com.tzld.piaoquan.supply.demand.engine.service.impl;
|
|
|
+package com.tzld.piaoquan.sde.service.impl;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.common.base.CommonRequest;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.common.base.Constant;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.common.enums.ExceptionEnum;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.common.enums.IsDeleteEnum;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.common.enums.TaskStatusEnum;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.common.enums.TaskTypeEnum;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.common.exception.CommonException;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.dao.mapper.SdStrategyMapper;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.dao.mapper.SdTaskMapper;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.model.param.TaskCreateParam;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.model.param.TaskGetParam;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.model.param.TaskListParam;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.model.po.SdStrategy;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.model.po.SdTask;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.model.vo.SdTaskVO;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.service.TaskService;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.util.DateUtil;
|
|
|
-import com.tzld.piaoquan.supply.demand.engine.util.IdGeneratorUtil;
|
|
|
+import com.tzld.piaoquan.sde.common.api.CommonRequest;
|
|
|
+import com.tzld.piaoquan.sde.common.constant.Constant;
|
|
|
+import com.tzld.piaoquan.sde.common.enums.ExceptionEnum;
|
|
|
+import com.tzld.piaoquan.sde.common.enums.IsDeleteEnum;
|
|
|
+import com.tzld.piaoquan.sde.common.enums.TaskStatusEnum;
|
|
|
+import com.tzld.piaoquan.sde.common.enums.TaskTypeEnum;
|
|
|
+import com.tzld.piaoquan.sde.common.exception.BizException;
|
|
|
+import com.tzld.piaoquan.sde.dao.mapper.SdStrategyMapper;
|
|
|
+import com.tzld.piaoquan.sde.dao.mapper.SdTaskMapper;
|
|
|
+import com.tzld.piaoquan.sde.model.request.TaskCreateParam;
|
|
|
+import com.tzld.piaoquan.sde.model.request.TaskGetParam;
|
|
|
+import com.tzld.piaoquan.sde.model.request.TaskListParam;
|
|
|
+import com.tzld.piaoquan.sde.model.entity.SdStrategy;
|
|
|
+import com.tzld.piaoquan.sde.model.entity.SdTask;
|
|
|
+import com.tzld.piaoquan.sde.model.vo.SdTaskVO;
|
|
|
+import com.tzld.piaoquan.sde.service.TaskService;
|
|
|
+import com.tzld.piaoquan.sde.util.DateUtil;
|
|
|
+import com.tzld.piaoquan.sde.util.IdGeneratorUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
-import org.apache.kafka.common.protocol.types.Field;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
@@ -66,18 +65,18 @@ public class TaskServiceImpl implements TaskService {
|
|
|
wrapper.eq(SdStrategy::getId, strategyId).eq(SdStrategy::getIsDeleted, IsDeleteEnum.NORMAL.getValue());
|
|
|
boolean strategyIdExists = sdStrategyMapper.exists(wrapper);
|
|
|
if (!strategyIdExists) {
|
|
|
- throw new CommonException(ExceptionEnum.DATA_NOT_EXIST, "该策略不存在");
|
|
|
+ throw new BizException(ExceptionEnum.DATA_NOT_EXIST, "该策略不存在");
|
|
|
}
|
|
|
sdTask.setStrategyId(params.getStrategyId());
|
|
|
TaskTypeEnum taskTypeEnum = TaskTypeEnum.getInstance(params.getTaskType());
|
|
|
if (Objects.isNull(taskTypeEnum)) {
|
|
|
- throw new CommonException(ExceptionEnum.NOT_SUPPORT_TASK_TYPE);
|
|
|
+ throw new BizException(ExceptionEnum.NOT_SUPPORT_TASK_TYPE);
|
|
|
}
|
|
|
sdTask.setTaskType(params.getTaskType());
|
|
|
sdTask.setTaskStatus(TaskStatusEnum.INIT.getValue());
|
|
|
int flag = sdTaskMapper.insert(sdTask);
|
|
|
if (flag <= 0) {
|
|
|
- throw new CommonException(ExceptionEnum.DATA_INSERT_ERROR);
|
|
|
+ throw new BizException(ExceptionEnum.DATA_INSERT_ERROR);
|
|
|
}
|
|
|
}
|
|
|
|