#

luxiaotao1123

2022-05-24 8e9f2f6925530be0e9f63d0a7205a98f8e6dae47

#

 src/main/java/com/zy/asrs/mapper/ApiLogMapper.java

@@ -9,4 +9,6 @@
@Repository
public interface ApiLogMapper extends BaseMapper<ApiLog> {

    int clearWeekBefore();

}

 src/main/java/com/zy/asrs/service/ApiLogService.java

@@ -7,4 +7,6 @@

    void save(String namespace, String url, String appkey, String ip, String request, String response, boolean success);

    boolean clearWeekBefore();

}

 src/main/java/com/zy/asrs/service/impl/ApiLogServiceImpl.java

@@ -43,4 +43,9 @@
            log.error("接口调用日志保存失败！");
        }
    }

    @Override
    public boolean clearWeekBefore() {
        return this.baseMapper.clearWeekBefore() > 0;
    }
}

 src/main/java/com/zy/asrs/task/OrderSyncScheduler.java

@@ -2,6 +2,7 @@

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.zy.asrs.entity.Order;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.OrderService;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.OrderSyncHandler;
@@ -24,6 +25,17 @@
    private OrderSyncHandler orderSyncHandler;
    @Autowired
    private OrderService orderService;
    @Autowired
    private ApiLogService apiLogService;

    @Scheduled(cron = "0 0 1 * * ? ")
    public void clearApiLog(){
        try {
            apiLogService.clearWeekBefore();
        } catch (Exception e) {
            log.error("第三方接口日志自动清除失败（范围：一周之前", e);
        }
    }

    @Scheduled(cron = "0/5 * * * * ? ")
    @Async("orderThreadPool")

 src/main/resources/mapper/ApiLogMapper.xml

@@ -22,4 +22,10 @@

    </resultMap>

    <delete id="clearWeekBefore">
        delete from man_api_log
        where 1=1
        and datediff(week,create_time,getdate()) >= 1
    </delete>

</mapper>