通过向金蝶库存单据注册Python脚本,用于实时监听库存单据审核/反审核,并且将数据发送到DATAHUB

向金蝶的库存单据注册脚本

注意修改脚本中的三个变量参数,MAIN_NAME表描述,MAIN_TABLE主表名,ENTRY_TABLE分录表名。关键库存单据表名参考:

库存变动表单 表头 表体
采购入库单 t_STK_InStock T_STK_INSTOCKENTRY
采购退料单 t_PUR_MRB T_PUR_MRBENTRY
销售出库单 T_SAL_OUTSTOCK T_SAL_OUTSTOCKENTRY
销售退货单 T_SAL_RETURNSTOCK T_SAL_RETURNSTOCKENTRY

更多表单名与字段可以自行查阅金蝶BOS平台,不在此赘述。
注意正式运行时将python脚本中的 SHOW_DEBUG 设置为 False 当然这不是必需的

注册金蝶列表插件

ListViewBarItemClick.py

  1. import clr
  2. clr.AddReference("System")
  3. clr.AddReference("System.Web.Extensions")
  4. clr.AddReference("Kingdee.BOS.Core")
  5. clr.AddReference("Kingdee.BOS")
  6. clr.AddReference('Kingdee.BOS.App')
  7. clr.AddReference("Kingdee.BOS.DataEntity")
  8. clr.AddReference("Kingdee.BOS.ServiceHelper")
  9. clr.AddReference("Newtonsoft.Json")
  10. import sys
  11. from System import *
  12. from System.Collections.Generic import *
  13. from System.Web.Script.Serialization import *
  14. from System.Security.Cryptography import *
  15. from System.Text import *
  16. from System.Net import *
  17. from System.IO import *
  18. from System.Threading import *
  19. from System.Collections.Generic import Dictionary
  20. from Newtonsoft.Json import *
  21. from Newtonsoft.Json.Linq import *
  22. from Kingdee.BOS.ServiceHelper import *
  23. from Kingdee.BOS.Core.DynamicForm import *
  24. from Kingdee.BOS.App.Data import *
  25. reload(sys)
  26. sys.setdefaultencoding('utf-8')
  28. # 金蝶Cloud列表插件
  29. # 用于监听审核、反审核事件后查询变动物料的库存数据，并将数据发送到DATAHUB
  30. # 在应用到需要监听的不同表单时，注意需要更换 MAIN_NAME,MAIN_TABLE,ENTRY_TABLE 三个变量
  32. # 开启debug调试消息提醒
  33. SHOW_DEBUG = True
  35. # DataHub Host 服务器主机
  36. DATAHUB_HOST = 'http://datahub-service.kdyunchuang.com'
  38. # StrategyId 集线器ID
  39. STRATEGY_ID = '2509d92a-a91e-30a3-ae4e-33eead036a97'
  42. # 当前表名
  43. MAIN_NAME = '外购入库';
  44. # 当前表的主表名
  45. MAIN_TABLE = 't_STK_InStock'
  46. # 当前表的分录表名
  47. ENTRY_TABLE = 'T_STK_INSTOCKENTRY'
  49. # 当前表的单据编码字段
  50. BILL_FIELD = 'FBILLNO';
  51. # 物料字段名,通常情况下应该是 FMATERIALID 不需要修改
  52. MATERIAL_FIELD = 'FMATERIALID'
  53. # 仓库字段名,通常情况下应该是 FSTOCKID 不需要修改
  54. STOCK_FIELD = 'FSTOCKID'
  55. # 库位字段名,通常情况下应该是 FSTOCKLOCID 不需要修改
  56. STOCKLOC_FIELD = 'FSTOCKLOCID'
  57. # 批次号字段名,通常情况下应该是 FLOT 不需要修改
  58. LOT_FIELD = 'FLOT'
  59. # 货主字段名,通常情况下应该是 FOWNERID 不需要修改
  60. OWNER_FIELD = 'FOWNERID'
  62. class Inventory:
  64.     def __init__(self,BarItemKey):
  65.         keys = this.ListView.SelectedRowsInfo.GetPrimaryKeyValues()
  66.         self.BarItemKey = BarItemKey
  67.         self.PKS = ','.join(keys)
  69.     def fetch(self):
  70.         return DBServiceHelper.ExecuteDynamicObject(
  71.             this.Context, self.__generateSQL())
  73.     def collectionToJson(self, collection):
  74.         json = '['
  75.         for row in collection:
  76.             json += '{"FID":"'+row[0].ToString() + '"' \
  77.                 ',"FStockId":"'+row[1].ToString()+'"' \
  78.                 ',"FMaterialId":"'+row[2].ToString()+'"' \
  79.                 ',"FBaseQty":"'+row[3].ToString()+'"' \
  80.                 ',"FBaseAVBQty":"'+row[4].ToString()+'"' \
  81.                 ',"FLot":"'+row[5].ToString()+'"' \
  82.                 ',"FUpdateTime":"'+row[6].ToString()+'"' \
  83.                 ',"FOwnerId":"'+row[7].ToString()+'"' \
  84.                 ',"FKeeperId":"'+row[8].ToString()+'"' \
  85.                 ',"FStockOrgId":"'+row[9].ToString()+'"' \
  86.                 ',"FOwnerTypeId":"'+row[10].ToString()+'"' \
  87.                 ',"FMaterialId_FNumber":"'+row[11].ToString()+'"' \
  88.                 ',"FOwnerId_FNumber":"'+row[12].ToString()+'"' \
  89.                 ',"FKeeperId_FNumber":"'+row[13].ToString()+'"' \
  90.                 ',"FStockOrgId_FNumber":"'+row[14].ToString()+'"' \
  91.                 ',"FProduceDate":"'+row[15].ToString()+'"' \
  92.                 ',"FMtoNo":"'+row[16].ToString()+'"' \
  93.                 ',"FStockStatusId":"'+row[17].ToString()+'"' \
  94.                 ',"FBILLNO":"'+row[18].ToString()+'"' \
  95.                 ',"id":"'+row[0].ToString()+'"' \
  96.                 ',"FormName":"'+MAIN_NAME+'"},'
  97.         json = json.rstrip(',') + ']'
  98.         return '{"idCheck":false,"content":'+json+',"multiple":true,"id":1}';
  100.     def __generateSQL(self):
  101.         sqlArray = [
  102.             'SELECT DISTINCT',
  103.             'INV.FID,',
  104.             'INV.FStockId,',
  105.             'INV.FMaterialId,',
  106.             'INV.FBaseQty,',
  107.             'INV.FBaseAVBQty,',
  108.             'INV.FLot,',
  109.             'INV.FUpdateTime,',
  110.             'INV.FOwnerId,',
  111.             'INV.FKeeperId,',
  112.             'INV.FStockOrgId,',
  113.             'INV.FOwnerTypeId,',
  114.             'MATE.FNUMBER AS FMaterialId_FNumber,',
  115.             'ORG1.FNUMBER AS FOwnerId_FNumber,',
  116.             'ORG2.FNUMBER AS FKeeperId_FNumber,',
  117.             'ORG3.FNUMBER AS FStockOrgId_FNumber,',
  118.             'INV.FProduceDate,',
  119.             'INV.FMtoNo,',
  120.             'INV.FStockStatusId,',
  121.             # 如果现实单据号,则可能导致会重复发送多一些数据.但是这并不影响真实库存.如果非要传入单号,可以开启
  122.             # 'MAIN.'+BILL_FIELD,
  123.             # 将单号现实为0,避免POST数据中存在重复
  124.             "'0' AS FBillNo",
  125.             'FROM T_STK_INVENTORY INV',
  126.             'LEFT JOIN '+ENTRY_TABLE+' BILL ON',
  127.             'INV.FMATERIALID = BILL.'+MATERIAL_FIELD,
  128.             'AND INV.FSTOCKID = BILL.'+STOCK_FIELD,
  129.             'AND INV.FSTOCKLOCID = BILL.'+STOCKLOC_FIELD,
  130.             'AND INV.FLOT = BILL.'+LOT_FIELD,
  131.             'AND INV.FOWNERID = BILL.'+OWNER_FIELD,
  132.             'LEFT JOIN t_bd_material   MATE  ON INV.FMATERIALID = MATE.FMATERIALID',
  133.             'LEFT JOIN t_ORG_Organizations ORG1 ON INV.FOwnerId = ORG1.FORGID',
  134.             'LEFT JOIN t_ORG_Organizations ORG2 ON INV.FKeeperId = ORG2.FORGID',
  135.             'LEFT JOIN t_ORG_Organizations ORG3 ON INV.FStockOrgId = ORG3.FORGID',
  136.             'LEFT JOIN '+MAIN_TABLE+' MAIN ON BILL.FID = MAIN.FID',
  137.             'WHERE BILL.FID IN ('+self.PKS+')',
  138.         ]
  139.         sql = ' '.join(sqlArray)
  140.         if self.BarItemKey == 'tbApprove':
  141.             sql += " AND MAIN.FDOCUMENTSTATUS = 'C'"
  142.         else:
  143.             sql += " AND MAIN.FDOCUMENTSTATUS = 'D'"
  144.         # this.View.ShowMessage(sql)
  145.         return sql
  147. def AfterBarItemClick(e):
  148.     if e.BarItemKey == 'tbApprove' or e.BarItemKey == 'tbReject':
  149.         if len(this.ListView.SelectedRowsInfo.GetPrimaryKeyValues()) > 0:
  150.             handle(e.BarItemKey)
  152. def handle(BarItemKey):
  153.     inv = Inventory(BarItemKey)
  154.     url = DATAHUB_HOST + '/api/open/operation/'+STRATEGY_ID
  155.     collection = inv.fetch()
  156.     if len(collection) == 0:
  157.         return;
  158.     webRequest = post(url, inv.collectionToJson(collection))
  159.     result = JObject.Parse(webRequest)
  160.     if SHOW_DEBUG == True:
  161.         this.View.ShowMessage(webRequest)
  163. def get(url):
  164.     webRequest = WebRequest.Create(url)
  165.     webRequest.Method = "GET"
  166.     webResponse = webRequest.GetResponse()
  167.     stream = webResponse.GetResponseStream()
  168.     streamReader = StreamReader(stream, Encoding.GetEncoding("utf-8"))
  169.     result = streamReader.ReadToEnd()
  170.     return result
  172. def post(url, postdata):
  173.     webRequest = HttpWebRequest.Create(url)
  174.     webRequest.Method = "POST"
  175.     webRequest.Accept = "application/json, text/plain, */*"
  176.     webRequest.ContentType = "application/json;charset=UTF-8"
  177.     data = Encoding.ASCII.GetBytes(postdata)
  178.     webRequest.ContentLength = data.Length
  179.     webRequest.GetRequestStream().Write(data, 0, data.Length)
  180.     webRequest.GetRequestStream().Flush()
  181.     webRequest.GetRequestStream().Close()
  182.     webResponse = webRequest.GetResponse()
  183.     streamReader = StreamReader(
  184.         webResponse .GetResponseStream(), Encoding.GetEncoding("utf-8"))
  185.     result = streamReader.ReadToEnd()
  186.     return result

注册金蝶表单插件

DynamicFormDataChanged.py

  1. import clr
  2. clr.AddReference("System")
  3. clr.AddReference("System.Web.Extensions")
  4. clr.AddReference("Kingdee.BOS.Core")
  5. clr.AddReference("Kingdee.BOS")
  6. clr.AddReference('Kingdee.BOS.App')
  7. clr.AddReference("Kingdee.BOS.DataEntity")
  8. clr.AddReference("Kingdee.BOS.ServiceHelper")
  9. clr.AddReference("Newtonsoft.Json")
  10. import sys
  11. from System import *
  12. from System.Collections.Generic import *
  13. from System.Web.Script.Serialization import *
  14. from System.Security.Cryptography import *
  15. from System.Text import *
  16. from System.Net import *
  17. from System.IO import *
  18. from System.Threading import *
  19. from System.Collections.Generic import Dictionary
  20. from Newtonsoft.Json import *
  21. from Newtonsoft.Json.Linq import *
  22. from Kingdee.BOS.ServiceHelper import *
  23. from Kingdee.BOS.Core.DynamicForm import *
  24. from Kingdee.BOS.App.Data import *
  25. reload(sys)
  26. sys.setdefaultencoding('utf-8')
  28. # 金蝶Cloud表单插件
  29. # 用于监听数据变动审核、反审核事件后查询变动物料的库存数据，并将数据发送到DATAHUB
  30. # 在应用到需要监听的不同表单时，注意需要更换 MAIN_NAME,MAIN_TABLE,ENTRY_TABLE 三个变量
  32. # 开启debug调试消息提醒
  33. SHOW_DEBUG = True
  35. # DataHub Host 服务器主机
  36. DATAHUB_HOST = 'http://datahub-service.kdyunchuang.com'
  38. # StrategyId 集线器ID
  39. STRATEGY_ID = '2509d92a-a91e-30a3-ae4e-33eead036a97'
  42. # 当前表名
  43. MAIN_NAME = '外购入库';
  44. # 当前表的主表名
  45. MAIN_TABLE = 't_STK_InStock'
  46. # 当前表的分录表名
  47. ENTRY_TABLE = 'T_STK_INSTOCKENTRY'
  48. # 当前表的单据编码字段
  49. BILL_FIELD = 'FBILLNO';
  51. # 物料字段名,通常情况下应该是 FMATERIALID 不需要修改
  52. MATERIAL_FIELD = 'FMATERIALID'
  53. # 仓库字段名,通常情况下应该是 FSTOCKID 不需要修改
  54. STOCK_FIELD = 'FSTOCKID'
  55. # 库位字段名,通常情况下应该是 FSTOCKLOCID 不需要修改
  56. STOCKLOC_FIELD = 'FSTOCKLOCID'
  57. # 批次号字段名,通常情况下应该是 FLOT 不需要修改
  58. LOT_FIELD = 'FLOT'
  59. # 货主字段名,通常情况下应该是 FOWNERID 不需要修改
  60. OWNER_FIELD = 'FOWNERID'
  63. class Inventory:
  65.     def __init__(self):
  66.         self.PK = this.View.Model.GetPKValue().ToString()
  68.     def fetch(self):
  69.         return DBServiceHelper.ExecuteDynamicObject(
  70.             this.Context, self.__generateSQL())
  72.     def collectionToJson(self, collection):
  73.         json = '['
  74.         for row in collection:
  75.             json += '{"FID":"'+row[0].ToString() + '"' \
  76.                 ',"FStockId":"'+row[1].ToString()+'"' \
  77.                 ',"FMaterialId":"'+row[2].ToString()+'"' \
  78.                 ',"FBaseQty":"'+row[3].ToString()+'"' \
  79.                 ',"FBaseAVBQty":"'+row[4].ToString()+'"' \
  80.                 ',"FLot":"'+row[5].ToString()+'"' \
  81.                 ',"FUpdateTime":"'+row[6].ToString()+'"' \
  82.                 ',"FOwnerId":"'+row[7].ToString()+'"' \
  83.                 ',"FKeeperId":"'+row[8].ToString()+'"' \
  84.                 ',"FStockOrgId":"'+row[9].ToString()+'"' \
  85.                 ',"FOwnerTypeId":"'+row[10].ToString()+'"' \
  86.                 ',"FMaterialId_FNumber":"'+row[11].ToString()+'"' \
  87.                 ',"FOwnerId_FNumber":"'+row[12].ToString()+'"' \
  88.                 ',"FKeeperId_FNumber":"'+row[13].ToString()+'"' \
  89.                 ',"FStockOrgId_FNumber":"'+row[14].ToString()+'"' \
  90.                 ',"FProduceDate":"'+row[15].ToString()+'"' \
  91.                 ',"FMtoNo":"'+row[16].ToString()+'"' \
  92.                 ',"FStockStatusId":"'+row[17].ToString()+'"' \
  93.                 ',"FBILLNO":"'+row[18].ToString()+'"' \
  94.                 ',"id":"'+row[0].ToString()+'"' \
  95.                 ',"FormName":"'+MAIN_NAME+'"},'
  96.         json = json.rstrip(',') + ']'
  97.         return '{"idCheck":false,"content":'+json+',"multiple":true,"id":1}';
  99.     def __generateSQL(self):
  100.         sqlArray = [
  101.             'SELECT DISTINCT',
  102.             'INV.FID,',
  103.             'INV.FStockId,',
  104.             'INV.FMaterialId,',
  105.             'INV.FBaseQty,',
  106.             'INV.FBaseAVBQty,',
  107.             'INV.FLot,',
  108.             'INV.FUpdateTime,',
  109.             'INV.FOwnerId,',
  110.             'INV.FKeeperId,',
  111.             'INV.FStockOrgId,',
  112.             'INV.FOwnerTypeId,',
  113.             'MATE.FNUMBER AS FMaterialId_FNumber,',
  114.             'ORG1.FNUMBER AS FOwnerId_FNumber,',
  115.             'ORG2.FNUMBER AS FKeeperId_FNumber,',
  116.             'ORG3.FNUMBER AS FStockOrgId_FNumber,',
  117.             'INV.FProduceDate,',
  118.             'INV.FMtoNo,',
  119.             'INV.FStockStatusId,',
  120.             'MAIN.'+BILL_FIELD,
  121.             'FROM T_STK_INVENTORY INV',
  122.             'LEFT JOIN '+ENTRY_TABLE+' BILL ON',
  123.             'INV.FMATERIALID = BILL.'+MATERIAL_FIELD,
  124.             'AND INV.FSTOCKID = BILL.'+STOCK_FIELD,
  125.             'AND INV.FSTOCKLOCID = BILL.'+STOCKLOC_FIELD,
  126.             'AND INV.FLOT = BILL.'+LOT_FIELD,
  127.             'AND INV.FOWNERID = BILL.'+OWNER_FIELD,
  128.             'LEFT JOIN t_bd_material   MATE  ON INV.FMATERIALID = MATE.FMATERIALID',
  129.             'LEFT JOIN t_ORG_Organizations ORG1 ON INV.FOwnerId = ORG1.FORGID',
  130.             'LEFT JOIN t_ORG_Organizations ORG2 ON INV.FKeeperId = ORG2.FORGID',
  131.             'LEFT JOIN t_ORG_Organizations ORG3 ON INV.FStockOrgId = ORG3.FORGID',
  132.             'LEFT JOIN '+MAIN_TABLE+' MAIN ON BILL.FID = MAIN.FID',
  133.             'WHERE BILL.FID = '+self.PK,
  134.         ]
  135.         return ' '.join(sqlArray)
  138. def DataChanged(e):
  139.     if e.Key.ToString() == 'FDocumentStatus' and e.OldValue.ToString() == 'B' and e.NewValue.ToString() == 'C':
  140.         handle()
  141.     elif e.Key.ToString() == 'FDocumentStatus' and e.OldValue.ToString() == 'C' and e.NewValue.ToString() == 'D':
  142.         handle()
  145. def handle():
  146.     inv = Inventory()
  147.     url = DATAHUB_HOST + '/api/open/operation/'+STRATEGY_ID
  148.     collection = inv.fetch()
  149.     if len(collection) == 0:
  150.         return;
  151.     webRequest = post(url, inv.collectionToJson(collection))
  152.     result = JObject.Parse(webRequest)
  153.     if SHOW_DEBUG == True:
  154.         this.View.ShowMessage(webRequest)
  157. def get(url):
  158.     webRequest = WebRequest.Create(url)
  159.     webRequest.Method = "GET"
  160.     webResponse = webRequest.GetResponse()
  161.     stream = webResponse.GetResponseStream()
  162.     streamReader = StreamReader(stream, Encoding.GetEncoding("utf-8"))
  163.     result = streamReader.ReadToEnd()
  164.     return result
  167. def post(url, postdata):
  168.     webRequest = HttpWebRequest.Create(url)
  169.     webRequest.Method = "POST"
  170.     webRequest.Accept = "application/json, text/plain, */*"
  171.     webRequest.ContentType = "application/json;charset=UTF-8"
  172.     data = Encoding.ASCII.GetBytes(postdata)
  173.     webRequest.ContentLength = data.Length
  174.     webRequest.GetRequestStream().Write(data, 0, data.Length)
  175.     webRequest.GetRequestStream().Flush()
  176.     webRequest.GetRequestStream().Close()
  177.     webResponse = webRequest.GetResponse()
  178.     streamReader = StreamReader(
  179.         webResponse .GetResponseStream(), Encoding.GetEncoding("utf-8"))
  180.     result = streamReader.ReadToEnd()
  181.     return result

金蝶发送get post请求

  1. import clr
  2. clr.AddReference("System")
  3. clr.AddReference("System.Web.Extensions")
  4. clr.AddReference("Kingdee.BOS.Core")
  5. clr.AddReference("Kingdee.BOS")
  6. clr.AddReference('Kingdee.BOS.App')
  7. clr.AddReference("Kingdee.BOS.DataEntity")
  8. clr.AddReference("Kingdee.BOS.ServiceHelper")
  9. clr.AddReference("Newtonsoft.Json")
  10. import sys
  11. from System import *
  12. from System.Collections.Generic import *
  13. from System.Web.Script.Serialization import *
  14. from System.Security.Cryptography import *
  15. from System.Text import *
  16. from System.Net import *
  17. from System.IO import *
  18. from System.Threading import *
  19. from System.Collections.Generic import Dictionary
  20. from Newtonsoft.Json import *
  21. from Newtonsoft.Json.Linq import *
  22. from Kingdee.BOS.ServiceHelper import *
  23. from Kingdee.BOS.Core.DynamicForm import *
  24. from Kingdee.BOS.App.Data import *
  25. reload(sys)
  26. sys.setdefaultencoding('utf-8')
  28. # 开启debug调试消息提醒
  29. SHOW_DEBUG = True
  31. # DataHub Host 服务器主机
  32. DATAHUB_HOST = 'http://datahub-service.kdyunchuang.com'
  35. def DataChanged(e):
  36.     if e.Key.ToString() == 'FDocumentStatus' and e.OldValue.ToString() == 'B' and e.NewValue.ToString() == 'C':
  37.         handle()
  39. def handle():
  40.     # 拿到当前页面那两个事件 
  41.     # self.PK = this.View.Model.GetPKValue().ToString()
  42.     begin = this.Model.GetValue('')
  43.     end = this.Model.GetValue('')
  44.     url = DATAHUB_HOST + '/api/open/operation/'+begin
  45.     webRequest = get(url);
  46.     if SHOW_DEBUG == True:
  47.         this.View.ShowMessage(webRequest)
  49. def get(url):
  50.     webRequest = WebRequest.Create(url)
  51.     webRequest.Method = "GET"
  52.     webResponse = webRequest.GetResponse()
  53.     stream = webResponse.GetResponseStream()
  54.     streamReader = StreamReader(stream, Encoding.GetEncoding("utf-8"))
  55.     result = streamReader.ReadToEnd()
  56.     return result
  59. def post(url, postdata):
  60.     webRequest = HttpWebRequest.Create(url)
  61.     webRequest.Method = "POST"
  62.     webRequest.Accept = "application/json, text/plain, */*"
  63.     webRequest.ContentType = "application/json;charset=UTF-8"
  64.     data = Encoding.ASCII.GetBytes(postdata)
  65.     webRequest.ContentLength = data.Length
  66.     webRequest.GetRequestStream().Write(data, 0, data.Length)
  67.     webRequest.GetRequestStream().Flush()
  68.     webRequest.GetRequestStream().Close()
  69.     webResponse = webRequest.GetResponse()
  70.     streamReader = StreamReader(
  71.         webResponse .GetResponseStream(), Encoding.GetEncoding("utf-8"))
  72.     result = streamReader.ReadToEnd()
  73.     return result