13

zhang

2025-05-24 c22266b4dfbe3f338d2dd0bb31b10df1b5c92fb5

 src/main/java/com/zy/nc/task/handler/BaseDataHandler.java

@@ -4,9 +4,11 @@
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.Cools;
import com.zy.asrs.entity.StoreType;
import com.zy.asrs.entity.Tag;
import com.zy.asrs.entity.param.MatSyncParam;
import com.zy.asrs.service.OpenService;
import com.zy.asrs.service.StoreTypeService;
import com.zy.asrs.service.TagService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
@@ -72,6 +74,9 @@
    @Autowired
    private UserService userService;

    @Autowired
    private StoreTypeService storeTypeService;

    @Value("${NYNC.pageSize}")
    private Integer pageSize;

@@ -133,6 +138,21 @@
        Page<NccJcCkWms> wmsFlag = nccJcCkWmsService.selectPage(page, new EntityWrapper<NccJcCkWms>().ne("wms_flag", 1));
        for (NccJcCkWms nccJcCkWms : wmsFlag.getRecords()) {
            log.info("NccJcCkWms数据:{}", JSONObject.toJSON(nccJcCkWms));
            StoreType storeType = storeTypeService.selectById(nccJcCkWms.getCode());
            if (storeType == null) {
                storeType = new StoreType();
                storeType.setStoreName(nccJcCkWms.getName());
                storeType.setStatus(1);
                storeType.setStoreId(nccJcCkWms.getCode());
                storeType.setCreateBy(1L);
                storeType.setCreateTime(new Date());
                storeTypeService.insert(storeType);
            } else {
                storeType.setStoreName(nccJcCkWms.getName());
                storeTypeService.updateById(storeType);
            }
            nccJcCkWms.setWmsFlag(1);
            nccJcCkWmsService.updateById(nccJcCkWms);
        }
        return SUCCESS;
    }