| | |
| | | } |
| | | |
| | | /** |
| | | * @description 获取发送外部消息 |
| | | */ |
| | | export function getOutMessage (config) { |
| | | let message = 'false' |
| | | |
| | | let filterBtn = (cell) => { |
| | | if (['pop', 'exec', 'form', 'prompt', 'formSubmit'].includes(cell.OpenType) && cell.verify) { |
| | | if (cell.verify.noteEnable === 'true' || cell.verify.wxNote === 'true' || cell.verify.emailEnable === 'true') { |
| | | message = 'true' |
| | | } |
| | | } |
| | | } |
| | | |
| | | let traversal = (components) => { |
| | | if (!components || message === 'true') return |
| | | |
| | | components.forEach(item => { |
| | | if (item.type === 'tabs') { |
| | | item.subtabs.forEach(tab => { |
| | | traversal(tab.components) |
| | | }) |
| | | } else if (item.type === 'group') { |
| | | traversal(item.components) |
| | | } else { |
| | | if (item.action) { |
| | | item.action.forEach(cell => { |
| | | if (cell.OpenType === 'popview') { |
| | | if (cell.config) { |
| | | traversal(cell.config.components) |
| | | } |
| | | } else { |
| | | filterBtn(cell) |
| | | } |
| | | }) |
| | | } |
| | | |
| | | if (item.type === 'card' || item.type === 'carousel' || item.type === 'timeline') { |
| | | item.subcards.forEach(card => { |
| | | card.elements && card.elements.forEach(cell => { |
| | | if (cell.eleType !== 'button') return |
| | | |
| | | if (cell.OpenType === 'popview') { |
| | | if (cell.config) { |
| | | traversal(cell.config.components) |
| | | } |
| | | } else { |
| | | filterBtn(cell) |
| | | } |
| | | }) |
| | | card.backElements && card.backElements.forEach(cell => { |
| | | if (cell.eleType !== 'button') return |
| | | |
| | | if (cell.OpenType === 'popview') { |
| | | if (cell.config) { |
| | | traversal(cell.config.components) |
| | | } |
| | | } else { |
| | | filterBtn(cell) |
| | | } |
| | | }) |
| | | }) |
| | | } else if (item.type === 'balcony') { |
| | | item.elements && item.elements.forEach(cell => { |
| | | if (cell.eleType !== 'button') return |
| | | |
| | | if (cell.OpenType === 'popview') { |
| | | if (cell.config) { |
| | | traversal(cell.config.components) |
| | | } |
| | | } else { |
| | | filterBtn(cell) |
| | | } |
| | | }) |
| | | } else if (item.type === 'table') { |
| | | let loopCol = (cols) => { |
| | | cols.forEach(col => { |
| | | if (col.type === 'colspan') { |
| | | loopCol(col.subcols) |
| | | } else if (col.type === 'custom') { |
| | | col.elements.forEach(cell => { |
| | | if (cell.eleType !== 'button') return |
| | | |
| | | if (cell.OpenType === 'popview') { |
| | | if (cell.config) { |
| | | traversal(cell.config.components) |
| | | } |
| | | } else { |
| | | filterBtn(cell) |
| | | } |
| | | }) |
| | | } |
| | | }) |
| | | } |
| | | loopCol(item.cols) |
| | | } else if (item.type === 'form') { |
| | | item.subcards.forEach(group => { |
| | | filterBtn(group.subButton) |
| | | }) |
| | | } |
| | | } |
| | | }) |
| | | } |
| | | |
| | | traversal(config.components) |
| | | |
| | | return message |
| | | } |
| | | |
| | | /** |
| | | * @description 检测组件内容 |
| | | */ |
| | | export function checkComponent (card) { |
| | |
| | | } |
| | | |
| | | if (['exec', 'prompt', 'pop', 'form', 'formSubmit'].includes(cell.OpenType)) { |
| | | if (cell.Ot !== 'requiredOnce' && ['pop', 'form'].includes(cell.OpenType) && cell.verify && cell.verify.uniques && cell.verify.uniques.length > 0) { |
| | | let forms = ['BID'] |
| | | |
| | | if (cell.OpenType === 'form') { |
| | | forms.push(cell.field) |
| | | } else if (cell.modal && cell.modal.fields.length > 0) { |
| | | cell.modal.fields.forEach(n => { |
| | | if (!n.field) return |
| | | forms.push(n.field) |
| | | }) |
| | | } |
| | | let emptys = [] |
| | | cell.verify.uniques.forEach(m => { |
| | | if (m.status === 'false') return |
| | | |
| | | m.field.split(',').forEach(n => { |
| | | if (!forms.includes(n)) { |
| | | emptys.push(n) |
| | | } |
| | | }) |
| | | }) |
| | | |
| | | if (emptys.length) { |
| | | errors.push({ level: 0, detail: `按钮“${cell.label}”唯一性验证字段${emptys.join('、')},在表单中不存在!`}) |
| | | } |
| | | } |
| | | |
| | | if (cell.OpenType === 'form' && cell.formType === 'count_line') return |
| | | |
| | | if (cell.intertype === 'system') { |
| | |
| | | let _quot = sql.match(/'{1}/g) |
| | | let _lparen = sql.match(/\({1}/g) |
| | | let _rparen = sql.match(/\){1}/g) |
| | | let _ch_b = sql.match(/\$check@/ig) |
| | | let _ch_d = sql.match(/@check\$/ig) |
| | | let _m_b = sql.match(/\$@/ig) |
| | | let _m_d = sql.match(/@\$/ig) |
| | | |
| | | _quot = _quot ? _quot.length : 0 |
| | | _lparen = _lparen ? _lparen.length : 0 |
| | | _rparen = _rparen ? _rparen.length : 0 |
| | | _ch_b = _ch_b ? _ch_b.length : 0 |
| | | _ch_d = _ch_d ? _ch_d.length : 0 |
| | | _m_b = _m_b ? _m_b.length : 0 |
| | | _m_d = _m_d ? _m_d.length : 0 |
| | | |
| | | if (_quot % 2 !== 0) { |
| | | notification.warning({ |
| | |
| | | notification.warning({ |
| | | top: 92, |
| | | message: 'sql中()必须成对出现', |
| | | duration: 5 |
| | | }) |
| | | return false |
| | | } else if (_ch_b !== _ch_d) { |
| | | notification.warning({ |
| | | top: 92, |
| | | message: 'sql中 $check@ 与 @check$ 必须成对出现', |
| | | duration: 5 |
| | | }) |
| | | return false |
| | | } else if (_m_b !== _m_d) { |
| | | notification.warning({ |
| | | top: 92, |
| | | message: 'sql中 $@ 与 @$ 必须成对出现', |
| | | duration: 5 |
| | | }) |
| | | return false |
| | |
| | | /** |
| | | * @description 获取执行脚本 |
| | | */ |
| | | export function getAllSqls (config) { |
| | | export function getAllSqls (conf) { |
| | | let config = fromJS(conf).toJS() |
| | | |
| | | let sqls = [] |
| | | let urlFields = config.urlFields |
| | | let appType = sessionStorage.getItem('appType') |
| | | let process = config.process === 'true' |
| | | let sysVars = ['loginuid', 'sessionuid', 'userid', 'appkey', 'lang', 'username', 'fullname', 'menuname'] |
| | | |
| | | let filterComponent = (components, mainSearch) => { |
| | | if (urlFields) { |
| | | urlFields = urlFields.map(n => n.toLowerCase()) |
| | | } |
| | | |
| | | let callback = ` |
| | | COMMIT TRAN |
| | | set NOCOUNT ON |
| | | RETURN |
| | | END TRY |
| | | BEGIN CATCH |
| | | ROLLBACK TRAN |
| | | DECLARE @ErrorMessage NVARCHAR(4000); |
| | | DECLARE @ErrorSeverity INT; |
| | | DECLARE @ErrorState INT; |
| | | |
| | | set @ErrorCode=cast(ERROR_NUMBER() as nvarchar(50)) |
| | | set @retmsg=ERROR_MESSAGE(); |
| | | select @ErrorMessage=ERROR_MESSAGE(), @ErrorSeverity=ERROR_SEVERITY(), @ErrorState=ERROR_STATE(); |
| | | |
| | | RAISERROR(@ErrorMessage, @ErrorSeverity, @ErrorState); |
| | | END CATCH |
| | | |
| | | aaa: |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | GOTO_RETURN: |
| | | ROLLBACK TRAN` |
| | | |
| | | let filterComponent = (components, mainSearch, label = '') => { |
| | | components.forEach(item => { |
| | | item.$menuname = (config.MenuName || '') + label + '-' + (item.name || '') |
| | | |
| | | if (item.type === 'tabs') { |
| | | item.subtabs.forEach(tab => { |
| | | let _mainSearch = mainSearch || [] |
| | |
| | | _mainSearch = com.search || [] |
| | | }) |
| | | } |
| | | filterComponent(tab.components, _mainSearch) |
| | | filterComponent(tab.components, _mainSearch, label) |
| | | }) |
| | | } else if (item.type === 'group') { |
| | | filterComponent(item.components, mainSearch) |
| | | filterComponent(item.components, mainSearch, label) |
| | | } else { |
| | | if (item.wrap && item.setting) { |
| | | if (item.wrap.datatype === 'public' || item.wrap.datatype === 'static') { |
| | |
| | | |
| | | if (appType === 'mob' && item.type !== 'search' && item.type !== 'topbar' && item.search && item.search.length > 0) { |
| | | item.search = [] |
| | | } |
| | | if (appType !== 'mob' && item.search && item.search.length > 0) { |
| | | item.search.forEach(cell => { |
| | | if (['select', 'link', 'multiselect', 'checkcard', 'radio'].includes(cell.type) && cell.resourceType === '1' && cell.dataSource) { |
| | | let msg = getFormSql(cell, '搜索') |
| | | |
| | | sqls.push({uuid: cell.uuid, type: 'sForm', ...msg}) |
| | | } |
| | | }) |
| | | } |
| | | |
| | | if (item.subtype === 'tablecard') { // 兼容 |
| | |
| | | item.setting.laypage = 'false' |
| | | item.setting.$top = true |
| | | } |
| | | item.setting.$name = item.$menuname || '' |
| | | |
| | | let msg = getDataSource(item, mainSearch) |
| | | |
| | | sqls.push({uuid: item.uuid, ...msg}) |
| | | sqls.push({uuid: item.uuid, type: 'datasource', ...msg}) |
| | | } else if (item.setting && item.setting.useMSearch === 'true') { |
| | | let searches = item.search || [] |
| | | if (mainSearch.length > 0) { |
| | |
| | | |
| | | resetButton(item, cell) |
| | | }) |
| | | } else if (item.subtype === 'editable' && col.editable === 'true') { |
| | | if (col.editType === 'select' && col.resourceType === '1') { |
| | | let msg = getFormSql(col, '表单') |
| | | |
| | | sqls.push({uuid: col.uuid, type: 'tbForm', ...msg}) |
| | | } else if (col.editType === 'popSelect') { |
| | | if (col.pops) { |
| | | col.pops.forEach(n => { |
| | | let msg = getPopSelectSql(n) |
| | | |
| | | sqls.push({uuid: n.uuid, type: 'popSource', ...msg}) |
| | | }) |
| | | } else { |
| | | let msg = getPopSelectSql(col) |
| | | |
| | | sqls.push({uuid: col.uuid, type: 'popSource', ...msg}) |
| | | } |
| | | } |
| | | } |
| | | }) |
| | | } |
| | |
| | | getCols(item.cols) |
| | | |
| | | if (item.subtype === 'editable' && item.submit.intertype === 'system') { |
| | | // let sql = this.getEditTableSql(item.submit, item.cols, item.columns) |
| | | item.submit.logLabel = item.$menuname + '-提交' |
| | | let msg = getEditTableSql(item.submit, item.cols, item.columns, item.setting) |
| | | |
| | | sqls.push({uuid: 'submit_' + item.uuid, type: 'editable', ...msg}) |
| | | } |
| | | } else if (item.type === 'card' || item.type === 'carousel' || item.type === 'timeline') { |
| | | item.subcards && item.subcards.forEach(card => { |
| | |
| | | } |
| | | |
| | | let resetButton = (item, cell, isback) => { |
| | | cell.logLabel = item.$menuname + '-' + cell.label |
| | | |
| | | if (['exec', 'prompt', 'pop', 'form', 'formSubmit'].includes(cell.OpenType)) { |
| | | if (cell.intertype === 'system' || cell.procMode === 'system') { // 系统接口 |
| | | if (cell.verify && cell.verify.linkEnable === 'true' && /@/.test(cell.verify.linkUrl)) { |
| | | cell.returnValue = 'true' |
| | | } |
| | | if (item.subtype === 'dualdatacard' && isback) { |
| | | let _item = fromJS(item).toJS() |
| | | _item.columns = _item.subColumns || [] |
| | |
| | | |
| | | let msg = getSysDefaultSql(cell, _item) |
| | | |
| | | sqls.push({uuid: cell.uuid, ...msg}) |
| | | sqls.push({uuid: cell.uuid, type: 'button', ...msg}) |
| | | } else { |
| | | let msg = getSysDefaultSql(cell, item) |
| | | |
| | | sqls.push({uuid: cell.uuid, ...msg}) |
| | | sqls.push({uuid: cell.uuid, type: 'button', ...msg}) |
| | | } |
| | | } |
| | | if (cell.callbackType === 'script' && cell.verify && cell.verify.cbScripts) { |
| | | // if (item.subtype === 'dualdatacard' && isback) { |
| | | // let _item = fromJS(item).toJS() |
| | | // _item.columns = _item.subColumns || [] |
| | | // _item.setting.primaryKey = _item.setting.subKey |
| | | if (item.subtype === 'dualdatacard' && isback) { |
| | | let _item = fromJS(item).toJS() |
| | | _item.columns = _item.subColumns || [] |
| | | |
| | | // getSysDefaultSql(cell, _item, true) |
| | | // } else { |
| | | |
| | | // getSysDefaultSql(cell, item, true) |
| | | // } |
| | | let msg = getSysBackSql(cell, _item) |
| | | |
| | | // let backSql = this.getSysBackSql(cell.verify.cbScripts, cell.cbTable) |
| | | sqls.push({uuid: 'back_' + cell.uuid, type: 'btnCallBack', ...msg}) |
| | | } else { |
| | | let msg = getSysBackSql(cell, item) |
| | | |
| | | // if (backSql) { |
| | | // backSql = `${defSql} |
| | | // ${backSql} |
| | | // ` |
| | | sqls.push({uuid: 'back_' + cell.uuid, type: 'btnCallBack', ...msg}) |
| | | } |
| | | } |
| | | if (['pop', 'formSubmit'].includes(cell.OpenType) && cell.modal && cell.modal.fields) { |
| | | cell.modal.fields.forEach(form => { |
| | | // 数据源sql语句,预处理,权限黑名单字段设置为隐藏表单 |
| | | if (['select', 'link', 'multiselect', 'radio', 'checkbox', 'checkcard'].includes(form.type) && form.resourceType === '1') { |
| | | let msg = getFormSql(form, '表单') |
| | | |
| | | // if (cell.output) { |
| | | // backSql += ` |
| | | // aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg,${cell.output} as mk_b_id` |
| | | // } else { |
| | | // backSql += ` |
| | | // aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg` |
| | | // } |
| | | |
| | | // backSql = backSql.replace(/@typename@/ig, `'typename'`) |
| | | // backSql = backSql.replace(/@\$|\$@/ig, '').replace(/@datam@/ig, `''`) |
| | | // } |
| | | sqls.push({uuid: md5(cell.uuid + form.uuid), type: 'form', ...msg}) |
| | | } else if (form.type === 'popSelect') { |
| | | let msg = getPopSelectSql(form) |
| | | |
| | | sqls.push({uuid: form.uuid, type: 'popSource', ...msg}) |
| | | } |
| | | }) |
| | | } |
| | | } else if (cell.OpenType === 'excelIn') { |
| | | if (cell.intertype === 'system') { |
| | | // sql = this.getExcelInSql(cell, process) |
| | | let msg = getExcelInSql(cell) |
| | | |
| | | sqls.push({uuid: cell.uuid, type: 'excelIn', ...msg}) |
| | | } |
| | | } else if (cell.OpenType === 'excelOut') { |
| | | if (cell.intertype === 'system' && cell.verify && cell.verify.dataType === 'custom') { |
| | | // sql = this.getExcelOutSql(cell, item) |
| | | let msg = getExcelOutSql(cell, item) |
| | | |
| | | sqls.push({uuid: cell.uuid, type: 'excelOut', ...msg}) |
| | | } |
| | | } else if (cell.OpenType === 'funcbutton') { |
| | | if (cell.funcType === 'print') { |
| | | |
| | | if (cell.intertype === 'system' && cell.verify && cell.verify.dataType === 'custom') { |
| | | let msg = getPrintSql(cell, item) |
| | | |
| | | sqls.push({uuid: cell.uuid, type: 'print', ...msg}) |
| | | } |
| | | if (cell.execMode === 'pop' && cell.modal && cell.modal.fields) { |
| | | cell.modal.fields.forEach(form => { |
| | | // 数据源sql语句,预处理,权限黑名单字段设置为隐藏表单 |
| | | if (['select', 'link', 'multiselect', 'radio', 'checkbox', 'checkcard'].includes(form.type) && form.resourceType === '1') { |
| | | let msg = getFormSql(form, '表单') |
| | | |
| | | sqls.push({uuid: md5(cell.uuid + form.uuid), type: 'form', ...msg}) |
| | | } else if (form.type === 'popSelect') { |
| | | let msg = getPopSelectSql(form) |
| | | |
| | | sqls.push({uuid: form.uuid, type: 'popSource', ...msg}) |
| | | } |
| | | }) |
| | | } |
| | | } else if ((cell.funcType === 'refund' || cell.funcType === 'pay') && cell.payMode === 'system') { |
| | | // sql = this.getPaySql(cell, item) |
| | | let msg = getPaySql(cell, item) |
| | | |
| | | sqls.push({uuid: cell.uuid, type: 'pay', ...msg}) |
| | | } |
| | | } else if (cell.OpenType === 'innerpage' || cell.OpenType === 'outerpage') { |
| | | if (cell.pageTemplate === 'pay' && cell.payMode === 'system') { |
| | | // sql = this.getPaySql(cell, item) |
| | | let msg = getPaySql(cell, item) |
| | | |
| | | sqls.push({uuid: cell.uuid, type: 'pay', ...msg}) |
| | | } |
| | | } else if (cell.OpenType === 'popview') { |
| | | if (cell.config && cell.config.components) { |
| | |
| | | }) |
| | | } |
| | | |
| | | filterComponent(cell.config.components, _mainSearch) |
| | | filterComponent(cell.config.components, _mainSearch, '-' + cell.label) |
| | | } |
| | | } |
| | | } |
| | | |
| | | let getSearches = (searches) => { |
| | | let sFields = [] |
| | | let query = false |
| | | searches.forEach(item => { |
| | | if (!item.field) return |
| | | |
| | |
| | | } else { |
| | | sFields.push(item.field) |
| | | } |
| | | |
| | | if (query) return |
| | | |
| | | query = item.query !== 'false' |
| | | }) |
| | | |
| | | return { sFields, query } |
| | | return sFields |
| | | } |
| | | |
| | | let getSysDefaultSql = (btn, component) => { |
| | |
| | | verify.invalid = 'false' |
| | | } else if (btn.Ot === 'notRequired') { |
| | | verify.invalid = 'false' |
| | | } |
| | | } |
| | | if (verify.uniques && verify.uniques.length > 0 && btn.Ot === 'requiredOnce') { |
| | | if (component.wrap && (component.wrap.datatype === 'static' || component.wrap.datatype === 'public')) { |
| | | verify.uniques = [] |
| | | } |
| | | } |
| | | |
| | |
| | | key: item.field, |
| | | fieldlen: item.fieldlength || 50, |
| | | writein: item.writein !== 'false', |
| | | type: item.type |
| | | type: item.type, |
| | | isconst: item.constant === 'true' |
| | | } |
| | | |
| | | |
| | | if (_item.type === 'datemonth') { |
| | | _item.type = 'text' |
| | | } else if (_item.type === 'number' || _item.type === 'rate') { |
| | |
| | | _initFormfields.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } else if (form.type === 'select' || form.type === 'link' || form.type === 'radio') { |
| | | _initFormfields.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } else if (form.isconst) { |
| | | _initFormfields.push(`@${_key}=N'@mk_${_key}_mk@'`) |
| | | } else { |
| | | _initFormfields.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } |
| | |
| | | select @tbid='', @ErrorCode='',@retmsg='' |
| | | select @tbid='X' from ${datasource} right join (select ID from dbo.SplitComma(@ID@)) sp |
| | | on tb.${primaryKey} =sp.id where tb.${primaryKey} is null |
| | | |
| | | |
| | | If @tbid!='' |
| | | Begin |
| | | select @ErrorCode='E',@retmsg='数据已失效' |
| | |
| | | item.field.split(',').forEach((_field, index) => { |
| | | let _key = _field.toLowerCase() |
| | | let _val = '' |
| | | let _val2 = '' |
| | | |
| | | arr.push(_key) |
| | | if (_key === 'bid') { // 表单中没有bid则使用系统bid变量 |
| | |
| | | } |
| | | |
| | | _fieldValue.push(`${_key}=${_val}`) |
| | | _value.push(`${_labels[index] || ''}:${_val || ''}`) |
| | | |
| | | if (_key === 'bid') { // 表单中没有bid则使用系统bid变量 |
| | | _val2 = `' + ${BID} + '` |
| | | } else { |
| | | _val2 = `@mk_${_key}_mk@` |
| | | } |
| | | |
| | | _value.push(`${_labels[index] || ''}:${_val2}`) |
| | | }) |
| | | |
| | | if (!arr.includes(primaryKey.toLowerCase())) { |
| | |
| | | _sql += ` |
| | | /* 同类数据验证 */ |
| | | Set @tbid='' |
| | | |
| | | |
| | | Select top 1 @tbid='X' from (select distinct ${item.field},1 as n from ${datasource} inner join (select ID from dbo.SplitComma(@ID@)) sp on tb.${primaryKey}=sp.ID ) a having sum(n)>1 |
| | | |
| | | |
| | | If @tbid!='' |
| | | Begin |
| | | Set @ErrorCode='E' Set @retmsg='${item.fieldlabel} 值不唯一' |
| | |
| | | let _key = item.key.toLowerCase() |
| | | |
| | | keys.push(_key) |
| | | values.push('@mk_' + _key + '_mk@') |
| | | values.push('@' + _key) |
| | | }) |
| | | |
| | | if (!keys.includes(primaryKey.toLowerCase())) { |
| | |
| | | let _key = item.key.toLowerCase() |
| | | |
| | | _arr.push(_key) |
| | | _form.push(_key + '=@mk_' + _key + '_mk@') |
| | | _form.push(_key + '=@' + _key) |
| | | }) |
| | | |
| | | if (_actionType === 'audit') { |
| | |
| | | select @works_flow_statuscharone=statuscharone,@works_flow_statuschartwo=statuschartwo,@works_flow_statuscharthree=statuscharthree,@works_flow_statuscharfour=statuscharfour,@works_flow_statuscharfive=statuscharfive,@works_flow_key_id=id,@s_my_works_flow_log_param=works_flow_param,@s_my_works_flow_log_status=status,@s_my_works_flow_log_statusname=statusname,@s_my_works_flow_log_detail_id=works_flow_detail_id |
| | | from s_my_works_flow where works_flow_id=@ID@ and works_flow_code=@works_flow_code@ and deleted=0 |
| | | |
| | | if @works_flow_statuscharone!='' and @works_flow_statuschartwo!='' and @works_flow_statuscharthree!='' and @works_flow_statuscharfour!='' and @works_flow_statuscharfive!='' |
| | | if @works_flow_statuscharone + @works_flow_statuschartwo + @works_flow_statuscharthree + @works_flow_statuscharfour + @works_flow_statuscharfive = @works_flow_sign_values@ |
| | | begin |
| | | set @works_flow_key_status='Y' |
| | | end |
| | |
| | | } |
| | | |
| | | if (verify.workFlow === 'true' && process) { |
| | | // works_flow_error 流程错误 |
| | | // works_flow_countersign 会签/或签 标记 |
| | | // works_begin_branch 驳回至开始分支(line.mknode === 'startEdge') |
| | | // works_flow_sign_field 会签 标记字段 statuscharone/statuschartwo/statuscharthree/statuscharfour/statuscharfive |
| | | // works_flow_sign_label 会签 标记值 ***/***/已审核 |
| | | let worksReFields = ['works_flow_error', 'works_flow_countersign', 'works_begin_branch', 'works_flow_sign_label', 'start_type', 'check_type', 'notice_type', 'check_userids', 'notice_userids', 'works_flow_sign', 'works_flow_code', 'works_flow_name', 'works_flow_param', 'works_flow_detail_id', 'status', 'statusname', 'work_group', 'work_grade'] |
| | | worksReFields.forEach(n => { |
| | | _sql = _sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | if (verify.flowType === 'start') { |
| | | _sql = _sql.replace(/@start_type@/ig, `'开始'`) |
| | | // works_flow_error 流程错误 |
| | | let worksReFields = ['works_flow_error', 'works_flow_code', 'works_flow_name', 'works_flow_param', 'works_flow_detail_id', 'status', 'statusname', 'work_group', 'work_grade'] |
| | | worksReFields.forEach(n => { |
| | | _sql = _sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | } else { |
| | | _sql = _sql.replace(/@check_type@/ig, verify.flowType === 'reject' ? `'驳回'` : `'审核'`) |
| | | _sql = _sql.replace(/@notice_type@/ig, `'抄送'`) |
| | | // works_flow_error 流程错误 |
| | | // works_flow_countersign 会签/或签标记 会签为 Y |
| | | // works_begin_branch 驳回至开始分支(line.mknode === 'startEdge') |
| | | // works_flow_sign_field 会签 标记字段 statuscharone/statuschartwo/statuscharthree/statuscharfour/statuscharfive |
| | | // works_flow_sign_label 会签 标记值 ***/***/已审核 |
| | | // works_flow_sign_values 会签标记拼接值(除本人外) |
| | | let worksReFields = ['works_flow_error', 'works_flow_countersign', 'works_flow_sign_values', 'works_begin_branch', 'works_flow_sign_label', 'works_flow_code', 'works_flow_name', 'works_flow_param', 'works_flow_detail_id', 'status', 'statusname', 'work_group', 'work_grade', 'check_userids', 'notice_userids', 'works_flow_sign'] |
| | | worksReFields.forEach(n => { |
| | | _sql = _sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | } |
| | | } |
| | | |
| | | if (btn.procMode === 'system') { |
| | | // if (btn.procMode === 'system' || btn.returnValue === 'true') { |
| | | // _sql += ` |
| | | // aaa: if @ErrorCode!='' |
| | | // insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode, @retmsg,@UserID@` |
| | | // } else if (btn.output) { |
| | | // _sql += ` |
| | | // aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg,${btn.output} as mk_b_id` |
| | | // } else { |
| | | // _sql += ` |
| | | // aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg` |
| | | // } |
| | | |
| | | if (/@ErrorCode='(ENT|NNT|FNT|NMNT|CNT|-2NT)'/ig.test(_sql)) { |
| | | _sql = _sql.replace(/@ErrorCode='(ENT|NNT|FNT|NMNT|CNT|-2NT)'[\S\s]+\sgoto\s+aaa($|\s)/ig, (word) => { |
| | | return word.replace(/goto aaa/, 'goto mk_ent') |
| | | }) |
| | | _sql += ` |
| | | aaa: if @ErrorCode!='' |
| | | insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode, @retmsg,@UserID@` |
| | | if 1=2 |
| | | begin |
| | | mk_ent: |
| | | set @ErrorCode=left(@ErrorCode,1) |
| | | end |
| | | ` |
| | | } |
| | | |
| | | if (btn.procMode === 'system' || btn.returnValue === 'true') { |
| | | _sql += callback |
| | | } else if (btn.output) { |
| | | _sql += ` |
| | | aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg,${btn.output} as mk_b_id` |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg,${btn.output} as mk_b_id |
| | | ${callback} |
| | | ` |
| | | } else { |
| | | _sql += ` |
| | | aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg` |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ${callback} |
| | | ` |
| | | } |
| | | |
| | | let syses = ['UserName', 'FullName', 'RoleID', 'mk_departmentcode', 'mk_organization', 'mk_user_type', 'mk_nation', 'mk_province', 'mk_city', 'mk_district', 'mk_address'] |
| | |
| | | columns.forEach(col => { |
| | | let _key = col.field.toLowerCase() |
| | | |
| | | if (formkeys.includes(_key) || !new RegExp('@' + _key + '[^0-9a-z_]', 'ig').test(_sql)) return |
| | | if (_key === 'id' && !/@id[^0-9a-z_@]/ig.test(_sql)) return |
| | | if (formkeys.includes(_key) || !new RegExp('@' + _key + '[^0-9a-z_@]', 'ig').test(_sql)) return |
| | | // if (_key === 'id' && !/@id[^0-9a-z_@]/ig.test(_sql)) return |
| | | |
| | | colreps.push(col.field) |
| | | |
| | |
| | | |
| | | let reps = [] |
| | | let decSql = [`@tbid nvarchar(50),@ErrorCode nvarchar(50),@retmsg nvarchar(4000),@BillCode nvarchar(50),@BVoucher nvarchar(50),@FIBVoucherDate nvarchar(50), @FiYear nvarchar(50),@ModularDetailCode nvarchar(50),@mk_deleted int,@bid nvarchar(50)`] |
| | | let secSql = [`@ErrorCode='',@retmsg='', @BillCode='',@BVoucher='',@FIBVoucherDate='',@FiYear='',@ModularDetailCode='', @mk_deleted=1, @bid=@BID@`] |
| | | let secSql = [`@ErrorCode='S',@retmsg='', @BillCode='',@BVoucher='',@FIBVoucherDate='',@FiYear='',@ModularDetailCode='', @mk_deleted=1, @bid=@BID@`] |
| | | |
| | | syses.forEach(s => { |
| | | if (new RegExp('@' + s + '[^0-9a-z_]', 'ig').test(_sql)) { |
| | |
| | | |
| | | decSql = [...decSql, ..._declares] |
| | | |
| | | let regs = ['ID', 'BID', 'time_id', 'datam', 'LoginUID', 'SessionUid', 'UserID', 'Appkey', 'lang', 'typename'] |
| | | // INSERT INTO s_paas_api_log (appkey,api_name,api_count,menuname,createuserid,createuser,createstaff,cdefine1,cdefine2) |
| | | // SELECT @appkey@,'sPC_TableData_InUpDe',1,@menuname@,@UserID@,@username@,@fullname@,@SessionUid@,@LoginUID@ |
| | | _sql = `/* ${btn.logLabel} */ |
| | | BEGIN TRY |
| | | begin TRAN |
| | | |
| | | Declare ${decSql.join(',')} |
| | | /* 凭证及用户信息初始化赋值 */ |
| | | select ${secSql.join(',')} |
| | | ${_sql} |
| | | ` |
| | | |
| | | let regs = ['ID', 'BID', 'time_id', 'datam', 'typename'] |
| | | |
| | | regs.forEach(s => { |
| | | if (new RegExp('@' + s + '@', 'ig').test(_sql)) { |
| | |
| | | } |
| | | }) |
| | | |
| | | _sql = `Declare ${decSql.join(',')} |
| | | /* 凭证及用户信息初始化赋值 */ |
| | | select ${secSql.join(',')} |
| | | ${_sql} |
| | | ` |
| | | _sql = _sql.replace(/\n\s{8,10}/g, '\n') |
| | | let map = new Map() |
| | | reps.push(...sysVars) |
| | | reps = reps.filter(n => { |
| | | if (map.has(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | map.set(n.toLowerCase(), true) |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps.forEach(n => { |
| | | _sql = _sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | |
| | | _sql = _sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | |
| | | if (/\$check@|@check\$/ig.test(_sql)) { |
| | | _sql = _sql.replace(/\$check@/ig, '@mk_check_begin@').replace(/@check\$/ig, '@mk_check_end@') |
| | | reps.push('mk_check_begin', 'mk_check_end') |
| | | if (btn.procMode === 'system') { |
| | | if (/\$check@|@check\$/ig.test(_sql)) { |
| | | _sql = _sql.replace(/\$check@|@check\$/ig, '') |
| | | } |
| | | } else { |
| | | if (/\$check@|@check\$/ig.test(_sql)) { |
| | | _sql = _sql.replace(/\$check@/ig, '@mk_check_begin@').replace(/@check\$/ig, '@mk_check_end@') |
| | | reps.push('mk_check_begin', 'mk_check_end') |
| | | } |
| | | } |
| | | if (/@db@/ig.test(_sql)) { |
| | | reps.push('db') |
| | | } |
| | | |
| | | reps = Array.from(new Set([...reps, ...colreps])) |
| | | _sql = _sql.replace(/\n\x20{8,10}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | colreps = Array.from(new Set(colreps)) |
| | | reps = [...reps, ...colreps] |
| | | |
| | | return { LText: _sql, reps } |
| | | return { LText: _sql, md5: md5(_sql), reps } |
| | | } |
| | | |
| | | let getDataSource = (item, mainSearch = []) => { |
| | | let getSysBackSql = (btn, component) => { |
| | | let verify = btn.verify || {} |
| | | let columns = component.columns || [] |
| | | let colreps = [] // 待替换变量集 |
| | | let _prev = '' |
| | | let _back = '' |
| | | let tables = [] |
| | | let reps = [] |
| | | |
| | | verify.cbScripts.forEach(script => { |
| | | if (script.status === 'false') return |
| | | |
| | | if (/\s#[a-z0-9_]+(\s|\()/ig.test(script.sql)) { |
| | | tables.push(...script.sql.match(/\s#[a-z0-9_]+(\s|\()/ig)) |
| | | } |
| | | |
| | | if (script.position === 'front') { |
| | | _prev += ` |
| | | /* 自定义脚本 */ |
| | | ${script.sql} |
| | | ` |
| | | } else { |
| | | _back += ` |
| | | /* 自定义脚本 */ |
| | | ${script.sql} |
| | | ` |
| | | } |
| | | }) |
| | | |
| | | tables = tables.map(tb => tb.replace(/\s|\(/g, '')) |
| | | |
| | | // 需要声明的变量集 |
| | | let _vars = ['tbid', 'errorcode', 'retmsg', 'billcode', 'bvoucher', 'fibvoucherdate', 'fiyear', 'username', 'fullname', 'modulardetailcode', 'roleid', 'mk_departmentcode', 'mk_organization', 'mk_user_type', 'mk_nation', 'mk_province', 'mk_city', 'mk_district', 'mk_address', 'mk_deleted', 'bid'] |
| | | |
| | | let _sql = '' |
| | | |
| | | let _initFormfields = [] |
| | | let _declares = [] |
| | | |
| | | let formdata = null |
| | | let formkeys = [] |
| | | if (btn.OpenType === 'pop' || btn.OpenType === 'formSubmit') { |
| | | formdata = [] |
| | | if (btn.modal && btn.modal.fields) { |
| | | btn.modal.fields.forEach(item => { |
| | | if (!item.field) return |
| | | |
| | | let _item = { |
| | | key: item.field, |
| | | fieldlen: item.fieldlength || 50, |
| | | writein: item.writein !== 'false', |
| | | type: item.type, |
| | | isconst: item.constant === 'true' |
| | | } |
| | | |
| | | if (_item.type === 'datemonth') { |
| | | _item.type = 'text' |
| | | } else if (_item.type === 'number' || _item.type === 'rate') { |
| | | _item.fieldlen = item.decimal || 0 |
| | | } else if (_item.type === 'date') { |
| | | _item.type = item.declareType === 'nvarchar(50)' ? 'text' : 'date' |
| | | } else if (_item.type === 'datetime') { |
| | | _item.type = 'date' |
| | | } else if (item.declare === 'decimal') { |
| | | _item.type = 'number' |
| | | _item.fieldlen = item.decimal || 0 |
| | | } |
| | | |
| | | formdata.push(_item) |
| | | }) |
| | | } |
| | | } else if (btn.OpenType === 'form') { |
| | | formdata = [] |
| | | |
| | | let item = { |
| | | type: 'text', |
| | | readin: true, |
| | | writein: true, |
| | | fieldlen: 50, |
| | | key: btn.field |
| | | } |
| | | if (btn.formType === 'counter') { |
| | | item.type = 'number' |
| | | item.fieldlen = 0 |
| | | } else if (btn.formType === 'switch' || btn.formType === 'radio') { |
| | | if (typeof(btn.openVal) === 'number') { |
| | | item.type = 'number' |
| | | item.fieldlen = 0 |
| | | } |
| | | } |
| | | formdata.push(item) |
| | | } |
| | | |
| | | // 获取字段键值对 |
| | | formdata && formdata.forEach(form => { |
| | | let _key = form.key.toLowerCase() |
| | | |
| | | if (!formkeys.includes(_key)) { |
| | | formkeys.push(_key) |
| | | if (form.type === 'number' || form.type === 'rate') { |
| | | _initFormfields.push(`@${_key}=@mk_${_key}_mk@`) |
| | | } else if (form.type === 'date') { |
| | | _initFormfields.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } else if (form.type === 'select' || form.type === 'link' || form.type === 'radio') { |
| | | _initFormfields.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } else if (form.isconst) { |
| | | _initFormfields.push(`@${_key}=N'@mk_${_key}_mk@'`) |
| | | } else { |
| | | _initFormfields.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } |
| | | } |
| | | |
| | | if (!_vars.includes(_key)) { |
| | | _vars.push(_key) |
| | | |
| | | if (form.fieldlen && form.fieldlen > 4000) { |
| | | form.fieldlen = 'max' |
| | | } |
| | | |
| | | let _type = `nvarchar(${form.fieldlen})` |
| | | |
| | | if (form.type.match(/date/ig)) { |
| | | _type = 'datetime' |
| | | } else if (form.type === 'number') { |
| | | _type = `decimal(18,${form.fieldlen})` |
| | | } else if (form.type === 'rate') { |
| | | _type = `decimal(18,2)` |
| | | } |
| | | |
| | | _declares.push(`@${_key} ${_type}`) |
| | | } |
| | | }) |
| | | |
| | | // 表单变量赋值 |
| | | if (_initFormfields.length > 0) { |
| | | _sql += ` |
| | | /* 表单变量赋值 */ |
| | | select ${_initFormfields.join(',')} |
| | | ` |
| | | } |
| | | |
| | | let testSql = _prev + _back + (btn.output || '') |
| | | |
| | | // 添加数据中字段,表单值优先(按钮不选行或多行拼接时跳过) |
| | | if (btn.Ot !== 'notRequired' && columns.length > 0) { |
| | | let _initColfields = [] |
| | | columns.forEach(col => { |
| | | let _key = col.field.toLowerCase() |
| | | |
| | | if (formkeys.includes(_key) || !new RegExp('@' + _key + '[^0-9a-z_@]', 'ig').test(testSql)) return |
| | | // if (_key === 'id' && !/@id[^0-9a-z_@]/ig.test(testSql)) return |
| | | |
| | | colreps.push(col.field) |
| | | |
| | | if (col.type === 'number') { |
| | | _initColfields.push(`@${_key}=@mk_${_key}_mk@`) |
| | | } else { |
| | | _initColfields.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } |
| | | |
| | | if (!_vars.includes(_key)) { |
| | | _declares.push(`@${_key} ${col.datatype || 'nvarchar(50)'}`) |
| | | } |
| | | }) |
| | | |
| | | // 显示列变量赋值 |
| | | if (_initColfields.length > 0) { |
| | | _sql += ` |
| | | /* 显示列变量赋值 */ |
| | | select ${_initColfields.join(',')} |
| | | ` |
| | | } |
| | | } |
| | | |
| | | _sql += ` |
| | | ${_prev} |
| | | /* 外部接口入参 */ |
| | | @mk_outer_params@ |
| | | ${_back} |
| | | ` |
| | | |
| | | // if (btn.output) { |
| | | // _sql += ` |
| | | // aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg,${btn.output} as mk_b_id` |
| | | // } else { |
| | | // _sql += ` |
| | | // aaa: select @ErrorCode as ErrorCode,@retmsg as retmsg` |
| | | // } |
| | | if (/@ErrorCode='(ENT|NNT|FNT|NMNT|CNT|-2NT)'/ig.test(_sql)) { |
| | | _sql = _sql.replace(/@ErrorCode='(ENT|NNT|FNT|NMNT|CNT|-2NT)'[\S\s]+\sgoto\s+aaa($|\s)/ig, (word) => { |
| | | return word.replace(/goto aaa/, 'goto mk_ent') |
| | | }) |
| | | _sql += ` |
| | | if 1=2 |
| | | begin |
| | | mk_ent: |
| | | set @ErrorCode=left(@ErrorCode,1) |
| | | end |
| | | ` |
| | | } |
| | | if (btn.output) { |
| | | _sql += ` |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg,${btn.output} as mk_b_id |
| | | ${callback} |
| | | ` |
| | | } else { |
| | | _sql += ` |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ${callback} |
| | | ` |
| | | } |
| | | |
| | | let syses = ['tbid', 'BillCode', 'BVoucher', 'FIBVoucherDate', 'FiYear', 'ModularDetailCode', 'mk_deleted', 'bid', 'UserName', 'FullName', 'RoleID', 'mk_departmentcode', 'mk_organization', 'mk_user_type', 'mk_nation', 'mk_province', 'mk_city', 'mk_district', 'mk_address'] |
| | | let decSql = [`@ErrorCode nvarchar(50),@retmsg nvarchar(4000)`] |
| | | let secSql = [`@ErrorCode='S',@retmsg=''`] |
| | | |
| | | syses.forEach(s => { |
| | | if (new RegExp('@' + s + '[^0-9a-z_]', 'ig').test(_sql)) { |
| | | if (['RoleID', 'mk_departmentcode', 'mk_organization'].includes(s)) { |
| | | decSql.push(`@${s} nvarchar(512)`) |
| | | } else if (['mk_address'].includes(s)) { |
| | | decSql.push(`@mk_address nvarchar(100)`) |
| | | } else if (['mk_deleted'].includes(s)) { |
| | | secSql.push(`@mk_deleted int`) |
| | | } else { |
| | | decSql.push(`@${s} nvarchar(50)`) |
| | | } |
| | | if (['tbid', 'BillCode', 'BVoucher', 'FIBVoucherDate', 'FiYear', 'ModularDetailCode'].includes(s)) { |
| | | secSql.push(`@${s}=''`) |
| | | } else if (['mk_deleted'].includes(s)) { |
| | | secSql.push(`@mk_deleted=1`) |
| | | } else if (['bid'].includes(s)) { |
| | | secSql.push(`@bid=@BID@`) |
| | | } else { |
| | | secSql.push(`@${s}=@${s}@`) |
| | | reps.push(s) |
| | | } |
| | | } |
| | | }) |
| | | |
| | | decSql = [...decSql, ..._declares] |
| | | |
| | | _sql = `/* ${btn.logLabel}(回调) */ |
| | | BEGIN TRY |
| | | begin TRAN |
| | | |
| | | Declare ${decSql.join(',')} |
| | | /* 初始化赋值 */ |
| | | select ${secSql.join(',')} |
| | | ${_sql} |
| | | ` |
| | | |
| | | let regs = ['ID', 'BID', 'time_id', 'datam', 'typename'] |
| | | |
| | | regs.forEach(s => { |
| | | if (new RegExp('@' + s + '@', 'ig').test(_sql)) { |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | let map = new Map() |
| | | reps.push(...sysVars) |
| | | reps = reps.filter(n => { |
| | | if (map.has(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | map.set(n.toLowerCase(), true) |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps.forEach(n => { |
| | | _sql = _sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | |
| | | if (/\$@/ig.test(_sql)) { |
| | | _sql = _sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | if (/@db@/ig.test(_sql)) { |
| | | reps.push('db') |
| | | } |
| | | |
| | | _sql = _sql.replace(/\n\x20{8,10}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps = [...reps, ...colreps] |
| | | |
| | | return { LText: _sql, md5: md5(_sql), reps, tbs: tables } |
| | | } |
| | | |
| | | let getDataSource = (item, mainSearch = [], type) => { |
| | | if (!item.setting || item.setting.interType !== 'system') return |
| | | |
| | | item.setting.primaryKey = item.setting.primaryKey || 'ID' |
| | | let searches = item.search || [] |
| | | if (item.setting.useMSearch === 'true' && mainSearch.length > 0) { |
| | | searches = [...searches, ...mainSearch] |
| | | } |
| | | item.$searches = fromJS(searches).toJS() |
| | | let { sFields, query } = getSearches(searches) |
| | | let sFields = getSearches(searches) |
| | | |
| | | let _columns = [] |
| | | if (item.subtype === 'dualdatacard') { |
| | |
| | | } |
| | | }) |
| | | |
| | | // if (_customScript || _tailScript) { |
| | | // _tailScript += `${_tailScript} |
| | | // aaa: |
| | | // if @ErrorCode!='' |
| | | // insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode, @retmsg,@UserID@ |
| | | // ` |
| | | // } |
| | | |
| | | let _search = '' |
| | | if (item.setting.execute !== 'false') { |
| | | _dataresource = item.setting.dataresource || '' |
| | | _search = '@mk_search@' |
| | | } |
| | | |
| | | if (type === 'print') { |
| | | _search = '' |
| | | } |
| | | |
| | | if (/\s/.test(_dataresource)) { |
| | |
| | | |
| | | item.setting.dataresource = _dataresource |
| | | item.setting.customScript = _customScript |
| | | |
| | | let _search = '@search@' |
| | | if (item.setting.queryType === 'statistics' || !query) { |
| | | _search = '' |
| | | } |
| | | |
| | | let testSql = _dataresource + _customScript + _tailScript |
| | | |
| | | let decSql = [`@ErrorCode nvarchar(50),@retmsg nvarchar(4000)`] |
| | | let secSql = [`@ErrorCode='',@retmsg =''`] |
| | | let secSql = [`@ErrorCode='S',@retmsg =''`] |
| | | |
| | | let reps = [] |
| | | if (_customScript || _tailScript) { |
| | | reps.push('UserID', 'time_id') |
| | | } |
| | | |
| | | let syses = ['UserName', 'FullName', 'RoleID', 'mk_departmentcode', 'mk_organization', 'mk_user_type', 'mk_nation', 'mk_province', 'mk_city', 'mk_district', 'mk_address'] |
| | | syses.forEach(s => { |
| | |
| | | } |
| | | }) |
| | | |
| | | decSql = `declare ${decSql.join(',')} |
| | | select ${secSql.join(',')}` |
| | | decSql = `declare ${decSql.join(',')}${type === 'print' ? '@mk_print_declare@' : ''} |
| | | select ${secSql.join(',')}${type === 'print' ? '@mk_print_select@' : ''}` |
| | | |
| | | // 不需要单引号:orderBy、pageSize、pageIndex、db |
| | | let regs = [...sFields, 'orderBy', 'pageSize', 'pageIndex', 'typename', 'datam', 'ID', 'BID', 'LoginUID', 'SessionUid', 'UserID', 'Appkey', 'lang', 'typename'] |
| | | let regs = [...sFields, 'orderBy', 'pageSize', 'pageIndex', 'ID', 'BID', 'time_id', 'datam', 'typename'] |
| | | |
| | | if (item.hasExtend) { |
| | | regs.push('mk_time') |
| | |
| | | } |
| | | if (window.GLOB.getLocation) { |
| | | regs.push('mk_longitude', 'mk_latitude') |
| | | } |
| | | if (window.GLOB.externalDatabase !== null) { |
| | | regs.push('db') |
| | | } |
| | | if (urlFields) { |
| | | regs.push(...urlFields) |
| | |
| | | let LText = '' |
| | | let DateCount = '' |
| | | if (_dataresource) { |
| | | /*system_query*/ |
| | | if (/@pageSize@|@orderBy@|@mk_total/i.test(testSql)) { |
| | | LText = `/*system_query*/select ${arr_field} from ${_dataresource} ${_search} ` |
| | | LText = `select ${arr_field} from ${_dataresource} ${_search} ` |
| | | } else if (item.setting.laypage === 'true' && item.setting.order) { |
| | | LText = `/*system_query*/select top @pageSize@ ${arr_field} from (select ${arr_field} ,ROW_NUMBER() over(order by @orderBy@) as rows from ${_dataresource} ${_search}) tmptable where rows > @mk_rows_begin@ order by tmptable.rows ` |
| | | reps.push('pageSize', 'orderBy', 'mk_rows_begin') |
| | | LText = `select top @pageSize@ ${arr_field} from (select ${arr_field} ,ROW_NUMBER() over(order by @orderBy@) as rows from ${_dataresource} ${_search}) tmptable where rows > @pageSize@ * (@pageIndex@ - 1) order by tmptable.rows ` |
| | | reps.push('pageSize', 'orderBy', 'pageIndex') |
| | | if (item.subtype === 'dualdatacard') { |
| | | DateCount = `/*system_query*/select count(1) as total from (select distinct ${item.setting.primaryKey} from ${_dataresource} ${_search})a` |
| | | DateCount = `select count(1) as total from (select distinct ${item.setting.primaryKey || 'ID'} from ${_dataresource} ${_search})a` |
| | | } else { |
| | | DateCount = `/*system_query*/select count(1) as total from ${_dataresource} ${_search}` |
| | | DateCount = `select count(1) as total from ${_dataresource} ${_search}` |
| | | } |
| | | } else if (item.setting.$top) { |
| | | if (item.setting.order) { |
| | | LText = `/*system_query*/select top 1 ${arr_field} from ${_dataresource} ${_search} order by @orderBy@ ` |
| | | LText = `select top 1 ${arr_field} from ${_dataresource} ${_search} order by @orderBy@ ` |
| | | reps.push('orderBy') |
| | | } else { |
| | | LText = `/*system_query*/select top 1 ${arr_field} from ${_dataresource} ${_search} ` |
| | | LText = `select top 1 ${arr_field} from ${_dataresource} ${_search} ` |
| | | } |
| | | } else if (item.setting.$fixOrder) { |
| | | LText = `select ${arr_field} from ${_dataresource} ${_search} order by ${item.setting.order} ` |
| | | } else if (item.setting.order) { |
| | | LText = `/*system_query*/select ${arr_field} from ${_dataresource} ${_search} order by @orderBy@ ` |
| | | LText = `select ${arr_field} from ${_dataresource} ${_search} order by @orderBy@ ` |
| | | reps.push('orderBy') |
| | | } else { |
| | | LText = `/*system_query*/select ${arr_field} from ${_dataresource} ${_search} ` |
| | | LText = `select ${arr_field} from ${_dataresource} ${_search} ` |
| | | } |
| | | } |
| | | |
| | | if (_customScript) { |
| | | _customScript = `${decSql} |
| | | ${_customScript} |
| | | let sub_name = '' |
| | | let tabid = '' |
| | | let parid = '' |
| | | let sub_field = '' |
| | | |
| | | if (item.subtype === 'dualdatacard') { |
| | | arr_field = item.columns.map(col => col.field).join(',') |
| | | sub_name = item.setting.subdata |
| | | tabid = item.setting.primaryKey || '' |
| | | parid = item.setting.subBID || '' |
| | | sub_field = item.subColumns.map(col => col.field).join(',') |
| | | } |
| | | |
| | | // INSERT INTO s_paas_api_log (appkey,api_name,api_count,menuname,createuserid,createuser,createstaff,cdefine1,cdefine2) |
| | | // SELECT @appkey@,'sPC_Get_TableData',1,@menuname@,@UserID@,@username@,@fullname@,@SessionUid@,@LoginUID@ |
| | | let sql = '' |
| | | |
| | | if (item.setting.transact === 'true') { |
| | | sql = `/* ${item.setting.$name} */ |
| | | BEGIN TRY |
| | | begin TRAN |
| | | |
| | | SELECT obj_name='@mk_obj_name@',prm_field='',str_field='', |
| | | arr_field='${arr_field}',tabid='${tabid}',parid='${parid}',sub_name='${sub_name}',sub_field='${sub_field}' |
| | | ` |
| | | if (DateCount) { |
| | | DateCount = `${DateCount} |
| | | ${_tailScript} |
| | | aaa: |
| | | if @ErrorCode!='' |
| | | insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode,@retmsg,@UserID@ |
| | | ` |
| | | } else if (LText) { |
| | | LText = `${LText} |
| | | ${_tailScript} |
| | | aaa: |
| | | if @ErrorCode!='' |
| | | insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode,@retmsg,@UserID@ |
| | | ` |
| | | } else { |
| | | _customScript = `${_customScript} |
| | | ${_tailScript} |
| | | aaa: |
| | | if @ErrorCode!='' |
| | | insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode, @retmsg,@UserID@ |
| | | ` |
| | | } |
| | | } else if (_tailScript && DateCount) { |
| | | LText = `${decSql} |
| | | ${LText} |
| | | ` |
| | | DateCount = `${DateCount} |
| | | ${_tailScript} |
| | | aaa: |
| | | if @ErrorCode!='' |
| | | insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode, @retmsg,@UserID@ |
| | | ` |
| | | } else if (_tailScript) { |
| | | LText = `${decSql} |
| | | ${LText} |
| | | ${_tailScript} |
| | | aaa: |
| | | if @ErrorCode!='' |
| | | insert into tmp_err_retmsg (ID, ErrorCode, retmsg, CreateUserID) select @time_id@,@ErrorCode, @retmsg,@UserID@ |
| | | |
| | | _tailScript = `${_tailScript} |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ${callback} |
| | | ` |
| | | } else { |
| | | LText = `${decSql} |
| | | ${LText} |
| | | sql = `/* ${item.setting.$name} */ |
| | | SELECT obj_name='@mk_obj_name@',prm_field='',str_field='', |
| | | arr_field='${arr_field}',tabid='${tabid}',parid='${parid}',sub_name='${sub_name}',sub_field='${sub_field}' |
| | | ` |
| | | |
| | | _tailScript = `${_tailScript} |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ` |
| | | } |
| | | |
| | | reps = Array.from(new Set(reps)) |
| | | if (DateCount) { |
| | | sql += `UNION ALL |
| | | SELECT obj_name='DateCount',prm_field='total',str_field='', |
| | | arr_field='',tabid='',parid='',sub_name='',sub_field='' |
| | | ` |
| | | } |
| | | // sql += `UNION ALL |
| | | // SELECT obj_name='mk_error_code',prm_field='ErrorCode,retmsg',str_field='', |
| | | // arr_field='',tabid='',parid='',sub_name='',sub_field='' |
| | | // ` |
| | | sql += ` |
| | | ${decSql} |
| | | ${_customScript} |
| | | ${LText} |
| | | ${DateCount} |
| | | ${_tailScript} |
| | | ` |
| | | |
| | | LText = LText.replace(/\n\s{6,8}/g, '\n') |
| | | DateCount = DateCount.replace(/\n\s{6,8}/g, '\n') |
| | | _customScript = _customScript.replace(/\n\s{6,8}/g, '\n') |
| | | let map = new Map() |
| | | reps.push(...sysVars) |
| | | reps = reps.filter(n => { |
| | | if (map.has(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | reps.forEach(n => { |
| | | if (['orderBy', 'pageSize', 'pageIndex', 'mk_rows_begin'].includes(n)) return |
| | | map.set(n.toLowerCase(), true) |
| | | |
| | | LText = LText.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | DateCount = DateCount.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | _customScript = _customScript.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | return true |
| | | }) |
| | | if (/\$@/ig.test(testSql)) { |
| | | LText = LText.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | DateCount = DateCount.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | _customScript = _customScript.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | |
| | | reps.forEach(n => { |
| | | if (['orderBy', 'pageSize', 'pageIndex'].includes(n)) return |
| | | |
| | | sql = sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | if (/\$@/ig.test(sql)) { |
| | | sql = sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | if (/@db@/ig.test(sql)) { |
| | | reps.push('db') |
| | | } |
| | | reps.push('mk_obj_name') |
| | | |
| | | sql = sql.replace(/\n\x20{6,8}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | return {LText: sql, md5: md5(sql), reps, luser: /@userid@/ig.test(testSql)} |
| | | } |
| | | |
| | | let getExcelInSql = (item) => { |
| | | let btn = item.verify |
| | | let sheet = item.sheet.replace(/@db@/ig, '') |
| | | let database = '' |
| | | if (/@db@/ig.test(item.sheet)) { |
| | | database = '@db@' |
| | | } |
| | | |
| | | let sql = '' |
| | | |
| | | return {LText, DateCount, customScript: _customScript, reps} |
| | | let _initCustomScript = '' // 初始化脚本 |
| | | let _prevCustomScript = '' // 默认sql前执行脚本 |
| | | let _backCustomScript = '' // 默认sql后执行脚本 |
| | | let _regs = [ |
| | | {reg: new RegExp('(^|\\s)@' + sheet + '(\\s|$)', 'ig'), value: ` #${sheet} `}, |
| | | {reg: new RegExp('(^|\\s)@' + sheet + '\\(', 'ig'), value: ` #${sheet}(`}, |
| | | {reg: new RegExp('(^|\\s)@' + sheet + '\\)', 'ig'), value: ` #${sheet})`}, |
| | | ] |
| | | |
| | | btn.scripts && btn.scripts.forEach(script => { |
| | | if (script.status === 'false') return |
| | | |
| | | let _sql = script.sql |
| | | |
| | | _regs.forEach(item => { |
| | | _sql = _sql.replace(item.reg, item.value) |
| | | }) |
| | | |
| | | if (script.position === 'init') { |
| | | _initCustomScript += ` |
| | | /* 自定义脚本 */ |
| | | ${_sql} |
| | | ` |
| | | } else if (script.position === 'front') { |
| | | _prevCustomScript += ` |
| | | /* 自定义脚本 */ |
| | | ${_sql} |
| | | ` |
| | | } else { |
| | | _backCustomScript += ` |
| | | /* 自定义脚本 */ |
| | | ${_sql} |
| | | ` |
| | | } |
| | | }) |
| | | |
| | | let _uniquesql = '' |
| | | if (btn.uniques && btn.uniques.length > 0) { |
| | | let textFields = [] |
| | | let numberFields = [] |
| | | let dateFields = [] |
| | | btn.columns.forEach((col) => { |
| | | if (/Nvarchar/ig.test(col.type)) { |
| | | textFields.push(col.Column) |
| | | } else if (/Decimal|int/ig.test(col.type)) { |
| | | numberFields.push(col.Column) |
| | | } else if (/date/ig.test(col.type)) { |
| | | dateFields.push(col.Column) |
| | | } |
| | | }) |
| | | btn.uniques.forEach(unique => { |
| | | if (unique.status === 'false' || !unique.verifyType) return |
| | | |
| | | let _fields = unique.field.split(',') |
| | | let _fields_ = _fields.map(_field => `a.${_field}=b.${_field}`) |
| | | _fields_ = _fields_.join(' and ') |
| | | |
| | | let _where = [] |
| | | _fields.forEach(f => { |
| | | if (textFields.includes(f)) { |
| | | _where.push(`${f}!=''`) |
| | | } else if (numberFields.includes(f)) { |
| | | _where.push(`${f}!=0`) |
| | | } else if (dateFields.includes(f)) { |
| | | _where.push(`${f}>'1949-10-01'`) |
| | | } |
| | | }) |
| | | _where = _where.length ? `where ${_where.join(' and ')} ` : '' |
| | | |
| | | if (unique.verifyType === 'logic' || unique.verifyType === 'logic_temp') { |
| | | _fields_ += ' and b.deleted=0' |
| | | } |
| | | |
| | | let _afields = [] |
| | | _fields = _fields.map(f => { |
| | | if (numberFields.includes(f)) { |
| | | _afields.push(`cast(a.${f} as nvarchar(50))`) |
| | | return `cast(${f} as nvarchar(50))` |
| | | } else if (dateFields.includes(f)) { |
| | | _afields.push(`CONVERT(nvarchar(50), a.${f}, 21)`) |
| | | return `CONVERT(nvarchar(50), ${f}, 21)` |
| | | } |
| | | _afields.push(`a.${f}`) |
| | | |
| | | return f |
| | | }) |
| | | |
| | | _uniquesql += ` |
| | | /* 重复性验证 */ |
| | | Set @tbid='' |
| | | Select top 1 @tbid=${_fields.join('+\' \'+')} from (select 1 as n,${unique.field} from #${sheet} ) a group by ${unique.field} having sum(n)>1 |
| | | |
| | | If @tbid!='' |
| | | Begin |
| | | select @ErrorCode='${unique.errorCode}',@retmsg=@tbid+' 重复' |
| | | goto aaa |
| | | end |
| | | |
| | | ${unique.verifyType.indexOf('temp') === -1 ? `Set @tbid='' |
| | | Select top 1 @tbid=${_afields.join('+\' \'+')} from ${_where ? `(select * from #${sheet} ${_where})` : `#${sheet}`} a Inner join ${sheet} b on ${_fields_} |
| | | |
| | | If @tbid!='' |
| | | Begin |
| | | select @ErrorCode='${unique.errorCode}',@retmsg=@tbid+' 与已有数据重复' |
| | | goto aaa |
| | | end` : ''} |
| | | ` |
| | | }) |
| | | } |
| | | |
| | | let declarefields = [] |
| | | let fields = [] |
| | | |
| | | btn.columns.forEach(col => { |
| | | if (col.import === 'false') return |
| | | |
| | | if (col.type === 'date') { |
| | | declarefields.push(`${col.Column} Nvarchar(50)`) |
| | | } else { |
| | | declarefields.push(`${col.Column} ${col.type}`) |
| | | } |
| | | fields.push(col.Column) |
| | | }) |
| | | |
| | | fields = fields.join(',') |
| | | |
| | | let _insert = '' |
| | | if (btn.default !== 'false') { |
| | | _insert = ` |
| | | /* 默认sql */ |
| | | Insert into ${database}${sheet} (${fields},createuserid,createuser,createstaff,bid) |
| | | Select ${fields},@UserID@,@username,@fullname,@BID@ From #${sheet} |
| | | ` |
| | | } |
| | | |
| | | sql = `/* ${item.logLabel} */ |
| | | BEGIN TRY |
| | | begin TRAN |
| | | |
| | | create table #${sheet} (${declarefields.join(',')},jskey nvarchar(50),BID nvarchar(50)) |
| | | Declare @ErrorCode nvarchar(50),@retmsg nvarchar(4000),@tbid Nvarchar(512)@mk_init_declare@ |
| | | |
| | | Select @ErrorCode='S',@retmsg=''@mk_init_select@ |
| | | ${_initCustomScript} |
| | | |
| | | Insert into #${sheet} (${fields},jskey,BID) |
| | | |
| | | /* excel数据*/ |
| | | @mk_excel_data@ |
| | | |
| | | ${_uniquesql} |
| | | ${_prevCustomScript} |
| | | ${_insert}` |
| | | |
| | | let mk_ent = '' |
| | | if (/@ErrorCode='(ENT|NNT|FNT|NMNT|CNT|-2NT)'/ig.test(sql + _backCustomScript)) { |
| | | mk_ent = ` |
| | | if 1=2 |
| | | begin |
| | | mk_ent: |
| | | set @ErrorCode=left(@ErrorCode,1) |
| | | end |
| | | ` |
| | | } |
| | | |
| | | if (btn.workFlow === 'true' && process) { |
| | | if (btn.flowSql === 'true') { |
| | | sql += ` |
| | | /* 工作流异常sql */ |
| | | if @works_flow_error@ != '' |
| | | select @ErrorCode='E',@retmsg=@works_flow_error@ goto aaa |
| | | |
| | | /* 工作流默认sql */ |
| | | insert into s_my_works_flow (works_flow_id,works_flow_code,works_flow_name,works_flow_param,status,statusname,work_group,works_flow_detail_id,work_grade,bid,createuserid,CreateUser,CreateStaff,upid) |
| | | select jskey,@works_flow_code@,@works_flow_name@,@works_flow_param@,@status@,@statusname@,@work_group@,@works_flow_detail_id@,@work_grade@,@bid@,@UserID@,@UserName,@FullName,@time_id@ |
| | | from #${sheet} |
| | | |
| | | insert into s_my_works_flow_log (works_flow_id,works_flow_code,works_flow_name,works_flow_param,status,statusname,works_flow_detail_id,work_group,work_grade,bid,createuserid,CreateUser,CreateStaff,upid) |
| | | select jskey,@works_flow_code@,@works_flow_name@ ,@works_flow_param@,@status@,@statusname@,@works_flow_detail_id@,@work_group@,@work_grade@,@bid@,@UserID@,@UserName,@FullName,@time_id@ |
| | | from #${sheet} |
| | | |
| | | insert into s_my_works_flow_notice (works_flow_id,works_flow_code,works_flow_detail_id,userid,notice_type,createuserid,CreateUser,CreateStaff,upid) |
| | | select jskey,@works_flow_code@,@works_flow_detail_id@,@userid@,@start_type@,@userid@,@UserName,@FullName,@time_id@ |
| | | from #${sheet} |
| | | |
| | | insert into s_my_works_flow_role (works_flow_id,works_flow_code,userid,works_flow_detail_id,createuserid,CreateUser,CreateStaff,upid,typecharone) |
| | | select jskey,@works_flow_code@,@userid@,@works_flow_detail_id@,@userid@,@UserName,@FullName,@time_id@,'begin' |
| | | from #${sheet} |
| | | ` |
| | | } |
| | | |
| | | sql += ` |
| | | ${_backCustomScript} |
| | | |
| | | drop table #${sheet} |
| | | ${mk_ent} |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ${callback}` |
| | | |
| | | sql = sql.replace(/@start_type@/ig, `'开始'`) |
| | | // works_flow_error 流程错误 |
| | | let worksReFields = ['works_flow_error', 'works_flow_code', 'works_flow_name', 'works_flow_param', 'works_flow_detail_id', 'status', 'statusname', 'work_group', 'work_grade'] |
| | | worksReFields.forEach(n => { |
| | | sql = sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | } else { |
| | | sql += ` |
| | | ${_backCustomScript} |
| | | |
| | | drop table #${sheet} |
| | | ${mk_ent} |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ${callback}` |
| | | } |
| | | |
| | | if (/@ErrorCode='(ENT|NNT|FNT|NMNT|CNT|-2NT)'/ig.test(sql)) { |
| | | sql = sql.replace(/@ErrorCode='(ENT|NNT|FNT|NMNT|CNT|-2NT)'[\S\s]+\sgoto\s+aaa($|\s)/ig, (word) => { |
| | | return word.replace(/goto aaa/, 'goto mk_ent') |
| | | }) |
| | | } |
| | | |
| | | let reps = [] |
| | | let decSql = [] |
| | | let secSql = [] |
| | | |
| | | let syses = ['UserName', 'FullName', 'RoleID', 'mk_departmentcode', 'mk_organization', 'mk_user_type', 'mk_nation', 'mk_province', 'mk_city', 'mk_district', 'mk_address'] |
| | | syses.forEach(s => { |
| | | if (new RegExp('@' + s + '[^0-9a-z_]', 'ig').test(sql)) { |
| | | if (['RoleID', 'mk_departmentcode', 'mk_organization'].includes(s)) { |
| | | decSql.push(`@${s} nvarchar(512)`) |
| | | } else if (['mk_address'].includes(s)) { |
| | | decSql.push(`@mk_address nvarchar(100)`) |
| | | } else { |
| | | decSql.push(`@${s} nvarchar(50)`) |
| | | } |
| | | secSql.push(`@${s}=@${s}@`) |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | decSql = decSql.length ? `,${decSql.join(',')}` : '' |
| | | secSql = secSql.length ? `,${secSql.join(',')}` : '' |
| | | |
| | | sql = sql.replace(/@mk_init_declare@/ig, decSql) |
| | | sql = sql.replace(/@mk_init_select@/ig, secSql) |
| | | |
| | | let regs = ['ID', 'BID', 'time_id', 'datam', 'typename'] |
| | | |
| | | regs.forEach(s => { |
| | | if (new RegExp('@' + s + '@', 'ig').test(sql)) { |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | let map = new Map() |
| | | reps.push(...sysVars) |
| | | reps = reps.filter(n => { |
| | | if (map.has(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | map.set(n.toLowerCase(), true) |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps.forEach(n => { |
| | | sql = sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | |
| | | if (/\$@/ig.test(sql)) { |
| | | sql = sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | if (/\$check@|@check\$/ig.test(sql)) { |
| | | sql = sql.replace(/\$check@/ig, '@mk_check_begin@').replace(/@check\$/ig, '@mk_check_end@') |
| | | reps.push('mk_check_begin', 'mk_check_end') |
| | | } |
| | | if (/@db@/ig.test(sql)) { |
| | | reps.push('db') |
| | | } |
| | | |
| | | sql = sql.replace(/\n\x20{6,10}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | return {LText: sql, md5: md5(sql), reps} |
| | | } |
| | | |
| | | let getEditTableSql = (btn, cols, columns, setting) => { |
| | | let sheet = btn.sheet.replace(/@db@/ig, '') |
| | | let database = '' |
| | | if (/@db@/ig.test(btn.sheet)) { |
| | | database = '@db@' |
| | | } |
| | | |
| | | let forms = [] |
| | | let _forms = {} |
| | | let index = 0 |
| | | |
| | | let getColumns = (cols) => { |
| | | cols.forEach(item => { |
| | | if (item.type === 'colspan') { |
| | | getColumns(item.subcols) |
| | | } else if (item.editable === 'true') { |
| | | item.$sort = index |
| | | _forms[item.field] = item |
| | | index++ |
| | | } |
| | | }) |
| | | } |
| | | |
| | | getColumns(cols) |
| | | |
| | | columns.forEach(item => { |
| | | if (item.field === setting.primaryKey) return |
| | | |
| | | if (_forms[item.field]) { |
| | | let _item = {..._forms[item.field]} |
| | | if (_item.editType === 'date') { |
| | | _item.datatype = _item.declareType || 'datetime' |
| | | } else { |
| | | _item.datatype = item.datatype |
| | | } |
| | | |
| | | forms.push(_item) |
| | | } else { |
| | | forms.push({...item, $sort: 999}) |
| | | } |
| | | }) |
| | | |
| | | forms.sort((a, b) => a.$sort - b.$sort) |
| | | |
| | | let sql = '' |
| | | |
| | | let _initCustomScript = '' // 初始化脚本 |
| | | let _prevCustomScript = '' // 默认sql前执行脚本 |
| | | let _backCustomScript = '' // 默认sql后执行脚本 |
| | | let _regs = [ |
| | | {reg: new RegExp('(^|\\s)@' + sheet + '(\\s|$)', 'ig'), value: ` #${sheet} `}, |
| | | {reg: new RegExp('(^|\\s)@' + sheet + '\\(', 'ig'), value: ` #${sheet}(`}, |
| | | {reg: new RegExp('(^|\\s)@' + sheet + '\\)', 'ig'), value: ` #${sheet})`}, |
| | | ] |
| | | |
| | | btn.scripts && btn.scripts.forEach(script => { |
| | | if (script.status === 'false') return |
| | | |
| | | let _sql = script.sql |
| | | |
| | | _regs.forEach(item => { |
| | | _sql = _sql.replace(item.reg, item.value) |
| | | }) |
| | | |
| | | if (script.position === 'init') { |
| | | _initCustomScript += ` |
| | | /* 自定义脚本 */ |
| | | ${_sql} |
| | | ` |
| | | } else if (script.position === 'front') { |
| | | _prevCustomScript += ` |
| | | /* 自定义脚本 */ |
| | | ${_sql} |
| | | ` |
| | | } else { |
| | | _backCustomScript += ` |
| | | /* 自定义脚本 */ |
| | | ${_sql} |
| | | ` |
| | | } |
| | | }) |
| | | |
| | | let _uniquesql = '' |
| | | if (btn.uniques && btn.uniques.length > 0) { |
| | | let textFields = [] |
| | | let numberFields = [] |
| | | let dateFields = [] |
| | | columns.forEach((col) => { |
| | | if (/Nvarchar/ig.test(col.datatype)) { |
| | | textFields.push(col.field) |
| | | } else if (/Decimal|int/ig.test(col.datatype)) { |
| | | numberFields.push(col.field) |
| | | } else if (/date/ig.test(col.datatype)) { |
| | | dateFields.push(col.field) |
| | | } |
| | | }) |
| | | btn.uniques.forEach(unique => { |
| | | if (unique.status === 'false' || !unique.verifyType) return |
| | | |
| | | let _fields = unique.field.split(',') |
| | | let _fields_ = _fields.map(_field => `a.${_field}=b.${_field}`) |
| | | _fields_ = _fields_.join(' and ') |
| | | |
| | | let _where = [] |
| | | _fields.forEach(f => { |
| | | if (textFields.includes(f)) { |
| | | _where.push(`${f}!=''`) |
| | | } else if (numberFields.includes(f)) { |
| | | _where.push(`${f}!=0`) |
| | | } else if (dateFields.includes(f)) { |
| | | _where.push(`${f}>'1949-10-01'`) |
| | | } |
| | | }) |
| | | _where = _where.length ? `where ${_where.join(' and ')} ` : '' |
| | | |
| | | if (unique.verifyType === 'logic' || unique.verifyType === 'logic_temp') { |
| | | _fields_ += ' and b.deleted=0' |
| | | } |
| | | |
| | | let _afields = [] |
| | | _fields = _fields.map(f => { |
| | | if (numberFields.includes(f)) { |
| | | _afields.push(`cast(a.${f} as nvarchar(50))`) |
| | | return `cast(${f} as nvarchar(50))` |
| | | } else if (dateFields.includes(f)) { |
| | | _afields.push(`CONVERT(nvarchar(50), a.${f}, 21)`) |
| | | return `CONVERT(nvarchar(50), ${f}, 21)` |
| | | } |
| | | _afields.push(`a.${f}`) |
| | | |
| | | return f |
| | | }) |
| | | |
| | | _uniquesql += ` |
| | | /* 重复性验证 */ |
| | | Set @tbid='' |
| | | Select top 1 @tbid=${_fields.join('+\' \'+')} from (select 1 as n,${unique.field} from #${sheet} ) a group by ${unique.field} having sum(n)>1 |
| | | |
| | | If @tbid!='' |
| | | Begin |
| | | select @ErrorCode='${unique.errorCode}',@retmsg=@tbid+' 重复' |
| | | goto aaa |
| | | end |
| | | |
| | | ${unique.verifyType.indexOf('temp') === -1 ? `Set @tbid='' |
| | | Select top 1 @tbid=${_afields.join('+\' \'+')} from ${_where ? `(select * from #${sheet} ${_where})` : `#${sheet}`} a Inner join ${sheet} b on ${_fields_} |
| | | |
| | | If @tbid!='' |
| | | Begin |
| | | select @ErrorCode='${unique.errorCode}',@retmsg=@tbid+' 与已有数据重复' |
| | | goto aaa |
| | | end` : ''} |
| | | ` |
| | | }) |
| | | } |
| | | |
| | | let declarefields = [] |
| | | let fields = [] |
| | | |
| | | forms.forEach(col => { |
| | | let key = col.field.toLowerCase() |
| | | if (key === 'jskey' || key === 'bid' || key === 'data_type') return |
| | | |
| | | declarefields.push(`${col.field} ${col.datatype}`) |
| | | fields.push(col.field) |
| | | }) |
| | | |
| | | fields = fields.join(',') |
| | | |
| | | let _insert = '' |
| | | if (btn.default !== 'false') { |
| | | _insert = ` |
| | | /* 默认sql */ |
| | | Insert into ${database}${sheet} (${fields},createuserid,createuser,createstaff,bid) |
| | | Select ${fields},@UserID@,@username,@fullname,@BID@ From #${sheet} |
| | | ` |
| | | } |
| | | |
| | | sql = `/* ${btn.logLabel} */ |
| | | BEGIN TRY |
| | | begin TRAN |
| | | |
| | | create table #${sheet} (${declarefields.join(',')},jskey nvarchar(50),data_type nvarchar(50),BID nvarchar(256)) |
| | | Declare @ErrorCode nvarchar(50),@retmsg nvarchar(4000),@tbid Nvarchar(512)@mk_init_declare@ |
| | | Select @ErrorCode='S',@retmsg=''@mk_init_select@ |
| | | |
| | | ${_initCustomScript} |
| | | Insert into #${sheet} (${fields},jskey,data_type,BID) |
| | | |
| | | /* table数据*/ |
| | | @mk_excel_data@ |
| | | |
| | | ${_uniquesql} |
| | | ${_prevCustomScript} |
| | | ${_insert} |
| | | ${_backCustomScript} |
| | | |
| | | drop table #${sheet} |
| | | |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ${callback}` |
| | | |
| | | let reps = [] |
| | | let decSql = [] |
| | | let secSql = [] |
| | | |
| | | let syses = ['UserName', 'FullName', 'RoleID', 'mk_departmentcode', 'mk_organization', 'mk_user_type', 'mk_nation', 'mk_province', 'mk_city', 'mk_district', 'mk_address'] |
| | | syses.forEach(s => { |
| | | if (new RegExp('@' + s + '[^0-9a-z_]', 'ig').test(sql)) { |
| | | if (['RoleID', 'mk_departmentcode', 'mk_organization'].includes(s)) { |
| | | decSql.push(`@${s} nvarchar(512)`) |
| | | } else if (['mk_address'].includes(s)) { |
| | | decSql.push(`@mk_address nvarchar(100)`) |
| | | } else { |
| | | decSql.push(`@${s} nvarchar(50)`) |
| | | } |
| | | secSql.push(`@${s}=@${s}@`) |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | decSql = decSql.length ? `,${decSql.join(',')}` : '' |
| | | secSql = secSql.length ? `,${secSql.join(',')}` : '' |
| | | |
| | | sql = sql.replace(/@mk_init_declare@/ig, decSql) |
| | | sql = sql.replace(/@mk_init_select@/ig, secSql) |
| | | |
| | | let regs = ['BID', 'time_id', 'datam', 'typename'] |
| | | |
| | | regs.forEach(s => { |
| | | if (new RegExp('@' + s + '@', 'ig').test(sql)) { |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | let map = new Map() |
| | | reps.push(...sysVars) |
| | | reps = reps.filter(n => { |
| | | if (map.has(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | map.set(n.toLowerCase(), true) |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps.forEach(n => { |
| | | sql = sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | |
| | | if (/\$@/ig.test(sql)) { |
| | | sql = sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | if (/@db@/ig.test(sql)) { |
| | | reps.push('db') |
| | | } |
| | | |
| | | sql = sql.replace(/\n\x20{6,10}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | return {LText: sql, md5: md5(sql), reps} |
| | | } |
| | | |
| | | let getExcelOutSql = (btn, component) => { |
| | | let item = {setting: {}, columns: [], search: [], useMSearch: 'false'} |
| | | |
| | | btn.verify.columns.forEach(col => { |
| | | if (col.output === 'false' || !col.Column || col.Column === '$Index') return |
| | | item.columns.push({ |
| | | field: col.Column |
| | | }) |
| | | }) |
| | | |
| | | if (btn.verify.useSearch !== 'false') { |
| | | item.search = component.$searches |
| | | } |
| | | |
| | | item.setting.interType = 'system' |
| | | item.setting.execute = btn.verify.defaultSql || 'true' |
| | | item.setting.dataresource = btn.verify.dataresource || '' |
| | | item.setting.queryType = btn.verify.queryType |
| | | item.setting.laypage = btn.pagination |
| | | item.setting.order = btn.verify.order || '' |
| | | item.setting.$name = btn.logLabel || '' |
| | | |
| | | if (btn.Ot === 'requiredOnce') { |
| | | item.setting.primaryKey = btn.verify.primaryKey || component.setting.primaryKey || 'ID' |
| | | } |
| | | |
| | | item.scripts = btn.verify.scripts || [] |
| | | |
| | | let msg = getDataSource(item, []) |
| | | |
| | | return msg |
| | | } |
| | | |
| | | let getPrintSql = (btn, component) => { |
| | | let item = {setting: {}, columns: btn.verify.columns || [], search: [], useMSearch: 'false'} |
| | | |
| | | item.setting.interType = 'system' |
| | | item.setting.execute = btn.verify.setting.defaultSql || 'true' |
| | | item.setting.dataresource = btn.verify.setting.dataresource || '' |
| | | item.setting.queryType = btn.verify.setting.queryType |
| | | item.setting.laypage = 'false' |
| | | item.setting.order = btn.verify.setting.order || '' |
| | | item.setting.$name = btn.logLabel || '' |
| | | item.setting.transact = 'true' |
| | | item.setting.$fixOrder = true |
| | | |
| | | item.scripts = btn.verify.scripts || [] |
| | | |
| | | let msg = getDataSource(item, [], 'print') |
| | | |
| | | msg.LText = msg.LText.replace(/@mk_obj_name@/ig, 'data') |
| | | msg.reps = msg.reps.filter(n => n !== 'mk_obj_name') |
| | | |
| | | let formkeys = [] |
| | | let colreps = [] |
| | | let _declares = [] |
| | | let _init = [] |
| | | if (btn.execMode === 'pop' && btn.modal && btn.modal.fields) { |
| | | btn.modal.fields.forEach(item => { |
| | | if (!item.field) return |
| | | let _key = item.field.toLowerCase() |
| | | |
| | | if (!new RegExp('@' + _key + '[^0-9a-z_]', 'ig').test(msg.LText)) return |
| | | |
| | | formkeys.push(_key) |
| | | colreps.push(item.field) |
| | | |
| | | let _item = { |
| | | key: item.field, |
| | | fieldlen: item.fieldlength || 50, |
| | | writein: item.writein !== 'false', |
| | | type: item.type, |
| | | isconst: item.constant === 'true' |
| | | } |
| | | |
| | | if (_item.type === 'datemonth') { |
| | | _item.type = 'text' |
| | | } else if (_item.type === 'number' || _item.type === 'rate') { |
| | | _item.fieldlen = item.decimal || 0 |
| | | } else if (_item.type === 'date') { |
| | | _item.type = item.declareType === 'nvarchar(50)' ? 'text' : 'date' |
| | | } else if (_item.type === 'datetime') { |
| | | _item.type = 'date' |
| | | } else if (item.declare === 'decimal') { |
| | | _item.type = 'number' |
| | | _item.fieldlen = item.decimal || 0 |
| | | } |
| | | |
| | | if (_item.type === 'number' || _item.type === 'rate') { |
| | | _init.push(`@${_key}=@mk_${_key}_mk@`) |
| | | } else if (_item.type === 'date') { |
| | | _init.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } else if (_item.type === 'select' || _item.type === 'link' || _item.type === 'radio') { |
| | | _init.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } else if (_item.isconst) { |
| | | _init.push(`@${_key}=N'@mk_${_key}_mk@'`) |
| | | } else { |
| | | _init.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } |
| | | |
| | | if (_item.fieldlen && _item.fieldlen > 4000) { |
| | | _item.fieldlen = 'max' |
| | | } |
| | | |
| | | let _type = `nvarchar(${_item.fieldlen})` |
| | | |
| | | if (_item.type.match(/date/ig)) { |
| | | _type = 'datetime' |
| | | } else if (_item.type === 'number') { |
| | | _type = `decimal(18,${_item.fieldlen})` |
| | | } else if (_item.type === 'rate') { |
| | | _type = `decimal(18,2)` |
| | | } |
| | | |
| | | _declares.push(`@${_key} ${_type}`) |
| | | }) |
| | | } |
| | | |
| | | // 添加数据中字段,表单值优先(按钮不选行或多行拼接时跳过) |
| | | if (btn.Ot !== 'notRequired' && component.columns.length > 0) { |
| | | component.columns.forEach(col => { |
| | | let _key = col.field.toLowerCase() |
| | | |
| | | if (formkeys.includes(_key) || !new RegExp('@' + _key + '[^0-9a-z_@]', 'ig').test(msg.LText)) return |
| | | // if (_key === 'id' && !/@id[^0-9a-z_@]/ig.test(msg.LText)) return |
| | | |
| | | colreps.push(col.field) |
| | | |
| | | if (col.type === 'number') { |
| | | _init.push(`@${_key}=@mk_${_key}_mk@`) |
| | | } else { |
| | | _init.push(`@${_key}='@mk_${_key}_mk@'`) |
| | | } |
| | | |
| | | _declares.push(`@${_key} ${col.datatype || 'nvarchar(50)'}`) |
| | | }) |
| | | } |
| | | |
| | | _declares = _declares.length ? ',' + _declares.join(',') : '' |
| | | _init = _init.length ? ',' + _init.join(',') : '' |
| | | |
| | | msg.LText = msg.LText.replace('@mk_print_declare@', _declares) |
| | | msg.LText = msg.LText.replace('@mk_print_select@', _init) |
| | | |
| | | msg.reps = [...msg.reps, ...colreps] |
| | | |
| | | return msg |
| | | } |
| | | |
| | | let getPaySql = (btn, component) => { |
| | | let _sql = `/* ${btn.logLabel} */ |
| | | BEGIN TRY |
| | | begin TRAN |
| | | |
| | | Declare @ErrorCode nvarchar(50),@retmsg nvarchar(4000),@tbid nvarchar(50)@mk_init_declare@ |
| | | Select @ErrorCode='S',@retmsg=''@mk_init_select@ |
| | | ` |
| | | |
| | | btn.verify.scripts.forEach(item => { |
| | | if (item.status === 'false') return |
| | | |
| | | _sql += ` |
| | | ${item.sql} |
| | | ` |
| | | }) |
| | | |
| | | if (btn.output) { |
| | | _sql += ` |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg,${btn.output} as mk_b_id |
| | | ${callback}` |
| | | } else { |
| | | _sql += ` |
| | | select @ErrorCode as ErrorCode,@retmsg as retmsg |
| | | ${callback}` |
| | | } |
| | | |
| | | let reps = [] |
| | | let decSql = [] |
| | | let secSql = [] |
| | | |
| | | let syses = ['UserName', 'FullName', 'RoleID', 'mk_departmentcode', 'mk_organization', 'mk_user_type', 'mk_nation', 'mk_province', 'mk_city', 'mk_district', 'mk_address', 'BID'] |
| | | syses.forEach(s => { |
| | | if (new RegExp('@' + s + '[^0-9a-z_]', 'ig').test(_sql)) { |
| | | if (['RoleID', 'mk_departmentcode', 'mk_organization'].includes(s)) { |
| | | decSql.push(`@${s} nvarchar(512)`) |
| | | } else if (['mk_address'].includes(s)) { |
| | | decSql.push(`@mk_address nvarchar(100)`) |
| | | } else { |
| | | decSql.push(`@${s} nvarchar(50)`) |
| | | } |
| | | secSql.push(`@${s}=@${s}@`) |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | let regs = ['ID', 'time_id', 'datam', 'typename'] |
| | | |
| | | regs.forEach(s => { |
| | | if (new RegExp('@' + s + '@', 'ig').test(_sql)) { |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | syses = syses.map(n => n.toLowerCase()) |
| | | syses.push('tbid') |
| | | |
| | | let colreps = [] |
| | | component.columns.forEach(col => { |
| | | let _key = col.field.toLowerCase() |
| | | |
| | | if (syses.includes(_key) || !new RegExp('@' + _key + '[^0-9a-z_@]', 'ig').test(_sql)) return |
| | | // if (_key === 'id' && !/@id[^0-9a-z_@]/ig.test(_sql)) return |
| | | |
| | | colreps.push(col.field) |
| | | |
| | | decSql.push(`@${col.field} ${col.datatype || 'nvarchar(50)'}`) |
| | | |
| | | if (col.type === 'number') { |
| | | secSql.push(`@${col.field}=@mk_${col.field}_mk@`) |
| | | } else { |
| | | secSql.push(`@${col.field}='@mk_${col.field}_mk@'`) |
| | | } |
| | | }) |
| | | |
| | | decSql = decSql.length ? `,${decSql.join(',')}` : '' |
| | | secSql = secSql.length ? `,${secSql.join(',')}` : '' |
| | | |
| | | _sql = _sql.replace(/@mk_init_declare@/ig, decSql) |
| | | _sql = _sql.replace(/@mk_init_select@/ig, secSql) |
| | | |
| | | let map = new Map() |
| | | reps.push(...sysVars) |
| | | reps = reps.filter(n => { |
| | | if (map.has(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | map.set(n.toLowerCase(), true) |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps.forEach(n => { |
| | | _sql = _sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | |
| | | if (/\$@/ig.test(_sql)) { |
| | | _sql = _sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | if (/@db@/ig.test(_sql)) { |
| | | reps.push('db') |
| | | } |
| | | |
| | | _sql = _sql.replace(/\n\x20{6,8}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps = [...reps, ...colreps] |
| | | |
| | | return {LText: _sql, md5: md5(_sql), reps} |
| | | } |
| | | |
| | | let getFormSql = (item, tname) => { |
| | | let arrfield = [item.valueField, item.valueText] |
| | | |
| | | if (item.type === 'checkcard') { |
| | | arrfield = item.fields ? item.fields.map(f => f.field) : [] |
| | | arrfield.push(item.cardValField) |
| | | if (item.urlField) { |
| | | arrfield.push(item.urlField) |
| | | } else if (item.colorField) { |
| | | arrfield.push(item.colorField) |
| | | } else if (item.parentField) { |
| | | arrfield.push(item.parentField) |
| | | } |
| | | } |
| | | |
| | | if (item.linkField) { |
| | | arrfield.push(item.linkField) |
| | | } |
| | | if (['select', 'radio', 'link', 'checkcard'].includes(item.type) && item.linkSubField && item.linkSubField.length > 0) { |
| | | arrfield.push(...item.linkSubField) |
| | | } else if (item.type === 'text' && item.editType === 'select' && item.linkSubField && item.linkSubField.length > 0) { // 可编辑表 |
| | | arrfield.push(...item.linkSubField) |
| | | } |
| | | if (item.disableField) { |
| | | arrfield.push(item.disableField) |
| | | } |
| | | |
| | | arrfield = Array.from(new Set(arrfield)) |
| | | |
| | | let _datasource = item.dataSource |
| | | let sql = '' |
| | | |
| | | if (/\s/.test(_datasource)) { // 拼接别名 |
| | | _datasource = '(' + _datasource + ') tb' |
| | | } |
| | | |
| | | arrfield = arrfield.join(',') |
| | | |
| | | if (item.orderBy) { |
| | | sql = `select distinct ${arrfield},${item.orderBy} as orderfield from ${_datasource} order by orderfield ${item.orderType}` |
| | | } else { |
| | | sql = `select distinct ${arrfield} from ${_datasource}` |
| | | } |
| | | |
| | | let reps = [] |
| | | |
| | | let decSql = [] |
| | | let secSql = [] |
| | | |
| | | let syses = ['mk_departmentcode', 'mk_organization', 'mk_user_type'] |
| | | syses.forEach(s => { |
| | | if (new RegExp('@' + s + '[^0-9a-z_]', 'ig').test(sql)) { |
| | | if (['mk_departmentcode', 'mk_organization'].includes(s)) { |
| | | decSql.push(`@${s} nvarchar(512)`) |
| | | } else { |
| | | decSql.push(`@${s} nvarchar(20)`) |
| | | } |
| | | secSql.push(`@${s}=@${s}@`) |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | decSql = decSql.join(',') |
| | | secSql = secSql.join(',') |
| | | decSql = decSql ? `Declare ${decSql} select ${secSql}` : '' |
| | | |
| | | sql = `/* ${item.label}(${tname}) */ |
| | | SELECT obj_name='${item.field}',prm_field='',str_field='', |
| | | arr_field='${arrfield}',tabid='',parid='',sub_name='',sub_field='' |
| | | |
| | | ${decSql} |
| | | ${sql} |
| | | |
| | | select 'S' as ErrorCode,'' as retmsg |
| | | ` |
| | | |
| | | let regs = ['ID', 'BID', 'datam'] |
| | | |
| | | regs.forEach(s => { |
| | | if (new RegExp('@' + s + '@', 'ig').test(sql)) { |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | reps.push(...sysVars) |
| | | |
| | | reps.forEach(n => { |
| | | sql = sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | |
| | | if (/\$@/ig.test(sql)) { |
| | | sql = sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | if (/@db@/ig.test(sql)) { |
| | | reps.push('db') |
| | | } |
| | | |
| | | // reps.push('mk_obj_name') |
| | | |
| | | sql = sql.replace(/\n\x20{6,8}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | return {LText: sql, md5: md5(sql), reps} |
| | | } |
| | | |
| | | let getPopSelectSql = (item) => { |
| | | let arrfield = item.columns.map(f => f.field) |
| | | |
| | | if (item.linkSubField && item.linkSubField.length > 0) { |
| | | item.linkSubField.forEach(n => { |
| | | if (!arrfield.includes(n)) { |
| | | arrfield.push(n) |
| | | } |
| | | }) |
| | | } |
| | | |
| | | arrfield = arrfield.join(',') |
| | | if (/\s/.test(item.dataSource)) { // 拼接别名 |
| | | item.dataSource = '(' + item.dataSource + ') tb' |
| | | } |
| | | |
| | | let LText = '' |
| | | let DateCount = '' |
| | | let _search = '' |
| | | let reps = [] |
| | | let sFields = [] |
| | | |
| | | if (item.searchKey) { |
| | | _search = '@mk_search@' |
| | | sFields = item.searchKey.split(',') |
| | | } |
| | | |
| | | // 不需要单引号:orderBy、pageSize、pageIndex、db |
| | | let regs = [...sFields, 'orderBy', 'pageSize', 'pageIndex', 'ID', 'BID', 'time_id', 'datam'] |
| | | |
| | | regs.forEach(s => { |
| | | if (new RegExp('@' + s + '@', 'ig').test(item.dataSource)) { |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | let decSql = [] |
| | | let secSql = [] |
| | | |
| | | let syses = ['mk_departmentcode', 'mk_organization', 'mk_user_type'] |
| | | syses.forEach(s => { |
| | | if (new RegExp('@' + s + '[^0-9a-z_]', 'ig').test(item.dataSource)) { |
| | | if (['mk_departmentcode', 'mk_organization'].includes(s)) { |
| | | decSql.push(`@${s} nvarchar(512)`) |
| | | } else { |
| | | decSql.push(`@${s} nvarchar(20)`) |
| | | } |
| | | secSql.push(`@${s}=@${s}@`) |
| | | reps.push(s) |
| | | } |
| | | }) |
| | | |
| | | decSql = decSql.join(',') |
| | | secSql = secSql.join(',') |
| | | decSql = decSql ? `Declare ${decSql} select ${secSql}` : '' |
| | | |
| | | if (item.laypage === 'true') { |
| | | /*system_query*/ |
| | | LText = `select top @pageSize@ ${arrfield} from (select ${arrfield} ,ROW_NUMBER() over(order by @orderBy@) as rows from ${item.dataSource} ${_search}) tmptable where rows > @pageSize@ * (@pageIndex@ - 1) order by tmptable.rows ` |
| | | DateCount = `select count(1) as total from ${item.dataSource} ${_search}` |
| | | |
| | | reps.push('pageSize', 'orderBy', 'pageIndex') |
| | | } else { |
| | | LText = `select ${arrfield} from ${item.dataSource} ${_search} order by @orderBy@ ` |
| | | reps.push('orderBy') |
| | | } |
| | | |
| | | let sql = `SELECT obj_name='data',prm_field='',str_field='', |
| | | arr_field='${arrfield}',tabid='',parid='',sub_name='',sub_field='' |
| | | ` |
| | | |
| | | if (DateCount) { |
| | | sql += `UNION ALL |
| | | SELECT obj_name='DateCount',prm_field='total',str_field='', |
| | | arr_field='',tabid='',parid='',sub_name='',sub_field='' |
| | | ` |
| | | } |
| | | |
| | | sql += ` |
| | | ${decSql} |
| | | ${LText} |
| | | ${DateCount} |
| | | |
| | | select 'S' as ErrorCode,'' as retmsg |
| | | ` |
| | | |
| | | let map = new Map() |
| | | reps.push(...sysVars) |
| | | reps = reps.filter(n => { |
| | | if (map.has(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | map.set(n.toLowerCase(), true) |
| | | |
| | | return true |
| | | }) |
| | | |
| | | reps.forEach(n => { |
| | | if (['orderBy', 'pageSize', 'pageIndex'].includes(n)) return |
| | | |
| | | sql = sql.replace(new RegExp('@' + n + '@', 'ig'), `'@${n}@'`) |
| | | }) |
| | | if (/\$@/ig.test(sql)) { |
| | | sql = sql.replace(/\$@/ig, '@datam_begin@').replace(/@\$/ig, '@datam_end@') |
| | | reps.push('datam_begin', 'datam_end') |
| | | } |
| | | if (/@db@/ig.test(sql)) { |
| | | reps.push('db') |
| | | } |
| | | |
| | | sql = sql.replace(/\n\x20{6,8}/g, '\n').replace(/\n{3,}/g, '\n\n').replace(/^\s+|\s+$/g, '').replace(/\t+|\v+/g, '') |
| | | |
| | | reps = reps.filter(n => { |
| | | if (sysVars.includes(n.toLowerCase())) { |
| | | return false |
| | | } |
| | | |
| | | return true |
| | | }) |
| | | |
| | | return {LText: sql, md5: md5(sql), reps} |
| | | } |
| | | |
| | | let _mainSearch = [] |
| | |
| | | } |
| | | search.push(...group.fields) |
| | | }) |
| | | |
| | | if (search.length > 0) { |
| | | search.forEach(cell => { |
| | | if (['select', 'link', 'multiselect', 'checkcard', 'radio'].includes(cell.type) && cell.resourceType === '1' && cell.dataSource) { |
| | | let msg = getFormSql(cell, '搜索') |
| | | |
| | | sqls.push({uuid: cell.uuid, type: 'sForm', ...msg}) |
| | | } |
| | | }) |
| | | } |
| | | } |
| | | |
| | | if (search.length > 0) { |
| | |
| | | |
| | | m.setting.laypage = 'false' |
| | | m.setting.$top = true |
| | | m.setting.$name = (config.MenuName || '') + '-' + (m.name || '') |
| | | |
| | | let msg = getDataSource(m, _mainSearch) |
| | | |
| | | sqls.push({uuid: m.uuid, ...msg}) |
| | | sqls.push({uuid: m.uuid, type: 'interface', ...msg}) |
| | | }) |
| | | } |
| | | |