项目存储过程记录

Posted Againn

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了项目存储过程记录相关的知识,希望对你有一定的参考价值。

CREATE DEFINER=`sas_settle`@`%` PROCEDURE `P_CREATE_ACCOUNT_CARRIER_TASK`()
BEGIN
    DECLARE done INT DEFAULT 0;
    DECLARE v_flow_id VARCHAR(10);                        -- 流水号
    DECLARE v_prefix VARCHAR(10) DEFAULT JS; -- 业务前缀
    
    #账期任务字段
    DECLARE v_belong VARCHAR(20);            -- 帐号
    DECLARE v_parent_id VARCHAR(20);    -- 父帐号
    DECLARE v_member_name VARCHAR(50); -- 结算商家
    DECLARE v_title_type INT;    -- 结算类型
    DECLARE v_title VARCHAR(2);            -- 结算日
    DECLARE v_year VARCHAR(4);                -- 年度
    DECLARE v_month VARCHAR(2);    -- 月度
    DECLARE v_set_no_type VARCHAR(2);      -- 账户类型(0:铁运 1:非铁运)
    DECLARE v_vip_type VARCHAR(2);        -- 用户类型    1:个人;2:企业
    DECLARE v_start_date DATE DEFAULT NOW(); -- 结算起始日期
    DECLARE v_end_date DATE DEFAULT NOW(); -- 结算结束日期
    DECLARE v_last_period_end DATE ; -- 上期结算结束日期
    DECLARE v_flag INT DEFAULT 0; -- 是否生成任务
    DECLARE v_last_title_type INT;-- 上期任务的结算类型
    DECLARE v_count INT DEFAULT 0; -- 同一个用户未执行任务存在的数目

    DECLARE y_year VARCHAR(4) DEFAULT YEAR(NOW()); -- 年份
    DECLARE i INT DEFAULT 0; -- 遍历标识
    #声明游标:所有年份
        #DECLARE y_cursor CURSOR FOR 
            #SELECT y.`YEAR` FROM sas_year y;
    
    #声明游标:清算日为当天且未生成任务的用户
    DECLARE v_cursor CURSOR FOR
        SELECT
            ME.BELONG,
            me.MEMBER_NAME,
            me.PARENT_ID,
            mri.TITLE,
            mri.TITLE_TYPE,
            mri.VIP_TYPE,
            mri.ACCOUNT_TYPE,
            YEAR (NOW()) YY,
            (SELECT tt.PERIOD_END FROM sas_task_carrier_pay_order_period tt 
                WHERE tt.BELONG = me.BELONG 
                ORDER BY tt.CREATE_TIME DESC LIMIT 0,1) last_period_end,
            (SELECT tt.SET_TYPE FROM sas_task_carrier_pay_order_period tt 
                WHERE tt.BELONG = me.BELONG 
                ORDER BY tt.CREATE_TIME DESC LIMIT 0,1) last_title_type
        FROM sas_member ME
        LEFT JOIN sas_member_rule_info mri ON (
            me.PARENT_ID = mri.USER_ID
            OR me.BELONG = mri.USER_ID
        ) AND mri.ENABLE_STATUS = 1
        WHERE me.ENABLE_STATUS = 1 
         AND NOT EXISTS (
            SELECT 1
            FROM sas_task_account_carrier_period t
            WHERE t.BELONG = me.BELONG
            #结算日为当天(月结周结)
            AND CASE WHEN mri.TITLE_TYPE = 10 THEN t.SET_DATE = WEEKDAY(now()) + 1 and t.SET_TYPE=10 and DATE_SUB(str_to_date(NOW(),%Y-%m-%d),INTERVAL 1 day) =t.PERIOD_END
            WHEN mri.TITLE_TYPE = 20 THEN t.SET_DATE = DAYOFMONTH(now()) and t.SET_TYPE=20  and DATE_SUB(str_to_date(NOW(),%Y-%m-%d),INTERVAL 1 day) =t.PERIOD_END
            #一单一结
            WHEN mri.TITLE_TYPE = 1 THEN t.TASK_STATUS = 0 and t.SET_TYPE=1
            END
        ) AND EXISTS(
            SELECT 1
            FROM sas_order_reports r
            #清算报表存在没出账单、未生成账单,没生成过账单,并且是非铁路的账单
            WHERE r.belong=me.belong and r.order_set_status =10 and r.is_create_account=10 and r.have_create_account=10 and r.IS_RAILWAY!=01
        )    AND CASE WHEN mri.TITLE_TYPE = 10 OR mri.TITLE_TYPE = 20 THEN
            EXISTS(
            SELECT 1
            FROM sas_order_reports r
            #清算报表存在没出账单、未生成账单,没生成过账单,并且是非铁路的账单
            WHERE r.belong=me.belong and r.order_set_status =10 and r.is_create_account=10 and r.have_create_account=10 and r.IS_RAILWAY!=01 and r.create_time<=DATE_SUB(str_to_date(NOW(),%Y-%m-%d),INTERVAL 1 day)
            ) END;
        
        #如果是一单一结 只生成有账单,且已审核的,且未生成过付款单的
        /*AND CASE WHEN mri.TITLE_TYPE=‘1‘ THEN EXISTS (SELECT id from sas_set_account_carrier_2016 s
            where s.BELONG =me.BELONG AND s.set_status=‘20‘ AND s.IS_PAYMENT!=‘1‘) END;*/
            
    
    
    /* 声明Continue Handler: 当游标到达尾部时,mysql自动设置done=1 */     
      DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1; 
    OPEN v_cursor;
    curLoop:LOOP
        FETCH v_cursor INTO v_belong, v_member_name, v_parent_id, v_title,v_title_type,
        v_vip_type,v_set_no_type,v_year,v_last_period_end,v_last_title_type;
        
        IF done=1 THEN
            LEAVE curLoop;
        END IF;
        SET v_flag = 0;
        #月结
        IF v_title_type IS NOT NULL AND v_title_type = 20 THEN
            
            #账期为当天
            IF v_title IS NOT NULL AND DAY(NOW()) = v_title THEN
                SET v_flag = 1;
                SET v_start_date = DATE_SUB(NOW(), INTERVAL 1 MONTH);
                SET v_end_date = DATE_SUB(NOW(), INTERVAL 1 DAY);
            
            #当帐期为31日时,当月只有30天情况,则本次帐期默认为30日
            ELSEIF v_title IS NOT NULL AND DAY(NOW()) = DAY(LAST_DAY(now())) AND v_title > DAY(LAST_DAY(now())) THEN
                SET v_flag = 1;
                SET v_title = DAY(LAST_DAY(now()));
                SET v_start_date = DATE_SUB(NOW(), INTERVAL 1 MONTH);
                SET v_end_date = DATE_SUB(NOW(), INTERVAL 1 DAY);
            END IF;

        #周结
        ELSEIF v_title_type IS NOT NULL AND v_title_type = 10 THEN
            #结算日为当天
            IF v_title IS NOT NULL AND v_title = WEEKDAY(NOW()) + 1 THEN
                SET v_flag = 1;
                SET v_end_date = DATE_SUB(NOW(), INTERVAL 1 DAY);
                SET v_start_date = DATE_SUB(NOW(), INTERVAL 1 WEEK);
            END IF;
        
        #一单一结
        ELSEIF v_title_type IS NOT NULL AND v_title_type= 1 THEN 
            #账期为清算报表的创建时间(后修改为账期为现在的时间)
            SELECT min(NOW()) INTO v_end_date FROM sas_order_reports r where r.belong=v_belong and r.is_create_account=10 and r.have_create_account=10;
            SET v_start_date=v_end_date;
            SET v_flag=1;
        END IF;


        #如果上期结算结束日期有值,且不是一单一结,则本期账单开始日期 = 上期结束日期 + 1天
        IF v_last_period_end IS NOT NULL AND v_last_period_end <> ‘‘ AND v_last_title_type !=1 THEN
            SET v_start_date = DATE_ADD(v_last_period_end, INTERVAL 1 DAY);
        ELSEIF  v_last_period_end IS NOT NULL AND v_last_period_end <> ‘‘ AND v_last_title_type =1 THEN
            SET v_start_date =v_last_period_end;
        END IF;
        
        #如果开始时间大于结束时间,设置开始时间等于结束时间
        IF v_start_date>v_end_date THEN
            SET v_start_date=v_end_date;
        END IF;
        
        #排除帐期为空的数据
        IF v_flag = 1 THEN
        
            #获取流水号
            CALL P_GET_SEQNO(v_prefix,4,0,2,v_flow_id);
            SET v_month = MONTH(v_start_date);
            
            #流水号转换为纯数字
            SET v_flow_id=v_flow_id+0;

            #查询任务重复的数量
            SELECT COUNT(1) into v_count FROM sas_task_account_carrier_period
            WHERE BELONG = v_belong and TASK_STATUS=0 and DATE_FORMAT(CREATE_TIME,%Y-%m-%d)=DATE_FORMAT(SYSDATE(),%Y-%m-%d);
            
            #不存在重复才生成
            IF v_count=0 THEN
            #生成任务
            INSERT INTO sas_task_account_carrier_period
            ( `YEAR`,
                `MONTH`,
                PERIOD_START,
                PERIOD_END,
                BELONG,
                PARENT_ID,
                MEMBER_NAME,
                SET_TYPE,
                SET_DATE,
                SET_NO_TYPE,
                TASK_STATUS,
                VIP_TYPE,
                CREATE_BY,
                CREATE_TIME,
                LAST_UPDATE_BY,
                LAST_UPDATE_TIME,
                ENABLE_STATUS,
                FLOW_ID
            ) VALUES (    
                v_year,
                v_month,
                v_start_date,
                v_end_date,
                v_belong,
                v_parent_id,
                v_member_name,
                v_title_type,
                v_title,
                v_set_no_type,
                0,
                v_vip_type,
                system,SYSDATE(),system,SYSDATE(),1,v_flow_id
            );
            END IF;
        END IF;
    END LOOP curLoop;

    COMMIT;
END
CREATE DEFINER=`sas_settle`@`%` PROCEDURE `P_CREATE_ACCOUNT_CARRIER`(IN p_task_id INT, -- 任务primary key
    IN p_user_id VARCHAR(20), -- 用户id
    IN p_belong VARCHAR(20), -- 母账号
    IN p_title_type VARCHAR(2), -- 结算类型:‘10‘周结,‘20‘月结,‘1‘现结
    IN p_title VARCHAR(2), -- 结算日
    IN p_set_start DATETIME, -- 账单开始日
    IN p_set_end DATETIME, -- 账单结束日
    IN p_year VARCHAR(4), -- 账单年份
    IN p_month VARCHAR(2), -- 账单月份
    IN p_vip_type VARCHAR(2), -- 用户类型
    IN p_flow_no VARCHAR(10))
BEGIN
    -- 辅助字段
    DECLARE v_table_c varchar(50) DEFAULT sas_not_railway_account_carrier_month_pay; -- 非铁路承运商帐单表
    DECLARE v_table_c_com VARCHAR(50) DEFAULT sas_not_railway_account_carrier_month_pay_detail; -- 非铁路承运商帐单明细表
    DECLARE v_prefix VARCHAR(10) DEFAULT JS;-- 业务前缀
    DECLARE v_tmp_count int default 0; -- 临时表数据量
    DECLARE v_min_id INT DEFAULT 1;
    DECLARE v_max_id INT DEFAULT 1;
    DECLARE v_report_id  INT UNSIGNED; -- 清算报表id
    DECLARE v_exception VARCHAR(10) DEFAULT ‘‘; -- 异常处理
    
-- 表头数据

    DECLARE v_sys_code VARCHAR(10) DEFAULT 10;-- 系统来源‘,
    DECLARE v_member_name VARCHAR(50); -- 清算对象
    DECLARE v_pay_way VARCHAR(2) DEFAULT 1; -- 账单类型
    DECLARE v_belong VARCHAR(20); -- 用户ID
    DECLARE v_set_date datetime DEFAULT NOW(); -- 账单时间
    DECLARE v_audit_time datetime; -- 审核时间
    DECLARE v_set_no  varchar(30); -- 清算账单号
    -- DECLARE v_p_order_no VARCHAR(30); -- 母订单号
    -- DECLARE v_order_no VARCHAR(30); -- 子订单号
    -- DECLARE v_trans_no VARCHAR(64); -- 运单号
    DECLARE v_pay_money NUMERIC(20,2);-- 账单金额
    DECLARE v_set_status VARCHAR(2) DEFAULT 10; -- 账单状态
    DECLARE v_pay_status VARCHAR(2) DEFAULT 10; -- 支付状态
    DECLARE v_is_print_pay VARCHAR(2) DEFAULT 10; -- 付款单
    DECLARE v_carrier_org_level_code VARCHAR(20) DEFAULT 0001; -- 承运商组织层级编码

-- 明细数据
  -- DECLARE v_set_no VARCHAR(30); -- 清算账单号,
  DECLARE v_order_no VARCHAR(30); -- 子订单号,
  DECLARE v_trans_no VARCHAR(30); -- 运单号,
  DECLARE v_p_order_no VARCHAR(30); -- 母订单号,
  DECLARE v_year VARCHAR(4) DEFAULT year(NOW()); -- 会计年度,
  DECLARE v_month VARCHAR(2) DEFAULT month(NOW()); -- 会计月度,
  DECLARE v_order_time datetime; -- 订单生成时间,
  DECLARE v_order_money NUMERIC(20,2); -- 订单金额,
  DECLARE v_claiming_value NUMERIC(20,2); -- 声明价值(元),
  DECLARE v_insurance_fee NUMERIC(20,2); -- 保价费,
  DECLARE v_premium NUMERIC(20,2); -- 保价差额,
  DECLARE v_basic_price NUMERIC(20,2); -- 基本运费,
  DECLARE v_rise_price NUMERIC(20,2); -- 上浮运费,
  DECLARE v_platform_buckle_point NUMERIC(20,3); -- 平台扣点,
  DECLARE v_platform_buckle_point_fee NUMERIC(20,2); -- 平台扣点费,
  DECLARE v_rebates_rate NUMERIC(20,3); -- 返点费率,
  DECLARE v_rebates_rate_fee NUMERIC(20,2); -- 返 点 费(母账号),
  DECLARE v_arbitrage_code VARCHAR(30); -- 仲裁单号,
  DECLARE v_carrier_rec_pay NUMERIC(20,2); -- 承运商收赔费,
  DECLARE v_supply_pay NUMERIC(20,2); -- 发货方应付,
  DECLARE v_carrier_verification_freight NUMERIC(20,2); -- 已核销运费(承运商),
  DECLARE v_carrier_denghexiao_money NUMERIC(20,2); -- 等核销金额(承运商),
  DECLARE v_carrier_com_rec NUMERIC(20,2); -- 公司应收(承运商),
  DECLARE v_reverse_money NUMERIC(20,2) DEFAULT 0; -- 冲销金额,
  DECLARE v_platform_discount_rate NUMERIC(20,2); -- 平台扣点折扣率,
  DECLARE v_platform_discount_fee NUMERIC(20,2); -- 平台扣点折扣费,
  DECLARE v_actual_platform_discount_fee NUMERIC(20,2); -- 实际平台扣点费,
  DECLARE v_create_by VARCHAR(20) DEFAULT system; -- 创建人
  DECLARE v_create_time DATETIME DEFAULT NOW(); -- 创建时间
  DECLARE v_enable_status INT DEFAULT 1; -- 数据有效性:默认有效
    
  DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET v_exception = error;
  -- 启动事务
  -- START TRANSACTION; 
  
  -- 创建临时表,用于临时存储承运商账单明细表数据
  DROP TEMPORARY TABLE IF EXISTS account_detail_tmp;
  CREATE TEMPORARY TABLE account_detail_tmp(
      id INT UNSIGNED NOT NULL AUTO_INCREMENT, -- 自增ID
      belong VARCHAR(20), -- 用户ID
      member_name VARCHAR(50), -- 清算对象
      -- set_no VARCHAR(30), -- 清算单号,
      order_no VARCHAR(30), -- 子订单号,
      p_order_no VARCHAR(30), -- 母订单号,
      trans_no VARCHAR(30), -- 运单号,
      -- year VARCHAR(4), -- 会计年度,
      -- month VARCHAR(2), -- 会计月度,
      order_time datetime, -- 订单生成时间,
      order_money NUMERIC(20,2), -- 订单金额,
      claiming_value NUMERIC(20,2), -- 声明价值(元),
      insurance_fee NUMERIC(20,2), -- 保价费,
      premium NUMERIC(20,2), -- 保价差额,
      basic_price NUMERIC(20,2), -- 基本运费,
      rise_price NUMERIC(20,2), -- 上浮运费,
      platform_buckle_point NUMERIC(20,3), -- 平台扣点,
      platform_buckle_point_fee NUMERIC(20,2), -- 平台扣点费,
      rebates_rate NUMERIC(20,3), -- 返点费率,
      rebates_rate_fee NUMERIC(20,2), -- 返 点 费(母账号),
      arbitrage_code VARCHAR(30), -- 仲裁单号,
      carrier_rec_pay NUMERIC(20,2), -- 承运商收赔费,
      supply_pay NUMERIC(20,2), -- 发货方应付,
      carrier_verification_freight NUMERIC(20,2), -- 已核销运费(承运商),
      carrier_denghexiao_money NUMERIC(20,2), -- 等核销金额(承运商),
      carrier_com_rec NUMERIC(20,2), -- 公司应收(承运商),
      platform_discount_rate NUMERIC(20,2), -- 平台扣点折扣率,
      platform_discount_fee NUMERIC(20,2), -- 平台扣点折扣费,
      actual_platform_discount_fee NUMERIC(20,2), -- 实际平台扣点费,
      report_id  INT , -- 清算报表id
      reverse_money NUMERIC(20,2), -- 冲销金额,
      -- create_by VARCHAR(20) DEFAULT ‘system‘, -- 创建人
      -- create_time DATETIME DEFAULT NOW(), -- 创建时间
      -- enable_status INT DEFAULT 1, -- 数据有效性:默认有效
      primary key(id)
  );
      
    IF p_belong IS NOT NULL AND p_belong <> ‘‘ THEN
        SET v_belong = p_belong;
    ELSEIF p_user_id IS NOT NULL AND p_user_id <> ‘‘ THEN
        SET v_belong = p_user_id;
    END IF;
  
    
    #将清算周期内清算报表的数据插入到临时表
    #为了防止漏单,数据取清算周期最晚时间之前所有没生成过账单的清算报表数据,不需区分清算周期(月结、周结、一单一结)
    SET @insert_tmp_table = CONCAT(insert into account_detail_tmp(belong,member_name,order_no,p_order_no,trans_no,,
             order_time,order_money,claiming_value,insurance_fee,premium,basic_price,rise_price,platform_buckle_point,,
             platform_buckle_point_fee,rebates_rate,rebates_rate_fee,arbitrage_code,carrier_rec_pay,supply_pay,,
             carrier_verification_freight,carrier_denghexiao_money,carrier_com_rec,platform_discount_rate,,
             platform_discount_fee,actual_platform_discount_fee,report_id,reverse_money) ,
             select r.BELONG,,
             (select CARRIER_NAME FROM sas_order_reports WHERE BELONG=,v_belong,  order by id desc limit 1 ),,
             r.ORDER_NO,r.P_ORDER_NO,r.WAYBILL_NO,,
             r.ORDER_TIME,r.ORDER_MONEY,r.CLAIMING_VALUE,r.INSURANCE_FEE,r.PREMIUM,r.BASIC_PRICE,r.RISE_PRICE,r.PLATFORM_BUCKLE_POINT,,
             r.PLATFORM_BUCKLE_POINT_FEE,r.REBATES_RATE,r.REBATES_RATE_FEE,r.ARBITRAGE_CODE,r.CARRIER_REC_PAY,r.SUPPLY_PAY,,
             r.CARRIER_VERIFICATION_FREIGHT,r.CARRIER_DENGHEXIAO_MONEY,r.CARRIER_COM_REC,r.PLATFORM_DISCOUNT_RATE,,
             r.PLATFORM_DISCOUNT_FEE,r.ACTUAL_PLATFORM_DISCOUNT_FEE,r.ID,r.REVERSE_MONEY from sas_order_reports r where r.belong = ,v_belong,
             and r.ORDER_SET_STATUS !=20 and r.IS_CREATE_ACCOUNT !=20 and r.HAVE_CREATE_ACCOUNT!=20 and r.IS_RAILWAY!=\01\ and ,
             str_to_date(r.create_time,\%Y-%m-%d\) <= str_to_date(\‘‘,p_set_end,\,\%Y-%m-%d\) order by r.id);
    PREPARE insert_tmp_table_stmt FROM @insert_tmp_table;
    EXECUTE insert_tmp_table_stmt;
    
    DEALLOCATE PREPARE insert_tmp_table_stmt;
    
    #查询临时表数据数量
    SELECT COUNT(1) INTO v_tmp_count FROM account_detail_tmp;
            SELECT v_tmp_count;
    
    #如果临时表有数据,正常账单
    IF v_tmp_count>0 THEN
        
        #如果是一单一结那一条账单对应一条订单
        IF p_title_type=1 THEN
        
            #取出临时表的最小id和最大id,用于循环插入明细表
            SELECT min(id) INTO v_min_id FROM account_detail_tmp;
            SELECT max(id) INTO v_max_id FROM account_detail_tmp;
            
            #从临时表查询数据,保存到明细表
            WHILE v_min_id - 1 < v_max_id DO
                
                #获取订单总金额及公共信息(承运商、belong等)用于生成账单表头
                select SUM(carrier_denghexiao_money),member_name,belong,SUM(IFNULL(reverse_money,0)) into v_pay_money,v_member_name,v_belong,v_reverse_money from account_detail_tmp  WHERE id=v_min_id;
                SET v_pay_money = v_pay_money - v_reverse_money;
                #清算账单号
                IF p_flow_no IS NULL THEN
                    CALL P_GET_SEQNO(v_prefix,4,0,2,p_flow_no);
                END IF;
                
                SET v_set_no = CONCAT(v_prefix, DATE_FORMAT(NOW(),%Y%m%d%H%i%S), LPAD(v_min_id, 4, 0));

                #生成承运商账单(非铁路)表头
                SET @insert_head_sql=CONCAT(insert into , v_table_c,  (SYS_CODE,SET_NO,BELONG,MEMBER_NAME,SET_DAY,,
                                     SET_TYPE,SET_START,SET_END,YEAR,MONTH,PAY_WAY,SET_DATE,PAY_MONEY,SET_STATUS,PAY_STATUS,,
                                     IS_PRINT_PAY,CARRIER_ORG_LEVEL_CODE,CREATE_BY,CREATE_TIME,ENABLE_STATUS) 
                                     values(\‘‘,v_sys_code,\,\‘‘,v_set_no,\,\‘‘,v_belong,\,\‘‘,v_member_name,\,\‘‘,p_title,
                                     \,\‘‘,p_title_type,\,\‘‘,p_set_start,\,\‘‘,p_set_end,\,\‘‘,v_year,\,\‘‘,v_month,\,\‘‘,v_pay_way,\,\‘‘,v_set_date,\,\‘‘,v_pay_money,\,\‘‘,v_set_status,\,\‘‘,v_pay_status,
                                     \,\‘‘,v_is_print_pay,\,\‘‘,v_carrier_org_level_code,\,\‘‘,v_create_by,\,\‘‘,v_create_time,\,\‘‘,v_enable_status,\));
                PREPARE insert_head_stmt FROM @insert_head_sql;
                EXECUTE insert_head_stmt;
                DEALLOCATE PREPARE insert_head_stmt;
                
                #账单id赋值
            SELECT report_id INTO v_report_id FROM account_detail_tmp WHERE id=v_min_id;
                #生成承运商账单明细(非铁路)
                    SET @insert_detail_sql=CONCAT(insert into ,v_table_c_com,
                         (SET_NO,ORDER_NO,TRANS_NO,P_ORDER_NO,YEAR,MONTH,ORDER_TIME,ORDER_MONEY,CLAIMING_VALUE,,
                         INSURANCE_FEE,PREMIUM,BASIC_PRICE,RISE_PRICE,PLATFORM_BUCKLE_POINT,PLATFORM_BUCKLE_POINT_FEE,,
                         REBATES_RATE,REBATES_RATE_FEE,ARBITRAGE_CODE,CARRIER_REC_PAY,SUPPLY_PAY,CARRIER_VERIFICATION_FREIGHT,,
                         CARRIER_DENGHEXIAO_MONEY,CARRIER_COM_REC,CREATE_BY,CREATE_TIME,ENABLE_STATUS,,
                         PLATFORM_DISCOUNT_RATE,PLATFORM_DISCOUNT_FEE,ACTUAL_PLATFORM_DISCOUNT_FEE),
                         select \‘‘,v_set_no,\,order_no,trans_no,p_order_no,,\‘‘,v_year,\,\‘‘,v_month,\,order_time,order_money,claiming_value,,
                         insurance_fee,premium,basic_price,rise_price,platform_buckle_point,platform_buckle_point_fee,,
                         rebates_rate,rebates_rate_fee,arbitrage_code,carrier_rec_pay,supply_pay,carrier_verification_freight,,
                         carrier_denghexiao_money,carrier_com_rec,,\‘‘,v_create_by,\,\‘‘,v_create_time,\,\‘‘,v_enable_status,
                         \, platform_discount_rate,platform_discount_fee,actual_platform_discount_fee from account_detail_tmp where id=, v_min_id);
                    
                PREPARE insert_detail_stmt FROM @insert_detail_sql;
                EXECUTE insert_detail_stmt;
                
                #更新清算报表状态为已生成账单、已生成过账单、已出账单
                SET @update_report_sql=CONCAT(update sas_order_reports set IS_CREATE_ACCOUNT =\20\, HAVE_CREATE_ACCOUNT=\20\,ORDER_SET_STATUS=\20\, LAST_UPDATE_TIME=SYSDATE(),LAST_UPDATE_BY=\system\  where id=,v_report_id);
                PREPARE update_report_stmt FROM @update_report_sql;
                EXECUTE update_report_stmt;
                
                SET v_min_id = v_min_id + 1;
            
            
            END WHILE;
            
                #释放资源
                DEALLOCATE PREPARE insert_detail_stmt;
                DEALLOCATE PREPARE update_report_stmt;
            
        
        #月结或周结一个账单对应多个订单
        ELSEIF p_title_type !=1 THEN
    
            
            #明细表
            #取出临时表的最小id和最大id,用于循环插入明细表
            SELECT min(id) INTO v_min_id FROM account_detail_tmp;
            SELECT max(id) INTO v_max_id FROM account_detail_tmp;

#获取订单总金额及公共信息(承运商、belong等)用于生成账单表头
            select SUM(carrier_denghexiao_money),member_name,belong,SUM(IFNULL(reverse_money,0)) into v_pay_money,v_member_name,v_belong,v_reverse_money from account_detail_tmp;
            SET v_pay_money = v_pay_money - v_reverse_money;
            SELECT v_reverse_money,v_pay_money;
            #清算账单号
            IF p_flow_no IS NULL THEN
                CALL P_GET_SEQNO(v_prefix,4,0,2,p_flow_no);
            END IF;
            
            SET v_set_no = CONCAT(v_prefix, DATE_FORMAT(NOW(),%Y%m%d%H%i%S), LPAD(p_flow_no, 4, 0));

            #生成承运商账单(非铁路)表头
            SET @insert_head_sql=CONCAT(insert into , v_table_c,  (SYS_CODE,SET_NO,BELONG,MEMBER_NAME,SET_DAY,,
                                 SET_TYPE,SET_START,SET_END,YEAR,MONTH,PAY_WAY,SET_DATE,PAY_MONEY,SET_STATUS,PAY_STATUS,,
                                 IS_PRINT_PAY,CARRIER_ORG_LEVEL_CODE,CREATE_BY,CREATE_TIME,ENABLE_STATUS) 
                                 values(\‘‘,v_sys_code,\,\‘‘,v_set_no,\,\‘‘,v_belong,\,\‘‘,v_member_name,\,\‘‘,p_title,
                                 \,\‘‘,p_title_type,\,\‘‘,p_set_start,\,\‘‘,p_set_end,\,\‘‘,v_year,\,\‘‘,v_month,\,\‘‘,v_pay_way,\,\‘‘,v_set_date,\,\‘‘,v_pay_money,\,\‘‘,v_set_status,\,\‘‘,v_pay_status,
                                 \,\‘‘,v_is_print_pay,\,\‘‘,v_carrier_org_level_code,\,\‘‘,v_create_by,\,\‘‘,v_create_time,\,\‘‘,v_enable_status,\));
            PREPARE insert_head_stmt FROM @insert_head_sql;
            EXECUTE insert_head_stmt;
            DEALLOCATE PREPARE insert_head_stmt;
            
            #从临时表查询数据,保存到明细表
            WHILE v_min_id - 1 < v_max_id DO
                    
            #账单id赋值
            SELECT report_id INTO v_report_id FROM account_detail_tmp WHERE id=v_min_id;
                #生成承运商账单明细(非铁路)
                    SET @insert_detail_sql=CONCAT(insert into ,v_table_c_com,
                         (SET_NO,ORDER_NO,TRANS_NO,P_ORDER_NO,YEAR,MONTH,ORDER_TIME,ORDER_MONEY,CLAIMING_VALUE,,
                         INSURANCE_FEE,PREMIUM,BASIC_PRICE,RISE_PRICE,PLATFORM_BUCKLE_POINT,PLATFORM_BUCKLE_POINT_FEE,,
                         REBATES_RATE,REBATES_RATE_FEE,ARBITRAGE_CODE,CARRIER_REC_PAY,SUPPLY_PAY,CARRIER_VERIFICATION_FREIGHT,,
                         CARRIER_DENGHEXIAO_MONEY,CARRIER_COM_REC,CREATE_BY,CREATE_TIME,ENABLE_STATUS,,
                         PLATFORM_DISCOUNT_RATE,PLATFORM_DISCOUNT_FEE,ACTUAL_PLATFORM_DISCOUNT_FEE),
                         select \‘‘,v_set_no,\,order_no,trans_no,p_order_no,,\‘‘,v_year,\,\‘‘,v_month,\,order_time,order_money,claiming_value,,
                         insurance_fee,premium,basic_price,rise_price,platform_buckle_point,platform_buckle_point_fee,,
                         rebates_rate,rebates_rate_fee,arbitrage_code,carrier_rec_pay,supply_pay,carrier_verification_freight,,
                         carrier_denghexiao_money,carrier_com_rec,,\‘‘,v_create_by,\,\‘‘,v_create_time,\,\‘‘,v_enable_status,
                         \, platform_discount_rate,platform_discount_fee,actual_platform_discount_fee from account_detail_tmp where id=, v_min_id);
                    
                PREPARE insert_detail_stmt FROM @insert_detail_sql;
                EXECUTE insert_detail_stmt;
                DEALLOCATE PREPARE insert_head_stmt;
                
                #更新清算报表状态为已生成账单、已生成过账单、已出账单
                SET @update_report_sql=CONCAT(update sas_order_reports set IS_CREATE_ACCOUNT =\20\, HAVE_CREATE_ACCOUNT=\20\,ORDER_SET_STATUS=\20\, LAST_UPDATE_TIME=SYSDATE(),LAST_UPDATE_BY=\system\  where id=,v_report_id);
                PREPARE update_report_stmt FROM @update_report_sql;
                EXECUTE update_report_stmt;
                
                SET v_min_id = v_min_id + 1;
            END WHILE;
            
                #释放资源
                DEALLOCATE PREPARE insert_detail_stmt;
                DEALLOCATE PREPARE update_report_stmt;
        END IF;
    END IF;
    
        #删除临时表
        TRUNCATE TABLE account_detail_tmp;
        DROP TEMPORARY TABLE IF EXISTS account_detail_tmp;
    
        #更新任务状态为“已处理”
        UPDATE sas_task_account_carrier_period 
        SET TASK_STATUS = 1, LAST_UPDATE_TIME = SYSDATE(), LAST_UPDATE_BY = system
        WHERE ID = p_task_id;
    IF v_exception<>‘‘ THEN    /*异常 :回滚*/
        ROLLBACK;
    ELSE
    #提交事务
        COMMIT;
    END IF;
END

 

以上是关于项目存储过程记录的主要内容,如果未能解决你的问题,请参考以下文章

用于从 cloudkit 检索单列的代码模式/片段

项目存储过程记录

iOS Coding项目片段记录

VsCode 代码片段-提升研发效率

java 登录过程 - android片段,异步任务登录,Asp.net控制器,存储库

将 List<> 传递给 SQL 存储过程