| package com.ruoyi.integration.controller; | 
|   | 
| import com.ruoyi.common.core.domain.R; | 
| import com.ruoyi.common.core.web.domain.AjaxResult; | 
| import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData; | 
| import com.ruoyi.integration.mongodb.service.UploadRealTimeMonitoringDataService; | 
| import io.swagger.annotations.Api; | 
| import io.swagger.annotations.ApiOperation; | 
| import org.springframework.web.bind.annotation.*; | 
|   | 
| import javax.annotation.Resource; | 
| import java.util.List; | 
|   | 
| /** | 
|  * <p> | 
|  *  前端控制器 | 
|  * </p> | 
|  * | 
|  * @author xiaochen | 
|  * @since 2024-08-07 | 
|  */ | 
| @RestController | 
| @RequestMapping("/uploadRealTimeMonitoringData") | 
| public class UploadRealTimeMonitoringDataController { | 
|     @Resource | 
|     private UploadRealTimeMonitoringDataService uploadRealTimeMonitoringDataService; | 
|   | 
|     /** | 
|      * 远程调用 通过订单流水号 查询订单详情 | 
|      * @param orderId | 
|      * @return | 
|      */ | 
|     @PostMapping(value = "/getOrderInfoByCode") | 
|     public R<UploadRealTimeMonitoringData> chargingOrderInfo(@RequestParam("orderId") String orderId){ | 
|         List<UploadRealTimeMonitoringData> dataByOrderCode = uploadRealTimeMonitoringDataService.getDataByOrderCode(orderId); | 
|         if(dataByOrderCode.size() > 0){ | 
|             UploadRealTimeMonitoringData uploadRealTimeMonitoringData = dataByOrderCode.get(dataByOrderCode.size() - 1); | 
|             return R.ok(uploadRealTimeMonitoringData); | 
|         } | 
|         return R.ok(); | 
|     } | 
|      | 
|      | 
|     /** | 
|      * 根据订单编号获取所有监测数据 | 
|      * @param code | 
|      * @return | 
|      */ | 
|     @PostMapping(value = "/getDataByOrderCode") | 
|     public R<List<UploadRealTimeMonitoringData>> getDataByOrderCode(@RequestParam("code") String code){ | 
|         List<UploadRealTimeMonitoringData> list = uploadRealTimeMonitoringDataService.getDataByOrderCode(code); | 
|         return R.ok(list); | 
|     } | 
|      | 
| } |