Compare commits
No commits in common. 'master' and 'liweidong' have entirely different histories.
30 changed files with 181 additions and 1167 deletions
@ -1,33 +0,0 @@ |
||||
package org.springblade.job.processor.oem; |
||||
|
||||
import jakarta.annotation.Resource; |
||||
import lombok.Data; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springblade.desk.oem.feign.IOemStatementClient; |
||||
import org.springframework.stereotype.Component; |
||||
import tech.powerjob.worker.core.processor.ProcessResult; |
||||
import tech.powerjob.worker.core.processor.TaskContext; |
||||
import tech.powerjob.worker.core.processor.sdk.BasicProcessor; |
||||
|
||||
/** |
||||
* 外协结算单生成定时任务 |
||||
* |
||||
* @author BladeX |
||||
* @since 2026-05-08 |
||||
*/ |
||||
@Component |
||||
@Data |
||||
@Slf4j |
||||
public class OemStatementTaskProcessor implements BasicProcessor { |
||||
|
||||
@Resource |
||||
private IOemStatementClient oemStatementClient; |
||||
|
||||
@Override |
||||
public ProcessResult process(TaskContext taskContext) throws Exception { |
||||
log.info("========== 开始外协结算单生成定时任务 =========="); |
||||
oemStatementClient.generateSettlement(); |
||||
log.info("========== 结束外协结算单生成定时任务 =========="); |
||||
return new ProcessResult(true); |
||||
} |
||||
} |
||||
@ -1,18 +0,0 @@ |
||||
package org.springblade.desk.oem.feign; |
||||
|
||||
import org.springblade.core.launch.constant.AppConstant; |
||||
import org.springframework.cloud.openfeign.FeignClient; |
||||
import org.springframework.web.bind.annotation.GetMapping; |
||||
|
||||
@FeignClient( |
||||
value = AppConstant.APPLICATION_DESK_NAME |
||||
) |
||||
public interface IOemStatementClient { |
||||
|
||||
String API_PREFIX = "/feign/client/oem-statement"; |
||||
String GENERATE_SETTLEMENT = API_PREFIX + "/generate-settlement"; |
||||
|
||||
@GetMapping(GENERATE_SETTLEMENT) |
||||
void generateSettlement(); |
||||
|
||||
} |
||||
@ -1,30 +0,0 @@ |
||||
package org.springblade.desk.oem.pojo.entity; |
||||
|
||||
import com.baomidou.mybatisplus.annotation.TableName; |
||||
import io.swagger.v3.oas.annotations.media.Schema; |
||||
import lombok.Data; |
||||
import lombok.EqualsAndHashCode; |
||||
import org.springblade.core.mp.base.BaseEntity; |
||||
|
||||
import java.io.Serial; |
||||
import java.util.Date; |
||||
|
||||
/** |
||||
* 外协结算任务日志 实体类 |
||||
* |
||||
* @author maxg |
||||
* @since 2026-05-08 |
||||
*/ |
||||
@Data |
||||
@TableName("MES_OEM_STATEMENT_TASK_LOG") |
||||
@Schema(description = "OemStatementTaskLog对象") |
||||
@EqualsAndHashCode(callSuper = true) |
||||
public class OemStatementTaskLogEntity extends BaseEntity { |
||||
|
||||
@Serial |
||||
private static final long serialVersionUID = 1L; |
||||
|
||||
@Schema(description = "镀后入库时间") |
||||
private Date putStoreTime; |
||||
|
||||
} |
||||
@ -1,19 +0,0 @@ |
||||
package org.springblade.desk.oem.feign; |
||||
|
||||
import io.swagger.v3.oas.annotations.Hidden; |
||||
import jakarta.annotation.Resource; |
||||
import org.springblade.desk.oem.service.IOemStatementService; |
||||
import org.springframework.web.bind.annotation.RestController; |
||||
|
||||
@RestController |
||||
@Hidden |
||||
public class OemStatementClient implements IOemStatementClient { |
||||
|
||||
@Resource |
||||
private IOemStatementService oemStatementService; |
||||
|
||||
@Override |
||||
public void generateSettlement() { |
||||
oemStatementService.generateSettlement(); |
||||
} |
||||
} |
||||
@ -1,18 +0,0 @@ |
||||
package org.springblade.desk.oem.mapper; |
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
||||
import org.springblade.desk.oem.pojo.entity.OemStatementTaskLogEntity; |
||||
|
||||
import java.util.Date; |
||||
|
||||
/** |
||||
* 外协结算任务日志 Mapper 接口 |
||||
* |
||||
* @author maxg |
||||
* @since 2026-05-08 |
||||
*/ |
||||
public interface OemStatementTaskLogMapper extends BaseMapper<OemStatementTaskLogEntity> { |
||||
|
||||
Date getLastMaxPutStoreTime(); |
||||
|
||||
} |
||||
@ -1,23 +0,0 @@ |
||||
<?xml version="1.0" encoding="UTF-8"?> |
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> |
||||
<mapper namespace="org.springblade.desk.oem.mapper.OemStatementTaskLogMapper"> |
||||
|
||||
<!-- 通用查询映射结果 --> |
||||
<resultMap id="mesOemStatementTaskLogResultMap" type="org.springblade.desk.oem.pojo.entity.OemStatementTaskLogEntity"> |
||||
<result column="ID" property="id"/> |
||||
<result column="PUT_STORE_TIME" property="putStoreTime"/> |
||||
<result column="CREATE_USER" property="createUser"/> |
||||
<result column="CREATE_TIME" property="createTime"/> |
||||
<result column="CREATE_DEPT" property="createDept"/> |
||||
<result column="UPDATE_USER" property="updateUser"/> |
||||
<result column="UPDATE_TIME" property="updateTime"/> |
||||
<result column="STATUS" property="status"/> |
||||
<result column="IS_DELETED" property="isDeleted"/> |
||||
</resultMap> |
||||
|
||||
<select id="getLastMaxPutStoreTime" resultType="java.util.Date"> |
||||
SELECT MAX(PUT_STORE_TIME) FROM MES_OEM_STATEMENT_TASK_LOG WHERE IS_DELETED = 0 |
||||
</select> |
||||
|
||||
|
||||
</mapper> |
||||
@ -1,24 +0,0 @@ |
||||
package org.springblade.desk.oem.service; |
||||
|
||||
import org.springblade.core.mp.base.BaseService; |
||||
import org.springblade.desk.oem.pojo.entity.OemStatementTaskLogEntity; |
||||
|
||||
import java.util.Date; |
||||
|
||||
public interface IOemStatementTaskLogService extends BaseService<OemStatementTaskLogEntity> { |
||||
|
||||
/** |
||||
* 获取最大镀后入库时间 |
||||
* |
||||
* @return |
||||
*/ |
||||
Date getLastMaxPutStoreTime(); |
||||
|
||||
/** |
||||
* 保存最大镀后入库时间 |
||||
* |
||||
* @param putStoreTime |
||||
*/ |
||||
void saveMaxPutStoreTime(Date putStoreTime); |
||||
|
||||
} |
||||
File diff suppressed because it is too large
Load Diff
@ -1,26 +0,0 @@ |
||||
package org.springblade.desk.oem.service.impl; |
||||
|
||||
import org.springblade.core.mp.base.BaseServiceImpl; |
||||
import org.springblade.desk.oem.mapper.OemStatementTaskLogMapper; |
||||
import org.springblade.desk.oem.pojo.entity.OemStatementTaskLogEntity; |
||||
import org.springblade.desk.oem.service.IOemStatementTaskLogService; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.util.Date; |
||||
|
||||
@Service |
||||
public class OemStatementTaskLogServiceImpl extends BaseServiceImpl<OemStatementTaskLogMapper, OemStatementTaskLogEntity> implements IOemStatementTaskLogService { |
||||
|
||||
@Override |
||||
public Date getLastMaxPutStoreTime() { |
||||
return baseMapper.getLastMaxPutStoreTime(); |
||||
} |
||||
|
||||
@Override |
||||
public void saveMaxPutStoreTime(Date putStoreTime) { |
||||
OemStatementTaskLogEntity entity = new OemStatementTaskLogEntity(); |
||||
entity.setPutStoreTime(putStoreTime); |
||||
this.save(entity); |
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue