分销，库存综合管理系统.zip

package cn.lmjia.market.core.trj.service; import cn.lmjia.market.core.define.MarketNoticeType; import cn.lmjia.market.core.define.MarketUserNoticeType; import cn.lmjia.market.core.entity.Login; import cn.lmjia.market.core.entity.MainOrder; import cn.lmjia.market.core.entity.support.ManageLevel; import cn.lmjia.market.core.entity.trj.AuthorisingInfo; import cn.lmjia.market.core.entity.trj.AuthorisingStatus; import cn.lmjia.market.core.entity.trj.TRJPayOrder; import cn.lmjia.market.core.event.MainOrderFinishEvent; import cn.lmjia.market.core.repository.MainOrderRepository; import cn.lmjia.market.core.repository.trj.AuthorisingInfoRepository; import cn.lmjia.market.core.service.LoginService; import cn.lmjia.market.core.service.ManagerService; import cn.lmjia.market.core.service.ScriptTaskService; import cn.lmjia.market.core.service.WechatNoticeHelper; import cn.lmjia.market.core.trj.InvalidAuthorisingException; import cn.lmjia.market.core.trj.TRJService; import me.jiangcai.jpa.entity.support.Address; import me.jiangcai.lib.resource.service.ResourceService; import me.jiangcai.lib.sys.service.SystemStringService; import me.jiangcai.logistics.entity.StockShiftUnit; import me.jiangcai.logistics.event.InstallationEvent; import me.jiangcai.logistics.event.OrderDeliveredEvent; import me.jiangcai.logistics.event.ShiftEvent; import me.jiangcai.logistics.haier.entity.HaierOrder; import me.jiangcai.payment.PayableOrder; import me.jiangcai.payment.entity.PayOrder; import me.jiangcai.payment.event.OrderPaySuccess; import me.jiangcai.payment.exception.SystemMaintainException; import me.jiangcai.payment.service.PaymentService; import me.jiangcai.user.notice.UserNoticeService; import me.jiangcai.wx.model.message.SimpleTemplateMessageParameter; import me.jiangcai.wx.model.message.TemplateMessageParameter; import org.apache.commons.codec.digest.DigestUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.http.HttpEntity; import org.apache.http.NameValuePair; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.entity.EntityBuilder; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.methods.HttpUriRequest; import org.apache.http.entity.ContentType; import org.apache.http.entity.mime.MultipartEntityBuilder; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.message.BasicNameValuePair; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.context.event.EventListener; import org.springframework.core.env.Environment; import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.Resource; import org.springframework.stereotype.Service; import org.springframework.util.StreamUtils; import org.springframework.util.StringUtils; import javax.activation.MimetypesFileTypeMap; import javax.annotation.PostConstruct; import javax.servlet.http.HttpServletRequest; import java.io.IOException; import java.math.BigDecimal; import java.nio.charset.Charset; import java.time.Instant; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.ZoneId; import java.time.ZonedDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import java.util.function.Function; /** * @author CJ */ @Service public class TRJServiceImpl implements TRJService { private static final DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); private static final DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); private static final Log log = LogFactory.getLog(TRJServiceImpl.class); private final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(5); private final String urlRoot; private final String tenant; private final String key; private final String autoRecallCode; @Autowired private AuthorisingInfoRepository authorisingInfoRepository; @Autowired private ApplicationContext applicationContext; @Autowired private MainOrderRepository mainOrderRepository; @Autowired private ScriptTaskService scriptTaskService; @Autowired private ManagerService managerService; @Autowired private LoginService loginService; @Autowired private UserNoticeService userNoticeService; @Autowired private ResourceService resourceService; @Autowired private SystemStringService systemStringService; @Autowired private WechatNoticeHelper wechatNoticeHelper; @Autowired public TRJServiceImpl(Environment environment) throws IOException { urlRoot = environment.getProperty("me.jiangcai.dating.tourongjia.url2", "http://crmtest2.tourongjia.com"); tenant = environment.getProperty("me.jiangcai.dating.tourongjia.tenant", "yuntao"); key = environment.getProperty("me.jiangcai.dating.tourongjia.key", "1234567890"); autoRecallCode = StreamUtils.copyToString(new ClassPathResource("/script/auto-recall.js").getInputStream(), Charset.forName("UTF-8")); } private static String toTRJString(Address address) { return address.getProvince() + "-" + address.getPrefecture() + "-" + address.getCounty() + "-" + address.getOtherAddress(); } private static String sign(final Map<String, String> params, String secretKey) { if (StringUtils.isEmpty(secretKey)) { throw new IllegalArgumentException("secretKey not bank."); } StringBuilder sb = new StringBuilder(); if (params != null && params.size() > 0) { List<String> nameList = new ArrayList<>(); for (Iterator<String> it = params.keySet().iterator(); it.hasNext(); ) { String key = it.next(); nameList.add(key); } Collections.sort(nameList); for (String name : nameList) { if (sb.length() > 0) { sb.append("&"); } sb.append(name).append("=").append(params.get(name)); } } log.trace("排序并且串联后：" + sb.toString()); sb.append(secretKey); log.trace("加入Key：" + sb.toString()); final String hex = DigestUtils.md5Hex(sb.toString()); log.trace("MD5 & Hex:" + hex); return hex; } @Override public void addAuthorisingInfo(String authorising, String idNumber) { if (authorisingInfoRepository.findOne(authorising) != null) throw new IllegalArgumentException(authorising + "existing"); AuthorisingInfo info = new AuthorisingInfo(); info.setId(authorising); info.setIdNumber(idNumber); info.setCreatedTime(LocalDateTime.now()); authorisingInfoRepository.save(info); } @Override public void deliverUpdate(long orderId, String deliverCompany, String deliverStore, int stockQuantity , LocalDate shipmentTime, LocalDate deliverTime) { MainOrder order = mainOrderRepository.getOne(orderId); TRJPayOrder payOrder = (TRJPayOrder) order.getPayOrder(); try { deliverUpdate(orderId, payOrder.getAuthorisingInfo().getId(), deliverCompany, deliverStore, stockQuantity , shipmentTime.format(dateFormatter), deliverTime.format(dateFormatter), order.getCustomer().getName() , order.getCustomer().getMobile(), toTRJString(order.getInstallAddress())