KuaiDiNiaoServiceImpl.java 19 KB

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