|
|
|
|
@ -30,6 +30,7 @@ import com.baiye.system.constant.LetterConst;
|
|
|
|
|
import com.baiye.system.enums.RoleCodeEnum;
|
|
|
|
|
import com.baiye.system.model.entity.SysUser;
|
|
|
|
|
import com.baiye.system.service.SysUserRoleService;
|
|
|
|
|
import com.baiye.system.model.entity.SysUser;
|
|
|
|
|
import com.baiye.system.service.SysUserService;
|
|
|
|
|
import com.baiye.util.AESUtils;
|
|
|
|
|
import com.baiye.utils.SerialCode;
|
|
|
|
|
@ -158,50 +159,71 @@ public class CustomServiceImpl extends ExtendServiceImpl<CustomMapper, CustomEnt
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
|
|
public Boolean auditFormById(ChangeCustomDTO dto) {
|
|
|
|
|
Long id = dto.getCustomId();
|
|
|
|
|
Integer status = dto.getStatus();
|
|
|
|
|
CustomEntity customEntity = baseMapper.selectById(id);
|
|
|
|
|
public Boolean auditFormById(CustomDTO customDTO) {
|
|
|
|
|
Long customId = customDTO.getCustomId();
|
|
|
|
|
Integer status = customDTO.getStatus();
|
|
|
|
|
List<Long> salesmanUserIdList = customDTO.getSalesmanUserIdList();
|
|
|
|
|
Long reviewUserId = customDTO.getReviewUserId();
|
|
|
|
|
Long currentUserId = SecurityUtils.getCurrentUserId();
|
|
|
|
|
CustomEntity updateCustomEntity = CustomConverter.INSTANCE.dtoToPo(customDTO);
|
|
|
|
|
|
|
|
|
|
List<ClueDTO> list = Lists.newArrayList();
|
|
|
|
|
CustomEntity customEntity = baseMapper.selectById(customId);
|
|
|
|
|
if (ObjectUtil.isNotNull(customEntity)) {
|
|
|
|
|
if (ObjectUtil.isNotNull(status) && status == 0) {
|
|
|
|
|
if (ObjectUtil.isNull(dto.getReviewUserId())) {
|
|
|
|
|
throw new BadRequestException("复审员不能为空!");
|
|
|
|
|
}
|
|
|
|
|
customEntity.setType(3);
|
|
|
|
|
customEntity.setReviewUserId(dto.getReviewUserId());
|
|
|
|
|
return SqlHelper.retBool(baseMapper.updateById(customEntity));
|
|
|
|
|
}
|
|
|
|
|
Gson gson = new Gson();
|
|
|
|
|
AddressDTO address = new AddressDTO();
|
|
|
|
|
List<ClueDTO> list = Lists.newArrayList();
|
|
|
|
|
BeanUtils.copyProperties(customEntity, address);
|
|
|
|
|
address.setCustomerName(customEntity.getCustomName());
|
|
|
|
|
String otherClue = gson.toJson(address);
|
|
|
|
|
List<CustomStoreEntity> customStores = customStoreService.selectListByCustomId(id);
|
|
|
|
|
if (CollUtil.isNotEmpty(customStores)) {
|
|
|
|
|
for (CustomStoreEntity store : customStores) {
|
|
|
|
|
// 雪花算法id
|
|
|
|
|
Long clueId = IdUtil.getSnowflake(workerId, datacenterId).nextId();
|
|
|
|
|
StoreUserDTO entity = storeUserService.findUserIdByStoreId(store.getStoreId());
|
|
|
|
|
if (ObjectUtil.isNotNull(entity) && ObjectUtil.isNotNull(entity.getUserId())) {
|
|
|
|
|
// 扣减余额
|
|
|
|
|
Boolean result = sysUserService.deductionQuantity(entity.getUserId(), entity.getStoreName());
|
|
|
|
|
if (Boolean.TRUE.equals(result)) {
|
|
|
|
|
ClueDTO clueDTO = ClueDTO.builder().originName(ClueSourceEnum.STORE_DISTRIBUTION.getDescription()).clueId(clueId).remark
|
|
|
|
|
(customEntity.getRemark()).nid(AESUtils.encrypt(customEntity.getCustomNid(), securityProperties.getPasswordSecretKey())).assignedBy
|
|
|
|
|
(entity.getUserId()).createBy(customEntity.getCompanyId()).assignedName(store.getStoreName()).otherClue(otherClue).isNewClue(Boolean.TRUE).build();
|
|
|
|
|
list.add(clueDTO);
|
|
|
|
|
String phone = AESUtils.encrypt(customEntity.getCustomNid(), securityProperties.getPasswordSecretKey());
|
|
|
|
|
Long companyId = customEntity.getCompanyId();
|
|
|
|
|
if (status == 0) {
|
|
|
|
|
Gson gson = new Gson();
|
|
|
|
|
AddressDTO address = new AddressDTO();
|
|
|
|
|
BeanUtils.copyProperties(customEntity, address);
|
|
|
|
|
address.setCustomerName(customEntity.getCustomName());
|
|
|
|
|
String otherClue = gson.toJson(address);
|
|
|
|
|
List<CustomStoreEntity> customStores = customStoreService.selectListByCustomId(customId);
|
|
|
|
|
if (CollUtil.isNotEmpty(customStores)) {
|
|
|
|
|
for (CustomStoreEntity store : customStores) {
|
|
|
|
|
Long clueId = IdUtil.getSnowflake(workerId, datacenterId).nextId();
|
|
|
|
|
StoreUserDTO entity = storeUserService.findUserIdByStoreId(store.getStoreId());
|
|
|
|
|
if (ObjectUtil.isNotNull(entity) && ObjectUtil.isNotNull(entity.getUserId())) {
|
|
|
|
|
String username = sysUserService.findById(entity.getUserId()).getUsername();
|
|
|
|
|
// 扣减余额
|
|
|
|
|
Boolean result = sysUserService.deductionQuantity(entity.getUserId(), entity.getStoreName());
|
|
|
|
|
if (Boolean.TRUE.equals(result)) {
|
|
|
|
|
ClueDTO clueDTO = new ClueDTO(clueId, ClueSourceEnum.STORE_DISTRIBUTION.getDescription(), phone, updateCustomEntity.getRemark(),
|
|
|
|
|
otherClue, entity.getUserId(), username, currentUserId, Boolean.TRUE, companyId, updateCustomEntity.getSex(),
|
|
|
|
|
customEntity.getCustomInformation(), customEntity.getChannelIdentifying(), customEntity.getChannelType());
|
|
|
|
|
list.add(clueDTO);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (CollUtil.isNotEmpty(list)) {
|
|
|
|
|
// 扣减数量
|
|
|
|
|
customEntity.setEnrollStatus(2);
|
|
|
|
|
clueService.saveClueListByStoreInfo(list);
|
|
|
|
|
customEntity.setDistributeTime(DateUtil.date());
|
|
|
|
|
customEntity.setUpdateTime(LocalDateTime.now());
|
|
|
|
|
return SqlHelper.retBool(baseMapper.updateById(customEntity));
|
|
|
|
|
} else if (status == 1) {
|
|
|
|
|
if (CollUtil.isEmpty(salesmanUserIdList)) throw new BadRequestException("下发人员不能为空!");
|
|
|
|
|
Map<Long, List<SysUser>> listMap = sysUserService.listByUserIds(salesmanUserIdList).stream().collect(Collectors.groupingBy(SysUser::getUserId));
|
|
|
|
|
for (Long userId : salesmanUserIdList) {
|
|
|
|
|
String username = listMap.get(userId).get(0).getUsername();
|
|
|
|
|
// 扣减余额
|
|
|
|
|
Boolean result = sysUserService.deductionQuantity(userId, null);
|
|
|
|
|
if (Boolean.TRUE.equals(result)) {
|
|
|
|
|
Long clueId = IdUtil.getSnowflake(workerId, datacenterId).nextId();
|
|
|
|
|
ClueDTO clueDTO = new ClueDTO(clueId, customEntity.getChannelName(), phone, updateCustomEntity.getRemark(), null, userId,
|
|
|
|
|
username, currentUserId, Boolean.TRUE, companyId, updateCustomEntity.getSex(), customEntity.getCustomInformation(),
|
|
|
|
|
customEntity.getChannelIdentifying(), customEntity.getChannelType());
|
|
|
|
|
list.add(clueDTO);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
if (reviewUserId != null) throw new BadRequestException("复审员不能为空!");
|
|
|
|
|
updateCustomEntity.setType(3);
|
|
|
|
|
updateCustomEntity.setReviewUserId(customDTO.getReviewUserId());
|
|
|
|
|
return SqlHelper.retBool(baseMapper.updateById(updateCustomEntity));
|
|
|
|
|
}
|
|
|
|
|
// 扣减数量,插入资源
|
|
|
|
|
if (CollUtil.isNotEmpty(list)) {
|
|
|
|
|
updateCustomEntity.setEnrollStatus(2);
|
|
|
|
|
clueService.saveClueListByStoreInfo(list);
|
|
|
|
|
updateCustomEntity.setDistributeTime(DateUtil.date());
|
|
|
|
|
updateCustomEntity.setUpdateTime(LocalDateTime.now());
|
|
|
|
|
return SqlHelper.retBool(baseMapper.updateById(updateCustomEntity));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return Boolean.FALSE;
|
|
|
|
|
@ -279,7 +301,6 @@ public class CustomServiceImpl extends ExtendServiceImpl<CustomMapper, CustomEnt
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 检测数据
|
|
|
|
|
*/
|
|
|
|
|
|
yqy
10 months ago