sweet

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/RedisMDSKDataUtils.java

@@ -213,20 +213,20 @@ public class RedisMDSKDataUtils {
                 ArrayList<String> signList = new ArrayList<>();
                 signList.add(artistsId);
                 vo.setSignList(signList);
-                sqls.add(SqlMapping.get("sweet_user_relation.insert"));
+                sqls.add(SqlMapping.get("sweet_user_relation_mdsk.insert"));
                 sqlsDataA.add(new Object[]{
                         uid, 2, artistsId, manualId, now
                 });
             } else {
                 if (vo.getSignList().contains(artistsId)) {
                     vo.getSignList().remove(artistsId);
-                    sqls.add(SqlMapping.get("sweet_user_relation.delete"));
+                    sqls.add(SqlMapping.get("sweet_user_relation_mdsk.delete"));
                     sqlsDataA.add(new Object[]{
                             uid, artistsId, manualId,2
                     });
                 } else {
                     vo.getSignList().add(artistsId);
-                    sqls.add(SqlMapping.get("sweet_user_relation.insert"));
+                    sqls.add(SqlMapping.get("sweet_user_relation_mdsk.insert"));
                     sqlsDataA.add(new Object[]{
                             uid, 2, artistsId, manualId, now
                     });
@@ -237,20 +237,20 @@ public class RedisMDSKDataUtils {
                 ArrayList<String> watchList = new ArrayList<>();
                 watchList.add(artistsId);
                 vo.setWatchList(watchList);
-                sqls.add(SqlMapping.get("sweet_user_relation.insert"));
+                sqls.add(SqlMapping.get("sweet_user_relation_mdsk.insert"));
                 sqlsDataA.add(new Object[]{
                         uid, 1, artistsId, manualId, now
                 });
             } else {
                 if (vo.getWatchList().contains(artistsId)) {
                     vo.getWatchList().remove(artistsId);
-                    sqls.add(SqlMapping.get("sweet_user_relation.delete"));
+                    sqls.add(SqlMapping.get("sweet_user_relation_mdsk.delete"));
                     sqlsDataA.add(new Object[]{
                             uid, artistsId, manualId,1
                     });
                 } else {
                     vo.getWatchList().add(artistsId);
-                    sqls.add(SqlMapping.get("sweet_user_relation.insert"));
+                    sqls.add(SqlMapping.get("sweet_user_relation_mdsk.insert"));
                     sqlsDataA.add(new Object[]{
                             uid, 1, artistsId, manualId, now
                     });

liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/sqlmap.properties

@@ -54,5 +54,8 @@ kylin_order_refund_entities.overtimeRefund=INSERT INTO kylin_order_refund_entiti
 sweet_user_relation.insert=INSERT INTO sweet_user_relation (user_id,type,target_id,manual_id,status,created_at) VALUES (?,?,?,?,1,?)
 sweet_user_relation.delete=DELETE FROM  sweet_user_relation WHERE user_id = ? and target_id = ? and manual_id = ? and type = ?
 
+sweet_user_relation_mdsk.insert=INSERT INTO sweet_user_relation (user_id,type,target_id,manual_id,status,created_at) VALUES (?,?,?,?,1,?)
+sweet_user_relation_mdsk.delete=DELETE FROM  sweet_user_relation WHERE user_id = ? and target_id = ? and manual_id = ? and type = ?
+
 # ------------------------用户关系----------------------------
 sweet_luck_draw.insert=INSERT INTO sweet_luck_draw (user_id,luck_draw_num,status,created_at) VALUES (?,?,1,?)