Commit deb92b4e38532fa3279e64af9eadfbd640c5915c
1 parent
3a114220
浦东调度车辆信息同步etl更新
1、从数据库获取公司分公司数据 2、同步是否电车信息
Showing
1 changed file
with
692 additions
and
105 deletions
src/main/resources/datatools/ktrs/vehicleDataSync.ktr
| ... | ... | @@ -36,7 +36,7 @@ |
| 36 | 36 | </parameter> |
| 37 | 37 | <parameter> |
| 38 | 38 | <name>paramClzbh</name> |
| 39 | - <default_value/> | |
| 39 | + <default_value>W0K-108</default_value> | |
| 40 | 40 | <description>参数-车辆自编号</description> |
| 41 | 41 | </parameter> |
| 42 | 42 | <parameter> |
| ... | ... | @@ -145,13 +145,448 @@ |
| 145 | 145 | <bordercolorblue>100</bordercolorblue> |
| 146 | 146 | <drawshadow>Y</drawshadow> |
| 147 | 147 | </notepad> |
| 148 | + <notepad> | |
| 149 | + <note>注意:从数据库中读取公司和分公司数据</note> | |
| 150 | + <xloc>42</xloc> | |
| 151 | + <yloc>293</yloc> | |
| 152 | + <width>226</width> | |
| 153 | + <heigth>26</heigth> | |
| 154 | + <fontname>YaHei Consolas Hybrid</fontname> | |
| 155 | + <fontsize>12</fontsize> | |
| 156 | + <fontbold>N</fontbold> | |
| 157 | + <fontitalic>N</fontitalic> | |
| 158 | + <fontcolorred>0</fontcolorred> | |
| 159 | + <fontcolorgreen>0</fontcolorgreen> | |
| 160 | + <fontcolorblue>0</fontcolorblue> | |
| 161 | + <backgroundcolorred>255</backgroundcolorred> | |
| 162 | + <backgroundcolorgreen>205</backgroundcolorgreen> | |
| 163 | + <backgroundcolorblue>112</backgroundcolorblue> | |
| 164 | + <bordercolorred>100</bordercolorred> | |
| 165 | + <bordercolorgreen>100</bordercolorgreen> | |
| 166 | + <bordercolorblue>100</bordercolorblue> | |
| 167 | + <drawshadow>Y</drawshadow> | |
| 168 | + </notepad> | |
| 148 | 169 | </notepads> |
| 149 | 170 | <connection> |
| 150 | - <name>control_jndi</name> | |
| 171 | + <name>192.168.168.1_jwgl_dw</name> | |
| 172 | + <server>192.168.168.1</server> | |
| 173 | + <type>ORACLE</type> | |
| 174 | + <access>Native</access> | |
| 175 | + <database>orcl</database> | |
| 176 | + <port>1521</port> | |
| 177 | + <username>jwgl_dw</username> | |
| 178 | + <password>Encrypted 2be98afc86aa7f2e4cb13b977d2adabcd</password> | |
| 179 | + <servername/> | |
| 180 | + <data_tablespace/> | |
| 181 | + <index_tablespace/> | |
| 182 | + <attributes> | |
| 183 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 184 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 185 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 186 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 187 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 188 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 189 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 190 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 191 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 192 | + </attributes> | |
| 193 | + </connection> | |
| 194 | + <connection> | |
| 195 | + <name>bus_control_variable</name> | |
| 196 | + <server>${v_db_ip}</server> | |
| 197 | + <type>MYSQL</type> | |
| 198 | + <access>Native</access> | |
| 199 | + <database>${v_db_dname}</database> | |
| 200 | + <port>3306</port> | |
| 201 | + <username>${v_db_uname}</username> | |
| 202 | + <password>${v_db_pwd}</password> | |
| 203 | + <servername/> | |
| 204 | + <data_tablespace/> | |
| 205 | + <index_tablespace/> | |
| 206 | + <attributes> | |
| 207 | + <attribute><code>EXTRA_OPTION_MYSQL.characterEncoding</code><attribute>utf8</attribute></attribute> | |
| 208 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 209 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 210 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 211 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 212 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 213 | + <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute> | |
| 214 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 215 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 216 | + <attribute><code>STREAM_RESULTS</code><attribute>N</attribute></attribute> | |
| 217 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 218 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 219 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 220 | + </attributes> | |
| 221 | + </connection> | |
| 222 | + <connection> | |
| 223 | + <name>bus_control_公司_201</name> | |
| 224 | + <server>localhost</server> | |
| 225 | + <type>MYSQL</type> | |
| 226 | + <access>Native</access> | |
| 227 | + <database>control</database> | |
| 228 | + <port>3306</port> | |
| 229 | + <username>root</username> | |
| 230 | + <password>Encrypted </password> | |
| 231 | + <servername/> | |
| 232 | + <data_tablespace/> | |
| 233 | + <index_tablespace/> | |
| 234 | + <attributes> | |
| 235 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 236 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 237 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 238 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 239 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 240 | + <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute> | |
| 241 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 242 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 243 | + <attribute><code>STREAM_RESULTS</code><attribute>N</attribute></attribute> | |
| 244 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 245 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 246 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 247 | + </attributes> | |
| 248 | + </connection> | |
| 249 | + <connection> | |
| 250 | + <name>bus_control_本机</name> | |
| 251 | + <server>localhost</server> | |
| 252 | + <type>MYSQL</type> | |
| 253 | + <access>Native</access> | |
| 254 | + <database>control</database> | |
| 255 | + <port>3306</port> | |
| 256 | + <username>root</username> | |
| 257 | + <password>Encrypted </password> | |
| 258 | + <servername/> | |
| 259 | + <data_tablespace/> | |
| 260 | + <index_tablespace/> | |
| 261 | + <attributes> | |
| 262 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 263 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 264 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 265 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 266 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 267 | + <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute> | |
| 268 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 269 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 270 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 271 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 272 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 273 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 274 | + </attributes> | |
| 275 | + </connection> | |
| 276 | + <connection> | |
| 277 | + <name>control_jndi</name> | |
| 278 | + <server/> | |
| 279 | + <type>MYSQL</type> | |
| 280 | + <access>JNDI</access> | |
| 281 | + <database>control_jndi</database> | |
| 282 | + <port>1521</port> | |
| 283 | + <username/> | |
| 284 | + <password>Encrypted </password> | |
| 285 | + <servername/> | |
| 286 | + <data_tablespace/> | |
| 287 | + <index_tablespace/> | |
| 288 | + <attributes> | |
| 289 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 290 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 291 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 292 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 293 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 294 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 295 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 296 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 297 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 298 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 299 | + </attributes> | |
| 300 | + </connection> | |
| 301 | + <connection> | |
| 302 | + <name>JGJW_VM</name> | |
| 303 | + <server>192.168.198.240</server> | |
| 304 | + <type>ORACLE</type> | |
| 305 | + <access>Native</access> | |
| 306 | + <database>orcl</database> | |
| 307 | + <port>1521</port> | |
| 308 | + <username>jwgl</username> | |
| 309 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10d485a8d6</password> | |
| 310 | + <servername/> | |
| 311 | + <data_tablespace/> | |
| 312 | + <index_tablespace/> | |
| 313 | + <attributes> | |
| 314 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 315 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 316 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 317 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 318 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 319 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 320 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 321 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 322 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 323 | + </attributes> | |
| 324 | + </connection> | |
| 325 | + <connection> | |
| 326 | + <name>NHJW_VM</name> | |
| 327 | + <server>192.168.198.240</server> | |
| 328 | + <type>ORACLE</type> | |
| 329 | + <access>Native</access> | |
| 330 | + <database>orcl</database> | |
| 331 | + <port>1521</port> | |
| 332 | + <username>nhjw</username> | |
| 333 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10d09aa5cd</password> | |
| 334 | + <servername/> | |
| 335 | + <data_tablespace/> | |
| 336 | + <index_tablespace/> | |
| 337 | + <attributes> | |
| 338 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 339 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 340 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 341 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 342 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 343 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 344 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 345 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 346 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 347 | + </attributes> | |
| 348 | + </connection> | |
| 349 | + <connection> | |
| 350 | + <name>PDGJ_VM</name> | |
| 351 | + <server>192.168.198.240</server> | |
| 352 | + <type>ORACLE</type> | |
| 353 | + <access>Native</access> | |
| 354 | + <database>orcl</database> | |
| 355 | + <port>1521</port> | |
| 356 | + <username>pdgj</username> | |
| 357 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10ce96a8d0</password> | |
| 358 | + <servername/> | |
| 359 | + <data_tablespace/> | |
| 360 | + <index_tablespace/> | |
| 361 | + <attributes> | |
| 362 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 363 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 364 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 365 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 366 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 367 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 368 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 369 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 370 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 371 | + </attributes> | |
| 372 | + </connection> | |
| 373 | + <connection> | |
| 374 | + <name>repair_dw_mysql_jndi</name> | |
| 375 | + <server/> | |
| 376 | + <type>MYSQL</type> | |
| 377 | + <access>JNDI</access> | |
| 378 | + <database>repair_dw_mysql</database> | |
| 379 | + <port>1521</port> | |
| 380 | + <username/> | |
| 381 | + <password>Encrypted </password> | |
| 382 | + <servername/> | |
| 383 | + <data_tablespace/> | |
| 384 | + <index_tablespace/> | |
| 385 | + <attributes> | |
| 386 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 387 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 388 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 389 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 390 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 391 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 392 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 393 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 394 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 395 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 396 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 397 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 398 | + </attributes> | |
| 399 | + </connection> | |
| 400 | + <connection> | |
| 401 | + <name>repair_dw(本机)</name> | |
| 402 | + <server>localhost</server> | |
| 403 | + <type>MYSQL</type> | |
| 404 | + <access>Native</access> | |
| 405 | + <database>ruoyi-vue-3.5</database> | |
| 406 | + <port>3306</port> | |
| 407 | + <username>root</username> | |
| 408 | + <password>Encrypted </password> | |
| 409 | + <servername/> | |
| 410 | + <data_tablespace/> | |
| 411 | + <index_tablespace/> | |
| 412 | + <attributes> | |
| 413 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 414 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 415 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 416 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 417 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 418 | + <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute> | |
| 419 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 420 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 421 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 422 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 423 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 424 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 425 | + </attributes> | |
| 426 | + </connection> | |
| 427 | + <connection> | |
| 428 | + <name>repair_real_h2</name> | |
| 429 | + <server/> | |
| 430 | + <type>H2</type> | |
| 431 | + <access>JNDI</access> | |
| 432 | + <database>repair_real_h2</database> | |
| 433 | + <port>1521</port> | |
| 434 | + <username/> | |
| 435 | + <password>Encrypted </password> | |
| 436 | + <servername/> | |
| 437 | + <data_tablespace/> | |
| 438 | + <index_tablespace/> | |
| 439 | + <attributes> | |
| 440 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 441 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 442 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 443 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 444 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 445 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 446 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 447 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 448 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 449 | + </attributes> | |
| 450 | + </connection> | |
| 451 | + <connection> | |
| 452 | + <name>SNJW_VM</name> | |
| 453 | + <server>192.168.198.240</server> | |
| 454 | + <type>ORACLE</type> | |
| 455 | + <access>Native</access> | |
| 456 | + <database>orcl</database> | |
| 457 | + <port>1521</port> | |
| 458 | + <username>snjw</username> | |
| 459 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10cd9ca5cd</password> | |
| 460 | + <servername/> | |
| 461 | + <data_tablespace/> | |
| 462 | + <index_tablespace/> | |
| 463 | + <attributes> | |
| 464 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 465 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 466 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 467 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 468 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 469 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 470 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 471 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 472 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 473 | + </attributes> | |
| 474 | + </connection> | |
| 475 | + <connection> | |
| 476 | + <name>test_control_local</name> | |
| 477 | + <server>localhost</server> | |
| 478 | + <type>MYSQL</type> | |
| 479 | + <access>Native</access> | |
| 480 | + <database>test_control</database> | |
| 481 | + <port>3306</port> | |
| 482 | + <username>root</username> | |
| 483 | + <password>Encrypted </password> | |
| 484 | + <servername/> | |
| 485 | + <data_tablespace/> | |
| 486 | + <index_tablespace/> | |
| 487 | + <attributes> | |
| 488 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 489 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 490 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 491 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 492 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 493 | + <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute> | |
| 494 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 495 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 496 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 497 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 498 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 499 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 500 | + </attributes> | |
| 501 | + </connection> | |
| 502 | + <connection> | |
| 503 | + <name>test_control(本机)</name> | |
| 504 | + <server>127.0.0.1</server> | |
| 505 | + <type>MYSQL</type> | |
| 506 | + <access>Native</access> | |
| 507 | + <database>test_control</database> | |
| 508 | + <port>3306</port> | |
| 509 | + <username>root</username> | |
| 510 | + <password>Encrypted </password> | |
| 511 | + <servername/> | |
| 512 | + <data_tablespace/> | |
| 513 | + <index_tablespace/> | |
| 514 | + <attributes> | |
| 515 | + <attribute><code>EXTRA_OPTION_MYSQL.characterEncoding</code><attribute>utf8</attribute></attribute> | |
| 516 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 517 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 518 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 519 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 520 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 521 | + <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute> | |
| 522 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 523 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 524 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 525 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 526 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 527 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 528 | + </attributes> | |
| 529 | + </connection> | |
| 530 | + <connection> | |
| 531 | + <name>xlab_mysql_youle</name> | |
| 532 | + <server>101.231.124.8</server> | |
| 533 | + <type>MYSQL</type> | |
| 534 | + <access>Native</access> | |
| 535 | + <database>xlab_youle</database> | |
| 536 | + <port>45687</port> | |
| 537 | + <username>xlab-youle</username> | |
| 538 | + <password>Encrypted 2be98afc86aa78a88aa1be369d187a3df</password> | |
| 539 | + <servername/> | |
| 540 | + <data_tablespace/> | |
| 541 | + <index_tablespace/> | |
| 542 | + <attributes> | |
| 543 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 544 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 545 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 546 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 547 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 548 | + <attribute><code>PORT_NUMBER</code><attribute>45687</attribute></attribute> | |
| 549 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 550 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 551 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 552 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>N</attribute></attribute> | |
| 553 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>N</attribute></attribute> | |
| 554 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 555 | + </attributes> | |
| 556 | + </connection> | |
| 557 | + <connection> | |
| 558 | + <name>xlab_mysql_youle(本机)</name> | |
| 559 | + <server>localhost</server> | |
| 560 | + <type>MYSQL</type> | |
| 561 | + <access>Native</access> | |
| 562 | + <database>xlab_youle</database> | |
| 563 | + <port>3306</port> | |
| 564 | + <username>root</username> | |
| 565 | + <password>Encrypted </password> | |
| 566 | + <servername/> | |
| 567 | + <data_tablespace/> | |
| 568 | + <index_tablespace/> | |
| 569 | + <attributes> | |
| 570 | + <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute> | |
| 571 | + <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute> | |
| 572 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 573 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 574 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 575 | + <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute> | |
| 576 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 577 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 578 | + <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute> | |
| 579 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>N</attribute></attribute> | |
| 580 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>N</attribute></attribute> | |
| 581 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 582 | + </attributes> | |
| 583 | + </connection> | |
| 584 | + <connection> | |
| 585 | + <name>xlab_youle</name> | |
| 151 | 586 | <server/> |
| 152 | 587 | <type>MYSQL</type> |
| 153 | 588 | <access>JNDI</access> |
| 154 | - <database>control_jndi</database> | |
| 589 | + <database>xlab_youle</database> | |
| 155 | 590 | <port>1521</port> |
| 156 | 591 | <username/> |
| 157 | 592 | <password>Encrypted </password> |
| ... | ... | @@ -171,14 +606,156 @@ |
| 171 | 606 | <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> |
| 172 | 607 | </attributes> |
| 173 | 608 | </connection> |
| 609 | + <connection> | |
| 610 | + <name>YGJW_VM</name> | |
| 611 | + <server>192.168.198.240</server> | |
| 612 | + <type>ORACLE</type> | |
| 613 | + <access>Native</access> | |
| 614 | + <database>orcl</database> | |
| 615 | + <port>1521</port> | |
| 616 | + <username>ygjw</username> | |
| 617 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10c795a5cd</password> | |
| 618 | + <servername/> | |
| 619 | + <data_tablespace/> | |
| 620 | + <index_tablespace/> | |
| 621 | + <attributes> | |
| 622 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 623 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 624 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 625 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 626 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 627 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 628 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 629 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 630 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 631 | + </attributes> | |
| 632 | + </connection> | |
| 633 | + <connection> | |
| 634 | + <name>公司jgjw</name> | |
| 635 | + <server>192.168.168.1</server> | |
| 636 | + <type>ORACLE</type> | |
| 637 | + <access>Native</access> | |
| 638 | + <database>orcl</database> | |
| 639 | + <port>1521</port> | |
| 640 | + <username>jwgl</username> | |
| 641 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10d485a8d6</password> | |
| 642 | + <servername/> | |
| 643 | + <data_tablespace/> | |
| 644 | + <index_tablespace/> | |
| 645 | + <attributes> | |
| 646 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 647 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 648 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 649 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 650 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 651 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 652 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 653 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 654 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 655 | + </attributes> | |
| 656 | + </connection> | |
| 657 | + <connection> | |
| 658 | + <name>公司snjw</name> | |
| 659 | + <server>192.168.168.1</server> | |
| 660 | + <type>ORACLE</type> | |
| 661 | + <access>Native</access> | |
| 662 | + <database>orcl</database> | |
| 663 | + <port>1521</port> | |
| 664 | + <username>snjw</username> | |
| 665 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10cd9ca5cd</password> | |
| 666 | + <servername/> | |
| 667 | + <data_tablespace/> | |
| 668 | + <index_tablespace/> | |
| 669 | + <attributes> | |
| 670 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 671 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 672 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 673 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 674 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 675 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 676 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 677 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 678 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 679 | + </attributes> | |
| 680 | + </connection> | |
| 681 | + <connection> | |
| 682 | + <name>公司ygjw</name> | |
| 683 | + <server>192.168.168.1</server> | |
| 684 | + <type>ORACLE</type> | |
| 685 | + <access>Native</access> | |
| 686 | + <database>orcl</database> | |
| 687 | + <port>1521</port> | |
| 688 | + <username>ygjw</username> | |
| 689 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10c795a5cd</password> | |
| 690 | + <servername/> | |
| 691 | + <data_tablespace/> | |
| 692 | + <index_tablespace/> | |
| 693 | + <attributes> | |
| 694 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 695 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 696 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 697 | + <attribute><code>PORT_NUMBER</code><attribute>1521</attribute></attribute> | |
| 698 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 699 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 700 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 701 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 702 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 703 | + </attributes> | |
| 704 | + </connection> | |
| 705 | + <connection> | |
| 706 | + <name>外网南汇机务oracle</name> | |
| 707 | + <server>58.247.254.118</server> | |
| 708 | + <type>ORACLE</type> | |
| 709 | + <access>Native</access> | |
| 710 | + <database>orcl</database> | |
| 711 | + <port>15211</port> | |
| 712 | + <username>nhjw</username> | |
| 713 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10d09aa5cd</password> | |
| 714 | + <servername/> | |
| 715 | + <data_tablespace/> | |
| 716 | + <index_tablespace/> | |
| 717 | + <attributes> | |
| 718 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 719 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 720 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 721 | + <attribute><code>PORT_NUMBER</code><attribute>15211</attribute></attribute> | |
| 722 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 723 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 724 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 725 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 726 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 727 | + </attributes> | |
| 728 | + </connection> | |
| 729 | + <connection> | |
| 730 | + <name>外网金高机务oracle</name> | |
| 731 | + <server>58.247.254.118</server> | |
| 732 | + <type>ORACLE</type> | |
| 733 | + <access>Native</access> | |
| 734 | + <database>orcl</database> | |
| 735 | + <port>15211</port> | |
| 736 | + <username>jwgl</username> | |
| 737 | + <password>Encrypted 2be98afc86aa7f2e4cb79ce10d485a8d6</password> | |
| 738 | + <servername/> | |
| 739 | + <data_tablespace/> | |
| 740 | + <index_tablespace/> | |
| 741 | + <attributes> | |
| 742 | + <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute> | |
| 743 | + <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute> | |
| 744 | + <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute> | |
| 745 | + <attribute><code>PORT_NUMBER</code><attribute>15211</attribute></attribute> | |
| 746 | + <attribute><code>PRESERVE_RESERVED_WORD_CASE</code><attribute>N</attribute></attribute> | |
| 747 | + <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute> | |
| 748 | + <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 749 | + <attribute><code>SUPPORTS_TIMESTAMP_DATA_TYPE</code><attribute>Y</attribute></attribute> | |
| 750 | + <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute> | |
| 751 | + </attributes> | |
| 752 | + </connection> | |
| 174 | 753 | <order> |
| 175 | 754 | <hop> <from>http接口调用</from><to>JavaScript解析json生成数据</to><enabled>Y</enabled> </hop> |
| 176 | 755 | <hop> <from>获取参数</from><to>http接口调用</to><enabled>Y</enabled> </hop> |
| 177 | 756 | <hop> <from>JavaScript解析json生成数据</from><to>数据检验</to><enabled>Y</enabled> </hop> |
| 178 | 757 | <hop> <from>数据检验</from><to>数据检验错误输出</to><enabled>Y</enabled> </hop> |
| 179 | - <hop> <from>公司,分公司名称代码数据</from><to>数据检验</to><enabled>Y</enabled> </hop> | |
| 180 | 758 | <hop> <from>数据检验</from><to>待处理数据</to><enabled>Y</enabled> </hop> |
| 181 | - <hop> <from>公司,分公司名称代码数据</from><to>获取公司分公司编码</to><enabled>Y</enabled> </hop> | |
| 182 | 759 | <hop> <from>待处理数据</from><to>获取公司分公司编码</to><enabled>Y</enabled> </hop> |
| 183 | 760 | <hop> <from>判定新增/更新数据</from><to>待新增数据</to><enabled>Y</enabled> </hop> |
| 184 | 761 | <hop> <from>判定新增/更新数据</from><to>待更新数据</to><enabled>Y</enabled> </hop> |
| ... | ... | @@ -202,6 +779,8 @@ |
| 202 | 779 | <hop> <from>待处理更新数据</from><to>判断是否报废更新</to><enabled>Y</enabled> </hop> |
| 203 | 780 | <hop> <from>判断是否报废更新</from><to>是否报废且曾经配置过线路</to><enabled>Y</enabled> </hop> |
| 204 | 781 | <hop> <from>是否报废且曾经配置过线路</from><to>报废车辆管理设备数据处理</to><enabled>Y</enabled> </hop> |
| 782 | + <hop> <from>公司,分公司名称代码数据</from><to>数据检验</to><enabled>Y</enabled> </hop> | |
| 783 | + <hop> <from>公司,分公司名称代码数据</from><to>获取公司分公司编码</to><enabled>Y</enabled> </hop> | |
| 205 | 784 | </order> |
| 206 | 785 | <step> |
| 207 | 786 | <name>JavaScript解析json生成数据</name> |
| ... | ... | @@ -218,7 +797,7 @@ |
| 218 | 797 | <optimizationLevel>9</optimizationLevel> |
| 219 | 798 | <jsScripts> <jsScript> <jsScript_type>0</jsScript_type> |
| 220 | 799 | <jsScript_name>Script 1</jsScript_name> |
| 221 | - <jsScript_script>//Script here
//---------------- 数据过滤参数处理 --------------//
// 1、车辆自编号
var existParamZbh = false; // 是否存在车辆自编号参数
if (paramClzbh != null && paramClzbh != "") {
 existParamZbh = true;
}
// 2、开始时间、结束时间参数
var paramFrom_date;
var paramTo_date;
if (paramFrom != null && paramFrom != "") {
 paramFrom_date = str2date(paramFrom, 'yyyy-MM-dd HH:mm:ss');
}
if (paramTo != null && paramTo != "") {
 paramTo_date = str2date(paramTo, 'yyyy-MM-dd HH:mm:ss');
}

/**
 * 新增处理行函数。
 * @param newRow 待新增的行
 * @param jsonRow 可解析的行对象数据
 * @return false:表示外部循环break
 */
function processRow(newRow, jsonRow) {
 //------------ 根据参数,过滤记录 ---------//
 // 1、车辆自编号参数,优先级最高(其他参数不匹配了),并且只匹配一次
 if (existParamZbh) {
 if (paramClzbh == jsonRow.car_code) {
 putRow(newRow);
 return false;
 }
 return true;
 }

 // 2、开始时间,结束时间参数,两个都是必填参数,只要有一个不存在,则退出整个循环
 // 使用新增和更新时间匹配,如果又一个为null,则忽略本条数据
 if (paramFrom_date == null || paramTo_date == null) {
 return false;
 }
 // create_time为空,过滤记录
 if (jsonRow.create_time == null || jsonRow.create_time == "") {
 return true;
 }
 // 判定 paramFrom_date <= create_time <= paramTo_date
 var create_time_cov = str2date(jsonRow.create_time, 'yyyy-MM-dd HH:mm:ss');
 if (dateDiff(paramFrom_date, create_time_cov, 'ss') >= 0 && dateDiff(create_time_cov, paramTo_date, 'ss') >= 0) {
 putRow(newRow);
 return true;
 }
 // create_time不为空,不再时间范围内,update_time为空,过滤记录
 if (jsonRow.update_time == null || jsonRow.update_time == "") {
 return true;
 }
 // 判定 paramFrom_date <= update_time <= paramTo_date
 var update_time_cov = str2date(jsonRow.update_time, 'yyyy-MM-dd HH:mm:ss');
 if (dateDiff(paramFrom_date, update_time_cov, 'ss') >= 0 && dateDiff(update_time_cov, paramTo_date, 'ss') >= 0) {
 putRow(newRow);
 return true;
 }

 // TODO:其他判定参数再议
 return true;
}


var json_script = 'var jsonlist = ' + result;
eval(json_script);
for (i = 0; i < jsonlist.length; i++) {
 newRow = createRowCopy(getOutputRowMeta().size());
 var rowIndex = getInputRowMeta().size();

 //----------- 新生成字段 ----------//
 newRow[rowIndex ++] = jsonlist[i].company || null; // 公司名称
 newRow[rowIndex ++] = jsonlist[i].branch_company || null; // 分公司名称
 newRow[rowIndex ++] = jsonlist[i].company + "-" + jsonlist[i].branch_company; // 公司分公司名称合并
 newRow[rowIndex ++] = jsonlist[i].car_code || null; // 车辆自编号
 newRow[rowIndex ++] = jsonlist[i].car_plate || null; // 车牌号
 newRow[rowIndex ++] = jsonlist[i].create_time || null; // 新增时间
 newRow[rowIndex ++] = jsonlist[i].update_time || null; // 更新时间
 // newRow[rowIndex ++] = jsonlist[i].application_scrap_type || null; // 报废类型
 newRow[rowIndex ++] = jsonlist[i].apply_scarp_type || null; // 报废类型
 newRow[rowIndex ++] = jsonlist[i].car_state || null; // 车辆状态
 newRow[rowIndex ++] = jsonlist[i].cancel_date || null; // 报废日期
 
 // 处理行数据
 if (!processRow(newRow, jsonlist[i])) {
 break;
 }
}
trans_Status = SKIP_TRANSFORMATION;

// 公司名称
var gsmc;
// 分公司名称
var fgsmc;
// 公司分公司名称合并
var allgsmc;
// 车辆自编号
var clzbh;
// 车牌号
var cph;
// 新增时间
var createTime;
// 更新时间
var updateTime;
// 报废类型
var scrapType;
// 车辆状态
var carState;
// 报废时间
var scrapDate;</jsScript_script> | |
| 800 | + <jsScript_script>//Script here
//---------------- 数据过滤参数处理 --------------//
// 1、车辆自编号
var existParamZbh = false; // 是否存在车辆自编号参数
if (paramClzbh != null && paramClzbh != "") {
 existParamZbh = true;
}
// 2、开始时间、结束时间参数
var paramFrom_date;
var paramTo_date;
if (paramFrom != null && paramFrom != "") {
 paramFrom_date = str2date(paramFrom, 'yyyy-MM-dd HH:mm:ss');
}
if (paramTo != null && paramTo != "") {
 paramTo_date = str2date(paramTo, 'yyyy-MM-dd HH:mm:ss');
}

/**
 * 新增处理行函数。
 * @param newRow 待新增的行
 * @param jsonRow 可解析的行对象数据
 * @return false:表示外部循环break
 */
function processRow(newRow, jsonRow) {
 //------------ 根据参数,过滤记录 ---------//
 // 1、车辆自编号参数,优先级最高(其他参数不匹配了),并且只匹配一次
 if (existParamZbh) {
 if (paramClzbh == jsonRow.car_code) {
 putRow(newRow);
 return false;
 }
 return true;
 }

 // 2、开始时间,结束时间参数,两个都是必填参数,只要有一个不存在,则退出整个循环
 // 使用新增和更新时间匹配,如果又一个为null,则忽略本条数据
 if (paramFrom_date == null || paramTo_date == null) {
 return false;
 }
 // create_time为空,过滤记录
 if (jsonRow.create_time == null || jsonRow.create_time == "") {
 return true;
 }
 // 判定 paramFrom_date <= create_time <= paramTo_date
 var create_time_cov = str2date(jsonRow.create_time, 'yyyy-MM-dd HH:mm:ss');
 if (dateDiff(paramFrom_date, create_time_cov, 'ss') >= 0 && dateDiff(create_time_cov, paramTo_date, 'ss') >= 0) {
 putRow(newRow);
 return true;
 }
 // create_time不为空,不再时间范围内,update_time为空,过滤记录
 if (jsonRow.update_time == null || jsonRow.update_time == "") {
 return true;
 }
 // 判定 paramFrom_date <= update_time <= paramTo_date
 var update_time_cov = str2date(jsonRow.update_time, 'yyyy-MM-dd HH:mm:ss');
 if (dateDiff(paramFrom_date, update_time_cov, 'ss') >= 0 && dateDiff(update_time_cov, paramTo_date, 'ss') >= 0) {
 putRow(newRow);
 return true;
 }

 // TODO:其他判定参数再议
 return true;
}


var json_script = 'var jsonlist = ' + result;
eval(json_script);
for (i = 0; i < jsonlist.length; i++) {
 newRow = createRowCopy(getOutputRowMeta().size());
 var rowIndex = getInputRowMeta().size();

 //----------- 新生成字段 ----------//
 newRow[rowIndex ++] = jsonlist[i].company || null; // 公司名称
 newRow[rowIndex ++] = jsonlist[i].branch_company || null; // 分公司名称
 newRow[rowIndex ++] = jsonlist[i].company + "-" + jsonlist[i].branch_company; // 公司分公司名称合并
 newRow[rowIndex ++] = jsonlist[i].car_code || null; // 车辆自编号
 newRow[rowIndex ++] = jsonlist[i].car_plate || null; // 车牌号
 newRow[rowIndex ++] = jsonlist[i].create_time || null; // 新增时间
 newRow[rowIndex ++] = jsonlist[i].update_time || null; // 更新时间
 // newRow[rowIndex ++] = jsonlist[i].application_scrap_type || null; // 报废类型
 newRow[rowIndex ++] = jsonlist[i].apply_scarp_type || null; // 报废类型
 newRow[rowIndex ++] = jsonlist[i].car_state || null; // 车辆状态
 newRow[rowIndex ++] = jsonlist[i].cancel_date || null; // 报废日期
 newRow[rowIndex ++] = jsonlist[i].car_energy_type || null; // 车辆动力类型
 
 // 处理行数据
 if (!processRow(newRow, jsonlist[i])) {
 break;
 }
}
trans_Status = SKIP_TRANSFORMATION;

// 公司名称
var gsmc;
// 分公司名称
var fgsmc;
// 公司分公司名称合并
var allgsmc;
// 车辆自编号
var clzbh;
// 车牌号
var cph;
// 新增时间
var createTime;
// 更新时间
var updateTime;
// 报废类型
var scrapType;
// 车辆状态
var carState;
// 报废时间
var scrapDate;
// 车辆动力类型
var carEnergyType;
</jsScript_script> | |
| 222 | 801 | </jsScript> </jsScripts> <fields> <field> <name>gsmc</name> |
| 223 | 802 | <rename>gsmc</rename> |
| 224 | 803 | <type>String</type> |
| ... | ... | @@ -279,6 +858,12 @@ |
| 279 | 858 | <length>-1</length> |
| 280 | 859 | <precision>-1</precision> |
| 281 | 860 | <replace>N</replace> |
| 861 | + </field> <field> <name>carEnergyType</name> | |
| 862 | + <rename>carEnergyType</rename> | |
| 863 | + <type>String</type> | |
| 864 | + <length>-1</length> | |
| 865 | + <precision>-1</precision> | |
| 866 | + <replace>N</replace> | |
| 282 | 867 | </field> </fields> <cluster_schema/> |
| 283 | 868 | <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> |
| 284 | 869 | <xloc>335</xloc> |
| ... | ... | @@ -329,103 +914,6 @@ |
| 329 | 914 | </step> |
| 330 | 915 | |
| 331 | 916 | <step> |
| 332 | - <name>公司,分公司名称代码数据</name> | |
| 333 | - <type>DataGrid</type> | |
| 334 | - <description/> | |
| 335 | - <distribute>N</distribute> | |
| 336 | - <custom_distribution/> | |
| 337 | - <copies>1</copies> | |
| 338 | - <partitioning> | |
| 339 | - <method>none</method> | |
| 340 | - <schema_name/> | |
| 341 | - </partitioning> | |
| 342 | - <fields> | |
| 343 | - <field> | |
| 344 | - <name>gsmc</name> | |
| 345 | - <type>String</type> | |
| 346 | - <format/> | |
| 347 | - <currency/> | |
| 348 | - <decimal/> | |
| 349 | - <group/> | |
| 350 | - <length>100</length> | |
| 351 | - <precision>-1</precision> | |
| 352 | - <set_empty_string>N</set_empty_string> | |
| 353 | - </field> | |
| 354 | - <field> | |
| 355 | - <name>fgsmc</name> | |
| 356 | - <type>String</type> | |
| 357 | - <format/> | |
| 358 | - <currency/> | |
| 359 | - <decimal/> | |
| 360 | - <group/> | |
| 361 | - <length>100</length> | |
| 362 | - <precision>-1</precision> | |
| 363 | - <set_empty_string>N</set_empty_string> | |
| 364 | - </field> | |
| 365 | - <field> | |
| 366 | - <name>allmc</name> | |
| 367 | - <type>String</type> | |
| 368 | - <format/> | |
| 369 | - <currency/> | |
| 370 | - <decimal/> | |
| 371 | - <group/> | |
| 372 | - <length>100</length> | |
| 373 | - <precision>-1</precision> | |
| 374 | - <set_empty_string>N</set_empty_string> | |
| 375 | - </field> | |
| 376 | - <field> | |
| 377 | - <name>gsdm</name> | |
| 378 | - <type>String</type> | |
| 379 | - <format/> | |
| 380 | - <currency/> | |
| 381 | - <decimal/> | |
| 382 | - <group/> | |
| 383 | - <length>-1</length> | |
| 384 | - <precision>-1</precision> | |
| 385 | - <set_empty_string>N</set_empty_string> | |
| 386 | - </field> | |
| 387 | - <field> | |
| 388 | - <name>fgsdm</name> | |
| 389 | - <type>String</type> | |
| 390 | - <format/> | |
| 391 | - <currency/> | |
| 392 | - <decimal/> | |
| 393 | - <group/> | |
| 394 | - <length>-1</length> | |
| 395 | - <precision>-1</precision> | |
| 396 | - <set_empty_string>N</set_empty_string> | |
| 397 | - </field> | |
| 398 | - </fields> | |
| 399 | - <data> | |
| 400 | - <line> <item>上南公司</item><item>上南一分公司</item><item>上南公司-上南一分公司</item><item>55</item><item>4</item> </line> | |
| 401 | - <line> <item>上南公司</item><item>上南六分公司</item><item>上南公司-上南六分公司</item><item>55</item><item>3</item> </line> | |
| 402 | - <line> <item>上南公司</item><item>上南二分公司</item><item>上南公司-上南二分公司</item><item>55</item><item>1</item> </line> | |
| 403 | - <line> <item>上南公司</item><item>上南三分公司</item><item>上南公司-上南三分公司</item><item>55</item><item>2</item> </line> | |
| 404 | - <line> <item>南汇公司</item><item>南汇三分</item><item>南汇公司-南汇三分</item><item>26</item><item>3</item> </line> | |
| 405 | - <line> <item>南汇公司</item><item>南汇二分</item><item>南汇公司-南汇二分</item><item>26</item><item>2</item> </line> | |
| 406 | - <line> <item>南汇公司</item><item>南汇一分</item><item>南汇公司-南汇一分</item><item>26</item><item>1</item> </line> | |
| 407 | - <line> <item>南汇公司</item><item>南汇维修公司</item><item>南汇公司-南汇维修公司</item><item>26</item><item>4</item> </line> | |
| 408 | - <line> <item>南汇公司</item><item>南汇公司</item><item>南汇公司-南汇公司</item><item>26</item><item>5</item> </line> | |
| 409 | - <line> <item>南汇公司</item><item>南汇六分</item><item>南汇公司-南汇六分</item><item>26</item><item>6</item> </line> | |
| 410 | - <line> <item>金高公司</item><item>二分公司</item><item>金高公司-二分公司</item><item>22</item><item>2</item> </line> | |
| 411 | - <line> <item>金高公司</item><item>四分公司</item><item>金高公司-四分公司</item><item>22</item><item>1</item> </line> | |
| 412 | - <line> <item>金高公司</item><item>三分公司</item><item>金高公司-三分公司</item><item>22</item><item>3</item> </line> | |
| 413 | - <line> <item>金高公司</item><item>一分公司</item><item>金高公司-一分公司</item><item>22</item><item>5</item> </line> | |
| 414 | - <line> <item>杨高公司</item><item>杨高分公司</item><item>杨高公司-杨高分公司</item><item>05</item><item>5</item> </line> | |
| 415 | - <line> <item>杨高公司</item><item>周浦分公司</item><item>杨高公司-周浦分公司</item><item>05</item><item>6</item> </line> | |
| 416 | - <line> <item>杨高公司</item><item>芦潮港分公司</item><item>杨高公司-芦潮港分公司</item><item>05</item><item>3</item> </line> | |
| 417 | - <line> <item>杨高公司</item><item>川沙分公司</item><item>杨高公司-川沙分公司</item><item>05</item><item>1</item> </line> | |
| 418 | - <line> <item>杨高公司</item><item>金桥分公司</item><item>杨高公司-金桥分公司</item><item>05</item><item>2</item> </line> | |
| 419 | - </data> | |
| 420 | - <cluster_schema/> | |
| 421 | - <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> | |
| 422 | - <xloc>178</xloc> | |
| 423 | - <yloc>222</yloc> | |
| 424 | - <draw>Y</draw> | |
| 425 | - </GUI> | |
| 426 | - </step> | |
| 427 | - | |
| 428 | - <step> | |
| 429 | 917 | <name>写日志</name> |
| 430 | 918 | <type>WriteToLog</type> |
| 431 | 919 | <description/> |
| ... | ... | @@ -510,6 +998,13 @@ |
| 510 | 998 | <function>=</function> |
| 511 | 999 | <rightvalue/> |
| 512 | 1000 | <value><name>constant</name><type>Boolean</type><text>Y</text><length>-1</length><precision>-1</precision><isnull>N</isnull><mask/></value> </condition> |
| 1001 | + <condition> | |
| 1002 | + <negated>N</negated> | |
| 1003 | + <operator>OR</operator> | |
| 1004 | + <leftvalue>isSfdcUpdate</leftvalue> | |
| 1005 | + <function>=</function> | |
| 1006 | + <rightvalue/> | |
| 1007 | + <value><name>constant</name><type>Boolean</type><text>Y</text><length>-1</length><precision>-1</precision><isnull>N</isnull><mask/></value> </condition> | |
| 513 | 1008 | </conditions> |
| 514 | 1009 | </condition> |
| 515 | 1010 | </compare> |
| ... | ... | @@ -603,6 +1098,10 @@ |
| 603 | 1098 | <rename>远程_cancel_date</rename> |
| 604 | 1099 | <length>-2</length> |
| 605 | 1100 | <precision>-2</precision> |
| 1101 | + </field> <field> <name>carEnergyType</name> | |
| 1102 | + <rename>远程_car_energy_type</rename> | |
| 1103 | + <length>-2</length> | |
| 1104 | + <precision>-2</precision> | |
| 606 | 1105 | </field> <field> <name>company</name> |
| 607 | 1106 | <rename>本地_公司名称</rename> |
| 608 | 1107 | <length>-2</length> |
| ... | ... | @@ -643,6 +1142,10 @@ |
| 643 | 1142 | <rename>本地_车辆报废日期</rename> |
| 644 | 1143 | <length>-2</length> |
| 645 | 1144 | <precision>-2</precision> |
| 1145 | + </field> <field> <name>sfdc</name> | |
| 1146 | + <rename>本地_是否电车</rename> | |
| 1147 | + <length>-2</length> | |
| 1148 | + <precision>-2</precision> | |
| 646 | 1149 | </field> <select_unspecified>N</select_unspecified> |
| 647 | 1150 | </fields> <cluster_schema/> |
| 648 | 1151 | <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> |
| ... | ... | @@ -758,6 +1261,11 @@ |
| 758 | 1261 | <format/> |
| 759 | 1262 | </field> |
| 760 | 1263 | <field> |
| 1264 | + <name>远程_car_energy_type</name> | |
| 1265 | + <type>String</type> | |
| 1266 | + <format/> | |
| 1267 | + </field> | |
| 1268 | + <field> | |
| 761 | 1269 | <name>本地_公司名称</name> |
| 762 | 1270 | <type>String</type> |
| 763 | 1271 | <format/> |
| ... | ... | @@ -807,6 +1315,11 @@ |
| 807 | 1315 | <type>Timestamp</type> |
| 808 | 1316 | <format/> |
| 809 | 1317 | </field> |
| 1318 | + <field> | |
| 1319 | + <name>本地_是否电车</name> | |
| 1320 | + <type>Boolean</type> | |
| 1321 | + <format/> | |
| 1322 | + </field> | |
| 810 | 1323 | </fields> |
| 811 | 1324 | <custom> |
| 812 | 1325 | <header_font_name>arial</header_font_name> |
| ... | ... | @@ -1220,7 +1733,7 @@ |
| 1220 | 1733 | <optimizationLevel>9</optimizationLevel> |
| 1221 | 1734 | <jsScripts> <jsScript> <jsScript_type>0</jsScript_type> |
| 1222 | 1735 | <jsScript_name>Script 1</jsScript_name> |
| 1223 | - <jsScript_script>//Script here

//---------------- 新增用的字段重新命名(方便后续操作)-----------//
var insideCode_add = clzbh; // 车辆自编号
var carPlate_add = cph; // 车牌号
var carCode_add = clzbh; // 车辆编码(初始使用自编号代替)
var supplierName_add = "1"; // 供应商名称(字典:1=巴士拓华)
var businessCode_add = gsdm; // 公司代码
var company_add = gsmc; // 公司名称
var brancheCompanyCode_add = fgsdm; // 分公司代码
var brancheCompany_add = fgsmc; // 分公司名称
var equipmentCode_add = gsdm + clzbh.replace(/-/g, ""); // 设备编号(初始使用公司代码+车辆自编号去除中间-,如:S0I-039 -> 22S0I039)
var scrapState_add = 0; // 是否报废
var scrapDate_add; // 报废日期
var scrapCode_add; // 报废号
if (carState == '3' || scrapType == '1') {
 scrapState_add = 1;
 scrapDate_add = scrapDate == null ? null : str2date(scrapDate, 'yyyy-MM-dd');
 equipmentCode_add = 'BF-' + equipmentCode_add;
 scrapCode_add = 'BF-' + equipmentCode_add;
}
var createDate_add = new Date(); // 创建时间
var updateDate_add = createDate_add; // 更新时间</jsScript_script> | |
| 1736 | + <jsScript_script>//Script here

//---------------- 新增用的字段重新命名(方便后续操作)-----------//
var insideCode_add = clzbh; // 车辆自编号
var carPlate_add = cph; // 车牌号
var carCode_add = clzbh; // 车辆编码(初始使用自编号代替)
var supplierName_add = "1"; // 供应商名称(字典:1=巴士拓华)
var businessCode_add = gsdm; // 公司代码
var company_add = gsmc; // 公司名称
var brancheCompanyCode_add = fgsdm; // 分公司代码
var brancheCompany_add = fgsmc; // 分公司名称
var equipmentCode_add = gsdm + clzbh.replace(/-/g, ""); // 设备编号(初始使用公司代码+车辆自编号去除中间-,如:S0I-039 -> 22S0I039)
var scrapState_add = 0; // 是否报废
var scrapDate_add; // 报废日期
var scrapCode_add; // 报废号
var sfdc_add; // 是否电车
if (carState == '3' || scrapType == '1') {
 scrapState_add = 1;
 scrapDate_add = scrapDate == null ? null : str2date(scrapDate, 'yyyy-MM-dd');
 equipmentCode_add = 'BF-' + equipmentCode_add;
 scrapCode_add = 'BF-' + equipmentCode_add;
}
if (carEnergyType == '常规柴油') {
 sfdc_add = 0;
} else {
 sfdc_add = 1;
}
var createDate_add = new Date(); // 创建时间
var updateDate_add = createDate_add; // 更新时间</jsScript_script> | |
| 1224 | 1737 | </jsScript> </jsScripts> <fields> <field> <name>insideCode_add</name> |
| 1225 | 1738 | <rename>insideCode_add</rename> |
| 1226 | 1739 | <type>String</type> |
| ... | ... | @@ -1293,6 +1806,12 @@ |
| 1293 | 1806 | <length>-1</length> |
| 1294 | 1807 | <precision>-1</precision> |
| 1295 | 1808 | <replace>N</replace> |
| 1809 | + </field> <field> <name>sfdc_add</name> | |
| 1810 | + <rename>sfdc_add</rename> | |
| 1811 | + <type>Integer</type> | |
| 1812 | + <length>-1</length> | |
| 1813 | + <precision>-1</precision> | |
| 1814 | + <replace>N</replace> | |
| 1296 | 1815 | </field> <field> <name>createDate_add</name> |
| 1297 | 1816 | <rename>createDate_add</rename> |
| 1298 | 1817 | <type>Date</type> |
| ... | ... | @@ -1391,6 +1910,10 @@ |
| 1391 | 1910 | <stream_name>scrapCode_add</stream_name> |
| 1392 | 1911 | </field> |
| 1393 | 1912 | <field> |
| 1913 | + <column_name>sfdc</column_name> | |
| 1914 | + <stream_name>sfdc_add</stream_name> | |
| 1915 | + </field> | |
| 1916 | + <field> | |
| 1394 | 1917 | <column_name>create_date</column_name> |
| 1395 | 1918 | <stream_name>createDate_add</stream_name> |
| 1396 | 1919 | </field> |
| ... | ... | @@ -1613,6 +2136,11 @@ |
| 1613 | 2136 | <format/> |
| 1614 | 2137 | </field> |
| 1615 | 2138 | <field> |
| 2139 | + <name>sfdc_add</name> | |
| 2140 | + <type>Integer</type> | |
| 2141 | + <format/> | |
| 2142 | + </field> | |
| 2143 | + <field> | |
| 1616 | 2144 | <name>NrErrors</name> |
| 1617 | 2145 | <type>Integer</type> |
| 1618 | 2146 | <format/> |
| ... | ... | @@ -1714,7 +2242,7 @@ |
| 1714 | 2242 | <optimizationLevel>9</optimizationLevel> |
| 1715 | 2243 | <jsScripts> <jsScript> <jsScript_type>0</jsScript_type> |
| 1716 | 2244 | <jsScript_name>Script 1</jsScript_name> |
| 1717 | - <jsScript_script>//Script here

//---------------- 更新用的字段重新命名(方便后续操作)-----------//
// TODO:后面还有更多的更新字段

var update_date = new Date();

//------------ 1、公司分公司相关字段 -----------//
var company_update = gsmc; // 公司名称
var branche_company_update = fgsmc; // 分公司名称
var business_code_update = gsdm; // 公司代码
var branch_company_code_update = fgsdm; // 分公司代码
var isGsUpdate = false; // 是否更新
if (!company_update.equals(company)) {
 isGsUpdate = true;
}
if (!branche_company_update.equals(branche_company)) {
 isGsUpdate = true;
}

//------------- 2、报废相关字段 ------------//
var equipmentCode_update = equipment_code; // 设备编号
var scrapCode_update = scrap_code; // 报废号
var scrapState_update = (scrap_state == true ? 1 : 0); // 报废状态
var scrapState_update_b = scrap_state; // 报废状态
var scrapDate_update = scrap_date; // 报废日期
var isScrapUpdate = false; // 是否更新
if (carState == '3' || scrapType == '1') {
 scrapState_update_b = true;
 scrapState_update = 1;
 // 使用车辆库的报废时间
 scrapDate_update = scrapDate == null ? null : str2date(scrapDate, 'yyyy-MM-dd');
 // 车辆库报废时间为空,再使用当前时间
 if (scrapDate_update == null) {
 scrapDate_update = new Date(); // 报废日期设定位当前日期
 }
 equipmentCode_update = 'BF-' + equipmentCode_update;
 scrapCode_update = 'BF-' + equipmentCode_update;
}
if (scrapState_update_b != scrap_state) {
 isScrapUpdate = true;
}</jsScript_script> | |
| 2245 | + <jsScript_script>//Script here

//---------------- 更新用的字段重新命名(方便后续操作)-----------//
// TODO:后面还有更多的更新字段

var update_date = new Date();

//------------ 1、公司分公司相关字段 -----------//
var company_update = gsmc; // 公司名称
var branche_company_update = fgsmc; // 分公司名称
var business_code_update = gsdm; // 公司代码
var branch_company_code_update = fgsdm; // 分公司代码
var isGsUpdate = false; // 是否更新
if (!company_update.equals(company)) {
 isGsUpdate = true;
}
if (!branche_company_update.equals(branche_company)) {
 isGsUpdate = true;
}

//------------- 2、报废相关字段 ------------//
var equipmentCode_update = equipment_code; // 设备编号
var scrapCode_update = scrap_code; // 报废号
var scrapState_update = (scrap_state == true ? 1 : 0); // 报废状态
var scrapState_update_b = scrap_state; // 报废状态
var scrapDate_update = scrap_date; // 报废日期
var isScrapUpdate = false; // 是否更新
if (carState == '3' || scrapType == '1') {
 scrapState_update_b = true;
 scrapState_update = 1;
 // 使用车辆库的报废时间
 scrapDate_update = scrapDate == null ? null : str2date(scrapDate, 'yyyy-MM-dd');
 // 车辆库报废时间为空,再使用当前时间
 if (scrapDate_update == null) {
 scrapDate_update = new Date(); // 报废日期设定位当前日期
 }
 equipmentCode_update = 'BF-' + equipmentCode_update;
 scrapCode_update = 'BF-' + equipmentCode_update;
}
if (scrapState_update_b != scrap_state) {
 isScrapUpdate = true;
}
//-------------- 3、是否电车相关字段 ------------//
var sfdc_update = (carEnergyType == '常规柴油' ? 0 : 1); // 是否电车
var sfdc_update_b = (sfdc == true ? true : false); // 是否电车
var isSfdcUpdate = false; // 是否更新
if (sfdc_update_b != sfdc) { 
 isSfdcUpdate = true;
}</jsScript_script> | |
| 1718 | 2246 | </jsScript> </jsScripts> <fields> <field> <name>update_date</name> |
| 1719 | 2247 | <rename>update_date</rename> |
| 1720 | 2248 | <type>Date</type> |
| ... | ... | @@ -1787,6 +2315,24 @@ |
| 1787 | 2315 | <length>-1</length> |
| 1788 | 2316 | <precision>-1</precision> |
| 1789 | 2317 | <replace>N</replace> |
| 2318 | + </field> <field> <name>sfdc_update</name> | |
| 2319 | + <rename>sfdc_update</rename> | |
| 2320 | + <type>Integer</type> | |
| 2321 | + <length>-1</length> | |
| 2322 | + <precision>-1</precision> | |
| 2323 | + <replace>N</replace> | |
| 2324 | + </field> <field> <name>sfdc_update_b</name> | |
| 2325 | + <rename>sfdc_update_b</rename> | |
| 2326 | + <type>Boolean</type> | |
| 2327 | + <length>-1</length> | |
| 2328 | + <precision>-1</precision> | |
| 2329 | + <replace>N</replace> | |
| 2330 | + </field> <field> <name>isSfdcUpdate</name> | |
| 2331 | + <rename>isSfdcUpdate</rename> | |
| 2332 | + <type>Boolean</type> | |
| 2333 | + <length>-1</length> | |
| 2334 | + <precision>-1</precision> | |
| 2335 | + <replace>N</replace> | |
| 1790 | 2336 | </field> </fields> <cluster_schema/> |
| 1791 | 2337 | <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> |
| 1792 | 2338 | <xloc>670</xloc> |
| ... | ... | @@ -1854,6 +2400,10 @@ |
| 1854 | 2400 | <rename>branch_company_code_update</rename> |
| 1855 | 2401 | </value> |
| 1856 | 2402 | <value> |
| 2403 | + <name>sfdc</name> | |
| 2404 | + <rename>sfdc_update</rename> | |
| 2405 | + </value> | |
| 2406 | + <value> | |
| 1857 | 2407 | <name>update_date</name> |
| 1858 | 2408 | <rename>update_date</rename> |
| 1859 | 2409 | </value> |
| ... | ... | @@ -1958,6 +2508,11 @@ |
| 1958 | 2508 | <format/> |
| 1959 | 2509 | </field> |
| 1960 | 2510 | <field> |
| 2511 | + <name>sfdc_update</name> | |
| 2512 | + <type>Integer</type> | |
| 2513 | + <format/> | |
| 2514 | + </field> | |
| 2515 | + <field> | |
| 1961 | 2516 | <name>NrErrors</name> |
| 1962 | 2517 | <type>Integer</type> |
| 1963 | 2518 | <format/> |
| ... | ... | @@ -2120,6 +2675,12 @@ |
| 2120 | 2675 | <default/> |
| 2121 | 2676 | <type>String</type> |
| 2122 | 2677 | </value> |
| 2678 | + <value> | |
| 2679 | + <name>sfdc</name> | |
| 2680 | + <rename>sfdc</rename> | |
| 2681 | + <default/> | |
| 2682 | + <type>Integer</type> | |
| 2683 | + </value> | |
| 2123 | 2684 | </lookup> |
| 2124 | 2685 | <cluster_schema/> |
| 2125 | 2686 | <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> |
| ... | ... | @@ -2451,6 +3012,32 @@ |
| 2451 | 3012 | </GUI> |
| 2452 | 3013 | </step> |
| 2453 | 3014 | |
| 3015 | + <step> | |
| 3016 | + <name>公司,分公司名称代码数据</name> | |
| 3017 | + <type>TableInput</type> | |
| 3018 | + <description/> | |
| 3019 | + <distribute>N</distribute> | |
| 3020 | + <custom_distribution/> | |
| 3021 | + <copies>1</copies> | |
| 3022 | + <partitioning> | |
| 3023 | + <method>none</method> | |
| 3024 | + <schema_name/> | |
| 3025 | + </partitioning> | |
| 3026 | + <connection>control_jndi</connection> | |
| 3027 | + <sql>select gs.gsmc as gsmc
, fgs.fgsmc as fgsmc
, concat (gs.gsmc, '-', fgs.fgsmc) as allmc
, gs.gsdm as gsdm
, fgs.fgsdm as fgsdm
from
(select business_name as fgsmc
, business_code as fgsdm
, up_code gsdm 
from bsth_c_business 
where up_code in (
select business_code from bsth_c_business where up_code = '88')
) fgs left join
(select business_name as gsmc
, business_code as gsdm
from bsth_c_business
where up_code = '88'
) gs on fgs.gsdm = gs.gsdm</sql> | |
| 3028 | + <limit>0</limit> | |
| 3029 | + <lookup/> | |
| 3030 | + <execute_each_row>N</execute_each_row> | |
| 3031 | + <variables_active>N</variables_active> | |
| 3032 | + <lazy_conversion_active>N</lazy_conversion_active> | |
| 3033 | + <cluster_schema/> | |
| 3034 | + <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> | |
| 3035 | + <xloc>176</xloc> | |
| 3036 | + <yloc>220</yloc> | |
| 3037 | + <draw>Y</draw> | |
| 3038 | + </GUI> | |
| 3039 | + </step> | |
| 3040 | + | |
| 2454 | 3041 | <step_error_handling> |
| 2455 | 3042 | <error> |
| 2456 | 3043 | <source_step>JavaScript解析json生成数据</source_step> | ... | ... |