自动化立体仓库 - WMS系统
ZY
2024-07-17 4eb50d3085ee4a674457024e1d7b96ba5ce75731
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
package com.zy.third.erp.task;
 
import com.zy.common.service.erp.ErpSqlServer;
import com.zy.third.erp.entity.ItemTB;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
import java.util.List;
 
@Component
public class ERPItemScheduler {
    @Value("${erp.enabled}")
    private Boolean erpEnabled;
 
    @Autowired
    private ERPItemSchedulerMS erpItemSchedulerMS;
 
    @Autowired
    private ErpSqlServer erpSqlServer;
 
    @Scheduled(cron = "${erp.refreshtime}")
    public void ItemScheduler() {
        if (!erpEnabled) return;
 
//        String selectALL = "SELECT AutoId AS autoId,ItemId AS ItemID,ItemCode AS ItemCode,ItemName AS ItemName ,ItemSpc AS ItemSpc,ItemPic AS itemPic,ItemUnit AS ItemUnit,ItemKind AS ItemKind ,Remark AS remark ,Flag AS flag ,MakeDate AS makedate,Temp1 AS temp1,Temp2 AS temp2 ,Temp3 AS temp3 FROM dbo.erp_ItemTB";
//        List<ItemTB> itemTBS = erpSqlServer.select(selectALL, ItemTB.class);
//        List<ItemTB> itemTBS = erpSqlServer.selectAll(ItemTB.class);
 
        String sqlItemTB = "select * from erp_ItemTB where LKName='中扬'";
        List<ItemTB> itemTBS = erpSqlServer.select(sqlItemTB, ItemTB.class);
        if (itemTBS != null && itemTBS.size() > 0) {
            for (ItemTB itemTB : itemTBS) {
                //00代表新增
                if (itemTB.getFlag().equals("00")) {
                    erpItemSchedulerMS.addToMainDatabase(itemTB);
                }
                //22代表删除
                if (itemTB.getFlag().equals("22")) {
                    erpItemSchedulerMS.deleteFromMainDatabase(itemTB);
                }
                moveToBak(itemTB);
            }
        }
    }
 
    /**
     * 数据库里有触发器,当item表的数据被删除时,会自动向item_bak添加,不用卸载代码里
     *
     * @param itemTB
     */
    //将数据从主表移动到bak表里
    private void moveToBak(ItemTB itemTB) {
//        ItemTBBak itemTBBak = new ItemTBBak();
//        BeanUtils.copyProperties(itemTB, itemTBBak);
//        itemTBBak.setDelDate(new Date());
//        erpItemTBBakMapper.insert(itemTBBak);
        erpSqlServer.update("delete from erp_ItemTB where LKName='中扬' and ItemId = '" + itemTB.getItemId() + "'");
//        erpItemTBMapper.delete(new EntityWrapper<ItemTB>()
//                .eq("ItemId",itemTB.getItemID()));
    }
}