服务统计与事件删除相关调度记录

zc-business/src/main/java/com/zc/business/controller/DcPublishManageController.java

@@ -142,4 +142,19 @@ public class DcPublishManageController extends BaseController
         }
         return AjaxResult.success(dcPublishManageService.monthTrendsPublishManage(dcPublishManage));
     }
+    //统计服务,事件类型对应的发布渠道发布的数量
+    @PostMapping("/eventTypePublishManageSum")
+    public AjaxResult eventTypePublishManageSum()
+    {
+        return AjaxResult.success(dcPublishManageService.eventTypePublishManageSum());
+    }
+    //统计服务,事件类型对应的发布渠道发布的数量按月统计
+    @PostMapping("/eventTypePublishManageMonth")
+    public AjaxResult eventTypePublishManageMonth(@RequestBody DcPublishManage dcPublishManage)
+    {
+        if (dcPublishManage==null||dcPublishManage.getPublishTime()==null){
+            return AjaxResult.error("参数错误");
+        }
+        return AjaxResult.success(dcPublishManageService.eventTypePublishManageMonth(dcPublishManage));
+    }
 }

zc-business/src/main/java/com/zc/business/mapper/DcPublishManageMapper.java

@@ -55,6 +55,8 @@ public interface DcPublishManageMapper
     int deleteDcPublishManageById(Long id);
     //删除事件发布记录 params 事件id
     int deleteDcPublishManageEventId(String eventId);
+    //删除调度记录
+    int deleteDisPath(String eventId);
     /**
      * 批量删除信息发布管理记录
      * 
@@ -76,4 +78,8 @@ public interface DcPublishManageMapper
     public List<HashMap<String,Object>> releaseTrendsPublishManage();
     //统计月发布趋势分析
     public List<HashMap<String,Object>> monthTrendsPublishManage(DcPublishManage dcPublishManage);
+    //统计不同事件的发布渠道数量
+    public List<HashMap<String,Object>> eventTypePublishManageSum();
+    //统计不同事件的发布渠道数量(月统计)
+    public List<HashMap<String,Object>> eventTypePublishManageMonth(DcPublishManage dcPublishManage);
 }

zc-business/src/main/java/com/zc/business/service/IDcPublishManageService.java

@@ -68,4 +68,8 @@ public interface IDcPublishManageService
     public List<HashMap<String,Object>> releaseTrendsPublishManage();
     //统计月发布趋势分析
     public List<HashMap<String,Object>> monthTrendsPublishManage(DcPublishManage dcPublishManage);
+    //统计不同事件的发布渠道数量
+    public List<HashMap<String,Object>> eventTypePublishManageSum();
+    //统计不同事件的发布渠道数量(月统计)
+    public List<HashMap<String,Object>> eventTypePublishManageMonth(DcPublishManage dcPublishManage);
 }

zc-business/src/main/java/com/zc/business/service/impl/DcPublishManageServiceImpl.java

@@ -130,4 +130,14 @@ public class DcPublishManageServiceImpl implements IDcPublishManageService
     public List<HashMap<String, Object>> monthTrendsPublishManage(DcPublishManage dcPublishManage) {
         return dcPublishManageMapper.monthTrendsPublishManage(dcPublishManage);
     }
+    //统计不同事件的发布渠道数量
+    @Override
+    public List<HashMap<String, Object>> eventTypePublishManageSum() {
+        return dcPublishManageMapper.eventTypePublishManageSum();
+    }
+    //统计不同事件的发布渠道数量(月统计)
+    @Override
+    public List<HashMap<String, Object>> eventTypePublishManageMonth(DcPublishManage dcPublishManage) {
+        return dcPublishManageMapper.eventTypePublishManageMonth(dcPublishManage);
+    }
 }

zc-business/src/main/resources/mapper/business/DcPublishManageMapper.xml

@@ -194,6 +194,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             #{id}
         </foreach>
     </delete>
+    <delete id="deleteDisPath">
+        delete dc_dispatch,dc_dispatch_resource
+        from dc_dispatch_resource
+        JOIN dc_dispatch  on dc_dispatch_resource.dispatch_id=dc_dispatch.id
+        WHERE dc_dispatch.event_id=#{eventId}
+
+    </delete>
 
     <select id="statisticsPublishManage" resultType="java.util.HashMap">
         SELECT
@@ -277,4 +284,59 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         ) AS m ON h.hour = m.hour AND pc.publish_channels = m.publish_channels
         ORDER BY h.hour, pc.publish_channels;
     </select>
+    <select id="eventTypePublishManageSum" resultType="java.util.HashMap">
+        SELECT h.eventType,
+               pc.publish_channels      publishChannels,
+               COALESCE(m.number, 0) AS number
+        FROM (
+                 SELECT 1 AS eventType
+                 UNION ALL
+                 SELECT 2 UNION ALL   SELECT 3 UNION ALL SELECT 4 UNION ALL
+                 SELECT 5 UNION ALL SELECT 6 UNION ALL SELECT 7 UNION ALL
+                 SELECT 8 UNION ALL SELECT 9 UNION ALL  SELECT 10 UNION ALL
+                 SELECT 11
+             ) AS h
+                 CROSS JOIN (
+            SELECT 1 AS publish_channels
+            UNION ALL SELECT 2 UNION ALL SELECT 3 UNION ALL SELECT 4 UNION ALL
+            SELECT 5 UNION ALL SELECT 6 UNION ALL
+            SELECT 7
+        ) AS pc
+                 LEFT JOIN (
+            SELECT publish_channels ,dc_event.event_type eventType,  COUNT(*)AS number
+            FROM dc_publish_manage
+            LEFT JOIN dc_event on dc_publish_manage.event_id=dc_event.id
+            GROUP BY HOUR(publish_time), publish_channels
+        ) AS m ON h.eventType = m.eventType AND pc.publish_channels = m.publish_channels
+        ORDER BY h.eventType, pc.publish_channels;
+    </select>
+    <select id="eventTypePublishManageMonth" resultType="java.util.HashMap">
+        SELECT h.eventType,
+               pc.publish_channels      publishChannels,
+               COALESCE(m.number, 0) AS number
+        FROM (
+                 SELECT 1 AS eventType
+                 UNION ALL
+                 SELECT 2 UNION ALL   SELECT 3 UNION ALL
+                 SELECT 4 UNION ALL SELECT 5 UNION ALL SELECT 6 UNION ALL
+                 SELECT 7 UNION ALL SELECT 8 UNION ALL SELECT 9 UNION ALL
+                 SELECT 10 UNION ALL
+                 SELECT 11
+             ) AS h
+                 CROSS JOIN (
+            SELECT 1 AS publish_channels
+            UNION ALL SELECT 2 UNION ALL SELECT 3 UNION ALL SELECT 4 UNION ALL
+            SELECT 5 UNION ALL SELECT 6 UNION ALL
+            SELECT 7
+        ) AS pc
+                 LEFT JOIN (
+            SELECT publish_channels ,dc_event.event_type eventType,  COUNT(*)AS number
+            FROM dc_publish_manage
+                     left join dc_event on dc_publish_manage.event_id=dc_event.id
+            WHERE YEAR(publish_time) = YEAR(CURDATE())
+              AND MONTH(publish_time) = MONTH(#{publishTime})
+            GROUP BY HOUR(publish_time), publish_channels
+        ) AS m ON h.eventType = m.eventType AND pc.publish_channels = m.publish_channels
+        ORDER BY h.eventType, pc.publish_channels;
+    </select>
 </mapper>