| | |
|---|
| | | import com.fzzy.api.service.ApiTriggerService; |
|---|
| | | import com.fzzy.api.utils.*; |
|---|
| | | import com.fzzy.api.view.repository.*; |
|---|
| | | import com.fzzy.order.data.OrderData; |
|---|
| | | import com.fzzy.order.common.data.OrderCommonData; |
|---|
| | | import com.fzzy.push.sh2023.dto.*; |
|---|
| | | import lombok.Data; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | |
|---|
| | | //获取指令id |
|---|
| | | String key = RedisConst.buildKey(RedisConst.KYE_ORDER, conf.getKqdm()); |
|---|
| | | OrderData orderData = (OrderData) redisUtil.get(key); |
|---|
| | | if (null == orderData || StringUtils.isEmpty(orderData.getOrderid())) { |
|---|
| | | OrderCommonData orderCommonData = (OrderCommonData) redisUtil.get(key); |
|---|
| | | if (null == orderCommonData || StringUtils.isEmpty(orderCommonData.getOrderid())) { |
|---|
| | | log.error("指令id失效=" + jsonData); |
|---|
| | | ResponseDto responseDto = new ResponseDto(99, "指令id失效"); |
|---|
| | | apiLog.setStatus(99); |
|---|
| | |
|---|
| | | //获取身份ID，即行政区划码 |
|---|
| | | reqData.setUid(conf.getUserName()); |
|---|
| | | //指令id |
|---|
| | | reqData.setOrderid(orderData.getOrderid()); |
|---|
| | | reqData.setOrderid(orderCommonData.getOrderid()); |
|---|
| | | |
|---|
| | | //身份签名，使用自有RSA私钥进行加密(地区行政区划代码_当天日期) |
|---|
| | | reqData.setAccess_token(ShRSAUtils.sign(reqData.getUid() + "_" + DateFormatUtils.format(new Date(), "yyyy-MM-dd"), conf.getPassword())); |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (StringUtils.isNotEmpty(apiData.getHwdm())) { |
|---|
| | | List<Api1208> api1208List = api1208Rep.findDataByHwdm(apiData.getHwdm()); |
|---|
| | | if (null != api1208List && api1208List.size() > 0) { |
|---|
| | | api1206.setPch(api1208List.get(0).getHwdm() + api1208List.get(0).getShnd()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //设置空属性为默认值 |
|---|
| | | changeObject(api1206); |
|---|
| | | return api1206; |
|---|
| | |
|---|
| | | Api1306 apiData = (Api1306) data; |
|---|
| | | BeanUtils.copyProperties(apiData, api1306); |
|---|
| | | api1306.setBjw(ShAreaBjw.getBjw(code)); |
|---|
| | | api1306.setPch(apiData.getXzzydh().substring(0, 30) + DateFormatUtils.format(apiData.getXzkssj(), "yyyy")); |
|---|
| | | api1306.setAjdm(apiData.getHwdm().substring(0, 28)); |
|---|
| | | //上海熏蒸作业单号：货位代码+yyyyMMdd + 3位顺序号 |
|---|
| | | api1306.setXzzydh(apiData.getHwdm() + apiData.getBizId()); |
|---|
| | | //设置批次号 |
|---|
| | | List<Api1208> api1208List = api1208Rep.findDataByHwdm(apiData.getHwdm()); |
|---|
| | | if (null != api1208List && api1208List.size() > 0) { |
|---|
| | | api1306.setPch(apiData.getHwdm() + api1208List.get(0).getShnd()); |
|---|
| | | } |
|---|
| | | if (StringUtils.isEmpty(api1306.getSyff())) { |
|---|
| | | api1306.setSyff("0"); //潮解法 |
|---|
| | | } |
|---|
