SQL Server给一批用户分别单独发送销售数据清单

销售：我们想要知道自己今年以来的成交订单明细，但是并没有ERP的账号，怎么办？

我：ERP的数据都是客服人员录入的，你们自己卖了多少自己心里没点AC数吗？

销售：没。。

我：系统里有销售表，但是，里面是所有销售员的销售数据，我不能整个表群发，否则别人的秘密你都知道了。

销售：我们部门内部都相互沟通的，没有秘密。

我：呵呵，那是你们的事，我还是分开单独发吧。

1. 首先获取销售清单的YTD（本年）数据，并只拿出一些他们可以看的列，销售员编号作为参数。

CREATE PROC [dbo].[uf_GetYTDInvoicesSp]     
@slpcode int    --销售人员的编号作为参数
as    
SELECT     
    
[Invoice Date]    
      ,[DocNum]    
      ,[LineNum]    
      ,[Piece No]    
      ,[Product Type]    
      ,[Customer No]    
      ,replace([Customer Name],',','')    --因为csv是逗号分隔的，所以把字符串里的逗号去掉  
      ,[Country]    
      ,[SalesArea]    
      ,[Sales Order No]    
      ,[Delivery Note NO.]    
      ,[Delivery Date]    
      ,[Material No]    
      ,[Machine Number]    
      ,[Position Number]    
      ,[Internal Ordered Desgin]    
      ,[Order Length]    
      ,[Order Width]    
      ,[Order GSM/SQM]    
      ,[Order Unit]    
      ,[Sales Order Quantity]    
      ,[Sales Invoiced Amount(Incl.Vat)]    
      ,[Sales Invoiced Amount in USD without vat]    
      ,[DocCurrency]    
      ,[LineCurrency]    
      ,[invoiceno]    
      ,[Customer ref No]    
      ,[Source]    
      ,[ItmsGrpCod]    
      ,[ItmsGrpNam]    
      ,[slpcode]    
      ,[slpname]    
      --,[email]    
      ,[cardcode]    
      ,[PymntGroup]    
      ,[PaperGrade L1]    
      ,[PaperGrade L2]    
      ,[PaperGrade L3]    
      ,[Order Release Date]    
      ,[ID Piece No.]    
  FROM [xxxxdb].[dbo].[uf_SalesInvoiceReport]     
  where [invoice date] >= DATEADD(yy, DATEDIFF(yy,0,getdate()), 0)     
  and email is not null    
  and [slpcode] = @slpcode    
    
GO

2. 将销售员的数据导出到CSV文件中，并写好邮件模板。

CREATE PROCEDURE [dbo].[uf_GetInvoicesBySales]  
 @slpcode   int null  
   
AS  
BEGIN  
 DECLARE @xml   NVARCHAR(MAX)  
 DECLARE @body   NVARCHAR(MAX)   
 DECLARE @myname   VARCHAR(1000)  
 DECLARE @mycmd   VARCHAR(1000)  
 DECLARE @myattachment VARCHAR(1000)  
 DECLARE @slpemail  VARCHAR(100) = NULL  
 DECLARE @CopyMail  VARCHAR(200) = NULL  
 DECLARE @slpname  VARCHAR(100)  
 DECLARE @mysubject  VARCHAR(100)  
 --DECLARE @slpcode   int  
 --set @slpcode = 69
DROP TABLE IF EXISTS xeriumnewlive..MyTempTable_sub
DROP TABLE IF EXISTS xeriumnewlive..MyTempTable

 CREATE TABLE MyTempTable_sub (  
 [Invoice Date] [varchar](100) NULL,  
 [DocNum] [varchar](100) NULL,  
 [LineNum] [varchar](100) NULL,  
 [Piece No] [nvarchar](100) NULL,  
 [Product Type] [nvarchar](100) NULL,  
 [Customer No] [nvarchar](100) NULL,  
 [Customer Name] [nvarchar](100) NULL,  
 --[Customer Foreign Name] [nvarchar](100) NULL,  
 [Country] [nvarchar](100) NULL,  
 [SalesArea] [nvarchar](100) NULL,  
 [Sales Order No] [varchar](100) NULL,  
 [Delivery Note NO.] [varchar](100) NULL,  
 [Delivery Date] [varchar](100) NULL,  
 [Material No] [nvarchar](100) NULL,  
 [Machine Number] [nvarchar](100) NULL,  
 [Position Number] [nvarchar](100) NULL,  
 [Internal Ordered Desgin] [nvarchar](100) NULL,  
 [Order Length] [nvarchar](100) NULL,  
 [Order Width] [nvarchar](100) NULL,  
 [Order GSM/SQM] [nvarchar](100) NULL,  
 [Order Unit] [nvarchar](100) NULL,  
 [Sales Order Quantity] [nvarchar](100) NULL,  
 [Sales Invoiced Amount(Incl.Vat)] [nvarchar](100) NULL,  
 [Sales Invoiced Amount in USD without vat] [nvarchar](100) NULL,  
 [DocCurrency] [nvarchar](100) NULL,  
 [LineCurrency] [nvarchar](100) NULL,  
 [invoiceno] [nvarchar](100) NULL,  
 [Customer ref No] [nvarchar](100) NULL,  
 [Source] [nvarchar](100) NULL,  
 [ItmsGrpCod] [nvarchar](100) NULL,  
 [ItmsGrpNam] [nvarchar](100) NULL,  
 [slpcode] [nvarchar](100) NULL,  
 [slpname] [nvarchar](155) NULL,  
 --[email] [nvarchar](100) NULL,  
 [cardcode] [nvarchar](15) NULL,  
 [PymntGroup] [nvarchar](100) NULL,  
 [PaperGrade L1] [nvarchar](100) NULL,  
 [PaperGrade L2] [nvarchar](100) NULL,  
 [PaperGrade L3] [nvarchar](100) NULL,  
 [Order Release Date] [nvarchar](100) NULL,  
 [ID Piece No.] [nvarchar](100) NULL  
 ) 
  
 CREATE TABLE MyTempTable(  
 [Invoice Date] [varchar](100) NULL,  
 [DocNum] [varchar](100) NULL,  
 [LineNum] [varchar](100) NULL,  
 [Piece No] [nvarchar](100) NULL,  
 [Product Type] [nvarchar](100) NULL,  
 [Customer No] [nvarchar](100) NULL,  
 [Customer Name] [nvarchar](100) NULL,  
 --[Customer Foreign Name] [nvarchar](100) NULL,  
 [Country] [nvarchar](100) NULL,  
 [SalesArea] [nvarchar](100) NULL,  
 [Sales Order No] [varchar](100) NULL,  
 [Delivery Note NO.] [varchar](100) NULL,  
 [Delivery Date] [varchar](100) NULL,  
 [Material No] [nvarchar](100) NULL,  
 [Machine Number] [nvarchar](100) NULL,  
 [Position Number] [nvarchar](100) NULL,  
 [Internal Ordered Desgin] [nvarchar](100) NULL,  
 [Order Length] [nvarchar](100) NULL,  
 [Order Width] [nvarchar](100) NULL,  
 [Order GSM/SQM] [nvarchar](100) NULL,  
 [Order Unit] [nvarchar](100) NULL,  
 [Sales Order Quantity] [nvarchar](100) NULL,  
 [Sales Invoiced Amount(Incl.Vat)] [nvarchar](100) NULL,  
 [Sales Invoiced Amount in USD without vat] [nvarchar](100) NULL,  
 [DocCurrency] [nvarchar](100) NULL,  
 [LineCurrency] [nvarchar](100) NULL,  
 [invoiceno] [nvarchar](100) NULL,  
 [Customer ref No] [nvarchar](100) NULL,  
 [Source] [nvarchar](100) NULL,  
 [ItmsGrpCod] [nvarchar](100) NULL,  
 [ItmsGrpNam] [nvarchar](100) NULL,  
 [slpcode] [nvarchar](100) NULL,  
 [slpname] [nvarchar](155) NULL,  
 --[email] [nvarchar](100) NULL,  
 [cardcode] [nvarchar](15) NULL,  
 [PymntGroup] [nvarchar](100) NULL,  
 [PaperGrade L1] [nvarchar](100) NULL,  
 [PaperGrade L2] [nvarchar](100) NULL,  
 [PaperGrade L3] [nvarchar](100) NULL,  
 [Order Release Date] [nvarchar](100) NULL,  
 [ID Piece No.] [nvarchar](100) NULL  
 )   
  
  
 --根据销售人员的代码，向MyTempTable_sub表中添加数据集  
 INSERT INTO MyTempTable_sub  
 EXEC dbo.uf_GetYTDInvoicesSp @slpcode  
   
 INSERT INTO MyTempTable  
 --这里做一个虚拟的表头，放在CSV文件中
 SELECT 'Invoice Date'  
      ,'DocNum'  
      ,'LineNum'  
      ,'Piece No'  
      ,'Product Type'  
      ,'Customer No'  
      ,'Customer Name'  
      --,'Customer Foreign Name'  
      ,'Country'  
      ,'SalesArea'  
      ,'Sales Order No'  
      ,'Delivery Note NO.'  
      ,'Delivery Date'  
      ,'Material No'  
      ,'Machine Number'  
      ,'Position Number'  
      ,'Internal Ordered Desgin'  
      ,'Order Length'  
      ,'Order Width'  
      ,'Order GSM/SQM'  
      ,'Order Unit'  
      ,'Sales Order Quantity'  
      ,'Sales Invoiced Amount(Incl.Vat)'  
      ,'Sales Invoiced Amount in USD without vat'  
      ,'DocCurrency'  
      ,'LineCurrency'  
      ,'invoiceno'  
      ,'Customer ref No'  
      ,'Source'  
      ,'ItmsGrpCod'  
      ,'ItmsGrpNam'  
      ,'slpcode'  
      ,'slpname'  
      --,'email'  
      ,'cardcode'  
      ,'PymntGroup'  
      ,'PaperGrade L1'  
      ,'PaperGrade L2'  
      ,'PaperGrade L3'  
      ,'Order Release Date'  
      ,'ID Piece No.'  
 union all  
 ---销售数据明细
 SELECT ISNULL([Invoice Date], '')
      ,ISNULL([DocNum], '')  
      ,ISNULL([LineNum], '')  
      ,ISNULL([Piece No], '')  
      ,ISNULL([Product Type], '')  
      ,ISNULL([Customer No], '')  
      ,ISNULL([Customer Name], '')  
      --,ISNULL([Customer Foreign Name], '')  
      ,ISNULL([Country], '')  
      ,ISNULL([SalesArea], '')  
      ,ISNULL([Sales Order No], '')  
      ,ISNULL([Delivery Note NO.], '')  
      ,ISNULL([Delivery Date], '')  
      ,ISNULL([Material No], '')  
      ,ISNULL([Machine Number], '')  
      ,ISNULL([Position Number], '')  
      ,ISNULL([Internal Ordered Desgin], '')  
      ,ISNULL([Order Length], '')  
      ,ISNULL([Order Width], '')  
      ,ISNULL([Order GSM/SQM], '')  
      ,ISNULL([Order Unit], '')  
      ,ISNULL([Sales Order Quantity], '')  
      ,ISNULL([Sales Invoiced Amount(Incl.Vat)], '')  
      ,ISNULL([Sales Invoiced Amount in USD without vat], '')  
      ,ISNULL([DocCurrency], '')  
      ,ISNULL([LineCurrency], '')  
      ,ISNULL([invoiceno], '')  
      ,ISNULL([Customer ref No], '')  
      ,ISNULL([Source], '')  
      ,ISNULL([ItmsGrpCod], '')  
      ,ISNULL([ItmsGrpNam], '')  
      ,ISNULL([slpcode], '')  
      ,ISNULL([slpname], '')  
      --,ISNULL([email], '')  
      ,ISNULL([cardcode], '')  
      ,ISNULL([PymntGroup], '')  
      ,ISNULL([PaperGrade L1], '')  
      ,ISNULL([PaperGrade L2], '')  
      ,ISNULL([PaperGrade L3], '')  
      ,ISNULL([Order Release Date], '')  
      ,ISNULL([ID Piece No.], '')  
 FROM MyTempTable_sub     
   
 select @slpemail = email from oslp where slpcode = @slpcode  
 select @slpname = slpname from oslp where slpcode = @slpcode  
  
  
 SET @body ='<html>  
    <body style= "font-size:10pt;font-family:arial;line-height:15pt;">  
    <p>
        Dear ' + @slpname + ', ' +
    '</p>
    <p>
        Please check the attachment to review your invoiced orders for this year.<br>
        The system automatically sends this report to you every Tuesday at 8:30 a.m
    </p>
    <p>
        * Please don''t reply to this email directly!<br>
        * At the beginning of each year, the records in this table may be small or empty because it''s YTD data!
    </p>  
    <p>
        Best Regards,<br> 
        <strong><font color="#0075be">
            公司名
        </font></strong>
    </p>
    </body>
    </html>
    '  
  
 SET @myname = 'Invoice_List'+ ' YTD_' + convert(varchar(10),year(GetDate()))+' '+replace(@slpname,' ','_')+' ' +CONVERT(varchar(12) , getdate(), 23)+'.csv'  
 --导出附件
 SET @mycmd = 'bcp "SELECT * FROM xxxxdb..MyTempTable order by [invoice date] desc" queryout "D:	emp' + @myname + '" -T -c -t","'  
 SET @myattachment = 'D:	emp' + @myname  
 SET @mysubject = 'Invoice_List'+ ' YTD_' + convert(varchar(10),year(GetDate()))+' '+replace(@slpname,' ','_')   

----打开高级设置  
--EXEC sp_configure 'show advanced options', 1  
--RECONFIGURE  
----打开xp_cmdshell扩展存储过程  
--EXEC sp_configure 'xp_cmdshell', 1  
--RECONFIGURE  
  
  
 EXEC xp_cmdshell @mycmd  
  
 EXEC msdb.dbo.sp_send_dbmail  
  @profile_name     = 'xxx.noreply'
  ,@recipients     =    @slpemail
  ,@body    = @body  
  ,@body_format    = 'HTML'  
  ,@subject      = @mysubject  
  ,@file_attachments    = @myattachment  --添加附件
  ;  
  
  
----关闭xp_cmdshell扩展存储过程、高级设置  
--EXEC sp_configure 'xp_cmdshell', 0  
--RECONFIGURE  
--EXEC sp_configure 'show advanced options', 0  
--RECONFIGURE  

DROP TABLE IF EXISTS MyTempTable_sub
DROP TABLE IF EXISTS MyTempTable

END  
GO

3. 利用游标，逐个抓取销售人员的编号，并将此编号作为参数传递给上一步的存储过程。

CREATE PROC [dbo].[uf_Split_SendInvoices2Sales]  

AS  
  
declare @slpcode int  
declare cusinfo cursor scroll --定义游标 --scroll为滚动游标  
    for  
    --select slpcode from oslp where email is not null  
    select slpcode FROM [xxxxdb].[dbo].[uf_SalesInvoiceReport]  where email is not null and slpcode not in (65) and [invoice date] >= DATEADD(yy, DATEDIFF(yy,0,getdate()), 0)    group by slpcode --确保没有销售记录的人员以及某些特人员不需要收到邮件
open cusinfo -- 打开游标  
fetch next from cusinfo INTO  @slpcode  --抓取下一行游标数据  
while @@fetch_status=0 --0 FETCH 语句成功; -1 FETCH 语句失败或此行不在结果集中; -2 被提取的行不存在  
    begin  
        exec uf_GetInvoicesBySales @slpcode    
        fetch next from cusinfo into @slpcode --抓取下一行游标数据  
    end  
close cusinfo --关闭游标  
deallocate cusinfo --释放游标
GO

4. 创建Job，定时发送。我用的是图形化界面创建的。

 OK，大功告成。