package com.whyc.schedule;
|
|
import com.whyc.dto.Response;
|
import com.whyc.dto.WmsPallet;
|
import com.whyc.dto.WmsPalletDto;
|
import com.whyc.dto.WmsResponse;
|
import com.whyc.pojo.db_wms.BattWarehouse;
|
import com.whyc.pojo.db_wms.Task;
|
import com.whyc.service.BattWarehouseService;
|
import com.whyc.service.TaskService;
|
import com.whyc.service.WmsService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 仓储系统的智能活化任务
|
* 解释来源:任务的来源,在 发生 入库任务时,所入库的电池 就需要 活化. 以及在仓储库内的所有电池都需要活化.活化周期为每n月活化一次.
|
* 实现思路:
|
* 1.创建仓储库所有电池单体编号的库存表,写明入库时间和上次活化时间-数据的来源分为2部分,1-初始已在库的电池,2-测压入库的新入电池
|
* 2.对于没有活化的电池单体,下发活化任务.
|
* 3.下发活化任务的选择: 每天早上9点,且没有正在进行的活化任务的时候. 对周期大于n月的单体进行任务下发
|
*/
|
|
@EnableScheduling
|
@Component
|
@Slf4j
|
public class WmsTaskSchedule {
|
|
@Autowired
|
private BattWarehouseService battWarehouseService;
|
|
@Autowired
|
private TaskService taskService;
|
|
@Autowired
|
private WmsService wmsService;
|
|
/**
|
* 仓储库所有电池的活化任务,任务之前还检查并加入 之前未放入仓储库表中的单体
|
* 活化周期: 在参数表里设置
|
* 每天早上9点执行一次
|
* */
|
//@Scheduled(cron= "0 0 9 * * ?")
|
public void checkAndActivate() {
|
//查询数据库记录的仓库内所有的电池
|
List<BattWarehouse> listInDB = battWarehouseService.getAll();
|
List<BattWarehouse> listNew = new ArrayList<>();
|
Date now = new Date();
|
List<Integer> monIdListInDB = listInDB.stream().map(BattWarehouse::getMonId).collect(Collectors.toList());
|
//查询当前实际存在的仓库内的所有电池
|
Response palletList = wmsService.getPalletList(2, 4);
|
WmsResponse data = (WmsResponse) palletList.getData();
|
if (palletList.getCode() == 1 && (data).getCode() == 0) { //查询到了所有库内电池
|
List<WmsPallet> palletsNow = (List<WmsPallet>) data.getData();
|
palletsNow.stream().forEach(item -> {
|
//palletCode就是电池单体编号
|
if(!monIdListInDB.contains(Integer.valueOf(item.getPalletCode()))){
|
BattWarehouse battWarehouse = new BattWarehouse();
|
battWarehouse.setMonId(Integer.valueOf(item.getPalletCode()));
|
battWarehouse.setStorageTime(now);
|
battWarehouse.setOnPlan(0);
|
battWarehouse.setChargeOnPlan(0);
|
battWarehouse.setDischargeOnPlan(0);
|
String volStr = item.getV().replace("v", "");
|
int vol = Integer.parseInt(volStr);
|
battWarehouse.setVol(vol);
|
|
listNew.add(battWarehouse);
|
}
|
});
|
}
|
//不在数据库内的电池单体,保存
|
if(listNew.size() > 0){
|
battWarehouseService.addBatch(listNew);
|
}
|
|
//查询需要活化的电池列表
|
List<BattWarehouse> list = battWarehouseService.getActivateList();
|
/*//通过电压进行分组list
|
Map<Integer, List<BattWarehouse>> mapToActivate = list.stream().filter(item->item.getVol() == 2).collect(Collectors.groupingBy(BattWarehouse::getVol));
|
Set<Integer> volSet = mapToActivate.keySet();
|
//永远只对一类电压进行活化任务下发!!!因为连续下发活化,后续的会失败
|
Integer vol;
|
String[] activateParameterStr = null;
|
if (volSet.size()>0){
|
vol = volSet.iterator().next();
|
list = mapToActivate.get(vol);
|
}else{
|
//本次终止
|
return;
|
}*/
|
if(list.size() == 0){
|
//没有需要活化的电池
|
return;
|
}
|
int vol =2;
|
String[] activateParameterStr = null;
|
list = list.stream().filter(item -> item.getVol() == 2).collect(Collectors.toList());
|
//查询是否存在正在进行的任务
|
List<Task> ongoingList = taskService.getOngoingList();
|
if (ongoingList.size() == 0) {
|
//没有正在进行的活化任务,则下发活化任务
|
WmsPalletDto wmsPalletDto = new WmsPalletDto();
|
wmsPalletDto.setDes(3);
|
List<String> pallets = list.stream().map(item -> String.valueOf(item.getMonId())).collect(Collectors.toList());
|
//pallets从List类型转LinkedList类型
|
LinkedList<String> palletsLinked = new LinkedList<>(pallets);
|
wmsPalletDto.setPallets(palletsLinked);
|
//活化参数设置
|
//{
|
// num: 1, // 电池编号
|
// cap: 350, // 标称容量
|
// vol: 200, // 电池类型-不可改动
|
// dTime: 10, // 放电时间 900
|
// dCurrent: 10, // 放电电流0.1A-需要根据容量实际设置 （实际容量/10）
|
// volLow: 1.8, // 组端电压下限0.001V
|
// dCap: 10, // 预放容量0.1AH-需要根据容量实际设置 等于实际容量
|
// cTime: 10, // 充电时间 900
|
// cCurrent: 10, // 充电电流0.1A-需要根据容量实际设置（实际容量/10）
|
// sCurrent: 5, // 截至电流0.1A-需要根据容量实际设置（实际容量/10/2）
|
// volHigh: 2.35, // 充电电压上限0.001V
|
// volFloat: 2.25, // 浮充电压0.001V
|
// cCap: 10, // 预充容量0.1AH-需要根据容量实际设置 等于实际容量
|
// tTimes: 1, // 充放次数
|
// standTime: 1, // 静置时间
|
// startType: 1, // 测试起点-默认充电. 测试起点:0放电,1充电
|
//}
|
if(vol == 2) {
|
activateParameterStr = new String[]{
|
"1", "350", "200", "10", "350", "1800", "3500", "10", "350", "175", "2350", "2250", "3500", "1", "1", "1"
|
};
|
}
|
//暂不考虑6V和12V,只存在2V
|
/*//6V待提供
|
else if(vol==6){
|
activateParameterStr = new String[]{
|
"1", "350", "200", "10", "350", "1800", "3500", "10", "350", "175", "2350", "2250", "3500", "1", "1", "1"
|
};
|
}
|
//12V待提供
|
else if(vol==12){
|
activateParameterStr = new String[]{
|
"1", "350", "200", "10", "350", "1800", "3500", "10", "350", "175", "2350", "2250", "3500", "1", "1", "1"
|
};
|
}*/
|
List<String> activateParameter = Arrays.asList(activateParameterStr);
|
wmsPalletDto.setActivateParameter(activateParameter);
|
Response response = wmsService.sendTask(wmsPalletDto);
|
if (response.getCode() == 1) {
|
WmsResponse responseInside = (WmsResponse) response.getData();
|
if(responseInside.getCode() == 0){//下发成功
|
LinkedList<String> taskNoList = responseInside.getTask_no();
|
//进行标志位和任务编号的更新
|
for (int i = 0; i < taskNoList.size(); i++) {
|
BattWarehouse item = list.get(i);
|
item.setOnPlan(1);
|
item.setTaskNo(taskNoList.get(i));
|
}
|
//批量更新BattWarehouse
|
battWarehouseService.updateActivateBatchById(list);
|
}
|
}
|
}
|
|
}
|
|
/**
|
* 仓储库所有电池的充电任务
|
* 充电周期:1个月
|
* 传入的活化参数:cTime=0,startType=1
|
* 每天早上10点执行一次
|
* */
|
//@Scheduled(cron= "0 0 10 * * ?")
|
public void checkAndCharge() {
|
//查询需要充电的电池列表
|
List<BattWarehouse> list = battWarehouseService.getChargeList();
|
list = list.stream().filter(item -> item.getVol() == 2).collect(Collectors.toList());
|
if(list.size() == 0){
|
//没有需要充电的电池
|
return;
|
}
|
|
//查询是否存在正在进行的任务
|
List<Task> ongoingList = taskService.getOngoingList();
|
if (ongoingList.size() == 0) {
|
//没有正在进行的活化任务,则下发活化任务
|
WmsPalletDto wmsPalletDto = new WmsPalletDto();
|
wmsPalletDto.setDes(3);
|
List<String> pallets = list.stream().map(item -> String.valueOf(item.getMonId())).collect(Collectors.toList());
|
//pallets从List类型转LinkedList类型
|
LinkedList<String> palletsLinked = new LinkedList<>(pallets);
|
wmsPalletDto.setPallets(palletsLinked);
|
//活化参数设置
|
String[] activateParameterStr = new String[]{
|
"1", "350", "200", "10", "350", "1800", "3500", "10", "350", "175", "2350", "2250", "3500", "0", "1", "1"
|
};
|
|
List<String> activateParameter = Arrays.asList(activateParameterStr);
|
wmsPalletDto.setActivateParameter(activateParameter);
|
Response response = wmsService.sendTask(wmsPalletDto);
|
if (response.getCode() == 1) {
|
WmsResponse responseInside = (WmsResponse) response.getData();
|
if(responseInside.getCode() == 0){//下发成功
|
LinkedList<String> taskNoList = responseInside.getTask_no();
|
//进行标志位和任务编号的更新
|
for (int i = 0; i < taskNoList.size(); i++) {
|
BattWarehouse item = list.get(i);
|
item.setChargeOnPlan(1);
|
item.setChargeTaskNo(taskNoList.get(i));
|
}
|
//批量更新BattWarehouse
|
battWarehouseService.updateChargeBatchById(list);
|
}
|
}
|
}
|
|
}
|
|
/**
|
* 仓储库所有电池的放电任务
|
* 放电周期:2个月
|
* 传入的活化参数:cTime=0,startType=0
|
* 每天早上11点执行一次
|
* */
|
//@Scheduled(cron= "0 0 11 * * ?")
|
public void checkAndDischarge() {
|
//查询需要放电的电池列表
|
List<BattWarehouse> list = battWarehouseService.getDischargeList();
|
list = list.stream().filter(item -> item.getVol() == 2).collect(Collectors.toList());
|
if(list.size() == 0){
|
//没有需要放电的电池
|
return;
|
}
|
|
//查询是否存在正在进行的任务
|
List<Task> ongoingList = taskService.getOngoingList();
|
if (ongoingList.size() == 0) {
|
//没有正在进行的活化任务,则下发活化任务
|
WmsPalletDto wmsPalletDto = new WmsPalletDto();
|
wmsPalletDto.setDes(3);
|
List<String> pallets = list.stream().map(item -> String.valueOf(item.getMonId())).collect(Collectors.toList());
|
//pallets从List类型转LinkedList类型
|
LinkedList<String> palletsLinked = new LinkedList<>(pallets);
|
wmsPalletDto.setPallets(palletsLinked);
|
//活化参数设置
|
String[] activateParameterStr = new String[]{
|
"1", "350", "200", "10", "350", "1800", "3500", "10", "350", "175", "2350", "2250", "3500", "0", "1", "0"
|
};
|
|
List<String> activateParameter = Arrays.asList(activateParameterStr);
|
wmsPalletDto.setActivateParameter(activateParameter);
|
Response response = wmsService.sendTask(wmsPalletDto);
|
if (response.getCode() == 1) {
|
WmsResponse responseInside = (WmsResponse) response.getData();
|
if(responseInside.getCode() == 0){//下发成功
|
LinkedList<String> taskNoList = responseInside.getTask_no();
|
//进行标志位和任务编号的更新
|
for (int i = 0; i < taskNoList.size(); i++) {
|
BattWarehouse item = list.get(i);
|
item.setDischargeOnPlan(1);
|
item.setDischargeTaskNo(taskNoList.get(i));
|
}
|
//批量更新BattWarehouse
|
battWarehouseService.updateDischargeBatchById(list);
|
}
|
}
|
}
|
|
}
|
|
}
|
