From 774316c8ae477a8424fc077e57e12aebca5678fd Mon Sep 17 00:00:00 2001 From: dxfeng Date: Sun, 5 May 2024 15:02:50 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B0=B4=E7=94=B5=E8=B4=B9=E9=9C=80=E6=B1=82?= =?UTF-8?q?=E5=BC=80=E5=8F=91-=E6=9A=82=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../akx/cronjob/CalculateCostsJob.java | 181 ++++++++++++++++-- 1 file changed, 167 insertions(+), 14 deletions(-) diff --git a/src/weaver/interfaces/akx/cronjob/CalculateCostsJob.java b/src/weaver/interfaces/akx/cronjob/CalculateCostsJob.java index 16f5731..62b9ee1 100644 --- a/src/weaver/interfaces/akx/cronjob/CalculateCostsJob.java +++ b/src/weaver/interfaces/akx/cronjob/CalculateCostsJob.java @@ -1,13 +1,17 @@ package weaver.interfaces.akx.cronjob; +import com.alibaba.fastjson.JSON; +import com.weaver.formmodel.mobile.appio.exports.beans.SqlDataBean; +import com.weaver.formmodel.util.DateHelper; +import org.apache.commons.lang3.StringUtils; import weaver.common.DateUtil; import weaver.conn.RecordSet; +import weaver.conn.StringUtil; +import weaver.formmode.setup.ModeRightInfo; +import weaver.general.Util; import weaver.interfaces.schedule.BaseCronJob; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; /** @@ -18,31 +22,57 @@ import java.util.stream.Collectors; * @version: 1.0 */ public class CalculateCostsJob extends BaseCronJob { + private String calculateDate; + private String modeId; + @Override public void execute() { String currentDate = DateUtil.getCurrentDate(); + // 未指定计算月份，默认计算当前月份 + if (StringUtils.isBlank(calculateDate)) { + calculateDate = currentDate; + } + // 需要计算的月份 + String calculateMonth = calculateDate.substring(0, 7); + // 当前月份 String currentMonth = currentDate.substring(0, 7); + // 计算的开始时间 + String startDay = DateUtil.getFirstDayOfMonth(calculateDate); + // 计算的结束时间 + String endDay = DateUtil.getLastDayOfMonth(calculateDate); + // 当前月的最后一天取当前时间，非当前月的取指定月的最后一天 + endDay = calculateMonth.equals(currentMonth) ? currentDate : endDay; RecordSet rs = new RecordSet(); + String updateSql = "update uf_rysdftz set ts = ?, sdf = ? where ry = ? and ld = ? and yf = ? "; + String insertSql = "insert into uf_rysdftz ( formmodeid, modedatacreater, modedatacreatertype, modedatacreatedate, modedatacreatetime, modeuuid, ts, yf, cs, qy, ld, ry, sdf) values(" + modeId + ", 1, 0, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) "; try { - rs.writeLog("当前日期：" + currentDate + ",水电费计算计划任务开始------"); + rs.writeLog("当前计算日期：" + calculateDate + ",水电费计算计划任务开始------"); // 查询入住日期<=当前日期，且转出日期>=当前日期，或未转出的数据 - String sql = "select * from uf_rygl where rzsj <=? and (zcsj >=? or zcsj is null)"; - rs.executeQuery(sql, currentDate, currentDate); + String sql = "select * from uf_rygl where rzsj <= ?"; + rs.executeQuery(sql, calculateDate); List personnelManagementList = new ArrayList<>(); while (rs.next()) { + String zcsj = rs.getString("zcsj"); + if (StringUtils.isNotBlank(zcsj)) { + boolean equals = zcsj.substring(0, 7).equals(calculateDate); + if (!equals) { + continue; + } + } PersonnelManagement personnelManagement = new PersonnelManagement(); personnelManagement.setLd(rs.getString("ld")); personnelManagement.setYg(rs.getString("yg")); personnelManagement.setRzsj(rs.getString("rzsj")); - personnelManagement.setZcsj(rs.getString("zcsj")); + personnelManagement.setZcsj(zcsj); personnelManagementList.add(personnelManagement); } + // 查询当月所有楼栋的水电费标准 - Map costMap = new HashMap<>(); + Map costMap = new HashMap<>(); sql = "select * from uf_sdfbz where yf = ?"; - rs.executeQuery(sql, currentMonth); + rs.executeQuery(sql, calculateMonth); while (rs.next()) { - costMap.put(rs.getString("yf"), rs.getInt("sdfbz")); + costMap.put(rs.getString("ld"), rs.getDouble("sdfbz")); } // 计算当月的入住天数和费用 @@ -53,22 +83,123 @@ public class CalculateCostsJob extends BaseCronJob { Map> ldMap = entry.getValue(); for (Map.Entry> item : ldMap.entrySet()) { String ld = item.getKey(); + Double sdfbz = costMap.get(ld); + // 未查询到当前楼栋、当前月份的水电费标准，不做计算 + if (null == sdfbz || -1 == sdfbz) { + rs.writeLog("当前楼栋[" + ld + "],未查询到[" + calculateMonth + "]月份的水电费标准，跳过本楼栋水电费计算"); + continue; + } List ldList = item.getValue(); // 计算入住的所有的天数 + int currentMonthCount = 0; for (PersonnelManagement management : ldList) { + String rzsj = management.getRzsj(); + String zcsj = management.getZcsj(); + currentMonthCount += calculateDays(rzsj, zcsj, startDay, endDay); + } + // 计算当前人员、当前楼栋的水电费，总入住天数*水电费标准 + Double total = currentMonthCount * sdfbz; + // 查询当前人员，当前月份、当前楼栋，是否在水电费管理台账存在 + sql = "select * from uf_rysdftz where ry = ? and ld = ? and yf = ? "; + rs.executeQuery(sql, yg, ld, calculateMonth); + if (rs.next()) { + // 做更新操作 + List paramList = new ArrayList<>(); + paramList.add(String.valueOf(currentMonthCount)); + paramList.add(String.valueOf(total)); + paramList.add(yg); + paramList.add(ld); + paramList.add(calculateMonth); + rs.executeUpdate(updateSql, paramList); + rs.writeLog("updateSql：" + updateSql + "------params=" + JSON.toJSONString(paramList)); + } else { + String cs = ""; + String qy = ""; + sql = "select * from uf_ldwh where id = ?"; + rs.executeQuery(sql, ld); + if (rs.next()) { + cs = rs.getString("cs"); + qy = rs.getString("qy"); + } + List paramList = new ArrayList<>(); + // modedatacreatedate + paramList.add(DateHelper.getCurrentDate()); + // modedatacreatetime + paramList.add(DateHelper.getCurrentTime()); + // modeuuid + String uuid = UUID.randomUUID().toString(); + paramList.add(uuid); + // ts + paramList.add(String.valueOf(currentMonthCount)); + // yf + paramList.add(calculateMonth); + // cs + paramList.add(cs); + // qy + paramList.add(qy); + // ld + paramList.add(ld); + // ry + paramList.add(yg); + // sdf + paramList.add(String.valueOf(total)); + + // 做插入操作 + rs.executeUpdate(insertSql, paramList); + rs.writeLog("insertSql：" + insertSql + "------params=" + JSON.toJSONString(paramList)); + // 刷新权限 + rs.executeQuery("select id from uf_rysdftz where modeuuid='" + uuid + "'"); + if (rs.next()) { + //建模数据的id + int bid = Util.getIntValue(rs.getString("id")); + ModeRightInfo modeRightInfo = new ModeRightInfo(); + modeRightInfo.setNewRight(true); + //新建的时候添加共享 + modeRightInfo.editModeDataShare(1, Integer.parseInt(modeId), bid); + } } - // 计算当前人员、当前楼栋的水电费 } } - rs.writeLog("当前日期：" + currentDate + ",水电费计算计划任务结束------"); + rs.writeLog("当前计算日期：" + calculateDate + ",水电费计算计划任务结束------"); } catch (Exception e) { - rs.writeLog("当前日期：" + currentDate + ",水电费计算计划任务异常"); + rs.writeLog("当前计算日期：" + calculateDate + ",水电费计算计划任务异常"); rs.writeLog(e); } } + /** + * 计算实际入住的天数 + * + * @param rzsj 入住时间 + * @param zcsj 转出时间 + * @param startDay 计算开始时间 + * @param endDay 计算结束时间 + * @return + */ + private int calculateDays(String rzsj, String zcsj, String startDay, String endDay) { + String firstDate = rzsj; + // 比较入住时间和当月开始时间 + int compStartDate = DateUtil.compDate(rzsj, startDay); + // 开始时间大于入职时间，取开始时间 + if (compStartDate > 0) { + firstDate = startDay; + } + + String lastDate = zcsj; + if (StringUtils.isBlank(zcsj)) { + lastDate = endDay; + } + int compEndDate = DateUtil.compDate(zcsj, endDay); + // 结束时间小于转出时间，取结束时间 + if (compEndDate < 0) { + lastDate = endDay; + } + // 实际天数为相差的天数+1 + return DateUtil.compDate(firstDate, lastDate) + 1; + } + /** * 人员管理对象 @@ -116,4 +247,26 @@ public class CalculateCostsJob extends BaseCronJob { } } + public String getCalculateDate() { + return calculateDate; + } + + public void setCalculateDate(String calculateDate) { + this.calculateDate = calculateDate; + } + + public String getModeId() { + return modeId; + } + + public void setModeId(String modeId) { + this.modeId = modeId; + } + + public static void main(String[] args) { + String startDate = "2024-03-01"; + String endDate = "2024-03-31"; + int i = DateUtil.compDate(startDate, endDate); + System.out.println(i); + } }