* bug fix

src/main/java/com/huiju/estateagents/bo/request/ActivityStatisticResponseBO.java

@@ -0,0 +1,44 @@
+package com.huiju.estateagents.bo.request;
+
+import lombok.Data;
+
+/**
+ * 活动统计返回实体
+ *
+ * @author gusy
+ * @date 2020/4/26 13:15
+ */
+@Data
+public class ActivityStatisticResponseBO {
+
+    /**
+     * 活动分享人数
+     */
+    private Integer sharePersons;
+
+    /**
+     * 活动分享次数
+     */
+    private Integer shareNum;
+
+    /**
+     * 活动访问人数
+     */
+    private Integer visitPersons;
+
+    /**
+     * 活动访问次数
+     */
+    private Integer visitNum;
+
+    /**
+     * 分享新增用户
+     */
+    private Integer newPersons;
+
+    /**
+     * 分享新增客户
+     */
+    private Integer newCustomers;
+
+}

src/main/java/com/huiju/estateagents/controller/ActivityManageController.java

@@ -0,0 +1,65 @@
+package com.huiju.estateagents.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.huiju.estateagents.base.BaseController;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.service.impl.ActivityManageServiceImpl;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * 活动管理
+ *
+ * @author gusy
+ * @date 2020/4/26 10:42
+ */
+@Controller
+@RequestMapping("/api")
+public class ActivityManageController extends BaseController {
+
+    private Logger logger = LoggerFactory.getLogger(ActivityManageController.class);
+
+    @Autowired
+    private ActivityManageServiceImpl activityManageService;
+
+    /**
+     * 根据类型获取统计数据
+     *
+     * @param type 报名活动:activity、
+     *             H5:h5、
+     *             助力:help、
+     *             拼团:group、
+     *             直播:live
+     * @return
+     */
+    @RequestMapping(value = "/admin/activityManage/getStatisticData", method = RequestMethod.GET)
+    @ResponseBody
+    public ResponseBean getStatisticDataByType(String type, String id, HttpServletRequest request) {
+        logger.info("getStatisticDataByType 接收参数：type：{}，id：{}", type, id);
+
+        ResponseBean responseBean = new ResponseBean();
+
+        // 校验参数
+        if (StringUtils.isBlank(type) || StringUtils.isBlank(id)) {
+            responseBean.addError("参数错误");
+            return responseBean;
+        }
+
+        try {
+            responseBean = activityManageService.getStatisticDataByType(type, id,getOrgId(request));
+            logger.info("getStatisticDataByType 返回结果：{}", JSONObject.toJSONString(responseBean));
+        } catch (Exception e) {
+            logger.error("异常：", e);
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+}

src/main/java/com/huiju/estateagents/mapper/ActivityManageMapper.java

@@ -0,0 +1,25 @@
+package com.huiju.estateagents.mapper;
+
+import com.huiju.estateagents.bo.request.ActivityStatisticResponseBO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author gusy
+ * @date 2020/4/26 11:16
+ */
+@Component
+@Mapper
+public interface ActivityManageMapper {
+
+    /**
+     * 获取活动统计数据
+     *
+     * @return
+     */
+    ActivityStatisticResponseBO getStatisticDataByType(@Param("type") String type,
+                                                       @Param("id") String id,
+                                                       @Param("orgId") Integer orgId);
+
+}

src/main/java/com/huiju/estateagents/mapper/TaBuildingDynamicMapper.java

@@ -3,6 +3,7 @@ package com.huiju.estateagents.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huiju.estateagents.bo.request.ActivityStatisticResponseBO;
 import com.huiju.estateagents.entity.TaBuildingDynamic;
 import com.huiju.estateagents.entity.TaPersonBuilding;
 import org.apache.ibatis.annotations.Mapper;

src/main/java/com/huiju/estateagents/service/IActivityManageService.java

@@ -0,0 +1,27 @@
+package com.huiju.estateagents.service;
+
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.bo.request.ActivityStatisticResponseBO;
+import com.huiju.estateagents.mapper.ActivityManageMapper;
+import com.huiju.estateagents.service.impl.ActivityManageServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author gusy
+ * @date 2020/4/26 11:14
+ */
+@Service
+public class IActivityManageService implements ActivityManageServiceImpl {
+
+    @Autowired
+    private ActivityManageMapper activityManageMapper;
+
+    @Override
+    public ResponseBean getStatisticDataByType(String type, String id,Integer orgId) {
+        ResponseBean responseBean = new ResponseBean();
+        ActivityStatisticResponseBO responseBO = activityManageMapper.getStatisticDataByType(type, id,orgId);
+        responseBean.addSuccess(responseBO);
+        return responseBean;
+    }
+}

src/main/java/com/huiju/estateagents/service/impl/ActivityManageServiceImpl.java

@@ -0,0 +1,12 @@
+package com.huiju.estateagents.service.impl;
+
+import com.huiju.estateagents.base.ResponseBean;
+
+/**
+ * @author gusy
+ * @date 2020/4/26 11:13
+ */
+public interface ActivityManageServiceImpl {
+
+    ResponseBean getStatisticDataByType(String type,String id,Integer orgId);
+}

src/main/resources/mapper/ActivityManageMapper.xml

@@ -0,0 +1,183 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.huiju.estateagents.mapper.ActivityManageMapper">
+
+    <select id = "getStatisticDataByType" resultType="com.huiju.estateagents.bo.request.ActivityStatisticResponseBO">
+      select
+        -- 活动分享人数
+        (SELECT count(DISTINCT b.person_id) FROM ta_share_count b
+        WHERE b.org_id = a.org_id
+            <choose>
+                <when test=" type == 'live'">
+                    AND b.tagert_type like concat('%',a.target_type,'%')
+                </when>
+                <otherwise>
+                    AND b.tagert_type = a.target_type
+                </otherwise>
+            </choose>
+            AND b.be_share = a.target_id
+        ) as share_persons,
+
+        -- 活动分享次数
+        (SELECT count(*) FROM ta_share_count c
+        WHERE c.org_id = a.org_id
+            <choose>
+                <when test=" type == 'live'">
+                    AND c.tagert_type like concat('%',a.target_type,'%')
+                </when>
+                <otherwise>
+                    AND c.tagert_type = a.target_type
+                </otherwise>
+            </choose>
+            AND c.be_share = a.target_id
+        ) as share_num,
+
+        -- 活动访问人数
+        (select count( DISTINCT d.person_id ) from ta_person_visit_record d
+        WHERE d.org_id = a.org_id
+            <choose>
+                <when test=" type == 'live'">
+                    AND d.target_type like concat('%',REPLACE(a.target_type, 'activity', 'dynamic'),'%')
+                </when>
+                <otherwise>
+                    AND d.target_type = REPLACE(a.target_type, 'activity', 'dynamic')
+                </otherwise>
+            </choose>
+            AND d.target_id = a.target_id
+            AND d.`event` = 'detail'
+        ) as visit_persons,
+
+        -- 活动访问次数
+        (select count(*) from ta_person_visit_record e
+        WHERE e.org_id = a.org_id
+            <choose>
+                <when test=" type == 'live'">
+                    AND e.target_type like concat('%',REPLACE(a.target_type, 'activity', 'dynamic'),'%')
+                </when>
+                <otherwise>
+                    AND e.target_type = REPLACE(a.target_type, 'activity', 'dynamic')
+                </otherwise>
+            </choose>
+            AND e.target_id = a.target_id
+            AND e.`event` = 'detail'
+        ) as visit_num,
+
+        -- 分享新增用户
+        (select count(*) from ta_share_person_from f
+        where	f.org_id = a.org_id
+        <choose>
+            <when test=" type == 'live'">
+                AND f.target_type = concat('%',REPLACE(a.target_type, 'activity', 'dynamic'), '_share%')
+            </when>
+            <otherwise>
+                AND f.target_type = concat(REPLACE(a.target_type, 'activity', 'dynamic'), '_share')
+            </otherwise>
+        </choose>
+        AND f.target_id = a.target_id
+        AND f.`status` > 0
+        AND f.is_first_time = 1
+        ) as new_persons,
+
+        -- 分享新增客户
+        (select count(*) from ta_share_person_from g
+        inner join ta_person h on h.person_id = g.person_id
+        where	g.org_id = a.org_id
+        <choose>
+            <when test=" type == 'live'">
+                AND g.target_type = concat('%',REPLACE(a.target_type, 'activity', 'dynamic'), '_share%')
+            </when>
+            <otherwise>
+                AND g.target_type = concat(REPLACE(a.target_type, 'activity', 'dynamic'), '_share')
+            </otherwise>
+        </choose>
+        AND g.target_id = a.target_id
+        AND g.`status` > 0
+        AND g.is_first_time = 1
+        AND h.phone is not null
+        ) as new_customers
+
+        from (
+            <if test=" type == 'activity' ">
+                SELECT
+                    t.org_id,
+                    t.building_id,
+                    s.building_name,
+                    t.dynamic_id AS target_id,
+                    t.title AS target_name,
+                    'activity' AS target_type
+                FROM
+                    ta_building_dynamic t
+                LEFT JOIN ta_building s ON s.building_id = t.building_id
+                WHERE
+                  t.`status` > - 1
+                  AND t.dynamic_id = #{id}
+            </if>
+
+            <if test=" type == 'h5' " >
+                    SELECT
+                    t.org_id,
+                    t.building_id,
+                    s.building_name,
+                    t.drainage_id AS target_id,
+                    t.`name` AS target_name,
+                    'h5' AS target_type
+                FROM
+                  ta_drainage t
+                LEFT JOIN ta_building s ON s.building_id = t.building_id
+                WHERE
+                  t.`status` > - 1
+                  AND t.drainage_id = #{id}
+            </if>
+
+            <if test=" type == 'help' ">
+                SELECT
+                    t.org_id,
+                    t.building_id,
+                    s.building_name,
+                    t.help_activity_id AS target_id,
+                    t.title AS target_name,
+                    'help' AS target_type
+                FROM
+                    ta_help_activity t
+                LEFT JOIN ta_building s ON s.building_id = t.building_id
+                WHERE
+                    t.`status` > - 1
+                    AND t.help_activity_id = #{id}
+            </if>
+
+            <if test=" type == 'group' ">
+                SELECT
+                    t.org_id,
+                    t.building_id,
+                    s.building_name,
+                    t.group_activity_id AS target_id,
+                    t.activity_name AS target_name,
+                    'group' AS target_type
+                FROM
+                    ta_share_activity t
+                LEFT JOIN ta_building s ON s.building_id = t.building_id
+                WHERE
+                    t.`status` > - 1
+                    AND t.group_activity_id = #{id}
+            </if>
+
+            <if test=" type == 'live' ">
+                SELECT
+                    t.org_id,
+                    t.building_id,
+                    s.building_name,
+                    t.live_activity_id AS target_id,
+                    t.live_activity_title AS target_name,
+                    'live' AS target_type
+                FROM
+                    ta_live_activity t
+                LEFT JOIN ta_building s ON s.building_id = t.building_id
+                WHERE
+                    t.`status` > -1
+                    AND t.live_activity_id = #{id}
+                    AND t.org_id = #{orgId}
+            </if>
+        ) a
+    </select>
+
+</mapper>

src/main/resources/mapper/TaBuildingDynamicMapper.xml

@@ -190,5 +190,4 @@
         from ta_building_dynamic
         where org_id = #{orgId}
     </select>
-
 </mapper>