线路预警

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

@@ -541,11 +541,15 @@ public class OrderChildDaoImpl extends BaseDaoImpl<OrderChildMapper, OrderChild,
 
     @Override
     public Integer loadTimeAvg(Integer sendAddressId, Integer receiveAddressId, Integer sendSystemAddressId, Integer receiveSystemAddressId, String beginTime) {
-        return 0;
+        return baseMapper.loadTimeAvg(sendAddressId,receiveAddressId,
+                sendSystemAddressId,receiveSystemAddressId,
+                beginTime);
     }
 
     @Override
     public Integer unloadTimeAvg(Integer sendAddressId, Integer receiveAddressId, Integer sendSystemAddressId, Integer receiveSystemAddressId, String beginTime) {
-        return 0;
+        return baseMapper.unloadTimeAvg(sendAddressId,receiveAddressId,
+                sendSystemAddressId,receiveSystemAddressId,
+                beginTime);
     }
 }

performance-web/src/main/java/com/clx/performance/mapper/OrderChildMapper.java

@@ -22,6 +22,7 @@ import java.util.List;
 
 @Mapper
 public interface OrderChildMapper extends BaseMapper<OrderChild> {
+    String TABLE = "order_child";
 
     /**
      * 司机运单列表
@@ -85,4 +86,32 @@ public interface OrderChildMapper extends BaseMapper<OrderChild> {
 
     @SelectProvider(type = OrderChildSqlProvider.class, method = "getLossNet")
     List<Double> getLossNet(@Param("param") OrderChildReportParam param);
+
+    @Select("<script>" +
+            "select avg(TIMESTAMPDIFF(SECOND,arrive_send_time,load_time)) from " + TABLE +
+            " where load_time is not null and pay_time &gt;= #{beginTime} " +
+            " <if test = 'sendSystemAddressId != null'>and send_system_address_id = #{sendSystemAddressId} </if> " +
+            " <if test = 'receiveSystemAddressId != null'>and receive_system_address_id = #{receiveSystemAddressId} </if> " +
+
+            " <if test = 'sendSystemAddressId == null'>and send_address_id = #{sendAddressId} </if> " +
+            " <if test = 'receiveSystemAddressId == null'>and receive_address_id = #{receiveAddressId} </if> " +
+            " </script>")
+
+    Integer loadTimeAvg(Integer sendAddressId, Integer receiveAddressId,
+                        Integer sendSystemAddressId, Integer receiveSystemAddressId,
+                        String beginTime);
+
+    @Select("<script>" +
+            "select avg(TIMESTAMPDIFF(SECOND,arrive_receive_time,unload_time)) from " + TABLE +
+            " where unload_time is not null and pay_time &gt;= #{beginTime} " +
+            " <if test = 'sendSystemAddressId != null'>and send_system_address_id = #{sendSystemAddressId} </if> " +
+            " <if test = 'receiveSystemAddressId != null'>and receive_system_address_id = #{receiveSystemAddressId} </if> " +
+
+            " <if test = 'sendSystemAddressId == null'>and send_address_id = #{sendAddressId} </if> " +
+            " <if test = 'receiveSystemAddressId == null'>and receive_address_id = #{receiveAddressId} </if> " +
+            " </script>")
+
+    Integer unloadTimeAvg(Integer sendAddressId, Integer receiveAddressId,
+                          Integer sendSystemAddressId, Integer receiveSystemAddressId,
+                          String beginTime);
 }
\ No newline at end of file