优化代码

java110-db/src/main/resources/mapper/user/QuestionAnswerServiceDaoImplMapper.xml

@@ -5,8 +5,8 @@
 
     <!-- 保存答卷信息 add by wuxw 2018-07-03 -->
     <insert id="saveQuestionAnswerInfo" parameterType="Map">
-        insert into question_answer(qa_name, qa_type, start_time, end_time, remark, obj_type, obj_id, qa_id, content)
-        values (#{qaName}, #{qaType}, #{startTime}, #{endTime}, #{remark}, #{objType}, #{objId}, #{qaId}, #{content})
+        insert into question_answer(qa_name, qa_type, start_time, end_time, remark,  obj_id, qa_id, content)
+        values (#{qaName}, #{qaType}, #{startTime}, #{endTime}, #{remark}, #{objType}, #{qaId}, #{content})
     </insert>
 
     <!-- 查询答卷信息 add by wuxw 2018-07-03 -->

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

@@ -21,8 +21,14 @@ import com.java110.core.annotation.Java110Transactional;
 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.dto.questionAnswerTitleRel.QuestionAnswerTitleRelDto;
+import com.java110.intf.user.*;
 import com.java110.po.questionAnswer.QuestionAnswerPo;
+import com.java110.po.questionAnswer.QuestionAnswerTitlePo;
+import com.java110.po.questionAnswerTitleRel.QuestionAnswerTitleRelPo;
+import com.java110.po.questionTitle.QuestionTitlePo;
+import com.java110.po.questionTitleValue.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;
@@ -31,6 +37,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.List;
+
 /**
  * 类表述：删除
  * 服务编码：questionAnswer.deleteQuestionAnswer
@@ -48,6 +56,18 @@ public class DeleteQuestionAnswerCmd extends Cmd {
     @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 +86,42 @@ public class DeleteQuestionAnswerCmd extends Cmd {
             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());
     }
 }