记得上下班打卡 | git大法好,push需谨慎

Commit df0cac31 authored by 胡佳晨's avatar 胡佳晨

积分明细

parent ccffc8df
...@@ -20,6 +20,7 @@ import com.liquidnet.service.stone.vo.StoneUserVo; ...@@ -20,6 +20,7 @@ import com.liquidnet.service.stone.vo.StoneUserVo;
import com.liquidnet.service.sweet.constant.SweetConstant; import com.liquidnet.service.sweet.constant.SweetConstant;
import com.liquidnet.service.sweet.vo.SweetAppletUsersVo; import com.liquidnet.service.sweet.vo.SweetAppletUsersVo;
import com.liquidnet.service.sweet.vo.SweetWechatUsersVo; import com.liquidnet.service.sweet.vo.SweetWechatUsersVo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.domain.PageRequest; import org.springframework.data.domain.PageRequest;
...@@ -38,10 +39,11 @@ import java.util.HashMap; ...@@ -38,10 +39,11 @@ import java.util.HashMap;
import java.util.List; import java.util.List;
@Service @Service
@Slf4j
public class DataImpl { public class DataImpl {
@Value("${liquidnet.service.stone.url}") @Value("${liquidnet.service.stone.url}")
private String stoneUrl; private String stoneUrl ;
@Autowired @Autowired
private MongoTemplate mongoTemplate; private MongoTemplate mongoTemplate;
...@@ -64,7 +66,9 @@ public class DataImpl { ...@@ -64,7 +66,9 @@ public class DataImpl {
//查询全部用户 //查询全部用户
List<AdamUser> adamUserList = userMapper.selectList(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1) List<AdamUser> adamUserList = userMapper.selectList(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1)
.select(AdamUser::getUid).last("limit " + ((page - 1) * size) + "," + ((page) * size))); .select(AdamUser::getUid).last("limit " + ((page - 1) * size) + "," + ((page) * size)));
log.info("AdamUserSize = "+adamUserList.size());
for (AdamUser item : adamUserList) { for (AdamUser item : adamUserList) {
int finishCount = 0;
//获取用户相关信息 //获取用户相关信息
String uid = item.getUid(); String uid = item.getUid();
String mobile = item.getMobile(); String mobile = item.getMobile();
...@@ -92,7 +96,7 @@ public class DataImpl { ...@@ -92,7 +96,7 @@ public class DataImpl {
Integer performancePrice = orderTicketsMapper.getOrderScore(uid); Integer performancePrice = orderTicketsMapper.getOrderScore(uid);
score += (performancePrice.intValue() / 100); score += (performancePrice.intValue() / 100);
//获取商品每日任务积分 //获取商品每日任务积分
String resultData = HttpUtil.get("http://devmall.zhengzai.tv/admin/sumUserCost?user_id=" + 1, null); String resultData = HttpUtil.get("http://testmall.zhengzai.tv/admin/sumUserCost?user_id=" + 1, null);
int goodsPrice = (int) JSONObject.parseObject(resultData).get("cost"); int goodsPrice = (int) JSONObject.parseObject(resultData).get("cost");
score += (goodsPrice / 100); score += (goodsPrice / 100);
...@@ -134,6 +138,8 @@ public class DataImpl { ...@@ -134,6 +138,8 @@ public class DataImpl {
params.add("content", "历史积分"); params.add("content", "历史积分");
HttpUtil.post(stoneUrl + "/user/logs/in2111", params); HttpUtil.post(stoneUrl + "/user/logs/in2111", params);
} }
finishCount+=1;
log.info("finishCount = "+finishCount);
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment