MQ置信度接口开发

business-service/src/main/java/com/ozs/service/service/CameraLogDetailService.java

@@ -9,4 +9,5 @@ import com.ozs.service.entity.CameraLogDetail;
  * @creat 2023/4/25
  */
 public interface CameraLogDetailService extends IService<CameraLogDetail> {
+    void updateAccessories(String deviceSn, Integer code);
 }

business-service/src/main/java/com/ozs/service/service/CameraUpdateLogService.java

@@ -17,6 +17,4 @@ public interface CameraUpdateLogService extends IService<CameraUpdateLog> {
     List<CameraUpdateLog> selectDetail(CameraUpdateLogResp cameraUpdateLogResp);
 
     IPage listToPage(List list, int pageNum, int pageSize);
-
-    void updateAccessories(String deviceSn, Integer code);
 }

business-service/src/main/java/com/ozs/service/service/impl/CameraLogDetailServiceImpl.java

@@ -1,13 +1,17 @@
 package com.ozs.service.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ozs.service.entity.CameraLogDetail;
 import com.ozs.service.entity.CameraUpdateLog;
 import com.ozs.service.mapper.CameraLogDetailMapper;
 import com.ozs.service.mapper.CameraUpdateLogMapper;
 import com.ozs.service.service.CameraLogDetailService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * @author wyy
  * @subject
@@ -15,4 +19,23 @@ import org.springframework.stereotype.Service;
  */
 @Service
 public class CameraLogDetailServiceImpl extends ServiceImpl<CameraLogDetailMapper, CameraLogDetail> implements CameraLogDetailService {
+    
+    @Autowired
+    CameraLogDetailMapper cameraLogDetailMapper;
+    
+    @Override
+    public  void updateAccessories(String deviceSn, Integer code){
+        LambdaQueryWrapper<CameraLogDetail> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(CameraLogDetail::getCameraCode, deviceSn);
+        wrapper.orderByDesc(CameraLogDetail::getUpdateTime);
+        List<CameraLogDetail> list = cameraLogDetailMapper.selectList(wrapper);
+        CameraLogDetail cameraUpdateLog = list.get(0);
+        if (200==code){
+            cameraUpdateLog.setStatus(1);
+            cameraLogDetailMapper.updateById(cameraUpdateLog);
+        }else if (400==code){
+            cameraUpdateLog.setStatus(3);
+            cameraLogDetailMapper.updateById(cameraUpdateLog);
+        }
+    }
 }

business-service/src/main/java/com/ozs/service/service/impl/CameraUpdateLogServiceImpl.java

@@ -44,20 +44,4 @@ public class CameraUpdateLogServiceImpl extends ServiceImpl<CameraUpdateLogMappe
         page.setTotal(list.size());
         return page;
     }
-
-  
-    public  void updateAccessories(String deviceSn, Integer code){
-        LambdaQueryWrapper<CameraUpdateLog> wrapper = new LambdaQueryWrapper<>();
-        wrapper.eq(CameraUpdateLog::getCameraCode, deviceSn);
-        wrapper.orderByDesc(CameraUpdateLog::getCreateTime);
-        List<CameraUpdateLog> list = cameraUpdateLogMapper.selectList(wrapper);
-        CameraUpdateLog cameraUpdateLog = list.get(0);
-        if (200==code){
-            cameraUpdateLog.setStatus(1);
-            cameraUpdateLogMapper.updateById(cameraUpdateLog);
-        }else if (400==code){
-            cameraUpdateLog.setStatus(3);
-            cameraUpdateLogMapper.updateById(cameraUpdateLog);
-        }
-    }
 }

business-service/src/main/java/com/ozs/service/utils/CallbackUtil.java

@@ -1,6 +1,7 @@
 package com.ozs.service.utils;
 
 
+import com.ozs.service.service.CameraLogDetailService;
 import com.ozs.service.service.CameraUpdateLogService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -19,16 +20,16 @@ import javax.annotation.PostConstruct;
 @Component
 public class CallbackUtil {
     @Autowired
-    CameraUpdateLogService cameraUpdateLogService;
-    private static  CameraUpdateLogService cameraUpdateLog;
+    CameraLogDetailService cameraLogDetailService;
+    private static  CameraLogDetailService cameraLogDetail;
 
 
     @PostConstruct
     public void init() {
-       cameraUpdateLog = cameraUpdateLogService;
+        cameraLogDetail = cameraLogDetailService;
     }
     
     public static void  callback(String deviceSn,Integer code){
-        CallbackUtil.cameraUpdateLog.updateAccessories(deviceSn,code);
+        CallbackUtil.cameraLogDetail.updateAccessories(deviceSn,code);
     }
 }