运营加入 房屋和房屋明细功能

wuxw

2025-02-28 f4ea663cc61e37a7ab645f2c35e9bcc7f2be7cf8

 service-user/src/main/java/com/java110/user/cmd/notepad/SaveNotepadCmd.java

@@ -22,15 +22,21 @@
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.notepad.NotepadDto;
import com.java110.dto.user.UserDto;
import com.java110.intf.user.INotepadV1InnerServiceSMO;
import com.java110.intf.user.IUserInnerServiceSMO;
import com.java110.po.notepad.NotepadPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.List;

/**
 * 类表述：保存
@@ -52,25 +58,53 @@
    @Autowired
    private INotepadV1InnerServiceSMO notepadV1InnerServiceSMOImpl;

    @Autowired
    private IUserInnerServiceSMO userInnerServiceSMOImpl;

    @Override
    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
        Assert.hasKeyAndValue(reqJson, "noteType", "请求报文中未包含noteType");
        Assert.hasKeyAndValue(reqJson, "title", "请求报文中未包含title");
        Assert.hasKeyAndValue(reqJson, "objType", "请求报文中未包含objType");
        Assert.hasKeyAndValue(reqJson, "objId", "请求报文中未包含objId");
        Assert.hasKeyAndValue(reqJson, "objName", "请求报文中未包含objName");
        Assert.hasKeyAndValue(reqJson, "createUserId", "请求报文中未包含createUserId");
        Assert.hasKeyAndValue(reqJson, "createUserName", "请求报文中未包含createUserName");
        Assert.hasKeyAndValue(reqJson, "state", "请求报文中未包含state");

    }

    @Override
    @Java110Transactional
    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {

        String userId = cmdDataFlowContext.getReqHeaders().get("user-id");
        UserDto userDto = new UserDto();
        userDto.setUserId(userId);
        userDto.setPage(1);
        userDto.setRow(1);
        List<UserDto> userDtos = userInnerServiceSMOImpl.getUsers(userDto);
        Assert.listOnlyOne(userDtos, "用户不存在");

        reqJson.put("createUserId", userDtos.get(0).getUserId());
        reqJson.put("createUserName", userDtos.get(0).getName());

        if (!StringUtil.jsonHasKayAndValue(reqJson, "roomId")) {
            reqJson.put("roomId", "-1");
        }
        if (!StringUtil.jsonHasKayAndValue(reqJson, "roomName")) {
            reqJson.put("roomId", "无");
        }

        if (!StringUtil.jsonHasKayAndValue(reqJson, "objId")) {
            reqJson.put("objId", "-1");
        }

        if (!StringUtil.jsonHasKayAndValue(reqJson, "objName")) {
            reqJson.put("objName", "无");
        }

        if (!StringUtil.jsonHasKayAndValue(reqJson, "objType")) {
            reqJson.put("objType", "3309");
        }

        NotepadPo notepadPo = BeanConvertUtil.covertBean(reqJson, NotepadPo.class);
        notepadPo.setNoteId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
        notepadPo.setState(NotepadDto.STATE_DOING);
        int flag = notepadV1InnerServiceSMOImpl.saveNotepad(notepadPo);

        if (flag < 1) {