Commit 1e0eabc8 authored by hezhen's avatar hezhen

123

parent ee300577
......@@ -9,6 +9,7 @@ import com.github.wxiaoqi.security.admin.mapper.MyWalletMapper;
import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
import com.xxfc.platform.activity.feign.ActivityFeign;
import com.xxl.job.core.log.XxlJobLogger;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
......@@ -186,9 +187,11 @@ public class MyWaterBiz extends BaseBiz<MyWalletMapper, MyWallet>{
example.createCriteria().andGreaterThan("todayAmount",0).andEqualTo("isFrozen",0);
List<MyWallet> list=selectByExample(example);
log.info("---钱包定时处理今日收益updTodayAmount----size==="+list.size());
XxlJobLogger.log("---钱包定时处理今日收益updTodayAmount----size==="+list.size());
if (list.size()>0){
for (MyWallet myWallet:list){
log.info("---钱包定时处理今日收益updTodayAmount----userId==="+myWallet.getUserId());
XxlJobLogger.log("---钱包定时处理今日收益updTodayAmount----userId==="+myWallet.getUserId());
MyWallet myWallet1=new MyWallet();
myWallet1.setId(myWallet.getId());
myWallet1.setTodayAmount(new BigDecimal("0.00"));
......
......@@ -19,18 +19,18 @@ import java.io.Serializable;
*/
@JobHandler(value = "walletHandler")
@Component
//@Slf4j
@Slf4j
public class RentDepositJobHandler extends IJobHandler {
// @Autowired
// MyWaterBiz myWaterBiz;
@Autowired
MyWaterBiz myWaterBiz;
@Override
public ReturnT<String> execute(String var1) {
try {
XxlJobLogger.log("-----定时器进入---walletHandler---");
// log.info("-----定时器进入---walletHandler---");
// myWaterBiz.updTodayAmount();
log.info("-----定时器进入---walletHandler---");
myWaterBiz.updTodayAmount();
ReturnT returnT = new ReturnT();
returnT.setCode(100);
returnT.setMsg("成功");
......
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