Bond2
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
chenluhua1980
5 天以前 bc7f1c4e028e69be51079b59dae4ae5c4d43f5bb 
 SourceCode/Bond/Servo/CEquipment.h


@@ -1,5 +1,6 @@


#pragma once


#pragma once


#include "Log.h"


#include "ServoCommo.h"


#include "CCLinkIEControl.h"


#include "CSample.h"


#include "CPin.h"


@@ -26,17 +27,42 @@


#include <map>


#include <list>


#include "CGlass.h"


#include "CRecipesManager.h"


#include "CJobDataA.h"


#include "CJobDataB.h"


#include "CJobDataC.h"


#include "CJobDataS.h"


#include "CProcessData.h"


#include "CPortStatusReport.h"


#include "CSlot.h"


#include "CParam.h"


#include "CSVData.h"






namespace SERVO {


#define BLOCK_BUFFER_MAX         1024


#define ALIVE_TIMEOUT            15


#define VCR_MAX                  1


#define SLOT_MAX            PATH_MAX


#define SIGNAL_UPSTREAM_INLINE   0


#define SIGNAL_UPSTREAM_TROUBLE   1


#define SIGNAL_INTERLOCK      2


#define SIGNAL_SEND_ABLE      3


#define SIGNAL_RECEIVE_ABLE      3




   typedef std::function<void(int writeCode, int retCode)> ONWRITEDRET;




   typedef std::function<void(void* pEiuipment, BOOL bAlive)> ONALIVE;


   typedef std::function<void(void* pEiuipment, int code)> ONDATACHANGED;


   typedef std::function<void(void* pEiuipment, int state, int alarmId, int unitId, int level)> ONALARM;


   typedef std::function<void(void* pEiuipment, void* pReport)> ONVCREVENTREPORT;


   typedef std::function<BOOL(void* pEiuipment, int port, CJobDataB* pJobDataB)> ONPREFETCHEDOUTJOB;


   typedef std::function<BOOL(void* pEiuipment, int port, CJobDataB* pJobDataB, short& putSlot)> ONPRESTOREDJOB;


   typedef std::function<void(void* pEiuipment, int nSlotNo, PROCESS_STATE prevState, PROCESS_STATE state)> ONPROCESSSTATE;


   typedef std::function<void(void* pEiuipment, short scanMap, short downMap)> ONMAPMISMATCH;


   typedef std::function<void(void* pEiuipment, short status, __int64 data)> ONPORTSTATUSCHANGED;


   typedef std::function<void(void* pEiuipment, const std::vector<CParam>& params)> ONPROCESSDATAREPORT;


   typedef std::function<void(void* pEiuipment, int port, CJobDataS* pJobDataS)> ONRECEIVEDJOB;


   typedef std::function<void(void* pEiuipment, int port, CJobDataS* pJobDataS)> ONSENTOUTJOB;


   typedef std::function<void(void* pEiuipment, int unitId, int status, int reason)> ONEQSTATUSCHANGED;


	


   typedef struct _EquipmentListener


   {


      ONALIVE            onAlive;


@@ -44,23 +70,19 @@


      ONALARM            onAlarm;


      ONDATACHANGED      onDataChanged;


      ONVCREVENTREPORT   onVcrEventReport;


      ONPREFETCHEDOUTJOB   onPreFethedOutJob;


      ONPRESTOREDJOB      onPreStoredJob;


      ONPROCESSSTATE      onProcessStateChanged;


      ONMAPMISMATCH      onMapMismatch;


      ONPORTSTATUSCHANGED   onPortStatusChanged;


      ONVCREVENTREPORT   onSVDataReport;


      ONVCREVENTREPORT   onPanelDataReport;


      ONPROCESSDATAREPORT   onProcessDataReport;


      ONRECEIVEDJOB      onReceivedJob;


      ONSENTOUTJOB      onSentOutJob;


      ONEQSTATUSCHANGED   onEqStatusChanged;


   } EquipmentListener;




   // Memory Block 结构体定义


   typedef struct _MemoryBlock {


      unsigned int type;


      unsigned int start;


      unsigned int end;


      unsigned int size;


      char buffer[BLOCK_BUFFER_MAX];


   } MemoryBlock;




   // ALIVE


   typedef struct _ALIVE {


      BOOL flag;


      int count;


      BOOL alive;


   } ALIVE;




   class CEquipment


   {


@@ -68,11 +90,15 @@


      CEquipment();


      virtual ~CEquipment();






   public:


      void SetEnable(BOOL bEnable);


      BOOL IsEnabled() const;


      virtual const char* getClassName() = 0;


      virtual void setListener(EquipmentListener listener);


      void setCcLink(CCCLinkIEControl* pCcLink);


      virtual BOOL isArm() { return FALSE; };


      void setArm(CEquipment* pEquipment);


      CEquipment* getArm();


      void setBaseAlarmId(int nBaseId);


      int getBaseAlarmId();


      void setID(int nID);


@@ -81,6 +107,8 @@


      std::string& getName();


      void setDescription(const char* pszDescription);


      std::string& getDescription();


      void setCurrentRecipe(const std::string& recipe);


      std::string getCurrentRecipe();


      void setStation(int network, int station);


      const StationIdentifier& getStation();


      virtual void getAttributeVector(CAttributeVector& attrubutes);


@@ -97,21 +125,34 @@


      virtual void term();


      virtual void initPins() = 0;


      virtual void initSteps();


      virtual void initSlots() = 0;


      virtual void onTimer(UINT nTimerid);


      virtual void serialize(CArchive& ar);


      virtual void onReceiveLBData(const char* pszData, size_t size);


      virtual int onStepEvent(CStep* pStep, int code);


      virtual CPin* addPin(PinType type, char* pszName);


      virtual short getSlotUnit(short slotNo) { return 0; };


      CPin* getPin(char* pszName);


      std::vector<CPin*>& CEquipment::getInputPins();


      std::vector<CPin*>& CEquipment::getOutputPins();


      CRecipeList* getRecipeList(int unitNo);


      bool saveRecipeList(int unitNo, std::string& strFilepath);


      bool readRecipeList(int unitNo, std::string& strFilepath);


      virtual int recvIntent(CPin* pPin, CIntent* pIntent);


      virtual BOOL glassWillArrive(CGlass* pGlass);


      virtual int outputGlass(int port);


      virtual int glassArrived(CGlass* pGlass);


      void getGlassList(std::list<CGlass*>& list);


      CGlass* getFrontGlass();


      BOOL removeClass(CGlass* pGlass);


      virtual int fetchedOutJob(int port, CJobDataB* pJobDataB);


      virtual int storedJob(int port, CJobDataB* pJobDataB, short putSlot);


      virtual int onReceivedJob(int port, CJobDataS* pJobDataS);


      virtual int onSentOutJob(int port, CJobDataS* pJobDataS);


      virtual BOOL onPreFetchedOutJob(int port, CJobDataB* pJobDataB);


      virtual int onFetchedOutJob(int port, CJobDataB* pJobDataB);


      virtual BOOL onPreStoredJob(int port, CJobDataB* pJobDataB, short& putSlot);


      virtual int onStoredJob(int port, CJobDataB* pJobDataB);


      virtual int onProcessData(CProcessData* pProcessData);


      virtual int onSendAble(int port);


      virtual int onReceiveAble(int port);


      virtual int onProcessStateChanged(int nSlotNo, PROCESS_STATE prevState, PROCESS_STATE state);


      virtual int getIndexerOperationModeBaseValue();


      virtual bool isSlotProcessed(int slot) { return true; };


      bool isAlarmStep(SERVO::CStep* pStep);


      bool isVcrEventStep(SERVO::CStep* pStep);


      bool isCassetteTransferStateStep(SERVO::CStep* pStep);


@@ -127,13 +168,82 @@


      int setCimMessage(const char* pszMessage, short id, short nTouchPanelNo);


      int clearCimMessage(short id, short nTouchPanelNo);


      int setDateTime(short year, short month, short day, short hour, short minute, short second);


		


      // 请求主配方列表


      int setDispatchingMode(DISPATCHING_MODE mode, ONWRITED onWritedBlock = nullptr);


      int indexerOperationModeChange(IDNEXER_OPERATION_MODE mode, ONWRITEDRET onWritedRetBlock);


      void printDebugString001();


      std::vector<SERVO::CSVData>& getSVDatas();




      // 请求主配方列表


      // unitNo: 0:local; Others:unit No


      int masterRecipeListRequest(short unitNo);


      int masterRecipeListRequest(short unitNo, ONSYNCINGSTATECHANGED block);




      // 请求配方参数


      // masterRecipeId: 主配方id


      // localRecipeId: 本地配方id


      // unitNo: 0:local; Others:unit No


      int recipeParameterRequest(short masterRecipeId, short localRecipeId, short unitNo, ONSYNCINGSTATECHANGED block);




      // 解析配方参数列表


      virtual int parsingParams(const char* pszData, size_t size, std::vector<CParam>& params) { return 0;  };


      virtual int parsingParams(const char* pszData, size_t size, std::string& strOut);


      virtual int parsingProcessData(const char* pszData, size_t size, std::vector<CParam>& params) { return 0; };


      virtual int parsingSVData(const char* pszData, size_t size, std::vector<CParam>& params) { return 0; };




      // 获取指定的Slot


      CSlot* getSlot(int index);


      CSlot* getSlotWithNo(int slotNo);




      // 获取一个可用的槽位


      CSlot* getAvailableSlot();




      // 获取一个指定物料类型(G1,G2,G1&G2)的空槽位


      CSlot* getAvailableSlotForGlass(MaterialsType type);


      CSlot* getAvailableSlotForGlassExcludeSignal(MaterialsType type);


      CSlot* isSlotAvailable(unsigned int slot);




      // 在指定的槽列表中，获取一个指定物料类型(G1,G2,G1&G2)的空槽位


      CSlot* getAvailableSlotForGlass2(MaterialsType type, const std::vector<int>& candidates);




      // 获取一个指定物料类型(G1,G2,G1&G2)的非空槽位


      CSlot* getNonEmptySlot(MaterialsType type);




      // 获取一个指定物料类型(G1,G2,G1&G2)的且已经加工处理的槽位


      CSlot* getProcessedSlot(MaterialsType putSlotType, BOOL bJobMode = FALSE);


      CSlot* getProcessedSlot2(MaterialsType putSlotType, const std::vector<int>& candidates);


      CSlot* getInspFailSlot();


      CSlot* getProcessedSlotCt(unsigned int slot);




      // 获取玻璃物料


      CGlass* getGlassFromSlot(int slotNo);


      CGlass* getGlassWithCassette(int cassetteSequenceNo, int jobSequenceNo);


      CGlass* getAnyGlass();


      CGlass* getGlass(const char* pszGlassId);


      int getAllGlass(std::vector<CGlass*>& glasses);


      CJobDataS* getJobDataSWithCassette(int cassetteSequenceNo, int jobSequenceNo);




      // 验证玻璃和槽是否匹配


      BOOL ValidateGlassSlotMatch();




      // 是否有玻璃


      BOOL hasGlass();


      BOOL slotHasGlass(int slotIndex = 0);




      // 指定槽位是否可以放置玻璃


      BOOL canPlaceGlassInSlot(const short slotIndex);




      // 手动移除物料


      int removeGlass(int slotNo);




      // 字符串检测结果转换


      InspResult judgeStringToInspResult(std::string& strJudge);




      PROCESS_STATE getProcessState(int slotNo) const;




      // for test


      void fireSetProcessState(int nSlotNo, PROCESS_STATE state) { return setProcessState(nSlotNo, state); }






   // 以下为从CC-Link读取到的Bit标志位检测函数


   // 以下为从CC-Link读取到的Bit标志位检测函数


   public:


      BOOL isAlive();


      BOOL isCimOn();


@@ -142,29 +252,58 @@


      BOOL isLocalAlarm();


      BOOL isAutoRecipeChange();


      BOOL isVCREnable(unsigned int index);


      BOOL isLinkSignalUpstreamOn(unsigned int path, unsigned int signal);


      BOOL isLinkSignalDownstreamOn(unsigned int path, unsigned int signal);




      // 只在模拟测试时使用的函数，用于模拟信号


      void setLinkSignalUpstream(unsigned int path, unsigned int signal, BOOL bOn);


      void setLinkSignalUpstreamBlock(unsigned int path, BOOL* pSignal);


      void setLinkSignalDownstream(unsigned int path, unsigned int signal, BOOL bOn);


      void setLinkSignalDownstreamBlock(unsigned int path, BOOL* pSignal);




   protected:


      inline void Lock() { EnterCriticalSection(&m_criticalSection); }


      inline void Unlock() { LeaveCriticalSection(&m_criticalSection); }


      BOOL isBitOn(const char* pszData, size_t size, int index);


      inline BOOL equalBool(BOOL b1, BOOL b2);


      void addGlassToList(CGlass* pGlass);


      short decodeRecipeListReport(const char* pszData, size_t size);


      short decodeRecipeParameterReport(const char* pszData, size_t size);


      int decodeProcessDataReport(CStep* pStep, const char* pszData, size_t size);


      int decodeReceivedJobReport(CStep* pStep, int port, const char* pszData, size_t size);


      int decodeSentOutJobReport(CStep* pStep, int port, const char* pszData, size_t size);


      int decodeFetchedOutJobReport(CStep* pStep, int port, const char* pszData, size_t size);


      int decodeStoredJobReport(CStep* pStep, int port, const char* pszData, size_t size);


      int decodeVCREventReport(CStep* pStep, const char* pszData, size_t size);


      int decodePanelDataReport(CStep* pStep, const char* pszData, size_t size);


      int decodeFacDataReport(CStep* pStep, const char* pszData, size_t size);


      int decodeJobDataRequest(CStep* pStep, const char* pszData, size_t size);


      int decodeJobProcessStartReport(CStep* pStep, const char* pszData, size_t size);


      int decodeJobProcessEndReport(CStep* pStep, const char* pszData, size_t size);


      BOOL compareJobData(CJobDataB* pJobDataB, CJobDataS* pJobDataS);


      void setProcessState(int nSlotNo, PROCESS_STATE state);


      float toFloat(const char* pszAddr);




   protected:


      // 部分优化/简化代码、暂实现部分，到时平铺开


      void addFacDataReportStep(int dataDev, int writeSignalDev, int port);






   protected:


      BOOL m_bEnable;


      EquipmentListener m_listener;


      int m_nID;


      std::string m_strName;


      std::string m_strDescription;


      std::string m_currentRecipe;


      CRITICAL_SECTION m_criticalSection;


      StationIdentifier m_station;


      MemoryBlock m_blockReadBit;


      MemoryBlock m_blockWriteBit;


      std::vector<CPin*> m_inputPins;


      std::vector<CPin*> m_outputPins;


      std::list<CGlass*> m_glassList;






      // 以下为从CC-Link读取到的Bit标志位


      // 以下为从CC-Link读取到的Bit标志位


   protected:


      ALIVE m_alive;


      BOOL m_bCimState;         // ON/OFF


@@ -173,11 +312,23 @@


      BOOL m_bLocalAlarm;


      BOOL m_bAutoRecipeChange;


      BOOL m_bVCREnable[VCR_MAX];


      BOOL m_bLinkSignalToUpstream[PATH_MAX][SIGNAL_MAX];


      BOOL m_bLinkSignalToDownstream[PATH_MAX][SIGNAL_MAX];




   protected:


      CCCLinkIEControl* m_pCclink;


      std::map<unsigned int, CStep*> m_mapStep;


      int m_nBaseAlarmId;


      CRecipesManager m_recipesManager;


      CSlot m_slot[SLOT_MAX];


      PROCESS_STATE m_processState[SLOT_MAX] = { PROCESS_STATE::Ready };


      std::vector<SERVO::CSVData> m_svDatas;




   private:


      CEquipment* m_pArm;




   public:


      int m_nTestFlag;


   };


}