feat(status memo): Write onemac activity to the Status Memo field (#352)

src/services/api/handlers/packageActions.ts

@@ -29,6 +29,7 @@ import { produceMessage } from "../libs/kafka";
 import { response } from "../libs/handler";
 import { SEATOOL_STATUS } from "shared-types/statusHelper";
 import { seaToolFriendlyTimestamp } from "shared-utils";
+import { buildStatusMemoQuery } from "../libs/statusMemo";
 
 const TOPIC_NAME = process.env.topicName as string;
 
@@ -59,6 +60,11 @@ export async function issueRai(body: RaiIssue) {
     const result2 = await transaction.request().query(query2);
     console.log(result2);
 
+    const statusMemoUpdate = await transaction
+      .request()
+      .query(buildStatusMemoQuery(body.id, "RAI Issued"));
+    console.log(statusMemoUpdate);
+
     // write to kafka here
     const result = raiIssueSchema.safeParse({ ...body, requestedDate: today });
     if (result.success === false) {
@@ -133,6 +139,11 @@ export async function withdrawRai(body: RaiWithdraw, document: any) {
       const result2 = await transaction.request().query(query2);
       console.log(result2);
 
+      const statusMemoUpdate = await transaction
+        .request()
+        .query(buildStatusMemoQuery(result.data.id, "RAI Response Withdrawn"));
+      console.log(statusMemoUpdate);
+
       // write to kafka here
       await produceMessage(
         TOPIC_NAME,
@@ -196,6 +207,11 @@ export async function respondToRai(body: RaiResponse, document: any) {
     const result2 = await transaction.request().query(query2);
     console.log(result2);
 
+    const statusMemoUpdate = await transaction
+      .request()
+      .query(buildStatusMemoQuery(body.id, "RAI Response Received"));
+    console.log(statusMemoUpdate);
+
     //   // write to kafka here
     const result = raiResponseSchema.safeParse({
       ...body,
@@ -267,6 +283,10 @@ export async function withdrawPackage(body: WithdrawPackage) {
     await transaction.begin();
     const txnResult = await transaction.request().query(query);
     console.log(txnResult);
+    const statusMemoUpdate = await transaction
+      .request()
+      .query(buildStatusMemoQuery(result.data.id, "Package Withdrawn"));
+    console.log(statusMemoUpdate);
     await produceMessage(
       TOPIC_NAME,
       body.id,

src/services/api/handlers/submit.ts

@@ -18,6 +18,7 @@ const config = {
 import { Kafka, Message } from "kafkajs";
 import { PlanType, onemacSchema, transformOnemac } from "shared-types";
 import { seaToolFriendlyTimestamp } from "shared-utils";
+import { buildStatusMemoQuery } from "../libs/statusMemo";
 
 const kafka = new Kafka({
   clientId: "submit",
@@ -80,6 +81,11 @@ export const submit = async (event: APIGatewayEvent) => {
     const result = await sql.query(query);
     console.log(result);
 
+    const statusMemoUpdate = await sql.query(
+      buildStatusMemoQuery(body.id, "Package Submitted")
+    );
+    console.log(statusMemoUpdate);
+
     await pool.close();
 
     const eventBody = onemacSchema.safeParse(body);

src/services/api/libs/statusMemo.ts

@@ -0,0 +1,8 @@
+export function buildStatusMemoQuery(id: string, msg: string) {
+  return `
+    UPDATE SEA.dbo.State_Plan
+    SET 
+        Status_Memo =  '- OneMAC Activity: ' + FORMAT(DATEADD(SECOND, CAST('${Date.now()}' AS BIGINT) / 1000, '1970-01-01'), 'MM/dd/yyyy HH:mm') + ' - ' + '${msg} ' + '\r' + CAST(ISNULL(Status_Memo, '') AS VARCHAR(MAX))
+    WHERE ID_Number = '${id}'
+  `;
+}