上个小节我们写好了异步线程任务类，接下来应该编写Web方法、Service方法这些内容，本小节咱们把这些代码写完，然后用Swagger测试一下。

一、编写持久层代码

用户在弹窗页面填写的会议申请信息需要保存到数据表里面，所以我们要在TbMeetingDao.xml文件中定义SQL语句。

<insert id="insert" parameterType="com.example.emos.api.db.pojo.TbMeeting">
    INSERT INTO tb_meeting
    SET title = #{title},
    <if test="uuid!=null">
        uuid = #{uuid},
    </if>
        `date` = #{date},
        creator_id = #{creatorId},
    <if test="place!=null">
        place = #{place},
    </if>
        `start` = #{start},
        `end` = #{end},
        `type` = #{type},
        members = #{members},
        `desc` = #{desc},
        instance_id = #{instanceId},
        status = #{status},
        create_time = NOW()
</insert>

在TbMeetingDao.java接口中，定义DAO方法。

public interface TbMeetingDao {
    ……
    public int insert(TbMeeting meeting);
}

二、编写业务层代码

在MeetingService.java接口中，定义抽象方法。

public interface MeetingService {
    ……
    public int insert(TbMeeting meeting);
}

在MeetingServiceImpl.java类中，实现抽象方法。

public class MeetingServiceImpl implements MeetingService {
    ……
    @Override
    public int insert(TbMeeting meeting) {
        int rows = meetingDao.insert(meeting);
        if (rows != 1) {
            throw new EmosException("会议添加失败");
        }
        meetingWorkflowTask.startMeetingWorkflow(meeting.getUuid(), meeting.getCreatorId(), meeting.getTitle(), meeting.getDate(), meeting.getStart() + ":00", "线下会议");
        return rows;
    }
}

三、编写Web层代码

创建InsertMeetingForm.java类，封装Ajax提交的数据。

@Data
@Schema(description = "添加会议表单")
public class InsertMeetingForm {

    @NotBlank(message = "title不能为空")
    @Pattern(regexp = "^[a-zA-Z0-9\\u4e00-\\u9fa5]{2,30}$", message = "title内容不正确")
    @Schema(description = "主题")
    private String title;

    @NotBlank(message = "date不能为空")
    @Pattern(regexp = "^((((1[6-9]|[2-9]\\d)\\d{2})-(0?[13578]|1[02])-(0?[1-9]|[12]\\d|3[01]))|(((1[6-9]|[2-9]\\d)\\d{2})-(0?[13456789]|1[012])-(0?[1-9]|[12]\\d|30))|(((1[6-9]|[2-9]\\d)\\d{2})-0?2-(0?[1-9]|1\\d|2[0-8]))|(((1[6-9]|[2-9]\\d)(0[48]|[2468][048]|[13579][26])|((16|[2468][048]|[3579][26])00))-0?2-29-))$", message = "date内容不正确")
    @Schema(description = "日期")
    private String date;

    @Pattern(regexp = "^[a-zA-Z0-9\\u4e00-\\u9fa5]{2,20}$", message = "place内容不正确")
    @Schema(description = "会议地点")
    private String place;

    @NotBlank(message = "start不能为空")
    @Pattern(regexp = "^([01]?[0-9]|2[0-3]):(00|30)$", message = "start内容不正确")
    @Schema(description = "起始时间")
    private String start;

    @NotBlank(message = "end不能为空")
    @Pattern(regexp = "^([01]?[0-9]|2[0-3]):(00|30)$", message = "end内容不正确")
    @Schema(description = "结束时间")
    private String end;

    @NotNull(message = "type不能为空")
    @Range(min = 1, max = 2, message = "type内容不正确")
    @Schema(description = "会议类型")
    private Byte type;

    @NotBlank(message = "members不能为空")
    @Schema(description = "参会人")
    private String members;

    @NotBlank(message = "desc不能为空")
    @Length(min = 1, max = 200)
    @Schema(description = "内容")
    private String desc;
}

在MeetingController.java类中，定义web方法，然后用Swagger测试一下。

public class MeetingController {
    ……
    @PostMapping("/insert")
    @Operation(summary = "添加会议")
    @SaCheckLogin
    public R insert(@Valid @RequestBody InsertMeetingForm form) {
        DateTime start = DateUtil.parse(form.getDate() + " " + form.getStart());
        DateTime end = DateUtil.parse(form.getDate() + " " + form.getEnd());
        if (start.isAfterOrEquals(end)) {
            return R.error("结束时间必须大于开始时间");
        } else if (new DateTime().isAfterOrEquals(start)) {
            return R.error("会议开始时间不能早于当前时间");
        }
        TbMeeting meeting = JSONUtil.parse(form).toBean(TbMeeting.class);
        meeting.setUuid(UUID.randomUUID().toString(true));
        meeting.setCreatorId(StpUtil.getLoginIdAsInt());
        meeting.setStatus((short) 1);
        int rows = meetingService.insert(meeting);
        return R.ok().put("rows", rows);
    }
}

创建RecieveNotifyForm.java类，封装工作流项目发送的数据。

@Data
public class RecieveNotifyForm {
    @NotBlank
    private String processId;
    @NotBlank
    private String uuid;
    @NotBlank
    private String result;
}

在MeetingController.java类中，定义接收会议审批结果的Web方法。

public class MeetingController {
    ……
    @PostMapping("/recieveNotify")
    @Operation(summary = "接收工作流通知")
    public R recieveNotify(@Valid @RequestBody RecieveNotifyForm form){
        if(form.getResult().equals("同意")){
            log.debug(form.getUuid()+"的会议审批通过");
        }
        else{
            log.debug(form.getUuid()+"的会议审批不通过");
        }
        return R.ok();
    }
}