|
@@ -4,12 +4,19 @@ import com.google.gson.Gson;
|
|
|
import com.persagy.common.enums.ResponseCode;
|
|
|
import com.persagy.common.exception.BusinessException;
|
|
|
import com.persagy.fm.common.jms.MsgBaseHandler;
|
|
|
+import com.persagy.fm.department.constant.enums.DepTypeEnum;
|
|
|
+import com.persagy.fm.department.model.Department;
|
|
|
+import com.persagy.fm.department.model.dto.QueryDepartmentDTO;
|
|
|
+import com.persagy.fm.department.service.IDepartmentService;
|
|
|
import com.persagy.fm.person.constant.PersonJmsType;
|
|
|
import com.persagy.fm.person.jms.model.AccountCreateMsg;
|
|
|
import com.persagy.fm.person.jms.model.AccountUpdateMsg;
|
|
|
import com.persagy.fm.person.model.ConvertPersonTool;
|
|
|
import com.persagy.fm.person.model.Person;
|
|
|
import com.persagy.fm.person.service.IPersonService;
|
|
|
+import com.persagy.fm.workresume.constant.enums.WorkResumeStateEnum;
|
|
|
+import com.persagy.fm.workresume.model.dto.AddWorkResumeDTO;
|
|
|
+import com.persagy.fm.workresume.service.IWorkResumeService;
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
import org.springframework.amqp.core.Message;
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
@@ -18,6 +25,7 @@ import org.springframework.stereotype.Service;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
import java.io.IOException;
|
|
|
+import java.util.Date;
|
|
|
import java.util.List;
|
|
|
|
|
|
/**
|
|
@@ -31,6 +39,10 @@ public class AccountMsgHandler {
|
|
|
@Autowired
|
|
|
private IPersonService personService;
|
|
|
@Autowired
|
|
|
+ private IWorkResumeService workResumeService;
|
|
|
+ @Autowired
|
|
|
+ private IDepartmentService departmentService;
|
|
|
+ @Autowired
|
|
|
MsgBaseHandler msgBaseHandler;
|
|
|
|
|
|
/**
|
|
@@ -41,8 +53,24 @@ public class AccountMsgHandler {
|
|
|
* @version V1.0 2021/3/18 11:40 上午
|
|
|
*/
|
|
|
public void createAccount(AccountCreateMsg accountCreateMsg) {
|
|
|
+ // 找到集团下类型为集团的部门
|
|
|
+ QueryDepartmentDTO queryDepartmentDTO = new QueryDepartmentDTO();
|
|
|
+ queryDepartmentDTO.setType(DepTypeEnum.GROUP.getType());
|
|
|
+ List<Department> departments = departmentService.queryDepartmentList(queryDepartmentDTO);
|
|
|
+ if (CollectionUtils.isEmpty(departments)) {
|
|
|
+ throw new IllegalArgumentException("尚未创建集团");
|
|
|
+ }
|
|
|
+ Department group = departments.get(0);
|
|
|
+
|
|
|
Person person = ConvertPersonTool.INSTANCE.convert2Entity(accountCreateMsg);
|
|
|
personService.createPerson(person);
|
|
|
+
|
|
|
+ // 创建人员的工作信息
|
|
|
+ AddWorkResumeDTO addWorkResumeDTO = new AddWorkResumeDTO();
|
|
|
+ addWorkResumeDTO.setHiredDate(new Date());
|
|
|
+ addWorkResumeDTO.setState(WorkResumeStateEnum.ON_JOB.getType());
|
|
|
+ addWorkResumeDTO.setDepId(group.getId());
|
|
|
+ addWorkResumeDTO.setPersonId(person.getId());
|
|
|
}
|
|
|
|
|
|
|