package com.zy.asrs.task; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.core.common.DateUtils; import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; import com.zy.asrs.entity.*; import com.zy.asrs.entity.result.OrderResult; import com.zy.asrs.service.*; import com.zy.asrs.service.impl.DocTypeServiceImpl; import com.zy.common.utils.HttpHandler; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.stereotype.Service; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.Date; import java.util.HashMap; @Service @Slf4j public class CollectOrdersScheduler extends AbstractHandler { @Value("${erp.address.URL}") private String URL; @Value("${erp.address.inaddress}") private String inaddress; @Autowired private OrderService orderService; @Autowired private DocTypeService docTypeService; @Autowired private SnowflakeIdWorker snowflakeIdWorker; @Autowired private MatService matService; @Autowired private OrderDetlService orderDetlService; @Autowired private ApiLogService apiLogService; /** * 轮询获取入库订单 */ @Scheduled(cron = "0/30 * * * * ? ") private synchronized void execute() { // 获取当前日期时间 LocalDateTime now = LocalDateTime.now(); // 减去一个月 LocalDateTime oneMonthAgo = now.minusMonths(1); // 定义日期时间格式（HH表示24小时制） DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); // 格式化日期时间 String formattedDateTime = oneMonthAgo.format(formatter); HashMap hashMap=new HashMap<>(); HashMap map = new HashMap<>(); map.put("orgNo", "2");//组织编号 // map.put("docNo",0); map.put("startTime", formattedDateTime);//开始时间 String format = now.format(formatter); map.put("endTime", format);//结束时间 hashMap.put("condition",map); //查询订单 String response = ""; boolean success = false; try { response = new HttpHandler.Builder() .setUri(URL) .setPath(inaddress) .setJson(JSON.toJSONString(hashMap)) .build() .doPost(); JSONObject jsonObject = JSON.parseObject(response); if (jsonObject.getInteger("status") == 200) { JSONArray response1 = JSON.parseArray(jsonObject.get("response").toString()); for (int j = 0; j < response1.size(); j++) { OrderResult orderResult = response1.getObject(j, OrderResult.class); Order order = orderService.selectByNo(orderResult.getDocNo());//单据编号 if (Cools.isEmpty(order)) { Date now1 = new Date(); DocType docType = docTypeService.selectOne(new EntityWrapper().eq("memo",orderResult.getDocType()));//单据编号 // 单据主档 order = new Order( String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空] orderResult.getDocNo(), // 订单编号 DateUtils.convert(now1), // 单据日期 docType.getDocId(), // 单据类型 null, // 项目编号 null, // null, // 调拨项目编号 null, // 初始票据号 null, // 票据号 null, // 客户编号 null, // 客户 null, // 联系方式 null, // 操作人员 null, // 合计金额 null, // 优惠率 null, // 优惠金额 null, // 销售或采购费用合计 null, // 实付金额 null, // 付款类型 null, // 业务员 null, // 结算天数 null, // 邮费支付类型 null, // 邮费 null, // 付款时间 null, // 发货时间 null, // 物流名称 null, // 物流单号 1L, // 订单状态 1, // 状态 9527L, // 添加人员 now1, // 添加时间 9527L, // 修改人员 now1, // 修改时间 null // 备注 ); if (!orderService.insert(order)) { throw new CoolException("生成单据失败，请联系管理员"); } } //物料编码 Mat mat = matService.selectByMatnr(orderResult.getItemNo()); if (Cools.isEmpty(mat)) { Mat mat1=new Mat(); mat1.setTagId(1L); mat1.setMatnr(orderResult.getItemNo()); mat1.setMaktx(orderResult.getItemName()); mat1.setSpecs(orderResult.getItemSpec()); mat1.setMatType(3); matService.insert(mat1); // throw new CoolException(orderResult.getItemNo() + "编号商品检索失败，请先添加商品"); } OrderDetl orderDetl1 = orderDetlService.selectOne(new EntityWrapper() .eq("order_no", orderResult.getDocNo()) .eq("matnr", orderResult.getItemNo()) .eq("batch", orderResult.getDocLotNo()));//批号 if(Cools.isEmpty(orderResult.getDocLotNo())){ orderDetl1 = orderDetlService.selectOne(new EntityWrapper() .eq("order_no", orderResult.getDocNo()) .eq("matnr", orderResult.getItemNo())); } if (!Cools.isEmpty(orderDetl1)) { continue; } OrderDetl orderDetl = new OrderDetl(); orderDetl.setMatnr(orderResult.getItemNo()); orderDetl.setMaktx(orderResult.getItemName()); orderDetl.setSpecs(orderResult.getItemSpec()); orderDetl.setBatch(orderResult.getDocLotNo()); orderDetl.setAnfme(orderResult.getApplyQty()); 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); //保存erp传过来的字段 orderDetl.setManu((orderResult.getOrgNo()));//组织编码 orderDetl.setModel(orderResult.getDocSeqNo());//项次--行号 orderDetl.setColor(orderResult.getDocWarehouseNo());//任务仓库 orderDetl.setBrand(orderResult.getDocCellNo());//任务储位 orderDetl.setUnit(orderResult.getUnitNo());//单位编号 orderDetl.setSku(orderResult.getUnitName());//单位名称 orderDetl.setItemNum(orderResult.getSupplierNo());//供应商编码 orderDetl.setOrigin(orderResult.getSupplierName());//供应商名称 if (!orderDetlService.insert(orderDetl)) { throw new CoolException("生成单据明细失败，请联系管理员"); } } } else { } } catch (Exception e) { log.error("fail", e); } finally { try { // 保存接口日志 apiLogService.save( "轮询数据", URL + inaddress, null, "127.0.0.1", map.toString(), response, success ); } catch (Exception e) { log.error("", e); } } } }