5-16 手动抓取

yxt-supervise-dbcenter/yxt-supervise-dbcenter-biz/src/main/java/com/yxt/supervise/dbcenter/zhj/crawl/biz/crawlSalesAmount/CrawlSalesAmountService.java

@@ -121,15 +121,19 @@ public class CrawlSalesAmountService extends ServiceImpl<CrawlSalesAmountMapper,
         if (time.equals(d.format(date))){
             return rb.setMsg("只能抓取今天之前的数据");
         }
-        if (param.get("salesAmount").toString() != null && !param.get("salesAmount").toString().equals("")){
-            pullData(time);
-        }
-        if (param.get("purchase").toString() != null && !param.get("purchase").toString().equals("")){
-            crawlPurchaseService.pullData(time);
-        }
-        if (param.get("salesDishes").toString() != null && !param.get("salesDishes").toString().equals("")){
-            crawlSalesDishesService.pullData(time);
+        if (param.get("data") != null){
+            Map<String, Object> data = (Map<String, Object>)param.get("data");
+            if (data.get("salesAmount").toString() != null && !data.get("salesAmount").toString().equals("")){
+                pullData(time);
+            }
+            if (data.get("purchase").toString() != null && !data.get("purchase").toString().equals("")){
+                crawlPurchaseService.pullData(time);
+            }
+            if (data.get("salesDishes").toString() != null && !data.get("salesDishes").toString().equals("")){
+                crawlSalesDishesService.pullData(time);
+            }
+            return rb.success().setMsg("抓取成功");
         }
-        return rb.success().setMsg("抓取成功");
+        return rb.setMsg("请选择要抓取的数据");
     }
 }