| | |
| | | import com.ruoyi.common.core.controller.BaseController; |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | import com.ruoyi.common.core.page.TableDataInfo; |
| | | import com.ruoyi.web.component.RedisMqReceiver; |
| | | import com.smartor.domain.CommonTaskcallMQ; |
| | | import com.smartor.domain.SendTaskVO; |
| | | import com.smartor.domain.ServiceThirdData; |
| | | import com.smartor.service.CommonTaskService; |
| | |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.web.bind.annotation.PostMapping; |
| | | import org.springframework.web.bind.annotation.RequestBody; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | |
| | | |
| | | @Autowired |
| | | private CommonTaskService commonTaskService; |
| | | @Autowired |
| | | private RedisMqReceiver redisMqReceiver; |
| | | @Value("${localIP}") |
| | | private String localIP; |
| | | |
| | | /** |
| | | * 查询题目列表(义乌的his数据获取情况) |
| | |
| | | return toAjax(commonTaskService.taskSend(sendTaskVO)); |
| | | } |
| | | |
| | | /** |
| | | * 任务的发送执行、暂停、终止 |
| | | */ |
| | | @ApiOperation("任务的发送执行、暂停、终止") |
| | | @PostMapping("/tsakHandle") |
| | | public AjaxResult tsakHandle(@RequestBody CommonTaskcallMQ commonTaskcallMQ) { |
| | | redisMqReceiver.tsakHandle(commonTaskcallMQ, localIP, 1); |
| | | return toAjax(1); |
| | | } |
| | | |
| | | } |