出入库调试

YYC

2023-06-15 a8da7c463224b9a5bc4628197afe4d9f7d05361c

出入库调试

 igds-api-phone/src/main/java/com/ld/igds/phone35/dto/Dto5501.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
package com.ld.igds.phone35.dto;

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;

import java.util.Date;

/**
 * @Author:YAN
 */
@Data
public class Dto5501 {
    private String depotId;
    private String depotType;
    private String depotName;
    private Double ua;
    private Double ub;
    private Double uc;
    private Double ia;
    private Double ib;
    private Double ic;
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date updateTime;
}

 igds-api-phone/src/main/java/com/ld/igds/phone35/dto/Phone35InoutDto.java

@@ -9,6 +9,7 @@

/**
 * å…¥åº“待值仓、出库待值仓封装
 *
 * @author chen
 */
@Data
@@ -39,6 +40,9 @@
    private String progress;
    private String progressName;

    private String storeKeeper;
    private String storeKeeperName;

    private String fileName1;
    private String fileName2;


 igds-api-phone/src/main/java/com/ld/igds/phone35/mapper/Phone35Mapper.java

@@ -1,9 +1,11 @@
package com.ld.igds.phone35.mapper;


import com.ld.igds.phone35.dto.Dto5501;
import com.ld.igds.phone35.dto.DtoPhoneGas;
import com.ld.igds.phone35.dto.DtoPhonePest;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
@@ -13,6 +15,7 @@

    /**
     * èŽ·å–仓库气体检测信息。默认每个仓库获取最新的一条
     *
     * @param companyId
     * @param deptId
     * @return
@@ -21,9 +24,19 @@

    /**
     * èŽ·å–仓库虫害检测信息。默认每个仓库获取最新的一条
     *
     * @param companyId
     * @param deptId
     * @return
     */
    List<DtoPhonePest> getPestByDepot(@Param("companyId") String companyId, @Param("deptId") String deptId);

    /**
     * èŽ·å– èƒ½è€—管理-实时配电 ä¿¡æ¯
     *
     * @param companyId
     * @param deptId
     * @return
     */
    List<Dto5501> getRealEnergyByDept(@Param("companyId") String companyId, @Param("deptId") String deptId);
}

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/HPhoneServiceImpl.java

@@ -9,6 +9,7 @@
import com.ld.igds.phone35.param.Phone35InoutCommonParam;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
@@ -16,6 +17,7 @@

/**
 * æ–°ç‰ˆæ‰‹æœº3.5，数据查询
 *
 * @author chen
 */
@Component
@@ -23,6 +25,7 @@

    /**
     * æŸ¥è¯¢ç”¨æˆ·
     *
     * @param username
     * @return
     */
@@ -41,6 +44,7 @@

    /**
     * èŽ·å–库区列表信息
     *
     * @param companyId
     * @return
     */
@@ -60,6 +64,7 @@

    /**
     * èŽ·å–仓库列表信息
     *
     * @param companyId
     * @param deptId
     * @return
@@ -81,6 +86,7 @@

    /**
     * æŸ¥è¯¢å‡ºå…¥åº“信息，用于查询出入库记录、待值仓列表等
     *
     * @param param
     * @return
     */
@@ -97,7 +103,7 @@
            hql += " and deptId =:deptId";
            args.put("deptId", param.getDeptId());
        }
        if(StringUtils.isNotEmpty(param.getDeptId())){
        if (StringUtils.isNotEmpty(param.getProgress())) {
            hql += " and progress =:progress";
            args.put("progress", param.getProgress());
        }
@@ -117,7 +123,7 @@
            hql += " and plateNum =:plateNum";
            args.put("plateNum", "%" + param.getPlateNum() + "%");
        }
        if(StringUtils.isNotEmpty(param.getType())){
        if (StringUtils.isNotEmpty(param.getIntelCard())) {
            hql += " and intelCard =:intelCard";
            args.put("intelCard", param.getIntelCard());
        }
@@ -136,7 +142,7 @@
     * @return
     */
    public InoutRecord getInoutRecord(String companyId, String deptId, String id, String intelCard) {
        String hql = " from " + InoutRecord.class.getName() + " where" + " and recordStatus <>:recordStatus1 and recordStatus <>:recordStatus2";
        String hql = " from " + InoutRecord.class.getName() + " where" + " recordStatus <>:recordStatus1 and recordStatus <>:recordStatus2";

        Map<String, Object> args = new HashMap<String, Object>();

@@ -170,6 +176,7 @@

    /**
     * æŸ¥è¯¢ä»“房信息数据----接口1103使用
     *
     * @param companyId
     * @param deptId
     * @return
@@ -191,6 +198,7 @@

    /**
     * æ ¹æ®ä»“房id获取仓房信息
     *
     * @param companyId
     * @param id
     * @return
@@ -218,6 +226,7 @@

    /**
     * æŸ¥è¯¢æ–‡ä»¶ä¿¡æ¯æ•°æ®----接口1112使用
     *
     * @param companyId
     * @param startTime
     * @param endTime
@@ -244,6 +253,7 @@

    /**
     * æŸ¥è¯¢è´¨æ£€æ•°æ®----接口1201使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -277,6 +287,7 @@

    /**
     * è¯¢è´¨æ£€æ˜Žç»†æ•°æ®----接口1202使用
     *
     * @param checkId
     * @return
     */
@@ -292,6 +303,7 @@

    /**
     * æŸ¥è¯¢å€’仓信息数据----接口1309使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -325,6 +337,7 @@

    /**
     * æŸ¥è¯¢æŸæº¢å•æ•°æ®----接口1311使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -358,6 +371,7 @@

    /**
     * æŸ¥è¯¢ç²®é£Ÿæ€§è´¨å˜æ›´ä¿¡æ¯----接口1312使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -391,6 +405,7 @@

    /**
     * æŸ¥è¯¢æ¸©æ¹¿åº¦ä¿¡æ¯----接口1401使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -424,6 +439,7 @@

    /**
     * æŸ¥è¯¢ç²®æƒ…配置信息----接口1402使用
     *
     * @param companyId
     * @param depotId
     * @return
@@ -446,6 +462,7 @@

    /**
     * æŸ¥è¯¢é€šé£Žä¿¡æ¯----接口1403使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -479,6 +496,7 @@

    /**
     * æŸ¥è¯¢ç†è’¸ä¿¡æ¯----接口1404使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -512,6 +530,7 @@

    /**
     * æŸ¥è¯¢è™«å®³ä¿¡æ¯----接口1405使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -545,6 +564,7 @@

    /**
     * æŸ¥è¯¢è™«å®³ä¿¡æ¯----接口1408使用
     *
     * @param companyId
     * @param depotId
     * @param startTime
@@ -578,6 +598,7 @@

    /**
     * æŸ¥è¯¢è½®æ¢è®¡åˆ’信息----接口1501使用
     *
     * @param companyId
     * @param type
     * @param startTime
@@ -611,6 +632,7 @@

    /**
     * æŸ¥è¯¢è½®æ¢æ˜Žç»†è®¡åˆ’信息----接口1502使用
     *
     * @param planId
     * @return
     */
@@ -626,6 +648,7 @@

    /**
     * æŸ¥è¯¢åˆåŒä¿¡æ¯----接口1503使用
     *
     * @param companyId
     * @param startTime
     * @param endTime

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5203.java

@@ -88,6 +88,9 @@
            BeanUtils.copyProperties(record, inoutData);
            inoutData.setDepotName(phone35Util.getDepotName(phone35AuthUser.getCompanyId(), record.getDepotId()));
            inoutData.setFoodVarietyName(FoodVariety.getMsg(record.getFoodVariety()));
            if (inoutData.getRecordWeight() == null) {
                inoutData.setRecordWeight(0.0);
            }
            sum += inoutData.getRecordWeight();
            listDto.add(inoutData);
        }

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5204.java

@@ -88,6 +88,9 @@
            BeanUtils.copyProperties(record, inoutData);
            inoutData.setDepotName(phone35Util.getDepotName(phone35AuthUser.getCompanyId(), record.getDepotId()));
            inoutData.setFoodVarietyName(FoodVariety.getMsg(record.getFoodVariety()));
            if (inoutData.getRecordWeight() == null) {
                inoutData.setRecordWeight(0.0);
            }
            sum += inoutData.getRecordWeight();
            listDto.add(inoutData);
        }

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5206.java

@@ -5,6 +5,7 @@
import com.ld.igds.constant.FoodVariety;
import com.ld.igds.constant.RespCodeEnum;
import com.ld.igds.inout.InoutConstant;
import com.ld.igds.models.Depot;
import com.ld.igds.models.InoutRecord;
import com.ld.igds.phone35.constant.Phone35Constant;
import com.ld.igds.phone35.dto.Phone35AuthUser;
@@ -39,7 +40,7 @@

    @Override
    public String getInterfaceId() {
        return Phone35Constant.API_PHONE_5203;
        return Phone35Constant.API_PHONE_5206;
    }

    @SuppressWarnings("unchecked")
@@ -75,8 +76,12 @@
        for (InoutRecord record : list) {
            inoutData = new Phone35InoutDto();
            BeanUtils.copyProperties(record, inoutData);
            //设置仓库、粮食品种、粮食等级等名称
            inoutData.setDepotName(phone35Util.getDepotName(phone35AuthUser.getCompanyId(), record.getDepotId()));
            Depot depot = phone35Util.getDepot(phone35AuthUser.getCompanyId(), record.getDepotId());

            //设置仓库、粮食品种、粮食等级、保管员等名称
            inoutData.setDepotName(depot.getName());
            inoutData.setStoreKeeper(depot.getStoreKeeper());
            inoutData.setStoreKeeperName(depot.getStoreKeeperName());
            inoutData.setFoodVarietyName(FoodVariety.getMsg(record.getFoodVariety()));
            inoutData.setFoodLevelName(FoodLevel.getMsg(record.getFoodLevel()));
            listDto.add(inoutData);

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5207.java

@@ -20,6 +20,7 @@
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -42,7 +43,7 @@

    @Override
    public String getInterfaceId() {
        return Phone35Constant.API_PHONE_5205;
        return Phone35Constant.API_PHONE_5207;
    }

    @SuppressWarnings("unchecked")
@@ -56,9 +57,9 @@
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
        //参数验证
        if (StringUtils.isEmpty(param.getDeptId())) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
//        if (StringUtils.isEmpty(param.getDeptId())) {
//            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
//        }

        //值仓提交前，再次确认当前流水是否为值仓流程
        InoutRecord record = hPhoneService.getInoutRecord(phone35AuthUser.getCompanyId(), phone35AuthUser.getDeptId(), param.getId(), null);

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5208.java

@@ -43,7 +43,7 @@

    @Override
    public String getInterfaceId() {
        return Phone35Constant.API_PHONE_5205;
        return Phone35Constant.API_PHONE_5208;
    }

    @SuppressWarnings("unchecked")
@@ -57,9 +57,9 @@
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
        //参数验证
        if (StringUtils.isEmpty(param.getDeptId())) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
//        if (StringUtils.isEmpty(param.getDeptId())) {
//            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
//        }

        //查询流水数据信息
        InoutRecord inoutData = hPhoneService.getInoutRecord(phone35AuthUser.getCompanyId(), phone35AuthUser.getDeptId(), param.getId(), param.getIntelCard());
@@ -76,8 +76,8 @@
        inoutHandle.setProgressName(phone35Util.getProgressName(phone35AuthUser.getCompanyId(), inoutData.getProgress()));
        inoutHandle.setFoodVarietyName(FoodVariety.getMsg(inoutData.getFoodVariety()));
        inoutHandle.setFoodLevelName(FoodLevel.getMsg(inoutData.getFoodLevel()));
//        inoutHandle.setHandleStart(inoutData.getHandleStart()); TODO 
//        inoutHandle.setHandelEnd(inoutData.getHandleEnd()); TODO 
//        inoutHandle.setHandleStart(inoutData.getHandleStart());
//        inoutHandle.setHandelEnd(inoutData.getHandleEnd());
        inoutHandle.setProgress(inoutData.getProgress());

        //根据流水id、组织编码查询图片信息

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5401.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
package com.ld.igds.phone35.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.phone35.constant.Phone35Constant;
import com.ld.igds.phone35.dto.Phone35AuthUser;
import com.ld.igds.phone35.dto.PhoneResponse;
import com.ld.igds.phone35.param.Phone35Request;
import com.ld.igds.phone35.service.Phone35Service;

/**
 * è®¾å¤‡æŽ§åˆ¶-设备列表接口实现
 *
 * @Author:YAN
 */
public class Phone35ServiceImpl5401 implements Phone35Service {
    @Override
    public String getInterfaceId() {
        return Phone35Constant.API_PHONE_5401;
    }

    @Override
    public PhoneResponse<Object> execute(Phone35Request<JSONObject> req, Phone35AuthUser phone35AuthUser) throws Exception {
        //todo è®¾å¤‡åˆ—表
        return null;
    }
}

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5501.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.ld.igds.phone35.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.constant.RespCodeEnum;
import com.ld.igds.phone35.constant.Phone35Constant;
import com.ld.igds.phone35.dto.Dto5501;
import com.ld.igds.phone35.dto.Phone35AuthUser;
import com.ld.igds.phone35.dto.PhoneResponse;
import com.ld.igds.phone35.mapper.Phone35Mapper;
import com.ld.igds.phone35.param.Phone35CommonParam;
import com.ld.igds.phone35.param.Phone35DepotCommonParam;
import com.ld.igds.phone35.param.Phone35Request;
import com.ld.igds.phone35.service.Phone35Service;
import com.ld.igds.phone35.util.PhoneRespUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @Author:YAN
 */
@Service
public class Phone35ServiceImpl5501 implements Phone35Service {
    @Autowired
    private Phone35Mapper phone35Mapper;

    @Override
    public String getInterfaceId() {
        return Phone35Constant.API_PHONE_5501;
    }

    @Override
    public PhoneResponse<Object> execute(Phone35Request<JSONObject> req, Phone35AuthUser phone35AuthUser) throws Exception {
        //转化对象
        Phone35CommonParam param = JSONObject.parseObject(req.getData().toString(), Phone35CommonParam.class);
        if (null == param) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
        //参数验证
        if (StringUtils.isEmpty(param.getDeptId())) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
        List<Dto5501> list = phone35Mapper.getRealEnergyByDept(phone35AuthUser.getCompanyId(), param.getDeptId());
        return PhoneRespUtil.success(list, req);
    }
}

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5801.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
package com.ld.igds.phone35.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.phone35.constant.Phone35Constant;
import com.ld.igds.phone35.dto.Phone35AuthUser;
import com.ld.igds.phone35.dto.PhoneResponse;
import com.ld.igds.phone35.param.Phone35Request;
import com.ld.igds.phone35.service.Phone35Service;

/**
 * @Author:YAN
 */
public class Phone35ServiceImpl5801 implements Phone35Service {
    @Override
    public String getInterfaceId() {
        return Phone35Constant.API_PHONE_5801;
    }

    @Override
    public PhoneResponse<Object> execute(Phone35Request<JSONObject> req, Phone35AuthUser phone35AuthUser) throws Exception {
        return null;
    }
}

 igds-api-phone/src/main/java/com/ld/igds/phone35/service/impl/Phone35ServiceImpl5802.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
package com.ld.igds.phone35.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.phone35.constant.Phone35Constant;
import com.ld.igds.phone35.dto.Phone35AuthUser;
import com.ld.igds.phone35.dto.PhoneResponse;
import com.ld.igds.phone35.param.Phone35Request;
import com.ld.igds.phone35.service.Phone35Service;

/**
 * @Author:YAN
 */
public class Phone35ServiceImpl5802 implements Phone35Service {
    @Override
    public String getInterfaceId() {
        return Phone35Constant.API_PHONE_5802;
    }

    @Override
    public PhoneResponse<Object> execute(Phone35Request<JSONObject> req, Phone35AuthUser phone35AuthUser) throws Exception {
        return null;
    }
}

 igds-api-phone/src/main/java/com/ld/igds/phone35/util/Phone35Util.java

@@ -22,8 +22,10 @@
    private CoreCommonService commonService;

    private static final String KEY_API_PHONE_TOKEN = "KEY_API_PHONE_TOKEN";

    /**
     * åˆ›å»ºç¼“å­˜Key
     *
     * @param token
     * @return
     */
@@ -33,6 +35,7 @@

    /**
     * èŽ·å–出入库流程名称
     *
     * @param companyId
     * @param progress
     * @return
@@ -52,6 +55,7 @@

    /**
     * èŽ·å–仓库名称
     *
     * @param companyId
     * @param depotId
     * @return
@@ -69,4 +73,25 @@
        }
        return depotName;
    }

    /**
     * èŽ·å–指定仓库的信息
     *
     * @param companyId
     * @param depotId
     * @return
     */
    public Depot getDepot(String companyId, String depotId) {
        List<Depot> depotList = commonService.getCacheDepotList(companyId);
        Depot depots = new Depot();
        if (depotList != null && depotList.size() > 0) {
            for (Depot depot : depotList) {
                if (depot.getId().equals(depotId)) {
                    depots = depot;
                    break;
                }
            }
        }
        return depots;
    }
}

 igds-api-phone/src/main/resources/mapper/Phone35Mapper.xml

@@ -44,5 +44,23 @@
        <if test="deptId != null and deptId != ''">AND d.DEPT_ID_ = #{deptId}</if>
        ORDER BY d.ID_
    </select>

    <!--实时配电-->
    <select id="getRealEnergyByDept" resultType="com.ld.igds.phone35.dto.Dto5501" parameterType="java.lang.String">
        SELECT d.ID_ as depotId,
        d.NAME_ as depotName,
        d.DEPOT_TYPE_ as depotType,
        e.UA_ as ua,
        e.UB_ as ub,
        e.UC_ as uc,
        e.IA_ as ia,
        e.IB_ as ib,
        e.IC_ as ic,
        e.UPDATE_TIME_ as updateTime
        FROM d_depot d
        LEFT JOIN d_energy e
        ON d.ID_ = e.DEPOT_ID_
        WHERE d.COMPANY_ID_ = #{companyId}
        <if test="deptId != null and deptId != ''">AND d.DEPT_ID_ = #{deptId}</if>
        ORDER BY d.ID_
    </select>
</mapper>