自动充放电自动化流程

whycxzp

2025-06-10 73bb5617e6aeb4ee8f7dfd4ad54b61d477969d86

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
package com.whyc.service;
 
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.mapper.BattWarehouseMapper;
import com.whyc.pojo.db_param.PageParam;
import com.whyc.pojo.db_wms.BattWarehouse;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import javax.annotation.Resource;
import java.util.Calendar;
import java.util.List;
 
@Service
public class BattWarehouseService {
 
    @Resource
    private BattWarehouseMapper mapper;
 
    @Autowired
    private PageParamService pageParamService;
 
    /**
     * 获取需要活化的电池:
     * 条件1:未在活化安排中
     * 条件2:大于活化周期
     * @return
     */
    public List<BattWarehouse> getActivateList() {
        PageParam param = pageParamService.getActivatePeriod();
        Integer period = param.getValue();
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.DAY_OF_MONTH,-period);
 
        QueryWrapper<BattWarehouse> query = Wrappers.query();
        query.eq("on_plan",0);
        //未活化过 或者 活化时间超过活化周期
        query.isNull("activate_time").or().le("activate_time",calendar.getTime());
        return mapper.selectList(query);
    }
 
    public List<BattWarehouse> getChargeList() {
        Integer period = 1;
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.MONTH,-period);
 
        QueryWrapper<BattWarehouse> query = Wrappers.query();
        query.eq("charge_on_plan",0);
        //未充电过 或者 充电时间超过充电周期
        query.isNull("charge_time").or().le("charge_time",calendar.getTime());
        return mapper.selectList(query);
    }
 
    public List<BattWarehouse> getDischargeList() {
        Integer period = 2;
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.MONTH,-period);
 
        QueryWrapper<BattWarehouse> query = Wrappers.query();
        query.eq("discharge_on_plan",0);
        //未放电过 或者 放电时间超过放电周期
        query.isNull("discharge_time").or().le("discharge_time",calendar.getTime());
        return mapper.selectList(query);
    }
 
    public List<BattWarehouse> getAll() {
        return mapper.selectList((Wrapper<BattWarehouse>) ActionUtil.objeNull);
    }
 
    public void addBatch(List<BattWarehouse> listNew) {
        mapper.insertBatchSomeColumn(listNew);
    }
 
    public void updateActivateBatchById(List<BattWarehouse> list) {
        mapper.updateActivateBatchById(list);
    }
 
    public void updateChargeBatchById(List<BattWarehouse> list) {
        mapper.updateChargeBatchById(list);
    }
 
    public void updateDischargeBatchById(List<BattWarehouse> list) {
        mapper.updateDischargeBatchById(list);
    }
 
    public BattWarehouse getByTaskNo(String taskNo) {
        QueryWrapper<BattWarehouse> query = Wrappers.query();
        query.eq("task_no",taskNo).or().eq("charge_task_no",taskNo).or().eq("discharge_task_no",taskNo);
        query.last(" limit 1");
        return mapper.selectOne(query);
    }
 
    /***
     * 结束活化,更新活化时间,重置task_no为null,on_plan为0
     * @param id
     */
    public void finishActivationById(Integer id) {
        UpdateWrapper<BattWarehouse> update = Wrappers.update();
        update.set("task_no",null);
        update.set("on_plan",0);
        update.set("activate_time",Calendar.getInstance().getTime());
        update.eq("id",id);
        mapper.update((BattWarehouse) ActionUtil.objeNull,update);
    }
 
    public void finishChargeById(Integer id) {
        UpdateWrapper<BattWarehouse> update = Wrappers.update();
        update.set("charge_task_no",null);
        update.set("charge_on_plan",0);
        update.set("charge_time",Calendar.getInstance().getTime());
        update.eq("id",id);
        mapper.update((BattWarehouse) ActionUtil.objeNull,update);
    }
 
    public void finishDischargeById(Integer id) {
        UpdateWrapper<BattWarehouse> update = Wrappers.update();
        update.set("discharge_task_no",null);
        update.set("discharge_on_plan",0);
        update.set("discharge_time",Calendar.getInstance().getTime());
        update.eq("id",id);
        mapper.update((BattWarehouse) ActionUtil.objeNull,update);
    }
}