|
|
@@ -1,19 +1,27 @@
|
|
|
package com.uas.erp.schedular.diymall.task;
|
|
|
|
|
|
-import com.uas.erp.schedular.diymall.domain.DiymallOrder;
|
|
|
-import com.uas.erp.schedular.diymall.domain.DiymallOrderItem;
|
|
|
+import com.sun.deploy.net.URLEncoder;
|
|
|
+import com.uas.erp.schedular.b2b.domain.Customer;
|
|
|
+import com.uas.erp.schedular.diymall.domain.*;
|
|
|
+import com.uas.erp.schedular.finance.mq.HttpsClientRequestFactory;
|
|
|
+import com.uas.erp.schedular.publicproduct.domain.Prod;
|
|
|
import com.uas.erp.schedular.task.support.Method;
|
|
|
import com.uas.erp.schedular.task.support.Role;
|
|
|
import com.uas.erp.schedular.task.support.TaskMapping;
|
|
|
import com.uas.erp.schedular.util.CollectionUtil;
|
|
|
import com.uas.erp.schedular.util.ContextHolder;
|
|
|
+import com.usoft.security.utils.OpenApiSignUtil;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
+import org.springframework.util.ObjectUtils;
|
|
|
import org.springframework.util.StringUtils;
|
|
|
+import org.springframework.web.client.RestTemplate;
|
|
|
+import org.springframework.web.util.DefaultUriTemplateHandler;
|
|
|
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.List;
|
|
|
-import java.util.Set;
|
|
|
+import java.io.UnsupportedEncodingException;
|
|
|
+import java.security.InvalidKeyException;
|
|
|
+import java.security.NoSuchAlgorithmException;
|
|
|
+import java.util.*;
|
|
|
|
|
|
/**
|
|
|
* Created by huangct on 2017/12/26.
|
|
|
@@ -117,4 +125,134 @@ public class DiymallApplyTask extends AbstractTask {
|
|
|
});
|
|
|
post("/erp/loan/back", dataWrap(idStr));
|
|
|
}
|
|
|
+
|
|
|
+ private final static String SECRETKEY = "c910666dcf0f4ff8a0398aa68adc5bf3";
|
|
|
+ private final static String SECRETUU = "10044423";
|
|
|
+ private final static String BASEPATH = "https://dev.uuzcc.cn/malltraderest";
|
|
|
+ /**
|
|
|
+ * 客户在商城店铺对怡海能达下订单,订单信息直接同步至怡海能达系统
|
|
|
+ */
|
|
|
+ @TaskMapping(title = "订单同步", cron = "0 0 3 * * ?")
|
|
|
+ public void getOrdersByPage() throws NoSuchAlgorithmException, InvalidKeyException, UnsupportedEncodingException {
|
|
|
+
|
|
|
+ String url = BASEPATH + "/openapi/trade/order/page/get?";
|
|
|
+ String materialCod = ""; // 物料编号
|
|
|
+ Long updateTime = new Date().getTime()-24*60*60*1000; // 数据修改时间 时间戳
|
|
|
+ Integer pageSize = 10; // 每页条数
|
|
|
+ Integer pageNumber = 1; // 当前页码
|
|
|
+
|
|
|
+ if(materialCod != ""){
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查询出数据总条数
|
|
|
+ Integer totalCount = gstOrderList(url,materialCod,updateTime,pageSize,pageNumber).getPagingInfo().getTotalCount();
|
|
|
+
|
|
|
+ // 按页数拿数据
|
|
|
+ GetOrdersByPage getOrdersByPage = null;
|
|
|
+ List<Order> orders = null;
|
|
|
+ tag:
|
|
|
+ for(int i = 1 ; i < totalCount/pageSize ; i ++ ){
|
|
|
+ getOrdersByPage = gstOrderList(url,materialCod,updateTime,pageSize,i);
|
|
|
+ orders = getOrdersByPage.getOrder();
|
|
|
+
|
|
|
+ if(StringUtils.isEmpty(orders)) {
|
|
|
+
|
|
|
+ continue ;
|
|
|
+ }
|
|
|
+
|
|
|
+ for(int j = 0 ; j < orders.size() ; j ++){
|
|
|
+
|
|
|
+ Order order = orders.get(j);
|
|
|
+ order.getEnuu();
|
|
|
+
|
|
|
+ //customer cu_uu cu_name
|
|
|
+ Customer customer = jdbcTemplate.queryForBean("select * from CUSTOMER where CU_UU = ? and CU_AUDITSTATUS = '已审核'",
|
|
|
+ Customer.class, order.getEnuu());
|
|
|
+
|
|
|
+ // 取销售id 和销售编号
|
|
|
+ int saleId = jdbcTemplate.getInt("select sale_seq.nextval from sale");
|
|
|
+ String code = jdbcTemplate.generateCode("sale",2);
|
|
|
+
|
|
|
+ Map<String, Object> payment = jdbcTemplate.queryForMap("select pa_code,pa_name from customer left join payments on CU_PAYMENTID = pa_id where cu_code = 'C18060102'");
|
|
|
+
|
|
|
+ String sql = "insert into SALE (SA_ID , SA_CODE , SA_DATE , SA_ORDERTYPE , SA_CURRENCY , SA_RATE , SA_CUSTCODE , SA_CUSTNAME , SA_APCUSTCODE , SA_APCUSTNAME ," +
|
|
|
+ "SA_PAYMENTSCODE , SA_PAYMENTS , SA_SELLER , SA_DEPARTMENTCODE , SA_DEPARTMENTNAME , SA_TOPLACE , SA_POCODE , SA_SENDSTATUS , SA_EMNAME , SA_RECORDDATE ," +
|
|
|
+ "SA_AUDITMAN , SA_AUDITDATE , SA_UPDATEMAN , SA_UPDATEDATE , sa_need1 , sa_need2) values ('" + saleId + "','"+ code + "',sysdate,'" + "商城订单" + "','RMB','1','" + customer.getCu_code() + "','" + customer.getCu_name() + "','" + "C18060102" + "','" + "深圳优软商城科技有限公司" + "','" + payment.get("PA_CODE") + "','" + payment.get("PA_NAME") +
|
|
|
+ "','" + "周连军" + "','" + "1202" + "','" + "研发二部" + "','" + order.getOrderDeliveryAddr() + "','" + order.getCode() + "','已审核','ADMIN',sysdate,'ADMIN',sysdate,'ADMIN',sysdate,'" + order.getBuyerName() + "','" + order.getBuyerMobile() + "')";
|
|
|
+
|
|
|
+ LoggingOrder loggingOrder = new LoggingOrder();
|
|
|
+
|
|
|
+ List<OrderProduct> orderProductList = order.getOrderProduct();
|
|
|
+ List<String> detailList = new ArrayList<>();
|
|
|
+ for(int n = 0, len = orderProductList.size() ; n < len ; n ++){
|
|
|
+ OrderProduct orderProduct = orderProductList.get(n);
|
|
|
+
|
|
|
+ String productSql = "select * from prodcut where pr_code = '" + orderProduct.getCode() + "'";
|
|
|
+ Prod product = jdbcTemplate.queryForBean(productSql, Prod.class);
|
|
|
+ if (!ObjectUtils.isEmpty(product)) {
|
|
|
+ String DetailSql = "Insert into saleDetail( sd_id , sd_said , SD_PRODID , SD_PRODCODE , SD_QTY , SD_PRICE , SD_TAXRATE , SD_DELIVERY) " +
|
|
|
+ "values(saleDetail_seq.nextval, " + saleId + ", " + product.getPr_id() + ", " + product.getPr_code() + ", " + orderProduct.getAmount() +", " + orderProduct.getUnitPrice() +", " + "13%" +", " + "sysdate" + orderProduct.getMaxDelivery() + ")";
|
|
|
+ detailList.add(DetailSql);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ String logOrderSql = "Insert into LOGORDER( ORDERCODE , STATUS , SALESTIME , ORDERNUMBER , REMARK)" +
|
|
|
+ "values(" + ", " + order.getCode() + ", " + loggingOrder.getStatus() + ", " + ",sysdate," + loggingOrder.getOrderNumber() + ", " + loggingOrder.getRemark() + ")";
|
|
|
+
|
|
|
+ boolean exists=!StringUtils.isEmpty(customer);
|
|
|
+
|
|
|
+ if(!exists){
|
|
|
+ Customer customerName = jdbcTemplate.queryForBean("select * from CUSTOMER where CU_NAME = ? and CU_AUDITSTATUS = '已审核'",
|
|
|
+ Customer.class, order.getBuyerEnName());
|
|
|
+ if(!StringUtils.isEmpty(customerName)){
|
|
|
+ exists=true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if(exists){
|
|
|
+ jdbcTemplate.execute(sql);
|
|
|
+ jdbcTemplate.batchExecute(detailList);
|
|
|
+
|
|
|
+ loggingOrder.setStatus("成功");
|
|
|
+ loggingOrder.setOrderNumber(code);
|
|
|
+ loggingOrder.setRemark("销售订单生成成功");
|
|
|
+ jdbcTemplate.execute(logOrderSql);
|
|
|
+ break tag;
|
|
|
+ }else {
|
|
|
+ loggingOrder.setStatus("失败");
|
|
|
+ loggingOrder.setOrderNumber("");
|
|
|
+ loggingOrder.setRemark("客户资料不存在或者状态不等于已审核");
|
|
|
+ jdbcTemplate.execute(logOrderSql);
|
|
|
+ break tag;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ private GetOrdersByPage gstOrderList(String requestURL, String materialCode, Long updateTime, Integer pageSize, Integer pageNumber) throws NoSuchAlgorithmException, InvalidKeyException, UnsupportedEncodingException {
|
|
|
+ String paramStr = "secretId=" + SECRETUU + "&"+ "materialCode=" + materialCode + "&" + "updateTime=" + updateTime + "&" + "pageSize=" + pageSize +"&" + "pageNumber=" + pageNumber;
|
|
|
+ //进行签名
|
|
|
+ String signatureValue = OpenApiSignUtil.sign(paramStr,SECRETKEY);
|
|
|
+ signatureValue = URLEncoder.encode(signatureValue, "UTF-8");
|
|
|
+ String signatureKV = OpenApiSignUtil.SIGNATURE_KEY + "=" + signatureValue;
|
|
|
+ paramStr += "&" + signatureKV;
|
|
|
+ requestURL = requestURL + paramStr;
|
|
|
+
|
|
|
+ DefaultUriTemplateHandler uriTemplateHandler = new DefaultUriTemplateHandler();
|
|
|
+ uriTemplateHandler.setStrictEncoding(true);
|
|
|
+
|
|
|
+ RestTemplate restTemp = new RestTemplate(new HttpsClientRequestFactory());
|
|
|
+ restTemp.setUriTemplateHandler(uriTemplateHandler);
|
|
|
+ GetOrdersByPage result = restTemp.getForObject(requestURL, GetOrdersByPage.class);
|
|
|
+ //String result1 = restTemp.getForObject(requestURL, String.class);
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
}
|