From 5700f42a37a2f9ecc27161e2b0559a820d320f6b Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期一, 17 三月 2025 15:11:40 +0800
Subject: [PATCH] 开发完成同一个手机号登录不同物业公司的支持
---
service-user/src/main/java/com/java110/user/cmd/question/DeleteQuestionAnswerCmd.java | 59 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 57 insertions(+), 2 deletions(-)
diff --git a/service-user/src/main/java/com/java110/user/cmd/question/DeleteQuestionAnswerCmd.java b/service-user/src/main/java/com/java110/user/cmd/question/DeleteQuestionAnswerCmd.java
index d01de06..1c7aa90 100644
--- a/service-user/src/main/java/com/java110/user/cmd/question/DeleteQuestionAnswerCmd.java
+++ b/service-user/src/main/java/com/java110/user/cmd/question/DeleteQuestionAnswerCmd.java
@@ -21,8 +21,13 @@
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
-import com.java110.intf.user.IQuestionAnswerV1InnerServiceSMO;
-import com.java110.po.questionAnswer.QuestionAnswerPo;
+import com.java110.dto.question.QuestionAnswerTitleRelDto;
+import com.java110.intf.user.*;
+import com.java110.po.question.QuestionAnswerPo;
+import com.java110.po.question.QuestionAnswerTitleRelPo;
+import com.java110.po.question.QuestionTitlePo;
+import com.java110.po.question.QuestionTitleValuePo;
+import com.java110.po.user.UserQuestionAnswerPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
@@ -30,6 +35,8 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+
+import java.util.List;
/**
* 绫昏〃杩帮細鍒犻櫎
@@ -48,6 +55,18 @@
@Autowired
private IQuestionAnswerV1InnerServiceSMO questionAnswerV1InnerServiceSMOImpl;
+ @Autowired
+ private IQuestionAnswerTitleRelV1InnerServiceSMO questionAnswerTitleRelV1InnerServiceSMOImpl;
+
+ @Autowired
+ private IQuestionTitleV1InnerServiceSMO questionTitleV1InnerServiceSMOImpl;
+
+ @Autowired
+ private IQuestionTitleValueV1InnerServiceSMO questionTitleValueV1InnerServiceSMOImpl;
+
+ @Autowired
+ private IUserQuestionAnswerV1InnerServiceSMO userQuestionAnswerV1InnerServiceSMOImpl;
+
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
Assert.hasKeyAndValue(reqJson, "qaId", "qaId涓嶈兘涓虹┖");
@@ -66,6 +85,42 @@
throw new CmdException("鍒犻櫎鏁版嵁澶辫触");
}
+
+ //todo 鍒犻櫎 棰樼洰
+ QuestionAnswerTitleRelDto questionAnswerTitleRelDto = new QuestionAnswerTitleRelDto();
+ questionAnswerTitleRelDto.setQaId(reqJson.getString("qaId"));
+ questionAnswerTitleRelDto.setCommunityId(reqJson.getString("communityId"));
+ List<QuestionAnswerTitleRelDto> questionAnswerTitleRelDtos = questionAnswerTitleRelV1InnerServiceSMOImpl.queryQuestionAnswerTitleRels(questionAnswerTitleRelDto);
+ if (questionAnswerTitleRelDtos == null || questionAnswerTitleRelDtos.size() < 1) {
+ return;
+ }
+
+ QuestionAnswerTitleRelPo questionAnswerTitleRelPo = new QuestionAnswerTitleRelPo();
+ questionAnswerTitleRelPo.setQatrId(questionAnswerTitleRelDtos.get(0).getQatrId());
+ questionAnswerTitleRelPo.setCommunityId(reqJson.getString("communityId"));
+ questionAnswerTitleRelV1InnerServiceSMOImpl.deleteQuestionAnswerTitleRel(questionAnswerTitleRelPo);
+
+ //todo 鍒犻櫎棰樼洰
+ QuestionTitlePo questionTitlePo = new QuestionTitlePo();
+ questionTitlePo.setTitleId(questionAnswerTitleRelDtos.get(0).getTitleId());
+ questionTitlePo.setCommunityId(reqJson.getString("communityId"));
+ questionTitleV1InnerServiceSMOImpl.deleteQuestionTitle(questionTitlePo);
+
+ //todo 鍒犻櫎閫夐」
+ QuestionTitleValuePo questionTitleValuePo = new QuestionTitleValuePo();
+ questionTitleValuePo.setTitleId(questionAnswerTitleRelDtos.get(0).getTitleId());
+ questionTitleValuePo.setCommunityId(reqJson.getString("communityId"));
+ questionTitleValueV1InnerServiceSMOImpl.deleteQuestionTitleValue(questionTitleValuePo);
+
+ //todo 鍒犻櫎鐢ㄦ埛鎶曠エ
+ UserQuestionAnswerPo userQuestionAnswerPo = new UserQuestionAnswerPo();
+ userQuestionAnswerPo.setQaId(reqJson.getString("qaId"));
+ userQuestionAnswerPo.setCommunityId(reqJson.getString("communityId"));
+ userQuestionAnswerV1InnerServiceSMOImpl.deleteUserQuestionAnswer(userQuestionAnswerPo);
+
+ //todo 鍒犻櫎鐢ㄦ埛鎶曠エ鍊�
+
+
cmdDataFlowContext.setResponseEntity(ResultVo.success());
}
}
--
Gitblit v1.8.0