wuxw
2024-02-26 a1066531335bdaa7664551f57921ad647711de7d
service-store/src/main/java/com/java110/store/cmd/complaintAppraise/SaveComplaintAppraiseCmd.java
@@ -23,10 +23,13 @@
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.complaintEvent.ComplaintEventDto;
import com.java110.dto.user.UserDto;
import com.java110.intf.store.IComplaintAppraiseV1InnerServiceSMO;
import com.java110.intf.store.IComplaintEventV1InnerServiceSMO;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.po.complaintAppraise.ComplaintAppraisePo;
import com.java110.po.complaintEvent.ComplaintEventPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
@@ -56,6 +59,9 @@
    @Autowired
    private IComplaintAppraiseV1InnerServiceSMO complaintAppraiseV1InnerServiceSMOImpl;
    @Autowired
    private IComplaintEventV1InnerServiceSMO complaintEventV1InnerServiceSMOImpl;
    @Autowired
    private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
@@ -92,6 +98,18 @@
            throw new CmdException("保存数据失败");
        }
        ComplaintEventPo complaintEventPo = new ComplaintEventPo();
        complaintEventPo.setEventId(GenerateCodeFactory.getGeneratorId("11"));
        complaintEventPo.setCreateUserId(userDtos.get(0).getUserId());
        complaintEventPo.setCreateUserName(userDtos.get(0).getName());
        complaintEventPo.setComplaintId(reqJson.getString("complaintId"));
        complaintEventPo.setRemark(reqJson.getString("context"));
        complaintEventPo.setEventType(ComplaintEventDto.EVENT_TYPE_APPRAISE);
        complaintEventPo.setCommunityId(reqJson.getString("communityId"));
        complaintEventV1InnerServiceSMOImpl.saveComplaintEvent(complaintEventPo);
        cmdDataFlowContext.setResponseEntity(ResultVo.success());
    }
}