diff --git a/src/main/java/com/yem/wm/es/exportpresent/task/ExportPresentWarningTask.java b/src/main/java/com/yem/wm/es/exportpresent/task/ExportPresentWarningTask.java new file mode 100644 index 00000000..7a775f27 --- /dev/null +++ b/src/main/java/com/yem/wm/es/exportpresent/task/ExportPresentWarningTask.java @@ -0,0 +1,170 @@ +package com.yem.wm.es.exportpresent.task; + +import com.yem.rf.utils.RFUtils; +import com.yem.tws.common1.DateUtils; +import com.yem.wm.es.shippingdetails.util.PaymentControlUtil; +import com.yem.wm.utils.DynamicObjectUtil; +import com.yem.wm.utils.YEM; +import kd.bos.context.RequestContext; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.exception.KDException; +import kd.bos.orm.query.QFilter; +import kd.bos.schedule.executor.AbstractTask; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import org.apache.commons.compress.utils.Lists; + +import java.math.BigDecimal; +import java.time.LocalDate; +import java.util.*; + +/** + * @Description: 寄单放单申请收汇方式，增加销售员（根据携带当前行合同上的销售员）、应回款日期（提单日+收款天数），应回款日期不为空时，每10天给销售员发送一次消息提醒：合同：***，寄单放单单号：***，应回款日期为：***，请知悉！ + * @Date: 2024/12/19 10:24 + * @Created: by ZZSLL + */ + +public class ExportPresentWarningTask extends AbstractTask { + @Override + public void execute(RequestContext requestContext, Map map) throws KDException { + +// boolean isSendMessage = isTenDaysAfter(); + + QFilter qFilter = RFUtils.getBaseQFilter(); + qFilter.and(new QFilter("yem_isladingbill", "=", "A")); + String selectfields = DynamicObjectUtil.getSelectfields("yem_es_exportpresent"); + selectfields = DynamicObjectUtil.getEntrySelectfields(selectfields, "yem_es_exportpresent", "yem_es_exportpre_erw"); + DynamicObject[] load = BusinessDataServiceHelper.load("yem_es_exportpresent", selectfields, qFilter.toArray()); + // 订舱单号-提单日期 + Map ladingDateMap = new HashMap<>(); + // 合同号-是否合同回款完成 + Map isClaimFinishedMap = new HashMap<>(); + for (DynamicObject d : load) { + DynamicObjectCollection c = d.getDynamicObjectCollection("yem_es_exportpre_erw"); + for (DynamicObject subD : c) { + String shipmentnum = subD.getString("yem_shipmentnum_c"); + ladingDateMap.put(shipmentnum, null); + String contractnum = subD.getString("yem_contractnum_c"); + + isClaimFinishedMap.put(contractnum, true); + } + } + + Map salesorders = BusinessDataServiceHelper.loadFromCache("yem_es_salesorder", "id, billno", new QFilter[]{new QFilter("billno", "in", isClaimFinishedMap.keySet())}); + Map salesorderNo = new HashMap<>(); + for (Map.Entry salesorderEntry : salesorders.entrySet()) { + Long orderId = (Long) salesorderEntry.getKey(); + DynamicObject order = salesorderEntry.getValue(); + salesorderNo.put(order.getString("billno"), orderId); + } + Map stOrder = BusinessDataServiceHelper.loadFromCache("yem_es_storagetrans", "id, billno, yem_es_salescontrac_s.yem_rapamt, yem_es_salescontrac_s.yem_contractnumbers_p, yem_es_salescontrac_s.yem_ispre", new QFilter[]{new QFilter("yem_es_salescontrac_s.yem_contractnumbers_p", "in", salesorderNo.keySet())}); + // 合同号-收汇金额合计 + Map receiveAmt = new HashMap<>(); + for (DynamicObject stBill : stOrder.values()) { + DynamicObjectCollection collection = stBill.getDynamicObjectCollection("yem_es_salescontrac_s"); + for (DynamicObject d : collection) { + boolean ispre = d.getBoolean("yem_ispre"); + if (ispre) { + BigDecimal rapamt = d.getBigDecimal("yem_rapamt"); + String contractnumbers = d.getString("yem_contractnumbers_p"); + BigDecimal calc; + if (receiveAmt.containsKey(contractnumbers)) { + calc = receiveAmt.get(contractnumbers).add(rapamt); + } else { + calc = rapamt; + } + receiveAmt.put(contractnumbers, calc); + } + } + } + for (Map.Entry salesorderEntry : salesorderNo.entrySet()) { + String billno = salesorderEntry.getKey(); + DynamicObject salesorder = salesorders.get(salesorderEntry.getValue()); + if (salesorder == null) continue; + BigDecimal climeAmt = PaymentControlUtil.getContractClimeAmt(salesorder, "F"); + if (receiveAmt.containsKey(billno)) { + BigDecimal receive = receiveAmt.get(billno); + if (receive.compareTo(climeAmt) < 0 && isClaimFinishedMap.containsKey(billno)) { + isClaimFinishedMap.put(billno, false); + } + } + } + + // 查询提单日期 + Map st = BusinessDataServiceHelper.loadFromCache("yem_es_storagetrans", "id, billno, yem_tddate", new QFilter[]{new QFilter("billno", "in", ladingDateMap.keySet())}); + for (DynamicObject value : st.values()) { + String billno = value.getString("billno"); + Date tddate = value.getDate("yem_tddate"); + ladingDateMap.put(billno, tddate); + } + + Map> message = new HashMap<>(); + for (DynamicObject d : load) { + DynamicObjectCollection c = d.getDynamicObjectCollection("yem_es_exportpre_erw"); + for (DynamicObject subD : c) { + String stno = subD.getString("yem_shipmentnum_c"); + if (ladingDateMap.containsKey(stno)) { + Date date = ladingDateMap.get(stno); + if (YEM.isEmpty(date)) continue; + // 计算应回款日期 = 天数 + 提单日期 + int forward = subD.getInt("yem_forward"); + Date added = DateUtils.addDays(date, forward); + subD.set("yem_shdreceivedate", added); + String contractnum = subD.getString("yem_contractnum_c"); +// if (isSendMessage) { + // 以认领完成 + if (isClaimFinishedMap.containsKey(contractnum) && isClaimFinishedMap.get(contractnum)) { + continue; + } + DynamicObject operator = subD.getDynamicObject("yem_operator_e"); + if (operator == null) continue; + long sendUser = operator.getLong("id"); + List list; + if (message.containsKey(sendUser)) { + list = message.get(sendUser); + } else { + list = new ArrayList<>(); + } + list.add(String.format("合同：%s，寄单放单单号：%s，应回款日期为：%s，请知悉！\n\r", contractnum, d.getString("billno"), DateUtils.getData(added, "yyyy-MM-dd"))); + message.put(sendUser, list); +// } + } + } + } + + Set phone = new HashSet<>(); + phone.add("15771670073"); + ArrayList devUserIds = Lists.newArrayList(); + // 发给开发测试 + DynamicObject[] users = BusinessDataServiceHelper.load("bos_user", "id, name, phone", new QFilter[]{new QFilter("phone", "in", phone)}); + for (DynamicObject user : users) { + devUserIds.add(user.getLong("id")); + } + + for (Map.Entry> sendMsg : message.entrySet()) { + Long userid = sendMsg.getKey(); + List messageContent = sendMsg.getValue(); + ArrayList sendUserId = Lists.newArrayList(); + sendUserId.add(userid);//销售员 + sendUserId.addAll(devUserIds); + + YEM.sendMessage(sendUserId, "预警消息", "回款预警", String.join("", messageContent), "预警消息"); + } + + SaveServiceHelper.save(load); + } + + /** + * 当前日期是否是给定日期的十天后 + * + * @return Boolean + */ + public static boolean isTenDaysAfter() { + // 起始日期 + LocalDate startDate = LocalDate.of(2024, 12, 1); + long daysBetween = java.time.temporal.ChronoUnit.DAYS.between(startDate, LocalDate.now()); + // 是否是起始日期10天后或，10*n天后 + return daysBetween >= 0 && daysBetween % 10 == 0; + } +}