From 48e4c4328cfd305d5465b66db11521ff70723683 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 24 十二月 2019 16:59:00 +0800
Subject: [PATCH] 京东内优惠商品爬取，淘宝无推广商品信息获取
---
fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyExtraServiceImpl.java | 36 +++++++++++++++++++++++++++++++-----
1 files changed, 31 insertions(+), 5 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyExtraServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyExtraServiceImpl.java
index fe06581..41c321d 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyExtraServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyExtraServiceImpl.java
@@ -1,22 +1,26 @@
package com.yeshi.fanli.service.impl.money;
import java.math.BigDecimal;
-import java.util.Date;
+import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import com.yeshi.fanli.dao.mybatis.user.UserMoneyExtraMapper;
import com.yeshi.fanli.entity.bus.user.UserMoneyExtra;
import com.yeshi.fanli.service.inter.money.UserMoneyExtraService;
-import com.yeshi.fanli.util.MoneyBigDecimalUtil;
+import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;
@Service
public class UserMoneyExtraServiceImpl implements UserMoneyExtraService {
@Resource
private UserMoneyExtraMapper userMoneyExtraMapper;
+
+ @Resource
+ private IntegralTaskRecordService integralTaskRecordService;
@Override
public UserMoneyExtra selectByPrimaryKey(Long uid) {
@@ -28,10 +32,32 @@
userMoneyExtraMapper.updateByPrimaryKeySelective(record);
}
+
+ @Override
+ public List<UserMoneyExtra> listValid(int page, int count) {
+ return userMoneyExtraMapper.listValid((page-1) * count, count);
+ }
@Override
- public void listValid(int page, int count) {
- userMoneyExtraMapper.listValid((page-1) * count, count);
+ @Transactional(rollbackFor = Exception.class)
+ public void taoLiJinExchange(int page, int count) {
+ List<UserMoneyExtra> listValid = userMoneyExtraMapper.listValid((page-1) * count, count);
+ if (listValid == null || listValid.isEmpty())
+ return;
+
+ BigDecimal zero = new BigDecimal(0);
+ for (UserMoneyExtra moneyExtra: listValid) {
+ BigDecimal tlj = moneyExtra.getTlj();
+ BigDecimal tljSelf = moneyExtra.getTljSelf();
+ if (tlj == null || tlj.compareTo(zero) <= 0 || tljSelf == null || tljSelf.intValue() <= 0)
+ continue;
+
+ integralTaskRecordService.taoLiJinExchange(moneyExtra.getUid(), tljSelf.intValue(), tlj);
+
+ moneyExtra.setTlj(zero);
+ moneyExtra.setTljSelf(zero);
+ userMoneyExtraMapper.updateByPrimaryKeySelective(moneyExtra);
+ }
}
-
+
}
--
Gitblit v1.8.0