Compare commits
No commits in common. 'master' and 'liweidong' have entirely different histories.
21 changed files with 177 additions and 1071 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