diff --git a/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java b/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java index e7afb97..fff4f50 100644 --- a/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java +++ b/platform-job-index/src/main/java/com/lyms/platform/job/index/service/SyncDataService.java @@ -27,7 +27,7 @@ import java.util.concurrent.TimeUnit; /** * Created by Administrator on 2016/10/13. */ -@Service +@Service("job-index-syncdataservice") public class SyncDataService { private static BlockingQueue patientsQueue = new LinkedBlockingQueue(); diff --git a/platform-job-index/src/main/java/com/lyms/platform/job/index/web/controller/SyncDataController.java b/platform-job-index/src/main/java/com/lyms/platform/job/index/web/controller/SyncDataController.java index 85a9754..040b3ab 100644 --- a/platform-job-index/src/main/java/com/lyms/platform/job/index/web/controller/SyncDataController.java +++ b/platform-job-index/src/main/java/com/lyms/platform/job/index/web/controller/SyncDataController.java @@ -2,6 +2,7 @@ package com.lyms.platform.job.index.web.controller; import com.lyms.platform.job.index.service.SyncDataService; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; @@ -18,6 +19,7 @@ import org.springframework.web.bind.annotation.ResponseBody; public class SyncDataController { @Autowired + @Qualifier("job-index-syncdataservice") private SyncDataService syncDataService; /** @@ -37,7 +39,7 @@ public class SyncDataController { @RequestMapping(value = "/syncBabyData", method = RequestMethod.GET) @ResponseBody public String syncBabyData(@RequestParam(required = true) String oracleHid,@RequestParam(required = true) Integer mysqlHid) { - syncDataService.syncBabyData(oracleHid,mysqlHid); + syncDataService.syncBabyData(oracleHid, mysqlHid); return "baby starting..........."; } }