質問編集履歴

要点を明確化

2021/12/13 10:26

投稿

yudaiyamashita

スコア10

test CHANGED Viewed

	@@ -1 +1 @@
1	- c~~_vo~~id_p~~, H~~C~~ONV(), _hC~~onvと~~は何か？~~
1	+ ddeclient.pyの167行目でDDE.ClientTransactionがFalseと値を返しているみたいなのですが

test CHANGED Viewed

@@ -10,6 +10,24 @@
+ddeclient.pyのrequest関数の中で条件分岐で
+if not hDdeData:
+　　　raise DDEError("Unable to request item", self._idInst)
+hDdeDataがFalseみたいです。
+self._idInstとhszItemはきちんと値が入っています。
+どうすればいいでしょうか。
 **ddeclient.pyの一部**
 ```ddeclient.pyの一部
@@ -304,6 +322,102 @@
+    def __del__(self):
+        """Cleanup any active connections."""
+        if self._hConv:
+            DDE.Disconnect(self._hConv)
+        if self._idInst:
+            DDE.Uninitialize(self._idInst)
+    def advise(self, item, stop=False):
+        """Request updates when DDE data changes."""
+        from ctypes import byref
+        hszItem = DDE.CreateStringHandle(self._idInst, item, 1200)
+        hDdeData = DDE.ClientTransaction(LPBYTE(), 0, self._hConv, hszItem, CF_TEXT, XTYP_ADVSTOP if stop else XTYP_ADVSTART, TIMEOUT_ASYNC, LPDWORD())
+        DDE.FreeStringHandle(self._idInst, hszItem)
+        if not hDdeData:
+            raise DDEError("Unable to %s advise" % ("stop" if stop else "start"), self._idInst)
+        DDE.FreeDataHandle(hDdeData)
+    def execute(self, command, timeout=5000):
+        """Execute a DDE command."""
+        pData = c_char_p(command)
+        cbData = DWORD(len(command) + 1)
+        hDdeData = DDE.ClientTransaction(pData, cbData, self._hConv, HSZ(), CF_TEXT, XTYP_EXECUTE, timeout, LPDWORD())
+        if not hDdeData:
+            raise DDEError("Unable to send command", self._idInst)
+        DDE.FreeDataHandle(hDdeData)
+    def request(self, item, timeout=5000):
+        """Request data from DDE service."""
+        from ctypes import byref
+        hszItem = DDE.CreateStringHandle(self._idInst, item, 1200)
+        hDdeData = DDE.ClientTransaction(LPBYTE(), 0, self._hConv, hszItem, CF_TEXT, XTYP_REQUEST, timeout, LPDWORD())
+        DDE.FreeStringHandle(self._idInst, hszItem)
+        print(self._hConv, hszItem)
+        if not hDdeData:
+            raise DDEError("Unable to request item", self._idInst)
+        if timeout != TIMEOUT_ASYNC:
+            pdwSize = DWORD(0)
+            pData = DDE.AccessData(hDdeData, byref(pdwSize))
+        if not pData:
+            DDE.FreeDataHandle(hDdeData)
+            raise DDEError("Unable to access data", self._idInst)
+        # TODO: use pdwSize
+            DDE.UnaccessData(hDdeData)
+        else:
+            pData = None
+            DDE.FreeDataHandle(hDdeData)
+        return pData
 ```
 **rakuten_rss.pyのコード**
@@ -318,174 +432,80 @@
 def rss(code, item):
+	dde = DDEClient("rss", str(code))
+	try:
+		res = dde.request(item).decode('sjis').strip()
+	except:
+		print('fail: code@', code)
+		res = 0
+	finally:
+		dde.__del__()
+	return res
+def rss_dict(code, *args):
+	dde = DDEClient("rss", str(code))
+	res = {}
+	try:
+		for item in args:
+			res[item] = dde.request(item).decode('sjis').strip()
+	except:
+		print('fail: code@', code)
+		res = {}
+	finally:
+		dde.__del__()
+	return res
+def fetch_open(code):
-	""" 楽天RSSから情報を取得
+	""" 始値を返す（SQ計算用に関数切り出し,入力int）
 	Parameters
 	----------
-	code : str
+	code : int
-		株価や先物のコード　例：東京電力の場合'9501.T'
-	item :
-	Returns
-	-------
-	str
 	Examples
-	----------
+	---------
-	>>>rss('9501.T' , '始値')
+	>>> fetch_open(9551)
-	'668.00'
-	>>>rss('9501.T' , '現在値')
-	'669.00'
-	>>>rss('9501.T' , '銘柄名称')
-	'東京電力ＨＤ'
-	>>>rss('9501.T' , '現在値詳細時刻')
-	'15:00:00'
+	50050
 	"""
-	dde = DDEClient("rss", str(code))
-	try:
-		res = dde.request(item).decode('sjis').strip()
-	except:
-		print('fail: code@', code)
-		res = 0
-	finally:
-		dde.__del__()
-	return res
-def rss_dict(code, *args):
-	"""
-	楽天RSSから辞書形式で情報を取り出す(複数の詳細情報問い合わせ可）
-	Parameters
-	----------
-	code : str
-	args : *str
-	Returns
-	-------
-	dict
-	Examples
-	----------
-	>>>rss_dict('9502.T', '始値','銘柄名称','現在値')
-	{'始値': '1739.50', '現在値': '1661.50', '銘柄名称': '中部電力'}
-	"""
-	dde = DDEClient("rss", str(code))
-	res = {}
-	try:
-		for item in args:
-			res[item] = dde.request(item).decode('sjis').strip()
-	except:
-		print('fail: code@', code)
-		res = {}
-	finally:
-		dde.__del__()
-	return res
-def fetch_open(code):
-	""" 始値を返す（SQ計算用に関数切り出し,入力int）
-	Parameters
-	----------
-	code : int
-	Examples
-	---------
-	>>> fetch_open(9551)
-	50050
-	"""
 	return float(rss(str(code) + '.T', '始値'))
 ```
@@ -505,7 +525,3 @@
 ![イメージ説明](299765a605623166d626a73b095e2da5.png)
 ![イメージ説明](71f733e87822eec9ca55fe6ef246b755.png)
-要は、_hconvつまりHCONV(), つまりc_void_pがないから、rakuten_rss.pyの仕様でエラーを返すみたいなので、そうならないようにするにはどうすればいいでしょうか。