数据大屏

performance-web/src/main/java/com/clx/performance/dao/LargeScreenAddressRouteDao.java

@@ -5,6 +5,8 @@ import com.clx.performance.model.LargeScreenAddressRoute;
 import com.msl.common.base.Optional;
 import com.msl.common.dao.BaseDao;
 
+import java.util.List;
+
 /**
  * @author kavin
  * Date 2023-11-22
@@ -12,5 +14,5 @@ import com.msl.common.dao.BaseDao;
  */
 public interface LargeScreenAddressRouteDao extends BaseDao<LargeScreenAddressRouteMapper, LargeScreenAddressRoute, Integer> {
 
-    Optional<LargeScreenAddressRoute> getEntityByReceiveAddressIdAndSendAddressId(Integer receiveAddressId, Integer sendAddressId);
+    Optional<List<LargeScreenAddressRoute>> getEntityByReceiveAddressIdAndSendAddressId(Integer receiveAddressId, Integer sendAddressId);
 }

performance-web/src/main/java/com/clx/performance/dao/impl/LargeScreenAddressRouteDaoImpl.java

@@ -8,6 +8,8 @@ import com.msl.common.base.Optional;
 import com.msl.common.dao.impl.BaseDaoImpl;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 /**
  * @author kavin
  * Date 2023-11-22
@@ -17,8 +19,8 @@ import org.springframework.stereotype.Repository;
 public class LargeScreenAddressRouteDaoImpl extends BaseDaoImpl<LargeScreenAddressRouteMapper, LargeScreenAddressRoute, Integer> implements LargeScreenAddressRouteDao {
 
     @Override
-    public Optional<LargeScreenAddressRoute> getEntityByReceiveAddressIdAndSendAddressId(Integer receiveAddressId, Integer sendAddressId) {
-        return Optional.ofNullable(baseMapper.selectOne(lQrWrapper().eq(LargeScreenAddressRoute::getReceiveSystemAddressId, receiveAddressId)
+    public Optional<List<LargeScreenAddressRoute>> getEntityByReceiveAddressIdAndSendAddressId(Integer receiveAddressId, Integer sendAddressId) {
+        return Optional.ofNullable(baseMapper.selectList(lQrWrapper().eq(LargeScreenAddressRoute::getReceiveSystemAddressId, receiveAddressId)
                 .eq(LargeScreenAddressRoute::getSendSystemAddressId, sendAddressId)
         ));
 

performance-web/src/main/java/com/clx/performance/listener/LargeScreenListener.java

@@ -59,10 +59,9 @@ public class LargeScreenListener {
             String receiveName = orderVO.getReveiveAddressShorter();
             String sendName = orderVO.getSendAddressShorter();
 
-            Optional<LargeScreenAddressRoute> optional = largeScreenAddressRouteDao.getEntityByReceiveAddressIdAndSendAddressId(receiveAddressId, sendAddressId);
+            Optional<List<LargeScreenAddressRoute>> optional = largeScreenAddressRouteDao.getEntityByReceiveAddressIdAndSendAddressId(receiveAddressId, sendAddressId);
             if (optional.isPresent()) {
                 log.info("当前地址已经记录receiveAddressId{}, sendAddressId{}", receiveAddressId, sendAddressId);
-                return;
             } else {
                 ReceiveAndSendAddressVO feignAddressVO = Optional.of(addressFeign.getSendAndReceiveSystemAddress(sendAddressId, receiveAddressId)).filter(Result::succeed)
                         .map(Result::getData).orElseThrow(PerformanceResultEnum.DATA_NOT_FIND);
@@ -96,7 +95,7 @@ public class LargeScreenListener {
                         .receiveName(receiveName)
                         .sendName(sendName)
                         .build();
-                log.info("执行保存：{}", JSONUtil.parse(build));
+                log.info("执行保存==========================：{}", JSONUtil.parse(build));
                 largeScreenAddressRouteDao.saveEntity(build);
             }