package com.gk.firework.Scheduls.DL;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.gk.firework.Domain.CustomerInfo;
|
import com.gk.firework.Domain.Enterprise;
|
import com.gk.firework.Domain.SaleOrderDetailInfo;
|
import com.gk.firework.Domain.SaleOrderInfo;
|
import com.gk.firework.Domain.Utils.BeanUtils;
|
import com.gk.firework.Domain.Utils.HttpUtils;
|
import com.gk.firework.Domain.Utils.StringUtils;
|
import com.gk.firework.Service.*;
|
import org.apache.axis.client.Call;
|
import org.apache.axis.client.Service;
|
import org.apache.axis.encoding.XMLType;
|
import org.apache.log4j.LogManager;
|
import org.apache.log4j.Logger;
|
import org.joda.time.DateTime;
|
import org.joda.time.format.DateTimeFormat;
|
import org.joda.time.format.DateTimeFormatter;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import sun.misc.BASE64Decoder;
|
import sun.misc.BASE64Encoder;
|
|
import javax.xml.bind.annotation.XmlElement;
|
import javax.xml.bind.annotation.XmlRootElement;
|
import java.io.IOException;
|
import java.util.*;
|
|
/**
|
* @author : jingjy
|
* @date : 2022/1/26 17:15
|
*/
|
@Configuration
|
@EnableScheduling
|
//@ConditionalOnProperty(prefix = "scheduling",name = "enabled",havingValue = "true")
|
public class ReportOrderTask {
|
private Logger logger = LogManager.getLogger(com.gk.firework.Scheduls.WarningTask.StockWarnTask.class);
|
private static final String url = "http://118.190.117.180:8888";
|
@Value("${com.gk.firework.schedules.single.switch}")
|
private Boolean switchBtn;
|
@Autowired
|
EnterpriseService enterpriseService;
|
@Autowired
|
SaleOrderService saleOrderService;
|
@Autowired
|
SaleOrderDetailService saleOrderDetailService;
|
@Autowired
|
StockService stockService;
|
@Autowired
|
CustomerService customerService;
|
|
//@Scheduled(cron = "0 0 2 * * ?") //每天凌晨两点执行一次
|
@Scheduled(cron = "0/10 * * * * ?") //每隔10秒执行一次
|
private void reportOrder() {
|
if (!switchBtn) return;
|
//1.获取需要上传的企业信息
|
List<Enterprise>enterprises = enterpriseService.selectSaleEnterpriseForUpload();
|
for (Enterprise enterprise : enterprises){
|
if (StringUtils.isBlank(enterprise.getDlcompanycode()) || StringUtils.isBlank(enterprise.getDeviceid())){
|
continue;
|
}
|
|
//2.获取握手密码
|
DlResult result = getHandshake(enterprise);
|
if (result == null || StringUtils.isBlank(result.getFwdz()) || StringUtils.isBlank(result.getWsmm())){
|
continue;
|
}
|
//获取企业未上传销售数据
|
List<SaleOrderInfo> orderInfos = saleOrderService.getWaitUploadOrderByEnterprise(enterprise);
|
if (orderInfos == null || orderInfos.size() == 0){
|
continue;
|
}
|
|
uploadOrders(orderInfos,result,enterprise);
|
}
|
|
//3.上传数据
|
//4.处理上传结果
|
|
}
|
|
private DlResult getHandshake(Enterprise enterprise){
|
String respnse = null;
|
DlResult result = new DlResult();
|
Map params = new HashMap();//请求参数
|
params.put("sbid", enterprise.getDeviceid());//
|
params.put("dwdm", enterprise.getDlcompanycode());//
|
|
try {
|
respnse = HttpUtils.net(url+"/lsjk/Sbrz", params, "GET");
|
JSONObject jsonResult = JSONObject.parseObject(respnse);
|
String wsmm = jsonResult.getString("wsmm");
|
String fwdz = jsonResult.getString("fwdz");
|
result.setFwdz(fwdz);
|
result.setWsmm(wsmm);
|
return result;
|
}catch (Exception e){
|
return result;
|
}
|
}
|
|
public void uploadOrders(List<SaleOrderInfo>orderInfos, DlResult result, Enterprise enterprise){
|
|
String servicesUrl = url+result.getFwdz();
|
for (SaleOrderInfo orderInfo : orderInfos){
|
Service service = new Service();
|
Call call = null;
|
/**
|
* <?xml version="1.0" encoding="GBK"?>
|
* <sb>
|
* <sjbs>YH</sjbs><!--数据标注 -->
|
* <jylx>XX</jylx><!-- 交易类型（03-运输入库、09-退货、10-零散销售） -->
|
* <sjscsj>20100630151617</sjscsj><!--数据生成时间（精确到秒） -->
|
* <dwdm>XXXX</dwdm><!--单位代码（和烟花系统确定对应关系） -->
|
* <cjsbid>XXXX</cjsbid ><!--条码采集设备ID（定长32，不足补0） -->
|
* <zjlx>1</zjlx><!--证件类型（1-身份证、2-其他） -->
|
* <zjhm>XXXX</zjhm><!--证件号码，定长18 -->
|
* <tms>
|
* <bh>XXX</bh><!--条码编号-->
|
* <sj>20100630151617</sj><!--采集时间（精确到秒）-->
|
* </tms>
|
* </sb>
|
*/
|
try {
|
List<SaleOrderDetailInfo> detailInfos = saleOrderDetailService.selectByOrderCode(orderInfo.getCode());
|
CustomerInfo customerInfo = customerService.getById(orderInfo.getCustomer());
|
String date = new DateTime(orderInfo.getCreatedat()).toString("yyyyMMddHHmmss");
|
ReportEntity reportEntity = new ReportEntity();
|
reportEntity.setSjbs("YH");
|
reportEntity.setJylx("10");
|
reportEntity.setSjscsj(date);
|
reportEntity.setDwdm(enterprise.getDlcompanycode());
|
reportEntity.setCjsbid(enterprise.getDeviceid());
|
reportEntity.setZjlx("1");
|
reportEntity.setZjhm(customerInfo.getIdcardnum());
|
|
List<TmsEntity>tmsEntities = new ArrayList<>();
|
for (SaleOrderDetailInfo detailInfo : detailInfos){
|
TmsEntity tmsEntity = new TmsEntity(detailInfo.getDirectioncode(),date);
|
tmsEntities.add(tmsEntity);
|
}
|
reportEntity.setTms(tmsEntities);
|
String xml = BeanUtils.beanToXml(reportEntity,ReportEntity.class);
|
//String xml = "<?xml version=\"1.0\" encoding=\"UTF-8\"?><sb><sjbs>YH</sjbs><jylx>03</jylx><sjscsj>20160203221055</sjscsj><dwdm>ADW000000008422</dwdm><cjsbid>ADW000000008422652722194006466</cjsbid><zjlx>1</zjlx><zjhm>220283198201021916</zjhm><tms><bh>11230I4WY0F62203824</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203819</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203822</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203826</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203820</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203823</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203818</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203817</bh><sj>20160114195153</sj></tms><tms><bh>11230I4WY0F62203821</bh><sj>20160114195153</sj></tms></sb>";
|
BASE64Encoder encoder = new BASE64Encoder();
|
//String str = encoder.encode(sb.toString().trim().getBytes("utf-8"));
|
String str = encoder.encode(xml.getBytes("UTF-8"));
|
String cjsbid = enterprise.getDeviceid();//设备ID
|
String dwdm = enterprise.getDlcompanycode();//单位代码
|
String wsmm = result.getWsmm();//握手密码
|
call = (Call) service.createCall();
|
call.setTargetEndpointAddress(servicesUrl);
|
call.setTimeout(5 * 60 * 1000);// 超时设定5分钟抛出异常
|
call.setOperationName("lssjsb");// 调用方法
|
call.setReturnType(XMLType.XSD_STRING);// 指定返回类型
|
call.addParameter("str", org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);// 接口的参数
|
call.addParameter("sbid", org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);// 接口的参数
|
call.addParameter("dwdm", org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);// 接口的参数
|
call.addParameter("wsmm", org.apache.axis.encoding.XMLType.XSD_STRING,javax.xml.rpc.ParameterMode.IN);// 接口的参数
|
String callResult = (String) call.invoke(new Object[] { str,cjsbid, dwdm,wsmm });// 调用服务并返回存在的对应数据
|
BASE64Decoder decoder = new BASE64Decoder();
|
String xmlCode = null;
|
try {
|
xmlCode = new String(decoder.decodeBuffer(callResult));
|
DlReportResult reportResult = (DlReportResult) BeanUtils.xmlToBean(xmlCode,DlReportResult.class);
|
DateTimeFormatter dateTimeFormatter = DateTimeFormat.forPattern("yyyyMMddHHmmss");
|
DateTime dateTime = dateTimeFormatter.parseDateTime(reportResult.getSjscsj());
|
Date uploadAt = dateTime.toDate();
|
orderInfo.setIsupload((byte)1);
|
orderInfo.setUploadat(uploadAt);
|
orderInfo.setReturncode(reportResult.getFhlx());
|
} catch (IOException e1) {
|
e1.printStackTrace();
|
orderInfo.setReturncode("999");
|
orderInfo.setIsupload((byte)2);
|
}
|
} catch (Exception e) {
|
System.out.println("调用webservice失败！" + e.getMessage());
|
orderInfo.setReturncode("998");
|
orderInfo.setIsupload((byte)2);
|
}
|
saleOrderService.updateById(orderInfo);
|
}
|
|
|
}
|
}
|
|
class DlResult{
|
private String wsmm;
|
private String fwdz;
|
|
DlResult() {
|
}
|
|
public DlResult(String wsmm, String fwdz) {
|
this.wsmm = wsmm;
|
this.fwdz = fwdz;
|
}
|
|
public String getWsmm() {
|
return wsmm;
|
}
|
|
public void setWsmm(String wsmm) {
|
this.wsmm = wsmm;
|
}
|
|
public String getFwdz() {
|
return fwdz;
|
}
|
|
public void setFwdz(String fwdz) {
|
this.fwdz = fwdz;
|
}
|
|
}
|
|
@XmlRootElement(name="fh")
|
class ReportEntity{
|
private String sjbs;
|
private String jylx;
|
private String sjscsj;
|
private String dwdm;
|
private String cjsbid;
|
private String zjlx;
|
private String zjhm;
|
private List<TmsEntity> tms;
|
|
public String getSjbs() {
|
return sjbs;
|
}
|
|
public void setSjbs(String sjbs) {
|
this.sjbs = sjbs;
|
}
|
|
public String getJylx() {
|
return jylx;
|
}
|
|
public void setJylx(String jylx) {
|
this.jylx = jylx;
|
}
|
|
public String getSjscsj() {
|
return sjscsj;
|
}
|
|
public void setSjscsj(String sjscsj) {
|
this.sjscsj = sjscsj;
|
}
|
|
public String getDwdm() {
|
return dwdm;
|
}
|
|
public void setDwdm(String dwdm) {
|
this.dwdm = dwdm;
|
}
|
|
public String getCjsbid() {
|
return cjsbid;
|
}
|
|
public void setCjsbid(String cjsbid) {
|
this.cjsbid = cjsbid;
|
}
|
|
public String getZjlx() {
|
return zjlx;
|
}
|
|
public void setZjlx(String zjlx) {
|
this.zjlx = zjlx;
|
}
|
|
public String getZjhm() {
|
return zjhm;
|
}
|
|
public void setZjhm(String zjhm) {
|
this.zjhm = zjhm;
|
}
|
|
@XmlElement(name="tms")
|
public List<TmsEntity> getTms() {
|
return tms;
|
}
|
|
public void setTms(List<TmsEntity> tms) {
|
this.tms = tms;
|
}
|
}
|
|
@XmlRootElement(name="tms")
|
class TmsEntity{
|
private String bh;
|
|
private String sj;
|
|
public String getBh() {
|
return bh;
|
}
|
|
public void setBh(String bh) {
|
this.bh = bh;
|
}
|
|
public TmsEntity() {
|
}
|
|
public TmsEntity(String bh, String sj) {
|
this.bh = bh;
|
this.sj = sj;
|
}
|
|
public String getSj() {
|
return sj;
|
}
|
|
public void setSj(String sj) {
|
this.sj = sj;
|
}
|
}
|
|
@XmlRootElement(name="fh")
|
class DlReportResult{
|
private String sjbs;
|
|
private String cjsbid;
|
|
private String sjscsj;
|
|
private String fhlx;
|
|
private String fhsj;
|
|
public String getSjbs() {
|
return sjbs;
|
}
|
|
public void setSjbs(String sjbs) {
|
this.sjbs = sjbs;
|
}
|
|
public String getCjsbid() {
|
return cjsbid;
|
}
|
|
public void setCjsbid(String cjsbid) {
|
this.cjsbid = cjsbid;
|
}
|
|
public String getSjscsj() {
|
return sjscsj;
|
}
|
|
public void setSjscsj(String sjscsj) {
|
this.sjscsj = sjscsj;
|
}
|
|
public String getFhlx() {
|
return fhlx;
|
}
|
|
public void setFhlx(String fhlx) {
|
this.fhlx = fhlx;
|
}
|
|
public String getFhsj() {
|
return fhsj;
|
}
|
|
public void setFhsj(String fhsj) {
|
this.fhsj = fhsj;
|
}
|
}
|
