zy-asrs.git - Gitblit

			@@ -38,9 +38,42 @@
			//端口
			private String URL;

			@Value("${erp.address.inaddress}")
			//单据，商品档案地址
			private String inaddress;
			@Value("${erp.address.mataddress}")
			//商品档案地址
			private String matAddress;
			@Value("${erp.address.orgaddress}")
			//货主档案地址
			private String orgAddress;
			@Value("${erp.address.impurreceivebilladdress}")
			//收料单查询
			private String imPurreceiveBillAddress;
			@Value("${erp.address.impurreceivebilldetl}")
			//进仓通知单
			private String imPurreceiveBillDetlAddress;
			@Value("${erp.address.imSaloutbill}")
			//销售出库单
			private String imSaloutbill;
			@Value("${erp.address.scpSalreturn}")
			//销售退货单
			private String scpSalreturn;
			@Value("${erp.address.scpSalreturnDetl}")
			//销售退货单
			private String scpSalreturnDetl;
			@Value("${erp.address.imMdcMftproorder}")
			//生产领料单
			private String imMdcMftproorder;
			@Value("${erp.address.imMdcMftreturnorder}")
			//生产退料单
			private String imMdcMftreturnorder;
			@Value("${erp.address.imMdcMftfeedorder}")
			//生产补料单
			private String imMdcMftfeedorder;
			@Value("${erp.address.imProductinbill}")
			//生产进仓单
			private String imProductinbill;
			@Value("${erp.address.qcppManuinspec}")
			//产品检验单
			private String qcppManuinspec;

			@Autowired
			private ApiLogService apiLogService;
			@@ -69,6 +102,8 @@
			@Autowired
			private LocOwnerService locOwnerService;
			@Autowired
			private LocSuppService locSuppService;
			@Autowired
			private ErpSecretServiceImpl erpSecretService;
			@Value("${erp.login.accountId}")
			private String accountId;
			@@ -83,52 +118,132 @@


			for(KingDeeUtilType kingDeeUtilType : KingDeeUtilType.values()) {
			MatLoadParam matLoadParam = new MatLoadParam();
			// MatLoadParam matLoadParam = new MatLoadParam();
			DocType docType = docTypeService.selectOne(new EntityWrapper<DocType>().eq("doc_name", kingDeeUtilType.desc));
			if (Cools.isEmpty(docType) && !kingDeeUtilType.formId.equals("BD_MATERIAL")){
			docType = docTypeService.selectOrAdd(kingDeeUtilType.desc, kingDeeUtilType.pakIn.equals(1));
			}
			String FDocumentStatus=null;
			if (Arrays.asList("INR").contains(kingDeeUtilType.formId)) {
			continue;
			}
			//条件和需要获得的结果拼接
			JSONObject jsonObject = new JSONObject();
			//物料档案查询
			if(kingDeeUtilType.formId.equals("BD_MATERIAL")){
			Tag tag = tagService.selectByName("全部", 1);
			jsonObject.put("id", null);//id
			jsonObject.put("number", null);//编码
			jsonObject.put("createorg_number", null);//创建组织
			jsonObject.put("start_createtime", "2025-01-01 00:00:00");//创建起始
			jsonObject.put("end_createtime", sdf1.format(new Date()));//创建截止
			jsonObject.put("start_modifytime", "2025-01-01 00:00:00");//更新起始
			jsonObject.put("end_modifytime", sdf1.format(new Date()));//更新截止
			jsonObject.put("start_approvedate", "2025-01-01");//审核起始
			jsonObject.put("end_approvedate", sdf2.format(new Date()));//审核截止
			jsonObject.put("status", Arrays.asList("B", "C"));//数据状态 [A:暂存, B:已提交, C:已审核]

			}else{
			//获取最新时间
			//单据状态
			FDocumentStatus="B";
			jsonObject.put("FilterString", "FCreateDate>'"+sdf1.format(docType.getCreateTime())+"'"+" and FStockId.Fname='立库'"+" and FDocumentStatus='"+FDocumentStatus+"'");
			jsonObject.put("FieldKeys", "FBillNo,FCreateDate,FMaterialId.FNumber,FMaterialId.FName,FMaterialId.FSpecification,"+kingDeeUtilType.anfme+",FDocumentStatus");
			// FBillNo :单据编号；
			// FCreateDate ：单据创建时间；
			// FMaterialId.FNumber : 物料编码；
			// FMaterialName ：物料名称；
			// FMaterialId.FSpecification：物料规格
			// anfme : 物料数量
			// FDocumentStatus ：单据状态；

			String path = null;
			Date now = new Date();
			String latestUpdateTime = sdf1.format(docType.getUpdateTime());
			switch (kingDeeUtilType.formId) {
			case "BD_MATERIAL": //物料同步
			jsonObject.put("id", null);//id
			jsonObject.put("number", null);//编码
			jsonObject.put("createorg_number", null);//创建组织
			jsonObject.put("start_createtime", "2025-01-01 00:00:00");//创建起始
			jsonObject.put("end_createtime", sdf1.format(now));//创建截止
			jsonObject.put("start_modifytime", latestUpdateTime);//更新起始
			jsonObject.put("end_modifytime", sdf1.format(now));//更新截止
			jsonObject.put("start_approvedate", "2025-01-01");//审核起始
			jsonObject.put("end_approvedate", sdf2.format(now));//审核截止
			jsonObject.put("status", Arrays.asList("C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			path = matAddress;
			break;
			case "BD_RRGANIZATION": //供应商同步
			jsonObject.put("start_createtime", "2025-01-01 00:00:00");//id
			jsonObject.put("end_createtime", sdf1.format(now));
			jsonObject.put("id", null);
			jsonObject.put("number", null);
			jsonObject.put("createorg_number", null);
			jsonObject.put("status", Arrays.asList("B", "C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			path = orgAddress;
			break;
			case "PUR_RECEIVEBIll": //已审核收料单查询
			jsonObject.put("start_biztime", "2025-01-01 00:00:00");//业务起始日期
			jsonObject.put("end_biztime", sdf1.format(now));//业务结束日期
			jsonObject.put("billno", null);
			jsonObject.put("billstatus", Arrays.asList("C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			jsonObject.put("start_auditdate", "2025-11-25 00:00:00");
			jsonObject.put("end_auditdate", sdf1.format(now));
			jsonObject.put("org_number", null);
			jsonObject.put("supplier_number", null);
			path = imPurreceiveBillAddress;
			break;
			case "SAL_OUTSTOCK"://销售出库单查询
			path = imSaloutbill;
			jsonObject.put("modify_starttime", latestUpdateTime);//业务起始日期
			jsonObject.put("billstatus", "B");//单据状态
			jsonObject.put("modify_endtime", sdf1.format(now));//业务起始日期
			break;
			case "SAL_RETURNSTOCK"://销售退货
			path = scpSalreturn;
			jsonObject.put("start_modifytime", "2025-11-25 00:00:00");//业务起始日期
			jsonObject.put("billstatus", "B");//单据状态
			jsonObject.put("end_starttime", sdf1.format(now));//业务起始日期
			break;
			case "PRD_PickMtrl"://生产领料单
			path = imMdcMftproorder;
			// jsonObject.put("start_modifytime", "2025-11-25 00:00:00");
			// jsonObject.put("start_auditdate", "2025-11-25 00:00:00");
			jsonObject.put("start_createtime", "2025-11-25 00:00:00");
			jsonObject.put("end_createtime", sdf1.format(now));
			// jsonObject.put("end_auditdate", sdf1.format(now));
			// jsonObject.put("end_modifytime", sdf1.format(now));
			jsonObject.put("billno", null);
			jsonObject.put("billstatus", Arrays.asList("B","C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			jsonObject.put("org_number", null);
			jsonObject.put("id", null);
			break;
			case "PRD_ReturnMtrl"://生产退料单
			path = imMdcMftreturnorder;
			jsonObject.put("id", null);
			jsonObject.put("billno", null);
			jsonObject.put("org_number", null);
			jsonObject.put("billstatus", Arrays.asList("C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			jsonObject.put("start_createtime", "2025-11-25 00:00:00");
			jsonObject.put("end_createtime", sdf1.format(now));
			// jsonObject.put("start_modifytime", "2025-11-25 00:00:00");
			// jsonObject.put("end_modifytime", sdf1.format(now));
			// jsonObject.put("start_auditdate", "2025-11-25 00:00:00");
			// jsonObject.put("end_auditdate", sdf1.format(now));
			break;
			case "PRD_FeedMtrl"://生产补料单
			path = imMdcMftfeedorder;
			jsonObject.put("id", null);
			jsonObject.put("billno", null);
			jsonObject.put("org_number", null);
			jsonObject.put("billstatus", Arrays.asList("C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			jsonObject.put("start_createtime", "2025-11-25 00:00:00");
			jsonObject.put("end_createtime", sdf1.format(now));
			// jsonObject.put("start_modifytime", "2025-11-25 00:00:00");
			// jsonObject.put("end_modifytime", sdf1.format(now));
			// jsonObject.put("start_auditdate", "2025-11-25 00:00:00");
			// jsonObject.put("end_auditdate", sdf1.format(now));
			break;
			case "PRD_MORPT"://生产进仓单
			path = imProductinbill;
			jsonObject.put("billstatus", Arrays.asList("C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			jsonObject.put("modifytime_start", "2025-11-25 00:00:00");
			jsonObject.put("modifytime_end", sdf1.format(now));
			break;
			case "STK_InspectionForm"://产品检验
			path = qcppManuinspec;
			jsonObject.put("billstatus", Arrays.asList("C"));//数据状态 [A:暂存, B:已提交, C:已审核]
			jsonObject.put("auditdate_start", "2025-11-25 00:00:00");
			jsonObject.put("auditdate_end", sdf1.format(now));
			break;
			}
			if(path == null){
			continue;
			}
			JSONObject jsonObject1 = new JSONObject();
			jsonObject1.put("data", jsonObject);
			jsonObject1.put("pageSize", 10);
			jsonObject1.put("pageSize", 20);
			jsonObject1.put("pageNo", 1);
			String add = jsonObject1.toJSONString();

			//上报
			String response = "";
			boolean success = false;
			if(path == null){
			continue;
			}
			try {
			//获取Cookie值
			HashMap<String, Object> headers = new HashMap<>();
			@@ -137,7 +252,7 @@
			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(inaddress)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();
			@@ -152,7 +267,6 @@
			//商品档案同步
			if (kingDeeUtilType.formId.equals("BD_MATERIAL")) {
			Tag tag = tagService.selectByName("全部", 1);

			// 处理分页：根据返回的totalCount和pageSize计算页数
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			@@ -165,7 +279,7 @@
			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(inaddress)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();
			@@ -177,24 +291,28 @@
			Date modifyTime = sdf1.parse(jsonObjectNew.get("modifytime").toString());
			String matnr = jsonObjectNew.get("number").toString();
			String name = jsonObjectNew.get("name").toString();
			String createtime = jsonObjectNew.get("createtime").toString();
			Double grossweight = jsonObjectNew.get("grossweight") != null ? new BigDecimal(jsonObjectNew.get("grossweight").toString()).doubleValue() : 0.0;
			Double height = jsonObjectNew.get("height") != null ? new BigDecimal(jsonObjectNew.get("height").toString()).doubleValue() : 0.0;
			Double width = jsonObjectNew.get("width") != null ? new BigDecimal(jsonObjectNew.get("width").toString()).doubleValue() : 0.0;
			Double length = jsonObjectNew.get("length") != null ? new BigDecimal(jsonObjectNew.get("length").toString()).doubleValue() : 0.0;

			String createTime = jsonObjectNew.get("createtime").toString();
			Double grossweight = jsonObjectNew.get("grossweight") != null ? new BigDecimal(jsonObjectNew.get("eap7_decimalfield6").toString()).doubleValue() : 0.0;
			Double height = jsonObjectNew.get("height") != null ? new BigDecimal(jsonObjectNew.get("eap7_decimalfield9").toString()).doubleValue() : 0.0;
			Double width = jsonObjectNew.get("width") != null ? new BigDecimal(jsonObjectNew.get("eap7_decimalfield8").toString()).doubleValue() : 0.0;
			Double length = jsonObjectNew.get("length") != null ? new BigDecimal(jsonObjectNew.get("eap7_decimalfield7").toString()).doubleValue() : 0.0;
			Double netweight = jsonObjectNew.get("netweight") != null ? new BigDecimal(jsonObjectNew.get("eap7_decimalfield").toString()).doubleValue() : 0.0;
			// 生成商品档案
			Double height1 = height*10;
			Double width1 = width*10;
			Double length1 = length*10;
			Mat mat = matService.selectByMatnr(matnr);
			if (mat == null) {
			mat = new Mat();
			mat.setMatnr(matnr);
			mat.setMaktx(name);
			mat.setTagId(tag.getId());
			mat.setWeight(grossweight);
			mat.setManLength(length);
			mat.setHeight(height);
			mat.setWidth(width);
			mat.setCreateTime(sdf1.parse(createtime));
			mat.setWeight(grossweight);//净重
			mat.setUnits(netweight);//毛重
			mat.setManLength(length1);
			mat.setHeight(height1);
			mat.setWidth(width1);
			mat.setCreateTime(sdf1.parse(createTime));
			mat.setUpdateTime(modifyTime);
			mat.setStatus(1);
			if (!matService.insert(mat)) {
			@@ -202,6 +320,7 @@
			log.info("同步新物料出错！参数：[{}]、[{}]", mat, jsonObjectNew);
			} else {
			callApiLogSaveMat(mat, kingDeeUtilType, "同步新物料成功！", true);
			success = true;
			}
			} else {
			boolean isUpdated = false;
			@@ -209,156 +328,1306 @@
			// 更新字段
			if (!mat.getMaktx().equals(name)) mat.setMaktx(name);
			if (mat.getWeight().compareTo(grossweight) != 0) mat.setWeight(grossweight);
			if (mat.getManLength().compareTo(length) != 0) mat.setManLength(length);
			if (mat.getHeight().compareTo(height) != 0) mat.setHeight(height);
			if (mat.getWidth().compareTo(width) != 0) mat.setWidth(width);
			if (mat.getCreateTime().compareTo(sdf1.parse(createtime)) != 0)
			mat.setCreateTime(sdf1.parse(createtime));
			if (mat.getManLength().compareTo(length) != 0) mat.setManLength(length1);
			if (mat.getHeight().compareTo(height) != 0) mat.setHeight(height1);
			if (mat.getWidth().compareTo(width) != 0) mat.setWidth(width1);
			if (mat.getCreateTime().compareTo(sdf1.parse(createTime)) != 0)
			mat.setCreateTime(sdf1.parse(createTime));
			mat.setUpdateTime(modifyTime);
			isUpdated = true;
			}
			// 执行更新操作
			if (isUpdated) {
			mat.setUpdateTime(new Date());
			if (!matService.updateById(mat)) {
			callApiLogSaveMat(mat, kingDeeUtilType, "更新物料出错！" + mat, false);
			log.info("更新物料[商品编号：{}], 更新失败！", mat.getMatnr());
			} else {
			callApiLogSaveMat(mat, kingDeeUtilType, "更新物料成功！", true);
			success = true;
			log.info("更新物料[商品编号：{}]", mat.getMatnr());
			}
			}
			}
			}
			}
			}else if(kingDeeUtilType.formId.equals("BD_RRGANIZATION")){

			} else {
			for (int j = 0; j < data.size(); j++) {
			JSONArray jsonArray = data.getJSONArray(j);
			//最新抓取时间
			Date jsonDate = KingDeeUtil.KingDeeDate(jsonArray.get(1).toString());
			docType.setCreateTime(jsonDate);
			Order order = OrderInAndOutUtil.selectByNo(kingDeeUtilType.pakIn == 1, jsonArray.get(0).toString());
			// Order order = orderService.selectByNo(jsonArray.get(0).toString());
			LocOwner locOwner = null;
			if (!Cools.isEmpty(1)) {
			locOwner = locOwnerService.selectById(1);
			} else {
			locOwner = locOwnerService.selectById(1);
			}
			if (Cools.isEmpty(order)) {
			Date now = new Date();
			// 单据主档
			order = new Order(
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			jsonArray.get(0).toString(), // 订单编号
			DateUtils.convert(now), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			"1", //项目名称客户PO号
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			locOwner.getOwnerUuid(), // 客户编号
			locOwner.getOwner(), // 客户
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null // 备注
			);
			OrderInAndOutUtil.insertOrder(kingDeeUtilType.pakIn == 1, order);

			// if (!orderService.insert(order)) {
			// if (!jsonDate.equals(docType.getCreateTime())){
			// callApiLogSaveOrder(order,kingDeeUtilType, "生成单据主档失败，请联系管理员"+order, false);
			// }
			// continue;
			//// throw new CoolException("生成单据主档失败，请联系管理员");
			// }
			}
			//物料编码
			Mat mat = matService.selectByMatnr(jsonArray.get(2).toString());
			if (Cools.isEmpty(mat)) {
			if (!jsonDate.equals(docType.getCreateTime())){
			callApiLogSaveOrder(order,kingDeeUtilType, "编号商品检索失败，请先添加商品"+jsonArray.get(2).toString(), false);
			}
			continue;
			}
			// OrderDetl orderDetl1 = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", jsonArray.get(0).toString()).eq("matnr", jsonArray.get(2).toString()));
			// if (!Cools.isEmpty(orderDetl1)) {
			// continue;
			// }
			Order order1 = OrderInAndOutUtil.selectByNo(kingDeeUtilType.pakIn == 1, jsonArray.get(0).toString());
			List<OrderDetl> orderDetls = OrderInAndOutUtil.selectByOrderId(kingDeeUtilType.pakIn == 1, order1.getId());
			boolean sign = false;
			for (OrderDetl orderDetl : orderDetls){
			if (orderDetl.getMatnr().equals( jsonArray.get(2).toString())){
			sign = true;
			break;
			}
			}
			if (sign){
			continue;
			}
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setBatch(null);
			orderDetl.setAnfme(Double.parseDouble(jsonArray.get(5).toString()));
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);
			// if (!orderDetlService.insert(orderDetl)) {
			// callApiLogSaveOrder(order,kingDeeUtilType, "生成单据明细失败，请联系管理员!订单号："+order.getOrderNo(), false);
			//// throw new CoolException("生成单据明细失败，请联系管理员");
			// }
			OrderInAndOutUtil.insertOrderDetl(kingDeeUtilType.pakIn == 1,order,orderDetl);
			if(success){
			docType.setUpdateTime(now);
			docTypeService.updateById(docType);
			}
			docTypeService.updateById(docType);
			}
			//供应商
			else if(kingDeeUtilType.formId.equals("BD_RRGANIZATION")){//供应商同步
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);

			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();
			// 重新发起请求以获取该页的数据
			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");
			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date updateTime = sdf1.parse(jsonObjectNew.get("modifytime").toString());
			String ownerUuid = jsonObjectNew.get("number").toString();
			String owner = jsonObjectNew.get("name").toString();
			Date createTime = sdf1.parse(jsonObjectNew.get("createtime").toString());
			// 生成商品档案
			LocSupp locSupp = locSuppService.selectByUuid(ownerUuid);
			if (locSupp == null) {
			locSupp = new LocSupp();
			locSupp.setOwner(owner);
			locSupp.setOwnerUuid(ownerUuid);
			locSupp.setCreateTime(createTime);
			locSupp.setUpdateTime(updateTime);
			locSupp.setStatus(1);
			if (!locSuppService.insert(locSupp)) {
			callApiLogSaveSupp(locSupp, kingDeeUtilType, "同步新供应商出错！" + locSupp, false);
			log.info("同步新供应商出错！参数：[{}]、[{}]", locSupp, jsonObjectNew);
			} else {
			callApiLogSaveSupp(locSupp, kingDeeUtilType, "同步新供应商成功！", true);
			}
			} else {
			boolean isUpdated = false;
			if (locSupp.getUpdateTime().compareTo(updateTime) != 0) {
			// 更新字段
			if (!locSupp.getOwner().equals(owner)) locSupp.setOwner(owner);
			if (!locSupp.getOwnerUuid().equals(ownerUuid)) locSupp.setOwnerUuid(ownerUuid);

			if (locSupp.getCreateTime().compareTo(createTime) != 0)
			locSupp.setCreateTime(createTime);
			locSupp.setUpdateTime(updateTime);
			isUpdated = true;
			}
			// 执行更新操作
			if (isUpdated) {
			if (!locSuppService.updateById(locSupp)) {
			callApiLogSaveSupp(locSupp, kingDeeUtilType, "更新供应商出错！" + locSupp, false);
			log.info("更新供应商[供应商编号：{}], 更新失败！", locSupp.getOwnerUuid());
			} else {
			callApiLogSaveSupp(locSupp, kingDeeUtilType, "更新供应商成功！", true);
			log.info("更新供应商[供应商编号：{}]", locSupp.getOwnerUuid());
			}
			}
			}
			}
			}
			}
			//收料单
			else if(kingDeeUtilType.formId.equals("PUR_RECEIVEBIll")){
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);
			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();
			// 重新发起请求以获取该页的数据
			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");
			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date createTime = sdf1.parse(jsonObjectNew.get("createtime").toString());
			String billNo = jsonObjectNew.get("billno").toString();//单据编号
			String owner = jsonObjectNew.get("org_name").toString();//货主名称
			String ownerUuid = jsonObjectNew.get("org_number").toString();//erp货主编号
			String orderId = jsonObjectNew.get("id").toString();
			JSONObject detailParam = new JSONObject();
			JSONObject dataObj = new JSONObject();
			dataObj.put("billno", billNo);
			detailParam.put("pageNo", 1);
			detailParam.put("pageSize", 100);
			detailParam.put("data", dataObj);
			boolean hasNext = true;
			while (hasNext) {
			String reqJson = detailParam.toJSONString();
			String detailResp = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(imPurreceiveBillDetlAddress)
			.setJson(reqJson)
			.build()
			.doPost();
			JSONObject detailJson = JSON.parseObject(detailResp);
			JSONObject detData = detailJson.getJSONObject("data");
			if(detData == null){
			continue;
			}
			JSONArray rows = detData.getJSONArray("rows");
			// ====== 处理明细 ======
			for (int i = 0; i < rows.size(); i++) {
			JSONObject jsonObjectNew2 = rows.getJSONObject(i);
			Order order = orderService.selectByNo(billNo);//检索单据
			LocOwner locOwner = null;
			if (ownerUuid != null) {
			locOwner = locOwnerService.selectByUuid(ownerUuid);
			if (locOwner == null) {
			callApiLogSaveOwner(locOwner,kingDeeUtilType, "货主检索失败，请先添加对应货主编号："+ownerUuid+"名称"+owner, false);continue;
			}
			} else{
			callApiLogSaveOwner(locOwner,kingDeeUtilType, "货主检索失败，未查询到货主编号！", false);continue;
			}
			if (Cools.isEmpty(order)) {
			// 单据主档
			order = new Order(
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			billNo, // 订单编号
			createTime.toString(), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			orderId, //收料单id
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			null, // 项目id
			owner, // 货主
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null, // 备注
			kingDeeUtilType.pakIn !=1?2:1
			);
			if( orderService.insert(order)){
			callApiLogSaveOrder(order, kingDeeUtilType, "创建入库单成功！单号：" + billNo, true);
			}
			}
			String suppCode = jsonObjectNew2.getString("supplier_number"); //供应商

			JSONArray billEntryArray = jsonObjectNew2.getJSONArray("billentry");
			for (int k = 0; k < billEntryArray.size(); k++) {
			JSONObject entry = billEntryArray.getJSONObject(k);
			String matnr = entry.getString("material_number"); //物料编码，内部SKU
			Double anfme = entry.getDouble("eap7_decimalfield");//箱数
			Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数
			Double Totalvolume = entry.getDouble("eap7_decimalfield2");//总体积
			String warehouse = entry.getString("warehouse_number");//仓库编码
			String pOrderNo = entry.getString("eap7_textfield3");//采购单号
			String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号）
			String s2 = entry.getString("eap7_textfield5"); //条码UPC
			String memo = entry.getString("eap7_textfield6"); //备注（英文描述）
			String s1 = entry.getString("eap7_textfield7"); //客户PO
			String detlId = entry.getString("id"); //明细id
			Long seq = entry.getLong("seq"); //分录行号
			// String
			if(anfme == 0){
			callApiLogSaveOrder(order,kingDeeUtilType, "单据数量异常"+matnr, false);
			continue;
			}
			//物料编码
			Mat mat = matService.selectByMatnr(matnr);
			if (Cools.isEmpty(mat)) {
			callApiLogSaveOrder(order,kingDeeUtilType, "编号商品检索失败，请先添加商品"+matnr, false);
			continue;
			}
			Order order1 = orderService.selectByNo( billNo);
			List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order1.getId());
			boolean sign = false;
			for (OrderDetl orderDetl : orderDetls){
			if (orderDetl.getMatnr().equals(matnr)){
			sign = true;
			break;
			}
			}
			if (sign){
			continue;
			}
			LocSupp locSupp = null;
			String supp =null;
			locSupp = locSuppService.selectByUuid(suppCode);
			if(locSupp != null){supp = locSupp.getOwner();}
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setThreeCode(detlId);//ERP明细id
			orderDetl.setLineNumber(seq);//分录行号
			orderDetl.setAnfme(anfme);//总箱数
			orderDetl.setErpAnfme(anfme);//erp数据
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());//表头单据
			orderDetl.setSupp(supp);//供应商名称（货源）
			orderDetl.setSuppCode(suppCode);//供应商编码
			orderDetl.setSku(matnr);//内部SKU
			orderDetl.setStandby1(s1);//客户PO
			orderDetl.setStandby2(s2);//条码UPC
			orderDetl.setStandby3(s3);//客户SKU
			orderDetl.setBoxType1(owner); //货主名称
			orderDetl.setBoxType2(ownerUuid);//货主编号（erp组织）
			orderDetl.setBoxType3(pOrderNo);//采购单号
			orderDetl.setMemo(memo);//英文备注
			orderDetl.setVolume(Totalvolume);//总体积
			orderDetl.setSafeQty(totalNumItems);//总件数
			orderDetl.setManu(warehouse);//仓库编码
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);
			orderDetlService.insert(orderDetl);
			}
			}
			// 是否还有下一页
			boolean lastPage = detData.getBoolean("lastPage");
			if (lastPage) {
			hasNext = false;
			} else {
			// 下一页
			int currPage = detData.getIntValue("pageNo");
			detailParam.put("pageNo", currPage + 1);
			}
			}
			}
			docTypeService.updateById(docType);
			}
			}
			//销售出库
			else if(kingDeeUtilType.formId.equals("SAL_OUTSTOCK")){
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);

			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();

			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");

			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date createTime = sdf1.parse(jsonObjectNew.getString("createtime"));
			String billNo = jsonObjectNew.getString("billno");
			String owner = jsonObjectNew.getString("org_name");
			String ownerUuid = jsonObjectNew.getString("org_number");
			String orderId = jsonObjectNew.getString("id");
			// ========= 货主校验 =========
			LocOwner locOwner = locOwnerService.selectByUuid(ownerUuid);
			// if (locOwner == null) {
			// callApiLogSaveOwner(null, kingDeeUtilType,
			// "货主检索失败：" + ownerUuid + " 名称：" + owner, false);
			// continue;
			// }

			// ========= 创建订单主表 =========
			Order order = orderService.selectByNo(billNo);
			if (Cools.isEmpty(order)) {
			order = new Order(
			// 单据主档
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			billNo, // 订单编号
			createTime.toString(), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			orderId, //收料单id
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			null, // 项目id
			owner, // 货主
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null, // 备注
			kingDeeUtilType.pakIn !=1?2:1
			);
			if (orderService.insert(order)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"创建销售出库单成功！单号：" + billNo, true);
			}
			}

			// ========= 直接从主接口取明细 billentry =========
			JSONArray billEntryArray = jsonObjectNew.getJSONArray("billentry");
			if (billEntryArray == null \|\| billEntryArray.isEmpty()) {
			continue;
			}
			for (int k = 0; k < billEntryArray.size(); k++) {
			JSONObject entry = billEntryArray.getJSONObject(k);
			String matnr = entry.getString("material_number"); //物料编码，内部SKU
			Double anfme = entry.getDouble("eap7_decimalfield");//箱数
			Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数
			Double totalVolume = entry.getDouble("eap7_decimalfield2");//总体积
			String warehouse = entry.getString("warehouse_number");//仓库编码
			String pOrderNo = entry.getString("eap7_textfield3");//采购单号
			String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号）
			String s2 = entry.getString("eap7_textfield5"); //条码UPC
			String memo = entry.getString("eap7_textfield6"); //备注（英文描述）
			String s1 = entry.getString("eap7_textfield7"); //客户PO
			String detlId = entry.getString("id"); //明细id
			Long seq = entry.getLong("seq"); //分录行号
			// String suppCode = entry.getString("supplier_number");
			String suppCode = null;
			if (anfme == null \|\| anfme == 0) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"单据数量异常：" + matnr, false);
			continue;
			}
			// ========= 物料校验 =========
			Mat mat = matService.selectByMatnr(matnr);
			if (Cools.isEmpty(mat)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"商品不存在：" + matnr, false);
			continue;
			}
			// ========= 明细去重 =========
			List<OrderDetl> orderDetls =
			orderDetlService.selectByOrderId(order.getId());

			boolean exists = orderDetls.stream()
			.anyMatch(o -> o.getMatnr().equals(matnr));
			if (exists) continue;
			// // ========= 供应商 =========
			String supp = null;
			// LocSupp locSupp = locSuppService.selectByUuid(suppCode);
			// if (locSupp != null) {
			// supp = locSupp.getOwner();
			// }
			// ========= 保存明细 =========
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setThreeCode(detlId);
			orderDetl.setLineNumber(seq);
			orderDetl.setAnfme(anfme);
			orderDetl.setErpAnfme(anfme);
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());
			orderDetl.setSupp(supp);
			orderDetl.setSuppCode(suppCode);
			orderDetl.setSku(matnr);
			orderDetl.setStandby1(s1);
			orderDetl.setStandby2(s2);
			orderDetl.setStandby3(s3);
			orderDetl.setBoxType1(owner);
			orderDetl.setBoxType2(ownerUuid);
			orderDetl.setBoxType3(pOrderNo);
			orderDetl.setMemo(memo);
			orderDetl.setVolume(totalVolume);
			orderDetl.setSafeQty(totalNumItems);
			orderDetl.setManu(warehouse);
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);

			orderDetlService.insert(orderDetl);
			}
			}
			docType.setUpdateTime(now);
			docTypeService.updateById(docType);
			}

			}
			//销售退货
			else if(kingDeeUtilType.formId.equals("SAL_RETURNSTOCK")){
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);
			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();
			// 重新发起请求以获取该页的数据
			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");
			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date createTime = sdf1.parse(jsonObjectNew.get("createtime").toString());
			String billNo = jsonObjectNew.get("billno").toString();//单据编号
			String orderId = jsonObjectNew.get("id").toString();
			JSONObject detailParam = new JSONObject();
			JSONObject dataObj = new JSONObject();
			dataObj.put("billno", billNo);
			detailParam.put("pageNo", 1);
			detailParam.put("pageSize", 100);
			detailParam.put("data", dataObj);
			boolean hasNext = true;
			while (hasNext) {
			String reqJson = detailParam.toJSONString();
			String detailResp = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(scpSalreturnDetl)
			.setJson(reqJson)
			.build()
			.doPost();
			JSONObject detailJson = JSON.parseObject(detailResp);
			JSONObject detData = detailJson.getJSONObject("data");
			JSONArray rows = detData.getJSONArray("rows");
			// ====== 处理明细 ======
			for (int i = 0; i < rows.size(); i++) {
			JSONObject jsonObjectNew2 = rows.getJSONObject(i);
			Order order = orderService.selectByNo(billNo);//检索单据
			LocOwner locOwner = null;
			if (Cools.isEmpty(order)) {
			// 单据主档
			order = new Order(
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			billNo, // 订单编号
			createTime.toString(), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			orderId, //收料单id
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			null, // 项目id
			null, // 货主
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null, // 备注
			kingDeeUtilType.pakIn !=1?2:1
			);
			if( orderService.insert(order)){
			callApiLogSaveOrder(order, kingDeeUtilType, "创建销售退货单成功！单号：" + billNo, true);
			}
			}
			// String suppCode = jsonObjectNew2.getString("supplier_number"); //供应商
			String suppCode = null; //供应商
			JSONArray billEntryArray = jsonObjectNew2.getJSONArray("materialentry");
			for (int k = 0; k < billEntryArray.size(); k++) {
			JSONObject entry = billEntryArray.getJSONObject(k);
			String matnr = entry.getString("material_number"); //物料编码，内部SKU
			Double anfme = entry.getDouble("qty");//箱数
			Double totalNumItems = 0.0;
			Double Totalvolume = 0.0;//总体积
			String warehouse = null;//仓库编码
			String pOrderNo = "1";//采购单号
			String s3 = "1";//客户sku（客户编号）
			String s2 = "1"; //条码UPC
			String memo ="1"; //备注（英文描述）
			String s1 = "1"; //客户PO
			// Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数
			// Double Totalvolume = entry.getDouble("eap7_decimalfield2");//总体积
			// String warehouse = entry.getString("warehouse_number");//仓库编码
			// String pOrderNo = entry.getString("eap7_textfield3");//采购单号
			// String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号）
			// String s2 = entry.getString("eap7_textfield5"); //条码UPC
			// String memo = entry.getString("eap7_textfield6"); //备注（英文描述）
			// String s1 = entry.getString("eap7_textfield7"); //客户PO
			String detlId = entry.getString("id"); //明细id
			Long seq = entry.getLong("seq"); //分录行号
			// String
			if(anfme == 0){
			callApiLogSaveOrder(order,kingDeeUtilType, "单据数量异常"+matnr, false);
			continue;
			}
			//物料编码
			Mat mat = matService.selectByMatnr(matnr);
			if (Cools.isEmpty(mat)) {
			callApiLogSaveOrder(order,kingDeeUtilType, "编号商品检索失败，请先添加商品"+matnr, false);
			continue;
			}
			Order order1 = orderService.selectByNo( billNo);
			List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order1.getId());
			boolean sign = false;
			for (OrderDetl orderDetl : orderDetls){
			if (orderDetl.getMatnr().equals(matnr)){
			sign = true;
			break;
			}
			}
			if (sign){
			continue;
			}
			LocSupp locSupp = null;
			String supp =null;
			// locSupp = locSuppService.selectByUuid(suppCode);
			// if(locSupp != null){supp = locSupp.getOwner();}
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setThreeCode(detlId);//ERP明细id
			orderDetl.setLineNumber(seq);//分录行号
			orderDetl.setAnfme(anfme);//总箱数
			orderDetl.setErpAnfme(anfme);//erp数据
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());//表头单据
			orderDetl.setSupp(supp);//供应商名称（货源）
			orderDetl.setSuppCode(suppCode);//供应商编码
			orderDetl.setSku(matnr);//内部SKU
			orderDetl.setStandby1(s1);//客户PO
			orderDetl.setStandby2(s2);//条码UPC
			orderDetl.setStandby3(s3);//客户SKU
			orderDetl.setBoxType1(null); //货主名称
			orderDetl.setBoxType2(null);//货主编号（erp组织）
			orderDetl.setBoxType3(pOrderNo);//采购单号
			orderDetl.setMemo(memo);//英文备注
			orderDetl.setVolume(Totalvolume);//总体积
			orderDetl.setSafeQty(totalNumItems);//总件数
			orderDetl.setManu(warehouse);//仓库编码
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);
			orderDetlService.insert(orderDetl);
			}
			}
			// 是否还有下一页
			boolean lastPage = detData.getBoolean("lastPage");
			if (lastPage) {
			hasNext = false;
			} else {
			// 下一页
			int currPage = detData.getIntValue("pageNo");
			detailParam.put("pageNo", currPage + 1);
			}
			}
			}
			docTypeService.updateById(docType);
			}
			}
			//产品检验单
			else if(kingDeeUtilType.formId.equals("STK_InspectionForm")){
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);

			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();

			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");

			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date createTime = sdf1.parse(jsonObjectNew.getString("createtime"));
			String billNo = jsonObjectNew.getString("billno");
			String owner = jsonObjectNew.getString("org_name");
			String ownerUuid = jsonObjectNew.getString("org_number");
			String orderId = jsonObjectNew.getString("id");
			// ========= 货主校验 =========
			LocOwner locOwner = locOwnerService.selectByUuid(ownerUuid);
			// if (locOwner == null) {
			// callApiLogSaveOwner(null, kingDeeUtilType,
			// "货主检索失败：" + ownerUuid + " 名称：" + owner, false);
			// continue;
			// }

			// ========= 创建订单主表 =========
			Order order = orderService.selectByNo(billNo);
			if (Cools.isEmpty(order)) {
			order = new Order(
			// 单据主档
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			billNo, // 订单编号
			createTime.toString(), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			orderId, //收料单id
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			null, // 项目id
			owner, // 货主
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null, // 备注
			kingDeeUtilType.pakIn !=1?2:1
			);
			if (orderService.insert(order)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"创建销售出库单成功！单号：" + billNo, true);
			}
			}

			// ========= 直接从主接口取明细 billentry =========
			JSONArray billEntryArray = jsonObjectNew.getJSONArray("billentry");
			if (billEntryArray == null \|\| billEntryArray.isEmpty()) {
			continue;
			}
			for (int k = 0; k < billEntryArray.size(); k++) {
			JSONObject entry = billEntryArray.getJSONObject(k);
			String matnr = entry.getString("material_number"); //物料编码，内部SKU
			Double anfme = entry.getDouble("eap7_decimalfield");//箱数
			Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数
			Double totalVolume = entry.getDouble("eap7_decimalfield2");//总体积
			String warehouse = entry.getString("warehouse_number");//仓库编码
			String pOrderNo = entry.getString("eap7_textfield3");//采购单号
			String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号）
			String s2 = entry.getString("eap7_textfield5"); //条码UPC
			String memo = entry.getString("eap7_textfield6"); //备注（英文描述）
			String s1 = entry.getString("eap7_textfield7"); //客户PO
			String detlId = entry.getString("id"); //明细id
			Long seq = entry.getLong("seq"); //分录行号
			// String suppCode = entry.getString("supplier_number");
			String suppCode = null;
			if (anfme == null \|\| anfme == 0) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"单据数量异常：" + matnr, false);
			continue;
			}
			// ========= 物料校验 =========
			Mat mat = matService.selectByMatnr(matnr);
			if (Cools.isEmpty(mat)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"商品不存在：" + matnr, false);
			continue;
			}
			// ========= 明细去重 =========
			List<OrderDetl> orderDetls =
			orderDetlService.selectByOrderId(order.getId());

			boolean exists = orderDetls.stream()
			.anyMatch(o -> o.getMatnr().equals(matnr));
			if (exists) continue;
			// // ========= 供应商 =========
			String supp = null;
			// LocSupp locSupp = locSuppService.selectByUuid(suppCode);
			// if (locSupp != null) {
			// supp = locSupp.getOwner();
			// }
			// ========= 保存明细 =========
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setThreeCode(detlId);
			orderDetl.setLineNumber(seq);
			orderDetl.setAnfme(anfme);
			orderDetl.setErpAnfme(anfme);
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());
			orderDetl.setSupp(supp);
			orderDetl.setSuppCode(suppCode);
			orderDetl.setSku(matnr);
			orderDetl.setStandby1(s1);
			orderDetl.setStandby2(s2);
			orderDetl.setStandby3(s3);
			orderDetl.setBoxType1(owner);
			orderDetl.setBoxType2(ownerUuid);
			orderDetl.setBoxType3(pOrderNo);
			orderDetl.setMemo(memo);
			orderDetl.setVolume(totalVolume);
			orderDetl.setSafeQty(totalNumItems);
			orderDetl.setManu(warehouse);
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);

			orderDetlService.insert(orderDetl);
			}
			}
			docType.setUpdateTime(now);
			docTypeService.updateById(docType);
			}

			}
			//生产领料，生产补料
			else if(kingDeeUtilType.formId.equals("PRD_PickMtrl") \|\| kingDeeUtilType.formId.equals("PRD_FeedMtrl")){
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);
			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();
			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");

			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date createTime = sdf1.parse(jsonObjectNew.getString("createtime"));
			String billNo = jsonObjectNew.getString("billno");
			String owner = jsonObjectNew.getString("org_name");
			String ownerUuid = jsonObjectNew.getString("org_number");
			String orderId = jsonObjectNew.getString("id");
			// ========= 创建订单主表 =========
			Order order = orderService.selectByNo(billNo);
			if (Cools.isEmpty(order)) {
			order = new Order(
			// 单据主档
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			billNo, // 订单编号
			createTime.toString(), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			orderId, //收料单id
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			null, // 项目id
			owner, // 货主
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null, // 备注
			kingDeeUtilType.pakIn !=1?2:1
			);
			if (orderService.insert(order)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"创建生产领料出库单成功！单号：" + billNo, true);
			}
			}
			// ========= 直接从主接口取明细 billentry =========
			JSONArray billEntryArray = jsonObjectNew.getJSONArray("billentry");
			if (billEntryArray == null \|\| billEntryArray.isEmpty()) {
			continue;
			}
			for (int k = 0; k < billEntryArray.size(); k++) {
			JSONObject entry = billEntryArray.getJSONObject(k);
			String matnr = entry.getString("material_number"); //物料编码，内部SKU
			Double anfme = entry.getDouble("qty");//箱数
			Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数
			Double totalVolume = entry.getDouble("eap7_decimalfield2");//总体积
			String warehouse = entry.getString("warehouse_number");//仓库编码
			String pOrderNo = entry.getString("eap7_textfield3");//采购单号
			String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号）
			String s2 = entry.getString("eap7_textfield5"); //条码UPC
			String memo = entry.getString("eap7_textfield6"); //备注（英文描述）
			String s1 = entry.getString("eap7_textfield7"); //客户PO
			String detlId = entry.getString("id"); //明细id
			Long seq = entry.getLong("seq"); //分录行号
			// String suppCode = entry.getString("supplier_number");
			String suppCode = null;
			if (anfme == null \|\| anfme == 0) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"单据数量异常：" + matnr, false);
			continue;
			}
			// ========= 物料校验 =========
			Mat mat = matService.selectByMatnr(matnr);
			if (Cools.isEmpty(mat)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"物料档案不存在：" + matnr, false);
			continue;
			}
			// ========= 明细去重 =========
			List<OrderDetl> orderDetls =
			orderDetlService.selectByOrderId(order.getId());

			boolean exists = orderDetls.stream()
			.anyMatch(o -> o.getMatnr().equals(matnr));
			if (exists) continue;
			// // ========= 供应商 =========
			String supp = null;
			// LocSupp locSupp = locSuppService.selectByUuid(suppCode);
			// if (locSupp != null) {
			// supp = locSupp.getOwner();
			// }
			// ========= 保存明细 =========
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setThreeCode(detlId);
			orderDetl.setLineNumber(seq);
			orderDetl.setAnfme(anfme);
			orderDetl.setErpAnfme(anfme);
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());
			orderDetl.setSupp(supp);
			orderDetl.setSuppCode(suppCode);
			orderDetl.setSku(matnr);
			orderDetl.setStandby1(s1);
			orderDetl.setStandby2(s2);
			orderDetl.setStandby3(s3);
			orderDetl.setBoxType1(owner);
			orderDetl.setBoxType2(ownerUuid);
			orderDetl.setBoxType3(pOrderNo);
			orderDetl.setMemo(memo);
			orderDetl.setVolume(totalVolume);
			orderDetl.setSafeQty(totalNumItems);
			orderDetl.setManu(warehouse);
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);

			orderDetlService.insert(orderDetl);
			}
			}
			docType.setUpdateTime(now);
			docTypeService.updateById(docType);
			}

			}
			//生产退料单PRD_ReturnMtrl
			else if(kingDeeUtilType.formId.equals("PRD_ReturnMtrl") ) {
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);

			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();

			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");

			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date createTime = sdf1.parse(jsonObjectNew.getString("createtime"));
			String billNo = jsonObjectNew.getString("billno");
			String owner = jsonObjectNew.getString("org_name");
			String ownerUuid = jsonObjectNew.getString("org_number");
			String orderId = jsonObjectNew.getString("id");
			// ========= 货主校验 =========
			LocOwner locOwner = locOwnerService.selectByUuid(ownerUuid);
			// if (locOwner == null) {
			// callApiLogSaveOwner(null, kingDeeUtilType,
			// "货主检索失败：" + ownerUuid + " 名称：" + owner, false);
			// continue;
			// }

			// ========= 创建订单主表 =========
			Order order = orderService.selectByNo(billNo);
			if (Cools.isEmpty(order)) {
			order = new Order(
			// 单据主档
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			billNo, // 订单编号
			createTime.toString(), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			orderId, //收料单id
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			null, // 项目id
			owner, // 货主
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null, // 备注
			kingDeeUtilType.pakIn !=1?2:1
			);
			if (orderService.insert(order)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"创建生产补料单成功！单号：" + billNo, true);
			}
			}

			// ========= 直接从主接口取明细 billentry =========
			JSONArray billEntryArray = jsonObjectNew.getJSONArray("billentry");
			if (billEntryArray == null \|\| billEntryArray.isEmpty()) {
			continue;
			}
			for (int k = 0; k < billEntryArray.size(); k++) {
			JSONObject entry = billEntryArray.getJSONObject(k);
			String matnr = entry.getString("material_number"); //物料编码，内部SKU
			Double anfme = entry.getDouble("eap7_decimalfield");//箱数
			Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数
			Double totalVolume = entry.getDouble("eap7_decimalfield2");//总体积
			String warehouse = entry.getString("warehouse_number");//仓库编码
			String pOrderNo = entry.getString("eap7_textfield3");//采购单号
			String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号）
			String s2 = entry.getString("eap7_textfield5"); //条码UPC
			String memo = entry.getString("eap7_textfield6"); //备注（英文描述）
			String s1 = entry.getString("eap7_textfield7"); //客户PO
			String detlId = entry.getString("id"); //明细id
			Long seq = entry.getLong("seq"); //分录行号
			// String suppCode = entry.getString("supplier_number");
			String suppCode = null;
			if (anfme == null \|\| anfme == 0) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"单据数量异常：" + matnr, false);
			continue;
			}
			// ========= 物料校验 =========
			Mat mat = matService.selectByMatnr(matnr);
			if (Cools.isEmpty(mat)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"商品不存在：" + matnr, false);
			continue;
			}
			// ========= 明细去重 =========
			List<OrderDetl> orderDetls =
			orderDetlService.selectByOrderId(order.getId());

			boolean exists = orderDetls.stream()
			.anyMatch(o -> o.getMatnr().equals(matnr));
			if (exists) continue;
			// // ========= 供应商 =========
			String supp = null;
			// LocSupp locSupp = locSuppService.selectByUuid(suppCode);
			// if (locSupp != null) {
			// supp = locSupp.getOwner();
			// }
			// ========= 保存明细 =========
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setThreeCode(detlId);
			orderDetl.setLineNumber(seq);
			orderDetl.setAnfme(anfme);
			orderDetl.setErpAnfme(anfme);
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());
			orderDetl.setSupp(supp);
			orderDetl.setSuppCode(suppCode);
			orderDetl.setSku(matnr);
			orderDetl.setStandby1(s1);
			orderDetl.setStandby2(s2);
			orderDetl.setStandby3(s3);
			orderDetl.setBoxType1(owner);
			orderDetl.setBoxType2(ownerUuid);
			orderDetl.setBoxType3(pOrderNo);
			orderDetl.setMemo(memo);
			orderDetl.setVolume(totalVolume);
			orderDetl.setSafeQty(totalNumItems);
			orderDetl.setManu(warehouse);
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);

			orderDetlService.insert(orderDetl);
			}
			}
			docType.setUpdateTime(now);
			docTypeService.updateById(docType);
			}

			}
			//生产汇报单
			else if(kingDeeUtilType.formId.equals("PRD_MORPT")) {
			int pageSize = jsonResponse.getJSONObject("data").getIntValue("pageSize");
			int totalCount = jsonResponse.getJSONObject("data").getIntValue("totalCount");
			int totalPages = (int) Math.ceil((double) totalCount / pageSize);

			for (int page = 1; page <= totalPages; page++) {
			jsonObject1.put("pageNo", page);
			add = jsonObject1.toJSONString();

			response = new HttpHandler.Builder()
			.setHeaders(headers)
			.setUri(URL)
			.setPath(path)
			.setJson(add)
			.build()
			.doPost();

			jsonResponse = JSON.parseObject(response);
			data = jsonResponse.getJSONObject("data").getJSONArray("rows");

			for (int j = 0; j < data.size(); j++) {
			JSONObject jsonObjectNew = data.getJSONObject(j);
			Date createTime = sdf1.parse(jsonObjectNew.getString("createtime"));
			String billNo = jsonObjectNew.getString("billno");
			String owner = "和得科技";
			String ownerUuid = "BU-00001";
			String orderId = jsonObjectNew.getString("id");
			// ========= 货主校验 =========
			LocOwner locOwner = locOwnerService.selectByUuid(ownerUuid);
			// if (locOwner == null) {
			// callApiLogSaveOwner(null, kingDeeUtilType,
			// "货主检索失败：" + ownerUuid + " 名称：" + owner, false);
			// continue;
			// }

			// ========= 创建订单主表 =========
			Order order = orderService.selectByNo(billNo);
			if (Cools.isEmpty(order)) {
			order = new Order(
			// 单据主档
			String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空]
			billNo, // 订单编号
			createTime.toString(), // 单据日期
			docType.getDocId(), // 单据类型
			null, // 项目编号
			orderId, //收料单id
			null, // 调拨项目编号
			null, // 初始票据号
			null, // 票据号
			null, // 项目id
			owner, // 货主
			null, // 联系方式
			null, // 操作人员
			null, // 合计金额
			null, // 优惠率
			null, // 优惠金额
			null, // 销售或采购费用合计
			null, // 实付金额
			null, // 付款类型
			null, // 业务员
			null, // 结算天数
			null, // 邮费支付类型
			null, // 邮费
			null, // 付款时间
			null, // 发货时间
			null, // 物流名称
			null, // 物流单号
			1L, // 订单状态
			1, // 状态
			9527L, // 添加人员
			now, // 添加时间
			9527L, // 修改人员
			now, // 修改时间
			null, // 备注
			kingDeeUtilType.pakIn !=1?2:1
			);
			if (orderService.insert(order)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"创建生产汇报单成功！单号：" + billNo, true);
			}
			}

			// ========= 直接从主接口取明细 billentry =========
			JSONArray billEntryArray = jsonObjectNew.getJSONArray("sumentry");
			if (billEntryArray == null \|\| billEntryArray.isEmpty()) {
			continue;
			}
			for (int k = 0; k < billEntryArray.size(); k++) {
			JSONObject entry = billEntryArray.getJSONObject(k);
			String matnr = entry.getString("material_number"); //物料编码，内部SKU
			Double anfme = entry.getDouble("completqty");//箱数
			Double totalNumItems = entry.getDouble("eap7_decimalfield1");//总件数
			Double totalVolume = entry.getDouble("eap7_decimalfield2");//总体积
			String warehouse = entry.getString("warehouse_number");//仓库编码
			String pOrderNo = entry.getString("eap7_textfield");//采购单号
			String s3 = entry.getString("eap7_textfield4");//客户sku（客户编号）
			String s2 = entry.getString("eap7_textfield1"); //条码UPC
			String memo = entry.getString("eap7_textfield6"); //备注（英文描述）
			String s1 = entry.getString("eap7_textfield7"); //客户PO
			String detlId = entry.getString("id"); //明细id
			Long seq = entry.getLong("seq"); //分录行号
			// String suppCode = entry.getString("supplier_number");
			String suppCode = null;
			if (anfme == null \|\| anfme == 0) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"单据数量异常：" + matnr, false);
			continue;
			}
			// ========= 物料校验 =========
			Mat mat = matService.selectByMatnr(matnr);
			if (Cools.isEmpty(mat)) {
			callApiLogSaveOrder(order, kingDeeUtilType,
			"商品不存在：" + matnr, false);
			continue;
			}
			// ========= 明细去重 =========
			List<OrderDetl> orderDetls =
			orderDetlService.selectByOrderId(order.getId());

			boolean exists = orderDetls.stream()
			.anyMatch(o -> o.getMatnr().equals(matnr));
			if (exists) continue;
			// // ========= 供应商 =========
			String supp = null;
			// LocSupp locSupp = locSuppService.selectByUuid(suppCode);
			// if (locSupp != null) {
			// supp = locSupp.getOwner();
			// }
			// ========= 保存明细 =========
			OrderDetl orderDetl = new OrderDetl();
			orderDetl.sync(mat);
			orderDetl.setThreeCode(detlId);
			orderDetl.setLineNumber(seq);
			orderDetl.setAnfme(anfme);
			orderDetl.setErpAnfme(anfme);
			orderDetl.setOrderId(order.getId());
			orderDetl.setOrderNo(order.getOrderNo());
			orderDetl.setSupp(supp);
			orderDetl.setSuppCode(suppCode);
			orderDetl.setSku(matnr);
			orderDetl.setStandby1(s1);
			orderDetl.setStandby2(s2);
			orderDetl.setStandby3(s3);
			orderDetl.setBoxType1(owner);
			orderDetl.setBoxType2(ownerUuid);
			orderDetl.setBoxType3(pOrderNo);
			orderDetl.setMemo(memo);
			orderDetl.setVolume(totalVolume);
			orderDetl.setSafeQty(totalNumItems);
			orderDetl.setManu(warehouse);
			orderDetl.setCreateBy(9527L);
			orderDetl.setCreateTime(new Date());
			orderDetl.setUpdateBy(9527L);
			orderDetl.setUpdateTime(new Date());
			orderDetl.setStatus(1);
			orderDetl.setQty(0.0D);

			orderDetlService.insert(orderDetl);
			}
			}
			docType.setUpdateTime(now);
			docTypeService.updateById(docType);
			}

			}


			} catch (Exception e) {
			log.error("fail", e);
			// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
			return FAIL.setMsg(e.getMessage());
			} finally {
			// try {
			// // 保存接口日志
			// apiLogService.save(
			// "轮询数据",
			// URL + inaddress,
			// null,
			// "127.0.0.1",
			// add,
			// response,
			// success
			// );
			// } catch (Exception e) {
			// log.error("", e);
			// }

			}
			}
			return SUCCESS;
			@@ -366,13 +1635,28 @@

			public void callApiLogSaveMat(Mat mat, KingDeeUtilType kingDeeUtilType, String response, Boolean bool) {
			apiLogService.save("获取"+kingDeeUtilType.desc, kingDeeUtilType.formId, "null", URL,
			"物料编号：" + mat.getMatnr() + "、物料名称：" + mat.getName() + "、类型：" + mat.getTagId$() + "、状态：" + mat.getStatus$(),
			"物料编号：" + mat.getMatnr() + "、物料名称：" + mat.getMaktx() + "、毛重：" + mat.getWeight()
			+ "、长：" + mat.getManLength()
			+ "、宽：" + mat.getWidth()
			+ "、高：" + mat.getHeight()
			+ "、状态：" + mat.getStatus$(),
			response, bool);
			}

			public void callApiLogSaveSupp(LocSupp locSupp, KingDeeUtilType kingDeeUtilType, String response, Boolean bool) {
			apiLogService.save("获取"+kingDeeUtilType.desc, kingDeeUtilType.formId, "null", URL,
			"供应商编号：" + locSupp.getOwnerUuid() + "、供应商名称：" + locSupp.getOwner(),
			response, bool);
			}
			public void callApiLogSaveOwner(LocOwner locOwner, KingDeeUtilType kingDeeUtilType, String response, Boolean bool) {
			apiLogService.save("获取"+kingDeeUtilType.desc, kingDeeUtilType.formId, "null", URL,
			"货主编号：" + locOwner.getOwnerUuid() + "、货主名称：" + locOwner.getOwner(),
			response, bool);
			}

			public void callApiLogSaveOrder(Order order, KingDeeUtilType kingDeeUtilType, String response, Boolean bool) {
			apiLogService.save("获取"+kingDeeUtilType.desc, kingDeeUtilType.formId, "null", URL,
			"单据编号：" + order.getId() + "、状态：" + order.getStatus$(),
			"单据编号：" + order.getOrderNo() + "、状态：" + order.getStatus$(),
			response, bool);
			}