|  |  |  | 
|---|
|  |  |  | package com.ld.igds.sh.service; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.alibaba.fastjson.JSONObject; | 
|---|
|  |  |  | import com.ld.igds.constant.RedisConst; | 
|---|
|  |  |  | import com.ld.igds.log.service.InteStatusLogService; | 
|---|
|  |  |  | import com.ld.igds.models.InoutLossOver; | 
|---|
|  |  |  | import com.ld.igds.models.InteStatusLog; | 
|---|
|  |  |  | import com.ld.igds.models.MLossOver; | 
|---|
|  |  |  | import com.ld.igds.sh.dto.ApiResponse; | 
|---|
|  |  |  | import com.ld.igds.sh.dto.Dto1311; | 
|---|
|  |  |  | import com.ld.igds.sh.param.ApiRequest; | 
|---|
|  |  |  | import com.ld.igds.sh.param.BaseParam; | 
|---|
|  |  |  | import com.ld.igds.sh.service.impl.HApiShServiceImpl; | 
|---|
|  |  |  | import com.ld.igds.sh.util.ApiShConst; | 
|---|
|  |  |  | import com.ld.igds.sh.util.ApiShUtil; | 
|---|
|  |  |  | import com.ld.igds.sh.util.RespCodeEnum; | 
|---|
|  |  |  | import com.ld.igds.sh.util.RespUtil; | 
|---|
|  |  |  | import com.ld.igds.util.ContextUtil; | 
|---|
|  |  |  | 
|---|
|  |  |  | import org.apache.commons.lang3.time.DateUtils; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.stereotype.Service; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  | import java.util.ArrayList; | 
|---|
|  |  |  | import java.util.Date; | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 损溢单数据接口 | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | String companyId = ContextUtil.getDefaultCompanyId(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | String key = RedisConst.buildKey(companyId, ApiShConst.API_SH_1311); | 
|---|
|  |  |  | Date startTime = (Date) redisUtil.get(key); | 
|---|
|  |  |  | if(null == startTime){ | 
|---|
|  |  |  | startTime = DateUtils.addDays(param.getEndTime(), -30); | 
|---|
|  |  |  | //        String key = RedisConst.buildKey(companyId, ApiShConst.API_SH_1112); | 
|---|
|  |  |  | //        Date startTime = (Date) redisUtil.get(key); | 
|---|
|  |  |  | //        if(null == startTime){ | 
|---|
|  |  |  | //            startTime = DateUtils.addDays(param.getEndTime(), -30); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //        redisUtil.set(key, param.getEndTime()); | 
|---|
|  |  |  | if(null == param.getStartTime()){ | 
|---|
|  |  |  | param.setStartTime(DateUtils.addDays(param.getEndTime(), -1)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | redisUtil.set(key, param.getEndTime()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //查询数据 | 
|---|
|  |  |  | List<MLossOver> dataList = hApiShServiceImpl.listLossOver(companyId, | 
|---|
|  |  |  | param.getDepotId(), startTime, param.getEndTime()); | 
|---|
|  |  |  | List<InoutLossOver> dataList = hApiShServiceImpl.listLossOver(companyId, | 
|---|
|  |  |  | param.getDepotId(), param.getStartTime(), param.getEndTime()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //响应数据为空则直接返回响应码2000 | 
|---|
|  |  |  | if (dataList == null || dataList.isEmpty()) { | 
|---|
|  |  |  | 
|---|
|  |  |  | InteStatusLog log; | 
|---|
|  |  |  | InteStatusLog addLog; | 
|---|
|  |  |  | //封装数据信息 | 
|---|
|  |  |  | for (MLossOver data : dataList) { | 
|---|
|  |  |  | for (InoutLossOver data : dataList) { | 
|---|
|  |  |  | dto1311 = new Dto1311(); | 
|---|
|  |  |  | dto1311.setSydbh(data.getId()); | 
|---|
|  |  |  | dto1311.setHwbm(data.getDepotId()); | 
|---|
|  |  |  | dto1311.setHwbm(ApiShUtil.getGbDepotId(data.getDepotId()) + "01"); | 
|---|
|  |  |  | dto1311.setYwrq(DateFormatUtils.format((data.getSubmitTime() == null ? new Date() : data.getSubmitTime()), "yyyy-MM-dd")); | 
|---|
|  |  |  | dto1311.setSylx("3"); | 
|---|
|  |  |  | if ("LOSS".equals(data.getType())) { | 
|---|
|  |  |  | 
|---|
|  |  |  | dto1311.setRksj(DateFormatUtils.format((data.getSubmitTime() == null ? new Date() : data.getSubmitTime()), "yyyy-MM-dd HH:mm:ss")); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | dto1311.setSyyy(StringUtils.isEmpty(data.getRemark()) ? "0" : data.getRemark()); | 
|---|
|  |  |  | dto1311.setNm(data.getDepotId().substring(0, 21)); | 
|---|
|  |  |  | dto1311.setZznm(data.getDepotId().substring(0, 21)); | 
|---|
|  |  |  | dto1311.setNm(ApiShUtil.getGbDepotId(data.getDepotId()).substring(0, 21)); | 
|---|
|  |  |  | dto1311.setZznm(ApiShUtil.getGbDepotId(data.getDepotId()).substring(0, 21)); | 
|---|
|  |  |  | dto1311.setSydjdbh(data.getId()); | 
|---|
|  |  |  | dto1311.setWlbh(StringUtils.isEmpty(data.getFoodVariety()) ? "0" : data.getFoodVariety()); | 
|---|
|  |  |  | //            dto1311.setWlbh(StringUtils.isEmpty(data.getFoodVariety()) ? "0" : data.getFoodVariety()); | 
|---|
|  |  |  | dto1311.setRknx(DateFormatUtils.format((data.getSubmitTime() == null ? new Date() : data.getSubmitTime()), "yyyy")); | 
|---|
|  |  |  | dto1311.setNx(DateFormatUtils.format((data.getSubmitTime() == null ? new Date() : data.getSubmitTime()), "yyyy")); | 
|---|
|  |  |  | dto1311.setLrsj(DateFormatUtils.format((data.getSubmitTime() == null ? new Date() : data.getSubmitTime()), "yyyy-MM-dd HH:mm:ss")); | 
|---|