#

luxiaotao1123

2023-04-06 e37cbe8c4d9cdf1f511135d302960faa04e12dd6

#

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

@@ -5,8 +5,12 @@
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;

import java.util.List;

@Mapper
@Repository
public interface WrkChargeMapper extends BaseMapper<WrkCharge> {

    List<WrkCharge> findTimeoutData();

}

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

@@ -1,8 +1,12 @@
package com.zy.asrs.service;

import com.zy.asrs.entity.WrkCharge;
import com.baomidou.mybatisplus.service.IService;
import com.zy.asrs.entity.WrkCharge;

import java.util.List;

public interface WrkChargeService extends IService<WrkCharge> {

    List<WrkCharge> findTimeoutData();

}

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

@@ -6,7 +6,13 @@
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

import java.util.List;

@Service("wrkChargeService")
public class WrkChargeServiceImpl extends ServiceImpl<WrkChargeMapper, WrkCharge> implements WrkChargeService {

    @Override
    public List<WrkCharge> findTimeoutData() {
        return this.baseMapper.findTimeoutData();
    }
}

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

New file
@@ -0,0 +1,30 @@
package com.zy.asrs.task;

import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.WrkChargeHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * Created by vincent on 2020/7/7
 */
@Component
public class WrkChargeScheduler {

    private static final Logger log = LoggerFactory.getLogger(WrkChargeScheduler.class);

    @Autowired
    private WrkChargeHandler wrkChargeHandler;

    @Scheduled(cron = "0/3 * * * * ? ")
    private void execute(){
        ReturnT<String> returnT = wrkChargeHandler.start();
        if (!returnT.isSuccess()) {
            log.error(returnT.getMsg());
        }
    }

}

 src/main/java/com/zy/asrs/task/handler/WrkChargeHandler.java

New file
@@ -0,0 +1,49 @@
package com.zy.asrs.task.handler;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.zy.asrs.entity.WrkCharge;
import com.zy.asrs.service.WrkChargeService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

import java.util.List;

/**
 * Created by vincent on 2020/7/7
 */
@Service
public class WrkChargeHandler extends AbstractHandler<String> {

    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Autowired
    private WrkChargeService wrkChargeService;

    @Transactional
    public ReturnT<String> start() {
        try {
            List<WrkCharge> wrkCharges = wrkChargeService.findTimeoutData();
            if (!Cools.isEmpty(wrkCharges)) {
                for (WrkCharge wrkCharge : wrkCharges) {
                    wrkChargeService.delete(new EntityWrapper<WrkCharge>()
                            .eq("wrk_no", wrkCharge.getWrkNo())
                            .eq("wrk_sts", wrkCharge.getWrkSts())
                            .eq("ste_no", wrkCharge.getSteNo())
                    );
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return FAIL.setMsg(e.getMessage());
        }
        return SUCCESS;
    }

}

 src/main/resources/mapper/WrkChargeMapper.xml

@@ -29,4 +29,11 @@

    </resultMap>

    <select id="findTimeoutData" resultMap="BaseResultMap">
        select * from asr_wrk_charge
        where 1=1
        and dateadd(mi,30,modi_time) &lt;= getdate()
        and wrk_sts not in (30, 47)
    </select>

</mapper>