admin
2019-03-11 b954bda649d5fe84b68cc592bd4ef9d06bf2eb3e
爬取规则修改
2个文件已修改
16 ■■■■■ 已修改文件
fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java 12 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java
@@ -16,7 +16,6 @@
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
import com.yeshi.fanli.exception.TaoBaoOrderException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.common.DataMonitorService;
import com.yeshi.fanli.service.inter.hongbao.HongBaoService;
@@ -352,11 +351,11 @@
    }
    // 每15分钟爬取一次
    // @Scheduled(cron = "0 0/15 * * * ? ")
    @Scheduled(cron = "0 0/15 * * * ? ")
    public void doJob1() {
        // if (!Constant.IS_TASK)
        // return;
        long currentTime = System.currentTimeMillis();
        if (!Constant.IS_TASK)
            return;
        long currentTime = System.currentTimeMillis() - 1000 * 60;
        String h = TimeUtil.getGernalTime(currentTime, "HH");
        String m = TimeUtil.getGernalTime(currentTime, "mm");
        int mm = Integer.parseInt(h) * 60 + Integer.parseInt(m);
@@ -375,7 +374,8 @@
    public void doJob6() {
        if (!Constant.IS_TASK)
            return;
        long endTime = System.currentTimeMillis();
        long endTime = System.currentTimeMillis() - 1000 * 60;
        ;
        updateOrder(endTime - 1000 * 60 * 20L, endTime);
    }
fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
@@ -486,7 +486,7 @@
            // 将自己添加到用户
            Long uid = its.next();
            BigDecimal money = userMoney.get(uid);
            userInfoMapper.addHongBaoByUid(uid, money);
            AccountDetails accountDetails = AccountDetailsFactory.create("+" + money, AccountDetailsFactory.FANLI, null,
                    null, new UserInfo(uid));
@@ -511,6 +511,8 @@
            for (HongBaoV2 v2 : userHongBao.get(uid)) {
                accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(v2.getId(), accountDetails.getId());
            }
            //增加用户资金
            userInfoMapper.addHongBaoByUid(uid, money);
            // 站内信+推送
            UserInfo user = userInfoMapper.selectByPrimaryKey(uid);