|
|
@@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSONObject;
|
|
|
import com.izouma.nineth.domain.Asset;
|
|
|
import com.izouma.nineth.domain.UserAssetSummary;
|
|
|
import com.izouma.nineth.dto.PageQuery;
|
|
|
-import com.izouma.nineth.enums.AssetShowStatus;
|
|
|
import com.izouma.nineth.enums.CollectionType;
|
|
|
import com.izouma.nineth.repo.AssetRepo;
|
|
|
import com.izouma.nineth.repo.UserAssetSummaryRepo;
|
|
|
@@ -17,10 +16,8 @@ import org.springframework.data.domain.Page;
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import javax.transaction.Transactional;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
-import java.util.Objects;
|
|
|
|
|
|
@Service
|
|
|
@AllArgsConstructor
|
|
|
@@ -35,33 +32,6 @@ public class UserAssetSummaryService {
|
|
|
return userAssetSummaryRepo.findAll(JpaUtils.toSpecification(pageQuery, UserAssetSummary.class), JpaUtils.toPageRequest(pageQuery));
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 当该分类下的资产数量为1的时候,添加相关状态
|
|
|
- *
|
|
|
- * @param userAssetSummary
|
|
|
- */
|
|
|
- private void setAssetStatus(UserAssetSummary userAssetSummary) {
|
|
|
- if (userAssetSummary.getNum() != 1) {
|
|
|
- return;
|
|
|
- }
|
|
|
- if (Objects.isNull(userAssetSummary.getAssetStatus())) {
|
|
|
- return;
|
|
|
- }
|
|
|
- if (userAssetSummary.getAuctioningNum() == 1) {
|
|
|
- userAssetSummary.setAssetStatus(AssetShowStatus.AUCTIONING);
|
|
|
- return;
|
|
|
- }
|
|
|
- if (userAssetSummary.getConsignmentNum() == 1) {
|
|
|
- userAssetSummary.setAssetStatus(AssetShowStatus.CONSIGNMENT);
|
|
|
- return;
|
|
|
- }
|
|
|
- if (userAssetSummary.getOpenShowNum() == 1) {
|
|
|
- userAssetSummary.setAssetStatus(AssetShowStatus.OPEN_SHOW);
|
|
|
- return;
|
|
|
- }
|
|
|
- userAssetSummary.setAssetStatus(AssetShowStatus.NORMAL);
|
|
|
- }
|
|
|
-
|
|
|
@Async
|
|
|
public void calculateNum(Long userId) {
|
|
|
log.info("开始重新计算用户:{}的资产数量", userId);
|
|
|
@@ -83,7 +53,6 @@ public class UserAssetSummaryService {
|
|
|
if (CollectionUtils.isNotEmpty(isExist)) {
|
|
|
userAssetSummaryRepo.deleteByUserId(userId);
|
|
|
}
|
|
|
- userAssetSummaries.forEach(this::setAssetStatus);
|
|
|
log.info(JSONObject.toJSONString(userAssetSummaries), true);
|
|
|
userAssetSummaryRepo.saveAll(userAssetSummaries);
|
|
|
}
|