更新水调接口

src/Test.java

@@ -14,6 +14,25 @@ public class Test {
 //		c.add(Calendar.DAY_OF_MONTH, 1); //输出一天后的日期
 //		System.out.println(sdf.format(c.getTime()));;
 		//DAY_OF_WEEK
-		System.out.println(c.get(Calendar.DAY_OF_WEEK)); 
+//		System.out.println(c.get(Calendar.DAY_OF_WEEK)); 
+		
+		
+		Calendar calendar1 = Calendar.getInstance(); //当前时间
+		
+
+		System.out.println(calendar1.get(Calendar.DAY_OF_WEEK));
+		
+		
+		
+		calendar1.add(Calendar.DAY_OF_MONTH,10);
+		
+		System.out.println(calendar1.getTime());
+		
+//		int weekNowNum=calendar1.get(Calendar.DAY_OF_WEEK);//获取当前星期
+//		System.out.println(weekNowNum);
+		
+		
+		
+		
 	}
 }

src/com/tohi/webclient/beans/pjoobservation/CustPjobehaviornoDataBean.java

@@ -38,7 +38,7 @@ public class CustPjobehaviornoDataBean extends MultiselectDataBean{
         	if (tempMbo.isSelected() && tempMbo.getString("WONUM").equalsIgnoreCase("")) {
 	        	MboRemote wo=woSet.add(11L); 
 	        	wo.setValue("DESCRIPTION", tempMbo.getString("ELABORATE"),11L);
-	        	wo.setValue("WORKTYPE", "EHS",11L);//
+	        	wo.setValue("WORKTYPE", "HSE",11L);//
 	        	wo.setValue("CUSTFZR", tempMbo.getString("PROPOSER"),11L); 
 	        	woSet.save(11L);
 	        	map.put(tempMbo.getLong("pjobehaviorid"),wo.getString("WONUM"));

src/com/tohi/webclient/beans/rlrelaymanage/CustrRlreDataBean.java

@@ -78,6 +78,8 @@ public class CustrRlreDataBean extends MultiselectDataBean {
 						tempMbo.getString("DEVICENAME"), 11L);
 				RLRELAYMANAGEmbo.setValue("BREMARK",
 						groupMbo.getString("BREMARK"), 11L);
+				RLRELAYMANAGEmbo.setValue("TYPE",
+						groupMbo.getString("PLAN"), 11L);
 
 				if (tempMbo.getString("SIGNOUT").equalsIgnoreCase("Y")) { // 退出
 				// proteplatelineMbo.setValue("SIGNOUT", 1,11L); //将压板表

src/tohi/app/crontask/MD5Utils.java

+
+	    package tohi.app.crontask;
+
+	    import java.security.MessageDigest;
+	    import java.security.NoSuchAlgorithmException;
+	    import org.apache.commons.lang.StringUtils;
+
+	    /**
+	     * MD5加密算法工具类
+	     * @author bbo
+	     *
+	     */
+	    public class MD5Utils {
+	    	/*
+	    	 * 为了提高安全性，我们又额外加了一串随机字符串
+	    	 */
+//	    	private static final String USER_PWD_ENCP_PREFIX = "LDHDSFHWRERHESLM";
+
+	    	/**
+	    	 * 用户密码加密
+	    	 * @param beforeEncp
+	    	 * @return
+	    	 */
+	    	public static String encode(final String beforeEncp){
+	    		if(StringUtils.isBlank(beforeEncp)){
+	    			return beforeEncp;
+	    		}
+	    		return encryptMD5(beforeEncp);
+	    	}
+	    	
+	    	/**
+	    	 * md5加密
+	    	 * @param strInput
+	    	 * @return
+	    	 */
+	    	private static String encryptMD5(final String strInput) {
+	    		StringBuffer buf = null;
+	    		try {
+	    			// 拿到一个MD5转换器（如果想要SHA1参数换成”SHA1”）  
+	    			MessageDigest md = MessageDigest.getInstance("MD5"); 
+	    			// 输入的字符串转换成字节数组   
+	    			md.update(strInput.getBytes());
+	    			 // 转换并返回结果，也是字节数组，包含16个元素  
+	    			byte b[] = md.digest();
+	    			// new一个StringBuffer，这个就是用来组成结果字符串的（解释一下：一个byte是八位二进制，也就是2位十六进制字符（2的8次方等于16的2次方））  
+	    			buf = new StringBuffer(b.length * 2);
+	    			//遍历
+	    			for (int i = 0; i < b.length; i++) {
+	    				if (((int) b[i] & 0xff) < 0x10) { //(int) b[i] & 0xff 转换成无符号整型
+	    					buf.append("0");
+	    				}
+	    				//Long.toHexString( 无符号长整数的十六进制字符串表示
+	    				buf.append(Long.toHexString((int) b[i] & 0xff)); 
+	    			}
+	    		} catch (NoSuchAlgorithmException ex) {
+	    			ex.printStackTrace();
+	    		}
+	    		return buf==null?null:buf.toString(); //返回加密后 的结果
+	    	}
+	    	
+	    }
+	 
\ No newline at end of file

src/tohi/app/crontask/RunCronTask.java

+package tohi.app.crontask;
+ 
+  
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.text.SimpleDateFormat;
+
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
+import psdi.mbo.MboRemote;
+import psdi.mbo.MboSetRemote;
+import psdi.server.MXServer;
+import psdi.server.SimpleCronTask;
+ 
+/**
+ * 定期任务安排生成定期任务
+ *
+ */
+public class RunCronTask  extends SimpleCronTask{
+	
+	 public static void interfaceUtil(String path,String data) throws IOException {
+	        try {
+	            URL url = new URL(path);
+	            //打开和url之间的连接
+	            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+	            PrintWriter out = null;
+	            //请求方式
+	            conn.setRequestMethod("GET");
+	            conn.setReadTimeout(500000);
+	            conn.setConnectTimeout(500000); 
+//	           //设置通用的请求属性
+	            //Content-Type： application/x-www-form-urlencoded
+	            conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded/charset=UTF-8");
+	            InputStream is = conn.getInputStream();
+	            //构造一个字符流缓存
+	            BufferedReader br = new BufferedReader(new InputStreamReader(is));
+	            String str="";
+	            String strInfo = "";
+	            while ((str = br.readLine()) != null) {
+	            	strInfo +=str;
+	            }
+//	            //关闭流
+	            is.close();
+	            conn.disconnect();
+	            System.out.println("完整结束");
+	            //写入数据库中
+	            JSONArray   jsarr=JSONArray.fromObject(strInfo);
+	            System.out.println(jsarr.toString());
+	            List<Resultitfa> list=new ArrayList<Resultitfa>();
+	            for (int i = 0; i < jsarr.size(); i++) {
+	            	JSONObject obj=(JSONObject) jsarr.get(i);
+	            	Resultitfa r=new Resultitfa();
+	            	r.Id=obj.getString("id");
+	            	r.time=obj.getString("time");
+	            	r.value=obj.getDouble("value");
+	            	list.add(r);
+				}
+	            
+	            MXServer mx=MXServer.getMXServer();
+	            MboSetRemote mboSet= mx.getMboSet("WATERPORT", mx.getSystemUserInfo()); //获取系统表
+	            SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+	            String nowDate = sdf.format(mx.getDate());
+	            //写入数据库
+	            for (int i = 0; i <list.size(); i++) {
+	            	Resultitfa r=list.get(i); 
+					MboRemote mbo=mboSet.addAtEnd();
+					mbo.setValue("id",r.Id );
+					if (r.Id.equalsIgnoreCase("H9760")) {
+						mbo.setValue("DESCRIPTION","时段出库流量");
+					}
+					if (r.Id.equalsIgnoreCase("R1183")) {
+						mbo.setValue("DESCRIPTION","实时坝下水位");
+					}
+					if (r.Id.equalsIgnoreCase("H9620")) {
+						mbo.setValue("DESCRIPTION","时段入库流量");
+					}
+					if (r.Id.equalsIgnoreCase("R1283")) {
+						mbo.setValue("DESCRIPTION","实时厂址水位");
+					}
+					if (r.Id.equalsIgnoreCase("R1083")) {
+						mbo.setValue("DESCRIPTION","实时坝上水位");
+					}
+					mbo.setValue("time",r.time);
+					mbo.setValue("value",r.value );
+					mbo.setValue("memo", nowDate+"  同步该记录！！！" );
+					mboSet.save();
+				}
+	            mboSet.close();
+	        } catch (Exception e) {
+	            e.printStackTrace();
+	        }
+	    }
+	    @Override
+		public void cronAction() {
+	    	try {
+	    		Date date=new Date();
+	        	System.out.println(date.getTime());
+	        	String info = "sduser"+date.getTime()+"sduser@2022";
+//	        	String info="sduser1656897995866sduser@2022";
+	        	String s=MD5Utils.encode(info);
+	        	String url="http://172.17.7.235:56022/getdata/all?Username=sduser&time="+date.getTime()+"&signature="+s;
+	        	System.out.println(url);
+				interfaceUtil(url, "");
+				} catch (IOException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+		}
+	    public static void main(String[] args) {
+	        try {
+	        	Date date=new Date();
+	        	System.out.println(date.getTime());
+	        	String info = "sduser"+date.getTime()+"sduser@2022";
+//	        	String info="sduser1656897995866sduser@2022";
+	        	String s=MD5Utils.encode(info);
+	        	String url="http://172.17.7.235:56022/getdata/all?Username=sduser&time="+date.getTime()+"&signature="+s;
+	        	System.out.println(url);
+				interfaceUtil(url, "");
+			} catch (IOException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}  
+	    }
+		static class Resultitfa{
+			  String Id;
+			  String time;
+			  Double value;
+			@Override
+			public String toString() {
+				return "Resultitfa [Id=" + Id + ", time=" + time + ", value=" + value + "]";
+			}
+			  
+		}
+	
+}