fix: fix guizhou wasm

mems/examples/ds-guizhou/src/lib.rs

@@ -2,7 +2,7 @@ use arrow_schema::{DataType, TimeUnit, Field, Schema};
 use bytes::{Buf, BufMut, BytesMut};
 use bytes::{Buf, BufMut, BytesMut};
 use log::info;
 use log::info;
 use mems::model::{PluginInput, PluginOutput};
 use mems::model::{PluginInput, PluginOutput};
-use chrono::{Local, Days, Timelike};
+use chrono::{Days, Duration, Local, Timelike};
 
 
 static mut OUTPUT: Vec<u8> = vec![];
 static mut OUTPUT: Vec<u8> = vec![];
 #[no_mangle]
 #[no_mangle]
@@ -32,17 +32,18 @@ pub unsafe fn run(ptr: i32, len: u32) -> u64 {
         today.checked_add_days(Days::new(1)).unwrap()
         today.checked_add_days(Days::new(1)).unwrap()
     };
     };
 
 
-    let timestamp = startday.and_hms_opt(0, 0, 0)
+    let starttime = startday.and_hms_opt(0, 0, 0)
         .unwrap()
         .unwrap()
         .and_local_timezone(Local)
         .and_local_timezone(Local)
-        .unwrap()
-        .timestamp_millis();
+        .unwrap();
 
 
     for (i, record) in records.enumerate() {
     for (i, record) in records.enumerate() {
         if let Ok(f) = record {
         if let Ok(f) = record {
             let s = f.get(0).unwrap().trim();
             let s = f.get(0).unwrap().trim();
             let value = s.parse::<f64>().unwrap();
             let value = s.parse::<f64>().unwrap();
-            let date = timestamp + (i*15*60*1000) as i64;
+
+            let date = starttime + Duration::minutes((15 * i) as i64);
+            let date_str = date.format("%Y-%m-%d %H:%M:%S");
             csv_str.push_str(&format!("{date}, {value}\n"));
             csv_str.push_str(&format!("{date}, {value}\n"));
         }
         }
     }
     }