#

luxiaotao1123

2022-11-02 9d53846856cdd55622b04f88863bc24b77308ac6

#

 src/main/java/com/zy/asrs/service/WrkChargeService.java

@@ -2,9 +2,10 @@

import com.baomidou.mybatisplus.service.IService;
import com.zy.asrs.entity.WrkCharge;
import com.zy.common.model.enums.WrkChargeType;

public interface WrkChargeService extends IService<WrkCharge> {

    WrkCharge selectWorking(Integer steNo, String memo);
    WrkCharge selectWorking(Integer steNo, WrkChargeType type);

}

 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java

@@ -2484,7 +2484,7 @@
     */
    @SuppressWarnings("serial")
    public synchronized void loopSteCharge() {
        if (null != wrkChargeService.selectWorking(null, WrkChargeType.reset.toString())) {
        if (null != wrkChargeService.selectWorking(null, WrkChargeType.reset)) {
            return;
        }
        SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
@@ -2509,7 +2509,7 @@
                if (steProtocol.getCharge() > Float.parseFloat(basSte.getChargeLine())) {
                    continue;
                }
                WrkCharge wrkCharge = wrkChargeService.selectWorking(null, WrkChargeType.charge.toString());
                WrkCharge wrkCharge = wrkChargeService.selectWorking(null, WrkChargeType.charge);

                if (wrkCharge == null && steProtocol.getChargeStatus() == 0) {
                    // 寻找空闲充电桩
@@ -2720,7 +2720,7 @@
     */
    public synchronized void queryChargeLocOfComplete() {
        // 与充电任务不同步进行
        if (null != wrkChargeService.selectWorking(null, WrkChargeType.charge.toString())) { return; }
        if (null != wrkChargeService.selectWorking(null, WrkChargeType.charge)) { return; }
        SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
        // 检索充电桩
        for (SteChargeType value : SteChargeType.values()) {
@@ -2757,7 +2757,7 @@
                    continue;
                }

                WrkCharge wrkCharge = wrkChargeService.selectWorking(steNo, WrkChargeType.reset.toString());
                WrkCharge wrkCharge = wrkChargeService.selectWorking(steNo, WrkChargeType.reset);

                if (wrkCharge == null) {
                    // 开始穿梭车复位任务
@@ -2783,7 +2783,7 @@
     * 小车从充电桩 至 待机库位
     */
    public synchronized void steFromChargeToIdleLoc() {
        WrkCharge wrkCharge = wrkChargeService.selectWorking(null, WrkChargeType.reset.toString());
        WrkCharge wrkCharge = wrkChargeService.selectWorking(null, WrkChargeType.reset);
        if (wrkCharge == null) { return; }
        SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, wrkCharge.getSteNo());
        SteProtocol steProtocol = steThread.getSteProtocol();

 src/main/java/com/zy/asrs/service/impl/WrkChargeServiceImpl.java

@@ -4,17 +4,18 @@
import com.zy.asrs.entity.WrkCharge;
import com.zy.asrs.mapper.WrkChargeMapper;
import com.zy.asrs.service.WrkChargeService;
import com.zy.common.model.enums.WrkChargeType;
import org.springframework.stereotype.Service;

@Service("wrkChargeService")
public class WrkChargeServiceImpl extends ServiceImpl<WrkChargeMapper, WrkCharge> implements WrkChargeService {

    @Override
    public WrkCharge selectWorking(Integer steNo, String memo) {
        switch (memo) {
            case "charge":
    public WrkCharge selectWorking(Integer steNo, WrkChargeType type) {
        switch (type) {
            case charge:
                return this.baseMapper.selectWorkingOfCharge(steNo);
            case "reset":
            case reset:
                return this.baseMapper.selectWorkingOfReset(steNo);
        }
        return null;