package com.fzzy.async.fzzy35.impl; import com.fzzy.api.Constant; import com.fzzy.api.entity.Api1109; import com.fzzy.api.entity.ApiLog; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.utils.FileUtil; import com.fzzy.api.view.repository.Api1109Rep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.async.fzzy35.entity.Fz35FileInfo; import com.fzzy.async.fzzy35.entity.Fz35InoutRecord; import com.fzzy.async.fzzy35.repository.Fzzy35Sync1109Rep; import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.*; /** * 文件信息 */ @Slf4j @Component public class Fzzy35Sync1109 { private final static String IMG_START_C = "C_"; private final static String IMG_START_R = "R_"; /** * 图片类型 */ private final static String IMG_TYPE_1 = "1"; //库区鸟瞰图 private final static String IMG_TYPE_2 = "2"; //入库图片 private final static String IMG_TYPE_3 = "3"; //出库图片 private final static String IMG_TYPE_4 = "4"; //入库检斤视频 private final static String IMG_TYPE_5 = "5"; //出库检斤视频 private final static String IMG_TYPE_104 = "104";//熏蒸备案接口附件，用于广东省 /** * 业务类型 */ private final static String BIZ_TAG_WEIGHT_FULL = "WEIGHT_FULL"; private final static String BIZ_TAG_WEIGHT_EMPTY = "WEIGHT_EMPTY"; private final static String BIZ_TAG_REGISTER = "REGISTER"; private final static String BIZ_TAG_HANDLE = "HANDLE"; @Autowired private Fzzy35Sync1109Rep fzzySync1109Rep; @Autowired private Fzzy35Sync1202Rep fzzySync1202Rep; @Autowired private Api1109Rep api1109Rep; @Autowired private ApiLogRep apiLogRep; @Autowired private FileUtil fileUtil; /** * 同步文件接口 * * @param deptId * @param start * @param end */ public void syncData(String kqdm, String deptId, Date start, Date end) { log.info("-------------1109接口数据开始同步------------------"); //同步数据，只记录失败的信息 ApiLog apiLog = new ApiLog(); apiLog.setType(ApiLog.TYPE_SYNC); apiLog.setKqdm(deptId); apiLog.setUploadTime(new Date()); apiLog.setInteId(Constant.API_CODE_1109); apiLog.setStatus(99); apiLog.setId(ContextUtil.getUUID()); try { List list = fzzySync1109Rep.listFileInfo(start, end); if (null == list || list.isEmpty()) { log.info("-------------没有获取到文件信息------------------"); return; } Map map = new HashMap<>(); Api1109 apiData; String wjlx; String wjmc; List api1109List; List listInout; for (Fz35FileInfo sysData : list) { if (StringUtils.isEmpty(sysData.getBizId())) { continue; } //根据图片id查询对应出入库信息 listInout = fzzySync1202Rep.listInoutRecordById(sysData.getBizId()); if(null == listInout || listInout.isEmpty()){ continue; } //若出入库信息为删除或者错误状态，则不同步 if("DEL".equals(listInout.get(0).getRecordStatus()) || "ERROR".equals(listInout.get(0).getRecordStatus())){ continue; } //若出入库信息中入库重量为空或为0，则不同步 if(null == listInout.get(0).getRecordWeight() || listInout.get(0).getRecordWeight() == 0){ continue; } //只同步称重 if(BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())){ wjlx = ""; wjmc = kqdm; //入库抓拍图 if (sysData.getBizId().startsWith(IMG_START_R)) { wjlx = IMG_TYPE_2; wjmc += "_" + Constant.INOUT_TYPE_14 + sysData.getBizId().substring(4); } //出库抓拍图 if (sysData.getBizId().startsWith(IMG_START_C)) { wjlx = IMG_TYPE_3; wjmc += "_" + Constant.INOUT_TYPE_15 + sysData.getBizId().substring(4); } //若文件类型为空，则跳过 if(StringUtils.isEmpty(wjlx)){ continue; } apiData = new Api1109(); //主键id apiData.setId(UUID.randomUUID().toString()); //文件路径 apiData.setWjdz(fileUtil.getInoutFilePath(sysData.getCreateTime()) + sysData.getFileName()); //文件名称 wjmc = getImgNameType(wjmc, sysData.getBizTag(), sysData.getBizId(), sysData.getFileName(), map); apiData.setWjmc(wjmc); //文件类型 apiData.setWjlx(wjlx); //操作标志及最后更新时间 apiData.setZhgxsj(new Date()); //业务id、库区编码、同步时间 apiData.setBizId(sysData.getFileId()); apiData.setKqdm(kqdm); apiData.setSyncTime(new Date()); api1109List = api1109Rep.getDataByBizId(apiData.getBizId()); if(null == api1109List || api1109List.isEmpty()){ apiData.setCzbz(Constant.CZBZ_I); }else { apiData.setCzbz(api1109List.get(0).getCzbz()); } //保存数据 api1109Rep.save(apiData); log.info("1109---同步数据：{}", apiData.toString()); } } } catch (Exception e) { log.error("---文件同步执行失败----{}", e); apiLog.setResult("同步文件信息失败：" + e.getMessage()); apiLogRep.save(apiLog); } } /** * 获取图片命名类型 * @param wjmc 需要的文件名称 * @param bizTag 文件业务类型 * @param bizId 文件业务id * @param fileName 原文件名 * @param map * @return */ private String getImgNameType(String wjmc, String bizTag, String bizId, String fileName, Map map) { if(fileName.indexOf(Constant.IMG_NAME_TYPE_GL) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_GL + ".jpg"; } if(fileName.indexOf(Constant.IMG_NAME_TYPE_GR) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_GR + ".jpg"; } if(fileName.indexOf(Constant.IMG_NAME_TYPE_GT) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_GT + ".jpg"; } if(fileName.indexOf(Constant.IMG_NAME_TYPE_TL) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_TL + ".jpg"; } if(fileName.indexOf(Constant.IMG_NAME_TYPE_TR) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_TR + ".jpg"; } if(fileName.indexOf(Constant.IMG_NAME_TYPE_TT) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_TT + ".jpg"; } if(fileName.indexOf(Constant.IMG_NAME_TYPE_SL) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_SL + ".jpg"; } if(fileName.indexOf(Constant.IMG_NAME_TYPE_SF) >= 0){ return wjmc + "_" + Constant.IMG_NAME_TYPE_SF + ".jpg"; } Integer num = 0; //毛重 if(BIZ_TAG_WEIGHT_FULL.equals(bizTag)){ if(null == map.get(bizId + "_" + bizTag)){ map.put(bizId + "_" + bizTag, 1); } num = map.get(bizId + "_" + bizTag); if(num == 1){ wjmc += "_" + Constant.IMG_NAME_TYPE_GL; map.put(bizId + "_" + bizTag, 2); } if(num == 2){ wjmc += "_" + Constant.IMG_NAME_TYPE_GR; map.put(bizId + "_" + bizTag, 3); } if(num == 3){ wjmc += "_" + Constant.IMG_NAME_TYPE_GT; map.remove(bizId + "_" + bizTag); } } //皮重 if(BIZ_TAG_WEIGHT_EMPTY.equals(bizTag)){ if(null == map.get(bizId + "_" + bizTag)){ map.put(bizId + "_" + bizTag, 1); } num = map.get(bizId + "_" + bizTag); if(num == 1){ wjmc += "_" + Constant.IMG_NAME_TYPE_TL; map.put(bizId + "_" + bizTag, 2); } if(num == 2){ wjmc += "_" + Constant.IMG_NAME_TYPE_TR; map.put(bizId + "_" + bizTag, 3); } if(num == 3){ wjmc += "_" + Constant.IMG_NAME_TYPE_TT; map.remove(bizId + "_" + bizTag); } } return wjmc + ".jpg"; } }