| | |
| | | package org.jeecg.modules.dry.controller; |
| | | |
| | | |
| | | import ai.djl.modality.Classifications; |
| | | import io.swagger.annotations.Api; |
| | | import io.swagger.annotations.ApiOperation; |
| | | import lombok.extern.slf4j.Slf4j; |
| | |
| | | |
| | | import org.jeecg.modules.dry.service.*; |
| | | |
| | | import org.jeecg.modules.dry.util.HerbUtil; |
| | | import org.jeecg.modules.dry.vo.CommandMessageVo; |
| | | import org.jeecg.modules.dry.vo.RealTimeDataVo; |
| | | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import java.io.InputStream; |
| | | import java.util.List; |
| | | |
| | | |
| | | @Api(tags = "实时数据处理控制器") |
| | |
| | | |
| | | @Autowired |
| | | private IDryRealTimeDataService dryRealTimeDataService; |
| | | |
| | | @Autowired |
| | | private HerbUtil herbUtil; |
| | | |
| | | |
| | | @ApiOperation(value="测试", notes="返回Hello") |
| | |
| | | public Result<?> sendCommand(@RequestBody CommandMessageVo msgVo) { |
| | | return dryRealTimeDataService.sendSocketMsg(msgVo); |
| | | } |
| | | |
| | | |
| | | @ApiOperation(value = "药材识别") |
| | | @PostMapping("/identify") |
| | | public Result<?> identify(@RequestParam("file") MultipartFile file) throws Exception { |
| | | try { |
| | | if (file.isEmpty()) { |
| | | throw new RuntimeException("上传文件不能为空"); |
| | | } |
| | | InputStream inputStream = file.getInputStream(); |
| | | List<Classifications.Classification> predict = herbUtil.predict(inputStream); |
| | | return Result.ok(predict); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | return Result.error("AI识别服务异常"); |
| | | } |
| | | } |
| | | |
| | | } |