“20191106 定时任务job

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

 package com.pica.cloud.account.account.server.job;
 
+import com.pica.cloud.account.account.server.mapper.AccountInfoDetailMapper;
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.IJobHandler;
 import com.xxl.job.core.handler.annotation.JobHandler;
+import com.xxl.job.core.log.XxlJobLogger;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 /**
@@ -10,12 +13,17 @@ import org.springframework.stereotype.Component;
  * author:crs
  * Description:doctor表重复记录处理
  */
-@JobHandler(value="AccountRepeatDataJob")
+@JobHandler(value = "AccountRepeatDataJob")
 @Component
 public class AccountRepeatDataJob extends IJobHandler {
 
+    @Autowired
+    private AccountInfoDetailMapper accountInfoDetailMapper;
+
     @Override
     public ReturnT<String> execute(String s) throws Exception {
+        accountInfoDetailMapper.processAccountRepeatData();
+        XxlJobLogger.log("刷新数据");
         return null;
     }
 }

server/src/main/java/com/pica/cloud/account/account/server/mapper/AccountInfoDetailMapper.java

@@ -59,4 +59,6 @@ public interface AccountInfoDetailMapper {
     int insertSelective(AccountInfoEntity record);
 
     void updateDeleteByPrimaryKey(Integer acctId);
+
+    void processAccountRepeatData();
 }

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

@@ -166,26 +166,26 @@ public class AESUtil {
      * 测试
      */
     public static void main(String[] args) throws Exception {
-//        String KEY="zJJ$c5md3$yuuhWW";
-//        System.out.println("-------------加密---------");
-//        String content = "13024112588";
-//        System.out.println("加密前：" + content);
-//        System.out.println("加密密钥和解密密钥：" + KEY);
-//
-//        System.out.println(
-//        "-------------解密---------");
-//        String encrypt = aesEncrypt(content, KEY);
-//        System.out.println("加密后：" + encrypt);
-//        String decrypt = aesDecrypt(encrypt, KEY);
-//        System.out.println("解密后：" + decrypt);
+        String KEY="E7vO8Mqbq5ObzhGi";
+        System.out.println("-------------加密---------");
+        String content = "15607241351";
+        System.out.println("加密前：" + content);
+        System.out.println("加密密钥和解密密钥：" + KEY);
+
+        System.out.println(
+        "-------------解密---------");
+        String encrypt = aesEncrypt(content, KEY);
+        System.out.println("加密后：" + encrypt);
+        String decrypt = aesDecrypt(encrypt, KEY);
+        System.out.println("解密后：" + decrypt);
 
 
         //请求参数解密处理
-        String key="Vi/4mtanXFW8huqyNi5/XMRWzTkMVFkHCDE53g49ye4AqUsaiKbINdmkFD+g+RyKeS2tEb+6ELukic3GCtZd0wT4iNzK9YVZoMDFQ9JaZwMn0HXSefnSGociozj5hRXHaim3oOuufRKmtJw372rVg4DEVuGLaIpBzdB5wNlaTbY=";
-        String decrypt = RSAUtil.decrypt(key,privateKey);
-        System.out.println(decrypt);
-        String content="lz8KLqk3rWsNLgMxCpuWOb0fQm3s4z6Oej67dYGu5cY=";
-        String result = AESUtil.aesDecrypt(content, decrypt);
-        System.out.println(result);
+//        String key="Vi/4mtanXFW8huqyNi5/XMRWzTkMVFkHCDE53g49ye4AqUsaiKbINdmkFD+g+RyKeS2tEb+6ELukic3GCtZd0wT4iNzK9YVZoMDFQ9JaZwMn0HXSefnSGociozj5hRXHaim3oOuufRKmtJw372rVg4DEVuGLaIpBzdB5wNlaTbY=";
+//        String decrypt = RSAUtil.decrypt(key,privateKey);
+//        System.out.println(decrypt);
+//        String content="lz8KLqk3rWsNLgMxCpuWOb0fQm3s4z6Oej67dYGu5cY=";
+//        String result = AESUtil.aesDecrypt(content, decrypt);
+//        System.out.println(result);
     }
 }

server/src/main/resources/bootstrap-dev.properties

@@ -57,7 +57,7 @@ management.endpoint.health.show-details=always
 xxl.job.admin.addresses=http://192.168.110.124:7899/job
 
 #执行器命名规则job-exec-<申请Port>
-xxl.job.executor.appname=job-exec-<申请Port>
+xxl.job.executor.appname=job-exec-7906
 xxl.job.executor.ip=
 xxl.job.executor.port=<申请Port>
 

server/src/main/resources/bootstrap-prod.properties

@@ -53,7 +53,7 @@ management.endpoint.health.show-details=always
 xxl.job.admin.addresses=http://172.19.137.74:7899/job,http://172.19.137.75:7899/job
 
 #执行器命名规则job-exec-<申请Port>
-xxl.job.executor.appname=job-exec-<申请Port>
+xxl.job.executor.appname=job-exec-7906
 xxl.job.executor.ip=
 xxl.job.executor.port=<申请Port>
 

server/src/main/resources/bootstrap-test1.properties

@@ -56,7 +56,7 @@ spring.rabbitmq.virtual-host=account-register-vhost
 xxl.job.admin.addresses=http://192.168.110.133:7899/job
 
 #执行器命名规则job-exec-<申请Port>
-xxl.job.executor.appname=job-exec-<申请Port>
+xxl.job.executor.appname=job-exec-7906
 xxl.job.executor.ip=
 xxl.job.executor.port=<申请Port>
 

server/src/main/resources/bootstrap-test2.properties

@@ -56,7 +56,7 @@ spring.rabbitmq.virtual-host=account-register-vhost
 xxl.job.admin.addresses=http://192.168.110.124:7899/job
 
 #执行器命名规则job-exec-<申请Port>
-xxl.job.executor.appname=job-exec-<申请Port>
+xxl.job.executor.appname=job-exec-7906
 xxl.job.executor.ip=
 xxl.job.executor.port=<申请Port>
 

server/src/main/resources/bootstrap-uat.properties

@@ -56,7 +56,7 @@ spring.rabbitmq.virtual-host=account-register-vhost
 xxl.job.admin.addresses=http://192.168.110.141:7899/job
 
 #执行器命名规则job-exec-<申请Port>
-xxl.job.executor.appname=job-exec-<申请Port>
+xxl.job.executor.appname=job-exec-7906
 xxl.job.executor.ip=
 xxl.job.executor.port=<申请Port>
 

server/src/main/resources/mybatis/AccountInfoEntityMapper.xml

@@ -50,6 +50,12 @@
       update account_info set created_id=#{acctId}, modified_id=#{acctId} where id=#{acctId}
   </update>
 
+    <update id="processAccountRepeatData">
+        update account_info set delete_flag=2, modified_id=101432928, modified_time=now() where id in (select id from (select pd.id from account_info pd
+        inner JOIN (SELECT mobile_phone,MIN(id) as id FROM account_info WHERE delete_flag=1 and mobile_phone is not null GROUP BY mobile_phone having count(*)>1) inn
+        on pd.id != inn.id and pd.mobile_phone = inn.mobile_phone) ttt);
+    </update>
+
     <!--逻辑删除用户-->
     <update id="updateDeleteByPrimaryKey" parameterType="java.lang.Integer">
       update account_info set delete_flag=2,modified_time=now(), modified_id=#{acctId} where id=#{acctId}