11

啊鑫

2025-01-24 2b38e425925d194c5cd4767c8c13e5f5d23ab120

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
134
135
136
using MES.Service.DB;
using MES.Service.Dto.webApi;
using MES.Service.Modes;
using MES.Service.util;
using SqlSugar;
 
namespace MES.Service.service.BasicData;
 
public class MesItemTypeManager : Repository<MesItemType>
{
    //当前类已经继承了 Repository 增、删、查、改的方法
    public bool Save(ErpItemType unit)
    {
        var entity = GetMesItemType(unit);
        return UseTransaction(db =>
        {
            switch (unit.Type)
            {
                case "3":
                    if (DeleteItemType(entity))
                        return 1;
                    break;
                case "2":
                case "4":
                    if (InsertItemType(db, entity))
                        return 1;
                    break;
                default:
                    throw new ArgumentNullException(
                        $"type没有{unit.Type}这个类型的参数");
            }
 
            throw new NotImplementedException("操作失败");
        }) > 0;
    }
    
    private bool InsertItemType(SqlSugarScope db, List<MesItemType> entity)
    {
        DeleteItemType(entity);
 
        var insert = db.Insertable(entity).PageSize(1).IgnoreColumnsNull().ExecuteCommand();
        return insert > 0;
    }
 
    private bool DeleteItemType(List<MesItemType> supplierId)
    {
        // 提取所有需要的 MesId 组合 
        var ids = supplierId.Select(customer => customer.Id.ToString())
            .ToList();
        
        // 使用这些 MesId 去查询 MesLinkU9 表，找到对应的 U9Id
        var u9Ids = Db.Queryable<MesLinkU9>()
            .Where(u =>
                ids.Contains(u.MesId) && u.TableType == "MES_ITEM_TYPE")
            .Select(u => u.U9Id)
            .Distinct() // 应用 Distinct 去重
            .ToList();
 
        // 根据 U9Id 找到所有对应的 MesId，进行删除
        // 注意：这里假设您确实想要删除这些记录。如果不确定，请先查询以验证结果。
        var idsToDelete = Db.Queryable<MesLinkU9>()
            .Where(u => u9Ids.Contains(u.U9Id) && u.TableType == "MES_ITEM_TYPE")
            .Select(u => u.MesId)
            .Distinct() // 应用 Distinct 去重
            .ToList();
 
        var deleteByIds = Db.Deleteable<MesItemType>().In(idsToDelete)
            .ExecuteCommand();
        // if (deleteByIds > 0)
        //     return true;
        return true;
        //throw new NotImplementedException("删除失败");
    }
 
    private List<MesItemType> GetMesItemType(ErpItemType department)
    {
        
        List<MesItemType> list = new();
        
        foreach (var erpDetail in department.FUseOrgId)
        {
            var exists = Db.Queryable<MesLinkU9>().Any(u =>
                u.U9Id == department.Id && u.OrgId == erpDetail.FUseOrgId &&
                u.TableType == "MES_ITEM_TYPE");
 
            decimal mesId = 0;
            if (exists)
            {
                //获取mesid
                mesId = Convert.ToDecimal(Db.Queryable<MesLinkU9>()
                    .Where(u =>
                        u.U9Id == department.Id && u.OrgId == erpDetail.FUseOrgId &&
                        u.TableType == "MES_ITEM_TYPE")
                    .Select(u => u.MesId) // 选择 MesId 字段
                    .First());
            }
            else
            {
                mesId = GetSeqUtil.GetSeq("SEQ_ITEM_ID");
                var entity = new MesLinkU9
                {
                    CreateDate = DateTime.Now,
                    MesId = mesId.ToString(),
                    U9Id = department.Id,
                    OrgId = erpDetail.FUseOrgId,
                    TableType = "MES_ITEM_TYPE"
                };
                Db.Insertable(entity).ExecuteCommand();
            }
            
            var mesItemType = new MesItemType
            {
                Id = mesId,
                Pgroup = department.FParentId,
                Tcode = department.FNumber,
                Tname = department.FName,
                Unit = department.Unit,
                ForbidStatus = department.FForbidStatus,
                IqcType = department.IqcType,
                CreateDate = DateTime.Now,
                Company = "1000",
                Factory = "1000"
            };
            
            list.Add(mesItemType);
        }
 
        return list;
    }
 
    public bool SaveList(List<ErpItemType> departments)
    {
        var result = departments.Select(Save).ToList();
        return result.All(b => b);
    }
}