|
|
|
@ -9,6 +9,7 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
|
|
import com.chanjet.openapi.sdk.java.exception.ChanjetApiException;
|
|
|
|
|
import com.chanko.yunxi.mes.framework.common.pojo.CommonResult;
|
|
|
|
|
import com.chanko.yunxi.mes.framework.common.util.object.BeanUtils;
|
|
|
|
|
import com.chanko.yunxi.mes.framework.mybatis.core.query.MPJLambdaWrapperX;
|
|
|
|
|
import com.chanko.yunxi.mes.framework.operatelog.core.enums.OperateTypeEnum;
|
|
|
|
|
import com.chanko.yunxi.mes.framework.operatelog.core.service.OperateLogFrameworkService;
|
|
|
|
|
import com.chanko.yunxi.mes.module.biz.controller.admin.chanjet.ChanjetSpi;
|
|
|
|
@ -552,7 +553,12 @@ public class ChanjetManager {
|
|
|
|
|
public void queryMaterial() throws ChanjetApiException {
|
|
|
|
|
// 设置为“否”,关闭所有与用友通信的接口
|
|
|
|
|
if(!getSystemParameters()) return ;
|
|
|
|
|
String maxTs = null;
|
|
|
|
|
// String maxTs = null;
|
|
|
|
|
MaterialDO materialDOMaxTs = materialMapper.selectList(new MPJLambdaWrapperX<MaterialDO>(){{
|
|
|
|
|
orderByDesc("CONV(REPLACE(ts,'0x',''), 16, 10)");
|
|
|
|
|
last("LIMIT 1");
|
|
|
|
|
}}).get(0);
|
|
|
|
|
String maxTs = materialDOMaxTs== null?null:materialDOMaxTs.getTs();
|
|
|
|
|
// HashSet<String> materialIds = new HashSet<>();
|
|
|
|
|
do {
|
|
|
|
|
QueryMaterialReqVO.QueryMaterialParamVO paramVO = new QueryMaterialReqVO.QueryMaterialParamVO(maxTs);
|
|
|
|
|