Commit 272d3322 authored by 刘林's avatar 刘林

fix(jg):设备履历字段添加

parent 85ac4add
package com.yeejoin.amos.boot.module.jg.api.enums;
import java.util.Arrays;
import java.util.Optional;
/**
* 业务类型枚举
*
......@@ -75,6 +78,13 @@ public enum BusinessTypeEnum {
return name;
}
public static Optional<String> findNameByEnumName(String enumName) {
return Arrays.stream(values())
.filter(e -> e.name().equals(enumName))
.map(BusinessTypeEnum::getName)
.findFirst();
}
public String getCode() {
return code;
}
......
......@@ -5,10 +5,13 @@ import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSONObject;
import com.yeejoin.amos.boot.module.jg.api.dto.ESDataChangeLogDto;
import com.yeejoin.amos.boot.module.jg.api.dto.FieldChangeMeta;
import com.yeejoin.amos.boot.module.jg.api.dto.JgResumeInfoDto;
import com.yeejoin.amos.boot.module.jg.api.entity.JgBizChangeLog;
import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
import com.yeejoin.amos.boot.module.jg.biz.dao.ESDataChangeLogDao;
import com.yeejoin.amos.boot.module.jg.biz.edit.event.BaseBizDataChangeEvent;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgBizChangeLogServiceImpl;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgResumeInfoServiceImpl;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
......@@ -52,6 +55,8 @@ public class ChangeLogInsertListener {
private final JgBizChangeLogServiceImpl bizChangeLogService;
private final JgResumeInfoServiceImpl jgResumeInfoService;
private final BlockingQueue<BaseBizDataChangeEvent> queue = new LinkedBlockingQueue<>();
......@@ -122,6 +127,19 @@ public class ChangeLogInsertListener {
// todo 使用上下文这个作为id 便于其他业务和其进行关联
changeLog.setSequenceNbr(Long.parseLong(event.getRequestContext().getTraceId()));
bizChangeLogService.getBaseMapper().insert(changeLog);
String equId = event.getBizRelationData().getRecords().stream().findFirst().orElse(null);
jgResumeInfoService.createWithModel(JgResumeInfoDto.builder()
.applyNo(event.getBizRelationData().getUnitCode())
.businessType(BusinessTypeEnum.findNameByEnumName(bizTypeTableMap.get(changeLog.getBizType())).orElse("未知类型"))
.businessId(event.getBizRelationData().getBizId())
.equId(equId)
.resumeType("1")
.changeLogId(String.valueOf(changeLog.getSequenceNbr()))
.approvalUnit(event.getBizRelationData().getUnitCode())
.approvalUnitCode(event.getBizRelationData().getUnitCode())
.createUserName(event.getBizRelationData().getCreateUserName())
.status("正常")
.build());
return changeLog;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment