| | |
|---|
| | | package org.sxkj.gd.workorder.service.impl; |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|---|
| | | import lombok.AllArgsConstructor; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springblade.core.secure.utils.AuthUtil; |
|---|
| | |
|---|
| | | if (taskResult.getDistributeStatus() != null && taskResult.getDistributeStatus() == 1) { |
|---|
| | | throw new RuntimeException("成果已分发，无法再次分发"); |
|---|
| | | } |
|---|
| | | GdClueEventEntity clueEvent = new GdClueEventEntity(); |
|---|
| | | // 查看事件直接是否分发过 |
|---|
| | | GdClueEventEntity clueEvent = getOne(Wrappers.<GdClueEventEntity>query().lambda() |
|---|
| | | .eq(GdClueEventEntity::getResultId, distributeParam.getResultId()) |
|---|
| | | .eq(GdClueEventEntity::getIsDeleted, 0)); |
|---|
| | | // 如果是空的则创建对象 |
|---|
| | | if (clueEvent == null) { |
|---|
| | | clueEvent = new GdClueEventEntity(); |
|---|
| | | } |
|---|
| | | clueEvent.setResultId(distributeParam.getResultId()); |
|---|
| | | clueEvent.setWorkOrderId(distributeParam.getWorkOrderId()); |
|---|
| | | clueEvent.setDisposeUser(distributeParam.getDisposeUser()); |
|---|
| | | clueEvent.setDisposeDept(distributeParam.getDisposeDept()); |
|---|
| | | clueEvent.setLongitude(distributeParam.getLongitude()); |
|---|
| | | clueEvent.setLatitude(distributeParam.getLatitude()); |
|---|
| | | clueEvent.setEventStatus(1); |
|---|
| | | clueEvent.setEventStatus(EventStatusEnum.PENDING_CONFIRM.getCode()); |
|---|
| | | String times = OrderNumUtils.initOrderNum(WordOrderConstant.EVENT_NUM_KEY); |
|---|
| | | String eventNum = WordOrderConstant.EVENT_NUM_PREFIX + times; |
|---|
| | | clueEvent.setEventNum(eventNum); |
|---|
| | |
|---|
| | | clueEvent.setCreateDept(Long.valueOf(AuthUtil.getDeptId())); |
|---|
| | | clueEvent.setCreateTime(new Date()); |
|---|
| | | clueEvent.setEventName(distributeParam.getEventName()); |
|---|
| | | if (!save(clueEvent)) { |
|---|
| | | if (!saveOrUpdate(clueEvent)) { |
|---|
| | | throw new RuntimeException("事件分发失败"); |
|---|
| | | } |
|---|
| | | taskResult.setDistributeStatus(1); |
|---|
