Merge branch 'feature-2023-12-data-rank' into 'test_branch'

Feature 2023 12 data rank

See merge request !1612

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/controller/data/StoreRankController.java

+package com.gic.haoban.manage.web.controller.data;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.gic.api.base.commons.Page;
+import com.gic.commons.util.EntityUtil;
+import com.gic.commons.web.qo.PageQo;
+import com.gic.commons.webapi.reponse.RestResponse;
+import com.gic.enterprise.api.dto.StoreWidgetDTO;
+import com.gic.enterprise.api.dto.data.DataIndexExplainDTO;
+import com.gic.enterprise.api.dto.rank.StoreRankAreaDTO;
+import com.gic.enterprise.api.dto.rank.StoreRankIndexDTO;
+import com.gic.enterprise.api.service.StoreWidgetService;
+import com.gic.enterprise.api.service.data.DataIndexApiService;
+import com.gic.enterprise.api.service.rank.StoreRankApiService;
+import com.gic.enterprise.service.CustomSettingApiService;
+import com.gic.haoban.manage.web.vo.rank.IndexVO;
+import com.gic.haoban.manage.web.vo.rank.StoreRankAreaVO;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.StringUtils;
+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.ResponseBody;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * 单项排行榜
+ * @Author guojx
+ * @Date 2023/12/28 14:14
+ */
+@Controller
+@RequestMapping("store-rank")
+@Slf4j
+public class StoreRankController {
+    @Autowired
+    private StoreRankApiService storeRankApiService;
+    @Autowired
+    private CustomSettingApiService customSettingApiService;
+    @Autowired
+    private StoreWidgetService storeWidgetService;
+    @Autowired
+    private DataIndexApiService dataIndexApiService;
+
+    public static final String RANK_INDEX_DB_NAME = "tab_store_pk_index_dict";
+    public static final String ORDER_FIELD = "custom_order_field_name";
+    public static final String ORDER_FIELD_DESC = "custom_order_field_name_desc";
+
+    /**
+     * 企业竞赛单项
+     * @param enterpriseId
+     * @return
+     */
+    @RequestMapping(value = "sales-structure")
+    @ResponseBody
+    public RestResponse<List<IndexVO>> salesStructure(String enterpriseId, String storeId) {
+        Map<String, Object> queryMap = new HashMap<>();
+        queryMap.put(ORDER_FIELD, "indexSort");
+        queryMap.put(ORDER_FIELD_DESC, 1);
+        Page<JSONObject> page = customSettingApiService.page(RANK_INDEX_DB_NAME, queryMap, 1, 100).getResult();
+        List<JSONObject> list = page.getResult();
+        List<IndexVO> indexList = JSON.parseArray(JSON.toJSONString(list), IndexVO.class);
+        List<DataIndexExplainDTO> dictIndex = dataIndexApiService.listDataIndexExplain();
+        Map<String, DataIndexExplainDTO> map = dictIndex.stream().collect(Collectors.toMap(e -> e.getIndexCode(), e -> e));
+        for (IndexVO vo : indexList) {
+            DataIndexExplainDTO dto = map.get(vo.getIndexCode());
+            if (dto != null) {
+                vo.setIndexExample(dto.getIndexExample());
+                vo.setIndexName(dto.getIndexName());
+                vo.setApiColName(dto.getApiColName());
+                vo.setIndexExplain(dto.getIndexExplain());
+                vo.setIndexRemark(dto.getIndexRemark());
+            }
+        }
+
+        List<StoreRankIndexDTO> enterpriseIndexList = storeRankApiService.listStoreRankIndex(enterpriseId);
+        if (CollectionUtils.isEmpty(enterpriseIndexList)) {
+            return RestResponse.successResult(Collections.emptyList());
+        }
+        Set<String> set = enterpriseIndexList.stream().map(e -> e.getIndexCode()).collect(Collectors.toSet());
+        indexList = indexList.stream().filter(e -> set.contains(e.getIndexCode())).collect(Collectors.toList());
+
+        List<IndexVO> resultList = new ArrayList<>();
+        if (CollectionUtils.isNotEmpty(indexList) && StringUtils.isNotBlank(storeId)) {
+            PageQo pageQo = new PageQo();
+            pageQo.setPageNum(1);
+            pageQo.setPageSize(1);
+            for (IndexVO temp : indexList) {
+                if (listStoreRankArea(pageQo, enterpriseId, temp.getIndexCode(), storeId).getResult().getTotalCount() > 0) {
+                    resultList.add(temp);
+                }
+            }
+            return RestResponse.successResult(resultList);
+        }
+        return RestResponse.successResult(indexList);
+    }
+
+    /**
+     * 赛区列表
+     * @param pageQo
+     * @param enterpriseId
+     * @param indexCode
+     * @param storeId
+     * @return
+     */
+    @RequestMapping("list-store-rank-area")
+    @ResponseBody
+    public RestResponse<Page<StoreRankAreaVO>> listStoreRankArea(PageQo pageQo, String enterpriseId, String indexCode, String storeId) {
+        List<String> authStoreIdList = new ArrayList<>();
+        if (StringUtils.isNotBlank(storeId)) {
+            authStoreIdList.add(storeId);
+        }
+        Page<StoreRankAreaDTO> page = storeRankApiService
+                .pageStoreRankArea(enterpriseId, indexCode, null, null, pageQo.getBasePageInfo(), authStoreIdList);
+        Page<StoreRankAreaVO> voPage = EntityUtil.changeEntityNew(Page.class, page);
+        List<StoreRankAreaVO> voList = EntityUtil.changeEntityListNew(StoreRankAreaVO.class, page.getResult());
+        if (CollectionUtils.isNotEmpty(voList)) {
+            for (StoreRankAreaVO vo : voList) {
+                StoreWidgetDTO storeWidgetDTO = storeWidgetService.getStoreWidgetBykey(vo.getStoreWidgetId());
+                if (storeWidgetDTO != null) {
+                    //0:所有门店   1：门店类型  2：门店标签  3：门店区域  4：门店分组   5：部分门店
+                    Integer selectType = storeWidgetDTO.getSelectType();
+                    String areaName;
+                    switch (selectType) {
+                        case 0:
+                            areaName = "所有门店";
+                            break;
+                        case 1:
+                            areaName = "门店类型";
+                            break;
+                        case 2:
+                            areaName = "门店标签";
+                            break;
+                        case 3:
+                            areaName = "门店区域";
+                            break;
+                        case 4:
+                            areaName = "门店分组";
+                            break;
+                        case 5:
+                            areaName = "部分门店";
+                            break;
+                        default:
+                            areaName = "未知";
+                    }
+                    vo.setAreaName(areaName);
+                }
+            }
+        }
+        voPage.setResult(voList);
+        return RestResponse.successResult(voPage);
+    }
+}

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/qo/data/ClerkListQO.java

+package com.gic.haoban.manage.web.qo.data;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author guojx
+ * @Date 2023/11/23 9:13
+ */
+@Data
+public class ClerkListQO implements Serializable {
+    /**
+     * 1：销售 2：会员
+     */
+    private Integer queryDataType = 1;
+
+    /**
+     * 数据组配置的接口key。数据组提供的yapi文档上有
+     */
+    private String apolloKey;
+
+    /**
+     * 组装的参数，JSON字符串.数据组提供的yapi文档上有.
+     * 销售：data_sales_perf_anal_cont_clerk_group 会员：
+     * 0: 'data_mbr_scale_stat_clerk_overview',
+     * 			1: 'data_mbr_scale_stat_week_clerk_overview',
+     * 			2: 'data_mbr_scale_stat_month_clerk_overview',
+     * 			3: 'data_mbr_scale_stat_year_clerk_overview',
+     * 			4: 'data_mbr_scale_stat_custm_clerk_overview'
+     * params里面的销售的storeGroup字段和会员的groupType字段不需要，如果有，也是无效，后端定值覆盖
+     */
+    private String params;
+}

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/qo/data/SalesStructureQO.java

+package com.gic.haoban.manage.web.qo.data;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author guojx
+ * @Date 2023/12/26 14:32
+ */
+@Data
+public class SalesStructureQO implements Serializable {
+
+    /**
+     * 1:新老客维度 2:生日会员 3：等级
+     */
+    private Integer salesStructureType = 1;
+
+    /**
+     * 开始时间
+     */
+    private String startDate;
+
+    /**
+     * 结束时间
+     */
+    private String endDate;
+
+    /**
+     * 门店查询参数. 区经可以为空，查询所有管辖门店
+     */
+    private String storeId;
+
+    /**
+     * 企业ID.
+     */
+    private String enterpriseId;
+
+    /**
+     * 微信企业
+     */
+    private String wxEnterpriseId;
+
+    /**
+     * 如果是区经，用于查询管辖门店权限
+     */
+    private String clerkId;
+}

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/utils/DateFillUtils.java

@@ -120,6 +120,18 @@ public class DateFillUtils {
         return dateList;
     }
 
+    public static List<String> getMonthOfYear(String date) {
+        List<String> dateList = new ArrayList<>();
+        for (int i = 1; i <= 12; i++) {
+            if (i < 10) {
+                dateList.add(date + "-0" + i);
+            } else {
+                dateList.add(date + "-" + i);
+            }
+        }
+        return dateList;
+    }
+
     public static void main(String[] args) {
         log.info("" + JSONObject.toJSONString(getWeek("2023-11-27")));
     }

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/vo/data/SalesStructureVO.java

+package com.gic.haoban.manage.web.vo.data;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author guojx
+ * @Date 2023/12/26 14:50
+ */
+@Data
+public class SalesStructureVO implements Serializable {
+
+    /**
+     * 1:新老客维度 2:生日会员 3：等级
+     */
+    private Integer salesStructureType = 1;
+
+    /**
+     * 实付金额
+     */
+    private Double payAmt;
+
+    /**
+     * 消费人数
+     */
+    private Integer csmeNum;
+
+    /**
+     * 有效订单数
+     */
+    private Integer effOrderCnt;
+
+    /**
+     * 名称类型
+     */
+    private String mbrType;
+
+    /**
+     * 实付金额占比
+     */
+    private String payAmtRate;
+
+    /**
+     * 消费人数占比
+     */
+    private String csmeNumRate;
+
+    /**
+     * 有效订单数占比
+     */
+    private String effOrderCntRate;
+}

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/vo/rank/IndexVO.java

+package com.gic.haoban.manage.web.vo.rank;
+
+import lombok.Data;
+import org.apache.commons.lang3.StringUtils;
+
+import java.io.Serializable;
+import java.util.Arrays;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * @Author guojx
+ * @Date 2023/12/25 9:56
+ */
+@Data
+public class IndexVO implements Serializable {
+
+    private String indexCode;
+
+    private String indexName;
+
+    private String indexExplain;
+
+    /**
+     * 前端使用：指标说明:若指标注释中有需要说明的
+     */
+    private List<String> indexRemarkList;
+
+    /**
+     * 前端使用：指标例子
+     */
+    private List<String> indexExampleList;
+
+    /**
+     * 指标说明:若指标注释中有需要说明的，英文分号隔开，可能多个。
+     */
+    private String indexRemark;
+
+    /**
+     * 指标例子: 英文分号隔开，可能多个
+     */
+    private String indexExample;
+
+    /**
+     * yapi文档上的驼峰字段名称
+     */
+    private String apiColName;
+
+    /**
+     * 观云台原指标code
+     */
+    private String itemId;
+
+    public List<String> getIndexRemarkList() {
+        if (StringUtils.isNotBlank(indexRemark)) {
+            return Arrays.stream(indexRemark.split(";")).collect(Collectors.toList());
+        }
+        return indexRemarkList;
+    }
+
+    public List<String> getIndexExampleList() {
+        if (StringUtils.isNotBlank(indexExample)) {
+            return Arrays.stream(indexExample.split(";")).collect(Collectors.toList());
+        }
+        return indexExampleList;
+    }
+}

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/vo/rank/StoreRankAreaVO.java

+package com.gic.haoban.manage.web.vo.rank;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Author guojx
+ * @Date 2023/12/25 15:44
+ */
+@Data
+public class StoreRankAreaVO implements Serializable {
+
+    private String competitionAreaId;
+
+    /**
+     * 赛区范围
+     */
+    private String areaName;
+
+
+    private String indexCode;
+
+    /**
+     * 赛区名称
+     */
+    private String name;
+
+    /**
+     * 是否显示指标（0：否，1：是）
+     */
+    private Integer showIndex;
+
+    /**
+     * 是否固化门店（0：否，1：是）
+     */
+    private Integer fixedStore;
+
+    /**
+     * 管辖门店控件id
+     */
+    private String storeWidgetId;
+
+    private String creatorUserId;
+
+    private String creatorName;
+
+    private Date createTime;
+    private Date updateTime;
+
+    private Integer storeCount;
+}

haoban-manage3-wx/src/main/webapp/WEB-INF/dubbo-haoban-manage-wx.xml

@@ -167,4 +167,7 @@
 
 
     <dubbo:reference id="enterpriseChannelApiService" interface="com.gic.enterprise.api.service.EnterpriseChannelApiService" timeout="10000" retries="0" check="false"/>
+
+    <dubbo:reference id="storeRankApiService" interface="com.gic.enterprise.api.service.rank.StoreRankApiService" timeout="100000" retries="0" check="false" />
+
 </beans>