增加群聊统计数据

offline-module/src/main/java/com/tzld/piaoquan/offline/job/WeComStaffDataJob.java

@@ -232,7 +232,7 @@ public class WeComStaffDataJob {
     }
 
 
-    private void statisticsStaffGroupTotal(Staff staff, long startTime, String date) throws IOException {
+    public void statisticsStaffGroupTotal(Staff staff, long startTime, String date) throws IOException {
         Long corpId = staff.getCorpId();
         StaffGroupStatisticsTotalExample example = new StaffGroupStatisticsTotalExample();
         example.createCriteria().andCorpIdEqualTo(corpId).andStaffIdEqualTo(staff.getId()).andDateEqualTo(date);
@@ -263,9 +263,9 @@ public class WeComStaffDataJob {
             if (errcode == 0) {
                 JSONArray jsonArray = jsonObject.getJSONArray("items");
                 if (!jsonArray.isEmpty()) {
-                    JSONObject data = jsonArray.getJSONObject(0);
                     StaffGroupStatisticsTotal statisticsTotal = new StaffGroupStatisticsTotal();
-                    statisticsTotal.setStatTime(data.getLong("stat_time"));
+                    JSONObject data = jsonArray.getJSONObject(0).getJSONObject("data");
+                    statisticsTotal.setStatTime(jsonArray.getJSONObject(0).getLong("stat_time"));
                     statisticsTotal.setNewChatCnt(data.getInteger("new_chat_cnt"));
                     statisticsTotal.setChatTotal(data.getInteger("chat_total"));
                     statisticsTotal.setChatHasMsg(data.getInteger("chat_has_msg"));
@@ -277,7 +277,8 @@ public class WeComStaffDataJob {
                     statisticsTotal.setDate(date);
                     statisticsTotal.setCorpId(corpId);
                     statisticsTotal.setStaffId(staff.getId());
-                    staffGroupStatisticsTotalMapper.insertSelective(statisticsTotal);
+                    System.out.println(statisticsTotal);
+//                    staffGroupStatisticsTotalMapper.insertSelective(statisticsTotal);
                 }
             }
         }