| | |
|---|
| | | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | @PostMapping("/sendRealTimeDataJson") |
|---|
| | | public Result<?> realTimeDataJson(@RequestBody RealTimeDataVo realTimeDataVo) { |
|---|
| | | try { |
|---|
| | | if ("user".equals(mqttConfig.getRole())){ |
|---|
| | | if (mqttConfig.isEnable() && "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) { |
|---|
| | |
|---|
| | | // return Result.error("AI识别服务异常"); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据设备和租户查询该设备类型的干燥配方，将配方转成xml格式，以字符串方式返回 |
|---|
| | | * @param tenantId |
|---|
| | | * @param eqpCode |
|---|
| | | * @return |
|---|
| | | * @throws JAXBException |
|---|
| | | */ |
|---|
| | | @ApiOperation(value="干燥配方获取", notes="干燥配方下发") |
|---|
| | | @GetMapping(value = "/queryFormula") |
|---|
| | | public Result<String> queryFormulaByEqpType(Integer tenantId, String eqpCode) throws JAXBException { |
|---|
