对账单

防漏单

下载对账单

https://pay.weixin.qq.com/index.php/settle/state_account

对账单 - 图1

对账

  1. var csv = require('csv');
  2. var import_csv = require('import-csv');
  3. var parse = csv.parse;
  4. var fs = require('fs');
  5. var Promise = require('bluebird');
  6. var iconv = require('iconv-lite');
  7. var Order = require('../app/models/order');
  8. var Activity = require('../app/models/activity');
  9. var Wechat = require('../app/models/wechat');
  10. var Contact = require('../app/models/contact');
  11. var DELIVERY = require('../config/delivery_company');
  12. require("../db");
  14. var import_csv = require('import-csv')
  16. var array = [];
  18. import_csv('./1229.csv',function(err, data){
  19.    array.push(data);
  20.    array[0].shift();
  21.    Promise.all(array).then(_for);
  22. }, 'utf-8')
  24. function _for () {
  25.   if(array[0].length > 0) {
  26.     var data = array[0].shift();
  27.     var pay_num = data[0].split('#')[0];
  28.     var type = data[24];
  29.     var deliver_number = data[2].split('`')[0];
  30.     var _company = data[1];
  31.     var company;
  32.     if (_company.indexOf('圆通速递') !=-1){
  33.       company = DELIVERY.Y_T_S_D;
  34.     }if (_company.indexOf('百世汇通') !=-1){
  35.       company = DELIVERY.B_S_H_T;
  36.     }
  37.     if(pay_num&&type&&deliver_number){
  38.       var obj = {
  39.         pay_num : pay_num,
  40.         type : type ,
  41.         deliver_number : deliver_number,
  42.         company : company
  43.       }
  44.       Promise.resolve(obj).then(function (obj) {
  45.         find_order(obj);
  46.       });
  47.     }
  48.   }
  49. }
  51. function find_order (obj) {
  52.   console.log(obj.pay_num + obj.type + obj.deliver_number + 'zzzzzzzzzzzzs');
  53.   Order.oneAsync({pay_num : obj.pay_num}
  54.   ).then(function (order) {
  55.     var d_num = order.delivery_num;
  56.     console.log(d_num + 'dddddddddddddd');
  57.     if (d_num) {
  58.       if (d_num.indexOf(obj.deliver_number) != -1) {
  59.         var d = obj.type + ':' + obj.deliver_number + ';';
  60.         console.log("这个单已经有了，不处理       " + d_num);
  61.       }else {
  62.         var d = d_num + obj.type + ':' + obj.deliver_number + ';';
  63.         console.log("这个单还没有，拼接插入" + d);
  64.         update_order(obj.pay_num, d, obj.company)
  65.       }
  66.     }else{
  67.       console.log("运单号是空的，直接插入");
  68.       var d = obj.type + ':' + obj.deliver_number + ';';
  69.       update_order(obj.pay_num, d, obj.company)
  70.     }
  71.   }).then(function () {
  72.     _for();
  73.   });
  74. }
  76. function update_order (pay_num, d, company) {
  77.   console.log(company);
  78.   return Order.updateAsync({pay_num : pay_num}, {status : "1", delivery_num : d, delivery_company : company}, function (err, result) {
  79.     console.log('-ok=' +result.ok + '-nModified=' +result.nModified  + '- n=' +result.n + '原有单号+拼接');
  80.   })
  81. }