| | |
|---|
| | | |
|---|
| | | import ai.djl.modality.Classifications; |
|---|
| | | import cn.hutool.core.bean.BeanUtil; |
|---|
| | | import cn.hutool.core.thread.ThreadUtil; |
|---|
| | | import com.alibaba.druid.support.json.JSONUtils; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import io.swagger.annotations.Api; |
|---|
| | | import io.swagger.annotations.ApiOperation; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.eclipse.paho.client.mqttv3.MqttException; |
|---|
| | | import org.eclipse.paho.client.mqttv3.MqttMessage; |
|---|
| | | import org.jeecg.common.api.vo.Result; |
|---|
| | | |
|---|
| | | import org.jeecg.common.config.TenantContext; |
|---|
| | | import org.jeecg.common.constant.MqttConstant; |
|---|
| | | import org.jeecg.common.system.query.QueryGenerator; |
|---|
| | | import org.jeecg.common.util.IpUtils; |
|---|
| | | import org.jeecg.common.util.SpringContextUtils; |
|---|
| | | import org.jeecg.common.util.oConvertUtils; |
|---|
| | | import org.jeecg.config.mybatis.MybatisPlusSaasConfig; |
|---|
| | | import org.jeecg.modules.dry.entity.*; |
|---|
| | | import org.jeecg.modules.dry.mqtt.MqttConfig; |
|---|
| | | import org.jeecg.modules.dry.mqtt.MqttUtil; |
|---|
| | | import org.jeecg.modules.dry.service.*; |
|---|
| | | |
|---|
| | | //import org.jeecg.modules.dry.util.HerbUtil; |
|---|
| | |
|---|
| | | // private HerbUtil herbUtil; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private MqttUtil mqttUtil; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private MqttConfig mqttConfig; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IDryHerbInfoService herbInfoService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | |
|---|
| | | @ApiOperation(value="接收实时数据Json", notes="设备实时数据上传") |
|---|
| | | @PostMapping("/sendRealTimeDataJson") |
|---|
| | | public Result<?> realTimeDataJson(@RequestBody RealTimeDataVo realTimeDataVo) { |
|---|
| | | public Result<?> realTimeDataJson(@RequestBody RealTimeDataVo realTimeDataVo) { |
|---|
| | | try { |
|---|
| | | if ("user".equals(mqttConfig.getRole())){ |
|---|
| | | MqttMessage mqttMessage = new MqttMessage(); |
|---|
| | | mqttMessage.setQos(0); |
|---|
| | | mqttMessage.setPayload(JSONObject.toJSONString(realTimeDataVo).getBytes()); |
|---|
| | | mqttUtil.getMqttClient().publish(MqttConstant.TENANT_UP_PREFIX_REALTIME_DATA,mqttMessage); |
|---|
| | | //处理故障信息 |
|---|
| | | dryRealTimeDataService.fitFultRecord(realTimeDataVo); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } catch (MqttException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return dryRealTimeDataService.realTimeDataHandle(realTimeDataVo); |
|---|
| | | } |
|---|
| | | |
|---|
