1

zc

昨天 6695e0e3e9b166a692b2f430ec09a3245b22a078

 src/main/java/com/zy/third/lk/task/LKInTBScheduler.java

@@ -2,12 +2,14 @@

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.Cools;
import com.core.common.DateUtils;
import com.core.exception.CoolException;
import com.zy.asrs.entity.DocType;
import com.zy.asrs.entity.Order;
import com.zy.asrs.entity.OrderDetl;
import com.zy.asrs.mapper.OrderMapper;
import com.zy.asrs.service.DocTypeService;
import com.zy.asrs.service.MatService;
import com.zy.asrs.service.OrderDetlService;
@@ -20,6 +22,7 @@
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
@@ -50,6 +53,9 @@

    private final ReentrantLock lock = new ReentrantLock();

    @Resource
    private OrderMapper orderMapper;

    @Transactional(rollbackFor = Throwable.class)
    @Scheduled(cron = "0/10 * * * * ?")
    public void pakinOrderComplete() {
@@ -62,7 +68,16 @@

        // 所有订单
        try {
            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().setSqlSelect("TOP 2 *").eq("settle", 4L));
//            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L));
            // 创建分页对象：页码 1，每页 2 条
            Page<Order> page = new Page<>(1, 10); // 一次10条，避免处理不过来
            // 使用 selectPage 获取前 2 条记录
            Page<Order> result = orderService.selectPage(
                    page,
                    new EntityWrapper<Order>().eq("settle", 4L)
            );

            List<Order> orders = result.getRecords(); // 这就是前 2 条
            DocType docType;
            for (Order order : orders) {

@@ -106,9 +121,9 @@
     */
    @Transactional(rollbackFor = Throwable.class)
    public boolean insertInDet(OrderDetl orderDetl) {
        String sqlInDetTb = "select * from lk_InDetTB where BillNo='" + orderDetl.getOrderNo() + "' and " + " ItemId='" + orderDetl.getMatnr() + "' and ItemBatch='" + orderDetl.getBatch() + "' and proType='" + orderDetl.getSpecs() + "'";
        String sqlInDetTb = "select * from lk_InDetTB where BillNo='" + orderDetl.getOrderNo() + "' and " + " ItemId='" + orderDetl.getMatnr() + "' and ItemBatch='" + orderDetl.getBatch() + "'";
        List<InDetTB> inDets = erpSqlServer.select(sqlInDetTb, InDetTB.class);
        String sqlInDetTbBak = "select * from lk_InDetTB_Bak where BillNo='" + orderDetl.getOrderNo() + "' and " + " ItemId='" + orderDetl.getMatnr() + "' and ItemBatch='" + orderDetl.getBatch() + "' and proType='" + orderDetl.getSpecs() + "'";
        String sqlInDetTbBak = "select * from lk_InDetTB_Bak where BillNo='" + orderDetl.getOrderNo() + "' and " + " ItemId='" + orderDetl.getMatnr() + "' and ItemBatch='" + orderDetl.getBatch() + "'";
        List<InDetTBBak> inDetBaks = erpSqlServer.select(sqlInDetTbBak, InDetTBBak.class);
        if (!inDets.isEmpty() || !inDetBaks.isEmpty()) {
            log.error("该单号料号中间表表身已存在:" + orderDetl.getOrderNo() + "==>>" + orderDetl.getOrderNo());