From 16bdb3de2d0ac84e5e63831cccfd275679d493d4 Mon Sep 17 00:00:00 2001
From: Jan Michel <mail@janmichel.eu>
Date: Tue, 13 Apr 2021 12:25:52 +0200
Subject: [PATCH] add support for KA3000 devices

---
 powersupplies/web/htdocs/build_index.pl |   8 +
 powersupplies/web/htdocs/pwr.pl         |  32 +++-
 powersupplies/web/htdocs/pwr_ka3000.htm | 195 ++++++++++++++++++++++++
 powersupplies/web/htdocs/pwr_remote.pl  |  28 +++-
 4 files changed, 257 insertions(+), 6 deletions(-)
 create mode 100644 powersupplies/web/htdocs/pwr_ka3000.htm

diff --git a/powersupplies/web/htdocs/build_index.pl b/powersupplies/web/htdocs/build_index.pl
index c416157..4151fea 100755
--- a/powersupplies/web/htdocs/build_index.pl
+++ b/powersupplies/web/htdocs/build_index.pl
@@ -52,6 +52,14 @@ print <<EOF;
 <h3 onClick="Enable($j)" id="$j">Power Supply <b>$dev_id</b> [connected to <b>$ser_dev</b>]</h3>
 <iframe id="iframe$j"  name="inlineframe" data-src="pwr_switch.htm?device=$ser_dev&id=$dev_id&type=$type&channels=$channels&speed=$speed&names=$names" frameborder="0" scrolling="auto" width="800" data-height="340" height="0"></iframe>
 
+EOF
+}
+
+if($type =~ /KA3000/) {
+print <<EOF;
+<h3 onClick="Enable($j)" id="$j">Power Supply <b>$dev_id</b> [connected to <b>$ser_dev</b>]</h3>
+<iframe id="iframe$j"  name="inlineframe" data-src="pwr_ka3000.htm?device=$ser_dev&id=$dev_id&type=$type&channels=$channels&speed=$speed&names=$names" frameborder="0" scrolling="auto" width="800" data-height="340" height="0"></iframe>
+
 EOF
 }
 
diff --git a/powersupplies/web/htdocs/pwr.pl b/powersupplies/web/htdocs/pwr.pl
index e1fc870..c6b21e9 100755
--- a/powersupplies/web/htdocs/pwr.pl
+++ b/powersupplies/web/htdocs/pwr.pl
@@ -16,6 +16,7 @@ use Time::HiRes qw( usleep);
 use POSIX qw/floor ceil strftime/;
 use Fcntl;
 use Storable qw(lock_store lock_retrieve);
+no warnings 'uninitialized';
 
 my $envstring = $ENV{'QUERY_STRING'};
 $envstring =~ s/%20/ /g;
@@ -66,7 +67,7 @@ elsif($ser_dev =~ /^SER(.*)/) {
 else {  
   if ($ser_speed != 0){
       my $command = "stty -F $ser_dev speed $ser_speed -opost -onlcr -isig -icanon -iexten -echo -echoe -echok -echoctl -echoke";
-      print stderr "$command\n";
+#       print STDERR "$command\n";
     $command .= " -ixoff " if $ser_type eq 'PSP';
     my $res = qx($command);
     }
@@ -82,6 +83,7 @@ else {
  else {
   print HMP_serial() if (($ser_type eq "HMP" or $ser_type eq "HMC") && $isIP == 0) or $ser_type eq "PST";
   print PWRSW_serial() if $ser_type eq "PWRSW";
+  print KA3000_serial() if $ser_type eq "KA3000";
   print HMP_ethernet() if (($ser_type eq "HMP" or $ser_type eq "HMC") && $isIP == 1);
   print PSP() if $ser_type eq 'PSP';
   }
@@ -189,6 +191,26 @@ sub HMP_serial {
   return;
   }
 
+
+sub KA3000_serial {
+  print strftime("%H:%M:%S &", localtime());
+  my $fh;
+  if(-e $ser_dev && -w $ser_dev) {
+    sysopen($fh, $ser_dev, O_RDWR|O_NDELAY) or die $!;
+    }
+  else { print "Device not found"; return;}  
+  
+  while ( my $command = shift(@new_command) ) {
+    $command = uri_unescape($command);
+    my $x = getValue($fh,$command,$cnt++);
+    $x =~ s/\&//;
+    $x = ord($x) if $command eq "STATUS?";
+    print $x."&" if $command =~ /\?/;
+    usleep(40000);# if $ser_type eq "PST";
+    }
+  close $fh;  
+  return;
+  }  
   
   
 sub HMP_ethernet {
@@ -209,12 +231,14 @@ sub HMP_ethernet {
 sub serial_rw {
   my ($fh, $command,$forceread) = @_;
   my $x = "";
-  if ($ser_type eq 'PSP') {$command .= "\r";} else {$command .= "\n";}
+  if ($ser_type eq 'PSP') {$command .= "\r";} 
+  elsif ($ser_type ne 'KA3000')  {$command .= "\n";}
+  
   print $fh  "$command";
 #   print $command;
   if($ser_type eq 'PWRSW' || $forceread || $command =~ /\?/) {
     for my $i (0..500) {
-      $x .=   <$fh>;
+      $x .=  <$fh>;
       if($x && ($x =~ /\n/ || $x =~ /\r/) ) {
         chomp $x;
         last;
@@ -237,7 +261,7 @@ sub getValue {
   else {
     usleep(10000);
     my $val = serial_rw($fh,$cmd,$forceread);
-    if($val eq "") {
+    if($val eq "" && $ser_type ne 'KA3000') {
       return $db->{$cmd.$cnt}{val};
       }
     addDB($cmd.$cnt,$val);
diff --git a/powersupplies/web/htdocs/pwr_ka3000.htm b/powersupplies/web/htdocs/pwr_ka3000.htm
new file mode 100644
index 0000000..5751a74
--- /dev/null
+++ b/powersupplies/web/htdocs/pwr_ka3000.htm
@@ -0,0 +1,195 @@
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
+<link href="styles.css" rel="stylesheet" type="text/css"/>
+<script src="scripts.js" type="text/javascript"></script>
+<title>Power Supply Monitor and Access</title>
+</head>
+<body style="font-family: sans-serif;" >
+
+
+<!-- <h3 id="headline">Power Supply Access</h3> -->
+
+
+
+<form acion="">
+<table id="settings" class="smallboxes">
+<tr>
+  <th>
+  <th colspan="4" id="chan1">Output 
+
+<tr class="sep">
+  <td align="right">Settings [V/A]
+  <td><input type="text" id="form_v1" name="voltage" value="">
+  <td><input type="button" onClick="set_v(1)" value="set">
+  <td><input type="text" id="form_c_lim1" name="current" value="">
+  <td><input type="button" onClick="set_c_lim(1)" value="set">
+
+<tr>
+  <td align="right">Actual[V/A]
+  <td> <input type="text" id="vol1" disabled style="color:black;">  
+  <td>
+  <td> <input type="text" id="cur1" disabled style="color:black;">
+  <td>
+  
+<tr class="sep">
+  <td>Output Relais
+  <td><input type="button" onClick="turn_on(1)" value="on">
+  <td><input type="button" onClick="turn_off(1)" value="off">
+  <td colspan="2">
+  
+<tr class="sep">
+  <td colspan="2"> <input type="checkbox" value="1" id="showreadings" checked>Enable read-back
+  <td colspan="3" id="info">&nbsp;
+  
+</table>
+</form>
+
+
+<script language="javascript">
+var updaterate = 5500;
+var updateTask;
+var new_commands = new Array();
+var ser_dev = getParameterByName("device");
+var dev_id = getParameterByName("id");
+var type = getParameterByName("type");
+var channels = getParameterByName("channels");
+var speed = getParameterByName("speed");
+var names = getParameterByName("names");
+var readSettingsRequest = 1;
+var forceShowReadings = 1;
+var notfirst = -1;
+var Vnames   = names.split(':');
+
+
+function set_v(chan) {
+  if (chan > channels) return;
+	var value = parseFloat(document.getElementById("form_v"+chan).value);
+	var command;
+  command = "VSET"+chan+":"+("000"+value.toFixed(2)).slice (-5);
+
+	new_commands.push(command);
+  forceShowReadings = 1;
+  communication();
+}
+
+
+function set_c_lim(chan) {
+  if (chan > channels) return;
+	var value = parseFloat(document.getElementById("form_c_lim"+chan).value);
+	var command;
+  command = "ISET"+chan+":"+("000"+value.toFixed(3)).slice (-5);
+
+	new_commands.push(command);
+  forceShowReadings = 1;
+  communication();
+}
+
+function turn_on(chan) {
+  if (chan > channels) return;
+  new_commands.push("OUT1");
+  forceShowReadings = 1;
+  communication();
+}
+
+function turn_off(chan) {
+  if (chan > channels) return;
+  new_commands.push("OUT0");
+  forceShowReadings = 1;
+  communication();
+}
+
+
+
+function update(data) {
+  updateTask = setTimeout("communication()",(notfirst++>0)?updaterate:10);
+  }
+
+  
+function updatereads(data) {
+  var e = data.split("&");
+  document.getElementById("info").innerHTML = e.shift();
+  var status = +e.shift();
+  document.getElementById("chan1").style.background=(status&0x40!=0)?"limegreen":"#C00";
+
+  document.getElementById("vol1").value=(+e[0]).toFixed(2);
+  document.getElementById("cur1").value=(+e[1]).toFixed(3);
+
+  updateTask = setTimeout("communication()",updaterate);
+  }  
+
+function updatesettings(data) {
+  var e = data.split("&");
+  document.getElementById("info").innerHTML = e.shift() + e.shift();
+  var status = +e.shift();
+  document.getElementById("chan1").style.background=(status&0x40!=0)?"limegreen":"#C00";
+  
+  document.getElementById("form_v1").value   =(+e[0]).toFixed(2);
+  document.getElementById("form_c_lim1").value=(+e[1]).toFixed(3);
+
+  document.getElementById("vol1").value=(+e[2]).toFixed(2);
+  document.getElementById("cur1").value=(+e[3]).toFixed(3);
+
+  updateTask = setTimeout("communication()",(notfirst++>0)?updaterate:10);
+  }   
+  
+function communication() {
+  cmds = new_commands.join('&');
+  if (cmds != "") {
+    getdata('pwr.pl?'+ser_dev+'&'+type+"&"+speed+'&'+cmds,);
+    }
+  else if(readSettingsRequest == 1) {
+    readSettingsRequest = 0;
+    cmds  = "%2AIDN%3F";
+    cmds += '&STATUS%3F';
+    cmds += '&VSET1%3F';
+    cmds += '&ISET1%3F';
+    cmds += '&VOUT1%3F';
+    cmds += '&IOUT1%3F';
+
+    getdata('pwr.pl?'+ser_dev+'&'+type+"&"+speed+'&'+cmds,updatesettings);
+    }
+  else if(document.getElementById("showreadings").checked || forceShowReadings) {
+    forceShowReadings = 0;
+    cmds  = 'STATUS%3F';
+    cmds += '&VOUT1%3F';
+    cmds += '&IOUT1%3F';
+
+    getdata('pwr.pl?'+ser_dev+'&'+type+"&"+speed+'&'+cmds,updatereads);
+    }
+  else {
+    updateTask = setTimeout("communication()",updaterate);
+    }
+	new_commands = new Array();
+}
+
+
+
+function getParameterByName(name)
+{
+  name = name.replace(/[\[]/, "\\\[").replace(/[\]]/, "\\\]");
+  var regexS = "[\\?&]" + name + "=([^&#]*)";
+  var regex = new RegExp(regexS);
+  var results = regex.exec(window.location.search);
+  if(results == null)
+    return "";
+  else
+    return decodeURIComponent(results[1].replace(/\+/g, " "));
+}
+
+
+function readSettings() {
+  readSettingsRequest = 1;
+  }
+
+updateTask = setTimeout("update()",500);
+//document.getElementById("headline").innerHTML  = "Power Supply "+'<b>'+dev_id+'</b>'+" [connected to "+'<b>'+ser_dev+'</b>'+"]" ;
+
+for(i=1;i<=channels;i++) {
+  if(typeof Vnames[i-1] !== 'undefined')
+    document.getElementById("chan"+i).innerHTML = 'Output - '+Vnames[i-1];
+  }
+  
+</script>
+</body></html>
diff --git a/powersupplies/web/htdocs/pwr_remote.pl b/powersupplies/web/htdocs/pwr_remote.pl
index 7bd7c30..c2478cc 100644
--- a/powersupplies/web/htdocs/pwr_remote.pl
+++ b/powersupplies/web/htdocs/pwr_remote.pl
@@ -70,6 +70,7 @@ transmit_command() if $ser_type eq "PSP"; #if new command, send it!
 receive_answer() if $ser_type eq "PSP"; # always called
 
 HMP_serial() if $ser_type eq 'HMP';
+KA3000_serial() if $ser_type eq "KA3000";
 
 sub transmit_command {
 
@@ -104,6 +105,27 @@ sub HMP_serial {
   }
 
 
+sub KA3000_serial {
+  print strftime("%H:%M:%S &", localtime());
+  my $fh;
+  if(-e $ser_dev && -w $ser_dev) {
+    sysopen($fh, $ser_dev, O_RDWR|O_NDELAY) or die $!;
+    }
+  else { print "Device not found"; return;}  
+  
+  while ( my $command = shift(@new_command) ) {
+    $command = uri_unescape($command);
+    my $x = getValue($fh,$command,$cnt++);
+    $x =~ s/\&//;
+    $x = ord($x) if $command eq "STATUS?";
+    print $x."&" if $command =~ /\?/;
+    usleep(40000);# if $ser_type eq "PST";
+    }
+  close $fh;  
+  return;
+  }  
+  
+  
 sub receive_answer {
 
 
@@ -176,7 +198,9 @@ sub receive_answer {
 sub serial_rw {
   my ($fh, $command,$forceread) = @_;
   my $x = "";
-  if ($ser_type eq 'PSP') {$command .= "\r";} else {$command .= "\n";}
+  if ($ser_type eq 'PSP') {$command .= "\r";} 
+  elsif ($ser_type ne 'KA3000')  {$command .= "\n";}
+
   print $fh  "$command";
 #   print $command;
   if($ser_type eq 'PWRSW' || $forceread || $command =~ /\?/) {
@@ -204,7 +228,7 @@ sub getValue {
   else {
     usleep(10000);
     my $val = serial_rw($fh,$cmd,$forceread);
-    if($val eq "") {
+    if($val eq "" && $ser_type ne 'KA3000') {
       return $db->{$cmd.$cnt}{val};
       }
     addDB($cmd.$cnt,$val);
-- 
2.43.0