添加日志

Administrator

2025-02-20 06ed77d317b8012ea0389cfd1405db9a425c0c7d

 src/main/java/com/taoke/autopay/service/impl/KeyOrderServiceImpl.java

@@ -1,5 +1,6 @@
package com.taoke.autopay.service.impl;

import com.google.gson.Gson;
import com.taoke.autopay.dao.KeyOrderMapper;
import com.taoke.autopay.dao.WxUserSettingsMapper;
import com.taoke.autopay.dto.ChannelOrderStatistic;
@@ -66,10 +67,19 @@
    @Resource
    private PayMoneySettingService payMoneySettingService;

    @Resource
    private WxUserService wxUserService;


    @Override
    public KeyOrder selectById(String id) {
        return keyOrderMapper.selectById(id);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public KeyOrder selectByIdForUpdate(String id) {
        return keyOrderMapper.selectByPrimaryKeyForUpdate(id);
    }

    @Transactional(rollbackFor = Exception.class)
@@ -80,6 +90,7 @@
            WxUserSettings settings = wxUserSettingService.getUserSettings(uid);
            OrderCountTypeEnum countType = OrderCountTypeEnum.SUBMIT_TOKEN_COUNT;
            wxUserOrderCountService.addOrderCount(uid, countType,null, day, 1, settings.getTotalOrderCountPerDay());
            wxUserService.setLatestInfoInfo(uid, keyInfo.getIp(),keyInfo.getIpInfo());
        }
        String id = OrderFactory.createId(keyInfo.getKey());
        KeyOrder order = keyOrderMapper.selectById(id);
@@ -132,9 +143,11 @@
            order.setOrderNo(orderDto.getOrder_id());
        }

        order.setIp(keyInfo.getIp());
        if(keyInfo.getIpInfo()!=null) {
            order.setIpInfo(new Gson().toJson(keyInfo.getIpInfo()));
        }
        keyOrderMapper.insertSelective(order);


        return order;
    }

@@ -430,4 +443,23 @@
    public long countAgentId(KeyOrderMapper.DaoQuery query) {
        return keyOrderMapper.countAgentId(query);
    }

    @Override
    public long countUserNotDoOrder(Long uid, Date minCreateTime) {
        KeyOrderMapper.DaoQuery daoQuery=new KeyOrderMapper.DaoQuery();
        daoQuery.uid = uid;
        daoQuery.stateList=Arrays.asList(new Integer[]{KeyOrder.STATE_NOT_PROCESS,KeyOrder.STATE_NOT_PAY});
        daoQuery.minCreateTime = minCreateTime;
        return keyOrderMapper.count(daoQuery);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public void rejectPay(String id, String rejectMsg) {
        KeyOrder keyOrder=new KeyOrder();
        keyOrder.setId(id);
        keyOrder.setState(KeyOrder.STATE_REJECT_PAY);
        keyOrder.setStateDesc(rejectMsg);
        update(keyOrder);
    }
}