KuaiDiNiaoServiceImpl.java 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420
  1. package com.hys.app.service.kuaidiniao;
  2. import cn.hutool.core.bean.BeanUtil;
  3. import cn.hutool.core.codec.Base64;
  4. import cn.hutool.core.util.IdUtil;
  5. import cn.hutool.core.util.ObjectUtil;
  6. import cn.hutool.core.util.StrUtil;
  7. import cn.hutool.crypto.digest.DigestUtil;
  8. import cn.hutool.http.HttpUtil;
  9. import cn.hutool.json.JSONUtil;
  10. import com.alibaba.fastjson.JSON;
  11. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  12. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  13. import com.hys.app.converter.erp.OrderConverter;
  14. import com.hys.app.framework.context.user.AdminUserContext;
  15. import com.hys.app.framework.database.BaseQueryParam;
  16. import com.hys.app.framework.exception.ServiceException;
  17. import com.hys.app.framework.util.BeanUtils;
  18. import com.hys.app.framework.util.ScriptUtil;
  19. import com.hys.app.mapper.erp.KdnMapper;
  20. import com.hys.app.mapper.goods.ProductMapper;
  21. import com.hys.app.model.erp.dos.*;
  22. import com.hys.app.model.erp.enums.*;
  23. import com.hys.app.service.erp.*;
  24. import com.hys.app.service.kuaidiniao.entity.*;
  25. import org.slf4j.Logger;
  26. import org.slf4j.LoggerFactory;
  27. import org.springframework.beans.factory.annotation.Autowired;
  28. import org.springframework.beans.factory.annotation.Value;
  29. import org.springframework.stereotype.Service;
  30. import java.net.URLEncoder;
  31. import java.time.LocalDateTime;
  32. import java.util.HashMap;
  33. import java.util.List;
  34. import java.util.Map;
  35. import java.util.regex.Pattern;
  36. @Service
  37. public class KuaiDiNiaoServiceImpl implements KuaiDiNiaoService {
  38. /**
  39. * 快递鸟apiId
  40. */
  41. @Value("${kuaidianiao.id}")
  42. private String id;
  43. /**
  44. * 快递鸟apiKey
  45. */
  46. @Value("${kuaidianiao.key}")
  47. private String apiKey;
  48. /**
  49. * 快递鸟请求地址
  50. */
  51. @Value("${kuaidianiao.apiUrl}")
  52. private String url;
  53. /**
  54. * 快递鸟apiId
  55. */
  56. @Value("${kuaidianiao.kuaidi.id}")
  57. private String kuaiDiId;
  58. /**
  59. * 快递鸟apiKey
  60. */
  61. @Value("${kuaidianiao.kuaidi.key}")
  62. private String kuaiDiKey;
  63. /**
  64. * 快递鸟请求地址
  65. */
  66. @Value("${kuaidianiao.kuaidi.apiUrl}")
  67. private String kuaiDiUrl;
  68. @Autowired
  69. private OrderSendManager orderSendManager;
  70. @Autowired
  71. private OrderManager orderManager;
  72. @Autowired
  73. private OrderConverter converter;
  74. @Autowired
  75. private KdnMapper kdnMapper;
  76. private static final Logger log = LoggerFactory.getLogger(ScriptUtil.class);
  77. @Override
  78. public String kdShip(PreOrderModelDTO preOrderModel, Long orderId, AddressDTO addressDTO) {
  79. preOrderModel.setOrderCode(IdUtil.fastUUID());
  80. fillParam(preOrderModel);
  81. PreOrderModel model = BeanUtil.copyProperties(preOrderModel, PreOrderModel.class);
  82. String kdnCode = sendUrl(JSONUtil.toJsonStr(model));
  83. if (StrUtil.isNotEmpty(kdnCode)) {
  84. //如果快递鸟下单成功保存 快递信息
  85. OrderSendDO aDo = orderSendManager.getById(orderId);
  86. log.info("快递鸟下单成功 我们的订单号:---------------------" + orderId);
  87. converter.copyProperties(aDo, preOrderModel, preOrderModel.getReceiver(), preOrderModel.getSender());
  88. aDo.setGoodsList(preOrderModel.getGoodsList());
  89. aDo.setKdnOrderCode(kdnCode);
  90. aDo.setSendAddress(addressDTO.getSendAddress());
  91. aDo.setReceiveAddress(addressDTO.getReceiveAddress());
  92. orderSendManager.updateById(aDo);
  93. }
  94. return kdnCode;
  95. }
  96. @Override
  97. public void createStore(CreateStoreModel createStoreModel, String constants) {
  98. if (Pattern.matches(".*[\\u4e00-\\u9fa5\\p{P}].*", createStoreModel.getStoreCode())){
  99. throw new ServiceException("门店编码和统一社会信用代码不能包含中文和特殊符号");
  100. }
  101. if (Pattern.matches(".*[\\u4e00-\\u9fa5\\p{P}].*", createStoreModel.getCreditCode())){
  102. throw new ServiceException("门店编码和统一社会信用代码不能包含中文和特殊符号");
  103. }
  104. Long modelId = createStoreModel.getId();
  105. createStoreModel.setId(null);
  106. fillParam(createStoreModel);
  107. CreateStoreModel2 createStoreModel2 = BeanUtil.copyProperties(createStoreModel, CreateStoreModel2.class);
  108. try {
  109. String design = URLEncoder.encode(Base64.encode(DigestUtil.md5Hex(JSONUtil.toJsonStr(createStoreModel2) + apiKey)), "UTF-8");
  110. System.out.println("创建店铺签名--------------------------------------" + design);
  111. //拼接参数
  112. String param = "interfaceType=" + constants + "&customerCode=" + id + "&requestData=" + JSONUtil.toJsonStr(createStoreModel2) + "&dataSign=" + design;
  113. //发请求
  114. String res = HttpUtil.post(url, param);
  115. Map map = JSON.parseObject(res, Map.class);
  116. if (ObjectUtil.isNotNull(map.get("resultCode")) && !(100 == Integer.parseInt(map.get("resultCode").toString()))) {
  117. throw new ServiceException("店铺创建失败" + map.get("reason").toString());
  118. }
  119. Map dataMap = JSON.parseObject(JSON.toJSONString(map.get("data")), Map.class);
  120. createStoreModel.setKdnStoreCode(dataMap.get("kdnStoreCode").toString());
  121. if (ObjectUtil.isNotNull(modelId)) {
  122. createStoreModel.setId(modelId);
  123. kdnMapper.updateById(createStoreModel);
  124. } else {
  125. kdnMapper.insert(createStoreModel);
  126. }
  127. } catch (Exception e) {
  128. e.printStackTrace();
  129. throw new ServiceException("店铺创建异常");
  130. }
  131. }
  132. @Override
  133. public Page<CreateStoreModel> getStoreList(BaseQueryParam baseQueryParam) {
  134. return kdnMapper.selectPage(new Page<>(baseQueryParam.getPageNo(), baseQueryParam.getPageSize()), new LambdaQueryWrapper<>());
  135. }
  136. @Override
  137. public void selectAudit(CreateStoreModel createStoreModel) {
  138. Map<String, Object> hashMap = new HashMap<>();
  139. hashMap.put("storeCode", createStoreModel.getStoreCode());
  140. try {
  141. String design = URLEncoder.encode(Base64.encode(DigestUtil.md5Hex(JSONUtil.toJsonStr(hashMap) + apiKey)), "UTF-8");
  142. System.out.println("获取门店状态签名--------------------------------------" + design);
  143. //拼接参数
  144. String param = "interfaceType=" + KdConstants.queryStoreStatus + "&customerCode=" + id + "&requestData=" + JSONUtil.toJsonStr(hashMap) + "&dataSign=" + design;
  145. //发请求
  146. String res = HttpUtil.post(url, param);
  147. Map map = JSON.parseObject(res, Map.class);
  148. if (ObjectUtil.isNotNull(map.get("resultCode")) && !(100 == Integer.parseInt(map.get("resultCode").toString()))) {
  149. throw new ServiceException("请求状态失败" + map.get("reason").toString());
  150. }
  151. Map dataMap = JSON.parseObject(JSON.toJSONString(map.get("data")), Map.class);
  152. List<Map> storeDetail = JSON.parseArray(dataMap.get("storeDetail").toString(), Map.class);
  153. for (Map statusMap : storeDetail) {
  154. switch (statusMap.get("intraCode").toString()) {
  155. case "SS":
  156. createStoreModel.setSsStatus(Integer.parseInt(statusMap.get("storeStatus").toString()));
  157. if (ObjectUtil.isNotNull(statusMap.get("operationFailReason"))){
  158. createStoreModel.setFnReason(statusMap.get("operationFailReason").toString());
  159. }
  160. case "DD":
  161. createStoreModel.setDdStatus(Integer.parseInt(statusMap.get("storeStatus").toString()));
  162. if (ObjectUtil.isNotNull(statusMap.get("operationFailReason"))){
  163. createStoreModel.setFnReason(statusMap.get("operationFailReason").toString());
  164. }
  165. case "FN":
  166. createStoreModel.setFnStatus(Integer.parseInt(statusMap.get("storeStatus").toString()));
  167. if (ObjectUtil.isNotNull(statusMap.get("operationFailReason"))){
  168. createStoreModel.setFnReason(statusMap.get("operationFailReason").toString());
  169. }
  170. case "MTPS":
  171. createStoreModel.setMtStatus(Integer.parseInt(statusMap.get("storeStatus").toString()));
  172. if (ObjectUtil.isNotNull(statusMap.get("operationFailReason"))){
  173. createStoreModel.setFnReason(statusMap.get("operationFailReason").toString());
  174. }
  175. }
  176. }
  177. kdnMapper.updateById(createStoreModel);
  178. } catch (Exception e) {
  179. e.printStackTrace();
  180. throw new ServiceException("请求发生异常");
  181. }
  182. }
  183. /**
  184. * 订阅就行了,订阅成功与否均不影响货物的正常派发
  185. */
  186. @Override
  187. public void queryLogistics(LogisyicsTopic logisyicsTopic) {
  188. try {
  189. String design = URLEncoder.encode(Base64.encode(DigestUtil.md5Hex(JSONUtil.toJsonStr(logisyicsTopic) + kuaiDiKey)), "UTF-8");
  190. Map<String, Object> paramMap = new HashMap<>();
  191. paramMap.put("RequestData", JSONUtil.toJsonStr(logisyicsTopic));
  192. paramMap.put("DataType", 2);
  193. paramMap.put("EBusinessID", kuaiDiId);
  194. paramMap.put("DataSign", design);
  195. paramMap.put("RequestType", KdConstants.orderLogistics);
  196. String res = HttpUtil.post(kuaiDiUrl, paramMap);
  197. log.info(logisyicsTopic.getLogisticCode() + "快递鸟轨迹订阅" + res);
  198. } catch (Exception e) {
  199. }
  200. }
  201. @Override
  202. public Boolean kdnReturnBackLogistics(Map map) {
  203. try {
  204. OrderSendDO sendDO = orderSendManager.getOne(new LambdaQueryWrapper<OrderSendDO>().eq(OrderSendDO::getLogisticsCode, map.get("LogisticCode").toString()).last("limit 1"));
  205. if (ObjectUtil.isNotNull(sendDO)) {
  206. List<Map> maps = JSON.parseArray(JSON.toJSONString(map.get("Traces")), Map.class);
  207. sendDO.setLogistics(maps);
  208. }
  209. orderSendManager.updateById(sendDO);
  210. return true;
  211. }catch (Exception e){
  212. return false;
  213. }
  214. }
  215. @Override
  216. public String prePareTime(PreOrderModelDTO preOrderModel, Long orderId, AddressDTO addressDTO) {
  217. return null;
  218. }
  219. /**
  220. * @param dataJson 业务参数
  221. * @return 返回JSON
  222. */
  223. private String sendUrl(String dataJson) {
  224. String design ="";
  225. try {
  226. design = URLEncoder.encode(Base64.encode(DigestUtil.md5Hex(dataJson + apiKey)), "UTF-8");
  227. }catch (Exception e){
  228. throw new ServiceException("签名异常");
  229. }
  230. System.out.println("--------------------------------------" + design);
  231. //拼接参数
  232. String param = "interfaceType=" + KdConstants.preOrder + "&customerCode=" + id + "&requestData=" + dataJson + "&dataSign=" + design;
  233. //发请求
  234. String res = HttpUtil.post(url, param);
  235. Map map = JSON.parseObject(res, Map.class);
  236. //resultCode == 100表示预下单成功,预下单郑工后立马调用下单接口
  237. if (ObjectUtil.isNotNull(map.get("resultCode")) && 100 == Integer.valueOf(map.get("resultCode").toString())) {
  238. //拼接参数
  239. String createParam = "interfaceType=" + KdConstants.createOrder + "&customerCode=" + id + "&requestData=" + dataJson + "&dataSign=" + design;
  240. //发请求
  241. String resCreate = HttpUtil.post(url, createParam);
  242. Map mapCreate = JSON.parseObject(resCreate, Map.class);
  243. //resultCode == 100表示下单成功,预下单成功后立马调用下单接口
  244. if (ObjectUtil.isNotNull(mapCreate.get("resultCode")) && 100 == Integer.valueOf(mapCreate.get("resultCode").toString())) {
  245. Map mapData = JSON.parseObject(mapCreate.get("data").toString(), Map.class);
  246. log.info("快递鸟下单成功 单号:--------------------------------" + mapData.get("kdnOrderCode").toString());
  247. return mapData.get("kdnOrderCode").toString();
  248. }
  249. } else {
  250. throw new ServiceException(map.get("reason").toString());
  251. }
  252. return null;
  253. }
  254. private void fillParam(PreOrderModelDTO preOrderModel) {
  255. if (preOrderModel.getAppointmentType() == 1 ){
  256. if (LocalDateTime.now().plusHours(2).isAfter(preOrderModel.getAppointmentTime())){
  257. throw new ServiceException("预约单必须在当前时间完后2小时");
  258. }
  259. }
  260. //填充送货人的经纬度
  261. LongitudeLatitude longitudeLatitudeSender = GaoDeUtil.getLongitudeLatitude(preOrderModel.getSender().getProvinceName()+preOrderModel.getSender().getCityName()+preOrderModel.getSender().getAreaName()+preOrderModel.getSender().getAddress());
  262. preOrderModel.getSender().setLongitude(longitudeLatitudeSender.getLongitude());
  263. preOrderModel.getSender().setLatitude(longitudeLatitudeSender.getLatitude());
  264. //填充收货人的经纬度
  265. LongitudeLatitude longitudeLatitudeReceiver = GaoDeUtil.getLongitudeLatitude(preOrderModel.getReceiver().getProvinceName()+preOrderModel.getReceiver().getCityName()+preOrderModel.getReceiver().getAreaName()+preOrderModel.getReceiver().getAddress());
  266. preOrderModel.getReceiver().setLongitude(longitudeLatitudeReceiver.getLongitude());
  267. preOrderModel.getReceiver().setLatitude(longitudeLatitudeReceiver.getLatitude());
  268. //获取下单人信息
  269. preOrderModel.setOrderName(AdminUserContext.getAdminUserName());
  270. preOrderModel.setOrderPhone("13127911751");
  271. }
  272. private void fillParam(CreateStoreModel model) {
  273. LongitudeLatitude longitudeLatitudeSender = GaoDeUtil.getLongitudeLatitude(model.getProvinceName() + model.getCityName() + model.getAreaName() + model.getAddress());
  274. model.setLongitude(longitudeLatitudeSender.getLongitude());
  275. model.setLatitude(longitudeLatitudeSender.getLatitude());
  276. //填充送货人的经纬度
  277. }
  278. /**
  279. * 推送待接单状态 接口指令103,状态码100
  280. * 推送业务员接单状态 接口指令103,状态码201
  281. * 推送业务员到达状态 接口指令103,状态码202
  282. * 推送配送中状态 接口指令103,状态码300
  283. * 推送签收状态
  284. * (签收分为两种签收) 接口指令103,状态码401(正常签收)
  285. * 接口指令103,状态码402(退回签收)
  286. * 推送取消状态 接口指令103,状态码500
  287. * 推送下单失败状态 接口指令103,状态码600
  288. * 推送订单费用状态 接口指令103,状态码206
  289. */
  290. @Override
  291. public resReturnBackBase kdnReturnBack(ReturnBackInstant returnBackBase) {
  292. Map map = JSON.parseObject(returnBackBase.getRequestData(), Map.class);
  293. resReturnBackBase base = new resReturnBackBase();
  294. base.setKdnOrderCode(map.get("kdnOrderCode").toString());
  295. //验签
  296. OrderSendDO aDo = orderSendManager.getOne(new LambdaQueryWrapper<OrderSendDO>().eq(OrderSendDO::getKdnOrderCode,map.get("kdnOrderCode").toString()));
  297. if (ObjectUtil.isNull(aDo)){
  298. // base.setRequestData("验签失败");
  299. base.setResultCode(1002);
  300. base.setReason("未找到对应的商家订单");
  301. return base;
  302. }
  303. OrderDO orderDO = orderManager.getById(aDo.getOrderId());
  304. // if (!checkDesign(aDo, returnBackBase.getDataSign())) {
  305. // base.setRequestData("验签失败");
  306. // base.setResultCode(1002);
  307. // return base;
  308. // }
  309. if (ObjectUtil.isNull(aDo) || ObjectUtil.isNull(orderDO)) {
  310. base.setReason("未找到对应的订单");
  311. log.error("未找到对应的订单-------------------------------" + map.get("orderCode").toString());
  312. base.setResultCode(1002);
  313. return base;
  314. }
  315. switch (map.get("orderStatus").toString()) {
  316. case KdConstants.callBackPreAccept:
  317. aDo.setCreateOrderSuccess(map);
  318. break;
  319. case KdConstants.callBackAccept:
  320. aDo.setUserTakeOrder(map);
  321. break;
  322. case KdConstants.callBackAttain:
  323. aDo.setUserArrives(map);
  324. break;
  325. case KdConstants.callBackSending:
  326. aDo.setUserSending(map);
  327. break;
  328. case KdConstants.callBackSign:
  329. aDo.setSignIn(map);
  330. aDo.setStatus(SaleOrderSendStatusEnum.TO_BE_SINGE);
  331. if (OrderTypeEnum.TO_B.equals(orderDO.getType())) {
  332. orderDO.setStatus(SaleOrderStatusEnum.ORDER_END);
  333. }
  334. if (OrderTypeEnum.TO_C.equals(orderDO.getType())) {
  335. orderDO.setStatus(SaleOrderStatusEnum.TO_BE_RETURN);
  336. }
  337. break;
  338. case KdConstants.callBackSignRefuse:
  339. aDo.setSignIn(map);
  340. aDo.setStatus(SaleOrderSendStatusEnum.TO_BE_SINGE_NOT);
  341. if (OrderTypeEnum.TO_B.equals(orderDO.getType())) {
  342. orderDO.setStatus(SaleOrderStatusEnum.ORDER_END);
  343. }
  344. if (OrderTypeEnum.TO_C.equals(orderDO.getType())) {
  345. orderDO.setStatus(SaleOrderStatusEnum.TO_BE_RETURN);
  346. }
  347. break;
  348. case KdConstants.callBackCancelStatus:
  349. //如果推送取消状态,需要重新下单
  350. aDo.setKdnOrderCode("");
  351. aDo.setStatus(SaleOrderSendStatusEnum.TO_BE_SEND);
  352. aDo.setSendNo(aDo.getSendNo()+1);
  353. break;
  354. case KdConstants.callBackCreateOrderFail:
  355. //如果下单失败更爱订单状态,清空快递鸟单号,让用户可以重新下单
  356. aDo.setKdnOrderCode("");
  357. aDo.setStatus(SaleOrderSendStatusEnum.TO_BE_SEND);
  358. aDo.setSendNo(aDo.getSendNo()+1);
  359. break;
  360. case KdConstants.callBackFeeStatus:
  361. aDo.setOrderFee(map);
  362. break;
  363. default:
  364. base.setResultCode(1002);
  365. base.setReason("内部业务异常,麻烦尽快通知商家,tel:13127911751");
  366. }
  367. orderSendManager.updateById(aDo);
  368. return base;
  369. }
  370. // private Boolean checkDesign(OrderSendDO aDo, String dataSign) {
  371. // try {
  372. // PreOrderModel model = new PreOrderModel();
  373. // converter.copyProperties(model, aDo);
  374. // model.setGoodsList(aDo.getGoodsList());
  375. // String design = URLEncoder.encode(Base64.encode(DigestUtil.md5Hex(JSONUtil.toJsonStr(model) + apiKey)), "UTF-8");
  376. // if (dataSign.equals(design)) {
  377. // return true;
  378. // }
  379. // return false;
  380. // } catch (Exception e) {
  381. // return false;
  382. // }
  383. // }
  384. }