| | |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | | import org.springframework.util.CollectionUtils; |
|---|
| | | |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * WMS平台对接Service实现 |
|---|
| | |
|---|
| | | update.setWmsSendNum(job.getWmsSendNum() + 1); |
|---|
| | | } |
|---|
| | | update.setWmsSendPlatformCode(job.getPlatformWmsCode()); |
|---|
| | | Boolean success = false; |
|---|
| | | if(response!=null && response.getData() !=null |
|---|
| | | && response.getData().size()>0 && StringUtils.equals(response.getData().get(0).getSuccess(),WmsBaseResponse.CODE_SUCCESS)){ |
|---|
| | | //如果成功 |
|---|
| | | update.setWmsSendStatus(Constants.ONE); |
|---|
| | | update.setWmsSendInfo("通知WMS作业单分配月台成功"); |
|---|
| | | success = true; |
|---|
| | | }else{ |
|---|
| | | //如果失败 |
|---|
| | | update.setWmsSendStatus(Constants.TWO); |
|---|
| | | update.setWmsSendInfo("通知WMS作业单分配月台失败:"+(response!=null?JSONObject.toJSONString(response):"接口调用失败")); |
|---|
| | | } |
|---|
| | | platformJobMapper.updateById(update); |
|---|
| | | this.saveInterfaceLog(url, name,JSONObject.toJSONString(param), |
|---|
| | | success?Constants.ZERO:Constants.ONE, update.getWmsSendInfo(),Constants.ZERO); |
|---|
| | | return response; |
|---|
| | | |
|---|
| | | } |
|---|
| | |
|---|
| | | job.setArriveDate(new Date()); |
|---|
| | | job.setSingType(Constants.TWO); |
|---|
| | | job.setSignDate(new Date()); |
|---|
| | | List<PlatformJob> signList = platformJobMapper.selectList(new QueryWrapper<PlatformJob>().lambda().apply(" DATE(SIGN_DATE) = DATE(NOW()) and sign_date is not null ")); |
|---|
| | | if(CollectionUtils.isEmpty(signList)){ |
|---|
| | | job.setSignNum(Constants.ONE); |
|---|
| | | } else{ |
|---|
| | | int maxNumber = Collections.max(signList.stream().map(i->i.getSignNum()).collect(Collectors.toList())); |
|---|
| | | job.setSignNum(maxNumber + Constants.ONE); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | PlatformGroup group = platformGroupMapper.selectOne(new QueryWrapper<PlatformGroup>().lambda() |
|---|
