Working code for pc app 12/01/2018 commit

Dependencies:   mbed MS5607 mbed-dsp

Fork of Turrentine_Code by Alex Stokoe

Revision:
0:2c6d81be69d8
Child:
1:ab3dacbfcde6
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp	Fri Jan 12 09:22:44 2018 +0000
@@ -0,0 +1,254 @@
+#include "mbed.h"
+
+#define M_PI 3.14159265358979323846
+
+//mbed class def
+Serial pc(USBTX, USBRX); // tx, rx
+SPI spi(p5, p6, p7); // mosi, miso, sclk
+DigitalOut cs(p8);
+
+PwmOut motorOn(p26);
+
+Timer t;
+
+//variable instaniation
+unsigned short calData[6];
+
+char buffer16[3];
+short int serbuffer[2]; 
+
+char tempBuffer[4];
+unsigned int temp = 0;
+char pressBuffer[4];
+unsigned int press = 0;
+
+unsigned int pData[1000];
+float spData[1000];
+unsigned int tData[1000];
+
+const char cb1 = 0xA2;
+const char cb2 = 0xA4;
+const char cb3 = 0xA6;
+const char cb4 = 0xA8;
+const char cb5 = 0xAA;
+const char cb6 = 0xAC;
+
+const char * commarr[6] = {&cb1, &cb2, &cb3, &cb4, &cb5, &cb6};
+
+const char D1conv256 = 0x40;
+const char D1conv512 = 0x42;
+const char D2conv4096 = 0x58;
+const char D2conv512 = 0x52;
+const char readADC = 0x00;
+
+float duty = 1;
+
+int round(float number)
+{
+    return (number >= 0) ? (int)(number + 0.5) : (int)(number - 0.5);
+}
+
+//calculate temperature
+int calcT(unsigned int Tval, unsigned short consts[6]) {
+    int dT = Tval - consts[4]*(2<<7);
+    
+    int T = 2000 + dT*consts[5]/(2<<22);
+    printf("Temp %d C\n\r", T); 
+    return T;
+    }
+
+//calculate 1st order temperature compensated pressure
+int calcP(unsigned int Tval, unsigned int Pval, unsigned short consts[6]) {
+    int dT = Tval - consts[4]*(2<<7);
+    
+    long long int off = (long long)consts[1]*(2<<16) + ((long long)consts[3] *(long long)dT)/(2<<5);
+    
+    long long int sens = (long long)consts[0]*(2<<15) + ((long long)consts[2] *(long long)dT)/(2<<6);
+    
+    int P = (Pval *(sens/(2<<20)) - off)/(2<<14);
+    //printf("Pressure %d Pa\n\r", P); 
+    return P;
+    }
+ 
+int main() {
+    pc.baud(115200);
+    motorOn = 0;
+    motorOn.period_ms(10);
+    
+    // Chip must be deselected
+    cs = 1;
+
+    // Setup the spi for 8 bit data, high steady state clock,
+    // second edge capture, with a 1MHz clock rate
+    spi.format(8,3);
+    spi.frequency(500000);
+    spi.set_default_write_value(0x00);
+ 
+    // Select the device by seting chip select low
+    cs = 0;
+ 
+    // Send 0x1E Command to reset the chip
+    spi.write(0x1E);
+    cs = 1;
+    wait_ms(100);
+    cs =1;
+    
+    //read cal data values from device into program
+    for (char i=0; i<6; i++){
+        //spi read sequence
+        cs= 0;
+        spi.write(commarr[i], 1, buffer16, 3);
+        //time for SPI to write into data buffers
+        wait_ms(10);
+        cs=1;
+        //Put data into 16bit unsigned int in calData array
+        calData[i] = buffer16[1]<<8 | buffer16[2];        
+        }
+        
+    //display calibration values to check against datasheet
+    printf("C1: %hu\n\rC2: %hu\n\rC3: %hu\n\rC4: %hu\n\rC5: %hu\n\rC6: %hu\n\r", calData[0], calData[1], calData[2], calData[3], calData[4], calData[5]);
+    
+    //program loop
+    while(1){
+        //read temerature value
+        cs = 0;
+        spi.write(&D2conv4096, 1, buffer16, 1);
+        wait_ms(10);
+        cs = 1; cs = 0;
+        
+        spi.write(&readADC, 1, tempBuffer, 4);
+        cs = 1;
+        
+        //read pressure value
+        cs = 0;
+        spi.write(&D1conv512, 1, buffer16, 1);
+        wait_ms(2);
+        cs = 1; cs = 0;
+        
+        spi.write(&readADC, 1, pressBuffer, 4);
+        cs = 1;
+        
+        //write values from buffers to program variables
+        temp = tempBuffer[1]<<16 | tempBuffer[2]<<8 | tempBuffer[3];
+        press = pressBuffer[1]<<16 | pressBuffer[2]<<8 | pressBuffer[3];
+        
+        //turn pump on
+        motorOn.write(duty);
+        
+        //dummy samples to wait for sensor response to stabilise
+        int a =0;
+        while(a<10000) {
+            cs = 0;
+            spi.write(&D1conv256, 1, buffer16, 1);
+            wait_us(500);
+            cs = 1; cs = 0;
+            spi.write(&readADC, 1, pressBuffer, 4);
+            cs = 1;
+            a++;
+            }
+            
+        
+        int nsample = 1000;
+        double cumsum = 0;
+        
+        t.reset();
+        t.start();
+        //loop values
+        for (int x=0; x <nsample; x++){
+           
+            cs = 0;
+            spi.write(&D1conv256, 1, buffer16, 1);
+            
+            wait_us(500);
+            cs = 1; cs = 0;
+            if (x >0){
+                pData[x-1] = pressBuffer[1]<<16 | pressBuffer[2]<<8 | pressBuffer[3];
+                cumsum = cumsum + pData[x-1];
+                }
+            spi.write(&readADC, 1, pressBuffer, 4);
+            tData[x] = t.read_us();
+            cs = 1;
+        
+            }
+            
+        //stop motor and timer
+        t.stop();
+        motorOn.write(0);
+        
+        //calc temperature
+        calcT(temp, calData);
+        long long sum = 0;
+        
+        float avg = calcP(temp, cumsum/(nsample-1), calData);
+        
+        printf("avg %f\n\r", avg); 
+        
+        //for crossing detection
+        bool cflag1 = (avg > pData[0]);
+        bool cflag2 = (avg > pData[1]);
+        int numcross = 0;
+        int lastcrosspoint = 0;
+        unsigned int crosstart;
+        unsigned int crossend;
+        float freq = 0;
+        
+        //smooth data array 20 sample size
+        for (int y=0; y< nsample-1; y++){
+            if (9< y && y <nsample-10){
+                sum = 0;
+                for (int z=0; z<20; z++){
+                    sum = sum + pData[y-10+z];
+                    }
+                    
+                spData[y] = (float) calcP(temp, sum/20, calData);
+                
+                //detect avg crossings for frequency calc
+                if (y>10){
+                    cflag2 = (avg > spData[y]);
+                    cflag1 = (avg > spData[y-1]);
+                    
+                    if (cflag1 != cflag2){
+                        if(lastcrosspoint<=(y-10)){
+                            numcross++;
+                            lastcrosspoint = y;
+                            
+                            if (numcross == 1){
+                                crosstart = tData[y];
+                                }
+                                
+                            crossend = tData[y];
+                            }
+                        }   
+                    }      
+                //calc pressure & display list
+                //printf("%d\t%d\t%d\n\r", tData[y], calcP(temp, spData[y], calData), calcP(temp, pData[y], calData));
+                printf("%d\t%f\n\r", tData[y],spData[y]);
+                } else if (10> y || y >nsample-10) {
+                    spData[y] = (float) calcP(temp, pData[y], calData);
+                    }
+            
+            
+            }
+        
+        printf("numcross = %d\n\r", numcross);
+        printf("crosstart = %d\n\r", crosstart);
+        printf("crossend = %d\n\r", crossend);
+            
+        freq = (1e6 *numcross)/(2*(crossend - crosstart));
+        printf("frequency = %f\n\r", freq);
+        
+        for (int z=0; z< nsample-1; z++){
+            
+            spData[z] = spData[z] -avg;
+            }
+        
+        printf("Repeat Blockage Test?\n\rPress Enter to continue\n\r");
+        
+        while(1){             
+            if (pc.getc() != 0) {
+                break;
+                }
+            }
+            
+        }
+}
\ No newline at end of file