initial v1.3.0

sean.zhou

2022-11-18 56df98ce4952239fbf7d0e99dbeb0e5c71531d6f

 src/main/java/com/dji/sample/wayline/service/IWaylineJobService.java

@@ -2,10 +2,14 @@

import com.dji.sample.common.model.CustomClaim;
import com.dji.sample.common.model.PaginationData;
import com.dji.sample.common.model.ResponseResult;
import com.dji.sample.component.mqtt.model.CommonTopicReceiver;
import com.dji.sample.wayline.model.dto.WaylineJobDTO;
import com.dji.sample.wayline.model.param.CreateJobParam;
import org.springframework.messaging.MessageHeaders;

import java.sql.SQLException;
import java.util.Collection;
import java.util.Optional;

/**
@@ -16,20 +20,36 @@
public interface IWaylineJobService {

    /**
     * Create a wayline mission for the dock.
     * Create wayline job in the database.
     * @param param
     * @param customClaim user info
     * @param customClaim   user info
     * @return
     */
    Boolean createJob(CreateJobParam param, CustomClaim customClaim) throws SQLException;
    Optional<WaylineJobDTO> createWaylineJob(CreateJobParam param, CustomClaim customClaim);

    /**
     * Issue wayline mission to the dock for execution.
     * @param workspaceId
     * @param jobId
     * Issue wayline mission to the dock.
     * @param param
     * @param customClaim   user info
     * @return
     */
    void publishFlightTask(String workspaceId, String jobId) throws SQLException;
    ResponseResult publishFlightTask(CreateJobParam param, CustomClaim customClaim) throws SQLException;

    /**
     * Execute the task immediately.
     * @param jobId
     * @throws SQLException
     * @return
     */
    Boolean executeFlightTask(String jobId);

    /**
     * Cancel the task Base on job Ids.
     * @param workspaceId
     * @param jobIds
     * @throws SQLException
     */
    void cancelFlightTask(String workspaceId, Collection<String> jobIds);

    /**
     * Query job information based on job id.
@@ -53,4 +73,11 @@
     * @return
     */
    PaginationData<WaylineJobDTO> getJobsByWorkspaceId(String workspaceId, long page, long pageSize);

    /**
     * Process to get interface data of flight mission resources.
     * @param receiver
     * @param headers
     */
    void flightTaskResourceGet(CommonTopicReceiver receiver, MessageHeaders headers);
}