fix sql to mq;

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamAddressesServiceImpl.java

@@ -150,7 +150,7 @@ public class AdamAddressesServiceImpl extends ServiceImpl<AdamAddressesMapper, A
         );
 
         // TODO: 2021/5/14
-        List<Object> paramList = Arrays.asList(null);
+        List<Object> paramList = Arrays.asList();
 //        rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
 //                SqlMapping.get("adam_addresses.edit", paramList.toArray()));
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamRealNameServiceImpl.java

@@ -7,14 +7,19 @@ import com.liquidnet.service.adam.dto.vo.AdamRealInfoVo;
 import com.liquidnet.service.adam.entity.AdamRealName;
 import com.liquidnet.service.adam.mapper.AdamRealNameMapper;
 import com.liquidnet.service.adam.service.IAdamRealNameService;
+import com.liquidnet.service.base.SqlMapping;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
 
-import java.util.Collection;
+import java.util.Arrays;
 import java.util.Collections;
+import java.util.List;
 
 /**
  * <p>
@@ -30,6 +35,8 @@ public class AdamRealNameServiceImpl extends ServiceImpl<AdamRealNameMapper, Ada
     MongoTemplate mongoTemplate;
     @Autowired
     RedisUtil redisUtil;
+    @Autowired
+    RabbitTemplate rabbitTemplate;
 
     @Override
     public AdamRealInfoVo queryByUid(String uid) {
@@ -44,10 +51,20 @@ public class AdamRealNameServiceImpl extends ServiceImpl<AdamRealNameMapper, Ada
     }
 
     @Override
+    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
     public void add(AdamRealName realName) {
         mongoTemplate.insert(Collections.singletonList(realName), AdamRealInfoVo.class.getSimpleName());
 
-        // TODO: 2021/5/18 sql to mq
-
+        List<Object> paramList = Arrays.asList(
+                realName.getRealNameId(),
+                realName.getUid(),
+                realName.getType(),
+                realName.getName(),
+                realName.getIdCard(),
+                realName.getState(),
+                realName.getCreatedAt()
+        );
+//        rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
+//                SqlMapping.get("adam_real_name.add", paramList.toArray()));
     }
 }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserServiceImpl.java

@@ -40,7 +40,6 @@ import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
 import java.util.Arrays;
-import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
 
@@ -92,6 +91,7 @@ public class AdamUserServiceImpl extends ServiceImpl<AdamUserMapper, AdamUser> i
     }
 
     @Override
+    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
     public AdamUserInfoVo register(String mobile) {
         LocalDateTime now = LocalDateTime.now();
         String nowStr = DateUtil.format(now, DateUtil.Formatter.yyyyMMddHHmmss);
@@ -207,6 +207,12 @@ public class AdamUserServiceImpl extends ServiceImpl<AdamUserMapper, AdamUser> i
         return thirdPartInfoVos;
     }
 
+    /**
+     * 解绑第三方账号操作
+     *
+     * @param uid
+     * @param platform
+     */
     private void unBindTpaProcess(String uid, String platform) {
         LocalDateTime now = LocalDateTime.now();
         String nowStr = DateUtil.format(now, DateUtil.Formatter.yyyyMMddHHmmss);
@@ -214,12 +220,14 @@ public class AdamUserServiceImpl extends ServiceImpl<AdamUserMapper, AdamUser> i
         AdamThirdPartInfoVo unBindThirdPartInfoVo = AdamThirdPartInfoVo.getNew();
         unBindThirdPartInfoVo.setUpdatedAt(nowStr);
         unBindThirdPartInfoVo.setState(2);// 2-解绑
-        BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(unBindThirdPartInfoVo));
-        mongoTemplate.getCollection(AdamThirdPartInfoVo.class.getSimpleName()).findOneAndUpdate(
+
+        mongoTemplate.getCollection(AdamThirdPartInfoVo.class.getSimpleName()).updateOne(
                 Query.query(Criteria.where("uid").is(uid).and("platform").is(platform).and("state").is(1)).getQueryObject(),
-                object
+                new BasicDBObject("$set", mongoConverter.convertToMongoType(unBindThirdPartInfoVo))
         );
-        // TODO: 2021/5/14 Execute sql to mq
+
+//        rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL, MQConst.ROUTING_KEY_SQL,
+//                SqlMapping.get("adam_third_party.unbind", now, uid, platform));
     }
 
     @Override
@@ -308,9 +316,6 @@ public class AdamUserServiceImpl extends ServiceImpl<AdamUserMapper, AdamUser> i
 
         redisUtil.hset(AdamRedisConst.INFO_REAL_NAME, uid, realInfoVo);
 
-        // TODO: 2021/5/18 修改UserInfoVo，同步redis
-
-
         return realInfoVo;
     }
 }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/resources/sqlmap/adam_real_name.properties

+adam_real_name.add=INSERT INTO ln_adam.adam_real_name (real_name_id, `uid`, `type`, `name`, id_card, `state`, created_at) VALUES (?,?,?,?,?,?,?) 
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/resources/sqlmap/adam_third_party.properties

-adam_third_party.add=INSERT INTO ln_adam.adam_third_party (`uid`, open_id, avatar, nickname, platform, `state`, created_at) values (?,?,?,?,?,?,?)
+adam_third_party.add=INSERT INTO ln_adam.adam_third_party (`uid`, open_id, avatar, nickname, platform, `state`, created_at) values (?,?,?,?,?,?,?) 
\ No newline at end of file
+adam_third_party.unbind=UPDATE ln_adam.adam_third_party SET `state`=2, updated_at=? WHERE `uid`=? AND platform=? AND `state`=1
\ No newline at end of file