瀏覽代碼

盘手业务,导入数据bug修复

zhaoxian 3 年之前
父節點
當前提交
1b089041e2

+ 16 - 12
ruixuan-live/src/main/java/com/ruixuan/data/service/impl/KuaishouLiveDataAnalysisServiceImpl.java

@@ -99,18 +99,22 @@ public class KuaishouLiveDataAnalysisServiceImpl implements IKuaishouLiveDataAna
         try {
             List<KuaishouLiveDataAnalysis> analysisList = new ArrayList<>();
             for (JSONObject cell : list) {
-                KuaishouLiveDataAnalysis analysis = new KuaishouLiveDataAnalysis();
-                analysis.setKsId(broadcast.getKsId());
-                analysis.setKsName(broadcast.getKsName());
-                analysis.setAccountId(broadcast.getAccountId());
-                analysis.setAccountName(broadcast.getAccountName());
-                analysis.setWaresName(cell.getString("0"));
-                analysis.setWaresPutDate(cell.getString("1"));
-                analysis.setWaresPrice(cell.getBigDecimal("2"));
-                analysis.setWaresSalesAmount(cell.getBigDecimal("3"));
-                analysis.setWaresSalesVolume(cell.getBigDecimal("4"));
-                analysis.setTopayOrders(cell.getLong("5"));
-                analysisList.add(analysis);
+                if (cell.size() == 6) {
+                    KuaishouLiveDataAnalysis analysis = new KuaishouLiveDataAnalysis();
+                    analysis.setKsId(broadcast.getKsId());
+                    analysis.setKsName(broadcast.getKsName());
+                    analysis.setAccountId(broadcast.getAccountId());
+                    analysis.setAccountName(broadcast.getAccountName());
+                    analysis.setWaresName(cell.getString("0"));
+                    analysis.setWaresPutDate(cell.getString("1"));
+                    analysis.setWaresPrice(cell.getBigDecimal("2"));
+                    analysis.setWaresSalesAmount(cell.getBigDecimal("3"));
+                    analysis.setWaresSalesVolume(cell.getBigDecimal("4"));
+                    analysis.setTopayOrders(cell.getLong("5"));
+                    analysisList.add(analysis);
+                } else {
+                    throw new Exception("商品分析列不对");
+                }
             }
 
             int i = kuaishouLiveDataAnalysisMapper.inserExcelBatchInfo(analysisList);

+ 12 - 8
ruixuan-live/src/main/java/com/ruixuan/data/service/impl/KuaishouLiveDataFunnelServiceImpl.java

@@ -98,14 +98,18 @@ public class KuaishouLiveDataFunnelServiceImpl implements IKuaishouLiveDataFunne
         try {
             List<KuaishouLiveDataFunnel> funnelList = new ArrayList<>();
             for (JSONObject cell : list) {
-                KuaishouLiveDataFunnel funnel = new KuaishouLiveDataFunnel();
-                funnel.setKsId(broadcast.getKsId());
-                funnel.setKsName(broadcast.getKsName());
-                funnel.setAccountId(broadcast.getAccountId());
-                funnel.setAccountName(broadcast.getAccountName());
-                funnel.setStatDate(cell.getString("0"));
-                funnel.setAllViewers(cell.getLong("1"));
-                funnelList.add(funnel);
+                if (cell.size() == 2) {
+                    KuaishouLiveDataFunnel funnel = new KuaishouLiveDataFunnel();
+                    funnel.setKsId(broadcast.getKsId());
+                    funnel.setKsName(broadcast.getKsName());
+                    funnel.setAccountId(broadcast.getAccountId());
+                    funnel.setAccountName(broadcast.getAccountName());
+                    funnel.setStatDate(cell.getString("0"));
+                    funnel.setAllViewers(cell.getLong("1"));
+                    funnelList.add(funnel);
+                } else {
+                    throw new Exception("直播漏斗数据列不对");
+                }
             }
             int i = kuaishouLiveDataFunnelMapper.inserExcelBatchInfo(funnelList);
             if (i > 0) {

+ 25 - 21
ruixuan-live/src/main/java/com/ruixuan/data/service/impl/KuaishouLiveDataKanbanServiceImpl.java

@@ -99,27 +99,31 @@ public class KuaishouLiveDataKanbanServiceImpl implements IKuaishouLiveDataKanba
         try {
             List<KuaishouLiveDataKanban> kanbanList = new ArrayList<>();
             for (JSONObject cell : list) {
-                KuaishouLiveDataKanban kanban = new KuaishouLiveDataKanban();
-                kanban.setKsId(broadcast.getKsId());
-                kanban.setKsName(broadcast.getKsName());
-                kanban.setAccountId(broadcast.getAccountId());
-                kanban.setAccountName(broadcast.getAccountName());
-                kanban.setOnlineViewers(cell.getLong("0"));
-                kanban.setViewers(cell.getLong("1"));
-                kanban.setViewingTimes(cell.getLong("2"));
-                kanban.setPerViewingTime(cell.getString("3"));
-                kanban.setFansViewingTime(cell.getString("4"));
-                kanban.setRewards(cell.getLong("5"));
-                kanban.setPutWares(cell.getLong("6"));
-                kanban.setNewFans(cell.getLong("7"));
-                kanban.setLikes(cell.getLong("8"));
-                kanban.setWaresClicks(cell.getLong("9"));
-                kanban.setCarClicks(cell.getLong("10"));
-                kanban.setAllAmount(cell.getBigDecimal("11"));
-                kanban.setAllTurnover(cell.getLong("12"));
-                kanban.setAllOrders(cell.getLong("13"));
-                kanban.setTurnoverRatio(cell.getString("14"));
-                kanbanList.add(kanban);
+                if (cell.size() == 15) {
+                    KuaishouLiveDataKanban kanban = new KuaishouLiveDataKanban();
+                    kanban.setKsId(broadcast.getKsId());
+                    kanban.setKsName(broadcast.getKsName());
+                    kanban.setAccountId(broadcast.getAccountId());
+                    kanban.setAccountName(broadcast.getAccountName());
+                    kanban.setOnlineViewers(cell.getLong("0"));
+                    kanban.setViewers(cell.getLong("1"));
+                    kanban.setViewingTimes(cell.getLong("2"));
+                    kanban.setPerViewingTime(cell.getString("3"));
+                    kanban.setFansViewingTime(cell.getString("4"));
+                    kanban.setRewards(cell.getLong("5"));
+                    kanban.setPutWares(cell.getLong("6"));
+                    kanban.setNewFans(cell.getLong("7"));
+                    kanban.setLikes(cell.getLong("8"));
+                    kanban.setWaresClicks(cell.getLong("9"));
+                    kanban.setCarClicks(cell.getLong("10"));
+                    kanban.setAllAmount(cell.getBigDecimal("11"));
+                    kanban.setAllTurnover(cell.getLong("12"));
+                    kanban.setAllOrders(cell.getLong("13"));
+                    kanban.setTurnoverRatio(cell.getString("14"));
+                    kanbanList.add(kanban);
+                } else {
+                    throw new Exception("直播数据看板数据列不对");
+                }
             }
 
             int i = kuaishouLiveDataKanbanMapper.inserExcelBatchInfo(kanbanList);

+ 12 - 8
ruixuan-live/src/main/java/com/ruixuan/data/service/impl/KuaishouLiveDataOverviewServiceImpl.java

@@ -99,14 +99,18 @@ public class KuaishouLiveDataOverviewServiceImpl implements IKuaishouLiveDataOve
         try {
             List<KuaishouLiveDataOverview> overviewList = new ArrayList<>();
             for (JSONObject cell : list) {
-                KuaishouLiveDataOverview overview = new KuaishouLiveDataOverview();
-                overview.setKsId(broadcast.getKsId());
-                overview.setKsName(broadcast.getKsName());
-                overview.setAccountId(broadcast.getAccountId());
-                overview.setAccountName(broadcast.getAccountName());
-                overview.setStatDate(cell.getString("0"));
-                overview.setAmounts(cell.getBigDecimal("1"));
-                overviewList.add(overview);
+                if (cell.size() == 2) {
+                    KuaishouLiveDataOverview overview = new KuaishouLiveDataOverview();
+                    overview.setKsId(broadcast.getKsId());
+                    overview.setKsName(broadcast.getKsName());
+                    overview.setAccountId(broadcast.getAccountId());
+                    overview.setAccountName(broadcast.getAccountName());
+                    overview.setStatDate(cell.getString("0"));
+                    overview.setAmounts(cell.getBigDecimal("1"));
+                    overviewList.add(overview);
+                } else {
+                    throw new Exception("直播数据概览数据列不对");
+                }
             }
             int i = kuaishouLiveDataOverviewMapper.inserExcelBatchInfo(overviewList);
             if (i > 0) {

+ 1 - 0
ruixuan-live/src/main/java/com/ruixuan/live/service/impl/KuaishouLiveBroadcastServiceImpl.java

@@ -186,6 +186,7 @@ public class KuaishouLiveBroadcastServiceImpl implements IKuaishouLiveBroadcastS
                         msg += fileName + "、";
                         continue;
                     }
+
                     List<JSONObject> list = LiveDataExcelUtils.analysisFile(file, fileName);
                     if (Check.isNotNull(list)) {
                         if (fileName.contains("看板")) {