提交 f04fdc48 authored 作者: inroi's avatar inroi

微调

上级 1c404144
......@@ -12,8 +12,11 @@ import org.jeecg.modules.iost.ims.entity.ImsPickingList;
import org.jeecg.modules.iost.ims.kingdeeapi.ImsPickingListKingdeeApi;
import org.jeecg.modules.iost.ims.mapper.ImsPickingListMapper;
import org.jeecg.modules.iost.ims.service.IImsPickingListService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import java.math.BigDecimal;
import java.util.*;
......@@ -24,6 +27,8 @@ import java.util.*;
@Service
public class ImsPickingListServiceImpl extends ServiceImpl<ImsPickingListMapper, ImsPickingList> implements IImsPickingListService {
private static final Logger log = LoggerFactory.getLogger(ImsPickingListServiceImpl.class);
@Autowired
private IMSApi imsApi;
......@@ -87,9 +92,8 @@ public class ImsPickingListServiceImpl extends ServiceImpl<ImsPickingListMapper,
//记录IMS日志
flag = new ImsLogUtil().ImsLog(json, result, "提料分析单", "SUP_MTRL_DT_DATA", null);
if (anAl(imsList.get(0).get("sup_mtrl_dt_anal_no").toString())) {
System.out.println("+++++++++++++++" + "总数以发送完");
/*Map<String, Object> noMap = new HashMap<>(3);
if (!CollectionUtils.isEmpty(imsList) && anAl(imsList.get(0).get("sup_mtrl_dt_anal_no").toString())) {
Map<String, Object> noMap = new HashMap<>(3);
map.put("docType", "SUP_MTRL_DT_DATA_ANAL");
map.put("updateType", "UPDATE");
map.put("data", new ArrayList<Map<String, Object>>().add(new HashMap<String, Object>(1) {{
......@@ -98,19 +102,16 @@ public class ImsPickingListServiceImpl extends ServiceImpl<ImsPickingListMapper,
String noJson = JsonUtil.toString(noMap);
String noResult = imsApi.add(noJson, "提料单计算", "SUP_MTRL_DT_DATA_ANAL");
//记录IMS日志
new ImsLogUtil().ImsLog(noJson, noResult, "提料单计算", "SUP_MTRL_DT_DATA_ANAL", null);*/
} else {
System.out.println("---------------" + "总数未发送完");
new ImsLogUtil().ImsLog(noJson, noResult, "提料单计算", "SUP_MTRL_DT_DATA_ANAL", null);
}
return flag;
}
public boolean anAl(String supMtrlDtAnalNo) {
Integer count = this.getBaseMapper().selectCount(new QueryWrapper<ImsPickingList>().eq("sup_mtrl_dt_anal_no", supMtrlDtAnalNo));
System.out.println("count----------->" + count);
Integer pushCount = this.getBaseMapper().selectOne(new QueryWrapper<ImsPickingList>().eq("sup_mtrl_dt_anal_no", supMtrlDtAnalNo).last("limit 1")).getPushCount();
System.out.println("pushCount----------->" + pushCount);
log.info("分析单号为{}, 以同步数量{}条, 需要同步数量{}条", supMtrlDtAnalNo, count, pushCount);
return pushCount != 0 && pushCount.equals(count);
}
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论