1. 月盘

1.1 月末负库存清零任务：

任务地址：https://store.lelecha.com/chronos.html
name：月盘负库存清零
topic: supply.stocktake.negative_stocktake_zero.init
和客户沟通过，暂时配置为每个月1号3:30执行，对应utc时间：就是每个月末最后一天的19:30执行

1.2 修改报废时间和盘点时间

由于报废日期和盘点日期是自然日，而库存切片是4点~4点，这样会导致报表和库存切片数据不一致，因此，就要求在凌晨0点~4点之间盘点或者报废的单子，应该算在前一天。这个需求已经实现并发布到生产，上个月的月结报废日期和盘点日期应该是对的，客户并没有让改。但为防止意外，附上对应的脚本

  1. 修改报废到日期 ```python

    更新报废单

    import os

import pymysql import xlrd

from util.read_file import read_excel

def update_adjust(created_at, adjust_date, codes):

  1. # 更新收货单状态
  2. db = pymysql.connect(
  3.         host="pc-uf649stob1f3o4si8.rwlb.rds.aliyuncs.com",
  4.         port=3306,
  5.         user="lelecha_prod",
  6.         passwd="EdCD4u69etNJHb7z",
  7.         db="lelecha_boh_supply"
  8.     )
  9. # 通过 cursor() 创建游标对象
  10. cur = db.cursor()
  11. # 更新报废单时间
  12. update_sql = """UPDATE supply_adjust_detail SET created_at = '{created_at}', adjust_date = '{adjust_date}' WHERE `code` in ({codes})""".\
  13.     format(created_at=created_at, adjust_date=adjust_date, codes=codes)
  14. try:
  15.     # 使用 execute() 执行sql
  16.     cur.execute(update_sql)
  17.     # 提交事务
  18.     db.commit()
  19. except Exception as e:
  20.     print("更新失败，error = {}".format(e))
  21.     # 回滚所有的更改
  22.     db.rollback()
  23. finally:
  24.     print("更新成功")
  25.     print("受影响行数：{}".format(cur.rowcount))
  26.     # 关闭游标
  27.     cur.close()
  28.     # 关闭数据库连接
  29.     db.close()

默认读出第一列

def read_excel(path=None, file_name=None): if not path: path = os.getcwd() + “/files/excel/“ rows = []

  1. # 打开文件
  2. workbook = xlrd.open_workbook(path + file_name)
  3. # 获取所有sheet
  4. sheets = workbook.sheet_names()
  5. for sheet in sheets:
  6.     # 根据sheet索引或者名称获取sheet内容
  7.     sheet = workbook.sheet_by_name(sheet)
  8.     rows = sheet.nrows()
  9.     cols = sheet.col_values(0) # 获取第1列内容
  10.     for col in cols[1:]:
  11.         col_str = str(int(col))
  12.         rows.append(col_str)
  13. print("rows = {}".format(rows))
  14. return rows

if name == ‘main‘:

  1. # 读取指定列
  2. # path = os.getcwd() + "/"
  3. file_name = "报废单.xlsx"
  4. rows = read_excel(file_name=file_name)
  5. codes= ",".join(rows)
  6. # 更新至 2021-11-30
  7. # created_at = "2021-11-30 15:50:00"
  8. # adjust_date = "2021-11-30 15:50:00"
  9. # 更新至 2021-12-31
  10. created_at = "2021-12-31 15:50:00"
  11. adjust_date = "2021-12-31 15:50:00"
  12. update_adjust(created_at=created_at, adjust_date=adjust_date, codes=codes)
  2. 2. 修改盘点单日期
  3. ```python
  4. # 更新盘点单
  5. import os
  7. import pymysql
  8. import xlrd
  10. from db.lelecha_boh_prod import get_db
  11. from util.read_file import read_excel
  13. def update_stocktake(target_date, codes):
  14.     # 更新收货单状态
  15.     db = pymysql.connect(
  16.         host="pc-uf649stob1f3o4si8.rwlb.rds.aliyuncs.com",
  17.         port=3306,
  18.         user="lelecha_prod",
  19.         passwd="EdCD4u69etNJHb7z",
  20.         db="lelecha_boh_supply"
  21.     )
  22.     # 通过 cursor() 创建游标对象
  23.     cur = db.cursor()
  24.     # 更新报废单时间
  25.     update_sql = """UPDATE supply_st_doc_details SET target_date = '{target_date}' WHERE `code` in ({codes})""".format(
  26.         target_date=target_date, codes=codes
  27.     )
  28.     try:
  29.         # 使用 execute() 执行sql
  30.         cur.execute(update_sql)
  31.         # 提交事务
  32.         db.commit()
  33.     except Exception as e:
  34.         print("更新失败，error = {}".format(e))
  35.         # 回滚所有的更改
  36.         db.rollback()
  37.     finally:
  38.         print("更新成功")
  39.         print("受影响行数：{}".format(cur.rowcount))
  40.         # 关闭游标
  41.         cur.close()
  42.         # 关闭数据库连接
  43.         db.close()
  45. # 默认读出第一列
  46. def read_excel(path=None, file_name=None):
  47.     if not path:
  48.         path = os.getcwd() + "/files/excel/"
  49.     rows = []
  50.     # 打开文件
  51.     workbook = xlrd.open_workbook(path + file_name)
  52.     # 获取所有sheet
  53.     sheets = workbook.sheet_names()
  54.     for sheet in sheets:
  55.         # 根据sheet索引或者名称获取sheet内容
  56.         sheet = workbook.sheet_by_name(sheet)
  57.         rows = sheet.nrows()
  58.         cols = sheet.col_values(0) # 获取第1列内容
  59.         for col in cols[1:]:
  60.             col_str = str(int(col))
  61.             rows.append(col_str)
  62.     print("rows = {}".format(rows))
  63.     return rows
  66. if __name__ == '__main__':
  67.     # 读取指定列
  68.     # path = os.getcwd() + "/"
  69.     file_name = "盘点单.xlsx"
  70.     rows = read_excel(file_name=file_name)
  71.     codes= ",".join(rows)
  72.     # 更新至 2021-12-31
  73.     target_date = "2021-12-31 15:50:00"
  74.     update_stocktake(target_date=target_date, codes=codes)

2. 变更收货单状态

之前客户有遇到过明明已经收货，但收货单仍旧显示 未到店，就需要手动 更改 单据的状态

  1. import pymysql, xlrd, os
  4. class UpdateReceiptReceive(object):
  5.     # 更新门店收货单状态：未到店 ———> 待收货
  7.     def __init__(self):
  8.         # 初始化
  9.         pass
  11.     def run(self):
  12.         # 主程序
  13.         # 读取要更新的收货单code_list
  14.         path = os.getcwd() + "/"
  15.         file_name = "未到店.xlsx"
  16.         code_list = self.get_receive_codes(path=path, file_name=file_name)
  17.         codes = ",".join(code_list)
  18.         # 更新收货单状态
  19.         self.update_receive(codes=codes)
  21.     def update_receive(self, codes):
  22.         # 更新收货单状态
  23.         print("codes = {}".format(codes))
  24.         # 建立数据库连接
  25.         db = pymysql.connect(
  26.             host="pc-uf649stob1f3o4si8.rwlb.rds.aliyuncs.com",
  27.             port=3306,
  28.             user="lelecha_prod",
  29.             passwd="EdCD4u69etNJHb7z",
  30.             db="lelecha_boh_receipt"
  31.         )
  32.         # 通过 cursor() 创建游标对象
  33.         cur = db.cursor()
  34.         # 未到店 ———> 待收货
  35.         update_sql = """UPDATE receipt_receive SET `status` = 'INITED' WHERE `status` = 'SUSPENDED' AND `code` in ({})""".format(codes)
  36.         # 待收货 ---> 已收货
  37.         # update_sql = """UPDATE receipt_receive SET `status` = 'SUCCESS' WHERE `status` = 'INITED' AND `code` in ({})""".format(codes)
  38.         try:
  39.             # 使用 execute() 执行sql
  40.             cur.execute(update_sql)
  41.             # 提交事务
  42.             db.commit()
  43.         except Exception as e:
  44.             print("更新失败，error = {}".format(e))
  45.             # 回滚所有的更改
  46.             db.rollback()
  47.         finally:
  48.             print("更新成功")
  49.             print("受影响行数：{}".format(cur.rowcount))
  50.             # 关闭游标
  51.             cur.close()
  52.             # 关闭数据库连接
  53.             db.close()
  55.     def get_receive_codes(self, path, file_name):
  56.         # 获取收货单编码列表
  57.         code_list = list()
  58.         # 打开文件
  59.         workbook = xlrd.open_workbook(path + file_name)
  60.         # 获取所有sheet
  61.         sheets = workbook.sheet_names()
  62.         for sheet_name in sheets:
  63.             # 根据sheet索引或者名称获取sheet内容
  64.             sheet = workbook.sheet_by_name(sheet_name)
  65.             cols = sheet.col_values(1) # 获取第2列内容
  66.             for col in cols[1:]:
  67.                 col_str = str(int(col))
  68.                 code_list.append(col_str)
  69.         return code_list
  72. if __name__ == '__main__':
  73.     URR = UpdateReceiptReceive()
  74.     URR.run()