委外到货单主表数据同步 Normal 0 / ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID TRANSNAME Y TRANSNAME STATUS Y STATUS LINES_READ Y LINES_READ LINES_WRITTEN Y LINES_WRITTEN LINES_UPDATED Y LINES_UPDATED LINES_INPUT Y LINES_INPUT LINES_OUTPUT Y LINES_OUTPUT LINES_REJECTED Y LINES_REJECTED ERRORS Y ERRORS STARTDATE Y STARTDATE ENDDATE Y ENDDATE LOGDATE Y LOGDATE DEPDATE Y DEPDATE REPLAYDATE Y REPLAYDATE LOG_FIELD Y LOG_FIELD EXECUTING_SERVER N EXECUTING_SERVER EXECUTING_USER N EXECUTING_USER CLIENT N CLIENT ID_BATCH Y ID_BATCH SEQ_NR Y SEQ_NR LOGDATE Y LOGDATE TRANSNAME Y TRANSNAME STEPNAME Y STEPNAME STEP_COPY Y STEP_COPY LINES_READ Y LINES_READ LINES_WRITTEN Y LINES_WRITTEN LINES_UPDATED Y LINES_UPDATED LINES_INPUT Y LINES_INPUT LINES_OUTPUT Y LINES_OUTPUT LINES_REJECTED Y LINES_REJECTED ERRORS Y ERRORS INPUT_BUFFER_ROWS Y INPUT_BUFFER_ROWS OUTPUT_BUFFER_ROWS Y OUTPUT_BUFFER_ROWS ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID LOG_DATE Y LOG_DATE LOGGING_OBJECT_TYPE Y LOGGING_OBJECT_TYPE OBJECT_NAME Y OBJECT_NAME OBJECT_COPY Y OBJECT_COPY REPOSITORY_DIRECTORY Y REPOSITORY_DIRECTORY FILENAME Y FILENAME OBJECT_ID Y OBJECT_ID OBJECT_REVISION Y OBJECT_REVISION PARENT_CHANNEL_ID Y PARENT_CHANNEL_ID ROOT_CHANNEL_ID Y ROOT_CHANNEL_ID ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID LOG_DATE Y LOG_DATE TRANSNAME Y TRANSNAME STEPNAME Y STEPNAME STEP_COPY Y STEP_COPY LINES_READ Y LINES_READ LINES_WRITTEN Y LINES_WRITTEN LINES_UPDATED Y LINES_UPDATED LINES_INPUT Y LINES_INPUT LINES_OUTPUT Y LINES_OUTPUT LINES_REJECTED Y LINES_REJECTED ERRORS Y ERRORS LOG_FIELD N LOG_FIELD ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID LOG_DATE Y LOG_DATE METRICS_DATE Y METRICS_DATE METRICS_CODE Y METRICS_CODE METRICS_DESCRIPTION Y METRICS_DESCRIPTION METRICS_SUBJECT Y METRICS_SUBJECT METRICS_TYPE Y METRICS_TYPE METRICS_VALUE Y METRICS_VALUE 0.0 0.0 10000 50 50 N Y 50000 Y N 1000 100 - 2024/01/09 15:07:19.021 - 2024/01/09 15:07:19.021 H4sIAAAAAAAAAAMAAAAAAAAAAAA= N MOM ${MOMDB_HOST} MYSQL Native ${MOMDB_NAME} 3306 ${MOMDB_USER} ${MOMDB_PASSWORD} EXTRA_OPTION_MYSQL.characterEncoding utf-8 EXTRA_OPTION_MYSQL.defaultFetchSize 5000 EXTRA_OPTION_MYSQL.rewriteBatchedStatements true EXTRA_OPTION_MYSQL.useCompression true EXTRA_OPTION_MYSQL.useCursorFetch true EXTRA_OPTION_MYSQL.useServerPrepStmts true FORCE_IDENTIFIERS_TO_LOWERCASE N FORCE_IDENTIFIERS_TO_UPPERCASE N IS_CLUSTERED N PORT_NUMBER 3306 PRESERVE_RESERVED_WORD_CASE Y QUOTE_ALL_FIELDS N STREAM_RESULTS N SUPPORTS_BOOLEAN_DATA_TYPE Y SUPPORTS_TIMESTAMP_DATA_TYPE Y USE_POOLING N U8 ${U8DB_HOST} MSSQL Native ${U8DB_NAME} 1433 ${U8DB_USER} ${U8DB_PASSWORD} EXTRA_OPTION_MSSQL.instance dbo FORCE_IDENTIFIERS_TO_LOWERCASE N FORCE_IDENTIFIERS_TO_UPPERCASE N IS_CLUSTERED N MSSQL_DOUBLE_DECIMAL_SEPARATOR N PORT_NUMBER 1433 PRESERVE_RESERVED_WORD_CASE Y QUOTE_ALL_FIELDS N SUPPORTS_BOOLEAN_DATA_TYPE Y SUPPORTS_TIMESTAMP_DATA_TYPE Y USE_POOLING N 插入 / 更新 复制记录到结果 Y Java 代码-id 插入 / 更新 Y 表输入 Java 代码-id Y Java 代码-id UserDefinedJavaClass Y 1 none TRANSFORM_CLASS Processor //import com.cath.set.util.CodeRuleUtil; import com.cath.util.SnowflakeIdWorkerUtil; SnowflakeIdWorkerUtil snowflakeIdWorkerUtil = new SnowflakeIdWorkerUtil(3, 5, 5); public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException { if (first) { first = false; } Object[] r = getRow(); if (r == null) { setOutputDone(); return false; } r = createOutputRow(r, data.outputRowMeta.size()); //String taskCode = get(Fields.In, "interface_code").getString(r); //get(Fields.Out, "task_code").setValue(r, taskCode); String id = String.valueOf(snowflakeIdWorkerUtil.nextId()); get(Fields.Out, "id").setValue(r, id); putRow(data.outputRowMeta, r); return true; } id String -1 -1 N

304 96 Y 复制记录到结果 RowsToResult Y 1 none

608 96 Y 插入 / 更新 InsertUpdate Y 1 none MOM 1000 Y wms_task_in interface_id interface_id = bill_type bill_type = interface_id interface_id N interface_code interface_code N id id N bill_type bill_type N task_type task_type N task_date task_date N task_code task_code N dept_code dept_code N employee_code employee_code N supplier_code supplier_code N create_id sync_id N create_by sync_name N create_time sync_time N

448 96 Y 表输入 TableInput Y 1 none U8 DECLARE @USER_NAME VARCHAR(50),@USER_ID INT,@BEGIN_DATE DATE,@END_DATE DATE SET @USER_NAME = CASE '${USER_NAME}' WHEN '' THEN '管理员（kettle）' ELSE '${USER_NAME}' END SET @USER_ID = CASE 0${USER_ID} WHEN 0 THEN 1 ELSE 0${USER_ID} END SET @BEGIN_DATE = CASE '${BEGIN_DATE}' WHEN '' THEN CONVERT(VARCHAR(100), GETDATE(), 23) ELSE '${BEGIN_DATE}' END SET @END_DATE = CASE '${BEGIN_DATE}' WHEN '' THEN CONVERT(VARCHAR(100), GETDATE(), 23) ELSE '${END_DATE}' END SELECT T1.ID AS interface_id ,T1.cCode AS interface_code ,1 AS task_type --1入库、-1入库退、-1出库、1出库退 ,3 AS bill_type --1生产订单、2委外订单、3委外到货单、4采购订单、5采购到货单、6销售订单、7销售发货单 ,'IT3-'+T1.cCode AS task_code ,CONVERT(DATE,T1.dDate) AS task_date ,T1.cDepCode AS dept_code ,T1.cPersonCode AS employee_code ,T1.cVenCode AS supplier_code ,@USER_NAME AS sync_name ,@USER_ID AS sync_id ,GETDATE() AS sync_time FROM PU_ArrivalVouch T1 WHERE 1=1 AND T1.iBillType =0 --1退货、0到货 AND T1.cBusType ='委外加工' AND ISNULL(T1.cverifier,'') <>'' AND EXISTS(SELECT 1 FROM PU_ArrivalVouchs T WHERE ID =T1.ID AND ISNULL(fValidInQuan,0) =0) AND CONVERT(DATE,T1.dDate) BETWEEN @BEGIN_DATE AND @END_DATE 0 N Y N N Integer normal interface_id 9 0 表输入 interface_id ####0;-####0 . , none N Y 0 N N N zh_CN Asia/Shanghai N String normal interface_code 30 -1 表输入 interface_code . , none N Y 0 N N N zh_CN Asia/Shanghai N Integer normal task_type 9 0 表输入 task_type ####0;-####0 . , none N Y 0 N N N zh_CN Asia/Shanghai N Integer normal bill_type 9 0 表输入 bill_type ####0;-####0 . , none N Y 0 N N N zh_CN Asia/Shanghai N String normal task_code 34 -1 表输入 task_code . , none N Y 0 N N N zh_CN Asia/Shanghai N String normal task_date 10 -1 表输入 task_date . , none N Y 0 N N N zh_CN Asia/Shanghai N String normal dept_code 12 -1 表输入 dept_code . , none N Y 0 N N N zh_CN Asia/Shanghai N String normal employee_code 20 -1 表输入 employee_code . , none N Y 0 N N N zh_CN Asia/Shanghai N String normal supplier_code 20 -1 表输入 supplier_code . , none N Y 0 N N N zh_CN Asia/Shanghai N String normal sync_name 16 -1 表输入 sync_name . , none N Y 0 N N N zh_CN Asia/Shanghai N Integer normal sync_id 9 0 表输入 sync_id ####0;-####0 . , none N Y 0 N N N zh_CN Asia/Shanghai N Timestamp normal sync_time 3 -1 表输入 sync_time . , none N Y 0 N N N zh_CN Asia/Shanghai N

144 96 Y N