20191029 注释掉发送mq消息的代码

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 static final String key = "cache_process_doctor_repeat";
+    private  final String KEY = "cache_process_doctor_repeat";
 
     private Logger logger = LoggerFactory.getLogger(this.getClass());
 
@@ -34,11 +34,11 @@ public class DoctorRepeatDataJob {
      */
     @Scheduled(cron = "0 0 0 1/1 * ?")
     public void processDoctorRepeatData() {
-        Long result = cacheClient.setnx(key, "1");
+        Long result = cacheClient.setnx(KEY, "1");
         //如果为1说明获取到分布式锁
         if (result == 1) {
             //10分钟后锁过期
-            cacheClient.expire(key, 60 * 10);
+            cacheClient.expire(KEY, 60 * 10);
             logger.info("开始执行刷新doctor表中重复的记录");
             int row = doctorMapper.processDoctorRepeatData();
             logger.info("此次数据刷新影响的行数：{}", row);
@@ -49,7 +49,7 @@ public class DoctorRepeatDataJob {
                 logger.error(ex.getMessage(), ex);
             }
             //释放锁
-            cacheClient.del(key);
+            cacheClient.del(KEY);
         }
     }
 }

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

@@ -146,14 +146,14 @@ public class RegisterServiceImpl implements RegisterService {
                     result.setToken(newToken);
                     result.setUserId(userId);
                     result.setEntireFlag(1);
-                    ByteArrayOutputStream bos = new ByteArrayOutputStream();
+                  /*  ByteArrayOutputStream bos = new ByteArrayOutputStream();
                     DataOutputStream dos = new DataOutputStream(bos);
                     try {
                         dos.writeLong(userId);
                     } catch (IOException e) {
                         e.printStackTrace();
                     }
-                    queueProducer.send(bos.toByteArray());
+                    queueProducer.send(bos.toByteArray());*/
                     LogLoginEntity entity = AccountLogEntityUtils.getLogLoginEntity(acctId, productType, baseRequest.getSourceType(),
                             AccountTypeEnum.LOGIN_REGISTER.getCode(), baseRequest.getLoginIp(), AccountTypeEnum.LOGIN_STATUS_SUCCESS.getCode(),
                             AccountTypeEnum.LOG_TYPE_LOGIN.getCode());

server/src/main/java/com/pica/cloud/account/account/server/util/AESUtil.java

@@ -168,7 +168,7 @@ public class AESUtil {
     public static void main(String[] args) throws Exception {
         String KEY="zJJ$c5md3$yuuhWW";
         System.out.println("-------------加密---------");
-        String content = "13916000007";
+        String content = "13024112588";
         System.out.println("加密前：" + content);
         System.out.println("加密密钥和解密密钥：" + KEY);