[add] 绿波数据实时数据优化

wj-databus/src/main/java/net/wanji/databus/dao/mapper/GreenwaveRealtimeMapper.java

@@ -4,6 +4,7 @@ import feign.Param;
 import net.wanji.databus.dao.entity.GreenwaveRealtimePO;
 import org.springframework.stereotype.Repository;
 
+import java.util.Collection;
 import java.util.List;
 
 /**
@@ -17,4 +18,7 @@ public interface GreenwaveRealtimeMapper {
     int insertBatch(@Param("list") List<GreenwaveRealtimePO> list);
 
     int deleteOne(@Param("greenId") Integer greenId);
+
+    void deleteBatch(@Param("list") Collection<Integer> greenIds);
+
 }

wj-databus/src/main/resources/mapper/GreenwaveRealtimeMapper.xml

@@ -76,4 +76,12 @@
         </where>
     </delete>
 
+    <delete id="deleteBatch" parameterType="String">
+        delete from t_greenwave_realtime
+        where green_id in
+        <foreach collection="list" item="greenId" separator="," open="(" close=")">
+            #{greenId}
+        </foreach>
+    </delete>
+
 </mapper>