1.PorcessJob和Glass关系绑定； 2.对话框显示ProcessJob、Glass等数据；

LAPTOP-SNT8I5JK\Boounion

2025-08-22 2a21061d88d5533065dc57cfae0b1f2c1952e06f

 SourceCode/Bond/EAPSimulator/CHsmsActive.cpp

@@ -3,6 +3,8 @@
#include "Log.h"


static unsigned int DATAID = 1;

CHsmsActive::CHsmsActive()
{
   m_listener = {};
@@ -67,8 +69,12 @@
      LOGI("onRecvDataMessage(%s).", pMessage->toString());

      if (nStream == 5 && pHeader->function == 1) {
         // S1F1
         // S5F1
         replyAck(5, 2, pMessage->getHeader()->systemBytes, 0, _T("ACK0"));
      }
      else if (nStream == 6 && pHeader->function == 11) {
         // S5F1
         replyAck(6, 12, pMessage->getHeader()->systemBytes, 0, _T("ACK0"));
      }
   };

@@ -245,6 +251,184 @@
   return 0;
}

int CHsmsActive::hsmsConfigureSpooling(std::map<unsigned int, std::set<unsigned int>>& spoolingConfig)
{
   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 2 | REPLY, 43, ++m_nSystemByte);
   if (spoolingConfig.size() > 0) {
      for (auto s : spoolingConfig) {
         ISECS2Item* pItemStreamList = pMessage->getBody()->addItem();
         pItemStreamList->addU1Item(s.first, "STRID");
         ISECS2Item* pItemFcnList = pItemStreamList->addItem();
         for (auto f : s.second) {
            pItemFcnList->addU1Item(f, "FCNID");
         }
      }
   }

   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::hsmsTransmitSpooledData()
{
   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 6 | REPLY, 23, ++m_nSystemByte);
   pMessage->getBody()->setU1(0, "RSDC");
   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::hsmsPurgeSpooledData()
{
   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 6 | REPLY, 23, ++m_nSystemByte);

   pMessage->getBody()->setU1(1, "RSDC");
   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::hsmsSelectedEquipmentStatusRequest(unsigned int SVID)
{
   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 1 | REPLY, 3, ++m_nSystemByte);

   pMessage->getBody()->addU4Item(SVID, "SVID");
   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::hsmsQueryPPIDList()
{
   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 7 | REPLY, 19, ++m_nSystemByte);
   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::hsmsCarrierActionRequest(unsigned int DATAID, 
   const char* pszCarrierAction, 
   const char* pszCarrierId,
   unsigned char PTN)
{
   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 3 | REPLY, 17, ++m_nSystemByte);
   pMessage->getBody()->addU4Item(DATAID, "DATAID");
   pMessage->getBody()->addItem(pszCarrierAction, "CARRIERACTION");
   pMessage->getBody()->addItem(pszCarrierId, "CARRIERID");
   pMessage->getBody()->addU1Item(PTN, "PTN");
   pMessage->getBody()->addItem();
   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::hsmsProceedWithCarrier(unsigned int DATAID,
   const char* pszCarrierId,
   unsigned char PTN)
{
   return hsmsCarrierActionRequest(DATAID, "ProceedWithCarrier", pszCarrierId, PTN);
}

int CHsmsActive::hsmsCarrierRelease(unsigned int DATAID,
   const char* pszCarrierId,
   unsigned char PTN)
{
   return hsmsCarrierActionRequest(DATAID, "CarrierRelease", pszCarrierId, PTN);
}

int CHsmsActive::hsmsPRJobMultiCreate(std::vector<SERVO::CProcessJob*>& pjs)
{
   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 16 | REPLY, 15, ++m_nSystemByte);
   char szMF[32] = {14};
   pMessage->getBody()->addU4Item(++DATAID, "DATAID");
   auto itemPjs = pMessage->getBody()->addItem();
   for (auto pj : pjs) {
      auto itemPj = itemPjs->addItem();
      itemPj->addItem(pj->id().c_str(), "PRJOBID");
      itemPj->addBinaryItem(szMF, 1, "MF");
      auto itemCarriers = itemPj->addItem();
      for (auto c : pj->carriers()) {
         auto itemCarrier = itemCarriers->addItem();
         itemCarrier->addItem(c.carrierId.c_str(), "CARRIERID");
         auto itemSlots = itemCarrier->addItem();
         for (auto s : c.slots) {
            itemSlots->addU1Item(s, "SLOTID");
         }
      }

      auto recipeItems = itemPj->addItem();
      recipeItems->addU1Item(1, "PRRECIPEMETHOD");
      recipeItems->addItem(pj->recipeSpec().c_str(), "RCPSPEC");
      recipeItems->addItem();

      itemPj->addBoolItem(false, "PRPROCESSSTART");
      itemPj->addItem();
   }

   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::hsmsCreateControlJob(const char* pszControlJobId, std::vector<std::string>& processJobIds)
{
   char szBuffer[256];
   sprintf_s(szBuffer, 256, "ControlJob:%s>", pszControlJobId);

   IMessage* pMessage = nullptr;
   int nRet = HSMS_Create1Message(pMessage, m_nSessionId, 14 | REPLY, 9, ++m_nSystemByte);
   pMessage->getBody()->addItem(szBuffer, "OBJSPEC");
   pMessage->getBody()->addItem("ControlJob", "OBJTYPE");
   auto itemAttrs = pMessage->getBody()->addItem();

   {
      auto itemAttr = itemAttrs->addItem();
      itemAttr->addItem("Priority", "ATTRID");
      itemAttr->addU1Item(8, "ATTRDATA");
   }

   {
      auto itemAttr = itemAttrs->addItem();
      itemAttr->addItem("weight", "ATTRID");
      itemAttr->addF4Item(60.5, "ATTRDATA");
   }

   {
      auto itemAttr = itemAttrs->addItem();
      itemAttr->addItem("tel", "ATTRID");
      itemAttr->addItem("15919875007", "ATTRDATA");
   }

   {
      auto itemAttr = itemAttrs->addItem();
      itemAttr->addItem("PRJOBLIST", "ATTRID");
      auto itemProcessJobs = itemAttr->addItem();
      for (auto& item : processJobIds) {
         itemProcessJobs->addItem(item.c_str(), "");
      }
   }

   m_pActive->sendMessage(pMessage);
   HSMS_Destroy1Message(pMessage);

   return 0;
}

int CHsmsActive::replyAck0(IMessage* pMessage)
{
   return 0;