|
|
|
@@ -1009,6 +1009,38 @@ public class InvestBizServiceImpl implements InvestBizService { |
|
|
|
return buildFollowRecordItem(usersMap, followRecordEntity, customerEntity, brand); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public Map<String, Object> statistics() { |
|
|
|
Map<String, Object> result = new HashMap<>(); |
|
|
|
if (Objects.isNull(InvestUserContext.getDataUser())) { |
|
|
|
result.put("taskTotal", taskService.count(new LambdaQueryWrapper<InvestTaskEntity>() |
|
|
|
.ge(InvestTaskEntity::getStatus, EnumTaskStatus.CREATED) |
|
|
|
.eq(InvestTaskEntity::getTenantId, InvestUserContext.getUser().getTenantId()))); |
|
|
|
result.put("customerTotal", customerService.count(new LambdaQueryWrapper<InvestCustomerEntity>() |
|
|
|
.ge(InvestCustomerEntity::getTenantId, InvestUserContext.getUser().getTenantId()))); |
|
|
|
result.put("taskToday", customerService.count(new LambdaQueryWrapper<InvestCustomerEntity>() |
|
|
|
.apply("date_format(create_date,'%Y-%m-%d') = {0}", DateUtils.format(new Date())) |
|
|
|
.eq(InvestCustomerEntity::getTenantId, InvestUserContext.getUser().getTenantId()))); |
|
|
|
result.put("customerImport", customerService.count(new LambdaQueryWrapper<InvestCustomerEntity>() |
|
|
|
.eq(InvestCustomerEntity::getType, EnumCustomerType.INTENTIONAL) |
|
|
|
.eq(InvestCustomerEntity::getTenantId, InvestUserContext.getUser().getTenantId()))); |
|
|
|
result.put("remindCount", remindService.count(new LambdaQueryWrapper<InvestRemindEntity>() |
|
|
|
.ge(InvestRemindEntity::getTenantId, InvestUserContext.getUser().getTenantId()))); |
|
|
|
result.put("taskCreate", taskService.count(new LambdaQueryWrapper<InvestTaskEntity>() |
|
|
|
.eq(InvestTaskEntity::getStatus, EnumTaskStatus.CREATED) |
|
|
|
.eq(InvestTaskEntity::getTenantId, InvestUserContext.getUser().getTenantId()))); |
|
|
|
//result.put("customerCreate", customerService.count(new LambdaQueryWrapper<InvestCustomerEntity>() |
|
|
|
// .eq(InvestCustomerEntity::getStatus, EnumTaskStatus.CREATED))); |
|
|
|
} else { |
|
|
|
result.put("taskTotal", taskService.count(new LambdaQueryWrapper<InvestTaskEntity>() |
|
|
|
.ge(InvestTaskEntity::getStatus, EnumTaskStatus.CREATED) |
|
|
|
.apply("`owner` REGEXP {0}", InvestUserContext.getUserId()))); |
|
|
|
result.put("customerTotal", demandService.count(new LambdaQueryWrapper<InvestDemandEntity>() |
|
|
|
.ge(InvestDemandEntity::getOwner, InvestUserContext.getUser().getTenantId()))); |
|
|
|
} |
|
|
|
return result; |
|
|
|
} |
|
|
|
|
|
|
|
private void syncTargetStatus(InvestTaskEntity investTaskEntity) { |
|
|
|
//if (!Objects.equals(investTaskEntity.getTargetType(), EnumInvestType.RENT)) { |
|
|
|
// return; |
|
|
|
|