我们再来回顾一下创建会议申请的时序图，看看我们应该从哪下笔写程序。
我们应该先写线程任务类（MeetingWorkflowTask），后面写MeetingService的时候正好可以调用这个任务类。那咱们就在com.example.emos.api.task包中创建MeetingWorkflowTask.java类。
线程任务类发送HTTP请求给工作流项目，提交的数据中包括了会议申请人的userId、姓名、部门经理的userId，以及总经理的userId，那么这些数据都是要经过SQL语句查询的。包括线程任务类拿到instanceId之后，要更新tb_meeting表中的记录，所以还需要定义UPDATE语句。看来线程任务类的内容还挺复杂的，所以搭建请看下面的时序图。
我们按照时序图写程序，思路就清晰多了，看来时序图的作用还真挺重要。
一、编写持久层代码
TbUserDao类中的searchUserInfo()、searchDeptManagerId()、searchGmId()；TbMeetingDao类中的searchMeetingMembersInSameDept()函数，以及它们对应的SQL语句，在我上一门实战课里面都已经讲过了，所以这里就不重复说明了，直接调用即可。
在TbMeetingDao.xml文件中，定义更新会议记录instance_id字段值的SQL语句。
<update id="updateMeetingInstanceId" parameterType="HashMap">
UPDATE tb_meeting
SET instance_id=#{instanceId}
WHERE uuid=#{uuid}
</update>
在TbMeetingDao.java接口中，定义DAO方法。
public interface TbMeetingDao {
……
public int updateMeetingInstanceId(HashMap param);
}
二、定义线程任务类
首先我们要在application.yml文件中，定义接收会议审批结果的URL地址。目前这个URL对应的Web方法还没有创建，一会儿我们去创建这个Web方法。
emos:
……
recieveNotify: http://本机ID地址:8090/emos-api/meeting/recieveNotify
在com.example.emos.api.task包中创建MeetingWorkflowTask.java类，代码如下：
@Component
@Slf4j
public class MeetingWorkflowTask {
@Autowired
private TbUserDao userDao;
@Autowired
private TbMeetingDao meetingDao;
@Value("${emos.recieveNotify}")
private String recieveNotify;
@Value("${emos.code}")
private String code;
@Value("${emos.tcode}")
private String tcode;
@Value("${workflow.url}")
private String workflow;
@Async("AsyncTaskExecutor")
public void startMeetingWorkflow(String uuid, int creatorId,String title, String date, String start,String meetingType) {
//查询申请人基本信息
HashMap info = userDao.searchUserInfo(creatorId);
JSONObject json = new JSONObject();
json.set("url", recieveNotify);
json.set("uuid", uuid);
json.set("creatorId",creatorId);
json.set("creatorName",info.get("name").toString());
json.set("code", code);
json.set("tcode", tcode);
json.set("title",title);
json.set("date", date);
json.set("start", start);
json.set("meetingType",meetingType);
String[] roles = info.get("roles").toString().split("，");
//判断用户角色是不是总经理，总经理创建的会议不需要审批，所以不需要查询总经理userId和部门经理userId
if (!ArrayUtil.contains(roles, "总经理")) {
//查询部门经理userId
Integer managerId = userDao.searchDeptManagerId(creatorId);
json.set("managerId", managerId);
//查询总经理userId
Integer gmId = userDao.searchGmId();
json.set("gmId", gmId);
//查询参会人是否为同一个部门
boolean bool = meetingDao.searchMeetingMembersInSameDept(uuid);
json.set("sameDept", bool);
}
String url = workflow + "/workflow/startMeetingProcess";
HttpResponse resp = HttpRequest.post(url).header("Content-Type", "application/json")
.body(json.toString()).execute();
if (resp.getStatus() == 200) {
json = JSONUtil.parseObj(resp.body());
String instanceId = json.getStr("instanceId");
HashMap param = new HashMap();
param.put("uuid", uuid);
param.put("instanceId", instanceId);
//更新会议记录的instance_id字段
int row = meetingDao.updateMeetingInstanceId(param);
if (row != 1) {
throw new EmosException("保存会议工作流实例ID失败");
}
} else {
log.error(resp.body());
}
}
}