|
@@ -0,0 +1,82 @@
|
|
|
+因计费逻辑调整,原统计步骤废弃,不再对原有文档进行维护更新,以下为最新统计逻辑:
|
|
|
+
|
|
|
+=====
|
|
|
+科大讯飞股份有限公司_卫健委jyKRZXQQEIBQRYSUJAFg9o科大讯飞股份有限公司_医疗jyPBBXQQEFCQVbSUNAJCd8科大讯飞股份有限公司_教育jyOSxXQQECCA9dS0BPKjxH科大讯飞股份有限公司_消委会jyHDhXQQIAAgdZQEBLERV2
|
|
|
+
|
|
|
+=====
|
|
|
+### 科大讯飞-教育/科大讯飞-销委会/科大讯飞-战略分析部:
|
|
|
+#### 数据准备
|
|
|
+第一步:商机管理导出的线上数据字段补充 a.取infoid的值新增一个id的字段 b.补充APPID字段,补销委会的appid
|
|
|
+具体操作步骤:
|
|
|
+1. 正式环境商机管理导出数据(qfw entdataexport里面的数据)库导入到167上临时表`jygyfw historyData-20230711kdxfentdataexport_tmp`(用于处理数据使用,使用完删掉)
|
|
|
+
|
|
|
+ 查询条件:开始时间不用改,结束时间改为统计截止日期的时间戳。(后续可以只查截止至上次统计时间的增量数据最后导入到统计表中)
|
|
|
+ 时间戳转换网址:https://tool.lu/timestamp/
|
|
|
+```
|
|
|
+{ "entid" : NumberInt(10511), "createtime":{ "$gt":1609212120, "$lt":1689004800 }}
|
|
|
+
|
|
|
+```
|
|
|
+2. 补充数据(临时表的名称需要替换)
|
|
|
+```
|
|
|
+db.getCollection("20230711kdxfentdataexport_tmp").find({}).forEach(function(item){
|
|
|
+item.id=item.infoid
|
|
|
+item.appid="jyHDhXQQIAAgdZQEBLERV2"
|
|
|
+db.getCollection("20230711kdxfentdataexport_tmp").save(item)
|
|
|
+})
|
|
|
+```
|
|
|
+第二步:合并数据(商机管理处理过的数据、科大讯飞-教育、科大讯飞-消委会、科大讯飞-战略分析部)到统计表(20230711kdxf_jy_xwh_zlfx_all) 后续可以只进增量数据
|
|
|
+```
|
|
|
+{ createtime:{ "$lte":NumberLong(1689004800)}}
|
|
|
+
|
|
|
+```
|
|
|
+
|
|
|
+#### 数据统计
|
|
|
+```
|
|
|
+db.getCollection("20230711kdxf_jy_xwh_zlfx_all").aggregate([
|
|
|
+{$match:{"createtime":{"$lte":NumberLong(1689004800)}}},
|
|
|
+{$sort: { id: 1, createtime:1}},
|
|
|
+{$group:{
|
|
|
+_id:"$id",
|
|
|
+first:{$first: "$appid"},
|
|
|
+}},
|
|
|
+{$group:{
|
|
|
+_id:"$first",
|
|
|
+count:{$sum:1}
|
|
|
+}
|
|
|
+}
|
|
|
+], {
|
|
|
+"allowDiskUse" : true
|
|
|
+})
|
|
|
+```
|
|
|
+
|
|
|
+
|
|
|
+### 科大讯飞-医疗/科大讯飞-卫健委
|
|
|
+#### 数据准备
|
|
|
+192.168.3.167-jygyfw_historyData-20211101Kdxf_yl;
|
|
|
+192.168.3.167-jygyfw_historyData-2021Kdxf_wjw
|
|
|
+导入到统计表(20230711kdxf_yl_wjw_all) 后续可以只导截止至上次统计的增量数据,不用再导全部
|
|
|
+查询条件:(时间根据统计范围替换)
|
|
|
+```
|
|
|
+{ createtime:{ "$lte":NumberLong(1689004800)}}
|
|
|
+```
|
|
|
+
|
|
|
+#### 统计
|
|
|
+时间根据统计范围替换
|
|
|
+```
|
|
|
+db.getCollection("20230711kdxf_yl_wjw_all").aggregate([
|
|
|
+{$match:{"createtime":{"$lte":NumberLong(1689004800)}}},
|
|
|
+{$sort: { id: 1, createtime:1}},
|
|
|
+{$group:{
|
|
|
+_id:"$id",
|
|
|
+first:{$first: "$appid"},
|
|
|
+}},
|
|
|
+{$group:{
|
|
|
+_id:"$first",
|
|
|
+count:{$sum:1}
|
|
|
+}
|
|
|
+}
|
|
|
+], {
|
|
|
+"allowDiskUse" : true
|
|
|
+})
|
|
|
+```
|
|
|
+
|