dengyu
/
DS7
1
0
Fork 0
Code Issues Pull Requests Projects 1 Releases Wiki Activity

1

Browse Source
DS7_JinGang
dengyu 1 year ago
parent e91a1e954a
commit b84b226461
2 changed files with 41 additions and 542 deletions
Show Stats Download Patch File Download Diff File

50
DSWeb.DJYMQ/DS7Service.cs
View File

File diff suppressed because one or more lines are too long

533
JobReqWebData/bin/Release/quartz_jobs.xml
Unescape Escape View File

@ -6,518 +6,6 @@
<schedule>
<!--发送请求数据任务-->
<job>
<name>JobSendRequest</name>
<group>SendRequest</group>
<description>发送数据请求</description>
<job-type>JobReqWebData.JobSendRequest,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=47.105.157.231;Initial Catalog=Shippingweb;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--查询SQL-->
<entry>
<key>QuerySql</key>
<value>
select MBLNO,C.YARDCODE as YARDNAME,'' as WEBUSERNAME,'' as WEBUSERPASS FROM OP_SEAE b
left join code_yarddata_set c on (c.YARD=b.YARD) WHERE MBLNO!='' AND ETD&gt;=GETDATE()-30 AND ETD&lt;=GETDATE()+10 AND ISNULL(C.YARDCODE,'')!=''
and not exists (SELECT 1 FROM op_status s where s.bsno=b.bsno and s.STATUS='重箱返场')
UNION
select MBLNO,'YGT' as YARDNAME,'15163472790' as WEBUSERNAME,'19861115qq' as WEBUSERPASS FROM OP_SEAE b
WHERE MBLNO!='' AND ETD&gt;=GETDATE()-10 AND ETD&lt;=GETDATE()+10 AND
exists (SELECT 1 FROM op_status s where s.bsno=b.bsno and s.STATUS='空箱出场' )
and not EXISTS (SELECT 1 FROM op_status s where s.bsno=b.bsno and s.STATUS='装船出运')
</value>
</entry>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>http://47.104.90.170:5000/save</value>
</entry>
<!--客户名-->
<entry>
<key>Customer</key>
<value>SDBT</value>
</entry>
<!--密码-->
<entry>
<key>Password</key>
<value>abc123</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>30</value>
</entry>
</job-data-map>
</job>
<!-- 发送请求数据任务触发器-->
<trigger>
<cron>
<name>TriggerSendRequest</name>
<group>SendRequest</group>
<description>发送数据请求触发器</description>
<job-name>JobSendRequest</job-name>
<job-group>SendRequest</job-group>
<cron-expression>0 0/10 * * * ? *</cron-expression>
</cron>
</trigger>
<!--获取数据任务-->
<job>
<name>JobGetData</name>
<group>GetData</group>
<description>获取数据</description>
<job-type>JobReqWebData.JobGetData,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>http://47.104.90.170:5000/extract</value>
</entry>
<!--连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=47.105.157.231;Initial Catalog=Shippingweb;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--客户名-->
<entry>
<key>Customer</key>
<value>SDBT</value>
</entry>
<!--密码-->
<entry>
<key>Password</key>
<value>abc123</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>60</value>
</entry>
</job-data-map>
</job>
<!-- 获取数据任务触发器-->
<trigger>
<cron>
<name>TriggerGetData</name>
<group>GetData</group>
<description>获取数据触发器</description>
<job-name>JobGetData</job-name>
<job-group>GetData</job-group>
<cron-expression>0 0/3 * * * ? *</cron-expression>
</cron>
</trigger>
<!--发送账号任务-->
<job>
<name>JobSendAccount</name>
<group>SendAccount</group>
<description>获取数据</description>
<job-type>JobReqWebData.JobSendAccount,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>http://47.104.90.170:5000/account/password</value>
</entry>
<!--客户名-->
<entry>
<key>Customer</key>
<value>SDBT</value>
</entry>
<!--密码-->
<entry>
<key>Password</key>
<value>abc123</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>30</value>
</entry>
<!--账号密码json-->
<entry>
<key>AccountJson</key>
<value>
[{
"WEBUSERNAME": "18560748070",
"WEBPASSWORD": "SDbt8888",
"YARDNAME": "YGT"
},{
"WEBUSERNAME": "18678203935",
"WEBPASSWORD": "Qd123456",
"YARDNAME": "YGT"
},{
"WEBUSERNAME": "13805337465",
"WEBPASSWORD": "QingDao123",
"YARDNAME": "YGT"
}]
</value>
</entry>
</job-data-map>
</job>
<!-- 发送账号任务触发器-->
<trigger>
<simple>
<name>TriggerSendAccount</name>
<group>SendAccount</group>
<description>发送账号任务触发器</description>
<job-name>JobSendAccount</job-name>
<job-group>SendAccount</job-group>
<repeat-count>0</repeat-count>
<repeat-interval>0</repeat-interval>
</simple>
</trigger>
<!--<4.1>浩宏需求 箱满仓的外运费用 发送请求数据任务-->
<job>
<name>JobXmcSend</name>
<group>JobXmcSend</group>
<description>发送数据请求</description>
<job-type>JobReqWebData.JobXmcSend,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=qdhaohong.dongshengsoft.net;Initial Catalog=ShippingWeb_QDHH;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--查询SQL-->
<entry>
<key>QuerySql</key>
<value>
select MBLNO,'XMC' as YARDNAME FROM OP_SEAE b left join code_yarddata_set c on (c.YARD=b.YARD) WHERE MBLNO&lt;&gt;'' AND ETD&gt;=CONVERT(DATETIME,CONVERT(VARCHAR(10),dateadd(day,-90,GETDATE()),21)) AND ETD&lt;CONVERT(DATETIME,CONVERT(VARCHAR(10),dateadd(day,-60,GETDATE()),21)) AND FORWARDER = '山东外运'
</value>
</entry>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>
http://47.104.90.170:6000/xmc/savedata
</value>
</entry>
<entry>
<key>custname</key>
<value>
QDHH
</value>
</entry>
<entry>
<key>custpsw</key>
<value>
QDHH123
</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>60</value>
</entry>
</job-data-map>
</job>
<!--
<cron>
<name>TriggerJobXmcSend</name>
<group>JobXmcSend</group>
<description>发送数据请求触发器</description>
<job-name>JobXmcSend</job-name>
<job-group>JobXmcSend</job-group>
<cron-expression>0 0/1 0 * * ? *</cron-expression>
</cron>
</trigger>
-->
<!--
<trigger>
<simple>
<name>TriggerJobXmcSend</name>
<group>JobXmcSend</group>
<description>发送数据请求触发器</description>
<job-name>JobXmcSend</job-name>
<job-group>JobXmcSend</job-group>
<repeat-count>0</repeat-count>
<repeat-interval>0</repeat-interval>
</simple>
</trigger>
-->
<trigger>
<cron>
<name>TriggerJobXmcSend</name>
<group>JobXmcSend</group>
<description>发送数据请求触发器</description>
<job-name>JobXmcSend</job-name>
<job-group>JobXmcSend</job-group>
<cron-expression>0 45 17 1/1 * ? *</cron-expression>
</cron>
</trigger>
<!-- <4.2>浩宏需求 从 箱满仓 获取应付费用 并与本地相同提单号业务对比
读取信息
-->
<job>
<name>JobXmcGet</name>
<group>JobXmcGet</group>
<description>箱满仓按提单号取费用_获取</description>
<job-type>JobReqWebData.JobXmcGet,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=qdhaohong.dongshengsoft.net;Initial Catalog=ShippingWeb_QDHH;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>
http://47.104.90.170:6000/xmc/extract
</value>
</entry>
<entry>
<key>custname</key>
<value>
QDHH
</value>
</entry>
<entry>
<key>custpsw</key>
<value>
QDHH123
</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>60</value>
</entry>
</job-data-map>
</job>
<!-- <4.2>浩宏需求 读取信息 触发器-->
<trigger>
<cron>
<name>TriggerXmcGet</name>
<group>JobXmcGet</group>
<description>箱满仓按提单号取费用_读取信息触发器</description>
<job-name>JobXmcGet</job-name>
<job-group>JobXmcGet</job-group>
<cron-expression>0 0/2 * * * ? *</cron-expression>
</cron>
</trigger>
<!--发送ATD请求数据任务-->
<job>
<name>JobSendATDRequest</name>
<group>SendATDRequest</group>
<description>发送数据请求</description>
<job-type>JobReqWebData.JobSendATDRequest,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=47.105.157.231;Initial Catalog=Shippingweb;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--查询SQL-->
<entry>
<key>QuerySql</key>
<value>
select distinct VESSEL ship_name,VOYNO as voyage_number,'' as web_name,'' as web_psw FROM OP_SEAE b
WHERE MBLNO!='' AND ETD&gt;=GETDATE()-30 AND ETD&lt;=GETDATE()+10
</value>
</entry>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>http://118.190.106.151:5500/ygt/cbjh/new/extract</value>
</entry>
<!--客户名-->
<entry>
<key>Customer</key>
<value>SDBT</value>
</entry>
<!--密码-->
<entry>
<key>Password</key>
<value>abc123</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>30</value>
</entry>
</job-data-map>
</job>
<!-- 发送ATD请求数据任务触发器-->
<trigger>
<cron>
<name>TriggerSendRequest</name>
<group>SendATDRequest</group>
<description>发送数据请求触发器</description>
<job-name>JobSendATDRequest</job-name>
<job-group>SendATDRequest</job-group>
<cron-expression>0 0/10 * * * ? *</cron-expression>
</cron>
</trigger>
<!--获取ATD数据-->
<job>
<name>JobGetATDData</name>
<group>GetATDData</group>
<description>获取数据</description>
<job-type>JobReqWebData.JobGetATDData,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=47.105.157.231;Initial Catalog=Shippingweb;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>http://118.190.106.151:5500/ygt/cbjh/new/save</value>
</entry>
<!--客户名-->
<entry>
<key>Customer</key>
<value>SDBT</value>
</entry>
<!--密码-->
<entry>
<key>Password</key>
<value>abc123</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>30</value>
</entry>
</job-data-map>
</job>
<!-- 获取ATD任务触发器-->
<trigger>
<cron>
<name>TriggerSendRequest</name>
<group>GetATDData</group>
<description>发送数据请求触发器</description>
<job-name>JobGetATDData</job-name>
<job-group>GetATDData</job-group>
<cron-expression>0 0/10 * * * ? *</cron-expression>
</cron>
</trigger>
<!--发送进口单一数据任务-->
<job>
<name>JobGetImpData</name>
<group>GetImpData</group>
<description>发送数据请求</description>
<job-type>JobReqWebData.JobGetImpData,JobReqWebData</job-type>
<durable>true</durable>
<recover>false</recover>
<job-data-map>
<!--连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=47.105.157.231;Initial Catalog=Shippingweb;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--查询SQL-->
<entry>
<key>QuerySql</key>
<value>
select MBLNO FROM OP_SEAI b
WHERE MBLNO!='' AND ETD&gt;=GETDATE()-10 AND ETD&lt;=GETDATE()+10
and not EXISTS (SELECT 1 FROM op_status s where s.bsno=b.bsno and s.STATUS='海关放行')
</value>
</entry>
<!--请求url-->
<entry>
<key>ReqUrl</key>
<value>http://47.104.90.170:5000/query</value>
</entry>
<!--客户名-->
<entry>
<key>Customer</key>
<value>SDBT</value>
</entry>
<!--密码-->
<entry>
<key>Password</key>
<value>abc123</value>
</entry>
<!--YGT客户名-->
<entry>
<key>YGTUser</key>
<value>SDBT</value>
</entry>
<!--YGT密码-->
<entry>
<key>YGTPsw</key>
<value>abc123</value>
</entry>
<!--YGT代码-->
<entry>
<key>Yardid</key>
<value>YGT_ZHCW</value>
</entry>
<!--请求超时（单位：秒）-->
<entry>
<key>RequestTimeout</key>
<value>30</value>
</entry>
<!--每票间隔时间（单位：秒）-->
<entry>
<key>SleepTime</key>
<value>70</value>
</entry>
</job-data-map>
</job>
<!-- 发送请求数据任务触发器-->
<trigger>
<cron>
<name>TriggerSendRequest</name>
<group>SendRequest</group>
<description>发送数据请求触发器</description>
<job-name>JobSendRequest</job-name>
<job-group>SendRequest</job-group>
<cron-expression>0 0/10 * * * ? *</cron-expression>
</cron>
</trigger>
<!--定时插入WEB数据库数据任务-->
<job>
@ -531,7 +19,7 @@
<!--DS7连接字符串-->
<entry>
<key>ConnectString</key>
<value>Data Source=47.105.157.231;Initial Catalog=Shippingweb;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
<value>Data Source=60.209.125.238,52314;Initial Catalog=shippingweb1;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--DS7查询SQL-->
<entry>
@ -539,21 +27,20 @@
<value>
select bl.AS_ID,bl.BSNO,b.CUSTNO,b.CONTRACTNO PONO,bl.MBLNO,bl.HBLNO,b.CUSTOMERNAME,bl.SHIPPER,bl.CONSIGNEE,bl.PORTLOAD,bl.DESTINATION
,CASE WHEN len(b.DESTINATIONID)!=5 THEN '' ELSE (select top 1 c_country_name from t_sys_country_code where c_country_code=LEFT(b.DESTINATIONID,2)) END as COUNTRY
,b.VESSEL,b.VOYNO,bl.CNTRTOTAL,b.BLTYPE,b.[SERVICE],b.ETD,b.ATD,b.CARRIER,bl.NOPKGS,bl.DESCRIPTION,bl.GROSSWEIGHT,bl.MEASUREMENT,b.HSCODE,b.FINANCIALSTAFFFAX INSURANCEOP
,b.VESSEL,b.VOYNO,bl.CNTRTOTAL,b.BLTYPE,b.[SERVICE],b.ETD,b.ATD,b.ETA,b.CARRIER,bl.NOPKGS,bl.DESCRIPTION,bl.GROSSWEIGHT,bl.MEASUREMENT,b.HSCODE,b.FINANCIALSTAFFFAX INSURANCEOP
,(SELECT TOP 1 COMPTIME FROM op_status WHERE [STATUS]='Approached' AND BSNO=B.BSNO) LINKCUSTTIME
,(SELECT TOP 1 OpTime FROM op_SeaCover WHERE coverTitle='接单' AND BSNO=B.BSNO) CREATETIME
,(SELECT TOP 1 OpTime FROM op_SeaCover WHERE coverTitle='出号' AND BSNO=B.BSNO) MBLNOTIME
,bl.MODIFYTIME BSDATE
FROM op_seae_billmanage bl
LEFT JOIN op_seae b on (b.bsno=bl.BSNO)
WHERE
bl.MODIFYTIME&gt;=DATEADD(HOUR,-12 ,getdate())
<!--WHERE bl.MODIFYTIME&gt;=DATEADD(HOUR,-12 ,getdate())-->
</value>
</entry>
<!--WEB连接字符串-->
<entry>
<key>WebConnectString</key>
<value>Data Source=47.105.157.231;Initial Catalog=Shippingweb;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
<value>Data Source=127.0.0.1;Initial Catalog=EIPI_WEB;Persist Security Info=True;User ID=sa;Password=Ds20040201</value>
</entry>
<!--请求超时（单位：秒）-->
@ -564,17 +51,17 @@
</job-data-map>
</job>
<!-- 发送ATD请求数据任务触发器-->
<!-- 定时插入WEB数据库数据任务触发器-->
<trigger>
<cron>
<name>TriggerSendRequest</name>
<group>SendATDRequest</group>
<group>SendDs7DataRequest</group>
<description>发送数据请求触发器</description>
<job-name>JobSendATDRequest</job-name>
<job-group>SendATDRequest</job-group>
<cron-expression>0 0/10 * * * ? *</cron-expression>
<job-name>JobDs7ToWeb</job-name>
<job-group>SendDs7DataRequest</job-group>
<cron-expression>0/1 * * * * ? * </cron-expression>
</cron>
</trigger>
</trigger>

Write Preview
Loading…
Cancel
Save