package com.app.hxqh.routes; import com.app.crontask.ChangeTimeUtils; import psdi.app.route.Route; import psdi.app.route.RouteRemote; import psdi.mbo.Mbo; import psdi.mbo.MboRemote; import psdi.mbo.MboSet; import psdi.mbo.MboSetRemote; import psdi.server.MXServer; import psdi.util.MXException; import java.rmi.RemoteException; import java.text.SimpleDateFormat; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.Calendar; import java.util.Date; /** * 检修路线Mbo */ public class UdRoutesMbo extends Route implements RouteRemote { public UdRoutesMbo(MboSet ms) throws MXException, RemoteException { super(ms); } @Override public void init() throws MXException { super.init(); try { String[] mainFields = new String[] {"ROUTE","DESCRIPTION"}; String status=getString("STATUS"); if("ACTIVE".equalsIgnoreCase(status)){ setFieldFlag(mainFields, 7L, true); getMboSet("ROUTE_STOP").setFlag(7L, true); } } catch (RemoteException e) { e.printStackTrace(); } } @Override public void save() throws MXException, RemoteException { super.save(); MboSetRemote routeLineSet=getMboSet("ROUTE_STOP"); if(null!=routeLineSet && !routeLineSet.isEmpty()){ String orgid=getString("ORGID"); String siteid=getString("SITEID"); String status=getString("STATUS"); int routesid=getInt("ROUTESID"); MboSetRemote djkssjwhbSet=getMboSet("$UDDJKSSJWH", "UDDJKSSJWH","ORGID='"+orgid+"' AND SITEID='"+siteid+"'"); if(null!=djkssjwhbSet && !djkssjwhbSet.isEmpty() && ("ACTIVE".equalsIgnoreCase(status) && isModified("STATUS"))){ Date serverstart=djkssjwhbSet.getMbo(0).getDate("SERVERSTART"); int hours = serverstart.getHours(); int minutes = serverstart.getMinutes(); int seconds = serverstart.getSeconds(); Calendar calendar = Calendar.getInstance(); MboSetRemote djbzpmlineSet = MXServer.getMXServer().getMboSet("PMSTDARDLINES",MXServer.getMXServer().getSystemUserInfo()); MboRemote zctzdjbzMbo=null; for(int i=0;i 0) { calendar.setTime(nextComDate); // 设置指定的年、月、日、时、分、秒 calendar.set(Calendar.HOUR_OF_DAY, hours); calendar.set(Calendar.MINUTE, minutes); calendar.set(Calendar.SECOND, seconds); Date NEXTEXDATE=calendar.getTime(); zctzdjbzMbo.setValue("NEXTEXDATE",NEXTEXDATE,2L); } } catch (Exception e) { e.printStackTrace(); e.getCause(); e.getMessage(); } zctzdjbzMbo.getThisMboSet().save(); } } } } } } } /** * 获取下次执行时间 * @param frequnit * @param firsDate * @param frequency * @return * @throws Exception */ public Date nextComDate(String frequnit,Date firsDate,int frequency) throws Exception { Date commitTime=null; if ("DAY".equalsIgnoreCase(frequnit)) {//日 commitTime = ChangeTimeUtils.changeDay(firsDate, frequency); } if ("HOUR".equalsIgnoreCase(frequnit)) {//小时 commitTime = ChangeTimeUtils.changeHour(firsDate, frequency); } if ("MONTH".equalsIgnoreCase(frequnit)) {//月 commitTime = ChangeTimeUtils.changeMonth(firsDate, frequency); SimpleDateFormat sf9=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); } if ("QUARTER".equalsIgnoreCase(frequnit)) {//季度 commitTime = ChangeTimeUtils.changeQuarter(firsDate, frequency); } if ("WEEK".equalsIgnoreCase(frequnit)) {//周 commitTime = ChangeTimeUtils.changeWeek(firsDate, frequency); } if ("YEAR".equalsIgnoreCase(frequnit)) {//年 commitTime = ChangeTimeUtils.changeYear(firsDate, frequency); } return commitTime; } @Override public void add() throws MXException, RemoteException { super.add(); } @Override public void delete() throws MXException, RemoteException { super.delete(); } }