package com.engine.salary.service.impl; import com.engine.common.util.ServiceUtil; import com.engine.core.impl.Service; import com.engine.salary.constant.SalaryDefaultTenantConstant; import com.engine.salary.entity.api.ApiTaskRecordPO; import com.engine.salary.mapper.api.ApiTaskRecordMapper; import com.engine.salary.service.ApiTaskService; import com.engine.salary.service.TaxAgentService; import com.engine.salary.util.db.IdGenerator; import com.engine.salary.util.db.MapperProxyFactory; import lombok.extern.slf4j.Slf4j; import weaver.hrm.User; import java.util.Date; /** * api任务调度服务 *
Copyright: Copyright (c) 2022
*Company: 泛微软件
* * @author qiantao * @version 1.0 **/ @Slf4j public class ApiTaskServiceImpl extends Service implements ApiTaskService { private ApiTaskRecordMapper getApiTaskRecordMapper() { return MapperProxyFactory.getProxy(ApiTaskRecordMapper.class); } private TaxAgentService getTaxAgentService(User user) { return ServiceUtil.getService(TaxAgentServiceImpl.class, user); } @Override public void writeApiTaskRecord(String source, String api, String param, String response) { log.info("source:{} , api:{} , param:{} , response : {}", source, api, param, response); Date now = new Date(); ApiTaskRecordPO build = ApiTaskRecordPO.builder() .id(IdGenerator.generate()) .source(source) .api(api) .param(param) .response(response) .createTime(now) .updateTime(now) .deleteType(0) .tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY) .build(); getApiTaskRecordMapper().insertIgnoreNull(build); } }