Browse Source

update config

supeng 20 hours ago
parent
commit
ac0644ea12

+ 25 - 0
supply-demand-engine-core/src/main/java/com/tzld/piaoquan/supply/demand/engine/service/TaskService.java

@@ -0,0 +1,25 @@
+package com.tzld.piaoquan.supply.demand.engine.service;
+
+/**
+ *
+ * @author supeng
+ */
+public interface TaskService {
+    /**
+     * 创建任务
+     * @param object
+     */
+    void create(Object object);
+
+    /**
+     * 任务调度
+     * @param object
+     */
+    void schedule(Object object);
+
+    /**
+     * 获取任务信息
+     * @param object
+     */
+    void get(Object object);
+}

+ 29 - 0
supply-demand-engine-core/src/main/java/com/tzld/piaoquan/supply/demand/engine/service/impl/TaskServiceImpl.java

@@ -0,0 +1,29 @@
+package com.tzld.piaoquan.supply.demand.engine.service.impl;
+
+import com.tzld.piaoquan.supply.demand.engine.service.TaskService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ * @author supeng
+ */
+@Slf4j
+@Service
+public class TaskServiceImpl implements TaskService {
+
+    @Override
+    public void create(Object object) {
+
+    }
+
+    @Override
+    public void schedule(Object object) {
+
+    }
+
+    @Override
+    public void get(Object object) {
+
+    }
+}

+ 1 - 0
supply-demand-engine-job/src/main/resources/application.yml

@@ -14,6 +14,7 @@ server:
     uri-encoding: UTF-8
     accept-count: 1000
   servlet:
+    context-path: /${spring.application.name}
     session:
       timeout: 60
 pagehelper:

+ 52 - 0
supply-demand-engine-service/src/main/java/com/tzld/piaoquan/supply/demand/engine/controller/TaskController.java

@@ -0,0 +1,52 @@
+package com.tzld.piaoquan.supply.demand.engine.controller;
+
+import com.tzld.piaoquan.supply.demand.engine.common.base.CommonRequest;
+import com.tzld.piaoquan.supply.demand.engine.common.base.CommonResponse;
+import com.tzld.piaoquan.supply.demand.engine.common.enums.ExceptionEnum;
+import com.tzld.piaoquan.supply.demand.engine.common.exception.CommonException;
+import com.tzld.piaoquan.supply.demand.engine.model.dto.BaseInfoDTO;
+import com.tzld.piaoquan.supply.demand.engine.service.TaskService;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+
+/**
+ *
+ * @author supeng
+ */
+@Slf4j
+@RestController
+@RequestMapping("/task")
+public class TaskController {
+
+    @Autowired
+    private TaskService taskService;
+
+    @ApiOperation(value = "创建任务", notes = "创建任务")
+    @PostMapping("/create")
+    public CommonResponse<String> create(@RequestBody CommonRequest<Map<String, String>> request) {
+        BaseInfoDTO baseInfo = request.getBaseInfo();
+        if (baseInfo == null) {
+            throw new CommonException(ExceptionEnum.PARAMS_INVALID);
+        }
+        taskService.create(baseInfo);
+        return CommonResponse.create();
+    }
+
+    @ApiOperation(value = "获取任务信息", notes = "获取任务信息")
+    @PostMapping("/get")
+    public CommonResponse<String> get(@RequestBody CommonRequest<Map<String, String>> request) {
+        BaseInfoDTO baseInfo = request.getBaseInfo();
+        if (baseInfo == null) {
+            throw new CommonException(ExceptionEnum.PARAMS_INVALID);
+        }
+        taskService.get(baseInfo);
+        return CommonResponse.create();
+    }
+}

+ 1 - 0
supply-demand-engine-service/src/main/resources/application.yml

@@ -14,6 +14,7 @@ server:
     uri-encoding: UTF-8
     accept-count: 1000
   servlet:
+    context-path: /${spring.application.name}
     session:
       timeout: 60
 pagehelper: