diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 91aa7e644..ceb491ffe 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -4,7 +4,8 @@ import ( "bytes" "context" "fmt" - "git.rosy.net.cn/baseapi/platformapi/jdshopapi" + "net" + "os" "regexp" "strings" "time" @@ -1944,25 +1945,44 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { //{"address":"成都市金牛区抚琴综合市场博力多超市旁边扶手楼梯上","cityName": "成都市","id": 100002,"name": "抚琴店-下单送盐","payeeName": "李川川","status": 1,"tel1": "13812641804","tel2": ""} //` //weixinmsg.SmartMessageTemplateSend("oYN_usv1RPvrSxCvo1WsbwI8lZa0", weixinmsg.WX_NEWORDER_TEMPLATE_ID, "", weixinmsg.WX_MINI_TO_ORDER_PAGE_URL+fmt.Sprintf("?jxStoreId=%v&data=%v", storeID, data), nil) - apiobj := jdshopapi.New("9ad9cf5fc8b140b19a1dbbb700b47676kown", "D5E8352BE0786ED16F77B4548F62F09A", "71e1061ac2f246f6ac27efb900edba12") - apiobj.SetCookieWithStr(` -__jdu=16193999982702078345144; shshshfpa=972f47df-9252-dc1a-1d6d-40594ce0501b-1619400562; webp=1; visitkey=44137284214309276; shshshfp=4d574741223da61a369c18ce2febefe8; shshshfpb=msX4%202n384blCOGusOxGDvQ%3D%3D; unpl=V2_ZzNtbRUHSx19DENcKBtUBWIHEF4RU0MddVwVXCwYDAVkBRVVclRCFnUUR1NnGFQUZwcZXUZcQBFFCEdkeB5fA2AFEFlBZxBFLV0CFi9JH1c%2bbRFdS1NBFH0JRFB6Hmw1ZAMiXUNnQxJ1AERccxFUDGQFE15DUUoXcAxGUX4pbAJXMyJbQFdHE3I4R2R6KR5ROwQXW0RUQVh1D0ZceRFUDW8KEVtDVEITfApDUHscWTVmMxE%3d; __jdv=122270672|baidu-search|t_262767352_baidusearch|cpc|218530903506_0_fa999549b3914532b5191eb9f0a12769|1623222888351; language=zh_CN; csrf_token=ec042bf0-a91b-43c8-a814-826a1c4272c0; wlfstk_smdl=oyivhfpk5e48pbcg0x4ntgoucg83flf4; TrackID=1PpB7nDH0GvHsG8yyfdpnyWOnRYjxio_6Sb9R4DOIfOITwDV6Qzm2AzaWNl12iy4Rcv4OPdaZz6AIBUPOKGSCzZGzc14os7bnKdFv1toeyyo; thor=E6F66DF4AD3A159C1AE9872C7BB0CF4D5E2B8B9C52714A91A28E40CDCDB5FE53E5A70BFEAE6D31233A6A81AE5374CCBC7A6FFCD510DD2A410A450DA70B629E589891DEF251C4E5937763B9560B45AAC01B06702BB6AF0EFCE718417DF1965AF091E9FEED778E89BE7D8B35913844851698F9F28BF3F055B563E6C71A92C9D0C0CA06E44ABDC59ABF07F627B57A4D26AF609D26C23B77DC52E123264DB3D75778; pinId=qA40zQJfoxUJ0BznFrVelbV9-x-f3wj7; pin=jd_5e10f2d70fb4c; unick=jd_181600jgy; ceshi3.com=201; _tp=tPAwCz7dZ2wG9FcrXkvXEPcH%2FgU%2BK8r%2FxTPrJfx1wo8%3D; _pst=jd_5e10f2d70fb4c; _base_=YKH2KDFHMOZBLCUV7NSRBWQUJPBI7JIMU5R3EFJ5UDHJ5LCU7R2NILKK5UJ6GLA2RGYT464UKXAI5KK7PNC5B5UHJ2HVQ4ENFP57OC2NCIWTST4KDNCWZES6EV2TD5XDTCNE6YVKRXISVWNQHZDBO6QEKYXMXGPYGVEOCQCSG4SOQWCP5WPWO6EFS7HEHMRWVKBRVHB33TFD4AUHV3TOJD7MGBX53BNNP2E6MSSOORYGL5H2GYFRURR5ACFJ54GH7PTHFL22YL3C6ODFYFTWGV5UAWCX5C6J372TDCL6LDNEERERTGCUFQRPJPTFLQYXSNPUKPGJPJAJ3VQAQIWW3S2YBGSPJZVO3XPNMOJI6RFTJD5NXZUZMBDK4FVEVR2D; _vender_new_=GI63BGTJFDBQ4KTM333PMOGFGWX4LCRFBIKRUXSZIMQR2CGA7UT6QS3UEGOG3AKYDYGEWBDNK3CSWSNHPSPAMTCGLEQDVNM2LSUTLX2WZTSR5DRPDW7BAWFO3PG4STZEJAOUXLDT2T3C5NVIUAUPD2U4MRQMIY4EBHC2ZCUHI2DYIR7IPWFPH4NRSF55Y2TLDCL5FPL62OR6GGSGHUAIVHXQY756M4VPLLBPMLZYMXAWOY2XWQCXI6RB3XVDWHR6HDOD2SNRC5NX4DRRYOYE7UGG7BABNQEEPCBQTSQOAL4YL62WZATBEQTCPO7SYGSIS655JUGOUILFLXVZE6KCFG7ZTOQUVBLFYXBD66CRKS6VHV72EFJ73OOOFEPN3IJYUFFIKZOFYI7XQUKUXVJ5P6RBKMT2HE65DLUI22O6QKUCCZAY7XTGOTMC53TFUYERGNIH2RBULZ7UTZH5GU3TC6RWFI2QL4QTAIARA6GNVXENEOYIPZEHN222YDAJX5OBBEECAMAPNKZ3XL3SMPZDFFIQY2ZLOCAKLFPCYTJIXW5JXUDR6HR5QTERLDBVKLQE6FXEXLO4Z2MJ7SQW32AXQCKXK6QX5GP7FEOWREOUFJ4PU5XZPDXM62SHEAUIPF33J2F76Z2L4GSPJATDWVYI5C3Y54; AESKEY=248110CB26061826; QRCodeKEY=A8501C3FD5CD679C9C7D63B309D8D2FDED5E44703E70D785D0627044F06D7877EBB6CF72E6BE7DDA170B889D756F81B0; UIDKEY=98771548919883507; _BELONG_CLIENT_=WPSC4XJXWK5USS4JNZY2X7VRLR5MCBKRSVHEXABGTHDGISIQK5YOLZUXYE7IOIM7MOKO74H6CRN6WHAAR4TMDV3XZWMXZRCRT5XRNE3V356BTOB2Y7LPK66VWQK6HPTGWVXIDXDCPVE3W5WMHAIO6AT2LX2XXVNUCXR34ZWFK6HY45CORGIKOSYDYZBF27WOKTUX6BS4FZMIJWNUX6CB4JAA25ZLF7ZEKYOO4QV5HTSBXGNRM3E242MBI6V5D4C5VJDQ3EOYCOW5BMTUJZACIBHXQFAVLRF76VQY5PNJGGJNBEZHSFYYJA3YORRT7FB5AHCOIFQKF3W5RWNUX6CB4JAA26JNMO7AYWNUPZF5HTSBXGNRM3E242MBI6V5D4C5VJDQ3EOYCOW5BWZDKMOJ5BS6II53ERY6ALV3ZWPF42L4CPUHEGPYIII35KDC4FCNVCORCXFD6IVNLBEDPB2GGP4UHWNRUDOQBDIW7RZJXBA2WV5ANZOTEGUCDWYRVQS2YUTIZNZ276PRYG4N56V6YTII7MBKBC7LYHO7C555HTSBXGNRM3E466AYN67DHWVM5HQFJ4NFDO5BTUIU4VMZUEOGM4TXPS4CQVB3CAA; _vender_=TNK3O6PALVQGHZYSSOH7L4PZFUJZD5EGDHEKASUPSRGCBG35OWV7FH6M2DZVEM4VQIKK67XHM3QRQKOLBUAWJMFWJSXXHFGGRIGTHQ6KVOF3DXDVMS5KAV2WMFSCLQKS44AIXTUDOHJ5HAHXVAO5IYCMSVW2AR2ELYDWYXCOEDAM3KGKCC5XRMZNVD5KUU5CBJU6NP7WOAPPTYGXF6PEVUXKO74BCY77252VZBHAW5H7TA7PK4EJVL2N2DWNOIJVHZNX4BZQ7W244ZAYLAW7T2BAXU3PUXOFDWMSSK6EVOSLOGBZC5PIZVNDVDNJXP4G2S23NQFGX3NFYERPAKAKHS3GO6DKGR3KYMAGT5B6LN7AOMH5WXHCJZAENA6SMDSKCIYM3B25NWIYPAC4U3MBP2BDLIX6J6LYQ77R7LC2BHTT2LLD2OP4PFOB4CD3PMLLXPPMWIO2JJAVEEMLPVZZVEIWOFYZJJKXK2CUIHRGHCEFZSYYGZNEN73JJFNNORES; b-sec=2GBADPFJ55VHNAQ2DUPKR7Y2CEX6NF5ABOAAZC76RT6BMTFU655T23CCCVWHAOO3DFOOI3IR4ARJBD6NRWBX675VTE; __jda=48732324.16193999982702078345144.1619399998.1624272684.1624324139.12; __jdc=48732324; JSESSIONID=B4AD8AAA993FA4FBBD38B108E9FF713D.s1; __jdb=48732324.35.16193999982702078345144|12.1624324139; 3AB9D23F7A4B3C9B=CKENC5MAUU744ZQDKVRY2L7UIJ23PJRDYJ6HF3ZMQHC5FFD46FMUQXRINFCOC4SKHL5MU3PPNPP4C4AX5ZYBXJ7LZ4 -`) - var CreateShopCategoryParams = []*jdshopapi.CreateShopCategoryParam{ - &jdshopapi.CreateShopCategoryParam{ - HomeShow: "0", - ID: "1", - Open: "", - OrderNo: "0", - ParentID: "", - Title: "测试1", - Type: "3", - }, + + server := "print.jxcs.net:8000" + tcpAddr, err := net.ResolveTCPAddr("tcp4", server) + if err != nil { + fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) + os.Exit(1) } - apiobj.CreateShopCategory(CreateShopCategoryParams) + fmt.Println("tcpaddr", utils.Format4Output(tcpAddr, true)) + conn, err := net.DialTCP("tcp", nil, tcpAddr) + if err != nil { + fmt.Println("Dial err:", err) + return + } + textChan = make(chan string, 10) + textChan <- "test" + connHandler(conn) return err } +var ( + textChan chan string +) + +func connHandler(c net.Conn) { + fmt.Println("Please input data...") + go func() { + for { + s := <-textChan + //写入数据 + n, err := c.Write([]byte(s)) + if err != nil { + fmt.Println("Write err:", err, n) + return + } + } + }() +} + func FreeBatchInfo2(name string, handler func(tasksch.ITask, []*jdapi.SkuIdEntity) (interface{}, int, error), ctx *jxcontext.Context, parentTask tasksch.ITask, storeSkuList []*jdapi.SkuIdEntity, batchSize int, isContinueWhenError bool) (resultList []interface{}, err error) { task := tasksch.NewParallelTask2(fmt.Sprintf("FreeBatchInfo:%s", name), tasksch.NewParallelConfig().SetParallelCount(1).SetBatchSize(batchSize).SetIsContinueWhenError(isContinueWhenError), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, successCount int, err error) {