优化报表误差

service-user/src/main/java/com/java110/user/bmo/question/IQuestionAnswerBMO.java

@@ -1,6 +1,7 @@
 package com.java110.user.bmo.question;
 
 
+import com.alibaba.fastjson.JSONArray;
 import com.java110.po.questionAnswer.QuestionAnswerPo;
 
 public interface IQuestionAnswerBMO {
@@ -9,5 +10,5 @@ public interface IQuestionAnswerBMO {
      * @param questionAnswerPo
      * @param roomIds
      */
-    void saveUserQuestionAnswer(QuestionAnswerPo questionAnswerPo,String roomIds);
+    void saveUserQuestionAnswer(QuestionAnswerPo questionAnswerPo, JSONArray roomIds);
 }

service-user/src/main/java/com/java110/user/bmo/question/impl/QuestionAnswerBMOImpl.java

@@ -1,5 +1,6 @@
 package com.java110.user.bmo.question.impl;
 
+import com.alibaba.fastjson.JSONArray;
 import com.java110.core.factory.GenerateCodeFactory;
 import com.java110.dto.owner.OwnerRoomRelDto;
 import com.java110.dto.room.RoomDto;
@@ -33,17 +34,16 @@ public class QuestionAnswerBMOImpl implements IQuestionAnswerBMO {
 
     @Async
     @Override
-    public void saveUserQuestionAnswer(QuestionAnswerPo questionAnswerPo, String roomId) {
+    public void saveUserQuestionAnswer(QuestionAnswerPo questionAnswerPo, JSONArray roomIds) {
 
-        String[] roomIds = roomId.split(",");
-        if (roomIds == null || roomIds.length < 1) {
+        if (roomIds == null || roomIds.size() < 1) {
             return;
         }
 
         List<String> roomIdStrs = new ArrayList<>();
 
-        for (int roomIndex = 0; roomIndex < roomIds.length; roomIndex++) {
-            roomIdStrs.add(roomIds[roomIndex]);
+        for (int roomIndex = 0; roomIndex < roomIds.size(); roomIndex++) {
+            roomIdStrs.add(roomIds.getString(roomIndex));
             if (roomIdStrs.size() == MAX_LENGTH) {
                 doData(roomIdStrs, questionAnswerPo);
                 roomIdStrs = new ArrayList<>();

service-user/src/main/java/com/java110/user/cmd/question/SaveOwnerVoteCmd.java

@@ -124,6 +124,6 @@ public class SaveOwnerVoteCmd extends Cmd {
         questionAnswerTitleRelPo.setQatrId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
         questionAnswerTitleRelV1InnerServiceSMOImpl.saveQuestionAnswerTitleRel(questionAnswerTitleRelPo);
 
-        questionAnswerBMOImpl.saveUserQuestionAnswer(questionAnswerPo,reqJson.getString("roomIds"));
+        questionAnswerBMOImpl.saveUserQuestionAnswer(questionAnswerPo,reqJson.getJSONArray("roomIds"));
     }
 }