汾渭数据源-接口数据爬取

services/fenwei/processor_factory.go

@@ -3,8 +3,8 @@
 package fenwei
 
 const (
-	url   = "https://www.sxcoal.com/api/coalresource-adhoc/queryV1/data"
-	byUrl = "https://www.sxcoal.com/api/coalresource-adhoc/queryV1/byData"
+	fenWeiUrl   = "https://www.sxcoal.com/api/coalresource-adhoc/queryV1/data"
+	fenWeiByUrl = "https://www.sxcoal.com/api/coalresource-adhoc/queryV1/byData"
 )
 
 type ProcessorFactory struct{}
@@ -13,91 +13,91 @@ func (f *ProcessorFactory) CreateProcessor(module string) DataProcessor {
 	switch module {
 	case "动力煤供应量":
 		return &ThermalCoalSupplyProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "炼焦精煤供应量":
 		return &CokingCleanCoalSupplyProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "原煤分省分煤种产量":
 		return &RawCoalProvinceProductionProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "国有重点煤矿原煤产量":
 		return &StateOwnedKeyCoalMineRawCoalProductionProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "炼焦烟煤分煤种产量":
 		return &CokingBituminousCoalProductionProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "动力煤库存-全社会":
 		return &ThermalCoalInventorySocietyProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "动力煤库存-生产企业":
 		return &ThermalCoalInventoryProductionProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "动力煤库存-六大电厂":
 		return &ThermalCoalInventorySixPowerPlantProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "炼焦煤库存-全社会":
 		return &CokingCoalInventorySocietyProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "炼焦煤库存-生产企业":
 		return &CokingCoalInventoryProductionProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "炼焦煤库存-下游企业":
 		return &CokingCoalInventoryDownstreamProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "全国煤矿库存":
 		return &NationalCoalMineInventoryProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "国有重点煤矿库存":
 		return &StateOwnedKeyCoalMineInventoryProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "焦炭库存":
 		return &CokeInventoryProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "港口数据-库存-北方港口":
 		return &PortDataInventoryNorthernPortProcessor{
-			BaseProcessor{URL: byUrl},
+			BaseProcessor{URL: fenWeiByUrl},
 		}
 	case "港口数据-库存-江内港口":
 		return &PortDataInventoryInlandPortProcessor{
-			BaseProcessor{URL: byUrl},
+			BaseProcessor{URL: fenWeiByUrl},
 		}
 	case "港口数据-调度-北方港口":
 		return &PortDataDispatchNorthernPortProcessor{
-			BaseProcessor{URL: byUrl},
+			BaseProcessor{URL: fenWeiByUrl},
 		}
 	case "港口数据-运量":
 		return &PortDataThroughputProcessor{
-			BaseProcessor{URL: byUrl},
+			BaseProcessor{URL: fenWeiByUrl},
 		}
 	case "大秦线日运量":
 		return &DaqinLineDailyThroughputProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "动力煤港口价格":
 		return &ThermalCoalPortPriceProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "动力煤消费量":
 		return &ThermalCoalConsumptionProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 	case "炼焦精煤消费量":
 		return &CokingCleanCoalConsumptionProcessor{
-			BaseProcessor{URL: url},
+			BaseProcessor{URL: fenWeiUrl},
 		}
 
 	default: