|
|
@@ -1,6 +1,5 @@
|
|
|
package com.izouma.nineth.service;
|
|
|
|
|
|
-import com.alibaba.fastjson.JSONObject;
|
|
|
import com.izouma.nineth.domain.Asset;
|
|
|
import com.izouma.nineth.domain.UserAssetSummary;
|
|
|
import com.izouma.nineth.dto.PageQuery;
|
|
|
@@ -13,7 +12,6 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.collections.CollectionUtils;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.data.domain.Page;
|
|
|
-import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
@@ -32,7 +30,6 @@ public class UserAssetSummaryService {
|
|
|
return userAssetSummaryRepo.findAll(JpaUtils.toSpecification(pageQuery, UserAssetSummary.class), JpaUtils.toPageRequest(pageQuery));
|
|
|
}
|
|
|
|
|
|
- @Async
|
|
|
public void calculateNum(Long userId) {
|
|
|
log.info("开始重新计算用户:{}的资产数量", userId);
|
|
|
List<UserAssetSummary> userAssetSummaries = new ArrayList<>();
|
|
|
@@ -53,7 +50,6 @@ public class UserAssetSummaryService {
|
|
|
if (CollectionUtils.isNotEmpty(isExist)) {
|
|
|
userAssetSummaryRepo.deleteByUserId(userId);
|
|
|
}
|
|
|
- log.info(JSONObject.toJSONString(userAssetSummaries), true);
|
|
|
userAssetSummaryRepo.saveAll(userAssetSummaries);
|
|
|
}
|
|
|
|