添加员工推送
bynt
2 years ago
parent
cd628a4114
commit
e5d98f6db0
@ -0,0 +1,23 @@
|
||||
package com.baiye.model.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* @author Enzo
|
||||
* @date : 2023/3/3
|
||||
*/
|
||||
@Data
|
||||
public class TaskUserDTO implements Serializable {
|
||||
private static final long serialVersionUID = 3421879104683964857L;
|
||||
|
||||
private Long userId;
|
||||
|
||||
private Long taskId;
|
||||
|
||||
public TaskUserDTO() {
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,32 @@
|
||||
package com.baiye.module.controller;
|
||||
|
||||
import com.baiye.http.CommonResponse;
|
||||
import com.baiye.module.service.AbMessageService;
|
||||
import com.baiye.module.service.dto.ABMessageDTO;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.validation.annotation.Validated;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RequestBody;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
/**
|
||||
* @author Enzo
|
||||
* @date : 2023/3/2
|
||||
*/
|
||||
|
||||
@RestController
|
||||
@RequestMapping("/open/v1/exchange")
|
||||
@RequiredArgsConstructor
|
||||
public class AbMessageController {
|
||||
|
||||
private final AbMessageService abMessageService;
|
||||
|
||||
|
||||
@ApiOperation(value = "查询个人未审核信息")
|
||||
@PostMapping("/form")
|
||||
public CommonResponse<Object> queryNotApproved(@RequestBody @Validated ABMessageDTO abMessageDTO){
|
||||
return CommonResponse.createBySuccess(abMessageService.receiveDate(abMessageDTO));
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
package com.baiye.module.service;
|
||||
|
||||
import com.baiye.module.service.dto.ABMessageDTO;
|
||||
|
||||
/**
|
||||
* @author Enzo
|
||||
* @date : 2023/3/2
|
||||
*/
|
||||
public interface AbMessageService {
|
||||
|
||||
/**
|
||||
* 接收数据
|
||||
* @param abMessageDTO
|
||||
* @return
|
||||
*/
|
||||
Boolean receiveDate(ABMessageDTO abMessageDTO);
|
||||
}
|
||||
@ -0,0 +1,92 @@
|
||||
package com.baiye.module.service.impl;
|
||||
|
||||
import cn.hutool.core.codec.Base64;
|
||||
import cn.hutool.core.util.ObjectUtil;
|
||||
import com.baiye.constant.DefaultNumberConstants;
|
||||
import com.baiye.constant.SecurityConstants;
|
||||
import com.baiye.feign.TaskClient;
|
||||
import com.baiye.feign.UserClient;
|
||||
import com.baiye.model.dto.TaskUserDTO;
|
||||
import com.baiye.module.dao.ClueMiddleRepository;
|
||||
import com.baiye.module.dao.ClueRepository;
|
||||
import com.baiye.module.entity.Clue;
|
||||
import com.baiye.module.entity.ClueMiddle;
|
||||
import com.baiye.module.entity.Task;
|
||||
import com.baiye.module.service.AbMessageService;
|
||||
import com.baiye.module.service.dto.ABMessageDTO;
|
||||
import com.baiye.util.MobileUtil;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.springframework.beans.factory.annotation.Value;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
/**
|
||||
* @author Enzo
|
||||
* @date : 2022/11/24
|
||||
*/
|
||||
@Service
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor
|
||||
public class AbMessageServiceImpl implements AbMessageService {
|
||||
|
||||
|
||||
private final TaskClient taskClient;
|
||||
|
||||
private final UserClient userClient;
|
||||
|
||||
private final ClueRepository clueRepository;
|
||||
|
||||
private final ClueMiddleRepository clueMiddleRepository;
|
||||
|
||||
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public Boolean receiveDate(ABMessageDTO abMessageDTO) {
|
||||
String mobile = Base64.decodeStr(abMessageDTO.getMobile());
|
||||
String jobNumber = abMessageDTO.getJobNumber();
|
||||
if (StringUtils.isBlank(jobNumber) || StringUtils.isBlank(mobile) || !MobileUtil.checkPhone(mobile)) {
|
||||
return Boolean.FALSE;
|
||||
}
|
||||
Long userId = userClient.findByJobNumber(jobNumber, SecurityConstants.FROM_IN);
|
||||
if (ObjectUtil.isNull(userId)) {
|
||||
return Boolean.FALSE;
|
||||
}
|
||||
|
||||
TaskUserDTO dto = taskClient.findByTaskByUserId
|
||||
(userId, DefaultNumberConstants.EIGHT_NUMBER, SecurityConstants.FROM_IN);
|
||||
if (ObjectUtil.isNotNull(dto)
|
||||
&& ObjectUtil.isNotNull(dto.getTaskId())) {
|
||||
Clue clue = new Clue();
|
||||
clue.setNid(mobile);
|
||||
Long taskId = dto.getTaskId();
|
||||
clue.setCreateBy(dto.getUserId());
|
||||
clue.setAudioUrl(abMessageDTO.getAudioUrl());
|
||||
clue.setOrigin(DefaultNumberConstants.FIVE_NUMBER);
|
||||
clue.setName(Base64.decodeStr(abMessageDTO.getActName()));
|
||||
Long clueId = clueRepository.save(clue).getId();
|
||||
ClueMiddle clueMiddle = new ClueMiddle();
|
||||
clueMiddle.setClueId(clueId);
|
||||
clueMiddle.setTaskId(taskId);
|
||||
clueMiddle.setMemberId(userId);
|
||||
clueMiddle.setClueType(DefaultNumberConstants.EIGHT_NUMBER);
|
||||
clueMiddle.setClueStage(DefaultNumberConstants.ZERO_NUMBER);
|
||||
clueMiddle.setMemberStatus(DefaultNumberConstants.ONE_NUMBER);
|
||||
clueMiddle.setClueCallStatus(DefaultNumberConstants.ZERO_NUMBER);
|
||||
clueMiddle.setOptimisticVersion(DefaultNumberConstants.ZERO_NUMBER);
|
||||
clueMiddleRepository.save(clueMiddle);
|
||||
Task task = new Task();
|
||||
// 修改任务总条数
|
||||
Integer taskNum = clueMiddleRepository.findTaskNum(taskId);
|
||||
task.setId(taskId);
|
||||
task.setTotalNumber(taskNum);
|
||||
task.setIsDistribution(DefaultNumberConstants.ONE_NUMBER);
|
||||
task.setIsEncryption(DefaultNumberConstants.ZERO_NUMBER);
|
||||
taskClient.updateTask(task);
|
||||
return Boolean.TRUE;
|
||||
}
|
||||
return Boolean.FALSE;
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue