20191030 定时任务的执行(redis锁不让用)

server/src/main/java/com/pica/cloud/account/account/server/job/DoctorRepeatDataJob.java

@@ -17,7 +17,7 @@ import org.springframework.stereotype.Component;
  */
 @Component
 public class DoctorRepeatDataJob {
-    private  final String KEY = "cache_process_doctor_repeat";
+    private final String KEY = "cacheProcessDoctorRepeat";
 
     private Logger logger = LoggerFactory.getLogger(this.getClass());
 
@@ -32,12 +32,12 @@ public class DoctorRepeatDataJob {
      * 1、使用分布式锁保证一个微服务执行；
      * 2、定时任务；
      */
-    @Scheduled(cron = "0 0 0 1/1 * ?")
+    @Scheduled(cron = "0 0 0 * * ?")
     public void processDoctorRepeatData() {
-        Long result = cacheClient.setnx(KEY, "1");
-        //如果为1说明获取到分布式锁
-        if (result == 1) {
-            //10分钟后锁过期
+        //通过接口幂等性逻辑处理
+        String exist = cacheClient.get(KEY);
+        if (exist==null){
+            cacheClient.set(KEY,"1");
             cacheClient.expire(KEY, 60 * 10);
             logger.info("开始执行刷新doctor表中重复的记录");
             int row = doctorMapper.processDoctorRepeatData();

server/src/main/java/com/pica/cloud/account/account/server/service/impl/RegisterServiceImpl.java

@@ -9,14 +9,12 @@ import com.pica.cloud.account.account.server.exception.AccountException;
 import com.pica.cloud.account.account.server.log.AccountLogEntityUtils;
 import com.pica.cloud.account.account.server.log.AccountLogUtils;
 import com.pica.cloud.account.account.server.mapper.*;
-import com.pica.cloud.account.account.server.queue.QueueProducer;
 import com.pica.cloud.account.account.server.req.BaseRequest;
 import com.pica.cloud.account.account.server.service.RegisterService;
 import com.pica.cloud.account.account.server.util.AESUtil;
 import com.pica.cloud.account.account.server.util.AccountUtils;
 import com.pica.cloud.account.account.server.util.ExecutorServiceUtils;
 import com.pica.cloud.account.account.server.util.TokenUtils;
-import com.pica.cloud.foundation.entity.PicaResponse;
 import com.pica.cloud.foundation.redis.ICacheClient;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
@@ -25,9 +23,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
 
-import java.io.ByteArrayOutputStream;
-import java.io.DataOutputStream;
-import java.io.IOException;
 import java.util.Date;
 import java.util.concurrent.ExecutorService;
 
@@ -56,8 +51,8 @@ public class RegisterServiceImpl implements RegisterService {
     @Autowired
     private TokenUtils tokenUtils;
 
-    @Autowired
-    private QueueProducer queueProducer;
+//    @Autowired
+//    private QueueProducer queueProducer;
 
     @Autowired
     private AgreementEntityMapper agreementEntityMapper;