增加方法

schangxiang@126.com

2025-09-09 3d8966ba2c81e7e0365c8b123e861d18ee4f94f5

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
import BaseService from "../baseService";
import { ResultInfo } from "../../public/commonInterface";
import { BaseProductPlaceHolder } from "../../entity/storage/storage/baseProductPlaceHolder";
import { StorageOuter } from "../../entity/storage/operation/storageOuter";
import { StorageOuterList } from "../../entity/storage/operation/storageOuterList";
 
export default class StorageService extends BaseService {
  //#region 终止
  public async stop(): Promise<ResultInfo> {
    let { ctx } = this;
    let body = ctx.request.body;
    let userInfo = await ctx.helper.userInfo();
    const className = "其他出库";
 
    try {
      let idValues = body.idValues;
      if (!Array.isArray(idValues)) {
        this.info.result = false;
        this.info.msg = "没有可执行的数据";
        return this.info;
      }
 
      for (var idValue of idValues) {
        let dataInfo = await this.dbRead.findOne(StorageOuter, idValue);
        if (!dataInfo) {
          this.info.result = false;
          this.info.msg = "单据不存在";
          return this.info;
        }
 
        let statusText = dataInfo.statusText;
        if (["新建", "审核成功"].indexOf(statusText) < 0) {
          this.info.result = false;
          this.info.msg = "只有【新建, 审核成功】才允许终止操作";
          return this.info;
        }
 
        //执行中止操作
        await this.dbWrite.delete(BaseProductPlaceHolder, {
          mainID: idValue,
          className: className,
          userProduct_Id: userInfo.userProduct_Id
        });
        await this.dbWrite.update(
          StorageOuterList,
          {
            outer_Id: dataInfo.outer_Id,
            userProduct_Id: userInfo.userProduct_Id
          },
          {
            lackStorage: 0
          }
        );
        await this.dbWrite.update(
          StorageOuter,
          {
            outer_Id: dataInfo.outer_Id,
            userProduct_Id: userInfo.userProduct_Id
          },
          {
            statusText: "终止",
            sortingStatus: 1,
            sortingDate: null,
            auditing: 0,
            modifyID: userInfo.user_Id,
            modifier: userInfo.userTrueName
          }
        );
      }
      this.info.result = true;
      this.info.msg = "终止成功";
    } catch (error) {
      this.info.result = false;
      this.info.msg = "终止失败" + error.message;
    }
 
    return this.info;
  }
  //#endregion
 
  //#region 开启
  public async open(): Promise<ResultInfo> {
    let { ctx } = this;
    let body = ctx.request.body;
    let userInfo = await ctx.helper.userInfo();
 
    try {
      let idValues = body.idValues;
      if (!Array.isArray(idValues)) {
        this.info.result = false;
        this.info.msg = "没有可执行的数据";
        return this.info;
      }
 
      for (var idValue of idValues) {
        let dataInfo = await this.dbRead.findOne(StorageOuter, idValue);
        if (!dataInfo) {
          this.info.result = false;
          this.info.msg = "单据不存在";
          return this.info;
        }
 
        await this.dbWrite.update(
          StorageOuter,
          {
            outer_Id: dataInfo.outer_Id,
            userProduct_Id: userInfo.userProduct_Id
          },
          {
            statusText: "新建",
            sortingStatus: 1,
            sortingDate: null,
            auditing: 0,
            modifyID: userInfo.user_Id,
            modifier: userInfo.userTrueName
          }
        );
 
        this.info.result = true;
        this.info.msg = "开启成功，单据需要重新审核、分拣操作！";
      }
 
      this.info.result = true;
      this.info.msg = "开启成功";
    } catch (error) {
      this.info.result = false;
      this.info.msg = "开启失败" + error.message;
    }
 
    return this.info;
  }
  //#endregion
}