09a5aa58cd961363ca487a4753d81d3936034f62.svn-base 7.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225
  1. <?xml version="1.0" encoding='UTF-8'?>
  2. <queryMap desc="STEEL MAKING QUERY ">
  3. <query id="RecvDataL2_G_RECV_DATA.Select" desc="" fetchSize="10">
  4. <![CDATA[
  5. SELECT SEQ_NO, MSG_ID, TRAN_DTIME, MSG_DATA
  6. FROM TBG06_L2_RECV_DATA
  7. WHERE MSG_ID IN ('NIG020100', 'NIG020110', 'NIG020120', -- KR
  8. 'NIG020200', 'NIG020210', 'NIG020220', 'NIG020230', -- BOF
  9. 'NIG020310', 'NIG020320', 'NIG020330', -- RH
  10. 'NIG020510', 'NIG020520', -- LF
  11. 'NIG020410', 'NIG020420', 'NIG020430', -- CAS
  12. 'NIG020610', 'NIG020620', 'NIG020630', 'NIG020640') -- CCM
  13. AND MSG_FLAG = 'N'
  14. AND ROWNUM < 21
  15. ORDER BY TRAN_DTIME
  16. ]]>
  17. </query>
  18. <!-- 未知接口数据,即业务不处理的记录:现不用了 -->
  19. <query id="RecvDataL2_UG_RECV_DATA.Select" desc="" fetchSize="10">
  20. <![CDATA[
  21. SELECT SEQ_NO, TRAN_DTIME
  22. FROM TBG06_L2_RECV_DATA
  23. WHERE MSG_ID NOT IN ('NIG020100', 'NIG020110', 'NIG020120', -- KR
  24. 'NIG020200', 'NIG020210', 'NIG020220', 'NIG020230', -- BOF
  25. 'NIG020310', 'NIG020320', 'NIG020330', -- RH
  26. 'NIG020510', 'NIG020520', -- LF
  27. 'NIG020410', 'NIG020420', 'NIG020430', -- CAS
  28. 'NIG020610', 'NIG020620', 'NIG020630', 'NIG020640') -- CCM
  29. AND MSG_FLAG = 'N'
  30. AND ROWNUM < 21
  31. ORDER BY TRAN_DTIME
  32. ]]>
  33. </query>
  34. <query id="RecvDataL2_G_RECV_DATA.Update" desc="" fetchSize="10">
  35. <![CDATA[
  36. UPDATE TBG06_L2_RECV_DATA SET
  37. MSG_FLAG = ?,
  38. UP_DTIME = TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')
  39. WHERE SEQ_NO = ?
  40. AND TRAN_DTIME = ?
  41. ]]>
  42. </query>
  43. <query id="RecvDataL2_UG_RECV_DATA.Update" desc="" fetchSize="10">
  44. <![CDATA[
  45. UPDATE TBG06_L2_RECV_DATA SET
  46. MSG_FLAG = 'U',
  47. UP_DTIME = TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')
  48. WHERE MSG_ID NOT IN ('NIG020100', 'NIG020110', 'NIG020120', -- KR
  49. 'NIG020200', 'NIG020210', 'NIG020220', 'NIG020230', -- BOF
  50. 'NIG020310', 'NIG020320', 'NIG020330', -- RH
  51. 'NIG020510', 'NIG020520', -- LF
  52. 'NIG020410', 'NIG020420', 'NIG020430', -- CAS
  53. 'NIG020610', 'NIG020620', 'NIG020630', 'NIG020640') -- CCM
  54. AND MSG_FLAG = 'N'
  55. ]]>
  56. </query>
  57. <query id="RecvDataL2_C_RECV_DATA.Select" desc=" " fetchSize="10">
  58. <![CDATA[
  59. SELECT SEQ_NO, PLAN_CHARGE_NO, RT_CD||' ' RT_CD, TRAN_DTIME, EXAMINE_SEQ
  60. ,ELE_CD_1, TO_CHAR(NVL(ELE_1, 0)) ELE_1
  61. ,ELE_CD_2, TO_CHAR(NVL(ELE_2, 0)) ELE_2
  62. ,ELE_CD_3, TO_CHAR(NVL(ELE_3, 0)) ELE_3
  63. ,ELE_CD_4, TO_CHAR(NVL(ELE_4, 0)) ELE_4
  64. ,ELE_CD_5, TO_CHAR(NVL(ELE_5, 0)) ELE_5
  65. ,ELE_CD_6, TO_CHAR(NVL(ELE_6, 0)) ELE_6
  66. ,ELE_CD_7, TO_CHAR(NVL(ELE_7, 0)) ELE_7
  67. ,ELE_CD_8, TO_CHAR(NVL(ELE_8, 0)) ELE_8
  68. ,ELE_CD_9, TO_CHAR(NVL(ELE_9, 0)) ELE_9
  69. ,ELE_CD_10, TO_CHAR(NVL(ELE_10,0)) ELE_10
  70. ,ELE_CD_11, TO_CHAR(NVL(ELE_11,0)) ELE_11
  71. ,ELE_CD_12, TO_CHAR(NVL(ELE_12,0)) ELE_12
  72. ,ELE_CD_13, TO_CHAR(NVL(ELE_13,0)) ELE_13
  73. ,ELE_CD_14, TO_CHAR(NVL(ELE_14,0)) ELE_14
  74. ,ELE_CD_15, TO_CHAR(NVL(ELE_15,0)) ELE_15
  75. ,ELE_CD_16, TO_CHAR(NVL(ELE_16,0)) ELE_16
  76. ,ELE_CD_17, TO_CHAR(NVL(ELE_17,0)) ELE_17
  77. ,ELE_CD_18, TO_CHAR(NVL(ELE_18,0)) ELE_18
  78. ,ELE_CD_19, TO_CHAR(NVL(ELE_19,0)) ELE_19
  79. ,ELE_CD_20, TO_CHAR(NVL(ELE_20,0)) ELE_20
  80. ,ELE_CD_21, TO_CHAR(NVL(ELE_21,0)) ELE_21
  81. ,ELE_CD_22, TO_CHAR(NVL(ELE_22,0)) ELE_22
  82. ,ELE_CD_23, TO_CHAR(NVL(ELE_23,0)) ELE_23
  83. ,ELE_CD_24, TO_CHAR(NVL(ELE_24,0)) ELE_24
  84. ,ELE_CD_25, TO_CHAR(NVL(ELE_25,0)) ELE_25
  85. ,ELE_CD_26, TO_CHAR(NVL(ELE_26,0)) ELE_26
  86. ,ELE_CD_27, TO_CHAR(NVL(ELE_27,0)) ELE_27
  87. ,ELE_CD_28, TO_CHAR(NVL(ELE_28,0)) ELE_28
  88. ,ELE_CD_29, TO_CHAR(NVL(ELE_29,0)) ELE_29
  89. ,ELE_CD_30, TO_CHAR(NVL(ELE_30,0)) ELE_30
  90. ,ELE_CD_31, TO_CHAR(NVL(ELE_31,0)) ELE_31
  91. ,ELE_CD_32, TO_CHAR(NVL(ELE_32,0)) ELE_32
  92. ,ELE_CD_33, TO_CHAR(NVL(ELE_33,0)) ELE_33
  93. ,ELE_CD_34, TO_CHAR(NVL(ELE_34,0)) ELE_34
  94. ,ELE_CD_35, TO_CHAR(NVL(ELE_35,0)) ELE_35
  95. FROM TBG06_L2_CHEM_RESULT
  96. WHERE MSG_FLAG = 'N'
  97. AND ROWNUM < 21
  98. ORDER BY TRAN_DTIME
  99. ]]>
  100. </query>
  101. <query id="RecvDataL2_C_RECV_DATA.Update" desc="" fetchSize="10">
  102. <![CDATA[
  103. UPDATE TBG06_L2_CHEM_RESULT SET
  104. MSG_FLAG = ?,
  105. UP_DTIME = TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')
  106. WHERE SEQ_NO = ?
  107. AND TRAN_DTIME = ?
  108. ]]>
  109. </query>
  110. <query id="RecvDataL2_H_RECV_DATA.Select" desc="" fetchSize="10">
  111. <![CDATA[
  112. SELECT A.SEQ_NO, B.TC_ID, A.TRANS_DTIME, SUBSTR(A.TC_MSG, 41) TC_MSG
  113. FROM TBH06_L2_RECV_DATA A, (
  114. SELECT TC_ID, L2_RECV_TC_ID
  115. FROM TBZ01_TCID_LEN
  116. WHERE PROC_CD = 'H'
  117. AND TC_SEND_RECV = 'R') B
  118. WHERE A.MSG_FLAG = 'N'
  119. AND TRIM(SUBSTR(A.TC_MSG, 5, 6)) = B.L2_RECV_TC_ID
  120. AND ROWNUM < 21
  121. ORDER BY TRANS_DTIME
  122. ]]>
  123. </query>
  124. <!-- 未知接口数据,即业务不处理的记录:现不用了 -->
  125. <query id="RecvDataL2_UH_RECV_DATA.Select" desc="" fetchSize="10">
  126. <![CDATA[
  127. SELECT A.SEQ_NO, A.TRANS_DTIME
  128. FROM TBH06_L2_RECV_DATA A
  129. WHERE A.MSG_FLAG = 'N'
  130. AND TRIM(SUBSTR(A.TC_MSG, 5, 6)) NOT IN (
  131. SELECT L2_RECV_TC_ID
  132. FROM TBZ01_TCID_LEN
  133. WHERE PROC_CD = 'H'
  134. AND TC_SEND_RECV = 'R')
  135. AND ROWNUM < 21
  136. ORDER BY TRANS_DTIME
  137. ]]>
  138. </query>
  139. <query id="RecvDataL2_H_RECV_DATA.Update" desc="" fetchSize="10">
  140. <![CDATA[
  141. UPDATE TBH06_L2_RECV_DATA SET
  142. MSG_FLAG = ?,
  143. UP_DTIME = TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')
  144. WHERE SEQ_NO = ?
  145. AND TRANS_DTIME = ?
  146. ]]>
  147. </query>
  148. <query id="RecvDataL2_UH_RECV_DATA.Update" desc="" fetchSize="10">
  149. <![CDATA[
  150. UPDATE TBH06_L2_RECV_DATA SET
  151. MSG_FLAG = 'U',
  152. UP_DTIME = TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISS')
  153. WHERE MSG_FLAG = 'N'
  154. AND TRIM(SUBSTR(TC_MSG, 5, 6)) NOT IN (
  155. SELECT L2_RECV_TC_ID
  156. FROM TBZ01_TCID_LEN
  157. WHERE PROC_CD = 'H'
  158. AND TC_SEND_RECV = 'R')
  159. ]]>
  160. </query>
  161. <!-- 生产实时数据处理,现在不同了 -->
  162. <query id="RecvDataL2_RT_RECV_DATA.Select" desc="" fetchSize="10">
  163. <![CDATA[
  164. SELECT SEQ_NO, MSG_ID, TRAN_DTIME, MSG_DATA
  165. FROM TBG06_L2_RECV_DATA
  166. WHERE MSG_ID IN ('NIG020130', -- KR
  167. 'NIG020250', -- BOF
  168. 'NIG020330', -- RH
  169. 'NIG020530', -- LF
  170. 'NIG020430', -- CAS
  171. 'NIG020650') -- CCM
  172. AND MSG_FLAG = 'N'
  173. AND ROWNUM < 101
  174. ORDER BY TRAN_DTIME
  175. ]]>
  176. </query>
  177. <query id="Delete.RecvData.DB" desc="数据库接收">
  178. <![CDATA[
  179. DELETE TBG06_L2_RECV_DATA
  180. WHERE (TO_CHAR(SYSDATE - 7, 'YYYYMMDD') > SUBSTR(TRAN_DTIME, 1, 8))
  181. OR (MSG_FLAG = 'C' AND MSG_ID IN ('NIG020331','NIG020332','NIG020530','NIG020650'))
  182. ]]>
  183. </query>
  184. <query id="Delete.Chem.DB" desc="成分接收">
  185. <![CDATA[
  186. DELETE TBG06_L2_CHEM_RESULT
  187. WHERE TO_CHAR(SYSDATE - 7, 'YYYYMMDD') > SUBSTR(TRAN_DTIME, 1, 8)
  188. ]]>
  189. </query>
  190. <query id="Delete.RecvData" desc="报文接收">
  191. <![CDATA[
  192. DELETE TBH06_L2_RECV_DATA
  193. WHERE TO_CHAR(SYSDATE - 7, 'YYYYMMDD') > SUBSTR(TRANS_DTIME, 1, 8)
  194. ]]>
  195. </query>
  196. <query id="Delete.MILL_INS" desc="轧制指示">
  197. <![CDATA[
  198. DELETE FROM TBH06_L2_MILL_INS T
  199. WHERE SYSDATE - TO_DATE(T.TRANS_DTIME, 'yyyymmddhh24miss') > 3
  200. ]]>
  201. </query>
  202. <query id="Delete.COIL_NO_INS" desc="顺序指示:未使用">
  203. <![CDATA[
  204. DELETE FROM TBH06_L2_COIL_NO_INS T
  205. WHERE SYSDATE - TO_DATE(T.TRANS_DTIME, 'yyyymmddhh24miss') > 1
  206. ]]>
  207. </query>
  208. <query id="Delete.RHT_INS" desc="加热炉指示">
  209. <![CDATA[
  210. DELETE FROM TBH06_L2_RHT_INS T
  211. WHERE SYSDATE - TO_DATE(T.TRANS_DTIME, 'yyyymmddhh24miss') > 3
  212. ]]>
  213. </query>
  214. <query id="TESTweb" desc="weblogic测试">
  215. <![CDATA[
  216. insert into test_date_t_table(date_t) values (sysdate)
  217. ]]>
  218. </query>
  219. </queryMap>