数据大屏相关接口

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

@@ -25,6 +25,7 @@ import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.geo.GeoJsonLineString;
 import org.springframework.data.mongodb.core.geo.GeoJsonPoint;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
@@ -44,6 +45,7 @@ public class LargeScreenListener {
 
     private final MongoTemplate mongoTemplate;
 
+    @Transactional(rollbackFor = Exception.class)
     @RabbitListener(queues = RabbitKeyConstants.ORDER_LARGE_SCREEN_QUEUE)
     public void onMessage(String message) {
         try {
@@ -86,22 +88,20 @@ public class LargeScreenListener {
                 points.add(geoJsonPoint);
             }
             mongoEntity.setGeometry(new GeoJsonLineString(points));
-
-
             mongoTemplate.insert(mongoEntity);
+            LargeScreenAddressRoute build = LargeScreenAddressRoute.builder().
+                    receiveSystemAddressId(receiveAddressId)
+                    .sendSystemAddressId(receiveAddressId)
+                    .receiveName(receiveName)
+                    .sendName(sendName)
+                    .build();
+            largeScreenAddressRouteDao.saveEntity(build);
 
         } catch (Exception e) {
-
+            log.info("数据大屏监控订单轨迹线路异常:{}", e.getMessage());
         }
 
 
-//        LargeScreenAddressRoute build = LargeScreenAddressRoute.builder().receiveSystemAddressId(receiveAddressId)
-//                .sendSystemAddressId(receiveAddressId)
-//                .receiveName(receiveName)
-//                .sendName(sendName)
-//                .line("").build();
-//
-//        largeScreenAddressRouteDao.saveEntity(build);
     }
 
 

performance-web/src/main/java/com/clx/performance/model/LargeScreenAddressRoute.java

@@ -7,6 +7,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
 import com.msl.common.config.KeyColumn;
 import com.msl.common.model.HasKey;
 import io.swagger.annotations.ApiModelProperty;
+import lombok.Builder;
+import lombok.Data;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.experimental.Accessors;
@@ -16,10 +18,10 @@ import lombok.experimental.Accessors;
  * Date 2023-11-22
  * Time 10:54
  */
-@Getter
-@Setter
 @Accessors(chain = true)
 @TableName("large_screen_address_route")
+@Data
+@Builder
 public class LargeScreenAddressRoute implements HasKey<Integer> {
 
     @TableId(value = "id", type = IdType.AUTO)
@@ -41,26 +43,6 @@ public class LargeScreenAddressRoute implements HasKey<Integer> {
     @ApiModelProperty("发货标准地址id")
     private Integer sendSystemAddressId;
 
-    @TableField("value")
-    @ApiModelProperty("数据大屏展示需要")
-    private String value;
-
-    @TableField("size_field")
-    @ApiModelProperty("数据大屏展示需要")
-    private String sizeField;
-
-    @TableField("color_field")
-    @ApiModelProperty("数据大屏展示需要")
-    private String colorField;
-
-    @TableField("info")
-    @ApiModelProperty("数据大屏展示需要")
-    private String info;
-
-    @TableField("line")
-    @ApiModelProperty("数据大屏展示需要")
-    private String line;
-
     @Override
     @KeyColumn("id")
     public Integer gainKey() {

performance-web/src/main/java/com/clx/performance/service/impl/LargeScreenServiceImpl.java

@@ -189,6 +189,8 @@ public class LargeScreenServiceImpl implements LargeScreenService {
         MongoLargeScreenAddressRoute route = routes.get(randomNum);
         GeoJsonLineString geometry = route.getGeometry();
         jsonObject.set("id", "1");
+        jsonObject.set("sendSystemAddressId", route.getSendSystemAddressId());
+        jsonObject.set("receiveSystemAddressId", route.getReceiveSystemAddressId());
         jsonObject.set("name", route.getName());
         jsonObject.set("value", route.getValue());
         jsonObject.set("sizeField", "3");