|
|
@@ -0,0 +1,56 @@
|
|
|
+package com.lc.ibps.platform.plan.job;
|
|
|
+
|
|
|
+import com.lc.ibps.base.core.util.JacksonUtil;
|
|
|
+import com.lc.ibps.base.core.util.string.StringUtil;
|
|
|
+import com.lc.ibps.components.quartz.BaseJob2;
|
|
|
+import org.quartz.JobDataMap;
|
|
|
+import org.quartz.JobExecutionContext;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
+
|
|
|
+import java.text.SimpleDateFormat;
|
|
|
+import java.util.Date;
|
|
|
+
|
|
|
+public class EquipmentMaintenancePlanJob extends BaseJob2 {
|
|
|
+
|
|
|
+ private static final Logger logger = LoggerFactory.getLogger(EquipmentMaintenancePlanJob.class);
|
|
|
+ public static final String PLAN_DATE = "plan-date";
|
|
|
+ @Override
|
|
|
+ public void executeJob(JobExecutionContext context) throws Exception {
|
|
|
+ JobDataMap dataMap = context.getMergedJobDataMap();
|
|
|
+ logger.warn("group={} job={} trigger={} is running.",
|
|
|
+ context.getJobDetail().getKey().getGroup(),
|
|
|
+ context.getJobDetail().getKey().getName(),
|
|
|
+ context.getTrigger().getKey().getName());
|
|
|
+ logger.warn("jobDataMap=is {}.", JacksonUtil.toJsonString(dataMap.getWrappedMap()));
|
|
|
+ String planDate = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
|
|
|
+ String planDateParam = dataMap.getString(PLAN_DATE);
|
|
|
+ if(StringUtil.isNotBlank(planDateParam)){
|
|
|
+ planDate = planDateParam;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+// SELECT * FROM (SELECT
|
|
|
+// YEAR('2024-1-7') AS plan_year,
|
|
|
+// CASE device.wei_hu_zhou_qi_c_
|
|
|
+// WHEN '日保养' THEN DATE_FORMAT('2024-1-7', '%j')
|
|
|
+// WHEN '周保养' THEN DATE_FORMAT('2024-1-7', '%u')
|
|
|
+// WHEN '月保养' THEN MONTH('2024-1-7')
|
|
|
+// WHEN '季度保养' THEN QUARTER( '2024-1-7')
|
|
|
+// WHEN '年保养' THEN YEAR('2024-1-7')
|
|
|
+// END AS period_num,device.wei_hu_zhou_qi_c_ ,device.id_
|
|
|
+// FROM `t_mjsbwhjhb` jhb,`t_mjsbwhjhzb` jhzb,`v_device_devicemaintenance` device
|
|
|
+// WHERE jhb.shi_fou_guo_shen_='已完成' AND jhb.zhi_xing_zhuang_t='正常'
|
|
|
+// AND jhb.id_ = jhzb.parent_id_
|
|
|
+// AND jhzb.she_bei_bian_hao_ = device.id_) plan
|
|
|
+// WHERE NOT EXISTS (SELECT 1 FROM `t_mjsbwhbyjlby` jlb WHERE jlb.she_bei_bian_hao_ = plan.id_ AND jlb.zhu_zhou_qi_ = plan.wei_hu_zhou_qi_c_ AND jlb.period_num = plan.period_num AND jlb.ji_hua_nian_du_=plan.plan_year);
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /*
|
|
|
+
|
|
|
+ Step1. fetch records from above sql.
|
|
|
+ step2. insert into t_mjsbwhbyjlby and t_mjsbwhbyjlzby
|
|
|
+ */
|
|
|
+ }
|
|
|
+}
|